ua_server.c 44 KB

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