fix: Attempt correction of grpc trying to use unix sockets instead of tcp

Author: AndrewWestberg

buildSrc/src/main/kotlin/Versions.kt

@@ -14,7 +14,7 @@ object Versions {
     const val EXPOSED = "0.61.0"
     const val FLYWAYDB = "11.11.2"
     const val GOOGLE_TRUTH = "1.4.4"
-    const val GRPC = "1.75.0"
+    const val GRPC = "1.74.0"
     const val GRPC_KOTLIN = "1.4.3"
     const val HIKARICP = "7.0.2"
     const val I2P_CRYPTO = "0.3.0"
@@ -36,7 +36,7 @@ object Versions {
     const val MAVEN_PUBLISH = "0.34.0"
     const val MOCKK = "1.14.5"
     const val POSTGRESQL = "42.7.7"
-    const val PROTOBUF = "4.32.0"
+    const val PROTOBUF = "4.31.1"
     const val PROTOBUF_PLUGIN = "0.9.5"
     const val QR_CODE_KOTLIN = "4.5.0"
     const val QUARTZ = "2.5.0"

newm-server/src/main/kotlin/io/newm/server/features/cardano/CardanoKoinModule.kt

@@ -1,5 +1,6 @@
 package io.newm.server.features.cardano
 
+import io.github.oshai.kotlinlogging.KotlinLogging
 import io.grpc.ManagedChannelBuilder
 import io.grpc.Metadata
 import io.grpc.stub.MetadataUtils
@@ -11,9 +12,11 @@ import io.newm.server.ktx.getSecureConfigString
 import io.newm.shared.ktx.getConfigBoolean
 import io.newm.shared.ktx.getConfigInt
 import io.newm.shared.ktx.getConfigString
+import java.util.concurrent.TimeUnit
 import kotlinx.coroutines.runBlocking
 import org.koin.dsl.module
-import java.util.concurrent.TimeUnit
+
+private val log by lazy { KotlinLogging.logger {} }
 
 val cardanoKoinModule =
     module {
@@ -33,19 +36,31 @@ val cardanoKoinModule =
             val port = environment.getConfigInt("newmChain.port")
             val jwt = runBlocking { environment.getSecureConfigString("newmChain.jwt") }
             val secure = environment.getConfigBoolean("newmChain.secure")
+
+            log.info { "Configuring gRPC channel for NewmChain:" }
+            log.info { "  Host: $host" }
+            log.info { "  Port: $port" }
+            log.info { "  Secure: $secure" }
+            log.info { "  Keep-alive time: 30 seconds" }
+            log.info { "  Keep-alive timeout: 20 seconds" }
+            log.info { "  Keep-alive without calls: true" }
+            log.info { "  Transport: ${if (secure) "TLS" else "Plaintext"}" }
+
             val channel =
                 ManagedChannelBuilder
-                    .forTarget("dns:///$host:$port")
+                    .forAddress(host, port)
+                    .keepAliveTime(30L, TimeUnit.SECONDS)
+                    .keepAliveTimeout(20L, TimeUnit.SECONDS)
+                    .keepAliveWithoutCalls(true)
                     .apply {
-                        keepAliveTime(30L, TimeUnit.SECONDS)
-                        keepAliveTimeout(20L, TimeUnit.SECONDS)
-                        keepAliveWithoutCalls(true)
                         if (secure) {
                             useTransportSecurity()
                         } else {
                             usePlaintext()
                         }
                     }.build()
+
+            log.info { "gRPC channel created successfully for $host:$port" }
             NewmChainCoroutineStub(channel)
                 .withInterceptors(
                     MetadataUtils.newAttachHeadersInterceptor(

newm-server/src/test/kotlin/io/newm/server/grpc/GrpcTests.kt

@@ -31,6 +31,7 @@ import io.newm.chain.grpc.walletRequest
 import io.newm.chain.util.Constants
 import io.newm.server.features.cardano.repo.CardanoRepository.Companion.CHARLI3_NEWM_USD_NAME_PREPROD
 import io.newm.server.features.cardano.repo.CardanoRepository.Companion.CHARLI3_NEWM_USD_POLICY_PREPROD
+import java.util.concurrent.TimeUnit
 import kotlinx.coroutines.flow.take
 import kotlinx.coroutines.runBlocking
 import org.junit.jupiter.api.Disabled
@@ -77,6 +78,32 @@ class GrpcTests {
         )
     }
 
+    @Test
+    @Disabled
+    fun `test transport for ManagedChannelBuilder`() {
+        // Test DNS resolution with secure transport and TCP-only configuration
+        val secureChannel = ManagedChannelBuilder
+            .forAddress("newm-chain.cardanostakehouse.com", 3737)
+            .keepAliveTime(30L, TimeUnit.SECONDS)
+            .keepAliveTimeout(20L, TimeUnit.SECONDS)
+            .keepAliveWithoutCalls(true)
+            .useTransportSecurity()
+            .build()
+
+        assertThat(secureChannel).isNotNull()
+        assertThat(secureChannel.isShutdown).isFalse()
+
+        // Verify the channel uses the expected transport
+        val channelState = secureChannel.getState(false)
+        assertThat(channelState).isNotNull()
+
+        // Clean up channels
+        secureChannel.shutdown()
+
+        // Verify channels can be shutdown properly
+        assertThat(secureChannel.awaitTermination(5, TimeUnit.SECONDS)).isTrue()
+    }
+
     @Test
     @Disabled
     fun `test queryUtxos`() =