Better logs on core

packages/reown_core/CHANGELOG.md

@@ -1,3 +1,7 @@
+## 1.0.3
+
+- Better logs
+
 ## 1.0.2
 
 - Better logs

packages/reown_core/lib/connectivity/connectivity.dart

@@ -31,14 +31,14 @@ class ConnectivityState implements IConnectivity {
     final isOnlineStatus = isMobileData || isWifi;
 
     if (isOnline.value != isOnlineStatus) {
-      _core.logger.i('[$runtimeType] Connectivity changed $result');
       isOnline.value = isOnlineStatus;
+      _core.logger.i('[$runtimeType] Connectivity changed $isOnlineStatus');
 
-      if (isOnline.value && !_core.relayClient.isConnected) {
-        await _core.relayClient.connect();
-      } else if (!isOnline.value && _core.relayClient.isConnected) {
-        await _core.relayClient.disconnect();
-      }
+      // if (isOnline.value && !_core.relayClient.isConnected) {
+      //   await _core.relayClient.connect();
+      // } else if (!isOnline.value && _core.relayClient.isConnected) {
+      //   await _core.relayClient.disconnect();
+      // }
     }
   }
 }

packages/reown_core/lib/pairing/pairing.dart

@@ -351,6 +351,8 @@ class Pairing implements IPairing {
   Future<void> disconnect({required String topic}) async {
     _checkInitialized();
 
+    core.logger.i('[$runtimeType] disconnect $topic');
+
     await _isValidDisconnect(topic);
     if (pairings.has(topic)) {
       // Send the request to delete the pairing, we don't care if it fails
@@ -605,6 +607,7 @@ class Pairing implements IPairing {
   }
 
   Future<void> _deletePairing(String topic, bool expirerHasDeleted) async {
+    core.logger.d('[$runtimeType] _deletePairing $topic, $expirerHasDeleted');
     await core.relayClient.unsubscribe(topic: topic);
     await pairings.delete(topic);
     await core.crypto.deleteSymKey(topic);
@@ -614,6 +617,7 @@ class Pairing implements IPairing {
   }
 
   Future<void> _cleanup() async {
+    core.logger.d('[$runtimeType] _cleanup');
     final List<PairingInfo> expiredPairings = getPairings()
         .where(
           (PairingInfo info) => ReownCoreUtils.isExpired(info.expiry),
@@ -780,7 +784,9 @@ class Pairing implements IPairing {
     JsonRpcRequest request, [
     _,
   ]) async {
-    // print('delete');
+    core.logger.d(
+      '[$runtimeType] _onPairingDeleteRequest $topic, ${request.toJson()}',
+    );
     final int id = request.id;
     try {
       await _isValidDisconnect(topic);
@@ -846,6 +852,7 @@ class Pairing implements IPairing {
     if (event == null) {
       return;
     }
+    core.logger.d('[$runtimeType] _onExpired, ${event.toString()}');
 
     if (pairings.has(event.target)) {
       // Clean up the pairing

packages/reown_core/lib/relay_client/relay_client.dart

@@ -114,6 +114,8 @@ class RelayClient implements IRelayClient {
   }) async {
     _checkInitialized();
 
+    core.logger.i('[$runtimeType] publish, $topic, $message');
+
     Map<String, dynamic> data = {
       'message': message,
       'ttl': ttl,
@@ -128,8 +130,8 @@ class RelayClient implements IRelayClient {
         data,
         JsonRpcUtils.payloadId(entropy: 6),
       );
-    } catch (e) {
-      // print(e);
+    } catch (e, s) {
+      core.logger.e('[$runtimeType], publish: $e', stackTrace: s);
       onRelayClientError.broadcast(ErrorEvent(e));
     }
   }
@@ -138,6 +140,8 @@ class RelayClient implements IRelayClient {
   Future<String> subscribe({required String topic}) async {
     _checkInitialized();
 
+    core.logger.i('[$runtimeType] subscribe, $topic');
+
     pendingSubscriptions[topic] = _onSubscribe(topic);
 
     return await pendingSubscriptions[topic];
@@ -147,6 +151,8 @@ class RelayClient implements IRelayClient {
   Future<void> unsubscribe({required String topic}) async {
     _checkInitialized();
 
+    core.logger.i('[$runtimeType] unsubscribe, $topic');
+
     String id = topicMap.get(topic) ?? '';
 
     try {
@@ -158,7 +164,8 @@ class RelayClient implements IRelayClient {
         },
         JsonRpcUtils.payloadId(entropy: 6),
       );
-    } catch (e) {
+    } catch (e, s) {
+      core.logger.e('[$runtimeType], unsubscribe: $e', stackTrace: s);
       onRelayClientError.broadcast(ErrorEvent(e));
     }
 
@@ -213,13 +220,13 @@ class RelayClient implements IRelayClient {
       _connecting = false;
       _subscribeToHeartbeat();
       //
-    } on TimeoutException catch (e) {
-      core.logger.e('[$runtimeType]: Connect timeout: $e');
+    } on TimeoutException catch (e, s) {
+      core.logger.e('[$runtimeType], _connect timeout: $e', stackTrace: s);
       onRelayClientError.broadcast(ErrorEvent('Connection to relay timeout'));
       _connecting = false;
       _connect();
-    } catch (e) {
-      core.logger.e('[$runtimeType]: Connect error: $e');
+    } catch (e, s) {
+      core.logger.e('[$runtimeType], _connect error: $e', stackTrace: s);
       onRelayClientError.broadcast(ErrorEvent(e));
       _connecting = false;
     }
@@ -335,6 +342,7 @@ class RelayClient implements IRelayClient {
             message: errorReason,
           )),
         );
+        core.logger.e('[$runtimeType], _handleRelayClose: $core, $errorReason');
       }
     }
   }
@@ -466,8 +474,11 @@ class RelayClient implements IRelayClient {
         {'topic': topic},
         JsonRpcUtils.payloadId(entropy: 6),
       );
-    } catch (e) {
-      core.logger.e('RelayClient, onSubscribe error. Topic: $topic, Error: $e');
+    } catch (e, s) {
+      core.logger.e(
+        '[$runtimeType], _onSubscribe: Topic, $topic, Error: $e',
+        stackTrace: s,
+      );
       onRelayClientError.broadcast(ErrorEvent(e));
     }
 

packages/reown_core/pubspec.yaml

@@ -1,6 +1,6 @@
 name: reown_core
 description: "Reown is the onchain UX platform that provides toolkits built on top of the WalletConnect Network"
-version: 1.0.2
+version: 1.0.3
 homepage: https://github.com/reown-com/reown_flutter
 repository: https://github.com/reown-com/reown_flutter/tree/master/packages/reown_core