|
1 |
| -from . httptools import Http |
2 |
| -from . task import Task |
3 |
| -from . metadata import Metadata |
| 1 | +from .httptools import Http |
| 2 | +from .task import Task |
| 3 | +from .metadata import Metadata |
| 4 | + |
4 | 5 |
|
5 | 6 | class Client(object):
|
6 | 7 |
|
7 |
| - """ |
| 8 | + """ |
8 | 9 | :return: encoder object
|
9 | 10 |
|
10 | 11 | """
|
11 |
| - def __init__(self, api_key, api_url=None, version=None): |
12 |
| - self.api_key = api_key |
13 |
| - self.api_url = api_url if api_url else 'https://api.qencode.com/' |
14 |
| - self.version = version if version else 'v1' |
15 |
| - self.connect = Http(self.version, self.api_url) |
16 |
| - self.access_token = None |
17 |
| - self.expire = None |
18 |
| - self.error = None |
19 |
| - self.code = None |
20 |
| - self.message = '' |
21 |
| - self._get_access_token() |
22 |
| - |
23 |
| - def create_task(self, **kwargs): |
24 |
| - return Task(self.access_token, self.connect, **kwargs) |
25 |
| - |
26 |
| - def refresh_access_token(self, **kwargs): |
27 |
| - response = self.connect.request('access_token', dict(api_key=self.api_key)) |
28 |
| - if not response['error']: |
29 |
| - self.access_token = response['token'] |
30 |
| - self.expire = response['expire'] |
31 |
| - else: |
32 |
| - self.error = response['error'] |
33 |
| - self.code = response['error'] |
34 |
| - self.message = response.get('message') |
35 |
| - |
36 |
| - def _get_access_token(self): |
37 |
| - response = self.connect.request('access_token', dict(api_key=self.api_key)) |
38 |
| - if not response['error']: |
39 |
| - self.access_token = response['token'] |
40 |
| - self.expire = response['expire'] |
41 |
| - else: |
42 |
| - self.error = response['error'] |
43 |
| - self.code = response['error'] |
44 |
| - self.message = response.get('message') |
45 |
| - |
46 |
| - def get_metadata(self, uri): |
47 |
| - metadata = Metadata(self.access_token, self.connect) |
48 |
| - video_info = metadata.get(uri) |
49 |
| - return video_info |
| 12 | + |
| 13 | + def __init__(self, api_key, api_url=None, version=None): |
| 14 | + self.api_key = api_key |
| 15 | + self.api_url = api_url if api_url else 'https://api.qencode.com/' |
| 16 | + self.version = version if version else 'v1' |
| 17 | + self.connect = Http(self.version, self.api_url) |
| 18 | + self.access_token = None |
| 19 | + self.expire = None |
| 20 | + self.error = None |
| 21 | + self.code = None |
| 22 | + self.message = '' |
| 23 | + self._get_access_token() |
| 24 | + |
| 25 | + def create_task(self, **kwargs): |
| 26 | + return Task(self.access_token, self.connect, **kwargs) |
| 27 | + |
| 28 | + def refresh_access_token(self, **kwargs): |
| 29 | + response = self.connect.request('access_token', dict(api_key=self.api_key)) |
| 30 | + if not response['error']: |
| 31 | + self.access_token = response['token'] |
| 32 | + self.expire = response['expire'] |
| 33 | + else: |
| 34 | + self.error = response['error'] |
| 35 | + self.code = response['error'] |
| 36 | + self.message = response.get('message') |
| 37 | + |
| 38 | + def _get_access_token(self): |
| 39 | + response = self.connect.request('access_token', dict(api_key=self.api_key)) |
| 40 | + if not response['error']: |
| 41 | + self.access_token = response['token'] |
| 42 | + self.expire = response['expire'] |
| 43 | + else: |
| 44 | + self.error = response['error'] |
| 45 | + self.code = response['error'] |
| 46 | + self.message = response.get('message') |
| 47 | + |
| 48 | + def get_metadata(self, uri): |
| 49 | + metadata = Metadata(self.access_token, self.connect) |
| 50 | + video_info = metadata.get(uri) |
| 51 | + return video_info |
0 commit comments