CM Subscription

Developed (Increments)

Description

Notes

Subscription Schemas

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

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

See schema definitions in Impl. Proposal for Merging of Subscriptions ( Positive Scenarios )

Subscription YANG model

Ref: cps-ncmp-service/src/main/resources/models/cm-data-subscriptions@2023-11-13.yang

See Use of Subscription model

cmSubscriptionEventCache

Hazelcast map to hold the incoming subscription create request

For comparison of in-database active subscriptions
For tracking of subscription request to DMI (Accepted, Rejected, Pending)

Key

Value

Unique Subscription Id

Key	Value
Dmi-Plugin Name	CmSubscriptionCompositeObject

CmSubscriptionCompositeObject

CmSubscriptionCompositeObject
    CmSubscriptionPredicate list
     - targetFilter : (List of cmHandles - Subscription request incoming cmhandles grouped using target dmiPlugin)
     - Status ( Accepted , Rejected or Pending ) - initially Pending
     - scopeFilter :
            Datastore ( passthrough-operational and passthrough-running )
            List of xpaths

Tracking Subscriptions in memory

NCMP Startup

Ref: CmSubscriptionModelLoader

Onboarding of Subscription model
Initialises parent node for the model
Initialises datastores

See Use of Subscription model

Client To NCMP

22 Jan 2024 Reads incoming subscription message

Backlog

	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 Validate Subscription ID Compare Active Subscriptions (DB) with the current request
6	Create NCMP to DMI flow	Fetch subscription data from database
7	Create DMI to NCMP flow	CmSubscription service layer methods Save new subscription to database Read and send response (DMI <>NCMP) Handle response from DMI
8	Create NCMP to Client flow