(self, method, params)
| 105 | return resp.json() |
| 106 | |
| 107 | async def send(self, method, params): |
| 108 | self._reqid += 1 |
| 109 | async with websockets.connect(self.wsurl) as ws: |
| 110 | await ws.send( |
| 111 | json.dumps( |
| 112 | {"method": method, "params": params, "id": self._reqid} |
| 113 | ) |
| 114 | ) |
| 115 | self._last_resp = await ws.recv() |
| 116 | self._last_json = json.loads(self._last_resp) |
| 117 | self.log.info(self._last_json) |
| 118 | |
| 119 | def get(self, uri): |
| 120 | from urllib.parse import unquote |
no test coverage detected