Fix sending messages

Author: CodeDoctorDE

api/lib/connection.dart

@@ -83,13 +83,17 @@ class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
     this.e2eePipe,
     this.split = kDefaultSwampSplit,
     this.flags = const RoomFlags(),
-  }) : messagePipe = InternalChannelPipe(bytes: 2, channel: kAnyChannel) {
+  }) : messagePipe = SimpleNetworkerPipe() {
+    final channelPipe = InternalChannelPipe(bytes: 2, channel: kAnyChannel);
     if (e2eePipe != null) {
-      registerNamedFunction(SwampEvent.message).connect(e2eePipe!);
+      registerNamedFunction(
+        SwampEvent.message,
+      ).connect(channelPipe..connect(e2eePipe!..connect(messagePipe)));
+    } else {
+      registerNamedFunction(
+        SwampEvent.message,
+      ).connect(channelPipe..connect(messagePipe));
     }
-    (e2eePipe ?? registerNamedFunction(SwampEvent.message)).connect(
-      messagePipe,
-    );
     _initFunctions();
   }
 

server/lib/room.dart

@@ -231,6 +231,8 @@ final class SwampRoomManager extends SimpleNetworkerPipe<RpcNetworkerPacket> {
     if (room == null) return;
     final senderChannel = room.getChannel(sender);
     if (senderChannel == null) return;
+    final receiverPlayer = room.getPlayer(receiver);
+    if (receiverPlayer == null) return;
     final builder = BytesBuilder();
     builder.addByte(senderChannel >> 8);
     builder.addByte(senderChannel & 0xFF);
@@ -240,7 +242,7 @@ final class SwampRoomManager extends SimpleNetworkerPipe<RpcNetworkerPacket> {
       name: SwampEvent.message,
       data: bytes,
     );
-    _sendPacketToRoom(room, packet, receiver);
+    _sendPacketToRoom(room, packet, receiverPlayer);
   }
 
   void setApplication(Channel channel, Uint8List? data) {