🗃️ Add more cache ability to local database

lib/database/account.dart

@@ -0,0 +1,40 @@
+import 'dart:convert';
+
+import 'package:drift/drift.dart';
+import 'package:surface/types/account.dart';
+
+class SnAccountConverter extends TypeConverter<SnAccount, String>
+    with JsonTypeConverter2<SnAccount, String, Map<String, Object?>> {
+  const SnAccountConverter();
+
+  @override
+  SnAccount fromSql(String fromDb) {
+    return fromJson(jsonDecode(fromDb) as Map<String, dynamic>);
+  }
+
+  @override
+  String toSql(SnAccount value) {
+    return jsonEncode(toJson(value));
+  }
+
+  @override
+  SnAccount fromJson(Map<String, Object?> json) {
+    return SnAccount.fromJson(json);
+  }
+
+  @override
+  Map<String, Object?> toJson(SnAccount value) {
+    return value.toJson();
+  }
+}
+
+@TableIndex(name: 'idx_account_name', columns: {#name})
+class SnLocalAccount extends Table {
+  IntColumn get id => integer().autoIncrement()();
+
+  TextColumn get name => text()();
+
+  TextColumn get content => text().map(const SnAccountConverter())();
+
+  DateTimeColumn get createdAt => dateTime().withDefault(currentDateAndTime)();
+}

lib/database/attachment.dart

@@ -0,0 +1,45 @@
+import 'dart:convert';
+
+import 'package:drift/drift.dart';
+import 'package:surface/types/attachment.dart';
+
+class SnAttachmentConverter extends TypeConverter<SnAttachment, String>
+    with JsonTypeConverter2<SnAttachment, String, Map<String, Object?>> {
+  const SnAttachmentConverter();
+
+  @override
+  SnAttachment fromSql(String fromDb) {
+    return fromJson(jsonDecode(fromDb) as Map<String, dynamic>);
+  }
+
+  @override
+  String toSql(SnAttachment value) {
+    return jsonEncode(toJson(value));
+  }
+
+  @override
+  SnAttachment fromJson(Map<String, Object?> json) {
+    return SnAttachment.fromJson(json);
+  }
+
+  @override
+  Map<String, Object?> toJson(SnAttachment value) {
+    return value.toJson();
+  }
+}
+
+@TableIndex(name: 'idx_attachment_rid', columns: {#rid})
+@TableIndex(name: 'idx_attachment_account', columns: {#accountId})
+class SnLocalAttachment extends Table {
+  IntColumn get id => integer().autoIncrement()();
+
+  TextColumn get rid => text().unique()();
+
+  TextColumn get uuid => text().unique()();
+
+  TextColumn get content => text().map(const SnAttachmentConverter())();
+
+  IntColumn get accountId => integer()();
+
+  DateTimeColumn get createdAt => dateTime().withDefault(currentDateAndTime)();
+}

lib/database/chat.dart

@@ -28,6 +28,7 @@ class SnChannelConverter extends TypeConverter<SnChannel, String>
   }
 }
 
+@TableIndex(name: 'idx_channel_alias', columns: {#alias})
 class SnLocalChatChannel extends Table {
   IntColumn get id => integer().autoIncrement()();
 
@@ -63,12 +64,52 @@ class SnMessageConverter extends TypeConverter<SnChatMessage, String>
   }
 }
 
+@TableIndex(name: 'idx_chat_channel', columns: {#channelId})
 class SnLocalChatMessage extends Table {
   IntColumn get id => integer().autoIncrement()();
 
   IntColumn get channelId => integer()();
 
+  IntColumn get senderId => integer().nullable()();
+
   TextColumn get content => text().map(const SnMessageConverter())();
 
   DateTimeColumn get createdAt => dateTime().withDefault(currentDateAndTime)();
 }
+
+class SnChannelMemberConverter extends TypeConverter<SnChannelMember, String>
+    with JsonTypeConverter2<SnChannelMember, String, Map<String, Object?>> {
+  const SnChannelMemberConverter();
+
+  @override
+  SnChannelMember fromSql(String fromDb) {
+    return fromJson(jsonDecode(fromDb) as Map<String, dynamic>);
+  }
+
+  @override
+  String toSql(SnChannelMember value) {
+    return jsonEncode(toJson(value));
+  }
+
+  @override
+  SnChannelMember fromJson(Map<String, Object?> json) {
+    return SnChannelMember.fromJson(json);
+  }
+
+  @override
+  Map<String, Object?> toJson(SnChannelMember value) {
+    return value.toJson();
+  }
+}
+
+class SnLocalChannelMember extends Table {
+  IntColumn get id => integer().autoIncrement()();
+
+  IntColumn get channelId => integer()();
+
+  IntColumn get accountId => integer()();
+
+  TextColumn get content => text().map(SnChannelMemberConverter())();
+
+  DateTimeColumn get createdAt => dateTime().withDefault(currentDateAndTime)();
+}

lib/database/database.dart

@@ -1,19 +1,30 @@
 import 'package:drift/drift.dart';
 import 'package:drift_flutter/drift_flutter.dart';
 import 'package:path_provider/path_provider.dart';
+import 'package:surface/database/account.dart';
+import 'package:surface/database/attachment.dart';
 import 'package:surface/database/chat.dart';
 import 'package:surface/database/database.steps.dart';
 import 'package:surface/database/keypair.dart';
 import 'package:surface/types/chat.dart';
+import 'package:surface/types/attachment.dart';
+import 'package:surface/types/account.dart';
 
 part 'database.g.dart';
 
-@DriftDatabase(tables: [SnLocalChatChannel, SnLocalChatMessage, SnLocalKeyPair])
+@DriftDatabase(tables: [
+  SnLocalChatChannel,
+  SnLocalChatMessage,
+  SnLocalChannelMember,
+  SnLocalKeyPair,
+  SnLocalAccount,
+  SnLocalAttachment,
+])
 class AppDatabase extends _$AppDatabase {
   AppDatabase([QueryExecutor? e]) : super(e ?? _openConnection());
 
   @override
-  int get schemaVersion => 2;
+  int get schemaVersion => 3;
 
   static QueryExecutor _openConnection() {
     return driftDatabase(
@@ -33,6 +44,8 @@ class AppDatabase extends _$AppDatabase {
     return MigrationStrategy(
       onUpgrade: stepByStep(from1To2: (m, schema) async {
         // Nothing else to do here
+      }, from2To3: (m, schema) async {
+        // Nothing else to do here, too
       }),
     );
   }

lib/database/database.steps.dart

@@ -140,8 +140,207 @@ i1.GeneratedColumn<bool> _column_9(String aliasedName) =>
         defaultConstraints: i1.GeneratedColumn.constraintIsAlways(
             'CHECK ("is_active" IN (0, 1))'),
         defaultValue: const CustomExpression('0'));
+
+final class Schema3 extends i0.VersionedSchema {
+  Schema3({required super.database}) : super(version: 3);
+  @override
+  late final List<i1.DatabaseSchemaEntity> entities = [
+    snLocalChatChannel,
+    snLocalChatMessage,
+    snLocalChannelMember,
+    snLocalKeyPair,
+    snLocalAccount,
+    snLocalAttachment,
+    idxChannelAlias,
+    idxChatChannel,
+    idxAccountName,
+    idxAttachmentRid,
+    idxAttachmentAccount,
+  ];
+  late final Shape0 snLocalChatChannel = Shape0(
+      source: i0.VersionedTable(
+        entityName: 'sn_local_chat_channel',
+        withoutRowId: false,
+        isStrict: false,
+        tableConstraints: [],
+        columns: [
+          _column_0,
+          _column_1,
+          _column_2,
+          _column_3,
+        ],
+        attachedDatabase: database,
+      ),
+      alias: null);
+  late final Shape3 snLocalChatMessage = Shape3(
+      source: i0.VersionedTable(
+        entityName: 'sn_local_chat_message',
+        withoutRowId: false,
+        isStrict: false,
+        tableConstraints: [],
+        columns: [
+          _column_0,
+          _column_4,
+          _column_10,
+          _column_2,
+          _column_3,
+        ],
+        attachedDatabase: database,
+      ),
+      alias: null);
+  late final Shape4 snLocalChannelMember = Shape4(
+      source: i0.VersionedTable(
+        entityName: 'sn_local_channel_member',
+        withoutRowId: false,
+        isStrict: false,
+        tableConstraints: [],
+        columns: [
+          _column_0,
+          _column_4,
+          _column_6,
+          _column_2,
+          _column_3,
+        ],
+        attachedDatabase: database,
+      ),
+      alias: null);
+  late final Shape2 snLocalKeyPair = Shape2(
+      source: i0.VersionedTable(
+        entityName: 'sn_local_key_pair',
+        withoutRowId: false,
+        isStrict: false,
+        tableConstraints: [
+          'PRIMARY KEY(id)',
+        ],
+        columns: [
+          _column_5,
+          _column_6,
+          _column_7,
+          _column_8,
+          _column_9,
+        ],
+        attachedDatabase: database,
+      ),
+      alias: null);
+  late final Shape5 snLocalAccount = Shape5(
+      source: i0.VersionedTable(
+        entityName: 'sn_local_account',
+        withoutRowId: false,
+        isStrict: false,
+        tableConstraints: [],
+        columns: [
+          _column_0,
+          _column_11,
+          _column_2,
+          _column_3,
+        ],
+        attachedDatabase: database,
+      ),
+      alias: null);
+  late final Shape6 snLocalAttachment = Shape6(
+      source: i0.VersionedTable(
+        entityName: 'sn_local_attachment',
+        withoutRowId: false,
+        isStrict: false,
+        tableConstraints: [],
+        columns: [
+          _column_0,
+          _column_12,
+          _column_13,
+          _column_2,
+          _column_6,
+          _column_3,
+        ],
+        attachedDatabase: database,
+      ),
+      alias: null);
+  final i1.Index idxChannelAlias = i1.Index('idx_channel_alias',
+      'CREATE INDEX idx_channel_alias ON sn_local_chat_channel (alias)');
+  final i1.Index idxChatChannel = i1.Index('idx_chat_channel',
+      'CREATE INDEX idx_chat_channel ON sn_local_chat_message (channel_id)');
+  final i1.Index idxAccountName = i1.Index('idx_account_name',
+      'CREATE INDEX idx_account_name ON sn_local_account (name)');
+  final i1.Index idxAttachmentRid = i1.Index('idx_attachment_rid',
+      'CREATE INDEX idx_attachment_rid ON sn_local_attachment (rid)');
+  final i1.Index idxAttachmentAccount = i1.Index('idx_attachment_account',
+      'CREATE INDEX idx_attachment_account ON sn_local_attachment (account_id)');
+}
+
+class Shape3 extends i0.VersionedTable {
+  Shape3({required super.source, required super.alias}) : super.aliased();
+  i1.GeneratedColumn<int> get id =>
+      columnsByName['id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<int> get channelId =>
+      columnsByName['channel_id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<int> get senderId =>
+      columnsByName['sender_id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<String> get content =>
+      columnsByName['content']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<DateTime> get createdAt =>
+      columnsByName['created_at']! as i1.GeneratedColumn<DateTime>;
+}
+
+i1.GeneratedColumn<int> _column_10(String aliasedName) =>
+    i1.GeneratedColumn<int>('sender_id', aliasedName, true,
+        type: i1.DriftSqlType.int);
+
+class Shape4 extends i0.VersionedTable {
+  Shape4({required super.source, required super.alias}) : super.aliased();
+  i1.GeneratedColumn<int> get id =>
+      columnsByName['id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<int> get channelId =>
+      columnsByName['channel_id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<int> get accountId =>
+      columnsByName['account_id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<String> get content =>
+      columnsByName['content']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<DateTime> get createdAt =>
+      columnsByName['created_at']! as i1.GeneratedColumn<DateTime>;
+}
+
+class Shape5 extends i0.VersionedTable {
+  Shape5({required super.source, required super.alias}) : super.aliased();
+  i1.GeneratedColumn<int> get id =>
+      columnsByName['id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<String> get name =>
+      columnsByName['name']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<String> get content =>
+      columnsByName['content']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<DateTime> get createdAt =>
+      columnsByName['created_at']! as i1.GeneratedColumn<DateTime>;
+}
+
+i1.GeneratedColumn<String> _column_11(String aliasedName) =>
+    i1.GeneratedColumn<String>('name', aliasedName, false,
+        type: i1.DriftSqlType.string);
+
+class Shape6 extends i0.VersionedTable {
+  Shape6({required super.source, required super.alias}) : super.aliased();
+  i1.GeneratedColumn<int> get id =>
+      columnsByName['id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<String> get rid =>
+      columnsByName['rid']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<String> get uuid =>
+      columnsByName['uuid']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<String> get content =>
+      columnsByName['content']! as i1.GeneratedColumn<String>;
+  i1.GeneratedColumn<int> get accountId =>
+      columnsByName['account_id']! as i1.GeneratedColumn<int>;
+  i1.GeneratedColumn<DateTime> get createdAt =>
+      columnsByName['created_at']! as i1.GeneratedColumn<DateTime>;
+}
+
+i1.GeneratedColumn<String> _column_12(String aliasedName) =>
+    i1.GeneratedColumn<String>('rid', aliasedName, false,
+        type: i1.DriftSqlType.string,
+        defaultConstraints: i1.GeneratedColumn.constraintIsAlways('UNIQUE'));
+i1.GeneratedColumn<String> _column_13(String aliasedName) =>
+    i1.GeneratedColumn<String>('uuid', aliasedName, false,
+        type: i1.DriftSqlType.string,
+        defaultConstraints: i1.GeneratedColumn.constraintIsAlways('UNIQUE'));
 i0.MigrationStepWithVersion migrationSteps({
   required Future<void> Function(i1.Migrator m, Schema2 schema) from1To2,
+  required Future<void> Function(i1.Migrator m, Schema3 schema) from2To3,
 }) {
   return (currentVersion, database) async {
     switch (currentVersion) {
@@ -150,6 +349,11 @@ i0.MigrationStepWithVersion migrationSteps({
         final migrator = i1.Migrator(database, schema);
         await from1To2(migrator, schema);
         return 2;
+      case 2:
+        final schema = Schema3(database: database);
+        final migrator = i1.Migrator(database, schema);
+        await from2To3(migrator, schema);
+        return 3;
       default:
         throw ArgumentError.value('Unknown migration from $currentVersion');
     }
@@ -158,8 +362,10 @@ i0.MigrationStepWithVersion migrationSteps({
 
 i1.OnUpgrade stepByStep({
   required Future<void> Function(i1.Migrator m, Schema2 schema) from1To2,
+  required Future<void> Function(i1.Migrator m, Schema3 schema) from2To3,
 }) =>
     i0.VersionedSchema.stepByStepHelper(
         step: migrationSteps(
       from1To2: from1To2,
+      from2To3: from2To3,
     ));

test/drift/my_database/generated/schema.dart

@@ -5,6 +5,7 @@ import 'package:drift/drift.dart';
 import 'package:drift/internal/migrations.dart';
 import 'schema_v1.dart' as v1;
 import 'schema_v2.dart' as v2;
+import 'schema_v3.dart' as v3;
 
 class GeneratedHelper implements SchemaInstantiationHelper {
   @override
@@ -14,10 +15,12 @@ class GeneratedHelper implements SchemaInstantiationHelper {
         return v1.DatabaseAtV1(db);
       case 2:
         return v2.DatabaseAtV2(db);
+      case 3:
+        return v3.DatabaseAtV3(db);
       default:
         throw MissingSchemaException(version, versions);
     }
   }
 
-  static const versions = const [1, 2];
+  static const versions = const [1, 2, 3];
 }