[ATL-3066] Implement logic for received messages (#43)

hyperledger · Mar 16, 2023 · a7b67bb · a7b67bb
1 parent f78b6a1
commit a7b67bb
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/prism-agent/src/allButJSMain/kotlin/io.iohk.atala.prism.walletsdk.prismagent/PrismAgent.kt b/prism-agent/src/allButJSMain/kotlin/io.iohk.atala.prism.walletsdk.prismagent/PrismAgent.kt
@@ -8,6 +8,7 @@ import io.iohk.atala.prism.walletsdk.domain.models.Curve
 import io.iohk.atala.prism.walletsdk.domain.models.DID
 import io.iohk.atala.prism.walletsdk.domain.models.DIDDocument
 import io.iohk.atala.prism.walletsdk.domain.models.KeyCurve
+import io.iohk.atala.prism.walletsdk.domain.models.Message
 import io.iohk.atala.prism.walletsdk.domain.models.PrismAgentError
 import io.iohk.atala.prism.walletsdk.domain.models.Seed
 import io.iohk.atala.prism.walletsdk.domain.models.Signature
@@ -26,6 +27,7 @@ import io.ktor.serialization.kotlinx.json.json
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.Job
 import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.launch
 import kotlinx.serialization.Serializable
@@ -263,6 +265,14 @@ class PrismAgent {
         fetchingMessagesJob.cancel()
     }
 
+    fun handleMessagesEvents(): Flow<List<Message>> {
+        return pluto.getAllMessages()
+    }
+
+    fun handleReceivedMessagesEvents(): Flow<List<Message>> {
+        return pluto.getAllMessagesReceived()
+    }
+
     private suspend fun parsePrismInvitation(str: String): PrismOnboardingInvitation {
         try {
             val prismOnboarding = PrismOnboardingInvitation.prismOnboardingInvitationFromJsonString(str)