Debounce thread preferences on leading edge, reduce to 2s (#9851)

* debounce on leading edge, reduce to 2s

* flush debounce on leave screen

* simplify by using useMutation properly

src/state/queries/preferences/index.ts

@@ -200,7 +200,13 @@ export function useSetFeedViewPreferencesMutation() {
   })
 }
 
-export function useSetThreadViewPreferencesMutation() {
+export function useSetThreadViewPreferencesMutation({
+  onSuccess,
+  onError,
+}: {
+  onSuccess?: (data: void, variables: Partial<ThreadViewPreferences>) => void
+  onError?: (error: unknown) => void
+}) {
   const queryClient = useQueryClient()
   const agent = useAgent()
 
@@ -212,6 +218,8 @@ export function useSetThreadViewPreferencesMutation() {
         queryKey: preferencesQueryKey,
       })
     },
+    onSuccess,
+    onError,
   })
 }
 

src/state/queries/preferences/useThreadPreferences.ts

@@ -1,5 +1,6 @@
 import {useCallback, useMemo, useRef, useState} from 'react'
 import {type AppBskyUnspeccedGetPostThreadV2} from '@atproto/api'
+import {useFocusEffect} from '@react-navigation/native'
 import debounce from 'lodash.debounce'
 
 import {useCallOnce} from '#/lib/once'
@@ -70,26 +71,37 @@ export function useThreadPreferences({
   }
 
   const userUpdatedPrefs = useRef(false)
-  const [isSaving, setIsSaving] = useState(false)
+  const {mutate, isPending: isSaving} = useSetThreadViewPreferencesMutation({
-  const {mutateAsync} = useSetThreadViewPreferencesMutation()
+    onSuccess: (_data, prefs) => {
+      ax.metric('thread:preferences:update', {
+        sort: prefs.sort,
+        view: prefs.lab_treeViewEnabled ? 'tree' : 'linear',
+      })
+    },
+    onError: err => {
+      ax.logger.error('useThreadPreferences failed to save', {
+        safeMessage: err,
+      })
+    },
+  })
   const savePrefs = useMemo(() => {
-    return debounce(async (prefs: ThreadViewPreferences) => {
+    return debounce(
-      try {
+      (prefs: ThreadViewPreferences) => {
-        setIsSaving(true)
+        mutate(prefs)
-        await mutateAsync(prefs)
+      },
-        ax.metric('thread:preferences:update', {
+      2e3,
-          sort: prefs.sort,
+      {leading: true, trailing: true},
-          view: prefs.lab_treeViewEnabled ? 'tree' : 'linear',
+    )
-        })
+  }, [mutate])
-      } catch (e) {
+
-        ax.logger.error('useThreadPreferences failed to save', {
+  // flush on leave screen
-          safeMessage: e,
+  useFocusEffect(
-        })
+    useCallback(() => {
-      } finally {
+      return () => {
-        setIsSaving(false)
+        void savePrefs.flush()
       }
-    }, 4e3)
+    }, [savePrefs]),
-  }, [mutateAsync])
+  )
 
   if (save && userUpdatedPrefs.current) {
     savePrefs({