acetheking987/bsky-social-app
1
0
Fork 0
Code Issues Actions Packages Projects Releases 1 Wiki Activity

[Chat] Sync single-convo cache on chat lock firehose events (#10746)

Browse Source 
Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This commit is contained in:
Samuel Newman
2026-06-05 16:39:23 +03:00
committed by GitHub
parent f81bb6f494
commit 7d4d7642fd
1 changed files with 15 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/state/queries/messages/list-conversations.tsx
+15 -48
View File
@@ -418,67 +418,34 @@ export function ListConvosProviderInner({
})), })),
) )
} else if (ChatBskyConvoDefs.isLogLockConvo(log)) { } else if (ChatBskyConvoDefs.isLogLockConvo(log)) {
queryClient.setQueriesData( mutateConvoView(log.convoId, convo =>
{queryKey: [RQKEY_ROOT]}, ChatBskyConvoDefs.isGroupConvo(convo.kind)
(old?: ConvoListQueryData) => ? {
optimisticUpdate(log.convoId, old, convo => {
if (ChatBskyConvoDefs.isGroupConvo(convo.kind)) {
return {
...convo, ...convo,
kind: { kind: {...convo.kind, lockStatus: 'locked'},
...convo.kind,
lockStatus: 'locked',
},
rev: log.rev, rev: log.rev,
} }
} : {...convo, rev: log.rev},
return {
...convo,
rev: log.rev,
}
}),
) )
} else if (ChatBskyConvoDefs.isLogUnlockConvo(log)) { } else if (ChatBskyConvoDefs.isLogUnlockConvo(log)) {
queryClient.setQueriesData( mutateConvoView(log.convoId, convo =>
{queryKey: [RQKEY_ROOT]}, ChatBskyConvoDefs.isGroupConvo(convo.kind)
(old?: ConvoListQueryData) => ? {
optimisticUpdate(log.convoId, old, convo => {
if (ChatBskyConvoDefs.isGroupConvo(convo.kind)) {
return {
...convo, ...convo,
kind: { kind: {...convo.kind, lockStatus: 'unlocked'},
...convo.kind,
lockStatus: 'unlocked',
},
rev: log.rev, rev: log.rev,
} }
} : {...convo, rev: log.rev},
return {
...convo,
rev: log.rev,
}
}),
) )
} else if (ChatBskyConvoDefs.isLogLockConvoPermanently(log)) { } else if (ChatBskyConvoDefs.isLogLockConvoPermanently(log)) {
queryClient.setQueriesData( mutateConvoView(log.convoId, convo =>
{queryKey: [RQKEY_ROOT]}, ChatBskyConvoDefs.isGroupConvo(convo.kind)
(old?: ConvoListQueryData) => ? {
optimisticUpdate(log.convoId, old, convo => {
if (ChatBskyConvoDefs.isGroupConvo(convo.kind)) {
return {
...convo, ...convo,
kind: { kind: {...convo.kind, lockStatus: 'locked-permanently'},
...convo.kind,
lockStatus: 'locked-permanently',
},
rev: log.rev, rev: log.rev,
} }
} : {...convo, rev: log.rev},
return {
...convo,
rev: log.rev,
}
}),
) )
} else if ( } else if (
ChatBskyConvoDefs.isLogCreateJoinLink(log) || ChatBskyConvoDefs.isLogCreateJoinLink(log) ||