ECHO-352 Conversation live indicator fix

echo/frontend/src/components/conversation/ConversationAccordion.tsx

@@ -445,7 +445,7 @@ const ConversationAccordionItem = ({
   highlight = false,
   showDuration = false,
 }: {
-  conversation: Conversation;
+  conversation?: Conversation & {live: boolean};
   highlight?: boolean;
   showDuration?: boolean;
 }) => {
@@ -459,15 +459,15 @@ const ConversationAccordionItem = ({
     return <Skeleton height={60} />;
   }
 
+  if (!conversation) {
+    return null;
+  }
+
   const isLocked = chatContextQuery.data?.conversations?.find(
     (c) => c.conversation_id === conversation.id && c.locked,
   );
 
   const isAutoSelectEnabled = chatContextQuery.data?.auto_select_bool ?? false;
-  const isUpload =
-    conversation.source?.toLowerCase().includes("upload") ?? false;
-
-  // Check if conversation has any content
 
   return (
     <NavigationButton
@@ -509,11 +509,11 @@ const ConversationAccordionItem = ({
           </Text>
           {
             // if from portal and not finished
-            !isUpload && conversation.is_finished === false && (
-              <Box className="flex items-center gap-1 pr-[4px]">
+            (["portal_audio"].includes(conversation.source?.toLowerCase() ?? "")) && conversation.live && (
+              <Box className="flex items-baseline gap-1 pr-[4px]">
                 <div className="h-2 w-2 animate-pulse rounded-full bg-red-500" />
                 <Text size="xs" fs="italic" fw={500}>
-                  <Trans>Live</Trans>
+                  <Trans id="conversation.ongoing">Ongoing</Trans>
                 </Text>
               </Box>
             )
@@ -868,7 +868,7 @@ export const ConversationAccordion = ({ projectId }: { projectId: string }) => {
               <ConversationAccordionItem
                 key={item.id}
                 highlight={item.id === activeConversationId}
-                conversation={item as Conversation}
+                conversation={item as Conversation & {live: boolean} ?? null}
                 showDuration={showDuration}
               />
             ))}

echo/frontend/src/components/conversation/ConversationLink.tsx

@@ -79,12 +79,12 @@ export const ConversationLink = ({
             <List>
               {conversation.linked_conversations.map(
                 (conversationLink: ConversationLink) =>
-                  conversationLink?.target_conversation_id?.id && (
+                  (conversationLink?.target_conversation_id as Conversation)?.id && (
                     <List.Item key={conversationLink?.id}>
                       <ConversationAnchor
-                        to={`/projects/${projectId}/conversation/${conversationLink?.target_conversation_id?.id}/overview`}
+                        to={`/projects/${projectId}/conversation/${(conversationLink?.target_conversation_id as Conversation)?.id}/overview`}
                         name={
-                          conversationLink?.target_conversation_id
+                          (conversationLink?.target_conversation_id as Conversation)
                             ?.participant_name ?? ""
                         }
                       />

echo/frontend/src/components/conversation/OngoingConversationsSummaryCard.tsx

@@ -24,7 +24,7 @@ export const OngoingConversationsSummaryCard = ({
               project_id: projectId,
             },
             source: {
-              _neq: "DASHBOARD_UPLOAD",
+              _nin: ["DASHBOARD_UPLOAD", "CLONE"],
             },
             timestamp: {
               // @ts-expect-error gt is not typed

echo/frontend/src/components/conversation/hooks/index.ts

@@ -624,6 +624,8 @@ export const useConversationsByProjectId = (
   query?: Partial<Query<CustomDirectusTypes, Conversation>>,
   filterBySource?: string[],
 ) => {
+  const TIME_INTERVAL_SECONDS = 40;
+
   return useQuery({
     queryKey: [
       "projects",
@@ -634,8 +636,8 @@ export const useConversationsByProjectId = (
       query,
       filterBySource,
     ],
-    queryFn: () =>
-      directus.request(
+    queryFn: async () => {
+      const conversations = await directus.request(
         readItems("conversation", {
           sort: "-updated_at",
           fields: [
@@ -677,7 +679,43 @@ export const useConversationsByProjectId = (
           limit: 1000,
           ...query,
         }),
-      ),
+      );
+
+      return conversations;
+    },
+    select: (data) => {
+      // Add live field to each conversation based on recent chunk activity
+      const cutoffTime = new Date(Date.now() - TIME_INTERVAL_SECONDS * 1000);
+
+      if (data.length === 0) return [];
+
+      return data.map((conversation) => {
+
+          // Skip upload chunks
+          if (
+            ["upload", "clone"].includes(conversation.source ?? "")
+          ) return {
+            ...conversation,
+            live: false,
+          };
+
+          if (conversation.chunks?.length === 0) return {
+            ...conversation,
+            live: false,
+          };
+
+        const hasRecentChunks = conversation.chunks?.some((chunk: any) => {
+          // Check if chunk timestamp is recent
+          const chunkTime = new Date(chunk.timestamp || chunk.created_at || 0);
+          return chunkTime > cutoffTime;
+        });
+
+        return {
+          ...conversation,
+          live: hasRecentChunks || false,
+        };
+      });
+    },
     refetchInterval: 30000,
   });
 };

echo/frontend/src/lib/typesDirectus.d.ts

@@ -62,6 +62,8 @@ type Conversation = {
   is_all_chunks_transcribed?: boolean | null;
   is_audio_processing_finished?: boolean | null;
   is_finished?: boolean | null;
+  linked_conversations: any[] | ConversationLink[];
+  linking_conversations: any[] | ConversationLink[];
   merged_audio_path?: string | null;
   merged_transcript?: string | null;
   participant_email?: string | null;
@@ -75,18 +77,9 @@ type Conversation = {
   source?: string | null;
   summary?: string | null;
   tags: any[] | ConversationProjectTag[];
-  linking_conversations?: any[] | ConversationLink[];
-  linked_conversations?: any[] | ConversationLink[];
   updated_at?: string | null;
 };
 
-type ConversationLink = {
-  id: string;
-  link_type: string;
-  source_conversation_id: Conversation | null;
-  target_conversation_id: Conversation | null;
-};
-
 type ConversationChunk = {
   conversation_id: string | Conversation;
   conversation_segments: any[] | ConversationSegmentConversationChunk[];
@@ -114,6 +107,15 @@ type ConversationChunk = {
   updated_at?: string | null;
 };
 
+type ConversationLink = {
+  date_created?: string | null;
+  date_updated?: string | null;
+  id: number;
+  link_type?: string | null;
+  source_conversation_id?: string | Conversation | null;
+  target_conversation_id?: string | Conversation | null;
+};
+
 type ConversationProjectTag = {
   conversation_id?: string | Conversation | null;
   id: number;
@@ -584,11 +586,13 @@ type ProcessingStatus = {
   id: number;
   message?: string | null;
   parent?: number | ProcessingStatus | null;
+  project_analysis_run_id?: string | ProjectAnalysisRun | null;
   project_id?: string | Project | null;
   timestamp?: string | null;
 };
 
 type Project = {
+  conversations_count?: number | null;
   context?: string | null;
   conversation_ask_for_participant_name_label?: string | null;
   conversations: any[] | Conversation[];
@@ -616,14 +620,13 @@ type Project = {
   project_reports: any[] | ProjectReport[];
   tags: any[] | ProjectTag[];
   updated_at?: string | null;
-
-  conversations_count?: number | null;
 };
 
 type ProjectAnalysisRun = {
   created_at?: string | null;
   id: string;
   insights: any[] | Insight[];
+  processing_status: any[] | ProcessingStatus[];
   project_id?: string | Project | null;
   updated_at?: string | null;
   views: any[] | View[];
@@ -730,14 +733,15 @@ type ProjectTag = {
 type View = {
   aspects: any[] | Aspect[];
   created_at?: string | null;
+  description?: string | null;
   id: string;
+  language?: string | null;
   name?: string | null;
   project_analysis_run_id?: string | ProjectAnalysisRun | null;
   summary?: string | null;
   updated_at?: string | null;
   user_input?: string | null;
   user_input_description?: string | null;
-  description?: string | null;
 };
 
 type CustomDirectusTypes = {
@@ -748,6 +752,7 @@ type CustomDirectusTypes = {
   aspect_segment: AspectSegment[];
   conversation: Conversation[];
   conversation_chunk: ConversationChunk[];
+  conversation_link: ConversationLink[];
   conversation_project_tag: ConversationProjectTag[];
   conversation_reply: ConversationReply[];
   conversation_segment: ConversationSegment[];

echo/frontend/src/locales/de-DE.po

@@ -1119,8 +1119,8 @@ msgstr "Link"
 #~ msgstr "LinkedIn-Beitrag (Experimentell)"
 
 #: src/components/conversation/ConversationAccordion.tsx:516
-msgid "Live"
-msgstr "Live"
+#~ msgid "Live"
+#~ msgstr "Live"
 
 #: src/components/participant/MicrophoneTest.tsx:274
 msgid "Live audio level:"
@@ -1355,6 +1355,15 @@ msgstr "Es wurden keine gültigen Audio-Dateien ausgewählt. Bitte wählen Sie n
 msgid "Oldest First"
 msgstr "Älteste zuerst"
 
+#. js-lingui-explicit-id
+#: src/components/conversation/ConversationAccordion.tsx:516
+msgid "conversation.ongoing"
+msgstr "Laufend"
+
+#: src/components/conversation/ConversationAccordion.tsx:516
+#~ msgid "Ongoing"
+#~ msgstr "Laufend"
+
 #: src/components/conversation/OngoingConversationsSummaryCard.tsx:60
 msgid "Ongoing Conversations"
 msgstr "Laufende Gespräche"

echo/frontend/src/locales/en-US.po

@@ -1156,8 +1156,8 @@ msgstr "Link"
 #~ msgstr "LinkedIn Post (Experimental)"
 
 #: src/components/conversation/ConversationAccordion.tsx:516
-msgid "Live"
-msgstr "Live"
+#~ msgid "Live"
+#~ msgstr "Live"
 
 #: src/components/participant/MicrophoneTest.tsx:274
 msgid "Live audio level:"
@@ -1392,6 +1392,15 @@ msgstr "No valid audio files were selected. Please select audio files only (MP3,
 msgid "Oldest First"
 msgstr "Oldest First"
 
+#. js-lingui-explicit-id
+#: src/components/conversation/ConversationAccordion.tsx:516
+msgid "conversation.ongoing"
+msgstr "Ongoing"
+
+#: src/components/conversation/ConversationAccordion.tsx:516
+#~ msgid "Ongoing"
+#~ msgstr "Ongoing"
+
 #: src/components/conversation/OngoingConversationsSummaryCard.tsx:60
 msgid "Ongoing Conversations"
 msgstr "Ongoing Conversations"

echo/frontend/src/locales/es-ES.po

@@ -1123,8 +1123,8 @@ msgstr "Enlace"
 #~ msgstr "Publicación LinkedIn (Experimental)"
 
 #: src/components/conversation/ConversationAccordion.tsx:516
-msgid "Live"
-msgstr "Vivo"
+#~ msgid "Live"
+#~ msgstr "Vivo"
 
 #: src/components/participant/MicrophoneTest.tsx:274
 msgid "Live audio level:"
@@ -1359,6 +1359,15 @@ msgstr "No se seleccionaron archivos de audio válidos. Por favor, selecciona so
 msgid "Oldest First"
 msgstr "Más antiguos primero"
 
+#. js-lingui-explicit-id
+#: src/components/conversation/ConversationAccordion.tsx:516
+msgid "conversation.ongoing"
+msgstr "En curso"
+
+#: src/components/conversation/ConversationAccordion.tsx:516
+#~ msgid "Ongoing"
+#~ msgstr "En curso"
+
 #: src/components/conversation/OngoingConversationsSummaryCard.tsx:60
 msgid "Ongoing Conversations"
 msgstr "Conversaciones en Curso"

echo/frontend/src/locales/fr-FR.po

@@ -1123,8 +1123,8 @@ msgstr "Lien"
 #~ msgstr "Publication LinkedIn (Expérimental)"
 
 #: src/components/conversation/ConversationAccordion.tsx:516
-msgid "Live"
-msgstr "Direct"
+#~ msgid "Live"
+#~ msgstr "Direct"
 
 #: src/components/participant/MicrophoneTest.tsx:274
 msgid "Live audio level:"
@@ -1359,6 +1359,15 @@ msgstr "Aucun fichier audio valide n'a été sélectionné. Veuillez sélectionn
 msgid "Oldest First"
 msgstr "Plus ancien en premier"
 
+#. js-lingui-explicit-id
+#: src/components/conversation/ConversationAccordion.tsx:516
+msgid "conversation.ongoing"
+msgstr "En cours"
+
+#: src/components/conversation/ConversationAccordion.tsx:516
+#~ msgid "Ongoing"
+#~ msgstr "En cours"
+
 #: src/components/conversation/OngoingConversationsSummaryCard.tsx:60
 msgid "Ongoing Conversations"
 msgstr "Conversations en cours"

echo/frontend/src/locales/nl-NL.po

@@ -1281,8 +1281,8 @@ msgstr "Link"
 #~ msgstr "LinkedIn Post (Experimenteel)"
 
 #: src/components/conversation/ConversationAccordion.tsx:516
-msgid "Live"
-msgstr "Live"
+#~ msgid "Live"
+#~ msgstr "Live"
 
 #: src/components/participant/MicrophoneTest.tsx:274
 msgid "Live audio level:"
@@ -1525,6 +1525,15 @@ msgstr "Er zijn geen geldige audiobestanden geselecteerd. Selecteer alleen audio
 msgid "Oldest First"
 msgstr "Oudste eerst"
 
+#. js-lingui-explicit-id
+#: src/components/conversation/ConversationAccordion.tsx:516
+msgid "conversation.ongoing"
+msgstr "Actief"
+
+#: src/components/conversation/ConversationAccordion.tsx:516
+#~ msgid "Ongoing"
+#~ msgstr "Actief"
+
 #: src/components/conversation/OngoingConversationsSummaryCard.tsx:60
 msgid "Ongoing Conversations"
 msgstr "Actieve Gesprekken"