* limitations under the License.
* ========================LICENSE_END===================================
*/
+
package org.oransc.policyagent;
import com.google.gson.JsonObject;
import org.oransc.policyagent.configuration.ApplicationConfig;
import org.oransc.policyagent.repository.ImmutablePolicyType;
import org.oransc.policyagent.repository.Policies;
+import org.oransc.policyagent.repository.Policy;
import org.oransc.policyagent.repository.PolicyType;
import org.oransc.policyagent.repository.PolicyTypes;
import org.oransc.policyagent.repository.Rics;
}
@Override
- public Flux<String> getAllPolicyTypes(String nearRtRicUrl) {
+ public Flux<String> getPolicyTypeIdentities(String nearRtRicUrl) {
Vector<String> result = new Vector<>();
for (PolicyType p : this.policyTypes.getAll()) {
result.add(p.name());
}
@Override
- public Flux<String> getPoliciesForType(String nearRtRicUrl, String policyTypeId) {
- return Flux.empty();
+ public Flux<String> getPolicyIdentities(String nearRtRicUrl) {
+ Vector<String> result = new Vector<>();
+ for (Policy p : this.policies.getAll()) {
+ result.add(p.id());
+ }
+ return Flux.fromIterable(result);
}
@Override
- public Mono<String> getPolicy(String nearRtRicUrl, String policyId) {
+ public Mono<String> getPolicyType(String nearRtRicUrl, String policyTypeId) {
try {
- return Mono.just(this.policies.get(policyId).json());
+ return Mono.just(this.policyTypes.getType(policyTypeId).toString());
} catch (Exception e) {
return Mono.error(e);
}
try {
String schema = readFile(file);
String typeName = title(schema);
- PolicyType type = ImmutablePolicyType.builder().name(typeName).jsonSchema(schema).build();
+ PolicyType type = ImmutablePolicyType.builder().name(typeName).build();
policyTypes.put(type);
} catch (Exception e) {
System.out.println("Could not load json schema " + e);