Sravan/BizGaze_Remote
0
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix(chat): non-destructive reconnect resync — stop messages disappearing after send

Browse Source 
batch42's resync-on-reconnect reopened the conversation via openConvo, which
replaces THREAD wholesale. On the desktop app (flaky WS), a reload racing with a
just-sent message could momentarily blank the chat ('messages disappear after
sending', seen on the Manasa chat). resync now MERGES: adds messages missed while
disconnected + refreshes read/delivered/seen/edited/deleted flags, but never
removes messages already on screen.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
Sravan
2026-07-07 12:41:12 +05:30
parent 37c8929c5e
commit 7d284213d1
1 changed files with 24 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/public/home.html
+24 -2
View File
@@ -788,7 +788,7 @@
<body>
<script src="/icons.js?v=4"></script>
<script src="https://cdn.jsdelivr.net/npm/@twemoji/api@15.1.0/dist/twemoji.min.js" crossorigin="anonymous"></script>
<script>window.__BUILD='2026-07-06-batch42';console.log('%cBiz Connect','color:#1F3B73;font-weight:bold','build '+window.__BUILD);
<script>window.__BUILD='2026-07-07-batch43';console.log('%cBiz Connect','color:#1F3B73;font-weight:bold','build '+window.__BUILD);
// Render modern (Twemoji) emojis in place of the OS's flat ones. No-op if the CDN didn't load
// (emojis stay as plain Unicode). (#5)
function twemojify(el){ try{ if(el && window.twemoji) window.twemoji.parse(el, { folder:'svg', ext:'.svg' }); }catch(_){} }</script>
@@ -2228,7 +2228,29 @@ let chatWs=null, _chatConnectedOnce=false;
// handled by boot's loadSidebar, so we skip the resync then.
function resyncChat(){
try{ loadSidebar(); }catch(_){}
if(selected && currentTab()==='chat'){ const s=selected; try{ openConvo(s.kind, s.id); }catch(_){} }
refreshOpenThread(); // NON-destructive catch-up (never wipes the open thread — see below)
}
// Re-fetch the open conversation and MERGE: add messages missed while disconnected + refresh
// read/delivered/seen/edited/deleted flags, but NEVER remove messages already shown. openConvo
// replaced THREAD wholesale, which could momentarily blank a chat (e.g. a just-sent message) if the
// reload raced or returned stale — the cause of the "messages disappear after sending" report.
async function refreshOpenThread(){
if(!selected || currentTab()!=='chat') return;
const kind=selected.kind, id=selected.id;
const url=kind==='group'?('/api/messages/thread?group='+encodeURIComponent(id)):('/api/messages/thread?with='+encodeURIComponent(id));
let msgs; try{ msgs=await fetch(url).then(r=>r.json()); }catch(_){ return; }
if(!Array.isArray(msgs)) return;
if(!selected||selected.kind!==kind||selected.id!==id) return; // switched away while fetching
const byId=new Map(THREAD.map(m=>[m.id,m])); let changed=false;
msgs.forEach(nm=>{ const ex=byId.get(nm.id);
if(!ex){ THREAD.push(nm); changed=true; return; }
if(nm.read_at&&!ex.read_at){ ex.read_at=nm.read_at; changed=true; }
if(nm.delivered_at&&!ex.delivered_at){ ex.delivered_at=nm.delivered_at; changed=true; }
if(nm.deleted&&!ex.deleted){ ex.deleted=true; ex.body=''; ex.attachment=null; ex.reactions=[]; changed=true; }
if(nm.edited_at&&nm.edited_at!==ex.edited_at){ ex.edited_at=nm.edited_at; ex.body=nm.body; changed=true; }
if(JSON.stringify(nm.seenBy||[])!==JSON.stringify(ex.seenBy||[])){ ex.seenBy=nm.seenBy||[]; changed=true; }
});
if(changed){ THREAD.sort((a,b)=>(a.created_at||0)-(b.created_at||0)); THREAD_CACHE.set(kind+':'+id, THREAD.slice()); renderThread(); }
}
function connectChatWs(){
try{