/*
 * Copyright (c) 2013 Cisco Systems, 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.openflowplugin.impl.util;

import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
import org.opendaylight.openflowplugin.openflow.md.util.OpenflowPortsUtil;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdatedBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortReason;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.State;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.StateBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemoved;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemovedBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdatedBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfigV10;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeaturesV10;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortStateV10;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortGrouping;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
import org.opendaylight.yangtools.yang.common.Uint32;
import org.opendaylight.yangtools.yang.common.Uint64;
import org.opendaylight.yangtools.yang.common.Uint8;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public abstract class PortTranslatorUtil {
    private static final Logger LOG = LoggerFactory.getLogger(PortTranslatorUtil.class);

    public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures
            translatePortFeatures(final PortFeatures apf) {
        return apf == null ? null
            : new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures(
                apf.getAutoneg(),   //_autoeng
                apf.getCopper(),    //_copper
                apf.getFiber(),     //_fiber
                apf.get_40gbFd(),   //_fortyGbFd
                apf.get_100gbFd(),  //_hundredGbFd
                apf.get_100mbFd(),  //_hundredMbFd
                apf.get_100mbHd(),  //_hundredMbHd
                apf.get_1gbFd(),    //_oneGbFd
                apf.get_1gbHd(),    //_oneGbHd
                apf.get_1tbFd(),    //_oneTbFd
                apf.getOther(),     //_other
                apf.getPause(),     //_pause
                apf.getPauseAsym(), //_pauseAsym
                apf.get_10gbFd(),   //_tenGbFd
                apf.get_10mbFd(),   //_tenMbFd
                apf.get_10mbHd());  //_tenMbHd
    }

    public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures
            translatePortFeatures(final PortFeaturesV10 apf) {
        return apf == null ? null
            : new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures(
                apf.getAutoneg(),   //_autoeng
                apf.getCopper(),    //_copper
                apf.getFiber(),     //_fiber
                false,              //_fortyGbFd
                false,              //_hundredGbFd
                apf.get_100mbFd(),  //_hundredMbFd
                apf.get_100mbHd(),  //_hundredMbHd
                apf.get_1gbFd(),    //_oneGbFd
                apf.get_1gbHd(),    //_oneGbHd
                false,              //_oneTbFd
                false,              //_other
                apf.getPause(),     //_pause
                apf.getPauseAsym(), //_pauseAsym
                apf.get_10gbFd(),   //_tenGbFd
                apf.get_10mbFd(),   //_tenMbFd
                apf.get_10mbHd());  //_tenMbHd
    }

    public static State translatePortState(final PortState state) {
        StateBuilder nstate = new StateBuilder();
        if (state != null) {
            nstate.setBlocked(state.getBlocked()).setLinkDown(state.getLinkDown()).setLive(state.getLive());
        }
        return nstate.build();
    }

    public static State translatePortState(final PortStateV10 state) {
        StateBuilder nstate = new StateBuilder();
        if (state != null) {
            nstate.setBlocked(state.getBlocked()).setLinkDown(state.getLinkDown()).setLive(state.getLive());
        }
        return nstate.build();
    }

    public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig
            translatePortConfig(final PortConfig pc) {
        return pc == null ? null
            : new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig(
                pc.getNoFwd(), pc.getNoPacketIn(), pc.getNoRecv(), pc.getPortDown());
    }

    public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig
            translatePortConfig(final PortConfigV10 pc) {
        return pc == null ? null
            : new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig(
                pc.getNoFwd(), pc.getNoPacketIn(), pc.getNoRecv(), pc.getPortDown());
    }

    public static NodeConnectorUpdated translatePort(final Uint8 version, final Uint64 datapathId,
                                                     final Uint32 portNumber, final PortGrouping port) {
        OpenflowVersion ofVersion = OpenflowVersion.get(version);
        final NodeConnectorUpdatedBuilder builder = InventoryDataServiceUtil
                .nodeConnectorUpdatedBuilderFromDatapathIdPortNo(datapathId, port.getPortNo(), ofVersion);
        FlowCapableNodeConnectorUpdatedBuilder fcncub = new FlowCapableNodeConnectorUpdatedBuilder();
        if (ofVersion == OpenflowVersion.OF13) {
            fcncub.setAdvertisedFeatures(PortTranslatorUtil.translatePortFeatures(port.getAdvertisedFeatures()));
            fcncub.setConfiguration(PortTranslatorUtil.translatePortConfig(port.getConfig()));
            fcncub.setCurrentFeature(PortTranslatorUtil.translatePortFeatures(port.getCurrentFeatures()));
            fcncub.setPeerFeatures(PortTranslatorUtil.translatePortFeatures(port.getPeerFeatures()));
            fcncub.setState(PortTranslatorUtil.translatePortState(port.getState()));
            fcncub.setSupported(PortTranslatorUtil.translatePortFeatures(port.getSupportedFeatures()));

        } else if (ofVersion == OpenflowVersion.OF10) {
            fcncub.setAdvertisedFeatures(PortTranslatorUtil.translatePortFeatures(port.getAdvertisedFeaturesV10()));
            fcncub.setConfiguration(PortTranslatorUtil.translatePortConfig(port.getConfigV10()));
            fcncub.setCurrentFeature(PortTranslatorUtil.translatePortFeatures(port.getCurrentFeaturesV10()));
            fcncub.setPeerFeatures(PortTranslatorUtil.translatePortFeatures(port.getPeerFeaturesV10()));
            fcncub.setState(PortTranslatorUtil.translatePortState(port.getStateV10()));
            fcncub.setSupported(PortTranslatorUtil.translatePortFeatures(port.getSupportedFeaturesV10()));
        }
        if (port instanceof PortStatusMessage) {
            if (((PortStatusMessage) port).getReason() != null) {
                fcncub.setReason(PortReason.forValue(((PortStatusMessage) port).getReason().getIntValue()));
            } else {
                LOG.debug("PortStatus Message has reason as null");
            }
        }
        fcncub.setCurrentSpeed(port.getCurrSpeed());
        fcncub.setHardwareAddress(port.getHwAddr());
        fcncub.setMaximumSpeed(port.getMaxSpeed());
        fcncub.setName(port.getName());
        fcncub.setPortNumber(OpenflowPortsUtil.getProtocolAgnosticPort(ofVersion, portNumber));
        return builder.addAugmentation(fcncub.build()).build();
    }

    public static NodeConnectorRemoved translatePortRemoved(final Uint8 version, final Uint64 datapathId,
                                                            final Uint32 portNumber, final PortGrouping port) {
        OpenflowVersion ofVersion = OpenflowVersion.get(version);
        NodeConnectorRemovedBuilder builder = new NodeConnectorRemovedBuilder();
        builder.setNodeConnectorRef(
                InventoryDataServiceUtil.nodeConnectorRefFromDatapathIdPortno(datapathId, portNumber, ofVersion));
        return builder.build();
    }
}