ua_server.c 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671
  1. #ifdef UA_MULTITHREADING
  2. #define _LGPL_SOURCE
  3. #include <urcu.h>
  4. #endif
  5. #include "ua_types.h"
  6. #include "ua_server_internal.h"
  7. #include "ua_securechannel_manager.h"
  8. #include "ua_session_manager.h"
  9. #include "ua_util.h"
  10. #include "ua_services.h"
  11. #include "ua_nodeids.h"
  12. /**********************/
  13. /* Namespace Handling */
  14. /**********************/
  15. static void UA_ExternalNamespace_init(UA_ExternalNamespace *ens) {
  16. ens->index = 0;
  17. UA_String_init(&ens->url);
  18. }
  19. static void UA_ExternalNamespace_deleteMembers(UA_ExternalNamespace *ens) {
  20. UA_String_deleteMembers(&ens->url);
  21. ens->externalNodeStore.destroy(ens->externalNodeStore.ensHandle);
  22. }
  23. /*****************/
  24. /* Configuration */
  25. /*****************/
  26. void UA_Server_addNetworkLayer(UA_Server *server, UA_ServerNetworkLayer networkLayer) {
  27. server->nls = UA_realloc(server->nls, sizeof(UA_ServerNetworkLayer)*(server->nlsSize+1));
  28. server->nls[server->nlsSize] = networkLayer;
  29. server->nlsSize++;
  30. }
  31. void UA_Server_setServerCertificate(UA_Server *server, UA_ByteString certificate) {
  32. UA_ByteString_copy(&certificate, &server->serverCertificate);
  33. }
  34. /**********/
  35. /* Server */
  36. /**********/
  37. void UA_Server_delete(UA_Server *server) {
  38. // The server needs to be stopped before it can be deleted
  39. // Delete the network layers
  40. for(UA_Int32 i=0;i<server->nlsSize;i++) {
  41. server->nls[i].free(server->nls[i].nlHandle);
  42. }
  43. UA_free(server->nls);
  44. // Delete the timed work
  45. UA_Server_deleteTimedWork(server);
  46. // Delete all internal data
  47. UA_ApplicationDescription_deleteMembers(&server->description);
  48. UA_SecureChannelManager_deleteMembers(&server->secureChannelManager);
  49. UA_SessionManager_deleteMembers(&server->sessionManager);
  50. UA_NodeStore_delete(server->nodestore);
  51. UA_ByteString_deleteMembers(&server->serverCertificate);
  52. UA_Array_delete(server->endpointDescriptions, &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION], server->endpointDescriptionsSize);
  53. #ifdef UA_MULTITHREADING
  54. pthread_cond_destroy(&server->dispatchQueue_condition); // so the workers don't spin if the queue is empty
  55. rcu_barrier(); // wait for all scheduled call_rcu work to complete
  56. #endif
  57. UA_free(server);
  58. }
  59. static UA_StatusCode readStatus(const void *handle, UA_VariantData *data) {
  60. UA_ServerStatusDataType *status = UA_ServerStatusDataType_new();
  61. status->startTime = ((const UA_Server*)handle)->timeStarted;
  62. status->currentTime = UA_DateTime_now();
  63. status->state = UA_SERVERSTATE_RUNNING;
  64. UA_String_copycstring("http://www.open62541.org", &status->buildInfo.productUri);
  65. UA_String_copycstring("open62541", &status->buildInfo.manufacturerName);
  66. UA_String_copycstring("open62541 OPC UA Server", &status->buildInfo.productName);
  67. UA_String_copycstring("0.0", &status->buildInfo.softwareVersion);
  68. UA_String_copycstring("0.0", &status->buildInfo.buildNumber);
  69. status->buildInfo.buildDate = UA_DateTime_now();
  70. status->secondsTillShutdown = 0;
  71. data->arrayLength = 1;
  72. data->dataPtr = status;
  73. data->arrayDimensionsSize = -1;
  74. data->arrayDimensions = UA_NULL;
  75. return UA_STATUSCODE_GOOD;
  76. }
  77. UA_Server * UA_Server_new(void) {
  78. UA_Server *server = UA_malloc(sizeof(UA_Server));
  79. if(!server)
  80. return UA_NULL;
  81. LIST_INIT(&server->timedWork);
  82. #ifdef UA_MULTITHREADING
  83. rcu_init();
  84. cds_wfcq_init(&server->dispatchQueue_head, &server->dispatchQueue_tail);
  85. server->delayedWork = UA_NULL;
  86. #endif
  87. // random seed
  88. server->random_seed = (UA_UInt32) UA_DateTime_now();
  89. // networklayers
  90. server->nls = UA_NULL;
  91. server->nlsSize = 0;
  92. UA_ByteString_init(&server->serverCertificate);
  93. // mockup application description
  94. UA_ApplicationDescription_init(&server->description);
  95. UA_String_copycstring("urn:unconfigured:open62541:application", &server->description.productUri);
  96. UA_String_copycstring("http://unconfigured.open62541/applications/", &server->description.applicationUri);
  97. UA_LocalizedText_copycstring("Unconfigured open62541 application", &server->description.applicationName);
  98. server->description.applicationType = UA_APPLICATIONTYPE_SERVER;
  99. server->externalNamespacesSize = 0;
  100. server->externalNamespaces = UA_NULL;
  101. // mockup endpoint description
  102. server->endpointDescriptionsSize = 1;
  103. UA_EndpointDescription *endpoint = UA_EndpointDescription_new(); // todo: check return code
  104. endpoint->securityMode = UA_MESSAGESECURITYMODE_NONE;
  105. UA_String_copycstring("http://opcfoundation.org/UA/SecurityPolicy#None", &endpoint->securityPolicyUri);
  106. UA_String_copycstring("http://opcfoundation.org/UA-Profile/Transport/uatcp-uasc-uabinary", &endpoint->transportProfileUri);
  107. endpoint->userIdentityTokensSize = 1;
  108. endpoint->userIdentityTokens = UA_malloc(sizeof(UA_UserTokenPolicy));
  109. UA_UserTokenPolicy_init(endpoint->userIdentityTokens);
  110. UA_String_copycstring("my-anonymous-policy", &endpoint->userIdentityTokens->policyId); // defined per server
  111. endpoint->userIdentityTokens->tokenType = UA_USERTOKENTYPE_ANONYMOUS;
  112. /* UA_String_copy(endpointUrl, &endpoint->endpointUrl); */
  113. /* /\* The standard says "the HostName specified in the Server Certificate is the */
  114. /* same as the HostName contained in the endpointUrl provided in the */
  115. /* EndpointDescription *\/ */
  116. /* UA_String_copy(&server->serverCertificate, &endpoint->serverCertificate); */
  117. UA_ApplicationDescription_copy(&server->description, &endpoint->server);
  118. server->endpointDescriptions = endpoint;
  119. #define MAXCHANNELCOUNT 100
  120. #define STARTCHANNELID 1
  121. #define TOKENLIFETIME 600000
  122. #define STARTTOKENID 1
  123. UA_SecureChannelManager_init(&server->secureChannelManager, MAXCHANNELCOUNT,
  124. TOKENLIFETIME, STARTCHANNELID, STARTTOKENID);
  125. #define MAXSESSIONCOUNT 1000
  126. #define SESSIONLIFETIME 10000
  127. #define STARTSESSIONID 1
  128. UA_SessionManager_init(&server->sessionManager, MAXSESSIONCOUNT, SESSIONLIFETIME, STARTSESSIONID);
  129. server->nodestore = UA_NodeStore_new();
  130. #define COPYNAMES(TARGET, NAME) do { \
  131. UA_QualifiedName_copycstring(NAME, &TARGET->browseName); \
  132. UA_LocalizedText_copycstring(NAME, &TARGET->displayName); \
  133. UA_LocalizedText_copycstring(NAME, &TARGET->description); \
  134. } while(0)
  135. /**************/
  136. /* Data Types */
  137. /**************/
  138. UA_DataTypeNode *booleanNode = UA_DataTypeNode_new();
  139. booleanNode->nodeId.identifier.numeric = UA_NS0ID_BOOLEAN;
  140. COPYNAMES(booleanNode, "Boolean");
  141. UA_NodeStore_insert(server->nodestore, (UA_Node*)booleanNode, UA_NULL);
  142. UA_DataTypeNode *sByteNode = UA_DataTypeNode_new();
  143. sByteNode->nodeId.identifier.numeric = UA_NS0ID_SBYTE;
  144. COPYNAMES(sByteNode, "SByte");
  145. UA_NodeStore_insert(server->nodestore, (UA_Node*)sByteNode, UA_NULL);
  146. UA_DataTypeNode *byteNode = UA_DataTypeNode_new();
  147. byteNode->nodeId.identifier.numeric = UA_NS0ID_BYTE;
  148. COPYNAMES(byteNode, "Byte");
  149. UA_NodeStore_insert(server->nodestore, (UA_Node*)byteNode, UA_NULL);
  150. UA_DataTypeNode *int16Node = UA_DataTypeNode_new();
  151. int16Node->nodeId.identifier.numeric = UA_NS0ID_INT16;
  152. COPYNAMES(int16Node, "Int16");
  153. UA_NodeStore_insert(server->nodestore, (UA_Node*)int16Node, UA_NULL);
  154. UA_DataTypeNode *uInt16Node = UA_DataTypeNode_new();
  155. uInt16Node->nodeId.identifier.numeric = UA_NS0ID_UINT16;
  156. COPYNAMES(uInt16Node, "UInt16");
  157. UA_NodeStore_insert(server->nodestore, (UA_Node*)uInt16Node, UA_NULL);
  158. UA_DataTypeNode *int32Node = UA_DataTypeNode_new();
  159. int32Node->nodeId.identifier.numeric = UA_NS0ID_INT32;
  160. COPYNAMES(int32Node, "Int32");
  161. UA_NodeStore_insert(server->nodestore, (UA_Node*)int32Node, UA_NULL);
  162. UA_DataTypeNode *uInt32Node = UA_DataTypeNode_new();
  163. uInt32Node->nodeId.identifier.numeric = UA_NS0ID_UINT32;
  164. COPYNAMES(uInt32Node, "UInt32");
  165. UA_NodeStore_insert(server->nodestore, (UA_Node*)uInt32Node, UA_NULL);
  166. UA_DataTypeNode *int64Node = UA_DataTypeNode_new();
  167. int64Node->nodeId.identifier.numeric = UA_NS0ID_INT64;
  168. COPYNAMES(int64Node, "Int64");
  169. UA_NodeStore_insert(server->nodestore, (UA_Node*)int64Node, UA_NULL);
  170. UA_DataTypeNode *uInt64Node = UA_DataTypeNode_new();
  171. uInt64Node->nodeId.identifier.numeric = UA_NS0ID_UINT64;
  172. COPYNAMES(uInt64Node, "UInt64");
  173. UA_NodeStore_insert(server->nodestore, (UA_Node*)uInt64Node, UA_NULL);
  174. UA_DataTypeNode *floatNode = UA_DataTypeNode_new();
  175. floatNode->nodeId.identifier.numeric = UA_NS0ID_FLOAT;
  176. COPYNAMES(floatNode, "Float");
  177. UA_NodeStore_insert(server->nodestore, (UA_Node*)floatNode, UA_NULL);
  178. UA_DataTypeNode *doubleNode = UA_DataTypeNode_new();
  179. doubleNode->nodeId.identifier.numeric = UA_NS0ID_DOUBLE;
  180. COPYNAMES(doubleNode, "Double");
  181. UA_NodeStore_insert(server->nodestore, (UA_Node*)doubleNode, UA_NULL);
  182. UA_DataTypeNode *stringNode = UA_DataTypeNode_new();
  183. stringNode->nodeId.identifier.numeric = UA_NS0ID_STRING;
  184. COPYNAMES(stringNode, "String");
  185. UA_NodeStore_insert(server->nodestore, (UA_Node*)stringNode, UA_NULL);
  186. UA_DataTypeNode *dateTimeNode = UA_DataTypeNode_new();
  187. dateTimeNode->nodeId.identifier.numeric = UA_NS0ID_DATETIME;
  188. COPYNAMES(dateTimeNode, "DateTime");
  189. UA_NodeStore_insert(server->nodestore, (UA_Node*)dateTimeNode, UA_NULL);
  190. UA_DataTypeNode *guidNode = UA_DataTypeNode_new();
  191. guidNode->nodeId.identifier.numeric = UA_NS0ID_GUID;
  192. COPYNAMES(guidNode, "Guid");
  193. UA_NodeStore_insert(server->nodestore, (UA_Node*)guidNode, UA_NULL);
  194. UA_DataTypeNode *byteStringNode = UA_DataTypeNode_new();
  195. byteStringNode->nodeId.identifier.numeric = UA_NS0ID_BYTESTRING;
  196. COPYNAMES(byteStringNode, "ByteString");
  197. UA_NodeStore_insert(server->nodestore, (UA_Node*)byteStringNode, UA_NULL);
  198. UA_DataTypeNode *xmlElementNode = UA_DataTypeNode_new();
  199. xmlElementNode->nodeId.identifier.numeric = UA_NS0ID_XMLELEMENT;
  200. COPYNAMES(xmlElementNode, "XmlElement");
  201. UA_NodeStore_insert(server->nodestore, (UA_Node*)xmlElementNode, UA_NULL);
  202. UA_DataTypeNode *nodeIdNode = UA_DataTypeNode_new();
  203. nodeIdNode->nodeId.identifier.numeric = UA_NS0ID_NODEID;
  204. COPYNAMES(nodeIdNode, "NodeId");
  205. UA_NodeStore_insert(server->nodestore, (UA_Node*)nodeIdNode, UA_NULL);
  206. UA_DataTypeNode *expandedNodeIdNode = UA_DataTypeNode_new();
  207. expandedNodeIdNode->nodeId.identifier.numeric = UA_NS0ID_EXPANDEDNODEID;
  208. COPYNAMES(expandedNodeIdNode, "ExpandedNodeId");
  209. UA_NodeStore_insert(server->nodestore, (UA_Node*)expandedNodeIdNode, UA_NULL);
  210. UA_DataTypeNode *statusCodeNode = UA_DataTypeNode_new();
  211. statusCodeNode->nodeId.identifier.numeric = UA_NS0ID_STATUSCODE;
  212. COPYNAMES(statusCodeNode, "StatusCode");
  213. UA_NodeStore_insert(server->nodestore, (UA_Node*)statusCodeNode, UA_NULL);
  214. UA_DataTypeNode *qualifiedNameNode = UA_DataTypeNode_new();
  215. qualifiedNameNode->nodeId.identifier.numeric = UA_NS0ID_QUALIFIEDNAME;
  216. COPYNAMES(qualifiedNameNode, "QualifiedName");
  217. UA_NodeStore_insert(server->nodestore, (UA_Node*)qualifiedNameNode, UA_NULL);
  218. UA_DataTypeNode *localizedTextNode = UA_DataTypeNode_new();
  219. localizedTextNode->nodeId.identifier.numeric = UA_NS0ID_LOCALIZEDTEXT;
  220. COPYNAMES(localizedTextNode, "LocalizedText");
  221. UA_NodeStore_insert(server->nodestore, (UA_Node*)localizedTextNode, UA_NULL);
  222. UA_DataTypeNode *structureNode = UA_DataTypeNode_new();
  223. structureNode->nodeId.identifier.numeric = UA_NS0ID_EXTENSIONOBJECT; //todo: why name missmatch?
  224. COPYNAMES(structureNode, "Structure");
  225. UA_NodeStore_insert(server->nodestore, (UA_Node*)structureNode, UA_NULL);
  226. UA_DataTypeNode *dataValueNode = UA_DataTypeNode_new();
  227. dataValueNode->nodeId.identifier.numeric = UA_NS0ID_DATAVALUE;
  228. COPYNAMES(dataValueNode, "DataValue");
  229. UA_NodeStore_insert(server->nodestore, (UA_Node*)dataValueNode, UA_NULL);
  230. UA_DataTypeNode *baseDataTypeNode = UA_DataTypeNode_new();
  231. baseDataTypeNode->nodeId.identifier.numeric = UA_NS0ID_VARIANT; //todo: why name missmatch?
  232. COPYNAMES(baseDataTypeNode, "BaseDataType");
  233. UA_NodeStore_insert(server->nodestore, (UA_Node*)baseDataTypeNode, UA_NULL);
  234. UA_DataTypeNode *diagnosticInfoNode = UA_DataTypeNode_new();
  235. diagnosticInfoNode->nodeId.identifier.numeric = UA_NS0ID_DIAGNOSTICINFO;
  236. COPYNAMES(diagnosticInfoNode, "DiagnosticInfo");
  237. UA_NodeStore_insert(server->nodestore, (UA_Node*)diagnosticInfoNode, UA_NULL);
  238. UA_DataTypeNode *numberNode = UA_DataTypeNode_new();
  239. numberNode->nodeId.identifier.numeric = UA_NS0ID_NUMBER;
  240. COPYNAMES(numberNode, "Number");
  241. UA_NodeStore_insert(server->nodestore, (UA_Node*)numberNode, UA_NULL);
  242. UA_DataTypeNode *integerNode = UA_DataTypeNode_new();
  243. integerNode->nodeId.identifier.numeric = UA_NS0ID_INTEGER;
  244. COPYNAMES(integerNode, "Integer");
  245. UA_NodeStore_insert(server->nodestore, (UA_Node*)integerNode, UA_NULL);
  246. UA_DataTypeNode *uIntegerNode = UA_DataTypeNode_new();
  247. uIntegerNode->nodeId.identifier.numeric = UA_NS0ID_UINTEGER;
  248. COPYNAMES(uIntegerNode, "UInteger");
  249. UA_NodeStore_insert(server->nodestore, (UA_Node*)uIntegerNode, UA_NULL);
  250. UA_DataTypeNode *enumerationNode = UA_DataTypeNode_new();
  251. enumerationNode->nodeId.identifier.numeric = UA_NS0ID_ENUMERATION;
  252. COPYNAMES(enumerationNode, "Enumeration");
  253. UA_NodeStore_insert(server->nodestore, (UA_Node*)enumerationNode, UA_NULL);
  254. UA_DataTypeNode *imageNode = UA_DataTypeNode_new();
  255. imageNode->nodeId.identifier.numeric = UA_NS0ID_IMAGE;
  256. COPYNAMES(imageNode, "Image");
  257. UA_NodeStore_insert(server->nodestore, (UA_Node*)imageNode, UA_NULL);
  258. /**************/
  259. /* References */
  260. /**************/
  261. /* bootstrap by manually inserting "references" and "hassubtype" */
  262. UA_ReferenceTypeNode *references = UA_ReferenceTypeNode_new();
  263. COPYNAMES(references, "References");
  264. references->nodeId.identifier.numeric = UA_NS0ID_REFERENCES;
  265. references->isAbstract = UA_TRUE;
  266. references->symmetric = UA_TRUE;
  267. // this node has no parent??
  268. UA_NodeStore_insert(server->nodestore, (UA_Node*)references, UA_NULL);
  269. UA_ReferenceTypeNode *hassubtype = UA_ReferenceTypeNode_new();
  270. COPYNAMES(hassubtype, "HasSubtype");
  271. UA_LocalizedText_copycstring("HasSupertype", &hassubtype->inverseName);
  272. hassubtype->nodeId.identifier.numeric = UA_NS0ID_HASSUBTYPE;
  273. hassubtype->isAbstract = UA_FALSE;
  274. hassubtype->symmetric = UA_FALSE;
  275. UA_NodeStore_insert(server->nodestore, (UA_Node*)hassubtype, UA_NULL);
  276. /* continue adding reference types with normal "addnode" */
  277. UA_ReferenceTypeNode *hierarchicalreferences = UA_ReferenceTypeNode_new();
  278. COPYNAMES(hierarchicalreferences, "Hierarchicalreferences");
  279. hierarchicalreferences->nodeId.identifier.numeric = UA_NS0ID_HIERARCHICALREFERENCES;
  280. hierarchicalreferences->isAbstract = UA_TRUE;
  281. hierarchicalreferences->symmetric = UA_FALSE;
  282. UA_Server_addNode(server, (UA_Node*)hierarchicalreferences,
  283. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_REFERENCES),
  284. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  285. UA_ReferenceTypeNode *nonhierarchicalreferences = UA_ReferenceTypeNode_new();
  286. COPYNAMES(nonhierarchicalreferences, "NonHierarchicalReferences");
  287. nonhierarchicalreferences->nodeId.identifier.numeric = UA_NS0ID_NONHIERARCHICALREFERENCES;
  288. nonhierarchicalreferences->isAbstract = UA_TRUE;
  289. nonhierarchicalreferences->symmetric = UA_FALSE;
  290. UA_Server_addNode(server, (UA_Node*)nonhierarchicalreferences,
  291. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_REFERENCES),
  292. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  293. UA_ReferenceTypeNode *haschild = UA_ReferenceTypeNode_new();
  294. COPYNAMES(haschild, "HasChild");
  295. haschild->nodeId.identifier.numeric = UA_NS0ID_HASCHILD;
  296. haschild->isAbstract = UA_TRUE;
  297. haschild->symmetric = UA_FALSE;
  298. UA_Server_addNode(server, (UA_Node*)haschild,
  299. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HIERARCHICALREFERENCES),
  300. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  301. UA_ReferenceTypeNode *organizes = UA_ReferenceTypeNode_new();
  302. COPYNAMES(organizes, "Organizes");
  303. UA_LocalizedText_copycstring("OrganizedBy", &organizes->inverseName);
  304. organizes->nodeId.identifier.numeric = UA_NS0ID_ORGANIZES;
  305. organizes->isAbstract = UA_FALSE;
  306. organizes->symmetric = UA_FALSE;
  307. UA_Server_addNode(server, (UA_Node*)organizes,
  308. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HIERARCHICALREFERENCES),
  309. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  310. UA_ReferenceTypeNode *haseventsource = UA_ReferenceTypeNode_new();
  311. COPYNAMES(haseventsource, "HasEventSource");
  312. UA_LocalizedText_copycstring("EventSourceOf", &haseventsource->inverseName);
  313. haseventsource->nodeId.identifier.numeric = UA_NS0ID_HASEVENTSOURCE;
  314. haseventsource->isAbstract = UA_FALSE;
  315. haseventsource->symmetric = UA_FALSE;
  316. UA_Server_addNode(server, (UA_Node*)haseventsource,
  317. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HIERARCHICALREFERENCES),
  318. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  319. UA_ReferenceTypeNode *hasmodellingrule = UA_ReferenceTypeNode_new();
  320. COPYNAMES(hasmodellingrule, "HasModellingRule");
  321. UA_LocalizedText_copycstring("ModellingRuleOf", &hasmodellingrule->inverseName);
  322. hasmodellingrule->nodeId.identifier.numeric = UA_NS0ID_HASMODELLINGRULE;
  323. hasmodellingrule->isAbstract = UA_FALSE;
  324. hasmodellingrule->symmetric = UA_FALSE;
  325. UA_Server_addNode(server, (UA_Node*)hasmodellingrule,
  326. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  327. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  328. UA_ReferenceTypeNode *hasencoding = UA_ReferenceTypeNode_new();
  329. COPYNAMES(hasencoding, "HasEncoding");
  330. UA_LocalizedText_copycstring("EncodingOf", &hasencoding->inverseName);
  331. hasencoding->nodeId.identifier.numeric = UA_NS0ID_HASENCODING;
  332. hasencoding->isAbstract = UA_FALSE;
  333. hasencoding->symmetric = UA_FALSE;
  334. UA_Server_addNode(server, (UA_Node*)hasencoding,
  335. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  336. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  337. UA_ReferenceTypeNode *hasdescription = UA_ReferenceTypeNode_new();
  338. COPYNAMES(hasdescription, "HasDescription");
  339. UA_LocalizedText_copycstring("DescriptionOf", &hasdescription->inverseName);
  340. hasdescription->nodeId.identifier.numeric = UA_NS0ID_HASDESCRIPTION;
  341. hasdescription->isAbstract = UA_FALSE;
  342. hasdescription->symmetric = UA_FALSE;
  343. UA_Server_addNode(server, (UA_Node*)hasdescription,
  344. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  345. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  346. UA_ReferenceTypeNode *hastypedefinition = UA_ReferenceTypeNode_new();
  347. COPYNAMES(hastypedefinition, "HasTypeDefinition");
  348. UA_LocalizedText_copycstring("TypeDefinitionOf", &hastypedefinition->inverseName);
  349. hastypedefinition->nodeId.identifier.numeric = UA_NS0ID_HASTYPEDEFINITION;
  350. hastypedefinition->isAbstract = UA_FALSE;
  351. hastypedefinition->symmetric = UA_FALSE;
  352. UA_Server_addNode(server, (UA_Node*)hastypedefinition,
  353. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  354. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  355. UA_ReferenceTypeNode *generatesevent = UA_ReferenceTypeNode_new();
  356. COPYNAMES(generatesevent, "GeneratesEvent");
  357. UA_LocalizedText_copycstring("GeneratedBy", &generatesevent->inverseName);
  358. generatesevent->nodeId.identifier.numeric = UA_NS0ID_GENERATESEVENT;
  359. generatesevent->isAbstract = UA_FALSE;
  360. generatesevent->symmetric = UA_FALSE;
  361. UA_Server_addNode(server, (UA_Node*)generatesevent,
  362. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  363. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  364. UA_ReferenceTypeNode *aggregates = UA_ReferenceTypeNode_new();
  365. COPYNAMES(aggregates, "Aggregates");
  366. // Todo: Is there an inverse name?
  367. aggregates->nodeId.identifier.numeric = UA_NS0ID_AGGREGATES;
  368. aggregates->isAbstract = UA_TRUE;
  369. aggregates->symmetric = UA_FALSE;
  370. UA_Server_addNode(server, (UA_Node*)aggregates,
  371. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HASCHILD),
  372. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  373. // complete bootstrap of hassubtype
  374. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_HASCHILD), UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE),
  375. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  376. UA_ReferenceTypeNode *hasproperty = UA_ReferenceTypeNode_new();
  377. COPYNAMES(hasproperty, "HasProperty");
  378. UA_LocalizedText_copycstring("PropertyOf", &hasproperty->inverseName);
  379. hasproperty->nodeId.identifier.numeric = UA_NS0ID_HASPROPERTY;
  380. hasproperty->isAbstract = UA_FALSE;
  381. hasproperty->symmetric = UA_FALSE;
  382. UA_Server_addNode(server, (UA_Node*)hasproperty,
  383. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_AGGREGATES),
  384. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  385. UA_ReferenceTypeNode *hascomponent = UA_ReferenceTypeNode_new();
  386. COPYNAMES(hascomponent, "HasComponent");
  387. UA_LocalizedText_copycstring("ComponentOf", &hascomponent->inverseName);
  388. hascomponent->nodeId.identifier.numeric = UA_NS0ID_HASCOMPONENT;
  389. hascomponent->isAbstract = UA_FALSE;
  390. hascomponent->symmetric = UA_FALSE;
  391. UA_Server_addNode(server, (UA_Node*)hascomponent,
  392. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_AGGREGATES),
  393. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  394. UA_ReferenceTypeNode *hasnotifier = UA_ReferenceTypeNode_new();
  395. COPYNAMES(hasnotifier, "HasNotifier");
  396. UA_LocalizedText_copycstring("NotifierOf", &hasnotifier->inverseName);
  397. hasnotifier->nodeId.identifier.numeric = UA_NS0ID_HASNOTIFIER;
  398. hasnotifier->isAbstract = UA_FALSE;
  399. hasnotifier->symmetric = UA_FALSE;
  400. UA_Server_addNode(server, (UA_Node*)hasnotifier,
  401. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HASEVENTSOURCE),
  402. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  403. UA_ReferenceTypeNode *hasorderedcomponent = UA_ReferenceTypeNode_new();
  404. COPYNAMES(hasorderedcomponent, "HasOrderedComponent");
  405. UA_LocalizedText_copycstring("OrderedComponentOf", &hasorderedcomponent->inverseName);
  406. hasorderedcomponent->nodeId.identifier.numeric = UA_NS0ID_HASORDEREDCOMPONENT;
  407. hasorderedcomponent->isAbstract = UA_FALSE;
  408. hasorderedcomponent->symmetric = UA_FALSE;
  409. UA_Server_addNode(server, (UA_Node*)hasorderedcomponent,
  410. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_HASCOMPONENT),
  411. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  412. UA_ReferenceTypeNode *hasmodelparent = UA_ReferenceTypeNode_new();
  413. COPYNAMES(hasmodelparent, "HasModelParent");
  414. UA_LocalizedText_copycstring("ModelParentOf", &hasmodelparent->inverseName);
  415. hasmodelparent->nodeId.identifier.numeric = UA_NS0ID_HASMODELPARENT;
  416. hasmodelparent->isAbstract = UA_FALSE;
  417. hasmodelparent->symmetric = UA_FALSE;
  418. UA_Server_addNode(server, (UA_Node*)hasmodelparent,
  419. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  420. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  421. UA_ReferenceTypeNode *fromstate = UA_ReferenceTypeNode_new();
  422. COPYNAMES(fromstate, "FromState");
  423. UA_LocalizedText_copycstring("ToTransition", &fromstate->inverseName);
  424. fromstate->nodeId.identifier.numeric = UA_NS0ID_FROMSTATE;
  425. fromstate->isAbstract = UA_FALSE;
  426. fromstate->symmetric = UA_FALSE;
  427. UA_Server_addNode(server, (UA_Node*)fromstate,
  428. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  429. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  430. UA_ReferenceTypeNode *tostate = UA_ReferenceTypeNode_new();
  431. COPYNAMES(tostate, "ToState");
  432. UA_LocalizedText_copycstring("FromTransition", &tostate->inverseName);
  433. tostate->nodeId.identifier.numeric = UA_NS0ID_TOSTATE;
  434. tostate->isAbstract = UA_FALSE;
  435. tostate->symmetric = UA_FALSE;
  436. UA_Server_addNode(server, (UA_Node*)tostate,
  437. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  438. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  439. UA_ReferenceTypeNode *hascause = UA_ReferenceTypeNode_new();
  440. COPYNAMES(hascause, "HasCause");
  441. UA_LocalizedText_copycstring("MayBeCausedBy", &hascause->inverseName);
  442. hascause->nodeId.identifier.numeric = UA_NS0ID_HASCAUSE;
  443. hascause->isAbstract = UA_FALSE;
  444. hascause->symmetric = UA_FALSE;
  445. UA_Server_addNode(server, (UA_Node*)hascause,
  446. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  447. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  448. UA_ReferenceTypeNode *haseffect = UA_ReferenceTypeNode_new();
  449. COPYNAMES(haseffect, "HasEffect");
  450. UA_LocalizedText_copycstring("MayBeEffectedBy", &haseffect->inverseName);
  451. haseffect->nodeId.identifier.numeric = UA_NS0ID_HASEFFECT;
  452. haseffect->isAbstract = UA_FALSE;
  453. haseffect->symmetric = UA_FALSE;
  454. UA_Server_addNode(server, (UA_Node*)haseffect,
  455. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_NONHIERARCHICALREFERENCES),
  456. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  457. UA_ReferenceTypeNode *hashistoricalconfiguration = UA_ReferenceTypeNode_new();
  458. COPYNAMES(hashistoricalconfiguration, "HasHistoricalConfiguration");
  459. UA_LocalizedText_copycstring("HistoricalConfigurationOf", &hashistoricalconfiguration->inverseName);
  460. hashistoricalconfiguration->nodeId.identifier.numeric = UA_NS0ID_HASHISTORICALCONFIGURATION;
  461. hashistoricalconfiguration->isAbstract = UA_FALSE;
  462. hashistoricalconfiguration->symmetric = UA_FALSE;
  463. UA_Server_addNode(server, (UA_Node*)hashistoricalconfiguration,
  464. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_AGGREGATES),
  465. &UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE));
  466. /***********/
  467. /* Objects */
  468. /***********/
  469. UA_ObjectTypeNode *baseObjectType = UA_ObjectTypeNode_new();
  470. baseObjectType->nodeId.identifier.numeric = UA_NS0ID_BASEOBJECTTYPE;
  471. COPYNAMES(baseObjectType, "BaseObjectType");
  472. UA_NodeStore_insert(server->nodestore, (UA_Node*)baseObjectType, UA_NULL);
  473. UA_ObjectTypeNode *baseDataVarialbeType = UA_ObjectTypeNode_new();
  474. baseDataVarialbeType->nodeId.identifier.numeric = UA_NS0ID_BASEDATAVARIABLETYPE;
  475. COPYNAMES(baseDataVarialbeType, "BaseDataVariableType");
  476. UA_NodeStore_insert(server->nodestore, (UA_Node*)baseDataVarialbeType, UA_NULL);
  477. UA_ObjectTypeNode *folderType = UA_ObjectTypeNode_new();
  478. folderType->nodeId.identifier.numeric = UA_NS0ID_FOLDERTYPE;
  479. COPYNAMES(folderType, "FolderType");
  480. UA_NodeStore_insert(server->nodestore, (UA_Node*)folderType, UA_NULL);
  481. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_BASEOBJECTTYPE), UA_NODEID_STATIC(0, UA_NS0ID_HASSUBTYPE),
  482. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_FOLDERTYPE));
  483. UA_ObjectNode *root = UA_ObjectNode_new();
  484. COPYNAMES(root, "Root");
  485. root->nodeId.identifier.numeric = UA_NS0ID_ROOTFOLDER;
  486. UA_NodeStore_insert(server->nodestore, (UA_Node*)root, UA_NULL);
  487. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_ROOTFOLDER), UA_NODEID_STATIC(0, UA_NS0ID_HASTYPEDEFINITION),
  488. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_FOLDERTYPE));
  489. UA_ObjectNode *objects = UA_ObjectNode_new();
  490. COPYNAMES(objects, "Objects");
  491. objects->nodeId.identifier.numeric = UA_NS0ID_OBJECTSFOLDER;
  492. UA_Server_addNode(server, (UA_Node*)objects,
  493. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_ROOTFOLDER),
  494. &UA_NODEID_STATIC(0, UA_NS0ID_ORGANIZES));
  495. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_OBJECTSFOLDER), UA_NODEID_STATIC(0, UA_NS0ID_HASTYPEDEFINITION),
  496. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_FOLDERTYPE));
  497. UA_ObjectNode *types = UA_ObjectNode_new();
  498. COPYNAMES(types, "Types");
  499. types->nodeId.identifier.numeric = UA_NS0ID_TYPESFOLDER;
  500. UA_Server_addNode(server, (UA_Node*)types,
  501. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_ROOTFOLDER),
  502. &UA_NODEID_STATIC(0, UA_NS0ID_ORGANIZES));
  503. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_TYPESFOLDER), UA_NODEID_STATIC(0, UA_NS0ID_HASTYPEDEFINITION),
  504. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_FOLDERTYPE));
  505. UA_ObjectNode *views = UA_ObjectNode_new();
  506. COPYNAMES(views, "Views");
  507. views->nodeId.identifier.numeric = UA_NS0ID_VIEWSFOLDER;
  508. UA_Server_addNode(server, (UA_Node*)views,
  509. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_ROOTFOLDER),
  510. &UA_NODEID_STATIC(0, UA_NS0ID_ORGANIZES));
  511. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_VIEWSFOLDER), UA_NODEID_STATIC(0, UA_NS0ID_HASTYPEDEFINITION),
  512. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_FOLDERTYPE));
  513. UA_ObjectNode *servernode = UA_ObjectNode_new();
  514. COPYNAMES(servernode, "Server");
  515. servernode->nodeId.identifier.numeric = UA_NS0ID_SERVER;
  516. UA_Server_addNode(server, (UA_Node*)servernode,
  517. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_OBJECTSFOLDER),
  518. &UA_NODEID_STATIC(0, UA_NS0ID_ORGANIZES));
  519. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_SERVER), UA_NODEID_STATIC(0, UA_NS0ID_HASCOMPONENT),
  520. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES));
  521. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_SERVER), UA_NODEID_STATIC(0, UA_NS0ID_HASPROPERTY),
  522. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_SERVER_SERVERARRAY));
  523. UA_VariableNode *namespaceArray = UA_VariableNode_new();
  524. COPYNAMES(namespaceArray, "NamespaceArray");
  525. namespaceArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_NAMESPACEARRAY;
  526. namespaceArray->value.storage.data.dataPtr = UA_Array_new(&UA_TYPES[UA_TYPES_STRING], 2);
  527. namespaceArray->value.storage.data.arrayLength = 2;
  528. namespaceArray->value.type = &UA_TYPES[UA_TYPES_STRING];
  529. // Fixme: Insert the external namespaces
  530. UA_String_copycstring("http://opcfoundation.org/UA/",
  531. &((UA_String *)(namespaceArray->value.storage.data.dataPtr))[0]);
  532. UA_String_copycstring("urn:myServer:myApplication",
  533. &((UA_String *)(namespaceArray->value.storage.data.dataPtr))[1]);
  534. namespaceArray->valueRank = 1;
  535. namespaceArray->minimumSamplingInterval = 1.0;
  536. namespaceArray->historizing = UA_FALSE;
  537. UA_Server_addNode(server, (UA_Node*)namespaceArray,
  538. &UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_SERVER),
  539. &UA_NODEID_STATIC(0, UA_NS0ID_HASPROPERTY));
  540. /*UA_Variant *serverstatus = UA_Variant_new();
  541. UA_Variant_setValue(serverstatus, status, UA_TYPES_SERVERSTATUSDATATYPE);
  542. UA_QualifiedName serverstatusname;
  543. UA_QUALIFIEDNAME_ASSIGN(serverstatusname, "ServerStatus");
  544. UA_Server_addVariableNode(server, serverstatus, &UA_NODEID_STATIC(0, UA_NS0ID_SERVER_SERVERSTATUS), &serverstatusname,
  545. &UA_NODEID_STATIC(0, UA_NS0ID_SERVER),
  546. &UA_NODEID_STATIC(0, UA_NS0ID_HASCOMPONENT));*/
  547. UA_Variant *serverstatus = UA_Variant_new();
  548. serverstatus->storageType = UA_VARIANT_DATASOURCE;
  549. serverstatus->storage.datasource = (UA_VariantDataSource)
  550. {.handle = server,
  551. .read = readStatus,
  552. .release = UA_NULL,
  553. .write = UA_NULL};
  554. serverstatus->type = &UA_TYPES[UA_TYPES_SERVERSTATUSDATATYPE];
  555. UA_QualifiedName serverstatusname;
  556. UA_QUALIFIEDNAME_ASSIGN(serverstatusname, "ServerStatus");
  557. UA_Server_addVariableNode(server, serverstatus, &UA_NODEID_NULL, &serverstatusname,
  558. &UA_NODEID_STATIC(0, UA_NS0ID_SERVER),
  559. &UA_NODEID_STATIC(0, UA_NS0ID_HASCOMPONENT));
  560. UA_VariableNode *state = UA_VariableNode_new();
  561. UA_ServerState *stateEnum = UA_ServerState_new();
  562. *stateEnum = UA_SERVERSTATE_RUNNING;
  563. COPYNAMES(state, "State");
  564. state->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERSTATUS_STATE;
  565. state->value.type = &UA_TYPES[UA_TYPES_SERVERSTATE];
  566. state->value.storage.data.arrayLength = 1;
  567. state->value.storage.data.dataPtr = stateEnum; // points into the other object.
  568. state->value.storageType = UA_VARIANT_DATA;
  569. UA_NodeStore_insert(server->nodestore, (UA_Node*)state, UA_NULL);
  570. ADDREFERENCE(UA_NODEID_STATIC(0, UA_NS0ID_SERVER_SERVERSTATUS), UA_NODEID_STATIC(0, UA_NS0ID_HASCOMPONENT),
  571. UA_EXPANDEDNODEID_STATIC(0, UA_NS0ID_SERVER_SERVERSTATUS_STATE));
  572. return server;
  573. }