/*
 *
 *  * ============LICENSE_START=======================================================
 *  *  org.onap.dcae
 *  *  ================================================================================
 *  *  Copyright (c) 2020  AT&T Intellectual Property. All rights reserved.
 *  *  ================================================================================
 *  *  Licensed under the Apache License, Version 2.0 (the "License");
 *  *  you may not use this file except in compliance with the License.
 *  *  You may obtain a copy of the License at
 *  *
 *  *       http://www.apache.org/licenses/LICENSE-2.0
 *  *
 *  *  Unless required by applicable law or agreed to in writing, software
 *  *  distributed under the License is distributed on an "AS IS" BASIS,
 *  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  *  See the License for the specific language governing permissions and
 *  *  limitations under the License.
 *  *  ============LICENSE_END=========================================================
 *
 *
 */

package org.onap.blueprintgenerator.service.common;

import org.onap.blueprintgenerator.constants.Constants;
import org.onap.blueprintgenerator.model.common.GetInput;
import org.onap.blueprintgenerator.model.common.Interfaces;
import org.onap.blueprintgenerator.model.common.Node;
import org.onap.blueprintgenerator.model.common.Properties;
import org.onap.blueprintgenerator.model.componentspec.OnapComponentSpec;
import org.onap.blueprintgenerator.model.componentspec.common.Publishes;
import org.onap.blueprintgenerator.model.componentspec.common.Subscribes;
import org.onap.blueprintgenerator.service.base.BlueprintHelperService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.LinkedHashMap;
import java.util.Map;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.TreeMap;
import java.util.List;


/**
 * @author : Ravi Mantena
 * @date 10/16/2020
 * Application: ONAP - Blueprint Generator
 * Common ONAP Service used by ONAP and DMAAP Blueprint to add ONAP/DMAAP/Feed/Topic Nodes
 */


@Service
public class NodeService {

    @Autowired
    private InterfacesService interfacesService;

    @Autowired
    private PolicyNodeService policyNodeService;

    @Autowired
    private PgaasNodeService pgaasNodeService;

    @Autowired
    private PropertiesService propertiesService;

    @Autowired
    private BlueprintHelperService blueprintHelperService;

    // method to create Onap Node to include interface
    public Map<String,Object> createOnapNode(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec, String override) {

        Map<String,Object> response = new HashMap<>();
        Node onapNode = new Node();

        Map<String, Object> onapResponse = interfacesService.createInterface(inputs, onapComponentSpec);
        inputs = (Map<String, LinkedHashMap<String, Object>>) onapResponse.get("inputs");

        Map<String, Interfaces> interfaces = new TreeMap<>();
        interfaces.put(Constants.CLOUDIFY_INTERFACES_LEFECYCLE, (Interfaces) onapResponse.get("interfaces"));
        onapNode.setInterfaces(interfaces);

        onapNode.setType(Constants.DCAE_NODES_CONTAINERIZED_SERVICE_COMPONENT);

        List<Map<String, String>> relationships = new ArrayList();

        if(onapComponentSpec.getPolicyInfo() != null){
            List<Map<String, String>> policyRelationshipsList = policyNodeService.getPolicyRelationships(onapComponentSpec);
            relationships.addAll(policyRelationshipsList);
        }

        if(onapComponentSpec.getAuxilary().getDatabases() != null){
            List<Map<String, String>> pgaasRelationshipsList = pgaasNodeService.getPgaasNodeRelationships(onapComponentSpec);
            relationships.addAll(pgaasRelationshipsList);
        }

        onapNode.setRelationships(relationships);

        Map<String, Object> propertiesResponse = propertiesService.createOnapProperties(inputs, onapComponentSpec, override);
        inputs = (Map<String, LinkedHashMap<String, Object>>) propertiesResponse.get("inputs");
        onapNode.setProperties((org.onap.blueprintgenerator.model.common.Properties)propertiesResponse.get("properties"));

        response.put("onapNode", onapNode);
        response.put("inputs", inputs);
        return response;
    }

