mirror of
https://github.com/dergigi/boris.git
synced 2026-02-16 12:34:41 +01:00
fddf79e0c6
- Create src/config/kinds.ts with named Nostr kind constants - Add streaming support to fetchAllReads and fetchLinks with onItem callbacks - Update all services to use KINDS constants instead of magic numbers - Add mergeReadItem utility for DRY state management - Add fallbackTitleFromUrl for external links without titles - Relax validation to allow external items without titles - Update Me.tsx to use streaming with Map-based state for reads/links - Fix refresh to merge new data instead of clearing state - Fix empty states for Reads and Links tabs (no more infinite skeletons) - Services updated: readsService, linksService, libraryService, bookmarkService, exploreService, highlights/fetchByAuthor
102 lines
3.2 KiB
TypeScript
102 lines
3.2 KiB
TypeScript
import { RelayPool } from 'applesauce-relay'
|
|
import { NostrEvent } from 'nostr-tools'
|
|
import { Helpers } from 'applesauce-core'
|
|
import { queryEvents } from './dataFetch'
|
|
import { KINDS } from '../config/kinds'
|
|
|
|
const { getArticleTitle, getArticleImage, getArticlePublished, getArticleSummary } = Helpers
|
|
|
|
export interface BlogPostPreview {
|
|
event: NostrEvent
|
|
title: string
|
|
summary?: string
|
|
image?: string
|
|
published?: number
|
|
author: string
|
|
}
|
|
|
|
/**
|
|
* Fetches blog posts (kind:30023) from a list of pubkeys (friends)
|
|
* @param relayPool - The relay pool to query
|
|
* @param pubkeys - Array of pubkeys to fetch posts from
|
|
* @param relayUrls - Array of relay URLs to query
|
|
* @returns Array of blog post previews
|
|
*/
|
|
export const fetchBlogPostsFromAuthors = async (
|
|
relayPool: RelayPool,
|
|
pubkeys: string[],
|
|
relayUrls: string[],
|
|
onPost?: (post: BlogPostPreview) => void
|
|
): Promise<BlogPostPreview[]> => {
|
|
try {
|
|
if (pubkeys.length === 0) {
|
|
console.log('⚠️ No pubkeys to fetch blog posts from')
|
|
return []
|
|
}
|
|
|
|
console.log('📚 Fetching blog posts (kind 30023) from', pubkeys.length, 'authors')
|
|
|
|
// Deduplicate replaceable events by keeping the most recent version
|
|
// Group by author + d-tag identifier
|
|
const uniqueEvents = new Map<string, NostrEvent>()
|
|
|
|
await queryEvents(
|
|
relayPool,
|
|
{ kinds: [KINDS.BlogPost], authors: pubkeys, limit: 100 },
|
|
{
|
|
relayUrls,
|
|
onEvent: (event: NostrEvent) => {
|
|
const dTag = event.tags.find(t => t[0] === 'd')?.[1] || ''
|
|
const key = `${event.pubkey}:${dTag}`
|
|
const existing = uniqueEvents.get(key)
|
|
if (!existing || event.created_at > existing.created_at) {
|
|
uniqueEvents.set(key, event)
|
|
// Emit as we incorporate
|
|
if (onPost) {
|
|
const post: BlogPostPreview = {
|
|
event,
|
|
title: getArticleTitle(event) || 'Untitled',
|
|
summary: getArticleSummary(event),
|
|
image: getArticleImage(event),
|
|
published: getArticlePublished(event),
|
|
author: event.pubkey
|
|
}
|
|
onPost(post)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
)
|
|
|
|
console.log('📊 Blog post events fetched (unique):', uniqueEvents.size)
|
|
|
|
// Convert to blog post previews and sort by published date (most recent first)
|
|
const blogPosts: BlogPostPreview[] = Array.from(uniqueEvents.values())
|
|
.map(event => {
|
|
const post: BlogPostPreview = {
|
|
event,
|
|
title: getArticleTitle(event) || 'Untitled',
|
|
summary: getArticleSummary(event),
|
|
image: getArticleImage(event),
|
|
published: getArticlePublished(event),
|
|
author: event.pubkey
|
|
}
|
|
if (onPost) onPost(post)
|
|
return post
|
|
})
|
|
.sort((a, b) => {
|
|
const timeA = a.published || a.event.created_at
|
|
const timeB = b.published || b.event.created_at
|
|
return timeB - timeA // Most recent first
|
|
})
|
|
|
|
console.log('📰 Processed', blogPosts.length, 'unique blog posts')
|
|
|
|
return blogPosts
|
|
} catch (error) {
|
|
console.error('Failed to fetch blog posts:', error)
|
|
return []
|
|
}
|
|
}
|
|
|