remove debezium events for namespaces and companies (#28)

Author: carlosthe19916

src/main/java/io/github/project/openubl/xsender/idm/DocumentRepresentation.java

@@ -18,9 +18,6 @@
 
 import io.quarkus.runtime.annotations.RegisterForReflection;
 
-import java.util.Date;
-import java.util.List;
-
 @RegisterForReflection
 public class DocumentRepresentation {
 

src/main/java/io/github/project/openubl/xsender/idm/NamespaceRepresentation.java

@@ -19,7 +19,6 @@
 import io.quarkus.runtime.annotations.RegisterForReflection;
 
 import javax.validation.constraints.NotNull;
-import javax.validation.constraints.Pattern;
 import javax.validation.constraints.Size;
 
 @RegisterForReflection

src/main/java/io/github/project/openubl/xsender/kafka/idm/CompanyCUDEventRepresentation.java

@@ -22,7 +22,6 @@
 
 import javax.persistence.*;
 import javax.validation.constraints.NotNull;
-import javax.validation.constraints.Pattern;
 import javax.validation.constraints.Size;
 import java.util.ArrayList;
 import java.util.Date;

src/main/java/io/github/project/openubl/xsender/kafka/idm/NamespaceCrudEventRepresentation.java

@@ -25,7 +25,6 @@
 
 import javax.ws.rs.core.UriInfo;
 import java.net.URISyntaxException;
-import java.util.List;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 

src/main/java/io/github/project/openubl/xsender/kafka/idm/UBLDocumentCUDEventRepresentation.java

@@ -17,16 +17,8 @@
  * limitations under the License.
  */
 
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.debezium.outbox.quarkus.ExportedEvent;
 import io.github.project.openubl.xsender.idm.CompanyRepresentation;
 import io.github.project.openubl.xsender.idm.PageRepresentation;
-import io.github.project.openubl.xsender.kafka.idm.CompanyCUDEventRepresentation;
-import io.github.project.openubl.xsender.kafka.producers.EntityEventProducer;
-import io.github.project.openubl.xsender.kafka.producers.EntityType;
-import io.github.project.openubl.xsender.kafka.producers.EventType;
-import io.github.project.openubl.xsender.kafka.utils.EventEntityToRepresentation;
 import io.github.project.openubl.xsender.managers.CompanyManager;
 import io.github.project.openubl.xsender.models.PageBean;
 import io.github.project.openubl.xsender.models.PageModel;
@@ -41,7 +33,6 @@
 import org.jboss.logging.Logger;
 
 import javax.enterprise.context.ApplicationScoped;
-import javax.enterprise.event.Event;
 import javax.inject.Inject;
 import javax.transaction.Transactional;
 import javax.validation.Valid;
@@ -71,12 +62,6 @@ public class CompanyResource {
     @Inject
     CompanyManager companyManager;
 
-    @Inject
-    Event<ExportedEvent<?, ?>> event;
-
-    @Inject
-    ObjectMapper objectMapper;
-
     @GET
     @Path("/")
     public PageRepresentation<CompanyRepresentation> getCompanies(
@@ -117,14 +102,6 @@ public Response createCompany(
 
         CompanyEntity companyEntity = companyManager.createCompany(namespaceEntity, rep);
 
-        try {
-            CompanyCUDEventRepresentation eventRep = EventEntityToRepresentation.toRepresentation(companyEntity);
-            String eventPayload = objectMapper.writeValueAsString(eventRep);
-            this.event.fire(new EntityEventProducer(companyEntity.getId(), EntityType.company, EventType.CREATED, eventPayload));
-        } catch (JsonProcessingException e) {
-            LOG.error(e);
-        }
-
         return Response.ok()
                 .entity(EntityToRepresentation.toRepresentation(companyEntity))
                 .build();
@@ -153,14 +130,6 @@ public CompanyRepresentation updateCompany(
 
         companyEntity = companyManager.updateCompany(rep, companyEntity);
 
-        try {
-            CompanyCUDEventRepresentation eventRep = EventEntityToRepresentation.toRepresentation(companyEntity);
-            String eventPayload = objectMapper.writeValueAsString(eventRep);
-            event.fire(new EntityEventProducer(companyEntity.getId(), EntityType.company, EventType.UPDATED, eventPayload));
-        } catch (JsonProcessingException e) {
-            LOG.error(e);
-        }
-
         return EntityToRepresentation.toRepresentation(companyEntity);
     }
 
@@ -174,14 +143,6 @@ public void deleteNamespace(
         CompanyEntity companyEntity = companyRepository.findById(namespaceEntity, companyId).orElseThrow(NotFoundException::new);
 
         companyRepository.delete(companyEntity);
-
-        try {
-            CompanyCUDEventRepresentation eventRep = EventEntityToRepresentation.toRepresentation(companyEntity);
-            String eventPayload = objectMapper.writeValueAsString(eventRep);
-            event.fire(new EntityEventProducer(companyEntity.getId(), EntityType.company, EventType.DELETED, eventPayload));
-        } catch (JsonProcessingException e) {
-            LOG.error(e);
-        }
     }
 
 }

src/main/java/io/github/project/openubl/xsender/kafka/utils/EventEntityToRepresentation.java

@@ -16,16 +16,8 @@
  */
 package io.github.project.openubl.xsender.resources;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.debezium.outbox.quarkus.ExportedEvent;
 import io.github.project.openubl.xsender.idm.NamespaceRepresentation;
 import io.github.project.openubl.xsender.idm.PageRepresentation;
-import io.github.project.openubl.xsender.kafka.idm.NamespaceCrudEventRepresentation;
-import io.github.project.openubl.xsender.kafka.producers.EntityEventProducer;
-import io.github.project.openubl.xsender.kafka.producers.EntityType;
-import io.github.project.openubl.xsender.kafka.producers.EventType;
-import io.github.project.openubl.xsender.kafka.utils.EventEntityToRepresentation;
 import io.github.project.openubl.xsender.models.PageBean;
 import io.github.project.openubl.xsender.models.PageModel;
 import io.github.project.openubl.xsender.models.SortBean;
@@ -37,7 +29,6 @@
 import org.jboss.logging.Logger;
 
 import javax.enterprise.context.ApplicationScoped;
-import javax.enterprise.event.Event;
 import javax.inject.Inject;
 import javax.transaction.Transactional;
 import javax.validation.Valid;
@@ -63,12 +54,6 @@ public class CurrentUserResource {
     @Inject
     NamespaceRepository namespaceRepository;
 
-    @Inject
-    Event<ExportedEvent<?, ?>> event;
-
-    @Inject
-    ObjectMapper objectMapper;
-
     @POST
     @Path("/namespaces")
     public Response createNameSpace(@NotNull @Valid NamespaceRepresentation rep) {
@@ -88,14 +73,6 @@ public Response createNameSpace(@NotNull @Valid NamespaceRepresentation rep) {
 
         namespaceRepository.persist(namespaceEntity);
 
-        try {
-            NamespaceCrudEventRepresentation eventRep = EventEntityToRepresentation.toRepresentation(namespaceEntity);
-            String eventPayload = objectMapper.writeValueAsString(eventRep);
-            event.fire(new EntityEventProducer(namespaceEntity.getId(), EntityType.namespace, EventType.CREATED, eventPayload));
-        } catch (JsonProcessingException e) {
-            LOG.error(e);
-        }
-
         return Response.ok()
                 .entity(EntityToRepresentation.toRepresentation(namespaceEntity))
                 .build();