Close #85, Implement ChainHandler.fetchChainInfo() (#86)

ebrahimmfadae · web-flow · commit 5db4fdde8734 · 2021-10-06T16:36:26.000+03:30
diff --git a/BlockchainGateway/bc-gateway-core/src/main/kotlin/co/nilin/opex/bcgateway/core/spi/ChainLoader.kt b/BlockchainGateway/bc-gateway-core/src/main/kotlin/co/nilin/opex/bcgateway/core/spi/ChainLoader.kt
@@ -1,8 +1,7 @@
 package co.nilin.opex.bcgateway.core.spi
 
 import co.nilin.opex.bcgateway.core.model.Chain
-import co.nilin.opex.bcgateway.core.model.CurrencyInfo
 
 interface ChainLoader {
     suspend fun fetchChainInfo(chain: String): Chain
-}
+}
diff --git a/BlockchainGateway/bc-gateway-ports/bc-persister-postgres/src/main/kotlin/co/nilin/opex/port/bcgateway/postgres/impl/ChainHandler.kt b/BlockchainGateway/bc-gateway-ports/bc-persister-postgres/src/main/kotlin/co/nilin/opex/port/bcgateway/postgres/impl/ChainHandler.kt
@@ -1,13 +1,22 @@
 package co.nilin.opex.port.bcgateway.postgres.impl
 
+import co.nilin.opex.bcgateway.core.model.AddressType
 import co.nilin.opex.bcgateway.core.model.Chain
+import co.nilin.opex.bcgateway.core.model.Endpoint
 import co.nilin.opex.bcgateway.core.spi.ChainLoader
 import co.nilin.opex.port.bcgateway.postgres.dao.ChainRepository
+import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.flow.toList
+import kotlinx.coroutines.reactive.awaitSingle
 import org.springframework.stereotype.Component
 
 @Component
-class ChainHandler(val chainRepository: ChainRepository): ChainLoader {
+class ChainHandler(val chainRepository: ChainRepository) : ChainLoader {
     override suspend fun fetchChainInfo(chain: String): Chain {
-        TODO("Not implemented!")
+        val chainDao = chainRepository.findByName(chain).awaitSingle()
+        val addressTypes = chainRepository.findAddressTypesByName(chain)
+            .map { AddressType(it.id!!, it.type, it.addressRegex, it.memoRegex) }.toList()
+        val endpoints = chainRepository.findEndpointsByName(chain).map { Endpoint(it.url) }.toList()
+        return Chain(chainDao.name, addressTypes, endpoints)
     }
-}
+}
