[dcaegen2/services/mapper.git] /

/*-\r
 * ============LICENSE_START=======================================================\r
 * ONAP : DCAE\r
 * ================================================================================\r
 * Copyright 2018-2019 TechMahindra\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.universalvesadapter.utils;\r
\r
import java.io.File;\r
import java.io.FileNotFoundException;\r
import java.io.IOException;\r
import java.net.URI;\r
import java.net.URISyntaxException;\r
import java.nio.file.Files;\r
import java.util.HashMap;\r
import java.util.Map;\r
\r
import org.json.simple.JSONArray;\r
import org.json.simple.JSONObject;\r
import org.json.simple.parser.JSONParser;\r
import org.json.simple.parser.ParseException;\r
import org.slf4j.Logger;\r
import org.slf4j.LoggerFactory;\r
import org.springframework.beans.factory.annotation.Autowired;\r
import org.springframework.stereotype.Component;\r
import org.springframework.util.ResourceUtils;\r
\r
import com.fasterxml.jackson.databind.JsonNode;\r
import com.fasterxml.jackson.databind.ObjectMapper;\r
\r
@Component\r
public class CollectorConfigPropertyRetrival {\r
        \r
        \r
        private static final Logger debugLogger = LoggerFactory.getLogger("debugLogger");\r
        private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger");\r
        private static JSONArray array;\r
        @Autowired\r
        private DmaapConfig dmaapConfig;\r
        \r
        public static JSONArray collectorConfigArray(String configFile) {\r
                try {\r
                        JSONParser parser = new JSONParser();\r
                        String content = readFile(configFile);\r
                        JSONObject obj = (JSONObject) parser.parse(content);\r
                        JSONObject appobj = (JSONObject) obj.get("app_preferences");\r
                        array = (JSONArray) appobj.get("collectors");\r
                        \r
                        debugLogger.info("Retrieved JsonArray from Collector Config File");\r
                        \r
                } catch (ParseException e) {\r
                        errorLogger.error("ParseException occured at position:", e.getPosition());\r
                }\r
                \r
                \r
                return array;\r
                \r
        }\r
        \r
        public static String[] getProperyArray(String properyName,\r
                        String defaultConfigFilelocation) {\r
                JSONArray jsonArray = collectorConfigArray(defaultConfigFilelocation);\r
                \r
                String[] propertyArray = new String[jsonArray.size()];\r
                \r
                for (int k = 0; k < jsonArray.size(); k++) {\r
                        \r
                        JSONObject collJson = (JSONObject) jsonArray.get(k);\r
                        \r
                        propertyArray[k] = (String) collJson.get(properyName);\r
                }\r
                debugLogger.info("returning " + properyName + " array from Collector Config");\r
                return propertyArray;\r
                \r
        }\r
        \r
        public Map<String, String> getDmaapTopics(String subscriber, String publisher,\r
                        String defaultConfigFilelocation) {\r
                JSONArray jsonArray = collectorConfigArray(defaultConfigFilelocation);\r
                \r
                Map<String, String> dmaapTopics = new HashMap<>();\r
                \r
                for (int k = 0; k < jsonArray.size(); k++) {\r
                        \r
                        JSONObject collJson = (JSONObject) jsonArray.get(k);\r
                        \r
                        dmaapTopics.put(collJson.get(subscriber).toString(),\r
                                        collJson.get(publisher).toString());\r
                        \r
                }\r
                debugLogger.info("returning Dmaap topics from Collector Config");\r
                return dmaapTopics;\r
                \r
        }\r
        \r
        public Map<String, String> getTopics(String subscriber, String publisher,\r
                        String defaultConfigFilelocation) {\r
                Map<String, String> dmaapTopics = new HashMap<>();\r
                \r
                try {\r
                        \r
                        ObjectMapper objectMapper = new ObjectMapper();\r
                        String content = readFile(defaultConfigFilelocation);\r
                        // read JSON like DOM Parser\r
                        JsonNode rootNode = objectMapper.readTree(content);\r
                        JsonNode subscriberUrl = rootNode.path("streams_subscribes")\r
                                        .path(subscriber).path("dmaap_info").path("topic_url");\r
                        JsonNode publisherUrl = rootNode.path("streams_publishes").path(publisher)\r
                                        .path("dmaap_info").path("topic_url");\r
                        \r
                        dmaapTopics.put(getTopicName(subscriberUrl.asText()),\r
                                        getTopicName(publisherUrl.asText()));\r
                        setDmaapConfig(subscriberUrl.asText());\r
                } catch (IOException ex) {\r
                        errorLogger.error("IOException occured:" + ex.getMessage());\r
                        \r
                } catch (URISyntaxException e) {\r
                        \r
                        errorLogger.error("Invalid URI :" + e.getInput() + ": " + e.getReason());\r
                }\r
                \r
                return dmaapTopics;\r
                \r
        }\r
        \r
        public String getTopicName(String url) throws URISyntaxException {\r
                URI uri = new URI(url);\r
                String path = uri.getPath();\r
                String idStr = path.substring(path.lastIndexOf('/') + 1);\r
                return idStr;\r
                \r
        }\r
        \r
        public void setDmaapConfig(String url) throws URISyntaxException {\r
                URI uri = new URI(url);\r
                dmaapConfig.setDmaaphost(uri.getHost());\r
                dmaapConfig.setDEFAULT_PORT_NUMBER(uri.getPort());\r
                \r
        }\r
        \r
        public static String readFile(String configFileName) {\r
                String content = null;\r
                File file = null;\r
                \r
                try {\r
                        file = ResourceUtils.getFile("classpath:" + configFileName);\r
                        content = new String(Files.readAllBytes(file.toPath()));\r
                } catch (FileNotFoundException e) {\r
                        errorLogger.error("colud not find file :", configFileName);\r
                        \r
                } catch (IOException e) {\r
                        errorLogger.error("unable to read the file , reason:", e.getCause());\r
                }\r
                \r
                return content;\r
                \r
        }\r
}\r