style: ktlint

Author: bangbang93

src/main/kotlin/com/bangbang93/openbmclapi/agent/nat/NatService.kt

@@ -13,7 +13,9 @@ class NatService(
     private val config: ClusterConfig,
 ) {
     private val mapper: NatMapper = WeUpnpNatMapper()
+
     @Volatile private var handle: MappingHandle? = null
+
     @Volatile private var external: InetAddress? = null
 
     fun startIfEnabled(): InetAddress? {
@@ -63,5 +65,3 @@ class NatService(
         }
     }
 }
-
-

src/main/kotlin/com/bangbang93/openbmclapi/agent/service/ClusterService.kt

@@ -8,8 +8,8 @@ import com.bangbang93.openbmclapi.agent.model.FileInfo
 import com.bangbang93.openbmclapi.agent.model.FileList
 import com.bangbang93.openbmclapi.agent.model.OpenbmclapiAgentConfiguration
 import com.bangbang93.openbmclapi.agent.model.SyncConfig
-import com.bangbang93.openbmclapi.agent.storage.IStorage
 import com.bangbang93.openbmclapi.agent.nat.NatService
+import com.bangbang93.openbmclapi.agent.storage.IStorage
 import com.bangbang93.openbmclapi.agent.util.HashUtil
 import com.bangbang93.openbmclapi.agent.util.emitAck
 import com.github.avrokotlin.avro4k.Avro
@@ -174,12 +174,13 @@ class ClusterService(
 
         logger.trace { "Enabling cluster" }
 
-        val upnpIp = try {
-            natService.startIfEnabled()
-        } catch (e: Exception) {
-            logger.error(e) { "UPnP/NAT 端口映射失败" }
-            throw e
-        }
+        val upnpIp =
+            try {
+                natService.startIfEnabled()
+            } catch (e: Exception) {
+                logger.error(e) { "UPnP/NAT 端口映射失败" }
+                throw e
+            }
 
         val hostForEnable = config.clusterIp ?: upnpIp?.hostAddress
 

src/test/kotlin/com/bangbang93/openbmclapi/agent/nat/WeUpnpNatMapperTest.kt

@@ -1,10 +1,10 @@
 package com.bangbang93.openbmclapi.agent.nat
 
-import kotlin.test.Test
-import kotlin.test.assertTrue
 import io.github.oshai.kotlinlogging.KotlinLogging
 import org.bitlet.weupnp.GatewayDiscover
 import java.net.Inet4Address
+import kotlin.test.Test
+import kotlin.test.assertTrue
 
 class WeUpnpNatMapperTest {
     private val logger = KotlinLogging.logger {}
@@ -15,22 +15,24 @@ class WeUpnpNatMapperTest {
         logger.info { "Discovering UPnP gateways..." }
         val found = discover.discover()
         logger.info { "Discovery result: found=$found, gw=${discover.validGateway}" }
-        val gw = discover.validGateway ?: run {
-            logger.info { "No UPnP IGD gateway found - skipping test" }
-            return
-        }
+        val gw =
+            discover.validGateway ?: run {
+                logger.info { "No UPnP IGD gateway found - skipping test" }
+                return
+            }
 
         val mapper = WeUpnpNatMapper()
         val privatePort = 4000
         val publicPort = 4000
 
-        val handle = mapper.map(
-            privatePort = privatePort,
-            publicPort = publicPort,
-            protocol = Protocol.TCP,
-            ttlSeconds = 300,
-            description = "openbmclapi-test",
-        )
+        val handle =
+            mapper.map(
+                privatePort = privatePort,
+                publicPort = publicPort,
+                protocol = Protocol.TCP,
+                ttlSeconds = 300,
+                description = "openbmclapi-test",
+            )
 
         val ip = mapper.externalIp()
         logger.info { "External IP: ${ip.hostAddress}" }
@@ -40,5 +42,3 @@ class WeUpnpNatMapperTest {
         logger.info { "Unmapped result: $removed" }
     }
 }
-
-