kytos-ng / telemetry_int

        return JSONResponse(status)

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

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

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

        Args:

            {"evc_ids": [list of evc_ids] }

        Returns:

            200 if successful

            400 is otherwise

        """

        try:

            content = get_json_or_400(request, self.controller.loop)

            evc_ids = content["evc_ids"]

        except (TypeError, KeyError):

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

        status = {}

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

        # TODO extract this and cover proxy port validations too

        for evc_id in evc_ids:

            if evc_id not in evcs:

                raise HTTPException(404, detail=f"EVC {evc_id} doesn't exist")

            if not has_int_enabled(evcs[evc_id]):

                raise HTTPException(

                    400, detail=f"EVC {evc_id} doesn't have INT enabled"

                )

        if not evc_ids:

            # Enable telemetry for ALL INT EVCs.

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

        else:

            evcs = {evc_id: evcs[evc_id] for evc_id in evc_ids}

        # Process each EVC individually

        # TODO dispatch in batch and update metadata in bulk shortly after

        for evc_id, evc in evcs.items():

            try:

                status[evc_id] = self.decommission_int(evc)

            except EvcHasNoINT as err_msg:

                # Ignore since it is not an issue.

                status[evc_id] = err_msg.message

            except ErrorBase as err_msg:

                # Rollback INT configuration. This error will lead to inconsistency.

                # Critical

                status[evc_id] = err_msg.message

        return JSONResponse(status)

    @rest("v1/evc")

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

    # REST methods

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

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

        """REST to enable/create INT flows for one or more EVC_IDs.

                  evcs are provided via POST as a list

        Args:

            {"evc_ids": [list of evc_ids] }

        Returns:

            200 and outcomes for each evc listed.

        """

        try:

            content = get_json_or_400(request, self.controller.loop)

            evc_ids = content["evc_ids"]

        except (TypeError, KeyError):

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

        status = {}

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

        # TODO extract this and cover proxy port validations too

        for evc_id in evc_ids:

            if evc_id not in evcs:

                raise HTTPException(404, detail=f"EVC {evc_id} doesn't exist")

            if has_int_enabled(evcs[evc_id]):

                raise HTTPException(400, detail=f"EVC {evc_id} already has INT enabled")

        if not evc_ids:

            # Enable telemetry for ALL non INT EVCs.

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

        else:

            evcs = {evc_id: evcs[evc_id] for evc_id in evc_ids}

        # Process each EVC individually

        # TODO dispatch in batch and update metadata in bulk shortly after

        for evc_id, evc in evcs.items():

            try:

                status[evc_id] = self.provision_int(evc)

            except ErrorBase as err_msg:

                status[evc_id] = err_msg.message

        return JSONResponse(status)

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

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