|
| 1 | +import type { BlogMetaResponse } from '#shared/schemas/atproto' |
| 2 | +import type { ResolvedAuthor } from '#shared/schemas/blog' |
| 3 | +import { type AtIdentifierString } from '@atproto/lex' |
| 4 | + |
| 5 | +// Input Interface |
| 6 | +export interface FederatedArticleInput { |
| 7 | + url: string |
| 8 | + authorHandle: string |
| 9 | +} |
| 10 | + |
| 11 | +// Output Interface |
| 12 | +export type ResolvedFederatedArticle = Omit<BlogMetaResponse, 'author' | '_meta'> & { |
| 13 | + url: string |
| 14 | + author: ResolvedAuthor |
| 15 | +} |
| 16 | + |
| 17 | +export async function useFederatedArticles( |
| 18 | + federatedArticles: FederatedArticleInput[], |
| 19 | +): Promise<ResolvedFederatedArticle[]> { |
| 20 | + if (!federatedArticles || federatedArticles.length === 0) return [] |
| 21 | + |
| 22 | + // 1. Prepare batch author request |
| 23 | + const authorQueryItems = federatedArticles.map(article => ({ |
| 24 | + name: article.authorHandle, |
| 25 | + blueskyHandle: article.authorHandle, |
| 26 | + })) |
| 27 | + |
| 28 | + // 2. Execute Fetches |
| 29 | + const [authorResponse, ...blogMetaResponses] = await Promise.all([ |
| 30 | + // Batch Author Fetch |
| 31 | + $fetch<{ authors: any[] }>('/api/atproto/bluesky-author-profiles', { |
| 32 | + query: { authors: JSON.stringify(authorQueryItems) }, |
| 33 | + }).catch(error => { |
| 34 | + console.error('Failed to fetch bluesky authors:', error) |
| 35 | + return { authors: [] } |
| 36 | + }), |
| 37 | + |
| 38 | + // Parallel Blog Meta Fetches |
| 39 | + ...federatedArticles.map(article => |
| 40 | + $fetch<BlogMetaResponse>('/api/atproto/blog-meta', { |
| 41 | + query: { url: article.url }, |
| 42 | + }).catch( |
| 43 | + () => |
| 44 | + ({ |
| 45 | + // Fallback if scraping fails |
| 46 | + title: 'Untitled Article', |
| 47 | + author: undefined, |
| 48 | + description: undefined, |
| 49 | + image: undefined, |
| 50 | + _meta: {}, |
| 51 | + _fetchedAt: '', |
| 52 | + }) as BlogMetaResponse, |
| 53 | + ), |
| 54 | + ), |
| 55 | + ]) |
| 56 | + |
| 57 | + // 3. Merge Data |
| 58 | + return federatedArticles.map((article, index) => { |
| 59 | + const meta = blogMetaResponses[index] |
| 60 | + const authorProfile = authorResponse?.authors?.[index] |
| 61 | + |
| 62 | + const resolvedAuthor: ResolvedAuthor = { |
| 63 | + name: meta?.author || authorProfile?.displayName || article.authorHandle, |
| 64 | + blueskyHandle: article.authorHandle as AtIdentifierString, |
| 65 | + avatar: authorProfile?.avatar || null, |
| 66 | + profileUrl: authorProfile?.profileUrl || null, |
| 67 | + } |
| 68 | + |
| 69 | + return { |
| 70 | + url: article.url, |
| 71 | + title: meta?.title || 'Untitled', |
| 72 | + description: meta?.description, |
| 73 | + image: meta?.image, |
| 74 | + author: resolvedAuthor, |
| 75 | + } |
| 76 | + }) |
| 77 | +} |
0 commit comments