diff --git a/app/actions/remote/thread.ts b/app/actions/remote/thread.ts index f4e91b0de4..e25a9f131d 100644 --- a/app/actions/remote/thread.ts +++ b/app/actions/remote/thread.ts @@ -360,7 +360,7 @@ export const syncTeamThreads = async (serverUrl: string, teamId: string, prepare const allNewThreads = await fetchThreads( serverUrl, teamId, - {deleted: true, since: syncData.latest}, + {deleted: true, since: syncData.latest + 1}, ); if (allNewThreads.error) { return {error: allNewThreads.error}; diff --git a/app/screens/global_threads/threads_list/index.ts b/app/screens/global_threads/threads_list/index.ts index 13b4a127fd..3aadd419d9 100644 --- a/app/screens/global_threads/threads_list/index.ts +++ b/app/screens/global_threads/threads_list/index.ts @@ -30,7 +30,7 @@ const enhanced = withObservables(['tab', 'teamId', 'forceQueryAfterAppState'], ( const teamThreadsSyncObserver = queryTeamThreadsSync(database, teamId).observeWithColumns(['earliest']); return { - unreadsCount: queryThreadsInTeam(database, teamId, true).observeCount(false), + unreadsCount: queryThreadsInTeam(database, teamId, true, true, true).observeCount(false), teammateNameDisplay: observeTeammateNameDisplay(database), threads: teamThreadsSyncObserver.pipe( switchMap((teamThreadsSync) => {