diff options
Diffstat (limited to 'src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy')
| -rw-r--r-- | src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy | 62 |
1 files changed, 34 insertions, 28 deletions
diff --git a/src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy b/src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy index 7c4dee6..95c47ce 100644 --- a/src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy +++ b/src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy @@ -6,13 +6,15 @@ * 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 + * 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. + * + * SPDX-License-Identifier: Apache-2.0 * ============LICENSE_END========================================================= */ @@ -32,36 +34,40 @@ class EventFixtures { static DateTimeFormatter isoTimestampFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSSZ") static String defaultEventType = 'org.onap.cps.data-updated-event' - static URI defaultEventSchema = new URI('urn:cps:org.onap.cps:data-updated-event-schema:v1') + static URI defaultEventSchema = new URI('urn:cps:org.onap.cps:data-updated-event-schema:v2') static URI defaultEventSource = new URI('urn:cps:org.onap.cps') - static CpsDataUpdatedEvent buildEvent(final Map map) { - CpsDataUpdatedEvent event = - new CpsDataUpdatedEvent() - .withSchema( - map.eventSchema != null ? new URI(map.eventSchema.toString()) : defaultEventSchema) - .withId( - map.id != null ? map.id.toString() : UUID.randomUUID().toString()) - .withType( - map.eventType != null ? map.eventType.toString() : defaultEventType) - .withSource( - map.eventSource != null ? new URI(map.eventSource.toString()) : defaultEventSource) - .withContent( - new Content() - .withObservedTimestamp( - map.timestamp != null ? map.timestamp.toString() : currentTimestamp()) - .withDataspaceName( - map.dataspace != null ? map.dataspace.toString() : 'a-dataspace') - .withSchemaSetName( - map.schemaSet != null ? map.schemaSet.toString() : 'a-schema-set') - .withAnchorName( - map.anchor != null ? map.anchor.toString() : 'an-anchor') - .withData( - new Data().withAdditionalProperty( - map.dataName != null ? map.dataName.toString() : 'a-data-name', - map.dataValue != null ? map.dataValue : 'a-data-value'))) + static def defaultEventValue = [ + eventSchema : defaultEventSchema, + id : UUID.randomUUID().toString(), + eventType : defaultEventType, + eventSource : defaultEventSource + ] + + static CpsDataUpdatedEvent buildEvent(final Map inputMap) { + def mergedMap = defaultEventValue + inputMap + + def dataExist = mergedMap.containsKey('data') + Data data = null + if (dataExist) { + data = new Data() + mergedMap.data.each { k, v -> data.withAdditionalProperty(k, v) } + } + + def content = new Content() + .withObservedTimestamp(mergedMap.observedTimestamp) + .withDataspaceName(mergedMap.dataspace) + .withSchemaSetName(mergedMap.schemaSet) + .withAnchorName(mergedMap.anchor) + .withOperation(mergedMap.operation) + .withData(data) - return event + return new CpsDataUpdatedEvent() + .withSchema(mergedMap.eventSchema) + .withId(mergedMap.id) + .withType(mergedMap.eventType) + .withSource(mergedMap.eventSource) + .withContent(content) } static String currentIsoTimestamp() { |