[🐴] Mod disabled (#4089)

* Handle send failures

* Add chat disabled state

src/screens/Messages/Conversation/ChatDisabled.tsx

···
+import React from 'react'
+import {View} from 'react-native'
+import {Trans} from '@lingui/macro'
+
+import {atoms as a, useTheme} from '#/alf'
+import {Text} from '#/components/Typography'
+
+export function ChatDisabled() {
+  const t = useTheme()
+  return (
+    <View style={[a.p_md]}>
+      <View style={[a.p_xl, a.rounded_md, t.atoms.bg_contrast_25]}>
+        <Text
+          style={[a.text_md, a.font_bold, a.pb_sm, t.atoms.text_contrast_high]}>
+          <Trans>Your chats have been disabled</Trans>
+        </Text>
+        <Text style={[a.text_sm, a.leading_snug, t.atoms.text_contrast_medium]}>
+          <Trans>
+            Our moderators have reviewed reports and decided to disable your
+            access to chats on Bluesky.
+          </Trans>
+        </Text>
+      </View>
+    </View>
+  )
+}

src/screens/Messages/Conversation/MessagesList.tsx

···
 import {shortenLinks} from '#/lib/strings/rich-text-manip'
 import {isIOS, isNative} from '#/platform/detection'
 import {useConvoActive} from '#/state/messages/convo'
-import {ConvoItem} from '#/state/messages/convo/types'
+import {ConvoItem, ConvoStatus} from '#/state/messages/convo/types'
 import {useAgent} from '#/state/session'
 import {ScrollProvider} from 'lib/ScrollContext'
 import {isWeb} from 'platform/detection'
 import {List} from 'view/com/util/List'
+import {ChatDisabled} from '#/screens/Messages/Conversation/ChatDisabled'
 import {MessageInput} from '#/screens/Messages/Conversation/MessageInput'
 import {MessageListError} from '#/screens/Messages/Conversation/MessageListError'
 import {atoms as a} from '#/alf'
···
         />
       </ScrollProvider>
       {!blocked ? (
-        <MessageInput
-          onSendMessage={onSendMessage}
-          scrollToEnd={scrollToEndNow}
-        />
+        <>
+          {convoState.status === ConvoStatus.Disabled ? (
+            <ChatDisabled />
+          ) : (
+            <MessageInput
+              onSendMessage={onSendMessage}
+              scrollToEnd={scrollToEndNow}
+            />
+          )}
+        </>
       ) : (
         footer
       )}

src/state/messages/convo/agent.ts

···
           fetchMessageHistory: undefined,
         }
       }
+      case ConvoStatus.Disabled:
       case ConvoStatus.Suspended:
       case ConvoStatus.Backgrounded:
       case ConvoStatus.Ready: {
···
             this.withdrawRequestedPollInterval()
             break
           }
+          case ConvoDispatchEvent.Disable: {
+            this.status = ConvoStatus.Disabled
+            this.fetchMessageHistory() // finish init
+            this.cleanupFirehoseConnection?.()
+            this.withdrawRequestedPollInterval()
+            break
+          }
         }
         break
       }
···
             this.withdrawRequestedPollInterval()
             break
           }
+          case ConvoDispatchEvent.Disable: {
+            this.status = ConvoStatus.Disabled
+            this.cleanupFirehoseConnection?.()
+            this.withdrawRequestedPollInterval()
+            break
+          }
         }
         break
       }
···
             this.withdrawRequestedPollInterval()
             break
           }
+          case ConvoDispatchEvent.Disable: {
+            this.status = ConvoStatus.Disabled
+            this.cleanupFirehoseConnection?.()
+            this.withdrawRequestedPollInterval()
+            break
+          }
         }
         break
       }
···
             this.error = action.payload
             break
           }
+          case ConvoDispatchEvent.Disable: {
+            this.status = ConvoStatus.Disabled
+            break
+          }
         }
         break
       }
···
             this.error = action.payload
             break
           }
