From c5ade7191f06da8c09274b7012273140aaae0595 Mon Sep 17 00:00:00 2001 From: Aditya Kulkarni Date: Wed, 6 Feb 2019 12:57:19 -0800 Subject: [PATCH] Wormhole connections --- src/main/kotlin/com/zecqtwallet/wormhole/Service.kt | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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")