gerrit.onap Code Review - dcaegen2/services.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : DataLake
   4  * ================================================================================
   5  * Copyright 2019 China Mobile
   6  *=================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *     http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.datalake.feeder.controller;
  22
  23 import org.onap.datalake.feeder.controller.domain.PostReturnBody;
  24 import org.onap.datalake.feeder.domain.Design;
  25 import org.onap.datalake.feeder.dto.DesignConfig;
  26 import org.onap.datalake.feeder.repository.DesignRepository;
  27 import org.onap.datalake.feeder.service.DesignService;
  28 import org.slf4j.Logger;
  29 import org.slf4j.LoggerFactory;
  30 import org.springframework.beans.factory.annotation.Autowired;
  31 import org.springframework.http.MediaType;
  32 import org.springframework.validation.BindingResult;
  33 import org.springframework.web.bind.annotation.*;
  34
  35 import io.swagger.annotations.ApiOperation;
  36
  37 import java.io.IOException;
  38 import java.util.List;
  39
  40 import javax.servlet.http.HttpServletResponse;
  41
  42
  43 /**
  44  * This controller manages design settings
  45  *
  46  * @author guochunmeng
  47  */
  48 @RestController
  49 @RequestMapping(value = "/designs", produces = MediaType.APPLICATION_JSON_VALUE)
  50 public class DesignController {
  51
  52     private final Logger log = LoggerFactory.getLogger(this.getClass());
  53
  54     @Autowired
  55     private DesignRepository designRepository;
  56
  57     @Autowired
  58     private DesignService designService;
  59
  60         @PostMapping("")
  61         @ResponseBody
  62         @ApiOperation(value="Create a design.")
  63     public PostReturnBody<DesignConfig> createDesign(@RequestBody DesignConfig designConfig, BindingResult result, HttpServletResponse response) throws IOException {
  64
  65                 if (result.hasErrors()) {
  66                         sendError(response, 400, "Error parsing DesignConfig: "+result.toString());
  67                         return null;
  68                 }
  69
  70                 Design design = null;
  71                 try {
  72                         design = designService.fillDesignConfiguration(designConfig);
  73                 } catch (Exception e) {
  74                         log.debug("FillDesignConfiguration failed", e.getMessage());
  75                         sendError(response, 400, "Error FillDesignConfiguration: "+e.getMessage());
  76                         return null;
  77                 }
  78                 designRepository.save(design);
  79                 log.info("Design save successed");
  80                 return mkPostReturnBody(200, design);
  81     }
  82
  83
  84         @PutMapping("{id}")
  85         @ResponseBody
  86         @ApiOperation(value="Update a design.")
  87         public PostReturnBody<DesignConfig> updateDesign(@RequestBody DesignConfig designConfig, BindingResult result, @PathVariable Integer id, HttpServletResponse response) throws IOException {
  88
  89                 if (result.hasErrors()) {
  90                         sendError(response, 400, "Error parsing DesignConfig: "+result.toString());
  91                         return null;
  92                 }
  93
  94                 Design design = designService.getDesign(id);
  95                 if (design != null) {
  96                         try {
  97                                 designService.fillDesignConfiguration(designConfig, design);
  98                         } catch (Exception e) {
  99                                 log.debug("FillDesignConfiguration failed", e.getMessage());
 100                                 sendError(response, 400, "Error FillDesignConfiguration: "+e.getMessage());
 101                                 return null;
 102                         }
 103                         designRepository.save(design);
 104                         log.info("Design update successed");
 105                         return mkPostReturnBody(200, design);
 106                 } else {
 107                         sendError(response, 400, "Design not found: "+id);
 108                         return null;
 109                 }
 110
 111         }
 112
 113
 114         @DeleteMapping("/{id}")
 115         @ResponseBody
 116         @ApiOperation(value="delete a design.")
 117     public void deleteDesign(@PathVariable("id") Integer id, HttpServletResponse response) throws IOException{
 118
 119                 Design oldDesign = designService.getDesign(id);
 120                 if (oldDesign == null) {
 121                         sendError(response, 400, "design not found "+id);
 122                 } else {
 123                         designRepository.delete(oldDesign);
 124                         response.setStatus(204);
 125                 }
 126     }
 127
 128
 129         @GetMapping("")
 130         @ResponseBody
 131         @ApiOperation(value="List all Designs")
 132     public List<DesignConfig> queryAllDesign(){
 133                 return designService.queryAllDesign();
 134     }
 135
 136
 137         @PostMapping("/deploy/{id}")
 138         @ResponseBody
 139         @ApiOperation(value="Design deploy")
 140         public void deployDesign(@PathVariable Integer id, HttpServletResponse response) throws IOException {
 141
 142                 Design design = null;
 143                 try {
 144                         design = designRepository.findById(id).get();
 145                         boolean flag;
 146                         try {
 147                                 flag = designService.deploy(design);
 148                                 if (flag) {
 149                                         design.setSubmitted(true);
 150                                         designRepository.save(design);
 151                                         response.setStatus(204);
 152                                 } else {
 153                                         sendError(response, 400, "DeployDesign failed, id: "+id);
 154                                 }
 155                         } catch (Exception e) {
 156                                 log.debug("The request failed", e.getMessage());
 157                                 sendError(response, 400, "The request failed : "+e.getMessage());
 158                         }
 159                 } catch (Exception e) {
 160                         log.debug("Design is null", e.getMessage());
 161                         sendError(response, 400, "Design not found, id: "+id);
 162                 }
 163
 164         }
 165
 166
 167         private PostReturnBody<DesignConfig> mkPostReturnBody(int statusCode, Design design) {
 168                 PostReturnBody<DesignConfig> retBody = new PostReturnBody<>();
 169         retBody.setStatusCode(statusCode);
 170         retBody.setReturnBody(design.getDesignConfig());
 171         return retBody;
 172         }
 173
 174         private void sendError(HttpServletResponse response, int sc, String msg) throws IOException {
 175                 log.info(msg);
 176                 response.sendError(sc, msg);
 177         }
 178
 179 }