ua_services_nodemanagement.c 76 KB

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