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

resubscribe when a new relay is added

Browse source
This commit is contained in:
callebtc 2023-04-11 15:47:21 +02:00
parent 0ffb158769
commit e0938cb760
3 changed files with 20 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
services.py
View file

@ -45,7 +45,6 @@ class NostrRouter:
except WebSocketDisconnect:
self.connected = False
break
# print(json_str)
# registers a subscription if the input was a REQ request
subscription_id, json_str_rewritten = await self._add_nostr_subscription(
@ -81,7 +80,7 @@ class NostrRouter:
}
# this reconstructs the original response from the relay
# reconstruct oriiginal subscription id
# reconstruct original subscription id
s_original = s[len(f"{self.subscription_id_rewrite}_") :]
event_to_forward = ["EVENT", s_original, event_json]
# print(json.dumps(event_to_forward))
@ -104,6 +103,7 @@ class NostrRouter:
async def stop(self):
for t in self.tasks:
t.cancel()
self.connected = False
def _marshall_nostr_filters(self, data: Union[dict, list]):
filters = data if isinstance(data, list) else [data]