ua_services_nodemanagement.c 91 KB

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