| 32 | |
| 33 | |
| 34 | class _FakeWebSocket: |
| 35 | def __init__(self, owner): |
| 36 | self.owner = owner |
| 37 | self.close_code = None |
| 38 | self.messages = [] |
| 39 | |
| 40 | async def send(self, message): |
| 41 | self.messages.append(message) |
| 42 | payload = json.loads(message) |
| 43 | transaction = self.owner.mapper[payload["id"]] |
| 44 | transaction(result={"ok": True}) |
| 45 | |
| 46 | |
| 47 | class _ConnectionWithoutClosed: |