kytos-ng / mef_eline

        return uni_flows

    @staticmethod

    @retry(

        stop=stop_after_attempt(3),

        wait=wait_combine(wait_fixed(3), wait_random(min=2, max=7)),

        retry=retry_if_exception_type(FlowModException),

        before_sleep=before_sleep,

        reraise=True,

    )

    def _send_flow_mods(data_content: dict, command="install", force=False):

        """Send a flow_mod list to a specific switch.

        Args:

            dpid(str): The target of flows (i.e. Switch.id).

            flow_mods(dict): Python dictionary with flow_mods.

            command(str): By default is 'flows'. To remove a flow is 'remove'.

            force(bool): True to send via consistency check in case of errors

        """

        endpoint = f"{settings.MANAGER_URL}/flows"

        data_content["force"] = force

        try:

            if command == "install":

                res = httpx.post(endpoint, json=data_content, timeout=30)

            elif command == "delete":

                res = httpx.request(

                    "DELETE", endpoint, json=data_content, timeout=30

                )

        except httpx.RequestError as err:

            raise FlowModException(str(err)) from err

        if res.is_server_error or res.status_code >= 400:

            raise FlowModException(res.text)

    @staticmethod

    @retry(

        if res.is_server_error or res.status_code >= 400:

            raise FlowModException(res.text)

    @staticmethod

    @retry(

        stop=stop_after_attempt(3),

        wait=wait_combine(wait_fixed(3), wait_random(min=2, max=7)),

        retry=retry_if_exception_type(FlowModException),

        before_sleep=before_sleep,

        reraise=True,

    )

    def _send_flow_mods_by_switch(

        flows_dict: dict[str, list],

        command: str,

        force=False

    ):

        """Send flow mods"""

        endpoint = f"{settings.MANAGER_URL}/flows_by_switch/?force={force}"

        try:

            if command == "install":

                res = httpx.post(endpoint, json=flows_dict, timeout=30)

            elif command == "delete":

                res = httpx.request(

                    "DELETE", endpoint, json=flows_dict, timeout=30

                )

        except httpx.RequestError as err:

            raise FlowModException(str(err)) from err

        if res.is_server_error or res.status_code >= 400:

            raise FlowModException(res.text)

    def get_cookie(self):

        """Return the cookie integer from evc id."""