add video upload end-points

Author: anxdpanic

addon.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
-<addon id="script.module.python.twitch" name="python-twitch for Kodi" version="1.0.0~alpha9" provider-name="A Talented Community">
+<addon id="script.module.python.twitch" name="python-twitch for Kodi" version="1.0.0~beta1" provider-name="A Talented Community">
     <requires>
         <import addon="xbmc.python" version="2.1.0"/>
         <import addon="script.module.six" version="1.9.0"/>

resources/lib/twitch/api/v5/videos.py

@@ -1,10 +1,11 @@
 # -*- encoding: utf-8 -*-
 # https://dev.twitch.tv/docs/v5/reference/videos/
 
-from twitch import keys
-from twitch.api.parameters import BroadcastType, Period
+from twitch import keys, methods
+from twitch.api.parameters import BroadcastType, Period, Language
 from twitch.queries import V5Query as Qry
 from twitch.queries import HiddenApiQuery as HQry
+from twitch.queries import UploadsQuery as UQry
 from twitch.queries import query
 
 
@@ -38,6 +39,63 @@ def get_followed(limit=10, offset=0, broadcast_type=BroadcastType.HIGHLIGHT):
     return q
 
 
+# required scope: channel_editor
+@query
+def create(channel_id, title, description=None, game=None, language=None, tag_list=None):
+    q = Qry('videos/', method=methods.POST)
+    q.add_param(keys.CHANNEL_ID, channel_id)
+    q.add_param(keys.TITLE, title)
+    q.add_param(keys.DESCRIPTION, description)
+    q.add_param(keys.GAME, game)
+    if language is not None:
+        q.add_param(keys.LANGUAGE, Language.validate(language))
+    q.add_param(keys.TAG_LIST, tag_list)
+    return q
+
+
+# required scope: channel_editor
+@query
+def update(video_id, title=None, description=None, game=None, language=None, tag_list=None):
+    q = Qry('videos/{video_id}', method=methods.PUT)
+    q.add_urlkw(keys.VIDEO_ID, video_id)
+    q.add_param(keys.TITLE, title)
+    q.add_param(keys.DESCRIPTION, description)
+    q.add_param(keys.GAME, game)
+    if language is not None:
+        q.add_param(keys.LANGUAGE, Language.validate(language))
+    q.add_param(keys.TAG_LIST, tag_list)
+    return q
+
+
+# required scope: channel_editor
+@query
+def delete(video_id):
+    q = Qry('videos/{video_id}', method=methods.DELETE)
+    q.add_urlkw(keys.VIDEO_ID, video_id)
+    return q
+
+
+# requires upload token
+@query
+def upload_part(video_id, part, upload_token, content_length, data):
+    q = UQry('upload/{video_id}', method=methods.PUT)
+    q.set_headers({'Content-Length': content_length, 'Content-Type': 'application/octet-stream'})
+    q.add_urlkw(keys.VIDEO_ID, video_id)
+    q.add_param(keys.PART, part)
+    q.add_param(keys.UPLOAD_TOKEN, upload_token)
+    q.add_bin(data)
+    return q
+
+
+# requires upload token
+@query
+def complete_upload(video_id, upload_token):
+    q = UQry('upload/{video_id}/complete', method=methods.POST)
+    q.add_urlkw(keys.VIDEO_ID, video_id)
+    q.add_param(keys.UPLOAD_TOKEN, upload_token)
+    return q
+
+
 # required scope: none
 # undocumented / unsupported
 @query

resources/lib/twitch/keys.py

@@ -51,6 +51,7 @@
 NEED_HTTPS = 'need_https'
 NOTIFICATIONS = 'notifications'
 OFFSET = 'offset'
+PART = 'part'
 PERIOD = 'period'
 POSITION = 'position'
 POST_ID = 'post_id'
@@ -66,6 +67,7 @@
 STATUS = 'status'
 STREAM_TYPE = 'stream_type'
 SUMMARY = 'summary'
+TAG_LIST = 'tag_list'
 TARGET_ID = 'target_id'
 TEAM = 'team'
 TITLE = 'title'
@@ -78,6 +80,7 @@
 USER_AGENT_STRING = ('Mozilla/5.0 (Windows NT 6.1; WOW64; rv:6.0) '
                      'Gecko/20100101 Firefox/6.0')
 USER_ID = 'user_id'
+UPLOAD_TOKEN = 'upload_token'
 VIDEO_ID = 'video_id'
 VOD = 'vod'
 XBOX_HEARTBEAT = 'xbox_heartbeat'

resources/lib/twitch/queries.py

@@ -12,6 +12,7 @@
 _hidden_baseurl = 'https://api.twitch.tv/api/'
 _usher_baseurl = 'https://usher.ttvnw.net/'
 _clips_baseurl = 'https://clips.twitch.tv/'
+_uploads_baseurl = 'https://uploads.twitch.tv/'
 
 _v4_headers = {'ACCEPT': 'application/vnd.twitchtv.v4+json'}
 _v5_headers = {'ACCEPT': 'application/vnd.twitchtv.v5+json'}
@@ -62,6 +63,10 @@ def add_data(self, key, value, default=None):
             self._data[key] = value
         return self
 
+    def add_bin(self, data):
+        self._data = data
+        return self
+
     def add_param(self, key, value, default=None):
         assert_new(self._params, key)
         if value != default:
@@ -73,8 +78,12 @@ def add_urlkw(self, kw, replacement):
         self._urlkws[kw] = replacement
         return self
 
+    def set_headers(self, headers):
+        self._headers = headers
+        return self
+
     def __str__(self):
-        return '{method} Query to {url}, params {params}, data {data},  headers {headers}'\
+        return '{method} Query to {url}, params {params}, data {data},  headers {headers}' \
             .format(url=self.url, params=self.params, headers=self.headers, data=self.data, method=self.method)
 
     def execute(self, f):
@@ -129,6 +138,12 @@ def __init__(self, path, headers={}, data={}, method=methods.GET):
         self.add_path(path)
 
 
+class UploadsQuery(DownloadQuery):
+    def __init__(self, path, headers={}, data={}, method=methods.PUT):
+        super(UploadsQuery, self).__init__(_uploads_baseurl, headers, data, method)
+        self.add_path(path)
+
+
 class V4Query(ApiQuery):
     def __init__(self, path, method=methods.GET):
         super(V4Query, self).__init__(path, _v4_headers, method=method)