Device transfer (MixinNetwork#1122)

* add protocol * add * improve crc check * attachment * attachment * fix transfer data * refactor * add convert * fix warning * add DEVICE_TRANSFER plain * fix * fix warning * link info * device transfer * handle received packet * improve * add participant and others * refactor * refactor * fix * folder * improve ui * send * emit event * improve * add count support * add tests * add ui * improve ui * add more test * fix test run * fix format * improve device transfer dialog * improve style * fix back button style * connet command add userId * improve * confirm restore * improve ui * send participant first * fix format * improve * i10n * progress * close server if verification code not match * fix handle pin message * improve style * fix writePacketToSink * decrease notify duration * fix re login * fix ci * remove about * add delay * fix format * improve test * test * improve ui * add network server permission * ensure sender progress * test write file to system temp file * improve * fix receive file * check primary session * fix media duration type * bump mixin_logger version * add type command * check command version * replace with asyncListen * fix process attachment if message id duplicated * fix message order * improve _processPinMessage * improve update conversation unseen count when insert message * process transcript message * fix format * show device transfer menu bar on macOS in debug mode
petercao · Apr 11, 2023 · 0617bfb · 0617bfb
1 parent 2c9ea0f
commit 0617bfb
Show file tree

Hide file tree

Showing 103 changed files with 7,399 additions and 507 deletions.
diff --git a/analysis_options.yaml b/analysis_options.yaml
@@ -33,6 +33,7 @@ analyzer:
     - '**.g.dart'
     #    - 'editable/**'
     - 'third_party/**'
+    - 'lib/constants/resources.preview.dart'
 
 linter:
   rules:

diff --git a/assets/images/device_transfer.svg b/assets/images/device_transfer.svg
diff --git a/assets/images/transfer_from_phone.svg b/assets/images/transfer_from_phone.svg
diff --git a/assets/images/transfer_to_phone.svg b/assets/images/transfer_to_phone.svg
diff --git a/lib/blaze/vo/plain_json_message.dart b/lib/blaze/vo/plain_json_message.dart
@@ -5,8 +5,34 @@ part 'plain_json_message.g.dart';
 
 @JsonSerializable()
 class PlainJsonMessage {
-  PlainJsonMessage(this.action, this.messages, this.userId, this.messageId,
-      this.sessionId, this.ackMessages);
+  PlainJsonMessage(
+    this.action,
+    this.messages,
+    this.userId,
+    this.messageId,
+    this.sessionId,
+    this.ackMessages, {
+    this.content,
+  });
+
+  factory PlainJsonMessage.create({
+    required String action,
+    List<String>? messages,
+    String? userId,
+    String? messageId,
+    String? sessionId,
+    List<BlazeAckMessage>? ackMessages,
+    String? content,
+  }) =>
+      PlainJsonMessage(
+        action,
+        messages,
+        userId,
+        messageId,
+        sessionId,
+        ackMessages,
+        content: content,
+      );
 
   factory PlainJsonMessage.fromJson(Map<String, dynamic> json) =>
       _$PlainJsonMessageFromJson(json);
@@ -24,5 +50,8 @@ class PlainJsonMessage {
   @JsonKey(name: 'ack_messages')
   List<BlazeAckMessage>? ackMessages;
 
+  @JsonKey(name: 'content')
+  String? content;
+
   Map<String, dynamic> toJson() => _$PlainJsonMessageToJson(this);
 }
diff --git a/lib/blaze/vo/plain_json_message.g.dart b/lib/blaze/vo/plain_json_message.g.dart
diff --git a/lib/constants/constants.dart b/lib/constants/constants.dart
@@ -6,6 +6,7 @@ const scpFull = 'FULL';
 
 const kAcknowledgeMessageReceipt = 'ACKNOWLEDGE_MESSAGE_RECEIPT';
 const kAcknowledgeMessageReceipts = 'ACKNOWLEDGE_MESSAGE_RECEIPTS';
+const kDeviceTransfer = 'DEVICE_TRANSFER';
 const kSendingMessage = 'SENDING_MESSAGE';
 const kRecallMessage = 'RECALL_MESSAGE';
 const kPinMessage = 'PIN_MESSAGE';

diff --git a/lib/constants/resources.dart b/lib/constants/resources.dart
diff --git a/lib/db/dao/asset_dao.dart b/lib/db/dao/asset_dao.dart
@@ -39,6 +39,9 @@ class AssetDao extends DatabaseAccessor<MixinDatabase> with _$AssetDaoMixin {
   Future<int> insertSdkAsset(sdk.Asset asset) =>
       into(db.assets).insertOnConflictUpdate(asset.asAssetsCompanion);
 
+  Future<int> insertAsset(Asset asset) =>
+      into(db.assets).insert(asset, mode: InsertMode.insertOrIgnore);
+
   Future deleteAsset(Asset asset) => delete(db.assets).delete(asset);
 
   Future<Asset?> findAssetById(String assetId) =>
@@ -49,4 +52,6 @@ class AssetDao extends DatabaseAccessor<MixinDatabase> with _$AssetDaoMixin {
       select(db.assets)
         ..where((t) => t.assetId.equals(assetId))
         ..limit(1);
+
+  Future<List<Asset>> getAssets() => (select(db.assets)).get();
 }
diff --git a/lib/db/dao/asset_dao.g.dart b/lib/db/dao/asset_dao.g.dart
diff --git a/lib/db/dao/conversation_dao.dart b/lib/db/dao/conversation_dao.dart
@@ -501,4 +501,15 @@ class ConversationDao extends DatabaseAccessor<MixinDatabase>
     }
     return isBotConversation ? EncryptCategory.plain : EncryptCategory.signal;
   }
+
+  Future<List<Conversation>> getConversations({
+    required int limit,
+    required int offset,
+  }) =>
+      (select(db.conversations)
+            ..orderBy([
+              (c) => OrderingTerm.asc(c.rowId),
+            ])
+            ..limit(limit, offset: offset))
+          .get();
 }
diff --git a/lib/db/dao/expired_message_dao.dart b/lib/db/dao/expired_message_dao.dart
@@ -3,6 +3,7 @@ import 'package:drift/drift.dart';
 import '../../constants/constants.dart';
 import '../../utils/extension/extension.dart';
 import '../database_event_bus.dart';
+import '../extension/db.dart';
 import '../mixin_database.dart';
 
 part 'expired_message_dao.g.dart';
@@ -21,13 +22,15 @@ class ExpiredMessageDao extends DatabaseAccessor<MixinDatabase>
     required String messageId,
     required int expireIn,
     int? expireAt,
+    bool updateIfConflict = true,
   }) async {
-    await into(db.expiredMessages).insertOnConflictUpdate(
+    await into(db.expiredMessages).simpleInsert(
       ExpiredMessagesCompanion.insert(
         messageId: messageId,
         expireIn: expireIn,
         expireAt: Value(expireAt),
       ),
+      updateIfConflict: updateIfConflict,
     );
     DataBaseEventBus.instance.updateExpiredMessageTable();
   }

diff --git a/lib/db/dao/expired_message_dao.g.dart b/lib/db/dao/expired_message_dao.g.dart