Add custom scheme

Author: CodeDoctorDE

api/lib/connection.dart

@@ -13,6 +13,7 @@ import 'package:web_socket_channel/web_socket_channel.dart';
 part 'info.dart';
 
 const kDefaultSwampSplit = ':';
+const kSwampSchemePrefix = 'swamp+';
 
 class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
     with
@@ -21,6 +22,10 @@ class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
         NetworkerServerMixin<SwampClientConnectionInfo, RpcNetworkerPacket>,
         NetworkerClientMixin<RpcNetworkerPacket>,
         NamedRpcNetworkerPipe<SwampEvent, SwampCommand> {
+  static final List<String> supportedSchemes = List.unmodifiable(const [
+    '${kSwampSchemePrefix}ws',
+    '${kSwampSchemePrefix}wss',
+  ]);
   final StreamController<void> _onOpen = StreamController<void>.broadcast(),
       _onClosed = StreamController<void>.broadcast();
   final BehaviorSubject<RoomInfo> _onRoomInfo = BehaviorSubject();
@@ -56,6 +61,7 @@ class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
     return server.replace(
       fragment:
           '${encodeRoomCode(id)}$split${encodeRoomCode(Uint8List.fromList(key))}',
+      scheme: '$kSwampSchemePrefix${server.scheme}',
     );
   }
 
@@ -158,6 +164,13 @@ class SwampConnection extends NetworkerPipe<Uint8List, RpcNetworkerPacket>
     if (isOpen) {
       return;
     }
+    var address = this.address;
+    final scheme = address.scheme;
+    if (scheme.startsWith(kSwampSchemePrefix)) {
+      address = address.replace(
+        scheme: scheme.substring(kSwampSchemePrefix.length),
+      );
+    }
     final channel =
         _channel = WebSocketChannel.connect(address, protocols: ['swamp-0']);
     channel.stream.listen(

server/lib/room.dart

@@ -212,14 +212,15 @@ final class SwampRoomManager extends SimpleNetworkerPipe<RpcNetworkerPacket> {
     SwampRoom room,
     RpcNetworkerPacket packet, [
     Channel receiver = kAnyChannel,
+    Channel sender = kAnyChannel,
   ]) {
-    final receivers = <Channel>[];
+    List<Channel> receivers;
     if (receiver == kAnyChannel) {
-      receivers.addAll(room._playerChannels.keys);
+      receivers = room._playerChannels.keys.where((c) => c != sender).toList();
     } else {
       final channel = room.getPlayer(receiver);
       if (channel == null) return;
-      receivers.add(channel);
+      receivers = [channel];
     }
     for (final receiver in receivers) {
       sendMessage(packet, receiver);
@@ -240,7 +241,7 @@ final class SwampRoomManager extends SimpleNetworkerPipe<RpcNetworkerPacket> {
       name: SwampEvent.message,
       data: bytes,
     );
-    _sendPacketToRoom(room, packet, receiver);
+    _sendPacketToRoom(room, packet, receiver, sender);
   }
 
   void setApplication(Channel channel, Uint8List? data) {