highperfocused/nostrudel
1
0
Fork 0
mirror of https://github.com/hzrd149/nostrudel.git synced 2025-03-17 21:31:43 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix username autocomplete

Browse Source
This commit is contained in:
hzrd149 2024-11-16 15:18:31 -06:00
parent dd37773f25
commit 1fa3e6573f
2 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/services/page-api.ts
View File

@ -1,6 +1,7 @@
import accountService from "./account";
import channelMetadataService from "./channel-metadata";
import { eventStore, queryStore } from "./event-store";
import { localRelay } from "./local-relay";
import localSettings from "./local-settings";
import readStatusService from "./read-status";
import relayInfoService from "./relay-info";
@ -28,6 +29,12 @@ const noStrudel = {
/** Signing queue */
signingService,
/**
* Cache relay interface
* @type MemoryRelay|WasmRelay|CacheRelay|Relay|undefined
*/
cacheRelay: localRelay,
// other internal services
replaceableEventsService,
userSearchDirectory,

18
src/services/username-search.ts
View File

@ -1,17 +1,25 @@
import _throttle from "lodash.throttle";
import { kinds } from "nostr-tools";
import { from } from "rxjs";
import { filter, bufferTime, concatMap, mergeWith, reduce, shareReplay, map } from "rxjs/operators";
import { filter, bufferTime, concatMap, mergeWith, shareReplay, map, scan } from "rxjs/operators";
import { getProfileContent, isFromCache } from "applesauce-core/helpers";
import { getSearchNames } from "../helpers/nostr/user-metadata";
import db from "./db";
import { eventStore } from "./event-store";
import { logger } from "../helpers/debug";
export type UserDirectory = Record<string, string[]>;
export type SearchDirectory = { pubkey: string; names: string[] }[];
const cached = from(db.getAll("userSearch") as Promise<{ pubkey: string; names: string[] }[]>);
const log = logger.extend("UsernameSearch");
log(`Started loading profiles`);
const cache = db.getAll("userSearch").then((rows: { pubkey: string; names: string[] }[]) => {
log(`Loaded ${rows.length} profiles`);
return rows.reduce<UserDirectory>((dir, row) => ({ ...dir, [row.pubkey]: row.names }), {});
});
const updates = eventStore.stream([{ kinds: [kinds.Metadata] }]).pipe(
filter((event) => !isFromCache(event)),
bufferTime(500),
@ -28,14 +36,14 @@ const updates = eventStore.stream([{ kinds: [kinds.Metadata] }]).pipe(
}
transaction.commit();
await transaction.done;
log(`Updated ${events.length} profiles`);
return updates;
}),
);
export const userSearchDirectory = cached.pipe(
map((rows) => rows.reduce<UserDirectory>((dir, row) => ({ ...dir, [row.pubkey]: row.names }), {})),
export const userSearchDirectory = from(cache).pipe(
mergeWith(updates),
reduce((dir, updates) => ({ ...dir, ...updates })),
scan((dir, updates) => ({ ...dir, ...updates })),
map<UserDirectory, SearchDirectory>((dir) => Object.entries(dir).map(([pubkey, names]) => ({ pubkey, names }))),
shareReplay(1),
);