123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189 |
- /* This Source Code Form is subject to the terms of the Mozilla Public
- * License, v. 2.0. If a copy of the MPL was not distributed with this
- * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
- #include "ua_services.h"
- #include "ua_server_internal.h"
- #ifdef UA_ENABLE_METHODCALLS /* conditional compilation */
- static const UA_VariableNode *
- getArgumentsVariableNode(UA_Server *server, const UA_MethodNode *ofMethod,
- UA_String withBrowseName) {
- UA_NodeId hasProperty = UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY);
- for(size_t i = 0; i < ofMethod->referencesSize; ++i) {
- UA_NodeReferenceKind *rk = &ofMethod->references[i];
- if(rk->isInverse != false)
- continue;
-
- if(!UA_NodeId_equal(&hasProperty, &rk->referenceTypeId))
- continue;
- for(size_t j = 0; j < rk->targetIdsSize; ++j) {
- const UA_Node *refTarget =
- UA_NodeStore_get(server->nodestore, &rk->targetIds[j].nodeId);
- if(!refTarget)
- continue;
- if(refTarget->nodeClass == UA_NODECLASS_VARIABLE &&
- refTarget->browseName.namespaceIndex == 0 &&
- UA_String_equal(&withBrowseName, &refTarget->browseName.name)) {
- return (const UA_VariableNode*) refTarget;
- }
- }
- }
- return NULL;
- }
- static UA_StatusCode
- argumentsConformsToDefinition(UA_Server *server, const UA_VariableNode *argRequirements,
- size_t argsSize, UA_Variant *args) {
- if(argRequirements->value.data.value.value.type != &UA_TYPES[UA_TYPES_ARGUMENT])
- return UA_STATUSCODE_BADINTERNALERROR;
- UA_Argument *argReqs = (UA_Argument*)argRequirements->value.data.value.value.data;
- size_t argReqsSize = argRequirements->value.data.value.value.arrayLength;
- if(argRequirements->valueSource != UA_VALUESOURCE_DATA)
- return UA_STATUSCODE_BADINTERNALERROR;
- if(UA_Variant_isScalar(&argRequirements->value.data.value.value))
- argReqsSize = 1;
- if(argReqsSize > argsSize)
- return UA_STATUSCODE_BADARGUMENTSMISSING;
- if(argReqsSize != argsSize)
- return UA_STATUSCODE_BADINVALIDARGUMENT;
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- for(size_t i = 0; i < argReqsSize; ++i)
- retval |= typeCheckValue(server, &argReqs[i].dataType, argReqs[i].valueRank,
- argReqs[i].arrayDimensionsSize, argReqs[i].arrayDimensions,
- &args[i], NULL, &args[i]);
- return retval;
- }
- static UA_StatusCode
- callMethod(UA_Server *server, UA_Session *session,
- const UA_CallMethodRequest *request,
- UA_CallMethodResult *result) {
- /* Get/verify the method node */
- const UA_MethodNode *methodCalled =
- (const UA_MethodNode*)UA_NodeStore_get(server->nodestore, &request->methodId);
- if(!methodCalled)
- return UA_STATUSCODE_BADMETHODINVALID;
- if(methodCalled->nodeClass != UA_NODECLASS_METHOD)
- return UA_STATUSCODE_BADNODECLASSINVALID;
- if(!methodCalled->attachedMethod)
- return UA_STATUSCODE_BADINTERNALERROR;
- /* Get/verify the object node */
- const UA_ObjectNode *object =
- (const UA_ObjectNode*)UA_NodeStore_get(server->nodestore, &request->objectId);
- if(!object)
- return UA_STATUSCODE_BADNODEIDINVALID;
- if(object->nodeClass != UA_NODECLASS_OBJECT &&
- object->nodeClass != UA_NODECLASS_OBJECTTYPE)
- return UA_STATUSCODE_BADNODECLASSINVALID;
- /* Verify access rights */
- UA_Boolean executable = methodCalled->executable;
- if(session != &adminSession)
- executable = executable &&
- server->config.accessControl.getUserExecutableOnObject(&session->sessionId,
- session->sessionHandle,
- &request->objectId,
- &request->methodId);
- if(!executable)
- return UA_STATUSCODE_BADNOTWRITABLE; // There is no NOTEXECUTABLE?
- /* Verify method/object relations. Object must have a hasComponent or a
- * subtype of hasComponent reference to the method node. Therefore, check
- * every reference between the parent object and the method node if there is
- * a hasComponent (or subtype) reference */
- UA_Boolean found = false;
- UA_NodeId hasComponentNodeId = UA_NODEID_NUMERIC(0,UA_NS0ID_HASCOMPONENT);
- UA_NodeId hasSubTypeNodeId = UA_NODEID_NUMERIC(0,UA_NS0ID_HASSUBTYPE);
- for(size_t i = 0; i < object->referencesSize; ++i) {
- UA_NodeReferenceKind *rk = &object->references[i];
- if(rk->isInverse)
- continue;
- if(!isNodeInTree(server->nodestore, &rk->referenceTypeId,
- &hasComponentNodeId, &hasSubTypeNodeId, 1))
- continue;
- for(size_t j = 0; j < rk->targetIdsSize; ++j) {
- if(UA_NodeId_equal(&rk->targetIds[j].nodeId, &request->methodId)) {
- found = true;
- break;
- }
- }
- }
- if(!found)
- return UA_STATUSCODE_BADMETHODINVALID;
- /* Verify Input Argument count, types and sizes */
- const UA_VariableNode *inputArguments =
- getArgumentsVariableNode(server, methodCalled, UA_STRING("InputArguments"));
- if(!inputArguments) {
- if(request->inputArgumentsSize > 0)
- return UA_STATUSCODE_BADINVALIDARGUMENT;
- } else {
- UA_StatusCode retval = argumentsConformsToDefinition(server, inputArguments,
- request->inputArgumentsSize,
- request->inputArguments);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- }
- /* Allocate the output arguments */
- result->outputArgumentsSize = 0; /* the default */
- const UA_VariableNode *outputArguments =
- getArgumentsVariableNode(server, methodCalled, UA_STRING("OutputArguments"));
- if(outputArguments) {
- result->outputArguments =
- (UA_Variant*)UA_Array_new(outputArguments->value.data.value.value.arrayLength,
- &UA_TYPES[UA_TYPES_VARIANT]);
- if(!result->outputArguments)
- return UA_STATUSCODE_BADOUTOFMEMORY;
- result->outputArgumentsSize = outputArguments->value.data.value.value.arrayLength;
- }
- /* Call the method */
- #if defined(UA_ENABLE_METHODCALLS) && defined(UA_ENABLE_SUBSCRIPTIONS)
- methodCallSession = session;
- #endif
- UA_StatusCode retval =
- methodCalled->attachedMethod(methodCalled->methodHandle, &object->nodeId,
- &session->sessionId, session->sessionHandle,
- request->inputArgumentsSize, request->inputArguments,
- result->outputArgumentsSize, result->outputArguments);
- #if defined(UA_ENABLE_METHODCALLS) && defined(UA_ENABLE_SUBSCRIPTIONS)
- methodCallSession = NULL;
- #endif
- /* TODO: Verify Output matches the argument definition */
- return retval;
- }
- void Service_Call(UA_Server *server, UA_Session *session,
- const UA_CallRequest *request,
- UA_CallResponse *response) {
- UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing CallRequest");
- if(request->methodsToCallSize <= 0) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
- return;
- }
- response->results = (UA_CallMethodResult*)UA_Array_new(request->methodsToCallSize,
- &UA_TYPES[UA_TYPES_CALLMETHODRESULT]);
- if(!response->results) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
- return;
- }
- response->resultsSize = request->methodsToCallSize;
- for(size_t i = 0; i < request->methodsToCallSize; ++i)
- response->results[i].statusCode =
- callMethod(server, session, &request->methodsToCall[i], &response->results[i]);
- }
- #endif /* UA_ENABLE_METHODCALLS */
|