Chilkat HOME .NET Core C# Android™ AutoIt C C# C++ Chilkat2-Python CkPython Classic ASP DataFlex Delphi ActiveX Delphi DLL Go Java Lianja Mono C# Node.js Objective-C PHP ActiveX PHP Extension Perl PowerBuilder PowerShell PureBasic Ruby SQL Server Swift 2 Swift 3,4,5... Tcl Unicode C Unicode C++ VB.NET VBScript Visual Basic 6.0 Visual FoxPro Xojo Plugin
(Unicode C) Twitter OAuth1 Authorization (3-legged)Demonstrates 3-legged OAuth1 authorization for Twitter.
#include <C_CkHttpW.h> #include <C_CkHttpRequestW.h> #include <C_CkHttpResponseW.h> #include <C_CkHashtableW.h> #include <C_CkStringBuilderW.h> #include <C_CkSocketW.h> #include <C_CkTaskW.h> #include <C_CkJsonObjectW.h> #include <C_CkFileAccessW.h> void ChilkatSample(void) { const wchar_t *consumerKey; const wchar_t *consumerSecret; const wchar_t *requestTokenUrl; const wchar_t *authorizeUrl; const wchar_t *accessTokenUrl; const wchar_t *callbackUrl; int callbackLocalPort; HCkHttpW http; BOOL success; HCkHttpRequestW req; HCkHttpResponseW resp; HCkHashtableW hashTab; const wchar_t *requestToken; const wchar_t *requestTokenSecret; HCkStringBuilderW sbUrlForBrowser; const wchar_t *url; HCkSocketW listenSock; int backLog; int maxWaitMs; HCkTaskW task; HCkSocketW sock; const wchar_t *startLine; const wchar_t *requestHeader; HCkStringBuilderW sbResponseHtml; HCkStringBuilderW sbResponse; HCkStringBuilderW sbStartLine; int numReplacements; const wchar_t *authVerifier; const wchar_t *accessToken; const wchar_t *accessTokenSecret; const wchar_t *userId; const wchar_t *screenName; HCkJsonObjectW json; HCkFileAccessW fac; consumerKey = L"TWITTER_CONSUMER_KEY"; consumerSecret = L"TWITTER_CONSUMER_SECRET"; requestTokenUrl = L"https://api.twitter.com/oauth/request_token"; authorizeUrl = L"https://api.twitter.com/oauth/authorize"; accessTokenUrl = L"https://api.twitter.com/oauth/access_token"; // The port number is picked at random. It's some unused port that won't likely conflict with anything else.. callbackUrl = L"http://localhost:3017/"; callbackLocalPort = 3017; // The 1st step in 3-legged OAuth1.0a is to send a POST to the request token URL to obtain an OAuth Request Token http = CkHttpW_Create(); CkHttpW_putOAuth1(http,TRUE); CkHttpW_putOAuthConsumerKey(http,consumerKey); CkHttpW_putOAuthConsumerSecret(http,consumerSecret); req = CkHttpRequestW_Create(); CkHttpRequestW_AddParam(req,L"oauth_callback",callbackUrl); resp = CkHttpW_PostUrlEncoded(http,requestTokenUrl,req); if (CkHttpW_getLastMethodSuccess(http) != TRUE) { wprintf(L"%s\n",CkHttpW_lastErrorText(http)); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); return; } // If successful, the resp.BodyStr contains something like this: // oauth_token=-Wa_KwAAAAAAxfEPAAABV8Qar4Q&oauth_token_secret=OfHY4tZBX2HK4f7yIw76WYdvnl99MVGB&oauth_callback_confirmed=true wprintf(L"%s\n",CkHttpResponseW_bodyStr(resp)); if (CkHttpResponseW_getStatusCode(resp) != 200) { wprintf(L"Failed response status code: %d\n",CkHttpResponseW_getStatusCode(resp)); CkHttpResponseW_Dispose(resp); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); return; } hashTab = CkHashtableW_Create(); CkHashtableW_AddQueryParams(hashTab,CkHttpResponseW_bodyStr(resp)); requestToken = CkHashtableW_lookupStr(hashTab,L"oauth_token"); requestTokenSecret = CkHashtableW_lookupStr(hashTab,L"oauth_token_secret"); CkHttpW_putOAuthTokenSecret(http,requestTokenSecret); CkHttpResponseW_Dispose(resp); wprintf(L"oauth_token = %s\n",requestToken); wprintf(L"oauth_token_secret = %s\n",requestTokenSecret); // --------------------------------------------------------------------------- // The next step is to form a URL to send to the authorizeUrl // This is an HTTP GET that we load into a popup browser. sbUrlForBrowser = CkStringBuilderW_Create(); CkStringBuilderW_Append(sbUrlForBrowser,authorizeUrl); CkStringBuilderW_Append(sbUrlForBrowser,L"?oauth_token="); CkStringBuilderW_Append(sbUrlForBrowser,requestToken); url = CkStringBuilderW_getAsString(sbUrlForBrowser); // At this point, your application should load the URL in a browser. // For example, // in C#: System.Diagnostics.Process.Start(url); // in Java: Desktop.getDesktop().browse(new URI(url)); // in VBScript: Set wsh=WScript.CreateObject("WScript.Shell") // wsh.Run url // in Xojo: ShowURL(url) (see http://docs.xojo.com/index.php/ShowURL) // in Dataflex: Runprogram Background "c:\Program Files\Internet Explorer\iexplore.exe" sUrl // The Microsoft account owner would interactively accept or deny the authorization request. // Add the code to load the url in a web browser here... // Add the code to load the url in a web browser here... // Add the code to load the url in a web browser here... // When the url is loaded into a browser, the response from Twitter will redirect back to localhost:3017 // We'll need to start a socket that is listening on port 3017 for the callback from the browser. listenSock = CkSocketW_Create(); backLog = 5; success = CkSocketW_BindAndListen(listenSock,callbackLocalPort,backLog); if (success != TRUE) { wprintf(L"%s\n",CkSocketW_lastErrorText(listenSock)); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); return; } // Wait for the browser's connection in a background thread. // (We'll send load the URL into the browser following this..) // Wait a max of 60 seconds before giving up. maxWaitMs = 60000; task = CkSocketW_AcceptNextConnectionAsync(listenSock,maxWaitMs); CkTaskW_Run(task); // At this point, your application should load the URL in a browser. // For example, // in C#: System.Diagnostics.Process.Start(url); // in Java: Desktop.getDesktop().browse(new URI(url)); // in VBScript: Set wsh=WScript.CreateObject("WScript.Shell") // wsh.Run url // in Xojo: ShowURL(url) (see http://docs.xojo.com/index.php/ShowURL) // in Dataflex: Runprogram Background "c:\Program Files\Internet Explorer\iexplore.exe" sUrl // The Twitter account owner would interactively accept or deny the authorization request. // Add the code to load the url in a web browser here... // Add the code to load the url in a web browser here... // Add the code to load the url in a web browser here... // System.Diagnostics.Process.Start(url); // Wait for the listenSock's task to complete. success = CkTaskW_Wait(task,maxWaitMs); if (!success || (CkTaskW_getStatusInt(task) != 7) || (CkTaskW_getTaskSuccess(task) != TRUE)) { if (!success) { // The task.LastErrorText applies to the Wait method call. wprintf(L"%s\n",CkTaskW_lastErrorText(task)); } else { // The ResultErrorText applies to the underlying task method call (i.e. the AcceptNextConnection) wprintf(L"%s\n",CkTaskW_status(task)); wprintf(L"%s\n",CkTaskW_resultErrorText(task)); } CkTaskW_Dispose(task); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); return; } // If we get to this point, the connection from the browser arrived and was accepted. // We no longer need the listen socket... // Stop listening on port 3017. CkSocketW_Close(listenSock,10); // First get the connected socket. sock = CkSocketW_Create(); CkSocketW_LoadTaskResult(sock,task); CkTaskW_Dispose(task); // Read the start line of the request.. startLine = CkSocketW_receiveUntilMatch(sock,L"\r\n"); if (CkSocketW_getLastMethodSuccess(sock) != TRUE) { wprintf(L"%s\n",CkSocketW_lastErrorText(sock)); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); CkSocketW_Dispose(sock); return; } // Read the request header. requestHeader = CkSocketW_receiveUntilMatch(sock,L"\r\n\r\n"); if (CkSocketW_getLastMethodSuccess(sock) != TRUE) { wprintf(L"%s\n",CkSocketW_lastErrorText(sock)); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); CkSocketW_Dispose(sock); return; } // The browser SHOULD be sending us a GET request, and therefore there is no body to the request. // Once the request header is received, we have all of it. // We can now send our HTTP response. sbResponseHtml = CkStringBuilderW_Create(); CkStringBuilderW_Append(sbResponseHtml,L"<html><body><p>Chilkat thanks you!</b></body</html>"); sbResponse = CkStringBuilderW_Create(); CkStringBuilderW_Append(sbResponse,L"HTTP/1.1 200 OK\r\n"); CkStringBuilderW_Append(sbResponse,L"Content-Length: "); CkStringBuilderW_AppendInt(sbResponse,CkStringBuilderW_getLength(sbResponseHtml)); CkStringBuilderW_Append(sbResponse,L"\r\n"); CkStringBuilderW_Append(sbResponse,L"Content-Type: text/html\r\n"); CkStringBuilderW_Append(sbResponse,L"\r\n"); CkStringBuilderW_AppendSb(sbResponse,sbResponseHtml); CkSocketW_SendString(sock,CkStringBuilderW_getAsString(sbResponse)); CkSocketW_Close(sock,50); // The information we need is in the startLine. // For example, the startLine will look like this: // GET /?oauth_token=abcdRQAAZZAAxfBBAAABVabcd_k&oauth_verifier=9rdOq5abcdCe6cn8M3jabcdj3Eabcd HTTP/1.1 sbStartLine = CkStringBuilderW_Create(); CkStringBuilderW_Append(sbStartLine,startLine); numReplacements = CkStringBuilderW_Replace(sbStartLine,L"GET /?",L""); numReplacements = CkStringBuilderW_Replace(sbStartLine,L" HTTP/1.1",L""); CkStringBuilderW_Trim(sbStartLine); // oauth_token=abcdRQAAZZAAxfBBAAABVabcd_k&oauth_verifier=9rdOq5abcdCe6cn8M3jabcdj3Eabcd wprintf(L"startline: %s\n",CkStringBuilderW_getAsString(sbStartLine)); CkHashtableW_Clear(hashTab); CkHashtableW_AddQueryParams(hashTab,CkStringBuilderW_getAsString(sbStartLine)); requestToken = CkHashtableW_lookupStr(hashTab,L"oauth_token"); authVerifier = CkHashtableW_lookupStr(hashTab,L"oauth_verifier"); // ------------------------------------------------------------------------------ // Finally , we must exchange the OAuth Request Token for an OAuth Access Token. CkHttpW_putOAuthToken(http,requestToken); CkHttpW_putOAuthVerifier(http,authVerifier); // We don't need the "Authorization: OAuth ..." header for this POST. CkHttpW_putOAuth1(http,FALSE); CkHttpRequestW_RemoveParam(req,L"oauth_callback"); CkHttpRequestW_AddParam(req,L"oauth_verifier",authVerifier); CkHttpRequestW_AddParam(req,L"oauth_token",requestToken); resp = CkHttpW_PostUrlEncoded(http,accessTokenUrl,req); if (CkHttpW_getLastMethodSuccess(http) != TRUE) { wprintf(L"%s\n",CkHttpW_lastErrorText(http)); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); CkSocketW_Dispose(sock); CkStringBuilderW_Dispose(sbResponseHtml); CkStringBuilderW_Dispose(sbResponse); CkStringBuilderW_Dispose(sbStartLine); return; } // Make sure a successful response was received. if (CkHttpResponseW_getStatusCode(resp) != 200) { wprintf(L"%s\n",CkHttpResponseW_statusLine(resp)); wprintf(L"%s\n",CkHttpResponseW_header(resp)); wprintf(L"%s\n",CkHttpResponseW_bodyStr(resp)); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); CkSocketW_Dispose(sock); CkStringBuilderW_Dispose(sbResponseHtml); CkStringBuilderW_Dispose(sbResponse); CkStringBuilderW_Dispose(sbStartLine); return; } // If successful, the resp.BodyStr contains something like this: // oauth_token=85123455-fF41296Bi3daM8eCo9Y5vZabcdxXpRv864plYPOjr&oauth_token_secret=afiYJOgabcdSfGae7BDvJVVTwys8fUGpra5guZxbmFBZo&user_id=85612355&screen_name=chilkatsoft&x_auth_expires=0 wprintf(L"%s\n",CkHttpResponseW_bodyStr(resp)); CkHashtableW_Clear(hashTab); CkHashtableW_AddQueryParams(hashTab,CkHttpResponseW_bodyStr(resp)); accessToken = CkHashtableW_lookupStr(hashTab,L"oauth_token"); accessTokenSecret = CkHashtableW_lookupStr(hashTab,L"oauth_token_secret"); userId = CkHashtableW_lookupStr(hashTab,L"user_id"); screenName = CkHashtableW_lookupStr(hashTab,L"screen_name"); CkHttpResponseW_Dispose(resp); // The access token + secret is what should be saved and used for // subsequent REST API calls. wprintf(L"Access Token = %s\n",accessToken); wprintf(L"Access Token Secret = %s\n",accessTokenSecret); wprintf(L"user_id = %s\n",userId); wprintf(L"screen_name = %s\n",screenName); // Save this access token for future calls. // Just in case we need user_id and screen_name, save those also.. json = CkJsonObjectW_Create(); CkJsonObjectW_AppendString(json,L"oauth_token",accessToken); CkJsonObjectW_AppendString(json,L"oauth_token_secret",accessTokenSecret); CkJsonObjectW_AppendString(json,L"user_id",userId); CkJsonObjectW_AppendString(json,L"screen_name",screenName); fac = CkFileAccessW_Create(); CkFileAccessW_WriteEntireTextFile(fac,L"qa_data/tokens/twitter.json",CkJsonObjectW_emit(json),L"utf-8",FALSE); wprintf(L"Success.\n"); CkHttpW_Dispose(http); CkHttpRequestW_Dispose(req); CkHashtableW_Dispose(hashTab); CkStringBuilderW_Dispose(sbUrlForBrowser); CkSocketW_Dispose(listenSock); CkSocketW_Dispose(sock); CkStringBuilderW_Dispose(sbResponseHtml); CkStringBuilderW_Dispose(sbResponse); CkStringBuilderW_Dispose(sbStartLine); CkJsonObjectW_Dispose(json); CkFileAccessW_Dispose(fac); } |
© 2000-2024 Chilkat Software, Inc. All Rights Reserved.