Skip to content

Commit ab74ae6

Browse files
committed
server: add support for api_version argument
1 parent 501093e commit ab74ae6

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

acestream/server.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,14 +33,16 @@ def _parse_message(self, message):
3333

3434
class Request(object):
3535

36-
def __init__(self, host, port=None, scheme='http'):
36+
def __init__(self, host, port=None, scheme='http', api_version=None):
3737
self.base = self._geturl_base(scheme, host, str(port))
38+
self.api_version = api_version
3839

3940
def get(self, req_url, **params):
4041
apiurl = self._geturl(req_url, **params)
4142
return self._request(apiurl)
4243

4344
def _geturl(self, path, **params):
45+
params = self._append_api_version(params)
4446
params = dict(map(self._parse_param, params.items()))
4547
params = urlencode(params)
4648
apiurl = str(path).replace(self.base, '').strip('/')
@@ -70,6 +72,12 @@ def _geturl_base(self, scheme, host, port):
7072

7173
return host
7274

75+
def _append_api_version(self, params):
76+
if self.api_version and not 'api_version' in params:
77+
params['api_version'] = self.api_version
78+
79+
return params
80+
7381
def _get_response_key(self, response, key):
7482
if response.success:
7583
return response.data.get(key)
@@ -91,8 +99,8 @@ def _parse_param(self, param):
9199

92100
class Server(Request):
93101

94-
def __init__(self, host, port=6878, scheme='http', api_token=None):
95-
Request.__init__(self, host, port, scheme)
102+
def __init__(self, host, port=6878, scheme='http', api_token=None, api_version=None):
103+
Request.__init__(self, host, port, scheme, api_version)
96104

97105
self.api_token = api_token
98106

0 commit comments

Comments
 (0)