From bf479d01625497eac9190286eaf383f381ca606b Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Fri, 17 May 2024 18:26:55 -0500
Subject: [PATCH] Move refreshAuthorStatsDebounced to stats.ts

---
 src/stats.ts            | 12 +++++++++++-
 src/storages/hydrate.ts | 16 +++-------------
 2 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/src/stats.ts b/src/stats.ts
index 08d4bb9..4364781 100644
--- a/src/stats.ts
+++ b/src/stats.ts
@@ -1,6 +1,7 @@
 import { NKinds, NostrEvent, NStore } from '@nostrify/nostrify';
 import Debug from '@soapbox/stickynotes/debug';
 import { InsertQueryBuilder, Kysely } from 'kysely';
+import { LRUCache } from 'lru-cache';
 import { SetRequired } from 'type-fest';
 
 import { DittoDB } from '@/db/DittoDB.ts';
@@ -250,4 +251,13 @@ async function countAuthorStats(
   };
 }
 
-export { refreshAuthorStats, updateStats };
+const lru = new LRUCache<string, true>({ max: 1000 });
+
+/** Calls `refreshAuthorStats` only once per author. */
+function refreshAuthorStatsDebounced(pubkey: string): void {
+  if (lru.get(pubkey)) return;
+  lru.set(pubkey, true);
+  refreshAuthorStats(pubkey).catch(() => {});
+}
+
+export { refreshAuthorStats, refreshAuthorStatsDebounced, updateStats };
diff --git a/src/storages/hydrate.ts b/src/storages/hydrate.ts
index 7b964d7..e5c488e 100644
--- a/src/storages/hydrate.ts
+++ b/src/storages/hydrate.ts
@@ -1,12 +1,11 @@
 import { NostrEvent, NStore } from '@nostrify/nostrify';
-import { LRUCache } from 'lru-cache';
 import { matchFilter } from 'nostr-tools';
 
 import { DittoDB } from '@/db/DittoDB.ts';
 import { type DittoEvent } from '@/interfaces/DittoEvent.ts';
 import { DittoTables } from '@/db/DittoTables.ts';
 import { Conf } from '@/config.ts';
-import { refreshAuthorStats } from '@/stats.ts';
+import { refreshAuthorStatsDebounced } from '@/stats.ts';
 
 interface HydrateOpts {
   events: DittoEvent[];
@@ -57,7 +56,7 @@ async function hydrateEvents(opts: HydrateOpts): Promise<DittoEvent[]> {
     events: await gatherEventStats(cache),
   };
 
-  requestMissingAuthorStats(events, stats.authors);
+  refreshMissingAuthorStats(events, stats.authors);
 
   // Dedupe events.
   const results = [...new Map(cache.map((event) => [event.id, event])).values()];
@@ -270,7 +269,7 @@ async function gatherAuthorStats(events: DittoEvent[]): Promise<DittoTables['aut
   }));
 }
 
-function requestMissingAuthorStats(events: NostrEvent[], stats: DittoTables['author_stats'][]) {
+function refreshMissingAuthorStats(events: NostrEvent[], stats: DittoTables['author_stats'][]) {
   const pubkeys = new Set<string>(
     events
       .filter((event) => event.kind === 0)
@@ -286,15 +285,6 @@ function requestMissingAuthorStats(events: NostrEvent[], stats: DittoTables['aut
   }
 }
 
-const lru = new LRUCache<string, true>({ max: 1000 });
-
-/** Calls `refreshAuthorStats` only once per author. */
-function refreshAuthorStatsDebounced(pubkey: string): void {
-  if (lru.get(pubkey)) return;
-  lru.set(pubkey, true);
-  refreshAuthorStats(pubkey).catch(() => {});
-}
-
 /** Collect event stats from the events. */
 async function gatherEventStats(events: DittoEvent[]): Promise<DittoTables['event_stats'][]> {
   const ids = new Set<string>(