loadThreadMessages method

  1. @override
Future<List<Map<String, dynamic>>> loadThreadMessages(
  1. String threadId
)
override

Implementation

@override
Future<List<Map<String, dynamic>>> loadThreadMessages(String threadId) async {
  await _ensureTables();
  final rows = await DB.query(
    'SELECT message_json FROM $_threadMessagesTable WHERE thread_id = ? ORDER BY id ASC',
    positionalParams: [threadId],
  );
  return rows
      .map(
        (row) => Map<String, dynamic>.from(
          jsonDecode(row['message_json'].toString()) as Map,
        ),
      )
      .toList(growable: false);
}