Show a banner when there are incoming chat requests (#10498)

Co-authored-by: Samuel Newman <mozzius@protonmail.com>

src/state/queries/messages/list-join-requests.ts

@@ -8,6 +8,8 @@ import {createQueryKey} from '#/state/queries/util'
 import {useAgent} from '#/state/session'
 import {STALE} from '..'
 
+export const JOIN_REQUESTS_THRESHOLD = 20
+
 const listJoinRequestsQueryKeyRoot = 'list-join-requests'
 
 export const createListJoinRequestsQueryKey = (args: {convoId: string}) =>
@@ -53,7 +55,7 @@ export function useListJoinRequestsQuery({
     queryKey: createListJoinRequestsQueryKey({convoId: convoId ?? ''}),
     queryFn: async ({pageParam}) => {
       const {data} = await agent.chat.bsky.group.listJoinRequests(
-        {convoId: convoId!, cursor: pageParam, limit: 20},
+        {convoId: convoId!, cursor: pageParam, limit: JOIN_REQUESTS_THRESHOLD},
         {headers: DM_SERVICE_HEADERS},
       )
       return data

src/state/queries/messages/mark-join-request-read.ts

@@ -0,0 +1,85 @@
+import {ChatBskyConvoDefs} from '@atproto/api'
+import {useMutation, useQueryClient} from '@tanstack/react-query'
+
+import {DM_SERVICE_HEADERS} from '#/lib/constants'
+import {logger} from '#/logger'
+import {useAgent} from '#/state/session'
+import {RQKEY as CONVO_KEY} from './conversation'
+import {
+  type ConvoListQueryData,
+  RQKEY_ROOT as CONVO_LIST_ROOT_KEY,
+} from './list-conversations'
+
+export function useMarkJoinRequestsRead(convoId: string | undefined) {
+  const queryClient = useQueryClient()
+  const agent = useAgent()
+
+  return useMutation({
+    mutationFn: async () => {
+      if (!convoId) throw new Error('No convoId provided')
+      await agent.chat.bsky.group.updateJoinRequestsRead(
+        {convoId},
+        {headers: DM_SERVICE_HEADERS, encoding: 'application/json'},
+      )
+    },
+    onMutate: () => {
+      if (!convoId) return
+
+      const prevConvo = queryClient.getQueryData<ChatBskyConvoDefs.ConvoView>(
+        CONVO_KEY(convoId),
+      )
+      queryClient.setQueryData<ChatBskyConvoDefs.ConvoView | undefined>(
+        CONVO_KEY(convoId),
+        old => {
+          if (!old || !ChatBskyConvoDefs.isGroupConvo(old.kind)) return old
+          return {
+            ...old,
+            kind: {...old.kind, unreadJoinRequestCount: 0},
+          }
+        },
+      )
+
+      const prevListEntries = queryClient.getQueriesData<ConvoListQueryData>({
+        queryKey: [CONVO_LIST_ROOT_KEY],
+      })
+      queryClient.setQueriesData<ConvoListQueryData>(
+        {queryKey: [CONVO_LIST_ROOT_KEY]},
+        old => {
+          if (!old) return old
+          return {
+            ...old,
+            pages: old.pages.map(page => ({
+              ...page,
+              convos: page.convos.map(convo => {
+                if (
+                  convo.id !== convoId ||
+                  !ChatBskyConvoDefs.isGroupConvo(convo.kind)
+                ) {
+                  return convo
+                }
+                return {
+                  ...convo,
+                  kind: {...convo.kind, unreadJoinRequestCount: 0},
+                }
+              }),
+            })),
+          }
+        },
+      )
+
+      return {prevConvo, prevListEntries}
+    },
+    onError: (error, _, context) => {
+      logger.error('Failed to mark join requests as read', {safeMessage: error})
+      if (!convoId) return
+      if (context?.prevConvo) {
+        queryClient.setQueryData(CONVO_KEY(convoId), context.prevConvo)
+      }
+      for (const [key, data] of context?.prevListEntries ?? []) {
+        queryClient.setQueryData(key, data)
+      }
+      void queryClient.invalidateQueries({queryKey: CONVO_KEY(convoId)})
+      void queryClient.invalidateQueries({queryKey: [CONVO_LIST_ROOT_KEY]})
+    },
+  })
+}