Merge pull request #280 from relaystr/chore-dart-format-11-11-25

chore: dart format

Author: 1-leo

packages/ndk/lib/domain_layer/usecases/broadcast/broadcast.dart

@@ -68,7 +68,8 @@ class Broadcast {
     final signer =
         nostrEvent.sig == '' ? _checkSinger(customSigner: customSigner) : null;
 
-    final cleanedSpecificRelays = specificRelays != null ? cleanRelayUrls(specificRelays.toList()) : null;
+    final cleanedSpecificRelays =
+        specificRelays != null ? cleanRelayUrls(specificRelays.toList()) : null;
 
     return _engine.handleEventBroadcast(
       nostrEvent: nostrEvent,
@@ -127,7 +128,8 @@ class Broadcast {
     }
 
     if (idsToDelete.isEmpty) {
-      throw ArgumentError("At least one eventId must be provided for deletion.");
+      throw ArgumentError(
+          "At least one eventId must be provided for deletion.");
     }
 
     Nip01Event event = Nip01Event(

packages/ndk/lib/domain_layer/usecases/jit_engine/jit_engine.dart

@@ -70,7 +70,8 @@ class JitEngine with Logger implements NetworkEngine {
 
       if (requestState.request.explicitRelays != null &&
           requestState.request.explicitRelays!.isNotEmpty) {
-        final cleanedExplicitRelays = cleanRelayUrls(requestState.request.explicitRelays!.toList());
+        final cleanedExplicitRelays =
+            cleanRelayUrls(requestState.request.explicitRelays!.toList());
         RelayJitRequestSpecificStrategy.handleRequest(
           relayManager: relayManagerLight,
           requestState: requestState,

packages/ndk/lib/domain_layer/usecases/nwc/nostr_wallet_connect_uri.dart

@@ -72,8 +72,11 @@ class NostrWalletConnectUri extends Equatable {
     String? secret = parsedUri.queryParameters['secret'];
     String? lud16 = parsedUri.queryParameters['lud16'];
 
-    if (pubkey.isEmpty || secret == null || parsedUri.scheme != 'nostr+walletconnect') {
-      throw Exception("Required fields (scheme, pubkey, secret) are missing or incorrect in the connection URI.");
+    if (pubkey.isEmpty ||
+        secret == null ||
+        parsedUri.scheme != 'nostr+walletconnect') {
+      throw Exception(
+          "Required fields (scheme, pubkey, secret) are missing or incorrect in the connection URI.");
     }
 
     // Parse relays - support both single relay and comma-separated relays
@@ -83,7 +86,11 @@ class NostrWalletConnectUri extends Equatable {
     List<String>? relayParams = parsedUri.queryParametersAll['relay'];
     if (relayParams != null) {
       for (var relay in relayParams) {
-        List<String> commaSeparatedRelays = relay.split(',').map((r) => r.trim()).where((r) => r.isNotEmpty).toList();
+        List<String> commaSeparatedRelays = relay
+            .split(',')
+            .map((r) => r.trim())
+            .where((r) => r.isNotEmpty)
+            .toList();
         for (String relay in commaSeparatedRelays) {
           if (!relaysList.contains(relay)) {
             relaysList.add(relay);
@@ -95,8 +102,11 @@ class NostrWalletConnectUri extends Equatable {
     // Check for comma-separated relays in a single parameter
     String? relaysParam = parsedUri.queryParameters['relays'];
     if (relaysParam != null) {
-      List<String> commaSeparatedRelays =
-          relaysParam.split(',').map((r) => r.trim()).where((r) => r.isNotEmpty).toList();
+      List<String> commaSeparatedRelays = relaysParam
+          .split(',')
+          .map((r) => r.trim())
+          .where((r) => r.isNotEmpty)
+          .toList();
       for (String relay in commaSeparatedRelays) {
         if (!relaysList.contains(relay)) {
           relaysList.add(relay);

packages/ndk/lib/domain_layer/usecases/nwc/nwc.dart

@@ -109,8 +109,9 @@ class Nwc {
 
         await _subscribeToNotificationsAndResponses(connection);
 
-        if (doGetInfoMethod && (ignoreCapabilitiesCheck ||
-            connection.permissions.contains(NwcMethod.GET_INFO.name))) {
+        if (doGetInfoMethod &&
+            (ignoreCapabilitiesCheck ||
+                connection.permissions.contains(NwcMethod.GET_INFO.name))) {
           try {
             await getInfo(connection, timeout: timeout).then((info) {
               connection.info = info;
@@ -145,7 +146,8 @@ class Nwc {
     connection.subscription = _requests.subscription(
         name:
             "nwc-sub-${connection.useETagForEachRequest ? "notifs-only" : ""}",
-        explicitRelays: connection.uri.relays.map((r) => Uri.decodeFull(r)).toList(),
+        explicitRelays:
+            connection.uri.relays.map((r) => Uri.decodeFull(r)).toList(),
         filters: [
           Filter(
             kinds: kindsToSubscribe,
@@ -298,7 +300,8 @@ class Nwc {
       );
       dedicatedResponse = _requests.subscription(
           name: "nwc-response-",
-          explicitRelays: connection.uri.relays.map((r) => Uri.decodeFull(r)).toList(),
+          explicitRelays:
+              connection.uri.relays.map((r) => Uri.decodeFull(r)).toList(),
           filters: [responseFilter],
           cacheRead: false,
           cacheWrite: false);
@@ -323,7 +326,8 @@ class Nwc {
 
     final bResponse = _broadcast.broadcast(
       nostrEvent: event,
-      specificRelays: connection.uri.relays.map((r) => Uri.decodeFull(r)).toList(),
+      specificRelays:
+          connection.uri.relays.map((r) => Uri.decodeFull(r)).toList(),
       customSigner: connection.signer,
     );
     await bResponse.broadcastDoneFuture;
@@ -375,8 +379,10 @@ class Nwc {
   }
 
   /// Does a `get_balance` request
-  Future<GetBalanceResponse> getBalance(NwcConnection connection, {Duration? timeout}) async {
-    return _executeRequest<GetBalanceResponse>(connection, GetBalanceRequest(), timeout: timeout);
+  Future<GetBalanceResponse> getBalance(NwcConnection connection,
+      {Duration? timeout}) async {
+    return _executeRequest<GetBalanceResponse>(connection, GetBalanceRequest(),
+        timeout: timeout);
   }
 
   /// Does a `get_balance` request

packages/ndk/lib/shared/logger/log_level.dart

@@ -1,5 +1,5 @@
 /// Log levels for the NDK logger.
-/// 
+///
 /// Defines the severity levels for logging messages.
 enum LogLevel {
   /// Log everything - lowest priority

packages/ndk/test/relays/requests_test.dart

@@ -131,7 +131,8 @@ void main() async {
       await relay1.stopServer();
     });
 
-    test('Subscription processes events immediately without stream closing', () async {
+    test('Subscription processes events immediately without stream closing',
+        () async {
       // This test would FAIL with the previous VerifyEventStream implementation
       // because events would remain stuck in buffer until stream closes
       MockRelay relay1 = MockRelay(name: "relay 1", explicitPort: 6060);
@@ -143,9 +144,11 @@ void main() async {
         engine: NdkEngine.RELAY_SETS,
         bootstrapRelays: [relay1.url],
       ));
-      ndk.accounts.loginPrivateKey(pubkey: key1.publicKey, privkey: key1.privateKey!);
+      ndk.accounts
+          .loginPrivateKey(pubkey: key1.publicKey, privkey: key1.privateKey!);
 
-      final filter = Filter(kinds: [Nip01Event.kTextNodeKind], authors: [key1.publicKey]);
+      final filter =
+          Filter(kinds: [Nip01Event.kTextNodeKind], authors: [key1.publicKey]);
 
       // Use subscription instead of query - this creates a long-lived stream
       final subscription = ndk.requests.subscription(filters: [filter]);
@@ -160,7 +163,8 @@ void main() async {
       await Future.delayed(Duration(milliseconds: 200));
 
       expect(receivedEvents.length, equals(1),
-          reason: 'Subscription should process events immediately without waiting for stream to close');
+          reason:
+              'Subscription should process events immediately without waiting for stream to close');
       expect(receivedEvents[0].content, contains('key1'));
 
       // Clean up
@@ -171,7 +175,8 @@ void main() async {
       await relay1.stopServer();
     });
 
-    test('Subscription handles continuous events from non-closing stream', () async {
+    test('Subscription handles continuous events from non-closing stream',
+        () async {
       // This test simulates a real-world scenario where a subscription
       // receives events continuously without the stream ever closing
       MockRelay relay1 = MockRelay(name: "relay 1", explicitPort: 6060);
@@ -191,10 +196,17 @@ void main() async {
         engine: NdkEngine.RELAY_SETS,
         bootstrapRelays: [relay1.url],
       ));
-      ndk.accounts.loginPrivateKey(pubkey: key1.publicKey, privkey: key1.privateKey!);
+      ndk.accounts
+          .loginPrivateKey(pubkey: key1.publicKey, privkey: key1.privateKey!);
 
-      final filter = Filter(
-          kinds: [Nip01Event.kTextNodeKind], authors: [key1.publicKey, key2.publicKey, key3.publicKey, key4.publicKey]);
+      final filter = Filter(kinds: [
+        Nip01Event.kTextNodeKind
+      ], authors: [
+        key1.publicKey,
+        key2.publicKey,
+        key3.publicKey,
+        key4.publicKey
+      ]);
 
       final subscription = ndk.requests.subscription(filters: [filter]);
 
@@ -208,11 +220,14 @@ void main() async {
       // because they would get stuck in the verification buffer
       await Future.delayed(Duration(milliseconds: 300));
 
-      expect(receivedEvents.length, equals(4), reason: 'Subscription should process all matching events immediately');
+      expect(receivedEvents.length, equals(4),
+          reason:
+              'Subscription should process all matching events immediately');
 
       // Verify we got events from different authors (showing parallel processing worked)
       final uniqueAuthors = receivedEvents.map((e) => e.pubKey).toSet();
-      expect(uniqueAuthors.length, greaterThan(1), reason: 'Should receive events from multiple authors');
+      expect(uniqueAuthors.length, greaterThan(1),
+          reason: 'Should receive events from multiple authors');
 
       // Clean up
       await streamSubscription.cancel();

packages/ndk/test/usecases/broadcast_jit_test.dart

@@ -127,7 +127,8 @@ void main() async {
         Filter(authors: [event1.pubKey], kinds: [Nip01Event.kTextNodeKind])
       ]).future;
 
-      response1 = ndk.broadcast.broadcastDeletion(eventIds: [event1.id, event2.id]);
+      response1 =
+          ndk.broadcast.broadcastDeletion(eventIds: [event1.id, event2.id]);
       await response1.broadcastDoneFuture;
 
       list = await ndk.requests.query(filters: [
@@ -136,7 +137,8 @@ void main() async {
       expect(list, isEmpty);
     });
 
-    test('broadcast deletion with empty eventIds throws ArgumentError', () async {
+    test('broadcast deletion with empty eventIds throws ArgumentError',
+        () async {
       ndk.accounts
           .loginPrivateKey(pubkey: key0.publicKey, privkey: key0.privateKey!);
       expect(

packages/ndk/test/usecases/broadcast_test.dart

@@ -129,7 +129,8 @@ void main() async {
         Filter(authors: [event1.pubKey], kinds: [Nip01Event.kTextNodeKind])
       ]).future;
 
-      response1 = ndk.broadcast.broadcastDeletion(eventIds: [event1.id, event2.id]);
+      response1 =
+          ndk.broadcast.broadcastDeletion(eventIds: [event1.id, event2.id]);
       await response1.broadcastDoneFuture;
 
       list = await ndk.requests.query(filters: [
@@ -166,7 +167,8 @@ void main() async {
       expect(list.first.content, reaction);
     });
 
-    test('broadcast deletion with empty eventIds throws ArgumentError', () async {
+    test('broadcast deletion with empty eventIds throws ArgumentError',
+        () async {
       ndk.accounts
           .loginPrivateKey(pubkey: key0.publicKey, privkey: key0.privateKey!);
       expect(

packages/ndk/test/usecases/nwc/nostr_wallet_connect_uri_test.dart

@@ -31,7 +31,9 @@ void main() {
           ]));
       expect(nostrUri.secret, equals('secret123'));
     });
-    test('should parse a connection URI with multiple individual relay parameters', () {
+    test(
+        'should parse a connection URI with multiple individual relay parameters',
+        () {
       final uri =
           'nostr+walletconnect://pubkey123?relay=wss://relay1.example.com&relay=wss://relay2.example.com&relay=wss://relay3.example.com&secret=secret123';
       final nostrUri = NostrWalletConnectUri.parseConnectionUri(uri);
@@ -75,7 +77,8 @@ void main() {
     });
 
     test('should throw an exception for missing required fields', () {
-      final uri = 'nostr+walletconnect://pubkey123?relays=wss://relay.example.com';
+      final uri =
+          'nostr+walletconnect://pubkey123?relays=wss://relay.example.com';
 
       expect(
         () => NostrWalletConnectUri.parseConnectionUri(uri),

packages/ndk/test/verifiers/verify_event_stream_test.dart

@@ -225,21 +225,25 @@ void main() {
 
       await Future.delayed(Duration(milliseconds: 50));
 
-      expect(resultList.length, equals(1), reason: 'First event should be processed immediately');
+      expect(resultList.length, equals(1),
+          reason: 'First event should be processed immediately');
       expect(resultList[0].content, equals('content1'));
 
       controller.add(createMockEvent('2'));
 
       await Future.delayed(Duration(milliseconds: 50));
 
-      expect(resultList.length, equals(2), reason: 'Second event should be processed immediately');
+      expect(resultList.length, equals(2),
+          reason: 'Second event should be processed immediately');
       expect(resultList[1].content, equals('content2'));
 
       await subscription.cancel();
       await controller.close();
     });
 
-    test('should process events from non-closing stream with fewer events than maxConcurrent', () async {
+    test(
+        'should process events from non-closing stream with fewer events than maxConcurrent',
+        () async {
       final controller = StreamController<Nip01Event>();
       final resultList = <Nip01Event>[];
 
@@ -259,7 +263,9 @@ void main() {
 
       await Future.delayed(Duration(milliseconds: 100));
 
-      expect(resultList.length, equals(3), reason: 'All events should be processed even when count < maxConcurrent');
+      expect(resultList.length, equals(3),
+          reason:
+              'All events should be processed even when count < maxConcurrent');
 
       await subscription.cancel();
       await controller.close();
@@ -286,8 +292,10 @@ void main() {
 
       await Future.delayed(Duration(milliseconds: 50));
 
-      expect(resultList.length, equals(1), reason: 'Fast event should complete first');
-      expect(resultList[0].content, equals('contentfast'), reason: 'Fast event should be yielded before slow event');
+      expect(resultList.length, equals(1),
+          reason: 'Fast event should complete first');
+      expect(resultList[0].content, equals('contentfast'),
+          reason: 'Fast event should be yielded before slow event');
 
       await Future.delayed(Duration(milliseconds: 80));
 
@@ -298,7 +306,8 @@ void main() {
       await controller.close();
     });
 
-    test('should handle continuous stream of events without blocking', () async {
+    test('should handle continuous stream of events without blocking',
+        () async {
       final controller = StreamController<Nip01Event>();
       final resultList = <Nip01Event>[];
 
@@ -319,19 +328,23 @@ void main() {
 
         if (i >= 2) {
           expect(resultList.length, greaterThan(0),
-              reason: 'Events should be processed continuously, not waiting for stream end');
+              reason:
+                  'Events should be processed continuously, not waiting for stream end');
         }
       }
 
       await Future.delayed(Duration(milliseconds: 100));
 
-      expect(resultList.length, equals(10), reason: 'All events should be processed from continuous stream');
+      expect(resultList.length, equals(10),
+          reason: 'All events should be processed from continuous stream');
 
       await subscription.cancel();
       await controller.close();
     });
 
-    test('should not deadlock when maxConcurrent is reached with non-closing stream', () async {
+    test(
+        'should not deadlock when maxConcurrent is reached with non-closing stream',
+        () async {
       final controller = StreamController<Nip01Event>();
       final resultList = <Nip01Event>[];
 
@@ -352,13 +365,15 @@ void main() {
 
       await Future.delayed(Duration(milliseconds: 200));
 
-      expect(resultList.length, equals(4), reason: 'Should process all events without deadlocking');
+      expect(resultList.length, equals(4),
+          reason: 'Should process all events without deadlocking');
 
       await subscription.cancel();
       await controller.close();
     });
 
-    test('should yield events immediately upon verification completion', () async {
+    test('should yield events immediately upon verification completion',
+        () async {
       final controller = StreamController<Nip01Event>();
       final resultTimes = <DateTime>[];
 
@@ -386,7 +401,9 @@ void main() {
 
       for (int i = 0; i < resultTimes.length; i++) {
         final timeDiff = resultTimes[i].difference(startTime).inMilliseconds;
-        expect(timeDiff, lessThan(200), reason: 'Event $i should be processed within 200ms, was ${timeDiff}ms');
+        expect(timeDiff, lessThan(200),
+            reason:
+                'Event $i should be processed within 200ms, was ${timeDiff}ms');
       }
 
       await subscription.cancel();