From 332ad7b91c15a8ad7962bb8d3c392b9dfdfbb853 Mon Sep 17 00:00:00 2001
From: Steve Korshakov <steve@korshakov.com>
Date: Thu, 17 Jul 2025 20:21:19 -0700
Subject: [PATCH] ref: implement localId on server side

---
 sources/app/api.ts       | 7 ++++++-
 sources/storage/types.ts | 1 +
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/sources/app/api.ts b/sources/app/api.ts
index 604418d..a5e5eb1 100644
--- a/sources/app/api.ts
+++ b/sources/app/api.ts
@@ -192,6 +192,7 @@ export async function startApi() {
                         id: true,
                         seq: true,
                         content: true,
+                        localId: true,
                         createdAt: true
                     }
                 }
@@ -213,6 +214,7 @@ export async function startApi() {
                 lastMessage: v.messages[0] ? {
                     id: v.messages[0].id,
                     seq: v.messages[0].seq,
+                    localId: v.messages[0].localId,
                     content: v.messages[0].content,
                     createdAt: v.messages[0].createdAt.getTime()
                 } : null
@@ -371,6 +373,7 @@ export async function startApi() {
             select: {
                 id: true,
                 seq: true,
+                localId: true,
                 content: true,
                 createdAt: true,
                 updatedAt: true
@@ -382,6 +385,7 @@ export async function startApi() {
                 id: v.id,
                 seq: v.seq,
                 content: v.content,
+                localId: v.localId,
                 createdAt: v.createdAt.getTime(),
                 updatedAt: v.updatedAt.getTime()
             }))
@@ -667,6 +671,7 @@ export async function startApi() {
                         id: msg.id,
                         seq: msg.seq,
                         content: msgContent,
+                        localId: useLocalId,
                         createdAt: msg.createdAt.getTime(),
                         updatedAt: msg.updatedAt.getTime()
                     }
@@ -703,7 +708,7 @@ export async function startApi() {
             if (!result) {
                 return;
             }
-            
+
             // Emit update to relevant clients
             if (result.update) {
                 emitUpdateToInterestedClients({
diff --git a/sources/storage/types.ts b/sources/storage/types.ts
index a5c869d..e0900a2 100644
--- a/sources/storage/types.ts
+++ b/sources/storage/types.ts
@@ -14,6 +14,7 @@ declare global {
                 id: string;
                 seq: number;
                 content: SessionMessageContent;
+                localId: string | null;
                 createdAt: number;
                 updatedAt: number;
             }