1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
#!/usr/bin/env python
from __future__ import print_function
import requests
from requests_oauthlib import OAuth1
import six
from urlparse import parse_qsl
if six.PY3:
from http.server import BaseHTTPRequestHandler, HTTPServer
from urllib.parse import urlsplit, parse_qs
else:
from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
from urlparse import urlsplit, parse_qs, unquote
url = "http://www.flickr.com/services/oauth/request_token"
class keys:
apikey = u'a233c66549c9fb5e40a68c1ae156b370'
apisecret = u'03fbb3ea705fe096'
class OAuthTokenHTTPHandler(BaseHTTPRequestHandler):
def do_GET(self):
# /?oauth_token=72157630789362986-5405f8542b549e95&oauth_verifier=fe4eac402339100e
qs = urlsplit(self.path).query
url_vars = parse_qs(qs)
self.server.oauth_token = url_vars['oauth_token'][0]
self.server.oauth_verifier = url_vars['oauth_verifier'][0]
self.send_response(200)
self.send_header('Content-type', 'text/plain')
self.end_headers()
self.wfile.write('OK')
#self.server.server_close()
#self.server.shutdown()
http_server = HTTPServer(('', 8000), OAuthTokenHTTPHandler)
def wait_for_http_request():
http_server.oauth_verifier = None
while http_server.oauth_verifier is None:
http_server.handle_request()
print('OAuth verifier: %s' % http_server.oauth_verifier)
return http_server.oauth_verifier
print(120 * '=')
print("Part 1: Obtain request token")
params = {
'oauth_callback': 'oob', # "http://localhost:8000/",
}
import sys
queryoauth = OAuth1(keys.apikey, keys.apisecret, signature_type='query')
r = requests.get(url, params=params, auth=queryoauth,
config={'verbose': sys.stderr})
assert isinstance(r, requests.Response)
parts = r.text.split('&')
print('Status code:', r.status_code)
for part in parts:
print(unquote(part))
print(50 * '-')
############################################################
# Part 2
############################################################
print(120 * '=')
print("Part 2: Authorize the request token")
authorize_url = "http://www.flickr.com/services/oauth/authorize"
#parse the content
request_token = dict(parse_qsl(r.text))
print("Request Token:")
print(" - oauth_token = %s" % request_token['oauth_token'])
print(" - oauth_token_secret = %s" % request_token['oauth_token_secret'])
print()
# Create the token object with returned oauth_token and oauth_token_secret
# You need to authorize this app via your browser.
print("Go to the following link in your browser:")
print("%s?oauth_token=%s&perms=read" % (authorize_url, request_token['oauth_token']))
print()
oauth_verifier = wait_for_http_request()
oauth_verifier = oauth_verifier.decode('ascii')
if http_server.oauth_token != request_token['oauth_token']:
print("ERROR: received verifier for different OAuth token")
print(" Expected token: %r" % request_token['oauth_token'])
print(" Received token: %r" % http_server.oauth_token)
############################################################
# Part 3
############################################################
print(120 * '=')
print("Part 3: Exchange request token for an access token")
# url to get access token
access_token_url = "http://www.flickr.com/services/oauth/access_token"
# Now you need to exchange your Request Token for an Access Token
queryoauth = OAuth1(keys.apikey, keys.apisecret,
request_token['oauth_token'],
request_token['oauth_token_secret'],
signature_type='query', verifier=oauth_verifier)
r = requests.get(access_token_url,
auth=queryoauth,
config={'verbose': sys.stderr})
#parse the response
access_token_resp = {k: v.decode('utf-8') for (k, v) in parse_qsl(r.content)}
#write out a file with the oauth_token and oauth_token_secret
with open('token', 'w') as f:
for key, value in access_token_resp.items():
keyvalue = key.encode('utf-8') + '=' + value.encode('utf-8') + '\n'
f.write(keyvalue)
sys.stdout.write(keyvalue)
|
