Go
Go
Etsy OAuth1 Authorization
See more Etsy Examples
Demonstrates 3-legged OAuth1 authorization for Etsy.Chilkat Go Downloads
success := false
consumerKey := "keystring"
consumerSecret := "shared_secret"
// Specify one or more SPACE separated scopes as query params in the requestTokenUrl
// See https://www.etsy.com/developers/documentation/getting_started/oauth#section_permission_scopes
requestTokenUrl := "https://openapi.etsy.com/v2/oauth/request_token?scope=email_r%20listings_r%20listings_w%20listings_d"
authorizeUrl := "https://www.etsy.com/oauth/signin"
accessTokenUrl := "https://openapi.etsy.com/v2/oauth/access_token"
// The port number is picked at random. It's some unused port that won't likely conflict with anything else..
callbackUrl := "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 := chilkat.NewHttp()
http.SetOAuth1(true)
http.SetOAuthConsumerKey(consumerKey)
http.SetOAuthConsumerSecret(consumerSecret)
http.SetOAuthCallback(callbackUrl)
req := chilkat.NewHttpRequest()
req.SetHttpVerb("POST")
req.SetContentType("application/x-www-form-urlencoded")
resp := chilkat.NewHttpResponse()
success = http.HttpReq(requestTokenUrl,req,resp)
if success == false {
fmt.Println(http.LastErrorText())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
return
}
// If successful, the resp.BodyStr contains something like this:
// login_url=https%3A%2F%2Fwww.etsy.com%2Foauth%2Fsignin%3Foauth_consumer_key%3D9ad9l1omxzbwfr2niq0ce1ly%26oauth_token%3D7116b4d0c72c2736561853d9e50113%26service%3Dv2_prod&oauth_token=7116b4d0c72c2736561853d9e50113&oauth_token_secret=3b7612b5d3&oauth_callback_confirmed=true&oauth_consumer_key=9ad9l1omxzbwfr2niq0ce1ly&oauth_callback=http%3A%2F%2Flocalhost%3A3017%2F
fmt.Println(resp.BodyStr())
// We'll need this for later..
hashTab := chilkat.NewHashtable()
hashTab.AddQueryParams(resp.BodyStr())
requestToken := hashTab.LookupStr("oauth_token")
requestTokenSecret := hashTab.LookupStr("oauth_token_secret")
http.SetOAuthTokenSecret(*requestTokenSecret)
fmt.Println("oauth_token = ", *requestToken)
fmt.Println("oauth_token_secret = ", *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 := chilkat.NewStringBuilder()
sbUrlForBrowser.Append(authorizeUrl)
sbUrlForBrowser.Append("?")
sbUrlForBrowser.Append(resp.BodyStr())
url := sbUrlForBrowser.GetAsString()
// When the url is loaded into a browser, the response from Etsy 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 := chilkat.NewSocket()
backLog := 5
success = listenSock.BindAndListen(callbackLocalPort,backLog)
if success == false {
fmt.Println(listenSock.LastErrorText())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
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.
sock := chilkat.NewSocket()
maxWaitMs := 60000
c := make(chan *chilkat.Task)
go listenSock.AcceptNextAsync(maxWaitMs,sock,c)
task := <-c
// Launch the system's default browser navigated to the URL.
oauth2 := chilkat.NewOAuth2()
success = oauth2.LaunchBrowser(*url)
if success == false {
fmt.Println(oauth2.LastErrorText())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
return
}
// Wait for the listenSock's task to complete.
success = task.Wait(maxWaitMs)
if !success || (task.StatusInt() != 7) || (task.TaskSuccess() != true) {
if !success {
// The task.LastErrorText applies to the Wait method call.
fmt.Println(task.LastErrorText())
} else {
// The ResultErrorText applies to the underlying task method call (i.e. the AcceptNextConnection)
fmt.Println(task.Status())
fmt.Println(task.ResultErrorText())
}
task.DisposeTask()
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
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.
listenSock.Close(10)
task.DisposeTask()
// Read the start line of the request..
startLine := sock.ReceiveUntilMatch("\r\n")
if sock.LastMethodSuccess() == false {
fmt.Println(sock.LastErrorText())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
return
}
// Read the request header.
requestHeader := sock.ReceiveUntilMatch("\r\n\r\n")
if sock.LastMethodSuccess() == false {
fmt.Println(sock.LastErrorText())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
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 := chilkat.NewStringBuilder()
sbResponseHtml.Append("<html><body><p>Chilkat thanks you!</b></body</html>")
sbResponse := chilkat.NewStringBuilder()
sbResponse.Append("HTTP/1.1 200 OK\r\n")
sbResponse.Append("Content-Length: ")
sbResponse.AppendInt(sbResponseHtml.Length())
sbResponse.Append("\r\n")
sbResponse.Append("Content-Type: text/html\r\n")
sbResponse.Append("\r\n")
sbResponse.AppendSb(sbResponseHtml)
sock.SendString(*sbResponse.GetAsString())
sock.Close(50)
// The information we need is in the startLine.
// For example, the startLine will look like this:
// GET /?oauth_token=a3bc8bec84acc31418b68a532e9511&oauth_verifier=b5558d37 HTTP/1.1
sbStartLine := chilkat.NewStringBuilder()
sbStartLine.Append(*startLine)
numReplacements := sbStartLine.Replace("GET /?","")
numReplacements = sbStartLine.Replace(" HTTP/1.1","")
sbStartLine.Trim()
// oauth_token=a3bc8bec84acc31418b68a532e9511&oauth_verifier=b5558d37
fmt.Println("startline: ", *sbStartLine.GetAsString())
hashTab.Clear()
hashTab.AddQueryParams(*sbStartLine.GetAsString())
requestToken = hashTab.LookupStr("oauth_token")
authVerifier := hashTab.LookupStr("oauth_verifier")
// ------------------------------------------------------------------------------
// Finally , we must exchange the OAuth Request Token for an OAuth Access Token.
http.SetOAuthToken(*requestToken)
http.SetOAuthVerifier(*authVerifier)
req.SetHttpVerb("POST")
req.SetContentType("application/x-www-form-urlencoded")
success = http.HttpReq(accessTokenUrl,req,resp)
if success == false {
fmt.Println(http.LastErrorText())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
sbResponseHtml.DisposeStringBuilder()
sbResponse.DisposeStringBuilder()
sbStartLine.DisposeStringBuilder()
return
}
// Make sure a successful response was received.
if resp.StatusCode() != 200 {
fmt.Println(resp.StatusLine())
fmt.Println(resp.Header())
fmt.Println(resp.BodyStr())
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
sbResponseHtml.DisposeStringBuilder()
sbResponse.DisposeStringBuilder()
sbStartLine.DisposeStringBuilder()
return
}
// If successful, the resp.BodyStr contains something like this:
// oauth_token=7898d7ba280dc791586dcfd26b37a9&oauth_token_secret=f2a7c267aa
fmt.Println(resp.BodyStr())
hashTab.Clear()
hashTab.AddQueryParams(resp.BodyStr())
accessToken := hashTab.LookupStr("oauth_token")
accessTokenSecret := hashTab.LookupStr("oauth_token_secret")
// The access token + secret is what should be saved and used for
// subsequent REST API calls.
fmt.Println("Access Token = ", *accessToken)
fmt.Println("Access Token Secret = ", *accessTokenSecret)
// Save this access token for future calls.
// Just in case we need user_id and screen_name, save those also..
json := chilkat.NewJsonObject()
json.AppendString("oauth_token",*accessToken)
json.AppendString("oauth_token_secret",*accessTokenSecret)
fac := chilkat.NewFileAccess()
fac.WriteEntireTextFile("qa_data/tokens/etsy.json",*json.Emit(),"utf-8",false)
fmt.Println("Success.")
http.DisposeHttp()
req.DisposeHttpRequest()
resp.DisposeHttpResponse()
hashTab.DisposeHashtable()
sbUrlForBrowser.DisposeStringBuilder()
listenSock.DisposeSocket()
sock.DisposeSocket()
task.DisposeTask()
oauth2.DisposeOAuth2()
sbResponseHtml.DisposeStringBuilder()
sbResponse.DisposeStringBuilder()
sbStartLine.DisposeStringBuilder()
json.DisposeJsonObject()
fac.DisposeFileAccess()