Subscription Create Event Outcome Kafka Part
- Add subscription event outcome schema with java type for pojos
- Add subscription event outcome json for testing
- Add mapper to convert subscription response to event outcome
- Add a bean to handle subscription response outcome tasks
- Change response consumer to publish outcome for client app
- Change response timeout task to publish outcome for client app
- Change subscription persistance to read datanodes
- Add helper to extract cm handle to status mapping from data nodes
event
- Fix code smells
Issue-ID: CPS-1507
Change-Id: I70195073490f456f014e53c1f59d1b6761d18cd4
Signed-off-by: halil.cakal <halil.cakal@est.tech>
diff --git a/cps-ncmp-service/src/test/resources/avcSubscriptionEventResponse.json b/cps-ncmp-service/src/test/resources/avcSubscriptionEventResponse.json
index b054362..3244f05 100644
--- a/cps-ncmp-service/src/test/resources/avcSubscriptionEventResponse.json
+++ b/cps-ncmp-service/src/test/resources/avcSubscriptionEventResponse.json
@@ -4,6 +4,8 @@
"dmiName": "ncmp-dmi-plugin",
"cmHandleIdToStatus": {
"CMHandle1": "ACCEPTED",
- "CMHandle2": "REJECTED"
+ "CMHandle3": "REJECTED",
+ "CMHandle4": "PENDING",
+ "CMHandle5": "PENDING"
}
}
\ No newline at end of file
diff --git a/cps-ncmp-service/src/test/resources/avcSubscriptionOutcomeEvent.json b/cps-ncmp-service/src/test/resources/avcSubscriptionOutcomeEvent.json
new file mode 100644
index 0000000..6bfa36b
--- /dev/null
+++ b/cps-ncmp-service/src/test/resources/avcSubscriptionOutcomeEvent.json
@@ -0,0 +1,21 @@
+{
+ "eventType": "PARTIAL_OUTCOME",
+ "event": {
+ "subscription": {
+ "clientID": "SCO-9989752",
+ "name": "cm-subscription-001"
+ },
+ "predicates": {
+ "rejectedTargets": [
+ "CMHandle3"
+ ],
+ "acceptedTargets": [
+ "CMHandle1"
+ ],
+ "pendingTargets": [
+ "CMHandle4",
+ "CMHandle5"
+ ]
+ }
+ }
+}
\ No newline at end of file