From 5e834d2a6b859b77bd08b959f10540575fe47654 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Tue, 2 Apr 2024 19:53:11 -0500
Subject: [PATCH] pipeline: remove broadcast function

---
 src/pipeline.ts | 19 +------------------
 1 file changed, 1 insertion(+), 18 deletions(-)

diff --git a/src/pipeline.ts b/src/pipeline.ts
index 1c7a891..8ab6b89 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -9,7 +9,7 @@ import { isEphemeralKind } from '@/kinds.ts';
 import { DVM } from '@/pipeline/DVM.ts';
 import { updateStats } from '@/stats.ts';
 import { hydrateEvents, purifyEvent } from '@/storages/hydrate.ts';
-import { cache, client, eventsDB, reqmeister } from '@/storages.ts';
+import { cache, eventsDB, reqmeister } from '@/storages.ts';
 import { Sub } from '@/subs.ts';
 import { getTagSet } from '@/tags.ts';
 import { eventAge, isRelay, nostrDate, nostrNow, parseNip05, Time } from '@/utils.ts';
@@ -43,7 +43,6 @@ async function handleEvent(event: DittoEvent, signal: AbortSignal): Promise<void
     processMedia(event),
     payZap(event, signal),
     streamOut(event),
-    broadcast(event, signal),
   ]);
 }
 
@@ -257,22 +256,6 @@ function streamOut(event: NostrEvent) {
   }
 }
 
-/**
- * Publish the event to other relays.
- * This should only be done in certain circumstances, like mentioning a user or publishing deletions.
- */
-async function broadcast(event: DittoEvent, signal: AbortSignal) {
-  if (!event.user || !isFresh(event)) return;
-
-  if (event.kind === 5) {
-    try {
-      await client.event(event, { signal });
-    } catch (e) {
-      debug(e);
-    }
-  }
-}
-
 /** NIP-20 command line result. */
 class RelayError extends Error {
   constructor(prefix: 'duplicate' | 'pow' | 'blocked' | 'rate-limited' | 'invalid' | 'error', message: string) {