From 38238cc4a8699a053cb18cd7aa973a63a16d819f Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Fri, 29 Dec 2023 21:21:56 -0600
Subject: [PATCH] Fix db/events test, remove unnecessary AbortSignal from
 pipeline

---
 src/db/events.test.ts | 6 +++---
 src/pipeline.ts       | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/db/events.test.ts b/src/db/events.test.ts
index ab689d5..bb3f6f4 100644
--- a/src/db/events.test.ts
+++ b/src/db/events.test.ts
@@ -42,9 +42,9 @@ Deno.test('query events with local filter', async () => {
     username: 'alex',
     pubkey: event1.pubkey,
     inserted_at: new Date(),
-    admin: 0,
+    admin: false,
   });
 
-  assertEquals(await db.getEvents([{ local: true }]), [event1]);
-  assertEquals(await db.getEvents([{ local: false }]), []);
+  assertEquals(await db.getEvents([{ kinds: [1], local: true }]), [event1]);
+  assertEquals(await db.getEvents([{ kinds: [1], local: false }]), []);
 });
diff --git a/src/pipeline.ts b/src/pipeline.ts
index f4e0abe..69ae941 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -71,7 +71,7 @@ async function storeEvent(event: Event, data: EventData, opts: StoreEventOpts =
   if (force || data.user || isAdminEvent(event) || await isLocallyFollowed(event.pubkey)) {
     const [deletion] = await eventsDB.getEvents(
       [{ kinds: [5], authors: [event.pubkey], '#e': [event.id], limit: 1 }],
-      { limit: 1, signal: AbortSignal.timeout(Time.seconds(1)) },
+      { limit: 1 },
     );
 
     if (deletion) {