From fee149c1fbc63f52aa66148018e569e30cca6161 Mon Sep 17 00:00:00 2001
From: Matthias Nott <mnott@mnsoft.org>
Date: Sun, 22 Mar 2026 20:04:15 +0100
Subject: [PATCH] fix: voice transcript display, audio file persistence, debug logging
---
lib/screens/chat_screen.dart | 18 +++++++++++++++++-
1 files changed, 17 insertions(+), 1 deletions(-)
diff --git a/lib/screens/chat_screen.dart b/lib/screens/chat_screen.dart
index 0c302f5..3137ff4 100644
--- a/lib/screens/chat_screen.dart
+++ b/lib/screens/chat_screen.dart
@@ -34,6 +34,15 @@
ConsumerState<ChatScreen> createState() => _ChatScreenState();
}
+Future<void> _chatLog(String msg) async {
+ try {
+ final dir = await getApplicationDocumentsDirectory();
+ final file = File('${dir.path}/mqtt_debug.log');
+ final ts = DateTime.now().toIso8601String().substring(11, 19);
+ await file.writeAsString('[$ts] $msg\n', mode: FileMode.append);
+ } catch (_) {}
+}
+
class _ChatScreenState extends ConsumerState<ChatScreen>
with WidgetsBindingObserver {
MqttService? _ws;
@@ -307,7 +316,7 @@
Future<void> _handleIncomingVoice(Map<String, dynamic> msg) async {
final sessionId = msg['sessionId'] as String?;
final audioData = msg['audioBase64'] as String? ?? msg['audio'] as String? ?? msg['data'] as String?;
- final content = msg['content'] as String? ?? msg['text'] as String? ?? '';
+ final content = msg['content'] as String? ?? msg['transcript'] as String? ?? msg['text'] as String? ?? '';
final duration = msg['duration'] as int?;
final message = Message(
@@ -346,8 +355,11 @@
);
final activeId = ref.read(activeSessionIdProvider);
+ _chatLog('voice: sessionId=$sessionId activeId=$activeId audioPath=$savedAudioPath content="${content.substring(0, content.length.clamp(0, 30))}"');
if (sessionId != null && sessionId != activeId) {
+ _chatLog('voice: cross-session, storing for $sessionId');
await _storeForSession(sessionId, storedMessage);
+ _chatLog('voice: stored, incrementing unread');
_incrementUnread(sessionId);
final sessions = ref.read(sessionsProvider);
final session = sessions.firstWhere(
@@ -414,8 +426,12 @@
/// Store a message for a non-active session so it persists when the user switches to it.
Future<void> _storeForSession(String sessionId, Message message) async {
final existing = await MessageStore.loadAll(sessionId);
+ _chatLog('storeForSession: $sessionId existing=${existing.length} adding type=${message.type.name} content="${message.content.substring(0, message.content.length.clamp(0, 30))}" audioUri=${message.audioUri != null ? "set(${message.audioUri!.length})" : "null"}');
MessageStore.save(sessionId, [...existing, message]);
await MessageStore.flush();
+ // Verify
+ final verify = await MessageStore.loadAll(sessionId);
+ _chatLog('storeForSession: verified ${verify.length} messages after save');
}
void _incrementUnread(String sessionId) {
--
Gitblit v1.3.1