ua_server_ns0.c 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089
  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 2017 (c) Fraunhofer IOSB (Author: Julius Pfrommer)
  6. * Copyright 2017 (c) Stefan Profanter, fortiss GmbH
  7. * Copyright 2017 (c) Thomas Bender
  8. * Copyright 2017 (c) Julian Grothoff
  9. * Copyright 2017 (c) Henrik Norrman
  10. * Copyright 2018 (c) Fabian Arndt, Root-Core
  11. * Copyright 2019 (c) Kalycito Infotech Private Limited
  12. */
  13. #include "open62541/namespace0_generated.h"
  14. #include "ua_server_internal.h"
  15. #include "ua_session.h"
  16. #include "ua_subscription.h"
  17. static UA_StatusCode
  18. addNode_raw(UA_Server *server, UA_NodeClass nodeClass,
  19. UA_UInt32 nodeId, char *name, void *attributes,
  20. const UA_DataType *attributesType) {
  21. UA_AddNodesItem item;
  22. UA_AddNodesItem_init(&item);
  23. item.nodeClass = nodeClass;
  24. item.requestedNewNodeId.nodeId = UA_NODEID_NUMERIC(0, nodeId);
  25. item.browseName = UA_QUALIFIEDNAME(0, name);
  26. item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
  27. item.nodeAttributes.content.decoded.data = attributes;
  28. item.nodeAttributes.content.decoded.type = attributesType;
  29. return AddNode_raw(server, &server->adminSession, NULL, &item, NULL);
  30. }
  31. static UA_StatusCode
  32. addNode_finish(UA_Server *server, UA_UInt32 nodeId,
  33. UA_UInt32 parentNodeId, UA_UInt32 referenceTypeId) {
  34. const UA_NodeId sourceId = UA_NODEID_NUMERIC(0, nodeId);
  35. const UA_NodeId refTypeId = UA_NODEID_NUMERIC(0, referenceTypeId);
  36. const UA_ExpandedNodeId targetId = UA_EXPANDEDNODEID_NUMERIC(0, parentNodeId);
  37. UA_StatusCode retval = UA_Server_addReference(server, sourceId, refTypeId, targetId, false);
  38. if (retval != UA_STATUSCODE_GOOD)
  39. return retval;
  40. return AddNode_finish(server, &server->adminSession, &sourceId);
  41. }
  42. static UA_StatusCode
  43. addObjectNode(UA_Server *server, char* name, UA_UInt32 objectid,
  44. UA_UInt32 parentid, UA_UInt32 referenceid, UA_UInt32 type_id) {
  45. UA_ObjectAttributes object_attr = UA_ObjectAttributes_default;
  46. object_attr.displayName = UA_LOCALIZEDTEXT("", name);
  47. return UA_Server_addObjectNode(server, UA_NODEID_NUMERIC(0, objectid),
  48. UA_NODEID_NUMERIC(0, parentid),
  49. UA_NODEID_NUMERIC(0, referenceid),
  50. UA_QUALIFIEDNAME(0, name),
  51. UA_NODEID_NUMERIC(0, type_id),
  52. object_attr, NULL, NULL);
  53. }
  54. static UA_StatusCode
  55. addReferenceTypeNode(UA_Server *server, char* name, char *inverseName, UA_UInt32 referencetypeid,
  56. UA_Boolean isabstract, UA_Boolean symmetric, UA_UInt32 parentid) {
  57. UA_ReferenceTypeAttributes reference_attr = UA_ReferenceTypeAttributes_default;
  58. reference_attr.displayName = UA_LOCALIZEDTEXT("", name);
  59. reference_attr.isAbstract = isabstract;
  60. reference_attr.symmetric = symmetric;
  61. if(inverseName)
  62. reference_attr.inverseName = UA_LOCALIZEDTEXT("", inverseName);
  63. return UA_Server_addReferenceTypeNode(server, UA_NODEID_NUMERIC(0, referencetypeid),
  64. UA_NODEID_NUMERIC(0, parentid), UA_NODEID_NULL,
  65. UA_QUALIFIEDNAME(0, name), reference_attr, NULL, NULL);
  66. }
  67. /***************************/
  68. /* Bootstrap NS0 hierarchy */
  69. /***************************/
  70. /* Creates the basic nodes which are expected by the nodeset compiler to be
  71. * already created. This is necessary to reduce the dependencies for the nodeset
  72. * compiler. */
  73. static UA_StatusCode
  74. UA_Server_createNS0_base(UA_Server *server) {
  75. /* Bootstrap References and HasSubtype */
  76. UA_StatusCode ret = UA_STATUSCODE_GOOD;
  77. UA_ReferenceTypeAttributes references_attr = UA_ReferenceTypeAttributes_default;
  78. references_attr.displayName = UA_LOCALIZEDTEXT("", "References");
  79. references_attr.isAbstract = true;
  80. references_attr.symmetric = true;
  81. references_attr.inverseName = UA_LOCALIZEDTEXT("", "References");
  82. ret |= addNode_raw(server, UA_NODECLASS_REFERENCETYPE, UA_NS0ID_REFERENCES, "References",
  83. &references_attr, &UA_TYPES[UA_TYPES_REFERENCETYPEATTRIBUTES]);
  84. UA_ReferenceTypeAttributes hassubtype_attr = UA_ReferenceTypeAttributes_default;
  85. hassubtype_attr.displayName = UA_LOCALIZEDTEXT("", "HasSubtype");
  86. hassubtype_attr.isAbstract = false;
  87. hassubtype_attr.symmetric = false;
  88. hassubtype_attr.inverseName = UA_LOCALIZEDTEXT("", "HasSupertype");
  89. ret |= addNode_raw(server, UA_NODECLASS_REFERENCETYPE, UA_NS0ID_HASSUBTYPE, "HasSubtype",
  90. &hassubtype_attr, &UA_TYPES[UA_TYPES_REFERENCETYPEATTRIBUTES]);
  91. UA_ReferenceTypeAttributes aggregates_attr = UA_ReferenceTypeAttributes_default;
  92. aggregates_attr.displayName = UA_LOCALIZEDTEXT("", "Aggregates");
  93. aggregates_attr.isAbstract = false;
  94. aggregates_attr.symmetric = false;
  95. aggregates_attr.inverseName = UA_LOCALIZEDTEXT("", "AggregatedBy");
  96. ret |= addNode_raw(server, UA_NODECLASS_REFERENCETYPE, UA_NS0ID_AGGREGATES, "Aggregates",
  97. &aggregates_attr, &UA_TYPES[UA_TYPES_REFERENCETYPEATTRIBUTES]);
  98. ret |= addReferenceTypeNode(server, "HierarchicalReferences", NULL,
  99. UA_NS0ID_HIERARCHICALREFERENCES, true, false, UA_NS0ID_REFERENCES);
  100. ret |= addReferenceTypeNode(server, "NonHierarchicalReferences", NULL,
  101. UA_NS0ID_NONHIERARCHICALREFERENCES, true, false, UA_NS0ID_REFERENCES);
  102. ret |= addReferenceTypeNode(server, "HasChild", NULL, UA_NS0ID_HASCHILD,
  103. true, false, UA_NS0ID_HIERARCHICALREFERENCES);
  104. ret |= addReferenceTypeNode(server, "Organizes", "OrganizedBy", UA_NS0ID_ORGANIZES,
  105. false, false, UA_NS0ID_HIERARCHICALREFERENCES);
  106. ret |= addReferenceTypeNode(server, "HasEventSource", "EventSourceOf", UA_NS0ID_HASEVENTSOURCE,
  107. false, false, UA_NS0ID_HIERARCHICALREFERENCES);
  108. ret |= addReferenceTypeNode(server, "HasModellingRule", "ModellingRuleOf", UA_NS0ID_HASMODELLINGRULE,
  109. false, false, UA_NS0ID_NONHIERARCHICALREFERENCES);
  110. ret |= addReferenceTypeNode(server, "HasEncoding", "EncodingOf", UA_NS0ID_HASENCODING,
  111. false, false, UA_NS0ID_NONHIERARCHICALREFERENCES);
  112. ret |= addReferenceTypeNode(server, "HasDescription", "DescriptionOf", UA_NS0ID_HASDESCRIPTION,
  113. false, false, UA_NS0ID_NONHIERARCHICALREFERENCES);
  114. ret |= addReferenceTypeNode(server, "HasTypeDefinition", "TypeDefinitionOf", UA_NS0ID_HASTYPEDEFINITION,
  115. false, false, UA_NS0ID_NONHIERARCHICALREFERENCES);
  116. ret |= addReferenceTypeNode(server, "GeneratesEvent", "GeneratedBy", UA_NS0ID_GENERATESEVENT,
  117. false, false, UA_NS0ID_NONHIERARCHICALREFERENCES);
  118. /* Complete bootstrap of Aggregates */
  119. ret |= addNode_finish(server, UA_NS0ID_AGGREGATES, UA_NS0ID_HASCHILD, UA_NS0ID_HASSUBTYPE);
  120. /* Complete bootstrap of HasSubtype */
  121. ret |= addNode_finish(server, UA_NS0ID_HASSUBTYPE, UA_NS0ID_HASCHILD, UA_NS0ID_HASSUBTYPE);
  122. ret |= addReferenceTypeNode(server, "HasProperty", "PropertyOf", UA_NS0ID_HASPROPERTY,
  123. false, false, UA_NS0ID_AGGREGATES);
  124. ret |= addReferenceTypeNode(server, "HasComponent", "ComponentOf", UA_NS0ID_HASCOMPONENT,
  125. false, false, UA_NS0ID_AGGREGATES);
  126. ret |= addReferenceTypeNode(server, "HasNotifier", "NotifierOf", UA_NS0ID_HASNOTIFIER,
  127. false, false, UA_NS0ID_HASEVENTSOURCE);
  128. ret |= addReferenceTypeNode(server, "HasOrderedComponent", "OrderedComponentOf",
  129. UA_NS0ID_HASORDEREDCOMPONENT, false, false, UA_NS0ID_HASCOMPONENT);
  130. /**************/
  131. /* Data Types */
  132. /**************/
  133. /* Bootstrap BaseDataType */
  134. UA_DataTypeAttributes basedatatype_attr = UA_DataTypeAttributes_default;
  135. basedatatype_attr.displayName = UA_LOCALIZEDTEXT("", "BaseDataType");
  136. basedatatype_attr.isAbstract = true;
  137. ret |= addNode_raw(server, UA_NODECLASS_DATATYPE, UA_NS0ID_BASEDATATYPE, "BaseDataType",
  138. &basedatatype_attr, &UA_TYPES[UA_TYPES_DATATYPEATTRIBUTES]);
  139. /*****************/
  140. /* VariableTypes */
  141. /*****************/
  142. UA_VariableTypeAttributes basevar_attr = UA_VariableTypeAttributes_default;
  143. basevar_attr.displayName = UA_LOCALIZEDTEXT("", "BaseVariableType");
  144. basevar_attr.isAbstract = true;
  145. basevar_attr.valueRank = UA_VALUERANK_ANY;
  146. basevar_attr.dataType = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATATYPE);
  147. ret |= addNode_raw(server, UA_NODECLASS_VARIABLETYPE, UA_NS0ID_BASEVARIABLETYPE, "BaseVariableType",
  148. &basevar_attr, &UA_TYPES[UA_TYPES_VARIABLETYPEATTRIBUTES]);
  149. UA_VariableTypeAttributes bdv_attr = UA_VariableTypeAttributes_default;
  150. bdv_attr.displayName = UA_LOCALIZEDTEXT("", "BaseDataVariableType");
  151. bdv_attr.dataType = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATATYPE);
  152. bdv_attr.valueRank = UA_VALUERANK_ANY;
  153. ret |= UA_Server_addVariableTypeNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE),
  154. UA_NODEID_NUMERIC(0, UA_NS0ID_BASEVARIABLETYPE),
  155. UA_NODEID_NULL, UA_QUALIFIEDNAME(0, "BaseDataVariableType"),
  156. UA_NODEID_NULL, bdv_attr, NULL, NULL);
  157. UA_VariableTypeAttributes prop_attr = UA_VariableTypeAttributes_default;
  158. prop_attr.displayName = UA_LOCALIZEDTEXT("", "PropertyType");
  159. prop_attr.dataType = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATATYPE);
  160. prop_attr.valueRank = UA_VALUERANK_ANY;
  161. ret |= UA_Server_addVariableTypeNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE),
  162. UA_NODEID_NUMERIC(0, UA_NS0ID_BASEVARIABLETYPE),
  163. UA_NODEID_NULL, UA_QUALIFIEDNAME(0, "PropertyType"),
  164. UA_NODEID_NULL, prop_attr, NULL, NULL);
  165. /***************/
  166. /* ObjectTypes */
  167. /***************/
  168. UA_ObjectTypeAttributes baseobj_attr = UA_ObjectTypeAttributes_default;
  169. baseobj_attr.displayName = UA_LOCALIZEDTEXT("", "BaseObjectType");
  170. ret |= addNode_raw(server, UA_NODECLASS_OBJECTTYPE, UA_NS0ID_BASEOBJECTTYPE, "BaseObjectType",
  171. &baseobj_attr, &UA_TYPES[UA_TYPES_OBJECTTYPEATTRIBUTES]);
  172. UA_ObjectTypeAttributes folder_attr = UA_ObjectTypeAttributes_default;
  173. folder_attr.displayName = UA_LOCALIZEDTEXT("", "FolderType");
  174. ret |= UA_Server_addObjectTypeNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE),
  175. UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE),
  176. UA_NODEID_NULL, UA_QUALIFIEDNAME(0, "FolderType"),
  177. folder_attr, NULL, NULL);
  178. /******************/
  179. /* Root and below */
  180. /******************/
  181. ret |= addObjectNode(server, "Root", UA_NS0ID_ROOTFOLDER, 0, 0, UA_NS0ID_FOLDERTYPE);
  182. ret |= addObjectNode(server, "Objects", UA_NS0ID_OBJECTSFOLDER, UA_NS0ID_ROOTFOLDER,
  183. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  184. ret |= addObjectNode(server, "Types", UA_NS0ID_TYPESFOLDER, UA_NS0ID_ROOTFOLDER,
  185. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  186. ret |= addObjectNode(server, "ReferenceTypes", UA_NS0ID_REFERENCETYPESFOLDER, UA_NS0ID_TYPESFOLDER,
  187. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  188. ret |= addNode_finish(server, UA_NS0ID_REFERENCES, UA_NS0ID_REFERENCETYPESFOLDER,
  189. UA_NS0ID_ORGANIZES);
  190. ret |= addObjectNode(server, "DataTypes", UA_NS0ID_DATATYPESFOLDER, UA_NS0ID_TYPESFOLDER,
  191. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  192. ret |= addNode_finish(server, UA_NS0ID_BASEDATATYPE, UA_NS0ID_DATATYPESFOLDER,
  193. UA_NS0ID_ORGANIZES);
  194. ret |= addObjectNode(server, "VariableTypes", UA_NS0ID_VARIABLETYPESFOLDER, UA_NS0ID_TYPESFOLDER,
  195. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  196. ret |= addNode_finish(server, UA_NS0ID_BASEVARIABLETYPE, UA_NS0ID_VARIABLETYPESFOLDER,
  197. UA_NS0ID_ORGANIZES);
  198. ret |= addObjectNode(server, "ObjectTypes", UA_NS0ID_OBJECTTYPESFOLDER, UA_NS0ID_TYPESFOLDER,
  199. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  200. ret |= addNode_finish(server, UA_NS0ID_BASEOBJECTTYPE, UA_NS0ID_OBJECTTYPESFOLDER,
  201. UA_NS0ID_ORGANIZES);
  202. ret |= addObjectNode(server, "EventTypes", UA_NS0ID_EVENTTYPESFOLDER, UA_NS0ID_TYPESFOLDER,
  203. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  204. ret |= addObjectNode(server, "Views", UA_NS0ID_VIEWSFOLDER, UA_NS0ID_ROOTFOLDER,
  205. UA_NS0ID_ORGANIZES, UA_NS0ID_FOLDERTYPE);
  206. if(ret != UA_STATUSCODE_GOOD)
  207. ret = UA_STATUSCODE_BADINTERNALERROR;
  208. return ret;
  209. }
  210. /****************/
  211. /* Data Sources */
  212. /****************/
  213. static UA_StatusCode
  214. readStatus(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  215. const UA_NodeId *nodeId, void *nodeContext, UA_Boolean sourceTimestamp,
  216. const UA_NumericRange *range, UA_DataValue *value) {
  217. if(range) {
  218. value->hasStatus = true;
  219. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  220. return UA_STATUSCODE_GOOD;
  221. }
  222. if(sourceTimestamp) {
  223. value->hasSourceTimestamp = true;
  224. value->sourceTimestamp = UA_DateTime_now();
  225. }
  226. void *data = NULL;
  227. UA_assert(nodeId->identifierType == UA_NODEIDTYPE_NUMERIC);
  228. switch(nodeId->identifier.numeric) {
  229. case UA_NS0ID_SERVER_SERVERSTATUS_SECONDSTILLSHUTDOWN: {
  230. UA_UInt32 *shutdown = UA_UInt32_new();
  231. if(!shutdown)
  232. return UA_STATUSCODE_BADOUTOFMEMORY;
  233. if(server->endTime != 0)
  234. *shutdown = (UA_UInt32)((server->endTime - UA_DateTime_now()) / UA_DATETIME_SEC);
  235. value->value.data = shutdown;
  236. value->value.type = &UA_TYPES[UA_TYPES_UINT32];
  237. value->hasValue = true;
  238. return UA_STATUSCODE_GOOD;
  239. }
  240. case UA_NS0ID_SERVER_SERVERSTATUS_STATE: {
  241. UA_ServerState *state = UA_ServerState_new();
  242. if(!state)
  243. return UA_STATUSCODE_BADOUTOFMEMORY;
  244. if(server->endTime != 0)
  245. *state = UA_SERVERSTATE_SHUTDOWN;
  246. value->value.data = state;
  247. value->value.type = &UA_TYPES[UA_TYPES_SERVERSTATE];
  248. value->hasValue = true;
  249. return UA_STATUSCODE_GOOD;
  250. }
  251. case UA_NS0ID_SERVER_SERVERSTATUS: {
  252. UA_ServerStatusDataType *statustype = UA_ServerStatusDataType_new();
  253. if(!statustype)
  254. return UA_STATUSCODE_BADOUTOFMEMORY;
  255. statustype->startTime = server->startTime;
  256. statustype->currentTime = UA_DateTime_now();
  257. statustype->state = UA_SERVERSTATE_RUNNING;
  258. statustype->secondsTillShutdown = 0;
  259. if(server->endTime != 0) {
  260. statustype->state = UA_SERVERSTATE_SHUTDOWN;
  261. statustype->secondsTillShutdown = (UA_UInt32)((server->endTime - UA_DateTime_now()) / UA_DATETIME_SEC);
  262. }
  263. value->value.data = statustype;
  264. value->value.type = &UA_TYPES[UA_TYPES_SERVERSTATUSDATATYPE];
  265. value->hasValue = true;
  266. return UA_BuildInfo_copy(&server->config.buildInfo, &statustype->buildInfo);
  267. }
  268. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO:
  269. value->value.type = &UA_TYPES[UA_TYPES_BUILDINFO];
  270. data = &server->config.buildInfo;
  271. break;
  272. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTURI:
  273. value->value.type = &UA_TYPES[UA_TYPES_STRING];
  274. data = &server->config.buildInfo.productUri;
  275. break;
  276. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_MANUFACTURERNAME:
  277. value->value.type = &UA_TYPES[UA_TYPES_STRING];
  278. data = &server->config.buildInfo.manufacturerName;
  279. break;
  280. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTNAME:
  281. value->value.type = &UA_TYPES[UA_TYPES_STRING];
  282. data = &server->config.buildInfo.productName;
  283. break;
  284. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_SOFTWAREVERSION:
  285. value->value.type = &UA_TYPES[UA_TYPES_STRING];
  286. data = &server->config.buildInfo.softwareVersion;
  287. break;
  288. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDNUMBER:
  289. value->value.type = &UA_TYPES[UA_TYPES_STRING];
  290. data = &server->config.buildInfo.buildNumber;
  291. break;
  292. case UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDDATE:
  293. value->value.type = &UA_TYPES[UA_TYPES_DATETIME];
  294. data = &server->config.buildInfo.buildDate;
  295. break;
  296. default:
  297. value->hasStatus = true;
  298. value->status = UA_STATUSCODE_BADINTERNALERROR;
  299. return UA_STATUSCODE_GOOD;
  300. }
  301. value->value.data = UA_new(value->value.type);
  302. if(!value->value.data) {
  303. value->value.type = NULL;
  304. return UA_STATUSCODE_BADOUTOFMEMORY;
  305. }
  306. value->hasValue = true;
  307. return UA_copy(data, value->value.data, value->value.type);
  308. }
  309. #ifdef UA_GENERATED_NAMESPACE_ZERO
  310. static UA_StatusCode
  311. readServiceLevel(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  312. const UA_NodeId *nodeId, void *nodeContext, UA_Boolean includeSourceTimeStamp,
  313. const UA_NumericRange *range, UA_DataValue *value) {
  314. if(range) {
  315. value->hasStatus = true;
  316. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  317. return UA_STATUSCODE_GOOD;
  318. }
  319. value->value.type = &UA_TYPES[UA_TYPES_BYTE];
  320. value->value.arrayLength = 0;
  321. UA_Byte *byte = UA_Byte_new();
  322. *byte = 255;
  323. value->value.data = byte;
  324. value->value.arrayDimensionsSize = 0;
  325. value->value.arrayDimensions = NULL;
  326. value->hasValue = true;
  327. if(includeSourceTimeStamp) {
  328. value->hasSourceTimestamp = true;
  329. value->sourceTimestamp = UA_DateTime_now();
  330. }
  331. return UA_STATUSCODE_GOOD;
  332. }
  333. static UA_StatusCode
  334. readAuditing(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  335. const UA_NodeId *nodeId, void *nodeContext, UA_Boolean includeSourceTimeStamp,
  336. const UA_NumericRange *range, UA_DataValue *value) {
  337. if(range) {
  338. value->hasStatus = true;
  339. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  340. return UA_STATUSCODE_GOOD;
  341. }
  342. value->value.type = &UA_TYPES[UA_TYPES_BOOLEAN];
  343. value->value.arrayLength = 0;
  344. UA_Boolean *boolean = UA_Boolean_new();
  345. *boolean = false;
  346. value->value.data = boolean;
  347. value->value.arrayDimensionsSize = 0;
  348. value->value.arrayDimensions = NULL;
  349. value->hasValue = true;
  350. if(includeSourceTimeStamp) {
  351. value->hasSourceTimestamp = true;
  352. value->sourceTimestamp = UA_DateTime_now();
  353. }
  354. return UA_STATUSCODE_GOOD;
  355. }
  356. #endif
  357. static UA_StatusCode
  358. readNamespaces(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  359. const UA_NodeId *nodeid, void *nodeContext, UA_Boolean includeSourceTimeStamp,
  360. const UA_NumericRange *range,
  361. UA_DataValue *value) {
  362. /* ensure that the uri for ns1 is set up from the app description */
  363. setupNs1Uri(server);
  364. if(range) {
  365. value->hasStatus = true;
  366. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  367. return UA_STATUSCODE_GOOD;
  368. }
  369. UA_StatusCode retval;
  370. retval = UA_Variant_setArrayCopy(&value->value, server->namespaces,
  371. server->namespacesSize, &UA_TYPES[UA_TYPES_STRING]);
  372. if(retval != UA_STATUSCODE_GOOD)
  373. return retval;
  374. value->hasValue = true;
  375. if(includeSourceTimeStamp) {
  376. value->hasSourceTimestamp = true;
  377. value->sourceTimestamp = UA_DateTime_now();
  378. }
  379. return UA_STATUSCODE_GOOD;
  380. }
  381. static UA_StatusCode
  382. writeNamespaces(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  383. const UA_NodeId *nodeid, void *nodeContext, const UA_NumericRange *range,
  384. const UA_DataValue *value) {
  385. /* Check the data type */
  386. if(!value->hasValue ||
  387. value->value.type != &UA_TYPES[UA_TYPES_STRING])
  388. return UA_STATUSCODE_BADTYPEMISMATCH;
  389. /* Check that the variant is not empty */
  390. if(!value->value.data)
  391. return UA_STATUSCODE_BADTYPEMISMATCH;
  392. /* TODO: Writing with a range is not implemented */
  393. if(range)
  394. return UA_STATUSCODE_BADINTERNALERROR;
  395. UA_String *newNamespaces = (UA_String*)value->value.data;
  396. size_t newNamespacesSize = value->value.arrayLength;
  397. /* Test if we append to the existing namespaces */
  398. if(newNamespacesSize <= server->namespacesSize)
  399. return UA_STATUSCODE_BADTYPEMISMATCH;
  400. /* ensure that the uri for ns1 is set up from the app description */
  401. setupNs1Uri(server);
  402. /* Test if the existing namespaces are unchanged */
  403. for(size_t i = 0; i < server->namespacesSize; ++i) {
  404. if(!UA_String_equal(&server->namespaces[i], &newNamespaces[i]))
  405. return UA_STATUSCODE_BADINTERNALERROR;
  406. }
  407. /* Add namespaces */
  408. for(size_t i = server->namespacesSize; i < newNamespacesSize; ++i)
  409. addNamespace(server, newNamespaces[i]);
  410. return UA_STATUSCODE_GOOD;
  411. }
  412. static UA_StatusCode
  413. readCurrentTime(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  414. const UA_NodeId *nodeid, void *nodeContext, UA_Boolean sourceTimeStamp,
  415. const UA_NumericRange *range, UA_DataValue *value) {
  416. if(range) {
  417. value->hasStatus = true;
  418. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  419. return UA_STATUSCODE_GOOD;
  420. }
  421. UA_DateTime currentTime = UA_DateTime_now();
  422. UA_StatusCode retval = UA_Variant_setScalarCopy(&value->value, &currentTime,
  423. &UA_TYPES[UA_TYPES_DATETIME]);
  424. if(retval != UA_STATUSCODE_GOOD)
  425. return retval;
  426. value->hasValue = true;
  427. if(sourceTimeStamp) {
  428. value->hasSourceTimestamp = true;
  429. value->sourceTimestamp = currentTime;
  430. }
  431. return UA_STATUSCODE_GOOD;
  432. }
  433. #ifdef UA_GENERATED_NAMESPACE_ZERO
  434. static UA_StatusCode
  435. readMinSamplingInterval(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  436. const UA_NodeId *nodeid, void *nodeContext, UA_Boolean includeSourceTimeStamp,
  437. const UA_NumericRange *range,
  438. UA_DataValue *value) {
  439. if(range) {
  440. value->hasStatus = true;
  441. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  442. return UA_STATUSCODE_GOOD;
  443. }
  444. UA_StatusCode retval;
  445. retval = UA_Variant_setScalarCopy(&value->value,
  446. &server->config.samplingIntervalLimits.min,
  447. &UA_TYPES[UA_TYPES_DURATION]);
  448. if(retval != UA_STATUSCODE_GOOD)
  449. return retval;
  450. value->hasValue = true;
  451. if(includeSourceTimeStamp) {
  452. value->hasSourceTimestamp = true;
  453. value->sourceTimestamp = UA_DateTime_now();
  454. }
  455. return UA_STATUSCODE_GOOD;
  456. }
  457. #endif
  458. #if defined(UA_GENERATED_NAMESPACE_ZERO) && defined(UA_ENABLE_METHODCALLS) && defined(UA_ENABLE_SUBSCRIPTIONS)
  459. static UA_StatusCode
  460. readMonitoredItems(UA_Server *server, const UA_NodeId *sessionId, void *sessionContext,
  461. const UA_NodeId *methodId, void *methodContext, const UA_NodeId *objectId,
  462. void *objectContext, size_t inputSize,
  463. const UA_Variant *input, size_t outputSize,
  464. UA_Variant *output) {
  465. UA_Session *session = UA_SessionManager_getSessionById(&server->sessionManager, sessionId);
  466. if(!session)
  467. return UA_STATUSCODE_BADINTERNALERROR;
  468. if (inputSize == 0 || !input[0].data)
  469. return UA_STATUSCODE_BADSUBSCRIPTIONIDINVALID;
  470. UA_UInt32 subscriptionId = *((UA_UInt32*)(input[0].data));
  471. UA_Subscription* subscription = UA_Session_getSubscriptionById(session, subscriptionId);
  472. if(!subscription)
  473. {
  474. if(LIST_EMPTY(&session->serverSubscriptions))
  475. {
  476. UA_Variant_setArray(&output[0], UA_Array_new(0, &UA_TYPES[UA_TYPES_UINT32]),
  477. 0, &UA_TYPES[UA_TYPES_UINT32]);
  478. UA_Variant_setArray(&output[1], UA_Array_new(0, &UA_TYPES[UA_TYPES_UINT32]),
  479. 0, &UA_TYPES[UA_TYPES_UINT32]);
  480. return UA_STATUSCODE_BADNOMATCH;
  481. }
  482. return UA_STATUSCODE_BADSUBSCRIPTIONIDINVALID;
  483. }
  484. UA_UInt32 sizeOfOutput = 0;
  485. UA_MonitoredItem* monitoredItem;
  486. LIST_FOREACH(monitoredItem, &subscription->monitoredItems, listEntry) {
  487. ++sizeOfOutput;
  488. }
  489. if(sizeOfOutput==0)
  490. return UA_STATUSCODE_GOOD;
  491. UA_UInt32* clientHandles = (UA_UInt32 *)UA_Array_new(sizeOfOutput, &UA_TYPES[UA_TYPES_UINT32]);
  492. UA_UInt32* serverHandles = (UA_UInt32 *)UA_Array_new(sizeOfOutput, &UA_TYPES[UA_TYPES_UINT32]);
  493. UA_UInt32 i = 0;
  494. LIST_FOREACH(monitoredItem, &subscription->monitoredItems, listEntry) {
  495. clientHandles[i] = monitoredItem->clientHandle;
  496. serverHandles[i] = monitoredItem->monitoredItemId;
  497. ++i;
  498. }
  499. UA_Variant_setArray(&output[0], serverHandles, sizeOfOutput, &UA_TYPES[UA_TYPES_UINT32]);
  500. UA_Variant_setArray(&output[1], clientHandles, sizeOfOutput, &UA_TYPES[UA_TYPES_UINT32]);
  501. return UA_STATUSCODE_GOOD;
  502. }
  503. #endif /* defined(UA_ENABLE_METHODCALLS) && defined(UA_ENABLE_SUBSCRIPTIONS) */
  504. UA_StatusCode
  505. writeNs0VariableArray(UA_Server *server, UA_UInt32 id, void *v,
  506. size_t length, const UA_DataType *type) {
  507. UA_Variant var;
  508. UA_Variant_init(&var);
  509. UA_Variant_setArray(&var, v, length, type);
  510. return UA_Server_writeValue(server, UA_NODEID_NUMERIC(0, id), var);
  511. }
  512. #ifndef UA_GENERATED_NAMESPACE_ZERO
  513. static UA_StatusCode
  514. addVariableNode(UA_Server *server, char* name, UA_UInt32 variableid,
  515. UA_UInt32 parentid, UA_UInt32 referenceid,
  516. UA_Int32 valueRank, UA_UInt32 dataType) {
  517. UA_VariableAttributes attr = UA_VariableAttributes_default;
  518. attr.displayName = UA_LOCALIZEDTEXT("", name);
  519. attr.dataType = UA_NODEID_NUMERIC(0, dataType);
  520. attr.valueRank = valueRank;
  521. attr.accessLevel = UA_ACCESSLEVELMASK_READ;
  522. return UA_Server_addVariableNode(server, UA_NODEID_NUMERIC(0, variableid),
  523. UA_NODEID_NUMERIC(0, parentid), UA_NODEID_NUMERIC(0, referenceid),
  524. UA_QUALIFIEDNAME(0, name),
  525. UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE),
  526. attr, NULL, NULL);
  527. }
  528. /* A minimal server object that is not complete and does not use the mandated
  529. * references to a server type. To be used on very constrained devices. */
  530. static UA_StatusCode
  531. UA_Server_minimalServerObject(UA_Server *server) {
  532. /* Server */
  533. UA_StatusCode retval = addObjectNode(server, "Server", UA_NS0ID_SERVER, UA_NS0ID_OBJECTSFOLDER,
  534. UA_NS0ID_ORGANIZES, UA_NS0ID_BASEOBJECTTYPE);
  535. /* Use a valuerank of -2 for now. The array is added later on and the valuerank set to 1. */
  536. retval |= addVariableNode(server, "ServerArray", UA_NS0ID_SERVER_SERVERARRAY,
  537. UA_NS0ID_SERVER, UA_NS0ID_HASPROPERTY,
  538. UA_VALUERANK_ANY, UA_NS0ID_BASEDATATYPE);
  539. retval |= addVariableNode(server, "NamespaceArray", UA_NS0ID_SERVER_NAMESPACEARRAY,
  540. UA_NS0ID_SERVER, UA_NS0ID_HASPROPERTY,
  541. UA_VALUERANK_ANY, UA_NS0ID_BASEDATATYPE);
  542. retval |= addVariableNode(server, "ServerStatus", UA_NS0ID_SERVER_SERVERSTATUS,
  543. UA_NS0ID_SERVER, UA_NS0ID_HASCOMPONENT,
  544. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  545. retval |= addVariableNode(server, "CurrentTime", UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME,
  546. UA_NS0ID_SERVER_SERVERSTATUS, UA_NS0ID_HASCOMPONENT,
  547. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  548. retval |= addVariableNode(server, "State", UA_NS0ID_SERVER_SERVERSTATUS_STATE,
  549. UA_NS0ID_SERVER_SERVERSTATUS, UA_NS0ID_HASCOMPONENT,
  550. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  551. retval |= addVariableNode(server, "BuildInfo", UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO,
  552. UA_NS0ID_SERVER_SERVERSTATUS, UA_NS0ID_HASCOMPONENT,
  553. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  554. retval |= addVariableNode(server, "ProductUri", UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTURI,
  555. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO, UA_NS0ID_HASCOMPONENT,
  556. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  557. retval |= addVariableNode(server, "ManufacturerName",
  558. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_MANUFACTURERNAME,
  559. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO, UA_NS0ID_HASCOMPONENT,
  560. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  561. retval |= addVariableNode(server, "ProductName",
  562. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTNAME,
  563. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO, UA_NS0ID_HASCOMPONENT,
  564. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  565. retval |= addVariableNode(server, "SoftwareVersion",
  566. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_SOFTWAREVERSION,
  567. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO, UA_NS0ID_HASCOMPONENT,
  568. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  569. retval |= addVariableNode(server, "BuildNumber",
  570. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDNUMBER,
  571. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO, UA_NS0ID_HASCOMPONENT,
  572. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  573. retval |= addVariableNode(server, "BuildDate",
  574. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDDATE,
  575. UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO, UA_NS0ID_HASCOMPONENT,
  576. UA_VALUERANK_SCALAR, UA_NS0ID_BASEDATATYPE);
  577. return retval;
  578. }
  579. #else
  580. static UA_StatusCode
  581. writeNs0Variable(UA_Server *server, UA_UInt32 id, void *v, const UA_DataType *type) {
  582. UA_Variant var;
  583. UA_Variant_init(&var);
  584. UA_Variant_setScalar(&var, v, type);
  585. return UA_Server_writeValue(server, UA_NODEID_NUMERIC(0, id), var);
  586. }
  587. static void
  588. addModellingRules(UA_Server *server) {
  589. /* Test if the ModellingRules folder was added. (Only for the full ns0.) */
  590. UA_NodeClass mrnc = UA_NODECLASS_UNSPECIFIED;
  591. UA_StatusCode retval = UA_Server_readNodeClass(server,
  592. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MODELLINGRULES),
  593. &mrnc);
  594. if(retval != UA_STATUSCODE_GOOD)
  595. return;
  596. /* Add ExposesItsArray */
  597. UA_Server_addReference(server,
  598. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MODELLINGRULES),
  599. UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  600. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_MODELLINGRULE_EXPOSESITSARRAY),
  601. true);
  602. /* Add Mandatory */
  603. UA_Server_addReference(server,
  604. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MODELLINGRULES),
  605. UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  606. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_MODELLINGRULE_MANDATORY),
  607. true);
  608. /* Add MandatoryPlaceholder */
  609. UA_Server_addReference(server,
  610. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MODELLINGRULES),
  611. UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  612. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_MODELLINGRULE_MANDATORYPLACEHOLDER),
  613. true);
  614. /* Add Optional */
  615. UA_Server_addReference(server,
  616. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MODELLINGRULES),
  617. UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  618. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_MODELLINGRULE_OPTIONAL),
  619. true);
  620. /* Add OptionalPlaceholder */
  621. UA_Server_addReference(server,
  622. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MODELLINGRULES),
  623. UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  624. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_MODELLINGRULE_OPTIONALPLACEHOLDER),
  625. true);
  626. }
  627. #endif
  628. /* Initialize the nodeset 0 by using the generated code of the nodeset compiler.
  629. * This also initialized the data sources for various variables, such as for
  630. * example server time. */
  631. UA_StatusCode
  632. UA_Server_initNS0(UA_Server *server) {
  633. /* Initialize base nodes which are always required an cannot be created
  634. * through the NS compiler */
  635. server->bootstrapNS0 = true;
  636. UA_StatusCode retVal = UA_Server_createNS0_base(server);
  637. server->bootstrapNS0 = false;
  638. if(retVal != UA_STATUSCODE_GOOD)
  639. return retVal;
  640. #ifdef UA_GENERATED_NAMESPACE_ZERO
  641. /* Load nodes and references generated from the XML ns0 definition */
  642. retVal = namespace0_generated(server);
  643. #else
  644. /* Create a minimal server object */
  645. retVal = UA_Server_minimalServerObject(server);
  646. #endif
  647. if(retVal != UA_STATUSCODE_GOOD) {
  648. UA_LOG_ERROR(&server->config.logger, UA_LOGCATEGORY_SERVER,
  649. "Initialization of Namespace 0 (before bootstrapping) "
  650. "failed with %s. See previous outputs for any error messages.",
  651. UA_StatusCode_name(retVal));
  652. return UA_STATUSCODE_BADINTERNALERROR;
  653. }
  654. /* NamespaceArray */
  655. UA_DataSource namespaceDataSource = {readNamespaces, writeNamespaces};
  656. retVal |= UA_Server_setVariableNode_dataSource(server,
  657. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACEARRAY),
  658. namespaceDataSource);
  659. retVal |= UA_Server_writeValueRank(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACEARRAY), 1);
  660. /* ServerArray */
  661. retVal |= writeNs0VariableArray(server, UA_NS0ID_SERVER_SERVERARRAY,
  662. &server->config.applicationDescription.applicationUri,
  663. 1, &UA_TYPES[UA_TYPES_STRING]);
  664. retVal |= UA_Server_writeValueRank(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERARRAY), 1);
  665. /* ServerStatus */
  666. UA_DataSource serverStatus = {readStatus, NULL};
  667. retVal |= UA_Server_setVariableNode_dataSource(server,
  668. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), serverStatus);
  669. /* StartTime will be sampled in UA_Server_run_startup()*/
  670. /* CurrentTime */
  671. UA_DataSource currentTime = {readCurrentTime, NULL};
  672. retVal |= UA_Server_setVariableNode_dataSource(server,
  673. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME), currentTime);
  674. /* State */
  675. retVal |= UA_Server_setVariableNode_dataSource(server,
  676. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_STATE),
  677. serverStatus);
  678. /* BuildInfo */
  679. retVal |= UA_Server_setVariableNode_dataSource(server,
  680. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), serverStatus);
  681. /* BuildInfo - ProductUri */
  682. retVal |= UA_Server_setVariableNode_dataSource(server,
  683. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTURI),
  684. serverStatus);
  685. /* BuildInfo - ManufacturerName */
  686. retVal |= UA_Server_setVariableNode_dataSource(server,
  687. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_MANUFACTURERNAME),
  688. serverStatus);
  689. /* BuildInfo - ProductName */
  690. retVal |= UA_Server_setVariableNode_dataSource(server,
  691. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTNAME),
  692. serverStatus);
  693. /* BuildInfo - SoftwareVersion */
  694. retVal |= UA_Server_setVariableNode_dataSource(server,
  695. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_SOFTWAREVERSION),
  696. serverStatus);
  697. /* BuildInfo - BuildNumber */
  698. retVal |= UA_Server_setVariableNode_dataSource(server,
  699. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDNUMBER),
  700. serverStatus);
  701. /* BuildInfo - BuildDate */
  702. retVal |= UA_Server_setVariableNode_dataSource(server,
  703. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDDATE),
  704. serverStatus);
  705. #ifdef UA_GENERATED_NAMESPACE_ZERO
  706. /* SecondsTillShutdown */
  707. retVal |= UA_Server_setVariableNode_dataSource(server,
  708. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_SECONDSTILLSHUTDOWN),
  709. serverStatus);
  710. /* ShutDownReason */
  711. UA_LocalizedText shutdownReason;
  712. UA_LocalizedText_init(&shutdownReason);
  713. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERSTATUS_SHUTDOWNREASON,
  714. &shutdownReason, &UA_TYPES[UA_TYPES_LOCALIZEDTEXT]);
  715. /* ServiceLevel */
  716. UA_DataSource serviceLevel = {readServiceLevel, NULL};
  717. retVal |= UA_Server_setVariableNode_dataSource(server,
  718. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVICELEVEL), serviceLevel);
  719. /* ServerDiagnostics - ServerDiagnosticsSummary */
  720. UA_ServerDiagnosticsSummaryDataType serverDiagnosticsSummary;
  721. UA_ServerDiagnosticsSummaryDataType_init(&serverDiagnosticsSummary);
  722. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_SERVERDIAGNOSTICSSUMMARY,
  723. &serverDiagnosticsSummary,
  724. &UA_TYPES[UA_TYPES_SERVERDIAGNOSTICSSUMMARYDATATYPE]);
  725. /* ServerDiagnostics - EnabledFlag */
  726. UA_Boolean enabledFlag = false;
  727. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_ENABLEDFLAG,
  728. &enabledFlag, &UA_TYPES[UA_TYPES_BOOLEAN]);
  729. /* According to Specification part-5 - pg.no-11(PDF pg.no-29), when the ServerDiagnostics is disabled the client
  730. * may modify the value of enabledFlag=true in the server. By default, this node have CurrentRead/Write access.
  731. * In CTT, Subscription_Minimum_1/002.js test will modify the above flag. This will not be a problem when build
  732. * configuration is set at UA_NAMESPACE_ZERO="REDUCED" as NodeIds will not be present. When UA_NAMESPACE_ZERO="FULL",
  733. * the test will fail. Hence made the NodeId as read only */
  734. retVal |= UA_Server_writeAccessLevel(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_ENABLEDFLAG),
  735. UA_ACCESSLEVELMASK_READ);
  736. /* Auditing */
  737. UA_DataSource auditing = {readAuditing, NULL};
  738. retVal |= UA_Server_setVariableNode_dataSource(server,
  739. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_AUDITING), auditing);
  740. /* Redundancy Support */
  741. UA_RedundancySupport redundancySupport = UA_REDUNDANCYSUPPORT_NONE;
  742. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERREDUNDANCY_REDUNDANCYSUPPORT,
  743. &redundancySupport, &UA_TYPES[UA_TYPES_REDUNDANCYSUPPORT]);
  744. /* Remove unused subtypes of ServerRedundancy */
  745. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERREDUNDANCY_CURRENTSERVERID), true);
  746. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERREDUNDANCY_REDUNDANTSERVERARRAY), true);
  747. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERREDUNDANCY_SERVERURIARRAY), true);
  748. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERREDUNDANCY_SERVERNETWORKGROUPS), true);
  749. /* ServerCapabilities - LocaleIdArray */
  750. UA_LocaleId locale_en = UA_STRING("en");
  751. retVal |= writeNs0VariableArray(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_LOCALEIDARRAY,
  752. &locale_en, 1, &UA_TYPES[UA_TYPES_LOCALEID]);
  753. /* ServerCapabilities - MaxBrowseContinuationPoints */
  754. UA_UInt16 maxBrowseContinuationPoints = UA_MAXCONTINUATIONPOINTS;
  755. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXBROWSECONTINUATIONPOINTS,
  756. &maxBrowseContinuationPoints, &UA_TYPES[UA_TYPES_UINT16]);
  757. /* ServerProfileArray */
  758. UA_String profileArray[3];
  759. UA_UInt16 profileArraySize = 0;
  760. #define ADDPROFILEARRAY(x) profileArray[profileArraySize++] = UA_STRING(x)
  761. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/MicroEmbeddedDevice");
  762. #ifdef UA_ENABLE_NODEMANAGEMENT
  763. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/NodeManagement");
  764. #endif
  765. #ifdef UA_ENABLE_METHODCALLS
  766. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/Methods");
  767. #endif
  768. retVal |= writeNs0VariableArray(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_SERVERPROFILEARRAY,
  769. profileArray, profileArraySize, &UA_TYPES[UA_TYPES_STRING]);
  770. /* ServerCapabilities - MaxQueryContinuationPoints */
  771. UA_UInt16 maxQueryContinuationPoints = 0;
  772. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXQUERYCONTINUATIONPOINTS,
  773. &maxQueryContinuationPoints, &UA_TYPES[UA_TYPES_UINT16]);
  774. /* ServerCapabilities - MaxHistoryContinuationPoints */
  775. UA_UInt16 maxHistoryContinuationPoints = 0;
  776. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXHISTORYCONTINUATIONPOINTS,
  777. &maxHistoryContinuationPoints, &UA_TYPES[UA_TYPES_UINT16]);
  778. /* ServerCapabilities - MinSupportedSampleRate */
  779. UA_DataSource samplingInterval = {readMinSamplingInterval, NULL};
  780. retVal |= UA_Server_setVariableNode_dataSource(server,
  781. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MINSUPPORTEDSAMPLERATE),
  782. samplingInterval);
  783. /* ServerCapabilities - OperationLimits - MaxNodesPerRead */
  784. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERREAD,
  785. &server->config.maxNodesPerRead, &UA_TYPES[UA_TYPES_UINT32]);
  786. /* ServerCapabilities - OperationLimits - maxNodesPerWrite */
  787. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERWRITE,
  788. &server->config.maxNodesPerWrite, &UA_TYPES[UA_TYPES_UINT32]);
  789. /* ServerCapabilities - OperationLimits - MaxNodesPerMethodCall */
  790. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERMETHODCALL,
  791. &server->config.maxNodesPerMethodCall, &UA_TYPES[UA_TYPES_UINT32]);
  792. /* ServerCapabilities - OperationLimits - MaxNodesPerBrowse */
  793. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERBROWSE,
  794. &server->config.maxNodesPerBrowse, &UA_TYPES[UA_TYPES_UINT32]);
  795. /* ServerCapabilities - OperationLimits - MaxNodesPerRegisterNodes */
  796. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERREGISTERNODES,
  797. &server->config.maxNodesPerRegisterNodes, &UA_TYPES[UA_TYPES_UINT32]);
  798. /* ServerCapabilities - OperationLimits - MaxNodesPerTranslateBrowsePathsToNodeIds */
  799. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERTRANSLATEBROWSEPATHSTONODEIDS,
  800. &server->config.maxNodesPerTranslateBrowsePathsToNodeIds, &UA_TYPES[UA_TYPES_UINT32]);
  801. /* ServerCapabilities - OperationLimits - MaxNodesPerNodeManagement */
  802. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERNODEMANAGEMENT,
  803. &server->config.maxNodesPerNodeManagement, &UA_TYPES[UA_TYPES_UINT32]);
  804. /* ServerCapabilities - OperationLimits - MaxMonitoredItemsPerCall */
  805. retVal |= writeNs0Variable(server, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXMONITOREDITEMSPERCALL,
  806. &server->config.maxMonitoredItemsPerCall, &UA_TYPES[UA_TYPES_UINT32]);
  807. #ifdef UA_ENABLE_MICRO_EMB_DEV_PROFILE
  808. /* Remove unused operation limit components */
  809. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERHISTORYREADDATA), true);
  810. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERHISTORYREADEVENTS), true);
  811. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERHISTORYUPDATEDATA), true);
  812. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_OPERATIONLIMITS_MAXNODESPERHISTORYUPDATEEVENTS), true);
  813. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_ROLESET), true);
  814. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXSTRINGLENGTH), true);
  815. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXARRAYLENGTH), true);
  816. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXBYTESTRINGLENGTH), true);
  817. /* Remove not supported Server Instance */
  818. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_DICTIONARIES), true);
  819. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_ESTIMATEDRETURNTIME), true);
  820. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_LOCALTIME), true);
  821. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_PUBLISHSUBSCRIBE), true);
  822. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACES), true);
  823. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_REQUESTSERVERSTATECHANGE), true);
  824. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_RESENDDATA), true);
  825. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVERCONFIGURATION), true);
  826. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SETSUBSCRIPTIONDURABLE), true);
  827. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_SAMPLINGINTERVALDIAGNOSTICSARRAY), true);
  828. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_SESSIONSDIAGNOSTICSSUMMARY), true);
  829. /* Removing these NodeIds make Server Object to be non-complaint with UA 1.03 in CTT (Base Inforamtion/Base Info Core Structure/ 001.js)
  830. * In the 1.04 specification this has been resolved by allowing to remove these static nodes as well */
  831. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_SERVERDIAGNOSTICSSUMMARY), true);
  832. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_SUBSCRIPTIONDIAGNOSTICSARRAY), true);
  833. #endif
  834. #ifndef UA_ENABLE_HISTORIZING
  835. UA_Server_deleteNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_HISTORYSERVERCAPABILITIES), true);
  836. #else
  837. /* ServerCapabilities - HistoryServerCapabilities - AccessHistoryDataCapability */
  838. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_ACCESSHISTORYDATACAPABILITY,
  839. &server->config.accessHistoryDataCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  840. /* ServerCapabilities - HistoryServerCapabilities - MaxReturnDataValues */
  841. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_MAXRETURNDATAVALUES,
  842. &server->config.maxReturnDataValues, &UA_TYPES[UA_TYPES_UINT32]);
  843. /* ServerCapabilities - HistoryServerCapabilities - AccessHistoryEventsCapability */
  844. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_ACCESSHISTORYEVENTSCAPABILITY,
  845. &server->config.accessHistoryEventsCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  846. /* ServerCapabilities - HistoryServerCapabilities - MaxReturnEventValues */
  847. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_MAXRETURNEVENTVALUES,
  848. &server->config.maxReturnEventValues, &UA_TYPES[UA_TYPES_UINT32]);
  849. /* ServerCapabilities - HistoryServerCapabilities - InsertDataCapability */
  850. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_INSERTDATACAPABILITY,
  851. &server->config.insertDataCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  852. /* ServerCapabilities - HistoryServerCapabilities - InsertEventCapability */
  853. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_INSERTEVENTCAPABILITY,
  854. &server->config.insertEventCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  855. /* ServerCapabilities - HistoryServerCapabilities - InsertAnnotationsCapability */
  856. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_INSERTANNOTATIONCAPABILITY,
  857. &server->config.insertAnnotationsCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  858. /* ServerCapabilities - HistoryServerCapabilities - ReplaceDataCapability */
  859. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_REPLACEDATACAPABILITY,
  860. &server->config.replaceDataCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  861. /* ServerCapabilities - HistoryServerCapabilities - ReplaceEventCapability */
  862. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_REPLACEEVENTCAPABILITY,
  863. &server->config.replaceEventCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  864. /* ServerCapabilities - HistoryServerCapabilities - UpdateDataCapability */
  865. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_UPDATEDATACAPABILITY,
  866. &server->config.updateDataCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  867. /* ServerCapabilities - HistoryServerCapabilities - UpdateEventCapability */
  868. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_UPDATEEVENTCAPABILITY,
  869. &server->config.updateEventCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  870. /* ServerCapabilities - HistoryServerCapabilities - DeleteRawCapability */
  871. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_DELETERAWCAPABILITY,
  872. &server->config.deleteRawCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  873. /* ServerCapabilities - HistoryServerCapabilities - DeleteEventCapability */
  874. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_DELETEEVENTCAPABILITY,
  875. &server->config.deleteEventCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  876. /* ServerCapabilities - HistoryServerCapabilities - DeleteAtTimeDataCapability */
  877. retVal |= writeNs0Variable(server, UA_NS0ID_HISTORYSERVERCAPABILITIES_DELETEATTIMECAPABILITY,
  878. &server->config.deleteAtTimeDataCapability, &UA_TYPES[UA_TYPES_BOOLEAN]);
  879. #endif
  880. #if defined(UA_ENABLE_METHODCALLS) && defined(UA_ENABLE_SUBSCRIPTIONS)
  881. retVal |= UA_Server_setMethodNode_callback(server,
  882. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_GETMONITOREDITEMS), readMonitoredItems);
  883. #endif
  884. /* The HasComponent references to the ModellingRules are not part of the
  885. * Nodeset2.xml. So we add the references manually. */
  886. addModellingRules(server);
  887. #endif /* UA_GENERATED_NAMESPACE_ZERO */
  888. /* create the OverFlowEventType
  889. * The EventQueueOverflowEventType is defined as abstract, therefore we can not create an instance of that type
  890. * directly, but need to create a subtype. This is already posted on the OPC Foundation bug tracker under the
  891. * following link for clarification: https://opcfoundation-onlineapplications.org/mantis/view.php?id=4206 */
  892. #ifdef UA_ENABLE_SUBSCRIPTIONS_EVENTS
  893. UA_ObjectTypeAttributes overflowAttr = UA_ObjectTypeAttributes_default;
  894. overflowAttr.description = UA_LOCALIZEDTEXT("en-US", "A simple event for indicating a queue overflow.");
  895. overflowAttr.displayName = UA_LOCALIZEDTEXT("en-US", "SimpleOverflowEventType");
  896. retVal |= UA_Server_addObjectTypeNode(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SIMPLEOVERFLOWEVENTTYPE),
  897. UA_NODEID_NUMERIC(0, UA_NS0ID_EVENTQUEUEOVERFLOWEVENTTYPE),
  898. UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE),
  899. UA_QUALIFIEDNAME(0, "SimpleOverflowEventType"),
  900. overflowAttr, NULL, NULL);
  901. #endif
  902. if(retVal != UA_STATUSCODE_GOOD) {
  903. UA_LOG_ERROR(&server->config.logger, UA_LOGCATEGORY_SERVER,
  904. "Initialization of Namespace 0 (after bootstrapping) "
  905. "failed with %s. See previous outputs for any error messages.",
  906. UA_StatusCode_name(retVal));
  907. return UA_STATUSCODE_BADINTERNALERROR;
  908. }
  909. return UA_STATUSCODE_GOOD;
  910. }