From b50f8c1cbc22b9394607a7dccb2a11bdb6dc7efd 2012-06-30 02:43:20
From: MinRK <benjaminrk@gmail.com>
Date: 2012-06-30 02:43:20
Subject: [PATCH] enable posting GitHub downloads
---

diff --git a/tools/gh_api.py b/tools/gh_api.py
index fbb9bf6..ed79300 100644
--- a/tools/gh_api.py
+++ b/tools/gh_api.py
@@ -6,6 +6,8 @@ try:
 except NameError:
     pass
 
+import os
+
 import requests
 import getpass
 import json
@@ -102,3 +104,101 @@ def get_pulls_list(project, github_api=3):
     if github_api == 2 :
         return json.loads(response.text)['pulls']
     return json.loads(response.text)
+
+# encode_multipart_formdata is from urllib3.filepost
+# The only change is to iter_fields, to enforce S3's required key ordering
+
+def iter_fields(fields):
+    fields = fields.copy()
+    for key in ('key', 'acl', 'Filename', 'success_action_status', 'AWSAccessKeyId',
+        'Policy', 'Signature', 'Content-Type', 'file'):
+        yield (key, fields.pop(key))
+    for (k,v) in fields.items():
+        yield k,v
+
+def encode_multipart_formdata(fields, boundary=None):
+    """
+    Encode a dictionary of ``fields`` using the multipart/form-data mime format.
+
+    :param fields:
+        Dictionary of fields or list of (key, value) field tuples.  The key is
+        treated as the field name, and the value as the body of the form-data
+        bytes. If the value is a tuple of two elements, then the first element
+        is treated as the filename of the form-data section.
+
+        Field names and filenames must be unicode.
+
+    :param boundary:
+        If not specified, then a random boundary will be generated using
+        :func:`mimetools.choose_boundary`.
+    """
+    # copy requests imports in here:
+    from io import BytesIO
+    from requests.packages.urllib3.filepost import (
+        choose_boundary, six, writer, b, get_content_type
+    )
+    body = BytesIO()
+    if boundary is None:
+        boundary = choose_boundary()
+
+    for fieldname, value in iter_fields(fields):
+        body.write(b('--%s\r\n' % (boundary)))
+
+        if isinstance(value, tuple):
+            filename, data = value
+            writer(body).write('Content-Disposition: form-data; name="%s"; '
+                               'filename="%s"\r\n' % (fieldname, filename))
+            body.write(b('Content-Type: %s\r\n\r\n' %
+                       (get_content_type(filename))))
+        else:
+            data = value
+            writer(body).write('Content-Disposition: form-data; name="%s"\r\n'
+                               % (fieldname))
+            body.write(b'Content-Type: text/plain\r\n\r\n')
+
+        if isinstance(data, int):
+            data = str(data)  # Backwards compatibility
+        if isinstance(data, six.text_type):
+            writer(body).write(data)
+        else:
+            body.write(data)
+
+        body.write(b'\r\n')
+
+    body.write(b('--%s--\r\n' % (boundary)))
+
+    content_type = b('multipart/form-data; boundary=%s' % boundary)
+
+    return body.getvalue(), content_type
+
+
+def post_download(project, filename, name=None, description=""):
+    """Upload a file to the GitHub downloads area"""
+    if name is None:
+        name = os.path.basename(filename)
+    with open(filename, 'rb') as f:
+        filedata = f.read()
+    
+    url = "https://api.github.com/repos/{project}/downloads".format(project=project)
+    
+    payload = json.dumps(dict(name=name, size=len(filedata),
+                    description=description))
+    response = requests.post(url, data=payload, headers=make_auth_header())
+    response.raise_for_status()
+    reply = json.loads(response.content)
+    s3_url = reply['s3_url']
+    
+    fields = dict(
+        key=reply['path'],
+        acl=reply['acl'],
+        success_action_status=201,
+        Filename=reply['name'],
+        AWSAccessKeyId=reply['accesskeyid'],
+        Policy=reply['policy'],
+        Signature=reply['signature'],
+        file=(reply['name'], filedata),
+    )
+    fields['Content-Type'] = reply['mime_type']
+    data, content_type = encode_multipart_formdata(fields)
+    s3r = requests.post(s3_url, data=data, headers={'Content-Type': content_type})
+    return s3r