Commit 7fc2dd4a authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade entrada a factoría para eventos rollback 

Añade tests
parent eb25332e

atlas-lib/src/main/java/es/redmic/atlaslib/events/category/CategoryEventFactory.java

+10 −0
Original line number Diff line number Diff line
@@ -39,12 +39,14 @@ import es.redmic.atlaslib.events.category.delete.DeleteCategoryCheckedEvent; 
import es.redmic.atlaslib.events.category.delete.DeleteCategoryConfirmedEvent;

import es.redmic.atlaslib.events.category.delete.DeleteCategoryEvent;

import es.redmic.atlaslib.events.category.delete.DeleteCategoryFailedEvent;

import es.redmic.atlaslib.events.category.fail.CategoryRollbackEvent;

import es.redmic.atlaslib.events.category.update.CategoryUpdatedEvent;

import es.redmic.atlaslib.events.category.update.UpdateCategoryCancelledEvent;

import es.redmic.atlaslib.events.category.update.UpdateCategoryConfirmedEvent;

import es.redmic.atlaslib.events.category.update.UpdateCategoryFailedEvent;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.avro.common.EventError;

import es.redmic.brokerlib.avro.fail.PrepareRollbackEvent;

import es.redmic.exception.common.ExceptionType;

import es.redmic.exception.common.InternalException;
@@ -99,6 +101,14 @@ public class CategoryEventFactory { 


	public static Event getEvent(Event source, String type, CategoryDTO category) {



		if (type.equals(CategoryEventTypes.ROLLBACK)) {

			logger.debug("Creando evento CategoryRollbackEvent para: " + source.getAggregateId());

			CategoryRollbackEvent rollbackEvent = new CategoryRollbackEvent().buildFrom(source);

			rollbackEvent.setLastSnapshotItem(category);

			rollbackEvent.setFailEventType(((PrepareRollbackEvent) source).getFailEventType());

			return rollbackEvent;

		}



		CategoryEvent successfulEvent = null;



		if (type.equals(CategoryEventTypes.CREATED)) {

atlas-lib/src/main/java/es/redmic/atlaslib/events/layer/LayerEventFactory.java

+10 −0
Original line number Diff line number Diff line
@@ -42,6 +42,7 @@ import es.redmic.atlaslib.events.layer.delete.DeleteLayerConfirmedEvent; 
import es.redmic.atlaslib.events.layer.delete.DeleteLayerEvent;

import es.redmic.atlaslib.events.layer.delete.DeleteLayerFailedEvent;

import es.redmic.atlaslib.events.layer.delete.LayerDeletedEvent;

import es.redmic.atlaslib.events.layer.fail.LayerRollbackEvent;

import es.redmic.atlaslib.events.layer.partialupdate.themeinspire.UpdateThemeInspireInLayerEvent;

import es.redmic.atlaslib.events.layer.refresh.LayerRefreshedEvent;

import es.redmic.atlaslib.events.layer.refresh.RefreshLayerCancelledEvent;
@@ -57,6 +58,7 @@ import es.redmic.atlaslib.events.layer.update.UpdateLayerFailedEvent; 
import es.redmic.atlaslib.events.themeinspire.common.ThemeInspireEvent;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.avro.common.EventError;

import es.redmic.brokerlib.avro.fail.PrepareRollbackEvent;

import es.redmic.exception.common.ExceptionType;

import es.redmic.exception.common.InternalException;
@@ -111,6 +113,14 @@ public class LayerEventFactory { 


	public static Event getEvent(Event source, String type, LayerDTO layer) {



		if (type.equals(LayerEventTypes.ROLLBACK)) {

			logger.debug("Creando evento LayerRollbackEvent para: " + source.getAggregateId());

			LayerRollbackEvent rollbackEvent = new LayerRollbackEvent().buildFrom(source);

			rollbackEvent.setLastSnapshotItem(layer);

			rollbackEvent.setFailEventType(((PrepareRollbackEvent) source).getFailEventType());

			return rollbackEvent;

		}



		LayerEvent successfulEvent = null;



		if (type.equals(LayerEventTypes.ENRICH_CREATE)) {

atlas-lib/src/main/java/es/redmic/atlaslib/events/themeinspire/ThemeInspireEventFactory.java

+10 −0
Original line number Diff line number Diff line
@@ -39,12 +39,14 @@ import es.redmic.atlaslib.events.themeinspire.delete.DeleteThemeInspireConfirmed 
import es.redmic.atlaslib.events.themeinspire.delete.DeleteThemeInspireEvent;

import es.redmic.atlaslib.events.themeinspire.delete.DeleteThemeInspireFailedEvent;

import es.redmic.atlaslib.events.themeinspire.delete.ThemeInspireDeletedEvent;

import es.redmic.atlaslib.events.themeinspire.fail.ThemeInspireRollbackEvent;

import es.redmic.atlaslib.events.themeinspire.update.ThemeInspireUpdatedEvent;

import es.redmic.atlaslib.events.themeinspire.update.UpdateThemeInspireCancelledEvent;

import es.redmic.atlaslib.events.themeinspire.update.UpdateThemeInspireConfirmedEvent;

import es.redmic.atlaslib.events.themeinspire.update.UpdateThemeInspireFailedEvent;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.avro.common.EventError;

import es.redmic.brokerlib.avro.fail.PrepareRollbackEvent;

import es.redmic.exception.common.ExceptionType;

import es.redmic.exception.common.InternalException;
@@ -99,6 +101,14 @@ public class ThemeInspireEventFactory { 


	public static Event getEvent(Event source, String type, ThemeInspireDTO themeInspire) {



		if (type.equals(ThemeInspireEventTypes.ROLLBACK)) {

			logger.debug("Creando evento ThemeInspireRollbackEvent para: " + source.getAggregateId());

			ThemeInspireRollbackEvent rollbackEvent = new ThemeInspireRollbackEvent().buildFrom(source);

			rollbackEvent.setLastSnapshotItem(themeInspire);

			rollbackEvent.setFailEventType(((PrepareRollbackEvent) source).getFailEventType());

			return rollbackEvent;

		}



		ThemeInspireEvent successfulEvent = null;



		if (type.equals(ThemeInspireEventTypes.CREATED)) {

atlas-lib/src/test/java/es/redmic/atlaslib/unit/events/category/CategoryEventFactoryTest.java

+17 −0
Original line number Diff line number Diff line
@@ -38,6 +38,7 @@ import es.redmic.atlaslib.events.category.delete.DeleteCategoryCheckedEvent; 
import es.redmic.atlaslib.events.category.delete.DeleteCategoryConfirmedEvent;

import es.redmic.atlaslib.events.category.delete.DeleteCategoryEvent;

import es.redmic.atlaslib.events.category.delete.DeleteCategoryFailedEvent;

import es.redmic.atlaslib.events.category.fail.CategoryRollbackEvent;

import es.redmic.atlaslib.events.category.update.CategoryUpdatedEvent;

import es.redmic.atlaslib.events.category.update.UpdateCategoryCancelledEvent;

import es.redmic.atlaslib.events.category.update.UpdateCategoryConfirmedEvent;
@@ -45,6 +46,7 @@ import es.redmic.atlaslib.events.category.update.UpdateCategoryFailedEvent; 
import es.redmic.atlaslib.unit.utils.CategoryDataUtil;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.avro.common.EventError;

import es.redmic.brokerlib.avro.fail.PrepareRollbackEvent;

import es.redmic.testutils.utils.AvroBaseTest;



public class CategoryEventFactoryTest extends AvroBaseTest {
@@ -271,6 +273,21 @@ public class CategoryEventFactoryTest extends AvroBaseTest { 


	////////////////////



	@Test

	public void GetEvent_ReturnCategoryRollbackEvent_IfTypeIsRollback() {



		PrepareRollbackEvent source = CategoryDataUtil.getPrepareRollbackEvent();



		CategoryRollbackEvent event = (CategoryRollbackEvent) CategoryEventFactory.getEvent(source,

				CategoryEventTypes.ROLLBACK, CategoryDataUtil.getCategory());



		assertEquals(CategoryEventTypes.ROLLBACK, event.getType());



		checkMetadataFields(source, event);

		assertEquals(source.getFailEventType(), event.getFailEventType());

		assertNotNull(event.getLastSnapshotItem());

	}



	private void checkMetadataFields(Event source, Event evt) {



		assertEquals(source.getAggregateId(), evt.getAggregateId());

atlas-lib/src/test/java/es/redmic/atlaslib/unit/events/layer/LayerEventFactoryTest.java

+19 −0
Original line number Diff line number Diff line
@@ -41,6 +41,7 @@ import es.redmic.atlaslib.events.layer.delete.DeleteLayerConfirmedEvent; 
import es.redmic.atlaslib.events.layer.delete.DeleteLayerEvent;

import es.redmic.atlaslib.events.layer.delete.DeleteLayerFailedEvent;

import es.redmic.atlaslib.events.layer.delete.LayerDeletedEvent;

import es.redmic.atlaslib.events.layer.fail.LayerRollbackEvent;

import es.redmic.atlaslib.events.layer.partialupdate.themeinspire.UpdateThemeInspireInLayerEvent;

import es.redmic.atlaslib.events.layer.refresh.LayerRefreshedEvent;

import es.redmic.atlaslib.events.layer.refresh.RefreshLayerCancelledEvent;
@@ -58,6 +59,7 @@ import es.redmic.atlaslib.unit.utils.LayerDataUtil; 
import es.redmic.atlaslib.unit.utils.ThemeInspireDataUtil;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.avro.common.EventError;

import es.redmic.brokerlib.avro.fail.PrepareRollbackEvent;

import es.redmic.testutils.utils.AvroBaseTest;



public class LayerEventFactoryTest extends AvroBaseTest {
@@ -441,6 +443,23 @@ public class LayerEventFactoryTest extends AvroBaseTest { 


	////////////////////



	@Test

	public void GetEvent_ReturnLayerRollbackEvent_IfTypeIsRollback() {



		PrepareRollbackEvent source = LayerDataUtil.getPrepareRollbackEvent();



		LayerRollbackEvent event = (LayerRollbackEvent) LayerEventFactory.getEvent(source, LayerEventTypes.ROLLBACK,

				LayerDataUtil.getLayer());



		assertEquals(LayerEventTypes.ROLLBACK, event.getType());



		checkMetadataFields(source, event);

		assertEquals(source.getFailEventType(), event.getFailEventType());

		assertNotNull(event.getLastSnapshotItem());

	}



	////////////////////



	private void checkMetadataFields(Event source, Event evt) {



		assertEquals(source.getAggregateId(), evt.getAggregateId());