2 * Copyright © 2019 Bell Canada Intellectual Property.
3 * Modifications Copyright © 2019 IBM.
4 * Modifications Copyright © 2019 Orange.
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
19 package org.onap.ccsdk.cds.blueprintsprocessor.designer.api
21 import io.swagger.annotations.ApiOperation
22 import io.swagger.annotations.ApiParam
23 import org.jetbrains.annotations.NotNull
24 import org.onap.ccsdk.cds.blueprintsprocessor.db.primary.domain.BlueprintModelSearch
25 import org.onap.ccsdk.cds.blueprintsprocessor.designer.api.handler.BluePrintModelHandler
26 import org.onap.ccsdk.cds.blueprintsprocessor.designer.api.utils.BlueprintSortByOption
27 import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.mdcWebCoroutineScope
28 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintException
29 import org.onap.ccsdk.cds.controllerblueprints.core.asJsonString
30 import org.springframework.core.io.Resource
31 import org.springframework.data.domain.Page
32 import org.springframework.data.domain.PageRequest
33 import org.springframework.data.domain.Sort
34 import org.springframework.http.HttpStatus
35 import org.springframework.http.MediaType
36 import org.springframework.http.ResponseEntity
37 import org.springframework.http.codec.multipart.FilePart
38 import org.springframework.security.access.prepost.PreAuthorize
39 import org.springframework.web.bind.annotation.DeleteMapping
40 import org.springframework.web.bind.annotation.GetMapping
41 import org.springframework.web.bind.annotation.PathVariable
42 import org.springframework.web.bind.annotation.PostMapping
43 import org.springframework.web.bind.annotation.RequestBody
44 import org.springframework.web.bind.annotation.RequestMapping
45 import org.springframework.web.bind.annotation.RequestParam
46 import org.springframework.web.bind.annotation.RequestPart
47 import org.springframework.web.bind.annotation.ResponseBody
48 import org.springframework.web.bind.annotation.RestController
51 * BlueprintModelController Purpose: Handle controllerBlueprint API request
57 @RequestMapping("/api/v1/blueprint-model")
58 open class BlueprintModelController(private val bluePrintModelHandler: BluePrintModelHandler) {
61 path = arrayOf("/bootstrap"), produces = arrayOf(MediaType.APPLICATION_JSON_VALUE),
62 consumes = arrayOf(MediaType.APPLICATION_JSON_VALUE)
65 @Throws(BluePrintException::class)
66 @PreAuthorize("hasRole('USER')")
67 suspend fun bootstrap(@RequestBody bootstrapRequest: BootstrapRequest): Unit = mdcWebCoroutineScope {
68 bluePrintModelHandler.bootstrapBlueprint(bootstrapRequest)
71 @PostMapping("", produces = [MediaType.APPLICATION_JSON_VALUE], consumes = [MediaType.MULTIPART_FORM_DATA_VALUE])
73 @Throws(BluePrintException::class)
74 @PreAuthorize("hasRole('USER')")
75 suspend fun saveBlueprint(@RequestPart("file") filePart: FilePart): BlueprintModelSearch = mdcWebCoroutineScope {
76 bluePrintModelHandler.saveBlueprintModel(filePart)
79 @GetMapping("", produces = [MediaType.APPLICATION_JSON_VALUE])
81 @PreAuthorize("hasRole('USER')")
82 fun allBlueprintModel(): List<BlueprintModelSearch> {
83 return this.bluePrintModelHandler.allBlueprintModel()
86 @GetMapping("/paged", produces = [MediaType.APPLICATION_JSON_VALUE])
88 @PreAuthorize("hasRole('USER')")
89 fun allBlueprintModel(
90 @RequestParam(defaultValue = "20") limit: Int,
91 @RequestParam(defaultValue = "0") offset: Int,
92 @RequestParam(defaultValue = "DATE") sort: BlueprintSortByOption,
93 @RequestParam(defaultValue = "ASC") sortType: String
94 ): Page<BlueprintModelSearch> {
95 val pageRequest = PageRequest.of(offset, limit,
96 Sort.Direction.fromString(sortType), sort.columnName)
97 return this.bluePrintModelHandler.allBlueprintModel(pageRequest)
100 @GetMapping("meta-data/{keyword}", produces = [MediaType.APPLICATION_JSON_VALUE])
102 @PreAuthorize("hasRole('USER')")
103 suspend fun allBlueprintModelMetaData(@NotNull @PathVariable(value = "keyword") keyWord: String): List<BlueprintModelSearch> =
104 mdcWebCoroutineScope {
105 bluePrintModelHandler.searchBluePrintModelsByKeyWord(keyWord)
108 @GetMapping("/paged/meta-data/{keyword}", produces = [MediaType.APPLICATION_JSON_VALUE])
110 @PreAuthorize("hasRole('USER')")
111 fun allBlueprintModelMetaDataPaged(
112 @NotNull @PathVariable(value = "keyword") keyWord: String,
113 @RequestParam(defaultValue = "20") limit: Int,
114 @RequestParam(defaultValue = "0") offset: Int,
115 @RequestParam(defaultValue = "DATE") sort: BlueprintSortByOption,
116 @RequestParam(defaultValue = "ASC") sortType: String
117 ): Page<BlueprintModelSearch> {
118 val pageRequest = PageRequest.of(offset, limit,
119 Sort.Direction.fromString(sortType), sort.columnName)
120 return this.bluePrintModelHandler.searchBluePrintModelsByKeyWordPaged(keyWord, pageRequest)
123 @DeleteMapping("/{id}")
124 @Throws(BluePrintException::class)
125 @PreAuthorize("hasRole('USER')")
126 suspend fun deleteBlueprint(@PathVariable(value = "id") id: String) = mdcWebCoroutineScope {
127 bluePrintModelHandler.deleteBlueprintModel(id)
130 @GetMapping("/by-name/{name}/version/{version}", produces = [MediaType.APPLICATION_JSON_VALUE])
132 @Throws(BluePrintException::class)
133 @PreAuthorize("hasRole('USER')")
134 suspend fun getBlueprintByNameAndVersion(
135 @PathVariable(value = "name") name: String,
136 @PathVariable(value = "version") version: String
137 ): ResponseEntity<BlueprintModelSearch> = mdcWebCoroutineScope {
138 val bluePrintModel: BlueprintModelSearch? =
139 bluePrintModelHandler.getBlueprintModelSearchByNameAndVersion(name, version)
140 if (bluePrintModel != null)
141 ResponseEntity(bluePrintModel, HttpStatus.OK)
143 ResponseEntity(HttpStatus.NO_CONTENT)
146 @GetMapping("/download/by-name/{name}/version/{version}", produces = [MediaType.APPLICATION_JSON_VALUE])
148 @Throws(BluePrintException::class)
149 @PreAuthorize("hasRole('USER')")
150 suspend fun downloadBlueprintByNameAndVersion(
151 @PathVariable(value = "name") name: String,
152 @PathVariable(value = "version") version: String
153 ): ResponseEntity<Resource> = mdcWebCoroutineScope {
154 bluePrintModelHandler.downloadBlueprintModelFileByNameAndVersion(name, version)
157 @GetMapping("/{id}", produces = [MediaType.APPLICATION_JSON_VALUE])
159 @Throws(BluePrintException::class)
160 @PreAuthorize("hasRole('USER')")
161 suspend fun getBlueprintModel(@PathVariable(value = "id") id: String): BlueprintModelSearch = mdcWebCoroutineScope {
162 bluePrintModelHandler.getBlueprintModelSearch(id)
165 @GetMapping("/download/{id}", produces = [MediaType.APPLICATION_JSON_VALUE])
167 @Throws(BluePrintException::class)
168 @PreAuthorize("hasRole('USER')")
169 suspend fun downloadBluePrint(@PathVariable(value = "id") id: String): ResponseEntity<Resource> =
170 mdcWebCoroutineScope {
171 bluePrintModelHandler.downloadBlueprintModelFile(id)
175 "/enrich", produces = [MediaType.APPLICATION_JSON_VALUE], consumes = [MediaType
176 .MULTIPART_FORM_DATA_VALUE]
179 @Throws(BluePrintException::class)
180 @PreAuthorize("hasRole('USER')")
181 suspend fun enrichBlueprint(@RequestPart("file") file: FilePart): ResponseEntity<Resource> = mdcWebCoroutineScope {
182 bluePrintModelHandler.enrichBlueprint(file)
185 @PostMapping("/publish", produces = [MediaType.APPLICATION_JSON_VALUE])
187 @Throws(BluePrintException::class)
188 @PreAuthorize("hasRole('USER')")
189 suspend fun publishBlueprint(@RequestPart("file") file: FilePart): BlueprintModelSearch = mdcWebCoroutineScope {
190 bluePrintModelHandler.publishBlueprint(file)
193 @GetMapping("/search/{tags}", produces = [MediaType.APPLICATION_JSON_VALUE])
195 @PreAuthorize("hasRole('USER')")
196 suspend fun searchBlueprintModels(@PathVariable(value = "tags") tags: String): List<BlueprintModelSearch> =
197 mdcWebCoroutineScope {
198 bluePrintModelHandler.searchBlueprintModels(tags)
201 @DeleteMapping("/name/{name}/version/{version}")
203 value = "Delete a CBA",
204 notes = "Delete the CBA package identified by its name and version.",
205 produces = MediaType.APPLICATION_JSON_VALUE
207 @PreAuthorize("hasRole('USER')")
208 suspend fun deleteBlueprint(
209 @ApiParam(value = "Name of the CBA.", required = true)
210 @PathVariable(value = "name") name: String,
211 @ApiParam(value = "Version of the CBA.", required = true)
212 @PathVariable(value = "version") version: String
213 ) = mdcWebCoroutineScope {
214 bluePrintModelHandler.deleteBlueprintModel(name, version)
218 path = arrayOf("/workflow-spec"), produces = arrayOf(
220 .APPLICATION_JSON_VALUE
222 consumes = arrayOf(MediaType.APPLICATION_JSON_VALUE)
225 @Throws(BluePrintException::class)
226 @PreAuthorize("hasRole('USER')")
227 suspend fun workflowSpec(@RequestBody workFlowSpecReq: WorkFlowSpecRequest):
228 ResponseEntity<String> = mdcWebCoroutineScope {
229 var json = bluePrintModelHandler.prepareWorkFlowSpec(workFlowSpecReq)
231 ResponseEntity(json, HttpStatus.OK)
236 "/workflows/blueprint-name/{name}/version/{version" +
239 produces = arrayOf(MediaType.APPLICATION_JSON_VALUE)
242 @Throws(BluePrintException::class)
243 @PreAuthorize("hasRole('USER')")
244 suspend fun getWorkflowList(
245 @ApiParam(value = "Name of the CBA.", required = true)
246 @PathVariable(value = "name") name: String,
247 @ApiParam(value = "Version of the CBA.", required = true)
248 @PathVariable(value = "version") version: String
249 ): ResponseEntity<String> = mdcWebCoroutineScope {
250 var json = bluePrintModelHandler.getWorkflowNames(name, version)
252 ResponseEntity(json, HttpStatus.OK)