Kieran/snort
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

check alreadyHaves from system.cacheRelay

Browse Source
This commit is contained in:
Martti Malmi
2024-02-01 10:11:12 +02:00
parent eb9f23b73b
commit 13a773a1ad
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
packages/system/src/connection-pool.ts
View File

@ -75,11 +75,13 @@ export class DefaultConnectionPool extends EventEmitter<NostrConnectionPoolEvent
this.#log("%s have: %s %o", c.Address, s, id);
if (this.#requestedIds.has(id)) {
this.#log("HAVE: Already requested from another relay %s", id);
// TODO if request to a relay fails, try another relay. otherwise malicious relays can block content.
return;
}
this.#requestedIds.add(id);
if (await this.#system.eventsCache.get(id)) {
// TODO better local cache / db check
// is this performant? should it be batched?
const alreadyHave = await this.#system.cacheRelay?.query(["REQ", id, {ids: [id]}]);
if (alreadyHave?.length) {
this.#log("HAVE: Already have %s", id);
return;
}