Loading src/dlt/gateway/src/main/kotlin/fabric/FabricConnector.kt +17 −6 Original line number Diff line number Diff line Loading @@ -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 { Loading @@ -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<DltRecordEvent> { Loading Loading
src/dlt/gateway/src/main/kotlin/fabric/FabricConnector.kt +17 −6 Original line number Diff line number Diff line Loading @@ -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 { Loading @@ -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<DltRecordEvent> { Loading