ua_services_nodemanagement.c 75 KB

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