[dcaegen2/services.git] /

/*\r
 * ============LICENSE_START=======================================================\r
 * ONAP : DataLake\r
 * ================================================================================\r
 * Copyright 2019 China Mobile\r
 *=================================================================================\r
 * Licensed under the Apache License, Version 2.0 (the "License");\r
 * you may not use this file except in compliance with the License.\r
 * You may obtain a copy of the License at\r
 *\r
 *     http://www.apache.org/licenses/LICENSE-2.0\r
 *\r
 * Unless required by applicable law or agreed to in writing, software\r
 * distributed under the License is distributed on an "AS IS" BASIS,\r
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
 * See the License for the specific language governing permissions and\r
 * limitations under the License.\r
 * ============LICENSE_END=========================================================\r
 */\r
\r
package org.onap.datalake.feeder.service;\r
\r
import java.util.HashMap;\r
import java.util.List;\r
import java.util.Map;\r
import java.util.Optional;\r
\r
import com.google.gson.Gson;\r
import org.onap.datalake.feeder.config.ApplicationConfiguration;\r
import org.onap.datalake.feeder.domain.DesignType;\r
import org.onap.datalake.feeder.domain.Portal;\r
import org.onap.datalake.feeder.domain.PortalDesign;\r
import org.onap.datalake.feeder.domain.Topic;\r
import org.onap.datalake.feeder.dto.PortalDesignConfig;\r
import org.onap.datalake.feeder.repository.DesignTypeRepository;\r
import org.onap.datalake.feeder.repository.PortalDesignRepository;\r
import org.onap.datalake.feeder.util.HttpClientUtil;\r
import org.springframework.beans.factory.annotation.Autowired;\r
import org.springframework.stereotype.Service;\r
\r
/**\r
 * Service for portalDesigns\r
 *\r
 * @author guochunmeng\r
 */\r
\r
@Service\r
public class PortalDesignService {\r
        \r
    @Autowired\r
    private PortalDesignRepository portalDesignRepository;\r
\r
    @Autowired\r
        private TopicService topicService;\r
\r
        @Autowired\r
        private DesignTypeRepository designTypeRepository;\r
\r
        @Autowired\r
        private ApplicationConfiguration applicationConfiguration;\r
\r
        public PortalDesign fillPortalDesignConfiguration(PortalDesignConfig portalDesignConfig) throws Exception\r
        {\r
                PortalDesign portalDesign = new PortalDesign();\r
                fillPortalDesign(portalDesignConfig, portalDesign);\r
                return portalDesign;\r
        }\r
        public void fillPortalDesignConfiguration(PortalDesignConfig portalDesignConfig, PortalDesign portalDesign) throws Exception\r
        {\r
                fillPortalDesign(portalDesignConfig, portalDesign);\r
        }\r
\r
        private void fillPortalDesign(PortalDesignConfig portalDesignConfig, PortalDesign portalDesign) throws IllegalArgumentException {\r
\r
                portalDesign.setId(portalDesignConfig.getId());\r
\r
                portalDesign.setBody(portalDesignConfig.getBody());\r
\r
                portalDesign.setName(portalDesignConfig.getName());\r
\r
                portalDesign.setNote(portalDesignConfig.getNote());\r
\r
                portalDesign.setSubmitted(portalDesignConfig.getSubmitted());\r
\r
                if (portalDesignConfig.getTopic() != null) {\r
                        Topic topic = topicService.getTopic(portalDesignConfig.getTopic());\r
                        if (topic == null) throw new IllegalArgumentException("topic is null");\r
                        portalDesign.setTopic(topic);\r
                }else {\r
                        throw new IllegalArgumentException("Can not find topic in DB, topic name: "+portalDesignConfig.getTopic());\r
                }\r
\r
                if (portalDesignConfig.getDesignType() != null) {\r
                        DesignType designType = designTypeRepository.findById(portalDesignConfig.getDesignType()).get();\r
                        if (designType == null) throw new IllegalArgumentException("designType is null");\r
                        portalDesign.setDesignType(designType);\r
                }else {\r
                        throw new IllegalArgumentException("Can not find designType in Design_type, designType name "+portalDesignConfig.getDesignType());\r
                }\r
\r
        }\r
\r
        \r
        public PortalDesign getPortalDesign(Integer id) {\r
                \r
                Optional<PortalDesign> ret = portalDesignRepository.findById(id);\r
                return ret.isPresent() ? ret.get() : null;\r
        }\r
\r
\r
        private String kibanaImportUrl(String host, Integer port){\r
                return "http://"+host+":"+port+applicationConfiguration.getKibanaDashboardImportApi();\r
        }\r
\r
\r
        public boolean deployKibanaImport(PortalDesign portalDesign) {\r
                boolean flag = false;\r
                String requestBody = portalDesign.getBody();\r
                Portal portal = portalDesign.getDesignType().getPortal();\r
                String portalHost = portal.getHost();\r
                Integer portalPort = portal.getPort();\r
                String url = "";\r
\r
                if (portalHost == null || portalPort == null) {\r
                        String dbHost = portal.getDb().getHost();\r
                        Integer dbPort = portal.getDb().getPort();\r
                        url = kibanaImportUrl(dbHost, dbPort);\r
                } else {\r
                        url = kibanaImportUrl(portalHost, portalPort);\r
                }\r
\r
                //Send httpclient to kibana\r
                String kibanaResponse = HttpClientUtil.sendPostToKibana(url, requestBody);\r
                Gson gson = new Gson();\r
                Map<String, Object> map = new HashMap<>();\r
                map = gson.fromJson(kibanaResponse, map.getClass());\r
                List objectsList = (List) map.get("objects");\r
\r
                if (objectsList != null && objectsList.size() > 0) {\r
                        Map<String, Object> map2 = new HashMap<>();\r
                        for (int i = 0; i < objectsList.size(); i++){\r
                                map2 = (Map<String, Object>)objectsList.get(i);\r
                                for(String key : map2.keySet()){\r
                                        if ("error".equals(key)) {\r
                                                return true;\r
                                        }\r
                                }\r
                        }\r
                }\r
                return flag;\r
        }\r
\r
}\r