CM Data Subscriptions PoC/Performance test fixes
[cps.git] / cps-ncmp-service / src / main / java / org / onap / cps / ncmp / init / SubscriptionModelLoader.java
1 /*
2  *  ============LICENSE_START=======================================================
3  *  Copyright (C) 2023 Nordix Foundation
4  *  ================================================================================
5  *  Licensed under the Apache License, Version 2.0 (the "License");
6  *  you may not use this file except in compliance with the License.
7  *  You may obtain a copy of the License at
8  *
9  *        http://www.apache.org/licenses/LICENSE-2.0
10  *
11  *  Unless required by applicable law or agreed to in writing, software
12  *  distributed under the License is distributed on an "AS IS" BASIS,
13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  *  See the License for the specific language governing permissions and
15  *  limitations under the License.
16  *
17  *  SPDX-License-Identifier: Apache-2.0
18  *  ============LICENSE_END=========================================================
19  */
20
21 package org.onap.cps.ncmp.init;
22
23 import lombok.extern.slf4j.Slf4j;
24 import org.onap.cps.api.CpsAdminService;
25 import org.onap.cps.api.CpsDataService;
26 import org.onap.cps.api.CpsModuleService;
27 import org.springframework.beans.factory.annotation.Value;
28 import org.springframework.stereotype.Service;
29
30 @Slf4j
31 @Service
32 public class SubscriptionModelLoader extends AbstractModelLoader {
33
34     private static final String MODEL_FILENAME = "subscription.yang";
35     private static final String DATASPACE_NAME = "NCMP-Admin";
36     private static final String ANCHOR_NAME = "AVC-Subscriptions";
37     private static final String SCHEMASET_NAME = "subscriptions";
38     private static final String REGISTRY_DATANODE_NAME = "subscription-registry";
39
40     public SubscriptionModelLoader(final CpsAdminService cpsAdminService,
41                                    final CpsModuleService cpsModuleService,
42                                    final CpsDataService cpsDataService) {
43         super(cpsAdminService, cpsModuleService, cpsDataService);
44     }
45
46     @Value("${ncmp.model-loader.subscription:true}")
47     private boolean subscriptionModelLoaderEnabled;
48
49     @Override
50     public void onboardOrUpgradeModel() {
51         if (subscriptionModelLoaderEnabled) {
52             waitUntilDataspaceIsAvailable(DATASPACE_NAME);
53             onboardSubscriptionModel();
54             log.info("Subscription Model onboarded successfully");
55         } else {
56             log.info("Subscription Model Loader is disabled");
57         }
58     }
59
60     private void onboardSubscriptionModel() {
61         createSchemaSet(DATASPACE_NAME, SCHEMASET_NAME, MODEL_FILENAME);
62         createAnchor(DATASPACE_NAME, SCHEMASET_NAME, ANCHOR_NAME);
63         createTopLevelDataNode(DATASPACE_NAME, ANCHOR_NAME, REGISTRY_DATANODE_NAME);
64     }
65
66 }