Merge pull request #24 from input-output-hk/feature/ATL-3064

feat(agent): add mediation and ability to send messages

castor/src/allButJSMain/kotlin/io/iohk/atala/prism/walletsdk/castor/resolvers/LongFormPrismDIDResolver.kt → castor/src/allButJSMain/kotlin/io.iohk.atala.prism.walletsdk.castor/resolvers/LongFormPrismDIDResolver.kt

@@ -13,7 +13,7 @@ actual class LongFormPrismDIDResolver(
     override suspend fun resolve(didString: String): DIDDocument {
         return CastorShared.resolveLongFormPrismDID(
             apollo = apollo,
-            didString = didString
+            didString = didString,
         )
     }
 }

castor/src/commonMain/kotlin/io/iohk/atala/prism/walletsdk/castor/did/DIDUrlParser.kt → castor/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.castor/did/DIDUrlParser.kt

@@ -32,7 +32,7 @@ object DIDUrlParser {
             did,
             listener.path ?: emptyArray(),
             listener.query,
-            listener.fragment
+            listener.fragment,
         )
     }
 }

castor/src/commonMain/kotlin/io/iohk/atala/prism/walletsdk/castor/did/PrismDID/LongFormPrismDID.kt → castor/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.castor/did/PrismDID/LongFormPrismDID.kt

@@ -1,6 +1,5 @@
-package io.iohk.atala.prism.walletsdk.castor.io.iohk.atala.prism.walletsdk.castor.did.prismdid
+package io.iohk.atala.prism.walletsdk.castor.did.prismdid
 
-import io.iohk.atala.prism.walletsdk.castor.did.prismdid.PrismDIDMethodId
 import io.iohk.atala.prism.walletsdk.domain.models.CastorError
 import io.iohk.atala.prism.walletsdk.domain.models.DID
 
@@ -12,7 +11,7 @@ LongFormPrismDID(val did: DID) {
 
     init {
         val methodId = PrismDIDMethodId(
-            did.methodId
+            did.methodId,
         )
 
         if (methodId.sections.size !== 2) {

castor/src/commonMain/kotlin/io/iohk/atala/prism/walletsdk/castor/did/PrismDID/PrismDIDPublicKey.kt → castor/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.castor/did/PrismDID/PrismDIDPublicKey.kt

@@ -17,7 +17,7 @@ class PrismDIDPublicKey {
         CAPABILITY_DELEGATION_KEY("capabilityDelegationKey"),
         CAPABILITY_INVOCATION_KEY("capabilityInvocationKey"),
         KEY_AGREEMENT_KEY("keyAgreementKey"),
-        UNKNOWN_KEY("unknownKey")
+        UNKNOWN_KEY("unknownKey"),
     }
 
     private val apollo: Apollo
@@ -53,8 +53,8 @@ class PrismDIDPublicKey {
             id = id,
             usage = usage.toProto(),
             keyData = io.iohk.atala.prism.protos.PublicKey.KeyData.CompressedEcKeyData(
-                compressed.toProto()
-            )
+                compressed.toProto(),
+            ),
         )
     }
 }
