Commit 5e1bd57d authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade eventos para enriquecer layer al crear 

Añade tests de eventos

Añade eventos a la factoría
parent 218f6164

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

+14 −0
Original line number Diff line number Diff line
@@ -30,7 +30,9 @@ import es.redmic.atlaslib.events.layer.common.LayerCancelledEvent; 
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.CreateLayerFailedEvent;

import es.redmic.atlaslib.events.layer.create.EnrichCreateLayerEvent;

import es.redmic.atlaslib.events.layer.create.LayerCreatedEvent;

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

import es.redmic.atlaslib.events.layer.delete.DeleteLayerCheckFailedEvent;
@@ -105,6 +107,18 @@ public class LayerEventFactory { 


		LayerEvent successfulEvent = null;



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



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

			successfulEvent = new EnrichCreateLayerEvent().buildFrom(source);

		}



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



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

			successfulEvent = new CreateLayerEnrichedEvent().buildFrom(source);

		}



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



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

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

0 → 100644
+35 −0
Original line number Diff line number Diff line 
package es.redmic.atlaslib.events.layer.create;



import org.apache.avro.Schema;



import es.redmic.atlaslib.dto.layer.LayerDTO;

import es.redmic.atlaslib.events.layer.LayerEventTypes;

import es.redmic.atlaslib.events.layer.common.LayerEvent;



public class CreateLayerEnrichedEvent extends LayerEvent {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

		+ "\"type\":\"record\",\"name\":\"CreateLayerEnrichedEvent\","

				+ "\"namespace\":\"es.redmic.atlaslib.events.layer.create\",\"fields\":["

			+ getLayerEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = LayerEventTypes.CREATE_ENRICHED;



	public CreateLayerEnrichedEvent() {

		super(type);

	}



	public CreateLayerEnrichedEvent(LayerDTO layer) {

		super(type);

		setLayer(layer);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

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

0 → 100644
+39 −0
Original line number Diff line number Diff line 
package es.redmic.atlaslib.events.layer.create;



import java.util.UUID;



import org.apache.avro.Schema;



import es.redmic.atlaslib.dto.layer.LayerDTO;

import es.redmic.atlaslib.events.layer.LayerEventTypes;

import es.redmic.atlaslib.events.layer.common.LayerEvent;



public class EnrichCreateLayerEvent extends LayerEvent {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

		+ "\"type\":\"record\",\"name\":\"EnrichCreateLayerEvent\","

				+ "\"namespace\":\"es.redmic.atlaslib.events.layer.create\",\"fields\":["

			+ getLayerEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = LayerEventTypes.ENRICH_CREATE;



	public EnrichCreateLayerEvent() {

		super(type);

		setSessionId(UUID.randomUUID().toString());

	}



	public EnrichCreateLayerEvent(LayerDTO layer) {

		super(type);

		setSessionId(UUID.randomUUID().toString());

		setLayer(layer);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

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

+28 −0
Original line number Diff line number Diff line
@@ -29,7 +29,9 @@ import es.redmic.atlaslib.events.layer.LayerEventFactory; 
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.CreateLayerFailedEvent;

import es.redmic.atlaslib.events.layer.create.EnrichCreateLayerEvent;

import es.redmic.atlaslib.events.layer.create.LayerCreatedEvent;

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

import es.redmic.atlaslib.events.layer.delete.DeleteLayerCheckFailedEvent;
@@ -124,6 +126,32 @@ public class LayerEventFactoryTest { 


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



	@Test

	public void GetEvent_ReturnEnrichCreateLayerEvent_IfTypeIsEnrichCreate() {



		Event source = LayerDataUtil.getEnrichCreateLayerEvent();

		EnrichCreateLayerEvent event = (EnrichCreateLayerEvent) LayerEventFactory.getEvent(source,

				LayerEventTypes.ENRICH_CREATE, LayerDataUtil.getLayer());



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

		assertNotNull(event.getLayer());



		checkMetadataFields(source, event);

	}



	@Test

	public void GetEvent_ReturnCreateEnrichedLayerEvent_IfTypeIsEnrichCreate() {



		Event source = LayerDataUtil.getCreateLayerEnrichedEvent();

		CreateLayerEnrichedEvent event = (CreateLayerEnrichedEvent) LayerEventFactory.getEvent(source,

				LayerEventTypes.CREATE_ENRICHED, LayerDataUtil.getLayer());



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

		assertNotNull(event.getLayer());



		checkMetadataFields(source, event);

	}



	@Test

	public void GetEvent_ReturnLayerCreatedEvent_IfTypeIsCreated() {

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

+28 −0
Original line number Diff line number Diff line
@@ -27,8 +27,10 @@ import org.junit.Test; 


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;

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

import es.redmic.atlaslib.events.layer.delete.DeleteLayerCancelledEvent;
@@ -55,6 +57,32 @@ public class LayerEventsCheckAvroSchemaTest extends AtlasAvroBaseTest { 


	// Create



	@Test

	public void EnrichCreateLayerEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		EnrichCreateLayerEvent event = LayerDataUtil.getEnrichCreateLayerEvent();



		Object result = serializerAndDeserializer(event);



		assertTrue("El objeto obtenido debe ser una instancia de EnrichCreateLayerEvent",

				EnrichCreateLayerEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void CreateLayerEnrichedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		CreateLayerEnrichedEvent event = LayerDataUtil.getCreateLayerEnrichedEvent();



		Object result = serializerAndDeserializer(event);



		assertTrue("El objeto obtenido debe ser una instancia de CreateLayerEnrichedEvent",

				CreateLayerEnrichedEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void CreateLayerEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {