"""
Open vSwitch Object Definition
Authors: james.luhrsen@hp.com
Created: 2014-10-02
"""
import re
from BaseSwitch import BaseSwitch


class Ovs(BaseSwitch):
    """
    OpenVswitch Class
    """

    make = "OpenVswitch"
    model = "OVS"

    mgmt_protocol = "ssh"
    mgmt_ip = ""
    mgmt_port = ""
    mgmt_user = "mininet"
    mgmt_password = "mininet"

    mgmt_prompt = ">"

    initialization_type = "cleanup"

    @property
    def connection_configs(self):
        return ["pwd"]

    @property
    def cleanup_cmds(self):
        return [
            "/sbin/ifconfig -a | egrep '^s' | awk '{print \"sudo ovs-vsctl del-br\",$1}' | sh"
        ]

    @property
    def initialization_cmds(self):
        return [self.cleanup_cmds]

    @property
    def base_openflow_config(self):
        return [
            "sudo ovs-vsctl add-br s1",
            "sudo ovs-vsctl set bridge s1 protocols=OpenFlow13",
            "sudo ovs-vsctl set-controller s1 tcp:" + self.of_controller_ip,
            "sudo ifconfig s1 up",
        ]

    @property
    def openflow_validation_cmd(self):
        return "sudo ovs-vsctl show"

    @property
    def openflow_enable_config(self):
        return ["sudo ovs-vsctl set-controller s1 tcp:" + self.of_controller_ip]

    @property
    def openflow_enable_validations(self):
        return ["is_connected: true"]

    invalid_of_controller_ip = "1.1.1.1"

    @property
    def openflow_disable_config(self):
        return ["sudo ovs-vsctl set-controller s1 tcp:" + self.invalid_of_controller_ip]

    @property
    def openflow_disable_validations(self):
        return []

    @property
    def dump_all_flows(self):
        return "sudo /usr/bin/ovs-ofctl dump-flows s1 -O OpenFlow13"

    @property
    def flow_validations(self):
        return [
            "dl_src="
            + self.src_mac
            + ",dl_dst="
            + self.dst_mac
            + ",nw_src="
            + self.ip_src
            + ",nw_dst="
            + self.ip_dst
            + " actions="
            + self.action,
            "table=" + self.table_id,
        ]

    def create_flow_match_elements(self, flow_xml):
        super(Ovs, self).create_flow_match_elements(flow_xml)
        if self.action == "INPORT":
            self.action = "IN_PORT"

    @property
    def datapath_id_output_command(self):
        """This regex will extract the macaddr of the ovs switch"""
        return (
            '/sbin/ifconfig s1 | grep -o -E "([[:xdigit:]]{1,2}:){5}[[:xdigit:]]{1,2}"'
        )

    datapath_id_output_string = ""
    datapath_id = ""

    def update_datapath_id(self):
        if not self.datapath_id_output_string:
            self.datapath_id = "unknown"
        else:
            # 32:cc:bf:34:ed:4c
            datapath_id_hex = re.sub(":", "", self.datapath_id_output_string)
            self.datapath_id = self.convert_hex_to_decimal_as_string(datapath_id_hex)