+          case ConvoDispatchEvent.Disable: {
+            this.status = ConvoStatus.Disabled
+            break
+          }
         }
+        break
+      }
+      case ConvoStatus.Disabled: {
+        // can't do anything
         break
       }
       default:
···
         throw new Error('Convo: could not find recipients in convo')
       }
 
-      // await new Promise(y => setTimeout(y, 2000))
-      // throw new Error('UNCOMMENT TO TEST INIT FAILURE')
-      this.dispatch({event: ConvoDispatchEvent.Ready})
+      const userIsDisabled = this.sender.chatDisabled as boolean
+
+      if (userIsDisabled) {
+        this.dispatch({event: ConvoDispatchEvent.Disable})
+      } else {
+        this.dispatch({event: ConvoDispatchEvent.Ready})
+      }
     } catch (e: any) {
       logger.error(e, {context: 'Convo: setup failed'})
 
···
                 ...this.recipients!.map(r => r.did),
               ],
             })
+            break
+          case 'Account is disabled':
+            this.pendingMessageFailure = 'unrecoverable'
+            this.dispatch({event: ConvoDispatchEvent.Disable})
             break
           default:
             logger.warn(

src/state/messages/convo/index.tsx

···
   ConvoParams,
   ConvoState,
   ConvoStateBackgrounded,
+  ConvoStateDisabled,
   ConvoStateReady,
   ConvoStateSuspended,
 } from '#/state/messages/convo/types'
···
     | ConvoStateReady
     | ConvoStateBackgrounded
     | ConvoStateSuspended
+    | ConvoStateDisabled
   if (!ctx) {
     throw new Error('useConvo must be used within a ConvoProvider')
   }

src/state/messages/convo/types.ts

···
   Error = 'error',
   Backgrounded = 'backgrounded',
   Suspended = 'suspended',
+  Disabled = 'disabled',
 }
 
 export enum ConvoItemError {
···
   Background = 'background',
   Suspend = 'suspend',
   Error = 'error',
+  Disable = 'disable',
 }
 
 export type ConvoDispatch =
···
   | {
       event: ConvoDispatchEvent.Error
       payload: ConvoError
+    }
+  | {
+      event: ConvoDispatchEvent.Disable
     }
 
 export type ConvoItem =
···
   sendMessage: undefined
   fetchMessageHistory: undefined
 }
+export type ConvoStateDisabled = {
+  status: ConvoStatus.Disabled
+  items: ConvoItem[]
+  convo: ChatBskyConvoDefs.ConvoView
+  error: undefined
+  sender: AppBskyActorDefs.ProfileViewBasic
+  recipients: AppBskyActorDefs.ProfileViewBasic[]
+  isFetchingHistory: boolean
+  deleteMessage: DeleteMessage
+  sendMessage: SendMessage
+  fetchMessageHistory: FetchMessageHistory
+}
 export type ConvoState =
   | ConvoStateUninitialized
   | ConvoStateInitializing
···
   | ConvoStateBackgrounded
   | ConvoStateSuspended
   | ConvoStateError
+  | ConvoStateDisabled
 
 export type ConvoEvent = {
   type: 'invalidate-block-state'

src/state/messages/convo/util.ts

···
 import {
   ConvoState,
   ConvoStateBackgrounded,
+  ConvoStateDisabled,
   ConvoStateReady,
   ConvoStateSuspended,
   ConvoStatus,
···
  */
 export function isConvoActive(
   convo: ConvoState,
-): convo is ConvoStateReady | ConvoStateBackgrounded | ConvoStateSuspended {
+): convo is
+  | ConvoStateReady
+  | ConvoStateBackgrounded
+  | ConvoStateSuspended
+  | ConvoStateDisabled {
   return (
     convo.status === ConvoStatus.Ready ||
     convo.status === ConvoStatus.Backgrounded ||
-    convo.status === ConvoStatus.Suspended
+    convo.status === ConvoStatus.Suspended ||
+    convo.status === ConvoStatus.Disabled
   )
 }