feat: show agent conversations in the desktop inbox

Author: leynier

lib/src/features/inbox/application/conversation_participant_labels.dart

@@ -0,0 +1,48 @@
+import 'package:alera/src/features/agent_status/application/agent_status_controller.dart';
+import 'package:alera/src/features/agent_status/presentation/agent_identity_icon.dart';
+import 'package:alera/src/features/workbench/application/workbench_controller.dart';
+import 'package:alera/src/features/workbench/domain/workspace_tab_record.dart';
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:riverpod_annotation/riverpod_annotation.dart';
+
+part 'conversation_participant_labels.g.dart';
+
+/// Readable names for terminal handles: the tab title and agent the sidebar
+/// knows. A handle missing from the sidebar keeps its raw id.
+@riverpod
+Map<String, String> conversationParticipantLabels(Ref ref) {
+  final tabsByWorkspace = ref.watch(
+    workbenchControllerProvider.select((state) => state.tabsByWorkspace),
+  );
+  final statuses = ref.watch(agentStatusControllerProvider);
+  return <String, String>{
+    for (final tabs in tabsByWorkspace.values)
+      for (final tab in tabs)
+        if (tab.kind == WorkspaceTabKind.terminal)
+          tab.terminalSessionId: _label(
+            tab.title.trim(),
+            statuses[tab.terminalSessionId] == null
+                ? null
+                : agentDisplayName(statuses[tab.terminalSessionId]!.agentType),
+          ),
+  };
+}
+
+/// Workspace names by id, for the conversation filter and rows.
+@riverpod
+Map<String, String> conversationWorkspaceNames(Ref ref) => ref.watch(
+  workbenchControllerProvider.select(
+    (state) => <String, String>{
+      for (final workspaces in state.workspacesByProject.values)
+        for (final workspace in workspaces) workspace.id: workspace.name,
+    },
+  ),
+);
+
+String participantLabel(Map<String, String> labels, String handle) =>
+    labels[handle] ?? handle;
+
+String _label(String title, String? agent) {
+  if (agent == null) return title.isEmpty ? 'Terminal' : title;
+  return title.isEmpty ? agent : '$title ($agent)';
+}

lib/src/features/inbox/application/conversation_participant_labels.g.dart

@@ -8,8 +8,14 @@ part 'inbox_navigation.g.dart';
 /// A request to open the composer, optionally with a recipient chosen.
 class const InboxComposeRequest({final String? targetHandle});
 
+/// Which half of the inbox page is shown.
+enum InboxView { questions, conversations }
+
 class const InboxLocation({
   final bool visible = false,
+  final InboxView view = InboxView.questions,
+  final String? conversationWorkspace,
+  final String? selectedConversationId,
   final String? inboxFilter,
   final InboxQuestionStatus? statusFilter,
   final String? selectedThreadId,
@@ -18,13 +24,23 @@ class const InboxLocation({
 }) {
   InboxLocation copyWith({
     bool? visible,
+    InboxView? view,
+    String? Function()? conversationWorkspace,
+    String? Function()? selectedConversationId,
     String? Function()? inboxFilter,
     InboxQuestionStatus? Function()? statusFilter,
     String? Function()? selectedThreadId,
     InboxComposeRequest? Function()? compose,
     int? composeSequence,
   }) => InboxLocation(
     visible: visible ?? this.visible,
+    view: view ?? this.view,
+    conversationWorkspace: conversationWorkspace == null
+        ? this.conversationWorkspace
+        : conversationWorkspace(),
+    selectedConversationId: selectedConversationId == null
+        ? this.selectedConversationId
+        : selectedConversationId(),
     inboxFilter: inboxFilter == null ? this.inboxFilter : inboxFilter(),
     statusFilter: statusFilter == null ? this.statusFilter : statusFilter(),
     selectedThreadId: selectedThreadId == null
@@ -50,8 +66,17 @@ class InboxNavigation extends _$InboxNavigation {
 
   void close() => state = state.copyWith(visible: false);
 
-  void selectThread(String? threadId) =>
-      state = state.copyWith(selectedThreadId: () => threadId);
+  /// A thread is a question, so selecting one always shows Questions.
+  void selectThread(String? threadId) => state = state.copyWith(
+    view: InboxView.questions,
+    selectedThreadId: () => threadId,
+  );
+
+  /// Opens the page on Questions, where replies are read.
+  void openQuestions() {
+    open();
+    state = state.copyWith(view: InboxView.questions);
+  }
 
   void filterInbox(String? inbox) => state = state.copyWith(
     inboxFilter: () => inbox,
@@ -63,12 +88,23 @@ class InboxNavigation extends _$InboxNavigation {
 
   /// Opens the page and asks it to show the composer once mounted.
   void compose({String? targetHandle}) {
-    open();
+    openQuestions();
     state = state.copyWith(
       compose: () => InboxComposeRequest(targetHandle: targetHandle),
       composeSequence: state.composeSequence + 1,
     );
   }
 
   void consumeCompose() => state = state.copyWith(compose: () => null);
+
+  void showView(InboxView view) => state = state.copyWith(view: view);
+
+  void selectConversation(String? threadId) =>
+      state = state.copyWith(selectedConversationId: () => threadId);
+
+  void filterConversationWorkspace(String? workspaceId) =>
+      state = state.copyWith(
+        conversationWorkspace: () => workspaceId,
+        selectedConversationId: () => null,
+      );
 }

lib/src/features/inbox/application/inbox_navigation.dart

@@ -70,7 +70,9 @@ void inboxReplyNotificationCoordinator(Ref ref) {
       if (!isInboxNotificationPayload(payload)) return;
       unawaited(
         windowActivator.showAndFocus().then((_) {
-          if (ref.mounted) ref.read(inboxNavigationProvider.notifier).open();
+          if (ref.mounted) {
+            ref.read(inboxNavigationProvider.notifier).openQuestions();
+          }
         }),
       );
     },

lib/src/features/inbox/application/inbox_navigation.g.dart

@@ -1,5 +1,6 @@
 import 'package:alera/src/features/app_window/domain/app_foreground.dart';
 import 'package:alera/src/features/app_window/infra/lifecycle_app_foreground.dart';
+import 'package:alera/src/features/inbox/domain/conversation_models.dart';
 import 'package:alera/src/features/inbox/domain/inbox_models.dart';
 import 'package:alera/src/features/inbox/infra/runtime_inbox_repository.dart';
 import 'package:alera/src/shared/infra/runtime/runtime_host_providers.dart';
@@ -52,3 +53,13 @@ AppForeground inboxWindowFocus(Ref ref) {
   ref.onDispose(focus.dispose);
   return focus;
 }
+
+@Riverpod(retry: _noInboxRetry)
+Stream<ConversationPage> agentConversations(Ref ref, {String? workspaceId}) =>
+    ref
+        .watch(inboxRepositoryProvider)
+        .watchConversations(workspaceId: workspaceId);
+
+@Riverpod(retry: _noInboxRetry)
+Stream<ConversationDetail> agentConversation(Ref ref, String threadId) =>
+    ref.watch(inboxRepositoryProvider).watchConversation(threadId);