(self, params={})
| 840 | client.resolve(message, messageHash) |
| 841 | |
| 842 | async def authenticate(self, params={}): |
| 843 | messageHash = 'authenticated' |
| 844 | type, query = self.handle_market_type_and_params('authenticate', None, params) |
| 845 | url = self.urls['api']['ws'][type] |
| 846 | client = self.client(url) |
| 847 | future = self.safe_value(client.subscriptions, messageHash) |
| 848 | if future is None: |
| 849 | time = self.milliseconds() |
| 850 | self.check_required_credentials() |
| 851 | requestId = self.request_id() |
| 852 | signData = self.apiKey + str(time) |
| 853 | sign = self.hmac(self.encode(signData), self.encode(self.secret), hashlib.sha512, 'base64') |
| 854 | request = { |
| 855 | 'method': 'login', |
| 856 | 'id': requestId, |
| 857 | 'api_key': self.apiKey, |
| 858 | 'sign': sign, |
| 859 | 'nonce': time, |
| 860 | } |
| 861 | message = self.extend(request, query) |
| 862 | future = await self.watch(url, messageHash, message, messageHash) |
| 863 | client.subscriptions[messageHash] = future |
| 864 | return future |
no test coverage detected