diff options
Diffstat (limited to 'src/state/queries/post-feed.ts')
-rw-r--r-- | src/state/queries/post-feed.ts | 30 |
1 files changed, 27 insertions, 3 deletions
diff --git a/src/state/queries/post-feed.ts b/src/state/queries/post-feed.ts index d87beb779..209f1f544 100644 --- a/src/state/queries/post-feed.ts +++ b/src/state/queries/post-feed.ts @@ -232,7 +232,20 @@ function createApi( export function findPostInQueryData( queryClient: QueryClient, uri: string, -): AppBskyFeedDefs.FeedViewPost | undefined { +): AppBskyFeedDefs.PostView | undefined { + const generator = findAllPostsInQueryData(queryClient, uri) + const result = generator.next() + if (result.done) { + return undefined + } else { + return result.value + } +} + +export function* findAllPostsInQueryData( + queryClient: QueryClient, + uri: string, +): Generator<AppBskyFeedDefs.PostView, void> { const queryDatas = queryClient.getQueriesData< InfiniteData<FeedPageUnselected> >({ @@ -245,12 +258,23 @@ export function findPostInQueryData( for (const page of queryData?.pages) { for (const item of page.feed) { if (item.post.uri === uri) { - return item + yield item.post + } + if ( + AppBskyFeedDefs.isPostView(item.reply?.parent) && + item.reply?.parent?.uri === uri + ) { + yield item.reply.parent + } + if ( + AppBskyFeedDefs.isPostView(item.reply?.root) && + item.reply?.root?.uri === uri + ) { + yield item.reply.root } } } } - return undefined } function assertSomePostsPassModeration(feed: AppBskyFeedDefs.FeedViewPost[]) { |