server_operations.cpp

Go to the documentation of this file.

#include "opc/ua/server_operations.h"

namespace OpcUa {
        ServerOperations::ServerOperations(Services::SharedPtr Server) : Server(Server)
        {
        }

        void ServerOperations::WriteAttributes(std::vector<WriteValue>& updates)
        {
                std::vector<StatusCode> codes = Server->Attributes()->Write(updates);
                CheckStatusCode(codes.front());
        }

        std::vector<DataValue> ServerOperations::ReadAttributes(std::vector<ReadValueId>& attributes)
        {
                ReadParameters params;
                params.AttributesToRead = attributes;
                auto vec = Server->Attributes()->Read(params);
                return vec;
        }

        std::vector<DataValue> ServerOperations::ReadAttributes(std::vector<Node>& nodes, AttributeId attr)
        {
                std::vector<ReadValueId> request;
                for (auto& n : nodes) {
                        ReadValueId r;
                        r.NodeId = n.GetId();
                        r.AttributeId = attr;
                        request.push_back(r);
                }
                return ReadAttributes(request);
        }

        std::vector<Node> ServerOperations::RegisterNodes(std::vector<Node>& nodes)
        {
                std::vector<OpcUa::NodeId> ids;
                for (auto& node : nodes) {
                        ids.push_back(node.GetId());
                }
                auto result = Server->Views()->RegisterNodes(ids);
                auto rit = result.begin();
                std::vector<Node> out;
                for (auto nit = nodes.begin(); nit != nodes.end() && rit != result.end(); ++nit, ++rit)
                {
                        out.push_back(Node(nit->GetServices(), *rit));
                }

                return out;
        }

        void ServerOperations::UnregisterNodes(std::vector<Node>& nodes)
        {
                std::vector<OpcUa::NodeId> ids;
                for (auto& node : nodes) {
                        ids.push_back(node.GetId());
                }

                Server->Views()->UnregisterNodes(ids);
        }
}