ua_server_addressspace.c 72 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755
  1. #include "ua_server.h"
  2. #include "ua_server_internal.h"
  3. #define UA_SERVER_DELETENODEALIAS(TYPE) \
  4. UA_StatusCode UA_Server_delete##TYPE##Node(UA_Server *server, UA_NodeId nodeId) { \
  5. return UA_Server_deleteNode(server, nodeId); \
  6. }
  7. UA_StatusCode
  8. UA_Server_deleteNode(UA_Server *server, UA_NodeId nodeId) {
  9. union nodeUnion {
  10. const UA_Node *delNodeConst;
  11. UA_Node *delNode;
  12. } ptrs;
  13. ptrs.delNodeConst = UA_NodeStore_get(server->nodestore, &nodeId);
  14. if (!ptrs.delNodeConst)
  15. return UA_STATUSCODE_BADNODEIDINVALID;
  16. UA_NodeStore_release(ptrs.delNodeConst);
  17. // Remove the node from the hashmap/slot
  18. UA_NodeStore_remove(server->nodestore, &nodeId);
  19. /*
  20. * FIXME: Delete unreachable child nodes???
  21. */
  22. return UA_STATUSCODE_GOOD;
  23. }
  24. UA_SERVER_DELETENODEALIAS(Object)
  25. UA_SERVER_DELETENODEALIAS(Variable)
  26. UA_SERVER_DELETENODEALIAS(ReferenceType)
  27. UA_SERVER_DELETENODEALIAS(View)
  28. UA_SERVER_DELETENODEALIAS(VariableType)
  29. UA_SERVER_DELETENODEALIAS(DataType)
  30. #ifdef ENABLE_METHODCALLS
  31. UA_SERVER_DELETENODEALIAS(Method)
  32. #endif
  33. UA_StatusCode UA_Server_getNodeCopy(UA_Server *server, UA_NodeId nodeId, void **copyInto) {
  34. const UA_Node *node = UA_NodeStore_get(server->nodestore, &nodeId);
  35. UA_Node **copy = (UA_Node **) copyInto;
  36. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  37. if (!node)
  38. return UA_STATUSCODE_BADNODEIDINVALID;
  39. switch(node->nodeClass) {
  40. case UA_NODECLASS_DATATYPE:
  41. *copy = (UA_Node *) UA_VariableNode_new();
  42. retval |= UA_DataTypeNode_copy((const UA_DataTypeNode *) node, (UA_DataTypeNode *) *copy);
  43. break;
  44. case UA_NODECLASS_METHOD:
  45. *copy = (UA_Node *) UA_MethodNode_new();
  46. retval |= UA_MethodNode_copy((const UA_MethodNode *) node, (UA_MethodNode *) *copy);
  47. break;
  48. case UA_NODECLASS_OBJECT:
  49. *copy = (UA_Node *) UA_ObjectNode_new();
  50. retval |= UA_ObjectNode_copy((const UA_ObjectNode *) node, (UA_ObjectNode *) *copy);
  51. break;
  52. case UA_NODECLASS_OBJECTTYPE:
  53. *copy = (UA_Node *) UA_ObjectTypeNode_new();
  54. retval |= UA_ObjectTypeNode_copy((const UA_ObjectTypeNode *) node, (UA_ObjectTypeNode *) *copy);
  55. break;
  56. case UA_NODECLASS_REFERENCETYPE:
  57. *copy = (UA_Node *) UA_ReferenceTypeNode_new();
  58. retval |= UA_ReferenceTypeNode_copy((const UA_ReferenceTypeNode *) node, (UA_ReferenceTypeNode *) *copy);
  59. break;
  60. case UA_NODECLASS_VARIABLE:
  61. *copy = (UA_Node *) UA_VariableNode_new();
  62. retval |= UA_VariableNode_copy((const UA_VariableNode *) node, (UA_VariableNode *) *copy);
  63. break;
  64. case UA_NODECLASS_VARIABLETYPE:
  65. *copy = (UA_Node *) UA_VariableTypeNode_new();
  66. retval |= UA_VariableTypeNode_copy((const UA_VariableTypeNode *) node, (UA_VariableTypeNode *) *copy);
  67. break;
  68. case UA_NODECLASS_VIEW:
  69. *copy = (UA_Node *) UA_ViewNode_new();
  70. retval |= UA_ViewNode_copy((const UA_ViewNode *) node, (UA_ViewNode *) *copy);
  71. break;
  72. default:
  73. break;
  74. }
  75. UA_NodeStore_release(node);
  76. return retval;
  77. }
  78. UA_StatusCode UA_Server_deleteNodeCopy(UA_Server *server, void **nodeptr) {
  79. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  80. UA_Node **node = (UA_Node **) nodeptr;
  81. if (!(*node))
  82. return UA_STATUSCODE_BADNODEIDINVALID;
  83. switch((*node)->nodeClass) {
  84. case UA_NODECLASS_DATATYPE:
  85. UA_DataTypeNode_delete((UA_DataTypeNode *) *node);
  86. break;
  87. case UA_NODECLASS_METHOD:
  88. UA_MethodNode_delete((UA_MethodNode *) *node);
  89. break;
  90. case UA_NODECLASS_OBJECT:
  91. UA_ObjectNode_delete((UA_ObjectNode *) *node);
  92. break;
  93. case UA_NODECLASS_OBJECTTYPE:
  94. UA_ObjectTypeNode_delete((UA_ObjectTypeNode *) *node);
  95. break;
  96. case UA_NODECLASS_REFERENCETYPE:
  97. UA_ReferenceTypeNode_delete((UA_ReferenceTypeNode *) *node);
  98. break;
  99. case UA_NODECLASS_VARIABLE:
  100. UA_VariableNode_delete((UA_VariableNode *) *node);
  101. break;
  102. case UA_NODECLASS_VARIABLETYPE:
  103. UA_VariableTypeNode_delete((UA_VariableTypeNode *) *node);
  104. break;
  105. case UA_NODECLASS_VIEW:
  106. UA_ViewNode_delete((UA_ViewNode *) *node);
  107. break;
  108. default:
  109. break;
  110. }
  111. return retval;
  112. }
  113. UA_StatusCode
  114. UA_Server_forEachChildNodeCall(UA_Server *server, UA_NodeId parentNodeId, UA_NodeIteratorCallback callback, void *handle) {
  115. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  116. const UA_Node *parent = UA_NodeStore_get(server->nodestore, &parentNodeId);
  117. if (!parent)
  118. return UA_STATUSCODE_BADNODEIDINVALID;
  119. for(int i=0; i<parent->referencesSize; i++) {
  120. UA_ReferenceNode *ref = &parent->references[i];
  121. retval |= callback(ref->targetId.nodeId, ref->isInverse, ref->referenceTypeId, handle);
  122. }
  123. UA_NodeStore_release(parent);
  124. return retval;
  125. }
  126. UA_StatusCode
  127. UA_Server_addVariableNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  128. const UA_LocalizedText displayName, const UA_LocalizedText description,
  129. const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  130. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  131. UA_Variant *value, UA_NodeId *createdNodeId) {
  132. UA_VariableNode *node = UA_VariableNode_new();
  133. UA_StatusCode retval;
  134. node->value.variant.value = *value; // copy content
  135. UA_NodeId_copy(&nodeId, &node->nodeId);
  136. UA_QualifiedName_copy(&browseName, &node->browseName);
  137. UA_LocalizedText_copy(&displayName, &node->displayName);
  138. UA_LocalizedText_copy(&description, &node->description);
  139. node->writeMask = writeMask;
  140. node->userWriteMask = userWriteMask;
  141. UA_ExpandedNodeId parentId;
  142. UA_ExpandedNodeId_init(&parentId);
  143. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  144. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  145. parentId, referenceTypeId);
  146. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  147. UA_EXPANDEDNODEID_NUMERIC(0, value->type->typeId.identifier.numeric));
  148. if(res.statusCode != UA_STATUSCODE_GOOD) {
  149. UA_Variant_init(&node->value.variant.value);
  150. UA_VariableNode_delete(node);
  151. } else
  152. UA_free(value);
  153. retval = res.statusCode;
  154. if (createdNodeId != UA_NULL)
  155. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  156. UA_AddNodesResult_deleteMembers(&res);
  157. UA_ExpandedNodeId_deleteMembers(&parentId);
  158. return retval;
  159. }
  160. UA_StatusCode
  161. UA_Server_addObjectNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  162. const UA_LocalizedText displayName, const UA_LocalizedText description,
  163. const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  164. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  165. const UA_ExpandedNodeId typeDefinition, UA_NodeId *createdNodeId){
  166. UA_ObjectNode *node = UA_ObjectNode_new();
  167. UA_StatusCode retval;
  168. UA_NodeId_copy(&nodeId, &node->nodeId);
  169. UA_QualifiedName_copy(&browseName, &node->browseName);
  170. UA_LocalizedText_copy(&displayName, &node->displayName);
  171. UA_LocalizedText_copy(&description, &node->description);
  172. node->writeMask = writeMask;
  173. node->userWriteMask = userWriteMask;
  174. UA_ExpandedNodeId parentId; // we need an expandednodeid
  175. UA_ExpandedNodeId_init(&parentId);
  176. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  177. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  178. parentId, referenceTypeId);
  179. if(res.statusCode != UA_STATUSCODE_GOOD)
  180. UA_ObjectNode_delete(node);
  181. retval = res.statusCode;
  182. if (createdNodeId != UA_NULL)
  183. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  184. UA_AddNodesResult_deleteMembers(&res);
  185. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  186. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  187. }
  188. return retval;
  189. }
  190. UA_StatusCode
  191. UA_Server_addDataSourceVariableNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  192. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  193. const UA_NodeId parentNodeId,
  194. const UA_NodeId referenceTypeId,
  195. const UA_DataSource dataSource,
  196. UA_NodeId *createdNodeId) {
  197. UA_VariableNode *node = UA_VariableNode_new();
  198. UA_StatusCode retval;
  199. node->valueSource = UA_VALUESOURCE_DATASOURCE;
  200. node->value.dataSource = dataSource;
  201. UA_NodeId_copy(&nodeId, &node->nodeId);
  202. UA_QualifiedName_copy(&browseName, &node->browseName);
  203. UA_LocalizedText_copy(&displayName, &node->displayName);
  204. UA_LocalizedText_copy(&description, &node->description);
  205. node->writeMask = writeMask;
  206. node->userWriteMask = userWriteMask;
  207. UA_ExpandedNodeId parentId; // dummy exapndednodeid
  208. UA_ExpandedNodeId_init(&parentId);
  209. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  210. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  211. parentId, referenceTypeId);
  212. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  213. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE));
  214. if(res.statusCode != UA_STATUSCODE_GOOD)
  215. UA_VariableNode_delete(node);
  216. retval = res.statusCode;
  217. if (createdNodeId != UA_NULL)
  218. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  219. UA_AddNodesResult_deleteMembers(&res);
  220. return retval;
  221. }
  222. UA_StatusCode
  223. UA_Server_addVariableTypeNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  224. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  225. const UA_NodeId parentNodeId,
  226. const UA_NodeId referenceTypeId,
  227. UA_Variant *value,
  228. const UA_Int32 valueRank,
  229. const UA_Boolean isAbstract,
  230. UA_NodeId *createdNodeId) {
  231. UA_VariableTypeNode *node = UA_VariableTypeNode_new();
  232. UA_StatusCode retval;
  233. node->value.variant.value = *value; // copy content
  234. UA_NodeId_copy(&nodeId, &node->nodeId);
  235. UA_QualifiedName_copy(&browseName, &node->browseName);
  236. UA_LocalizedText_copy(&displayName, &node->displayName);
  237. UA_LocalizedText_copy(&description, &node->description);
  238. node->writeMask = writeMask;
  239. node->userWriteMask = userWriteMask;
  240. UA_ExpandedNodeId parentId;
  241. UA_ExpandedNodeId_init(&parentId);
  242. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  243. node->isAbstract = isAbstract;
  244. node->valueRank = valueRank;
  245. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  246. parentId, referenceTypeId);
  247. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  248. UA_EXPANDEDNODEID_NUMERIC(0, value->type->typeId.identifier.numeric));
  249. if(res.statusCode != UA_STATUSCODE_GOOD) {
  250. UA_Variant_init(&node->value.variant.value);
  251. UA_VariableTypeNode_delete(node);
  252. } else
  253. UA_free(value);
  254. retval = res.statusCode;
  255. if (createdNodeId != UA_NULL)
  256. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  257. UA_AddNodesResult_deleteMembers(&res);
  258. return retval ;
  259. }
  260. UA_StatusCode
  261. UA_Server_addDataTypeNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  262. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  263. const UA_NodeId parentNodeId,
  264. const UA_NodeId referenceTypeId,
  265. const UA_ExpandedNodeId typeDefinition,
  266. const UA_Boolean isAbstract,
  267. UA_NodeId *createdNodeId) {
  268. UA_DataTypeNode *node = UA_DataTypeNode_new();
  269. UA_StatusCode retval;
  270. UA_NodeId_copy(&nodeId, &node->nodeId);
  271. UA_QualifiedName_copy(&browseName, &node->browseName);
  272. UA_LocalizedText_copy(&displayName, &node->displayName);
  273. UA_LocalizedText_copy(&description, &node->description);
  274. node->writeMask = writeMask;
  275. node->userWriteMask = userWriteMask;
  276. UA_ExpandedNodeId parentId; // we need an expandednodeid
  277. UA_ExpandedNodeId_init(&parentId);
  278. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  279. node->isAbstract = isAbstract;
  280. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  281. parentId, referenceTypeId);
  282. if(res.statusCode != UA_STATUSCODE_GOOD)
  283. UA_DataTypeNode_delete(node);
  284. retval = res.statusCode;
  285. if (createdNodeId != UA_NULL)
  286. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  287. UA_AddNodesResult_deleteMembers(&res);
  288. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  289. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  290. }
  291. return retval;
  292. }
  293. UA_StatusCode
  294. UA_Server_addViewNode(UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  295. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  296. const UA_NodeId parentNodeId,
  297. const UA_NodeId referenceTypeId,
  298. const UA_ExpandedNodeId typeDefinition,
  299. UA_NodeId *createdNodeId) {
  300. UA_ViewNode *node = UA_ViewNode_new();
  301. UA_StatusCode retval;
  302. UA_NodeId_copy(&nodeId, &node->nodeId);
  303. UA_QualifiedName_copy(&browseName, &node->browseName);
  304. UA_LocalizedText_copy(&displayName, &node->displayName);
  305. UA_LocalizedText_copy(&description, &node->description);
  306. node->writeMask = writeMask;
  307. node->userWriteMask = userWriteMask;
  308. UA_ExpandedNodeId parentId; // we need an expandednodeid
  309. UA_ExpandedNodeId_init(&parentId);
  310. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  311. node->containsNoLoops = UA_TRUE;
  312. node->eventNotifier = 0;
  313. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  314. parentId, referenceTypeId);
  315. if(res.statusCode != UA_STATUSCODE_GOOD)
  316. UA_ViewNode_delete(node);
  317. retval = res.statusCode;
  318. if (createdNodeId != UA_NULL)
  319. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  320. UA_AddNodesResult_deleteMembers(&res);
  321. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  322. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  323. }
  324. return retval;
  325. }
  326. UA_StatusCode UA_Server_addReferenceTypeNode (UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  327. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  328. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  329. const UA_ExpandedNodeId typeDefinition,
  330. const UA_LocalizedText inverseName,
  331. UA_NodeId *createdNodeId ){
  332. UA_ReferenceTypeNode *node = UA_ReferenceTypeNode_new();
  333. UA_StatusCode retval;
  334. UA_NodeId_copy(&nodeId, &node->nodeId);
  335. UA_QualifiedName_copy(&browseName, &node->browseName);
  336. UA_LocalizedText_copy(&displayName, &node->displayName);
  337. UA_LocalizedText_copy(&description, &node->description);
  338. node->writeMask = writeMask;
  339. node->userWriteMask = userWriteMask;
  340. UA_ExpandedNodeId parentId; // we need an expandednodeid
  341. UA_ExpandedNodeId_init(&parentId);
  342. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  343. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  344. parentId, referenceTypeId);
  345. if(res.statusCode != UA_STATUSCODE_GOOD)
  346. UA_ReferenceTypeNode_delete(node);
  347. retval = res.statusCode;
  348. if (createdNodeId != UA_NULL)
  349. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  350. UA_AddNodesResult_deleteMembers(&res);
  351. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  352. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  353. }
  354. return retval;
  355. }
  356. UA_StatusCode UA_Server_addObjectTypeNode (UA_Server *server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  357. const UA_LocalizedText displayName, const UA_LocalizedText description, const UA_UInt32 userWriteMask, const UA_UInt32 writeMask,
  358. const UA_NodeId parentNodeId, const UA_NodeId referenceTypeId,
  359. const UA_ExpandedNodeId typeDefinition,
  360. const UA_Boolean isAbstract,
  361. UA_NodeId *createdNodeId ){
  362. UA_ObjectTypeNode *node = UA_ObjectTypeNode_new();
  363. UA_StatusCode retval;
  364. UA_NodeId_copy(&nodeId, &node->nodeId);
  365. UA_QualifiedName_copy(&browseName, &node->browseName);
  366. UA_LocalizedText_copy(&displayName, &node->displayName);
  367. UA_LocalizedText_copy(&description, &node->description);
  368. node->writeMask = writeMask;
  369. node->userWriteMask = userWriteMask;
  370. UA_ExpandedNodeId parentId; // we need an expandednodeid
  371. UA_ExpandedNodeId_init(&parentId);
  372. UA_NodeId_copy(&parentNodeId, &parentId.nodeId);
  373. node->isAbstract = isAbstract;
  374. UA_AddNodesResult res = UA_Server_addNodeWithSession(server, &adminSession, (UA_Node*)node,
  375. parentId, referenceTypeId);
  376. if(res.statusCode != UA_STATUSCODE_GOOD)
  377. UA_ObjectTypeNode_delete(node);
  378. retval = res.statusCode;
  379. if (createdNodeId != UA_NULL)
  380. UA_NodeId_copy(&res.addedNodeId, createdNodeId);
  381. UA_AddNodesResult_deleteMembers(&res);
  382. if(!UA_NodeId_isNull(&typeDefinition.nodeId)) {
  383. UA_Server_addReference(server, res.addedNodeId, UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION), typeDefinition);
  384. }
  385. return retval;
  386. }
  387. /* Userspace Version of addOneWayReferenceWithSession*/
  388. UA_StatusCode
  389. UA_Server_addMonodirectionalReference(UA_Server *server, UA_NodeId sourceNodeId, UA_ExpandedNodeId targetNodeId,
  390. UA_NodeId referenceTypeId, UA_Boolean isforward) {
  391. UA_AddReferencesItem ref;
  392. UA_AddReferencesItem_init(&ref);
  393. UA_StatusCode retval = UA_NodeId_copy(&sourceNodeId, &ref.sourceNodeId);
  394. retval |= UA_ExpandedNodeId_copy(&targetNodeId, &ref.targetNodeId);
  395. retval |= UA_NodeId_copy(&referenceTypeId, &ref.referenceTypeId);
  396. if(retval != UA_STATUSCODE_GOOD)
  397. goto cleanup;
  398. const UA_Node *target = UA_NodeStore_get(server->nodestore, &ref.targetNodeId.nodeId);
  399. if(!target) {
  400. retval = UA_STATUSCODE_BADNODEIDINVALID;
  401. goto cleanup;
  402. }
  403. if(isforward == UA_TRUE)
  404. ref.isForward = UA_TRUE;
  405. ref.targetNodeClass = target->nodeClass;
  406. UA_NodeStore_release(target);
  407. retval = addOneWayReferenceWithSession(server, (UA_Session *) UA_NULL, &ref);
  408. cleanup:
  409. UA_AddReferencesItem_deleteMembers(&ref);
  410. return retval;
  411. }
  412. /* Adds a one-way reference to the local nodestore */
  413. UA_StatusCode
  414. addOneWayReferenceWithSession(UA_Server *server, UA_Session *session, const UA_AddReferencesItem *item) {
  415. const UA_Node *node = UA_NodeStore_get(server->nodestore, &item->sourceNodeId);
  416. if(!node)
  417. return UA_STATUSCODE_BADINTERNALERROR;
  418. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  419. #ifndef UA_MULTITHREADING
  420. size_t i = node->referencesSize;
  421. if(node->referencesSize < 0)
  422. i = 0;
  423. size_t refssize = (i+1) | 3; // so the realloc is not necessary every time
  424. UA_ReferenceNode *new_refs = UA_realloc(node->references, sizeof(UA_ReferenceNode) * refssize);
  425. if(!new_refs)
  426. retval = UA_STATUSCODE_BADOUTOFMEMORY;
  427. else {
  428. UA_ReferenceNode_init(&new_refs[i]);
  429. retval = UA_NodeId_copy(&item->referenceTypeId, &new_refs[i].referenceTypeId);
  430. new_refs[i].isInverse = !item->isForward;
  431. retval |= UA_ExpandedNodeId_copy(&item->targetNodeId, &new_refs[i].targetId);
  432. /* hack. be careful! possible only in the single-threaded case. */
  433. UA_Node *mutable_node = (UA_Node*)(uintptr_t)node;
  434. mutable_node->references = new_refs;
  435. if(retval != UA_STATUSCODE_GOOD) {
  436. UA_NodeId_deleteMembers(&new_refs[node->referencesSize].referenceTypeId);
  437. UA_ExpandedNodeId_deleteMembers(&new_refs[node->referencesSize].targetId);
  438. } else
  439. mutable_node->referencesSize = i+1;
  440. }
  441. UA_NodeStore_release(node);
  442. return retval;
  443. #else
  444. UA_Node *newNode = UA_NULL;
  445. void (*deleteNode)(UA_Node*) = UA_NULL;
  446. switch(node->nodeClass) {
  447. case UA_NODECLASS_OBJECT:
  448. newNode = (UA_Node*)UA_ObjectNode_new();
  449. UA_ObjectNode_copy((const UA_ObjectNode*)node, (UA_ObjectNode*)newNode);
  450. deleteNode = (void (*)(UA_Node*))UA_ObjectNode_delete;
  451. break;
  452. case UA_NODECLASS_VARIABLE:
  453. newNode = (UA_Node*)UA_VariableNode_new();
  454. UA_VariableNode_copy((const UA_VariableNode*)node, (UA_VariableNode*)newNode);
  455. deleteNode = (void (*)(UA_Node*))UA_VariableNode_delete;
  456. break;
  457. case UA_NODECLASS_METHOD:
  458. newNode = (UA_Node*)UA_MethodNode_new();
  459. UA_MethodNode_copy((const UA_MethodNode*)node, (UA_MethodNode*)newNode);
  460. deleteNode = (void (*)(UA_Node*))UA_MethodNode_delete;
  461. break;
  462. case UA_NODECLASS_OBJECTTYPE:
  463. newNode = (UA_Node*)UA_ObjectTypeNode_new();
  464. UA_ObjectTypeNode_copy((const UA_ObjectTypeNode*)node, (UA_ObjectTypeNode*)newNode);
  465. deleteNode = (void (*)(UA_Node*))UA_ObjectTypeNode_delete;
  466. break;
  467. case UA_NODECLASS_VARIABLETYPE:
  468. newNode = (UA_Node*)UA_VariableTypeNode_new();
  469. UA_VariableTypeNode_copy((const UA_VariableTypeNode*)node, (UA_VariableTypeNode*)newNode);
  470. deleteNode = (void (*)(UA_Node*))UA_VariableTypeNode_delete;
  471. break;
  472. case UA_NODECLASS_REFERENCETYPE:
  473. newNode = (UA_Node*)UA_ReferenceTypeNode_new();
  474. UA_ReferenceTypeNode_copy((const UA_ReferenceTypeNode*)node, (UA_ReferenceTypeNode*)newNode);
  475. deleteNode = (void (*)(UA_Node*))UA_ReferenceTypeNode_delete;
  476. break;
  477. case UA_NODECLASS_DATATYPE:
  478. newNode = (UA_Node*)UA_DataTypeNode_new();
  479. UA_DataTypeNode_copy((const UA_DataTypeNode*)node, (UA_DataTypeNode*)newNode);
  480. deleteNode = (void (*)(UA_Node*))UA_DataTypeNode_delete;
  481. break;
  482. case UA_NODECLASS_VIEW:
  483. newNode = (UA_Node*)UA_ViewNode_new();
  484. UA_ViewNode_copy((const UA_ViewNode*)node, (UA_ViewNode*)newNode);
  485. deleteNode = (void (*)(UA_Node*))UA_ViewNode_delete;
  486. break;
  487. default:
  488. return UA_STATUSCODE_BADINTERNALERROR;
  489. }
  490. UA_Int32 count = node->referencesSize;
  491. if(count < 0)
  492. count = 0;
  493. UA_ReferenceNode *old_refs = newNode->references;
  494. UA_ReferenceNode *new_refs = UA_malloc(sizeof(UA_ReferenceNode)*(count+1));
  495. if(!new_refs) {
  496. deleteNode(newNode);
  497. UA_NodeStore_release(node);
  498. return UA_STATUSCODE_BADOUTOFMEMORY;
  499. }
  500. // insert the new reference
  501. UA_memcpy(new_refs, old_refs, sizeof(UA_ReferenceNode)*count);
  502. UA_ReferenceNode_init(&new_refs[count]);
  503. retval = UA_NodeId_copy(&item->referenceTypeId, &new_refs[count].referenceTypeId);
  504. new_refs[count].isInverse = !item->isForward;
  505. retval |= UA_ExpandedNodeId_copy(&item->targetNodeId, &new_refs[count].targetId);
  506. if(retval != UA_STATUSCODE_GOOD) {
  507. UA_Array_delete(new_refs, &UA_TYPES[UA_TYPES_REFERENCENODE], ++count);
  508. newNode->references = UA_NULL;
  509. newNode->referencesSize = 0;
  510. deleteNode(newNode);
  511. UA_NodeStore_release(node);
  512. return UA_STATUSCODE_BADOUTOFMEMORY;
  513. }
  514. UA_free(old_refs);
  515. newNode->references = new_refs;
  516. newNode->referencesSize = ++count;
  517. retval = UA_NodeStore_replace(server->nodestore, node, newNode, UA_NULL);
  518. UA_NodeStore_release(node);
  519. if(retval == UA_STATUSCODE_BADINTERNALERROR) {
  520. /* presumably because the node was replaced and an old version was updated at the same time.
  521. just try again */
  522. deleteNode(newNode);
  523. return addOneWayReferenceWithSession(server, session, item);
  524. }
  525. return retval;
  526. #endif
  527. }
  528. UA_StatusCode deleteOneWayReferenceWithSession(UA_Server *server, UA_Session *session, const UA_DeleteReferencesItem *item) {
  529. UA_Node *node = UA_NULL;
  530. UA_StatusCode retval = UA_Server_getNodeCopy(server, item->sourceNodeId, (void *) &node);
  531. if (!node)
  532. return retval;
  533. // Copy all that do not target the targetNode in a new array
  534. UA_ReferenceNode *newRefs = (UA_ReferenceNode*) UA_malloc(sizeof(UA_ReferenceNode) * node->referencesSize);
  535. UA_UInt32 newRefCount = 0;
  536. for(int refn = 0; refn < node->referencesSize; refn++) {
  537. // Completely different target node:
  538. if (!UA_NodeId_equal(&item->targetNodeId.nodeId, &node->references[refn].targetId.nodeId)) {
  539. UA_ReferenceNode_copy(&node->references[refn], &newRefs[newRefCount]);
  540. newRefCount++;
  541. }
  542. else {
  543. // Correct target node, wrong referenceType
  544. if (!UA_NodeId_equal(&item->referenceTypeId, &node->references[refn].referenceTypeId)) {
  545. UA_ReferenceNode_copy(&node->references[refn], &newRefs[newRefCount]);
  546. newRefCount++;
  547. }
  548. else {
  549. // Correct target, correct referenceType, wrong direction
  550. // FIXME: Check semantics of deleteBidirectional: does it mean we delete any forward or inverse refs
  551. // in this node (assumed here) OR does it mean we remove Invers refs from target node??
  552. if (item->deleteBidirectional == UA_FALSE && (item->isForward != node->references[refn].isInverse)) {
  553. UA_ReferenceNode_copy(&node->references[refn], &newRefs[newRefCount]);
  554. newRefCount++;
  555. }
  556. // else... everything matches, don't copy this node into the new reference array.
  557. }
  558. }
  559. }
  560. // Reallocate
  561. UA_ReferenceNode *tmp = UA_realloc(newRefs, sizeof(UA_ReferenceNode) * newRefCount);
  562. if (!tmp) {
  563. if (newRefCount > 0)
  564. UA_free(newRefs); //realloc with zero size is equal to free!
  565. UA_Server_deleteNodeCopy(server, (void *) &node);
  566. return UA_STATUSCODE_BADOUTOFMEMORY;
  567. }
  568. newRefs = tmp;
  569. // Swap old references in node for new ones, then free old array
  570. tmp = node->references;
  571. node->referencesSize = newRefCount;
  572. node->references = newRefs;
  573. if (tmp)
  574. UA_free(tmp);
  575. const UA_Node *inserted;
  576. retval |= UA_NodeStore_replace(server->nodestore, (const UA_Node *) node, node, &inserted);
  577. return retval;
  578. }
  579. /* userland version of addReferenceWithSession */
  580. UA_StatusCode UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId, const UA_NodeId refTypeId,
  581. const UA_ExpandedNodeId targetId) {
  582. UA_AddReferencesItem item;
  583. UA_AddReferencesItem_init(&item);
  584. item.sourceNodeId = sourceId;
  585. item.referenceTypeId = refTypeId;
  586. item.isForward = UA_TRUE;
  587. item.targetNodeId = targetId;
  588. return UA_Server_addReferenceWithSession(server, &adminSession, &item);
  589. }
  590. UA_StatusCode UA_Server_addReferenceWithSession(UA_Server *server, UA_Session *session,
  591. const UA_AddReferencesItem *item) {
  592. if(item->targetServerUri.length > 0)
  593. return UA_STATUSCODE_BADNOTIMPLEMENTED; // currently no expandednodeids are allowed
  594. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  595. #ifdef UA_EXTERNAL_NAMESPACES
  596. UA_ExternalNodeStore *ensFirst = UA_NULL;
  597. UA_ExternalNodeStore *ensSecond = UA_NULL;
  598. for(size_t j = 0;j<server->externalNamespacesSize && (!ensFirst || !ensSecond);j++) {
  599. if(item->sourceNodeId.namespaceIndex == server->externalNamespaces[j].index)
  600. ensFirst = &server->externalNamespaces[j].externalNodeStore;
  601. if(item->targetNodeId.nodeId.namespaceIndex == server->externalNamespaces[j].index)
  602. ensSecond = &server->externalNamespaces[j].externalNodeStore;
  603. }
  604. if(ensFirst) {
  605. // todo: use external nodestore
  606. } else
  607. #endif
  608. retval = addOneWayReferenceWithSession(server, session, item);
  609. if(retval)
  610. return retval;
  611. UA_AddReferencesItem secondItem;
  612. secondItem = *item;
  613. secondItem.targetNodeId.nodeId = item->sourceNodeId;
  614. secondItem.sourceNodeId = item->targetNodeId.nodeId;
  615. secondItem.isForward = !item->isForward;
  616. #ifdef UA_EXTERNAL_NAMESPACES
  617. if(ensSecond) {
  618. // todo: use external nodestore
  619. } else
  620. #endif
  621. retval = addOneWayReferenceWithSession (server, session, &secondItem);
  622. // todo: remove reference if the second direction failed
  623. return retval;
  624. }
  625. /* userland version of addNodeWithSession */
  626. UA_AddNodesResult
  627. UA_Server_addNode(UA_Server *server, UA_Node *node, const UA_ExpandedNodeId parentNodeId,
  628. const UA_NodeId referenceTypeId) {
  629. return UA_Server_addNodeWithSession(server, &adminSession, node, parentNodeId, referenceTypeId);
  630. }
  631. UA_AddNodesResult
  632. UA_Server_addNodeWithSession(UA_Server *server, UA_Session *session, UA_Node *node,
  633. const UA_ExpandedNodeId parentNodeId, const UA_NodeId referenceTypeId) {
  634. UA_AddNodesResult result;
  635. UA_AddNodesResult_init(&result);
  636. if(node->nodeId.namespaceIndex >= server->namespacesSize) {
  637. result.statusCode = UA_STATUSCODE_BADNODEIDINVALID;
  638. return result;
  639. }
  640. const UA_Node *parent = UA_NodeStore_get(server->nodestore, &parentNodeId.nodeId);
  641. if(!parent) {
  642. result.statusCode = UA_STATUSCODE_BADPARENTNODEIDINVALID;
  643. return result;
  644. }
  645. const UA_ReferenceTypeNode *referenceType =
  646. (const UA_ReferenceTypeNode *)UA_NodeStore_get(server->nodestore, &referenceTypeId);
  647. if(!referenceType) {
  648. result.statusCode = UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  649. goto ret;
  650. }
  651. if(referenceType->nodeClass != UA_NODECLASS_REFERENCETYPE) {
  652. result.statusCode = UA_STATUSCODE_BADREFERENCETYPEIDINVALID;
  653. goto ret2;
  654. }
  655. if(referenceType->isAbstract == UA_TRUE) {
  656. result.statusCode = UA_STATUSCODE_BADREFERENCENOTALLOWED;
  657. goto ret2;
  658. }
  659. // todo: test if the referencetype is hierarchical
  660. //FIXME: a bit dirty workaround of preserving namespace
  661. //namespace index is assumed to be valid
  662. const UA_Node *managed = UA_NULL;
  663. UA_NodeId tempNodeid;
  664. UA_NodeId_init(&tempNodeid);
  665. UA_NodeId_copy(&node->nodeId, &tempNodeid);
  666. tempNodeid.namespaceIndex = 0;
  667. if(UA_NodeId_isNull(&tempNodeid)) {
  668. if(UA_NodeStore_insert(server->nodestore, node, &managed) != UA_STATUSCODE_GOOD) {
  669. result.statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  670. goto ret2;
  671. }
  672. result.addedNodeId = managed->nodeId; // cannot fail as unique nodeids are numeric
  673. } else {
  674. if(UA_NodeId_copy(&node->nodeId, &result.addedNodeId) != UA_STATUSCODE_GOOD) {
  675. result.statusCode = UA_STATUSCODE_BADOUTOFMEMORY;
  676. goto ret2;
  677. }
  678. if(UA_NodeStore_insert(server->nodestore, node, &managed) != UA_STATUSCODE_GOOD) {
  679. result.statusCode = UA_STATUSCODE_BADNODEIDEXISTS; // todo: differentiate out of memory
  680. UA_NodeId_deleteMembers(&result.addedNodeId);
  681. goto ret2;
  682. }
  683. }
  684. // reference back to the parent
  685. UA_AddReferencesItem item;
  686. UA_AddReferencesItem_init(&item);
  687. item.sourceNodeId = managed->nodeId;
  688. item.referenceTypeId = referenceType->nodeId;
  689. item.isForward = UA_FALSE;
  690. item.targetNodeId.nodeId = parent->nodeId;
  691. UA_Server_addReferenceWithSession(server, session, &item);
  692. // todo: error handling. remove new node from nodestore
  693. UA_NodeStore_release(managed);
  694. ret2:
  695. UA_NodeId_deleteMembers(&tempNodeid);
  696. UA_NodeStore_release((const UA_Node*)referenceType);
  697. ret:
  698. UA_NodeStore_release(parent);
  699. return result;
  700. }
  701. #ifdef ENABLE_METHODCALLS
  702. UA_StatusCode
  703. UA_Server_addMethodNode(UA_Server* server, const UA_NodeId nodeId, const UA_QualifiedName browseName,
  704. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  705. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  706. UA_MethodCallback method, void *handle, UA_Int32 inputArgumentsSize, const UA_Argument* inputArguments,
  707. UA_Int32 outputArgumentsSize, const UA_Argument* outputArguments,
  708. UA_NodeId* createdNodeId) {
  709. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  710. UA_MethodNode *newMethod = UA_MethodNode_new();
  711. UA_NodeId_copy(&nodeId, &newMethod->nodeId);
  712. UA_QualifiedName_copy(&browseName, &newMethod->browseName);
  713. UA_LocalizedText_copy(&displayName, &newMethod->displayName);
  714. UA_LocalizedText_copy(&description, &newMethod->description);
  715. newMethod->writeMask = writeMask;
  716. newMethod->userWriteMask = userWriteMask;
  717. newMethod->attachedMethod = method;
  718. newMethod->methodHandle = handle;
  719. newMethod->executable = UA_TRUE;
  720. newMethod->userExecutable = UA_TRUE;
  721. UA_ExpandedNodeId parentExpandedNodeId;
  722. UA_ExpandedNodeId_init(&parentExpandedNodeId);
  723. UA_NodeId_copy(&parentNodeId, &parentExpandedNodeId.nodeId);
  724. UA_AddNodesResult addRes = UA_Server_addNode(server, (UA_Node*)newMethod, parentExpandedNodeId, referenceTypeId);
  725. retval |= addRes.statusCode;
  726. if(retval!= UA_STATUSCODE_GOOD) {
  727. UA_MethodNode_delete(newMethod);
  728. return retval;
  729. }
  730. UA_ExpandedNodeId methodExpandedNodeId;
  731. UA_ExpandedNodeId_init(&methodExpandedNodeId);
  732. UA_NodeId_copy(&addRes.addedNodeId, &methodExpandedNodeId.nodeId);
  733. if (createdNodeId != UA_NULL)
  734. UA_NodeId_copy(&addRes.addedNodeId, createdNodeId);
  735. UA_AddNodesResult_deleteMembers(&addRes);
  736. /* Only proceed with creating in/outputArguments if the method and both arguments are not
  737. * UA_NULL; otherwise this is a pretty strong indicator that this node was generated,
  738. * in which case these arguments will be created later and individually.
  739. */
  740. if (method == UA_NULL && inputArguments == UA_NULL && outputArguments == UA_NULL && inputArgumentsSize == 0 && outputArgumentsSize == 0)
  741. return retval;
  742. /* create InputArguments */
  743. UA_NodeId argId = UA_NODEID_NUMERIC(nodeId.namespaceIndex, 0);
  744. UA_VariableNode *inputArgumentsVariableNode = UA_VariableNode_new();
  745. retval |= UA_NodeId_copy(&argId, &inputArgumentsVariableNode->nodeId);
  746. inputArgumentsVariableNode->browseName = UA_QUALIFIEDNAME_ALLOC(0,"InputArguments");
  747. inputArgumentsVariableNode->displayName = UA_LOCALIZEDTEXT_ALLOC("en_US", "InputArguments");
  748. inputArgumentsVariableNode->description = UA_LOCALIZEDTEXT_ALLOC("en_US", "InputArguments");
  749. inputArgumentsVariableNode->valueRank = 1;
  750. UA_Variant_setArrayCopy(&inputArgumentsVariableNode->value.variant.value, inputArguments,
  751. inputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  752. addRes = UA_Server_addNode(server, (UA_Node*)inputArgumentsVariableNode, methodExpandedNodeId,
  753. UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  754. if(addRes.statusCode != UA_STATUSCODE_GOOD) {
  755. UA_ExpandedNodeId_deleteMembers(&methodExpandedNodeId);
  756. if(createdNodeId != UA_NULL)
  757. UA_NodeId_deleteMembers(createdNodeId);
  758. // TODO Remove node
  759. return addRes.statusCode;
  760. }
  761. UA_AddNodesResult_deleteMembers(&addRes);
  762. /* create OutputArguments */
  763. argId = UA_NODEID_NUMERIC(nodeId.namespaceIndex, 0);
  764. UA_VariableNode *outputArgumentsVariableNode = UA_VariableNode_new();
  765. retval |= UA_NodeId_copy(&argId, &outputArgumentsVariableNode->nodeId);
  766. outputArgumentsVariableNode->browseName = UA_QUALIFIEDNAME_ALLOC(0,"OutputArguments");
  767. outputArgumentsVariableNode->displayName = UA_LOCALIZEDTEXT_ALLOC("en_US", "OutputArguments");
  768. outputArgumentsVariableNode->description = UA_LOCALIZEDTEXT_ALLOC("en_US", "OutputArguments");
  769. outputArgumentsVariableNode->valueRank = 1;
  770. UA_Variant_setArrayCopy(&outputArgumentsVariableNode->value.variant.value, outputArguments,
  771. outputArgumentsSize, &UA_TYPES[UA_TYPES_ARGUMENT]);
  772. addRes = UA_Server_addNode(server, (UA_Node*)outputArgumentsVariableNode, methodExpandedNodeId,
  773. UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  774. UA_ExpandedNodeId_deleteMembers(&methodExpandedNodeId);
  775. if(addRes.statusCode != UA_STATUSCODE_GOOD)
  776. {
  777. if(createdNodeId != UA_NULL)
  778. UA_NodeId_deleteMembers(createdNodeId);
  779. // TODO Remove node
  780. retval = addRes.statusCode;
  781. }
  782. UA_AddNodesResult_deleteMembers(&addRes);
  783. return retval;
  784. }
  785. #endif
  786. #define SETATTRIBUTE_ASSERTNODECLASS(CLASS) { \
  787. if ((anyTypeNode.node->nodeClass & ( CLASS )) == 0) { \
  788. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node); \
  789. return UA_STATUSCODE_BADNODECLASSINVALID; \
  790. } \
  791. }
  792. #define SETATTRIBUTE_ASSERTTYPECORRECT(TYPE) { \
  793. UA_NodeId expectedType = UA_NODEID_NUMERIC(0, UA_NS0ID_##TYPE); \
  794. if (!UA_NodeId_equal(&dataType->typeId, &expectedType)) { \
  795. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node); \
  796. return UA_STATUSCODE_BADTYPEMISMATCH; \
  797. } \
  798. }\
  799. UA_StatusCode UA_Server_setAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void *value) {
  800. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  801. if (!value)
  802. return UA_STATUSCODE_BADNOTHINGTODO;
  803. union {
  804. UA_Node *node;
  805. UA_ObjectNode *oObj;
  806. UA_ObjectTypeNode *otObj;
  807. UA_VariableNode *vObj;
  808. UA_VariableTypeNode *vtObj;
  809. UA_ReferenceTypeNode *rtObj;
  810. UA_MethodNode *mObj;
  811. UA_DataTypeNode *dtObj;
  812. UA_ViewNode *vwObj;
  813. } anyTypeNode;
  814. retval = UA_Server_getNodeCopy(server, nodeId, (void **) &anyTypeNode.node);
  815. if (retval)
  816. return retval;
  817. UA_UInt32 *nInt;
  818. UA_Boolean *nBool;
  819. UA_Byte *nByte;
  820. UA_Variant *nVariant;
  821. UA_Double *nDouble;
  822. switch(attributeId) {
  823. case UA_ATTRIBUTEID_NODEID:
  824. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  825. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  826. break;
  827. case UA_ATTRIBUTEID_NODECLASS:
  828. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  829. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  830. break;
  831. case UA_ATTRIBUTEID_BROWSENAME:
  832. UA_QualifiedName_deleteMembers(&anyTypeNode.node->browseName);
  833. UA_QualifiedName_copy((UA_QualifiedName *) value, &anyTypeNode.node->browseName);
  834. break;
  835. case UA_ATTRIBUTEID_DISPLAYNAME:
  836. UA_LocalizedText_deleteMembers(&anyTypeNode.node->displayName);
  837. UA_LocalizedText_copy((UA_LocalizedText *) value, &anyTypeNode.node->displayName);
  838. break;
  839. case UA_ATTRIBUTEID_DESCRIPTION:
  840. UA_LocalizedText_deleteMembers(&anyTypeNode.node->description);
  841. UA_LocalizedText_copy((UA_LocalizedText *) value, &anyTypeNode.node->description);
  842. break;
  843. case UA_ATTRIBUTEID_WRITEMASK:
  844. nInt = (UA_UInt32*) value;
  845. anyTypeNode.node->writeMask = *nInt;
  846. break;
  847. case UA_ATTRIBUTEID_USERWRITEMASK:
  848. nInt = (UA_UInt32*) value;
  849. anyTypeNode.node->userWriteMask = *nInt;
  850. break;
  851. case UA_ATTRIBUTEID_ISABSTRACT:
  852. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_OBJECTTYPE | UA_NODECLASS_REFERENCETYPE | UA_NODECLASS_VARIABLETYPE | UA_NODECLASS_DATATYPE)
  853. nBool = (UA_Boolean *) value;
  854. switch(anyTypeNode.node->nodeClass) {
  855. case UA_NODECLASS_OBJECTTYPE:
  856. anyTypeNode.otObj->isAbstract = *nBool;
  857. break;
  858. case UA_NODECLASS_REFERENCETYPE:
  859. anyTypeNode.rtObj->isAbstract = *nBool;
  860. break;
  861. case UA_NODECLASS_VARIABLETYPE:
  862. anyTypeNode.vtObj->isAbstract = *nBool;
  863. break;
  864. case UA_NODECLASS_DATATYPE:
  865. anyTypeNode.dtObj->isAbstract = *nBool;
  866. break;
  867. default:
  868. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  869. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  870. break;
  871. }
  872. break;
  873. case UA_ATTRIBUTEID_SYMMETRIC:
  874. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  875. nBool = (UA_Boolean *) value;
  876. anyTypeNode.rtObj->symmetric = *nBool;
  877. break;
  878. case UA_ATTRIBUTEID_INVERSENAME:
  879. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  880. UA_LocalizedText_deleteMembers(&anyTypeNode.rtObj->inverseName);
  881. UA_LocalizedText_copy((UA_LocalizedText *) value, &anyTypeNode.rtObj->inverseName);
  882. break;
  883. case UA_ATTRIBUTEID_CONTAINSNOLOOPS:
  884. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW)
  885. nBool = (UA_Boolean *) value;
  886. anyTypeNode.vwObj->containsNoLoops = *nBool;
  887. break;
  888. case UA_ATTRIBUTEID_EVENTNOTIFIER:
  889. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW | UA_NODECLASS_OBJECT)
  890. nByte = (UA_Byte *) value;
  891. switch(anyTypeNode.node->nodeClass) {
  892. case UA_NODECLASS_VIEW:
  893. anyTypeNode.vwObj->eventNotifier = *nByte;
  894. break;
  895. case UA_NODECLASS_OBJECT:
  896. anyTypeNode.oObj->eventNotifier = *nByte;
  897. break;
  898. default:
  899. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  900. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  901. break;
  902. }
  903. break;
  904. case UA_ATTRIBUTEID_VALUE:
  905. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE)
  906. if(anyTypeNode.vObj->valueSource == UA_VALUESOURCE_DATASOURCE) {
  907. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  908. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  909. }
  910. nVariant = value;
  911. UA_Variant_deleteMembers(&anyTypeNode.vObj->value.variant.value);
  912. UA_Variant_copy(nVariant, &anyTypeNode.vObj->value.variant.value);
  913. break;
  914. case UA_ATTRIBUTEID_DATATYPE:
  915. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  916. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  917. break;
  918. case UA_ATTRIBUTEID_VALUERANK:
  919. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  920. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  921. break;
  922. case UA_ATTRIBUTEID_ARRAYDIMENSIONS:
  923. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  924. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  925. break;
  926. case UA_ATTRIBUTEID_ACCESSLEVEL:
  927. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  928. nByte = (UA_Byte*) value;
  929. anyTypeNode.vObj->accessLevel = *nByte;
  930. break;
  931. case UA_ATTRIBUTEID_USERACCESSLEVEL:
  932. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  933. nByte = (UA_Byte*) value;
  934. anyTypeNode.vObj->userAccessLevel = *nByte;
  935. break;
  936. case UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL:
  937. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  938. nDouble = (UA_Double *) value;
  939. anyTypeNode.vObj->minimumSamplingInterval = *nDouble;
  940. break;
  941. case UA_ATTRIBUTEID_HISTORIZING:
  942. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  943. nBool = (UA_Boolean *) value;
  944. anyTypeNode.vObj->historizing= *nBool;
  945. break;
  946. case UA_ATTRIBUTEID_EXECUTABLE:
  947. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  948. nBool = (UA_Boolean *) value;
  949. anyTypeNode.mObj->executable= *nBool;
  950. break;
  951. case UA_ATTRIBUTEID_USEREXECUTABLE:
  952. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  953. nBool = (UA_Boolean *) value;
  954. anyTypeNode.mObj->userExecutable= *nBool;
  955. break;
  956. default:
  957. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  958. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  959. break;
  960. }
  961. const UA_Node *oldNode = UA_NodeStore_get(server->nodestore, &nodeId);
  962. const UA_Node **inserted = UA_NULL;
  963. retval |= UA_NodeStore_replace(server->nodestore, oldNode, anyTypeNode.node, inserted);
  964. UA_NodeStore_release(oldNode);
  965. // Node Copy deleted by nodeEntryFromNode() during nodestore_replace()!
  966. //UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  967. return retval;
  968. }
  969. #ifdef ENABLE_METHODCALLS
  970. /* Allow userspace to attach a method to one defined via XML or to switch an attached method for another */
  971. UA_StatusCode
  972. UA_Server_setAttribute_method(UA_Server *server, UA_NodeId methodNodeId, UA_MethodCallback method, void *handle) {
  973. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  974. const UA_Node *attachToMethod = UA_NULL;
  975. UA_MethodNode *replacementMethod = UA_NULL;
  976. if (!method)
  977. return UA_STATUSCODE_BADMETHODINVALID;
  978. if (!server)
  979. return UA_STATUSCODE_BADSERVERINDEXINVALID;
  980. attachToMethod = UA_NodeStore_get(server->nodestore, &methodNodeId);
  981. if (!attachToMethod)
  982. return UA_STATUSCODE_BADNODEIDINVALID;
  983. if (attachToMethod->nodeClass != UA_NODECLASS_METHOD){
  984. UA_NodeStore_release(attachToMethod);
  985. return UA_STATUSCODE_BADNODEIDINVALID;
  986. }
  987. replacementMethod = UA_MethodNode_new();
  988. UA_MethodNode_copy((const UA_MethodNode *) attachToMethod, replacementMethod);
  989. replacementMethod->attachedMethod = method;
  990. replacementMethod->methodHandle = handle;
  991. UA_NodeStore_replace(server->nodestore, attachToMethod, (UA_Node *) replacementMethod, UA_NULL);
  992. UA_NodeStore_release(attachToMethod);
  993. return retval;
  994. }
  995. #endif
  996. UA_StatusCode
  997. UA_Server_setAttribute_DataSource(UA_Server *server, UA_NodeId nodeId, UA_DataSource value) {
  998. union {
  999. UA_Node *anyNode;
  1000. UA_VariableNode *varNode;
  1001. UA_VariableTypeNode *varTNode;
  1002. } node;
  1003. UA_StatusCode retval;
  1004. retval = UA_Server_getNodeCopy(server, nodeId, (void **) &node.anyNode);
  1005. if (retval != UA_STATUSCODE_GOOD || node.anyNode == UA_NULL)
  1006. return retval;
  1007. if (node.anyNode->nodeClass != UA_NODECLASS_VARIABLE && node.anyNode->nodeClass != UA_NODECLASS_VARIABLETYPE) {
  1008. UA_Server_deleteNodeCopy(server, (void **) &node);
  1009. return UA_STATUSCODE_BADNODECLASSINVALID;
  1010. }
  1011. if (node.anyNode->nodeClass == UA_NODECLASS_VARIABLE) {
  1012. if (node.varNode->valueSource == UA_VALUESOURCE_VARIANT) {
  1013. UA_Variant_deleteMembers(&node.varNode->value.variant.value);
  1014. }
  1015. node.varNode->valueSource = UA_VALUESOURCE_DATASOURCE;
  1016. node.varNode->value.dataSource = value;
  1017. }
  1018. //UA_NODECLASS_VARIABLE_TYPE
  1019. else {
  1020. if (node.varTNode->valueSource == UA_VALUESOURCE_VARIANT) {
  1021. UA_Variant_deleteMembers(&node.varTNode->value.variant.value);
  1022. }
  1023. node.varTNode->valueSource = UA_VALUESOURCE_DATASOURCE;
  1024. node.varTNode->value.dataSource = value;
  1025. }
  1026. const UA_Node **inserted = UA_NULL;
  1027. const UA_Node *oldNode = UA_NodeStore_get(server->nodestore, &node.anyNode->nodeId);
  1028. retval |= UA_NodeStore_replace(server->nodestore, oldNode, node.anyNode, inserted);
  1029. UA_NodeStore_release(oldNode);
  1030. return retval;
  1031. }
  1032. UA_StatusCode
  1033. UA_Server_setAttribute_valueCallback(UA_Server *server, UA_NodeId nodeId, UA_ValueCallback callback) {
  1034. union {
  1035. UA_Node *anyNode;
  1036. UA_VariableNode *varNode;
  1037. UA_VariableTypeNode *varTNode;
  1038. } node;
  1039. UA_StatusCode retval;
  1040. retval = UA_Server_getNodeCopy(server, nodeId, (void **) &node.anyNode);
  1041. if (retval != UA_STATUSCODE_GOOD || node.anyNode == UA_NULL)
  1042. return retval;
  1043. if (node.anyNode->nodeClass != UA_NODECLASS_VARIABLE && node.anyNode->nodeClass != UA_NODECLASS_VARIABLETYPE) {
  1044. UA_Server_deleteNodeCopy(server, (void **) &node);
  1045. return UA_STATUSCODE_BADNODECLASSINVALID;
  1046. }
  1047. if(node.varNode->valueSource == UA_VALUESOURCE_DATASOURCE){
  1048. return UA_STATUSCODE_BADNODECLASSINVALID;
  1049. }
  1050. if (node.anyNode->nodeClass == UA_NODECLASS_VARIABLE) {
  1051. node.varNode->value.variant.callback = callback;
  1052. }
  1053. //UA_NODECLASS_VARIABLE_TYPE
  1054. else {
  1055. node.varTNode->value.variant.callback = callback;
  1056. }
  1057. const UA_Node **inserted = UA_NULL;
  1058. const UA_Node *oldNode = UA_NodeStore_get(server->nodestore, &node.anyNode->nodeId);
  1059. retval |= UA_NodeStore_replace(server->nodestore, oldNode, node.anyNode, inserted);
  1060. UA_NodeStore_release(oldNode);
  1061. return retval;
  1062. }
  1063. #define SERVER_GETATTRIBUTE_COPYTYPEVALUE(TYPE, SRC) \
  1064. *value = (void *) UA_##TYPE##_new(); \
  1065. UA_##TYPE##_copy( SRC, (UA_##TYPE *) *value ); \
  1066. UA_StatusCode UA_Server_getAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void **value) {
  1067. union {
  1068. UA_Node *node;
  1069. UA_ObjectNode *oObj;
  1070. UA_ObjectTypeNode *otObj;
  1071. UA_VariableNode *vObj;
  1072. UA_VariableTypeNode *vtObj;
  1073. UA_ReferenceTypeNode *rtObj;
  1074. UA_MethodNode *mObj;
  1075. UA_DataTypeNode *dtObj;
  1076. UA_ViewNode *vwObj;
  1077. } anyTypeNode;
  1078. UA_StatusCode retval = UA_Server_getNodeCopy(server, nodeId, (void **) &anyTypeNode.node);
  1079. if (retval != UA_STATUSCODE_GOOD)
  1080. return retval;
  1081. switch(attributeId) {
  1082. case UA_ATTRIBUTEID_NODEID:
  1083. SERVER_GETATTRIBUTE_COPYTYPEVALUE(NodeId, &anyTypeNode.node->nodeId);
  1084. break;
  1085. case UA_ATTRIBUTEID_NODECLASS:
  1086. SERVER_GETATTRIBUTE_COPYTYPEVALUE(NodeClass, &anyTypeNode.node->nodeClass);
  1087. break;
  1088. case UA_ATTRIBUTEID_BROWSENAME:
  1089. SERVER_GETATTRIBUTE_COPYTYPEVALUE(QualifiedName, &anyTypeNode.node->browseName);
  1090. break;
  1091. case UA_ATTRIBUTEID_DISPLAYNAME:
  1092. SERVER_GETATTRIBUTE_COPYTYPEVALUE(LocalizedText, &anyTypeNode.node->displayName);
  1093. break;
  1094. case UA_ATTRIBUTEID_DESCRIPTION:
  1095. SERVER_GETATTRIBUTE_COPYTYPEVALUE(LocalizedText, &anyTypeNode.node->description);
  1096. break;
  1097. case UA_ATTRIBUTEID_WRITEMASK:
  1098. SERVER_GETATTRIBUTE_COPYTYPEVALUE(UInt32, &anyTypeNode.node->writeMask);
  1099. break;
  1100. case UA_ATTRIBUTEID_USERWRITEMASK:
  1101. SERVER_GETATTRIBUTE_COPYTYPEVALUE(UInt32, &anyTypeNode.node->userWriteMask);
  1102. break;
  1103. case UA_ATTRIBUTEID_ISABSTRACT:
  1104. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_OBJECTTYPE | UA_NODECLASS_REFERENCETYPE | UA_NODECLASS_VARIABLETYPE | UA_NODECLASS_DATATYPE)
  1105. switch(anyTypeNode.node->nodeClass) {
  1106. case UA_NODECLASS_OBJECTTYPE:
  1107. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.otObj->isAbstract);
  1108. break;
  1109. case UA_NODECLASS_REFERENCETYPE:
  1110. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.rtObj->isAbstract);
  1111. break;
  1112. case UA_NODECLASS_VARIABLETYPE:
  1113. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.vtObj->isAbstract);
  1114. break;
  1115. case UA_NODECLASS_DATATYPE:
  1116. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.dtObj->isAbstract);
  1117. break;
  1118. default:
  1119. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1120. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1121. break;
  1122. }
  1123. break;
  1124. case UA_ATTRIBUTEID_SYMMETRIC:
  1125. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  1126. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.rtObj->symmetric);
  1127. break;
  1128. case UA_ATTRIBUTEID_INVERSENAME:
  1129. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_REFERENCETYPE)
  1130. SERVER_GETATTRIBUTE_COPYTYPEVALUE(LocalizedText, &anyTypeNode.rtObj->inverseName);
  1131. break;
  1132. case UA_ATTRIBUTEID_CONTAINSNOLOOPS:
  1133. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW)
  1134. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.vwObj->containsNoLoops);
  1135. break;
  1136. case UA_ATTRIBUTEID_EVENTNOTIFIER:
  1137. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VIEW | UA_NODECLASS_OBJECT)
  1138. switch(anyTypeNode.node->nodeClass) {
  1139. case UA_NODECLASS_VIEW:
  1140. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.vwObj->eventNotifier);
  1141. break;
  1142. case UA_NODECLASS_OBJECT:
  1143. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.oObj->eventNotifier);
  1144. break;
  1145. default:
  1146. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1147. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1148. break;
  1149. }
  1150. break;
  1151. case UA_ATTRIBUTEID_VALUE:
  1152. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE)
  1153. switch(anyTypeNode.node->nodeClass) {
  1154. case UA_NODECLASS_VARIABLE:
  1155. *value = UA_Variant_new();
  1156. if(anyTypeNode.vObj->valueSource == UA_VALUESOURCE_VARIANT) {
  1157. retval |= UA_Variant_copy(&anyTypeNode.vObj->value.variant.value, *value);
  1158. if(anyTypeNode.vObj->value.variant.callback.onRead)
  1159. anyTypeNode.vObj->value.variant.callback.onRead(anyTypeNode.vObj->value.variant.callback.handle, nodeId, *value, UA_NULL);
  1160. } else {
  1161. UA_DataValue ds;
  1162. UA_DataValue_init(&ds);
  1163. retval |= anyTypeNode.vObj->value.dataSource.read(anyTypeNode.vObj->value.dataSource.handle, nodeId, UA_FALSE, UA_NULL, &ds);
  1164. UA_Variant_copy(&ds.value, *value);
  1165. }
  1166. break;
  1167. case UA_NODECLASS_VARIABLETYPE:
  1168. // Note: Precicely the same as variableNode above!
  1169. *value = UA_Variant_new();
  1170. if(anyTypeNode.vtObj->valueSource == UA_VALUESOURCE_VARIANT) {
  1171. retval |= UA_Variant_copy(&anyTypeNode.vtObj->value.variant.value, *value);
  1172. if(anyTypeNode.vtObj->value.variant.callback.onRead)
  1173. anyTypeNode.vtObj->value.variant.callback.onRead(anyTypeNode.vtObj->value.variant.callback.handle, nodeId, *value, UA_NULL);
  1174. } else {
  1175. UA_DataValue ds;
  1176. UA_DataValue_init(&ds);
  1177. retval |= anyTypeNode.vtObj->value.dataSource.read(anyTypeNode.vtObj->value.dataSource.handle, nodeId, UA_FALSE, UA_NULL, &ds);
  1178. UA_Variant_copy(&ds.value, *value);
  1179. }
  1180. break;
  1181. default:
  1182. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1183. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1184. }
  1185. break;
  1186. case UA_ATTRIBUTEID_DATATYPE:
  1187. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1188. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1189. break;
  1190. case UA_ATTRIBUTEID_VALUERANK:
  1191. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1192. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1193. break;
  1194. case UA_ATTRIBUTEID_ARRAYDIMENSIONS:
  1195. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1196. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1197. break;
  1198. case UA_ATTRIBUTEID_ACCESSLEVEL:
  1199. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1200. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.vObj->accessLevel);
  1201. break;
  1202. case UA_ATTRIBUTEID_USERACCESSLEVEL:
  1203. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1204. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Byte, &anyTypeNode.vObj->userAccessLevel);
  1205. break;
  1206. case UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL:
  1207. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1208. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Double, &anyTypeNode.vObj->minimumSamplingInterval);
  1209. break;
  1210. case UA_ATTRIBUTEID_HISTORIZING:
  1211. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_VARIABLE)
  1212. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.vObj->historizing);
  1213. break;
  1214. case UA_ATTRIBUTEID_EXECUTABLE:
  1215. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  1216. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.mObj->executable);
  1217. break;
  1218. case UA_ATTRIBUTEID_USEREXECUTABLE:
  1219. SETATTRIBUTE_ASSERTNODECLASS(UA_NODECLASS_METHOD)
  1220. SERVER_GETATTRIBUTE_COPYTYPEVALUE(Boolean, &anyTypeNode.mObj->userExecutable);
  1221. break;
  1222. default:
  1223. UA_Server_deleteNodeCopy(server, (void **) &anyTypeNode.node);
  1224. return UA_STATUSCODE_BADATTRIBUTEIDINVALID;
  1225. break;
  1226. }
  1227. return retval;
  1228. }
  1229. #ifdef ENABLE_METHODCALLS
  1230. UA_StatusCode UA_Server_getAttribute_method(UA_Server *server, UA_NodeId methodNodeId, UA_MethodCallback *method) {
  1231. union {
  1232. UA_Node *anyNode;
  1233. UA_MethodNode *mNode;
  1234. } node;
  1235. UA_StatusCode retval;
  1236. *method= UA_NULL;
  1237. retval = UA_Server_getNodeCopy(server, methodNodeId, (void **) &node.anyNode);
  1238. if (retval != UA_STATUSCODE_GOOD || node.anyNode == UA_NULL)
  1239. return retval;
  1240. if (node.anyNode->nodeClass != UA_NODECLASS_METHOD) {
  1241. UA_Server_deleteNodeCopy(server, (void **) &node);
  1242. return UA_STATUSCODE_BADNODECLASSINVALID;
  1243. }
  1244. if (node.mNode->attachedMethod != UA_NULL) {
  1245. method = &node.mNode->attachedMethod;
  1246. }
  1247. retval |= UA_Server_deleteNodeCopy(server, (void **) &node);
  1248. return retval;
  1249. }
  1250. #endif
  1251. UA_StatusCode
  1252. UA_Server_getAttribute_DataSource(UA_Server *server, UA_NodeId nodeId, UA_DataSource **value) {
  1253. union {
  1254. UA_Node *anyNode;
  1255. UA_VariableNode *varNode;
  1256. UA_VariableTypeNode *varTNode;
  1257. } node;
  1258. UA_StatusCode retval;
  1259. *value = UA_NULL;
  1260. retval = UA_Server_getNodeCopy(server, nodeId, (void **) &node.anyNode);
  1261. if (retval != UA_STATUSCODE_GOOD || node.anyNode == UA_NULL)
  1262. return retval;
  1263. if (node.anyNode->nodeClass != UA_NODECLASS_VARIABLE && node.anyNode->nodeClass != UA_NODECLASS_VARIABLETYPE) {
  1264. UA_Server_deleteNodeCopy(server, (void **) &node);
  1265. return UA_STATUSCODE_BADNODECLASSINVALID;
  1266. }
  1267. if (node.anyNode->nodeClass == UA_NODECLASS_VARIABLE) {
  1268. if (node.varNode->valueSource == UA_VALUESOURCE_VARIANT) {
  1269. retval |= UA_Server_deleteNodeCopy(server, (void **) &node);
  1270. return UA_STATUSCODE_BADINVALIDARGUMENT;
  1271. }
  1272. *value = (UA_DataSource *) UA_malloc(sizeof(UA_DataSource));
  1273. (*(value))->handle = node.varNode->value.dataSource.handle;
  1274. (*(value))->read = node.varNode->value.dataSource.read;
  1275. (*(value))->write = node.varNode->value.dataSource.write;
  1276. }
  1277. else {
  1278. if (node.varTNode->valueSource == UA_VALUESOURCE_VARIANT) {
  1279. retval |= UA_Server_deleteNodeCopy(server, (void **) &node);
  1280. return UA_STATUSCODE_BADINVALIDARGUMENT;
  1281. }
  1282. *value = (UA_DataSource *) UA_malloc(sizeof(UA_DataSource));
  1283. (*(value))->handle = node.varNode->value.dataSource.handle;
  1284. (*(value))->read = node.varNode->value.dataSource.read;
  1285. (*(value))->write = node.varNode->value.dataSource.write;
  1286. }
  1287. retval |= UA_Server_deleteNodeCopy(server, (void **) &node);
  1288. return retval;
  1289. }
  1290. UA_StatusCode UA_Server_getAttributeValue(UA_Server *server, UA_NodeId nodeId, UA_AttributeId attributeId, void **value);
  1291. #define arrayOfNodeIds_addNodeId(ARRAYNAME, NODEID) { \
  1292. ARRAYNAME.size++; \
  1293. ARRAYNAME.ids = UA_realloc(ARRAYNAME.ids, sizeof(UA_NodeId) * ARRAYNAME.size); \
  1294. UA_NodeId_copy(&NODEID, &ARRAYNAME.ids[ARRAYNAME.size-1]); \
  1295. }
  1296. #define arrayOfNodeIds_deleteMembers(ARRAYNAME) { \
  1297. if (ARRAYNAME.size > 0) \
  1298. UA_free(ARRAYNAME.ids); \
  1299. ARRAYNAME.size = 0; \
  1300. }
  1301. #define arrayOfNodeIds_idInArray(ARRAYNAME, NODEID, BOOLEAN, BOOLINIT) { \
  1302. BOOLEAN = BOOLINIT;\
  1303. for (int z=0; z<ARRAYNAME.size; z++) {\
  1304. if (UA_NodeId_equal(&ARRAYNAME.ids[z], &NODEID)) {\
  1305. BOOLEAN = !BOOLINIT; \
  1306. break; \
  1307. } \
  1308. } \
  1309. } \
  1310. static void UA_Server_addInstanceOf_inheritParentAttributes(UA_Server *server, arrayOfNodeIds *subtypeRefs, arrayOfNodeIds *componentRefs,
  1311. UA_NodeId objectRoot, UA_InstantiationCallback callback, UA_ObjectTypeNode *typeDefNode,
  1312. arrayOfNodeIds *instantiatedTypes, void *handle)
  1313. {
  1314. UA_Boolean refTypeValid;
  1315. UA_ReferenceNode ref;
  1316. arrayOfNodeIds visitedNodes = (arrayOfNodeIds) {.size=0, .ids = UA_NULL};
  1317. for(int i=0; i<typeDefNode->referencesSize; i++) {
  1318. ref = typeDefNode->references[i];
  1319. if (ref.isInverse == UA_FALSE)
  1320. continue;
  1321. refTypeValid = UA_FALSE;
  1322. arrayOfNodeIds_idInArray((*subtypeRefs), ref.referenceTypeId, refTypeValid, UA_FALSE);
  1323. if (!refTypeValid)
  1324. continue;
  1325. // Check if already tried to inherit from this node (there is such a thing as duplicate refs)
  1326. arrayOfNodeIds_idInArray(visitedNodes, ref.targetId.nodeId, refTypeValid, UA_TRUE);
  1327. if (!refTypeValid)
  1328. continue;
  1329. // Go ahead and inherit this nodes variables and methods (not objects!)
  1330. arrayOfNodeIds_addNodeId(visitedNodes, ref.targetId.nodeId);
  1331. UA_Server_appendInstanceOfSupertype(server, ref.targetId.nodeId, objectRoot, subtypeRefs, componentRefs, callback, instantiatedTypes, handle);
  1332. } // End check all hassubtype refs
  1333. arrayOfNodeIds_deleteMembers(visitedNodes);
  1334. return;
  1335. }
  1336. static void UA_Server_addInstanceOf_instatiateChildObject(UA_Server *server,
  1337. arrayOfNodeIds *subtypeRefs, arrayOfNodeIds *componentRefs, arrayOfNodeIds *typedefRefs,
  1338. UA_Node *objectCopy, UA_NodeId parentId, UA_ExpandedNodeId typeDefinition, UA_NodeId referenceTypeId,
  1339. UA_InstantiationCallback callback, UA_Boolean instantiateObjects, arrayOfNodeIds *instantiatedTypes,
  1340. void *handle)
  1341. {
  1342. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1343. // Refuse to create this node if we detect a circular type definition
  1344. UA_Boolean typeDefRecursion;
  1345. arrayOfNodeIds_idInArray((*instantiatedTypes), typeDefinition.nodeId, typeDefRecursion, UA_FALSE);
  1346. if (typeDefRecursion)
  1347. return;
  1348. UA_Node *typeDefNode;
  1349. UA_Server_getNodeCopy(server, typeDefinition.nodeId, (void *) &typeDefNode);
  1350. if (typeDefNode == UA_NULL) {
  1351. return;
  1352. }
  1353. if (typeDefNode->nodeClass != UA_NODECLASS_OBJECTTYPE) {
  1354. UA_Server_deleteNodeCopy(server, (void **) &typeDefNode);
  1355. return;
  1356. }
  1357. // Create the object root as specified by the user
  1358. UA_NodeId objectRoot;
  1359. retval |= UA_Server_addObjectNode(server, UA_NODEID_NUMERIC(parentId.namespaceIndex, 0), objectCopy->browseName, objectCopy->displayName,
  1360. objectCopy->description, objectCopy->userWriteMask, objectCopy->writeMask,
  1361. parentId, referenceTypeId, typeDefinition, &objectRoot);
  1362. if (retval)
  1363. return;
  1364. if (callback != UA_NULL)
  1365. callback(objectRoot, typeDefinition.nodeId, handle);
  1366. // (1) If this node is a subtype of any other node, create its things first
  1367. UA_Server_addInstanceOf_inheritParentAttributes(server, subtypeRefs, componentRefs, objectRoot, callback,
  1368. (UA_ObjectTypeNode *) typeDefNode, instantiatedTypes, handle);
  1369. // (2) For each object or variable referenced with hasComponent or hasProperty, create a new node of that
  1370. // type for this objectRoot
  1371. UA_Server_addInstanceOf_instatiateChildNode(server, subtypeRefs, componentRefs, typedefRefs,
  1372. objectRoot, callback, (UA_ObjectTypeNode *) typeDefNode,
  1373. UA_TRUE, instantiatedTypes, handle);
  1374. return;
  1375. }
  1376. void UA_Server_addInstanceOf_instatiateChildNode(UA_Server *server,
  1377. arrayOfNodeIds *subtypeRefs, arrayOfNodeIds *componentRefs, arrayOfNodeIds *typedefRefs,
  1378. UA_NodeId objectRoot, UA_InstantiationCallback callback, void *typeDefNode,
  1379. UA_Boolean instantiateObjects, arrayOfNodeIds *instantiatedTypes, void *handle)
  1380. {
  1381. UA_Boolean refTypeValid;
  1382. UA_NodeClass *refClass;
  1383. UA_Node *nodeClone;
  1384. UA_ExpandedNodeId *objectRootExpanded = UA_ExpandedNodeId_new();
  1385. UA_VariableNode *newVarNode;
  1386. UA_VariableTypeNode *varTypeNode;
  1387. UA_ReferenceNode ref;
  1388. UA_NodeId_copy(&objectRoot, &objectRootExpanded->nodeId );
  1389. UA_AddNodesResult adres;
  1390. for(int i=0; i< ((UA_ObjectTypeNode *) typeDefNode)->referencesSize; i++) {
  1391. ref = ((UA_ObjectTypeNode *) typeDefNode)->references[i];
  1392. if (ref.isInverse)
  1393. continue;
  1394. arrayOfNodeIds_idInArray((*componentRefs), ref.referenceTypeId, refTypeValid, UA_FALSE);
  1395. if (!refTypeValid)
  1396. continue;
  1397. // What type of node is this?
  1398. refClass = UA_NULL;
  1399. UA_Server_getAttributeValue(server, ref.targetId.nodeId, UA_ATTRIBUTEID_NODECLASS, (void **) &refClass);
  1400. switch (*refClass) {
  1401. case UA_NODECLASS_VARIABLE: // Just clone the variable node with a new nodeId
  1402. UA_Server_getNodeCopy(server, ref.targetId.nodeId, (void **) &nodeClone);
  1403. if (nodeClone == UA_NULL)
  1404. break;
  1405. UA_NodeId_init(&nodeClone->nodeId);
  1406. nodeClone->nodeId.namespaceIndex = objectRoot.namespaceIndex;
  1407. if (nodeClone != UA_NULL) {
  1408. adres = UA_Server_addNode(server, nodeClone, *objectRootExpanded, ref.referenceTypeId);
  1409. if (callback != UA_NULL)
  1410. callback(adres.addedNodeId, ref.targetId.nodeId, handle);
  1411. }
  1412. break;
  1413. case UA_NODECLASS_VARIABLETYPE: // Convert from a value protoype to a value, then add it
  1414. UA_Server_getNodeCopy(server, ref.targetId.nodeId, (void **) &varTypeNode);
  1415. newVarNode = UA_VariableNode_new();
  1416. newVarNode->nodeId.namespaceIndex = objectRoot.namespaceIndex;
  1417. UA_QualifiedName_copy(&varTypeNode->browseName, &varTypeNode->browseName);
  1418. UA_LocalizedText_copy(&varTypeNode->displayName, &varTypeNode->displayName);
  1419. UA_LocalizedText_copy(&varTypeNode->description, &varTypeNode->description);
  1420. newVarNode->writeMask = varTypeNode->writeMask;
  1421. newVarNode->userWriteMask = varTypeNode->userWriteMask;
  1422. newVarNode->valueRank = varTypeNode->valueRank;
  1423. newVarNode->valueSource = varTypeNode->valueSource;
  1424. if (varTypeNode->valueSource == UA_VALUESOURCE_DATASOURCE)
  1425. newVarNode->value.dataSource = varTypeNode->value.dataSource;
  1426. else{
  1427. newVarNode->value.variant.callback = varTypeNode->value.variant.callback;
  1428. UA_Variant_copy(&varTypeNode->value.variant.value, &newVarNode->value.variant.value);
  1429. }
  1430. adres = UA_Server_addNode(server, (UA_Node *) newVarNode, *objectRootExpanded, ref.referenceTypeId);
  1431. if (callback != UA_NULL)
  1432. callback(adres.addedNodeId, ref.targetId.nodeId, handle);
  1433. UA_Server_deleteNodeCopy(server, (void **) &newVarNode);
  1434. UA_Server_deleteNodeCopy(server, (void **) &varTypeNode);
  1435. break;
  1436. case UA_NODECLASS_OBJECT: // An object may have it's own inheritance or child nodes
  1437. if (!instantiateObjects)
  1438. break;
  1439. UA_Server_getNodeCopy(server, ref.targetId.nodeId, (void **) &nodeClone);
  1440. if (nodeClone == UA_NULL)
  1441. break; // switch
  1442. // Retrieve this nodes type definition
  1443. UA_ExpandedNodeId_init(objectRootExpanded); // Slight misuse of an unsused ExpandedNodeId to encode the typeDefinition
  1444. int tidx;
  1445. for(tidx=0; tidx<nodeClone->referencesSize; tidx++) {
  1446. arrayOfNodeIds_idInArray((*typedefRefs), nodeClone->references[tidx].referenceTypeId, refTypeValid, UA_FALSE);
  1447. if (refTypeValid)
  1448. break;
  1449. } // End iterate over nodeClone refs
  1450. if (!refTypeValid) // This may be plain wrong, but since got this far...
  1451. objectRootExpanded->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE);
  1452. else
  1453. UA_ExpandedNodeId_copy(&nodeClone->references[tidx].targetId, objectRootExpanded);
  1454. int lastArrayDepth = instantiatedTypes->size;
  1455. arrayOfNodeIds_addNodeId((*instantiatedTypes), ((UA_ObjectTypeNode *) typeDefNode)->nodeId);
  1456. UA_Server_addInstanceOf_instatiateChildObject(server, subtypeRefs, componentRefs, typedefRefs, nodeClone,
  1457. objectRoot, *objectRootExpanded, ref.referenceTypeId,
  1458. callback, UA_TRUE, instantiatedTypes, handle);
  1459. instantiatedTypes->size = lastArrayDepth;
  1460. instantiatedTypes->ids = (UA_NodeId *) UA_realloc(instantiatedTypes->ids, lastArrayDepth);
  1461. UA_Server_deleteNodeCopy(server, (void **) &nodeClone);
  1462. UA_ExpandedNodeId_deleteMembers(objectRootExpanded); // since we only borrowed this, reset it
  1463. UA_NodeId_copy(&objectRoot, &objectRootExpanded->nodeId );
  1464. break;
  1465. case UA_NODECLASS_METHOD: // Link this method (don't clone the node)
  1466. UA_Server_addMonodirectionalReference(server, objectRoot, ref.targetId, ref.referenceTypeId, UA_TRUE);
  1467. break;
  1468. default:
  1469. break;
  1470. }
  1471. UA_NodeClass_delete(refClass);
  1472. }
  1473. if (objectRootExpanded != UA_NULL)
  1474. UA_ExpandedNodeId_delete(objectRootExpanded);
  1475. return;
  1476. }
  1477. UA_StatusCode UA_Server_appendInstanceOfSupertype(UA_Server *server, UA_NodeId nodeId, UA_NodeId appendToNodeId,
  1478. arrayOfNodeIds *subtypeRefs, arrayOfNodeIds *componentRefs,
  1479. UA_InstantiationCallback callback, arrayOfNodeIds *instantiatedTypes,
  1480. void *handle)
  1481. {
  1482. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1483. UA_Node *typeDefNode = UA_NULL;
  1484. UA_Server_getNodeCopy(server, nodeId, (void *) &typeDefNode);
  1485. if (typeDefNode == UA_NULL) {
  1486. return UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  1487. }
  1488. if (typeDefNode->nodeClass != UA_NODECLASS_OBJECTTYPE) {
  1489. UA_Server_deleteNodeCopy(server, (void **) &typeDefNode);
  1490. return UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  1491. }
  1492. UA_ExpandedNodeId *objectRootExpanded = UA_ExpandedNodeId_new();
  1493. UA_NodeId_copy(&appendToNodeId, &objectRootExpanded->nodeId );
  1494. // (1) If this node is a subtype of any other node, create its things first
  1495. UA_Server_addInstanceOf_inheritParentAttributes(server, subtypeRefs, componentRefs, appendToNodeId, callback,
  1496. (UA_ObjectTypeNode *) typeDefNode, instantiatedTypes, handle);
  1497. UA_Server_addInstanceOf_instatiateChildNode(server, subtypeRefs, componentRefs, UA_NULL,
  1498. appendToNodeId, callback, (UA_ObjectTypeNode *) typeDefNode,
  1499. UA_FALSE, instantiatedTypes, handle);
  1500. if (objectRootExpanded != UA_NULL)
  1501. UA_ExpandedNodeId_delete(objectRootExpanded);
  1502. return retval;
  1503. }
  1504. UA_StatusCode UA_Server_addInstanceOf(UA_Server *server, UA_NodeId nodeId, const UA_QualifiedName browseName,
  1505. UA_LocalizedText displayName, UA_LocalizedText description, const UA_NodeId parentNodeId,
  1506. const UA_NodeId referenceTypeId, UA_UInt32 userWriteMask, UA_UInt32 writeMask,
  1507. const UA_ExpandedNodeId typeDefinition, UA_InstantiationCallback callback, void *handle,
  1508. UA_NodeId *createdNodeId)
  1509. {
  1510. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1511. UA_Node *typeDefNode = UA_NULL;
  1512. UA_Server_getNodeCopy(server, typeDefinition.nodeId, (void *) &typeDefNode);
  1513. if (typeDefNode == UA_NULL) {
  1514. return UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  1515. }
  1516. if (typeDefNode->nodeClass != UA_NODECLASS_OBJECTTYPE) {
  1517. UA_Server_deleteNodeCopy(server, (void **) &typeDefNode);
  1518. return UA_STATUSCODE_BADTYPEDEFINITIONINVALID;
  1519. }
  1520. // Create the object root as specified by the user
  1521. UA_NodeId objectRoot;
  1522. retval |= UA_Server_addObjectNode(server, nodeId, browseName, displayName, description, userWriteMask, writeMask,
  1523. parentNodeId, referenceTypeId,
  1524. typeDefinition, &objectRoot
  1525. );
  1526. if (retval)
  1527. return retval;
  1528. // These refs will be examined later.
  1529. // FIXME: Create these arrays dynamically to include any subtypes as well
  1530. UA_NodeId* tempArraySubtypeRefs = (UA_NodeId[]) { UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE)};
  1531. arrayOfNodeIds subtypeRefs = (arrayOfNodeIds) {
  1532. .size = 1,
  1533. .ids = tempArraySubtypeRefs
  1534. };
  1535. UA_NodeId* tempArrayComponentRefs = (UA_NodeId[]) { UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT), UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY)};
  1536. arrayOfNodeIds componentRefs = (arrayOfNodeIds) {
  1537. .size = 2,
  1538. .ids = tempArrayComponentRefs
  1539. };
  1540. UA_NodeId* tempArrayTypedefRefs = (UA_NodeId[]) { UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION)};
  1541. arrayOfNodeIds typedefRefs = (arrayOfNodeIds) {
  1542. .size = 1,
  1543. .ids = tempArrayTypedefRefs
  1544. };
  1545. UA_ExpandedNodeId *objectRootExpanded = UA_ExpandedNodeId_new();
  1546. UA_NodeId_copy(&objectRoot, &objectRootExpanded->nodeId );
  1547. arrayOfNodeIds instantiatedTypes = (arrayOfNodeIds ) {.size=0, .ids=UA_NULL};
  1548. arrayOfNodeIds_addNodeId(instantiatedTypes, typeDefNode->nodeId);
  1549. // (1) If this node is a subtype of any other node, create its things first
  1550. UA_Server_addInstanceOf_inheritParentAttributes(server, &subtypeRefs, &componentRefs, objectRoot, callback,
  1551. (UA_ObjectTypeNode *) typeDefNode, &instantiatedTypes, handle);
  1552. // (2) For each object or variable referenced with hasComponent or hasProperty, create a new node of that
  1553. // type for this objectRoot
  1554. UA_Server_addInstanceOf_instatiateChildNode(server, &subtypeRefs, &componentRefs, &typedefRefs,
  1555. objectRoot, callback, (UA_ObjectTypeNode *) typeDefNode,
  1556. UA_TRUE, &instantiatedTypes, handle);
  1557. arrayOfNodeIds_deleteMembers(instantiatedTypes);
  1558. UA_ExpandedNodeId_delete(objectRootExpanded);
  1559. UA_Server_deleteNodeCopy(server, (void **) &typeDefNode);
  1560. return retval;
  1561. }