Move isLocallyFollowed to queries.ts

src/db/events.ts

@@ -119,16 +119,4 @@ async function getFilters<K extends number>(
   ));
 }
 
-/** Returns whether the pubkey is followed by a local user. */
-async function isLocallyFollowed(pubkey: string): Promise<boolean> {
-  return Boolean(
-    await getFilterQuery({
-      kinds: [3],
-      '#p': [pubkey],
-      limit: 1,
-      local: true,
-    }).executeTakeFirst(),
-  );
-}
-
-export { getFilters, insertEvent, isLocallyFollowed };
+export { getFilters, insertEvent };

src/pipeline.ts

@@ -2,6 +2,7 @@ import * as eventsDB from '@/db/events.ts';
 import { addRelays } from '@/db/relays.ts';
 import { findUser } from '@/db/users.ts';
 import { type Event } from '@/deps.ts';
+import { isLocallyFollowed } from '@/queries.ts';
 import { trends } from '@/trends.ts';
 import { isRelay, nostrDate } from '@/utils.ts';
 
@@ -19,7 +20,7 @@ async function handleEvent(event: Event): Promise<void> {
 
 /** Maybe store the event, if eligible. */
 async function storeEvent(event: Event): Promise<void> {
-  if (await findUser({ pubkey: event.pubkey }) || await eventsDB.isLocallyFollowed(event.pubkey)) {
+  if (await findUser({ pubkey: event.pubkey }) || await isLocallyFollowed(event.pubkey)) {
     await eventsDB.insertEvent(event).catch(console.warn);
   }
 }

src/queries.ts

@@ -1,8 +1,8 @@
+import * as eventsDB from '@/db/events.ts';
 import { type Event, type Filter, findReplyTag } from '@/deps.ts';
+import * as mixer from '@/mixer.ts';
 import { type PaginationParams } from '@/utils.ts';
 
-import * as mixer from './mixer.ts';
-
 interface GetEventOpts<K extends number> {
   /** Timeout in milliseconds. */
   timeout?: number;
@@ -83,4 +83,10 @@ function getDescendants(eventId: string): Promise<Event<1>[]> {
   return mixer.getFilters([{ kinds: [1], '#e': [eventId] }], { limit: 200, timeout: 2000 });
 }
 
-export { getAncestors, getAuthor, getDescendants, getEvent, getFeed, getFollows, getPublicFeed };
+/** Returns whether the pubkey is followed by a local user. */
+async function isLocallyFollowed(pubkey: string): Promise<boolean> {
+  const [event] = await eventsDB.getFilters([{ kinds: [3], '#p': [pubkey], local: true }], { limit: 1 });
+  return Boolean(event);
+}
+
+export { getAncestors, getAuthor, getDescendants, getEvent, getFeed, getFollows, getPublicFeed, isLocallyFollowed };