songtianlun/happy-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ref: implement localId on server side

Browse Source
This commit is contained in:
Steve Korshakov 2025-07-17 20:21:19 -07:00
parent bed3f87cba
commit 332ad7b91c
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
sources/app/api.ts
View File

@ -192,6 +192,7 @@ export async function startApi() {
id: true, id: true,
seq: true, seq: true,
content: true, content: true,
localId: true,
createdAt: true createdAt: true
} }
} }
@ -213,6 +214,7 @@ export async function startApi() {
lastMessage: v.messages[0] ? { lastMessage: v.messages[0] ? {
id: v.messages[0].id, id: v.messages[0].id,
seq: v.messages[0].seq, seq: v.messages[0].seq,
localId: v.messages[0].localId,
content: v.messages[0].content, content: v.messages[0].content,
createdAt: v.messages[0].createdAt.getTime() createdAt: v.messages[0].createdAt.getTime()
} : null } : null
@ -371,6 +373,7 @@ export async function startApi() {
select: { select: {
id: true, id: true,
seq: true, seq: true,
localId: true,
content: true, content: true,
createdAt: true, createdAt: true,
updatedAt: true updatedAt: true
@ -382,6 +385,7 @@ export async function startApi() {
id: v.id, id: v.id,
seq: v.seq, seq: v.seq,
content: v.content, content: v.content,
localId: v.localId,
createdAt: v.createdAt.getTime(), createdAt: v.createdAt.getTime(),
updatedAt: v.updatedAt.getTime() updatedAt: v.updatedAt.getTime()
})) }))
@ -667,6 +671,7 @@ export async function startApi() {
id: msg.id, id: msg.id,
seq: msg.seq, seq: msg.seq,
content: msgContent, content: msgContent,
localId: useLocalId,
createdAt: msg.createdAt.getTime(), createdAt: msg.createdAt.getTime(),
updatedAt: msg.updatedAt.getTime() updatedAt: msg.updatedAt.getTime()
} }
@ -703,7 +708,7 @@ export async function startApi() {
if (!result) { if (!result) {
return; return;
} }
// Emit update to relevant clients // Emit update to relevant clients
if (result.update) { if (result.update) {
emitUpdateToInterestedClients({ emitUpdateToInterestedClients({

1
sources/storage/types.ts
View File

@ -14,6 +14,7 @@ declare global {
id: string; id: string;
seq: number; seq: number;
content: SessionMessageContent; content: SessionMessageContent;
localId: string | null;
createdAt: number; createdAt: number;
updatedAt: number; updatedAt: number;
} }