/**
 * Copyright (c) 2018 Orange
 *
 * 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.
 */

package org.onap.nbi.apis.serviceinventory;

import java.util.LinkedHashMap;
import java.util.Map;
import javax.annotation.PostConstruct;
import org.onap.nbi.OnapComponentsUrlPaths;
import org.onap.nbi.exceptions.BackendFunctionalException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.stereotype.Service;

@Service
public class AaiClient extends BaseClient {

    public static final String CUSTOMER_ID = "$customerId";

    @Value("${aai.host}")
    private String aaiHost;

    @Value("${aai.header.authorization}")
    private String aaiHeaderAuthorization;

    @Value("${aai.api.id}")
    private String aaiApiId;

    @Value("${aai.header.transaction.id}")
    private String aaiTransactionId;

    private static final String HEADER_AUTHORIZATION = "Authorization";
    private static final String X_FROM_APP_ID = "X-FromAppId";
    private static final Logger LOGGER = LoggerFactory.getLogger(AaiClient.class);
    private static final String X_TRANSACTION_ID = "X-TransactionId";

    private String aaiServiceUrl;
    private String aaiServiceCustomerUrl;
    private String aaiServicesUrl;
    private String aaiServicesInstancesUrl;
    private String aaiHealthCheckUrl;

    @PostConstruct
    private void setUpAndlogAAIUrl() {
        aaiServiceUrl = new StringBuilder().append(aaiHost).append(OnapComponentsUrlPaths.AAI_GET_SERVICE).toString();
        aaiServiceCustomerUrl =
                new StringBuilder().append(aaiHost).append(OnapComponentsUrlPaths.AAI_GET_SERVICE_CUSTOMER).toString();
        aaiServicesUrl = new StringBuilder().append(aaiHost)
                .append(OnapComponentsUrlPaths.AAI_GET_SERVICES_FOR_CUSTOMER_PATH).toString();
        aaiServicesInstancesUrl = new StringBuilder().append(aaiHost)
                .append(OnapComponentsUrlPaths.AAI_GET_SERVICE_INSTANCES_PATH).toString();
        aaiHealthCheckUrl =
                new StringBuilder().append(aaiHost).append(OnapComponentsUrlPaths.AAI_HEALTH_CHECK).toString();

        LOGGER.info("AAI service url :  " + aaiServiceUrl);
        LOGGER.info("AAI services url :  " + aaiServicesUrl);
        LOGGER.info("AAI service instances url :  " + aaiServicesInstancesUrl);
        LOGGER.info("AAI aaiHealthCheckUrl :  " + aaiHealthCheckUrl);

    }

    private HttpHeaders buildRequestHeaderForAAI() {

        HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.add(HEADER_AUTHORIZATION, aaiHeaderAuthorization);
        httpHeaders.add(X_FROM_APP_ID, aaiApiId);
        httpHeaders.add("Accept", "application/json");
        httpHeaders.add("Content-Type", "application/json");
        httpHeaders.add(X_TRANSACTION_ID, aaiTransactionId);

        return httpHeaders;

    }

    public Map getCatalogService(String customerId, String serviceSpecName, String serviceId) {

        String callUrlFormated = aaiServiceUrl.replace(CUSTOMER_ID, customerId);
        callUrlFormated = callUrlFormated.replace("$serviceSpecName", serviceSpecName);
        callUrlFormated = callUrlFormated.replace("$serviceId", serviceId);

        ResponseEntity<Object> response = callApiGet(callUrlFormated, buildRequestHeaderForAAI());
        if (response != null && response.getStatusCode().equals(HttpStatus.OK)) {
            return (LinkedHashMap) response.getBody();
        }
        return null;
    }

    public Map getService(String serviceId) {
        // Retrieve the Service Instance using AAI node query
        String callUrlFormated = aaiServiceUrl.replace("$serviceId", serviceId);
        ResponseEntity<Object> response = callApiGet(callUrlFormated, buildRequestHeaderForAAI());
        if (response != null && response.getStatusCode().equals(HttpStatus.OK)) {
            return (LinkedHashMap) response.getBody();
        }
        return null;
    }

    public Map getServiceCustomer(String serviceId) {

        String callUrlFormated = aaiServiceCustomerUrl.replace("$serviceId", serviceId);
        try {
            ResponseEntity<Object> response = callApiGet(callUrlFormated, buildRequestHeaderForAAI());
            return (LinkedHashMap) response.getBody();
        } catch (BackendFunctionalException e) {
            LOGGER.error("error on calling {} , {}", callUrlFormated.toString(), e);
            return null;
        }
    }

    public void callCheckConnectivity() {
        String customersUrl = new StringBuilder().append(aaiHealthCheckUrl).toString();
        ResponseEntity<String> response = callApiGetHealthCheck(customersUrl, buildRequestHeaderForAAI());
    }

    public Map getVNF(String relatedLink) {

        StringBuilder callURL = new StringBuilder().append(aaiHost).append(relatedLink);
        try {
            ResponseEntity<Object> response = callApiGet(callURL.toString(), buildRequestHeaderForAAI());
            return (LinkedHashMap) response.getBody();
        } catch (BackendFunctionalException e) {
            LOGGER.error("error on calling {} , {}", callURL.toString(), e);
            return null;
        }
    }

    public Map getServicesInAaiForCustomer(String customerId) {
        String callUrlFormated = aaiServicesUrl.replace(CUSTOMER_ID, customerId);
        try {
            ResponseEntity<Object> response = callApiGet(callUrlFormated, buildRequestHeaderForAAI());
            return (LinkedHashMap) response.getBody();
        } catch (BackendFunctionalException e) {
            LOGGER.error("error on calling {} , {}", callUrlFormated, e);
            return null;
        }
    }

    public Map getServiceInstancesInAaiForCustomer(String customerId, String serviceType) {
        String callUrlFormated = aaiServicesInstancesUrl.replace(CUSTOMER_ID, customerId);
        callUrlFormated = callUrlFormated.replace("$serviceSpecName", serviceType);

        try {
            ResponseEntity<Object> response = callApiGet(callUrlFormated, buildRequestHeaderForAAI());
            return (LinkedHashMap) response.getBody();
        } catch (BackendFunctionalException e) {
            LOGGER.error("error on calling {} , {}", callUrlFormated, e);
            return null;
        }
    }
}