    // method to create Dmaap Node to include interface
    public Map<String,Object> createDmaapNode(OnapComponentSpec onapComponentSpec, Map<String, LinkedHashMap<String, Object>> inputs, String override) {

        Map<String,Object> response = new HashMap<>();
        Node dmaapNode = new Node();

        dmaapNode.setType(Constants.DCAE_NODES_CONTAINERIZED_SERVICE_COMPONENT_USING_DMAAP);

        Map<String, Object> dmaapResponse = interfacesService.createInterface(inputs, onapComponentSpec);
        inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapResponse.get("inputs");

        Map<String, Interfaces> interfaces = new TreeMap<>();
        interfaces.put(Constants.CLOUDIFY_INTERFACES_LEFECYCLE, (Interfaces) dmaapResponse.get("interfaces"));
        dmaapNode.setInterfaces(interfaces);

        List<Map<String, String>> relationships = new ArrayList();

        if(onapComponentSpec.getStreams().getPublishes() != null) {
            for(Publishes publishes: onapComponentSpec.getStreams().getPublishes()) {
                Map<String, String> pubRelations = new LinkedHashMap();
                if(blueprintHelperService.isMessageRouterType(publishes.getType())){
                    pubRelations.put("type", Constants.PUBLISH_EVENTS);
                    pubRelations.put("target", publishes.getConfig_key() + Constants._TOPIC);
                } else if(blueprintHelperService.isDataRouterType(publishes.getType())){
                    pubRelations.put("type", Constants.PUBLISH_FILES);
                    pubRelations.put("target", publishes.getConfig_key() + Constants._FEED);
                }
                relationships.add(pubRelations);
            }
        }

        if(onapComponentSpec.getStreams().getSubscribes() != null) {
            for(Subscribes subscribes: onapComponentSpec.getStreams().getSubscribes()) {
               Map<String, String> subRelations = new LinkedHashMap();
                if(blueprintHelperService.isMessageRouterType(subscribes.getType())){
                    subRelations.put("type", Constants.SUBSCRIBE_TO_EVENTS);
                    subRelations.put("target", subscribes.getConfig_key() + Constants._TOPIC);
                } else  if(blueprintHelperService.isDataRouterType(subscribes.getType())){
                    subRelations.put("type", Constants.SUBSCRIBE_TO_FILES);
                    subRelations.put("target", subscribes.getConfig_key() + Constants._FEED);
                }
                relationships.add(subRelations);
            }
        }

        if(onapComponentSpec.getPolicyInfo() != null){
            List<Map<String, String>> policyRelationshipsList = policyNodeService.getPolicyRelationships(onapComponentSpec);
            relationships.addAll(policyRelationshipsList);
        }

        if(onapComponentSpec.getAuxilary().getDatabases() != null){
            List<Map<String, String>> pgaasRelationshipsList = pgaasNodeService.getPgaasNodeRelationships(onapComponentSpec);
            relationships.addAll(pgaasRelationshipsList);
        }

        dmaapNode.setRelationships(relationships);

        Map<String, Object> propertiesResponse = propertiesService.createDmaapProperties(inputs, onapComponentSpec, override);
        inputs = (Map<String, LinkedHashMap<String, Object>>) propertiesResponse.get("inputs");
        dmaapNode.setProperties((org.onap.blueprintgenerator.model.common.Properties)propertiesResponse.get("properties"));

        response.put("dmaapNode", dmaapNode);
        response.put("inputs", inputs);
        return response;
    }

    // method to create Feed Node for Streams
    public Map<String,Object> createFeedNode(Map<String, LinkedHashMap<String, Object>> inputs, String name){
        Map<String,Object> response = new HashMap<>();
        Node feedNode = new Node();

        LinkedHashMap<String, Object> stringType = new LinkedHashMap();
        stringType.put("type", "string");

        feedNode.setType(Constants.FEED);

        org.onap.blueprintgenerator.model.common.Properties props = new org.onap.blueprintgenerator.model.common.Properties();
        GetInput topicInput = new GetInput();
        topicInput.setBpInputName(name + "_name");
        props.setFeed_name(topicInput);
        props.setUseExisting(true);
        inputs.put(name + "_name", stringType);
        feedNode.setProperties(props);

        response.put("feedNode", feedNode);
        response.put("inputs", inputs);
        return response;
    }

    // method to create Topic Node for Streams
    public Map<String,Object> createTopicNode(Map<String, LinkedHashMap<String, Object>> inputs, String name){
        Map<String,Object> response = new HashMap<>();
        Node topicNode = new Node();

        LinkedHashMap<String, Object> stringType = new LinkedHashMap();
        stringType.put("type", "string");

        topicNode.setType(Constants.TOPIC);

        org.onap.blueprintgenerator.model.common.Properties props = new Properties();
        GetInput topicInput = new GetInput();
        topicInput.setBpInputName(name + "_name");
        props.setTopic_name(topicInput);
        inputs.put(name + "_name", stringType);
        topicNode.setProperties(props);

        response.put("topicNode", topicNode);
        response.put("inputs", inputs);
        return response;
    }


}