Send events over rabbitmq [ACC-2107]

Author: rschev

contentgrid-appserver-app/src/main/resources/application-bootRun.yml

@@ -11,6 +11,13 @@ contentgrid:
   system:
     policyPackage: xfb0e9318f3894300a64edba3532e6ac0
 
+spring:
+  rabbitmq:
+    host: localhost
+    port: 5672
+    username: guest
+    password: guest
+
 # When unauthenticated, you get HTTP 403 instead of 401 if you don't have the following
 
 #spring:

contentgrid-appserver-autoconfigure/src/main/java/com/contentgrid/appserver/autoconfigure/events/ContentGridEventsAutoConfiguration.java

@@ -3,24 +3,30 @@
 import com.contentgrid.appserver.autoconfigure.query.engine.JOOQQueryEngineAutoConfiguration;
 import com.contentgrid.appserver.domain.events.DomainEventDispatcher;
 import com.contentgrid.appserver.domain.events.EntityFormatter;
+import com.contentgrid.appserver.events.RabbitMqEventHandlers;
+import org.springframework.beans.factory.ObjectProvider;
 import com.contentgrid.appserver.events.EventHandlerConfiguration;
 import com.contentgrid.appserver.query.engine.api.EventConsumer;
 import org.springframework.boot.autoconfigure.AutoConfiguration;
