/*******************************************************************************
 * Copyright 2016-2017 ZTE, Inc. and others.
 * 
 * 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.msb.apiroute.wrapper;

import java.util.List;

import org.onap.msb.apiroute.api.CustomRouteInfo;
import org.onap.msb.apiroute.api.exception.ExtendedInternalServerErrorException;
import org.onap.msb.apiroute.api.exception.ExtendedNotFoundException;
import org.onap.msb.apiroute.wrapper.service.CustomRouteService;
import org.onap.msb.apiroute.wrapper.util.RouteUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CustomRouteServiceWrapper {


    private static final Logger LOGGER = LoggerFactory.getLogger(CustomRouteServiceWrapper.class);

    private static CustomRouteServiceWrapper instance = new CustomRouteServiceWrapper();

    private CustomRouteServiceWrapper() {}

    public static CustomRouteServiceWrapper getInstance() {
        return instance;
    }


    /**
     * @Title: getAllCustomRouteService
     * @Description: TODO(get AllCustomRoute Service)
     * @param: @return
     * @return: CustomRouteInfo[]
     */
    public List<CustomRouteInfo> getAllCustomRouteInstances(String routeWay) {

        RouteUtil.checkRouteWay(routeWay);

        try {
            String customRedisKey = RouteUtil.getMutiRedisKey(RouteUtil.CUSTOMROUTE, routeWay);
            return CustomRouteService.getInstance().getMultiCustomRouteInstances(customRedisKey);

        } catch (Exception e) {
            throw new ExtendedInternalServerErrorException(e.getMessage());
        }


    }



    /**
     * @Title: getCustomRouteInstance
     * @Description: TODO(get CustomRouteInstance by serviceName)
     * @param: @param serviceName
     * @param: @return
     * @return: CustomRouteInfo
     */
    public CustomRouteInfo getCustomRouteInstance(String serviceName, String host, String publish_port,
                    String routeWay) {

        RouteUtil.checkRouteWay(routeWay);

        String customRedisPrefixedKey =
                        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, serviceName, host, publish_port, routeWay);

        CustomRouteInfo customRouteInfo;
        try {
            customRouteInfo = CustomRouteService.getInstance().getCustomRouteInstance(customRedisPrefixedKey);
        } catch (Exception e) {
            LOGGER.error("get customRouteInstance throw exception", e);
            throw new ExtendedInternalServerErrorException("get customRouteInstance throw exception" + e.getMessage());
        }


        if (null == customRouteInfo) {
            throw new ExtendedNotFoundException("customRoute Info not found");

        }

        return customRouteInfo;

    }


    /**
     * @Title updateCustomRouteStatus
     * @Description TODO(update one CustomRoute Status)
     * @param serviceName
     * @param status
     * @return
     * @return RouteResult
     */
    public synchronized CustomRouteInfo updateCustomRouteStatus(String serviceName, String host, String publish_port,
                    String status, String routeWay) {

        RouteUtil.checkRouteWay(routeWay);

        RouteUtil.checkServiceStatus(status);

        String customRedisPrefixedKey =
                        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, serviceName, host, publish_port, routeWay);


        try {
            CustomRouteService.getInstance().updateCustomRouteStatus2Redis(customRedisPrefixedKey, status);
        } catch (Exception e) {
            LOGGER.error("update CustomRoute status  throw exception", e);
            throw new ExtendedInternalServerErrorException(e.getMessage());
        }

        CustomRouteInfo new_customRouteInfo = getCustomRouteInstance(serviceName, host, publish_port, routeWay);

        return new_customRouteInfo;
    }

    /**
     * @Title: saveCustomRouteInstance
     * @Description: TODO(save one CustomRouteInstance)
     * @param: @param CustomRouteInfo
     * @param: @return
     * @return: CustomRouteInfo
     */
    public synchronized CustomRouteInfo saveCustomRouteInstance4Rest(CustomRouteInfo customRouteInfo, String routeWay) {

        RouteUtil.checkRouteWay(routeWay);

        RouteUtil.checkRouterInfoFormat(customRouteInfo);

        try {
            saveCustomRouteInstance(customRouteInfo, routeWay);

        } catch (Exception e) {

            throw new ExtendedInternalServerErrorException("save CustomRouteInfo  fail: [serviceName]"
                            + customRouteInfo.getServiceName() + e.getMessage());
        }

        return customRouteInfo;

    }


    public synchronized CustomRouteInfo saveCustomRouteInstance(CustomRouteInfo customRouteInfo, String routeWay)
                    throws Exception {
        try {
            String customRedisPrefixedKey =
                            RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, customRouteInfo.getServiceName(),
                                            customRouteInfo.getHost(), customRouteInfo.getPublish_port(), routeWay);;


            CustomRouteService.getInstance().saveCustomRouteService2Redis(customRouteInfo, customRedisPrefixedKey);
            LOGGER.info("save CustomRouteInfo [serviceName]" + customRouteInfo.getServiceName() + " [host]"
                            + customRouteInfo.getHost() + " [publish_port]" + customRouteInfo.getPublish_port()
                            + " [routeWay]" + routeWay + " success");

        } catch (Exception e) {
            LOGGER.error("save CustomRouteInfo [serviceName]" + customRouteInfo.getServiceName() + " [host]"
                            + customRouteInfo.getHost() + " [publish_port]" + customRouteInfo.getPublish_port()
                            + " [routeWay]" + routeWay + " throw exception", e);

            throw e;
        }

        return customRouteInfo;

    }


    /**
     * @Title: deleteCustomRoute
     * @Description: TODO(delete one CustomRoute)
     * @param: @param type
     * @param: @param serviceName
     * @param: @param delKey
     * @param: @return
     * @return: void
     */
    public synchronized void deleteCustomRoute(String serviceName, String host, String publish_port, String routeWay) {

        RouteUtil.checkRouteWay(routeWay);

        String customRedisPrefixedKey =
                        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, serviceName, host, publish_port, routeWay);

        try {
            CustomRouteService.getInstance().deleteCustomRouteService2Redis(customRedisPrefixedKey);
            LOGGER.info("delete CustomRouteInfo [serviceName]" + serviceName + " [host]" + host + " [publish_port]"
                            + publish_port + " [routeWay]" + routeWay + " success");

        } catch (ExtendedNotFoundException e) {
            throw e;
        } catch (Exception e) {
            LOGGER.error("delete CustomRouteInfo [serviceName]" + serviceName + " [host]" + host + " [publish_port]"
                            + publish_port + " [routeWay]" + routeWay + " throw exception", e);
            throw new ExtendedInternalServerErrorException(
                            "delete CustomRouteInfo [serviceName]" + serviceName + e.getMessage());
        }



    }
}