@@ -76,7 +76,7 @@ fun KeyUsage.fromProto(): PrismDIDPublicKey.Usage {
 fun CompressedPublicKey.toProto(): CompressedECKeyData {
     return CompressedECKeyData(
         curve = uncompressed.curve.curve.value,
-        data = ByteArr(value)
+        data = ByteArr(value),
     )
 }
 

castor/src/commonMain/kotlin/io/iohk/atala/prism/walletsdk/castor/shared/CastorShared.kt → castor/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.castor/shared/CastorShared.kt

@@ -21,10 +21,10 @@ import io.iohk.atala.prism.protos.CreateDIDOperation
 import io.iohk.atala.prism.protos.Service
 import io.iohk.atala.prism.walletsdk.castor.did.DIDParser
 import io.iohk.atala.prism.walletsdk.castor.did.DIDUrlParser
+import io.iohk.atala.prism.walletsdk.castor.did.prismdid.LongFormPrismDID
 import io.iohk.atala.prism.walletsdk.castor.did.prismdid.PrismDIDMethodId
 import io.iohk.atala.prism.walletsdk.castor.did.prismdid.PrismDIDPublicKey
 import io.iohk.atala.prism.walletsdk.castor.did.prismdid.defaultId
-import io.iohk.atala.prism.walletsdk.castor.io.iohk.atala.prism.walletsdk.castor.did.prismdid.LongFormPrismDID
 import io.iohk.atala.prism.walletsdk.domain.buildingBlocks.Apollo
 import io.iohk.atala.prism.walletsdk.domain.models.CastorError
 import io.iohk.atala.prism.walletsdk.domain.models.Curve

castor/src/jsMain/kotlin/io/iohk/atala/prism/walletsdk/castor/resolvers/LongFormPrismDIDResolver.kt → castor/src/jsMain/kotlin/io.iohk.atala.prism.walletsdk.castor/resolvers/LongFormPrismDIDResolver.kt

@@ -18,7 +18,7 @@ actual class LongFormPrismDIDResolver(
         return GlobalScope.promise {
             CastorShared.resolveLongFormPrismDID(
                 apollo = apollo,
-                didString = didString
+                didString = didString,
             )
         }
     }

domain/src/allButJSMain/kotlin/io/iohk/atala/prism/walletsdk/domain/buildingBlocks/Castor.kt → domain/src/allButJSMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Castor.kt

@@ -9,12 +9,12 @@ actual interface Castor {
     actual fun parseDID(did: String): DID
     actual fun createPrismDID(
         masterPublicKey: PublicKey,
-        services: Array<DIDDocument.Service>?
+        services: Array<DIDDocument.Service>?,
     ): DID
 
     actual fun createPeerDID(
         keyPairs: Array<KeyPair>,
-        services: Array<DIDDocument.Service>
+        services: Array<DIDDocument.Service>,
     ): DID
 
     @Throws() // TODO: Add throw classes
@@ -24,6 +24,6 @@ actual interface Castor {
     suspend fun verifySignature(
         did: DID,
         challenge: ByteArray,
-        signature: ByteArray
+        signature: ByteArray,
     ): Boolean
 }

domain/src/allButJSMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Mercury.kt

@@ -0,0 +1,16 @@
+package io.iohk.atala.prism.walletsdk.domain.buildingBlocks
+
+import io.iohk.atala.prism.walletsdk.domain.models.Message
+
+actual interface Mercury {
+
+    actual fun packMessage(message: Message): String
+
+    actual fun unpackMessage(message: String): Message
+
+    @Throws() // TODO: Add throw classes
+    suspend fun sendMessage(message: Message): ByteArray?
+
+    @Throws() // TODO: Add throw classes
+    suspend fun sendMessageParseMessage(message: Message): Message?
+}

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Castor.kt

@@ -11,11 +11,11 @@ expect interface Castor {
 
     fun createPrismDID(
         masterPublicKey: PublicKey,
-        services: Array<DIDDocument.Service>? = null
+        services: Array<DIDDocument.Service>? = null,
     ): DID
 
     fun createPeerDID(
         keyPairs: Array<KeyPair>,
-        services: Array<DIDDocument.Service>
+        services: Array<DIDDocument.Service>,
     ): DID
 }

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Mercury.kt

@@ -2,17 +2,8 @@ package io.iohk.atala.prism.walletsdk.domain.buildingBlocks
 
 import io.iohk.atala.prism.walletsdk.domain.models.Message
 
-interface Mercury {
+expect interface Mercury {
+    fun packMessage(message: Message): String
 
-    @Throws() // TODO: Add throw classes
-    suspend fun packMessage(message: Message): String
-
-    @Throws() // TODO: Add throw classes
-    suspend fun unpackMessage(message: String): Message
-
-    @Throws() // TODO: Add throw classes
-    suspend fun sendMessage(message: Message): ByteArray?
-
-    @Throws() // TODO: Add throw classes
-    suspend fun sendMessageParseMessage(message: Message): Message?
+    fun unpackMessage(message: String): Message
 }

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Pluto.kt

@@ -2,7 +2,7 @@ package io.iohk.atala.prism.walletsdk.domain.buildingBlocks
 
 import io.iohk.atala.prism.walletsdk.domain.models.DID
 import io.iohk.atala.prism.walletsdk.domain.models.DIDPair
-import io.iohk.atala.prism.walletsdk.domain.models.MediatorDID
+import io.iohk.atala.prism.walletsdk.domain.models.Mediator
 import io.iohk.atala.prism.walletsdk.domain.models.Message
 import io.iohk.atala.prism.walletsdk.domain.models.PeerDID
 import io.iohk.atala.prism.walletsdk.domain.models.PrismDIDInfo
@@ -77,7 +77,7 @@ interface Pluto {
 
     fun getMessage(id: String): Message?
 
-    fun getAllMediators(): Array<MediatorDID>
+    fun getAllMediators(): Array<Mediator>
 
     fun getAllCredentials(): Array<VerifiableCredential>
 }

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/DIDPair.kt

@@ -8,5 +8,5 @@ import kotlin.js.JsExport
 data class DIDPair(
     val host: DID,
     val receiver: DID,
-    val name: String?
+    val name: String?,
 )

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/DIDUrl.kt

@@ -4,7 +4,7 @@ data class DIDUrl(
     val did: DID,
     val path: Array<String>? = arrayOf(),
     val parameters: Map<String, String>? = mapOf(),
-    val fragment: String? = null
+    val fragment: String? = null,
 ) {
 
     fun string(): String {

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/Errors.kt

@@ -72,6 +72,7 @@ sealed class PrismAgentError(message: String? = null) : Throwable(message) {
     class invalidRequestPresentationMessageError(message: String? = null) : PrismAgentError(message)
     class invalidProposePresentationMessageError(message: String? = null) : PrismAgentError(message)
     class invalidMediationGrantMessageError(message: String? = null) : PrismAgentError(message)
+    class invalidMessageError(message: String? = null) : PrismAgentError(message)
     class noMediatorAvailableError(message: String? = null) : PrismAgentError(message)
     class mediationRequestFailedError(message: String? = null) : PrismAgentError(message)
 }

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/JWTVerifiableCredential.kt

@@ -17,7 +17,7 @@ data class JWTVerifiableCredential(
     override val validFrom: VerifiableCredentialTypeContainer?,
     override val validUntil: VerifiableCredentialTypeContainer?,
     override val proof: String?,
-    override val aud: Set<String>
+    override val aud: Set<String>,
 ) : VerifiableCredential
 
 data class JWTCredentialPayload(

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/KeyPair.kt

@@ -8,7 +8,7 @@ import kotlin.js.JsExport
 data class KeyPair(
     val keyCurve: KeyCurve? = KeyCurve(Curve.SECP256K1),
     val privateKey: PrivateKey,
-    val publicKey: PublicKey
+    val publicKey: PublicKey,
 )
 
 @Serializable
@@ -20,7 +20,7 @@ data class KeyCurve(val curve: Curve, val index: Int? = 0)
 enum class Curve(val value: String) {
     X25519("X25519"),
     ED25519("Ed25519"),
-    SECP256K1("secp256k1");
+    SECP256K1("secp256k1"),
 }
 
 @JsExport

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/MediatorDID.kt → domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/Mediator.kt

@@ -5,9 +5,9 @@ import kotlin.js.JsExport
 
 @JsExport
 @Serializable
-data class MediatorDID(
+data class Mediator(
     val id: String,
     val mediatorDID: DID,
     val hostDID: DID,
-    val routingDID: DID
+    val routingDID: DID,
 )

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/Message.kt

@@ -17,11 +17,11 @@ data class Message(
     val extraHeaders: Array<String>,
     val createdTime: String,
     val expiresTimePlus: String,
-    val attachments: Array<String>, // TODO: Change to AttachmentDescriptor
+    val attachments: Array<AttachmentDescriptor>,
     val thid: String? = null,
     val pthid: String? = null,
     val ack: Array<String>,
-    val direction: Direction
+    val direction: Direction,
 ) {
     override fun equals(other: Any?): Boolean {
         if (this === other) return true
@@ -69,7 +69,7 @@ data class Message(
 
     enum class Direction(val value: Int) {
         SENT(0),
-        RECEIVED(1)
+        RECEIVED(1),
     }
 }
 

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/MessageAttachment.kt

@@ -1,29 +1,43 @@
 package io.iohk.atala.prism.walletsdk.domain.models
 
+import kotlinx.serialization.Serializable
+import kotlin.js.JsExport
+
+@JsExport
 interface AttachmentData
 
+@Serializable
+@JsExport
 data class AttachmentHeader(
-    val children: String
+    val children: String,
 ) : AttachmentData
 
+@Serializable
+@JsExport
 data class AttachmentJws(
     val header: AttachmentHeader,
     val protected: String,
-    val signature: String
+    val signature: String,
 ) : AttachmentData
 
+@Serializable
+@JsExport
 data class AttachmentJwsData(
     val base64: String,
-    val jws: AttachmentJws
+    val jws: AttachmentJws,
 ) : AttachmentData
 
+@Serializable
+@JsExport
 data class AttachmentBase64(
-    val base64: String
+    val base64: String,
 ) : AttachmentData
 
+@Serializable
+@JsExport
 data class AttachmentLinkData(
     val links: Array<String>,
-    val hash: String
+    val hash: String,
 ) : AttachmentData {
     override fun equals(other: Any?): Boolean {
         if (this === other) return true
@@ -44,10 +58,14 @@ data class AttachmentLinkData(
     }
 }
 
+@Serializable
+@JsExport
 data class AttachmentJsonData(
-    val data: String
+    val data: String,
 ) : AttachmentData
 
+@Serializable
+@JsExport
 data class AttachmentDescriptor(
     val id: String,
     val mediaType: String? = null,
@@ -56,7 +74,7 @@ data class AttachmentDescriptor(
     val format: String? = null,
     val lastModTime: String? = null, // Date format
     val byteCount: Int? = null,
-    val description: String? = null
+    val description: String? = null,
 ) : AttachmentData {
     override fun equals(other: Any?): Boolean {
         if (this === other) return true

domain/src/commonMain/kotlin/io.iohk.atala.prism.walletsdk.domain/models/PeerDID.kt

@@ -5,7 +5,7 @@ import kotlin.js.JsExport
 @JsExport
 data class PeerDID(
     val did: DID,
-    val privateKeys: Array<PrivateKey>
+    val privateKeys: Array<PrivateKey>,
 ) {
     override fun equals(other: Any?): Boolean {
         if (this === other) return true

domain/src/jsMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Castor.kt

@@ -12,18 +12,18 @@ actual interface Castor {
     actual fun parseDID(did: String): DID
     actual fun createPrismDID(
         masterPublicKey: PublicKey,
-        services: Array<DIDDocument.Service>?
+        services: Array<DIDDocument.Service>?,
     ): DID
 
     actual fun createPeerDID(
         keyPairs: Array<KeyPair>,
-        services: Array<DIDDocument.Service>
+        services: Array<DIDDocument.Service>,
     ): DID
 
     fun resolveDID(did: String): Promise<DIDDocument>
     fun verifySignature(
         did: DID,
         challenge: ByteArray,
-        signature: ByteArray
+        signature: ByteArray,
     ): Promise<Boolean>
 }

domain/src/jsMain/kotlin/io.iohk.atala.prism.walletsdk.domain/buildingBlocks/Mercury.kt

@@ -0,0 +1,16 @@
+package io.iohk.atala.prism.walletsdk.domain.buildingBlocks
+
+import io.iohk.atala.prism.walletsdk.domain.models.Message
+import kotlin.js.Promise
+
+@OptIn(ExperimentalJsExport::class)
+@JsExport
+actual interface Mercury {
+    actual fun packMessage(message: Message): String
+
+    actual fun unpackMessage(message: String): Message
+
+    fun sendMessage(message: Message): Promise<ByteArray>
+
+    fun sendMessageParseMessage(message: Message): Promise<Message?>
+}