fix: uniqueness check

This commit is contained in:
Vlad Stan 2023-05-31 12:13:57 +03:00
parent 727f8fc3ce
commit 7e2c903334

View file

@ -69,7 +69,7 @@ class MessagePool:
e["sig"], e["sig"],
) )
with self.lock: with self.lock:
if not event.id in self._unique_events: if not f"{subscription_id}_{event.id}" in self._unique_events:
self._accept_event(EventMessage(event, subscription_id, url)) self._accept_event(EventMessage(event, subscription_id, url))
elif message_type == RelayMessageType.NOTICE: elif message_type == RelayMessageType.NOTICE:
self.notices.put(NoticeMessage(message_json[1], url)) self.notices.put(NoticeMessage(message_json[1], url))