Integrating A1 client with service supervision
[nonrtric.git] / policy-agent / src / main / java / org / oransc / policyagent / tasks / StartupService.java
1 /*-
2  * ========================LICENSE_START=================================
3  * O-RAN-SC
4  * %%
5  * Copyright (C) 2019 Nordix Foundation
6  * %%
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ========================LICENSE_END===================================
19  */
20
21 package org.oransc.policyagent.tasks;
22
23 import java.util.Vector;
24
25 import org.oransc.policyagent.clients.RicClient;
26 import org.oransc.policyagent.configuration.ApplicationConfig;
27 import org.oransc.policyagent.configuration.RicConfig;
28 import org.oransc.policyagent.repository.PolicyType;
29 import org.oransc.policyagent.repository.PolicyTypes;
30 import org.oransc.policyagent.repository.Ric;
31 import org.oransc.policyagent.repository.Ric.RicState;
32 import org.oransc.policyagent.repository.Rics;
33 import org.slf4j.Logger;
34 import org.slf4j.LoggerFactory;
35 import org.springframework.beans.factory.annotation.Autowired;
36 import org.springframework.stereotype.Service;
37
38 /**
39  * Loads information about RealTime-RICs at startup.
40  */
41 @Service("startupService")
42 public class StartupService {
43
44     private static final Logger logger = LoggerFactory.getLogger(StartupService.class);
45
46     @Autowired
47     ApplicationConfig applicationConfig;
48
49     @Autowired
50     private Rics rics;
51
52     @Autowired
53     PolicyTypes policyTypes;
54
55     @Autowired
56     private RicClient ricClient;
57
58     StartupService(ApplicationConfig appConfig, Rics rics, PolicyTypes policyTypes, RicClient ricClient) {
59         this.applicationConfig = appConfig;
60         this.rics = rics;
61         this.policyTypes = policyTypes;
62         this.ricClient = ricClient;
63     }
64
65     /**
66      * Reads the configured Rics and performs the service discovery. The result is put into the repository.
67      */
68     public void startup() {
69         applicationConfig.initialize();
70         Vector<RicConfig> ricConfigs = applicationConfig.getRicConfigs();
71         for (RicConfig ricConfig : ricConfigs) {
72             Ric ric = new Ric(ricConfig);
73             String baseUrl = ricConfig.baseUrl();
74             ricClient.deleteAllPolicies(baseUrl);
75             Vector<PolicyType> types = ricClient.getPolicyTypes(baseUrl);
76             for (PolicyType policyType : types) {
77                 if (!policyTypes.contains(policyType)) {
78                     policyTypes.put(policyType);
79                 }
80             }
81             ric.addSupportedPolicyTypes(types);
82             ric.setState(RicState.ACTIVE);
83             rics.put(ric);
84         }
85
86     }
87
88 }