ua_services_nodemanagement.c 71 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688
  1. /* This Source Code Form is subject to the terms of the Mozilla Public
  2. * License, v. 2.0. If a copy of the MPL was not distributed with this
  3. * file, You can obtain one at http://mozilla.org/MPL/2.0/.
  4. *
  5. * Copyright 2014-2017 (c) Julius Pfrommer, Fraunhofer IOSB
  6. * Copyright 2014-2017 (c) Florian Palm
  7. * Copyright 2015-2016 (c) Sten Grüner
  8. * Copyright 2015-2016 (c) Chris Iatrou
  9. * Copyright 2015-2016 (c) Oleksiy Vasylyev
  10. * Copyright 2017 (c) Julian Grothoff
  11. * Copyright 2016 (c) LEvertz
  12. * Copyright 2016 (c) Lorenz Haas
  13. * Copyright 2017 (c) frax2222
  14. * Copyright 2017-2018 (c) Stefan Profanter, fortiss GmbH
  15. * Copyright 2017 (c) Christian von Arnim
  16. * Copyright 2017 (c) Henrik Norrman
  17. */
  18. #include "ua_server_internal.h"
  19. #include "ua_services.h"
  20. /*********************/
  21. /* Edit Node Context */
  22. /*********************/
  23. UA_StatusCode
  24. UA_Server_getNodeContext(UA_Server *server, UA_NodeId nodeId,
  25. void **nodeContext) {
  26. const UA_Node *node = UA_Nodestore_get(server, &nodeId);
  27. if(!node)
  28. return UA_STATUSCODE_BADNODEIDUNKNOWN;
  29. *nodeContext = node->context;
  30. UA_Nodestore_release(server, node);
  31. return UA_STATUSCODE_GOOD;
  32. }
  33. static UA_StatusCode
  34. editNodeContext(UA_Server *server, UA_Session* session,
  35. UA_Node* node, void *context) {
  36. node->context = context;
  37. return UA_STATUSCODE_GOOD;
  38. }
  39. UA_StatusCode
  40. UA_Server_setNodeContext(UA_Server *server, UA_NodeId nodeId,
  41. void *nodeContext) {
  42. UA_StatusCode retval =
  43. UA_Server_editNode(server, &adminSession, &nodeId,
  44. (UA_EditNodeCallback)editNodeContext, nodeContext);
  45. return retval;
  46. }
  47. /**********************/
  48. /* Consistency Checks */
  49. /**********************/
  50. /* Check if the requested parent node exists, has the right node class and is
  51. * referenced with an allowed (hierarchical) reference type. For "type" nodes,
  52. * only hasSubType references are allowed. */
  53. static UA_StatusCode
  54. checkParentReference(UA_Server *server, UA_Session *session, UA_NodeClass nodeClass,
  55. const UA_NodeId *parentNodeId, const UA_NodeId *referenceTypeId) {
  56. /* Objects do not need a parent (e.g. mandatory/optional modellingrules) */
  57. if(nodeClass == UA_NODECLASS_OBJECT && UA_NodeId_isNull(parentNodeId) &&
  58. UA_NodeId_isNull(referenceTypeId))
  59. return UA_STATUSCODE_GOOD;
  60. /* Omit checks during bootstrap */
  61. if(server->bootstrapNS0)
  62. return UA_STATUSCODE_GOOD;
  63. /* See if the parent exists */
  64. const UA_Node *parent = UA_Nodestore_get(server, parentNodeId);
  65. if(!parent) {
  66. UA_LOG_INFO_SESSION(server->config.logger, session,
  67. "AddNodes: Parent node not found");
  68. return UA_STATUSCODE_BADPARENTNODEIDINVALID;
  69. }
  70. UA_NodeClass parentNodeClass = parent->nodeClass;
  71. UA_Nodestore_release(server, parent);
  72. /* Check the referencetype exists */
  73. const UA_ReferenceTypeNode *referenceType = (const UA_ReferenceTypeNode*)
  74. UA_Nodestore_get(server, referenceTypeId);
  75. if(!referenceType) {
  76. UA_LOG_INFO_SESSION(server->config.logger, session,
  77. "AddNodes: Reference type to the parent not found");
  78. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  79. }
  80. /* Check if the referencetype is a reference type node */
  81. if(referenceType->nodeClass != UA_NODECLASS_REFERENCETYPE) {
  82. UA_LOG_INFO_SESSION(server->config.logger, session,
  83. "AddNodes: Reference type to the parent invalid");
  84. UA_Nodestore_release(server, (const UA_Node*)referenceType);
  85. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  86. }
  87. UA_Boolean referenceTypeIsAbstract = referenceType->isAbstract;
  88. UA_Nodestore_release(server, (const UA_Node*)referenceType);
  89. /* Check that the reference type is not abstract */
  90. if(referenceTypeIsAbstract == true) {
  91. UA_LOG_INFO_SESSION(server->config.logger, session,
  92. "AddNodes: Abstract reference type to the parent not allowed");
  93. return UA_STATUSCODE_BADREFERENCENOTALLOWED;
  94. }
  95. /* Check hassubtype relation for type nodes */
  96. if(nodeClass == UA_NODECLASS_DATATYPE ||
  97. nodeClass == UA_NODECLASS_VARIABLETYPE ||
  98. nodeClass == UA_NODECLASS_OBJECTTYPE ||
  99. nodeClass == UA_NODECLASS_REFERENCETYPE) {
  100. /* type needs hassubtype reference to the supertype */
  101. if(!UA_NodeId_equal(referenceTypeId, &subtypeId)) {
  102. UA_LOG_INFO_SESSION(server->config.logger, session,
  103. "AddNodes: New type node need to have a "
  104. "HasSubType reference");
  105. return UA_STATUSCODE_BADREFERENCENOTALLOWED;
  106. }
  107. /* supertype needs to be of the same node type */
  108. if(parentNodeClass != nodeClass) {
  109. UA_LOG_INFO_SESSION(server->config.logger, session,
  110. "AddNodes: New type node needs to be of the same "
  111. "node type as the parent");
  112. return UA_STATUSCODE_BADPARENTNODEIDINVALID;
  113. }
  114. return UA_STATUSCODE_GOOD;
  115. }
  116. /* Test if the referencetype is hierarchical */
  117. const UA_NodeId hierarchicalReference =
  118. UA_NODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES);
  119. if(!isNodeInTree(&server->config.nodestore, referenceTypeId,
  120. &hierarchicalReference, &subtypeId, 1)) {
  121. UA_LOG_INFO_SESSION(server->config.logger, session,
  122. "AddNodes: Reference type is not hierarchical");
  123. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  124. }
  125. return UA_STATUSCODE_GOOD;
  126. }
  127. static UA_StatusCode
  128. typeCheckVariableNode(UA_Server *server, UA_Session *session,
  129. const UA_VariableNode *node,
  130. const UA_VariableTypeNode *vt,
  131. const UA_NodeId *parentNodeId) {
  132. /* The value might come from a datasource, so we perform a
  133. * regular read. */
  134. UA_DataValue value;
  135. UA_DataValue_init(&value);
  136. UA_StatusCode retval = readValueAttribute(server, session, node, &value);
  137. if(retval != UA_STATUSCODE_GOOD)
  138. return retval;
  139. /* Check the datatype against the vt */
  140. if(!compatibleDataType(server, &node->dataType, &vt->dataType, false))
  141. return UA_STATUSCODE_BADTYPEMISMATCH;
  142. /* Get the array dimensions */
  143. size_t arrayDims = node->arrayDimensionsSize;
  144. if(arrayDims == 0 && value.hasValue && value.value.type &&
  145. !UA_Variant_isScalar(&value.value)) {
  146. arrayDims = 1; /* No array dimensions on an array implies one dimension */
  147. }
  148. /* Check valueRank against array dimensions */
  149. if(!(node->nodeClass == UA_NODECLASS_VARIABLETYPE &&
  150. ((const UA_VariableTypeNode*)node)->isAbstract && node->valueRank == 0) &&
  151. !compatibleValueRankArrayDimensions(node->valueRank, arrayDims))
  152. return UA_STATUSCODE_BADTYPEMISMATCH;
  153. /* If variable node is created below BaseObjectType and has its default valueRank of -2,
  154. * skip the test */
  155. const UA_NodeId objectTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE);
  156. UA_NodeId refs[2];
  157. refs[0] = UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE);
  158. refs[1] = UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT);
  159. if(node->valueRank != vt->valueRank &&
  160. node->valueRank != UA_VariableAttributes_default.valueRank &&
  161. !isNodeInTree(&server->config.nodestore, parentNodeId, &objectTypes, refs, 2)) {
  162. /* Check valueRank against the vt */
  163. if(!compatibleValueRanks(node->valueRank, vt->valueRank))
  164. return UA_STATUSCODE_BADTYPEMISMATCH;
  165. }
  166. /* Check array dimensions against the vt */
  167. if(!compatibleArrayDimensions(vt->arrayDimensionsSize, vt->arrayDimensions,
  168. node->arrayDimensionsSize, node->arrayDimensions))
  169. return UA_STATUSCODE_BADTYPEMISMATCH;
  170. /* Typecheck the value */
  171. if(!server->bootstrapNS0 && value.hasValue) {
  172. /* If the type-check failed write the same value again. The
  173. * write-service tries to convert to the correct type... */
  174. if(!compatibleValue(server, &node->dataType, node->valueRank,
  175. node->arrayDimensionsSize, node->arrayDimensions,
  176. &value.value, NULL))
  177. retval = UA_Server_writeValue(server, node->nodeId, value.value);
  178. UA_DataValue_deleteMembers(&value);
  179. }
  180. return retval;
  181. }
  182. /********************/
  183. /* Instantiate Node */
  184. /********************/
  185. static const UA_NodeId baseDataVariableType =
  186. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_BASEDATAVARIABLETYPE}};
  187. static const UA_NodeId baseObjectType =
  188. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_BASEOBJECTTYPE}};
  189. /* Use attributes from the variable type wherever required */
  190. static UA_StatusCode
  191. useVariableTypeAttributes(UA_Server *server, UA_Session *session,
  192. UA_VariableNode *node, const UA_AddNodesItem *item) {
  193. const UA_VariableAttributes *attributes = (const UA_VariableAttributes*)
  194. item->nodeAttributes.content.decoded.data;
  195. /* Select the type definition */
  196. const UA_NodeId *typeDefinition;
  197. if(node->nodeClass == UA_NODECLASS_VARIABLE)
  198. typeDefinition = &item->typeDefinition.nodeId;
  199. else /* UA_NODECLASS_VARIABLETYPE */
  200. typeDefinition = &item->parentNodeId.nodeId;
  201. /* Replace an empty typeDefinition with the most permissive default */
  202. if(UA_NodeId_isNull(typeDefinition))
  203. typeDefinition = &baseDataVariableType;
  204. const UA_VariableTypeNode *vt = (const UA_VariableTypeNode*)
  205. UA_Nodestore_get(server, typeDefinition);
  206. if(!vt || vt->nodeClass != UA_NODECLASS_VARIABLETYPE) {
  207. UA_Nodestore_release(server, (const UA_Node*)vt);
  208. return UA_STATUSCODE_BADTYPEMISMATCH;
  209. }
  210. /* If no value is set, see if the vt provides one and copy it. This needs to
  211. * be done before copying the datatype from the vt, as setting the datatype
  212. * triggers a typecheck. */
  213. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  214. if(!attributes->value.type) {
  215. UA_LOG_DEBUG_SESSION(server->config.logger, session,
  216. "AddNodes: No value given; Copy the value"
  217. "from the TypeDefinition");
  218. UA_DataValue vt_value;
  219. UA_DataValue_init(&vt_value);
  220. retval = readValueAttribute(server, session,
  221. (const UA_VariableNode*)vt, &vt_value);
  222. if(retval == UA_STATUSCODE_GOOD && vt_value.hasValue) {
  223. retval = UA_Variant_copy(&vt_value.value, &node->value.data.value.value);
  224. node->value.data.value.hasValue = true;
  225. }
  226. UA_DataValue_deleteMembers(&vt_value);
  227. }
  228. /* If no datatype is given, use the datatype of the vt */
  229. if(retval == UA_STATUSCODE_GOOD && UA_NodeId_isNull(&node->dataType)) {
  230. UA_LOG_INFO_SESSION(server->config.logger, session, "AddNodes: "
  231. "No datatype given; Copy the datatype attribute "
  232. "from the TypeDefinition");
  233. retval = UA_NodeId_copy(&vt->dataType, &node->dataType);
  234. }
  235. /* TODO: If the vt has arraydimensions but this variable does not, copy */
  236. UA_Nodestore_release(server, (const UA_Node*)vt);
  237. return retval;
  238. }
  239. /* Search for an instance of "browseName" in node searchInstance. Used during
  240. * copyChildNodes to find overwritable/mergable nodes. Does not touch
  241. * outInstanceNodeId if no child is found. */
  242. static UA_StatusCode
  243. findChildByBrowsename(UA_Server *server, UA_Session *session,
  244. const UA_NodeId *searchInstance,
  245. const UA_QualifiedName *browseName,
  246. UA_NodeId *outInstanceNodeId) {
  247. UA_BrowseDescription bd;
  248. UA_BrowseDescription_init(&bd);
  249. bd.nodeId = *searchInstance;
  250. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  251. bd.includeSubtypes = true;
  252. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  253. bd.nodeClassMask = UA_NODECLASS_OBJECT | UA_NODECLASS_VARIABLE | UA_NODECLASS_METHOD;
  254. bd.resultMask = UA_BROWSERESULTMASK_NODECLASS | UA_BROWSERESULTMASK_BROWSENAME;
  255. UA_BrowseResult br;
  256. UA_BrowseResult_init(&br);
  257. UA_UInt32 maxrefs = 0;
  258. Operation_Browse(server, session, &maxrefs, &bd, &br);
  259. if(br.statusCode != UA_STATUSCODE_GOOD)
  260. return br.statusCode;
  261. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  262. for(size_t i = 0; i < br.referencesSize; ++i) {
  263. UA_ReferenceDescription *rd = &br.references[i];
  264. if(rd->browseName.namespaceIndex == browseName->namespaceIndex &&
  265. UA_String_equal(&rd->browseName.name, &browseName->name)) {
  266. retval = UA_NodeId_copy(&rd->nodeId.nodeId, outInstanceNodeId);
  267. break;
  268. }
  269. }
  270. UA_BrowseResult_deleteMembers(&br);
  271. return retval;
  272. }
  273. static const UA_NodeId mandatoryId =
  274. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_MODELLINGRULE_MANDATORY}};
  275. static const UA_NodeId hasModellingRuleId =
  276. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASMODELLINGRULE}};
  277. static UA_Boolean
  278. isMandatoryChild(UA_Server *server, UA_Session *session,
  279. const UA_NodeId *childNodeId) {
  280. /* Get the child */
  281. const UA_Node *child = UA_Nodestore_get(server, childNodeId);
  282. if(!child)
  283. return false;
  284. /* Look for the reference making the child mandatory */
  285. for(size_t i = 0; i < child->referencesSize; ++i) {
  286. UA_NodeReferenceKind *refs = &child->references[i];
  287. if(!UA_NodeId_equal(&hasModellingRuleId, &refs->referenceTypeId))
  288. continue;
  289. if(refs->isInverse)
  290. continue;
  291. for(size_t j = 0; j < refs->targetIdsSize; ++j) {
  292. if(UA_NodeId_equal(&mandatoryId, &refs->targetIds[j].nodeId)) {
  293. UA_Nodestore_release(server, child);
  294. return true;
  295. }
  296. }
  297. }
  298. UA_Nodestore_release(server, child);
  299. return false;
  300. }
  301. static UA_StatusCode
  302. copyChildNodes(UA_Server *server, UA_Session *session,
  303. const UA_NodeId *sourceNodeId,
  304. const UA_NodeId *destinationNodeId);
  305. static void
  306. Operation_addReference(UA_Server *server, UA_Session *session, void *context,
  307. const UA_AddReferencesItem *item, UA_StatusCode *retval);
  308. /*
  309. * This method only deletes references from the node which are not matching any type in the given array.
  310. * Could be used to e.g. delete all the references, except 'HASMODELINGRULE'
  311. */
  312. static void deleteReferencesSubset(UA_Node *node, size_t referencesSkipSize, UA_NodeId* referencesSkip) {
  313. if(referencesSkipSize == 0) {
  314. UA_Node_deleteReferences(node);
  315. return;
  316. }
  317. /* Let's count if there are references left. If not just delete all the references.
  318. * It's faster */
  319. size_t newSize = 0;
  320. for(size_t i = 0; i < node->referencesSize; ++i) {
  321. for(size_t j = 0; j < referencesSkipSize; j++) {
  322. if(UA_NodeId_equal(&node->references[i].referenceTypeId, &referencesSkip[j])) {
  323. newSize++;
  324. }
  325. }
  326. }
  327. if(newSize == 0) {
  328. UA_Node_deleteReferences(node);
  329. return;
  330. }
  331. /* Now copy the remaining references to a new array */
  332. UA_NodeReferenceKind *newReferences = (UA_NodeReferenceKind *)UA_malloc(sizeof(UA_NodeReferenceKind) * (newSize));
  333. size_t curr = 0;
  334. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  335. for(size_t i = 0; i < node->referencesSize && retval == UA_STATUSCODE_GOOD; ++i) {
  336. for(size_t j = 0; j < referencesSkipSize; j++) {
  337. if(!UA_NodeId_equal(&node->references[i].referenceTypeId, &referencesSkip[j]))
  338. continue;
  339. // copy the reference
  340. UA_NodeReferenceKind *srefs = &node->references[i];
  341. UA_NodeReferenceKind *drefs = &newReferences[curr++];
  342. drefs->isInverse = srefs->isInverse;
  343. retval = UA_NodeId_copy(&srefs->referenceTypeId, &drefs->referenceTypeId);
  344. if(retval != UA_STATUSCODE_GOOD)
  345. break;
  346. retval = UA_Array_copy(srefs->targetIds, srefs->targetIdsSize,
  347. (void**)&drefs->targetIds,
  348. &UA_TYPES[UA_TYPES_EXPANDEDNODEID]);
  349. if(retval != UA_STATUSCODE_GOOD)
  350. break;
  351. drefs->targetIdsSize = srefs->targetIdsSize;
  352. break;
  353. }
  354. if(retval != UA_STATUSCODE_GOOD) {
  355. for(size_t k=0; k<i; k++) {
  356. UA_NodeReferenceKind *refs = &newReferences[i];
  357. for(size_t j = 0; j < refs->targetIdsSize; ++j)
  358. UA_ExpandedNodeId_deleteMembers(&refs->targetIds[j]);
  359. UA_Array_delete(refs->targetIds, refs->targetIdsSize, &UA_TYPES[UA_TYPES_EXPANDEDNODEID]);
  360. UA_NodeId_deleteMembers(&refs->referenceTypeId);
  361. }
  362. }
  363. }
  364. UA_Node_deleteReferences(node);
  365. if(retval == UA_STATUSCODE_GOOD) {
  366. node->references = newReferences;
  367. node->referencesSize = newSize;
  368. } else {
  369. UA_free(newReferences);
  370. }
  371. }
  372. static UA_StatusCode
  373. copyChildNode(UA_Server *server, UA_Session *session,
  374. const UA_NodeId *destinationNodeId,
  375. const UA_ReferenceDescription *rd) {
  376. UA_NodeId existingChild = UA_NODEID_NULL;
  377. UA_StatusCode retval =
  378. findChildByBrowsename(server, session, destinationNodeId,
  379. &rd->browseName, &existingChild);
  380. if(retval != UA_STATUSCODE_GOOD)
  381. return retval;
  382. /* Have a child with that browseName. Try to deep-copy missing members. */
  383. if(!UA_NodeId_isNull(&existingChild)) {
  384. if(rd->nodeClass == UA_NODECLASS_VARIABLE ||
  385. rd->nodeClass == UA_NODECLASS_OBJECT)
  386. retval = copyChildNodes(server, session, &rd->nodeId.nodeId, &existingChild);
  387. UA_NodeId_deleteMembers(&existingChild);
  388. return retval;
  389. }
  390. /* Is the child mandatory? If not, skip */
  391. if(!isMandatoryChild(server, session, &rd->nodeId.nodeId))
  392. return UA_STATUSCODE_GOOD;
  393. /* No existing child with that browsename. Create it. */
  394. if(rd->nodeClass == UA_NODECLASS_METHOD) {
  395. /* Add a reference to the method in the objecttype */
  396. UA_AddReferencesItem newItem;
  397. UA_AddReferencesItem_init(&newItem);
  398. newItem.sourceNodeId = *destinationNodeId;
  399. newItem.referenceTypeId = rd->referenceTypeId;
  400. newItem.isForward = true;
  401. newItem.targetNodeId = rd->nodeId;
  402. newItem.targetNodeClass = UA_NODECLASS_METHOD;
  403. Operation_addReference(server, session, NULL, &newItem, &retval);
  404. return retval;
  405. }
  406. /* Node exists and is a variable or object. Instantiate missing mandatory
  407. * children */
  408. if(rd->nodeClass == UA_NODECLASS_VARIABLE ||
  409. rd->nodeClass == UA_NODECLASS_OBJECT) {
  410. /* Get the node */
  411. UA_Node *node;
  412. retval = UA_Nodestore_getCopy(server, &rd->nodeId.nodeId, &node);
  413. if(retval != UA_STATUSCODE_GOOD)
  414. return retval;
  415. /* Get the type */
  416. const UA_Node *type = getNodeType(server, node);
  417. const UA_NodeId *typeId;
  418. if(type)
  419. typeId = &type->nodeId;
  420. else
  421. typeId = &UA_NODEID_NULL;
  422. /* Reset the NodeId (random numeric id will be assigned in the nodestore) */
  423. UA_NodeId_deleteMembers(&node->nodeId);
  424. node->nodeId.namespaceIndex = destinationNodeId->namespaceIndex;
  425. /* Remove references, they are re-created from scratch in addnode_finish */
  426. /* TODO: Be more clever in removing references that are re-added during
  427. * addnode_finish. That way, we can call addnode_finish also on children that were
  428. * manually added by the user during addnode_begin and addnode_finish. */
  429. /* For now we keep all the modelling rule references and delete all others */
  430. UA_NodeId modellingRuleReferenceId = UA_NODEID_NUMERIC(0, UA_NS0ID_HASMODELLINGRULE);
  431. deleteReferencesSubset(node, 1, &modellingRuleReferenceId);
  432. /* Add the node to the nodestore */
  433. UA_NodeId newNodeId;
  434. retval = UA_Nodestore_insert(server, node, &newNodeId);
  435. if(retval != UA_STATUSCODE_GOOD) {
  436. UA_Nodestore_release(server, type);
  437. return retval;
  438. }
  439. /* Add all the children of this child to the new child node to make sure we take
  440. * the values from the nearest inherited object first.
  441. */
  442. copyChildNodes(server, session, &rd->nodeId.nodeId, &newNodeId);
  443. /* Call addnode_finish, this recursively adds additional members, the type
  444. * definition and so on of the base type of this child, if they are not yet
  445. * in the destination */
  446. retval = Operation_addNode_finish(server, session, &newNodeId, destinationNodeId,
  447. &rd->referenceTypeId, typeId);
  448. UA_NodeId_deleteMembers(&newNodeId);
  449. UA_Nodestore_release(server, type);
  450. }
  451. return retval;
  452. }
  453. /* Copy any children of Node sourceNodeId to another node destinationNodeId. */
  454. static UA_StatusCode
  455. copyChildNodes(UA_Server *server, UA_Session *session,
  456. const UA_NodeId *sourceNodeId, const UA_NodeId *destinationNodeId) {
  457. /* Browse to get all children of the source */
  458. UA_BrowseDescription bd;
  459. UA_BrowseDescription_init(&bd);
  460. bd.nodeId = *sourceNodeId;
  461. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  462. bd.includeSubtypes = true;
  463. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  464. bd.nodeClassMask = UA_NODECLASS_OBJECT | UA_NODECLASS_VARIABLE | UA_NODECLASS_METHOD;
  465. bd.resultMask = UA_BROWSERESULTMASK_REFERENCETYPEID | UA_BROWSERESULTMASK_NODECLASS |
  466. UA_BROWSERESULTMASK_BROWSENAME;
  467. UA_BrowseResult br;
  468. UA_BrowseResult_init(&br);
  469. UA_UInt32 maxrefs = 0;
  470. Operation_Browse(server, session, &maxrefs, &bd, &br);
  471. if(br.statusCode != UA_STATUSCODE_GOOD)
  472. return br.statusCode;
  473. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  474. for(size_t i = 0; i < br.referencesSize; ++i) {
  475. UA_ReferenceDescription *rd = &br.references[i];
  476. retval |= copyChildNode(server, session, destinationNodeId, rd);
  477. }
  478. UA_BrowseResult_deleteMembers(&br);
  479. return retval;
  480. }
  481. static UA_StatusCode
  482. addChildren(UA_Server *server, UA_Session *session,
  483. const UA_Node *node, const UA_Node *type) {
  484. /* Get the hierarchy of the type and all its supertypes */
  485. UA_NodeId *hierarchy = NULL;
  486. size_t hierarchySize = 0;
  487. UA_StatusCode retval = getTypeHierarchy(&server->config.nodestore, &type->nodeId,
  488. &hierarchy, &hierarchySize);
  489. if(retval != UA_STATUSCODE_GOOD)
  490. return retval;
  491. /* Copy members of the type and supertypes (and instantiate them) */
  492. for(size_t i = 0; i < hierarchySize; ++i)
  493. retval |= copyChildNodes(server, session, &hierarchy[i], &node->nodeId);
  494. UA_Array_delete(hierarchy, hierarchySize, &UA_TYPES[UA_TYPES_NODEID]);
  495. return retval;
  496. }
  497. /* Calls the global destructor internally of the global constructor succeeds and
  498. * the type-level constructor fails. */
  499. static UA_StatusCode callConstructors(UA_Server *server, UA_Session *session,
  500. const UA_Node *node, const UA_Node *type) {
  501. /* Get the node type constructor */
  502. const UA_NodeTypeLifecycle *lifecycle = NULL;
  503. if(node->nodeClass == UA_NODECLASS_OBJECT) {
  504. const UA_ObjectTypeNode *ot = (const UA_ObjectTypeNode*)type;
  505. lifecycle = &ot->lifecycle;
  506. } else if(node->nodeClass == UA_NODECLASS_VARIABLE) {
  507. const UA_VariableTypeNode *vt = (const UA_VariableTypeNode*)type;
  508. lifecycle = &vt->lifecycle;
  509. }
  510. /* Call the global constructor */
  511. void *context = node->context;
  512. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  513. if(server->config.nodeLifecycle.constructor)
  514. retval = server->config.nodeLifecycle.constructor(server, &session->sessionId,
  515. session->sessionHandle,
  516. &node->nodeId, &context);
  517. /* Call the type constructor */
  518. if(retval == UA_STATUSCODE_GOOD && lifecycle && lifecycle->constructor)
  519. retval = lifecycle->constructor(server, &session->sessionId,
  520. session->sessionHandle, &type->nodeId,
  521. type->context, &node->nodeId, &context);
  522. /* Set the context *and* mark the node as constructed */
  523. if(retval == UA_STATUSCODE_GOOD)
  524. retval = UA_Server_editNode(server, &adminSession, &node->nodeId,
  525. (UA_EditNodeCallback)editNodeContext,
  526. context);
  527. /* Fail. Call the global destructor. */
  528. if(retval != UA_STATUSCODE_GOOD && server->config.nodeLifecycle.destructor)
  529. server->config.nodeLifecycle.destructor(server, &session->sessionId,
  530. session->sessionHandle,
  531. &node->nodeId, context);
  532. return retval;
  533. }
  534. static UA_StatusCode
  535. addTypeDefRef(UA_Server *server, UA_Session *session,
  536. const UA_Node *node, const UA_Node *type) {
  537. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  538. UA_AddReferencesItem addref;
  539. UA_AddReferencesItem_init(&addref);
  540. addref.sourceNodeId = node->nodeId;
  541. addref.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION);
  542. addref.isForward = true;
  543. addref.targetNodeId.nodeId = type->nodeId;
  544. Operation_addReference(server, session, NULL, &addref, &retval);
  545. return retval;
  546. }
  547. static UA_StatusCode
  548. addParentRef(UA_Server *server, UA_Session *session,
  549. const UA_NodeId *nodeId,
  550. const UA_NodeId *referenceTypeId,
  551. const UA_NodeId *parentNodeId) {
  552. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  553. UA_AddReferencesItem ref_item;
  554. UA_AddReferencesItem_init(&ref_item);
  555. ref_item.sourceNodeId = *nodeId;
  556. ref_item.referenceTypeId = *referenceTypeId;
  557. ref_item.isForward = false;
  558. ref_item.targetNodeId.nodeId = *parentNodeId;
  559. Operation_addReference(server, session, NULL, &ref_item, &retval);
  560. return retval;
  561. }
  562. /************/
  563. /* Add Node */
  564. /************/
  565. /* Prepare the node, then add it to the nodestore */
  566. UA_StatusCode
  567. Operation_addNode_begin(UA_Server *server, UA_Session *session, void *nodeContext,
  568. const UA_AddNodesItem *item, UA_NodeId *outNewNodeId) {
  569. /* Do not check access for server */
  570. if(session != &adminSession && server->config.accessControl.allowAddNode &&
  571. !server->config.accessControl.allowAddNode(&session->sessionId, session->sessionHandle, item)) {
  572. return UA_STATUSCODE_BADUSERACCESSDENIED;
  573. }
  574. /* Check the namespaceindex */
  575. if(item->requestedNewNodeId.nodeId.namespaceIndex >= server->namespacesSize) {
  576. UA_LOG_INFO_SESSION(server->config.logger, session,
  577. "AddNodes: Namespace invalid");
  578. return UA_STATUSCODE_BADNODEIDINVALID;
  579. }
  580. if(item->nodeAttributes.encoding != UA_EXTENSIONOBJECT_DECODED &&
  581. item->nodeAttributes.encoding != UA_EXTENSIONOBJECT_DECODED_NODELETE) {
  582. UA_LOG_INFO_SESSION(server->config.logger, session,
  583. "AddNodes: Node attributes invalid");
  584. return UA_STATUSCODE_BADINTERNALERROR;
  585. }
  586. /* Create a node */
  587. UA_Node *node = UA_Nodestore_new(server, item->nodeClass);
  588. if(!node) {
  589. UA_LOG_INFO_SESSION(server->config.logger, session,
  590. "AddNodes: Node could not create a node "
  591. "in the nodestore");
  592. return UA_STATUSCODE_BADOUTOFMEMORY;
  593. }
  594. /* Fill the node */
  595. node->context = nodeContext;
  596. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  597. retval |= UA_NodeId_copy(&item->requestedNewNodeId.nodeId, &node->nodeId);
  598. retval |= UA_QualifiedName_copy(&item->browseName, &node->browseName);
  599. retval |= UA_Node_setAttributes(node, item->nodeAttributes.content.decoded.data,
  600. item->nodeAttributes.content.decoded.type);
  601. if(retval != UA_STATUSCODE_GOOD) {
  602. UA_LOG_INFO_SESSION(server->config.logger, session,
  603. "AddNodes: Node could not create a node "
  604. "with error code %s",
  605. UA_StatusCode_name(retval));
  606. UA_Nodestore_delete(server, node);
  607. return retval;
  608. }
  609. if(server->bootstrapNS0)
  610. goto finished_checks;
  611. /* Use attributes from the typedefinition */
  612. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  613. node->nodeClass == UA_NODECLASS_VARIABLETYPE) {
  614. /* Use attributes from the type. The value and value constraints are the
  615. * same for the variable and variabletype attribute structs. */
  616. retval = useVariableTypeAttributes(server, session,
  617. (UA_VariableNode*)node, item);
  618. if(retval != UA_STATUSCODE_GOOD) {
  619. UA_LOG_INFO_SESSION(server->config.logger, session,
  620. "AddNodes: Using attributes from the variable type "
  621. "failed with error code %s",
  622. UA_StatusCode_name(retval));
  623. UA_Nodestore_delete(server, node);
  624. return retval;
  625. }
  626. }
  627. finished_checks:
  628. /* Add the node to the nodestore */
  629. retval = UA_Nodestore_insert(server, node, outNewNodeId);
  630. if(retval != UA_STATUSCODE_GOOD) {
  631. UA_LOG_INFO_SESSION(server->config.logger, session,
  632. "AddNodes: Node could not add the new node "
  633. "to the nodestore with error code %s",
  634. UA_StatusCode_name(retval));
  635. }
  636. return retval;
  637. }
  638. static void
  639. removeDeconstructedNode(UA_Server *server, UA_Session *session,
  640. const UA_Node *node, UA_Boolean removeTargetRefs);
  641. static const UA_NodeId hasSubtype = {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASSUBTYPE}};
  642. /* Children, references, type-checking, constructors. */
  643. UA_StatusCode
  644. Operation_addNode_finish(UA_Server *server, UA_Session *session, const UA_NodeId *nodeId,
  645. const UA_NodeId *parentNodeId, const UA_NodeId *referenceTypeId,
  646. const UA_NodeId *typeDefinitionId) {
  647. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  648. const UA_Node *type = NULL;
  649. /* Get the node */
  650. const UA_Node *node = UA_Nodestore_get(server, nodeId);
  651. if(!node)
  652. return UA_STATUSCODE_BADNODEIDUNKNOWN;
  653. /* Use the typeDefinition as parent for type-nodes */
  654. if(node->nodeClass == UA_NODECLASS_VARIABLETYPE ||
  655. node->nodeClass == UA_NODECLASS_OBJECTTYPE ||
  656. node->nodeClass == UA_NODECLASS_REFERENCETYPE ||
  657. node->nodeClass == UA_NODECLASS_DATATYPE) {
  658. if(UA_NodeId_equal(referenceTypeId, &UA_NODEID_NULL))
  659. referenceTypeId = &hasSubtype;
  660. const UA_Node *parentNode = UA_Nodestore_get(server, parentNodeId);
  661. if(parentNode) {
  662. if(parentNode->nodeClass == node->nodeClass)
  663. typeDefinitionId = parentNodeId;
  664. UA_Nodestore_release(server, parentNode);
  665. }
  666. }
  667. if(server->bootstrapNS0)
  668. goto get_type;
  669. /* Check parent reference. Objects may have no parent. */
  670. retval = checkParentReference(server, session, node->nodeClass,
  671. parentNodeId, referenceTypeId);
  672. if(retval != UA_STATUSCODE_GOOD) {
  673. UA_LOG_INFO_SESSION(server->config.logger, session,
  674. "AddNodes: The parent reference is invalid");
  675. UA_Nodestore_release(server, node);
  676. UA_Server_deleteNode(server, *nodeId, true);
  677. return retval;
  678. }
  679. /* Replace empty typeDefinition with the most permissive default */
  680. if((node->nodeClass == UA_NODECLASS_VARIABLE ||
  681. node->nodeClass == UA_NODECLASS_OBJECT) &&
  682. UA_NodeId_isNull(typeDefinitionId)) {
  683. UA_LOG_INFO_SESSION(server->config.logger, session,
  684. "AddNodes: No TypeDefinition; Use the default "
  685. "TypeDefinition for the Variable/Object");
  686. if(node->nodeClass == UA_NODECLASS_VARIABLE)
  687. typeDefinitionId = &baseDataVariableType;
  688. else
  689. typeDefinitionId = &baseObjectType;
  690. }
  691. get_type:
  692. /* Get the node type. There must be a typedefinition for variables, objects
  693. * and type-nodes. See the above checks. */
  694. if(!UA_NodeId_isNull(typeDefinitionId)) {
  695. /* Get the type node */
  696. type = UA_Nodestore_get(server, typeDefinitionId);
  697. if(!type) {
  698. UA_LOG_INFO_SESSION(server->config.logger, session,
  699. "AddNodes: Node type not found in nodestore");
  700. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  701. goto cleanup;
  702. }
  703. UA_Boolean typeOk = UA_FALSE;
  704. switch(node->nodeClass) {
  705. case UA_NODECLASS_DATATYPE:
  706. typeOk = type->nodeClass == UA_NODECLASS_DATATYPE;
  707. break;
  708. case UA_NODECLASS_METHOD:
  709. typeOk = type->nodeClass == UA_NODECLASS_METHOD;
  710. break;
  711. case UA_NODECLASS_OBJECT:
  712. typeOk = type->nodeClass == UA_NODECLASS_OBJECTTYPE;
  713. break;
  714. case UA_NODECLASS_OBJECTTYPE:
  715. typeOk = type->nodeClass == UA_NODECLASS_OBJECTTYPE;
  716. break;
  717. case UA_NODECLASS_REFERENCETYPE:
  718. typeOk = type->nodeClass == UA_NODECLASS_REFERENCETYPE;
  719. break;
  720. case UA_NODECLASS_VARIABLE:
  721. typeOk = type->nodeClass == UA_NODECLASS_VARIABLETYPE;
  722. break;
  723. case UA_NODECLASS_VARIABLETYPE:
  724. typeOk = type->nodeClass == UA_NODECLASS_VARIABLETYPE;
  725. break;
  726. case UA_NODECLASS_VIEW:
  727. typeOk = type->nodeClass == UA_NODECLASS_VIEW;
  728. break;
  729. default:
  730. typeOk = UA_FALSE;
  731. }
  732. if(!typeOk) {
  733. UA_LOG_INFO_SESSION(server->config.logger, session,
  734. "AddNodes: Type does not match node class");
  735. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  736. goto cleanup;
  737. }
  738. /* See if the type has the correct node class. For type-nodes, we know
  739. * that type has the same nodeClass from checkParentReference. */
  740. if(!server->bootstrapNS0 && node->nodeClass == UA_NODECLASS_VARIABLE) {
  741. if(((const UA_VariableTypeNode*)type)->isAbstract) {
  742. /* Abstract variable is allowed if parent is a children of a base data variable */
  743. const UA_NodeId variableTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE);
  744. /* A variable may be of an object type which again is below BaseObjectType */
  745. const UA_NodeId objectTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE);
  746. UA_NodeId refs[2];
  747. refs[0] = UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE);
  748. refs[1] = UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT);
  749. if(!isNodeInTree(&server->config.nodestore, parentNodeId, &variableTypes, refs, 2) &&
  750. !isNodeInTree(&server->config.nodestore, parentNodeId, &objectTypes, refs, 2)) {
  751. UA_LOG_INFO_SESSION(server->config.logger, session,
  752. "AddNodes: Type of variable node must "
  753. "be VariableType and not cannot be abstract");
  754. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  755. goto cleanup;
  756. }
  757. }
  758. }
  759. if(!server->bootstrapNS0 && node->nodeClass == UA_NODECLASS_OBJECT) {
  760. if(((const UA_ObjectTypeNode*)type)->isAbstract) {
  761. /* Object node created of an abstract ObjectType. Only allowed if within BaseObjectType folder */
  762. const UA_NodeId objectTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE);
  763. UA_NodeId refs[2];
  764. refs[0] = UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE);
  765. refs[1] = UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT);
  766. if(!isNodeInTree(&server->config.nodestore, parentNodeId, &objectTypes, refs, 2)) {
  767. UA_LOG_INFO_SESSION(server->config.logger, session,
  768. "AddNodes: Type of object node must "
  769. "be ObjectType and not be abstract");
  770. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  771. goto cleanup;
  772. }
  773. }
  774. }
  775. }
  776. /* Check if all attributes hold the constraints of the type now. The initial
  777. * attributes must type-check. The constructor might change the attributes
  778. * again. Then, the changes are type-checked by the normal write service. */
  779. if(type && (node->nodeClass == UA_NODECLASS_VARIABLE ||
  780. node->nodeClass == UA_NODECLASS_VARIABLETYPE)) {
  781. retval = typeCheckVariableNode(server, session,
  782. (const UA_VariableNode*)node,
  783. (const UA_VariableTypeNode*)type, parentNodeId);
  784. if(retval != UA_STATUSCODE_GOOD) {
  785. UA_LOG_INFO_SESSION(server->config.logger, session,
  786. "AddNodes: Type-checking the variable node "
  787. "failed with error code %s", UA_StatusCode_name(retval));
  788. goto cleanup;
  789. }
  790. }
  791. /* Instantiate variables and objects */
  792. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  793. node->nodeClass == UA_NODECLASS_OBJECT) {
  794. UA_assert(type != NULL); /* see above */
  795. /* Add (mandatory) child nodes from the type definition */
  796. if(!server->bootstrapNS0) {
  797. retval = addChildren(server, session, node, type);
  798. if(retval != UA_STATUSCODE_GOOD) {
  799. UA_LOG_INFO_SESSION(server->config.logger, session,
  800. "AddNodes: Adding child nodes failed with error code %s",
  801. UA_StatusCode_name(retval));
  802. goto cleanup;
  803. }
  804. }
  805. /* Add a hasTypeDefinition reference */
  806. retval = addTypeDefRef(server, session, node, type);
  807. if(retval != UA_STATUSCODE_GOOD) {
  808. UA_LOG_INFO_SESSION(server->config.logger, session,
  809. "AddNodes: Adding a reference to the type "
  810. "definition failed with error code %s",
  811. UA_StatusCode_name(retval));
  812. goto cleanup;
  813. }
  814. }
  815. /* Add reference to the parent */
  816. if(!UA_NodeId_isNull(parentNodeId)) {
  817. if(UA_NodeId_isNull(referenceTypeId)) {
  818. UA_LOG_INFO_SESSION(server->config.logger, session,
  819. "AddNodes: Reference to parent cannot be null");
  820. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  821. goto cleanup;
  822. }
  823. retval = addParentRef(server, session, nodeId, referenceTypeId, parentNodeId);
  824. if(retval != UA_STATUSCODE_GOOD) {
  825. UA_LOG_INFO_SESSION(server->config.logger, session,
  826. "AddNodes: Adding reference to parent failed");
  827. goto cleanup;
  828. }
  829. }
  830. /* Call the constructor(s) */
  831. retval = callConstructors(server, session, node, type);
  832. if(retval != UA_STATUSCODE_GOOD) {
  833. UA_LOG_INFO_SESSION(server->config.logger, session,
  834. "AddNodes: Calling the node constructor(s) failed "
  835. "with status code %s", UA_StatusCode_name(retval));
  836. }
  837. cleanup:
  838. if(type)
  839. UA_Nodestore_release(server, type);
  840. if(retval != UA_STATUSCODE_GOOD)
  841. removeDeconstructedNode(server, session, node, true);
  842. UA_Nodestore_release(server, node);
  843. return retval;
  844. }
  845. static void
  846. Operation_addNode(UA_Server *server, UA_Session *session, void *nodeContext,
  847. const UA_AddNodesItem *item, UA_AddNodesResult *result) {
  848. result->statusCode = Operation_addNode_begin(server, session, nodeContext,
  849. item, &result->addedNodeId);
  850. if(result->statusCode != UA_STATUSCODE_GOOD)
  851. return;
  852. /* AddNodes_finish */
  853. result->statusCode =
  854. Operation_addNode_finish(server, session, &result->addedNodeId,
  855. &item->parentNodeId.nodeId, &item->referenceTypeId,
  856. &item->typeDefinition.nodeId);
  857. /* If finishing failed, the node was deleted */
  858. if(result->statusCode != UA_STATUSCODE_GOOD)
  859. UA_NodeId_deleteMembers(&result->addedNodeId);
  860. }
  861. void
  862. Service_AddNodes(UA_Server *server, UA_Session *session,
  863. const UA_AddNodesRequest *request,
  864. UA_AddNodesResponse *response) {
  865. UA_LOG_DEBUG_SESSION(server->config.logger, session, "Processing AddNodesRequest");
  866. if(server->config.maxNodesPerNodeManagement != 0 &&
  867. request->nodesToAddSize > server->config.maxNodesPerNodeManagement) {
  868. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  869. return;
  870. }
  871. response->responseHeader.serviceResult =
  872. UA_Server_processServiceOperations(server, session, (UA_ServiceOperation)Operation_addNode, NULL,
  873. &request->nodesToAddSize, &UA_TYPES[UA_TYPES_ADDNODESITEM],
  874. &response->resultsSize, &UA_TYPES[UA_TYPES_ADDNODESRESULT]);
  875. }
  876. UA_StatusCode
  877. __UA_Server_addNode(UA_Server *server, const UA_NodeClass nodeClass,
  878. const UA_NodeId *requestedNewNodeId,
  879. const UA_NodeId *parentNodeId,
  880. const UA_NodeId *referenceTypeId,
  881. const UA_QualifiedName browseName,
  882. const UA_NodeId *typeDefinition,
  883. const UA_NodeAttributes *attr,
  884. const UA_DataType *attributeType,
  885. void *nodeContext, UA_NodeId *outNewNodeId) {
  886. /* Create the AddNodesItem */
  887. UA_AddNodesItem item;
  888. UA_AddNodesItem_init(&item);
  889. item.nodeClass = nodeClass;
  890. item.requestedNewNodeId.nodeId = *requestedNewNodeId;
  891. item.browseName = browseName;
  892. item.parentNodeId.nodeId = *parentNodeId;
  893. item.referenceTypeId = *referenceTypeId;
  894. item.typeDefinition.nodeId = *typeDefinition;
  895. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  896. item.nodeAttributes.content.decoded.type = attributeType;
  897. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)attr;
  898. /* Call the normal addnodes service */
  899. UA_AddNodesResult result;
  900. UA_AddNodesResult_init(&result);
  901. Operation_addNode(server, &adminSession, nodeContext, &item, &result);
  902. if(outNewNodeId)
  903. *outNewNodeId = result.addedNodeId;
  904. else
  905. UA_NodeId_deleteMembers(&result.addedNodeId);
  906. return result.statusCode;
  907. }
  908. UA_StatusCode
  909. UA_Server_addNode_begin(UA_Server *server, const UA_NodeClass nodeClass,
  910. const UA_NodeId requestedNewNodeId,
  911. const UA_QualifiedName browseName,
  912. const UA_NodeId typeDefinition,
  913. const void *attr, const UA_DataType *attributeType,
  914. void *nodeContext, UA_NodeId *outNewNodeId) {
  915. UA_AddNodesItem item;
  916. UA_AddNodesItem_init(&item);
  917. item.nodeClass = nodeClass;
  918. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  919. item.browseName = browseName;
  920. item.typeDefinition.nodeId = typeDefinition;
  921. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  922. item.nodeAttributes.content.decoded.type = attributeType;
  923. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)attr;
  924. return Operation_addNode_begin(server, &adminSession, nodeContext,
  925. &item, outNewNodeId);
  926. }
  927. UA_StatusCode
  928. UA_Server_addNode_finish(UA_Server *server, const UA_NodeId nodeId,
  929. const UA_NodeId parentNodeId,
  930. const UA_NodeId referenceTypeId,
  931. const UA_NodeId typeDefinitionId) {
  932. return Operation_addNode_finish(server, &adminSession, &nodeId, &parentNodeId,
  933. &referenceTypeId, &typeDefinitionId);
  934. }
  935. /****************/
  936. /* Delete Nodes */
  937. /****************/
  938. static void
  939. Operation_deleteReference(UA_Server *server, UA_Session *session, void *context,
  940. const UA_DeleteReferencesItem *item, UA_StatusCode *retval);
  941. /* Remove references to this node (in the other nodes) */
  942. static void
  943. removeIncomingReferences(UA_Server *server, UA_Session *session,
  944. const UA_Node *node) {
  945. UA_DeleteReferencesItem item;
  946. UA_DeleteReferencesItem_init(&item);
  947. item.targetNodeId.nodeId = node->nodeId;
  948. item.deleteBidirectional = false;
  949. UA_StatusCode dummy;
  950. for(size_t i = 0; i < node->referencesSize; ++i) {
  951. UA_NodeReferenceKind *refs = &node->references[i];
  952. item.isForward = refs->isInverse;
  953. item.referenceTypeId = refs->referenceTypeId;
  954. for(size_t j = 0; j < refs->targetIdsSize; ++j) {
  955. item.sourceNodeId = refs->targetIds[j].nodeId;
  956. Operation_deleteReference(server, session, NULL, &item, &dummy);
  957. }
  958. }
  959. }
  960. static void
  961. deconstructNode(UA_Server *server, UA_Session *session,
  962. const UA_Node *node) {
  963. /* Call the type-level destructor */
  964. void *context = node->context; /* No longer needed after this function */
  965. if(node->nodeClass == UA_NODECLASS_OBJECT ||
  966. node->nodeClass == UA_NODECLASS_VARIABLE) {
  967. const UA_Node *type = getNodeType(server, node);
  968. if(type) {
  969. const UA_NodeTypeLifecycle *lifecycle;
  970. if(node->nodeClass == UA_NODECLASS_OBJECT)
  971. lifecycle = &((const UA_ObjectTypeNode*)type)->lifecycle;
  972. else
  973. lifecycle = &((const UA_VariableTypeNode*)type)->lifecycle;
  974. if(lifecycle->destructor)
  975. lifecycle->destructor(server,
  976. &session->sessionId, session->sessionHandle,
  977. &type->nodeId, type->context,
  978. &node->nodeId, &context);
  979. UA_Nodestore_release(server, type);
  980. }
  981. }
  982. /* Call the global destructor */
  983. if(server->config.nodeLifecycle.destructor)
  984. server->config.nodeLifecycle.destructor(server, &session->sessionId,
  985. session->sessionHandle,
  986. &node->nodeId, context);
  987. }
  988. static void
  989. deleteNodeOperation(UA_Server *server, UA_Session *session, void *context,
  990. const UA_DeleteNodesItem *item, UA_StatusCode *result);
  991. static void
  992. removeChildren(UA_Server *server, UA_Session *session,
  993. const UA_Node *node) {
  994. /* Browse to get all children of the node */
  995. UA_BrowseDescription bd;
  996. UA_BrowseDescription_init(&bd);
  997. bd.nodeId = node->nodeId;
  998. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  999. bd.includeSubtypes = true;
  1000. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  1001. bd.nodeClassMask = UA_NODECLASS_OBJECT | UA_NODECLASS_VARIABLE | UA_NODECLASS_METHOD;
  1002. bd.resultMask = UA_BROWSERESULTMASK_NONE;
  1003. UA_BrowseResult br;
  1004. UA_BrowseResult_init(&br);
  1005. UA_UInt32 maxrefs = 0;
  1006. Operation_Browse(server, session, &maxrefs, &bd, &br);
  1007. if(br.statusCode != UA_STATUSCODE_GOOD)
  1008. return;
  1009. UA_DeleteNodesItem item;
  1010. item.deleteTargetReferences = true;
  1011. /* Remove every child */
  1012. for(size_t i = 0; i < br.referencesSize; ++i) {
  1013. UA_ReferenceDescription *rd = &br.references[i];
  1014. // check for self-reference to avoid endless loop
  1015. if(UA_NodeId_equal(&node->nodeId, &rd->nodeId.nodeId))
  1016. continue;
  1017. item.nodeId = rd->nodeId.nodeId;
  1018. UA_StatusCode retval;
  1019. deleteNodeOperation(server, session, NULL, &item, &retval);
  1020. }
  1021. UA_BrowseResult_deleteMembers(&br);
  1022. }
  1023. static void
  1024. removeDeconstructedNode(UA_Server *server, UA_Session *session,
  1025. const UA_Node *node, UA_Boolean removeTargetRefs) {
  1026. /* Remove all children of the node */
  1027. removeChildren(server, session, node);
  1028. /* Remove references to the node (not the references going out, as the node
  1029. * will be deleted anyway) */
  1030. if(removeTargetRefs)
  1031. removeIncomingReferences(server, session, node);
  1032. /* Remove the node in the nodestore */
  1033. UA_Nodestore_remove(server, &node->nodeId);
  1034. }
  1035. static void
  1036. deleteNodeOperation(UA_Server *server, UA_Session *session, void *context,
  1037. const UA_DeleteNodesItem *item, UA_StatusCode *result) {
  1038. /* Do not check access for server */
  1039. if(session != &adminSession && server->config.accessControl.allowDeleteNode &&
  1040. !server->config.accessControl.allowDeleteNode(&session->sessionId, session->sessionHandle, item)) {
  1041. *result = UA_STATUSCODE_BADUSERACCESSDENIED;
  1042. return;
  1043. }
  1044. const UA_Node *node = UA_Nodestore_get(server, &item->nodeId);
  1045. if(!node) {
  1046. *result = UA_STATUSCODE_BADNODEIDUNKNOWN;
  1047. return;
  1048. }
  1049. if(UA_Node_hasSubTypeOrInstances(node)) {
  1050. UA_LOG_INFO_SESSION(server->config.logger, session,
  1051. "Delete Nodes: Cannot delete a type node "
  1052. "with active instances or subtypes");
  1053. UA_Nodestore_release(server, node);
  1054. *result = UA_STATUSCODE_BADINTERNALERROR;
  1055. return;
  1056. }
  1057. /* TODO: Check if the information model consistency is violated */
  1058. /* TODO: Check if the node is a mandatory child of a parent */
  1059. deconstructNode(server, session, node);
  1060. removeDeconstructedNode(server, session, node, item->deleteTargetReferences);
  1061. UA_Nodestore_release(server, node);
  1062. }
  1063. void Service_DeleteNodes(UA_Server *server, UA_Session *session,
  1064. const UA_DeleteNodesRequest *request,
  1065. UA_DeleteNodesResponse *response) {
  1066. UA_LOG_DEBUG_SESSION(server->config.logger, session,
  1067. "Processing DeleteNodesRequest");
  1068. if(server->config.maxNodesPerNodeManagement != 0 &&
  1069. request->nodesToDeleteSize > server->config.maxNodesPerNodeManagement) {
  1070. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1071. return;
  1072. }
  1073. response->responseHeader.serviceResult =
  1074. UA_Server_processServiceOperations(server, session, (UA_ServiceOperation)deleteNodeOperation, NULL,
  1075. &request->nodesToDeleteSize, &UA_TYPES[UA_TYPES_DELETENODESITEM],
  1076. &response->resultsSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
  1077. }
  1078. UA_StatusCode
  1079. UA_Server_deleteNode(UA_Server *server, const UA_NodeId nodeId,
  1080. UA_Boolean deleteReferences) {
  1081. UA_DeleteNodesItem item;
  1082. item.deleteTargetReferences = deleteReferences;
  1083. item.nodeId = nodeId;
  1084. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1085. deleteNodeOperation(server, &adminSession, NULL, &item, &retval);
  1086. return retval;
  1087. }
  1088. /******************/
  1089. /* Add References */
  1090. /******************/
  1091. static UA_StatusCode
  1092. addOneWayReference(UA_Server *server, UA_Session *session,
  1093. UA_Node *node, const UA_AddReferencesItem *item) {
  1094. return UA_Node_addReference(node, item);
  1095. }
  1096. static UA_StatusCode
  1097. deleteOneWayReference(UA_Server *server, UA_Session *session, UA_Node *node,
  1098. const UA_DeleteReferencesItem *item) {
  1099. return UA_Node_deleteReference(node, item);
  1100. }
  1101. static void
  1102. Operation_addReference(UA_Server *server, UA_Session *session, void *context,
  1103. const UA_AddReferencesItem *item, UA_StatusCode *retval) {
  1104. /* Do not check access for server */
  1105. if(session != &adminSession && server->config.accessControl.allowAddReference &&
  1106. !server->config.accessControl. allowAddReference(&session->sessionId, session->sessionHandle, item)) {
  1107. *retval = UA_STATUSCODE_BADUSERACCESSDENIED;
  1108. return;
  1109. }
  1110. /* Currently no expandednodeids are allowed */
  1111. if(item->targetServerUri.length > 0) {
  1112. *retval = UA_STATUSCODE_BADNOTIMPLEMENTED;
  1113. return;
  1114. }
  1115. /* Add the first direction */
  1116. *retval = UA_Server_editNode(server, session, &item->sourceNodeId,
  1117. (UA_EditNodeCallback)addOneWayReference, item);
  1118. if(*retval != UA_STATUSCODE_GOOD)
  1119. return;
  1120. /* Add the second direction */
  1121. UA_AddReferencesItem secondItem;
  1122. UA_AddReferencesItem_init(&secondItem);
  1123. secondItem.sourceNodeId = item->targetNodeId.nodeId;
  1124. secondItem.referenceTypeId = item->referenceTypeId;
  1125. secondItem.isForward = !item->isForward;
  1126. secondItem.targetNodeId.nodeId = item->sourceNodeId;
  1127. /* keep default secondItem.targetNodeClass = UA_NODECLASS_UNSPECIFIED */
  1128. *retval = UA_Server_editNode(server, session, &secondItem.sourceNodeId,
  1129. (UA_EditNodeCallback)addOneWayReference, &secondItem);
  1130. /* remove reference if the second direction failed */
  1131. if(*retval != UA_STATUSCODE_GOOD) {
  1132. UA_DeleteReferencesItem deleteItem;
  1133. deleteItem.sourceNodeId = item->sourceNodeId;
  1134. deleteItem.referenceTypeId = item->referenceTypeId;
  1135. deleteItem.isForward = item->isForward;
  1136. deleteItem.targetNodeId = item->targetNodeId;
  1137. deleteItem.deleteBidirectional = false;
  1138. /* ignore returned status code */
  1139. UA_Server_editNode(server, session, &item->sourceNodeId,
  1140. (UA_EditNodeCallback)deleteOneWayReference, &deleteItem);
  1141. }
  1142. }
  1143. void Service_AddReferences(UA_Server *server, UA_Session *session,
  1144. const UA_AddReferencesRequest *request,
  1145. UA_AddReferencesResponse *response) {
  1146. UA_LOG_DEBUG_SESSION(server->config.logger, session,
  1147. "Processing AddReferencesRequest");
  1148. if(server->config.maxNodesPerNodeManagement != 0 &&
  1149. request->referencesToAddSize > server->config.maxNodesPerNodeManagement) {
  1150. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1151. return;
  1152. }
  1153. response->responseHeader.serviceResult =
  1154. UA_Server_processServiceOperations(server, session, (UA_ServiceOperation)Operation_addReference, NULL,
  1155. &request->referencesToAddSize, &UA_TYPES[UA_TYPES_ADDREFERENCESITEM],
  1156. &response->resultsSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
  1157. }
  1158. UA_StatusCode
  1159. UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId,
  1160. const UA_NodeId refTypeId,
  1161. const UA_ExpandedNodeId targetId,
  1162. UA_Boolean isForward) {
  1163. UA_AddReferencesItem item;
  1164. UA_AddReferencesItem_init(&item);
  1165. item.sourceNodeId = sourceId;
  1166. item.referenceTypeId = refTypeId;
  1167. item.isForward = isForward;
  1168. item.targetNodeId = targetId;
  1169. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1170. Operation_addReference(server, &adminSession, NULL, &item, &retval);
  1171. return retval;
  1172. }
  1173. /*********************/
  1174. /* Delete References */
  1175. /*********************/
  1176. static void
  1177. Operation_deleteReference(UA_Server *server, UA_Session *session, void *context,
  1178. const UA_DeleteReferencesItem *item, UA_StatusCode *retval) {
  1179. /* Do not check access for server */
  1180. if(session != &adminSession && server->config.accessControl.allowDeleteReference &&
  1181. !server->config.accessControl.allowDeleteReference(&session->sessionId, session->sessionHandle, item)) {
  1182. *retval = UA_STATUSCODE_BADUSERACCESSDENIED;
  1183. return;
  1184. }
  1185. // TODO: Check consistency constraints, remove the references.
  1186. *retval = UA_Server_editNode(server, session, &item->sourceNodeId,
  1187. (UA_EditNodeCallback)deleteOneWayReference, item);
  1188. if(*retval != UA_STATUSCODE_GOOD)
  1189. return;
  1190. if(!item->deleteBidirectional || item->targetNodeId.serverIndex != 0)
  1191. return;
  1192. UA_DeleteReferencesItem secondItem;
  1193. UA_DeleteReferencesItem_init(&secondItem);
  1194. secondItem.isForward = !item->isForward;
  1195. secondItem.sourceNodeId = item->targetNodeId.nodeId;
  1196. secondItem.targetNodeId.nodeId = item->sourceNodeId;
  1197. secondItem.referenceTypeId = item->referenceTypeId;
  1198. *retval = UA_Server_editNode(server, session, &secondItem.sourceNodeId,
  1199. (UA_EditNodeCallback)deleteOneWayReference,
  1200. &secondItem);
  1201. }
  1202. void
  1203. Service_DeleteReferences(UA_Server *server, UA_Session *session,
  1204. const UA_DeleteReferencesRequest *request,
  1205. UA_DeleteReferencesResponse *response) {
  1206. UA_LOG_DEBUG_SESSION(server->config.logger, session,
  1207. "Processing DeleteReferencesRequest");
  1208. if(server->config.maxNodesPerNodeManagement != 0 &&
  1209. request->referencesToDeleteSize > server->config.maxNodesPerNodeManagement) {
  1210. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1211. return;
  1212. }
  1213. response->responseHeader.serviceResult =
  1214. UA_Server_processServiceOperations(server, session, (UA_ServiceOperation)Operation_deleteReference, NULL,
  1215. &request->referencesToDeleteSize, &UA_TYPES[UA_TYPES_DELETEREFERENCESITEM],
  1216. &response->resultsSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
  1217. }
  1218. UA_StatusCode
  1219. UA_Server_deleteReference(UA_Server *server, const UA_NodeId sourceNodeId,
  1220. const UA_NodeId referenceTypeId, UA_Boolean isForward,
  1221. const UA_ExpandedNodeId targetNodeId,
  1222. UA_Boolean deleteBidirectional) {
  1223. UA_DeleteReferencesItem item;
  1224. item.sourceNodeId = sourceNodeId;
  1225. item.referenceTypeId = referenceTypeId;
  1226. item.isForward = isForward;
  1227. item.targetNodeId = targetNodeId;
  1228. item.deleteBidirectional = deleteBidirectional;
  1229. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1230. Operation_deleteReference(server, &adminSession, NULL, &item, &retval);
  1231. return retval;
  1232. }
  1233. /**********************/
  1234. /* Set Value Callback */
  1235. /**********************/
  1236. static UA_StatusCode
  1237. setValueCallback(UA_Server *server, UA_Session *session,
  1238. UA_VariableNode *node, UA_ValueCallback *callback) {
  1239. if(node->nodeClass != UA_NODECLASS_VARIABLE)
  1240. return UA_STATUSCODE_BADNODECLASSINVALID;
  1241. node->value.data.callback = *callback;
  1242. return UA_STATUSCODE_GOOD;
  1243. }
  1244. UA_StatusCode
  1245. UA_Server_setVariableNode_valueCallback(UA_Server *server,
  1246. const UA_NodeId nodeId,
  1247. const UA_ValueCallback callback) {
  1248. return UA_Server_editNode(server, &adminSession, &nodeId,
  1249. (UA_EditNodeCallback)setValueCallback, &callback);
  1250. }
  1251. /***************************************************/
  1252. /* Special Handling of Variables with Data Sources */
  1253. /***************************************************/
  1254. UA_StatusCode
  1255. UA_Server_addDataSourceVariableNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  1256. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  1257. const UA_QualifiedName browseName, const UA_NodeId typeDefinition,
  1258. const UA_VariableAttributes attr, const UA_DataSource dataSource,
  1259. void *nodeContext, UA_NodeId *outNewNodeId) {
  1260. UA_AddNodesItem item;
  1261. UA_AddNodesItem_init(&item);
  1262. item.nodeClass = UA_NODECLASS_VARIABLE;
  1263. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  1264. item.browseName = browseName;
  1265. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  1266. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)&attr;
  1267. item.nodeAttributes.content.decoded.type = &UA_TYPES[UA_TYPES_VARIABLEATTRIBUTES];
  1268. UA_NodeId newNodeId;
  1269. UA_Boolean deleteNodeId = UA_FALSE;
  1270. if(!outNewNodeId) {
  1271. newNodeId = UA_NODEID_NULL;
  1272. outNewNodeId = &newNodeId;
  1273. deleteNodeId = UA_TRUE;
  1274. }
  1275. UA_StatusCode retval = Operation_addNode_begin(server, &adminSession, nodeContext,
  1276. &item, outNewNodeId);
  1277. if(retval != UA_STATUSCODE_GOOD)
  1278. return retval;
  1279. retval = UA_Server_setVariableNode_dataSource(server, *outNewNodeId, dataSource);
  1280. if(retval == UA_STATUSCODE_GOOD)
  1281. retval = Operation_addNode_finish(server, &adminSession, outNewNodeId,
  1282. &parentNodeId, &referenceTypeId, &typeDefinition);
  1283. if(retval != UA_STATUSCODE_GOOD || deleteNodeId)
  1284. UA_NodeId_deleteMembers(outNewNodeId);
  1285. return retval;
  1286. }
  1287. static UA_StatusCode
  1288. setDataSource(UA_Server *server, UA_Session *session,
  1289. UA_VariableNode* node, UA_DataSource *dataSource) {
  1290. if(node->nodeClass != UA_NODECLASS_VARIABLE)
  1291. return UA_STATUSCODE_BADNODECLASSINVALID;
  1292. if(node->valueSource == UA_VALUESOURCE_DATA)
  1293. UA_DataValue_deleteMembers(&node->value.data.value);
  1294. node->value.dataSource = *dataSource;
  1295. node->valueSource = UA_VALUESOURCE_DATASOURCE;
  1296. return UA_STATUSCODE_GOOD;
  1297. }
  1298. UA_StatusCode
  1299. UA_Server_setVariableNode_dataSource(UA_Server *server, const UA_NodeId nodeId,
  1300. const UA_DataSource dataSource) {
  1301. return UA_Server_editNode(server, &adminSession, &nodeId,
  1302. (UA_EditNodeCallback)setDataSource,
  1303. &dataSource);
  1304. }
  1305. /************************************/
  1306. /* Special Handling of Method Nodes */
  1307. /************************************/
  1308. #ifdef UA_ENABLE_METHODCALLS
  1309. static const UA_NodeId hasproperty = {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASPROPERTY}};
  1310. static const UA_NodeId propertytype = {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_PROPERTYTYPE}};
  1311. static UA_StatusCode
  1312. UA_Server_addMethodNodeEx_finish(UA_Server *server, const UA_NodeId nodeId,
  1313. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  1314. UA_MethodCallback method,
  1315. const size_t inputArgumentsSize, const UA_Argument *inputArguments,
  1316. const UA_NodeId inputArgumentsRequestedNewNodeId,
  1317. UA_NodeId *inputArgumentsOutNewNodeId,
  1318. const size_t outputArgumentsSize, const UA_Argument *outputArguments,
  1319. const UA_NodeId outputArgumentsRequestedNewNodeId,
  1320. UA_NodeId *outputArgumentsOutNewNodeId) {
  1321. /* Browse to see which argument nodes exist */
  1322. UA_BrowseDescription bd;
  1323. UA_BrowseDescription_init(&bd);
  1324. bd.nodeId = nodeId;
  1325. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY);
  1326. bd.includeSubtypes = false;
  1327. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  1328. bd.nodeClassMask = UA_NODECLASS_VARIABLE;
  1329. bd.resultMask = UA_BROWSERESULTMASK_BROWSENAME;
  1330. UA_BrowseResult br;
  1331. UA_BrowseResult_init(&br);
  1332. UA_UInt32 maxrefs = 0;
  1333. Operation_Browse(server, &adminSession, &maxrefs, &bd, &br);
  1334. UA_StatusCode retval = br.statusCode;
  1335. if(retval != UA_STATUSCODE_GOOD) {
  1336. UA_Server_deleteNode(server, nodeId, true);
  1337. UA_BrowseResult_deleteMembers(&br);
  1338. return retval;
  1339. }
  1340. /* Filter out the argument nodes */
  1341. UA_NodeId inputArgsId = UA_NODEID_NULL;
  1342. UA_NodeId outputArgsId = UA_NODEID_NULL;
  1343. const UA_QualifiedName inputArgsName = UA_QUALIFIEDNAME(0, "InputArguments");
  1344. const UA_QualifiedName outputArgsName = UA_QUALIFIEDNAME(0, "OutputArguments");
  1345. for(size_t i = 0; i < br.referencesSize; i++) {
  1346. UA_ReferenceDescription *rd = &br.references[i];
  1347. if(rd->browseName.namespaceIndex == 0 &&
  1348. UA_String_equal(&rd->browseName.name, &inputArgsName.name))
  1349. inputArgsId = rd->nodeId.nodeId;
  1350. else if(rd->browseName.namespaceIndex == 0 &&
  1351. UA_String_equal(&rd->browseName.name, &outputArgsName.name))
  1352. outputArgsId = rd->nodeId.nodeId;
  1353. }
  1354. /* Add the Input Arguments VariableNode */
  1355. if(inputArgumentsSize > 0 && UA_NodeId_isNull(&inputArgsId)) {
  1356. UA_VariableAttributes attr = UA_VariableAttributes_default;
  1357. char *name = "InputArguments";
  1358. attr.displayName = UA_LOCALIZEDTEXT("", name);
  1359. attr.dataType = UA_TYPES[UA_TYPES_ARGUMENT].typeId;
  1360. attr.valueRank = 1;
  1361. UA_Variant_setArray(&attr.value, (void*)(uintptr_t) inputArguments,
  1362. inputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  1363. retval |= UA_Server_addVariableNode(server, inputArgumentsRequestedNewNodeId, nodeId,
  1364. hasproperty, UA_QUALIFIEDNAME(0, name),
  1365. propertytype, attr, NULL, &inputArgsId);
  1366. }
  1367. /* Add the Output Arguments VariableNode */
  1368. if(outputArgumentsSize > 0 && UA_NodeId_isNull(&outputArgsId)) {
  1369. UA_VariableAttributes attr = UA_VariableAttributes_default;
  1370. char *name = "OutputArguments";
  1371. attr.displayName = UA_LOCALIZEDTEXT("", name);
  1372. attr.dataType = UA_TYPES[UA_TYPES_ARGUMENT].typeId;
  1373. attr.valueRank = 1;
  1374. UA_Variant_setArray(&attr.value, (void*)(uintptr_t) outputArguments,
  1375. outputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  1376. retval |= UA_Server_addVariableNode(server, outputArgumentsRequestedNewNodeId, nodeId,
  1377. hasproperty, UA_QUALIFIEDNAME(0, name),
  1378. propertytype, attr, NULL, &outputArgsId);
  1379. }
  1380. retval |= UA_Server_setMethodNode_callback(server, nodeId, method);
  1381. /* Call finish to add the parent reference */
  1382. retval |= Operation_addNode_finish(server, &adminSession, &nodeId, &parentNodeId,
  1383. &referenceTypeId, &UA_NODEID_NULL);
  1384. if(retval != UA_STATUSCODE_GOOD) {
  1385. UA_Server_deleteNode(server, nodeId, true);
  1386. UA_Server_deleteNode(server, inputArgsId, true);
  1387. UA_Server_deleteNode(server, outputArgsId, true);
  1388. } else {
  1389. if(inputArgumentsOutNewNodeId != NULL) {
  1390. UA_NodeId_copy(&inputArgsId, inputArgumentsOutNewNodeId);
  1391. }
  1392. if(outputArgumentsOutNewNodeId != NULL) {
  1393. UA_NodeId_copy(&outputArgsId, outputArgumentsOutNewNodeId);
  1394. }
  1395. }
  1396. UA_BrowseResult_deleteMembers(&br);
  1397. return retval;
  1398. }
  1399. UA_StatusCode
  1400. UA_Server_addMethodNode_finish(UA_Server *server, const UA_NodeId nodeId,
  1401. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  1402. UA_MethodCallback method,
  1403. size_t inputArgumentsSize, const UA_Argument* inputArguments,
  1404. size_t outputArgumentsSize, const UA_Argument* outputArguments) {
  1405. return UA_Server_addMethodNodeEx_finish(server, nodeId, parentNodeId,
  1406. referenceTypeId, method,
  1407. inputArgumentsSize, inputArguments, UA_NODEID_NULL, NULL,
  1408. outputArgumentsSize, outputArguments, UA_NODEID_NULL, NULL);
  1409. }
  1410. UA_StatusCode
  1411. UA_Server_addMethodNodeEx(UA_Server *server, const UA_NodeId requestedNewNodeId,
  1412. const UA_NodeId parentNodeId,
  1413. const UA_NodeId referenceTypeId,
  1414. const UA_QualifiedName browseName,
  1415. const UA_MethodAttributes attr, UA_MethodCallback method,
  1416. size_t inputArgumentsSize, const UA_Argument *inputArguments,
  1417. const UA_NodeId inputArgumentsRequestedNewNodeId,
  1418. UA_NodeId *inputArgumentsOutNewNodeId,
  1419. size_t outputArgumentsSize, const UA_Argument *outputArguments,
  1420. const UA_NodeId outputArgumentsRequestedNewNodeId,
  1421. UA_NodeId *outputArgumentsOutNewNodeId,
  1422. void *nodeContext, UA_NodeId *outNewNodeId) {
  1423. UA_AddNodesItem item;
  1424. UA_AddNodesItem_init(&item);
  1425. item.nodeClass = UA_NODECLASS_METHOD;
  1426. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  1427. item.browseName = browseName;
  1428. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  1429. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)&attr;
  1430. item.nodeAttributes.content.decoded.type = &UA_TYPES[UA_TYPES_METHODATTRIBUTES];
  1431. UA_NodeId newId;
  1432. if(!outNewNodeId) {
  1433. UA_NodeId_init(&newId);
  1434. outNewNodeId = &newId;
  1435. }
  1436. UA_StatusCode retval = Operation_addNode_begin(server, &adminSession, nodeContext,
  1437. &item, outNewNodeId);
  1438. if(retval != UA_STATUSCODE_GOOD)
  1439. return retval;
  1440. retval = UA_Server_addMethodNodeEx_finish(server, *outNewNodeId,
  1441. parentNodeId, referenceTypeId, method,
  1442. inputArgumentsSize, inputArguments,
  1443. inputArgumentsRequestedNewNodeId,
  1444. inputArgumentsOutNewNodeId,
  1445. outputArgumentsSize, outputArguments,
  1446. outputArgumentsRequestedNewNodeId,
  1447. outputArgumentsOutNewNodeId);
  1448. if(outNewNodeId == &newId)
  1449. UA_NodeId_deleteMembers(&newId);
  1450. return retval;
  1451. }
  1452. static UA_StatusCode
  1453. editMethodCallback(UA_Server *server, UA_Session* session,
  1454. UA_Node* node, void* handle) {
  1455. if(node->nodeClass != UA_NODECLASS_METHOD)
  1456. return UA_STATUSCODE_BADNODECLASSINVALID;
  1457. UA_MethodNode *mnode = (UA_MethodNode*) node;
  1458. mnode->method = (UA_MethodCallback)(uintptr_t)handle;
  1459. return UA_STATUSCODE_GOOD;
  1460. }
  1461. UA_StatusCode
  1462. UA_Server_setMethodNode_callback(UA_Server *server,
  1463. const UA_NodeId methodNodeId,
  1464. UA_MethodCallback methodCallback) {
  1465. return UA_Server_editNode(server, &adminSession, &methodNodeId,
  1466. (UA_EditNodeCallback)editMethodCallback,
  1467. (void*)(uintptr_t)methodCallback);
  1468. }
  1469. #endif
  1470. /************************/
  1471. /* Lifecycle Management */
  1472. /************************/
  1473. static UA_StatusCode
  1474. setNodeTypeLifecycle(UA_Server *server, UA_Session *session,
  1475. UA_Node* node, UA_NodeTypeLifecycle *lifecycle) {
  1476. if(node->nodeClass == UA_NODECLASS_OBJECTTYPE) {
  1477. UA_ObjectTypeNode *ot = (UA_ObjectTypeNode*)node;
  1478. ot->lifecycle = *lifecycle;
  1479. return UA_STATUSCODE_GOOD;
  1480. }
  1481. if(node->nodeClass == UA_NODECLASS_VARIABLETYPE) {
  1482. UA_VariableTypeNode *vt = (UA_VariableTypeNode*)node;
  1483. vt->lifecycle = *lifecycle;
  1484. return UA_STATUSCODE_GOOD;
  1485. }
  1486. return UA_STATUSCODE_BADNODECLASSINVALID;
  1487. }
  1488. UA_StatusCode
  1489. UA_Server_setNodeTypeLifecycle(UA_Server *server, UA_NodeId nodeId,
  1490. UA_NodeTypeLifecycle lifecycle) {
  1491. return UA_Server_editNode(server, &adminSession, &nodeId,
  1492. (UA_EditNodeCallback)setNodeTypeLifecycle,
  1493. &lifecycle);
  1494. }