ua_services_nodemanagement.c 90 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123
  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) Fraunhofer IOSB (Author: Julius Pfrommer)
  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_getNode(server->nsCtx, &nodeId);
  27. if(!node)
  28. return UA_STATUSCODE_BADNODEIDUNKNOWN;
  29. *nodeContext = node->context;
  30. UA_Nodestore_releaseNode(server->nsCtx, node);
  31. return UA_STATUSCODE_GOOD;
  32. }
  33. static UA_StatusCode
  34. setDeconstructedNode(UA_Server *server, UA_Session *session,
  35. UA_Node *node, void *context) {
  36. node->constructed = false;
  37. return UA_STATUSCODE_GOOD;
  38. }
  39. static UA_StatusCode
  40. setConstructedNodeContext(UA_Server *server, UA_Session *session,
  41. UA_Node *node, void *context) {
  42. node->context = context;
  43. node->constructed = true;
  44. return UA_STATUSCODE_GOOD;
  45. }
  46. static UA_StatusCode
  47. editNodeContext(UA_Server *server, UA_Session* session,
  48. UA_Node* node, void *context) {
  49. node->context = context;
  50. return UA_STATUSCODE_GOOD;
  51. }
  52. UA_StatusCode
  53. UA_Server_setNodeContext(UA_Server *server, UA_NodeId nodeId,
  54. void *nodeContext) {
  55. return UA_Server_editNode(server, &server->adminSession, &nodeId,
  56. (UA_EditNodeCallback)editNodeContext, nodeContext);
  57. }
  58. /**********************/
  59. /* Consistency Checks */
  60. /**********************/
  61. #define UA_PARENT_REFERENCES_COUNT 2
  62. const UA_NodeId parentReferences[UA_PARENT_REFERENCES_COUNT] = {
  63. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASSUBTYPE}},
  64. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASCOMPONENT}}
  65. };
  66. /* Check if the requested parent node exists, has the right node class and is
  67. * referenced with an allowed (hierarchical) reference type. For "type" nodes,
  68. * only hasSubType references are allowed. */
  69. static UA_StatusCode
  70. checkParentReference(UA_Server *server, UA_Session *session, UA_NodeClass nodeClass,
  71. const UA_NodeId *parentNodeId, const UA_NodeId *referenceTypeId) {
  72. /* Objects do not need a parent (e.g. mandatory/optional modellingrules) */
  73. /* Also, there are some variables which do not have parents, e.g. EnumStrings, EnumValues */
  74. if((nodeClass == UA_NODECLASS_OBJECT || nodeClass == UA_NODECLASS_VARIABLE) &&
  75. UA_NodeId_isNull(parentNodeId) && UA_NodeId_isNull(referenceTypeId))
  76. return UA_STATUSCODE_GOOD;
  77. /* See if the parent exists */
  78. const UA_Node *parent = UA_Nodestore_getNode(server->nsCtx, parentNodeId);
  79. if(!parent) {
  80. UA_LOG_NODEID_WRAP(parentNodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  81. "AddNodes: Parent node %.*s not found",
  82. (int)nodeIdStr.length, nodeIdStr.data));
  83. return UA_STATUSCODE_BADPARENTNODEIDINVALID;
  84. }
  85. UA_NodeClass parentNodeClass = parent->nodeClass;
  86. UA_Nodestore_releaseNode(server->nsCtx, parent);
  87. /* Check the referencetype exists */
  88. const UA_ReferenceTypeNode *referenceType = (const UA_ReferenceTypeNode*)
  89. UA_Nodestore_getNode(server->nsCtx, referenceTypeId);
  90. if(!referenceType) {
  91. UA_LOG_NODEID_WRAP(referenceTypeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  92. "AddNodes: Reference type %.*s to the parent not found",
  93. (int)nodeIdStr.length, nodeIdStr.data));
  94. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  95. }
  96. /* Check if the referencetype is a reference type node */
  97. if(referenceType->nodeClass != UA_NODECLASS_REFERENCETYPE) {
  98. UA_LOG_NODEID_WRAP(referenceTypeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  99. "AddNodes: Reference type %.*s to the parent is not a ReferenceTypeNode",
  100. (int)nodeIdStr.length, nodeIdStr.data));
  101. UA_Nodestore_releaseNode(server->nsCtx, (const UA_Node*)referenceType);
  102. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  103. }
  104. UA_Boolean referenceTypeIsAbstract = referenceType->isAbstract;
  105. UA_Nodestore_releaseNode(server->nsCtx, (const UA_Node*)referenceType);
  106. /* Check that the reference type is not abstract */
  107. if(referenceTypeIsAbstract == true) {
  108. UA_LOG_NODEID_WRAP(referenceTypeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  109. "AddNodes: Abstract reference type %.*s to the parent not allowed",
  110. (int)nodeIdStr.length, nodeIdStr.data));
  111. return UA_STATUSCODE_BADREFERENCENOTALLOWED;
  112. }
  113. /* Check hassubtype relation for type nodes */
  114. if(nodeClass == UA_NODECLASS_DATATYPE ||
  115. nodeClass == UA_NODECLASS_VARIABLETYPE ||
  116. nodeClass == UA_NODECLASS_OBJECTTYPE ||
  117. nodeClass == UA_NODECLASS_REFERENCETYPE) {
  118. /* type needs hassubtype reference to the supertype */
  119. if(!UA_NodeId_equal(referenceTypeId, &subtypeId)) {
  120. UA_LOG_INFO_SESSION(&server->config.logger, session,
  121. "AddNodes: Type nodes need to have a HasSubType "
  122. "reference to the parent");
  123. return UA_STATUSCODE_BADREFERENCENOTALLOWED;
  124. }
  125. /* supertype needs to be of the same node type */
  126. if(parentNodeClass != nodeClass) {
  127. UA_LOG_INFO_SESSION(&server->config.logger, session,
  128. "AddNodes: Type nodes needs to be of the same node "
  129. "type as their parent");
  130. return UA_STATUSCODE_BADPARENTNODEIDINVALID;
  131. }
  132. return UA_STATUSCODE_GOOD;
  133. }
  134. /* Test if the referencetype is hierarchical */
  135. if(!isNodeInTree(server->nsCtx, referenceTypeId,
  136. &hierarchicalReferences, &subtypeId, 1)) {
  137. UA_LOG_INFO_SESSION(&server->config.logger, session,
  138. "AddNodes: Reference type to the parent is not hierarchical");
  139. return UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  140. }
  141. return UA_STATUSCODE_GOOD;
  142. }
  143. static UA_StatusCode
  144. typeCheckVariableNode(UA_Server *server, UA_Session *session,
  145. const UA_VariableNode *node,
  146. const UA_VariableTypeNode *vt) {
  147. /* The value might come from a datasource, so we perform a
  148. * regular read. */
  149. UA_DataValue value;
  150. UA_DataValue_init(&value);
  151. UA_StatusCode retval = readValueAttribute(server, session, node, &value);
  152. if(retval != UA_STATUSCODE_GOOD)
  153. return retval;
  154. UA_NodeId baseDataType = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATATYPE);
  155. /* Check the datatype against the vt */
  156. /* If the node does not have any value and the dataType is BaseDataType,
  157. * then it's also fine. This is the default for empty nodes. */
  158. if(!compatibleDataType(server, &node->dataType, &vt->dataType, false) &&
  159. (value.hasValue || !UA_NodeId_equal(&node->dataType, &baseDataType))) {
  160. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  161. "AddNodes: The value of %.*s is incompatible with "
  162. "the datatype of the VariableType",
  163. (int)nodeIdStr.length, nodeIdStr.data));
  164. UA_DataValue_deleteMembers(&value);
  165. return UA_STATUSCODE_BADTYPEMISMATCH;
  166. }
  167. /* Check valueRank against array dimensions */
  168. if(!compatibleValueRankArrayDimensions(server, session, node->valueRank,
  169. node->arrayDimensionsSize)) {
  170. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  171. "AddNodes: The value rank of %.*s is incomatible "
  172. "with its array dimensions", (int)nodeIdStr.length, nodeIdStr.data));
  173. UA_DataValue_deleteMembers(&value);
  174. return UA_STATUSCODE_BADTYPEMISMATCH;
  175. }
  176. /* Check valueRank against the vt */
  177. if(!compatibleValueRanks(node->valueRank, vt->valueRank)) {
  178. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  179. "AddNodes: The value rank of %.*s is incomatible "
  180. "with the value rank of the VariableType",
  181. (int)nodeIdStr.length, nodeIdStr.data));
  182. UA_DataValue_deleteMembers(&value);
  183. return UA_STATUSCODE_BADTYPEMISMATCH;
  184. }
  185. /* Check array dimensions against the vt */
  186. if(!compatibleArrayDimensions(vt->arrayDimensionsSize, vt->arrayDimensions,
  187. node->arrayDimensionsSize, node->arrayDimensions)) {
  188. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  189. "AddNodes: The array dimensions of %.*s are "
  190. "incomatible with the array dimensions of the VariableType",
  191. (int)nodeIdStr.length, nodeIdStr.data));
  192. UA_DataValue_deleteMembers(&value);
  193. return UA_STATUSCODE_BADTYPEMISMATCH;
  194. }
  195. /* Typecheck the value */
  196. if(value.hasValue && value.value.data) {
  197. /* If the type-check failed write the same value again. The
  198. * write-service tries to convert to the correct type... */
  199. if(!compatibleValue(server, session, &node->dataType, node->valueRank,
  200. node->arrayDimensionsSize, node->arrayDimensions,
  201. &value.value, NULL))
  202. retval = UA_Server_writeValue(server, node->nodeId, value.value);
  203. UA_DataValue_deleteMembers(&value);
  204. if(retval != UA_STATUSCODE_GOOD) {
  205. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  206. "AddNodes: The value of of %.*s is incomatible with the "
  207. "variable definition", (int)nodeIdStr.length, nodeIdStr.data));
  208. }
  209. }
  210. return retval;
  211. }
  212. /********************/
  213. /* Instantiate Node */
  214. /********************/
  215. static const UA_NodeId baseDataVariableType =
  216. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_BASEDATAVARIABLETYPE}};
  217. static const UA_NodeId baseObjectType =
  218. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_BASEOBJECTTYPE}};
  219. static const UA_NodeId hasTypeDefinition =
  220. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASTYPEDEFINITION}};
  221. /* Use attributes from the variable type wherever required. Reload the node if
  222. * changes were made. */
  223. static UA_StatusCode
  224. useVariableTypeAttributes(UA_Server *server, UA_Session *session,
  225. const UA_VariableNode **node_ptr,
  226. const UA_VariableTypeNode *vt) {
  227. const UA_VariableNode *node = *node_ptr;
  228. UA_Boolean modified = false;
  229. /* If no value is set, see if the vt provides one and copy it. This needs to
  230. * be done before copying the datatype from the vt, as setting the datatype
  231. * triggers a typecheck. */
  232. UA_DataValue orig;
  233. UA_DataValue_init(&orig);
  234. UA_StatusCode retval = readValueAttribute(server, session, node, &orig);
  235. if(retval != UA_STATUSCODE_GOOD)
  236. return retval;
  237. if(orig.value.type) {
  238. /* A value is present */
  239. UA_DataValue_deleteMembers(&orig);
  240. } else {
  241. UA_LOG_DEBUG_SESSION(&server->config.logger, session,
  242. "AddNodes: No value given; Copy the value "
  243. "from the TypeDefinition");
  244. UA_WriteValue v;
  245. UA_WriteValue_init(&v);
  246. retval = readValueAttribute(server, session, (const UA_VariableNode*)vt, &v.value);
  247. if(retval == UA_STATUSCODE_GOOD && v.value.hasValue) {
  248. v.nodeId = node->nodeId;
  249. v.attributeId = UA_ATTRIBUTEID_VALUE;
  250. retval = UA_Server_writeWithSession(server, session, &v);
  251. modified = true;
  252. }
  253. UA_DataValue_deleteMembers(&v.value);
  254. if(retval != UA_STATUSCODE_GOOD)
  255. return retval;
  256. }
  257. /* If no datatype is given, use the datatype of the vt */
  258. if(UA_NodeId_isNull(&node->dataType)) {
  259. UA_LOG_INFO_SESSION(&server->config.logger, session, "AddNodes: "
  260. "No datatype given; Copy the datatype attribute "
  261. "from the TypeDefinition");
  262. UA_WriteValue v;
  263. UA_WriteValue_init(&v);
  264. v.nodeId = node->nodeId;
  265. v.attributeId = UA_ATTRIBUTEID_DATATYPE;
  266. v.value.hasValue = true;
  267. UA_Variant_setScalar(&v.value.value, (void*)(uintptr_t)&vt->dataType,
  268. &UA_TYPES[UA_TYPES_NODEID]);
  269. retval = UA_Server_writeWithSession(server, session, &v);
  270. modified = true;
  271. if(retval != UA_STATUSCODE_GOOD)
  272. return retval;
  273. }
  274. /* Use the ArrayDimensions of the vt */
  275. if(node->arrayDimensionsSize == 0 && vt->arrayDimensionsSize > 0) {
  276. UA_WriteValue v;
  277. UA_WriteValue_init(&v);
  278. v.nodeId = node->nodeId;
  279. v.attributeId = UA_ATTRIBUTEID_ARRAYDIMENSIONS;
  280. v.value.hasValue = true;
  281. UA_Variant_setArray(&v.value.value, vt->arrayDimensions,
  282. vt->arrayDimensionsSize, &UA_TYPES[UA_TYPES_UINT32]);
  283. retval = UA_Server_writeWithSession(server, session, &v);
  284. modified = true;
  285. if(retval != UA_STATUSCODE_GOOD)
  286. return retval;
  287. }
  288. /* If the node was modified, update the pointer to the new version */
  289. if(modified) {
  290. const UA_VariableNode *updated = (const UA_VariableNode*)
  291. UA_Nodestore_getNode(server->nsCtx, &node->nodeId);
  292. if(!updated)
  293. return UA_STATUSCODE_BADINTERNALERROR;
  294. UA_Nodestore_releaseNode(server->nsCtx, (const UA_Node*)node);
  295. *node_ptr = updated;
  296. }
  297. return UA_STATUSCODE_GOOD;
  298. }
  299. /* Search for an instance of "browseName" in node searchInstance. Used during
  300. * copyChildNodes to find overwritable/mergable nodes. Does not touch
  301. * outInstanceNodeId if no child is found. */
  302. static UA_StatusCode
  303. findChildByBrowsename(UA_Server *server, UA_Session *session,
  304. const UA_NodeId *searchInstance,
  305. const UA_QualifiedName *browseName,
  306. UA_NodeId *outInstanceNodeId) {
  307. UA_BrowseDescription bd;
  308. UA_BrowseDescription_init(&bd);
  309. bd.nodeId = *searchInstance;
  310. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  311. bd.includeSubtypes = true;
  312. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  313. bd.nodeClassMask = UA_NODECLASS_OBJECT | UA_NODECLASS_VARIABLE | UA_NODECLASS_METHOD;
  314. bd.resultMask = UA_BROWSERESULTMASK_BROWSENAME;
  315. UA_BrowseResult br;
  316. UA_BrowseResult_init(&br);
  317. UA_UInt32 maxrefs = 0;
  318. Operation_Browse(server, session, &maxrefs, &bd, &br);
  319. if(br.statusCode != UA_STATUSCODE_GOOD)
  320. return br.statusCode;
  321. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  322. for(size_t i = 0; i < br.referencesSize; ++i) {
  323. UA_ReferenceDescription *rd = &br.references[i];
  324. if(rd->browseName.namespaceIndex == browseName->namespaceIndex &&
  325. UA_String_equal(&rd->browseName.name, &browseName->name)) {
  326. retval = UA_NodeId_copy(&rd->nodeId.nodeId, outInstanceNodeId);
  327. break;
  328. }
  329. }
  330. UA_BrowseResult_deleteMembers(&br);
  331. return retval;
  332. }
  333. static const UA_NodeId mandatoryId =
  334. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_MODELLINGRULE_MANDATORY}};
  335. static const UA_NodeId hasModellingRuleId =
  336. {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASMODELLINGRULE}};
  337. static UA_Boolean
  338. isMandatoryChild(UA_Server *server, UA_Session *session,
  339. const UA_NodeId *childNodeId) {
  340. /* Get the child */
  341. const UA_Node *child = UA_Nodestore_getNode(server->nsCtx, childNodeId);
  342. if(!child)
  343. return false;
  344. /* Look for the reference making the child mandatory */
  345. for(size_t i = 0; i < child->referencesSize; ++i) {
  346. UA_NodeReferenceKind *refs = &child->references[i];
  347. if(!UA_NodeId_equal(&hasModellingRuleId, &refs->referenceTypeId))
  348. continue;
  349. if(refs->isInverse)
  350. continue;
  351. for(size_t j = 0; j < refs->refTargetsSize; ++j) {
  352. if(UA_NodeId_equal(&mandatoryId, &refs->refTargets[j].target.nodeId)) {
  353. UA_Nodestore_releaseNode(server->nsCtx, child);
  354. return true;
  355. }
  356. }
  357. }
  358. UA_Nodestore_releaseNode(server->nsCtx, child);
  359. return false;
  360. }
  361. static UA_StatusCode
  362. copyAllChildren(UA_Server *server, UA_Session *session,
  363. const UA_NodeId *source, const UA_NodeId *destination);
  364. static UA_StatusCode
  365. recursiveTypeCheckAddChildren(UA_Server *server, UA_Session *session,
  366. const UA_Node **node, const UA_Node *type);
  367. static void
  368. Operation_addReference(UA_Server *server, UA_Session *session, void *context,
  369. const UA_AddReferencesItem *item, UA_StatusCode *retval);
  370. static UA_StatusCode
  371. copyChild(UA_Server *server, UA_Session *session, const UA_NodeId *destinationNodeId,
  372. const UA_ReferenceDescription *rd) {
  373. /* Is there an existing child with the browsename? */
  374. UA_NodeId existingChild = UA_NODEID_NULL;
  375. UA_StatusCode retval = findChildByBrowsename(server, session, destinationNodeId,
  376. &rd->browseName, &existingChild);
  377. if(retval != UA_STATUSCODE_GOOD)
  378. return retval;
  379. /* Have a child with that browseName. Deep-copy missing members. */
  380. if(!UA_NodeId_isNull(&existingChild)) {
  381. if(rd->nodeClass == UA_NODECLASS_VARIABLE ||
  382. rd->nodeClass == UA_NODECLASS_OBJECT)
  383. retval = copyAllChildren(server, session, &rd->nodeId.nodeId, &existingChild);
  384. UA_NodeId_deleteMembers(&existingChild);
  385. return retval;
  386. }
  387. /* Is the child mandatory? If not, ask callback whether child should be instantiated.
  388. * If not, skip. */
  389. if(!isMandatoryChild(server, session, &rd->nodeId.nodeId)) {
  390. if(!server->config.nodeLifecycle.createOptionalChild)
  391. return UA_STATUSCODE_GOOD;
  392. if(server->config.nodeLifecycle.createOptionalChild(server,
  393. &session->sessionId,
  394. session->sessionHandle,
  395. &rd->nodeId.nodeId,
  396. destinationNodeId,
  397. &rd->referenceTypeId) == UA_FALSE) {
  398. return UA_STATUSCODE_GOOD;
  399. }
  400. }
  401. /* Child is a method -> create a reference */
  402. if(rd->nodeClass == UA_NODECLASS_METHOD) {
  403. UA_AddReferencesItem newItem;
  404. UA_AddReferencesItem_init(&newItem);
  405. newItem.sourceNodeId = *destinationNodeId;
  406. newItem.referenceTypeId = rd->referenceTypeId;
  407. newItem.isForward = true;
  408. newItem.targetNodeId = rd->nodeId;
  409. newItem.targetNodeClass = UA_NODECLASS_METHOD;
  410. Operation_addReference(server, session, NULL, &newItem, &retval);
  411. return retval;
  412. }
  413. /* Child is a variable or object */
  414. if(rd->nodeClass == UA_NODECLASS_VARIABLE ||
  415. rd->nodeClass == UA_NODECLASS_OBJECT) {
  416. /* Make a copy of the node */
  417. UA_Node *node;
  418. retval = UA_Nodestore_getNodeCopy(server->nsCtx, &rd->nodeId.nodeId, &node);
  419. if(retval != UA_STATUSCODE_GOOD)
  420. return retval;
  421. /* Remove the context of the copied node */
  422. node->context = NULL;
  423. node->constructed = false;
  424. /* Reset the NodeId (random numeric id will be assigned in the nodestore) */
  425. UA_NodeId_deleteMembers(&node->nodeId);
  426. node->nodeId.namespaceIndex = destinationNodeId->namespaceIndex;
  427. if (server->config.nodeLifecycle.generateChildNodeId) {
  428. retval = server->config.nodeLifecycle.generateChildNodeId(server,
  429. &session->sessionId, session->sessionHandle,
  430. &rd->nodeId.nodeId,
  431. destinationNodeId,
  432. &rd->referenceTypeId,
  433. &node->nodeId);
  434. if(retval != UA_STATUSCODE_GOOD) {
  435. UA_Nodestore_deleteNode(server->nsCtx, node);
  436. return retval;
  437. }
  438. }
  439. /* Remove references, they are re-created from scratch in addnode_finish */
  440. /* TODO: Be more clever in removing references that are re-added during
  441. * addnode_finish. That way, we can call addnode_finish also on children that were
  442. * manually added by the user during addnode_begin and addnode_finish. */
  443. /* For now we keep all the modelling rule references and delete all others */
  444. UA_NodeId modellingRuleReferenceId = UA_NODEID_NUMERIC(0, UA_NS0ID_HASMODELLINGRULE);
  445. UA_Node_deleteReferencesSubset(node, 1, &modellingRuleReferenceId);
  446. /* Add the node to the nodestore */
  447. UA_NodeId newNodeId;
  448. retval = UA_Nodestore_insertNode(server->nsCtx, node, &newNodeId);
  449. if(retval != UA_STATUSCODE_GOOD)
  450. return retval;
  451. /* Add the node references */
  452. retval = AddNode_addRefs(server, session, &newNodeId, destinationNodeId,
  453. &rd->referenceTypeId, &rd->typeDefinition.nodeId);
  454. if(retval != UA_STATUSCODE_GOOD) {
  455. UA_Nodestore_removeNode(server->nsCtx, &newNodeId);
  456. return retval;
  457. }
  458. /* For the new child, recursively copy the members of the original. No
  459. * typechecking is performed here. Assuming that the original is
  460. * consistent. */
  461. retval = copyAllChildren(server, session, &rd->nodeId.nodeId, &newNodeId);
  462. }
  463. return retval;
  464. }
  465. /* Copy any children of Node sourceNodeId to another node destinationNodeId. */
  466. static UA_StatusCode
  467. copyAllChildren(UA_Server *server, UA_Session *session,
  468. const UA_NodeId *source, const UA_NodeId *destination) {
  469. /* Browse to get all children of the source */
  470. UA_BrowseDescription bd;
  471. UA_BrowseDescription_init(&bd);
  472. bd.nodeId = *source;
  473. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  474. bd.includeSubtypes = true;
  475. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  476. bd.nodeClassMask = UA_NODECLASS_OBJECT | UA_NODECLASS_VARIABLE | UA_NODECLASS_METHOD;
  477. bd.resultMask = UA_BROWSERESULTMASK_REFERENCETYPEID | UA_BROWSERESULTMASK_NODECLASS |
  478. UA_BROWSERESULTMASK_BROWSENAME | UA_BROWSERESULTMASK_TYPEDEFINITION;
  479. UA_BrowseResult br;
  480. UA_BrowseResult_init(&br);
  481. UA_UInt32 maxrefs = 0;
  482. Operation_Browse(server, session, &maxrefs, &bd, &br);
  483. if(br.statusCode != UA_STATUSCODE_GOOD)
  484. return br.statusCode;
  485. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  486. for(size_t i = 0; i < br.referencesSize; ++i) {
  487. UA_ReferenceDescription *rd = &br.references[i];
  488. retval = copyChild(server, session, destination, rd);
  489. if(retval != UA_STATUSCODE_GOOD)
  490. return retval;
  491. }
  492. UA_BrowseResult_deleteMembers(&br);
  493. return retval;
  494. }
  495. static UA_StatusCode
  496. addTypeChildren(UA_Server *server, UA_Session *session,
  497. const UA_Node *node, const UA_Node *type) {
  498. /* Get the hierarchy of the type and all its supertypes */
  499. UA_NodeId *hierarchy = NULL;
  500. size_t hierarchySize = 0;
  501. UA_StatusCode retval = getParentTypeAndInterfaceHierarchy(server, &type->nodeId,
  502. &hierarchy, &hierarchySize);
  503. if(retval != UA_STATUSCODE_GOOD)
  504. return retval;
  505. UA_assert(hierarchySize < 1000);
  506. /* Copy members of the type and supertypes (and instantiate them) */
  507. for(size_t i = 0; i < hierarchySize; ++i) {
  508. retval = copyAllChildren(server, session, &hierarchy[i], &node->nodeId);
  509. if(retval != UA_STATUSCODE_GOOD)
  510. break;
  511. }
  512. UA_Array_delete(hierarchy, hierarchySize, &UA_TYPES[UA_TYPES_NODEID]);
  513. return retval;
  514. }
  515. static UA_StatusCode
  516. addRef(UA_Server *server, UA_Session *session, const UA_NodeId *nodeId,
  517. const UA_NodeId *referenceTypeId, const UA_NodeId *parentNodeId,
  518. UA_Boolean forward) {
  519. UA_AddReferencesItem ref_item;
  520. UA_AddReferencesItem_init(&ref_item);
  521. ref_item.sourceNodeId = *nodeId;
  522. ref_item.referenceTypeId = *referenceTypeId;
  523. ref_item.isForward = forward;
  524. ref_item.targetNodeId.nodeId = *parentNodeId;
  525. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  526. Operation_addReference(server, session, NULL, &ref_item, &retval);
  527. return retval;
  528. }
  529. /************/
  530. /* Add Node */
  531. /************/
  532. static const UA_NodeId hasSubtype = {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASSUBTYPE}};
  533. UA_StatusCode
  534. AddNode_addRefs(UA_Server *server, UA_Session *session, const UA_NodeId *nodeId,
  535. const UA_NodeId *parentNodeId, const UA_NodeId *referenceTypeId,
  536. const UA_NodeId *typeDefinitionId) {
  537. /* Get the node */
  538. const UA_Node *type = NULL;
  539. const UA_Node *node = UA_Nodestore_getNode(server->nsCtx, nodeId);
  540. if(!node)
  541. return UA_STATUSCODE_BADNODEIDUNKNOWN;
  542. /* Use the typeDefinition as parent for type-nodes */
  543. if(node->nodeClass == UA_NODECLASS_VARIABLETYPE ||
  544. node->nodeClass == UA_NODECLASS_OBJECTTYPE ||
  545. node->nodeClass == UA_NODECLASS_REFERENCETYPE ||
  546. node->nodeClass == UA_NODECLASS_DATATYPE) {
  547. if(UA_NodeId_equal(referenceTypeId, &UA_NODEID_NULL))
  548. referenceTypeId = &hasSubtype;
  549. const UA_Node *parentNode = UA_Nodestore_getNode(server->nsCtx, parentNodeId);
  550. if(parentNode) {
  551. if(parentNode->nodeClass == node->nodeClass)
  552. typeDefinitionId = parentNodeId;
  553. UA_Nodestore_releaseNode(server->nsCtx, parentNode);
  554. }
  555. }
  556. UA_StatusCode retval;
  557. /* Make sure newly created node does not have itself as parent */
  558. if (UA_NodeId_equal(nodeId, parentNodeId)) {
  559. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  560. "AddNodes: The node %.*s can not have "
  561. "itself as parent",
  562. (int)nodeIdStr.length, nodeIdStr.data));
  563. retval = UA_STATUSCODE_BADINVALIDARGUMENT;
  564. goto cleanup;
  565. }
  566. /* Check parent reference. Objects may have no parent. */
  567. retval = checkParentReference(server, session, node->nodeClass,
  568. parentNodeId, referenceTypeId);
  569. if(retval != UA_STATUSCODE_GOOD) {
  570. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  571. "AddNodes: The parent reference for %.*s is invalid "
  572. "with status code %s",
  573. (int)nodeIdStr.length, nodeIdStr.data,
  574. UA_StatusCode_name(retval)));
  575. goto cleanup;
  576. }
  577. /* Replace empty typeDefinition with the most permissive default */
  578. if((node->nodeClass == UA_NODECLASS_VARIABLE ||
  579. node->nodeClass == UA_NODECLASS_OBJECT) &&
  580. UA_NodeId_isNull(typeDefinitionId)) {
  581. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  582. "AddNodes: No TypeDefinition for %.*s; Use the default "
  583. "TypeDefinition for the Variable/Object",
  584. (int)nodeIdStr.length, nodeIdStr.data));
  585. if(node->nodeClass == UA_NODECLASS_VARIABLE)
  586. typeDefinitionId = &baseDataVariableType;
  587. else
  588. typeDefinitionId = &baseObjectType;
  589. }
  590. /* Get the node type. There must be a typedefinition for variables, objects
  591. * and type-nodes. See the above checks. */
  592. if(!UA_NodeId_isNull(typeDefinitionId)) {
  593. /* Get the type node */
  594. type = UA_Nodestore_getNode(server->nsCtx, typeDefinitionId);
  595. if(!type) {
  596. UA_LOG_NODEID_WRAP(typeDefinitionId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  597. "AddNodes: Node type %.*s not found",
  598. (int)nodeIdStr.length, nodeIdStr.data));
  599. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  600. goto cleanup;
  601. }
  602. UA_Boolean typeOk = false;
  603. switch(node->nodeClass) {
  604. case UA_NODECLASS_DATATYPE:
  605. typeOk = type->nodeClass == UA_NODECLASS_DATATYPE;
  606. break;
  607. case UA_NODECLASS_METHOD:
  608. typeOk = type->nodeClass == UA_NODECLASS_METHOD;
  609. break;
  610. case UA_NODECLASS_OBJECT:
  611. typeOk = type->nodeClass == UA_NODECLASS_OBJECTTYPE;
  612. break;
  613. case UA_NODECLASS_OBJECTTYPE:
  614. typeOk = type->nodeClass == UA_NODECLASS_OBJECTTYPE;
  615. break;
  616. case UA_NODECLASS_REFERENCETYPE:
  617. typeOk = type->nodeClass == UA_NODECLASS_REFERENCETYPE;
  618. break;
  619. case UA_NODECLASS_VARIABLE:
  620. typeOk = type->nodeClass == UA_NODECLASS_VARIABLETYPE;
  621. break;
  622. case UA_NODECLASS_VARIABLETYPE:
  623. typeOk = type->nodeClass == UA_NODECLASS_VARIABLETYPE;
  624. break;
  625. case UA_NODECLASS_VIEW:
  626. typeOk = type->nodeClass == UA_NODECLASS_VIEW;
  627. break;
  628. default:
  629. typeOk = false;
  630. }
  631. if(!typeOk) {
  632. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  633. "AddNodes: Type for %.*s does not match node class",
  634. (int)nodeIdStr.length, nodeIdStr.data));
  635. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  636. goto cleanup;
  637. }
  638. /* See if the type has the correct node class. For type-nodes, we know
  639. * that type has the same nodeClass from checkParentReference. */
  640. if(node->nodeClass == UA_NODECLASS_VARIABLE) {
  641. if(((const UA_VariableTypeNode*)type)->isAbstract) {
  642. /* Get subtypes of the parent reference types */
  643. UA_NodeId *parentTypeHierarchy = NULL;
  644. size_t parentTypeHierarchySize = 0;
  645. retval |= referenceSubtypes(server, &parentReferences[0],
  646. &parentTypeHierarchySize, &parentTypeHierarchy);
  647. retval |= referenceSubtypes(server, &parentReferences[1],
  648. &parentTypeHierarchySize, &parentTypeHierarchy);
  649. if(retval != UA_STATUSCODE_GOOD) {
  650. UA_Array_delete(parentTypeHierarchy, parentTypeHierarchySize,
  651. &UA_TYPES[UA_TYPES_NODEID]);
  652. goto cleanup;
  653. }
  654. /* Abstract variable is allowed if parent is a children of a
  655. * base data variable. An abstract variable may be part of an
  656. * object type which again is below BaseObjectType */
  657. const UA_NodeId variableTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE);
  658. const UA_NodeId objectTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE);
  659. if(!isNodeInTree(server->nsCtx, parentNodeId, &variableTypes,
  660. parentTypeHierarchy, parentTypeHierarchySize) &&
  661. !isNodeInTree(server->nsCtx, parentNodeId, &objectTypes,
  662. parentTypeHierarchy, parentTypeHierarchySize)) {
  663. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  664. "AddNodes: Type of variable node %.*s must "
  665. "be VariableType and not cannot be abstract",
  666. (int)nodeIdStr.length, nodeIdStr.data));
  667. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  668. }
  669. UA_Array_delete(parentTypeHierarchy, parentTypeHierarchySize,
  670. &UA_TYPES[UA_TYPES_NODEID]);
  671. if(retval != UA_STATUSCODE_GOOD)
  672. goto cleanup;
  673. }
  674. }
  675. if(node->nodeClass == UA_NODECLASS_OBJECT) {
  676. if(((const UA_ObjectTypeNode*)type)->isAbstract) {
  677. /* Get subtypes of the parent reference types */
  678. UA_NodeId *parentTypeHierarchy = NULL;
  679. size_t parentTypeHierarchySize = 0;
  680. retval |= referenceSubtypes(server, &parentReferences[0],
  681. &parentTypeHierarchySize, &parentTypeHierarchy);
  682. retval |= referenceSubtypes(server, &parentReferences[1],
  683. &parentTypeHierarchySize, &parentTypeHierarchy);
  684. if(retval != UA_STATUSCODE_GOOD) {
  685. UA_Array_delete(parentTypeHierarchy, parentTypeHierarchySize,
  686. &UA_TYPES[UA_TYPES_NODEID]);
  687. goto cleanup;
  688. }
  689. /* Object node created of an abstract ObjectType. Only allowed
  690. * if within BaseObjectType folder or if it's an event (subType of BaseEventType) */
  691. const UA_NodeId objectTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE);
  692. UA_Boolean isInBaseObjectType = isNodeInTree(server->nsCtx, parentNodeId, &objectTypes,
  693. parentTypeHierarchy, parentTypeHierarchySize);
  694. const UA_NodeId eventTypes = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEEVENTTYPE);
  695. UA_Boolean isInBaseEventType = isNodeInTree(server->nsCtx, &type->nodeId, &eventTypes, &hasSubtype, 1);
  696. if(!isInBaseObjectType && !(isInBaseEventType && UA_NodeId_isNull(parentNodeId))) {
  697. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  698. "AddNodes: Type of object node %.*s must "
  699. "be ObjectType and not be abstract",
  700. (int)nodeIdStr.length, nodeIdStr.data));
  701. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  702. }
  703. UA_Array_delete(parentTypeHierarchy, parentTypeHierarchySize,
  704. &UA_TYPES[UA_TYPES_NODEID]);
  705. if(retval != UA_STATUSCODE_GOOD)
  706. goto cleanup;
  707. }
  708. }
  709. }
  710. /* Add reference to the parent */
  711. if(!UA_NodeId_isNull(parentNodeId)) {
  712. if(UA_NodeId_isNull(referenceTypeId)) {
  713. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  714. "AddNodes: Reference to parent of %.*s cannot be null",
  715. (int)nodeIdStr.length, nodeIdStr.data));
  716. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  717. goto cleanup;
  718. }
  719. retval = addRef(server, session, &node->nodeId, referenceTypeId, parentNodeId, false);
  720. if(retval != UA_STATUSCODE_GOOD) {
  721. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  722. "AddNodes: Adding reference to parent of %.*s failed",
  723. (int)nodeIdStr.length, nodeIdStr.data));
  724. goto cleanup;
  725. }
  726. }
  727. /* Add a hasTypeDefinition reference */
  728. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  729. node->nodeClass == UA_NODECLASS_OBJECT) {
  730. UA_assert(type != NULL); /* see above */
  731. retval = addRef(server, session, &node->nodeId, &hasTypeDefinition, &type->nodeId, true);
  732. if(retval != UA_STATUSCODE_GOOD) {
  733. UA_LOG_NODEID_WRAP(nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  734. "AddNodes: Adding a reference to the type "
  735. "definition of %.*s failed with error code %s",
  736. (int)nodeIdStr.length, nodeIdStr.data,
  737. UA_StatusCode_name(retval)));
  738. }
  739. }
  740. cleanup:
  741. UA_Nodestore_releaseNode(server->nsCtx, node);
  742. if(type)
  743. UA_Nodestore_releaseNode(server->nsCtx, type);
  744. return retval;
  745. }
  746. /* Create the node and add it to the nodestore. But don't typecheck and add
  747. * references so far */
  748. UA_StatusCode
  749. AddNode_raw(UA_Server *server, UA_Session *session, void *nodeContext,
  750. const UA_AddNodesItem *item, UA_NodeId *outNewNodeId) {
  751. /* Do not check access for server */
  752. if(session != &server->adminSession && server->config.accessControl.allowAddNode &&
  753. !server->config.accessControl.allowAddNode(server, &server->config.accessControl,
  754. &session->sessionId, session->sessionHandle, item)) {
  755. return UA_STATUSCODE_BADUSERACCESSDENIED;
  756. }
  757. /* Check the namespaceindex */
  758. if(item->requestedNewNodeId.nodeId.namespaceIndex >= server->namespacesSize) {
  759. UA_LOG_INFO_SESSION(&server->config.logger, session,
  760. "AddNodes: Namespace invalid");
  761. return UA_STATUSCODE_BADNODEIDINVALID;
  762. }
  763. if(item->nodeAttributes.encoding != UA_EXTENSIONOBJECT_DECODED &&
  764. item->nodeAttributes.encoding != UA_EXTENSIONOBJECT_DECODED_NODELETE) {
  765. UA_LOG_INFO_SESSION(&server->config.logger, session,
  766. "AddNodes: Node attributes invalid");
  767. return UA_STATUSCODE_BADINTERNALERROR;
  768. }
  769. /* Create a node */
  770. UA_Node *node = UA_Nodestore_newNode(server->nsCtx, item->nodeClass);
  771. if(!node) {
  772. UA_LOG_INFO_SESSION(&server->config.logger, session,
  773. "AddNodes: Node could not create a node "
  774. "in the nodestore");
  775. return UA_STATUSCODE_BADOUTOFMEMORY;
  776. }
  777. /* Fill the node attributes */
  778. node->context = nodeContext;
  779. UA_StatusCode retval = UA_NodeId_copy(&item->requestedNewNodeId.nodeId, &node->nodeId);
  780. if(retval != UA_STATUSCODE_GOOD)
  781. goto create_error;
  782. retval = UA_QualifiedName_copy(&item->browseName, &node->browseName);
  783. if(retval != UA_STATUSCODE_GOOD)
  784. goto create_error;
  785. retval = UA_Node_setAttributes(node, item->nodeAttributes.content.decoded.data,
  786. item->nodeAttributes.content.decoded.type);
  787. if(retval != UA_STATUSCODE_GOOD)
  788. goto create_error;
  789. /* Add the node to the nodestore */
  790. retval = UA_Nodestore_insertNode(server->nsCtx, node, outNewNodeId);
  791. if(retval != UA_STATUSCODE_GOOD)
  792. UA_LOG_INFO_SESSION(&server->config.logger, session,
  793. "AddNodes: Node could not add the new node "
  794. "to the nodestore with error code %s",
  795. UA_StatusCode_name(retval));
  796. return retval;
  797. create_error:
  798. UA_LOG_INFO_SESSION(&server->config.logger, session,
  799. "AddNodes: Node could not create a node "
  800. "with error code %s", UA_StatusCode_name(retval));
  801. UA_Nodestore_deleteNode(server->nsCtx, node);
  802. return retval;
  803. }
  804. /* Prepare the node, then add it to the nodestore */
  805. static UA_StatusCode
  806. Operation_addNode_begin(UA_Server *server, UA_Session *session, void *nodeContext,
  807. const UA_AddNodesItem *item, const UA_NodeId *parentNodeId,
  808. const UA_NodeId *referenceTypeId, UA_NodeId *outNewNodeId) {
  809. /* Create a temporary NodeId if none is returned */
  810. UA_NodeId newId;
  811. if(!outNewNodeId) {
  812. UA_NodeId_init(&newId);
  813. outNewNodeId = &newId;
  814. }
  815. /* Create the node and add it to the nodestore */
  816. UA_StatusCode retval = AddNode_raw(server, session, nodeContext, item, outNewNodeId);
  817. if(retval != UA_STATUSCODE_GOOD)
  818. return retval;
  819. /* Typecheck and add references to parent and type definition */
  820. retval = AddNode_addRefs(server, session, outNewNodeId, parentNodeId,
  821. referenceTypeId, &item->typeDefinition.nodeId);
  822. if(retval != UA_STATUSCODE_GOOD)
  823. UA_Server_deleteNode(server, *outNewNodeId, true);
  824. if(outNewNodeId == &newId)
  825. UA_NodeId_deleteMembers(&newId);
  826. return retval;
  827. }
  828. static UA_StatusCode
  829. recursiveTypeCheckAddChildren(UA_Server *server, UA_Session *session,
  830. const UA_Node **nodeptr, const UA_Node *type) {
  831. UA_assert(type != NULL);
  832. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  833. const UA_Node *node = *nodeptr;
  834. /* Use attributes from the type. The value and value constraints are the
  835. * same for the variable and variabletype attribute structs. */
  836. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  837. node->nodeClass == UA_NODECLASS_VARIABLETYPE) {
  838. retval = useVariableTypeAttributes(server, session, (const UA_VariableNode**)nodeptr,
  839. (const UA_VariableTypeNode*)type);
  840. node = *nodeptr; /* If the node was replaced */
  841. if(retval != UA_STATUSCODE_GOOD) {
  842. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  843. "AddNodes: Using attributes for %.*s from the variable type "
  844. "failed with error code %s", (int)nodeIdStr.length,
  845. nodeIdStr.data, UA_StatusCode_name(retval)));
  846. return retval;
  847. }
  848. /* Check NodeClass for 'hasSubtype'. UA_NODECLASS_VARIABLE not allowed to have subtype */
  849. if((node->nodeClass == UA_NODECLASS_VARIABLE) && (UA_NodeId_equal(
  850. &node->references->referenceTypeId, &hasSubtype))) {
  851. UA_LOG_INFO_SESSION(&server->config.logger, session,
  852. "AddNodes: VariableType not allowed to have HasSubType");
  853. return UA_STATUSCODE_BADREFERENCENOTALLOWED;
  854. }
  855. /* Check if all attributes hold the constraints of the type now. The initial
  856. * attributes must type-check. The constructor might change the attributes
  857. * again. Then, the changes are type-checked by the normal write service. */
  858. retval = typeCheckVariableNode(server, session, (const UA_VariableNode*)node,
  859. (const UA_VariableTypeNode*)type);
  860. if(retval != UA_STATUSCODE_GOOD) {
  861. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  862. "AddNodes: Type-checking the variable node %.*s "
  863. "failed with error code %s", (int)nodeIdStr.length,
  864. nodeIdStr.data, UA_StatusCode_name(retval)));
  865. return retval;
  866. }
  867. }
  868. /* Add (mandatory) child nodes from the type definition */
  869. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  870. node->nodeClass == UA_NODECLASS_OBJECT) {
  871. retval = addTypeChildren(server, session, node, type);
  872. if(retval != UA_STATUSCODE_GOOD) {
  873. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  874. "AddNodes: Adding child nodes of %.*s failed with error code %s",
  875. (int)nodeIdStr.length, nodeIdStr.data, UA_StatusCode_name(retval)));
  876. }
  877. }
  878. return UA_STATUSCODE_GOOD;
  879. }
  880. static UA_StatusCode
  881. findDefaultInstanceBrowseNameNode(UA_Server *server,
  882. UA_NodeId startingNode, UA_NodeId *foundId){
  883. UA_NodeId_init(foundId);
  884. UA_RelativePathElement rpe;
  885. UA_RelativePathElement_init(&rpe);
  886. rpe.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY);
  887. rpe.isInverse = false;
  888. rpe.includeSubtypes = false;
  889. rpe.targetName = UA_QUALIFIEDNAME(0, "DefaultInstanceBrowseName");
  890. UA_BrowsePath bp;
  891. UA_BrowsePath_init(&bp);
  892. bp.startingNode = startingNode;
  893. bp.relativePath.elementsSize = 1;
  894. bp.relativePath.elements = &rpe;
  895. UA_BrowsePathResult bpr =
  896. UA_Server_translateBrowsePathToNodeIds(server, &bp);
  897. UA_StatusCode retval = bpr.statusCode;
  898. if (retval == UA_STATUSCODE_GOOD &&
  899. bpr.targetsSize > 0) {
  900. retval = UA_NodeId_copy(&bpr.targets[0].targetId.nodeId, foundId);
  901. }
  902. UA_BrowsePathResult_deleteMembers(&bpr);
  903. return retval;
  904. }
  905. /* Check if we got a valid browse name for the new node.
  906. * For object nodes the BrowseName may only be null if the parent type has a
  907. * 'DefaultInstanceBrowseName' property.
  908. * */
  909. static UA_StatusCode
  910. checkValidBrowseName(UA_Server *server, UA_Session *session,
  911. const UA_Node *node, const UA_Node *type) {
  912. UA_assert(type != NULL);
  913. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  914. if(node->nodeClass != UA_NODECLASS_OBJECT) {
  915. /* nodes other than Objects must have a browseName */
  916. if (UA_QualifiedName_isNull(&node->browseName))
  917. return UA_STATUSCODE_BADBROWSENAMEINVALID;
  918. return UA_STATUSCODE_GOOD;
  919. }
  920. /* If the object node already has a browse name we are done here. */
  921. if(!UA_QualifiedName_isNull(&node->browseName))
  922. return UA_STATUSCODE_GOOD;
  923. /* at this point we have an object with an empty browse name.
  924. * Check the type node if it has a DefaultInstanceBrowseName property
  925. */
  926. UA_NodeId defaultBrowseNameNode;
  927. retval = findDefaultInstanceBrowseNameNode(server, type->nodeId, &defaultBrowseNameNode);
  928. if (retval != UA_STATUSCODE_GOOD) {
  929. if (retval == UA_STATUSCODE_BADNOMATCH)
  930. /* the DefaultBrowseName property is not found, return the corresponding status code */
  931. return UA_STATUSCODE_BADBROWSENAMEINVALID;
  932. return retval;
  933. }
  934. UA_Variant defaultBrowseName;
  935. retval = UA_Server_readValue(server, defaultBrowseNameNode, &defaultBrowseName);
  936. if (retval != UA_STATUSCODE_GOOD)
  937. return retval;
  938. UA_QualifiedName *defaultValue = (UA_QualifiedName *) defaultBrowseName.data;
  939. retval = UA_Server_writeBrowseName(server, node->nodeId, *defaultValue);
  940. UA_Variant_clear(&defaultBrowseName);
  941. return retval;
  942. }
  943. /* Construct children first */
  944. static UA_StatusCode
  945. recursiveCallConstructors(UA_Server *server, UA_Session *session,
  946. const UA_Node *node, const UA_Node *type) {
  947. if(node->constructed)
  948. return UA_STATUSCODE_GOOD;
  949. /* Construct the children */
  950. UA_BrowseDescription bd;
  951. UA_BrowseDescription_init(&bd);
  952. bd.nodeId = node->nodeId;
  953. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  954. bd.includeSubtypes = true;
  955. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  956. UA_BrowseResult br;
  957. UA_BrowseResult_init(&br);
  958. UA_UInt32 maxrefs = 0;
  959. Operation_Browse(server, session, &maxrefs, &bd, &br);
  960. if(br.statusCode != UA_STATUSCODE_GOOD)
  961. return br.statusCode;
  962. /* Call the constructor for every unconstructed node */
  963. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  964. for(size_t i = 0; i < br.referencesSize; ++i) {
  965. UA_ReferenceDescription *rd = &br.references[i];
  966. const UA_Node *target = UA_Nodestore_getNode(server->nsCtx, &rd->nodeId.nodeId);
  967. if(!target)
  968. continue;
  969. if(target->constructed) {
  970. UA_Nodestore_releaseNode(server->nsCtx, target);
  971. continue;
  972. }
  973. const UA_Node *targetType = NULL;
  974. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  975. node->nodeClass == UA_NODECLASS_OBJECT) {
  976. targetType = getNodeType(server, target);
  977. if(!targetType) {
  978. UA_Nodestore_releaseNode(server->nsCtx, target);
  979. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  980. break;
  981. }
  982. }
  983. retval = recursiveCallConstructors(server, session, target, targetType);
  984. UA_Nodestore_releaseNode(server->nsCtx, target);
  985. if(targetType)
  986. UA_Nodestore_releaseNode(server->nsCtx, targetType);
  987. if(retval != UA_STATUSCODE_GOOD)
  988. break;
  989. }
  990. UA_BrowseResult_deleteMembers(&br);
  991. /* If a child could not be constructed or the node is already constructed */
  992. if(retval != UA_STATUSCODE_GOOD)
  993. return retval;
  994. /* Get the node type constructor */
  995. const UA_NodeTypeLifecycle *lifecycle = NULL;
  996. if(type && node->nodeClass == UA_NODECLASS_OBJECT) {
  997. const UA_ObjectTypeNode *ot = (const UA_ObjectTypeNode*)type;
  998. lifecycle = &ot->lifecycle;
  999. } else if(type && node->nodeClass == UA_NODECLASS_VARIABLE) {
  1000. const UA_VariableTypeNode *vt = (const UA_VariableTypeNode*)type;
  1001. lifecycle = &vt->lifecycle;
  1002. }
  1003. /* Call the global constructor */
  1004. void *context = node->context;
  1005. if(server->config.nodeLifecycle.constructor)
  1006. retval = server->config.nodeLifecycle.constructor(server, &session->sessionId,
  1007. session->sessionHandle,
  1008. &node->nodeId, &context);
  1009. /* Call the type constructor */
  1010. if(retval == UA_STATUSCODE_GOOD && lifecycle && lifecycle->constructor)
  1011. retval = lifecycle->constructor(server, &session->sessionId,
  1012. session->sessionHandle, &type->nodeId,
  1013. type->context, &node->nodeId, &context);
  1014. if(retval != UA_STATUSCODE_GOOD)
  1015. goto fail1;
  1016. /* Set the context *and* mark the node as constructed */
  1017. if(retval == UA_STATUSCODE_GOOD)
  1018. retval = UA_Server_editNode(server, &server->adminSession, &node->nodeId,
  1019. (UA_EditNodeCallback)setConstructedNodeContext,
  1020. context);
  1021. /* All good, return */
  1022. if(retval == UA_STATUSCODE_GOOD)
  1023. return retval;
  1024. /* Fail. Call the destructors. */
  1025. if(lifecycle && lifecycle->destructor)
  1026. lifecycle->destructor(server, &session->sessionId,
  1027. session->sessionHandle, &type->nodeId,
  1028. type->context, &node->nodeId, &context);
  1029. fail1:
  1030. if(server->config.nodeLifecycle.destructor)
  1031. server->config.nodeLifecycle.destructor(server, &session->sessionId,
  1032. session->sessionHandle,
  1033. &node->nodeId, context);
  1034. return retval;
  1035. }
  1036. static void
  1037. recursiveDeconstructNode(UA_Server *server, UA_Session *session,
  1038. size_t hierarchicalReferencesSize,
  1039. UA_ExpandedNodeId *hierarchicalReferences,
  1040. const UA_Node *node);
  1041. static void
  1042. recursiveDeleteNode(UA_Server *server, UA_Session *session,
  1043. size_t hierarchicalReferencesSize,
  1044. UA_ExpandedNodeId *hierarchicalReferences,
  1045. const UA_Node *node, UA_Boolean removeTargetRefs);
  1046. /* Children, references, type-checking, constructors. */
  1047. UA_StatusCode
  1048. AddNode_finish(UA_Server *server, UA_Session *session, const UA_NodeId *nodeId) {
  1049. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1050. /* Get the node */
  1051. const UA_Node *node = UA_Nodestore_getNode(server->nsCtx, nodeId);
  1052. if(!node)
  1053. return UA_STATUSCODE_BADNODEIDUNKNOWN;
  1054. const UA_Node *type = NULL;
  1055. /* Instantiate variables and objects */
  1056. if(node->nodeClass == UA_NODECLASS_VARIABLE ||
  1057. node->nodeClass == UA_NODECLASS_VARIABLETYPE ||
  1058. node->nodeClass == UA_NODECLASS_OBJECT) {
  1059. /* Get the type node */
  1060. type = getNodeType(server, node);
  1061. if(!type) {
  1062. if(server->bootstrapNS0)
  1063. goto constructor;
  1064. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  1065. "AddNodes: Node type for %.*s not found",
  1066. (int)nodeIdStr.length, nodeIdStr.data));
  1067. retval = UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  1068. goto cleanup;
  1069. }
  1070. retval = checkValidBrowseName(server, session, node, type);
  1071. if(retval != UA_STATUSCODE_GOOD)
  1072. goto cleanup;
  1073. retval = recursiveTypeCheckAddChildren(server, session, &node, type);
  1074. if(retval != UA_STATUSCODE_GOOD)
  1075. goto cleanup;
  1076. }
  1077. /* Call the constructor(s) */
  1078. constructor:
  1079. retval = recursiveCallConstructors(server, session, node, type);
  1080. if(retval != UA_STATUSCODE_GOOD) {
  1081. UA_LOG_NODEID_WRAP(&node->nodeId, UA_LOG_INFO_SESSION(&server->config.logger, session,
  1082. "AddNodes: Calling the node constructor(s) of %.*s failed "
  1083. "with status code %s", (int)nodeIdStr.length,
  1084. nodeIdStr.data, UA_StatusCode_name(retval)));
  1085. }
  1086. cleanup:
  1087. if(type)
  1088. UA_Nodestore_releaseNode(server->nsCtx, type);
  1089. if(retval != UA_STATUSCODE_GOOD) {
  1090. recursiveDeconstructNode(server, session, 0, NULL, node);
  1091. recursiveDeleteNode(server, session, 0, NULL, node, true);
  1092. }
  1093. UA_Nodestore_releaseNode(server->nsCtx, node);
  1094. return retval;
  1095. }
  1096. static void
  1097. Operation_addNode(UA_Server *server, UA_Session *session, void *nodeContext,
  1098. const UA_AddNodesItem *item, UA_AddNodesResult *result) {
  1099. result->statusCode =
  1100. Operation_addNode_begin(server, session, nodeContext, item, &item->parentNodeId.nodeId,
  1101. &item->referenceTypeId, &result->addedNodeId);
  1102. if(result->statusCode != UA_STATUSCODE_GOOD)
  1103. return;
  1104. /* AddNodes_finish */
  1105. result->statusCode = AddNode_finish(server, session, &result->addedNodeId);
  1106. /* If finishing failed, the node was deleted */
  1107. if(result->statusCode != UA_STATUSCODE_GOOD)
  1108. UA_NodeId_deleteMembers(&result->addedNodeId);
  1109. }
  1110. void
  1111. Service_AddNodes(UA_Server *server, UA_Session *session,
  1112. const UA_AddNodesRequest *request,
  1113. UA_AddNodesResponse *response) {
  1114. UA_LOG_DEBUG_SESSION(&server->config.logger, session, "Processing AddNodesRequest");
  1115. if(server->config.maxNodesPerNodeManagement != 0 &&
  1116. request->nodesToAddSize > server->config.maxNodesPerNodeManagement) {
  1117. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1118. return;
  1119. }
  1120. response->responseHeader.serviceResult =
  1121. UA_Server_processServiceOperations(server, session,
  1122. (UA_ServiceOperation)Operation_addNode, NULL,
  1123. &request->nodesToAddSize, &UA_TYPES[UA_TYPES_ADDNODESITEM],
  1124. &response->resultsSize, &UA_TYPES[UA_TYPES_ADDNODESRESULT]);
  1125. }
  1126. UA_StatusCode
  1127. __UA_Server_addNode(UA_Server *server, const UA_NodeClass nodeClass,
  1128. const UA_NodeId *requestedNewNodeId,
  1129. const UA_NodeId *parentNodeId,
  1130. const UA_NodeId *referenceTypeId,
  1131. const UA_QualifiedName browseName,
  1132. const UA_NodeId *typeDefinition,
  1133. const UA_NodeAttributes *attr,
  1134. const UA_DataType *attributeType,
  1135. void *nodeContext, UA_NodeId *outNewNodeId) {
  1136. /* Create the AddNodesItem */
  1137. UA_AddNodesItem item;
  1138. UA_AddNodesItem_init(&item);
  1139. item.nodeClass = nodeClass;
  1140. item.requestedNewNodeId.nodeId = *requestedNewNodeId;
  1141. item.browseName = browseName;
  1142. item.parentNodeId.nodeId = *parentNodeId;
  1143. item.referenceTypeId = *referenceTypeId;
  1144. item.typeDefinition.nodeId = *typeDefinition;
  1145. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  1146. item.nodeAttributes.content.decoded.type = attributeType;
  1147. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)attr;
  1148. /* Call the normal addnodes service */
  1149. UA_AddNodesResult result;
  1150. UA_AddNodesResult_init(&result);
  1151. Operation_addNode(server, &server->adminSession, nodeContext, &item, &result);
  1152. if(outNewNodeId)
  1153. *outNewNodeId = result.addedNodeId;
  1154. else
  1155. UA_NodeId_deleteMembers(&result.addedNodeId);
  1156. return result.statusCode;
  1157. }
  1158. UA_StatusCode
  1159. UA_Server_addNode_begin(UA_Server *server, const UA_NodeClass nodeClass,
  1160. const UA_NodeId requestedNewNodeId,
  1161. const UA_NodeId parentNodeId,
  1162. const UA_NodeId referenceTypeId,
  1163. const UA_QualifiedName browseName,
  1164. const UA_NodeId typeDefinition,
  1165. const void *attr, const UA_DataType *attributeType,
  1166. void *nodeContext, UA_NodeId *outNewNodeId) {
  1167. UA_AddNodesItem item;
  1168. UA_AddNodesItem_init(&item);
  1169. item.nodeClass = nodeClass;
  1170. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  1171. item.browseName = browseName;
  1172. item.typeDefinition.nodeId = typeDefinition;
  1173. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  1174. item.nodeAttributes.content.decoded.type = attributeType;
  1175. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)attr;
  1176. return Operation_addNode_begin(server, &server->adminSession, nodeContext, &item,
  1177. &parentNodeId, &referenceTypeId, outNewNodeId);
  1178. }
  1179. UA_StatusCode
  1180. UA_Server_addNode_finish(UA_Server *server, const UA_NodeId nodeId) {
  1181. return AddNode_finish(server, &server->adminSession, &nodeId);
  1182. }
  1183. /****************/
  1184. /* Delete Nodes */
  1185. /****************/
  1186. static void
  1187. Operation_deleteReference(UA_Server *server, UA_Session *session, void *context,
  1188. const UA_DeleteReferencesItem *item, UA_StatusCode *retval);
  1189. /* Remove references to this node (in the other nodes) */
  1190. static void
  1191. removeIncomingReferences(UA_Server *server, UA_Session *session,
  1192. const UA_Node *node) {
  1193. UA_DeleteReferencesItem item;
  1194. UA_DeleteReferencesItem_init(&item);
  1195. item.targetNodeId.nodeId = node->nodeId;
  1196. item.deleteBidirectional = false;
  1197. UA_StatusCode dummy;
  1198. for(size_t i = 0; i < node->referencesSize; ++i) {
  1199. UA_NodeReferenceKind *refs = &node->references[i];
  1200. item.isForward = refs->isInverse;
  1201. item.referenceTypeId = refs->referenceTypeId;
  1202. for(size_t j = 0; j < refs->refTargetsSize; ++j) {
  1203. item.sourceNodeId = refs->refTargets[j].target.nodeId;
  1204. Operation_deleteReference(server, session, NULL, &item, &dummy);
  1205. }
  1206. }
  1207. }
  1208. /* A node can only be deleted if it has at most one incoming hierarchical
  1209. * reference. If hierarchicalReferences is NULL, always remove. */
  1210. static UA_Boolean
  1211. multipleHierarchies(size_t hierarchicalRefsSize, UA_ExpandedNodeId *hierarchicalRefs,
  1212. const UA_Node *node) {
  1213. if(!hierarchicalRefs)
  1214. return false;
  1215. size_t incomingRefs = 0;
  1216. for(size_t i = 0; i < node->referencesSize; i++) {
  1217. const UA_NodeReferenceKind *k = &node->references[i];
  1218. if(!k->isInverse)
  1219. continue;
  1220. UA_Boolean hierarchical = false;
  1221. for(size_t j = 0; j < hierarchicalRefsSize; j++) {
  1222. if(UA_NodeId_equal(&hierarchicalRefs[j].nodeId,
  1223. &k->referenceTypeId)) {
  1224. hierarchical = true;
  1225. break;
  1226. }
  1227. }
  1228. if(!hierarchical)
  1229. continue;
  1230. incomingRefs += k->refTargetsSize;
  1231. if(incomingRefs > 1)
  1232. return true;
  1233. }
  1234. return false;
  1235. }
  1236. /* Recursively call the destructors of this node and all child nodes.
  1237. * Deconstructs the parent before its children. */
  1238. static void
  1239. recursiveDeconstructNode(UA_Server *server, UA_Session *session,
  1240. size_t hierarchicalRefsSize,
  1241. UA_ExpandedNodeId *hierarchicalRefs,
  1242. const UA_Node *node) {
  1243. /* Was the constructor called for the node? */
  1244. if(!node->constructed)
  1245. return;
  1246. /* Call the type-level destructor */
  1247. void *context = node->context; /* No longer needed after this function */
  1248. if(node->nodeClass == UA_NODECLASS_OBJECT ||
  1249. node->nodeClass == UA_NODECLASS_VARIABLE) {
  1250. const UA_Node *type = getNodeType(server, node);
  1251. if(type) {
  1252. const UA_NodeTypeLifecycle *lifecycle;
  1253. if(node->nodeClass == UA_NODECLASS_OBJECT)
  1254. lifecycle = &((const UA_ObjectTypeNode*)type)->lifecycle;
  1255. else
  1256. lifecycle = &((const UA_VariableTypeNode*)type)->lifecycle;
  1257. if(lifecycle->destructor)
  1258. lifecycle->destructor(server,
  1259. &session->sessionId, session->sessionHandle,
  1260. &type->nodeId, type->context,
  1261. &node->nodeId, &context);
  1262. UA_Nodestore_releaseNode(server->nsCtx, type);
  1263. }
  1264. }
  1265. /* Call the global destructor */
  1266. if(server->config.nodeLifecycle.destructor)
  1267. server->config.nodeLifecycle.destructor(server, &session->sessionId,
  1268. session->sessionHandle,
  1269. &node->nodeId, context);
  1270. /* Set the constructed flag to false */
  1271. UA_Server_editNode(server, &server->adminSession, &node->nodeId,
  1272. (UA_EditNodeCallback)setDeconstructedNode, context);
  1273. /* Browse to get all children of the node */
  1274. UA_BrowseDescription bd;
  1275. UA_BrowseDescription_init(&bd);
  1276. bd.nodeId = node->nodeId;
  1277. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  1278. bd.includeSubtypes = true;
  1279. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  1280. UA_BrowseResult br;
  1281. UA_BrowseResult_init(&br);
  1282. UA_UInt32 maxrefs = 0;
  1283. Operation_Browse(server, session, &maxrefs, &bd, &br);
  1284. if(br.statusCode != UA_STATUSCODE_GOOD)
  1285. return;
  1286. /* Deconstruct every child node */
  1287. for(size_t i = 0; i < br.referencesSize; ++i) {
  1288. UA_ReferenceDescription *rd = &br.references[i];
  1289. const UA_Node *child = UA_Nodestore_getNode(server->nsCtx, &rd->nodeId.nodeId);
  1290. if(!child)
  1291. continue;
  1292. /* Only delete child nodes that have no other parent */
  1293. if(!multipleHierarchies(hierarchicalRefsSize, hierarchicalRefs, child))
  1294. recursiveDeconstructNode(server, session, hierarchicalRefsSize,
  1295. hierarchicalRefs, child);
  1296. UA_Nodestore_releaseNode(server->nsCtx, child);
  1297. }
  1298. UA_BrowseResult_deleteMembers(&br);
  1299. }
  1300. static void
  1301. recursiveDeleteNode(UA_Server *server, UA_Session *session,
  1302. size_t hierarchicalRefsSize,
  1303. UA_ExpandedNodeId *hierarchicalRefs,
  1304. const UA_Node *node, UA_Boolean removeTargetRefs) {
  1305. /* Browse to get all children of the node */
  1306. UA_BrowseDescription bd;
  1307. UA_BrowseDescription_init(&bd);
  1308. bd.nodeId = node->nodeId;
  1309. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES);
  1310. bd.includeSubtypes = true;
  1311. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  1312. UA_BrowseResult br;
  1313. UA_BrowseResult_init(&br);
  1314. UA_UInt32 maxrefs = 0;
  1315. Operation_Browse(server, session, &maxrefs, &bd, &br);
  1316. if(br.statusCode != UA_STATUSCODE_GOOD)
  1317. return;
  1318. /* Remove every child */
  1319. for(size_t i = 0; i < br.referencesSize; ++i) {
  1320. UA_ReferenceDescription *rd = &br.references[i];
  1321. /* Check for self-reference to avoid endless loop */
  1322. if(UA_NodeId_equal(&node->nodeId, &rd->nodeId.nodeId))
  1323. continue;
  1324. const UA_Node *child = UA_Nodestore_getNode(server->nsCtx, &rd->nodeId.nodeId);
  1325. if(!child)
  1326. continue;
  1327. /* Only delete child nodes that have no other parent */
  1328. if(!multipleHierarchies(hierarchicalRefsSize, hierarchicalRefs, child))
  1329. recursiveDeleteNode(server, session, hierarchicalRefsSize,
  1330. hierarchicalRefs, child, true);
  1331. UA_Nodestore_releaseNode(server->nsCtx, child);
  1332. }
  1333. UA_BrowseResult_deleteMembers(&br);
  1334. if(removeTargetRefs)
  1335. removeIncomingReferences(server, session, node);
  1336. UA_Nodestore_removeNode(server->nsCtx, &node->nodeId);
  1337. }
  1338. static void
  1339. deleteNodeOperation(UA_Server *server, UA_Session *session, void *context,
  1340. const UA_DeleteNodesItem *item, UA_StatusCode *result) {
  1341. /* Do not check access for server */
  1342. if(session != &server->adminSession &&
  1343. server->config.accessControl.allowDeleteNode &&
  1344. !server->config.accessControl.allowDeleteNode(server, &server->config.accessControl,
  1345. &session->sessionId,
  1346. session->sessionHandle, item)) {
  1347. *result = UA_STATUSCODE_BADUSERACCESSDENIED;
  1348. return;
  1349. }
  1350. const UA_Node *node = UA_Nodestore_getNode(server->nsCtx, &item->nodeId);
  1351. if(!node) {
  1352. *result = UA_STATUSCODE_BADNODEIDUNKNOWN;
  1353. return;
  1354. }
  1355. if(UA_Node_hasSubTypeOrInstances(node)) {
  1356. UA_LOG_INFO_SESSION(&server->config.logger, session,
  1357. "Delete Nodes: Cannot delete a type node "
  1358. "with active instances or subtypes");
  1359. UA_Nodestore_releaseNode(server->nsCtx, node);
  1360. *result = UA_STATUSCODE_BADINTERNALERROR;
  1361. return;
  1362. }
  1363. /* TODO: Check if the information model consistency is violated */
  1364. /* TODO: Check if the node is a mandatory child of a parent */
  1365. /* A node can be referenced with hierarchical references from several
  1366. * parents in the information model. (But not in a circular way.) The
  1367. * hierarchical references are checked to see if a node can be deleted.
  1368. * Getting the type hierarchy can fail in case of low RAM. In that case the
  1369. * nodes are always deleted. */
  1370. UA_ExpandedNodeId *hierarchicalRefs = NULL;
  1371. size_t hierarchicalRefsSize = 0;
  1372. UA_NodeId hr = UA_NODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES);
  1373. browseRecursive(server, 1, &hr, 1, &subtypeId, UA_BROWSEDIRECTION_FORWARD, true,
  1374. &hierarchicalRefsSize, &hierarchicalRefs);
  1375. if(!hierarchicalRefs) {
  1376. UA_LOG_WARNING_SESSION(&server->config.logger, session,
  1377. "Delete Nodes: Cannot test for hierarchical "
  1378. "references. Deleting the node and all child nodes.");
  1379. }
  1380. recursiveDeconstructNode(server, session, hierarchicalRefsSize, hierarchicalRefs, node);
  1381. recursiveDeleteNode(server, session, hierarchicalRefsSize, hierarchicalRefs, node,
  1382. item->deleteTargetReferences);
  1383. UA_Array_delete(hierarchicalRefs, hierarchicalRefsSize, &UA_TYPES[UA_TYPES_EXPANDEDNODEID]);
  1384. UA_Nodestore_releaseNode(server->nsCtx, node);
  1385. }
  1386. void Service_DeleteNodes(UA_Server *server, UA_Session *session,
  1387. const UA_DeleteNodesRequest *request,
  1388. UA_DeleteNodesResponse *response) {
  1389. UA_LOG_DEBUG_SESSION(&server->config.logger, session,
  1390. "Processing DeleteNodesRequest");
  1391. if(server->config.maxNodesPerNodeManagement != 0 &&
  1392. request->nodesToDeleteSize > server->config.maxNodesPerNodeManagement) {
  1393. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1394. return;
  1395. }
  1396. response->responseHeader.serviceResult =
  1397. UA_Server_processServiceOperations(server, session,
  1398. (UA_ServiceOperation)deleteNodeOperation,
  1399. NULL, &request->nodesToDeleteSize,
  1400. &UA_TYPES[UA_TYPES_DELETENODESITEM],
  1401. &response->resultsSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
  1402. }
  1403. UA_StatusCode
  1404. UA_Server_deleteNode(UA_Server *server, const UA_NodeId nodeId,
  1405. UA_Boolean deleteReferences) {
  1406. UA_DeleteNodesItem item;
  1407. item.deleteTargetReferences = deleteReferences;
  1408. item.nodeId = nodeId;
  1409. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1410. deleteNodeOperation(server, &server->adminSession, NULL, &item, &retval);
  1411. return retval;
  1412. }
  1413. /******************/
  1414. /* Add References */
  1415. /******************/
  1416. static UA_StatusCode
  1417. addOneWayReference(UA_Server *server, UA_Session *session,
  1418. UA_Node *node, const UA_AddReferencesItem *item) {
  1419. return UA_Node_addReference(node, item);
  1420. }
  1421. static UA_StatusCode
  1422. deleteOneWayReference(UA_Server *server, UA_Session *session, UA_Node *node,
  1423. const UA_DeleteReferencesItem *item) {
  1424. return UA_Node_deleteReference(node, item);
  1425. }
  1426. static void
  1427. Operation_addReference(UA_Server *server, UA_Session *session, void *context,
  1428. const UA_AddReferencesItem *item, UA_StatusCode *retval) {
  1429. /* Do not check access for server */
  1430. if(session != &server->adminSession && server->config.accessControl.allowAddReference &&
  1431. !server->config.accessControl.
  1432. allowAddReference(server, &server->config.accessControl,
  1433. &session->sessionId, session->sessionHandle, item)) {
  1434. *retval = UA_STATUSCODE_BADUSERACCESSDENIED;
  1435. return;
  1436. }
  1437. /* Currently no expandednodeids are allowed */
  1438. if(item->targetServerUri.length > 0) {
  1439. *retval = UA_STATUSCODE_BADNOTIMPLEMENTED;
  1440. return;
  1441. }
  1442. /* Add the first direction */
  1443. *retval = UA_Server_editNode(server, session, &item->sourceNodeId,
  1444. (UA_EditNodeCallback)addOneWayReference,
  1445. /* cast away const because callback uses const anyway */
  1446. (UA_AddReferencesItem *)(uintptr_t)item);
  1447. UA_Boolean firstExisted = false;
  1448. if(*retval == UA_STATUSCODE_BADDUPLICATEREFERENCENOTALLOWED) {
  1449. *retval = UA_STATUSCODE_GOOD;
  1450. firstExisted = true;
  1451. } else if(*retval != UA_STATUSCODE_GOOD)
  1452. return;
  1453. /* Add the second direction */
  1454. UA_AddReferencesItem secondItem;
  1455. UA_AddReferencesItem_init(&secondItem);
  1456. secondItem.sourceNodeId = item->targetNodeId.nodeId;
  1457. secondItem.referenceTypeId = item->referenceTypeId;
  1458. secondItem.isForward = !item->isForward;
  1459. secondItem.targetNodeId.nodeId = item->sourceNodeId;
  1460. /* keep default secondItem.targetNodeClass = UA_NODECLASS_UNSPECIFIED */
  1461. *retval = UA_Server_editNode(server, session, &secondItem.sourceNodeId,
  1462. (UA_EditNodeCallback)addOneWayReference, &secondItem);
  1463. /* remove reference if the second direction failed */
  1464. UA_Boolean secondExisted = false;
  1465. if(*retval == UA_STATUSCODE_BADDUPLICATEREFERENCENOTALLOWED) {
  1466. *retval = UA_STATUSCODE_GOOD;
  1467. secondExisted = true;
  1468. } else if(*retval != UA_STATUSCODE_GOOD && !firstExisted) {
  1469. UA_DeleteReferencesItem deleteItem;
  1470. deleteItem.sourceNodeId = item->sourceNodeId;
  1471. deleteItem.referenceTypeId = item->referenceTypeId;
  1472. deleteItem.isForward = item->isForward;
  1473. deleteItem.targetNodeId = item->targetNodeId;
  1474. deleteItem.deleteBidirectional = false;
  1475. /* ignore returned status code */
  1476. UA_Server_editNode(server, session, &item->sourceNodeId,
  1477. (UA_EditNodeCallback)deleteOneWayReference, &deleteItem);
  1478. }
  1479. /* Calculate common duplicate reference not allowed result and set bad result
  1480. * if BOTH directions already existed */
  1481. if(firstExisted && secondExisted)
  1482. *retval = UA_STATUSCODE_BADDUPLICATEREFERENCENOTALLOWED;
  1483. }
  1484. void Service_AddReferences(UA_Server *server, UA_Session *session,
  1485. const UA_AddReferencesRequest *request,
  1486. UA_AddReferencesResponse *response) {
  1487. UA_LOG_DEBUG_SESSION(&server->config.logger, session,
  1488. "Processing AddReferencesRequest");
  1489. if(server->config.maxNodesPerNodeManagement != 0 &&
  1490. request->referencesToAddSize > server->config.maxNodesPerNodeManagement) {
  1491. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1492. return;
  1493. }
  1494. response->responseHeader.serviceResult =
  1495. UA_Server_processServiceOperations(server, session,
  1496. (UA_ServiceOperation)Operation_addReference,
  1497. NULL, &request->referencesToAddSize,
  1498. &UA_TYPES[UA_TYPES_ADDREFERENCESITEM],
  1499. &response->resultsSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
  1500. }
  1501. UA_StatusCode
  1502. UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId,
  1503. const UA_NodeId refTypeId,
  1504. const UA_ExpandedNodeId targetId,
  1505. UA_Boolean isForward) {
  1506. UA_AddReferencesItem item;
  1507. UA_AddReferencesItem_init(&item);
  1508. item.sourceNodeId = sourceId;
  1509. item.referenceTypeId = refTypeId;
  1510. item.isForward = isForward;
  1511. item.targetNodeId = targetId;
  1512. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1513. Operation_addReference(server, &server->adminSession, NULL, &item, &retval);
  1514. return retval;
  1515. }
  1516. /*********************/
  1517. /* Delete References */
  1518. /*********************/
  1519. static void
  1520. Operation_deleteReference(UA_Server *server, UA_Session *session, void *context,
  1521. const UA_DeleteReferencesItem *item, UA_StatusCode *retval) {
  1522. /* Do not check access for server */
  1523. if(session != &server->adminSession &&
  1524. server->config.accessControl.allowDeleteReference &&
  1525. !server->config.accessControl.allowDeleteReference(server,
  1526. &server->config.accessControl,
  1527. &session->sessionId,
  1528. session->sessionHandle, item)) {
  1529. *retval = UA_STATUSCODE_BADUSERACCESSDENIED;
  1530. return;
  1531. }
  1532. // TODO: Check consistency constraints, remove the references.
  1533. *retval = UA_Server_editNode(server, session, &item->sourceNodeId,
  1534. (UA_EditNodeCallback)deleteOneWayReference,
  1535. /* cast away const qualifier because callback uses it anyway */
  1536. (UA_DeleteReferencesItem *)(uintptr_t)item);
  1537. if(*retval != UA_STATUSCODE_GOOD)
  1538. return;
  1539. if(!item->deleteBidirectional || item->targetNodeId.serverIndex != 0)
  1540. return;
  1541. UA_DeleteReferencesItem secondItem;
  1542. UA_DeleteReferencesItem_init(&secondItem);
  1543. secondItem.isForward = !item->isForward;
  1544. secondItem.sourceNodeId = item->targetNodeId.nodeId;
  1545. secondItem.targetNodeId.nodeId = item->sourceNodeId;
  1546. secondItem.referenceTypeId = item->referenceTypeId;
  1547. *retval = UA_Server_editNode(server, session, &secondItem.sourceNodeId,
  1548. (UA_EditNodeCallback)deleteOneWayReference,
  1549. &secondItem);
  1550. }
  1551. void
  1552. Service_DeleteReferences(UA_Server *server, UA_Session *session,
  1553. const UA_DeleteReferencesRequest *request,
  1554. UA_DeleteReferencesResponse *response) {
  1555. UA_LOG_DEBUG_SESSION(&server->config.logger, session,
  1556. "Processing DeleteReferencesRequest");
  1557. if(server->config.maxNodesPerNodeManagement != 0 &&
  1558. request->referencesToDeleteSize > server->config.maxNodesPerNodeManagement) {
  1559. response->responseHeader.serviceResult = UA_STATUSCODE_BADTOOMANYOPERATIONS;
  1560. return;
  1561. }
  1562. response->responseHeader.serviceResult =
  1563. UA_Server_processServiceOperations(server, session,
  1564. (UA_ServiceOperation)Operation_deleteReference,
  1565. NULL, &request->referencesToDeleteSize,
  1566. &UA_TYPES[UA_TYPES_DELETEREFERENCESITEM],
  1567. &response->resultsSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
  1568. }
  1569. UA_StatusCode
  1570. UA_Server_deleteReference(UA_Server *server, const UA_NodeId sourceNodeId,
  1571. const UA_NodeId referenceTypeId, UA_Boolean isForward,
  1572. const UA_ExpandedNodeId targetNodeId,
  1573. UA_Boolean deleteBidirectional) {
  1574. UA_DeleteReferencesItem item;
  1575. item.sourceNodeId = sourceNodeId;
  1576. item.referenceTypeId = referenceTypeId;
  1577. item.isForward = isForward;
  1578. item.targetNodeId = targetNodeId;
  1579. item.deleteBidirectional = deleteBidirectional;
  1580. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1581. Operation_deleteReference(server, &server->adminSession, NULL, &item, &retval);
  1582. return retval;
  1583. }
  1584. /**********************/
  1585. /* Set Value Callback */
  1586. /**********************/
  1587. static UA_StatusCode
  1588. setValueCallback(UA_Server *server, UA_Session *session,
  1589. UA_VariableNode *node, const UA_ValueCallback *callback) {
  1590. if(node->nodeClass != UA_NODECLASS_VARIABLE)
  1591. return UA_STATUSCODE_BADNODECLASSINVALID;
  1592. node->value.data.callback = *callback;
  1593. return UA_STATUSCODE_GOOD;
  1594. }
  1595. UA_StatusCode
  1596. UA_Server_setVariableNode_valueCallback(UA_Server *server,
  1597. const UA_NodeId nodeId,
  1598. const UA_ValueCallback callback) {
  1599. return UA_Server_editNode(server, &server->adminSession, &nodeId,
  1600. (UA_EditNodeCallback)setValueCallback,
  1601. /* cast away const because callback uses const anyway */
  1602. (UA_ValueCallback *)(uintptr_t) &callback);
  1603. }
  1604. /***************************************************/
  1605. /* Special Handling of Variables with Data Sources */
  1606. /***************************************************/
  1607. UA_StatusCode
  1608. UA_Server_addDataSourceVariableNode(UA_Server *server, const UA_NodeId requestedNewNodeId,
  1609. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  1610. const UA_QualifiedName browseName, const UA_NodeId typeDefinition,
  1611. const UA_VariableAttributes attr, const UA_DataSource dataSource,
  1612. void *nodeContext, UA_NodeId *outNewNodeId) {
  1613. UA_AddNodesItem item;
  1614. UA_AddNodesItem_init(&item);
  1615. item.nodeClass = UA_NODECLASS_VARIABLE;
  1616. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  1617. item.browseName = browseName;
  1618. UA_ExpandedNodeId typeDefinitionId;
  1619. UA_ExpandedNodeId_init(&typeDefinitionId);
  1620. typeDefinitionId.nodeId = typeDefinition;
  1621. item.typeDefinition = typeDefinitionId;
  1622. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  1623. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)&attr;
  1624. item.nodeAttributes.content.decoded.type = &UA_TYPES[UA_TYPES_VARIABLEATTRIBUTES];
  1625. UA_NodeId newNodeId;
  1626. if(!outNewNodeId) {
  1627. newNodeId = UA_NODEID_NULL;
  1628. outNewNodeId = &newNodeId;
  1629. }
  1630. /* Create the node and add it to the nodestore */
  1631. UA_StatusCode retval = AddNode_raw(server, &server->adminSession, nodeContext,
  1632. &item, outNewNodeId);
  1633. if(retval != UA_STATUSCODE_GOOD)
  1634. goto cleanup;
  1635. /* Set the data source */
  1636. retval = UA_Server_setVariableNode_dataSource(server, *outNewNodeId, dataSource);
  1637. if(retval != UA_STATUSCODE_GOOD)
  1638. goto cleanup;
  1639. /* Typecheck and add references to parent and type definition */
  1640. retval = AddNode_addRefs(server, &server->adminSession, outNewNodeId, &parentNodeId,
  1641. &referenceTypeId, &typeDefinition);
  1642. if(retval != UA_STATUSCODE_GOOD)
  1643. goto cleanup;
  1644. /* Call the constructors */
  1645. retval = AddNode_finish(server, &server->adminSession, outNewNodeId);
  1646. cleanup:
  1647. if(outNewNodeId == &newNodeId)
  1648. UA_NodeId_deleteMembers(&newNodeId);
  1649. return retval;
  1650. }
  1651. static UA_StatusCode
  1652. setDataSource(UA_Server *server, UA_Session *session,
  1653. UA_VariableNode* node, const UA_DataSource *dataSource) {
  1654. if(node->nodeClass != UA_NODECLASS_VARIABLE)
  1655. return UA_STATUSCODE_BADNODECLASSINVALID;
  1656. if(node->valueSource == UA_VALUESOURCE_DATA)
  1657. UA_DataValue_deleteMembers(&node->value.data.value);
  1658. node->value.dataSource = *dataSource;
  1659. node->valueSource = UA_VALUESOURCE_DATASOURCE;
  1660. return UA_STATUSCODE_GOOD;
  1661. }
  1662. UA_StatusCode
  1663. UA_Server_setVariableNode_dataSource(UA_Server *server, const UA_NodeId nodeId,
  1664. const UA_DataSource dataSource) {
  1665. return UA_Server_editNode(server, &server->adminSession, &nodeId,
  1666. (UA_EditNodeCallback)setDataSource,
  1667. /* casting away const because callback casts it back anyway */
  1668. (UA_DataSource *) (uintptr_t)&dataSource);
  1669. }
  1670. /************************************/
  1671. /* Special Handling of Method Nodes */
  1672. /************************************/
  1673. #ifdef UA_ENABLE_METHODCALLS
  1674. static const UA_NodeId hasproperty = {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_HASPROPERTY}};
  1675. static const UA_NodeId propertytype = {0, UA_NODEIDTYPE_NUMERIC, {UA_NS0ID_PROPERTYTYPE}};
  1676. static UA_StatusCode
  1677. UA_Server_addMethodNodeEx_finish(UA_Server *server, const UA_NodeId nodeId, UA_MethodCallback method,
  1678. const size_t inputArgumentsSize, const UA_Argument *inputArguments,
  1679. const UA_NodeId inputArgumentsRequestedNewNodeId,
  1680. UA_NodeId *inputArgumentsOutNewNodeId,
  1681. const size_t outputArgumentsSize, const UA_Argument *outputArguments,
  1682. const UA_NodeId outputArgumentsRequestedNewNodeId,
  1683. UA_NodeId *outputArgumentsOutNewNodeId) {
  1684. /* Browse to see which argument nodes exist */
  1685. UA_BrowseDescription bd;
  1686. UA_BrowseDescription_init(&bd);
  1687. bd.nodeId = nodeId;
  1688. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY);
  1689. bd.includeSubtypes = false;
  1690. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  1691. bd.nodeClassMask = UA_NODECLASS_VARIABLE;
  1692. bd.resultMask = UA_BROWSERESULTMASK_BROWSENAME;
  1693. UA_BrowseResult br;
  1694. UA_BrowseResult_init(&br);
  1695. UA_UInt32 maxrefs = 0;
  1696. Operation_Browse(server, &server->adminSession, &maxrefs, &bd, &br);
  1697. UA_StatusCode retval = br.statusCode;
  1698. if(retval != UA_STATUSCODE_GOOD) {
  1699. UA_Server_deleteNode(server, nodeId, true);
  1700. UA_BrowseResult_deleteMembers(&br);
  1701. return retval;
  1702. }
  1703. /* Filter out the argument nodes */
  1704. UA_NodeId inputArgsId = UA_NODEID_NULL;
  1705. UA_NodeId outputArgsId = UA_NODEID_NULL;
  1706. const UA_QualifiedName inputArgsName = UA_QUALIFIEDNAME(0, "InputArguments");
  1707. const UA_QualifiedName outputArgsName = UA_QUALIFIEDNAME(0, "OutputArguments");
  1708. for(size_t i = 0; i < br.referencesSize; i++) {
  1709. UA_ReferenceDescription *rd = &br.references[i];
  1710. if(rd->browseName.namespaceIndex == 0 &&
  1711. UA_String_equal(&rd->browseName.name, &inputArgsName.name))
  1712. inputArgsId = rd->nodeId.nodeId;
  1713. else if(rd->browseName.namespaceIndex == 0 &&
  1714. UA_String_equal(&rd->browseName.name, &outputArgsName.name))
  1715. outputArgsId = rd->nodeId.nodeId;
  1716. }
  1717. /* Add the Input Arguments VariableNode */
  1718. if(inputArgumentsSize > 0 && UA_NodeId_isNull(&inputArgsId)) {
  1719. UA_VariableAttributes attr = UA_VariableAttributes_default;
  1720. char *name = "InputArguments";
  1721. attr.displayName = UA_LOCALIZEDTEXT("", name);
  1722. attr.dataType = UA_TYPES[UA_TYPES_ARGUMENT].typeId;
  1723. attr.valueRank = UA_VALUERANK_ONE_DIMENSION;
  1724. UA_UInt32 inputArgsSize32 = (UA_UInt32)inputArgumentsSize;
  1725. attr.arrayDimensions = &inputArgsSize32;
  1726. attr.arrayDimensionsSize = 1;
  1727. UA_Variant_setArray(&attr.value, (void *)(uintptr_t)inputArguments,
  1728. inputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  1729. retval = UA_Server_addVariableNode(server, inputArgumentsRequestedNewNodeId, nodeId,
  1730. hasproperty, UA_QUALIFIEDNAME(0, name),
  1731. propertytype, attr, NULL, &inputArgsId);
  1732. if(retval != UA_STATUSCODE_GOOD)
  1733. goto error;
  1734. }
  1735. /* Add the Output Arguments VariableNode */
  1736. if(outputArgumentsSize > 0 && UA_NodeId_isNull(&outputArgsId)) {
  1737. UA_VariableAttributes attr = UA_VariableAttributes_default;
  1738. char *name = "OutputArguments";
  1739. attr.displayName = UA_LOCALIZEDTEXT("", name);
  1740. attr.dataType = UA_TYPES[UA_TYPES_ARGUMENT].typeId;
  1741. attr.valueRank = UA_VALUERANK_ONE_DIMENSION;
  1742. UA_UInt32 outputArgsSize32 = (UA_UInt32)outputArgumentsSize;
  1743. attr.arrayDimensions = &outputArgsSize32;
  1744. attr.arrayDimensionsSize = 1;
  1745. UA_Variant_setArray(&attr.value, (void *)(uintptr_t)outputArguments,
  1746. outputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  1747. retval = UA_Server_addVariableNode(server, outputArgumentsRequestedNewNodeId, nodeId,
  1748. hasproperty, UA_QUALIFIEDNAME(0, name),
  1749. propertytype, attr, NULL, &outputArgsId);
  1750. if(retval != UA_STATUSCODE_GOOD)
  1751. goto error;
  1752. }
  1753. retval = UA_Server_setMethodNode_callback(server, nodeId, method);
  1754. if(retval != UA_STATUSCODE_GOOD)
  1755. goto error;
  1756. /* Call finish to add the parent reference */
  1757. retval = AddNode_finish(server, &server->adminSession, &nodeId);
  1758. if(retval != UA_STATUSCODE_GOOD)
  1759. goto error;
  1760. if(inputArgumentsOutNewNodeId != NULL) {
  1761. UA_NodeId_copy(&inputArgsId, inputArgumentsOutNewNodeId);
  1762. }
  1763. if(outputArgumentsOutNewNodeId != NULL) {
  1764. UA_NodeId_copy(&outputArgsId, outputArgumentsOutNewNodeId);
  1765. }
  1766. UA_BrowseResult_deleteMembers(&br);
  1767. return retval;
  1768. error:
  1769. UA_Server_deleteNode(server, nodeId, true);
  1770. UA_Server_deleteNode(server, inputArgsId, true);
  1771. UA_Server_deleteNode(server, outputArgsId, true);
  1772. UA_BrowseResult_deleteMembers(&br);
  1773. return retval;
  1774. }
  1775. UA_StatusCode
  1776. UA_Server_addMethodNode_finish(UA_Server *server, const UA_NodeId nodeId,
  1777. UA_MethodCallback method,
  1778. size_t inputArgumentsSize, const UA_Argument* inputArguments,
  1779. size_t outputArgumentsSize, const UA_Argument* outputArguments) {
  1780. return UA_Server_addMethodNodeEx_finish(server, nodeId, method,
  1781. inputArgumentsSize, inputArguments, UA_NODEID_NULL, NULL,
  1782. outputArgumentsSize, outputArguments, UA_NODEID_NULL, NULL);
  1783. }
  1784. UA_StatusCode
  1785. UA_Server_addMethodNodeEx(UA_Server *server, const UA_NodeId requestedNewNodeId,
  1786. const UA_NodeId parentNodeId,
  1787. const UA_NodeId referenceTypeId,
  1788. const UA_QualifiedName browseName,
  1789. const UA_MethodAttributes attr, UA_MethodCallback method,
  1790. size_t inputArgumentsSize, const UA_Argument *inputArguments,
  1791. const UA_NodeId inputArgumentsRequestedNewNodeId,
  1792. UA_NodeId *inputArgumentsOutNewNodeId,
  1793. size_t outputArgumentsSize, const UA_Argument *outputArguments,
  1794. const UA_NodeId outputArgumentsRequestedNewNodeId,
  1795. UA_NodeId *outputArgumentsOutNewNodeId,
  1796. void *nodeContext, UA_NodeId *outNewNodeId) {
  1797. UA_AddNodesItem item;
  1798. UA_AddNodesItem_init(&item);
  1799. item.nodeClass = UA_NODECLASS_METHOD;
  1800. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  1801. item.browseName = browseName;
  1802. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  1803. item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)&attr;
  1804. item.nodeAttributes.content.decoded.type = &UA_TYPES[UA_TYPES_METHODATTRIBUTES];
  1805. UA_NodeId newId;
  1806. if(!outNewNodeId) {
  1807. UA_NodeId_init(&newId);
  1808. outNewNodeId = &newId;
  1809. }
  1810. UA_StatusCode retval = Operation_addNode_begin(server, &server->adminSession,
  1811. nodeContext, &item, &parentNodeId,
  1812. &referenceTypeId, outNewNodeId);
  1813. if(retval != UA_STATUSCODE_GOOD)
  1814. return retval;
  1815. retval = UA_Server_addMethodNodeEx_finish(server, *outNewNodeId, method,
  1816. inputArgumentsSize, inputArguments,
  1817. inputArgumentsRequestedNewNodeId,
  1818. inputArgumentsOutNewNodeId,
  1819. outputArgumentsSize, outputArguments,
  1820. outputArgumentsRequestedNewNodeId,
  1821. outputArgumentsOutNewNodeId);
  1822. if(outNewNodeId == &newId)
  1823. UA_NodeId_deleteMembers(&newId);
  1824. return retval;
  1825. }
  1826. static UA_StatusCode
  1827. editMethodCallback(UA_Server *server, UA_Session* session,
  1828. UA_Node* node, void* handle) {
  1829. if(node->nodeClass != UA_NODECLASS_METHOD)
  1830. return UA_STATUSCODE_BADNODECLASSINVALID;
  1831. UA_MethodNode *mnode = (UA_MethodNode*) node;
  1832. mnode->method = (UA_MethodCallback)(uintptr_t)handle;
  1833. return UA_STATUSCODE_GOOD;
  1834. }
  1835. UA_StatusCode
  1836. UA_Server_setMethodNode_callback(UA_Server *server,
  1837. const UA_NodeId methodNodeId,
  1838. UA_MethodCallback methodCallback) {
  1839. return UA_Server_editNode(server, &server->adminSession, &methodNodeId,
  1840. (UA_EditNodeCallback)editMethodCallback,
  1841. (void*)(uintptr_t)methodCallback);
  1842. }
  1843. #endif
  1844. /************************/
  1845. /* Lifecycle Management */
  1846. /************************/
  1847. static UA_StatusCode
  1848. setNodeTypeLifecycle(UA_Server *server, UA_Session *session,
  1849. UA_Node* node, UA_NodeTypeLifecycle *lifecycle) {
  1850. if(node->nodeClass == UA_NODECLASS_OBJECTTYPE) {
  1851. UA_ObjectTypeNode *ot = (UA_ObjectTypeNode*)node;
  1852. ot->lifecycle = *lifecycle;
  1853. return UA_STATUSCODE_GOOD;
  1854. }
  1855. if(node->nodeClass == UA_NODECLASS_VARIABLETYPE) {
  1856. UA_VariableTypeNode *vt = (UA_VariableTypeNode*)node;
  1857. vt->lifecycle = *lifecycle;
  1858. return UA_STATUSCODE_GOOD;
  1859. }
  1860. return UA_STATUSCODE_BADNODECLASSINVALID;
  1861. }
  1862. UA_StatusCode
  1863. UA_Server_setNodeTypeLifecycle(UA_Server *server, UA_NodeId nodeId,
  1864. UA_NodeTypeLifecycle lifecycle) {
  1865. return UA_Server_editNode(server, &server->adminSession, &nodeId,
  1866. (UA_EditNodeCallback)setNodeTypeLifecycle,
  1867. &lifecycle);
  1868. }