Loading atlas-lib/src/main/java/es/redmic/atlaslib/events/layer/LayerEventFactory.java +14 −0 Original line number Diff line number Diff line Loading @@ -31,6 +31,7 @@ import es.redmic.atlaslib.events.layer.common.LayerEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerFailedEvent; import es.redmic.atlaslib.events.layer.create.EnrichCreateLayerEvent; import es.redmic.atlaslib.events.layer.create.LayerCreatedEvent; Loading @@ -50,6 +51,7 @@ import es.redmic.atlaslib.events.layer.update.LayerUpdatedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerFailedEvent; import es.redmic.brokerlib.avro.common.Event; import es.redmic.brokerlib.avro.common.EventError; Loading Loading @@ -121,6 +123,18 @@ public class LayerEventFactory { successfulEvent = new CreateLayerEnrichedEvent().buildFrom(source); } if (type.equals(LayerEventTypes.CREATE)) { logger.debug("Creando evento CreateLayerEvent para: " + source.getAggregateId()); successfulEvent = new CreateLayerEvent().buildFrom(source); } if (type.equals(LayerEventTypes.UPDATE)) { logger.debug("Creando evento UpdateLayerEvent para: " + source.getAggregateId()); successfulEvent = new UpdateLayerEvent().buildFrom(source); } if (type.equals(LayerEventTypes.CREATED)) { logger.debug("Creando evento LayerCreatedEvent para: " + source.getAggregateId()); Loading atlas-lib/src/test/java/es/redmic/atlaslib/unit/events/layer/LayerEventFactoryTest.java +28 −0 Original line number Diff line number Diff line Loading @@ -30,6 +30,7 @@ import es.redmic.atlaslib.events.layer.LayerEventTypes; import es.redmic.atlaslib.events.layer.create.CreateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerFailedEvent; import es.redmic.atlaslib.events.layer.create.EnrichCreateLayerEvent; import es.redmic.atlaslib.events.layer.create.LayerCreatedEvent; Loading @@ -49,6 +50,7 @@ import es.redmic.atlaslib.events.layer.update.LayerUpdatedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerFailedEvent; import es.redmic.atlaslib.unit.utils.LayerDataUtil; import es.redmic.brokerlib.avro.common.Event; Loading Loading @@ -154,6 +156,19 @@ public class LayerEventFactoryTest { checkMetadataFields(source, event); } @Test public void GetEvent_ReturnCreateLayerEvent_IfTypeIsCreate() { Event source = LayerDataUtil.getCreateLayerEnrichedEvent(); CreateLayerEvent event = (CreateLayerEvent) LayerEventFactory.getEvent(source, LayerEventTypes.CREATE, LayerDataUtil.getLayer()); assertEquals(LayerEventTypes.CREATE, event.getType()); assertNotNull(event.getLayer()); checkMetadataFields(source, event); } @Test public void GetEvent_ReturnLayerCreatedEvent_IfTypeIsCreated() { Loading Loading @@ -193,6 +208,19 @@ public class LayerEventFactoryTest { checkMetadataFields(source, event); } @Test public void GetEvent_ReturnUpdateLayerEvent_IfTypeIsUpdate() { Event source = LayerDataUtil.getUpdateLayerEnrichedEvent(); UpdateLayerEvent event = (UpdateLayerEvent) LayerEventFactory.getEvent(source, LayerEventTypes.UPDATE, LayerDataUtil.getLayer()); assertEquals(LayerEventTypes.UPDATE, event.getType()); assertNotNull(event.getLayer()); checkMetadataFields(source, event); } @Test public void GetEvent_ReturnLayerCreatedEvent_IfTypeIsUpdated() { Loading Loading
atlas-lib/src/main/java/es/redmic/atlaslib/events/layer/LayerEventFactory.java +14 −0 Original line number Diff line number Diff line Loading @@ -31,6 +31,7 @@ import es.redmic.atlaslib.events.layer.common.LayerEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerFailedEvent; import es.redmic.atlaslib.events.layer.create.EnrichCreateLayerEvent; import es.redmic.atlaslib.events.layer.create.LayerCreatedEvent; Loading @@ -50,6 +51,7 @@ import es.redmic.atlaslib.events.layer.update.LayerUpdatedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerFailedEvent; import es.redmic.brokerlib.avro.common.Event; import es.redmic.brokerlib.avro.common.EventError; Loading Loading @@ -121,6 +123,18 @@ public class LayerEventFactory { successfulEvent = new CreateLayerEnrichedEvent().buildFrom(source); } if (type.equals(LayerEventTypes.CREATE)) { logger.debug("Creando evento CreateLayerEvent para: " + source.getAggregateId()); successfulEvent = new CreateLayerEvent().buildFrom(source); } if (type.equals(LayerEventTypes.UPDATE)) { logger.debug("Creando evento UpdateLayerEvent para: " + source.getAggregateId()); successfulEvent = new UpdateLayerEvent().buildFrom(source); } if (type.equals(LayerEventTypes.CREATED)) { logger.debug("Creando evento LayerCreatedEvent para: " + source.getAggregateId()); Loading
atlas-lib/src/test/java/es/redmic/atlaslib/unit/events/layer/LayerEventFactoryTest.java +28 −0 Original line number Diff line number Diff line Loading @@ -30,6 +30,7 @@ import es.redmic.atlaslib.events.layer.LayerEventTypes; import es.redmic.atlaslib.events.layer.create.CreateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerEvent; import es.redmic.atlaslib.events.layer.create.CreateLayerFailedEvent; import es.redmic.atlaslib.events.layer.create.EnrichCreateLayerEvent; import es.redmic.atlaslib.events.layer.create.LayerCreatedEvent; Loading @@ -49,6 +50,7 @@ import es.redmic.atlaslib.events.layer.update.LayerUpdatedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerCancelledEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerConfirmedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEnrichedEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerEvent; import es.redmic.atlaslib.events.layer.update.UpdateLayerFailedEvent; import es.redmic.atlaslib.unit.utils.LayerDataUtil; import es.redmic.brokerlib.avro.common.Event; Loading Loading @@ -154,6 +156,19 @@ public class LayerEventFactoryTest { checkMetadataFields(source, event); } @Test public void GetEvent_ReturnCreateLayerEvent_IfTypeIsCreate() { Event source = LayerDataUtil.getCreateLayerEnrichedEvent(); CreateLayerEvent event = (CreateLayerEvent) LayerEventFactory.getEvent(source, LayerEventTypes.CREATE, LayerDataUtil.getLayer()); assertEquals(LayerEventTypes.CREATE, event.getType()); assertNotNull(event.getLayer()); checkMetadataFields(source, event); } @Test public void GetEvent_ReturnLayerCreatedEvent_IfTypeIsCreated() { Loading Loading @@ -193,6 +208,19 @@ public class LayerEventFactoryTest { checkMetadataFields(source, event); } @Test public void GetEvent_ReturnUpdateLayerEvent_IfTypeIsUpdate() { Event source = LayerDataUtil.getUpdateLayerEnrichedEvent(); UpdateLayerEvent event = (UpdateLayerEvent) LayerEventFactory.getEvent(source, LayerEventTypes.UPDATE, LayerDataUtil.getLayer()); assertEquals(LayerEventTypes.UPDATE, event.getType()); assertNotNull(event.getLayer()); checkMetadataFields(source, event); } @Test public void GetEvent_ReturnLayerCreatedEvent_IfTypeIsUpdated() { Loading