From f631a273d7c82424d6f166aab40fa5584fe229cf Mon Sep 17 00:00:00 2001 From: Pritimay Sarkar Date: Fri, 9 Feb 2024 13:50:33 +0530 Subject: [PATCH] TLS impleamentation on NATS server --- .../com/example/hpostesting/presentation/NatsManager.kt | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/app/src/main/java/com/example/hpostesting/presentation/NatsManager.kt b/app/src/main/java/com/example/hpostesting/presentation/NatsManager.kt index 4c8f3dc..56898c7 100644 --- a/app/src/main/java/com/example/hpostesting/presentation/NatsManager.kt +++ b/app/src/main/java/com/example/hpostesting/presentation/NatsManager.kt @@ -8,6 +8,7 @@ import io.nats.client.Message import io.nats.client.NKey import io.nats.client.Nats import io.nats.client.Options +import io.nats.client.support.SSLUtils import java.io.IOException import java.nio.charset.StandardCharsets import java.security.GeneralSecurityException @@ -30,7 +31,8 @@ class NatsManager(datacollector: DashboardActivity) { val theNKey = NKey.fromSeed(seedBytes) // really should load from somewhere val options = Options.Builder() - .server("nats://192.168.10.117:4222") + .server("nats://nanodgx.in:4222") + .sslContext(SSLUtils.createOpenTLSContext()) .authHandler(object : AuthHandler { override fun getID(): CharArray? { return try { @@ -84,7 +86,7 @@ class NatsManager(datacollector: DashboardActivity) { d?.subscribe("device.hpos.HCV-000-3001.update") { msg -> val response = String(msg.data, StandardCharsets.UTF_8) - datacollector. setResponse(response) + datacollector.setResponse(response) println("Message received (up to 100 times): $response") }