problem: can't debug bloom filter issue

src/lib/snort_workers/master_worker.ts

@@ -4,6 +4,7 @@ import { NostrSystem, RequestBuilder, type QueryLike } from '@snort/system';
 import { derived, writable } from 'svelte/store';
 import { Command, FrontendData, WorkerData } from './types';
 import { execTime, followsFromKind3, getNostrEvent, tagSplits, updateRepliesInPlace } from './utils';
+import { BloomFilter } from 'bloomfilter';
 
 let workerData = new WorkerData();
 let workerDataStore = writable(workerData);
@@ -33,7 +34,7 @@ workerDataStore.subscribe((data) => {
 	for (let r of data.roots) {
 		if (!data.ourBloom.test(r)) {
 			let re = data.events.get(r);
-			if (!r) {
+			if (!re) {
 				throw new Error('missing event, this should not happen, bug!');
 			}
 			roots.push(re!);
@@ -57,6 +58,8 @@ workerDataStore.subscribe((data) => {
 	});
 	fed.replies = data.replies;
 	fed.events = data.events;
+	fed._bloomString = JSON.stringify([].slice.call(data.ourBloom.buckets))
+	fed.ourBloom = data.ourBloom;//new BloomFilter(JSON.parse(fed._bloomString), 32)
 	postMessage(fed);
 	end()
 });
@@ -125,13 +128,17 @@ async function start(pubkey?: string, pubkeys?: string[]) {
 			let end = execTime("125 async start")
 			const rb = new RequestBuilder('fetch-initial-data');
 			let _pukeys: string[] = [];
+			let kinds = [3, 10002]
 			if (pubkeys) {
 				_pukeys = pubkeys;
 			}
 			if (pubkey) {
 				_pukeys.push(pubkey);
 			}
-			rb.withFilter().authors(_pukeys).kinds([3, 10002]);
+			if (pubkey && !pubkeys) {
+				kinds = [3, 10002, 1, 7]
+			}
+			rb.withFilter().authors(_pukeys).kinds(kinds);
 			rb.withOptions({ leaveOpen: false });
 
 			const _q = sys.Query(rb);

src/lib/snort_workers/types.ts

@@ -49,8 +49,8 @@ export class WorkerData {
 	constructor(pubkey?: string) {
 		this.bloomSize = 0;
 		this.ourBloom = new BloomFilter(
-			32 * 256, // bits to allocate.
-			16 // number of hashes
+			64 * 256, // bits to allocate.
+			32 // number of hashes
 		);
 		this.missingEvents = new Set();
 		this.latestReplaceable = new Map();
@@ -69,9 +69,9 @@ export class FrontendData {
 	replies: Map<string, Set<string>>;
 	baseFollows: Set<string>;
 	events: Map<string, NostrEvent>;
-	//ourBloom: BloomFilter;
+	ourBloom: BloomFilter | undefined;
+	_bloomString: string | undefined;
 	constructor() {
-		//this.ourBloom = new BloomFilter()
 		this.roots = [];
 		this.replies = new Map();
 		this.baseFollows = new Set();

src/lib/snort_workers/utils.ts

@@ -3,6 +3,8 @@ import type { TaggedNostrEvent } from '@snort/system';
 import type { Event } from 'nostr-tools';
 import { FrontendData, WorkerData } from './types';
 
+let debug = false
+
 export let execTime = (name: string): (() => void) => {
 	let start = performance.now();
 	let ended = false;
@@ -14,7 +16,10 @@ export let execTime = (name: string): (() => void) => {
 	return () => {
 		let end = performance.now();
 		ended = true;
-		console.log(name, end - start, 'ms');
+        if (debug) {
+            console.log(name, end - start, 'ms');
+        }
+
 	};
 };
 

src/lib/views/messages/Messages.svelte

@@ -14,6 +14,8 @@
 	import { updateRepliesInPlace } from '@/snort_workers/utils';
 	import Login from '@/ndk/Login.svelte';
 	import { currentUser } from '@/ndk/ndk';
+	import Input from '@/components/ui/input/input.svelte';
+	import { BloomFilter } from 'bloomfilter';
 
 	let localEvents = writable(new Map<string, NostrEvent>());
 
@@ -149,6 +151,8 @@
 		}
 		return inSet.has(id);
 	}
+
+	let eventID:string;
 </script>
 <div class=" hidden">{$shortListLength}</div>
 <ChatLayout hideFaucet={$threadParentID != 'root'}>
@@ -198,8 +202,21 @@
 				onClick={() => {
 					console.log($threadParentID, $FrontendDataStore.replies.get($threadParentID));
 				}}>Print root event data</Button
-			>
-			{$currentUser?.pubkey}
+			><br />
+			LOGGED IN AS: {$currentUser?.pubkey} <br />
+			<Input bind:value={eventID} class="w-64" /><Button onClick={()=>{
+				//let bloom = new BloomFilter(JSON.parse($FrontendDataStore._bloomString), 32)
+				console.log($FrontendDataStore.ourBloom)
+				if ($FrontendDataStore.ourBloom) {
+					console.log(210)
+					console.log(eventID)
+					$FrontendDataStore.ourBloom.add("t")
+					let result = $FrontendDataStore.ourBloom.test(eventID)
+					console.log(213)
+					console.log(214, result)
+				}
+				}}>Check if event is in bloom filter</Button><br />
+			{$FrontendDataStore.ourBloom?.buckets.byteLength}
 		</div>
 	</div>
 </ChatLayout>