ua_services_nodemanagement.c 76 KB

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