2 * Copyright © 2019 Bell Canada
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org.onap.ccsdk.cds.blueprintsprocessor.resource.api
19 import com.fasterxml.jackson.databind.JsonNode
20 import io.swagger.annotations.Api
21 import io.swagger.annotations.ApiOperation
22 import io.swagger.annotations.ApiParam
23 import kotlinx.coroutines.runBlocking
24 import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.db.ResourceResolution
25 import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.db.ResourceResolutionDBService
26 import org.onap.ccsdk.cds.controllerblueprints.core.httpProcessorException
27 import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
28 import org.onap.ccsdk.cds.error.catalog.core.ErrorCatalogCodes
29 import org.springframework.http.MediaType
30 import org.springframework.http.ResponseEntity
31 import org.springframework.security.access.prepost.PreAuthorize
32 import org.springframework.web.bind.annotation.RequestMapping
33 import org.springframework.web.bind.annotation.RequestMethod
34 import org.springframework.web.bind.annotation.RequestParam
35 import org.springframework.web.bind.annotation.ResponseBody
36 import org.springframework.web.bind.annotation.RestController
39 @RequestMapping("/api/v1/resources")
42 description = "Interaction with resolved resources."
44 open class ResourceController(private var resourceResolutionDBService: ResourceResolutionDBService) {
47 path = ["/health-check"],
48 method = [RequestMethod.GET],
49 produces = [MediaType.APPLICATION_JSON_VALUE]
52 @ApiOperation(value = "Health Check", hidden = true)
53 fun resourceControllerHealthCheck(): JsonNode = runBlocking {
54 JacksonUtils.getJsonNode("Success")
59 method = [RequestMethod.GET], produces = [MediaType.APPLICATION_JSON_VALUE]
62 value = "Get all resolved resources using the resolution key. ",
63 notes = "Retrieve all stored resolved resources using the blueprint name, blueprint version, " +
64 "artifact name and the resolution-key.",
65 response = ResourceResolution::class,
66 responseContainer = "List",
67 produces = MediaType.APPLICATION_JSON_VALUE
70 @PreAuthorize("hasRole('USER')")
71 fun getAllFromResolutionKeyOrFromResourceTypeAndId(
72 @ApiParam(value = "Name of the CBA.", required = true)
73 @RequestParam(value = "bpName", required = true) bpName: String,
74 @ApiParam(value = "Version of the CBA.", required = true)
75 @RequestParam(value = "bpVersion", required = true) bpVersion: String,
76 @ApiParam(value = "Artifact name for which to retrieve a resolved resource.", required = true)
77 @RequestParam(value = "artifactName", required = false, defaultValue = "") artifactName: String,
78 @ApiParam(value = "Resolution Key associated with the resolution.", required = false)
79 @RequestParam(value = "resolutionKey", required = false, defaultValue = "") resolutionKey: String,
80 @ApiParam(value = "Resource Type associated with the resolution.", required = false)
81 @RequestParam(value = "resourceType", required = false, defaultValue = "") resourceType: String,
82 @ApiParam(value = "Resource Id associated with the resolution.", required = false)
83 @RequestParam(value = "resourceId", required = false, defaultValue = "") resourceId: String
85 ResponseEntity<List<ResourceResolution>> = runBlocking {
87 if ((resolutionKey.isNotEmpty() || artifactName.isNotEmpty()) && (resourceId.isNotEmpty() || resourceType.isNotEmpty())) {
88 throw httpProcessorException(
89 ErrorCatalogCodes.REQUEST_NOT_FOUND, ResourceApiDomains.RESOURCE_API,
90 "Either retrieve resolved value using artifact name and resolution-key OR using resource-id and resource-type."
92 } else if (resolutionKey.isNotEmpty() && artifactName.isNotEmpty()) {
94 .body(resourceResolutionDBService.readWithResolutionKey(bpName, bpVersion, artifactName, resolutionKey))
95 } else if (resourceType.isNotEmpty() && resourceId.isNotEmpty()) {
98 resourceResolutionDBService.readWithResourceIdAndResourceType(
106 throw httpProcessorException(
107 ErrorCatalogCodes.REQUEST_NOT_FOUND, ResourceApiDomains.RESOURCE_API,
108 "Missing param. Either retrieve resolved value using artifact name and resolution-key OR using resource-id and resource-type."
115 method = [RequestMethod.DELETE], produces = [MediaType.APPLICATION_JSON_VALUE]
118 value = "Delete resources using resolution key",
119 notes = "Delete all the resources associated to a resolution-key using blueprint metadata, artifact name and the resolution-key."
121 @PreAuthorize("hasRole('USER')")
122 fun deleteByBlueprintNameAndBlueprintVersionAndArtifactNameAndResolutionKey(
123 @ApiParam(value = "Name of the CBA.", required = true)
124 @RequestParam(value = "bpName", required = true) bpName: String,
125 @ApiParam(value = "Version of the CBA.", required = true)
126 @RequestParam(value = "bpVersion", required = true) bpVersion: String,
127 @ApiParam(value = "Artifact name for which to retrieve a resolved resource.", required = true)
128 @RequestParam(value = "artifactName", required = false, defaultValue = "") artifactName: String,
129 @ApiParam(value = "Resolution Key associated with the resolution.", required = true)
130 @RequestParam(value = "resolutionKey", required = true) resolutionKey: String
134 resourceResolutionDBService.deleteByBlueprintNameAndBlueprintVersionAndArtifactNameAndResolutionKey(
144 path = ["/resource"],
145 method = [RequestMethod.GET],
146 produces = [MediaType.APPLICATION_JSON_VALUE]
149 value = "Fetch a resource value using resolution key.",
150 notes = "Retrieve a stored resource value using the blueprint metadata, artifact name, resolution-key along with the name of the resource value to retrieve."
153 @PreAuthorize("hasRole('USER')")
154 fun getOneFromResolutionKey(
155 @ApiParam(value = "Name of the CBA.", required = true)
156 @RequestParam(value = "bpName", required = true) bpName: String,
157 @ApiParam(value = "Version of the CBA.", required = true)
158 @RequestParam(value = "bpVersion", required = true) bpVersion: String,
159 @ApiParam(value = "Artifact name for which to retrieve a resolved resource.", required = true)
160 @RequestParam(value = "artifactName", required = true) artifactName: String,
161 @ApiParam(value = "Resolution Key associated with the resolution.", required = true)
162 @RequestParam(value = "resolutionKey", required = true) resolutionKey: String,
163 @ApiParam(value = "Name of the resource to retrieve.", required = true)
164 @RequestParam(value = "name", required = true) name: String
166 ResponseEntity<ResourceResolution> = runBlocking {
169 .body(resourceResolutionDBService.readValue(bpName, bpVersion, artifactName, resolutionKey, name))