Refresh the ledger pool (#27)

Signed-off-by: conanoc <[email protected]>
hyperledger · Mar 11, 2024 · 72c218c · 72c218c
1 parent 2d02e92
commit 72c218c
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 9 deletions.
diff --git a/ariesframework/build.gradle b/ariesframework/build.gradle
@@ -47,7 +47,7 @@ ktlint {
 
 dependencies {
     implementation("org.hyperledger:anoncreds_uniffi:0.2.0-wrapper.1")
-    implementation("org.hyperledger:indy_vdr_uniffi:0.2.0-wrapper.1")
+    implementation("org.hyperledger:indy_vdr_uniffi:0.2.1-wrapper.2")
     implementation("org.hyperledger:askar_uniffi:0.2.0-wrapper.1")
 
     implementation "org.jetbrains.kotlinx:kotlinx-serialization-json:1.5.0"

diff --git a/ariesframework/src/androidTest/java/org/hyperledger/ariesframework/agent/AgentTest.kt b/ariesframework/src/androidTest/java/org/hyperledger/ariesframework/agent/AgentTest.kt
@@ -199,5 +199,4 @@ class AgentTest {
         // alice will be reset on tearDown
         faber.reset()
     }
-
 }
diff --git a/ariesframework/src/main/java/org/hyperledger/ariesframework/agent/HttpOutboundTransport.kt b/ariesframework/src/main/java/org/hyperledger/ariesframework/agent/HttpOutboundTransport.kt
@@ -27,9 +27,11 @@ class HttpOutboundTransport(val agent: Agent) : OutboundTransport {
         val responseText = withContext(Dispatchers.IO) {
             val request = okhttp3.Request.Builder()
                 .url(_package.endpoint)
-                .post(Json.encodeToString(_package.payload)
-                    .toByteArray()  // prevent okHttp from adding charset=utf-8 to the content type
-                    .toRequestBody(DidCommMimeType.V1.value.toMediaType()))
+                .post(
+                    Json.encodeToString(_package.payload)
+                        .toByteArray() // prevent okHttp from adding charset=utf-8 to the content type
+                        .toRequestBody(DidCommMimeType.V1.value.toMediaType()),
+                )
                 .build()
             val response = AgentHttpClient.client.newCall(request).execute()
             logger.debug("response with status code: {}", response.code)

diff --git a/ariesframework/src/main/java/org/hyperledger/ariesframework/ledger/LedgerService.kt b/ariesframework/src/main/java/org/hyperledger/ariesframework/ledger/LedgerService.kt
@@ -10,6 +10,8 @@ import indy_vdr_uniffi.Pool
 import indy_vdr_uniffi.Request
 import indy_vdr_uniffi.openPool
 import indy_vdr_uniffi.setProtocolVersion
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.launch
 import kotlinx.serialization.encodeToString
 import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.JsonArray
@@ -59,8 +61,12 @@ class LedgerService(val agent: Agent) {
         } catch (e: Exception) {
             throw Exception("Pool opening failed: ${e.message}")
         }
-        val status = pool!!.getStatus()
-        logger.debug("Pool status: $status")
+
+        GlobalScope.launch {
+            pool?.refresh()
+            val status = pool?.getStatus()
+            logger.debug("Pool status after refresh: $status")
+        }
     }
 
     suspend fun registerSchema(did: DidInfo, schemaTemplate: SchemaTemplate): String {

diff --git a/...mework/src/main/java/org/hyperledger/ariesframework/oob/models/OutOfBandDidCommService.kt b/...mework/src/main/java/org/hyperledger/ariesframework/oob/models/OutOfBandDidCommService.kt
@@ -11,7 +11,6 @@ import kotlinx.serialization.json.JsonContentPolymorphicSerializer
 import kotlinx.serialization.json.JsonElement
 import kotlinx.serialization.json.JsonPrimitive
 import org.hyperledger.ariesframework.connection.models.didauth.DidCommService
-import org.hyperledger.ariesframework.connection.models.didauth.DidDocService
 import org.hyperledger.ariesframework.util.DIDParser
 
 @Serializable(with = OutOfBandDidCommServiceSerializer::class)

diff --git a/ariesframework/src/main/java/org/hyperledger/ariesframework/routing/MediationRecipient.kt b/ariesframework/src/main/java/org/hyperledger/ariesframework/routing/MediationRecipient.kt
@@ -227,7 +227,7 @@ class MediationRecipient(private val agent: Agent, private val dispatcher: Dispa
         mediationRecord.assertState(MediationState.Requested)
 
         mediationRecord.endpoint = message.endpoint
-        mediationRecord.routingKeys = message.routingKeys.map {key ->
+        mediationRecord.routingKeys = message.routingKeys.map { key ->
             if (key.startsWith("did:key:")) {
                 DIDParser.convertDidKeyToVerkey(key)
             } else {
-Original file line number
+Diff line change
@@ Expand Up / @@ -199,5 +199,4 @@ class AgentTest { @@
             // alice will be reset on tearDown
             faber.reset()
         }
     }