- return getPolicyIdentities() //
- .flatMapMany(policyIds -> Flux.fromIterable(policyIds)) // )
- .flatMap(policyId -> deletePolicy(policyId)); //
- }
-
- public Mono<String> deletePolicy(String policyId) {
- JSONObject paramsJson = new JSONObject();
- paramsJson.put("near-rt-ric-url", ricConfig.baseUrl());
- paramsJson.put("policy-id", policyId);
- String inputJsonString = createInputJsonString(paramsJson);
- logger.debug("POST deletePolicy inputJsonString = {}", inputJsonString);
-
- return restClient.postWithAuthHeader("/A1-ADAPTER-API:deletePolicy", inputJsonString, A1_CONTROLLER_USERNAME,
- A1_CONTROLLER_PASSWORD);