/*-
 * ============LICENSE_START=======================================================
 * SDC
 * ================================================================================
 * Copyright (C) 2019 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.openecomp.sdc.be.components.merge.instance;

import fj.data.Either;
import org.apache.commons.collections.CollectionUtils;
import org.openecomp.sdc.be.components.merge.VspComponentsMergeCommand;
import org.openecomp.sdc.be.components.merge.capability.CapabilityResolver;
import org.openecomp.sdc.be.components.merge.property.DataDefinitionsValuesMergingBusinessLogic;
import org.openecomp.sdc.be.dao.api.ActionStatus;
import org.openecomp.sdc.be.dao.utils.MapUtil;
import org.openecomp.sdc.be.impl.ComponentsUtils;
import org.openecomp.sdc.be.model.CapabilityDefinition;
import org.openecomp.sdc.be.model.Component;
import org.openecomp.sdc.be.model.ComponentInstance;
import org.openecomp.sdc.be.model.ComponentParametersView;
import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade;
import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
import org.openecomp.sdc.common.log.wrappers.Logger;
import org.springframework.core.annotation.Order;

import java.util.List;
import java.util.Map;

import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.ANY_ORDER_COMMAND;

@org.springframework.stereotype.Component
@Order(ANY_ORDER_COMMAND)
public class ComponentCapabilitiesPropertiesMergeBL implements VspComponentsMergeCommand {

    private static final Logger log = Logger.getLogger(ComponentCapabilitiesPropertiesMergeBL.class);

    private final DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic;
    private final ToscaOperationFacade toscaOperationFacade;
    private final ComponentsUtils componentsUtils;
    private final CapabilityResolver capabilityResolver;

    public ComponentCapabilitiesPropertiesMergeBL(DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic, ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, CapabilityResolver capabilityResolver) {
        this.dataDefinitionsValuesMergingBusinessLogic = dataDefinitionsValuesMergingBusinessLogic;
        this.toscaOperationFacade = toscaOperationFacade;
        this.componentsUtils = componentsUtils;
        this.capabilityResolver = capabilityResolver;
    }

    @Override
    public String description() {
        return "merge component instances capabilities properties";
    }

    @Override
    public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
        StorageOperationStatus mergeStatus = getCmptWithCapabilitiesProps(currentComponent.getUniqueId())
                .either(currCmptWithCap -> mergeCmptCalculatedCapabilitiesProperties(prevComponent, currCmptWithCap),
                        err -> err);
        return componentsUtils.convertFromStorageResponse(mergeStatus);
    }

    public ActionStatus mergeComponentInstanceCapabilities(Component currentComponent, Component origInstanceCmpt, String instanceId, List<CapabilityDefinition> prevInstanceCapabilities) {
        if (CollectionUtils.isEmpty(prevInstanceCapabilities)) {
            return ActionStatus.OK;
        }
        Map<CapabilityDefinition, CapabilityDefinition> oldToNewCap = capabilityResolver.resolvePrevCapToNewCapability(currentComponent, origInstanceCmpt, instanceId, prevInstanceCapabilities);
        oldToNewCap.forEach(this::mergeCapabilityProperties);
        StorageOperationStatus updateStatus = updateInstanceCapabilitiesProperties(currentComponent, instanceId);
        return componentsUtils.convertFromStorageResponse(updateStatus);
    }

    private StorageOperationStatus mergeCmptCalculatedCapabilitiesProperties(Component prevComponent, Component currentComponent) {
        List<ComponentInstance> prevInstances = prevComponent.getComponentInstances();
        if (prevInstances == null) {
            return StorageOperationStatus.OK;
        }
        prevInstances.forEach(prevInstance -> mergeInstanceCapabilities(prevInstance, currentComponent));
        return updateComponentCapabilitiesProperties(currentComponent);
    }

    private void mergeInstanceCapabilities(ComponentInstance prevInstance, Component currComponent) {
        ComponentInstance currInstance = MapUtil.toMap(currComponent.getComponentInstances(), ComponentInstance::getName).get(prevInstance.getName());
        Map<CapabilityDefinition, CapabilityDefinition> oldToNewCapabilities = capabilityResolver.resolvePrevCapIdToNewCapability(prevInstance, currInstance);
        oldToNewCapabilities.forEach(this::mergeCapabilityProperties);
    }

    private void mergeCapabilityProperties(CapabilityDefinition prevCapability, CapabilityDefinition currCapability) {
        dataDefinitionsValuesMergingBusinessLogic.mergeInstanceDataDefinitions(prevCapability.getProperties(), currCapability.getProperties());
    }

    private StorageOperationStatus updateComponentCapabilitiesProperties(Component currComponent) {
        return toscaOperationFacade.updateComponentCalculatedCapabilitiesProperties(currComponent);
    }

    private StorageOperationStatus updateInstanceCapabilitiesProperties(Component currComponent, String instanceId) {
        return toscaOperationFacade.updateComponentInstanceCapabilityProperties(currComponent, instanceId);
    }

    private Either<Component, StorageOperationStatus> getCmptWithCapabilitiesProps(String cmptId) {
        ComponentParametersView propertiesCapabilitiesFilter = new ComponentParametersView(true);
        propertiesCapabilitiesFilter.setIgnoreCapabiltyProperties(false);
        propertiesCapabilitiesFilter.setIgnoreComponentInstances(false);
        propertiesCapabilitiesFilter.setIgnoreCapabilities(false);
        propertiesCapabilitiesFilter.setIgnoreGroups(false);
        return toscaOperationFacade.getToscaElement(cmptId, propertiesCapabilitiesFilter)
                .right()
                .map(err -> {
                   log.debug("failed to fetch cmpt {} with properties capabilities. status: {}", cmptId, err);
                   return err;
                });

    }

}