diff options
Diffstat (limited to 'src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.groovy')
| -rw-r--r-- | src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.groovy | 32 |
1 files changed, 24 insertions, 8 deletions
diff --git a/src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.groovy b/src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.groovy index a51c4fe..0c82782 100644 --- a/src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.groovy +++ b/src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.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========================================================= */ @@ -24,6 +26,7 @@ import org.onap.cps.event.model.Content import org.onap.cps.event.model.CpsDataUpdatedEvent import org.onap.cps.event.model.Data import org.onap.cps.temporal.domain.NetworkData +import org.onap.cps.temporal.domain.Operation import spock.lang.Specification import java.time.OffsetDateTime @@ -75,7 +78,7 @@ class CpsDataUpdatedEventMapperSpec extends Specification { then: 'the result entity is not null' result != null and: 'the result entity payload is an empty json ' - result.getPayload() == "{}" + result.getPayload() == '{}' } def 'Mapping an event whose content data is invalid'() { @@ -103,20 +106,33 @@ class CpsDataUpdatedEventMapperSpec extends Specification { .withDataspaceName('a-dataspace') .withSchemaSetName('a-schema-set') .withAnchorName('an-anchor') + .withOperation(Content.Operation.CREATE) .withData(new Data().withAdditionalProperty(aDataName, aDataValue))) when: 'the event is mapped to an entity' NetworkData result = objectUnderTest.eventToEntity(event) then: 'the result entity is not null' result != null and: 'all result entity properties are the ones from the event' - result.getObservedTimestamp() == - OffsetDateTime.parse(event.getContent().getObservedTimestamp(), isoTimestampFormatter) - result.getDataspace() == event.getContent().getDataspaceName() - result.getSchemaSet() == event.getContent().getSchemaSetName() - result.getAnchor() == event.getContent().getAnchorName() + with(result) { + observedTimestamp == + OffsetDateTime.parse(event.getContent().getObservedTimestamp(), isoTimestampFormatter) + dataspace == event.getContent().getDataspaceName() + schemaSet == event.getContent().getSchemaSetName() + operation == Operation.CREATE + anchor == event.getContent().getAnchorName() + createdTimestamp == null + } result.getPayload().contains(aDataValue) result.getPayload().contains(aDataValue) - result.getCreatedTimestamp() == null + } + + def 'Mapping event without operation field' () { + given: 'event without operation field in content' + def cpsDataUpdatedEvent = new CpsDataUpdatedEvent().withContent(new Content()) + when: 'event is mapped to network data' + def networkData = objectUnderTest.eventToEntity(cpsDataUpdatedEvent) + then: 'the operation field has default UPDATE value' + networkData.operation == Operation.UPDATE } private void assertEntityPropertiesAreNull(NetworkData networkData) { |