67 lines
1.8 KiB
Dart
67 lines
1.8 KiB
Dart
import 'dart:async';
|
|
import 'dart:convert';
|
|
import 'package:floor/floor.dart';
|
|
import 'package:solian/models/message.dart';
|
|
import 'package:sqflite/sqflite.dart' as sqflite;
|
|
|
|
part 'history.g.dart';
|
|
|
|
@entity
|
|
class LocalMessage {
|
|
@primaryKey
|
|
final int id;
|
|
|
|
final Message data;
|
|
final int channelId;
|
|
|
|
LocalMessage(this.id, this.data, this.channelId);
|
|
}
|
|
|
|
class RemoteMessageConverter extends TypeConverter<Message, String> {
|
|
@override
|
|
Message decode(String databaseValue) {
|
|
return Message.fromJson(jsonDecode(databaseValue));
|
|
}
|
|
|
|
@override
|
|
String encode(Message value) {
|
|
return jsonEncode(value.toJson());
|
|
}
|
|
}
|
|
|
|
@dao
|
|
abstract class LocalMessageDao {
|
|
@Query('SELECT COUNT(id) FROM LocalMessage WHERE channelId = :channelId')
|
|
Future<int?> countByChannel(int channelId);
|
|
|
|
@Query('SELECT * FROM LocalMessage WHERE channelId = :channelId ORDER BY id DESC')
|
|
Future<List<LocalMessage>> findAllByChannel(int channelId);
|
|
|
|
@Query('SELECT * FROM LocalMessage WHERE channelId = :channelId ORDER BY id DESC LIMIT 1')
|
|
Future<LocalMessage?> findLastByChannel(int channelId);
|
|
|
|
@Insert(onConflict: OnConflictStrategy.replace)
|
|
Future<void> insert(LocalMessage m);
|
|
|
|
@Insert(onConflict: OnConflictStrategy.replace)
|
|
Future<void> insertBulk(List<LocalMessage> m);
|
|
|
|
@Update(onConflict: OnConflictStrategy.replace)
|
|
Future<void> update(LocalMessage person);
|
|
|
|
@Query('DELETE FROM LocalMessage WHERE id = :id')
|
|
Future<void> delete(int id);
|
|
|
|
@Query('DELETE FROM LocalMessage WHERE channelId = :channelId')
|
|
Future<List<LocalMessage>> deleteByChannel(int channelId);
|
|
|
|
@Query('DELETE FROM LocalMessage')
|
|
Future<void> wipeLocalMessages();
|
|
}
|
|
|
|
@TypeConverters([RemoteMessageConverter])
|
|
@Database(version: 1, entities: [LocalMessage])
|
|
abstract class MessageHistoryDb extends FloorDatabase {
|
|
LocalMessageDao get localMessages;
|
|
}
|