Skip to content

Commit

Permalink
CM SUBSCRIPTION: Update schemas
Browse files Browse the repository at this point in the history
- updated the cm subscription schemas with proper case as agreed before
  for the events
- fixed the tests to reflect the camelCase change

Issue-ID: CPS-2245
Change-Id: I64fb8b27a5f64280dfa19d86ae310e6b5309de39
Signed-off-by: mpriyank <[email protected]>
  • Loading branch information
mpriyank91 committed May 31, 2024
1 parent 7cb6430 commit daa92d7
Show file tree
Hide file tree
Showing 7 changed files with 24 additions and 24 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
"description": "Information about the targets and subscription",
"additionalProperties": false,
"properties": {
"cmhandles": {
"cmHandles": {
"type": "array",
"items": {
"type": "object",
Expand All @@ -32,7 +32,7 @@
"cmhandleId": {
"type": "string"
},
"private-properties": {
"privateProperties": {
"type": "object",
"existingJavaType": "java.util.Map<String,String>",
"items": {
Expand Down Expand Up @@ -63,7 +63,7 @@
"type": "string",
"enum": ["ncmp-datastore:passthrough-operational", "ncmp-datastore:passthrough-running"]
},
"xpath-filter": {
"xpathFilter": {
"description": "Filter to be applied to the CM Handles through this event",
"type": "array",
"items": {
Expand All @@ -73,7 +73,7 @@
},
"additionalProperties": false,
"required": [
"xpath-filter"
"xpathFilter"
]
}
},
Expand All @@ -86,7 +86,7 @@
}
},
"required": [
"cmhandles",
"cmHandles",
"predicates"
]
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
"type": "string",
"enum": ["ncmp-datastore:passthrough-operational", "ncmp-datastore:passthrough-running"]
},
"xpath-filter": {
"xpathFilter": {
"description": "Filter to be applied to the CM Handles through this event",
"type": "array",
"items": {
Expand All @@ -44,7 +44,7 @@
},
"additionalProperties": false,
"required": [
"xpath-filter"
"xpathFilter"
]
}
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,21 +27,21 @@
"type": "string",
"description": "The unique subscription id"
},
"accepted-targets": {
"acceptedTargets": {
"type": "array",
"description": "List of accepted targets",
"items": {
"type": "string"
}
},
"rejected-targets": {
"rejectedTargets": {
"type": "array",
"description": "List of rejected targets",
"items": {
"type": "string"
}
},
"pending-targets": {
"pendingTargets": {
"type": "array",
"description": "List of pending targets",
"items": {
Expand All @@ -50,9 +50,9 @@
}
},
"required": [
"accepted-targets",
"pending-targets",
"rejected-targets",
"acceptedTargets",
"pendingTargets",
"rejectedTargets",
"subscriptionId"
],
"title": "Data"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@
import lombok.RequiredArgsConstructor;
import org.onap.cps.ncmp.api.impl.events.cmsubscription.model.DmiCmNotificationSubscriptionPredicate;
import org.onap.cps.ncmp.api.impl.inventory.InventoryPersistence;
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.CmHandle;
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.CmNotificationSubscriptionDmiInEvent;
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.Cmhandle;
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.Data;
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.Predicate;
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.ScopeFilter;
Expand All @@ -54,7 +54,7 @@ public CmNotificationSubscriptionDmiInEvent toCmNotificationSubscriptionDmiInEve
new CmNotificationSubscriptionDmiInEvent();
final Data cmSubscriptionData = new Data();
cmSubscriptionData.setPredicates(mapToDmiInEventPredicates(dmiCmNotificationSubscriptionPredicates));
cmSubscriptionData.setCmhandles(mapToCmSubscriptionCmhandleWithPrivateProperties(
cmSubscriptionData.setCmHandles(mapToCmSubscriptionCmhandleWithPrivateProperties(
extractUniqueCmHandleIds(dmiCmNotificationSubscriptionPredicates)));
cmNotificationSubscriptionDmiInEvent.setData(cmSubscriptionData);
return cmNotificationSubscriptionDmiInEvent;
Expand All @@ -81,12 +81,12 @@ private List<Predicate> mapToDmiInEventPredicates(

}

private List<Cmhandle> mapToCmSubscriptionCmhandleWithPrivateProperties(final Set<String> cmHandleIds) {
private List<CmHandle> mapToCmSubscriptionCmhandleWithPrivateProperties(final Set<String> cmHandleIds) {

final List<Cmhandle> cmSubscriptionCmHandles = new ArrayList<>();
final List<CmHandle> cmSubscriptionCmHandles = new ArrayList<>();

inventoryPersistence.getYangModelCmHandles(cmHandleIds).forEach(yangModelCmHandle -> {
final Cmhandle cmhandle = new Cmhandle();
final CmHandle cmhandle = new CmHandle();
final Map<String, String> cmhandleDmiProperties = new LinkedHashMap<>();
yangModelCmHandle.getDmiProperties()
.forEach(dmiProperty -> cmhandleDmiProperties.put(dmiProperty.getName(), dmiProperty.getValue()));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@ import io.cloudevents.CloudEvent
import org.onap.cps.events.EventsPublisher
import org.onap.cps.ncmp.api.impl.events.cmsubscription.producer.CmNotificationSubscriptionDmiInEventProducer
import org.onap.cps.ncmp.api.impl.events.mapper.CloudEventMapper
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.CmHandle
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.CmNotificationSubscriptionDmiInEvent
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.Cmhandle
import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.ncmp_to_dmi.Data
import org.onap.cps.utils.JsonObjectMapper
import spock.lang.Specification
Expand All @@ -43,7 +43,7 @@ class CmNotificationSubscriptionDmiInEventProducerSpec extends Specification {
def subscriptionId = 'test-subscription-id'
def dmiPluginName = 'test-dmiplugin'
def eventType = 'subscriptionCreateRequest'
def cmNotificationSubscriptionDmiInEvent = new CmNotificationSubscriptionDmiInEvent(data: new Data(cmhandles: [new Cmhandle(cmhandleId: 'test-1', privateProperties: [:])]))
def cmNotificationSubscriptionDmiInEvent = new CmNotificationSubscriptionDmiInEvent(data: new Data(cmHandles: [new CmHandle(cmhandleId: 'test-1', privateProperties: [:])]))
and: 'also we have target topic for dmiPlugin'
objectUnderTest.cmNotificationSubscriptionDmiInEventTopic = 'dmiplugin-test-topic'
when: 'the event is published'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,8 +48,8 @@ class CmNotificationSubscriptionDmiInEventMapperSpec extends Specification {
when: 'we try to map the values'
def result = objectUnderTest.toCmNotificationSubscriptionDmiInEvent(dmiCmNotificationSubscriptionPredicates)
then: 'it contains correct cm notification subscription cmhandle object'
assert result.data.cmhandles.cmhandleId.containsAll(['ch-1', 'ch-2'])
assert result.data.cmhandles.privateProperties.containsAll([['k1': 'v1'], ['k2': 'v2']])
assert result.data.cmHandles.cmhandleId.containsAll(['ch-1', 'ch-2'])
assert result.data.cmHandles.privateProperties.containsAll([['k1': 'v1'], ['k2': 'v2']])
and: 'also has the correct dmi cm notification subscription predicates'
assert result.data.predicates.targetFilter.containsAll([['ch-1'], ['ch-2']])

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,14 +6,14 @@
"targetFilter": ["ch1","ch2"],
"scopeFilter": {
"datastore": "ncmp-datastore:passthrough-operational",
"xpath-filter": ["/x1/y1","x2/y2"]
"xpathFilter": ["/x1/y1","x2/y2"]
}
},
{
"targetFilter": ["ch3","ch4"],
"scopeFilter": {
"datastore": "ncmp-datastore:passthrough-operational",
"xpath-filter": ["/x3/y3","x4/y4"]
"xpathFilter": ["/x3/y3","x4/y4"]
}
}
]
Expand Down

0 comments on commit daa92d7

Please sign in to comment.