ua_server.c 47 KB

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