wip breaking test

Author: chriamue

backend/business-partner-agent/src/main/java/org/hyperledger/bpa/api/notification/PartnerRemovedEvent.java

@@ -27,7 +27,7 @@
 @NoArgsConstructor
 @AllArgsConstructor
 @Getter
-public class PartnerRemovedEvent {
+public class PartnerRemovedEvent extends Event {
 
     private Partner partner;
 }

backend/business-partner-agent/src/main/java/org/hyperledger/bpa/api/notification/PartnerRequestCompletedEvent.java

@@ -27,7 +27,7 @@
 @NoArgsConstructor
 @AllArgsConstructor
 @Getter
-public class PartnerRequestCompletedEvent {
+public class PartnerRequestCompletedEvent extends Event {
 
     private Partner partner;
 

backend/business-partner-agent/src/main/java/org/hyperledger/bpa/api/notification/PartnerRequestReceivedEvent.java

@@ -27,7 +27,7 @@
 @NoArgsConstructor
 @AllArgsConstructor
 @Getter
-public class PartnerRequestReceivedEvent {
+public class PartnerRequestReceivedEvent extends Event {
 
     private Partner partner;
 

backend/business-partner-agent/src/main/java/org/hyperledger/bpa/impl/rules/PartnerRuleEventHandler.java

@@ -21,9 +21,6 @@ public class PartnerRuleEventHandler {
     @Inject
     RulesService rs;
 
-    // @Inject
-    // ApplicationContext appCtx;
-
     @EventListener
     @Async
     public void onPartnerAddedEvent(PartnerAddedEvent event) {
@@ -42,18 +39,21 @@ public void onPartnerAcceptedEvent(PartnerAcceptedEvent event) {
     @Async
     public void onPartnerRemovedEvent(PartnerRemovedEvent event) {
         log.debug("detected {}", event.getClass());
+        runRule(event);
     }
 
     @EventListener
     @Async
     public void onPartnerRequestReceivedEvent(PartnerRequestReceivedEvent event) {
         log.debug("detected {}", event.getClass());
+        runRule(event);
     }
 
     @EventListener
     @Async
     public void onPartnerRequestCompletedEvent(PartnerRequestCompletedEvent event) {
         log.debug("detected {}", event.getClass());
+        runRule(event);
     }
 
     public void runRule(Event event) {

backend/business-partner-agent/src/main/java/org/hyperledger/bpa/impl/rules/RulesData.java

@@ -134,6 +134,8 @@ public static class TagConnection extends Action {
 
             @Override
             void run(EventContext ctx) {
+                // TODO: get partner by connection Id and update tags
+
                 log.debug("tag: {}", tag);
             }
         }

backend/business-partner-agent/src/test/java/org/hyperledger/bpa/impl/rules/PartnerRuleEventHandlerTest.java

@@ -49,7 +49,7 @@
 import static org.junit.jupiter.api.Assertions.*;
 
 @Slf4j
-@MicronautTest(environments = { Environment.TEST, "test-web" })
+@MicronautTest(transactional = false)
 public class PartnerRuleEventHandlerTest {
 
     private final Gson gson = GsonConfig.defaultConfig();
@@ -116,7 +116,6 @@ void testNewPartnerOnConnection() throws InterruptedException {
         log.debug(rs.getAll().toString());
 
         String did1 = "did-1";
-        String did2 = "did-2";
 
         pRepo.save(Partner
                 .builder()
@@ -125,21 +124,15 @@ void testNewPartnerOnConnection() throws InterruptedException {
                 .connectionId(did1)
                 .build());
 
-        pRepo.save(Partner
-                .builder()
-                .ariesSupport(Boolean.TRUE)
-                .did(did2)
-                .connectionId(did2)
-                .state(ConnectionState.INIT)
-                .build());
-
-        Optional<Partner> p = pRepo.findByConnectionId(did1);
-
-        assert(p.isPresent());
-
-        eventPublisher.publishEventAsync(PartnerAddedEvent.builder().partner(p.get()).build());
+        Optional<Partner> pBefore = pRepo.findByConnectionId(did1);
+        assert(pBefore.isPresent());
+        Assertions.assertEquals(Set.of(), pBefore.get().getTags());
 
+        eventPublisher.publishEventAsync(PartnerAddedEvent.builder().partner(pBefore.get()).build());
 
+        Optional<Partner> pAfter = pRepo.findByConnectionId(did1);
+        assert(pAfter.isPresent());
+        Assertions.assertNotEquals(Set.of(), pAfter.get().getTags());
         // added asynchron?
 
         /*