lnbits-exts/nostrrelay
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

feat: hack send message multiple times

Browse source
This commit is contained in:
Vlad Stan 2023-02-01 19:18:53 +02:00
parent 0412361147
commit 3cd1711f84
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
client_manager.py
View file

@ -1,4 +1,5 @@
import json import json
import asyncio
from typing import Any, Callable, List, Union from typing import Any, Callable, List, Union
from fastapi import WebSocket from fastapi import WebSocket
@ -22,7 +23,8 @@ class NostrClientManager:
async def broadcast_event(self, source: "NostrClientConnection", event: NostrEvent): async def broadcast_event(self, source: "NostrClientConnection", event: NostrEvent):
for client in self.clients: for client in self.clients:
if client != source: if client != source:
await client.notify_event(event) sent = await client.notify_event(event)
print("### sent", sent, event.id)
class NostrClientConnection: class NostrClientConnection:
@ -46,11 +48,16 @@ class NostrClientConnection:
except Exception as e: except Exception as e:
logger.warning(e) logger.warning(e)
async def notify_event(self, event: NostrEvent): async def notify_event(self, event: NostrEvent) -> bool:
for filter in self.filters: for filter in self.filters:
if filter.matches(event): if filter.matches(event):
resp = event.serialize_response(filter.subscription_id) resp = event.serialize_response(filter.subscription_id)
await self.websocket.send_text(json.dumps(resp)) for i in range(0, 100):
await self.websocket.send_text(json.dumps(resp))
await asyncio.sleep(1)
return True
return False
async def __handle_message(self, data: List) -> Union[None, List]: async def __handle_message(self, data: List) -> Union[None, List]:
if len(data) < 2: if len(data) < 2: