EMS, EMS-4-MOR: Moved 'eu.melodic.models' package from main EMS project to EMS-4-Morphemic. Also updated TranslationResultsCoordinator class (in EMS-4-MOR)

This commit is contained in:
ipatini 2023-09-18 16:25:56 +03:00
parent e1a288f6a4
commit 369ae24436
27 changed files with 0 additions and 1328 deletions

View File

@ -1,42 +0,0 @@
package eu.melodic.models.commons;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = NotificationResultImpl.class
)
public interface NotificationResult {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
StatusType getStatus();
void setStatus(StatusType status);
String getErrorCode();
void setErrorCode(String errorCode);
String getErrorDescription();
void setErrorDescription(String errorDescription);
enum StatusType {
@JsonProperty("SUCCESS")
SUCCESS("SUCCESS"),
@JsonProperty("ERROR")
ERROR("ERROR");
private String name;
StatusType(String name) {
this.name = name;
}
}
}

View File

@ -1,72 +0,0 @@
package eu.melodic.models.commons;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"status",
"errorCode",
"errorDescription"
})
public class NotificationResultImpl implements NotificationResult {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("status")
private StatusType status;
@JsonProperty("errorCode")
private String errorCode;
@JsonProperty("errorDescription")
private String errorDescription;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("status")
public StatusType getStatus() {
return this.status;
}
@JsonProperty("status")
public void setStatus(StatusType status) {
this.status = status;
}
@JsonProperty("errorCode")
public String getErrorCode() {
return this.errorCode;
}
@JsonProperty("errorCode")
public void setErrorCode(String errorCode) {
this.errorCode = errorCode;
}
@JsonProperty("errorDescription")
public String getErrorDescription() {
return this.errorDescription;
}
@JsonProperty("errorDescription")
public void setErrorDescription(String errorDescription) {
this.errorDescription = errorDescription;
}
}

View File

@ -1,32 +0,0 @@
package eu.melodic.models.commons;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.Date;
import java.util.Map;
@JsonDeserialize(
as = WatermarkImpl.class
)
public interface Watermark {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getUser();
void setUser(String user);
String getSystem();
void setSystem(String system);
Date getDate();
void setDate(Date date);
String getUuid();
void setUuid(String uuid);
}

View File

@ -1,92 +0,0 @@
package eu.melodic.models.commons;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"user",
"system",
"date",
"uuid"
})
public class WatermarkImpl implements Watermark {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("user")
private String user;
@JsonProperty("system")
private String system;
@JsonProperty("date")
@JsonFormat(
shape = JsonFormat.Shape.STRING,
pattern = "yyyy-MM-dd'T'HH:mm:ssZ"
)
private Date date;
@JsonProperty("uuid")
private String uuid;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("user")
public String getUser() {
return this.user;
}
@JsonProperty("user")
public void setUser(String user) {
this.user = user;
}
@JsonProperty("system")
public String getSystem() {
return this.system;
}
@JsonProperty("system")
public void setSystem(String system) {
this.system = system;
}
@JsonProperty("date")
public Date getDate() {
return this.date;
}
@JsonProperty("date")
public void setDate(Date date) {
this.date = date;
}
@JsonProperty("uuid")
public String getUuid() {
return this.uuid;
}
@JsonProperty("uuid")
public void setUuid(String uuid) {
this.uuid = uuid;
}
}

View File

@ -1,29 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = CamelModelRequestImpl.class
)
public interface CamelModelRequest {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getApplicationId();
void setApplicationId(String applicationId);
String getNotificationURI();
void setNotificationURI(String notificationURI);
Watermark getWatermark();
void setWatermark(Watermark watermark);
}

View File

@ -1,74 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"applicationId",
"notificationURI",
"watermark"
})
public class CamelModelRequestImpl implements CamelModelRequest {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("applicationId")
private String applicationId;
@JsonProperty("notificationURI")
private String notificationURI;
@JsonProperty("watermark")
private Watermark watermark;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("applicationId")
public String getApplicationId() {
return this.applicationId;
}
@JsonProperty("applicationId")
public void setApplicationId(String applicationId) {
this.applicationId = applicationId;
}
@JsonProperty("notificationURI")
public String getNotificationURI() {
return this.notificationURI;
}
@JsonProperty("notificationURI")
public void setNotificationURI(String notificationURI) {
this.notificationURI = notificationURI;
}
@JsonProperty("watermark")
public Watermark getWatermark() {
return this.watermark;
}
@JsonProperty("watermark")
public void setWatermark(Watermark watermark) {
this.watermark = watermark;
}
}

