Add support for async mode operation

Author: michelts

convertapi/__init__.py

@@ -3,7 +3,7 @@
 from .exceptions import *
 from .client import Client
 from .upload_io import UploadIO
-from .api import convert, user
+from .api import convert, user, async_convert, async_poll
 
 # configuration
 

convertapi/api.py

@@ -1,10 +1,22 @@
 import convertapi
 
 from .task import Task
+from .result import Result
 
 def convert(to_format, params, from_format = None, timeout = None):
     task = Task(from_format, to_format, params, timeout = timeout)
     return task.run()
 
+
 def user(timeout = None):
     return convertapi.client.get('user', timeout = timeout)
+
+
+def async_convert(to_format, params, from_format = None, timeout = None):
+    task = Task(from_format, to_format, params, timeout = timeout, is_async = True)
+    return task.run()
+
+
+def async_poll(job_id):
+    response = convertapi.client.get('async/job/%s' % job_id)
+    return Result(response)

convertapi/task.py

@@ -6,11 +6,12 @@
 DEFAULT_URL_FORMAT = 'web'
 
 class Task:
-    def __init__(self, from_format, to_format, params, timeout = None):
+    def __init__(self, from_format, to_format, params, timeout = None, is_async = False):
         self.from_format = from_format
         self.to_format = to_format
         self.params = params
         self.timeout = timeout or convertapi.conversion_timeout
+        self.is_async = is_async
 
         self.default_params = {
             'Timeout': self.timeout,
@@ -21,7 +22,8 @@ def run(self):
         params = self.__normalize_params()
         from_format = self.from_format or self.__detect_format()
         timeout = self.timeout + convertapi.conversion_timeout_delta if self.timeout else None
-        path = "convert/%s/to/%s" % (from_format, self.to_format)
+        base_path = 'convert' if not self.is_async else 'async/convert'
+        path = "%s/%s/to/%s" % (base_path, from_format, self.to_format)
 
         if 'converter' in params:
             path += "/converter/%s" % (params['converter'])

tests/test_convertapi.py

@@ -2,6 +2,7 @@
 import os
 import io
 import tempfile
+import time
 import requests
 
 from . import utils
@@ -74,3 +75,29 @@ def test_api_error(self):
 	def test_user_info(self):
 		user_info = convertapi.user()
 		assert user_info['Active']
+
+class TestAsyncConvertapi(utils.TestCase):
+	def setUp(self):
+		convertapi.api_secret = os.environ['CONVERT_API_SECRET']
+		convertapi.max_parallel_uploads = 10
+
+	def test_async_convert_file(self):
+		convert_result = convertapi.async_convert('pdf', { 'File': 'examples/files/test.docx' })
+		assert convert_result.response['JobId']
+
+		poll_result = get_poll_result(convert_result.response['JobId'])
+		assert poll_result.save_files(tempfile.gettempdir())
+		assert poll_result.conversion_cost > 0
+
+
+def get_poll_result(job_id, retry_count=5):
+	try:
+		result = convertapi.async_poll(job_id)
+	except Exception as error:
+		if retry_count > 0:
+			time.sleep(0.1)
+			return get_poll_result(job_id, retry_count=retry_count - 1)
+		else:
+			raise error
+	else:
+		return result