kytos-ng / telemetry_int

        return await self.install_int_flows(switches_flows)

    @rest("v1/evc/enable", methods=["POST"])

    async def enable_telemetry(self, request: Request) -> JSONResponse:

        """REST to enable INT flows on EVCs.

        If a list of evc_ids is empty, it'll enable on non-INT EVCs.

        """

        try:

            content = await aget_json_or_400(request)

            evc_ids = content["evc_ids"]

            force = bool(content.get("force", False))

        except (TypeError, KeyError):

            raise HTTPException(400, detail=f"Invalid payload: {content}")

        try:

            evcs = await get_evcs() if len(evc_ids) != 1 else await get_evc(evc_ids[0])

        except RetryError as exc:

            exc_error = str(exc.last_attempt.exception())

            log.error(exc_error)

            raise HTTPException(503, detail=exc_error)

        if evc_ids:

            evcs = {evc_id: evcs.get(evc_id, {}) for evc_id in evc_ids}

        else:

            evcs = {k: v for k, v in evcs.items() if not utils.has_int_enabled(v)}

            if not evcs:

                # There's no non-INT EVCs to get enabled.

                return JSONResponse({})

        try:

            await self.int_manager.enable_int(evcs, force)

        except (EVCNotFound, FlowsNotFound, ProxyPortNotFound) as exc:

            raise HTTPException(404, detail=str(exc))

        except (EVCHasINT, ProxyPortStatusNotUP) as exc:

            raise HTTPException(400, detail=str(exc))

        except RetryError as exc:

            exc_error = str(exc.last_attempt.exception())

            log.error(exc_error)

            raise HTTPException(503, detail=exc_error)

        except UnrecoverableError as exc:

            exc_error = str(exc)

            log.error(exc_error)

            raise HTTPException(500, detail=exc_error)

        return JSONResponse({}, status_code=201)

    @rest("v1/evc/disable", methods=["POST"])

    async def disable_telemetry(self, request: Request) -> JSONResponse:

        return JSONResponse({}, status_code=201)

    @rest("v1/evc/disable", methods=["POST"])

    async def disable_telemetry(self, request: Request) -> JSONResponse:

        """REST to disable/remove INT flows for an EVC_ID

        If a list of evc_ids is empty, it'll disable on all INT EVCs.

        """

        try:

            content = await aget_json_or_400(request)

            evc_ids = content["evc_ids"]

            force = bool(content.get("force", False))

        except (TypeError, KeyError):

            raise HTTPException(400, detail=f"Invalid payload: {content}")

        try:

            evcs = await get_evcs() if len(evc_ids) != 1 else await get_evc(evc_ids[0])

        except RetryError as exc:

            exc_error = str(exc.last_attempt.exception())

            log.error(exc_error)

            raise HTTPException(503, detail=exc_error)

        if evc_ids:

            evcs = {evc_id: evcs.get(evc_id, {}) for evc_id in evc_ids}

        else:

            evcs = {k: v for k, v in evcs.items() if utils.has_int_enabled(v)}

            if not evcs:

                # There's no INT EVCs to get disabled.

                return JSONResponse({})

        try:

            await self.int_manager.disable_int(evcs, force)

        except EVCNotFound as exc:

            raise HTTPException(404, detail=str(exc))

        except EVCHasNoINT as exc:

            raise HTTPException(400, detail=str(exc))

        except RetryError as exc:

            exc_error = str(exc.last_attempt.exception())

            log.error(exc_error)

            raise HTTPException(503, detail=exc_error)

        except UnrecoverableError as exc:

            exc_error = str(exc)

            log.error(exc_error)

            raise HTTPException(500, detail=exc_error)

        return JSONResponse({})

    @rest("v1/evc")

    def get_evcs(self, _request: Request) -> JSONResponse: