reya/lume
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add instant zap

Browse Source
This commit is contained in:
reya
2024-01-18 13:56:35 +07:00
parent 240fe8bc7c
commit 0e9418949b
15 changed files with 809 additions and 341 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
packages/ark/src/ark.ts
View File

@@ -305,9 +305,7 @@ export class Ark {
public async getThreads(id: string) {
const eventId = this.getCleanEventId(id);
const fetcher = NostrFetcher.withCustomPool(ndkAdapter(this.ndk));
const relayUrls = [...this.ndk.pool.relays.values()].map(
(item) => item.url,
);
const relayUrls = Array.from(this.ndk.pool.relays.keys());
try {
const rawEvents = (await fetcher.fetchAllEvents(
@@ -357,9 +355,7 @@ export class Ark {
public async getAllRelaysFromContacts({ signal }: { signal: AbortSignal }) {
const fetcher = NostrFetcher.withCustomPool(ndkAdapter(this.ndk));
const connectedRelays = this.ndk.pool
.connectedRelays()
.map((item) => item.url);
const connectedRelays = Array.from(this.ndk.pool.relays.keys());
try {
const relayMap = new Map<string, string[]>();
@@ -373,8 +369,6 @@ export class Ark {
{ abortSignal: signal },
);
console.log(relayEvents);
for await (const { author, events } of relayEvents) {
if (events.length) {
const relayTags = events[0].tags.filter((item) => item[0] === "r");
@@ -411,9 +405,7 @@ export class Ark {
dedup?: boolean;
}) {
const fetcher = NostrFetcher.withCustomPool(ndkAdapter(this.ndk));
const relayUrls = [...this.ndk.pool.relays.values()].map(
(item) => item.url,
);
const relayUrls = Array.from(this.ndk.pool.relays.keys());
const seenIds = new Set<string>();
const dedupQueue = new Set<string>();