FIX Modify the sockets definition location

pubkey · Apr 30, 2024 · 48ea5ee · 48ea5ee
1 parent 6927db5
commit 48ea5ee
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/plugins/replication-webrtc/connection-handler-simple-peer.ts b/src/plugins/replication-webrtc/connection-handler-simple-peer.ts
@@ -72,7 +72,6 @@ function sendMessage(ws: WebSocket, msg: PeerMessage) {
 
 const DEFAULT_SIGNALING_SERVER_HOSTNAME = 'signaling.rxdb.info';
 export const DEFAULT_SIGNALING_SERVER = 'wss://' + DEFAULT_SIGNALING_SERVER_HOSTNAME + '/';
-const sockets = new Map<string, WebSocket>();
 let defaultServerWarningShown = false;
 
 export type SimplePeerWrtc = SimplePeerOptions['wrtc'];
@@ -130,6 +129,7 @@ export function getConnectionHandlerSimplePeer({
  const response$ = new Subject<PeerWithResponse<SimplePeer>>();
  const error$ = new Subject<RxError | RxTypeError>();
 
+ const sockets = new Map<string, WebSocket>();
  const peers = new Map<string, SimplePeer>();
  let closed = false;
  let ownPeerId: string;
@@ -246,6 +246,7 @@ export function getConnectionHandlerSimplePeer({
  }
  }
  }
+ return socket
  };
 
  const creator: WebRTCConnectionHandlerCreator<SimplePeer> = async (options: SyncOptionsWebRTC<any, SimplePeer>) => {