diff --git a/packages/app/src/Cache/ProfileWorkeCache.ts b/packages/app/src/Cache/ProfileWorkeCache.ts index f3ae4ad8..7d4ec5c3 100644 --- a/packages/app/src/Cache/ProfileWorkeCache.ts +++ b/packages/app/src/Cache/ProfileWorkeCache.ts @@ -81,9 +81,7 @@ export class ProfileCacheRelayWorker extends EventEmitter implement this.emit("change", mapped); } - async update( - m: TWithCreated, - ): Promise<"new" | "refresh" | "updated" | "no_change"> { + async update(): Promise<"new" | "refresh" | "updated" | "no_change"> { // do nothing return "refresh"; } diff --git a/packages/worker-relay/src/relay.ts b/packages/worker-relay/src/relay.ts index a5729167..b443aa50 100644 --- a/packages/worker-relay/src/relay.ts +++ b/packages/worker-relay/src/relay.ts @@ -157,11 +157,13 @@ export class WorkerRelay extends EventEmitter { }); let eventInserted = (this.#db?.changes() as number) > 0; if (eventInserted) { - for (const t of ev.tags.filter(a => a[0].length === 1)) { - db.exec("insert into tags(event_id, key, value) values(?, ?, ?)", { - bind: [ev.id, t[0], t[1]], - }); - } + db.transaction(db => { + for (const t of ev.tags.filter(a => a[0].length === 1)) { + db.exec("insert into tags(event_id, key, value) values(?, ?, ?)", { + bind: [ev.id, t[0], t[1]], + }); + } + }); } this.#seenInserts.add(ev.id); return eventInserted;