LCOV - code coverage report
Current view: top level - lib/models - profile.dart (source / functions) Hit Total Coverage
Test: lcov.info Lines: 0 255 0.0 %
Date: 2024-08-22 16:58:37 Functions: 0 0 -

          Line data    Source code
       1             : import 'dart:convert';
       2             : import 'dart:math';
       3             : 
       4             : import 'package:cwtch/config.dart';
       5             : import 'package:cwtch/models/remoteserver.dart';
       6             : import 'package:cwtch/models/search.dart';
       7             : import 'package:flutter/widgets.dart';
       8             : import 'package:provider/provider.dart';
       9             : import 'package:scrollable_positioned_list/scrollable_positioned_list.dart';
      10             : 
      11             : import '../main.dart';
      12             : import '../themes/opaque.dart';
      13             : import '../views/contactsview.dart';
      14             : import 'contact.dart';
      15             : import 'contactlist.dart';
      16             : import 'filedownloadprogress.dart';
      17             : import 'profileservers.dart';
      18             : 
      19             : class ProfileInfoState extends ChangeNotifier {
      20             :   ProfileServerListState _servers = ProfileServerListState();
      21             :   ContactListState _contacts = ContactListState();
      22             :   final String onion;
      23             :   String _nickname = "";
      24             :   String _imagePath = "";
      25             :   String _defaultImagePath = "";
      26             :   int _unreadMessages = 0;
      27             :   bool _online = false;
      28             :   Map<String, FileDownloadProgress> _downloads = Map<String, FileDownloadProgress>();
      29             :   Map<String, int> _downloadTriggers = Map<String, int>();
      30             :   ItemScrollController contactListScrollController = new ItemScrollController();
      31             :   // assume profiles are encrypted...this will be set to false
      32             :   // in the constructor if the profile is encrypted with the defacto password.
      33             :   bool _encrypted = true;
      34             : 
      35             :   bool _autostart = true;
      36             :   bool _enabled = false;
      37             :   bool _appearOffline = false;
      38             :   bool _appearOfflineAtStartup = false;
      39             : 
      40           0 :   ProfileInfoState({
      41             :     required this.onion,
      42             :     nickname = "",
      43             :     imagePath = "",
      44             :     defaultImagePath = "",
      45             :     unreadMessages = 0,
      46             :     contactsJson = "",
      47             :     serversJson = "",
      48             :     online = false,
      49             :     autostart = true,
      50             :     encrypted = true,
      51             :     appearOffline = false,
      52             :     String,
      53             :   }) {
      54           0 :     this._nickname = nickname;
      55           0 :     this._imagePath = imagePath;
      56           0 :     this._defaultImagePath = defaultImagePath;
      57           0 :     this._unreadMessages = unreadMessages;
      58           0 :     this._online = online;
      59           0 :     this._enabled = _enabled;
      60           0 :     this._autostart = autostart;
      61             :     if (autostart) {
      62           0 :       this._enabled = true;
      63             :     }
      64           0 :     this._appearOffline = appearOffline;
      65           0 :     this._appearOfflineAtStartup = appearOffline;
      66           0 :     this._encrypted = encrypted;
      67             : 
      68           0 :     _contacts.connectServers(this._servers);
      69             : 
      70           0 :     if (contactsJson != null && contactsJson != "" && contactsJson != "null") {
      71           0 :       this.replaceServers(serversJson);
      72             : 
      73           0 :       List<dynamic> contacts = jsonDecode(contactsJson);
      74           0 :       this._contacts.addAll(contacts.map((contact) {
      75           0 :         this._unreadMessages += contact["numUnread"] as int;
      76             : 
      77           0 :         return ContactInfoState(this.onion, contact["identifier"], contact["onion"],
      78           0 :             nickname: contact["name"],
      79           0 :             localNickname: contact["attributes"]?["local.profile.name"] ?? "", // contact may not have a local name
      80           0 :             status: contact["status"],
      81           0 :             imagePath: contact["picture"],
      82           0 :             defaultImagePath: contact["isGroup"] ? contact["picture"] : contact["defaultPicture"],
      83           0 :             accepted: contact["accepted"],
      84           0 :             blocked: contact["blocked"],
      85           0 :             savePeerHistory: contact["saveConversationHistory"],
      86           0 :             numMessages: contact["numMessages"],
      87           0 :             numUnread: contact["numUnread"],
      88           0 :             isGroup: contact["isGroup"],
      89           0 :             server: contact["groupServer"],
      90           0 :             archived: contact["isArchived"] == true,
      91           0 :             lastMessageTime: DateTime.fromMillisecondsSinceEpoch(1000 * int.parse(contact["lastMsgTime"])),
      92           0 :             pinned: contact["attributes"]?["local.profile.pinned"] == "true",
      93           0 :             notificationPolicy: contact["notificationPolicy"] ?? "ConversationNotificationPolicy.Default");
      94             :       }));
      95             : 
      96             :       // dummy set to invoke sort-on-load
      97           0 :       if (this._contacts.num > 0) {
      98           0 :         this._contacts.updateLastMessageReceivedTime(this._contacts.contacts.first.identifier, this._contacts.contacts.first.lastMessageReceivedTime);
      99             :       }
     100             :     }
     101             :   }
     102             : 
     103             :   // Code for managing the state of the profile-wide search feature...
     104             :   String activeSearchID = "";
     105             :   List<SearchResult> activeSearchResults = List.empty(growable: true);
     106             : 
     107           0 :   void newSearch(String activeSearchID) {
     108           0 :     this.activeSearchID = activeSearchID;
     109           0 :     this.activeSearchResults.clear();
     110           0 :     notifyListeners();
     111             :   }
     112             : 
     113           0 :   void handleSearchResult(String searchID, int conversationIdentifier, int messageIndex) {
     114           0 :     if (searchID == activeSearchID) {
     115           0 :       activeSearchResults.add(SearchResult(searchID: searchID, conversationIdentifier: conversationIdentifier, messageIndex: messageIndex));
     116           0 :       notifyListeners();
     117             :     }
     118             :   }
     119             : 
     120             :   // Parse out the server list json into our server info state struct...
     121           0 :   void replaceServers(String serversJson) {
     122           0 :     if (serversJson != "" && serversJson != "null") {
     123           0 :       List<dynamic> servers = jsonDecode(serversJson);
     124           0 :       this._servers.replace(servers.map((server) {
     125             :         // TODO Keys...
     126           0 :         var preSyncStartTime = DateTime.tryParse(server["syncProgress"]["startTime"]);
     127           0 :         var lastMessageTime = DateTime.tryParse(server["syncProgress"]["lastMessageTime"]);
     128           0 :         return RemoteServerInfoState(server["onion"], server["identifier"], server["description"], server["status"], lastPreSyncMessageTime: preSyncStartTime, mostRecentMessageTime: lastMessageTime);
     129             :       }));
     130             : 
     131           0 :       this._contacts.contacts.forEach((contact) {
     132           0 :         if (contact.isGroup) {
     133           0 :           _servers.addGroup(contact);
     134             :         }
     135             :       });
     136             : 
     137           0 :       notifyListeners();
     138             :     }
     139             :   }
     140             : 
     141             :   //
     142           0 :   void updateServerStatusCache(String server, String status) {
     143           0 :     this._servers.updateServerState(server, status);
     144           0 :     notifyListeners();
     145             :   }
     146             : 
     147             :   //  Getters and Setters for Online Status
     148           0 :   bool get isOnline => this._online;
     149             : 
     150           0 :   set isOnline(bool newValue) {
     151           0 :     this._online = newValue;
     152           0 :     notifyListeners();
     153             :   }
     154             : 
     155             :   // Check encrypted status for profile info screen
     156           0 :   bool get isEncrypted => this._encrypted;
     157           0 :   set isEncrypted(bool newValue) {
     158           0 :     this._encrypted = newValue;
     159           0 :     notifyListeners();
     160             :   }
     161             : 
     162           0 :   String get nickname => this._nickname;
     163             : 
     164           0 :   set nickname(String newValue) {
     165           0 :     this._nickname = newValue;
     166           0 :     notifyListeners();
     167             :   }
     168             : 
     169           0 :   String get imagePath => this._imagePath;
     170             : 
     171           0 :   set imagePath(String newVal) {
     172           0 :     this._imagePath = newVal;
     173           0 :     notifyListeners();
     174             :   }
     175             : 
     176           0 :   bool get enabled => this._enabled;
     177             : 
     178           0 :   set enabled(bool newVal) {
     179           0 :     this._enabled = newVal;
     180           0 :     notifyListeners();
     181             :   }
     182             : 
     183           0 :   bool get autostart => this._autostart;
     184           0 :   set autostart(bool newVal) {
     185           0 :     this._autostart = newVal;
     186           0 :     notifyListeners();
     187             :   }
     188             : 
     189           0 :   bool get appearOfflineAtStartup => this._appearOfflineAtStartup;
     190           0 :   set appearOfflineAtStartup(bool newVal) {
     191           0 :     this._appearOfflineAtStartup = newVal;
     192           0 :     notifyListeners();
     193             :   }
     194             : 
     195           0 :   bool get appearOffline => this._appearOffline;
     196           0 :   set appearOffline(bool newVal) {
     197           0 :     this._appearOffline = newVal;
     198           0 :     notifyListeners();
     199             :   }
     200             : 
     201           0 :   String get defaultImagePath => this._defaultImagePath;
     202             : 
     203           0 :   set defaultImagePath(String newVal) {
     204           0 :     this._defaultImagePath = newVal;
     205           0 :     notifyListeners();
     206             :   }
     207             : 
     208           0 :   int get unreadMessages => this._unreadMessages;
     209             : 
     210           0 :   set unreadMessages(int newVal) {
     211           0 :     this._unreadMessages = newVal;
     212           0 :     notifyListeners();
     213             :   }
     214             : 
     215           0 :   void recountUnread() {
     216           0 :     this._unreadMessages = _contacts.contacts.fold(0, (i, c) => i + c.unreadMessages);
     217             :   }
     218             : 
     219             :   // Remove a contact from a list. Currently only used when rejecting a group invitation.
     220             :   // Eventually will also be used for other removals.
     221           0 :   void removeContact(String handle) {
     222           0 :     this.contactList.removeContactByHandle(handle);
     223           0 :     notifyListeners();
     224             :   }
     225             : 
     226           0 :   ContactListState get contactList => this._contacts;
     227             : 
     228           0 :   ProfileServerListState get serverList => this._servers;
     229             : 
     230           0 :   @override
     231             :   void dispose() {
     232           0 :     super.dispose();
     233             :   }
     234             : 
     235           0 :   void updateFrom(String onion, String name, String picture, String contactsJson, String serverJson, bool online) {
     236           0 :     this._nickname = name;
     237           0 :     this._imagePath = picture;
     238           0 :     this._online = online;
     239           0 :     this._unreadMessages = 0;
     240           0 :     this.replaceServers(serverJson);
     241             : 
     242           0 :     if (contactsJson != "" && contactsJson != "null") {
     243           0 :       List<dynamic> contacts = jsonDecode(contactsJson);
     244           0 :       contacts.forEach((contact) {
     245           0 :         var profileContact = this._contacts.getContact(contact["identifier"]);
     246           0 :         this._unreadMessages += contact["numUnread"] as int;
     247             :         if (profileContact != null) {
     248           0 :           profileContact.status = contact["status"];
     249             : 
     250           0 :           var newCount = contact["numMessages"] as int;
     251           0 :           if (newCount != profileContact.totalMessages) {
     252           0 :             if (newCount < profileContact.totalMessages) {
     253             :               // on Android, when sharing a file the UI may be briefly unloaded for the
     254             :               // OS to display the file management/selection screen. Afterwards a
     255             :               // call to ReconnectCwtchForeground will be made which will refresh all values (including count of numMessages)
     256             :               // **at the same time** the foreground will increment .totalMessages and send a new message to the backend.
     257             :               // This will result in a negative number of messages being calculated here, and an incorrect totalMessage count.
     258             :               // This bug is exacerbated in debug mode, and when multiple files are sent in succession. Both cases result in multiple ReconnectCwtchForeground
     259             :               // events that have the potential to conflict with currentMessageCounts.
     260             :               // Note that *if* a new message came in at the same time, we would be unable to distinguish this case - as such this is specific instance of a more general problem
     261             :               // TODO: A true-fix to this bug is to implement a syncing step in the foreground where totalMessages and inFlightMessages can be distinguished
     262             :               // This requires a change to the backend to confirm submission of an inFlightMessage, which will be implemented in #664
     263           0 :               EnvironmentConfig.debugLog("Conflicting message counts: $newCount ${profileContact.totalMessages}");
     264           0 :               newCount = max(newCount, profileContact.totalMessages);
     265             :             }
     266           0 :             profileContact.messageCache.addFrontIndexGap(newCount - profileContact.totalMessages);
     267             :           }
     268           0 :           profileContact.totalMessages = newCount;
     269           0 :           profileContact.unreadMessages = contact["numUnread"];
     270           0 :           profileContact.lastMessageReceivedTime = DateTime.fromMillisecondsSinceEpoch(1000 * int.parse(contact["lastMsgTime"]));
     271             :         } else {
     272           0 :           this._contacts.add(ContactInfoState(
     273           0 :                 this.onion,
     274           0 :                 contact["identifier"],
     275           0 :                 contact["onion"],
     276           0 :                 nickname: contact["name"],
     277           0 :                 defaultImagePath: contact["defaultPicture"],
     278           0 :                 status: contact["status"],
     279           0 :                 imagePath: contact["picture"],
     280           0 :                 accepted: contact["accepted"],
     281           0 :                 blocked: contact["blocked"],
     282           0 :                 savePeerHistory: contact["saveConversationHistory"],
     283           0 :                 numMessages: contact["numMessages"],
     284           0 :                 numUnread: contact["numUnread"],
     285           0 :                 isGroup: contact["isGroup"],
     286           0 :                 server: contact["groupServer"],
     287           0 :                 lastMessageTime: DateTime.fromMillisecondsSinceEpoch(1000 * int.parse(contact["lastMsgTime"])),
     288           0 :                 notificationPolicy: contact["notificationPolicy"] ?? "ConversationNotificationPolicy.Default",
     289             :               ));
     290             :         }
     291             :       });
     292             :     }
     293           0 :     this._contacts.resort();
     294             :   }
     295             : 
     296           0 :   void newMessage(
     297             :       int identifier, int messageID, DateTime timestamp, String senderHandle, String senderImage, bool isAuto, String data, String contenthash, bool selectedProfile, bool selectedConversation) {
     298             :     if (!selectedProfile) {
     299           0 :       unreadMessages++;
     300           0 :       notifyListeners();
     301             :     }
     302             : 
     303           0 :     contactList.newMessage(identifier, messageID, timestamp, senderHandle, senderImage, isAuto, data, contenthash, selectedConversation);
     304             :   }
     305             : 
     306           0 :   void downloadInit(String fileKey, int numChunks) {
     307           0 :     this._downloads[fileKey] = FileDownloadProgress(numChunks, DateTime.now());
     308           0 :     notifyListeners();
     309             :   }
     310             : 
     311           0 :   void downloadUpdate(String fileKey, int progress, int numChunks) {
     312           0 :     if (!downloadActive(fileKey)) {
     313           0 :       this._downloads[fileKey] = FileDownloadProgress(numChunks, DateTime.now());
     314           0 :       if (progress < 0) {
     315           0 :         this._downloads[fileKey]!.interrupted = true;
     316             :       }
     317             :     } else {
     318           0 :       if (this._downloads[fileKey]!.interrupted) {
     319           0 :         this._downloads[fileKey]!.interrupted = false;
     320             :       }
     321           0 :       this._downloads[fileKey]!.chunksDownloaded = progress;
     322           0 :       this._downloads[fileKey]!.chunksTotal = numChunks;
     323           0 :       this._downloads[fileKey]!.markUpdate();
     324             :     }
     325           0 :     notifyListeners();
     326             :   }
     327             : 
     328           0 :   void downloadMarkManifest(String fileKey) {
     329           0 :     if (!downloadActive(fileKey)) {
     330           0 :       this._downloads[fileKey] = FileDownloadProgress(1, DateTime.now());
     331             :     }
     332           0 :     this._downloads[fileKey]!.gotManifest = true;
     333           0 :     this._downloads[fileKey]!.markUpdate();
     334           0 :     notifyListeners();
     335             :   }
     336             : 
     337           0 :   void downloadMarkFinished(String fileKey, String finalPath) {
     338           0 :     if (!downloadActive(fileKey)) {
     339             :       // happens as a result of a CheckDownloadStatus call,
     340             :       // invoked from a historical (timeline) download message
     341             :       // so setting numChunks correctly shouldn't matter
     342           0 :       this.downloadInit(fileKey, 1);
     343             :     }
     344             : 
     345             :     // Update the contact with a custom profile image if we are
     346             :     // waiting for one...
     347           0 :     if (this._downloadTriggers.containsKey(fileKey)) {
     348           0 :       int identifier = this._downloadTriggers[fileKey]!;
     349           0 :       this.contactList.getContact(identifier)!.imagePath = finalPath;
     350           0 :       notifyListeners();
     351             :     }
     352             : 
     353             :     // only update if different
     354           0 :     if (!this._downloads[fileKey]!.complete) {
     355           0 :       this._downloads[fileKey]!.timeEnd = DateTime.now();
     356           0 :       this._downloads[fileKey]!.downloadedTo = finalPath;
     357           0 :       this._downloads[fileKey]!.complete = true;
     358           0 :       this._downloads[fileKey]!.markUpdate();
     359           0 :       notifyListeners();
     360             :     }
     361             :   }
     362             : 
     363           0 :   bool downloadKnown(String fileKey) {
     364           0 :     return this._downloads.containsKey(fileKey);
     365             :   }
     366             : 
     367           0 :   bool downloadActive(String fileKey) {
     368           0 :     return this._downloads.containsKey(fileKey) && !this._downloads[fileKey]!.interrupted;
     369             :   }
     370             : 
     371           0 :   bool downloadGotManifest(String fileKey) {
     372           0 :     return this._downloads.containsKey(fileKey) && this._downloads[fileKey]!.gotManifest;
     373             :   }
     374             : 
     375           0 :   bool downloadComplete(String fileKey) {
     376           0 :     return this._downloads.containsKey(fileKey) && this._downloads[fileKey]!.complete;
     377             :   }
     378             : 
     379           0 :   bool downloadInterrupted(String fileKey) {
     380           0 :     if (this._downloads.containsKey(fileKey)) {
     381           0 :       if (this._downloads[fileKey]!.interrupted) {
     382             :         return true;
     383             :       }
     384             :     }
     385             :     return false;
     386             :   }
     387             : 
     388           0 :   void downloadMarkResumed(String fileKey) {
     389           0 :     if (this._downloads.containsKey(fileKey)) {
     390           0 :       this._downloads[fileKey]!.interrupted = false;
     391           0 :       this._downloads[fileKey]!.requested = DateTime.now();
     392           0 :       this._downloads[fileKey]!.markUpdate();
     393           0 :       notifyListeners();
     394             :     }
     395             :   }
     396             : 
     397           0 :   double downloadProgress(String fileKey) {
     398           0 :     return this._downloads.containsKey(fileKey) ? this._downloads[fileKey]!.progress() : 0.0;
     399             :   }
     400             : 
     401             :   // used for loading interrupted download info; use downloadMarkFinished for successful downloads
     402           0 :   void downloadSetPath(String fileKey, String path) {
     403           0 :     if (this._downloads.containsKey(fileKey)) {
     404           0 :       this._downloads[fileKey]!.downloadedTo = path;
     405           0 :       notifyListeners();
     406             :     }
     407             :   }
     408             : 
     409             :   // set the download path for the sender
     410           0 :   void downloadSetPathForSender(String fileKey, String path) {
     411             :     // we may trigger this event for auto-downloaded receivers too,
     412             :     // as such we don't assume anything else about the file...other than that
     413             :     // it exists.
     414           0 :     if (!this._downloads.containsKey(fileKey)) {
     415             :       // this will be overwritten by download update if the file is being downloaded
     416           0 :       this._downloads[fileKey] = FileDownloadProgress(1, DateTime.now());
     417             :     }
     418           0 :     this._downloads[fileKey]!.downloadedTo = path;
     419           0 :     notifyListeners();
     420             :   }
     421             : 
     422           0 :   String? downloadFinalPath(String fileKey) {
     423           0 :     return this._downloads.containsKey(fileKey) ? this._downloads[fileKey]!.downloadedTo : null;
     424             :   }
     425             : 
     426           0 :   String downloadSpeed(String fileKey) {
     427           0 :     if (!downloadActive(fileKey) || this._downloads[fileKey]!.chunksDownloaded == 0) {
     428             :       return "0 B/s";
     429             :     }
     430           0 :     var bytes = this._downloads[fileKey]!.chunksDownloaded * 4096;
     431           0 :     var seconds = (this._downloads[fileKey]!.timeEnd ?? DateTime.now()).difference(this._downloads[fileKey]!.timeStart!).inSeconds;
     432           0 :     if (seconds == 0) {
     433             :       return "0 B/s";
     434             :     }
     435           0 :     return prettyBytes((bytes / seconds).round()) + "/s";
     436             :   }
     437             : 
     438           0 :   void waitForDownloadComplete(int identifier, String fileKey) {
     439           0 :     _downloadTriggers[fileKey] = identifier;
     440           0 :     notifyListeners();
     441             :   }
     442             : 
     443           0 :   int cacheMemUsage() {
     444           0 :     return _contacts.cacheMemUsage();
     445             :   }
     446             : 
     447           0 :   void downloadReset(String fileKey) {
     448           0 :     this._downloads.remove(fileKey);
     449           0 :     notifyListeners();
     450             :   }
     451             : 
     452             :   // Profile Attributes. Can be set in Profile Edit View...
     453             :   List<String?> attributes = [null, null, null];
     454           0 :   void setAttribute(int i, String? value) {
     455           0 :     this.attributes[i] = value;
     456           0 :     notifyListeners();
     457             :   }
     458             : 
     459             :   ProfileStatusMenu availabilityStatus = ProfileStatusMenu.available;
     460           0 :   void setAvailabilityStatus(String status) {
     461             :     switch (status) {
     462           0 :       case "available":
     463           0 :         availabilityStatus = ProfileStatusMenu.available;
     464             :         break;
     465           0 :       case "busy":
     466           0 :         availabilityStatus = ProfileStatusMenu.busy;
     467             :         break;
     468           0 :       case "away":
     469           0 :         availabilityStatus = ProfileStatusMenu.away;
     470             :         break;
     471             :       default:
     472             :         ProfileStatusMenu.available;
     473             :     }
     474           0 :     notifyListeners();
     475             :   }
     476             : 
     477           0 :   Color getBorderColor(OpaqueThemeType theme) {
     478           0 :     switch (this.availabilityStatus) {
     479           0 :       case ProfileStatusMenu.available:
     480           0 :         return theme.portraitOnlineBorderColor;
     481           0 :       case ProfileStatusMenu.away:
     482           0 :         return theme.portraitOnlineAwayColor;
     483           0 :       case ProfileStatusMenu.busy:
     484           0 :         return theme.portraitOnlineBusyColor;
     485             :       default:
     486           0 :         throw UnimplementedError("not a valid status");
     487             :     }
     488             :   }
     489             : 
     490             :   // during deactivation it is possible that the event bus is cleaned up prior to statuses being updated
     491             :   // this method nicely cleans up our current state so that the UI functions as expected.
     492             :   // FIXME: Cwtch should be sending these events prior to shutting down the engine...
     493           0 :   void deactivatePeerEngine(BuildContext context) {
     494           0 :     Provider.of<FlwtchState>(context, listen: false).cwtch.DeactivatePeerEngine(onion);
     495           0 :     this.contactList.contacts.forEach((element) {
     496           0 :       element.status = "Disconnected";
     497             :       // reset retry time to allow for instant reconnection...
     498           0 :       element.lastRetryTime = element.loaded;
     499             :     });
     500           0 :     this.serverList.servers.forEach((element) {
     501           0 :       element.status = "Disconnected";
     502             :     });
     503             :   }
     504             : }

Generated by: LCOV version 1.14