1 files changed, 30 insertions, 3 deletions
diff --git a/feed/server.js b/feed/server.js
index 2cf26a1..12ff850 100644
--- a/feed/server.js
+++ b/feed/server.js
@@ -1,12 +1,39 @@
+import { SimplePool } from 'nostr-tools/pool';
 import { startFeedCache } from './service.js';
 import { snapshotResponse } from './cache.js';
+import { NOTE_PATH, buildThread, createThreadCache, createIndexSource, notePageResponse } from './note-page.js';
 const cache = await startFeedCache();
+// SimplePool verifies signatures and matches filters before accepting events.
+const pool = new SimplePool();
+// Every relay's answer, or maxWait — but an ask by id is done the moment
+// every id has turned up, rather than waiting out the slowest relay.
+const query = (relays, filter, maxWait) => new Promise((resolve) => {
+  const got = new Map();
+  let done = false, sub = null;
+  const finish = () => { if (done) return; done = true; try { sub && sub.close(); } catch {} resolve([...got.values()]); };
+  sub = pool.subscribeManyEose(relays, filter, {
+    maxWait,
+    onevent(e) {
+      got.set(e.id, e);
+      if (filter.ids && filter.ids.every((id) => got.has(id))) finish();
+    },
+    onclose: finish,
+  });
+  if (done) try { sub.close(); } catch {}
+});
+const threads = createThreadCache({ build: (ref) => buildThread(ref, query) });
+const index = createIndexSource(process.env.INDEX_URL || 'http://bitcoin-wallet/index.html');
 const server = Bun.serve({
   hostname: process.env.HOST || '127.0.0.1',
   port: Number(process.env.PORT || 8792),
-  fetch(req) {
-    if (new URL(req.url).pathname !== '/api/feed') return new Response('Not found', { status: 404 });
-    return snapshotResponse(cache, req);
+  idleTimeout: 30,
+  async fetch(req) {
+    const path = new URL(req.url).pathname;
+    if (path === '/api/feed') return snapshotResponse(cache, req);
+    if (NOTE_PATH.test(path) && ['GET', 'HEAD'].includes(req.method)) {
+      try { return await notePageResponse(req, { index, threads }); } catch { return new Response('Unavailable', { status: 502 }); }
+    }
+    return new Response('Not found', { status: 404 });
   },
 });
 console.log(`Public feed cache listening on ${server.url}`);