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

Añade dto en los eventos cancelados 

De este modo se puede compensar el cambio no realizado añadiendo el item
antes de la modificación
parent 5bb0da4a

src/main/java/es/redmic/usersettingslib/events/clear/ClearCancelledEvent.java

+9 −2
Original line number Diff line number Diff line
@@ -2,8 +2,9 @@ package es.redmic.usersettingslib.events.clear; 


import org.apache.avro.Schema;



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

import es.redmic.usersettingslib.dto.SelectionDTO;

import es.redmic.usersettingslib.events.SettingsEventTypes;

import es.redmic.usersettingslib.events.common.SelectionCancelledEvent;



/*-

 * #%L
@@ -25,13 +26,14 @@ import es.redmic.usersettingslib.events.SettingsEventTypes; 
 * #L%

 */



public class ClearCancelledEvent extends EventError {

public class ClearCancelledEvent extends SelectionCancelledEvent {



	// @formatter:off



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

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

				+ "\"namespace\":\"es.redmic.usersettingslib.events.clear\",\"fields\":["

			+ getSelectionEventSchema() + "," 

			+ getFailEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on
@@ -42,6 +44,11 @@ public class ClearCancelledEvent extends EventError { 
		super(type);

	}



	public ClearCancelledEvent(SelectionDTO selection) {

		super(type);

		this.setSelection(selection);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

src/main/java/es/redmic/usersettingslib/events/common/PersistenceCancelledEvent.java

0 → 100644
+121 −0
Original line number Diff line number Diff line 
package es.redmic.usersettingslib.events.common;



/*-

 * #%L

 * user-settings-lib

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import java.util.Map;



import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



import com.fasterxml.jackson.annotation.JsonIgnore;



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

import es.redmic.usersettingslib.dto.PersistenceDTO;



public abstract class PersistenceCancelledEvent extends EventError {



	private PersistenceDTO persistence;



	public PersistenceCancelledEvent(String type) {

		super(type);

	}



	public PersistenceDTO getPersistence() {

		return persistence;

	}



	public void setPersistence(PersistenceDTO persistence) {

		this.persistence = persistence;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getPersistence();

		case 1:

			return getExceptionType();

		case 2:

			return getArguments();

		case 3:

			return getAggregateId();

		case 4:

			return getVersion();

		case 5:

			return getType();

		case 6:

			return getDate().getMillis();

		case 7:

			return getSessionId();

		case 8:

			return getUserId();

		case 9:

			return getId();

		default:

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

		}

	}



	@SuppressWarnings("rawtypes")

	@Override

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

		switch (field$) {

		case 0:

			persistence = (PersistenceDTO) value$;

			break;

		case 1:

			setExceptionType(value$.toString());

			break;

		case 2:

			setArguments((Map) value$);

			break;

		case 3:

			setAggregateId(value$.toString());

			break;

		case 4:

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

			break;

		case 5:

			setType(value$.toString());

			break;

		case 6:

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

			break;

		case 7:

			setSessionId(value$.toString());

			break;

		case 8:

			setUserId(value$.toString());

			break;

		case 9:

			setId(value$.toString());

			break;

		default:

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

		}

	}



	@JsonIgnore

	public static String getPersistenceEventSchema() {



		return "{\"name\":\"persistence\", \"type\": " + PersistenceDTO.SCHEMA$.toString() + "}";

	}

}

src/main/java/es/redmic/usersettingslib/events/common/SelectionCancelledEvent.java

0 → 100644
+121 −0
Original line number Diff line number Diff line 
package es.redmic.usersettingslib.events.common;



/*-

 * #%L

 * user-settings-lib

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import java.util.Map;



import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



import com.fasterxml.jackson.annotation.JsonIgnore;



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

import es.redmic.usersettingslib.dto.SelectionDTO;



public abstract class SelectionCancelledEvent extends EventError {



	private SelectionDTO selection;



	public SelectionCancelledEvent(String type) {

		super(type);

	}



	public SelectionDTO getSelection() {

		return selection;

	}



	public void setSelection(SelectionDTO selection) {

		this.selection = selection;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getSelection();

		case 1:

			return getExceptionType();

		case 2:

			return getArguments();

		case 3:

			return getAggregateId();

		case 4:

			return getVersion();

		case 5:

			return getType();

		case 6:

			return getDate().getMillis();

		case 7:

			return getSessionId();

		case 8:

			return getUserId();

		case 9:

			return getId();

		default:

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

		}

	}



	@SuppressWarnings("rawtypes")

	@Override

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

		switch (field$) {

		case 0:

			selection = (SelectionDTO) value$;

			break;

		case 1:

			setExceptionType(value$.toString());

			break;

		case 2:

			setArguments((Map) value$);

			break;

		case 3:

			setAggregateId(value$.toString());

			break;

		case 4:

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

			break;

		case 5:

			setType(value$.toString());

			break;

		case 6:

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

			break;

		case 7:

			setSessionId(value$.toString());

			break;

		case 8:

			setUserId(value$.toString());

			break;

		case 9:

			setId(value$.toString());

			break;

		default:

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

		}

	}



	@JsonIgnore

	public static String getSelectionEventSchema() {



		return "{\"name\":\"selection\", \"type\": " + SelectionDTO.SCHEMA$.toString() + "}";

	}

}

src/main/java/es/redmic/usersettingslib/events/deselect/DeselectCancelledEvent.java

+9 −2
Original line number Diff line number Diff line
@@ -2,8 +2,9 @@ package es.redmic.usersettingslib.events.deselect; 


import org.apache.avro.Schema;



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

import es.redmic.usersettingslib.dto.SelectionDTO;

import es.redmic.usersettingslib.events.SettingsEventTypes;

import es.redmic.usersettingslib.events.common.SelectionCancelledEvent;



/*-

 * #%L
@@ -25,13 +26,14 @@ import es.redmic.usersettingslib.events.SettingsEventTypes; 
 * #L%

 */



public class DeselectCancelledEvent extends EventError {

public class DeselectCancelledEvent extends SelectionCancelledEvent {



	// @formatter:off



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

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

				+ "\"namespace\":\"es.redmic.usersettingslib.events.deselect\",\"fields\":["

			+ getSelectionEventSchema() + ","

			+ getFailEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on
@@ -42,6 +44,11 @@ public class DeselectCancelledEvent extends EventError { 
		super(type);

	}



	public DeselectCancelledEvent(SelectionDTO selection) {

		super(type);

		this.setSelection(selection);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

src/main/java/es/redmic/usersettingslib/events/save/SaveCancelledEvent.java

+9 −2
Original line number Diff line number Diff line
@@ -2,8 +2,9 @@ package es.redmic.usersettingslib.events.save; 


import org.apache.avro.Schema;



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

import es.redmic.usersettingslib.dto.PersistenceDTO;

import es.redmic.usersettingslib.events.SettingsEventTypes;

import es.redmic.usersettingslib.events.common.PersistenceCancelledEvent;



/*-

 * #%L
@@ -25,13 +26,14 @@ import es.redmic.usersettingslib.events.SettingsEventTypes; 
 * #L%

 */



public class SaveCancelledEvent extends EventError {

public class SaveCancelledEvent extends PersistenceCancelledEvent {



	// @formatter:off



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

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

				+ "\"namespace\":\"es.redmic.usersettingslib.events.save\",\"fields\":["

			+ getPersistenceEventSchema() + ","

			+ getFailEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on
@@ -42,6 +44,11 @@ public class SaveCancelledEvent extends EventError { 
		super(type);

	}



	public SaveCancelledEvent(PersistenceDTO persistence) {

		super(type);

		this.setPersistence(persistence);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;