Merge pull request 'STT context, refresh improvements, calendar timezone fix' (#16) from dev into main

Offline queue (SharedPreferences) persists captures when the device
is offline and replays them as chat conversations on next launch,
preserving the same fire-and-forget guarantee as the online path.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

lib/app.dart

@@ -5,10 +5,10 @@ import 'package:go_router/go_router.dart';
 import 'package:flutter_timezone/flutter_timezone.dart';
 
 import 'core/constants.dart';
-import 'core/exceptions.dart';
 import 'core/theme.dart';
 import 'providers/api_client_provider.dart';
 import 'providers/auth_provider.dart';
+import 'core/exceptions.dart';
 import 'providers/capture_queue_provider.dart';
 import 'providers/capture_work_queue_provider.dart';
 import 'providers/briefing_provider.dart';
@@ -16,10 +16,8 @@ import 'providers/calendar_provider.dart';
 import 'providers/chat_provider.dart';
 import 'providers/knowledge_provider.dart';
 import 'providers/news_provider.dart';
-import 'providers/notes_provider.dart';
 import 'providers/settings_provider.dart';
 import 'providers/update_provider.dart';
-import 'providers/tasks_provider.dart';
 import 'screens/auth/login_screen.dart';
 import 'screens/briefing/briefing_screen.dart';
 import 'screens/knowledge/knowledge_screen.dart';
@@ -195,7 +193,7 @@ class _ShellState extends ConsumerState<_Shell> with WidgetsBindingObserver {
   ];
 
   // Minimum gap between app-resume refreshes to avoid hammering the server.
-  static const _resumeCooldown = Duration(minutes: 5);
+  static const _resumeCooldown = Duration(seconds: 30);
   DateTime? _lastResumeRefresh;
   int? _prevTabIndex;
 
@@ -541,27 +539,19 @@ class _QuickCaptureBarState extends ConsumerState<_QuickCaptureBar> {
     if (!mounted) return;
     final queue = ref.read(captureQueueProvider);
     if (queue.isEmpty) return;
-    final api = ref.read(quickCaptureApiProvider);
     for (final text in List<String>.from(queue)) {
       if (!mounted) break;
       try {
-        final result = await api.capture(text);
+        final conv =
-        // Dequeue before the mounted check — SharedPreferences doesn't need
+            await ref.read(conversationsProvider.notifier).create('');
-        // the widget alive, and skipping this would leave a ghost item.
+        final chatRepo = ref.read(chatRepositoryProvider);
+        await chatRepo.sendMessage(conv.id, text);
+        chatRepo.streamGeneration(conv.id).drain<void>().ignore();
         await ref.read(captureQueueProvider.notifier).dequeue(text);
-        if (!mounted) break;
-        switch (result.type) {
-          case 'note':
-            ref.invalidate(notesProvider);
-          case 'task':
-          case 'todo':
-            ref.invalidate(tasksProvider);
-        }
       } on NetworkException {
         break;
       } catch (_) {
-        // Server error or unexpected failure — drop from queue to prevent
+        // Server error — drop from queue to prevent ghost items.
-        // ghost items that can never be cleared.
         await ref.read(captureQueueProvider.notifier).dequeue(text);
       }
     }

lib/data/api/voice_api.dart

@@ -40,16 +40,20 @@ class VoiceApi {
   }
 
   /// POST WebM/Opus audio bytes and return the transcript string.
+  /// [context] is optional recent conversation text passed as initial_prompt
+  /// to Whisper, reducing mishearings of domain-specific words.
   /// Returns empty string on empty or error response.
-  Future<String> transcribe(Uint8List audioBytes) async {
+  Future<String> transcribe(Uint8List audioBytes, {String? context}) async {
     try {
-      final formData = FormData.fromMap({
+      final fields = <String, dynamic>{
         'audio': MultipartFile.fromBytes(
           audioBytes,
           filename: 'audio.m4a',
           contentType: DioMediaType('audio', 'mp4'),
         ),
-      });
+        if (context != null && context.isNotEmpty) 'context': context,
+      };
+      final formData = FormData.fromMap(fields);
       final response = await _dio.post(
         '/api/voice/transcribe',
         data: formData,

lib/data/models/calendar_event.dart

@@ -28,9 +28,9 @@ class CalendarEvent {
   factory CalendarEvent.fromJson(Map<String, dynamic> json) => CalendarEvent(
         id: json['id'] as int,
         title: json['title'] as String? ?? '',
-        startDt: DateTime.parse(json['start_dt'] as String),
+        startDt: DateTime.parse(json['start_dt'] as String).toLocal(),
         endDt: json['end_dt'] != null
-            ? DateTime.parse(json['end_dt'] as String)
+            ? DateTime.parse(json['end_dt'] as String).toLocal()
             : null,
         allDay: json['all_day'] as bool? ?? false,
         description: json['description'] as String? ?? '',

lib/data/repositories/voice_repository.dart

@@ -7,6 +7,7 @@ class VoiceRepository {
   const VoiceRepository(this._api);
 
   Future<VoiceStatus> checkStatus() => _api.checkStatus();
-  Future<String> transcribe(Uint8List audioBytes) => _api.transcribe(audioBytes);
+  Future<String> transcribe(Uint8List audioBytes, {String? context}) =>
+      _api.transcribe(audioBytes, context: context);
   Future<Uint8List> synthesise(String text) => _api.synthesise(text);
 }

lib/providers/capture_work_queue_provider.dart

@@ -3,8 +3,7 @@ import 'package:flutter_riverpod/flutter_riverpod.dart';
 import '../core/exceptions.dart';
 import 'api_client_provider.dart';
 import 'capture_queue_provider.dart';
-import 'notes_provider.dart';
+import 'chat_provider.dart';
-import 'tasks_provider.dart';
 
 /// Outcome of a single capture attempt — consumed by the UI for snackbars.
 class CaptureResult {
@@ -25,7 +24,6 @@ class _CaptureResultNotifier extends Notifier<CaptureResult?> {
 }
 
 /// In-memory sequential work queue for quick captures.
-/// Separate from [captureQueueProvider] (which is the offline persistence queue).
 final captureWorkQueueProvider =
     NotifierProvider<CaptureWorkQueueNotifier, List<String>>(
   CaptureWorkQueueNotifier.new,
@@ -52,31 +50,24 @@ class CaptureWorkQueueNotifier extends Notifier<List<String>> {
         // Signal "no result yet" so the same result value can re-trigger watch.
         ref.read(captureResultProvider.notifier).state = null;
         try {
-          final api = ref.read(quickCaptureApiProvider);
+          // Create a new conversation, add it to the conversations list, then
-          final result = await api.capture(text);
+          // send the message and kick off generation in the background.
+          final conv =
+              await ref.read(conversationsProvider.notifier).create('');
+          final chatRepo = ref.read(chatRepositoryProvider);
+          await chatRepo.sendMessage(conv.id, text);
+          // Fire-and-forget: drain the SSE stream so the server generates a
+          // response (creating notes/tasks/etc.) without blocking the UI.
+          chatRepo.streamGeneration(conv.id).drain<void>().ignore();
 
-          // Dequeue on success.
           state = state.length > 1 ? state.sublist(1) : [];
-
+          ref.read(captureResultProvider.notifier).state =
-          // Invalidate content providers so lists refresh.
+              const CaptureResult('Sent to Fabled.');
-          switch (result.type) {
-            case 'note':
-              ref.invalidate(notesProvider);
-            case 'task':
-            case 'todo':
-              ref.invalidate(tasksProvider);
-          }
-
-          // Publish result for snackbar.
-          final msg = result.message.isNotEmpty
-              ? result.message
-              : '${_typeLabel(result.type)} created: ${result.title}';
-          ref.read(captureResultProvider.notifier).state = CaptureResult(msg);
         } on NetworkException catch (_) {
           // Persist to offline queue and stop draining — still offline.
           await ref.read(captureQueueProvider.notifier).enqueue(text);
           state = state.length > 1 ? state.sublist(1) : [];
-          ref.read(captureResultProvider.notifier).state = CaptureResult(
+          ref.read(captureResultProvider.notifier).state = const CaptureResult(
             "You're offline — capture saved and will retry automatically.",
           );
           break;
@@ -86,20 +77,13 @@ class CaptureWorkQueueNotifier extends Notifier<List<String>> {
               CaptureResult(e.message, isError: true);
         } catch (_) {
           state = state.length > 1 ? state.sublist(1) : [];
-          ref.read(captureResultProvider.notifier).state =
+          ref.read(captureResultProvider.notifier).state = const CaptureResult(
-              CaptureResult('Capture failed. Please try again.', isError: true);
+              'Failed to send. Please try again.',
+              isError: true);
         }
       }
     } finally {
       _running = false;
     }
   }
-
-  String _typeLabel(String type) => switch (type) {
-        'note' => 'Note',
-        'task' => 'Task',
-        'event' => 'Event',
-        'todo' => 'To-do',
-        _ => type,
-      };
 }

lib/providers/voice_provider.dart

@@ -108,6 +108,10 @@ class VoiceNotifier extends Notifier<VoiceState> {
   int _lastSeenLength = 0;
   bool _streamComplete = false;
 
+  // Last complete assistant response — passed to Whisper as initial_prompt
+  // to reduce STT mishearings of domain-specific words.
+  String _lastAssistantContent = '';
+
   // TTS playback queue
   final _ttsQueue = Queue<Uint8List>();
   bool _ttsPlaying = false;
@@ -205,6 +209,7 @@ class VoiceNotifier extends Notifier<VoiceState> {
     _dispatchSentences(flush: isComplete);
 
     if (isComplete) {
+      _lastAssistantContent = fullContent;
       _streamComplete = true;
       _checkRestartListening();
     }
@@ -278,8 +283,10 @@ class VoiceNotifier extends Notifier<VoiceState> {
 
       if (!state.voiceModeActive) return;
 
-      final transcript =
+      final transcript = await ref.read(voiceRepositoryProvider).transcribe(
-          await ref.read(voiceRepositoryProvider).transcribe(bytes);
+            bytes,
+            context: _lastAssistantContent.isNotEmpty ? _lastAssistantContent : null,
+          );
 
       if (!state.voiceModeActive) return;
 

lib/screens/calendar/calendar_screen.dart

@@ -67,10 +67,13 @@ class CalendarScreen extends ConsumerWidget {
             ),
             const Divider(height: 1),
             Expanded(
-              child: _AgendaList(
+              child: RefreshIndicator(
-                events:
+                onRefresh: () async => ref.invalidate(calendarProvider),
-                    cal.eventsByDay[dateOnly(cal.selectedDay)] ?? [],
+                child: _AgendaList(
-                notifier: notifier,
+                  events:
+                      cal.eventsByDay[dateOnly(cal.selectedDay)] ?? [],
+                  notifier: notifier,
+                ),
               ),
             ),
           ],
@@ -106,7 +109,12 @@ class _AgendaList extends StatelessWidget {
   @override
   Widget build(BuildContext context) {
     if (events.isEmpty) {
-      return const Center(child: Text('No events'));
+      return ListView(
+        children: const [
+          SizedBox(height: 80),
+          Center(child: Text('No events')),
+        ],
+      );
     }
     return ListView.builder(
       padding: const EdgeInsets.symmetric(vertical: 8),

lib/screens/calendar/event_form_sheet.dart

@@ -143,19 +143,19 @@ class _EventFormSheetState extends ConsumerState<EventFormSheet> {
   Future<void> _delete() async {
     final confirmed = await showDialog<bool>(
       context: context,
-      builder: (_) => AlertDialog(
+      builder: (dialogContext) => AlertDialog(
         title: const Text('Delete this event?'),
         actions: [
           TextButton(
-            onPressed: () => Navigator.of(context).pop(false),
+            onPressed: () => Navigator.pop(dialogContext, false),
             child: const Text('Cancel'),
           ),
           TextButton(
-            onPressed: () => Navigator.of(context).pop(true),
+            onPressed: () => Navigator.pop(dialogContext, true),
             child: Text(
               'Delete',
-              style:
+              style: TextStyle(
-                  TextStyle(color: Theme.of(context).colorScheme.error),
+                  color: Theme.of(dialogContext).colorScheme.error),
             ),
           ),
         ],

lib/screens/chat/chat_screen.dart

@@ -16,12 +16,27 @@ class ChatScreen extends ConsumerStatefulWidget {
   ConsumerState<ChatScreen> createState() => _ChatScreenState();
 }
 
-class _ChatScreenState extends ConsumerState<ChatScreen> {
+class _ChatScreenState extends ConsumerState<ChatScreen>
+    with WidgetsBindingObserver {
   final _controller = TextEditingController();
   final _scrollController = ScrollController();
 
+  @override
+  void initState() {
+    super.initState();
+    WidgetsBinding.instance.addObserver(this);
+  }
+
+  @override
+  void didChangeAppLifecycleState(AppLifecycleState state) {
+    if (state == AppLifecycleState.resumed) {
+      ref.invalidate(messagesProvider(widget.conversationId));
+    }
+  }
+
   @override
   void dispose() {
+    WidgetsBinding.instance.removeObserver(this);
     _controller.dispose();
     _scrollController.dispose();
     // Exit voice mode if the user navigates away mid-session.

lib/screens/chat/conversations_tab_screen.dart

@@ -99,15 +99,15 @@ class ConversationsTabScreen extends ConsumerWidget {
       BuildContext context, WidgetRef ref, int id, String title) async {
     final ok = await showDialog<bool>(
       context: context,
-      builder: (_) => AlertDialog(
+      builder: (dialogContext) => AlertDialog(
         title: const Text('Delete conversation?'),
         content: Text('"$title" will be permanently deleted.'),
         actions: [
           TextButton(
-              onPressed: () => Navigator.pop(context, false),
+              onPressed: () => Navigator.pop(dialogContext, false),
               child: const Text('Cancel')),
           FilledButton(
-              onPressed: () => Navigator.pop(context, true),
+              onPressed: () => Navigator.pop(dialogContext, true),
               child: const Text('Delete')),
         ],
       ),

lib/screens/news/news_screen.dart

@@ -96,7 +96,9 @@ class _NewsScreenState extends ConsumerState<NewsScreen> {
             ),
             const Divider(height: 1),
             Expanded(
-              child: ListView.builder(
+              child: RefreshIndicator(
+                onRefresh: () async => ref.invalidate(newsProvider),
+                child: ListView.builder(
                 padding:
                     const EdgeInsets.symmetric(horizontal: 8, vertical: 8),
                 itemCount: news.items.length + 1,
@@ -128,6 +130,7 @@ class _NewsScreenState extends ConsumerState<NewsScreen> {
                   );
                 },
               ),
+              ),
             ),
           ],
         ),