saveThreadMessage method

@override Future<void> saveThreadMessage(String threadId, Map<String, dynamic> message)

Implementation

@override
Future<void> saveThreadMessage(
  String threadId,
  Map<String, dynamic> message,
) async {
  await _ensureTables();
  await DB.execute(
    'INSERT INTO $_threadMessagesTable (thread_id, message_json, created_at) VALUES (?, ?, ?)',
    positionalParams: [
      threadId,
      jsonEncode(message),
      DateTime.now().toIso8601String(),
    ],
  );
}