Skip to content

Commit

Permalink
Fix github API requests after asset upload; PyGithub#2
Browse files Browse the repository at this point in the history
In the old code the self.__hostname would be overwritten with uploads.github.com
but it could not be correctly re-set to api.github.com after completing the upload
Create a separate connection if hostname or port differ in requestblobandcheck

in the end this became quite a large overhaul, to also make this change generic
for e.g. connecting to status.github.com and all methods
  • Loading branch information
mfonville committed Apr 25, 2018
1 parent d9071a9 commit c6a7acb
Show file tree
Hide file tree
Showing 6 changed files with 25 additions and 24 deletions.
10 changes: 4 additions & 6 deletions github/MainClass.py
Expand Up @@ -72,6 +72,7 @@
atLeastPython3 = sys.hexversion >= 0x03000000

DEFAULT_BASE_URL = "https://api.github.com"
DEFAULT_STATUS_URL = "https://status.github.com"
DEFAULT_TIMEOUT = 10
DEFAULT_PER_PAGE = 30

Expand Down Expand Up @@ -621,8 +622,7 @@ def get_api_status(self):
"""
headers, attributes = self.__requester.requestJsonAndCheck(
"GET",
"/api/status.json",
cnx="status"
DEFAULT_STATUS_URL + "/api/status.json"
)
return Status.Status(self.__requester, headers, attributes, completed=True)

Expand All @@ -635,8 +635,7 @@ def get_last_api_status_message(self):
"""
headers, attributes = self.__requester.requestJsonAndCheck(
"GET",
"/api/last-message.json",
cnx="status"
DEFAULT_STATUS_URL + "/api/last-message.json"
)
return StatusMessage.StatusMessage(self.__requester, headers, attributes, completed=True)

Expand All @@ -649,8 +648,7 @@ def get_api_status_messages(self):
"""
headers, data = self.__requester.requestJsonAndCheck(
"GET",
"/api/messages.json",
cnx="status"
DEFAULT_STATUS_URL + "/api/messages.json"
)
return [StatusMessage.StatusMessage(self.__requester, headers, attributes, completed=True) for attributes in data]

Expand Down
29 changes: 16 additions & 13 deletions github/Requester.py
Expand Up @@ -251,23 +251,29 @@ def __init__(self, login_or_token, password, base_url, timeout, client_id, clien
self.__userAgent = user_agent
self.__apiPreview = api_preview

def requestJsonAndCheck(self, verb, url, parameters=None, headers=None, input=None, cnx=None):
return self.__check(*self.requestJson(verb, url, parameters, headers, input, cnx))
def requestJsonAndCheck(self, verb, url, parameters=None, headers=None, input=None):
return self.__check(*self.requestJson(verb, url, parameters, headers, input, self.__customConnection(url)))

def requestMultipartAndCheck(self, verb, url, parameters=None, headers=None, input=None):
return self.__check(*self.requestMultipart(verb, url, parameters, headers, input))
return self.__check(*self.requestMultipart(verb, url, parameters, headers, input, self.__customConnection(url)))

def requestBlobAndCheck(self, verb, url, parameters=None, headers=None, input=None):
o = urlparse.urlparse(url)
self.__hostname = o.hostname
return self.__check(*self.requestBlob(verb, url, parameters, headers, input))
return self.__check(*self.requestBlob(verb, url, parameters, headers, input, self.__customConnection(url)))

def __check(self, status, responseHeaders, output):
output = self.__structuredFromJson(output)
if status >= 400:
raise self.__createException(status, responseHeaders, output)
return responseHeaders, output

def __customConnection(self, url):
cnx = None
if not url.startswith("/"):
o = urlparse.urlparse(url)
if o.hostname != self.__hostname or o.port != self.__port:
cnx = self.__httpsConnectionClass(o.hostname, o.port)
return cnx

def __createException(self, status, headers, output):
if status == 401 and output.get("message") == "Bad credentials":
cls = GithubException.BadCredentialsException
Expand Down Expand Up @@ -300,7 +306,7 @@ def encode(input):

return self.__requestEncode(cnx, verb, url, parameters, headers, input, encode)

def requestMultipart(self, verb, url, parameters=None, headers=None, input=None):
def requestMultipart(self, verb, url, parameters=None, headers=None, input=None, cnx=None):
def encode(input):
boundary = "----------------------------3c3ba8b523b2"
eol = "\r\n"
Expand All @@ -314,9 +320,9 @@ def encode(input):
encoded_input += "--" + boundary + "--" + eol
return "multipart/form-data; boundary=" + boundary, encoded_input

return self.__requestEncode(None, verb, url, parameters, headers, input, encode)
return self.__requestEncode(cnx, verb, url, parameters, headers, input, encode)

def requestBlob(self, verb, url, parameters={}, headers={}, input=None):
def requestBlob(self, verb, url, parameters={}, headers={}, input=None, cnx=None):
def encode(local_path):
if "Content-Type" in headers:
mime_type = headers["Content-Type"]
Expand All @@ -328,7 +334,7 @@ def encode(local_path):

if input:
headers["Content-Length"] = os.path.getsize(input)
return self.__requestEncode(None, verb, url, parameters, headers, input, encode)
return self.__requestEncode(cnx, verb, url, parameters, headers, input, encode)

def __requestEncode(self, cnx, verb, url, parameters, requestHeaders, input, encode):
assert verb in ["HEAD", "GET", "POST", "PATCH", "PUT", "DELETE"]
Expand Down Expand Up @@ -369,9 +375,6 @@ def __requestRaw(self, cnx, verb, url, requestHeaders, input):
original_cnx = cnx
if cnx is None:
cnx = self.__createConnection()
else:
assert cnx == "status"
cnx = self.__httpsConnectionClass("status.github.com", 443)
cnx.request(
verb,
url,
Expand Down
Expand Up @@ -265,7 +265,7 @@ None
https
GET
status.github.com
443
None
/api/status.json
{'Authorization': 'Basic login_and_password_removed', 'User-Agent': 'PyGithub/Python'}
None
Expand All @@ -276,7 +276,7 @@ None
https
GET
status.github.com
443
None
/api/last-message.json
{'Authorization': 'Basic login_and_password_removed', 'User-Agent': 'PyGithub/Python'}
None
Expand Down
2 changes: 1 addition & 1 deletion github/tests/ReplayData/Status.testGetLastMessage.txt
@@ -1,7 +1,7 @@
https
GET
status.github.com
443
None
/api/last-message.json
{'Authorization': 'Basic login_and_password_removed', 'User-Agent': 'PyGithub/Python'}
None
Expand Down
2 changes: 1 addition & 1 deletion github/tests/ReplayData/Status.testGetMessages.txt
@@ -1,7 +1,7 @@
https
GET
status.github.com
443
None
/api/messages.json
{'Authorization': 'Basic login_and_password_removed', 'User-Agent': 'PyGithub/Python'}
None
Expand Down
2 changes: 1 addition & 1 deletion github/tests/ReplayData/Status.testGetStatus.txt
@@ -1,7 +1,7 @@
https
GET
status.github.com
443
None
/api/status.json
{'Authorization': 'Basic login_and_password_removed', 'User-Agent': 'PyGithub/Python'}
None
Expand Down

0 comments on commit c6a7acb

Please sign in to comment.