Commit f1962400 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade eventos de rollback por tipo + tests

parent 6ac74578

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

0 → 100644
+105 −0
Original line number Diff line number Diff line 
package es.redmic.atlaslib.events.category.fail;



import org.apache.avro.Schema;

import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



import es.redmic.atlaslib.dto.category.CategoryDTO;

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

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



public class CategoryRollbackEvent extends BaseRollbackEvent {



	// @formatter:off



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

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

				+ "\"namespace\":\"es.redmic.atlaslib.events.category.fail\",\"fields\":["

			+ "{\"name\":\"lastSnapshotItem\",\"type\":" + CategoryDTO.SCHEMA$.toString() + "},"

			+ "{\"name\":\"failEventType\",\"type\": \"string\"},"

			+ getEventBaseSchema() + "]}");

	

	// @formatter:on



	static String type = EventTypes.ROLLBACK;



	private CategoryDTO lastSnapshotItem;



	public CategoryRollbackEvent() {

		super(type);

	}



	public CategoryDTO getLastSnapshotItem() {

		return lastSnapshotItem;

	}



	public void setLastSnapshotItem(CategoryDTO lastSnapshotItem) {

		this.lastSnapshotItem = lastSnapshotItem;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getLastSnapshotItem();

		case 1:

			return getFailEventType();

		case 2:

			return getAggregateId();

		case 3:

			return getVersion();

		case 4:

			return getType();

		case 5:

			return getDate().getMillis();

		case 6:

			return getSessionId();

		case 7:

			return getUserId();

		case 8:

			return getId();

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public void put(int field$, Object value$) {

		switch (field$) {

		case 0:

			setLastSnapshotItem((CategoryDTO) value$);

			break;

		case 1:

			setFailEventType(value$.toString());

			break;

		case 2:

			setAggregateId(value$.toString());

			break;

		case 3:

			setVersion((java.lang.Integer) value$);

			break;

		case 4:

			setType(value$.toString());

			break;

		case 5:

			setDate(new DateTime(value$, DateTimeZone.UTC));

			break;

		case 6:

			setSessionId(value$.toString());

			break;

		case 7:

			setUserId(value$.toString());

			break;

		case 8:

			setId(value$.toString());

			break;

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

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

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



import org.apache.avro.Schema;

import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



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

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

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



public class LayerRollbackEvent extends BaseRollbackEvent {



	// @formatter:off



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

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

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

			+ "{\"name\":\"lastSnapshotItem\",\"type\":" + LayerDTO.SCHEMA$.toString() + "},"

			+ "{\"name\":\"failEventType\",\"type\": \"string\"},"

			+ getEventBaseSchema() + "]}");

	

	// @formatter:on



	static String type = EventTypes.ROLLBACK;



	private LayerDTO lastSnapshotItem;



	public LayerRollbackEvent() {

		super(type);

	}



	public LayerDTO getLastSnapshotItem() {

		return lastSnapshotItem;

	}



	public void setLastSnapshotItem(LayerDTO lastSnapshotItem) {

		this.lastSnapshotItem = lastSnapshotItem;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getLastSnapshotItem();

		case 1:

			return getFailEventType();

		case 2:

			return getAggregateId();

		case 3:

			return getVersion();

		case 4:

			return getType();

		case 5:

			return getDate().getMillis();

		case 6:

			return getSessionId();

		case 7:

			return getUserId();

		case 8:

			return getId();

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public void put(int field$, Object value$) {

		switch (field$) {

		case 0:

			setLastSnapshotItem((LayerDTO) value$);

			break;

		case 1:

			setFailEventType(value$.toString());

			break;

		case 2:

			setAggregateId(value$.toString());

			break;

		case 3:

			setVersion((java.lang.Integer) value$);

			break;

		case 4:

			setType(value$.toString());

			break;

		case 5:

			setDate(new DateTime(value$, DateTimeZone.UTC));

			break;

		case 6:

			setSessionId(value$.toString());

			break;

		case 7:

			setUserId(value$.toString());

			break;

		case 8:

			setId(value$.toString());

			break;

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

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

0 → 100644
+105 −0
Original line number Diff line number Diff line 
package es.redmic.atlaslib.events.themeinspire.fail;



import org.apache.avro.Schema;

import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



import es.redmic.atlaslib.dto.themeinspire.ThemeInspireDTO;

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

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



public class ThemeInspireRollbackEvent extends BaseRollbackEvent {



	// @formatter:off



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

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

				+ "\"namespace\":\"es.redmic.atlaslib.events.themeinspire.fail\",\"fields\":["

			+ "{\"name\":\"lastSnapshotItem\",\"type\":" + ThemeInspireDTO.SCHEMA$.toString() + "},"

			+ "{\"name\":\"failEventType\",\"type\": \"string\"},"

			+ getEventBaseSchema() + "]}");

	

	// @formatter:on



	static String type = EventTypes.ROLLBACK;



	private ThemeInspireDTO lastSnapshotItem;



	public ThemeInspireRollbackEvent() {

		super(type);

	}



	public ThemeInspireDTO getLastSnapshotItem() {

		return lastSnapshotItem;

	}



	public void setLastSnapshotItem(ThemeInspireDTO lastSnapshotItem) {

		this.lastSnapshotItem = lastSnapshotItem;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getLastSnapshotItem();

		case 1:

			return getFailEventType();

		case 2:

			return getAggregateId();

		case 3:

			return getVersion();

		case 4:

			return getType();

		case 5:

			return getDate().getMillis();

		case 6:

			return getSessionId();

		case 7:

			return getUserId();

		case 8:

			return getId();

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public void put(int field$, Object value$) {

		switch (field$) {

		case 0:

			setLastSnapshotItem((ThemeInspireDTO) value$);

			break;

		case 1:

			setFailEventType(value$.toString());

			break;

		case 2:

			setAggregateId(value$.toString());

			break;

		case 3:

			setVersion((java.lang.Integer) value$);

			break;

		case 4:

			setType(value$.toString());

			break;

		case 5:

			setDate(new DateTime(value$, DateTimeZone.UTC));

			break;

		case 6:

			setSessionId(value$.toString());

			break;

		case 7:

			setUserId(value$.toString());

			break;

		case 8:

			setId(value$.toString());

			break;

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

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

+16 −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;
@@ -287,4 +288,19 @@ public class CategoryEventsCheckAvroSchemaTest extends AvroBaseTest { 


		assertEquals(result, event);

	}



	// FAIL



	@Test

	public void CategoryRollbackEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		CategoryRollbackEvent event = CategoryDataUtil.getCategoryRollbackEvent();



		Object result = serializerAndDeserializer(event);



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

				CategoryRollbackEvent.class.isInstance(result));



		assertEquals(result, event);

	}

}

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

+16 −0
Original line number Diff line number Diff line
@@ -40,6 +40,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;
@@ -429,4 +430,19 @@ public class LayerEventsCheckAvroSchemaTest extends AvroBaseTest { 


		assertEquals(result, event);

	}



	// FAIL



	@Test

	public void LayerRollbackEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		LayerRollbackEvent event = LayerDataUtil.getLayerRollbackEvent();



		Object result = serializerAndDeserializer(event);



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

				LayerRollbackEvent.class.isInstance(result));



		assertEquals(result, event);

	}

}