Move RefreshConfigTask under tasks
[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 org.oransc.policyagent.clients.A1Client;
24 import org.oransc.policyagent.configuration.ApplicationConfig;
25 import org.oransc.policyagent.configuration.RicConfig;
26 import org.oransc.policyagent.repository.Policies;
27 import org.oransc.policyagent.repository.PolicyTypes;
28 import org.oransc.policyagent.repository.Ric;
29 import org.oransc.policyagent.repository.Rics;
30 import org.oransc.policyagent.repository.Services;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
33 import org.springframework.beans.factory.annotation.Autowired;
34 import org.springframework.core.Ordered;
35 import org.springframework.core.annotation.Order;
36 import org.springframework.stereotype.Service;
37
38 /**
39  * Loads information about RealTime-RICs at startup.
40  */
41 @Service("startupService")
42 @Order(Ordered.HIGHEST_PRECEDENCE)
43 public class StartupService implements ApplicationConfig.Observer {
44
45     private static final Logger logger = LoggerFactory.getLogger(StartupService.class);
46
47     @Autowired
48     ApplicationConfig applicationConfig;
49
50     @Autowired
51     RefreshConfigTask refreshConfigTask;
52
53     @Autowired
54     private Rics rics;
55
56     @Autowired
57     PolicyTypes policyTypes;
58
59     @Autowired
60     private A1Client a1Client;
61
62     @Autowired
63     private Policies policies;
64
65     @Autowired
66     private Services services;
67
68     // Only for unittesting
69     StartupService(ApplicationConfig appConfig, RefreshConfigTask refreshTask, Rics rics, PolicyTypes policyTypes,
70         A1Client a1Client, Policies policies, Services services) {
71         this.applicationConfig = appConfig;
72         this.refreshConfigTask = refreshTask;
73         this.rics = rics;
74         this.policyTypes = policyTypes;
75         this.a1Client = a1Client;
76         this.policies = policies;
77         this.services = services;
78     }
79
80     @Override
81     public void onRicConfigUpdate(RicConfig ricConfig, ApplicationConfig.RicConfigUpdate event) {
82         synchronized (this.rics) {
83             if (event.equals(ApplicationConfig.RicConfigUpdate.ADDED)
84                 || event.equals(ApplicationConfig.RicConfigUpdate.CHANGED)) {
85                 Ric ric = new Ric(ricConfig);
86                 rics.put(ric);
87                 RicRecoveryTask recoveryTask = new RicRecoveryTask(a1Client, policyTypes, policies, services);
88                 recoveryTask.run(ric);
89             } else if (event.equals(ApplicationConfig.RicConfigUpdate.REMOVED)) {
90                 rics.remove(ricConfig.name());
91             } else {
92                 logger.debug("Unhandled event :" + event);
93             }
94         }
95     }
96
97     /**
98      * Reads the configured Rics and performs the service discovery. The result is put into the repository.
99      */
100     public void startup() {
101         logger.debug("Starting up");
102         applicationConfig.addObserver(this);
103         refreshConfigTask.start();
104     }
105
106 }