View File

@ -1,53 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = IntervalImpl.class
)
public interface Interval {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
UnitType getUnit();
void setUnit(UnitType unit);
int getPeriod();
void setPeriod(int period);
enum UnitType {
@JsonProperty("DAYS")
DAYS("DAYS"),
@JsonProperty("HOURS")
HOURS("HOURS"),
@JsonProperty("MICROSECONDS")
MICROSECONDS("MICROSECONDS"),
@JsonProperty("MILLISECONDS")
MILLISECONDS("MILLISECONDS"),
@JsonProperty("MINUTES")
MINUTES("MINUTES"),
@JsonProperty("NANOSECONDS")
NANOSECONDS("NANOSECONDS"),
@JsonProperty("SECONDS")
SECONDS("SECONDS");
private String name;
UnitType(String name) {
this.name = name;
}
}
}

View File

@ -1,58 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"unit",
"period"
})
public class IntervalImpl implements Interval {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("unit")
private UnitType unit;
@JsonProperty("period")
private int period;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("unit")
public UnitType getUnit() {
return this.unit;
}
@JsonProperty("unit")
public void setUnit(UnitType unit) {
this.unit = unit;
}
@JsonProperty("period")
public int getPeriod() {
return this.period;
}
@JsonProperty("period")
public void setPeriod(int period) {
this.period = period;
}
}

View File

@ -1,23 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = KeyValuePairImpl.class
)
public interface KeyValuePair {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getKey();
void setKey(String key);
String getValue();
void setValue(String value);
}

View File

@ -1,58 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"key",
"value"
})
public class KeyValuePairImpl implements KeyValuePair {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("key")
private String key;
@JsonProperty("value")
private String value;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("key")
public String getKey() {
return this.key;
}
@JsonProperty("key")
public void setKey(String key) {
this.key = key;
}
@JsonProperty("value")
public String getValue() {
return this.value;
}
@JsonProperty("value")
public void setValue(String value) {
this.value = value;
}
}

View File

@ -1,37 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.List;
import java.util.Map;
@JsonDeserialize(
as = MonitorImpl.class
)
public interface Monitor {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getMetric();
void setMetric(String metric);
String getComponent();
void setComponent(String component);
Sensor getSensor();
void setSensor(Sensor sensor);
List<Sink> getSinks();
void setSinks(List<Sink> sinks);
List<KeyValuePair> getTags();
void setTags(List<KeyValuePair> tags);
}

View File

@ -1,102 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"metric",
"component",
"sensor",
"sinks",
"tags"
})
public class MonitorImpl implements Monitor {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("metric")
private String metric;
@JsonProperty("component")
private String component;
@JsonProperty("sensor")
private Sensor sensor;
@JsonProperty("sinks")
private List<Sink> sinks;
@JsonProperty("tags")
private List<KeyValuePair> tags;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("metric")
public String getMetric() {
return this.metric;
}
@JsonProperty("metric")
public void setMetric(String metric) {
this.metric = metric;
}
@JsonProperty("component")
public String getComponent() {
return this.component;
}
@JsonProperty("component")
public void setComponent(String component) {
this.component = component;
}
@JsonProperty("sensor")
public Sensor getSensor() {
return this.sensor;
}
@JsonProperty("sensor")
public void setSensor(Sensor sensor) {
this.sensor = sensor;
}
@JsonProperty("sinks")
public List<Sink> getSinks() {
return this.sinks;
}
@JsonProperty("sinks")
public void setSinks(List<Sink> sinks) {
this.sinks = sinks;
}
@JsonProperty("tags")
public List<KeyValuePair> getTags() {
return this.tags;
}
@JsonProperty("tags")
public void setTags(List<KeyValuePair> tags) {
this.tags = tags;
}
}

View File

@ -1,25 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = MonitorsDataRequestImpl.class
)
public interface MonitorsDataRequest {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getApplicationId();
void setApplicationId(String applicationId);
Watermark getWatermark();
void setWatermark(Watermark watermark);
}

View File

@ -1,60 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"applicationId",
"watermark"
})
public class MonitorsDataRequestImpl implements MonitorsDataRequest {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("applicationId")
private String applicationId;
@JsonProperty("watermark")
private Watermark watermark;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("applicationId")
public String getApplicationId() {
return this.applicationId;
}
@JsonProperty("applicationId")
public void setApplicationId(String applicationId) {
this.applicationId = applicationId;
}
@JsonProperty("watermark")
public Watermark getWatermark() {
return this.watermark;
}
@JsonProperty("watermark")
public void setWatermark(Watermark watermark) {
this.watermark = watermark;
}
}

