Test Coverage Added

Author: hosseinkarami-dev

client/src/test/kotlin/io/github/hosseinkarami_dev/near/rpc/client/BroadcastTxAsyncTest.kt

@@ -0,0 +1,53 @@
+package io.github.hosseinkarami_dev.near.rpc.client
+
+import io.github.hosseinkarami_dev.near.rpc.client.Utils.getResultOrNull
+import io.github.hosseinkarami_dev.near.rpc.models.CryptoHash
+import io.github.hosseinkarami_dev.near.rpc.models.RpcSendTransactionRequest
+import io.github.hosseinkarami_dev.near.rpc.models.RpcValidatorResponse
+import io.github.hosseinkarami_dev.near.rpc.models.SignedTransaction
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.cio.CIO
+import io.ktor.client.plugins.contentnegotiation.ContentNegotiation
+import io.ktor.serialization.kotlinx.json.json
+import kotlinx.coroutines.test.runTest
+import org.junit.jupiter.api.Test
+import kotlin.test.AfterTest
+import kotlin.test.BeforeTest
+import kotlin.test.assertNotNull
+
+class BroadcastTxAsyncTest {
+
+    private lateinit var httpClient: HttpClient
+    private lateinit var nearClient: NearClient
+
+    @BeforeTest
+    fun setup() {
+        httpClient = HttpClient(CIO) {
+            install(ContentNegotiation) {
+                json()
+            }
+        }
+
+        nearClient = NearClient(
+            httpClient = httpClient,
+            baseUrl = "https://rpc.mainnet.near.org"
+        )
+    }
+
+    @AfterTest
+    fun teardown() {
+        httpClient.close()
+    }
+
+    @Test
+    fun testStatus() = runTest {
+        val response = nearClient.broadcastTxAsync(
+            RpcSendTransactionRequest(
+                signedTxBase64 = SignedTransaction("DgAAAHNlbmRlci50ZXN0bmV0AOrmAai64SZOv9e/naX4W15pJx0GAap35wTT1T/DwcbbDwAAAAAAAAAQAAAAcmVjZWl2ZXIudGVzdG5ldNMnL7URB1cxPOu3G8jTqlEwlcasagIbKlAJlF5ywVFLAQAAAAMAAACh7czOG8LTAAAAAAAAAGQcOG03xVSFQFjoagOb4NBBqWhERnnz45LY4+52JgZhm1iQKz7qAdPByrGFDQhQ2Mfga8RlbysuQ8D8LlA6bQE="),
+                )
+        )
+        val result = response.getResultOrNull<CryptoHash>()
+        println("broadcastTxAsync Response: $result")
+        assertNotNull(response !is RpcResponse.Failure)
+    }
+}

client/src/test/kotlin/io/github/hosseinkarami_dev/near/rpc/client/BroadcastTxCommitTest.kt

@@ -0,0 +1,53 @@
+package io.github.hosseinkarami_dev.near.rpc.client
+
+import io.github.hosseinkarami_dev.near.rpc.client.Utils.getResultOrNull
+import io.github.hosseinkarami_dev.near.rpc.models.CryptoHash
+import io.github.hosseinkarami_dev.near.rpc.models.RpcSendTransactionRequest
+import io.github.hosseinkarami_dev.near.rpc.models.RpcTransactionResponse
+import io.github.hosseinkarami_dev.near.rpc.models.SignedTransaction
+import io.ktor.client.HttpClient
+import io.ktor.client.engine.cio.CIO
+import io.ktor.client.plugins.contentnegotiation.ContentNegotiation
+import io.ktor.serialization.kotlinx.json.json
+import kotlinx.coroutines.test.runTest
+import org.junit.jupiter.api.Test
+import kotlin.test.AfterTest
+import kotlin.test.BeforeTest
+import kotlin.test.assertNotNull
+
+class BroadcastTxCommitTest {
+
+    private lateinit var httpClient: HttpClient
+    private lateinit var nearClient: NearClient
+
+    @BeforeTest
+    fun setup() {
+        httpClient = HttpClient(CIO) {
+            install(ContentNegotiation) {
+                json()
+            }
+        }
+
+        nearClient = NearClient(
+            httpClient = httpClient,
+            baseUrl = "https://rpc.mainnet.near.org"
+        )
+    }
+
+    @AfterTest
+    fun teardown() {
+        httpClient.close()
+    }
+
+    @Test
+    fun testStatus() = runTest {
+        val response = nearClient.broadcastTxCommit(
+            RpcSendTransactionRequest(
+                signedTxBase64 = SignedTransaction("DgAAAHNlbmRlci50ZXN0bmV0AOrmAai64SZOv9e/naX4W15pJx0GAap35wTT1T/DwcbbDwAAAAAAAAAQAAAAcmVjZWl2ZXIudGVzdG5ldNMnL7URB1cxPOu3G8jTqlEwlcasagIbKlAJlF5ywVFLAQAAAAMAAACh7czOG8LTAAAAAAAAAGQcOG03xVSFQFjoagOb4NBBqWhERnnz45LY4+52JgZhm1iQKz7qAdPByrGFDQhQ2Mfga8RlbysuQ8D8LlA6bQE="),
+                )
+        )
+        val result = response.getResultOrNull<RpcTransactionResponse>()
+        println("broadcastTxCommit Response: $result")
+        assertNotNull(response !is RpcResponse.Failure)
+    }
+}