diff options
Diffstat (limited to 'src/state/queries/list-members.ts')
-rw-r--r-- | src/state/queries/list-members.ts | 40 |
1 files changed, 38 insertions, 2 deletions
diff --git a/src/state/queries/list-members.ts b/src/state/queries/list-members.ts index 7aa91b1dc..d84089c90 100644 --- a/src/state/queries/list-members.ts +++ b/src/state/queries/list-members.ts @@ -1,5 +1,10 @@ -import {AppBskyGraphGetList} from '@atproto/api' -import {useInfiniteQuery, InfiniteData, QueryKey} from '@tanstack/react-query' +import {AppBskyActorDefs, AppBskyGraphGetList} from '@atproto/api' +import { + useInfiniteQuery, + InfiniteData, + QueryClient, + QueryKey, +} from '@tanstack/react-query' import {getAgent} from '#/state/session' import {STALE} from '#/state/queries' @@ -31,3 +36,34 @@ export function useListMembersQuery(uri: string) { getNextPageParam: lastPage => lastPage.cursor, }) } + +export function* findAllProfilesInQueryData( + queryClient: QueryClient, + did: string, +): Generator<AppBskyActorDefs.ProfileView, void> { + const queryDatas = queryClient.getQueriesData< + InfiniteData<AppBskyGraphGetList.OutputSchema> + >({ + queryKey: ['list-members'], + }) + for (const [_queryKey, queryData] of queryDatas) { + if (!queryData) { + continue + } + for (const [_queryKey, queryData] of queryDatas) { + if (!queryData?.pages) { + continue + } + for (const page of queryData?.pages) { + if (page.list.creator.did === did) { + yield page.list.creator + } + for (const item of page.items) { + if (item.subject.did === did) { + yield item.subject + } + } + } + } + } +} |