a3fe0b4b61
The mobile app was receiving SSE status events but showing the peek text only while the assistant bubble was empty — as soon as the first token arrived, the status line was replaced by streaming content and any tool calls fired mid-turn left no trace. Tool call SSE events were also being dropped by the parser, and Message.fromJson never read the persisted tool_calls array, so chips never rendered after reload either. Parse tool_call SSE frames into a new ChatToolCall event, carry tool calls on Message, and update the chat and briefing streaming loops to append chips to the in-flight assistant message as they arrive. Rework ChatMessageBubble to show a chip row + rolling peek status line above any streamed text, matching the web ToolCallCard/status indicator behaviour across chat, briefing, and briefing history surfaces. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
237 lines
8.2 KiB
Dart
237 lines
8.2 KiB
Dart
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
|
|
|
import '../data/api/chat_api.dart';
|
|
import '../data/models/briefing_conversation.dart';
|
|
import '../data/models/message.dart';
|
|
import 'api_client_provider.dart';
|
|
|
|
/// Drives the loading indicator in BriefingScreen's reply area.
|
|
final isBriefingStreamingProvider =
|
|
NotifierProvider<_BoolNotifier, bool>(_BoolNotifier.new);
|
|
|
|
class _BoolNotifier extends Notifier<bool> {
|
|
@override
|
|
bool build() => false;
|
|
}
|
|
|
|
final briefingProvider =
|
|
AsyncNotifierProvider<BriefingNotifier, BriefingConversation>(
|
|
BriefingNotifier.new);
|
|
|
|
class BriefingNotifier extends AsyncNotifier<BriefingConversation> {
|
|
@override
|
|
Future<BriefingConversation> build() async {
|
|
return ref.read(briefingApiProvider).getToday();
|
|
}
|
|
|
|
/// Silently fetch the latest briefing and patch state without triggering
|
|
/// AsyncLoading — existing content stays visible while the fetch is in flight.
|
|
Future<void> silentRefresh() async {
|
|
final current = state.value;
|
|
if (current == null) return;
|
|
try {
|
|
final fresh = await ref.read(briefingApiProvider).getToday();
|
|
final curLast = current.messages.isNotEmpty ? current.messages.last : null;
|
|
final newLast = fresh.messages.isNotEmpty ? fresh.messages.last : null;
|
|
if (fresh.messages.length != current.messages.length ||
|
|
newLast?.content != curLast?.content) {
|
|
state = AsyncData(fresh);
|
|
}
|
|
} catch (_) {
|
|
// Network hiccup — silently ignore, keep existing content
|
|
}
|
|
}
|
|
|
|
/// Trigger a briefing slot (e.g. "compilation") then reload.
|
|
Future<void> refresh(String slot) async {
|
|
await ref.read(briefingApiProvider).triggerSlot(slot);
|
|
ref.invalidateSelf();
|
|
await future;
|
|
}
|
|
|
|
/// Inject a news article as context and trigger generation.
|
|
///
|
|
/// Mirrors sendReply() but calls the /discuss endpoint instead of
|
|
/// /messages so the backend injects article content before generating.
|
|
Future<void> discussArticle(int convId, int itemId) async {
|
|
final conv = state.value;
|
|
if (conv == null) return;
|
|
final chatApi = ref.read(chatApiProvider);
|
|
final briefingApi = ref.read(briefingApiProvider);
|
|
|
|
final previous = conv.messages;
|
|
final placeholder = Message(
|
|
conversationId: convId,
|
|
role: MessageRole.assistant,
|
|
content: '',
|
|
status: 'generating',
|
|
);
|
|
state = AsyncData(conv.copyWith(messages: [...previous, placeholder]));
|
|
ref.read(isBriefingStreamingProvider.notifier).state = true;
|
|
|
|
try {
|
|
await briefingApi.discussArticle(convId, itemId);
|
|
} catch (e) {
|
|
state = AsyncData(conv.copyWith(messages: previous));
|
|
ref.read(isBriefingStreamingProvider.notifier).state = false;
|
|
rethrow;
|
|
}
|
|
|
|
// SSE stream (best-effort)
|
|
bool streamedContent = false;
|
|
try {
|
|
await for (final event in chatApi.streamGeneration(convId)) {
|
|
final current = state.value;
|
|
if (current == null) break;
|
|
final msgs = current.messages;
|
|
if (msgs.isEmpty) continue;
|
|
if (event is ChatTextChunk) {
|
|
streamedContent = true;
|
|
final updated =
|
|
msgs.last.copyWith(content: msgs.last.content + event.text);
|
|
state = AsyncData(current.copyWith(
|
|
messages: [...msgs.sublist(0, msgs.length - 1), updated]));
|
|
} else if (event is ChatToolCall) {
|
|
final last = msgs.last;
|
|
if (last.role != MessageRole.assistant) continue;
|
|
final nextCalls = [...?last.toolCalls, event.toolCall];
|
|
final updated = last.copyWith(toolCalls: nextCalls);
|
|
state = AsyncData(current.copyWith(
|
|
messages: [...msgs.sublist(0, msgs.length - 1), updated]));
|
|
}
|
|
}
|
|
} catch (_) {
|
|
// Fall through to polling.
|
|
}
|
|
|
|
// Poll until complete (max 20 attempts, 2s apart)
|
|
try {
|
|
for (var attempt = 0; attempt < 20; attempt++) {
|
|
if (attempt > 0) await Future.delayed(const Duration(seconds: 2));
|
|
final fresh = await briefingApi.getMessages(convId);
|
|
final done = fresh.any(
|
|
(m) => m.role == MessageRole.assistant && m.status != 'generating',
|
|
);
|
|
final hasContent = fresh.any(
|
|
(m) => m.role == MessageRole.assistant && m.content.isNotEmpty,
|
|
);
|
|
final current = state.value;
|
|
if (current != null && (!streamedContent || done || hasContent)) {
|
|
state = AsyncData(current.copyWith(messages: fresh));
|
|
}
|
|
if (done) break;
|
|
}
|
|
} catch (_) {
|
|
final current = state.value;
|
|
if (current != null) {
|
|
final msgs = current.messages;
|
|
if (msgs.isNotEmpty && msgs.last.status == 'generating') {
|
|
state = AsyncData(current.copyWith(messages: [
|
|
...msgs.sublist(0, msgs.length - 1),
|
|
msgs.last.copyWith(status: 'complete'),
|
|
]));
|
|
}
|
|
}
|
|
} finally {
|
|
ref.read(isBriefingStreamingProvider.notifier).state = false;
|
|
}
|
|
}
|
|
|
|
/// Send a reply to today's briefing conversation.
|
|
///
|
|
/// Mirrors MessagesNotifier.sendMessage():
|
|
/// 1. Optimistic UI update
|
|
/// 2. POST message to chat endpoint
|
|
/// 3. SSE stream (best-effort)
|
|
/// 4. Poll until complete
|
|
Future<void> sendReply(String content) async {
|
|
final conv = state.value;
|
|
if (conv == null) return;
|
|
final convId = conv.id;
|
|
final chatApi = ref.read(chatApiProvider);
|
|
|
|
final previous = conv.messages;
|
|
final userMsg = Message(
|
|
conversationId: convId,
|
|
role: MessageRole.user,
|
|
content: content,
|
|
);
|
|
final placeholder = Message(
|
|
conversationId: convId,
|
|
role: MessageRole.assistant,
|
|
content: '',
|
|
status: 'generating',
|
|
);
|
|
state = AsyncData(conv.copyWith(messages: [...previous, userMsg, placeholder]));
|
|
ref.read(isBriefingStreamingProvider.notifier).state = true;
|
|
|
|
try {
|
|
await chatApi.sendMessage(convId, content);
|
|
} catch (e) {
|
|
state = AsyncData(conv.copyWith(messages: previous));
|
|
ref.read(isBriefingStreamingProvider.notifier).state = false;
|
|
rethrow;
|
|
}
|
|
|
|
// SSE stream (best-effort)
|
|
bool streamedContent = false;
|
|
try {
|
|
await for (final event in chatApi.streamGeneration(convId)) {
|
|
final current = state.value;
|
|
if (current == null) break;
|
|
final msgs = current.messages;
|
|
if (msgs.isEmpty) continue;
|
|
if (event is ChatTextChunk) {
|
|
streamedContent = true;
|
|
final updated =
|
|
msgs.last.copyWith(content: msgs.last.content + event.text);
|
|
state = AsyncData(current.copyWith(
|
|
messages: [...msgs.sublist(0, msgs.length - 1), updated]));
|
|
} else if (event is ChatToolCall) {
|
|
final last = msgs.last;
|
|
if (last.role != MessageRole.assistant) continue;
|
|
final nextCalls = [...?last.toolCalls, event.toolCall];
|
|
final updated = last.copyWith(toolCalls: nextCalls);
|
|
state = AsyncData(current.copyWith(
|
|
messages: [...msgs.sublist(0, msgs.length - 1), updated]));
|
|
}
|
|
}
|
|
} catch (_) {
|
|
// Fall through to polling.
|
|
}
|
|
|
|
// Poll until complete (max 20 attempts, 2s apart)
|
|
try {
|
|
for (var attempt = 0; attempt < 20; attempt++) {
|
|
if (attempt > 0) await Future.delayed(const Duration(seconds: 2));
|
|
final fresh = await ref.read(briefingApiProvider).getMessages(convId);
|
|
final done = fresh.any(
|
|
(m) => m.role == MessageRole.assistant && m.status != 'generating',
|
|
);
|
|
final hasContent = fresh.any(
|
|
(m) => m.role == MessageRole.assistant && m.content.isNotEmpty,
|
|
);
|
|
final current = state.value;
|
|
if (current != null && (!streamedContent || done || hasContent)) {
|
|
state = AsyncData(current.copyWith(messages: fresh));
|
|
}
|
|
if (done) break;
|
|
}
|
|
} catch (_) {
|
|
// Clear the generating placeholder so UI doesn't spin forever.
|
|
final current = state.value;
|
|
if (current != null) {
|
|
final msgs = current.messages;
|
|
if (msgs.isNotEmpty && msgs.last.status == 'generating') {
|
|
state = AsyncData(current.copyWith(messages: [
|
|
...msgs.sublist(0, msgs.length - 1),
|
|
msgs.last.copyWith(status: 'complete'),
|
|
]));
|
|
}
|
|
}
|
|
} finally {
|
|
ref.read(isBriefingStreamingProvider.notifier).state = false;
|
|
}
|
|
}
|
|
}
|