diff --git a/src/dlt/gateway/src/main/kotlin/fabric/FabricConnector.kt b/src/dlt/gateway/src/main/kotlin/fabric/FabricConnector.kt index 4027416494cc83841302b093670a311b4ee1f5e6..53e88a56f7f96195a9f828bc428227747981d66c 100644 --- a/src/dlt/gateway/src/main/kotlin/fabric/FabricConnector.kt +++ b/src/dlt/gateway/src/main/kotlin/fabric/FabricConnector.kt @@ -119,13 +119,18 @@ class FabricConnector(val config: Config.DltConfig) { fun putData(record: DltRecord): String { println(record.toString()) println("Put: ${record.toByteArray().decodeToString().length}") - return String( + + try { contract.submitTransaction( "AddRecord", record.recordId.recordUuid.uuid, record.toByteArray().decodeToString() ) - ) + } catch (e: Exception) { + println(e.toString()) + return e.toString() + } + return "" } fun getData(uuid: String): DltRecord { @@ -135,22 +140,28 @@ class FabricConnector(val config: Config.DltConfig) { } fun updateData(record: DltRecord): String { - return String( + try { contract.submitTransaction( "UpdateRecord", record.recordId.recordUuid.uuid, record.toByteArray().decodeToString() ) - ) + } catch (e: Exception) { + return e.toString() + } + return "" } fun deleteData(record: DltRecord): String { - return String( + try { contract.submitTransaction( "DeleteRecord", record.recordId.recordUuid.uuid, ) - ) + } catch (e: Exception) { + return e.toString() + } + return "" } fun subscribeForEvents(): Channel {