updates for getting status of encoding

Author: obhodny

qencode3/__init__.py

@@ -29,7 +29,7 @@ def x265_video_codec():
 
 from . exeptions import QencodeClientException, QencodeTaskException
 
-__version__ = "0.9.25"
+__version__ = "0.9.26"
 __status__ = "Beta"
 __author__ = "Qencode"
 

qencode3/const.py

@@ -1,4 +1,20 @@
 REPEAT = 32
 SLEEP_REGULAR = 10
 SLEEP_ERROR = 60
-COMPLETED_STATUS = ['completed', 'saved']
+COMPLETED_STATUS = ['completed', 'saved']
+
+ERROR_OK                = 0
+ERROR_SERVER_INTERNAL   = 1
+ERROR_BAD_APP_ID        = 2
+ERROR_APP_ID_NOT_FOUND  = 3
+ERROR_BAD_TOKEN         = 4
+ERROR_TOKEN_NOT_FOUND   = 5
+ERROR_TARIFF_NOT_PAID   = 6
+ERROR_MASTER_NOT_FOUND  = 7
+ERROR_SYSTEM_BUSY       = 8
+ERROR_BAD_PAYLOAD       = 9
+ERROR_PROJECT_NOT_FOUND = 10
+ERROR_BAD_PROFILE       = 11
+ERROR_PROFILE_NOT_FOUND = 12
+ERROR_BAD_TOKENS        = 13
+ERROR_FIELD_REQUIRED    = 14

qencode3/httptools.py

@@ -12,10 +12,11 @@ def __init__(self, version, url, debug=False):
 
   def _call_server(self, url, post_data):
     if not url:
-      response = dict(error=True, message='AttributeError: not URL')
+      response = dict(error=True, message='AttributeError: Bad URL: ' + str(url))
       return json.dumps(response)
     data = urlencode(post_data).encode("utf-8")
     request = urllib2.Request(url, data)
+    #print('call_server: ', url, data)
     try:
       res = urllib2.urlopen(request)
     except urllib2.HTTPError as e:
@@ -48,4 +49,4 @@ def post(self, url, data):
       response = json.loads(response)
     except ValueError as e:
       response = dict(error=True, message=repr(e))
-    return response
+    return response

qencode3/task.py

@@ -10,6 +10,7 @@ class Task(object):
   def __init__(self, access_token, connect, debug=False, **kwargs):
     self.connect = connect
     self.status_url = None
+    self.main_status_url = '{0}/{1}/status'.format(self.connect.url, self.connect.version)
     self.task_token = None
     self.upload_url = None
     self.access_token = access_token
@@ -166,33 +167,43 @@ def _create_task(self, count):
 
   def _start_encode(self, api_name, data):
     res = self.connect.request(api_name, data)
-    if not res['error']:
-      self.status_url = res.get('status_url')
+    if not res['error'] and res.get('status_url'):
+      self.status_url = res['status_url']
     else:
-      self.status_url = '{0}/{1}/status'.format(self.connect.url, self.connect.version)
-      self.error = res['error']
+      self.status_url = self.main_status_url
+      self.error = res.get('error')
       self.message = res.get('message')
 
   def _status(self):
     response = self.connect.post(self.status_url, dict(task_tokens=self.task_token))
-    if not response['error']:
+    status = None
+
+    if response['error'] == ERROR_BAD_TOKENS:
+      raise ValueError('Bad token: ' + str(self.task_token))
+
+    if 'statuses' in response and self.task_token in response['statuses']:
+      status = response['statuses'][self.task_token]
+
+    if not status and self.status_url != self.main_status_url:
+      self.status_url = self.main_status_url
+      response = self.connect.post(self.status_url, dict(task_tokens=self.task_token))
+      if 'statuses' in response and self.task_token in response['statuses']:
         status = response['statuses'][self.task_token]
-        if not status:
-          status = self._status2()
-        return status
-    else:
-      status = self._status2()
-      return status
 
+    if status and 'status_url' in status:
+      self.status_url = status['status_url']
 
-  def _status2(self):
-    response = self.connect.request('status', {'task_tokens[]': self.task_token})
-    if not response['error']:
-      res = response['statuses'][self.task_token]
-      if res:
-        return res
-      else:
-        return dict(error=True, message='Error getting status')
-    else:
-      return response
+    return status
+
+
+  # def _status2(self):
+  #   response = self.connect.request('status', {'task_tokens[]': self.task_token})
+  #   if not response['error']:
+  #     res = response['statuses'][self.task_token]
+  #     if res:
+  #       return res
+  #     else:
+  #       return dict(error=True, message='Error getting status')
+  #   else:
+  #     return response
 

setup.py

@@ -13,7 +13,7 @@
 
 setup(
     name='qencode3',
-    version='0.9.25',
+    version='0.9.26',
     description="Qencode client library to easily setup a working solution using Python v3.x.",
     long_description=long_description,
     long_description_content_type='text/markdown',