View File

@ -1,26 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.List;
import java.util.Map;
@JsonDeserialize(
as = MonitorsDataResponseImpl.class
)
public interface MonitorsDataResponse {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
List<Monitor> getMonitors();
void setMonitors(List<Monitor> monitors);
Watermark getWatermark();
void setWatermark(Watermark watermark);
}

View File

@ -1,61 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"monitors",
"watermark"
})
public class MonitorsDataResponseImpl implements MonitorsDataResponse {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("monitors")
private List<Monitor> monitors;
@JsonProperty("watermark")
private Watermark watermark;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("monitors")
public List<Monitor> getMonitors() {
return this.monitors;
}
@JsonProperty("monitors")
public void setMonitors(List<Monitor> monitors) {
this.monitors = monitors;
}
@JsonProperty("watermark")
public Watermark getWatermark() {
return this.watermark;
}
@JsonProperty("watermark")
public void setWatermark(Watermark watermark) {
this.watermark = watermark;
}
}

View File

@ -1,29 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.List;
import java.util.Map;
@JsonDeserialize(
as = PullSensorImpl.class
)
public interface PullSensor {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getClassName();
void setClassName(String className);
List<KeyValuePair> getConfiguration();
void setConfiguration(List<KeyValuePair> configuration);
Interval getInterval();
void setInterval(Interval interval);
}

View File

@ -1,73 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"className",
"configuration",
"interval"
})
public class PullSensorImpl implements PullSensor {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("className")
private String className;
@JsonProperty("configuration")
private List<KeyValuePair> configuration;
@JsonProperty("interval")
private Interval interval;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("className")
public String getClassName() {
return this.className;
}
@JsonProperty("className")
public void setClassName(String className) {
this.className = className;
}
@JsonProperty("configuration")
public List<KeyValuePair> getConfiguration() {
return this.configuration;
}
@JsonProperty("configuration")
public void setConfiguration(List<KeyValuePair> configuration) {
this.configuration = configuration;
}
@JsonProperty("interval")
public Interval getInterval() {
return this.interval;
}
@JsonProperty("interval")
public void setInterval(Interval interval) {
this.interval = interval;
}
}

View File

@ -1,19 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = PushSensorImpl.class
)
public interface PushSensor {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
int getPort();
void setPort(int port);
}

View File

@ -1,42 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder("port")
public class PushSensorImpl implements PushSensor {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("port")
private int port;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("port")
public int getPort() {
return this.port;
}
@JsonProperty("port")
public void setPort(int port) {
this.port = port;
}
}

View File

@ -1,49 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import eu.melodic.models.resources.SensorDeserializer;
import eu.melodic.models.resources.SensorSerializer;
import java.lang.IllegalStateException;
import java.lang.Object;
@JsonDeserialize(
using = SensorDeserializer.class
)
@JsonSerialize(
using = SensorSerializer.class
)
public class Sensor {
private Object anyType;
private Sensor() {
this.anyType = null;
}
public Sensor(PushSensor pushSensor) {
this.anyType = pushSensor;
}
public Sensor(PullSensor pullSensor) {
this.anyType = pullSensor;
}
public PushSensor getPushSensor() {
if ( !(anyType instanceof PushSensor)) throw new IllegalStateException("fetching wrong type out of the union: PushSensor");
return (PushSensor) anyType;
}
public boolean isPushSensor() {
return anyType instanceof PushSensor;
}
public PullSensor getPullSensor() {
if ( !(anyType instanceof PullSensor)) throw new IllegalStateException("fetching wrong type out of the union: PullSensor");
return (PullSensor) anyType;
}
public boolean isPullSensor() {
return anyType instanceof PullSensor;
}
}

View File

@ -1,46 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.lang.Object;
import java.lang.String;
import java.util.List;
import java.util.Map;
@JsonDeserialize(
as = SinkImpl.class
)
public interface Sink {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
TypeType getType();
void setType(TypeType type);
List<KeyValuePair> getConfiguration();
void setConfiguration(List<KeyValuePair> configuration);
enum TypeType {
@JsonProperty("KAIROS_DB")
KAIROSDB("KAIROS_DB"),
@JsonProperty("INFLUX")
INFLUX("INFLUX"),
@JsonProperty("JMS")
JMS("JMS"),
@JsonProperty("CLI")
CLI("CLI");
private String name;
TypeType(String name) {
this.name = name;
}
}
}

View File

