Something went wrong. Try again.
An ATproto social media client -- with an independent Appview.
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253import { type Agent, type AppBskyFeedDefs, type AppBskyFeedGetPosts,} from '@atproto/api'
import {logger} from '#/logger'import {type FeedAPI, type FeedAPIResponse} from './types'
export class PostListFeedAPI implements FeedAPI { agent: Agent params: AppBskyFeedGetPosts.QueryParams peek: AppBskyFeedDefs.FeedViewPost | null = null
constructor({ agent, feedParams, }: { agent: Agent feedParams: AppBskyFeedGetPosts.QueryParams }) { this.agent = agent if (feedParams.uris.length > 25) { logger.warn( `Too many URIs provided - expected 25, got ${feedParams.uris.length}`, ) } this.params = { uris: feedParams.uris.slice(0, 25), } }
async peekLatest(): Promise<AppBskyFeedDefs.FeedViewPost> { if (this.peek) return this.peek throw new Error('Has not fetched yet') }
async fetch({}: {}): Promise<FeedAPIResponse> { const res = await this.agent.app.bsky.feed.getPosts({ ...this.params, }) if (res.success) { this.peek = {post: res.data.posts[0]} return { feed: res.data.posts.map(post => ({post})), } } return { feed: [], } }}