- private Mono<PolicyType> createPolicyType(String policyTypeId, String schema) {
- PolicyType pt = ImmutablePolicyType.builder().name(policyTypeId).schema(schema).build();
- policyTypes.put(pt);
- return Mono.just(pt);
- }
-
- private Mono<PolicyType> addTypeToRic(Ric ric, PolicyType policyType) {
- ric.addSupportedPolicyType(policyType);
- return Mono.just(policyType);
- }
-
- private Mono<Ric> deletePoliciesForRic(Ric ric) {
- if (!Ric.RicState.NOT_REACHABLE.equals(ric.state())) {
- a1Client.getPolicyIdentities(ric.getConfig().baseUrl()) //
- .doOnNext(
- policyId -> logger.debug("Deleting policy: {}, for ric: {}", policyId, ric.getConfig().name()))
- .flatMap(policyId -> a1Client.deletePolicy(ric.getConfig().baseUrl(), policyId)) //
- .subscribe(null, cause -> setRicToNotReachable(ric, cause), null);
- }
-
- return Mono.just(ric);
- }
-
- private void setRicToNotReachable(Ric ric, Throwable t) {
- ric.setState(Ric.RicState.NOT_REACHABLE);
- logger.info("Unable to connect to ric {}. Cause: {}", ric.name(), t.getMessage());
- }
-
- private void setRicToActive(Ric ric) {
- ric.setState(RicState.ACTIVE);
+ /**
+ * Reads the configured Rics and performs the service discovery. The result is put into the repository.
+ */
+ public void startup() {
+ logger.debug("Starting up");
+ applicationConfig.addObserver(this);
+ refreshConfigTask.start();