fix: add more TransferStates and add field for LogMessage of Transfer…

…State
truzzt · Feb 14, 2024 · e8d2e06 · e8d2e06
1 parent 4d0e1b7
commit e8d2e06
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -62,7 +62,7 @@ subprojects {
             maven {
                 name = "GitHubPackages"
                 url = uri("https://maven.pkg.github.com/truzzt/mds-ap3")
-                version = "0.2.7"
+                version = "0.2.8"
                 credentials {
                     username = System.getenv("USERNAME")
                     password = System.getenv("TOKEN")

diff --git a/...house-client/src/main/java/com/truzzt/extension/logginghouse/client/LogMessageSender.java b/...house-client/src/main/java/com/truzzt/extension/logginghouse/client/LogMessageSender.java
@@ -89,6 +89,8 @@ private String buildContractAgreementPayload(ContractAgreement contractAgreement
     private String buildTransferProcessPayload(TransferProcess transferProcess) {
         var jo = new JSONObject();
         jo.put("transferProcessId", transferProcess.getId());
+        jo.put("transferState", transferProcess.stateAsString());
+
         var dataRequest = transferProcess.getDataRequest();
         jo.put("contractId", dataRequest.getContractId());
         jo.put("connectorId", dataRequest.getConnectorId());

diff --git a/...t/src/main/java/com/truzzt/extension/logginghouse/client/LoggingHouseClientExtension.java b/...t/src/main/java/com/truzzt/extension/logginghouse/client/LoggingHouseClientExtension.java
@@ -135,9 +135,10 @@ private void registerEventSubscriber(ServiceExtensionContext context) {
         eventRouter.registerSync(ContractNegotiationFinalized.class, eventSubscriber);
         eventRouter.registerSync(ContractNegotiationAgreed.class, eventSubscriber);
         eventRouter.registerSync(ContractNegotiationAccepted.class, eventSubscriber);
-        eventRouter.registerSync(TransferProcessCompleted.class, eventSubscriber);
+        eventRouter.registerSync(TransferProcessRequested.class, eventSubscriber);
         eventRouter.registerSync(TransferProcessInitiated.class, eventSubscriber);
         eventRouter.registerSync(TransferProcessStarted.class, eventSubscriber);
+        eventRouter.registerSync(TransferProcessCompleted.class, eventSubscriber);
         eventRouter.registerSync(TransferProcessFailed.class, eventSubscriber);
         eventRouter.registerSync(TransferProcessTerminated.class, eventSubscriber);
         context.registerService(IdsClearingHouseServiceImpl.class, eventSubscriber);