1.2.2

CHANGELOG.md

@@ -1,3 +1,9 @@
+## [1.2.1] - Release.
+Reconnect error handling
+
+## [1.2.0] - Release.
+Added resume connection
+
 ## [1.1.9] - Release.
 Added new property event
 

lib/src/Net/IIP/DistributedConnection.dart

@@ -259,12 +259,8 @@ class DistributedConnection extends NetworkConnection with IStore
     }
 
     Future<bool> reconnect() async
-    {
-      try
     {
         if (await connect())
-        {
-          try
         {
           var bag = AsyncBag();
 
@@ -277,21 +273,13 @@ class DistributedConnection extends NetworkConnection with IStore
 
           bag.seal();
           await bag;
-          }
-          catch(ex)
-          {
-            print(ex.toString());
-          }
-        }
-      }
-      catch(ex)
-      {
-        return false;
-      }
 
           return true;
         }
         
+        return false;
+    }
+
     /// <summary>
     /// KeyList to store user variables related to this connection.
     /// </summary>

lib/src/Net/Packets/IIPPacket.dart

@@ -220,6 +220,9 @@ class IIPPacket
                 var cl = data.getUint32( offset);
                 offset += 4;
 
+                if (_notEnough(offset, ends, cl))
+                    return -_dataLengthNeeded;
+
                 content = data.clip(offset, cl);
                 offset += cl;
 

pubspec.yaml

@@ -1,6 +1,6 @@
 name: esyur
 description: Distributed Object Framework.
-version: 1.1.9
+version: 1.2.1
 # author: Ahmed Zamil <ahmed@dijlh.com>
 homepage: https://github.com/esyur/esyur-dart
 

test/main.dart

@@ -24,18 +24,23 @@ main() async
     print(x.suspended);
 
     DistributedConnection con = x.connection;
-    con.close();
+    //con.close();
         print(x.suspended);
 
    now = DateTime.now();
 
-    await con.reconnect();
+    //await con.reconnect();
 
     print("Time ${DateTime.now().difference(now).inSeconds}");
     print(x.suspended);
     var u = await x.getMyTrackers();
     print(trackers[0].suspended);
 
+    u[0].on("moved", (x){
+      print("Movvvvvvvvvvvvvvvvved");
+    });
+    
+  Future.delayed(Duration(seconds: 100));
   // for(var i = 0; i < trackers.length; i++)
   //   print(trackers[i].name);