fix android segfault in flwtch worker; try/catch to catch future bugs in flwtch worker; resume servers load sync status from cwtch; add bg color to sync progress bar; showdown now synchronous so completes

LIBCWTCH-GO-MACOS.version

@@ -1 +1 @@
-2022-02-23-17-17-v1.6.0-2-ge8b2def
+2022-03-03-19-53-v1.6.0-4-g4b881b9

LIBCWTCH-GO.version

@@ -1 +1 @@
-2022-02-23-22-17-v1.6.0-2-ge8b2def
+2022-03-04-00-54-v1.6.0-4-g4b881b9

android/app/src/main/kotlin/im/cwtch/flwtch/FlwtchWorker.kt

@@ -38,7 +38,7 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
         val args = inputData.getString(KEY_ARGS)
                 ?: return Result.failure()
         // Mark the Worker as important
-        val progress = "Cwtch is keeping Tor running in the background"//todo:translate
+        val progress = "Cwtch is keeping Tor running in the background" // TODO: translate
         setForeground(createForegroundInfo(progress))
         return handleCwtch(method, args)
     }
@@ -52,6 +52,7 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
     }
 
     private fun handleCwtch(method: String, args: String): Result {
+        try {
             val a = JSONObject(args)
             when (method) {
                 "Start" -> {
@@ -64,11 +65,12 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
 
                     Log.i("FlwtchWorker.kt", "startCwtch success, starting coroutine AppbusEvent loop...")
                     val downloadIDs = mutableMapOf<String, Int>()
-                while(true) {
+                    while (true) {
                         val evt = MainActivity.AppbusEvent(Cwtch.getAppBusEvent())
+                        // TODO replace this notification block with the NixNotification manager in dart as it has access to contact names and also needs less working around
                         if (evt.EventType == "NewMessageFromPeer" || evt.EventType == "NewMessageFromGroup") {
                             val data = JSONObject(evt.Data)
-                        val handle = if (evt.EventType == "NewMessageFromPeer") data.getString("RemotePeer") else data.getString("GroupID");
+                            val handle = data.getString("RemotePeer");
                             if (data["RemotePeer"] != data["ProfileOnion"]) {
                                 val notification = data["notification"]
 
@@ -118,7 +120,8 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
 
                                     val newNotification = NotificationCompat.Builder(applicationContext, channelId)
                                             .setContentTitle(data.getString("Nick"))
-                                            .setContentText((notificationConversationInfo ?: "New Message From %1").replace("%1", data.getString("Nick")))
+                                            .setContentText((notificationConversationInfo
+                                                    ?: "New Message From %1").replace("%1", data.getString("Nick")))
                                             .setLargeIcon(BitmapFactory.decodeStream(fh))
                                             .setSmallIcon(R.mipmap.knott_transparent)
                                             .setContentIntent(PendingIntent.getActivity(applicationContext, 1, clickIntent, PendingIntent.FLAG_UPDATE_CURRENT))
@@ -173,7 +176,7 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
                             val fileKey = data.getString("FileKey");
                             if (tempFile != "" && tempFile != data.getString("FilePath")) {
                                 val filePath = data.getString("FilePath");
-                            Log.i("FlwtchWorker", "moving "+tempFile+" to "+filePath);
+                                Log.i("FlwtchWorker", "moving " + tempFile + " to " + filePath);
                                 val sourcePath = Paths.get(tempFile);
                                 val targetUri = Uri.parse(filePath);
                                 val os = this.applicationContext.getContentResolver().openOutputStream(targetUri);
@@ -186,7 +189,7 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
                                 }
                             }
                             if (downloadIDs.containsKey(fileKey)) {
-                            notificationManager.cancel(downloadIDs.get(fileKey)?:0);
+                                notificationManager.cancel(downloadIDs.get(fileKey) ?: 0);
                             }
                         }
 
@@ -265,6 +268,7 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
                     val profile = (a.get("ProfileOnion") as? String) ?: ""
                     val conversation = a.getInt("conversation").toLong()
                     val message = (a.get("message") as? String) ?: ""
+                    Log.i("FlwtchWorker.kt", "SendMessage: $message")
                     Cwtch.sendMessage(profile, conversation, message)
                 }
                 "SendInvitation" -> {
@@ -405,14 +409,18 @@ class FlwtchWorker(context: Context, parameters: WorkerParameters) :
                 }
             }
             return Result.success()
+        } catch (e: Exception) {
+            Log.e("FlwtchWorker", "Error in handleCwtch: " + e.toString() + " :: " + e.getStackTrace())
+            return Result.failure()
+        }
     }
 
     // Creates an instance of ForegroundInfo which can be used to update the
     // ongoing notification.
     private fun createForegroundInfo(progress: String): ForegroundInfo {
         val id = "flwtch"
-        val title = "Flwtch"
-        val cancel = "Shut down"//todo: translate
+        val title = "Flwtch" // TODO: change
+        val cancel = "Shut down" // TODO: translate
         val channelId =
                 if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
                     createForegroundNotificationChannel(id, id)

lib/cwtch/cwtch.dart

@@ -100,7 +100,7 @@ abstract class Cwtch {
   void SetServerAttribute(String serverOnion, String key, String val);
 
   // ignore: non_constant_identifier_names
-  void Shutdown();
+  Future<void> Shutdown();
 
   // non-ffi
   String defaultDownloadPath();

lib/cwtch/cwtchNotifier.dart

@@ -317,7 +317,7 @@ class CwtchNotifier {
                 server: groupInvite["ServerHost"],
                 status: status,
                 isGroup: true,
-                lastMessageTime: DateTime.fromMillisecondsSinceEpoch(0)));
+                lastMessageTime: DateTime.now()));
             profileCN.getProfile(data["ProfileOnion"])?.contactList.updateLastMessageTime(identifier, DateTime.fromMillisecondsSinceEpoch(0));
           }
         }

