Fix sending message

Author: CodeDoctorDE

api/example/host.dart

@@ -8,22 +8,27 @@ Future<void> main(List<String> args) async {
   final connection = SwampConnection.build(
     Uri.parse(args.elementAtOrNull(0) ?? 'ws://localhost:8080/ws'),
   );
+  await Future.delayed(Duration(seconds: 5));
+  Timer? timer;
+
   connection.onRoomInfo.listen((event) {
     print('Room created: ${encodeRoomCode(event.roomId)}');
+    timer?.cancel();
+    var i = 0;
+    timer = Timer.periodic(Duration(seconds: 2), (timer) {
+      final message = 'Hello, World! ${i++}';
+      connection.messagePipe.sendMessage(utf8.encode(message));
+      print('Sent message: $message');
+    });
   });
   connection.onCreationFailed.listen((event) {
     print('Failed to create room ($event)');
   });
   connection.onClosed.listen((event) {
     print('Connection closed');
+    timer?.cancel();
+    timer = null;
   });
   await connection.init();
   print('Connected to ${connection.server}');
-  await Future.delayed(Duration(seconds: 5));
-  var i = 0;
-  Timer.periodic(Duration(seconds: 2), (timer) {
-    final message = 'Hello, World! ${i++}';
-    connection.sendNamedFunction(SwampCommand.message, utf8.encode(message));
-    print('Sent message: $message');
-  });
 }

api/lib/connection.dart

@@ -24,6 +24,7 @@ class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
   final Uri server;
   final Uint8List? roomId;
   final E2EENetworkerPipe? e2eePipe;
+  final RawNetworkerPipe messagePipe;
 
   WebSocketChannel? _channel;
 
@@ -56,18 +57,18 @@ class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
 
   RoomInfo? get roomInfo => _onRoomInfo.valueOrNull;
 
-  NetworkerPipe<Uint8List, Uint8List> get messagePipe =>
-      e2eePipe ?? registerNamedFunction(SwampEvent.message);
-
   SwampConnection({
     required this.server,
     this.roomId,
     this.roomCodeEncoder = encodeRoomCode,
     this.e2eePipe,
-  }) {
+  }) : messagePipe = InternalChannelPipe(bytes: 2, channel: kAnyChannel) {
     if (e2eePipe != null) {
       registerNamedFunction(SwampEvent.message).connect(e2eePipe!);
     }
+    (e2eePipe ?? registerNamedFunction(SwampEvent.message)).connect(
+      messagePipe,
+    );
     _initFunctions();
   }
 

api/pubspec.lock

@@ -309,8 +309,8 @@ packages:
     dependency: "direct main"
     description:
       path: "packages/networker/networker"
-      ref: "08928a4dc5ef638809b18c84f4f9bd64108fe18d"
-      resolved-ref: "08928a4dc5ef638809b18c84f4f9bd64108fe18d"
+      ref: "213c6382f196ee93c4c43ca911cdb26a38317e39"
+      resolved-ref: "213c6382f196ee93c4c43ca911cdb26a38317e39"
       url: "https://github.com/LinwoodDev/dart_pkgs.git"
     source: git
     version: "1.0.0"

api/pubspec.yaml

@@ -9,11 +9,7 @@ environment:
 
 # Add regular dependencies here.
 dependencies:
-  networker:
-    git:
-      url: https://github.com/LinwoodDev/dart_pkgs.git
-      path: packages/networker/networker
-      ref: 08928a4dc5ef638809b18c84f4f9bd64108fe18d
+  networker: any
   networker_crypto:
     git:
       url: https://github.com/LinwoodDev/dart_pkgs.git
@@ -27,3 +23,9 @@ dev_dependencies:
   build_runner: ^2.4.15
   lints: ^5.0.0
   test: ^1.24.0
+dependency_overrides:
+  networker:
+    git:
+      url: https://github.com/LinwoodDev/dart_pkgs.git
+      path: packages/networker/networker
+      ref: 213c6382f196ee93c4c43ca911cdb26a38317e39

server/pubspec.lock

@@ -318,8 +318,8 @@ packages:
     dependency: "direct main"
     description:
       path: "packages/networker/networker"
-      ref: "08928a4dc5ef638809b18c84f4f9bd64108fe18d"
-      resolved-ref: "08928a4dc5ef638809b18c84f4f9bd64108fe18d"
+      ref: "213c6382f196ee93c4c43ca911cdb26a38317e39"
+      resolved-ref: "213c6382f196ee93c4c43ca911cdb26a38317e39"
       url: "https://github.com/LinwoodDev/dart_pkgs.git"
     source: git
     version: "1.0.0"

server/pubspec.yaml

@@ -10,11 +10,7 @@ environment:
 dependencies:
   swamp_api:
     path: ../api
-  networker:
-    git:
-      url: https://github.com/LinwoodDev/dart_pkgs.git
-      path: packages/networker/networker
-      ref: 08928a4dc5ef638809b18c84f4f9bd64108fe18d
+  networker: any
   networker_crypto:
     git:
       url: https://github.com/LinwoodDev/dart_pkgs.git
@@ -36,3 +32,9 @@ dev_dependencies:
   http: ^1.1.0
   lints: ^5.0.0
   test: ^1.24.0
+dependency_overrides:
+  networker:
+    git:
+      url: https://github.com/LinwoodDev/dart_pkgs.git
+      path: packages/networker/networker
+      ref: 213c6382f196ee93c4c43ca911cdb26a38317e39