ua_services_nodemanagement.c 75 KB

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