LCOV - code coverage report
Current view: top level - lib/cwtch - cwtchNotifier.dart (source / functions) Hit Total Coverage
Test: lcov.info Lines: 0 285 0.0 %
Date: 2024-09-10 17:47:43 Functions: 0 0 -

          Line data    Source code
       1             : import 'dart:convert';
       2             : import 'package:cwtch/cwtch/cwtch.dart';
       3             : import 'package:cwtch/main.dart';
       4             : import 'package:cwtch/models/appstate.dart';
       5             : import 'package:cwtch/models/contact.dart';
       6             : import 'package:cwtch/models/profilelist.dart';
       7             : import 'package:cwtch/models/remoteserver.dart';
       8             : import 'package:cwtch/models/servers.dart';
       9             : import 'package:cwtch/notification_manager.dart';
      10             : 
      11             : import 'package:cwtch/torstatus.dart';
      12             : 
      13             : import '../config.dart';
      14             : import '../errorHandler.dart';
      15             : import '../settings.dart';
      16             : 
      17             : typedef SeenMessageCallback = Function(String, int, DateTime);
      18             : 
      19             : // Class that handles libcwtch-go events (received either via ffi with an isolate or gomobile over a method channel from kotlin)
      20             : //   Takes Notifiers and triggers them on appropriate events
      21             : class CwtchNotifier {
      22             :   late ProfileListState profileCN;
      23             :   late Settings settings;
      24             :   late ErrorHandler error;
      25             :   late TorStatus torStatus;
      26             :   late NotificationsManager notificationManager;
      27             :   late AppState appState;
      28             :   late ServerListState serverListState;
      29             :   late FlwtchState flwtchState;
      30             : 
      31             :   String? notificationSimple;
      32             :   String? notificationConversationInfo;
      33             : 
      34             :   SeenMessageCallback? seenMessageCallback;
      35             : 
      36           0 :   CwtchNotifier(ProfileListState pcn, Settings settingsCN, ErrorHandler errorCN, TorStatus torStatusCN, NotificationsManager notificationManagerP, AppState appStateCN,
      37             :       ServerListState serverListStateCN, FlwtchState flwtchStateCN) {
      38           0 :     profileCN = pcn;
      39           0 :     settings = settingsCN;
      40           0 :     error = errorCN;
      41           0 :     torStatus = torStatusCN;
      42           0 :     notificationManager = notificationManagerP;
      43           0 :     appState = appStateCN;
      44           0 :     serverListState = serverListStateCN;
      45           0 :     flwtchState = flwtchStateCN;
      46             :   }
      47             : 
      48           0 :   void l10nInit(String notificationSimple, String notificationConversationInfo) {
      49           0 :     this.notificationSimple = notificationSimple;
      50           0 :     this.notificationConversationInfo = notificationConversationInfo;
      51             :   }
      52             : 
      53           0 :   void setMessageSeenCallback(SeenMessageCallback callback) {
      54           0 :     seenMessageCallback = callback;
      55             :   }
      56             : 
      57           0 :   void handleMessage(String type, dynamic data) {
      58             :     // EnvironmentConfig.debugLog("NewEvent $type $data");
      59             :     switch (type) {
      60           0 :       case "CwtchStarted":
      61           0 :         if (data["Reload"] == "true" && profileCN.num > 0) {
      62             :           // don't reload...
      63             :           // unless we have loaded no profiles...then there isnt a risk and this
      64             :           // might be a first time (e.g. new apk, existing service)
      65             :         } else {
      66           0 :           flwtchState.cwtch.LoadProfiles(DefaultPassword);
      67             :         }
      68             : 
      69           0 :         appState.SetCwtchInit();
      70             :         break;
      71           0 :       case "CwtchStartError":
      72           0 :         appState.SetAppError(data["Error"]);
      73             :         break;
      74           0 :       case "NewPeer":
      75             :         // EnvironmentConfig.debugLog("NewPeer $data");
      76             :         // if tag != v1-defaultPassword then it is either encrypted OR it is an unencrypted account created during pre-beta...
      77           0 :         profileCN.add(
      78           0 :           data["Identity"],
      79           0 :           data["name"],
      80           0 :           data["private-name"],
      81           0 :           data["picture"],
      82           0 :           data["defaultPicture"],
      83           0 :           data["ContactsJson"],
      84           0 :           data["ServerList"],
      85           0 :           data["Online"] == "true",
      86           0 :           data["autostart"] == "true",
      87           0 :           data["tag"] != "v1-defaultPassword",
      88           0 :           data["appearOffline"] == "true",
      89             :         );
      90             : 
      91             :         // Update Profile Attributes
      92           0 :         EnvironmentConfig.debugLog("Looking up Profile Attributes ${data["Identity"]} ${profileCN.getProfile(data["Identity"])}");
      93           0 :         flwtchState.cwtch.GetProfileAttribute(data["Identity"], "profile.profile-attribute-1").then((value) => profileCN.getProfile(data["Identity"])?.setAttribute(0, value));
      94           0 :         flwtchState.cwtch.GetProfileAttribute(data["Identity"], "profile.profile-attribute-2").then((value) => profileCN.getProfile(data["Identity"])?.setAttribute(1, value));
      95           0 :         flwtchState.cwtch.GetProfileAttribute(data["Identity"], "profile.profile-attribute-3").then((value) => profileCN.getProfile(data["Identity"])?.setAttribute(2, value));
      96           0 :         flwtchState.cwtch.GetProfileAttribute(data["Identity"], "profile.profile-status").then((value) => profileCN.getProfile(data["Identity"])?.setAvailabilityStatus(value ?? ""));
      97             : 
      98           0 :         EnvironmentConfig.debugLog("Looking up Profile Information for Contact...");
      99           0 :         profileCN.getProfile(data["Identity"])?.contactList.contacts.forEach((contact) {
     100           0 :           flwtchState.cwtch.GetConversationAttribute(data["Identity"], contact.identifier, "public.profile.profile-attribute-1").then((value) => contact.setAttribute(0, value));
     101           0 :           flwtchState.cwtch.GetConversationAttribute(data["Identity"], contact.identifier, "public.profile.profile-attribute-2").then((value) => contact.setAttribute(1, value));
     102           0 :           flwtchState.cwtch.GetConversationAttribute(data["Identity"], contact.identifier, "public.profile.profile-attribute-3").then((value) => contact.setAttribute(2, value));
     103           0 :           flwtchState.cwtch.GetConversationAttribute(data["Identity"], contact.identifier, "public.profile.profile-status").then((value) => contact.setAvailabilityStatus(value ?? ""));
     104             :         });
     105             : 
     106             :         break;
     107           0 :       case "ContactCreated":
     108           0 :         EnvironmentConfig.debugLog("ContactCreated $data");
     109             : 
     110           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.add(ContactInfoState(data["ProfileOnion"], int.parse(data["ConversationID"]), data["RemotePeer"],
     111           0 :             nickname: data["nick"],
     112           0 :             status: data["status"],
     113           0 :             imagePath: data["picture"],
     114           0 :             defaultImagePath: data["defaultPicture"],
     115           0 :             blocked: data["blocked"] == "true",
     116           0 :             accepted: data["accepted"] == "true",
     117           0 :             savePeerHistory: data["saveConversationHistory"] == null ? "DeleteHistoryConfirmed" : data["saveConversationHistory"],
     118           0 :             numMessages: int.parse(data["numMessages"]),
     119           0 :             numUnread: int.parse(data["unread"]),
     120             :             isGroup: false, // by definition
     121             :             server: null,
     122             :             archived: false,
     123           0 :             lastMessageTime: DateTime.now(), //show at the top of the contact list even if no messages yet
     124           0 :             notificationPolicy: data["notificationPolicy"] ?? "ConversationNotificationPolicy.Default"));
     125             : 
     126             :         break;
     127           0 :       case "NewServer":
     128           0 :         EnvironmentConfig.debugLog("NewServer $data");
     129           0 :         serverListState.add(data["Onion"], data["ServerBundle"], data["Running"] == "true", data["Description"], data["Autostart"] == "true", data["StorageType"] == "storage-password");
     130             :         break;
     131           0 :       case "ServerIntentUpdate":
     132           0 :         EnvironmentConfig.debugLog("ServerIntentUpdate $data");
     133           0 :         var server = serverListState.getServer(data["Identity"]);
     134             :         if (server != null) {
     135           0 :           server.setRunning(data["Intent"] == "running");
     136             :         }
     137             :         break;
     138           0 :       case "ServerStatsUpdate":
     139           0 :         EnvironmentConfig.debugLog("ServerStatsUpdate $data");
     140           0 :         var totalMessages = int.parse(data["TotalMessages"]);
     141           0 :         var connections = int.parse(data["Connections"]);
     142           0 :         serverListState.updateServerStats(data["Identity"], totalMessages, connections);
     143             :         break;
     144           0 :       case "GroupCreated":
     145             :         // Retrieve Server Status from Cache...
     146             :         String status = "";
     147           0 :         RemoteServerInfoState? serverInfoState = profileCN.getProfile(data["ProfileOnion"])?.serverList.getServer(data["GroupServer"]);
     148             :         if (serverInfoState != null) {
     149           0 :           status = serverInfoState.status;
     150             :         }
     151           0 :         if (profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(int.parse(data["ConversationID"])) == null) {
     152           0 :           profileCN.getProfile(data["ProfileOnion"])?.contactList.add(ContactInfoState(data["ProfileOnion"], int.parse(data["ConversationID"]), data["GroupID"],
     153             :               blocked: false, // we created
     154             :               accepted: true, // we created
     155           0 :               imagePath: data["picture"],
     156           0 :               defaultImagePath: data["picture"],
     157           0 :               nickname: data["GroupName"],
     158             :               status: status,
     159           0 :               server: data["GroupServer"],
     160             :               isGroup: true,
     161           0 :               lastMessageTime: DateTime.now(),
     162           0 :               notificationPolicy: data["notificationPolicy"] ?? "ConversationNotificationPolicy.Default"));
     163             : 
     164           0 :           profileCN.getProfile(data["ProfileOnion"])?.contactList.updateLastMessageReceivedTime(int.parse(data["ConversationID"]), DateTime.now());
     165             :         }
     166             :         break;
     167           0 :       case "PeerDeleted":
     168           0 :         profileCN.delete(data["Identity"]);
     169             :         // todo standarize
     170           0 :         error.handleUpdate("deleteprofile.success");
     171             :         break;
     172           0 :       case "ServerDeleted":
     173           0 :         error.handleUpdate("deletedserver." + data["Status"]);
     174           0 :         if (data["Status"] == "success") {
     175           0 :           serverListState.delete(data["Identity"]);
     176             :         }
     177             :         break;
     178           0 :       case "DeleteContact":
     179           0 :         var identifier = int.parse(data["ConversationID"]);
     180           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.removeContact(identifier);
     181             :         break;
     182           0 :       case "PeerStateChange":
     183           0 :         ContactInfoState? contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(data["RemotePeer"]);
     184             :         if (contact != null) {
     185           0 :           if (data["ConnectionState"] != null) {
     186           0 :             contact.status = data["ConnectionState"];
     187             :           }
     188           0 :           profileCN.getProfile(data["ProfileOnion"])?.contactList.resort();
     189             :         }
     190             :         break;
     191           0 :       case "NewMessageFromPeer":
     192           0 :         var identifier = int.parse(data["ConversationID"]);
     193           0 :         var messageID = int.parse(data["Index"]);
     194           0 :         var timestamp = DateTime.tryParse(data['TimestampReceived'])!;
     195           0 :         var senderHandle = data['RemotePeer'];
     196           0 :         var senderImage = data['picture'];
     197           0 :         var isAuto = data['Auto'] == "true";
     198           0 :         String contenthash = data['ContentHash'];
     199             : 
     200             :         try {
     201           0 :           dynamic message = jsonDecode(data["Data"]);
     202           0 :           var overlay = int.parse(message['o'].toString());
     203           0 :           if (overlay > 1024 && overlay & 0x07 != 0) {
     204             :             break;
     205             :           }
     206             :         } catch (e) {
     207             :           // malformed message...
     208             :         }
     209             : 
     210           0 :         var selectedProfile = appState.selectedProfile == data["ProfileOnion"];
     211           0 :         var selectedConversation = selectedProfile && appState.selectedConversation == identifier;
     212           0 :         profileCN.getProfile(data["ProfileOnion"])?.newMessage(
     213             :               identifier,
     214             :               messageID,
     215             :               timestamp,
     216             :               senderHandle,
     217             :               senderImage,
     218             :               isAuto,
     219           0 :               data["Data"],
     220             :               contenthash,
     221             :               selectedProfile,
     222             :               selectedConversation,
     223             :             );
     224             : 
     225             :         // Now perform the notification logic...
     226           0 :         var notification = data["notification"];
     227           0 :         if (selectedConversation && seenMessageCallback != null) {
     228           0 :           seenMessageCallback!(data["ProfileOnion"]!, identifier, DateTime.now().toUtc());
     229             :         }
     230             : 
     231           0 :         if (notification == "SimpleEvent") {
     232           0 :           notificationManager.notify(notificationSimple ?? "New Message", "", 0);
     233           0 :         } else if (notification == "ContactInfo") {
     234           0 :           var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(identifier);
     235           0 :           notificationManager.notify((notificationConversationInfo ?? "New Message from %1").replaceFirst("%1", (contact?.nickname ?? senderHandle.toString())), data["ProfileOnion"], identifier);
     236             :         }
     237           0 :         appState.notifyProfileUnread();
     238             :         break;
     239           0 :       case "PeerAcknowledgement":
     240             :         // We don't use these anymore, IndexedAcknowledgement is more suited to the UI front end...
     241             :         break;
     242           0 :       case "IndexedAcknowledgement":
     243           0 :         var conversation = int.parse(data["ConversationID"]);
     244           0 :         var messageID = int.parse(data["Index"]);
     245             : 
     246             :         // We only ever see acks from authenticated peers.
     247             :         // If the contact is marked as offline then override this - can happen when the contact is removed from the front
     248             :         // end during syncing.
     249           0 :         if (profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(conversation)!.isOnline() == false) {
     250           0 :           profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(conversation)!.status = "Authenticated";
     251             :         }
     252           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(conversation)!.ackCache(messageID);
     253             : 
     254             :         break;
     255           0 :       case "NewMessageFromGroup":
     256           0 :         var identifier = int.parse(data["ConversationID"]);
     257           0 :         if (data["ProfileOnion"] != data["RemotePeer"]) {
     258           0 :           var idx = int.parse(data["Index"]);
     259           0 :           var senderHandle = data['RemotePeer'];
     260           0 :           var senderImage = data['picture'];
     261           0 :           var timestampSent = DateTime.tryParse(data['TimestampSent'])!;
     262           0 :           var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(identifier);
     263           0 :           var currentTotal = contact!.totalMessages;
     264           0 :           var isAuto = data['Auto'] == "true";
     265           0 :           String contenthash = data['ContentHash'];
     266           0 :           var selectedProfile = appState.selectedProfile == data["ProfileOnion"];
     267           0 :           var selectedConversation = selectedProfile && appState.selectedConversation == identifier;
     268           0 :           var notification = data["notification"];
     269             : 
     270             :           // Only bother to do anything if we know about the group and the provided index is greater than our current total...
     271           0 :           if (idx >= currentTotal) {
     272             :             // TODO: There are 2 timestamps associated with a new group message - time sent and time received.
     273             :             // Sent refers to the time a profile alleges they sent a message
     274             :             // Received refers to the time we actually saw the message from the server
     275             :             // These can obviously be very different for legitimate reasons.
     276             :             // We also maintain a relative hash-link through PreviousMessageSignature which is the ground truth for
     277             :             // order.
     278             :             // In the future we will want to combine these 3 ordering mechanisms into a cohesive view of the timeline
     279             :             // For now we perform some minimal checks on the sent timestamp to use to provide a useful ordering for honest contacts
     280             :             // and ensure that malicious contacts in groups can only set this timestamp to a value within the range of `last seen message time`
     281             :             // and `local now`.
     282           0 :             profileCN.getProfile(data["ProfileOnion"])?.newMessage(identifier, idx, timestampSent, senderHandle, senderImage, isAuto, data["Data"], contenthash, selectedProfile, selectedConversation);
     283           0 :             if (selectedConversation && seenMessageCallback != null) {
     284           0 :               seenMessageCallback!(data["ProfileOnion"]!, identifier, DateTime.now().toUtc());
     285             :             }
     286             : 
     287           0 :             if (notification == "SimpleEvent") {
     288           0 :               notificationManager.notify(notificationSimple ?? "New Message", "", 0);
     289           0 :             } else if (notification == "ContactInfo") {
     290           0 :               var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(identifier);
     291           0 :               notificationManager.notify((notificationConversationInfo ?? "New Message from %1").replaceFirst("%1", (contact?.nickname ?? senderHandle.toString())), data["ProfileOnion"], identifier);
     292             :             }
     293           0 :             appState.notifyProfileUnread();
     294             :           }
     295           0 :           RemoteServerInfoState? server = profileCN.getProfile(data["ProfileOnion"])?.serverList.getServer(contact.server ?? "");
     296           0 :           server?.updateSyncProgressFor(timestampSent);
     297             :         } else {
     298             :           // This is dealt with by IndexedAcknowledgment
     299           0 :           EnvironmentConfig.debugLog("new message from group from yourself - this should not happen");
     300             :         }
     301             :         break;
     302           0 :       case "IndexedFailure":
     303           0 :         var identifier = int.parse(data["ConversationID"]);
     304           0 :         var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(identifier);
     305           0 :         var messageID = int.parse(data["Index"]);
     306           0 :         contact!.errCache(messageID);
     307             :         break;
     308           0 :       case "AppError":
     309           0 :         EnvironmentConfig.debugLog("New App Error: $data");
     310             :         // special case for delete error (todo: standardize cwtch errors)
     311           0 :         if (data["Error"] == "Password did not match") {
     312           0 :           error.handleUpdate("deleteprofile.error");
     313           0 :         } else if (data["Data"] != null) {
     314           0 :           error.handleUpdate(data["Data"]);
     315             :         }
     316             :         break;
     317           0 :       case "UpdateGlobalSettings":
     318           0 :         settings.handleUpdate(jsonDecode(data["Data"]));
     319           0 :         appState.settingsLoaded = true;
     320             :         break;
     321           0 :       case "UpdatedProfileAttribute":
     322           0 :         if (data["Key"] == "public.profile.name") {
     323           0 :           profileCN.getProfile(data["ProfileOnion"])?.nickname = data["Data"];
     324           0 :         } else if (data["Key"].toString().startsWith("local.filesharing.")) {
     325           0 :           if (data["Key"].toString().endsWith(".path")) {
     326             :             // local.conversation.filekey.path
     327           0 :             List<String> keyparts = data["Key"].toString().split(".");
     328           0 :             if (keyparts.length == 5) {
     329           0 :               String filekey = keyparts[2] + "." + keyparts[3];
     330           0 :               profileCN.getProfile(data["ProfileOnion"])?.downloadSetPathForSender(filekey, data["Data"]);
     331             :             }
     332             :           }
     333           0 :         } else if (data["Key"].toString().startsWith("local.profile.private-name")) {
     334           0 :           profileCN.getProfile(data["ProfileOnion"])?.setPrivateName(data["Data"]);
     335           0 :         } else if (data["Key"].toString().startsWith("public.profile.profile-attribute")) {
     336             :           // ignore these events...
     337           0 :         } else if (data["Key"].toString().startsWith("public.profile.profile-status")) {
     338           0 :           profileCN.getProfile(data["ProfileOnion"])?.setAvailabilityStatus(data["Data"]);
     339             :         } else {
     340           0 :           EnvironmentConfig.debugLog("unhandled set attribute event: ${data['Key']}");
     341             :         }
     342             :         break;
     343           0 :       case "NetworkError":
     344           0 :         var isOnline = data["Status"] == "Success";
     345           0 :         profileCN.getProfile(data["ProfileOnion"])?.isOnline = isOnline;
     346             :         break;
     347           0 :       case "ACNStatus":
     348           0 :         EnvironmentConfig.debugLog("acn status: $data");
     349           0 :         torStatus.handleUpdate(int.parse(data["Progress"]), data["Status"]);
     350             :         break;
     351           0 :       case "ACNVersion":
     352           0 :         EnvironmentConfig.debugLog("acn version: $data");
     353           0 :         torStatus.updateVersion(data["Data"]);
     354             :         break;
     355           0 :       case "UpdateServerInfo":
     356           0 :         EnvironmentConfig.debugLog("NewEvent  UpdateServerInfo $type $data");
     357           0 :         profileCN.getProfile(data["ProfileOnion"])?.replaceServers(data["ServerList"]);
     358             :         break;
     359           0 :       case "TokenManagerInfo":
     360             :         try {
     361           0 :           List<dynamic> associatedGroups = jsonDecode(data["Data"]);
     362           0 :           int count = int.parse(data["ServerTokenCount"]);
     363           0 :           associatedGroups.forEach((identifier) {
     364           0 :             profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(int.parse(identifier.toString()))!.antispamTickets = count;
     365             :           });
     366           0 :           EnvironmentConfig.debugLog("update server token count for $associatedGroups, $count");
     367             :         } catch (e) {
     368             :           //  No tokens in data...
     369             :         }
     370             :         break;
     371           0 :       case "NewGroup":
     372           0 :         String invite = data["GroupInvite"].toString();
     373           0 :         if (invite.startsWith("torv3")) {
     374           0 :           String inviteJson = new String.fromCharCodes(base64Decode(invite.substring(5)));
     375           0 :           dynamic groupInvite = jsonDecode(inviteJson);
     376             : 
     377             :           // Retrieve Server Status from Cache...
     378             :           String status = "";
     379           0 :           RemoteServerInfoState? serverInfoState = profileCN.getProfile(data["ProfileOnion"])!.serverList.getServer(groupInvite["ServerHost"]);
     380             :           if (serverInfoState != null) {
     381           0 :             status = serverInfoState.status;
     382             :           }
     383             : 
     384           0 :           if (profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(groupInvite["GroupID"]) == null) {
     385           0 :             var identifier = int.parse(data["ConversationID"]);
     386           0 :             profileCN.getProfile(data["ProfileOnion"])?.contactList.add(ContactInfoState(data["ProfileOnion"], identifier, groupInvite["GroupID"],
     387             :                 blocked: false, // NewGroup only issued on accepting invite
     388             :                 accepted: true, // NewGroup only issued on accepting invite
     389           0 :                 imagePath: data["picture"],
     390           0 :                 nickname: groupInvite["GroupName"],
     391           0 :                 server: groupInvite["ServerHost"],
     392             :                 status: status,
     393             :                 isGroup: true,
     394           0 :                 lastMessageTime: DateTime.now()));
     395             : 
     396           0 :             profileCN.getProfile(data["ProfileOnion"])?.contactList.updateLastMessageReceivedTime(identifier, DateTime.fromMillisecondsSinceEpoch(0));
     397             :           }
     398             :           // request a new server update...
     399             :           // NOTE: In the future this should also update the TokenManagerInfo
     400             :           // This is not currently communicated by ServerUpdateInfo (but it probably should be)git
     401           0 :           flwtchState.cwtch.PublishServerUpdate(data["ProfileOnion"]);
     402             :         }
     403             :         break;
     404           0 :       case "ServerStateChange":
     405             :         // Update the Server Cache
     406           0 :         profileCN.getProfile(data["ProfileOnion"])?.updateServerStatusCache(data["GroupServer"], data["ConnectionState"]);
     407           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.contacts.forEach((contact) {
     408           0 :           if (contact.isGroup == true && contact.server == data["GroupServer"]) {
     409           0 :             contact.status = data["ConnectionState"];
     410             :           }
     411             :         });
     412           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.resort();
     413             :         break;
     414           0 :       case "UpdatedConversationAttribute":
     415           0 :         if (data["Path"] == "profile.name") {
     416           0 :           if (data["Data"].toString().trim().length > 0) {
     417             :             // Update locally on the UI...
     418           0 :             if (profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(data["RemotePeer"]) != null) {
     419           0 :               profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(data["RemotePeer"])!.nickname = data["Data"];
     420             :             }
     421             :           }
     422           0 :         } else if (data['Path'] == "profile.custom-profile-image") {
     423           0 :           EnvironmentConfig.debugLog("received ret val of custom profile image: $data");
     424           0 :           String fileKey = data['Data'];
     425           0 :           var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(data["RemotePeer"]);
     426             :           if (contact != null) {
     427           0 :             EnvironmentConfig.debugLog("waiting for download from $contact");
     428           0 :             profileCN.getProfile(data["ProfileOnion"])?.waitForDownloadComplete(contact.identifier, fileKey);
     429             :           }
     430           0 :         } else if (data['Path'] == "profile.profile-attribute-1" || data['Path'] == "profile.profile-attribute-2" || data['Path'] == "profile.profile-attribute-3") {
     431           0 :           var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(data["RemotePeer"]);
     432             :           if (contact != null) {
     433           0 :             switch (data['Path']) {
     434           0 :               case "profile.profile-attribute-1":
     435           0 :                 contact.setAttribute(0, data["Data"]);
     436             :                 break;
     437           0 :               case "profile.profile-attribute-2":
     438           0 :                 contact.setAttribute(1, data["Data"]);
     439             :                 break;
     440           0 :               case "profile.profile-attribute-3":
     441           0 :                 contact.setAttribute(2, data["Data"]);
     442             :                 break;
     443             :             }
     444             :           }
     445           0 :         } else if (data['Path'] == "profile.profile-status") {
     446           0 :           var contact = profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(data["RemotePeer"]);
     447             :           if (contact != null) {
     448           0 :             contact.setAvailabilityStatus(data['Data']);
     449             :           }
     450             :         } else {
     451           0 :           EnvironmentConfig.debugLog("unhandled ret val event: ${data['Path']}");
     452             :         }
     453             :         break;
     454           0 :       case "ManifestSizeReceived":
     455           0 :         if (!profileCN.getProfile(data["ProfileOnion"])!.downloadActive(data["FileKey"])) {
     456           0 :           profileCN.getProfile(data["ProfileOnion"])?.downloadUpdate(data["FileKey"], 0, 1);
     457             :         }
     458             :         break;
     459           0 :       case "ManifestSaved":
     460           0 :         profileCN.getProfile(data["ProfileOnion"])?.downloadMarkManifest(data["FileKey"]);
     461             :         break;
     462           0 :       case "FileDownloadProgressUpdate":
     463           0 :         var progress = int.parse(data["Progress"]);
     464           0 :         profileCN.getProfile(data["ProfileOnion"])?.downloadUpdate(data["FileKey"], progress, int.parse(data["FileSizeInChunks"]));
     465             :         // progress == -1 is a "download was interrupted" message and should contain a path
     466           0 :         if (progress < 0) {
     467           0 :           profileCN.getProfile(data["ProfileOnion"])?.downloadSetPath(data["FileKey"], data["FilePath"]);
     468             :         }
     469             :         break;
     470           0 :       case "FileDownloaded":
     471           0 :         profileCN.getProfile(data["ProfileOnion"])?.downloadMarkFinished(data["FileKey"], data["FilePath"]);
     472             :         break;
     473           0 :       case "ImportingProfileEvent":
     474             :         break;
     475           0 :       case "StartingStorageMigration":
     476           0 :         appState.SetModalState(ModalState.storageMigration);
     477             :         break;
     478           0 :       case "DoneStorageMigration":
     479           0 :         appState.SetModalState(ModalState.none);
     480             :         break;
     481           0 :       case "BlodeuweddSummary":
     482           0 :         var identifier = int.parse(data["ConversationID"]);
     483           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(identifier)?.updateSummaryEvent(data["Summary"]);
     484             :         break;
     485           0 :       case "BlodeuweddTranslation":
     486           0 :         var identifier = int.parse(data["ConversationID"]);
     487           0 :         var mid = int.parse(data["Index"]);
     488           0 :         EnvironmentConfig.debugLog("received translation event: $identifier $mid $data");
     489           0 :         profileCN.getProfile(data["ProfileOnion"])?.contactList.getContact(identifier)?.updateTranslationEvent(mid, data["Translation"]);
     490             :         break;
     491           0 :       case "ACNInfo":
     492           0 :         var key = data["Key"];
     493           0 :         var handle = data["Handle"];
     494           0 :         if (key == "circuit") {
     495           0 :           profileCN.getProfile(data["ProfileOnion"])?.contactList.findContact(handle)?.acnCircuit = data["Data"];
     496             :         }
     497             :         break;
     498           0 :       case "SearchResult":
     499           0 :         String searchID = data["SearchID"];
     500           0 :         var conversationIdentifier = int.parse(data["ConversationID"]);
     501           0 :         var messageIndex = int.parse(data["RowIndex"]);
     502           0 :         profileCN.getProfile(data["ProfileOnion"])?.handleSearchResult(searchID, conversationIdentifier, messageIndex);
     503             :         break;
     504             :       default:
     505           0 :         EnvironmentConfig.debugLog("unhandled event: $type");
     506             :     }
     507             :   }
     508             : }

Generated by: LCOV version 1.14