added createHTLC function in SDK

Signed-off-by: Krishnasuri Narayanam <[email protected]>

Author: knarayan

sdks/corda/build.gradle

@@ -42,7 +42,7 @@ repositories {
     if (file("$projectDir/./github.properties").exists()) {
         file("$projectDir/github.properties").withInputStream { constants.load(it) }
         maven {
-            url 'https://maven.pkg.github.com/sanvenDev/weaver-dlt-interoperability'
+            url	constants.url
             credentials {
                 username constants.username
                 password constants.password

sdks/corda/src/main/kotlin/com/weaver/corda/sdk/AssetManager.kt

@@ -27,6 +27,41 @@ class AssetManager {
     companion object {
         private val logger = LoggerFactory.getLogger(AssetManager::class.java)
 
+        @JvmStatic
+        fun createHTLC(
+            proxy: CordaRPCOps,
+            assetType: String,
+            assetId: String,
+            recipientParty: String,
+	        hashBase64: String,
+            expiryTimeSecs: Long,
+            getAssetStateAndRefFlow: String,
+            deleteAssetStateCommand: CommandData
+        ): Either<Error, String> {
+            return try {
+                AssetManager.logger.debug("Sending asset-lock request to Corda as part of asset-exchange.\n")
+                val contractId = runCatching {
+
+                    val assetAgreement = createAssetExchangeAgreement(assetType, assetId, recipientParty, "")
+                    val lockInfo = createAssetLockInfo(hashBase64, expiryTimeSecs)
+
+                    proxy.startFlow(::LockAsset, lockInfo, assetAgreement, getAssetStateAndRefFlow, deleteAssetStateCommand)
+                        .returnValue.get()
+                }.fold({
+                    it.map { linearId ->
+                        AssetManager.logger.debug("Locking asset was successful and the state was stored with linearId $linearId.\n")
+                        linearId.toString()
+                    }
+                }, {
+                    Left(Error("Corda Network Error: Error running LockAsset flow: ${it.message}\n"))
+                })
+                contractId
+            } catch (e: Exception) {
+                AssetManager.logger.error("Error locking asset in Corda network: ${e.message}\n")
+                Left(Error("Error locking asset in Corda network: ${e.message}"))
+            }
+        }
+
         @JvmStatic
         fun createFungibleHTLC(
             proxy: CordaRPCOps,
@@ -39,7 +74,7 @@ class AssetManager {
             deleteAssetStateCommand: CommandData
         ): Either<Error, String> {
             return try {
-                AssetManager.logger.debug("Sending asset-lock request to Corda as part of asset-exchange.\n")
+                AssetManager.logger.debug("Sending fungible asset-lock request to Corda as part of asset-exchange.\n")
                 val contractId = runCatching {
 
                     val assetAgreement = createFungibleAssetExchangeAgreement(tokenType, numUnits, recipientParty, "")
@@ -49,16 +84,16 @@ class AssetManager {
                         .returnValue.get()
                 }.fold({
                     it.map { linearId ->
-                        AssetManager.logger.debug("Locking asset was successful and the state was stored with linearId $linearId.\n")
+                        AssetManager.logger.debug("Locking fungible asset was successful and the state was stored with linearId $linearId.\n")
                         linearId.toString()
                     }
                 }, {
                     Left(Error("Corda Network Error: Error running LockFungibleAsset flow: ${it.message}\n"))
                 })
                 contractId
             } catch (e: Exception) {
-                AssetManager.logger.error("Error locking asset in Corda network: ${e.message}\n")
-                Left(Error("Error locking asset in Corda network: ${e.message}"))
+                AssetManager.logger.error("Error locking fungible asset in Corda network: ${e.message}\n")
+                Left(Error("Error locking fungible asset in Corda network: ${e.message}"))
             }
         }
 
@@ -164,6 +199,22 @@ class AssetManager {
             }
         }
 
+        fun createAssetExchangeAgreement(
+            assetType: String,
+            assetId: String,
+            recipient: String,
+            locker: String): AssetLocks.AssetExchangeAgreement {
+
+                val assetAgreement = AssetLocks.AssetExchangeAgreement.newBuilder()
+                    .setType(assetType)
+                    .setId(assetId)
+                    .setLocker(locker)
+                    .setRecipient(recipient)
+                    .build()
+
+                return assetAgreement
+        }
+
         fun createFungibleAssetExchangeAgreement(
             tokenType: String,
             numUnits: Long,