/*
 * Copyright (c) 2017 HPE, Inc. and others. All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
 * and is available at http://www.eclipse.org/legal/epl-v10.html
 */
package org.opendaylight.netvirt.statistics;

import java.math.BigInteger;
import java.util.ArrayList;
import java.util.List;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
import org.opendaylight.genius.mdsalutil.ActionInfo;
import org.opendaylight.genius.mdsalutil.InstructionInfo;
import org.opendaylight.genius.mdsalutil.MDSALUtil;
import org.opendaylight.genius.mdsalutil.MatchInfoBase;
import org.opendaylight.genius.mdsalutil.NwConstants;
import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceModeIngress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.services.info.BoundServices;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;

public class IngressCountersServiceImpl extends AbstractCountersService {

    public IngressCountersServiceImpl(DataBroker db, IInterfaceManager interfaceManager,
            IMdsalApiManager mdsalApiManager) {
        super(db, interfaceManager, mdsalApiManager);
    }

    @Override
    public void bind(String interfaceId) {
        int instructionKey = 0;
        List<Instruction> instructions = new ArrayList<>();
        instructions
                .add(MDSALUtil.buildAndGetGotoTableInstruction(NwConstants.INGRESS_COUNTERS_TABLE, ++instructionKey));
        BoundServices serviceInfo =
                CountersServiceUtils.getBoundServices(String.format("%s.%s", "counters-ingress", interfaceId),
                        CountersServiceUtils.INGRESS_COUNTERS_SERVICE_INDEX,
                        CountersServiceUtils.INGRESS_COUNTERS_DEFAULT_FLOW_PRIORITY,
                        CountersServiceUtils.COOKIE_COUNTERS_BASE, instructions);
        InstanceIdentifier<BoundServices> serviceId = CountersServiceUtils.buildServiceId(interfaceId,
                CountersServiceUtils.INGRESS_COUNTERS_SERVICE_INDEX, ServiceModeIngress.class);
        MDSALUtil.syncWrite(db, LogicalDatastoreType.CONFIGURATION, serviceId, serviceInfo);
    }

    @Override
    public void installDefaultCounterRules(String interfaceId) {
        BigInteger dpn = interfaceManager.getDpnForInterface(interfaceId);
        String defaultFlowName = CountersServiceUtils.DEFAULT_INGRESS_COUNTER_FLOW_PREFIX + dpn + interfaceId;
        List<MatchInfoBase> defaultFlowMatches = new ArrayList<>();
        List<ActionInfo> actionsInfos = new ArrayList<>();
        List<InstructionInfo> instructions = CountersServiceUtils.getDispatcherTableResubmitInstructions(actionsInfos,
                ElementCountersDirection.INGRESS);
        syncFlow(dpn, NwConstants.INGRESS_COUNTERS_TABLE, defaultFlowName,
                CountersServiceUtils.COUNTER_TABLE_DEFAULT_FLOW_PRIORITY, CountersServiceUtils.COUNTER_FLOW_NAME, 0, 0,
                CountersServiceUtils.COOKIE_COUNTERS_BASE, defaultFlowMatches, instructions, NwConstants.ADD_FLOW);
    }

    @Override
    public void syncCounterFlows(ElementCountersRequest ecr, int operation) {
        int lportTag = ecr.getLportTag();
        List<MatchInfoBase> flowMatches =
                CountersServiceUtils.getCounterFlowMatch(ecr, lportTag, ElementCountersDirection.INGRESS);
        List<ActionInfo> actionsInfos = new ArrayList<>();
        List<InstructionInfo> instructions = CountersServiceUtils.getDispatcherTableResubmitInstructions(actionsInfos,
                ElementCountersDirection.INGRESS);

        BigInteger dpn = ecr.getDpn();
        String flowName = createFlowName(ecr, lportTag, dpn);

        syncFlow(dpn, NwConstants.INGRESS_COUNTERS_TABLE, flowName,
                CountersServiceUtils.COUNTER_TABLE_COUNTER_FLOW_PRIORITY, CountersServiceUtils.COUNTER_FLOW_NAME, 0, 0,
                CountersServiceUtils.COOKIE_COUNTERS_BASE, flowMatches, instructions, operation);
    }

    private String createFlowName(ElementCountersRequest ecr, int lportTag, BigInteger dpn) {
        return "Ingress_Counters" + dpn + "_" + lportTag + "_" + ecr.toString().hashCode();
    }

    @Override
    public void unBindService(String interfaceId) {
        InstanceIdentifier<BoundServices> serviceId = CountersServiceUtils.buildServiceId(interfaceId,
                CountersServiceUtils.INGRESS_COUNTERS_SERVICE_INDEX, ServiceModeIngress.class);
        MDSALUtil.syncDelete(db, LogicalDatastoreType.CONFIGURATION, serviceId);
    }
}