ua_server.c 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777
  1. #include "ua_types.h"
  2. #include "ua_server_internal.h"
  3. #include "ua_securechannel_manager.h"
  4. #include "ua_session_manager.h"
  5. #include "ua_util.h"
  6. #include "ua_services.h"
  7. #include "ua_nodeids.h"
  8. const char *UA_LoggerCategoryNames[3] = {"communication", "server", "userland"};
  9. /**********************/
  10. /* Namespace Handling */
  11. /**********************/
  12. static void UA_ExternalNamespace_init(UA_ExternalNamespace *ens) {
  13. ens->index = 0;
  14. UA_String_init(&ens->url);
  15. }
  16. static void UA_ExternalNamespace_deleteMembers(UA_ExternalNamespace *ens) {
  17. UA_String_deleteMembers(&ens->url);
  18. ens->externalNodeStore.destroy(ens->externalNodeStore.ensHandle);
  19. }
  20. /*****************/
  21. /* Configuration */
  22. /*****************/
  23. void UA_Server_addNetworkLayer(UA_Server *server, UA_ServerNetworkLayer networkLayer) {
  24. UA_ServerNetworkLayer *newlayers = UA_realloc(server->nls, sizeof(UA_ServerNetworkLayer)*(server->nlsSize+1));
  25. if(!newlayers) {
  26. UA_LOG_ERROR(server->logger, UA_LOGGERCATEGORY_SERVER, "Networklayer added");
  27. return;
  28. }
  29. server->nls = newlayers;
  30. server->nls[server->nlsSize] = networkLayer;
  31. server->nlsSize++;
  32. if(networkLayer.discoveryUrl){
  33. if(server->description.discoveryUrlsSize < 0)
  34. server->description.discoveryUrlsSize = 0;
  35. UA_String* newUrls = UA_realloc(server->description.discoveryUrls,
  36. sizeof(UA_String)*(server->description.discoveryUrlsSize+1));
  37. if(!newUrls) {
  38. UA_LOG_ERROR(server->logger, UA_LOGGERCATEGORY_SERVER, "Adding discoveryUrl");
  39. return;
  40. }
  41. server->description.discoveryUrls = newUrls;
  42. UA_String_copy(networkLayer.discoveryUrl,
  43. &server->description.discoveryUrls[server->description.discoveryUrlsSize]);
  44. server->description.discoveryUrlsSize++;
  45. }
  46. }
  47. void UA_Server_setServerCertificate(UA_Server *server, UA_ByteString certificate) {
  48. for(UA_Int32 i=0;i<server->endpointDescriptionsSize;i++)
  49. UA_ByteString_copy(&certificate, &server->endpointDescriptions[i].serverCertificate);
  50. }
  51. void UA_Server_setLogger(UA_Server *server, UA_Logger logger) {
  52. server->logger = logger;
  53. }
  54. /**********/
  55. /* Server */
  56. /**********/
  57. void UA_Server_delete(UA_Server *server) {
  58. // The server needs to be stopped before it can be deleted
  59. // Delete all internal data
  60. UA_ApplicationDescription_deleteMembers(&server->description);
  61. UA_SecureChannelManager_deleteMembers(&server->secureChannelManager);
  62. UA_SessionManager_deleteMembers(&server->sessionManager);
  63. UA_NodeStore_delete(server->nodestore);
  64. UA_ByteString_deleteMembers(&server->serverCertificate);
  65. UA_Array_delete(server->endpointDescriptions, &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION], server->endpointDescriptionsSize);
  66. // Delete the timed work
  67. UA_Server_deleteTimedWork(server);
  68. // Delete the network layers
  69. for(UA_Int32 i=0;i<server->nlsSize;i++) {
  70. server->nls[i].free(server->nls[i].nlHandle);
  71. }
  72. UA_free(server->nls);
  73. #ifdef UA_MULTITHREADING
  74. pthread_cond_destroy(&server->dispatchQueue_condition); // so the workers don't spin if the queue is empty
  75. rcu_barrier(); // wait for all scheduled call_rcu work to complete
  76. #endif
  77. UA_free(server);
  78. }
  79. static UA_StatusCode readStatus(const void *handle, UA_Boolean sourceTimeStamp, UA_DataValue *value) {
  80. UA_ServerStatusDataType *status = UA_ServerStatusDataType_new();
  81. status->startTime = ((const UA_Server*)handle)->startTime;
  82. status->currentTime = UA_DateTime_now();
  83. status->state = UA_SERVERSTATE_RUNNING;
  84. status->buildInfo.productUri = UA_STRING_ALLOC("http://www.open62541.org");
  85. status->buildInfo.manufacturerName = UA_STRING_ALLOC("open62541");
  86. status->buildInfo.productName = UA_STRING_ALLOC("open62541 OPC UA Server");
  87. #define STRINGIFY(x) #x //some magic
  88. #define TOSTRING(x) STRINGIFY(x) //some magic
  89. status->buildInfo.softwareVersion = UA_STRING_ALLOC(TOSTRING(OPEN62541_VERSION_MAJOR) "." TOSTRING(OPEN62541_VERSION_MINOR) "." TOSTRING(OPEN62541_VERSION_PATCH));
  90. status->buildInfo.buildNumber = UA_STRING_ALLOC("0");
  91. status->buildInfo.buildDate = ((const UA_Server*)handle)->buildDate;
  92. status->secondsTillShutdown = 0;
  93. value->value.type = &UA_TYPES[UA_TYPES_SERVERSTATUSDATATYPE];
  94. value->value.arrayLength = -1;
  95. value->value.data = status;
  96. value->value.arrayDimensionsSize = -1;
  97. value->value.arrayDimensions = UA_NULL;
  98. value->hasValue = UA_TRUE;
  99. if(sourceTimeStamp) {
  100. value->hasSourceTimestamp = UA_TRUE;
  101. value->sourceTimestamp = UA_DateTime_now();
  102. }
  103. return UA_STATUSCODE_GOOD;
  104. }
  105. static void releaseStatus(const void *handle, UA_DataValue *value) {
  106. UA_DataValue_deleteMembers(value);
  107. }
  108. static UA_StatusCode readCurrentTime(const void *handle, UA_Boolean sourceTimeStamp, UA_DataValue *value) {
  109. UA_DateTime *currentTime = UA_DateTime_new();
  110. if(!currentTime)
  111. return UA_STATUSCODE_BADOUTOFMEMORY;
  112. *currentTime = UA_DateTime_now();
  113. value->value.type = &UA_TYPES[UA_TYPES_DATETIME];
  114. value->value.arrayLength = -1;
  115. value->value.data = currentTime;
  116. value->value.arrayDimensionsSize = -1;
  117. value->value.arrayDimensions = NULL;
  118. value->hasValue = UA_TRUE;
  119. if(sourceTimeStamp) {
  120. value->hasSourceTimestamp = UA_TRUE;
  121. value->sourceTimestamp = *currentTime;
  122. }
  123. return UA_STATUSCODE_GOOD;
  124. }
  125. static void releaseCurrentTime(const void *handle, UA_DataValue *value) {
  126. UA_DateTime_delete((UA_DateTime*)value->value.data);
  127. }
  128. static void copyNames(UA_Node *node, char *name) {
  129. node->browseName = UA_QUALIFIEDNAME_ALLOC(0, name);
  130. node->displayName = UA_LOCALIZEDTEXT_ALLOC("", name);
  131. node->description = UA_LOCALIZEDTEXT_ALLOC("", name);
  132. }
  133. static void addDataTypeNode(UA_Server *server, char* name, UA_UInt32 datatypeid, UA_Int32 parent) {
  134. UA_DataTypeNode *datatype = UA_DataTypeNode_new();
  135. copyNames((UA_Node*)datatype, name);
  136. datatype->nodeId.identifier.numeric = datatypeid;
  137. UA_Server_addNode(server, (UA_Node*)datatype,
  138. &UA_EXPANDEDNODEID_NUMERIC(0, parent),
  139. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  140. }
  141. static UA_VariableTypeNode* createVariableTypeNode(UA_Server *server, char* name, UA_UInt32 variabletypeid, UA_Int32 parent, UA_Boolean abstract) {
  142. UA_VariableTypeNode *variabletype = UA_VariableTypeNode_new();
  143. copyNames((UA_Node*)variabletype, name);
  144. variabletype->nodeId.identifier.numeric = variabletypeid;
  145. variabletype->isAbstract = abstract;
  146. variabletype->value.variant.type = &UA_TYPES[UA_TYPES_VARIANT];
  147. return variabletype;
  148. }
  149. static void addVariableTypeNode_organized(UA_Server *server, char* name, UA_UInt32 variabletypeid, UA_Int32 parent, UA_Boolean abstract) {
  150. UA_VariableTypeNode *variabletype = createVariableTypeNode(server, name, variabletypeid, parent, abstract);
  151. UA_Server_addNode(server, (UA_Node*)variabletype,
  152. &UA_EXPANDEDNODEID_NUMERIC(0, parent),
  153. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  154. }
  155. static void addVariableTypeNode_subtype(UA_Server *server, char* name, UA_UInt32 variabletypeid, UA_Int32 parent, UA_Boolean abstract) {
  156. UA_VariableTypeNode *variabletype = createVariableTypeNode(server, name, variabletypeid, parent, abstract);
  157. UA_Server_addNode(server, (UA_Node*)variabletype,
  158. &UA_EXPANDEDNODEID_NUMERIC(0, parent),
  159. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  160. }
  161. UA_Server * UA_Server_new(void) {
  162. UA_Server *server = UA_malloc(sizeof(UA_Server));
  163. if(!server)
  164. return UA_NULL;
  165. LIST_INIT(&server->timedWork);
  166. #ifdef UA_MULTITHREADING
  167. rcu_init();
  168. cds_wfcq_init(&server->dispatchQueue_head, &server->dispatchQueue_tail);
  169. server->delayedWork = UA_NULL;
  170. #endif
  171. // logger
  172. server->logger = (UA_Logger){ UA_NULL, UA_NULL, UA_NULL, UA_NULL, UA_NULL, UA_NULL };
  173. // random seed
  174. server->random_seed = (UA_UInt32)UA_DateTime_now();
  175. // networklayers
  176. server->nls = UA_NULL;
  177. server->nlsSize = 0;
  178. UA_ByteString_init(&server->serverCertificate);
  179. #define PRODUCT_URI "http://open62541.org"
  180. #define APPLICATION_URI "urn:unconfigured:open62541:open62541Server"
  181. // mockup application description
  182. UA_ApplicationDescription_init(&server->description);
  183. server->description.productUri = UA_STRING_ALLOC(PRODUCT_URI);
  184. server->description.applicationUri = UA_STRING_ALLOC(APPLICATION_URI);
  185. server->description.discoveryUrlsSize = 0;
  186. server->description.applicationName = UA_LOCALIZEDTEXT_ALLOC("", "Unconfigured open62541 application");
  187. server->description.applicationType = UA_APPLICATIONTYPE_SERVER;
  188. server->externalNamespacesSize = 0;
  189. server->externalNamespaces = UA_NULL;
  190. server->endpointDescriptions = UA_NULL;
  191. server->endpointDescriptionsSize = 0;
  192. UA_EndpointDescription *endpoint = UA_EndpointDescription_new(); // todo: check return code
  193. if(endpoint) {
  194. endpoint->securityMode = UA_MESSAGESECURITYMODE_NONE;
  195. endpoint->securityPolicyUri = UA_STRING_ALLOC("http://opcfoundation.org/UA/SecurityPolicy#None");
  196. endpoint->transportProfileUri = UA_STRING_ALLOC("http://opcfoundation.org/UA-Profile/Transport/uatcp-uasc-uabinary");
  197. endpoint->userIdentityTokensSize = 2;
  198. endpoint->userIdentityTokens = UA_Array_new(&UA_TYPES[UA_TYPES_USERTOKENPOLICY], 2);
  199. UA_UserTokenPolicy_init(&endpoint->userIdentityTokens[0]);
  200. endpoint->userIdentityTokens[0].tokenType = UA_USERTOKENTYPE_ANONYMOUS;
  201. endpoint->userIdentityTokens[0].policyId = UA_STRING_ALLOC("my-anonymous-policy"); // defined per server
  202. UA_UserTokenPolicy_init(&endpoint->userIdentityTokens[1]);
  203. endpoint->userIdentityTokens[1].tokenType = UA_USERTOKENTYPE_USERNAME;
  204. endpoint->userIdentityTokens[1].policyId = UA_STRING_ALLOC("my-username-policy"); // defined per server
  205. /* UA_String_copy(endpointUrl, &endpoint->endpointUrl); */
  206. /* /\* The standard says "the HostName specified in the Server Certificate is the */
  207. /* same as the HostName contained in the endpointUrl provided in the */
  208. /* EndpointDescription *\/ */
  209. /* UA_String_copy(&server->serverCertificate, &endpoint->serverCertificate); */
  210. UA_ApplicationDescription_copy(&server->description, &endpoint->server);
  211. server->endpointDescriptions = endpoint;
  212. server->endpointDescriptionsSize = 1;
  213. }
  214. #define MAXCHANNELCOUNT 100
  215. #define STARTCHANNELID 1
  216. #define TOKENLIFETIME 600000
  217. #define STARTTOKENID 1
  218. UA_SecureChannelManager_init(&server->secureChannelManager, MAXCHANNELCOUNT,
  219. TOKENLIFETIME, STARTCHANNELID, STARTTOKENID);
  220. #define MAXSESSIONCOUNT 1000
  221. #define MAXSESSIONLIFETIME 10000
  222. #define STARTSESSIONID 1
  223. UA_SessionManager_init(&server->sessionManager, MAXSESSIONCOUNT, MAXSESSIONLIFETIME, STARTSESSIONID);
  224. server->nodestore = UA_NodeStore_new();
  225. /**************/
  226. /* References */
  227. /**************/
  228. /* bootstrap by manually inserting "references" and "hassubtype" */
  229. UA_ReferenceTypeNode *references = UA_ReferenceTypeNode_new();
  230. copyNames((UA_Node*)references, "References");
  231. references->nodeId.identifier.numeric = UA_NS0ID_REFERENCES;
  232. references->isAbstract = UA_TRUE;
  233. references->symmetric = UA_TRUE;
  234. // this node has no parent??
  235. UA_NodeStore_insert(server->nodestore, (UA_Node*)references, UA_NULL);
  236. UA_ReferenceTypeNode *hassubtype = UA_ReferenceTypeNode_new();
  237. copyNames((UA_Node*)hassubtype, "HasSubtype");
  238. hassubtype->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "HasSupertype");
  239. hassubtype->nodeId.identifier.numeric = UA_NS0ID_HASSUBTYPE;
  240. hassubtype->isAbstract = UA_FALSE;
  241. hassubtype->symmetric = UA_FALSE;
  242. UA_NodeStore_insert(server->nodestore, (UA_Node*)hassubtype, UA_NULL);
  243. /* continue adding reference types with normal "addnode" */
  244. UA_ReferenceTypeNode *hierarchicalreferences = UA_ReferenceTypeNode_new();
  245. copyNames((UA_Node*)hierarchicalreferences, "Hierarchicalreferences");
  246. hierarchicalreferences->nodeId.identifier.numeric = UA_NS0ID_HIERARCHICALREFERENCES;
  247. hierarchicalreferences->isAbstract = UA_TRUE;
  248. hierarchicalreferences->symmetric = UA_FALSE;
  249. UA_Server_addNode(server, (UA_Node*)hierarchicalreferences,
  250. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_REFERENCES),
  251. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  252. UA_ReferenceTypeNode *nonhierarchicalreferences = UA_ReferenceTypeNode_new();
  253. copyNames((UA_Node*)nonhierarchicalreferences, "NonHierarchicalReferences");
  254. nonhierarchicalreferences->nodeId.identifier.numeric = UA_NS0ID_NONHIERARCHICALREFERENCES;
  255. nonhierarchicalreferences->isAbstract = UA_TRUE;
  256. nonhierarchicalreferences->symmetric = UA_FALSE;
  257. UA_Server_addNode(server, (UA_Node*)nonhierarchicalreferences,
  258. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_REFERENCES),
  259. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  260. UA_ReferenceTypeNode *haschild = UA_ReferenceTypeNode_new();
  261. copyNames((UA_Node*)haschild, "HasChild");
  262. haschild->nodeId.identifier.numeric = UA_NS0ID_HASCHILD;
  263. haschild->isAbstract = UA_TRUE;
  264. haschild->symmetric = UA_FALSE;
  265. UA_Server_addNode(server, (UA_Node*)haschild,
  266. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES),
  267. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  268. UA_ReferenceTypeNode *organizes = UA_ReferenceTypeNode_new();
  269. copyNames((UA_Node*)organizes, "Organizes");
  270. organizes->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "OrganizedBy");
  271. organizes->nodeId.identifier.numeric = UA_NS0ID_ORGANIZES;
  272. organizes->isAbstract = UA_FALSE;
  273. organizes->symmetric = UA_FALSE;
  274. UA_Server_addNode(server, (UA_Node*)organizes,
  275. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES),
  276. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  277. UA_ReferenceTypeNode *haseventsource = UA_ReferenceTypeNode_new();
  278. copyNames((UA_Node*)haseventsource, "HasEventSource");
  279. haseventsource->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "EventSourceOf");
  280. haseventsource->nodeId.identifier.numeric = UA_NS0ID_HASEVENTSOURCE;
  281. haseventsource->isAbstract = UA_FALSE;
  282. haseventsource->symmetric = UA_FALSE;
  283. UA_Server_addNode(server, (UA_Node*)haseventsource,
  284. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES),
  285. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  286. UA_ReferenceTypeNode *hasmodellingrule = UA_ReferenceTypeNode_new();
  287. copyNames((UA_Node*)hasmodellingrule, "HasModellingRule");
  288. hasmodellingrule->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "ModellingRuleOf");
  289. hasmodellingrule->nodeId.identifier.numeric = UA_NS0ID_HASMODELLINGRULE;
  290. hasmodellingrule->isAbstract = UA_FALSE;
  291. hasmodellingrule->symmetric = UA_FALSE;
  292. UA_Server_addNode(server, (UA_Node*)hasmodellingrule,
  293. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  294. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  295. UA_ReferenceTypeNode *hasencoding = UA_ReferenceTypeNode_new();
  296. copyNames((UA_Node*)hasencoding, "HasEncoding");
  297. hasencoding->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "EncodingOf");
  298. hasencoding->nodeId.identifier.numeric = UA_NS0ID_HASENCODING;
  299. hasencoding->isAbstract = UA_FALSE;
  300. hasencoding->symmetric = UA_FALSE;
  301. UA_Server_addNode(server, (UA_Node*)hasencoding,
  302. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  303. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  304. UA_ReferenceTypeNode *hasdescription = UA_ReferenceTypeNode_new();
  305. copyNames((UA_Node*)hasdescription, "HasDescription");
  306. hasdescription->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "DescriptionOf");
  307. hasdescription->nodeId.identifier.numeric = UA_NS0ID_HASDESCRIPTION;
  308. hasdescription->isAbstract = UA_FALSE;
  309. hasdescription->symmetric = UA_FALSE;
  310. UA_Server_addNode(server, (UA_Node*)hasdescription,
  311. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  312. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  313. UA_ReferenceTypeNode *hastypedefinition = UA_ReferenceTypeNode_new();
  314. copyNames((UA_Node*)hastypedefinition, "HasTypeDefinition");
  315. hastypedefinition->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "TypeDefinitionOf");
  316. hastypedefinition->nodeId.identifier.numeric = UA_NS0ID_HASTYPEDEFINITION;
  317. hastypedefinition->isAbstract = UA_FALSE;
  318. hastypedefinition->symmetric = UA_FALSE;
  319. UA_Server_addNode(server, (UA_Node*)hastypedefinition,
  320. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  321. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  322. UA_ReferenceTypeNode *generatesevent = UA_ReferenceTypeNode_new();
  323. copyNames((UA_Node*)generatesevent, "GeneratesEvent");
  324. generatesevent->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "GeneratedBy");
  325. generatesevent->nodeId.identifier.numeric = UA_NS0ID_GENERATESEVENT;
  326. generatesevent->isAbstract = UA_FALSE;
  327. generatesevent->symmetric = UA_FALSE;
  328. UA_Server_addNode(server, (UA_Node*)generatesevent,
  329. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  330. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  331. UA_ReferenceTypeNode *aggregates = UA_ReferenceTypeNode_new();
  332. copyNames((UA_Node*)aggregates, "Aggregates");
  333. // Todo: Is there an inverse name?
  334. aggregates->nodeId.identifier.numeric = UA_NS0ID_AGGREGATES;
  335. aggregates->isAbstract = UA_TRUE;
  336. aggregates->symmetric = UA_FALSE;
  337. UA_Server_addNode(server, (UA_Node*)aggregates,
  338. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HASCHILD),
  339. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  340. // complete bootstrap of hassubtype
  341. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_HASCHILD), UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE),
  342. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  343. UA_ReferenceTypeNode *hasproperty = UA_ReferenceTypeNode_new();
  344. copyNames((UA_Node*)hasproperty, "HasProperty");
  345. hasproperty->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "PropertyOf");
  346. hasproperty->nodeId.identifier.numeric = UA_NS0ID_HASPROPERTY;
  347. hasproperty->isAbstract = UA_FALSE;
  348. hasproperty->symmetric = UA_FALSE;
  349. UA_Server_addNode(server, (UA_Node*)hasproperty,
  350. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_AGGREGATES),
  351. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  352. UA_ReferenceTypeNode *hascomponent = UA_ReferenceTypeNode_new();
  353. copyNames((UA_Node*)hascomponent, "HasComponent");
  354. hascomponent->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "ComponentOf");
  355. hascomponent->nodeId.identifier.numeric = UA_NS0ID_HASCOMPONENT;
  356. hascomponent->isAbstract = UA_FALSE;
  357. hascomponent->symmetric = UA_FALSE;
  358. UA_Server_addNode(server, (UA_Node*)hascomponent,
  359. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_AGGREGATES),
  360. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  361. UA_ReferenceTypeNode *hasnotifier = UA_ReferenceTypeNode_new();
  362. copyNames((UA_Node*)hasnotifier, "HasNotifier");
  363. hasnotifier->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "NotifierOf");
  364. hasnotifier->nodeId.identifier.numeric = UA_NS0ID_HASNOTIFIER;
  365. hasnotifier->isAbstract = UA_FALSE;
  366. hasnotifier->symmetric = UA_FALSE;
  367. UA_Server_addNode(server, (UA_Node*)hasnotifier,
  368. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HASEVENTSOURCE),
  369. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  370. UA_ReferenceTypeNode *hasorderedcomponent = UA_ReferenceTypeNode_new();
  371. copyNames((UA_Node*)hasorderedcomponent, "HasOrderedComponent");
  372. hasorderedcomponent->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "OrderedComponentOf");
  373. hasorderedcomponent->nodeId.identifier.numeric = UA_NS0ID_HASORDEREDCOMPONENT;
  374. hasorderedcomponent->isAbstract = UA_FALSE;
  375. hasorderedcomponent->symmetric = UA_FALSE;
  376. UA_Server_addNode(server, (UA_Node*)hasorderedcomponent,
  377. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  378. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  379. UA_ReferenceTypeNode *hasmodelparent = UA_ReferenceTypeNode_new();
  380. copyNames((UA_Node*)hasmodelparent, "HasModelParent");
  381. hasmodelparent->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "ModelParentOf");
  382. hasmodelparent->nodeId.identifier.numeric = UA_NS0ID_HASMODELPARENT;
  383. hasmodelparent->isAbstract = UA_FALSE;
  384. hasmodelparent->symmetric = UA_FALSE;
  385. UA_Server_addNode(server, (UA_Node*)hasmodelparent,
  386. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  387. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  388. UA_ReferenceTypeNode *fromstate = UA_ReferenceTypeNode_new();
  389. copyNames((UA_Node*)fromstate, "FromState");
  390. fromstate->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "ToTransition");
  391. fromstate->nodeId.identifier.numeric = UA_NS0ID_FROMSTATE;
  392. fromstate->isAbstract = UA_FALSE;
  393. fromstate->symmetric = UA_FALSE;
  394. UA_Server_addNode(server, (UA_Node*)fromstate,
  395. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  396. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  397. UA_ReferenceTypeNode *tostate = UA_ReferenceTypeNode_new();
  398. copyNames((UA_Node*)tostate, "ToState");
  399. tostate->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "FromTransition");
  400. tostate->nodeId.identifier.numeric = UA_NS0ID_TOSTATE;
  401. tostate->isAbstract = UA_FALSE;
  402. tostate->symmetric = UA_FALSE;
  403. UA_Server_addNode(server, (UA_Node*)tostate,
  404. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  405. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  406. UA_ReferenceTypeNode *hascause = UA_ReferenceTypeNode_new();
  407. copyNames((UA_Node*)hascause, "HasCause");
  408. hascause->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "MayBeCausedBy");
  409. hascause->nodeId.identifier.numeric = UA_NS0ID_HASCAUSE;
  410. hascause->isAbstract = UA_FALSE;
  411. hascause->symmetric = UA_FALSE;
  412. UA_Server_addNode(server, (UA_Node*)hascause,
  413. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  414. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  415. UA_ReferenceTypeNode *haseffect = UA_ReferenceTypeNode_new();
  416. copyNames((UA_Node*)haseffect, "HasEffect");
  417. haseffect->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "MayBeEffectedBy");
  418. haseffect->nodeId.identifier.numeric = UA_NS0ID_HASEFFECT;
  419. haseffect->isAbstract = UA_FALSE;
  420. haseffect->symmetric = UA_FALSE;
  421. UA_Server_addNode(server, (UA_Node*)haseffect,
  422. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  423. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  424. UA_ReferenceTypeNode *hashistoricalconfiguration = UA_ReferenceTypeNode_new();
  425. copyNames((UA_Node*)hashistoricalconfiguration, "HasHistoricalConfiguration");
  426. hashistoricalconfiguration->inverseName = UA_LOCALIZEDTEXT_ALLOC("", "HistoricalConfigurationOf");
  427. hashistoricalconfiguration->nodeId.identifier.numeric = UA_NS0ID_HASHISTORICALCONFIGURATION;
  428. hashistoricalconfiguration->isAbstract = UA_FALSE;
  429. hashistoricalconfiguration->symmetric = UA_FALSE;
  430. UA_Server_addNode(server, (UA_Node*)hashistoricalconfiguration,
  431. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_AGGREGATES),
  432. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE));
  433. /**********************/
  434. /* Basic Object Types */
  435. /**********************/
  436. UA_ObjectTypeNode *baseObjectType = UA_ObjectTypeNode_new();
  437. baseObjectType->nodeId.identifier.numeric = UA_NS0ID_BASEOBJECTTYPE;
  438. copyNames((UA_Node*)baseObjectType, "BaseObjectType");
  439. UA_NodeStore_insert(server->nodestore, (UA_Node*)baseObjectType, UA_NULL);
  440. UA_ObjectTypeNode *baseDataVarialbeType = UA_ObjectTypeNode_new();
  441. baseDataVarialbeType->nodeId.identifier.numeric = UA_NS0ID_BASEDATAVARIABLETYPE;
  442. copyNames((UA_Node*)baseDataVarialbeType, "BaseDataVariableType");
  443. UA_NodeStore_insert(server->nodestore, (UA_Node*)baseDataVarialbeType, UA_NULL);
  444. UA_ObjectTypeNode *folderType = UA_ObjectTypeNode_new();
  445. folderType->nodeId.identifier.numeric = UA_NS0ID_FOLDERTYPE;
  446. copyNames((UA_Node*)folderType, "FolderType");
  447. UA_NodeStore_insert(server->nodestore, (UA_Node*)folderType, UA_NULL);
  448. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_BASEOBJECTTYPE), UA_NODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE),
  449. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  450. /*****************/
  451. /* Basic Folders */
  452. /*****************/
  453. UA_ObjectNode *root = UA_ObjectNode_new();
  454. copyNames((UA_Node*)root, "Root");
  455. root->nodeId.identifier.numeric = UA_NS0ID_ROOTFOLDER;
  456. UA_NodeStore_insert(server->nodestore, (UA_Node*)root, UA_NULL);
  457. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  458. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  459. UA_ObjectNode *objects = UA_ObjectNode_new();
  460. copyNames((UA_Node*)objects, "Objects");
  461. objects->nodeId.identifier.numeric = UA_NS0ID_OBJECTSFOLDER;
  462. UA_Server_addNode(server, (UA_Node*)objects,
  463. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  464. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  465. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  466. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  467. UA_ObjectNode *types = UA_ObjectNode_new();
  468. copyNames((UA_Node*)types, "Types");
  469. types->nodeId.identifier.numeric = UA_NS0ID_TYPESFOLDER;
  470. UA_Server_addNode(server, (UA_Node*)types,
  471. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  472. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  473. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  474. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  475. UA_ObjectNode *views = UA_ObjectNode_new();
  476. copyNames((UA_Node*)views, "Views");
  477. views->nodeId.identifier.numeric = UA_NS0ID_VIEWSFOLDER;
  478. UA_Server_addNode(server, (UA_Node*)views,
  479. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  480. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  481. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_VIEWSFOLDER), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  482. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  483. /**********************/
  484. /* Further Data Types */
  485. /**********************/
  486. UA_ObjectNode *datatypes = UA_ObjectNode_new();
  487. copyNames((UA_Node*)datatypes, "DataTypes");
  488. datatypes->nodeId.identifier.numeric = UA_NS0ID_DATATYPESFOLDER;
  489. UA_Server_addNode(server, (UA_Node*)datatypes,
  490. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER),
  491. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  492. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_DATATYPESFOLDER), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  493. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  494. addDataTypeNode(server, "BaseDataType", UA_NS0ID_BASEDATATYPE, UA_NS0ID_DATATYPESFOLDER);
  495. addDataTypeNode(server, "Boolean", UA_NS0ID_BOOLEAN, UA_NS0ID_BASEDATATYPE);
  496. addDataTypeNode(server, "Number", UA_NS0ID_NUMBER, UA_NS0ID_BASEDATATYPE);
  497. addDataTypeNode(server, "Float", UA_NS0ID_FLOAT, UA_NS0ID_NUMBER);
  498. addDataTypeNode(server, "Double", UA_NS0ID_DOUBLE, UA_NS0ID_NUMBER);
  499. addDataTypeNode(server, "Integer", UA_NS0ID_INTEGER, UA_NS0ID_NUMBER);
  500. addDataTypeNode(server, "SByte", UA_NS0ID_SBYTE, UA_NS0ID_INTEGER);
  501. addDataTypeNode(server, "Int16", UA_NS0ID_INT16, UA_NS0ID_INTEGER);
  502. addDataTypeNode(server, "Int32", UA_NS0ID_INT32, UA_NS0ID_INTEGER);
  503. addDataTypeNode(server, "Int64", UA_NS0ID_INT64, UA_NS0ID_INTEGER);
  504. addDataTypeNode(server, "UInteger", UA_NS0ID_UINTEGER, UA_NS0ID_INTEGER);
  505. addDataTypeNode(server, "Byte", UA_NS0ID_BYTE, UA_NS0ID_UINTEGER);
  506. addDataTypeNode(server, "UInt16", UA_NS0ID_UINT16, UA_NS0ID_UINTEGER);
  507. addDataTypeNode(server, "UInt32", UA_NS0ID_UINT32, UA_NS0ID_UINTEGER);
  508. addDataTypeNode(server, "UInt64", UA_NS0ID_UINT64, UA_NS0ID_UINTEGER);
  509. addDataTypeNode(server, "String", UA_NS0ID_STRING, UA_NS0ID_BASEDATATYPE);
  510. addDataTypeNode(server, "DateTime", UA_NS0ID_DATETIME, UA_NS0ID_BASEDATATYPE);
  511. addDataTypeNode(server, "Guid", UA_NS0ID_GUID, UA_NS0ID_BASEDATATYPE);
  512. addDataTypeNode(server, "ByteString", UA_NS0ID_BYTESTRING, UA_NS0ID_BASEDATATYPE);
  513. addDataTypeNode(server, "XmlElement", UA_NS0ID_XMLELEMENT, UA_NS0ID_BASEDATATYPE);
  514. addDataTypeNode(server, "NodeId", UA_NS0ID_NODEID, UA_NS0ID_BASEDATATYPE);
  515. addDataTypeNode(server, "ExpandedNodeId", UA_NS0ID_EXPANDEDNODEID, UA_NS0ID_BASEDATATYPE);
  516. addDataTypeNode(server, "StatusCode", UA_NS0ID_STATUSCODE, UA_NS0ID_BASEDATATYPE);
  517. addDataTypeNode(server, "QualifiedName", UA_NS0ID_QUALIFIEDNAME, UA_NS0ID_BASEDATATYPE);
  518. addDataTypeNode(server, "LocalizedText", UA_NS0ID_LOCALIZEDTEXT, UA_NS0ID_BASEDATATYPE);
  519. addDataTypeNode(server, "Structure", UA_NS0ID_STRUCTURE, UA_NS0ID_BASEDATATYPE);
  520. addDataTypeNode(server, "DataValue", UA_NS0ID_DATAVALUE, UA_NS0ID_BASEDATATYPE);
  521. addDataTypeNode(server, "DiagnosticInfo", UA_NS0ID_DIAGNOSTICINFO, UA_NS0ID_BASEDATATYPE);
  522. addDataTypeNode(server, "Enumeration", UA_NS0ID_ENUMERATION, UA_NS0ID_BASEDATATYPE);
  523. addDataTypeNode(server, "ServerState", UA_NS0ID_SERVERSTATE, UA_NS0ID_ENUMERATION);
  524. UA_ObjectNode *variabletypes = UA_ObjectNode_new();
  525. copyNames((UA_Node*)variabletypes, "VariableTypes");
  526. variabletypes->nodeId.identifier.numeric = UA_NS0ID_VARIABLETYPESFOLDER;
  527. UA_Server_addNode(server, (UA_Node*)variabletypes,
  528. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER),
  529. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  530. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_VARIABLETYPESFOLDER), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  531. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  532. addVariableTypeNode_organized(server, "BaseVariableType", UA_NS0ID_BASEVARIABLETYPE, UA_NS0ID_VARIABLETYPESFOLDER, UA_TRUE);
  533. addVariableTypeNode_subtype(server, "PropertyType", UA_NS0ID_PROPERTYTYPE, UA_NS0ID_BASEVARIABLETYPE, UA_FALSE);
  534. /*******************/
  535. /* Further Objects */
  536. /*******************/
  537. UA_ObjectNode *servernode = UA_ObjectNode_new();
  538. copyNames((UA_Node*)servernode, "Server");
  539. servernode->nodeId.identifier.numeric = UA_NS0ID_SERVER;
  540. UA_Server_addNode(server, (UA_Node*)servernode,
  541. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER),
  542. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  543. UA_VariableNode *namespaceArray = UA_VariableNode_new();
  544. copyNames((UA_Node*)namespaceArray, "NamespaceArray");
  545. namespaceArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_NAMESPACEARRAY;
  546. namespaceArray->value.variant.data = UA_Array_new(&UA_TYPES[UA_TYPES_STRING], 2);
  547. namespaceArray->value.variant.arrayLength = 2;
  548. namespaceArray->value.variant.type = &UA_TYPES[UA_TYPES_STRING];
  549. // Fixme: Insert the external namespaces
  550. ((UA_String *)namespaceArray->value.variant.data)[0] = UA_STRING_ALLOC("http://opcfoundation.org/UA/");
  551. ((UA_String *)namespaceArray->value.variant.data)[1] = UA_STRING_ALLOC(APPLICATION_URI);
  552. namespaceArray->valueRank = 1;
  553. namespaceArray->minimumSamplingInterval = 1.0;
  554. namespaceArray->historizing = UA_FALSE;
  555. UA_Server_addNode(server, (UA_Node*)namespaceArray,
  556. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER),
  557. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  558. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACEARRAY),
  559. UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  560. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE));
  561. UA_VariableNode *serverArray = UA_VariableNode_new();
  562. copyNames((UA_Node*)serverArray, "ServerArray");
  563. serverArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERARRAY;
  564. serverArray->value.variant.data = UA_Array_new(&UA_TYPES[UA_TYPES_STRING], 1);
  565. serverArray->value.variant.arrayLength = 1;
  566. serverArray->value.variant.type = &UA_TYPES[UA_TYPES_STRING];
  567. *(UA_String *)serverArray->value.variant.data = UA_STRING_ALLOC(APPLICATION_URI);
  568. serverArray->valueRank = 1;
  569. serverArray->minimumSamplingInterval = 1.0;
  570. serverArray->historizing = UA_FALSE;
  571. UA_Server_addNode(server, (UA_Node*)serverArray,
  572. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER),
  573. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  574. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERARRAY),
  575. UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  576. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE));
  577. UA_ObjectNode *servercapablities = UA_ObjectNode_new();
  578. copyNames((UA_Node*)servercapablities, "ServerCapabilities");
  579. servercapablities->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERCAPABILITIES;
  580. UA_Server_addNode(server, (UA_Node*)servercapablities,
  581. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER),
  582. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT));
  583. UA_VariableNode *localeIdArray = UA_VariableNode_new();
  584. copyNames((UA_Node*)localeIdArray, "LocaleIdArray");
  585. localeIdArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERCAPABILITIES_LOCALEIDARRAY;
  586. localeIdArray->value.variant.data = UA_Array_new(&UA_TYPES[UA_TYPES_STRING], 2);
  587. localeIdArray->value.variant.arrayLength = 2;
  588. localeIdArray->value.variant.type = &UA_TYPES[UA_TYPES_STRING];
  589. *(UA_String *)localeIdArray->value.variant.data = UA_STRING_ALLOC("en");
  590. localeIdArray->valueRank = 1;
  591. localeIdArray->minimumSamplingInterval = 1.0;
  592. localeIdArray->historizing = UA_FALSE;
  593. UA_Server_addNode(server, (UA_Node*)localeIdArray,
  594. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES),
  595. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY));
  596. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_LOCALEIDARRAY), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  597. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE));
  598. UA_VariableNode *serverstatus = UA_VariableNode_new();
  599. copyNames((UA_Node*)serverstatus, "ServerStatus");
  600. serverstatus->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS);
  601. serverstatus->valueSource = UA_VALUESOURCE_DATASOURCE;
  602. serverstatus->value.dataSource = (UA_DataSource) {.handle = server, .read = readStatus,
  603. .release = releaseStatus, .write = UA_NULL};
  604. UA_Server_addNode(server, (UA_Node*)serverstatus, &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER),
  605. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT));
  606. UA_VariableNode *state = UA_VariableNode_new();
  607. UA_ServerState *stateEnum = UA_ServerState_new();
  608. *stateEnum = UA_SERVERSTATE_RUNNING;
  609. copyNames((UA_Node*)state, "State");
  610. state->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERSTATUS_STATE;
  611. state->value.variant.type = &UA_TYPES[UA_TYPES_SERVERSTATE];
  612. state->value.variant.arrayLength = -1;
  613. state->value.variant.data = stateEnum; // points into the other object.
  614. UA_NodeStore_insert(server->nodestore, (UA_Node*)state, UA_NULL);
  615. ADDREFERENCE(UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  616. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_STATE));
  617. UA_VariableNode *currenttime = UA_VariableNode_new();
  618. copyNames((UA_Node*)currenttime, "CurrentTime");
  619. currenttime->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME);
  620. currenttime->valueSource = UA_VALUESOURCE_DATASOURCE;
  621. currenttime->value.dataSource = (UA_DataSource) {.handle = NULL, .read = readCurrentTime,
  622. .release = releaseCurrentTime, .write = UA_NULL};
  623. UA_Server_addNode(server, (UA_Node*)currenttime, &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS),
  624. &UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT));
  625. #ifdef DEMO_NODESET
  626. /**************/
  627. /* Demo Nodes */
  628. /**************/
  629. #define DEMOID 990
  630. UA_ObjectNode *demo = UA_ObjectNode_new();
  631. copyNames((UA_Node*)demo, "Demo");
  632. demo->nodeId = UA_NODEID_NUMERIC(1, DEMOID);
  633. UA_Server_addNode(server, (UA_Node*)demo,
  634. &UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER),
  635. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  636. ADDREFERENCE(UA_NODEID_NUMERIC(1, DEMOID), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  637. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  638. #define SCALARID 991
  639. UA_ObjectNode *scalar = UA_ObjectNode_new();
  640. copyNames((UA_Node*)scalar, "Scalar");
  641. scalar->nodeId = UA_NODEID_NUMERIC(1, SCALARID);
  642. UA_Server_addNode(server, (UA_Node*)scalar,
  643. &UA_EXPANDEDNODEID_NUMERIC(1, DEMOID),
  644. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  645. ADDREFERENCE(UA_NODEID_NUMERIC(1, SCALARID), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  646. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  647. #define ARRAYID 992
  648. UA_ObjectNode *array = UA_ObjectNode_new();
  649. copyNames((UA_Node*)array, "Arrays");
  650. array->nodeId = UA_NODEID_NUMERIC(1, ARRAYID);
  651. UA_Server_addNode(server, (UA_Node*)array,
  652. &UA_EXPANDEDNODEID_NUMERIC(1, DEMOID),
  653. &UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  654. ADDREFERENCE(UA_NODEID_NUMERIC(1, ARRAYID), UA_NODEID_NUMERIC(0, UA_NS0ID_HASTYPEDEFINITION),
  655. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE));
  656. UA_UInt32 id = 1000; //running id in namespace 1
  657. for(UA_UInt32 type = 0; UA_IS_BUILTIN(type); type++) {
  658. if(type == UA_TYPES_VARIANT || type == UA_TYPES_DIAGNOSTICINFO)
  659. continue;
  660. //add a scalar node for every built-in type
  661. void *value = UA_new(&UA_TYPES[type]);
  662. UA_Variant *variant = UA_Variant_new();
  663. UA_Variant_setScalar(variant, value, &UA_TYPES[type]);
  664. char name[15];
  665. sprintf(name, "%02d", type);
  666. UA_QualifiedName myIntegerName = UA_QUALIFIEDNAME(1, name);
  667. UA_Server_addVariableNode(server, variant, myIntegerName, UA_NODEID_NUMERIC(1, ++id),
  668. UA_NODEID_NUMERIC(1, SCALARID), UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  669. //add an array node for every built-in type
  670. UA_Variant *arrayvar = UA_Variant_new();
  671. UA_Variant_setArray(arrayvar, UA_Array_new(&UA_TYPES[type], 10), 10, &UA_TYPES[type]);
  672. UA_Server_addVariableNode(server, arrayvar, myIntegerName, UA_NODEID_NUMERIC(1, ++id),
  673. UA_NODEID_NUMERIC(1, ARRAYID), UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES));
  674. }
  675. #endif
  676. return server;
  677. }