loadThreadMessages method

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

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) => _decodeMap(row['message_json']))
      .toList(growable: false);
}