CM Subscription

Developed (Increments)

Description

Notes

Subscription Schemas

Ref: cps-ncmp-events/src/main/resources/schemas/cmnotificationsubscription

DME to NCMP Subscription Request
- cm-notification-subscription-ncmp-in-event-schema-1.0.0.json
NCMP to DMI-Plugin Subscription Request
- cm-notification-subscription-dmi-in-event-schema-1.0.0.json
DMI-Plugin to NCMP Subscription Response
- cm-notification-subscription-dmi-out-event-schema-1.0.0.json
NCMP to DME Subscription Response
- cm-notification-subscription-ncmp-out-event-schema-1.0.0.json

Subscription YANG model

cmNotificationSubscriptionCache

Hazelcast map to hold the incoming subscription create request

Key

Value

Unique Subscription Id

Key	Value
Dmi-Plugin Name	DmiCmNotificationSubscriptionDetails
Dmi-Plugin Name	DmiCmNotificationSubscriptionDetails

NCMP Startup

Ref: CmSubscriptionModelLoader

Client To NCMP

Ref: CmNotificationSubscriptionNcmpInEventConsumer

NCMP to DMI

Ref: CmNotificationSubscriptionPersistenceService

06 Feb 2024Method to fetch ongoing subscription in database via datastore Type, cmHandle ID, xpath

Ref: CmNotificationSubscriptionDmiInEventMapper

	User Story	Tasks
1	Analysis - Merging of Subscriptions ( Positive Scenarios )
2	Update Subscription Event Schemas for Subscription Merge Use Case
3	Create POC for Merge subscriptions datastore logic
4	Onboard subscription model for merging	Deprecate use of basic subscription model Create Datastores in NCMP w/ subscription model
5	Create Client to NCMP flow	Inmemory Datastructure to track Subscription Read and validate incoming sub create request from Kafka Populate hazelcast map with cmSubscriptions Check for Subscription ID uniqueness Validate datastore Compare Active Subscriptions (DB) with the current request
6	Create NCMP to DMI flow	Create CmSubscriptionPredicate to CmSubscriptionDmiInEvent mapper Publish the CmNotificationDmiInEvent to DMI Plugin Check/Fetch ongoing cm subscription from database
7	Create DMI to NCMP flow	CmSubscription service layer methods Save new subscription to database Kafka consumer to read message from DMI Plugin Read and send response (DMI <>NCMP) Handle response from DMI
8	Create NCMP to Client flow	Producer to send the response to client