X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fcontrollers%2FRicRepositoryController.java;h=38369a84af73f48bdba9d62ffaa2a12cca869647;hb=b40e1b476b25dfdd5ad3ba235ab085d6d4087be3;hp=db17fb21eba0f9333b5b93d1ebe375748907dee7;hpb=bca519150103ccd308dd492e07744bc494a4a4ec;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/controllers/RicRepositoryController.java b/policy-agent/src/main/java/org/oransc/policyagent/controllers/RicRepositoryController.java index db17fb21..38369a84 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/controllers/RicRepositoryController.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/controllers/RicRepositoryController.java @@ -32,7 +32,6 @@ import java.util.Optional; import java.util.Vector; import org.oransc.policyagent.configuration.ApplicationConfig; -import org.oransc.policyagent.configuration.RicConfig; import org.oransc.policyagent.repository.Ric; import org.oransc.policyagent.repository.Rics; import org.springframework.beans.factory.annotation.Autowired; @@ -46,8 +45,6 @@ import org.springframework.web.bind.annotation.RestController; @Api(value = "RIC Management API") public class RicRepositoryController { - private final ApplicationConfig appConfig; - @Autowired private Rics rics; @@ -57,26 +54,25 @@ public class RicRepositoryController { @Autowired RicRepositoryController(ApplicationConfig appConfig) { - this.appConfig = appConfig; } /** - * Example: http://localhost:8080/rics?managedElementId=kista_1 + * Example: http://localhost:8081/rics?managedElementId=kista_1 */ @GetMapping("/ric") @ApiOperation(value = "Returns the name of a RIC managing one Mananged Element") @ApiResponses( value = { // - @ApiResponse(code = 200, message = "RIC is fond"), // - @ApiResponse(code = 404, message = "RIC is not fond") // + @ApiResponse(code = 200, message = "RIC is fond", response = String.class), // + @ApiResponse(code = 404, message = "RIC is not fond", response = String.class) // }) public ResponseEntity getRic( @RequestParam(name = "managedElementId", required = false, defaultValue = "") String managedElementId) { - Optional config = appConfig.lookupRicConfigForManagedElement(managedElementId); + Optional ric = this.rics.lookupRicForManagedElement(managedElementId); - if (config.isPresent()) { - return new ResponseEntity<>(config.get().name(), HttpStatus.OK); + if (ric.isPresent()) { + return new ResponseEntity<>(ric.get().name(), HttpStatus.OK); } else { return new ResponseEntity<>("", HttpStatus.NOT_FOUND); } @@ -84,24 +80,23 @@ public class RicRepositoryController { /** * @return a Json array of all RIC data - * Example: http://localhost:8080/ric + * Example: http://localhost:8081/ric */ @GetMapping("/rics") - @ApiOperation(value = "Returns defined NearRT RIC:s as Json") + @ApiOperation(value = "Query NearRT RIC information") @ApiResponses( value = { // - @ApiResponse(code = 200, message = "OK") // + @ApiResponse(code = 200, message = "OK", response = RicInfo.class, responseContainer = "List") // }) public ResponseEntity getRics( @RequestParam(name = "policyType", required = false) String supportingPolicyType) { + Vector result = new Vector<>(); - for (Ric ric : rics.getRics()) { - if (supportingPolicyType == null || ric.isSupportingType(supportingPolicyType)) { - result.add(ImmutableRicInfo.builder() // - .name(ric.name()) // - .nodeNames(ric.getManagedNodes()) // - .policyTypes(ric.getSupportedPolicyTypeNames()) // - .build()); + synchronized (rics) { + for (Ric ric : rics.getRics()) { + if (supportingPolicyType == null || ric.isSupportingType(supportingPolicyType)) { + result.add(new RicInfo(ric.name(), ric.getManagedElementIds(), ric.getSupportedPolicyTypeNames())); + } } }