feat: migrate anonymous threads to user account

Author: NamesMT

apps/backend-convex/functions/threads/mutate.ts

@@ -127,6 +127,30 @@ export const unfreeze = mutation({
   },
 })
 
+export const migrateToUser = mutation({
+  args: {
+    threadId: v.id('threads'),
+    lockerKey: v.optional(v.string()),
+  },
+  handler: async (ctx, args) => {
+    const userIdentity = await ctx.auth.getUserIdentity()
+    if (!userIdentity)
+      throw new ConvexError('Not authenticated')
+
+    const thread = await ctx.db.get(args.threadId)
+    if (!thread)
+      throw new ConvexError('Thread not found')
+    if (thread.userId)
+      throw new ConvexError('Thread already have an owner')
+
+    await assertThreadAccess(ctx, { thread, lockerKey: args.lockerKey })
+
+    await ctx.db.patch(args.threadId, {
+      userId: userIdentity.subject,
+    })
+  },
+})
+
 export const setLockerKey = mutation({
   args: {
     threadId: v.id('threads'),

apps/frontend/app/components/chat/ChatSidebar.vue

@@ -54,8 +54,18 @@ if ($auth.loggedIn) {
   })
 
   // Migrate anonymous threads to user account
-  watch(threads, () => {
-    // TODO
+  until(fetchingFromConvex).not.toBeTruthy({ timeout: 5000 }).then(() => {
+    for (const thread of threads.value) {
+      if (thread && !thread.userId) {
+        // eslint-disable-next-line no-console
+        console.info(`Migrating thread: ${thread._id} to user account`)
+        thread.userId = $auth.user.sub
+        migrateThreadToUser(convex, { threadId: thread._id, lockerKey: getLockerKey(thread._id) })
+          .catch(async () => {
+            await refreshThread(convex, { threadId: thread._id, chatContext })
+          })
+      }
+    }
   })
 }
 // For anonymous users, subscribe to threads via sessionId
@@ -149,8 +159,7 @@ const [DefineThreadLiItem, ReuseThreadLiItem] = createReusableTemplate<{ thread:
     <SidebarHeader class="px-4 py-2">
       <div class="absolute right-3 top-3">
         <Button
-          variant="ghost" size="icon"
-          class="size-7"
+          variant="ghost" size="icon" class="size-7"
           @click="colorMode.preference = (colorMode.preference === 'dark') ? 'light' : 'dark'"
         >
           <div>{{ colorMode.preference === 'dark' ? '🌙' : '🌞' }}</div>

apps/frontend/app/components/chat/thread/ShareThreadAlertDialog.vue

@@ -51,7 +51,11 @@ const open = ref(false)
       <AlertDialogHeader>
         <AlertDialogTitle>{{ $t('chat.alert.shareThread.title') }}</AlertDialogTitle>
         <AlertDialogDescription class="whitespace-pre-line">
-          {{ $t('chat.alert.shareThread.description', { name: thread.title }) }}
+          {{
+            !thread.userId
+              ? $t('chat.alert.shareThread.descriptionDanger', { name: thread.title })
+              : $t('chat.alert.shareThread.description', { name: thread.title })
+          }}
         </AlertDialogDescription>
       </AlertDialogHeader>
       <AlertDialogFooter>

apps/frontend/app/utils/chat.ts

@@ -43,7 +43,7 @@ export interface HostedProvider {
   default: string
 }
 
-export const [useChatContext, provideChatContext] = createContext<{
+export interface ChatContext {
   threads: Ref<Doc<'threads'>[]>
   threadsKeyed: ComputedRef<Record<Doc<'threads'>['_id'], Doc<'threads'>>>
   pinnedThreadIds: Ref<string[]>
@@ -59,7 +59,8 @@ export const [useChatContext, provideChatContext] = createContext<{
   insaneUI: Ref<boolean>
   // Interface soft render key
   interfaceSRK: Ref<number>
-}>('chat page')
+}
+export const [useChatContext, provideChatContext] = createContext<ChatContext>('chat page')
 
 export function displayActiveAgent(agent: AgentObject) {
   if (agent.provider === 'hosted')

apps/frontend/app/utils/chat_threads.ts

@@ -2,6 +2,28 @@ import type { Id } from 'backend-convex/convex/_generated/dataModel'
 import type { ConvexClient, ConvexHttpClient } from 'convex/browser'
 import { api } from 'backend-convex/convex/_generated/api'
 
+export interface refreshThreadArgs {
+  threadId: Id<'threads'>
+  chatContext: ChatContext
+}
+export async function refreshThread(convex: ConvexClient | ConvexHttpClient, { threadId, chatContext }: refreshThreadArgs) {
+  await convex.query(api.threads.get, { threadId, lockerKey: getLockerKey(threadId) })
+    .then((res) => {
+      const foundLocallyAt = chatContext.threads.value.findIndex(t => t._id === threadId)
+      if (foundLocallyAt !== -1)
+        Object.assign(chatContext.threads.value[foundLocallyAt]!, convex.query(api.threads.get, { threadId, lockerKey: getLockerKey(threadId) }))
+      else
+        chatContext.threads.value.push(res)
+    })
+    .catch((e) => {
+      if (getConvexErrorMessage(e) === 'Thread not found') {
+        const foundLocallyAt = chatContext.threads.value.findIndex(t => t._id === threadId)
+        if (foundLocallyAt !== -1)
+          chatContext.threads.value.splice(foundLocallyAt, 1)
+      }
+    })
+}
+
 export interface BranchThreadFromMessageArgs {
   messageId: Id<'messages'>
   sessionId?: string
@@ -74,6 +96,17 @@ export async function unfreezeThread(convex: ConvexClient | ConvexHttpClient, {
   })
 }
 
+export interface MigrateThreadToUserArgs {
+  threadId: Id<'threads'>
+  lockerKey?: string
+}
+export async function migrateThreadToUser(convex: ConvexClient | ConvexHttpClient, { threadId, lockerKey }: MigrateThreadToUserArgs) {
+  return await convex.mutation(api.threads.migrateToUser, {
+    threadId,
+    lockerKey,
+  })
+}
+
 export interface GenerateThreadTitleArgs {
   threadId: Id<'threads'>
   lockerKey?: string

i18n.lock

@@ -6,7 +6,8 @@ checksums:
     cancel: 2e2a849c2223911717de8caa2c71bade
     chat.alert.deleteThread.description: b0cca6d07bbbd907b4d25dc2a1dbe2e3
     chat.alert.deleteThread.title: 3dea4a78f8c5c2073d8eab4aad3f2015
-    chat.alert.shareThread.description: e8eeee4bd83372c3a997a593a585f077
+    chat.alert.shareThread.description: 38470c662f7c91952c7190a873d200ac
+    chat.alert.shareThread.descriptionDanger: 85dad0b017b628e0c2e29abb45e3d5fa
     chat.alert.shareThread.title: e00e8208d2dd52a00a4cbccdc57199e3
     chat.interface.selectOrStart: 5ae94ab41d0b599f36924f5db15dd16d
     chat.interface.sendToStart: 6ba07995188dc929a2de0e8f0bb4d1ea
@@ -23,7 +24,7 @@ checksums:
     chat.sidebar.threads.empty: eaa3199ed3ba5dd2bb3988ea999649e3
     chat.sidebar.threads.loading: c0591fcc6aa3eb6092ab4f4ce577804c
     chat.thread.branchedFrom: 9235ad091f1d3b7f65a33b2e906674ad
-    components.convexIntegrationTest.addTask.label: 94bfce6a5916c8955cea8d04ad41c10e
+    chat.thread.delete: 3dea4a78f8c5c2073d8eab4aad3f2015
     chat.thread.freeze: b90fc4e37a58e2f60fbc9a25945b2138
     chat.thread.frozen: 69fa1ed78bb636c218ec3d95eae69bca
     chat.thread.frozenWithDescription: 5cf38e514472bed10297a7936924737f
@@ -33,8 +34,10 @@ checksums:
     chat.thread.unpin: 9f3e0c1a25452b171dfffee566e11d49
     chat.toast.threadBranched: edc2466649225081b38d4c6fe1dd27cf
     chat.toast.threadRemovedExternal: db7f0c7a17abd8f2fa3bdf24f0e81377
+    chat.toast.threadNameRemovedExternal: 4a962f76e9e63e9c764659f88661058c
     chat.toast.threadShareLinkCopied: 301236632c59a15e329f433e7b4a3706
     chat.typeYourMessageHere: 592c39355ee2ce96113655e58b1e65c9
+    components.convexIntegrationTest.addTask.label: 94bfce6a5916c8955cea8d04ad41c10e
     components.convexIntegrationTest.addTask.placeholder: cfe9cb319a1f23515f7c2215dba202a3
     components.convexIntegrationTest.authenticated: 7aeaface3edc0f5dca2c8ebd6c7e1974
     components.convexIntegrationTest.configuredUrl: ca306d17f0a8f6bd7e0b9b2efcf23fe7

locals/locales/src/sheets/frontend/i18n.csv

@@ -9,12 +9,25 @@ Hành động này không thể hoàn tác.","您确定要删除“{name}”吗
 此操作无法撤销。"
 chat.alert.deleteThread.title,,Delete Thread,Eliminar conversación,Supprimer la conversation,Удалить тему,Xóa Chủ Đề,删除话题
 chat.alert.shareThread.description,,"Are you sure you want to share ""{name}""?
-The recipient will have full access to the history and future of the thread.","¿Estás seguro de que quieres compartir ""{name}""?
-El destinatario tendrá acceso completo al historial y futuro de la conversación.","Êtes-vous sûr de vouloir partager ""{name}"" ?
-Le destinataire aura un accès complet à l'historique et au futur de la conversation.","Вы уверены, что хотите поделиться ""{name}""?
-Получатель получит полный доступ к истории и будущему этой ветки.","Bạn có chắc chắn muốn chia sẻ ""{name}""?
-Người nhận sẽ có toàn quyền truy cập vào lịch sử và tương lai của cuộc trò chuyện.","您确定要分享“{name}”吗？
-接收者将可以完全访问该线程的历史记录和未来内容。"
+The recipient will have full access including deleting and viewing the history and future of the thread.","¿Estás seguro de que quieres compartir ""{name}""?
+El destinatario tendrá acceso completo, incluyendo la posibilidad de eliminar y ver el historial y futuro del hilo.","Êtes-vous sûr de vouloir partager ""{name}"" ?
+Le destinataire aura un accès complet, y compris la possibilité de supprimer et de consulter l'historique et les futures conversations du fil.","Вы уверены, что хотите поделиться ""{name}""?
+Получатель получит полный доступ, включая возможность удаления, просмотра истории и будущего этой темы.","Bạn có chắc chắn muốn chia sẻ ""{name}""?
+Người nhận sẽ có toàn quyền truy cập bao gồm xóa và xem lịch sử cũng như tương lai của cuộc trò chuyện.","您确定要分享“{name}”吗？
+接收者将拥有完全的访问权限，包括删除以及查看该线程的历史和未来内容。"
+chat.alert.shareThread.descriptionDanger,,"Are you sure you want to share ""{name}""?
+The recipient will have full access including deleting and viewing the history and future of the thread.
+The thread currently are also not assigned to any user account, its ownership will be transferred to the first user account that joins the thread.","¿Estás seguro de que quieres compartir ""{name}""?
+El destinatario tendrá acceso completo, incluyendo la posibilidad de eliminar y ver el historial y futuro del hilo.
+Actualmente, el hilo no está asignado a ninguna cuenta de usuario, su propiedad se transferirá a la primera cuenta de usuario que se una al hilo.","Êtes-vous sûr de vouloir partager ""{name}"" ?
+Le destinataire aura un accès complet, y compris la possibilité de supprimer et de consulter l'historique et les futures conversations du fil.
+Actuellement, ce fil n'est associé à aucun compte utilisateur, sa propriété sera transférée au premier compte utilisateur qui rejoindra le fil.","Вы уверены, что хотите поделиться ""{name}""?
+Получатель получит полный доступ, включая возможность удаления, просмотра истории и будущего этой темы.
+В настоящее время эта тема также не привязана ни к одной учетной записи пользователя, и её владение будет передано первой учетной записи пользователя, которая присоединится к теме.","Bạn có chắc chắn muốn chia sẻ ""{name}""?
+Người nhận sẽ có toàn quyền truy cập bao gồm xóa và xem lịch sử cũng như tương lai của cuộc trò chuyện.
+Hiện tại cuộc trò chuyện này chưa được gán cho bất kỳ tài khoản người dùng nào, quyền sở hữu sẽ được chuyển cho tài khoản người dùng đầu tiên tham gia vào cuộc trò chuyện.","您确定要分享“{name}”吗？
+接收者将拥有完全的访问权限，包括删除以及查看该线程的历史和未来内容。
+目前该线程未分配给任何用户账户，其所有权将转移给第一个加入该线程的用户账户。"
 chat.alert.shareThread.title,,Share Thread,Compartir hilo,Partager la discussion,Поделиться дискуссией,Chia sẻ chủ đề,共享线程
 chat.interface.selectOrStart,,Select a chat or start a new one.,Selecciona un chat o inicia uno nuevo.,Sélectionnez une conversation ou commencez-en une nouvelle.,Выберите чат или начните новый.,Chọn một cuộc trò chuyện hoặc bắt đầu cuộc trò chuyện mới.,选择一个聊天或开始新的聊天。
 chat.interface.sendToStart,,Send a message to start chatting.,Envía un mensaje para comenzar a chatear.,Envoyez un message pour commencer la conversation.,"Отправьте сообщение, чтобы начать общение.",Gửi tin nhắn để bắt đầu trò chuyện.,发送消息以开始聊天。
@@ -40,7 +53,8 @@ chat.thread.share,,Share thread,Compartir hilo,Partager la discussion,Подел
 chat.thread.unfreeze,,Unfreeze thread,Descongelar hilo,Dégeler la discussion,Разморозить тему,Giải băng chủ đề,解冻线程
 chat.thread.unpin,,Unpin Thread,Desfijar conversación,Désépingler la conversation,Открепить тему,Bỏ ghim chủ đề,取消置顶话题
 chat.toast.threadBranched,,The thread has been branched off.,La conversación ha sido ramificada.,La conversation a été ramifiée.,Тема была выделена в отдельную ветку.,Chủ đề đã được tạo nhánh.,话题已被分支。
-chat.toast.threadRemovedExternal,,The chat has been removed by the owner.,El chat ha sido eliminado por el propietario.,Le chat a été supprimé par le propriétaire.,Чат был удален владельцем.,Cuộc trò chuyện đã bị xóa bởi chủ sở hữu.,此聊天已被所有者移除。
+chat.toast.threadRemovedExternal,,The chat has been removed by the owner.,El chat ha sido eliminado por el propietario.,Le chat a été supprimé par le propriétaire.,Чат был удалён владельцем.,Cuộc trò chuyện đã bị xóa bởi chủ sở hữu.,此聊天已被所有者移除。
+chat.toast.threadNameRemovedExternal,,"Thread ""{name}"" has been removed by the owner.","El hilo ""{name}"" ha sido eliminado por el propietario.","La discussion ""{name}"" a été supprimée par le propriétaire.","Тема ""{name}"" была удалена владельцем.","Cuộc trò chuyện ""{name}"" đã bị xóa bởi chủ sở hữu.",主题“{name}”已被所有者移除。
 chat.toast.threadShareLinkCopied,,The thread access link has been copied to your clipboard.,El enlace de acceso a la conversación ha sido copiado a tu portapapeles.,Le lien d'accès à la conversation a été copié dans votre presse-papiers.,Ссылка для доступа к ветке скопирована в ваш буфер обмена.,Đường dẫn truy cập cuộc trò chuyện đã được sao chép vào bảng tạm của bạn.,线程访问链接已复制到您的剪贴板。
 chat.typeYourMessageHere,,Type your message here...,Escribe tu mensaje aquí...,Tapez votre message ici...,Введите ваше сообщение здесь...,Nhập tin nhắn của bạn tại đây...,在这里输入你的消息...
 components.convexIntegrationTest.addTask.label,,Add task entry (press enter),Añadir tarea (pulsar enter),Ajouter une tâche (appuyer sur Entrée),Добавить задачу (нажмите Enter),Thêm mục công việc (nhấn enter),添加任务条目（按回车键）