@ -1,60 +0,0 @@
package eu.melodic.models.interfaces;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"type",
"configuration"
})
public class SinkImpl implements Sink {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("type")
private TypeType type;
@JsonProperty("configuration")
private List<KeyValuePair> configuration;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("type")
public TypeType getType() {
return this.type;
}
@JsonProperty("type")
public void setType(TypeType type) {
this.type = type;
}
@JsonProperty("configuration")
public List<KeyValuePair> getConfiguration() {
return this.configuration;
}
@JsonProperty("configuration")
public void setConfiguration(List<KeyValuePair> configuration) {
this.configuration = configuration;
}
}

View File

@ -1,36 +0,0 @@
package eu.melodic.models.resources;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.deser.std.StdDeserializer;
import gr.iccs.imu.ems.util.StrUtil;
import eu.melodic.models.interfaces.PullSensor;
import eu.melodic.models.interfaces.PushSensor;
import eu.melodic.models.interfaces.Sensor;
import java.io.IOException;
import java.lang.Object;
import java.lang.String;
import java.util.Arrays;
import java.util.Map;
public class SensorDeserializer extends StdDeserializer<Sensor> {
public SensorDeserializer() {
super(Sensor.class);}
private boolean looksLikePushSensor(Map<String, Object> map) {
return map.keySet().containsAll(Arrays.asList("port"));
}
private boolean looksLikePullSensor(Map<String, Object> map) {
return map.keySet().containsAll(Arrays.asList("className","configuration","interval"));
}
public Sensor deserialize(JsonParser jsonParser, DeserializationContext jsonContext) throws IOException {
ObjectMapper mapper = new ObjectMapper();
Map<String, Object> map = StrUtil.castToMapStringObject( mapper.readValue(jsonParser, Map.class) );
if ( looksLikePushSensor(map) ) return new Sensor(mapper.convertValue(map, PushSensor.class));
if ( looksLikePullSensor(map) ) return new Sensor(mapper.convertValue(map, PullSensor.class));
throw new IOException("Can't figure out type of object" + map);
}
}

View File

@ -1,25 +0,0 @@
package eu.melodic.models.resources;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import eu.melodic.models.interfaces.Sensor;
import java.io.IOException;
public class SensorSerializer extends StdSerializer<Sensor> {
public SensorSerializer() {
super(Sensor.class);}
public void serialize(Sensor object, JsonGenerator jsonGenerator, SerializerProvider jsonSerializerProvider) throws IOException, JsonProcessingException {
if ( object.isPushSensor()) {
jsonGenerator.writeObject(object.getPushSensor());
return;
}
if ( object.isPullSensor()) {
jsonGenerator.writeObject(object.getPullSensor());
return;
}
throw new IOException("Can't figure out type of object" + object);
}
}

View File

@ -1,30 +0,0 @@
package eu.melodic.models.services;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import eu.melodic.models.commons.NotificationResult;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.Map;
@JsonDeserialize(
as = CamelModelNotificationRequestImpl.class
)
public interface CamelModelNotificationRequest {
Map<String, Object> getAdditionalProperties();
void setAdditionalProperties(Map<String, Object> additionalProperties);
String getApplicationId();
void setApplicationId(String applicationId);
NotificationResult getResult();
void setResult(NotificationResult result);
Watermark getWatermark();
void setWatermark(Watermark watermark);
}

View File

@ -1,75 +0,0 @@
package eu.melodic.models.services;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
import com.fasterxml.jackson.annotation.JsonAnySetter;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import eu.melodic.models.commons.NotificationResult;
import eu.melodic.models.commons.Watermark;
import java.lang.Object;
import java.lang.String;
import java.util.HashMap;
import java.util.Map;
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({
"applicationId",
"result",
"watermark"
})
public class CamelModelNotificationRequestImpl implements CamelModelNotificationRequest {
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
@JsonProperty("applicationId")
private String applicationId;
@JsonProperty("result")
private NotificationResult result;
@JsonProperty("watermark")
private Watermark watermark;
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperties(Map<String, Object> additionalProperties) {
this.additionalProperties = additionalProperties;
}
@JsonProperty("applicationId")
public String getApplicationId() {
return this.applicationId;
}
@JsonProperty("applicationId")
public void setApplicationId(String applicationId) {
this.applicationId = applicationId;
}
@JsonProperty("result")
public NotificationResult getResult() {
return this.result;
}
@JsonProperty("result")
public void setResult(NotificationResult result) {
this.result = result;
}
@JsonProperty("watermark")
public Watermark getWatermark() {
return this.watermark;
}
@JsonProperty("watermark")
public void setWatermark(Watermark watermark) {
this.watermark = watermark;
}
}