Something went wrong. Try again.
Bluesky app fork with some witchin' additions 💫
Something went wrong. Try again.
13 kB · 389 lines
TypeScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390import {useCallback} from 'react'import { type $Typed, type AppBskyActorDefs, type AppBskyFeedDefs, AppBskyUnspeccedDefs, type AppBskyUnspeccedGetPostThreadOtherV2, type AppBskyUnspeccedGetPostThreadV2, AtUri,} from '@atproto/api'import {type QueryClient, useQueryClient} from '@tanstack/react-query'
import { dangerousGetPostShadow, updatePostShadow,} from '#/state/cache/post-shadow'import {findAllPostsInQueryData as findAllPostsInBookmarksQueryData} from '#/state/queries/bookmarks/useBookmarksQuery'import {findAllPostsInQueryData as findAllPostsInExploreFeedPreviewsQueryData} from '#/state/queries/explore-feed-previews'import {findAllPostsInQueryData as findAllPostsInNotifsQueryData} from '#/state/queries/notifications/feed'import {findAllPostsInQueryData as findAllPostsInPostQueryData} from '#/state/queries/post'import {findAllPostsInQueryData as findAllPostsInAlsoLikedQueryData} from '#/state/queries/post-also-liked'import {findAllPostsInQueryData as findAllPostsInFeedQueryData} from '#/state/queries/post-feed'import {findAllPostsInQueryData as findAllPostsInQuoteQueryData} from '#/state/queries/post-quotes'import {findAllPostsInQueryData as findAllPostsInSearchQueryData} from '#/state/queries/search-posts-v2'import {usePostThreadContext} from '#/state/queries/usePostThread'import {getBranch} from '#/state/queries/usePostThread/traversal'import { type ApiThreadItem, type createPostThreadOtherQueryKey, type createPostThreadQueryKey, type PostThreadParams, postThreadQueryKeyRoot,} from '#/state/queries/usePostThread/types'import {getRootPostAtUri} from '#/state/queries/usePostThread/utils'import {postViewToThreadPlaceholder} from '#/state/queries/usePostThread/views'import { didOrHandleUriMatches, embedViewRecordToPostView, getEmbeddedPost,} from '#/state/queries/util'
export function createCacheMutator({ queryClient, postThreadQueryKey, postThreadOtherQueryKey, params,}: { queryClient: QueryClient postThreadQueryKey: ReturnType<typeof createPostThreadQueryKey> postThreadOtherQueryKey: ReturnType<typeof createPostThreadOtherQueryKey> params: Pick<PostThreadParams, 'view'> & {below: number}}) { return { insertReplies( parentUri: string, replies: AppBskyUnspeccedGetPostThreadV2.ThreadItem[], ) { /* * Main thread query mutator. */ queryClient.setQueryData<AppBskyUnspeccedGetPostThreadV2.OutputSchema>( postThreadQueryKey, data => { if (!data) return return { ...data, thread: mutator<AppBskyUnspeccedGetPostThreadV2.ThreadItem>([ ...data.thread, ]), } }, )
/* * Additional replies query mutator. */ queryClient.setQueryData<AppBskyUnspeccedGetPostThreadOtherV2.OutputSchema>( postThreadOtherQueryKey, data => { if (!data) return return { ...data, thread: mutator<AppBskyUnspeccedGetPostThreadOtherV2.ThreadItem>([ ...data.thread, ]), } }, )
function mutator<T>(thread: ApiThreadItem[]): T[] { for (let i = 0; i < thread.length; i++) { const parent = thread[i]
if (!AppBskyUnspeccedDefs.isThreadItemPost(parent.value)) continue if (parent.uri !== parentUri) continue
/* * Update parent data */ const shadow = dangerousGetPostShadow(parent.value.post) const prevOptimisticCount = shadow?.optimisticReplyCount const prevReplyCount = parent.value.post.replyCount // prefer optimistic count, if we already have some const currentReplyCount = (prevOptimisticCount ?? prevReplyCount ?? 0) + 1
/* * We must update the value in the query cache in order for thread * traversal to properly compute required metadata. */ parent.value.post.replyCount = currentReplyCount
/** * Additionally, we need to update the post shadow to keep track of * these new values, since mutating the post object above does not * cause a re-render. */ updatePostShadow(queryClient, parent.value.post.uri, { optimisticReplyCount: currentReplyCount, })
const opDid = getRootPostAtUri(parent.value.post)?.host const nextPreexistingItem = thread.at(i + 1) const isEndOfReplyChain = !nextPreexistingItem || nextPreexistingItem.depth <= parent.depth const isParentRoot = parent.depth === 0 const isParentBelowRoot = parent.depth > 0 const optimisticReply = replies.at(0) const opIsReplier = AppBskyUnspeccedDefs.isThreadItemPost( optimisticReply?.value, ) ? opDid === optimisticReply.value.post.author.did : false
/* * Always insert replies if the following conditions are met. Max * depth checks are handled below. */ const canAlwaysInsertReplies = isParentRoot || (params.view === 'tree' && isParentBelowRoot) || (params.view === 'linear' && isEndOfReplyChain) /* * Maybe insert replies if we're in linear view, the replier is the * OP, and certain conditions are met */ const shouldReplaceWithOPReplies = params.view === 'linear' && opIsReplier && isParentBelowRoot
if (canAlwaysInsertReplies || shouldReplaceWithOPReplies) { const branch = getBranch(thread, i, parent.depth) /* * OP insertions replace other replies _in linear view_. */ const itemsToRemove = shouldReplaceWithOPReplies ? branch.length : 0 const itemsToInsert = replies .map((r, ri) => { r.depth = parent.depth + 1 + ri return r }) .filter(r => { // Filter out replies that are too deep for our UI return r.depth <= params.below })
thread.splice(i + 1, itemsToRemove, ...itemsToInsert) } }
return thread as T[] } }, /** * Unused atm, post shadow does the trick, but it would be nice to clean up * the whole sub-tree on deletes. */ deletePost(post: AppBskyUnspeccedGetPostThreadV2.ThreadItem) { queryClient.setQueryData<AppBskyUnspeccedGetPostThreadV2.OutputSchema>( postThreadQueryKey, queryData => { if (!queryData) return
const thread = [...queryData.thread]
for (let i = 0; i < thread.length; i++) { const existingPost = thread[i] if (!AppBskyUnspeccedDefs.isThreadItemPost(post.value)) continue
if (existingPost.uri === post.uri) { const branch = getBranch(thread, i, existingPost.depth) thread.splice(branch.start, branch.length) break } }
return { ...queryData, thread, } }, ) }, }}
export function getThreadPlaceholder( queryClient: QueryClient, uri: string,): $Typed<AppBskyUnspeccedGetPostThreadV2.ThreadItem> | void { let partial for (let item of getThreadPlaceholderCandidates(queryClient, uri)) { /* * Currently, the backend doesn't send full post info in some cases (for * example, for quoted posts). We use missing `likeCount` as a way to * detect that. In the future, we should fix this on the backend, which * will let us always stop on the first result. * * TODO can we send in feeds and quotes? */ const hasAllInfo = item.value.post.likeCount != null if (hasAllInfo) { return item } else { // Keep searching, we might still find a full post in the cache. partial = item } } return partial}
export function* getThreadPlaceholderCandidates( queryClient: QueryClient, uri: string,): Generator< $Typed< Omit<AppBskyUnspeccedGetPostThreadV2.ThreadItem, 'value'> & { value: $Typed<AppBskyUnspeccedDefs.ThreadItemPost> } >, void> { /* * Check post thread queries first */ for (const post of findAllPostsInQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) }
/* * Check notifications first. If you have a post in notifications, it's * often due to a like or a repost, and we want to prioritize a post object * with >0 likes/reposts over a stale version with no metrics in order to * avoid a notification->post scroll jump. */ for (let post of findAllPostsInNotifsQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInFeedQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInQuoteQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInSearchQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInAlsoLikedQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInPostQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInBookmarksQueryData(queryClient, uri)) { yield postViewToThreadPlaceholder(post) } for (let post of findAllPostsInExploreFeedPreviewsQueryData( queryClient, uri, )) { yield postViewToThreadPlaceholder(post) }}
export function* findAllPostsInQueryData( queryClient: QueryClient, uri: string,): Generator<AppBskyFeedDefs.PostView, void> { const atUri = new AtUri(uri) const queryDatas = queryClient.getQueriesData<AppBskyUnspeccedGetPostThreadV2.OutputSchema>({ queryKey: [postThreadQueryKeyRoot], })
for (const [_queryKey, queryData] of queryDatas) { if (!queryData) continue
const {thread} = queryData
for (const item of thread) { if (AppBskyUnspeccedDefs.isThreadItemPost(item.value)) { if (didOrHandleUriMatches(atUri, item.value.post)) { yield item.value.post }
const qp = getEmbeddedPost(item.value.post.embed) if (qp && didOrHandleUriMatches(atUri, qp)) { yield embedViewRecordToPostView(qp) } } } }}
export function* findAllProfilesInQueryData( queryClient: QueryClient, did: string,): Generator<AppBskyActorDefs.ProfileViewBasic, void> { const queryDatas = queryClient.getQueriesData<AppBskyUnspeccedGetPostThreadV2.OutputSchema>({ queryKey: [postThreadQueryKeyRoot], })
for (const [_queryKey, queryData] of queryDatas) { if (!queryData) continue
const {thread} = queryData
for (const item of thread) { if (AppBskyUnspeccedDefs.isThreadItemPost(item.value)) { if (item.value.post.author.did === did) { yield item.value.post.author }
const qp = getEmbeddedPost(item.value.post.embed) if (qp && qp.author.did === did) { yield qp.author } } } }}
export function useUpdatePostThreadThreadgateQueryCache() { const qc = useQueryClient() const context = usePostThreadContext()
return useCallback( (threadgate: AppBskyFeedDefs.ThreadgateView) => { if (!context) return
function mutator<T>(thread: ApiThreadItem[]): T[] { for (let i = 0; i < thread.length; i++) { const item = thread[i]
if (!AppBskyUnspeccedDefs.isThreadItemPost(item.value)) continue
if (item.depth === 0) { thread.splice(i, 1, { ...item, value: { ...item.value, post: { ...item.value.post, threadgate, }, }, }) } }
return thread as T[] }
qc.setQueryData<AppBskyUnspeccedGetPostThreadV2.OutputSchema>( context.postThreadQueryKey, data => { if (!data) return return { ...data, thread: mutator<AppBskyUnspeccedGetPostThreadV2.ThreadItem>([ ...data.thread, ]), } }, ) }, [qc, context], )}