/*-
 * ============LICENSE_START=======================================================
 * VID
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
 * Modifications Copyright (C) 2018 Nokia. 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.vid.services;

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.onap.sdc.tosca.parser.exceptions.SdcToscaParserException;
import org.onap.vid.asdc.AsdcCatalogException;
import org.onap.vid.asdc.AsdcClient;
import org.onap.vid.asdc.beans.Service;
import org.onap.vid.asdc.parser.ToscaParser;
import org.onap.vid.asdc.parser.ToscaParserImpl;
import org.onap.vid.asdc.parser.ToscaParserImpl2;
import org.onap.vid.exceptions.GenericUncheckedException;
import org.onap.vid.model.ServiceModel;
import org.springframework.beans.factory.annotation.Autowired;
import org.togglz.core.manager.FeatureManager;

import java.nio.file.Path;
import java.util.UUID;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

import static org.onap.vid.properties.Features.FLAG_SERVICE_MODEL_CACHE;

/**
 * The Class VidController.
 */

public class VidServiceImpl implements VidService {
    /**
     * The Constant LOG.
     */
    private static final EELFLoggerDelegate LOG = EELFLoggerDelegate.getLogger(VidServiceImpl.class);

    protected final AsdcClient asdcClient;
    private final FeatureManager featureManager;

    @Autowired
    private ToscaParserImpl2 toscaParser;
    private final LoadingCache<String, ServiceModel> serviceModelCache;


    private class NullServiceModelException extends Exception {
        NullServiceModelException(String modelUuid) {
            super("Could not create service model for UUID " + modelUuid);
        }
    }

    public VidServiceImpl(AsdcClient asdcClient, FeatureManager featureManager) {
        this.asdcClient = asdcClient;
        this.featureManager = featureManager;

        this.serviceModelCache = CacheBuilder.newBuilder()
                .maximumSize(1000)
                .expireAfterAccess(7, TimeUnit.DAYS)
                .build(new CacheLoader<String, ServiceModel>() {
                    @Override
                    public ServiceModel load(String modelUuid) throws AsdcCatalogException, NullServiceModelException {
                        ServiceModel serviceModel = getServiceFromSdc(modelUuid);
                        if (serviceModel != null) {
                            return serviceModel;
                        } else {
                            throw new NullServiceModelException(modelUuid);
                        }
                    }
                });
    }

    /*
     * (non-Javadoc)
     *
     * @see org.onap.vid.controller.VidService#getService(java.lang.String)
     */
    @Override
    public ServiceModel getService(String uuid) throws AsdcCatalogException {
        if (featureManager.isActive(FLAG_SERVICE_MODEL_CACHE)) {
            return getServiceFromCache(uuid);
        }else {
            return getServiceFromSdc(uuid);
        }
    }

    private ServiceModel getServiceFromCache(String uuid) throws AsdcCatalogException {
        try {
            return serviceModelCache.get(uuid);
        } catch (ExecutionException e) {
            if (e.getCause() instanceof AsdcCatalogException) {
                throw (AsdcCatalogException) e.getCause();
            } else if (e.getCause() instanceof NullServiceModelException) {
                return null;
            } else {
                throw new GenericUncheckedException(e);
            }
        }
    }

    private ServiceModel getServiceFromSdc(String uuid) throws AsdcCatalogException {
        final Path serviceCsar = asdcClient.getServiceToscaModel(UUID.fromString(uuid));
        ToscaParser tosca = new ToscaParserImpl();
        serviceCsar.toFile().getAbsolutePath();
        ServiceModel serviceModel = null;
        try {
            final Service asdcServiceMetadata = asdcClient.getService(UUID.fromString(uuid));
            return getServiceModel(uuid, serviceCsar, tosca, asdcServiceMetadata);
        } catch (Exception e) {
            LOG.error("Failed to download and process service from SDC", e);
        }
        return serviceModel;
    }

    private ServiceModel getServiceModel(String uuid, Path serviceCsar, ToscaParser tosca, Service asdcServiceMetadata) throws AsdcCatalogException {
        try {
            return toscaParser.makeServiceModel(serviceCsar, asdcServiceMetadata);
        } catch (SdcToscaParserException e) {
            return tosca.makeServiceModel(uuid, serviceCsar, asdcServiceMetadata);
        }
    }
    
    @Override
    public void invalidateServiceCache(){
        serviceModelCache.invalidateAll();
    }

}