@@ -18,6 +18,7 @@ def __init__(self, client_id, client_secret, instance_url, version):
1818 version = version [1 :]
1919 self .version = version
2020 self .access_token = None
21+ self ._refresh_token = None
2122 self .resource_urls = {}
2223
2324 def _get_resource_url (self , name ):
@@ -30,7 +31,12 @@ def _get_resource_url(self, name):
3031 return self .resource_urls .get (name , None )
3132
3233 def set_access_token (self , token ):
33- self .access_token = token ['access_token' ]
34+ if isinstance (token , dict ):
35+ self .access_token = token ['access_token' ]
36+ if 'refresh_token' in token :
37+ self ._refresh_token = token ['refresh_token' ]
38+ else :
39+ self .access_token = token
3440
3541 def authorization_url (self , redirect_uri ):
3642 params = {
@@ -52,11 +58,13 @@ def exchange_code(self, redirect_uri, code):
5258 }
5359 return self ._request ('POST' , self .SALESFORCE_REQUEST_TOKEN_URL , data = data , headers = headers )
5460
55- def extend_token (self , refresh_token ):
61+ def refresh_token (self ):
62+ if not self ._refresh_token :
63+ return None
5664 headers = {'Content-Type' : 'application/x-www-form-urlencoded' }
5765 data = {
5866 'grant_type' : 'refresh_token' ,
59- 'refresh_token' : unquote (refresh_token ),
67+ 'refresh_token' : unquote (self . _refresh_token ),
6068 'client_id' : self .client_id ,
6169 'client_secret' : self .client_secret
6270 }
@@ -146,8 +154,6 @@ def _request(self, method, url, headers=None, **kwargs):
146154 return self ._parse (requests .request (method , url , headers = _headers , ** kwargs ))
147155
148156 def _parse (self , response ):
149- print (response .status_code )
150- print (response .text )
151157 status_code = response .status_code
152158 if status_code == 200 or status_code == 201 :
153159 return response .json ()
0 commit comments