FreeOpcUa / python-opcua

    def publish(self, acks):

        self.logger.info("publish request with acks %s", acks)

        with self._lock:

            for subid, sub in self.subscriptions.items():

                sub.publish([ack.SequenceNumber for ack in acks if ack.SubscriptionId == subid])

    def create_monitored_items(self, params):

        self.logger.info("create monitored items")

        with self._lock:

            if params.SubscriptionId not in self.subscriptions:

                res = []

                for _ in params.ItemsToCreate:

                    response = ua.MonitoredItemCreateResult()

                    response.StatusCode = ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid)

                    res.append(response)

                return res

    def delete_subscriptions(self, ids):

        self.logger.info("delete subscriptions: %s", ids)

        res = []

        for i in ids:

            with self._lock:

                if i not in self.subscriptions:

                    res.append(ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid))

                else:

                    sub = self.subscriptions.pop(i)

                    sub.stop()

                    res.append(ua.StatusCode())

        return res

    def publish(self, acks):

        self.logger.info("publish request with acks %s", acks)

        with self._lock:

            for subid, sub in self.subscriptions.items():

                for _ in params.ItemsToCreate:

                    response = ua.MonitoredItemCreateResult()

                    response.StatusCode = ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid)

                    res.append(response)

                return res

            return self.subscriptions[params.SubscriptionId].monitored_item_srv.create_monitored_items(params)

    def modify_monitored_items(self, params):

        self.logger.info("modify monitored items")

        with self._lock:

            if params.SubscriptionId not in self.subscriptions:

                res = []

                for _ in params.ItemsToModify:

                    result = ua.MonitoredItemModifyResult()

                    result.StatusCode = ua.StatusCode(ua.StatusCodes.BadSubscriptionIdInvalid)

                    res.append(result)