lib/main.dart

@@ -179,9 +179,9 @@ class FlwtchState extends State<Flwtch> with WindowListener {
   }
 
   Future<void> shutdown() async {
-    cwtch.Shutdown();
+    await cwtch.Shutdown();
     // Wait a few seconds as shutting down things takes a little time..
-    Future.delayed(Duration(seconds: 2)).then((value) {
+    Future.delayed(Duration(seconds: 1)).then((value) {
       if (Platform.isAndroid) {
         SystemNavigator.pop();
       } else if (Platform.isLinux || Platform.isWindows || Platform.isMacOS) {

lib/models/profile.dart

@@ -80,7 +80,9 @@ class ProfileInfoState extends ChangeNotifier {
       List<dynamic> servers = jsonDecode(serversJson);
       this._servers.replace(servers.map((server) {
         // TODO Keys...
-        return RemoteServerInfoState(server["onion"], server["identifier"], server["description"], server["status"]);
+        var preSyncStartTime = DateTime.tryParse(server["syncProgress"]["startTime"]);
+        var lastMessageTime = DateTime.tryParse(server["syncProgress"]["lastMessageTime"]);
+        return RemoteServerInfoState(server["onion"], server["identifier"], server["description"], server["status"], lastPreSyncMessageTime: preSyncStartTime, mostRecentMessageTime: lastMessageTime);
       }));
 
       this._contacts.contacts.forEach((contact) {

lib/models/remoteserver.dart

@@ -12,7 +12,12 @@ class RemoteServerInfoState extends ChangeNotifier {
   double syncProgress = 0;
   DateTime lastPreSyncMessagTime = new DateTime(2020);
 
-  RemoteServerInfoState(this.onion, this.identifier, this.description, this._status);
+  RemoteServerInfoState(this.onion, this.identifier, this.description, this._status, {lastPreSyncMessageTime, mostRecentMessageTime}) {
+    if (_status == "Authenticated") {
+      this.lastPreSyncMessagTime = lastPreSyncMessageTime;
+      updateSyncProgressFor(mostRecentMessageTime);
+    }
+  }
 
   void updateDescription(String newDescription) {
     this.description = newDescription;

lib/notification_manager.dart

@@ -117,7 +117,7 @@ class NixNotificationManager implements NotificationsManager {
 }
 
 NotificationsManager newDesktopNotificationsManager(Future<void> Function(String profileOnion, int convoId) notificationSelectConvo) {
-  if (Platform.isLinux || Platform.isMacOS) {
+  if ((Platform.isLinux && !Platform.isAndroid) || Platform.isMacOS) {
     try {
       return NixNotificationManager(notificationSelectConvo);
     } catch (e) {

lib/widgets/contactrow.dart

@@ -32,6 +32,7 @@ class _ContactRowState extends State<ContactRow> {
           visible: contact.isGroup && contact.status == "Authenticated",
           child: LinearProgressIndicator(
             color: Provider.of<Settings>(context).theme.defaultButtonActiveColor,
+            backgroundColor: Provider.of<Settings>(context).theme.defaultButtonDisabledColor,
             value: Provider.of<ProfileInfoState>(context).serverList.getServer(contact.server ?? "")?.syncProgress,
           ));
     }

lib/widgets/remoteserverrow.dart

@@ -61,6 +61,7 @@ class _RemoteServerRowState extends State<RemoteServerRow> {
                         visible: server.status == "Authenticated",
                         child: LinearProgressIndicator(
                           color: Provider.of<Settings>(context).theme.defaultButtonActiveColor,
+                          backgroundColor: Provider.of<Settings>(context).theme.defaultButtonDisabledColor,
                           value: server.syncProgress,
                         )),
                   ],

pubspec.yaml

@@ -15,7 +15,7 @@ publish_to: 'none' # Remove this line if you wish to publish to pub.dev
 # In iOS, build-name is used as CFBundleShortVersionString while build-number used as CFBundleVersion.
 # Read more about iOS versioning at
 # https://developer.apple.com/library/archive/documentation/General/Reference/InfoPlistKeyReference/Articles/CoreFoundationKeys.html
-version: 1.6.1+26
+version: 1.6.2+27
 
 environment:
   sdk: ">=2.15.0 <3.0.0"