+import org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Import;
 
 @AutoConfiguration(before = {
         JOOQQueryEngineAutoConfiguration.class,
+}, after = {
+        RabbitAutoConfiguration.class,
 })
 @ConditionalOnWebApplication
 @ConditionalOnClass(EventHandlerConfiguration.class)
 @Import(EventHandlerConfiguration.class)
 public class ContentGridEventsAutoConfiguration {
 
     @Bean
-    EventConsumer eventConsumer(EntityFormatter formatter) {
-        return new DomainEventDispatcher(formatter);
+    EventConsumer eventConsumer(EntityFormatter formatter, ObjectProvider<RabbitMqEventHandlers> rabbitProvider) {
+        var rabbit = rabbitProvider.getIfAvailable();
+        return (rabbit != null) ? new DomainEventDispatcher(formatter, rabbit) : new DomainEventDispatcher(formatter);
     }
 }

contentgrid-appserver-domain/build.gradle

@@ -7,6 +7,7 @@ plugins {
 dependencies {
     api project(':contentgrid-appserver-application-model')
     api project(':contentgrid-appserver-query-engine-api')
+//    api project(':contentgrid-appserver-events')
     api 'com.contentgrid.hateoas:contentgrid-pagination-api'
     api 'com.fasterxml.jackson.core:jackson-databind'
 

contentgrid-appserver-domain/src/main/java/com/contentgrid/appserver/domain/events/DomainEventDispatcher.java

@@ -6,13 +6,21 @@
 import com.contentgrid.appserver.domain.data.mapper.AttributeDataToDataEntryMapper;
 import com.contentgrid.appserver.query.engine.api.EventConsumer;
 import com.contentgrid.appserver.query.engine.api.data.EntityData;
-import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
-@RequiredArgsConstructor
 public class DomainEventDispatcher implements EventConsumer {
     private final EntityFormatter formatter;
+    private final FormattedEventDispatcher rabbitMqEventDispatcher;
+
+    public DomainEventDispatcher(EntityFormatter formatter) {
+        this(formatter, null);
+    }
+
+    public DomainEventDispatcher(EntityFormatter formatter, FormattedEventDispatcher formattedEventDispatcher) {
+        this.formatter = formatter;
+        this.rabbitMqEventDispatcher = formattedEventDispatcher;
+    }
 
     @Override
     public void dispatchCreate(Application application, EntityName entity, EntityData data) {
@@ -27,15 +35,47 @@ public void dispatchCreate(Application application, EntityName entity, EntityDat
         var entityInstance = mapper.mapAttributes(data);
         var jsonNode = formatter.format(application, entity, entityInstance);
         log.info("[[[ JSON ]]]\n{}", jsonNode);
+        if (rabbitMqEventDispatcher != null) {
+            rabbitMqEventDispatcher.dispatchCreate(entity.getValue(), jsonNode);
+        }
     }
 
     @Override
     public void dispatchUpdate(Application application, EntityName entity, EntityData oldData, EntityData newData) {
         log.info("=== UPDATE === [{}] Was:\n{}\nBecomes:\n{}", entity, oldData, newData);
+
+        var ent = application.getRequiredEntityByName(entity);
+        var mapper = new ResponseOutputDataMapper(
+                ent.getAttributes(),
+                new AttributeDataToDataEntryMapper()
+        );
+
+        var oldInstance = mapper.mapAttributes(oldData);
+        var newInstance = mapper.mapAttributes(newData);
+
+        var oldJson = formatter.format(application, entity, oldInstance);
+        var newJson = formatter.format(application, entity, newInstance);
+
+        if (rabbitMqEventDispatcher != null) {
+            rabbitMqEventDispatcher.dispatchUpdate(entity.getValue(), oldJson, newJson);
+        }
     }
 
     @Override
     public void dispatchDelete(Application application, EntityName entity, EntityData oldData) {
         log.info("=== DELETE === [{}]: {}", entity, oldData);
+
+        var ent = application.getRequiredEntityByName(entity);
+        var mapper = new ResponseOutputDataMapper(
+                ent.getAttributes(),
+                new AttributeDataToDataEntryMapper()
+        );
+
+        var oldInstance = mapper.mapAttributes(oldData);
+        var oldJson = formatter.format(application, entity, oldInstance);
+
+        if (rabbitMqEventDispatcher != null) {
+            rabbitMqEventDispatcher.dispatchDelete(entity.getValue(), oldJson);
+        }
     }
 }

contentgrid-appserver-domain/src/main/java/com/contentgrid/appserver/domain/events/FormattedEventDispatcher.java

@@ -0,0 +1,9 @@
+package com.contentgrid.appserver.domain.events;
+
+import com.fasterxml.jackson.databind.JsonNode;
+
+public interface FormattedEventDispatcher {
+    void dispatchCreate(String entity, JsonNode newData);
+    void dispatchUpdate(String entity, JsonNode oldData, JsonNode newData);
+    void dispatchDelete(String entity, JsonNode oldData);
+}

contentgrid-appserver-events/build.gradle

@@ -10,7 +10,7 @@ dependencies {
 
     api 'org.springframework.boot:spring-boot-starter'
 
-    implementation 'org.springframework.boot:spring-boot-starter-amqp'
+    api 'org.springframework.boot:spring-boot-starter-amqp'
     implementation project(':contentgrid-appserver-rest')
     implementation 'com.fasterxml.jackson.core:jackson-databind'
 

contentgrid-appserver-events/src/main/java/com/contentgrid/appserver/events/EntityChangeEvent.java

@@ -2,7 +2,6 @@
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.JsonNode;
-import java.io.Serializable;
 import lombok.Getter;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
@@ -23,4 +22,26 @@ public class EntityChangeEventPayload {
     public JsonNode getNew() {
         return _new;
     }
+
+    @RequiredArgsConstructor
+    public enum ChangeKind {
+        CREATE("create"),
+        UPDATE("update"),
+        DELETE("delete");
+
+        @Getter
+        private final String value;
+    }
+
+    public static EntityChangeEventPayload forCreate(@NonNull JsonNode newData) {
+        return new EntityChangeEventPayload(ChangeKind.CREATE.getValue(), null, newData);
+    }
+
+    public static EntityChangeEventPayload forUpdate(@NonNull JsonNode oldData, @NonNull JsonNode newData) {
+        return new EntityChangeEventPayload(ChangeKind.UPDATE.getValue(), oldData, newData);
+    }
+
+    public static EntityChangeEventPayload forDelete(@NonNull JsonNode oldData) {
+        return new EntityChangeEventPayload(ChangeKind.DELETE.getValue(), oldData, null);
+    }
 }

contentgrid-appserver-events/src/main/java/com/contentgrid/appserver/events/EntityChangeEventPayload.java

@@ -1,10 +1,9 @@
 package com.contentgrid.appserver.events;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.SerializationFeature;
 import lombok.RequiredArgsConstructor;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.boot.autoconfigure.amqp.RabbitProperties;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -18,15 +17,13 @@ ContentGridEventHandlerProperties contentgridEventHandlerProperties() {
         return new ContentGridEventHandlerProperties();
     }
 
-//    @Bean
-//    EventHandlers rabbitEventHandlers(RabbitTemplate rabbitTemplate, RabbitProperties rabbitProperties,
-//            ContentGridEventHandlerProperties contentGridProps, EventMapper eventMapper) {
-//        return new RabbitMqEventHandlers(rabbitTemplate, rabbitProperties, contentGridProps, eventMapper);
-//    }
-
     @Bean
-    EventMapper eventMapper(ObjectMapper objectMapper) {
-        objectMapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
-        return new EventMapper(objectMapper);
+    @ConditionalOnBean({RabbitTemplate.class, RabbitProperties.class})
+    RabbitMqEventHandlers rabbitEventHandlers(RabbitTemplate rabbitTemplate,
+            RabbitProperties rabbitProperties,
+            ContentGridEventHandlerProperties contentGridProps,
+            com.fasterxml.jackson.databind.ObjectMapper objectMapper) {
+        return new RabbitMqEventHandlers(rabbitTemplate, rabbitProperties, contentGridProps, objectMapper);
     }
+
 }