summaryrefslogtreecommitdiffstats
path: root/cps-ncmp-events
diff options
context:
space:
mode:
authorhalil.cakal <halil.cakal@est.tech>2023-05-08 14:18:26 +0100
committerhalil.cakal <halil.cakal@est.tech>2023-06-01 16:06:35 +0100
commit900261c1935dba87179d2e4aa36cede4826186ca (patch)
tree7ba7991da8af1981e8444fb50bf49c32ffa359ae /cps-ncmp-events
parentec3a1d19456b034593b2a365c044a3904c32e98d (diff)
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>
Diffstat (limited to 'cps-ncmp-events')
-rw-r--r--cps-ncmp-events/src/main/resources/schemas/avc-subscription-event-outcome-v1.json81
1 files changed, 81 insertions, 0 deletions
diff --git a/cps-ncmp-events/src/main/resources/schemas/avc-subscription-event-outcome-v1.json b/cps-ncmp-events/src/main/resources/schemas/avc-subscription-event-outcome-v1.json
new file mode 100644
index 0000000000..34970ac1c3
--- /dev/null
+++ b/cps-ncmp-events/src/main/resources/schemas/avc-subscription-event-outcome-v1.json
@@ -0,0 +1,81 @@
+{
+ "$schema": "https://json-schema.org/draft/2019-09/schema",
+ "$id": "urn:cps:org.onap.cps.ncmp.events:avc-subscription-event-outcome:v1",
+ "$ref": "#/definitions/SubscriptionEventOutcome",
+ "definitions": {
+ "SubscriptionEventOutcome": {
+ "description": "The payload for avc subscription event outcome message.",
+ "type": "object",
+ "javaType" : "org.onap.cps.ncmp.events.avc.subscription.v1.SubscriptionEventOutcome",
+ "properties": {
+ "version": {
+ "description": "The outcome event type version",
+ "type": "string"
+ },
+ "eventType": {
+ "description": "The event type",
+ "type": "string",
+ "enum": [
+ "COMPLETE_OUTCOME",
+ "PARTIAL_OUTCOME"
+ ]
+ },
+ "event": {
+ "$ref": "#/definitions/event"
+ }
+ },
+ "required": [
+ "version",
+ "eventType",
+ "event"
+ ]
+ },
+ "event": {
+ "description": "The event content for outcome message.",
+ "type": "object",
+ "javaType": "InnerSubscriptionEventOutcome",
+ "properties": {
+ "subscription": {
+ "description": "The subscription details.",
+ "type": "object",
+ "properties": {
+ "clientID": {
+ "description": "The clientID",
+ "type": "string"
+ },
+ "name": {
+ "description": "The name of the subscription",
+ "type": "string"
+ }
+ },
+ "required": [
+ "clientID",
+ "name"
+ ]
+ },
+ "predicates": {
+ "description": "Additional values to be added into the subscription outcome",
+ "type": "object",
+ "properties": {
+ "rejectedTargets": {
+ "description": "Rejected CM Handles to be responded by the subscription",
+ "type": "array"
+ },
+ "acceptedTargets": {
+ "description": "Accepted CM Handles to be responded by the subscription",
+ "type": "array"
+ },
+ "pendingTargets": {
+ "description": "Pending CM Handles to be responded by the subscription",
+ "type": "array"
+ }
+ }
+ }
+ },
+ "required": [
+ "subscription",
+ "predicates"
+ ]
+ }
+ }
+} \ No newline at end of file