import { BIG_RELAY_URLS, ExtendedKind } from '@/constants' import client from '@/services/client.service' import { TEmoji, TImageInfo, TRelayList, TRelaySet } from '@/types' import { LRUCache } from 'lru-cache' import { Event, kinds, nip19 } from 'nostr-tools' import { getAmountFromInvoice, getLightningAddressFromProfile } from './lightning' import { formatPubkey, pubkeyToNpub } from './pubkey' import { extractImageInfoFromTag, generateEventIdFromATag, generateEventIdFromETag, isReplyETag, isRootETag, tagNameEquals } from './tag' import { isWebsocketUrl, normalizeHttpUrl, normalizeUrl } from './url' import { isTorBrowser } from './utils' const EVENT_EMBEDDED_EVENT_IDS_CACHE = new LRUCache({ max: 10000 }) const EVENT_IS_REPLY_NOTE_CACHE = new LRUCache({ max: 10000 }) export function isNsfwEvent(event: Event) { return event.tags.some( ([tagName, tagValue]) => tagName === 'content-warning' || (tagName === 't' && tagValue.toLowerCase() === 'nsfw') ) } export function isReplyNoteEvent(event: Event) { if (event.kind === ExtendedKind.COMMENT) { return !!getParentEventTag(event) || !!getParentAddressableEventTag(event) } if (event.kind !== kinds.ShortTextNote) return false const cache = EVENT_IS_REPLY_NOTE_CACHE.get(event.id) if (cache !== undefined) return cache const mentionsEventIds: string[] = [] for (const [tagName, id, , marker] of event.tags) { if (tagName === 'a' && id) { EVENT_IS_REPLY_NOTE_CACHE.set(event.id, true) return true } if (tagName !== 'e' || !id) continue mentionsEventIds.push(id) if (['root', 'reply'].includes(marker)) { EVENT_IS_REPLY_NOTE_CACHE.set(event.id, true) return true } } const embeddedEventIds = extractEmbeddedEventIds(event) const result = mentionsEventIds.some((id) => !embeddedEventIds.includes(id)) EVENT_IS_REPLY_NOTE_CACHE.set(event.id, result) return result } export function isCommentEvent(event: Event) { return event.kind === ExtendedKind.COMMENT } export function isPictureEvent(event: Event) { return event.kind === ExtendedKind.PICTURE } export function isProtectedEvent(event: Event) { return event.tags.some(([tagName]) => tagName === '-') } export function getParentEventTag(event?: Event) { if (!event || ![kinds.ShortTextNote, ExtendedKind.COMMENT].includes(event.kind)) return undefined if (event.kind === ExtendedKind.COMMENT) { return event.tags.find(tagNameEquals('e')) ?? event.tags.find(tagNameEquals('E')) } let tag = event.tags.find(isReplyETag) if (!tag) { const embeddedEventIds = extractEmbeddedEventIds(event) tag = event.tags.findLast( ([tagName, tagValue]) => tagName === 'e' && !!tagValue && !embeddedEventIds.includes(tagValue) ) } return tag } export function getParentAddressableEventTag(event?: Event) { if (!event || ![kinds.ShortTextNote, ExtendedKind.COMMENT].includes(event.kind)) return undefined return event.tags.find(tagNameEquals('a')) ?? event.tags.find(tagNameEquals('A')) } export function getParentEventHexId(event?: Event) { const tag = getParentEventTag(event) return tag?.[1] } export function getParentEventId(event?: Event) { const eTag = getParentEventTag(event) if (!eTag) { const aTag = getParentAddressableEventTag(event) if (!aTag) return undefined return generateEventIdFromATag(aTag) } return generateEventIdFromETag(eTag) } export function getRootEventTag(event?: Event) { if (!event || ![kinds.ShortTextNote, ExtendedKind.COMMENT].includes(event.kind)) return undefined if (event.kind === ExtendedKind.COMMENT) { return event.tags.find(tagNameEquals('E')) } let tag = event.tags.find(isRootETag) if (!tag) { const embeddedEventIds = extractEmbeddedEventIds(event) tag = event.tags.find( ([tagName, tagValue]) => tagName === 'e' && !!tagValue && !embeddedEventIds.includes(tagValue) ) } return tag } export function getRootAddressableEventTag(event?: Event) { if (!event || event.kind !== ExtendedKind.COMMENT) return undefined return event.tags.find(tagNameEquals('A')) } export function getRootEventHexId(event?: Event) { const tag = getRootEventTag(event) return tag?.[1] } export function getRootEventId(event?: Event) { const tag = getRootEventTag(event) if (!tag) { const aTag = getRootAddressableEventTag(event) if (!aTag) return undefined return generateEventIdFromATag(aTag) } return generateEventIdFromETag(tag) } export function isReplaceable(kind: number) { return kinds.isReplaceableKind(kind) || kinds.isAddressableKind(kind) } export function getEventCoordinate(event: Event) { const d = event.tags.find(tagNameEquals('d'))?.[1] return d ? `${event.kind}:${event.pubkey}:${d}` : `${event.kind}:${event.pubkey}` } export function getSharableEventId(event: Event) { const hints = client.getEventHints(event.id).slice(0, 2) if (isReplaceable(event.kind)) { const identifier = event.tags.find(tagNameEquals('d'))?.[1] ?? '' return nip19.naddrEncode({ pubkey: event.pubkey, kind: event.kind, identifier, relays: hints }) } return nip19.neventEncode({ id: event.id, author: event.pubkey, kind: event.kind, relays: hints }) } export function getUsingClient(event: Event) { return event.tags.find(tagNameEquals('client'))?.[1] } export function getRelayListFromRelayListEvent(event?: Event) { if (!event) { return { write: BIG_RELAY_URLS, read: BIG_RELAY_URLS, originalRelays: [] } } const torBrowserDetected = isTorBrowser() const relayList = { write: [], read: [], originalRelays: [] } as TRelayList event.tags.filter(tagNameEquals('r')).forEach(([, url, type]) => { if (!url || !isWebsocketUrl(url)) return const normalizedUrl = normalizeUrl(url) if (!normalizedUrl) return const scope = type === 'read' ? 'read' : type === 'write' ? 'write' : 'both' relayList.originalRelays.push({ url: normalizedUrl, scope }) // Filter out .onion URLs if not using Tor browser if (normalizedUrl.endsWith('.onion/') && !torBrowserDetected) return if (type === 'write') { relayList.write.push(normalizedUrl) } else if (type === 'read') { relayList.read.push(normalizedUrl) } else { relayList.write.push(normalizedUrl) relayList.read.push(normalizedUrl) } }) // If there are too many relays, use the default BIG_RELAY_URLS // Because they don't know anything about relays, their settings cannot be trusted return { write: relayList.write.length && relayList.write.length <= 8 ? relayList.write : BIG_RELAY_URLS, read: relayList.read.length && relayList.write.length <= 8 ? relayList.read : BIG_RELAY_URLS, originalRelays: relayList.originalRelays } } export function getProfileFromProfileEvent(event: Event) { try { const profileObj = JSON.parse(event.content) const username = profileObj.display_name?.trim() || profileObj.name?.trim() || profileObj.nip05?.split('@')[0]?.trim() return { pubkey: event.pubkey, npub: pubkeyToNpub(event.pubkey) ?? '', banner: profileObj.banner, avatar: profileObj.picture, username: username || formatPubkey(event.pubkey), original_username: username, nip05: profileObj.nip05, about: profileObj.about, website: profileObj.website ? normalizeHttpUrl(profileObj.website) : undefined, lud06: profileObj.lud06, lud16: profileObj.lud16, lightningAddress: getLightningAddressFromProfile(profileObj), created_at: event.created_at } } catch (err) { console.error(err) return { pubkey: event.pubkey, npub: pubkeyToNpub(event.pubkey) ?? '', username: formatPubkey(event.pubkey) } } } export function getRelaySetFromRelaySetEvent(event: Event): TRelaySet { const id = getReplaceableEventIdentifier(event) const relayUrls = event.tags .filter(tagNameEquals('relay')) .map((tag) => tag[1]) .filter((url) => url && isWebsocketUrl(url)) .map((url) => normalizeUrl(url)) let name = event.tags.find(tagNameEquals('title'))?.[1] if (!name) { name = id } return { id, name, relayUrls } } export async function extractMentions(content: string, parentEvent?: Event) { const parentEventPubkey = parentEvent ? parentEvent.pubkey : undefined const pubkeys: string[] = [] const relatedPubkeys: string[] = [] const matches = content.match( /nostr:(npub1[a-z0-9]{58}|nprofile1[a-z0-9]+|note1[a-z0-9]{58}|nevent1[a-z0-9]+)/g ) const addToSet = (arr: string[], pubkey: string) => { if (pubkey === parentEventPubkey) return if (!arr.includes(pubkey)) arr.push(pubkey) } for (const m of matches || []) { try { const id = m.split(':')[1] const { type, data } = nip19.decode(id) if (type === 'nprofile') { addToSet(pubkeys, data.pubkey) } else if (type === 'npub') { addToSet(pubkeys, data) } else if (['nevent', 'note'].includes(type)) { const event = await client.fetchEvent(id) if (event) { addToSet(pubkeys, event.pubkey) } } } catch (e) { console.error(e) } } if (parentEvent) { parentEvent.tags.forEach(([tagName, tagValue]) => { if (['p', 'P'].includes(tagName) && !!tagValue) { addToSet(relatedPubkeys, tagValue) } }) } return { pubkeys, relatedPubkeys: relatedPubkeys.filter((p) => !pubkeys.includes(p)), parentEventPubkey } } export async function extractRelatedEventIds(content: string, parentEvent?: Event) { const quoteEventIds: string[] = [] let rootETag: string[] = [] let parentETag: string[] = [] const matches = content.match(/nostr:(note1[a-z0-9]{58}|nevent1[a-z0-9]+)/g) const addToSet = (arr: string[], item: string) => { if (!arr.includes(item)) arr.push(item) } for (const m of matches || []) { try { const id = m.split(':')[1] const { type, data } = nip19.decode(id) if (type === 'nevent') { addToSet(quoteEventIds, data.id) } else if (type === 'note') { addToSet(quoteEventIds, data) } } catch (e) { console.error(e) } } if (parentEvent) { const rootEventTag = getRootEventTag(parentEvent) if (rootEventTag) { parentETag = [ 'e', parentEvent.id, client.getEventHint(parentEvent.id), 'reply', parentEvent.pubkey ] const [, rootEventHexId, hint, , rootEventPubkey] = rootEventTag if (rootEventPubkey) { rootETag = [ 'e', rootEventHexId, hint ?? client.getEventHint(rootEventHexId), 'root', rootEventPubkey ] } else { const rootEventId = generateEventIdFromETag(rootEventTag) const rootEvent = rootEventId ? await client.fetchEvent(rootEventId) : undefined rootETag = rootEvent ? ['e', rootEvent.id, hint ?? client.getEventHint(rootEvent.id), 'root', rootEvent.pubkey] : ['e', rootEventHexId, hint ?? client.getEventHint(rootEventHexId), 'root'] } } else { // reply to root event rootETag = [ 'e', parentEvent.id, client.getEventHint(parentEvent.id), 'root', parentEvent.pubkey ] } } return { quoteEventIds, rootETag, parentETag } } export async function extractCommentMentions(content: string, parentEvent: Event) { const quoteEventIds: string[] = [] const parentEventIsReplaceable = isReplaceable(parentEvent.kind) const rootCoordinateTag = parentEvent.kind === ExtendedKind.COMMENT ? parentEvent.tags.find(tagNameEquals('A')) : isReplaceable(parentEvent.kind) ? ['A', getEventCoordinate(parentEvent), client.getEventHint(parentEvent.id)] : undefined const rootEventId = parentEvent.kind === ExtendedKind.COMMENT ? parentEvent.tags.find(tagNameEquals('E'))?.[1] : parentEvent.id const rootKind = parentEvent.kind === ExtendedKind.COMMENT ? parentEvent.tags.find(tagNameEquals('K'))?.[1] : parentEvent.kind const rootPubkey = parentEvent.kind === ExtendedKind.COMMENT ? parentEvent.tags.find(tagNameEquals('P'))?.[1] : parentEvent.pubkey const rootUrl = parentEvent.kind === ExtendedKind.COMMENT ? parentEvent.tags.find(tagNameEquals('I'))?.[1] : undefined const parentEventId = parentEvent.id const parentCoordinate = parentEventIsReplaceable ? getEventCoordinate(parentEvent) : undefined const parentKind = parentEvent.kind const parentPubkey = parentEvent.pubkey const addToSet = (arr: string[], item: string) => { if (!arr.includes(item)) arr.push(item) } const matches = content.match(/nostr:(note1[a-z0-9]{58}|nevent1[a-z0-9]+)/g) for (const m of matches || []) { try { const id = m.split(':')[1] const { type, data } = nip19.decode(id) if (type === 'nevent') { addToSet(quoteEventIds, data.id) } else if (type === 'note') { addToSet(quoteEventIds, data) } } catch (e) { console.error(e) } } return { quoteEventIds, rootEventId, rootCoordinateTag, rootKind, rootPubkey, rootUrl, parentEventId, parentCoordinate, parentKind, parentPubkey } } export function extractHashtags(content: string) { const hashtags: string[] = [] const matches = content.match(/#[\p{L}\p{N}\p{M}]+/gu) matches?.forEach((m) => { const hashtag = m.slice(1).toLowerCase() if (hashtag) { hashtags.push(hashtag) } }) return hashtags } export function extractImageInfosFromEventTags(event: Event) { const images: TImageInfo[] = [] event.tags.forEach((tag) => { const imageInfo = extractImageInfoFromTag(tag) if (imageInfo) { images.push(imageInfo) } }) return images } export function extractImagesFromContent(content: string) { const images = content.match(/https?:\/\/[^\s"']+\.(jpg|jpeg|png|gif|webp|heic)/gi) let contentWithoutImages = content images?.forEach((url) => { contentWithoutImages = contentWithoutImages.replace(url, '').trim() }) contentWithoutImages = contentWithoutImages.replace(/\n{3,}/g, '\n\n').trim() return { images, contentWithoutImages } } export function extractEmbeddedNotesFromContent(content: string) { let c = content const embeddedNotes: string[] = [] const embeddedNoteRegex = /nostr:(note1[a-z0-9]{58}|nevent1[a-z0-9]+|naddr1[a-z0-9]+)/g ;(c.match(embeddedNoteRegex) || []).forEach((note) => { c = c.replace(note, '').trim() embeddedNotes.push(note) }) c = c.replace(/\n{3,}/g, '\n\n').trim() return { embeddedNotes, contentWithoutEmbeddedNotes: c } } export function extractZapInfoFromReceipt(receiptEvent: Event) { if (receiptEvent.kind !== kinds.Zap) return null let senderPubkey: string | undefined let recipientPubkey: string | undefined let originalEventId: string | undefined let eventId: string | undefined let invoice: string | undefined let amount: number | undefined let comment: string | undefined let description: string | undefined let preimage: string | undefined try { receiptEvent.tags.forEach((tag) => { const [tagName, tagValue] = tag switch (tagName) { case 'P': senderPubkey = tagValue break case 'p': recipientPubkey = tagValue break case 'e': originalEventId = tag[1] eventId = generateEventIdFromETag(tag) break case 'bolt11': invoice = tagValue break case 'description': description = tagValue break case 'preimage': preimage = tagValue break } }) if (!recipientPubkey || !invoice) return null amount = invoice ? getAmountFromInvoice(invoice) : 0 if (description) { try { const zapRequest = JSON.parse(description) comment = zapRequest.content if (!senderPubkey) { senderPubkey = zapRequest.pubkey } } catch { // ignore } } return { senderPubkey, recipientPubkey, eventId, originalEventId, invoice, amount, comment, preimage } } catch { return null } } export function extractEmbeddedEventIds(event: Event) { const cache = EVENT_EMBEDDED_EVENT_IDS_CACHE.get(event.id) if (cache) return cache const embeddedEventIds: string[] = [] const embeddedNoteRegex = /nostr:(note1[a-z0-9]{58}|nevent1[a-z0-9]+)/g ;(event.content.match(embeddedNoteRegex) || []).forEach((note) => { try { const { type, data } = nip19.decode(note.split(':')[1]) if (type === 'nevent') { embeddedEventIds.push(data.id) } else if (type === 'note') { embeddedEventIds.push(data) } } catch { // ignore } }) EVENT_EMBEDDED_EVENT_IDS_CACHE.set(event.id, embeddedEventIds) return embeddedEventIds } export function getLatestEvent(events: Event[]) { return events.sort((a, b) => b.created_at - a.created_at)[0] } export function getReplaceableEventIdentifier(event: Event) { return event.tags.find(tagNameEquals('d'))?.[1] ?? '' } export function extractEmojiInfosFromTags(tags: string[][] = []) { return tags .map((tag) => { if (tag.length < 3 || tag[0] !== 'emoji') return null return { shortcode: tag[1], url: tag[2] } }) .filter(Boolean) as TEmoji[] } export function createFakeEvent(event: Partial): Event { return { id: '', kind: 1, pubkey: '', content: '', created_at: 0, tags: [], sig: '', ...event } } export function getLongFormArticleMetadata(event: Event) { let title: string | undefined let summary: string | undefined let image: string | undefined const tags = new Set() event.tags.forEach(([tagName, tagValue]) => { if (tagName === 'title') { title = tagValue } else if (tagName === 'summary') { summary = tagValue } else if (tagName === 'image') { image = tagValue } else if (tagName === 't' && tagValue && tags.size < 6) { tags.add(tagValue.toLocaleLowerCase()) } }) if (!title) { title = event.tags.find(tagNameEquals('d'))?.[1] ?? 'no title' } return { title, summary, image, tags: Array.from(tags) } } export function getLiveEventMetadata(event: Event) { let title: string | undefined let summary: string | undefined let image: string | undefined let status: string | undefined const tags = new Set() event.tags.forEach(([tagName, tagValue]) => { if (tagName === 'title') { title = tagValue } else if (tagName === 'summary') { summary = tagValue } else if (tagName === 'image') { image = tagValue } else if (tagName === 'status') { status = tagValue } else if (tagName === 't' && tagValue && tags.size < 6) { tags.add(tagValue.toLocaleLowerCase()) } }) if (!title) { title = event.tags.find(tagNameEquals('d'))?.[1] ?? 'no title' } return { title, summary, image, status, tags: Array.from(tags) } } export function getGroupMetadata(event: Event) { let d: string | undefined let name: string | undefined let about: string | undefined let picture: string | undefined const tags = new Set() event.tags.forEach(([tagName, tagValue]) => { if (tagName === 'name') { name = tagValue } else if (tagName === 'about') { about = tagValue } else if (tagName === 'picture') { picture = tagValue } else if (tagName === 't' && tagValue) { tags.add(tagValue.toLocaleLowerCase()) } else if (tagName === 'd') { d = tagValue } }) if (!name) { name = d ?? 'no name' } return { d, name, about, picture, tags: Array.from(tags) } } export function getCommunityDefinition(event: Event) { let name: string | undefined let description: string | undefined let image: string | undefined event.tags.forEach(([tagName, tagValue]) => { if (tagName === 'name') { name = tagValue } else if (tagName === 'description') { description = tagValue } else if (tagName === 'image') { image = tagValue } }) if (!name) { name = event.tags.find(tagNameEquals('d'))?.[1] ?? 'no name' } return { name, description, image } }