blob: a076a551d3d2df676871d83165c525c9ebf26437 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
/**
* ============LICENSE_START=======================================================
* org.onap.aai
* ================================================================================
* Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
* Copyright © 2017-2018 Amdocs
* ================================================================================
* 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.
* ============LICENSE_END=========================================================
*/
package org.onap.aai.spike.event.outgoing;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.annotations.SerializedName;
import org.onap.aai.spike.exception.SpikeException;
public class SpikeGraphEvent {
public enum SpikeOperation {
CREATE, UPDATE, DELETE
}
private SpikeOperation operation;
@SerializedName("transaction-id")
private String transactionId;
@SerializedName("database-transaction-id")
private String dbTransactionId;
@SerializedName("timestamp")
private long operationTimestamp;
private SpikeVertex vertex;
private SpikeEdge relationship;
// Time this event was received in spike, used to determine when to send the event
@GsonExclude
private long spikeTimestamp = System.currentTimeMillis();
/** Serializer/deserializer for converting to/from JSON. */
private static final Gson gson = new GsonBuilder().disableHtmlEscaping().create();
public SpikeOperation getOperation() {
return operation;
}
public void setOperation(SpikeOperation operation) {
this.operation = operation;
}
public long getOperationTimestamp() {
return operationTimestamp;
}
public void setOperationTimestamp(long operationTimestamp) {
this.operationTimestamp = operationTimestamp;
}
public SpikeVertex getVertex() {
return vertex;
}
public void setVertex(SpikeVertex vertex) {
this.vertex = vertex;
}
public SpikeEdge getRelationship() {
return relationship;
}
public void setRelationship(SpikeEdge relationship) {
this.relationship = relationship;
}
public String getTransactionId() {
return transactionId;
}
public void setTransactionId(String transactionId) {
this.transactionId = transactionId;
}
public void setDbTransactionId(String dbTransactionId) {
this.dbTransactionId = dbTransactionId;
}
public long getSpikeTimestamp() {
return spikeTimestamp;
}
/**
* Unmarshalls this Vertex object into a JSON string.
*
* @return - A JSON format string representation of this Vertex.
*/
public String toJson() {
return gson.toJson(this);
}
/**
* Marshalls the provided JSON string into a Vertex object.
*
* @param json - The JSON string to produce the Vertex from.
*
* @return - A Vertex object.
*
* @throws SpikeException
*/
public static SpikeGraphEvent fromJson(String json) throws SpikeException {
try {
// Make sure that we were actually provided a non-empty string
// before we
// go any further.
if (json == null || json.isEmpty()) {
throw new SpikeException("Empty or null JSON string.");
}
// Marshall the string into a Vertex object.
return gson.fromJson(json, SpikeGraphEvent.class);
} catch (Exception ex) {
throw new SpikeException("Unable to parse JSON string: " + ex.getMessage());
}
}
@Override
public String toString() {
return toJson();
}
public String getObjectKey() {
if (this.getVertex() != null) {
return this.getVertex().getId();
} else if (this.getRelationship() != null) {
return this.getRelationship().getId();
}
return null;
}
public String getObjectType() {
if (this.getVertex() != null) {
return "Vertex->" + this.getVertex().getType();
} else if (this.getRelationship() != null) {
return "Relationship->" + this.getRelationship().getType();
}
return null;
}
}
|
