ua_server.c 38 KB

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