diff --git a/src/main/kotlin/com/zecqtwallet/wormhole/Service.kt b/src/main/kotlin/com/zecqtwallet/wormhole/Service.kt index 0ffc668..bfeab9c 100644 --- a/src/main/kotlin/com/zecqtwallet/wormhole/Service.kt +++ b/src/main/kotlin/com/zecqtwallet/wormhole/Service.kt @@ -46,13 +46,15 @@ fun main(args : Array) { } if (j.contains("to")) { - val s = usermap.getKeys(j["to"].toString()).filter { it != session } + val s = usermap.getKeys(j["to"].toString()).filter { it.id != session.id } if (s.isEmpty()) { // Not connected sendError(session, "Peer is not connected") return@onMessage } + println("Number of sessions matched: ${s.size}") + s[0].send(message) return@onMessage } else { @@ -78,6 +80,7 @@ fun main(args : Array) { fun doRegister(session: WsSession, id: String) { if (usermap.containsKey(session)) { println("Already registered a session") + return } println("Registered $id")