123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225 |
- /* 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;
- }
- void
- Service_Call_single(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) {
- result->statusCode = UA_STATUSCODE_BADMETHODINVALID;
- return;
- }
- if(methodCalled->nodeClass != UA_NODECLASS_METHOD) {
- result->statusCode = UA_STATUSCODE_BADNODECLASSINVALID;
- return;
- }
- if(!methodCalled->attachedMethod) {
- result->statusCode = UA_STATUSCODE_BADINTERNALERROR;
- return;
- }
- /* Get/verify the object node */
- const UA_ObjectNode *object =
- (const UA_ObjectNode*)UA_NodeStore_get(server->nodestore, &request->objectId);
- if(!object) {
- result->statusCode = UA_STATUSCODE_BADNODEIDINVALID;
- return;
- }
- if(object->nodeClass != UA_NODECLASS_OBJECT && object->nodeClass != UA_NODECLASS_OBJECTTYPE) {
- result->statusCode = UA_STATUSCODE_BADNODECLASSINVALID;
- return;
- }
- /* 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) {
- result->statusCode = UA_STATUSCODE_BADNOTWRITABLE; // There is no NOTEXECUTABLE?
- return;
- }
- /* 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) {
- result->statusCode = UA_STATUSCODE_BADMETHODINVALID;
- return;
- }
- /* Verify Input Argument count, types and sizes */
- const UA_VariableNode *inputArguments =
- getArgumentsVariableNode(server, methodCalled, UA_STRING("InputArguments"));
- if(!inputArguments) {
- if(request->inputArgumentsSize > 0) {
- result->statusCode = UA_STATUSCODE_BADINVALIDARGUMENT;
- return;
- }
- } else {
- result->statusCode = argumentsConformsToDefinition(server, inputArguments,
- request->inputArgumentsSize,
- request->inputArguments);
- if(result->statusCode != UA_STATUSCODE_GOOD)
- return;
- }
- /* 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) {
- result->statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
- return;
- }
- result->outputArgumentsSize = outputArguments->value.data.value.value.arrayLength;
- }
- /* Call the method */
- #if defined(UA_ENABLE_METHODCALLS) && defined(UA_ENABLE_SUBSCRIPTIONS)
- methodCallSession = session;
- #endif
- result->statusCode = 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 */
- }
- 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;
- #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
- UA_Boolean isExternal[request->methodsToCallSize];
- UA_UInt32 indices[request->methodsToCallSize];
- memset(isExternal, false, sizeof(UA_Boolean) * request->methodsToCallSize);
- for(size_t j = 0;j<server->externalNamespacesSize;++j) {
- size_t indexSize = 0;
- for(size_t i = 0;i < request->methodsToCallSize;++i) {
- if(request->methodsToCall[i].methodId.namespaceIndex != server->externalNamespaces[j].index)
- continue;
- isExternal[i] = true;
- indices[indexSize] = (UA_UInt32)i;
- ++indexSize;
- }
- if(indexSize == 0)
- continue;
- UA_ExternalNodeStore *ens = &server->externalNamespaces[j].externalNodeStore;
- ens->call(ens->ensHandle, &request->requestHeader, request->methodsToCall,
- indices, (UA_UInt32)indexSize, response->results);
- }
- #endif
-
- for(size_t i = 0; i < request->methodsToCallSize;++i){
- #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
- if(!isExternal[i])
- #endif
- Service_Call_single(server, session, &request->methodsToCall[i], &response->results[i]);
- }
- }
- #endif /* UA_ENABLE_METHODCALLS */
|