ua_server.c 61 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228
  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. #ifdef UA_ENABLE_GENERATE_NAMESPACE0
  9. #include "ua_namespaceinit_generated.h"
  10. #endif
  11. #define MANUFACTURER_NAME "open62541"
  12. #define PRODUCT_NAME "open62541 OPC UA Server"
  13. #define PRODUCT_URI "urn:unconfigured:open62541"
  14. #define UA_STRING_STATIC(s) {sizeof(s)-1, (UA_Byte*)s}
  15. #define UA_STRING_STATIC_NULL {0, NULL}
  16. const UA_ServerConfig UA_ServerConfig_standard = {
  17. .nThreads = 1,
  18. .logger = NULL,
  19. .buildInfo = {
  20. .productUri = UA_STRING_STATIC(PRODUCT_URI),
  21. .manufacturerName = UA_STRING_STATIC(MANUFACTURER_NAME),
  22. .productName = UA_STRING_STATIC(PRODUCT_NAME),
  23. .softwareVersion = UA_STRING_STATIC("0"),
  24. .buildNumber = UA_STRING_STATIC("0"),
  25. .buildDate = 0},
  26. .applicationDescription = {
  27. .applicationUri = UA_STRING_STATIC("urn:unconfigured:application"),
  28. .productUri = UA_STRING_STATIC("urn:unconfigured:product"),
  29. .applicationName = { .locale = UA_STRING_STATIC(""), .text = UA_STRING_STATIC("open62541Server") },
  30. .applicationType = UA_APPLICATIONTYPE_SERVER,
  31. .gatewayServerUri = UA_STRING_STATIC_NULL,
  32. .discoveryProfileUri = UA_STRING_STATIC_NULL,
  33. .discoveryUrlsSize = 0,
  34. .discoveryUrls = NULL
  35. },
  36. .serverCertificate = UA_STRING_STATIC_NULL,
  37. .networkLayersSize = 0, .networkLayers = NULL,
  38. .enableAnonymousLogin = UA_TRUE,
  39. .enableUsernamePasswordLogin = UA_TRUE,
  40. .usernamePasswordLogins =
  41. { { UA_STRING_STATIC("user1"), UA_STRING_STATIC("password") },
  42. { UA_STRING_STATIC("uset2"), UA_STRING_STATIC("password1") } },
  43. .usernamePasswordLoginsSize = 2
  44. };
  45. #if defined(UA_ENABLE_MULTITHREADING) && !defined(NDEBUG)
  46. UA_THREAD_LOCAL bool rcu_locked = UA_FALSE;
  47. #endif
  48. static const UA_NodeId nodeIdHasSubType = {
  49. .namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  50. .identifier.numeric = UA_NS0ID_HASSUBTYPE};
  51. static const UA_NodeId nodeIdHasTypeDefinition = {
  52. .namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  53. .identifier.numeric = UA_NS0ID_HASTYPEDEFINITION};
  54. static const UA_NodeId nodeIdHasComponent = {
  55. .namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  56. .identifier.numeric = UA_NS0ID_HASCOMPONENT};
  57. static const UA_NodeId nodeIdHasProperty = {
  58. .namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  59. .identifier.numeric = UA_NS0ID_HASPROPERTY};
  60. static const UA_NodeId nodeIdOrganizes = {
  61. .namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  62. .identifier.numeric = UA_NS0ID_ORGANIZES};
  63. static const UA_ExpandedNodeId expandedNodeIdBaseDataVariabletype = {
  64. .nodeId = {.namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  65. .identifier.numeric = UA_NS0ID_BASEDATAVARIABLETYPE},
  66. .namespaceUri = {.length = -1, .data = NULL}, .serverIndex = 0};
  67. #ifndef UA_ENABLE_GENERATE_NAMESPACE0
  68. static const UA_NodeId nodeIdNonHierarchicalReferences = {
  69. .namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  70. .identifier.numeric = UA_NS0ID_NONHIERARCHICALREFERENCES};
  71. #endif
  72. /**********************/
  73. /* Namespace Handling */
  74. /**********************/
  75. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  76. static void UA_ExternalNamespace_init(UA_ExternalNamespace *ens) {
  77. ens->index = 0;
  78. UA_String_init(&ens->url);
  79. }
  80. static void UA_ExternalNamespace_deleteMembers(UA_ExternalNamespace *ens) {
  81. UA_String_deleteMembers(&ens->url);
  82. ens->externalNodeStore.destroy(ens->externalNodeStore.ensHandle);
  83. }
  84. static void UA_Server_deleteExternalNamespaces(UA_Server *server) {
  85. for(UA_UInt32 i = 0; i < server->externalNamespacesSize; i++){
  86. UA_ExternalNamespace_deleteMembers(&(server->externalNamespaces[i]));
  87. }
  88. if(server->externalNamespacesSize > 0){
  89. UA_free(server->externalNamespaces);
  90. server->externalNamespaces = NULL;
  91. server->externalNamespacesSize = 0;
  92. }
  93. }
  94. UA_StatusCode UA_EXPORT
  95. UA_Server_addExternalNamespace(UA_Server *server, UA_UInt16 namespaceIndex,
  96. const UA_String *url, UA_ExternalNodeStore *nodeStore) {
  97. if(nodeStore == NULL)
  98. return UA_STATUSCODE_BADARGUMENTSMISSING;
  99. UA_UInt32 size = server->externalNamespacesSize;
  100. //do not allow double indices
  101. for(UA_UInt32 i = 0; i < size; i++) {
  102. if(server->externalNamespaces[i].index == namespaceIndex)
  103. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  104. }
  105. server->externalNamespaces =
  106. UA_realloc(server->externalNamespaces, sizeof(UA_ExternalNamespace) * (size+1));
  107. server->externalNamespaces[size].externalNodeStore = *nodeStore;
  108. server->externalNamespaces[size].index = namespaceIndex;
  109. UA_String_copy(url, &server->externalNamespaces[size].url);
  110. server->externalNamespacesSize++;
  111. return UA_STATUSCODE_GOOD;
  112. }
  113. #endif /* UA_ENABLE_EXTERNAL_NAMESPACES*/
  114. UA_UInt16 UA_Server_addNamespace(UA_Server *server, const char* name) {
  115. server->namespaces = UA_realloc(server->namespaces,
  116. sizeof(UA_String) * (server->namespacesSize+1));
  117. server->namespaces[server->namespacesSize] = UA_STRING_ALLOC(name);
  118. server->namespacesSize++;
  119. return (UA_UInt16)server->namespacesSize - 1;
  120. }
  121. UA_StatusCode
  122. UA_Server_deleteNode(UA_Server *server, const UA_NodeId nodeId, UA_Boolean deleteReferences) {
  123. UA_RCU_LOCK();
  124. UA_StatusCode retval = Service_DeleteNodes_single(server, &adminSession, &nodeId, deleteReferences);
  125. UA_RCU_UNLOCK();
  126. return retval;
  127. }
  128. UA_StatusCode
  129. UA_Server_deleteReference(UA_Server *server, const UA_NodeId sourceNodeId, const UA_NodeId referenceTypeId,
  130. UA_Boolean isForward, const UA_ExpandedNodeId targetNodeId,
  131. UA_Boolean deleteBidirectional) {
  132. UA_DeleteReferencesItem item;
  133. item.sourceNodeId = sourceNodeId;
  134. item.referenceTypeId = referenceTypeId;
  135. item.isForward = isForward;
  136. item.targetNodeId = targetNodeId;
  137. item.deleteBidirectional = deleteBidirectional;
  138. UA_RCU_LOCK();
  139. UA_StatusCode retval = Service_DeleteReferences_single(server, &adminSession, &item);
  140. UA_RCU_UNLOCK();
  141. return retval;
  142. }
  143. UA_StatusCode
  144. UA_Server_forEachChildNodeCall(UA_Server *server, UA_NodeId parentNodeId,
  145. UA_NodeIteratorCallback callback, void *handle) {
  146. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  147. UA_RCU_LOCK();
  148. const UA_Node *parent = UA_NodeStore_get(server->nodestore, &parentNodeId);
  149. if(!parent) {
  150. UA_RCU_UNLOCK();
  151. return UA_STATUSCODE_BADNODEIDINVALID;
  152. }
  153. for(size_t i = 0; i < parent->referencesSize; i++) {
  154. UA_ReferenceNode *ref = &parent->references[i];
  155. retval |= callback(ref->targetId.nodeId, ref->isInverse,
  156. ref->referenceTypeId, handle);
  157. }
  158. UA_RCU_UNLOCK();
  159. return retval;
  160. }
  161. UA_StatusCode
  162. UA_Server_addReference(UA_Server *server, const UA_NodeId sourceId,
  163. const UA_NodeId refTypeId, const UA_ExpandedNodeId targetId,
  164. UA_Boolean isForward) {
  165. UA_AddReferencesItem item;
  166. UA_AddReferencesItem_init(&item);
  167. item.sourceNodeId = sourceId;
  168. item.referenceTypeId = refTypeId;
  169. item.isForward = isForward;
  170. item.targetNodeId = targetId;
  171. UA_RCU_LOCK();
  172. UA_StatusCode retval = Service_AddReferences_single(server, &adminSession, &item);
  173. UA_RCU_UNLOCK();
  174. return retval;
  175. }
  176. static UA_StatusCode
  177. addReferenceInternal(UA_Server *server, const UA_NodeId sourceId, const UA_NodeId refTypeId,
  178. const UA_ExpandedNodeId targetId, UA_Boolean isForward) {
  179. UA_AddReferencesItem item;
  180. UA_AddReferencesItem_init(&item);
  181. item.sourceNodeId = sourceId;
  182. item.referenceTypeId = refTypeId;
  183. item.isForward = isForward;
  184. item.targetNodeId = targetId;
  185. return Service_AddReferences_single(server, &adminSession, &item);
  186. }
  187. static UA_AddNodesResult
  188. addNodeInternal(UA_Server *server, UA_Node *node, const UA_NodeId parentNodeId,
  189. const UA_NodeId referenceTypeId) {
  190. UA_AddNodesResult res;
  191. UA_AddNodesResult_init(&res);
  192. UA_Server_addExistingNode(server, &adminSession, node, &parentNodeId,
  193. &referenceTypeId, &res);
  194. return res;
  195. }
  196. UA_StatusCode
  197. __UA_Server_addNode(UA_Server *server, const UA_NodeClass nodeClass,
  198. const UA_NodeId requestedNewNodeId, const UA_NodeId parentNodeId,
  199. const UA_NodeId referenceTypeId, const UA_QualifiedName browseName,
  200. const UA_NodeId typeDefinition, const UA_NodeAttributes *attr,
  201. const UA_DataType *attributeType,
  202. UA_InstantiationCallback *instantiationCallback, UA_NodeId *outNewNodeId) {
  203. UA_AddNodesItem item;
  204. UA_AddNodesItem_init(&item);
  205. item.parentNodeId.nodeId = parentNodeId;
  206. item.referenceTypeId = referenceTypeId;
  207. item.requestedNewNodeId.nodeId = requestedNewNodeId;
  208. item.browseName = browseName;
  209. item.nodeClass = nodeClass;
  210. item.typeDefinition.nodeId = typeDefinition;
  211. item.nodeAttributes = (UA_ExtensionObject){.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE,
  212. .content.decoded = {attributeType, (void*)(uintptr_t)attr}};
  213. UA_AddNodesResult result;
  214. UA_AddNodesResult_init(&result);
  215. UA_RCU_LOCK();
  216. Service_AddNodes_single(server, &adminSession, &item, &result, instantiationCallback);
  217. UA_RCU_UNLOCK();
  218. if(outNewNodeId && result.statusCode == UA_STATUSCODE_GOOD)
  219. *outNewNodeId = result.addedNodeId;
  220. else
  221. UA_AddNodesResult_deleteMembers(&result);
  222. return result.statusCode;
  223. }
  224. /**********/
  225. /* Server */
  226. /**********/
  227. /* The server needs to be stopped before it can be deleted */
  228. void UA_Server_delete(UA_Server *server) {
  229. // Delete the timed work
  230. UA_RCU_LOCK();
  231. UA_Server_deleteAllRepeatedJobs(server);
  232. // Delete all internal data
  233. UA_SecureChannelManager_deleteMembers(&server->secureChannelManager);
  234. UA_SessionManager_deleteMembers(&server->sessionManager, server);
  235. UA_NodeStore_delete(server->nodestore);
  236. #ifdef UA_ENABLE_EXTERNAL_NAMESPACES
  237. UA_Server_deleteExternalNamespaces(server);
  238. #endif
  239. UA_Array_delete(server->namespaces, server->namespacesSize, &UA_TYPES[UA_TYPES_STRING]);
  240. UA_Array_delete(server->endpointDescriptions, server->endpointDescriptionsSize,
  241. &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
  242. UA_RCU_UNLOCK();
  243. #ifdef UA_ENABLE_MULTITHREADING
  244. pthread_cond_destroy(&server->dispatchQueue_condition);
  245. rcu_barrier(); // wait for all scheduled call_rcu work to complete
  246. rcu_unregister_thread();
  247. #endif
  248. UA_free(server);
  249. }
  250. /* Recurring cleanup. Removing unused and timed-out channels and sessions */
  251. static void UA_Server_cleanup(UA_Server *server, void *nothing) {
  252. UA_DateTime now = UA_DateTime_now();
  253. UA_SessionManager_cleanupTimedOut(&server->sessionManager, server, now);
  254. UA_SecureChannelManager_cleanupTimedOut(&server->secureChannelManager, now);
  255. }
  256. static UA_StatusCode
  257. readStatus(void *handle, const UA_NodeId nodeid, UA_Boolean sourceTimeStamp,
  258. const UA_NumericRange *range, UA_DataValue *value) {
  259. if(range) {
  260. value->hasStatus = UA_TRUE;
  261. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  262. return UA_STATUSCODE_GOOD;
  263. }
  264. UA_Server *server = (UA_Server*)handle;
  265. UA_ServerStatusDataType *status = UA_ServerStatusDataType_new();
  266. status->startTime = server->startTime;
  267. status->currentTime = UA_DateTime_now();
  268. status->state = UA_SERVERSTATE_RUNNING;
  269. status->secondsTillShutdown = 0;
  270. value->value.type = &UA_TYPES[UA_TYPES_SERVERSTATUSDATATYPE];
  271. value->value.arrayLength = 0;
  272. value->value.data = status;
  273. value->value.arrayDimensionsSize = 0;
  274. value->value.arrayDimensions = NULL;
  275. value->hasValue = UA_TRUE;
  276. if(sourceTimeStamp) {
  277. value->hasSourceTimestamp = UA_TRUE;
  278. value->sourceTimestamp = UA_DateTime_now();
  279. }
  280. return UA_STATUSCODE_GOOD;
  281. }
  282. static UA_StatusCode
  283. readNamespaces(void *handle, const UA_NodeId nodeid, UA_Boolean sourceTimestamp,
  284. const UA_NumericRange *range, UA_DataValue *value) {
  285. if(range) {
  286. value->hasStatus = UA_TRUE;
  287. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  288. return UA_STATUSCODE_GOOD;
  289. }
  290. UA_Server *server = (UA_Server*)handle;
  291. UA_StatusCode retval;
  292. retval = UA_Variant_setArrayCopy(&value->value, server->namespaces,
  293. server->namespacesSize, &UA_TYPES[UA_TYPES_STRING]);
  294. if(retval != UA_STATUSCODE_GOOD)
  295. return retval;
  296. value->hasValue = UA_TRUE;
  297. if(sourceTimestamp) {
  298. value->hasSourceTimestamp = UA_TRUE;
  299. value->sourceTimestamp = UA_DateTime_now();
  300. }
  301. return UA_STATUSCODE_GOOD;
  302. }
  303. static UA_StatusCode
  304. readCurrentTime(void *handle, const UA_NodeId nodeid, UA_Boolean sourceTimeStamp,
  305. const UA_NumericRange *range, UA_DataValue *value) {
  306. if(range) {
  307. value->hasStatus = UA_TRUE;
  308. value->status = UA_STATUSCODE_BADINDEXRANGEINVALID;
  309. return UA_STATUSCODE_GOOD;
  310. }
  311. UA_DateTime currentTime = UA_DateTime_now();
  312. UA_StatusCode retval = UA_Variant_setScalarCopy(&value->value, &currentTime, &UA_TYPES[UA_TYPES_DATETIME]);
  313. if(retval != UA_STATUSCODE_GOOD)
  314. return retval;
  315. value->hasValue = UA_TRUE;
  316. if(sourceTimeStamp) {
  317. value->hasSourceTimestamp = UA_TRUE;
  318. value->sourceTimestamp = currentTime;
  319. }
  320. return UA_STATUSCODE_GOOD;
  321. }
  322. static void copyNames(UA_Node *node, char *name) {
  323. node->browseName = UA_QUALIFIEDNAME_ALLOC(0, name);
  324. node->displayName = UA_LOCALIZEDTEXT_ALLOC("en_US", name);
  325. node->description = UA_LOCALIZEDTEXT_ALLOC("en_US", name);
  326. }
  327. static void
  328. addDataTypeNode(UA_Server *server, char* name, UA_UInt32 datatypeid, UA_Int32 parent) {
  329. UA_DataTypeNode *datatype = UA_DataTypeNode_new();
  330. copyNames((UA_Node*)datatype, name);
  331. datatype->nodeId.identifier.numeric = datatypeid;
  332. addNodeInternal(server, (UA_Node*)datatype, UA_NODEID_NUMERIC(0, parent), nodeIdOrganizes);
  333. }
  334. static void
  335. addObjectTypeNode(UA_Server *server, char* name, UA_UInt32 objecttypeid,
  336. UA_Int32 parent, UA_Int32 parentreference) {
  337. UA_ObjectTypeNode *objecttype = UA_ObjectTypeNode_new();
  338. copyNames((UA_Node*)objecttype, name);
  339. objecttype->nodeId.identifier.numeric = objecttypeid;
  340. addNodeInternal(server, (UA_Node*)objecttype, UA_NODEID_NUMERIC(0, parent),
  341. UA_NODEID_NUMERIC(0, parentreference));
  342. }
  343. static UA_VariableTypeNode*
  344. createVariableTypeNode(UA_Server *server, char* name, UA_UInt32 variabletypeid,
  345. UA_Int32 parent, UA_Boolean abstract) {
  346. UA_VariableTypeNode *variabletype = UA_VariableTypeNode_new();
  347. copyNames((UA_Node*)variabletype, name);
  348. variabletype->nodeId.identifier.numeric = variabletypeid;
  349. variabletype->isAbstract = abstract;
  350. variabletype->value.variant.value.type = &UA_TYPES[UA_TYPES_VARIANT];
  351. return variabletype;
  352. }
  353. static void
  354. addVariableTypeNode_organized(UA_Server *server, char* name, UA_UInt32 variabletypeid,
  355. UA_Int32 parent, UA_Boolean abstract) {
  356. UA_VariableTypeNode *variabletype = createVariableTypeNode(server, name, variabletypeid, parent, abstract);
  357. addNodeInternal(server, (UA_Node*)variabletype, UA_NODEID_NUMERIC(0, parent), nodeIdOrganizes);
  358. }
  359. static void
  360. addVariableTypeNode_subtype(UA_Server *server, char* name, UA_UInt32 variabletypeid,
  361. UA_Int32 parent, UA_Boolean abstract) {
  362. UA_VariableTypeNode *variabletype =
  363. createVariableTypeNode(server, name, variabletypeid, parent, abstract);
  364. addNodeInternal(server, (UA_Node*)variabletype, UA_NODEID_NUMERIC(0, parent), nodeIdHasSubType);
  365. }
  366. UA_Server * UA_Server_new(const UA_ServerConfig config) {
  367. UA_Server *server = UA_calloc(1, sizeof(UA_Server));
  368. if(!server)
  369. return NULL;
  370. server->config = config;
  371. LIST_INIT(&server->repeatedJobs);
  372. #ifdef UA_ENABLE_MULTITHREADING
  373. rcu_init();
  374. rcu_register_thread();
  375. cds_wfcq_init(&server->dispatchQueue_head, &server->dispatchQueue_tail);
  376. cds_lfs_init(&server->mainLoopJobs);
  377. UA_RCU_LOCK();
  378. #endif
  379. /* uncomment for non-reproducible server runs */
  380. //UA_random_seed(UA_DateTime_now());
  381. /* ns0 and ns1 */
  382. server->namespaces = UA_Array_new(2, &UA_TYPES[UA_TYPES_STRING]);
  383. server->namespaces[0] = UA_STRING_ALLOC("http://opcfoundation.org/UA/");
  384. UA_String_copy(&server->config.applicationDescription.applicationUri, &server->namespaces[1]);
  385. server->namespacesSize = 2;
  386. server->endpointDescriptions = UA_Array_new(server->config.networkLayersSize,
  387. &UA_TYPES[UA_TYPES_ENDPOINTDESCRIPTION]);
  388. server->endpointDescriptionsSize = server->config.networkLayersSize;
  389. for(size_t i = 0; i < server->config.networkLayersSize; i++) {
  390. UA_EndpointDescription *endpoint = &server->endpointDescriptions[i];
  391. endpoint->securityMode = UA_MESSAGESECURITYMODE_NONE;
  392. endpoint->securityPolicyUri =
  393. UA_STRING_ALLOC("http://opcfoundation.org/UA/SecurityPolicy#None");
  394. endpoint->transportProfileUri =
  395. UA_STRING_ALLOC("http://opcfoundation.org/UA-Profile/Transport/uatcp-uasc-uabinary");
  396. size_t policies = 0;
  397. if(server->config.enableAnonymousLogin)
  398. policies++;
  399. if(server->config.enableUsernamePasswordLogin)
  400. policies++;
  401. endpoint->userIdentityTokensSize = policies;
  402. endpoint->userIdentityTokens = UA_Array_new(policies, &UA_TYPES[UA_TYPES_USERTOKENPOLICY]);
  403. size_t currentIndex = 0;
  404. if(server->config.enableAnonymousLogin) {
  405. UA_UserTokenPolicy_init(&endpoint->userIdentityTokens[currentIndex]);
  406. endpoint->userIdentityTokens[currentIndex].tokenType = UA_USERTOKENTYPE_ANONYMOUS;
  407. endpoint->userIdentityTokens[currentIndex].policyId = UA_STRING_ALLOC(ANONYMOUS_POLICY);
  408. currentIndex++;
  409. }
  410. if(server->config.enableUsernamePasswordLogin) {
  411. UA_UserTokenPolicy_init(&endpoint->userIdentityTokens[currentIndex]);
  412. endpoint->userIdentityTokens[currentIndex].tokenType = UA_USERTOKENTYPE_USERNAME;
  413. endpoint->userIdentityTokens[currentIndex].policyId = UA_STRING_ALLOC(USERNAME_POLICY);
  414. }
  415. /* The standard says "the HostName specified in the Server Certificate is the
  416. same as the HostName contained in the endpointUrl provided in the
  417. EndpointDescription */
  418. UA_String_copy(&server->config.networkLayers[i].discoveryUrl, &endpoint->endpointUrl);
  419. UA_String_copy(&server->config.serverCertificate, &endpoint->serverCertificate);
  420. UA_ApplicationDescription_copy(&server->config.applicationDescription, &endpoint->server);
  421. }
  422. #define MAXCHANNELCOUNT 100
  423. #define STARTCHANNELID 1
  424. #define TOKENLIFETIME 600000 //this is in milliseconds //600000 seems to be the minimal allowet time for UaExpert
  425. #define STARTTOKENID 1
  426. UA_SecureChannelManager_init(&server->secureChannelManager, MAXCHANNELCOUNT,
  427. TOKENLIFETIME, STARTCHANNELID, STARTTOKENID);
  428. #define MAXSESSIONCOUNT 1000
  429. #define MAXSESSIONLIFETIME 10000
  430. #define STARTSESSIONID 1
  431. UA_SessionManager_init(&server->sessionManager, MAXSESSIONCOUNT, MAXSESSIONLIFETIME, STARTSESSIONID);
  432. server->nodestore = UA_NodeStore_new();
  433. UA_Job cleanup = {.type = UA_JOBTYPE_METHODCALL,
  434. .job.methodCall = {.method = UA_Server_cleanup, .data = NULL} };
  435. UA_Server_addRepeatedJob(server, cleanup, 10000, NULL);
  436. /**********************/
  437. /* Server Information */
  438. /**********************/
  439. server->startTime = UA_DateTime_now();
  440. /**************/
  441. /* References */
  442. /**************/
  443. #ifndef UA_ENABLE_GENERATE_NAMESPACE0
  444. /* Bootstrap by manually inserting "references" and "hassubtype" */
  445. UA_ReferenceTypeNode *references = UA_ReferenceTypeNode_new();
  446. copyNames((UA_Node*)references, "References");
  447. references->nodeId.identifier.numeric = UA_NS0ID_REFERENCES;
  448. references->isAbstract = UA_TRUE;
  449. references->symmetric = UA_TRUE;
  450. references->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "References");
  451. /* The reference to root is later inserted */
  452. UA_NodeStore_insert(server->nodestore, (UA_Node*)references, NULL);
  453. UA_ReferenceTypeNode *hassubtype = UA_ReferenceTypeNode_new();
  454. copyNames((UA_Node*)hassubtype, "HasSubtype");
  455. hassubtype->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "HasSupertype");
  456. hassubtype->nodeId.identifier.numeric = UA_NS0ID_HASSUBTYPE;
  457. hassubtype->isAbstract = UA_FALSE;
  458. hassubtype->symmetric = UA_FALSE;
  459. /* The reference to root is later inserted */
  460. UA_NodeStore_insert(server->nodestore, (UA_Node*)hassubtype, NULL);
  461. /* Continue adding reference types with normal "addnode" */
  462. UA_ReferenceTypeNode *hierarchicalreferences = UA_ReferenceTypeNode_new();
  463. copyNames((UA_Node*)hierarchicalreferences, "Hierarchicalreferences");
  464. hierarchicalreferences->nodeId.identifier.numeric = UA_NS0ID_HIERARCHICALREFERENCES;
  465. hierarchicalreferences->isAbstract = UA_TRUE;
  466. hierarchicalreferences->symmetric = UA_FALSE;
  467. addNodeInternal(server, (UA_Node*)hierarchicalreferences,
  468. UA_NODEID_NUMERIC(0, UA_NS0ID_REFERENCES), nodeIdHasSubType);
  469. UA_ReferenceTypeNode *nonhierarchicalreferences = UA_ReferenceTypeNode_new();
  470. copyNames((UA_Node*)nonhierarchicalreferences, "NonHierarchicalReferences");
  471. nonhierarchicalreferences->nodeId.identifier.numeric = UA_NS0ID_NONHIERARCHICALREFERENCES;
  472. nonhierarchicalreferences->isAbstract = UA_TRUE;
  473. nonhierarchicalreferences->symmetric = UA_FALSE;
  474. addNodeInternal(server, (UA_Node*)nonhierarchicalreferences,
  475. UA_NODEID_NUMERIC(0, UA_NS0ID_REFERENCES), nodeIdHasSubType);
  476. UA_ReferenceTypeNode *haschild = UA_ReferenceTypeNode_new();
  477. copyNames((UA_Node*)haschild, "HasChild");
  478. haschild->nodeId.identifier.numeric = UA_NS0ID_HASCHILD;
  479. haschild->isAbstract = UA_TRUE;
  480. haschild->symmetric = UA_FALSE;
  481. addNodeInternal(server, (UA_Node*)haschild,
  482. UA_NODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES), nodeIdHasSubType);
  483. UA_ReferenceTypeNode *organizes = UA_ReferenceTypeNode_new();
  484. copyNames((UA_Node*)organizes, "Organizes");
  485. organizes->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "OrganizedBy");
  486. organizes->nodeId.identifier.numeric = UA_NS0ID_ORGANIZES;
  487. organizes->isAbstract = UA_FALSE;
  488. organizes->symmetric = UA_FALSE;
  489. addNodeInternal(server, (UA_Node*)organizes,
  490. UA_NODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES), nodeIdHasSubType);
  491. UA_ReferenceTypeNode *haseventsource = UA_ReferenceTypeNode_new();
  492. copyNames((UA_Node*)haseventsource, "HasEventSource");
  493. haseventsource->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "EventSourceOf");
  494. haseventsource->nodeId.identifier.numeric = UA_NS0ID_HASEVENTSOURCE;
  495. haseventsource->isAbstract = UA_FALSE;
  496. haseventsource->symmetric = UA_FALSE;
  497. addNodeInternal(server, (UA_Node*)haseventsource,
  498. UA_NODEID_NUMERIC(0, UA_NS0ID_HIERARCHICALREFERENCES), nodeIdHasSubType);
  499. UA_ReferenceTypeNode *hasmodellingrule = UA_ReferenceTypeNode_new();
  500. copyNames((UA_Node*)hasmodellingrule, "HasModellingRule");
  501. hasmodellingrule->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "ModellingRuleOf");
  502. hasmodellingrule->nodeId.identifier.numeric = UA_NS0ID_HASMODELLINGRULE;
  503. hasmodellingrule->isAbstract = UA_FALSE;
  504. hasmodellingrule->symmetric = UA_FALSE;
  505. addNodeInternal(server, (UA_Node*)hasmodellingrule, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  506. UA_ReferenceTypeNode *hasencoding = UA_ReferenceTypeNode_new();
  507. copyNames((UA_Node*)hasencoding, "HasEncoding");
  508. hasencoding->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "EncodingOf");
  509. hasencoding->nodeId.identifier.numeric = UA_NS0ID_HASENCODING;
  510. hasencoding->isAbstract = UA_FALSE;
  511. hasencoding->symmetric = UA_FALSE;
  512. addNodeInternal(server, (UA_Node*)hasencoding, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  513. UA_ReferenceTypeNode *hasdescription = UA_ReferenceTypeNode_new();
  514. copyNames((UA_Node*)hasdescription, "HasDescription");
  515. hasdescription->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "DescriptionOf");
  516. hasdescription->nodeId.identifier.numeric = UA_NS0ID_HASDESCRIPTION;
  517. hasdescription->isAbstract = UA_FALSE;
  518. hasdescription->symmetric = UA_FALSE;
  519. addNodeInternal(server, (UA_Node*)hasdescription, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  520. UA_ReferenceTypeNode *hastypedefinition = UA_ReferenceTypeNode_new();
  521. copyNames((UA_Node*)hastypedefinition, "HasTypeDefinition");
  522. hastypedefinition->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "TypeDefinitionOf");
  523. hastypedefinition->nodeId.identifier.numeric = UA_NS0ID_HASTYPEDEFINITION;
  524. hastypedefinition->isAbstract = UA_FALSE;
  525. hastypedefinition->symmetric = UA_FALSE;
  526. addNodeInternal(server, (UA_Node*)hastypedefinition, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  527. UA_ReferenceTypeNode *generatesevent = UA_ReferenceTypeNode_new();
  528. copyNames((UA_Node*)generatesevent, "GeneratesEvent");
  529. generatesevent->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "GeneratedBy");
  530. generatesevent->nodeId.identifier.numeric = UA_NS0ID_GENERATESEVENT;
  531. generatesevent->isAbstract = UA_FALSE;
  532. generatesevent->symmetric = UA_FALSE;
  533. addNodeInternal(server, (UA_Node*)generatesevent, nodeIdNonHierarchicalReferences,
  534. nodeIdHasSubType);
  535. UA_ReferenceTypeNode *aggregates = UA_ReferenceTypeNode_new();
  536. copyNames((UA_Node*)aggregates, "Aggregates");
  537. // Todo: Is there an inverse name?
  538. aggregates->nodeId.identifier.numeric = UA_NS0ID_AGGREGATES;
  539. aggregates->isAbstract = UA_TRUE;
  540. aggregates->symmetric = UA_FALSE;
  541. addNodeInternal(server, (UA_Node*)aggregates,
  542. UA_NODEID_NUMERIC(0, UA_NS0ID_HASCHILD), nodeIdHasSubType);
  543. // complete bootstrap of hassubtype
  544. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_HASCHILD), nodeIdHasSubType,
  545. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_HASSUBTYPE), UA_TRUE);
  546. UA_ReferenceTypeNode *hasproperty = UA_ReferenceTypeNode_new();
  547. copyNames((UA_Node*)hasproperty, "HasProperty");
  548. hasproperty->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "PropertyOf");
  549. hasproperty->nodeId.identifier.numeric = UA_NS0ID_HASPROPERTY;
  550. hasproperty->isAbstract = UA_FALSE;
  551. hasproperty->symmetric = UA_FALSE;
  552. addNodeInternal(server, (UA_Node*)hasproperty,
  553. UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES), nodeIdHasSubType);
  554. UA_ReferenceTypeNode *hascomponent = UA_ReferenceTypeNode_new();
  555. copyNames((UA_Node*)hascomponent, "HasComponent");
  556. hascomponent->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "ComponentOf");
  557. hascomponent->nodeId.identifier.numeric = UA_NS0ID_HASCOMPONENT;
  558. hascomponent->isAbstract = UA_FALSE;
  559. hascomponent->symmetric = UA_FALSE;
  560. addNodeInternal(server, (UA_Node*)hascomponent,
  561. UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES), nodeIdHasSubType);
  562. UA_ReferenceTypeNode *hasnotifier = UA_ReferenceTypeNode_new();
  563. copyNames((UA_Node*)hasnotifier, "HasNotifier");
  564. hasnotifier->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "NotifierOf");
  565. hasnotifier->nodeId.identifier.numeric = UA_NS0ID_HASNOTIFIER;
  566. hasnotifier->isAbstract = UA_FALSE;
  567. hasnotifier->symmetric = UA_FALSE;
  568. addNodeInternal(server, (UA_Node*)hasnotifier, UA_NODEID_NUMERIC(0, UA_NS0ID_HASEVENTSOURCE),
  569. nodeIdHasSubType);
  570. UA_ReferenceTypeNode *hasorderedcomponent = UA_ReferenceTypeNode_new();
  571. copyNames((UA_Node*)hasorderedcomponent, "HasOrderedComponent");
  572. hasorderedcomponent->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "OrderedComponentOf");
  573. hasorderedcomponent->nodeId.identifier.numeric = UA_NS0ID_HASORDEREDCOMPONENT;
  574. hasorderedcomponent->isAbstract = UA_FALSE;
  575. hasorderedcomponent->symmetric = UA_FALSE;
  576. addNodeInternal(server, (UA_Node*)hasorderedcomponent, UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT),
  577. nodeIdHasSubType);
  578. UA_ReferenceTypeNode *hasmodelparent = UA_ReferenceTypeNode_new();
  579. copyNames((UA_Node*)hasmodelparent, "HasModelParent");
  580. hasmodelparent->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "ModelParentOf");
  581. hasmodelparent->nodeId.identifier.numeric = UA_NS0ID_HASMODELPARENT;
  582. hasmodelparent->isAbstract = UA_FALSE;
  583. hasmodelparent->symmetric = UA_FALSE;
  584. addNodeInternal(server, (UA_Node*)hasmodelparent, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  585. UA_ReferenceTypeNode *fromstate = UA_ReferenceTypeNode_new();
  586. copyNames((UA_Node*)fromstate, "FromState");
  587. fromstate->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "ToTransition");
  588. fromstate->nodeId.identifier.numeric = UA_NS0ID_FROMSTATE;
  589. fromstate->isAbstract = UA_FALSE;
  590. fromstate->symmetric = UA_FALSE;
  591. addNodeInternal(server, (UA_Node*)fromstate, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  592. UA_ReferenceTypeNode *tostate = UA_ReferenceTypeNode_new();
  593. copyNames((UA_Node*)tostate, "ToState");
  594. tostate->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "FromTransition");
  595. tostate->nodeId.identifier.numeric = UA_NS0ID_TOSTATE;
  596. tostate->isAbstract = UA_FALSE;
  597. tostate->symmetric = UA_FALSE;
  598. addNodeInternal(server, (UA_Node*)tostate, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  599. UA_ReferenceTypeNode *hascause = UA_ReferenceTypeNode_new();
  600. copyNames((UA_Node*)hascause, "HasCause");
  601. hascause->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "MayBeCausedBy");
  602. hascause->nodeId.identifier.numeric = UA_NS0ID_HASCAUSE;
  603. hascause->isAbstract = UA_FALSE;
  604. hascause->symmetric = UA_FALSE;
  605. addNodeInternal(server, (UA_Node*)hascause, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  606. UA_ReferenceTypeNode *haseffect = UA_ReferenceTypeNode_new();
  607. copyNames((UA_Node*)haseffect, "HasEffect");
  608. haseffect->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "MayBeEffectedBy");
  609. haseffect->nodeId.identifier.numeric = UA_NS0ID_HASEFFECT;
  610. haseffect->isAbstract = UA_FALSE;
  611. haseffect->symmetric = UA_FALSE;
  612. addNodeInternal(server, (UA_Node*)haseffect, nodeIdNonHierarchicalReferences, nodeIdHasSubType);
  613. UA_ReferenceTypeNode *hashistoricalconfiguration = UA_ReferenceTypeNode_new();
  614. copyNames((UA_Node*)hashistoricalconfiguration, "HasHistoricalConfiguration");
  615. hashistoricalconfiguration->inverseName = UA_LOCALIZEDTEXT_ALLOC("en_US", "HistoricalConfigurationOf");
  616. hashistoricalconfiguration->nodeId.identifier.numeric = UA_NS0ID_HASHISTORICALCONFIGURATION;
  617. hashistoricalconfiguration->isAbstract = UA_FALSE;
  618. hashistoricalconfiguration->symmetric = UA_FALSE;
  619. addNodeInternal(server, (UA_Node*)hashistoricalconfiguration,
  620. UA_NODEID_NUMERIC(0, UA_NS0ID_AGGREGATES), nodeIdHasSubType);
  621. /*****************/
  622. /* Basic Folders */
  623. /*****************/
  624. UA_ObjectNode *root = UA_ObjectNode_new();
  625. copyNames((UA_Node*)root, "Root");
  626. root->nodeId.identifier.numeric = UA_NS0ID_ROOTFOLDER;
  627. UA_NodeStore_insert(server->nodestore, (UA_Node*)root, NULL);
  628. UA_ObjectNode *objects = UA_ObjectNode_new();
  629. copyNames((UA_Node*)objects, "Objects");
  630. objects->nodeId.identifier.numeric = UA_NS0ID_OBJECTSFOLDER;
  631. addNodeInternal(server, (UA_Node*)objects, UA_NODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  632. nodeIdOrganizes);
  633. UA_ObjectNode *types = UA_ObjectNode_new();
  634. copyNames((UA_Node*)types, "Types");
  635. types->nodeId.identifier.numeric = UA_NS0ID_TYPESFOLDER;
  636. addNodeInternal(server, (UA_Node*)types, UA_NODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  637. nodeIdOrganizes);
  638. UA_ObjectNode *views = UA_ObjectNode_new();
  639. copyNames((UA_Node*)views, "Views");
  640. views->nodeId.identifier.numeric = UA_NS0ID_VIEWSFOLDER;
  641. addNodeInternal(server, (UA_Node*)views, UA_NODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  642. nodeIdOrganizes);
  643. UA_ObjectNode *referencetypes = UA_ObjectNode_new();
  644. copyNames((UA_Node*)referencetypes, "ReferenceTypes");
  645. referencetypes->nodeId.identifier.numeric = UA_NS0ID_REFERENCETYPESFOLDER;
  646. addNodeInternal(server, (UA_Node*)referencetypes, UA_NODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER),
  647. nodeIdOrganizes);
  648. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_REFERENCETYPESFOLDER), nodeIdOrganizes,
  649. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_REFERENCES), UA_TRUE);
  650. /**********************/
  651. /* Basic Object Types */
  652. /**********************/
  653. UA_ObjectNode *objecttypes = UA_ObjectNode_new();
  654. copyNames((UA_Node*)objecttypes, "ObjectTypes");
  655. objecttypes->nodeId.identifier.numeric = UA_NS0ID_OBJECTTYPESFOLDER;
  656. addNodeInternal(server, (UA_Node*)objecttypes, UA_NODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER),
  657. nodeIdOrganizes);
  658. addObjectTypeNode(server, "BaseObjectType", UA_NS0ID_BASEOBJECTTYPE, UA_NS0ID_OBJECTTYPESFOLDER,
  659. UA_NS0ID_ORGANIZES);
  660. addObjectTypeNode(server, "FolderType", UA_NS0ID_FOLDERTYPE, UA_NS0ID_BASEOBJECTTYPE, UA_NS0ID_HASSUBTYPE);
  661. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTTYPESFOLDER), nodeIdHasTypeDefinition,
  662. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  663. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER), nodeIdHasTypeDefinition,
  664. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  665. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER), nodeIdHasTypeDefinition,
  666. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  667. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER), nodeIdHasTypeDefinition,
  668. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  669. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_VIEWSFOLDER), nodeIdHasTypeDefinition,
  670. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  671. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_REFERENCETYPESFOLDER),
  672. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  673. addObjectTypeNode(server, "ServerType", UA_NS0ID_SERVERTYPE, UA_NS0ID_BASEOBJECTTYPE, UA_NS0ID_HASSUBTYPE);
  674. addObjectTypeNode(server, "ServerDiagnosticsType", UA_NS0ID_SERVERDIAGNOSTICSTYPE,
  675. UA_NS0ID_BASEOBJECTTYPE, UA_NS0ID_HASSUBTYPE);
  676. addObjectTypeNode(server, "ServerCapatilitiesType", UA_NS0ID_SERVERCAPABILITIESTYPE,
  677. UA_NS0ID_BASEOBJECTTYPE, UA_NS0ID_HASSUBTYPE);
  678. addObjectTypeNode(server, "ServerStatusType", UA_NS0ID_SERVERSTATUSTYPE, UA_NS0ID_BASEOBJECTTYPE,
  679. UA_NS0ID_HASSUBTYPE);
  680. addObjectTypeNode(server, "BuildInfoType", UA_NS0ID_BUILDINFOTYPE, UA_NS0ID_BASEOBJECTTYPE,
  681. UA_NS0ID_HASSUBTYPE);
  682. /**************/
  683. /* Data Types */
  684. /**************/
  685. UA_ObjectNode *datatypes = UA_ObjectNode_new();
  686. copyNames((UA_Node*)datatypes, "DataTypes");
  687. datatypes->nodeId.identifier.numeric = UA_NS0ID_DATATYPESFOLDER;
  688. addNodeInternal(server, (UA_Node*)datatypes, UA_NODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER), nodeIdOrganizes);
  689. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_DATATYPESFOLDER), nodeIdHasTypeDefinition,
  690. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  691. addDataTypeNode(server, "BaseDataType", UA_NS0ID_BASEDATATYPE, UA_NS0ID_DATATYPESFOLDER);
  692. addDataTypeNode(server, "Boolean", UA_NS0ID_BOOLEAN, UA_NS0ID_BASEDATATYPE);
  693. addDataTypeNode(server, "Number", UA_NS0ID_NUMBER, UA_NS0ID_BASEDATATYPE);
  694. addDataTypeNode(server, "Float", UA_NS0ID_FLOAT, UA_NS0ID_NUMBER);
  695. addDataTypeNode(server, "Double", UA_NS0ID_DOUBLE, UA_NS0ID_NUMBER);
  696. addDataTypeNode(server, "Integer", UA_NS0ID_INTEGER, UA_NS0ID_NUMBER);
  697. addDataTypeNode(server, "SByte", UA_NS0ID_SBYTE, UA_NS0ID_INTEGER);
  698. addDataTypeNode(server, "Int16", UA_NS0ID_INT16, UA_NS0ID_INTEGER);
  699. addDataTypeNode(server, "Int32", UA_NS0ID_INT32, UA_NS0ID_INTEGER);
  700. addDataTypeNode(server, "Int64", UA_NS0ID_INT64, UA_NS0ID_INTEGER);
  701. addDataTypeNode(server, "UInteger", UA_NS0ID_UINTEGER, UA_NS0ID_INTEGER);
  702. addDataTypeNode(server, "Byte", UA_NS0ID_BYTE, UA_NS0ID_UINTEGER);
  703. addDataTypeNode(server, "UInt16", UA_NS0ID_UINT16, UA_NS0ID_UINTEGER);
  704. addDataTypeNode(server, "UInt32", UA_NS0ID_UINT32, UA_NS0ID_UINTEGER);
  705. addDataTypeNode(server, "UInt64", UA_NS0ID_UINT64, UA_NS0ID_UINTEGER);
  706. addDataTypeNode(server, "String", UA_NS0ID_STRING, UA_NS0ID_BASEDATATYPE);
  707. addDataTypeNode(server, "DateTime", UA_NS0ID_DATETIME, UA_NS0ID_BASEDATATYPE);
  708. addDataTypeNode(server, "Guid", UA_NS0ID_GUID, UA_NS0ID_BASEDATATYPE);
  709. addDataTypeNode(server, "ByteString", UA_NS0ID_BYTESTRING, UA_NS0ID_BASEDATATYPE);
  710. addDataTypeNode(server, "XmlElement", UA_NS0ID_XMLELEMENT, UA_NS0ID_BASEDATATYPE);
  711. addDataTypeNode(server, "NodeId", UA_NS0ID_NODEID, UA_NS0ID_BASEDATATYPE);
  712. addDataTypeNode(server, "ExpandedNodeId", UA_NS0ID_EXPANDEDNODEID, UA_NS0ID_BASEDATATYPE);
  713. addDataTypeNode(server, "StatusCode", UA_NS0ID_STATUSCODE, UA_NS0ID_BASEDATATYPE);
  714. addDataTypeNode(server, "QualifiedName", UA_NS0ID_QUALIFIEDNAME, UA_NS0ID_BASEDATATYPE);
  715. addDataTypeNode(server, "LocalizedText", UA_NS0ID_LOCALIZEDTEXT, UA_NS0ID_BASEDATATYPE);
  716. addDataTypeNode(server, "Structure", UA_NS0ID_STRUCTURE, UA_NS0ID_BASEDATATYPE);
  717. addDataTypeNode(server, "ServerStatusDataType", UA_NS0ID_SERVERSTATUSDATATYPE, UA_NS0ID_STRUCTURE);
  718. addDataTypeNode(server, "BuildInfo", UA_NS0ID_BUILDINFO, UA_NS0ID_STRUCTURE);
  719. addDataTypeNode(server, "DataValue", UA_NS0ID_DATAVALUE, UA_NS0ID_BASEDATATYPE);
  720. addDataTypeNode(server, "DiagnosticInfo", UA_NS0ID_DIAGNOSTICINFO, UA_NS0ID_BASEDATATYPE);
  721. addDataTypeNode(server, "Enumeration", UA_NS0ID_ENUMERATION, UA_NS0ID_BASEDATATYPE);
  722. addDataTypeNode(server, "ServerState", UA_NS0ID_SERVERSTATE, UA_NS0ID_ENUMERATION);
  723. UA_ObjectNode *variabletypes = UA_ObjectNode_new();
  724. copyNames((UA_Node*)variabletypes, "VariableTypes");
  725. variabletypes->nodeId.identifier.numeric = UA_NS0ID_VARIABLETYPESFOLDER;
  726. addNodeInternal(server, (UA_Node*)variabletypes, UA_NODEID_NUMERIC(0, UA_NS0ID_TYPESFOLDER),
  727. nodeIdOrganizes);
  728. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_VARIABLETYPESFOLDER),
  729. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_FOLDERTYPE), UA_TRUE);
  730. addVariableTypeNode_organized(server, "BaseVariableType", UA_NS0ID_BASEVARIABLETYPE,
  731. UA_NS0ID_VARIABLETYPESFOLDER, UA_TRUE);
  732. addVariableTypeNode_subtype(server, "BaseDataVariableType", UA_NS0ID_BASEDATAVARIABLETYPE,
  733. UA_NS0ID_BASEVARIABLETYPE, UA_FALSE);
  734. addVariableTypeNode_subtype(server, "PropertyType", UA_NS0ID_PROPERTYTYPE,
  735. UA_NS0ID_BASEVARIABLETYPE, UA_FALSE);
  736. #endif
  737. #ifdef UA_ENABLE_GENERATE_NAMESPACE0
  738. //load the generated namespace
  739. ua_namespaceinit_generated(server);
  740. #endif
  741. /*********************/
  742. /* The Server Object */
  743. /*********************/
  744. UA_ObjectNode *servernode = UA_ObjectNode_new();
  745. copyNames((UA_Node*)servernode, "Server");
  746. servernode->nodeId.identifier.numeric = UA_NS0ID_SERVER;
  747. addNodeInternal(server, (UA_Node*)servernode, UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER),
  748. nodeIdOrganizes);
  749. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER), nodeIdHasTypeDefinition,
  750. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVERTYPE), UA_TRUE);
  751. UA_VariableNode *namespaceArray = UA_VariableNode_new();
  752. copyNames((UA_Node*)namespaceArray, "NamespaceArray");
  753. namespaceArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_NAMESPACEARRAY;
  754. namespaceArray->valueSource = UA_VALUESOURCE_DATASOURCE;
  755. namespaceArray->value.dataSource = (UA_DataSource) {.handle = server, .read = readNamespaces,
  756. .write = NULL};
  757. namespaceArray->valueRank = 1;
  758. namespaceArray->minimumSamplingInterval = 1.0;
  759. addNodeInternal(server, (UA_Node*)namespaceArray, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER), nodeIdHasProperty);
  760. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACEARRAY),
  761. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE), UA_TRUE);
  762. UA_VariableNode *serverArray = UA_VariableNode_new();
  763. copyNames((UA_Node*)serverArray, "ServerArray");
  764. serverArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERARRAY;
  765. UA_Variant_setArrayCopy(&serverArray->value.variant.value,
  766. &server->config.applicationDescription.applicationUri, 1,
  767. &UA_TYPES[UA_TYPES_STRING]);
  768. serverArray->valueRank = 1;
  769. serverArray->minimumSamplingInterval = 1.0;
  770. addNodeInternal(server, (UA_Node*)serverArray, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER), nodeIdHasProperty);
  771. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERARRAY), nodeIdHasTypeDefinition,
  772. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE), UA_TRUE);
  773. UA_ObjectNode *servercapablities = UA_ObjectNode_new();
  774. copyNames((UA_Node*)servercapablities, "ServerCapabilities");
  775. servercapablities->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERCAPABILITIES;
  776. addNodeInternal(server, (UA_Node*)servercapablities, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER),
  777. nodeIdHasComponent);
  778. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES), nodeIdHasTypeDefinition,
  779. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVERCAPABILITIESTYPE), UA_TRUE);
  780. UA_VariableNode *localeIdArray = UA_VariableNode_new();
  781. copyNames((UA_Node*)localeIdArray, "LocaleIdArray");
  782. localeIdArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERCAPABILITIES_LOCALEIDARRAY;
  783. localeIdArray->value.variant.value.data = UA_Array_new(1, &UA_TYPES[UA_TYPES_STRING]);
  784. localeIdArray->value.variant.value.arrayLength = 1;
  785. localeIdArray->value.variant.value.type = &UA_TYPES[UA_TYPES_STRING];
  786. *(UA_String *)localeIdArray->value.variant.value.data = UA_STRING_ALLOC("en");
  787. localeIdArray->valueRank = 1;
  788. localeIdArray->minimumSamplingInterval = 1.0;
  789. addNodeInternal(server, (UA_Node*)localeIdArray,
  790. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES), nodeIdHasProperty);
  791. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_LOCALEIDARRAY),
  792. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE), UA_TRUE);
  793. UA_VariableNode *maxBrowseContinuationPoints = UA_VariableNode_new();
  794. copyNames((UA_Node*)maxBrowseContinuationPoints, "MaxBrowseContinuationPoints");
  795. maxBrowseContinuationPoints->nodeId.identifier.numeric =
  796. UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXBROWSECONTINUATIONPOINTS;
  797. maxBrowseContinuationPoints->value.variant.value.data = UA_UInt16_new();
  798. *((UA_UInt16*)maxBrowseContinuationPoints->value.variant.value.data) = MAXCONTINUATIONPOINTS;
  799. maxBrowseContinuationPoints->value.variant.value.type = &UA_TYPES[UA_TYPES_UINT16];
  800. addNodeInternal(server, (UA_Node*)maxBrowseContinuationPoints,
  801. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES), nodeIdHasProperty);
  802. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_MAXBROWSECONTINUATIONPOINTS),
  803. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE), UA_TRUE);
  804. /** ServerProfileArray **/
  805. #define MAX_PROFILEARRAY 16 //a *magic* limit to the number of supported profiles
  806. #define ADDPROFILEARRAY(x) profileArray[profileArraySize++] = UA_STRING_ALLOC(x)
  807. UA_String profileArray[MAX_PROFILEARRAY];
  808. UA_UInt16 profileArraySize = 0;
  809. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/NanoEmbeddedDevice");
  810. #ifdef UA_ENABLE_SERVICESET_NODEMANAGEMENT
  811. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/NodeManagement");
  812. #endif
  813. #ifdef UA_ENABLE_SERVICESET_METHOD
  814. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/Methods");
  815. #endif
  816. #ifdef UA_ENABLE_SUBSCRIPTIONS
  817. ADDPROFILEARRAY("http://opcfoundation.org/UA-Profile/Server/EmbeddedDataChangeSubscription");
  818. #endif
  819. UA_VariableNode *serverProfileArray = UA_VariableNode_new();
  820. copyNames((UA_Node*)serverProfileArray, "ServerProfileArray");
  821. serverProfileArray->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERCAPABILITIES_SERVERPROFILEARRAY;
  822. serverProfileArray->value.variant.value.arrayLength = profileArraySize;
  823. serverProfileArray->value.variant.value.data = UA_Array_new(profileArraySize, &UA_TYPES[UA_TYPES_STRING]);
  824. serverProfileArray->value.variant.value.type = &UA_TYPES[UA_TYPES_STRING];
  825. for(UA_UInt16 i=0;i<profileArraySize;i++)
  826. ((UA_String *)serverProfileArray->value.variant.value.data)[i] = profileArray[i];
  827. serverProfileArray->valueRank = 1;
  828. serverProfileArray->minimumSamplingInterval = 1.0;
  829. addNodeInternal(server, (UA_Node*)serverProfileArray,
  830. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES), nodeIdHasProperty);
  831. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERCAPABILITIES_SERVERPROFILEARRAY),
  832. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE), UA_TRUE);
  833. UA_ObjectNode *serverdiagnostics = UA_ObjectNode_new();
  834. copyNames((UA_Node*)serverdiagnostics, "ServerDiagnostics");
  835. serverdiagnostics->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERDIAGNOSTICS;
  836. addNodeInternal(server, (UA_Node*)serverdiagnostics,
  837. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER), nodeIdHasComponent);
  838. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS),
  839. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVERDIAGNOSTICSTYPE), UA_TRUE);
  840. UA_VariableNode *enabledFlag = UA_VariableNode_new();
  841. copyNames((UA_Node*)enabledFlag, "EnabledFlag");
  842. enabledFlag->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERDIAGNOSTICS_ENABLEDFLAG;
  843. enabledFlag->value.variant.value.data = UA_Boolean_new(); //initialized as false
  844. enabledFlag->value.variant.value.type = &UA_TYPES[UA_TYPES_BOOLEAN];
  845. enabledFlag->valueRank = 1;
  846. enabledFlag->minimumSamplingInterval = 1.0;
  847. addNodeInternal(server, (UA_Node*)enabledFlag,
  848. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS), nodeIdHasProperty);
  849. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERDIAGNOSTICS_ENABLEDFLAG),
  850. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_PROPERTYTYPE), UA_TRUE);
  851. UA_VariableNode *serverstatus = UA_VariableNode_new();
  852. copyNames((UA_Node*)serverstatus, "ServerStatus");
  853. serverstatus->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS);
  854. serverstatus->valueSource = UA_VALUESOURCE_DATASOURCE;
  855. serverstatus->value.dataSource = (UA_DataSource) {.handle = server, .read = readStatus, .write = NULL};
  856. addNodeInternal(server, (UA_Node*)serverstatus, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER), nodeIdHasComponent);
  857. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), nodeIdHasTypeDefinition,
  858. UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_SERVERSTATUSTYPE), UA_TRUE);
  859. UA_VariableNode *starttime = UA_VariableNode_new();
  860. copyNames((UA_Node*)starttime, "StartTime");
  861. starttime->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_STARTTIME);
  862. starttime->value.variant.value.storageType = UA_VARIANT_DATA_NODELETE;
  863. starttime->value.variant.value.data = &server->startTime;
  864. starttime->value.variant.value.type = &UA_TYPES[UA_TYPES_DATETIME];
  865. addNodeInternal(server, (UA_Node*)starttime, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS),
  866. nodeIdHasComponent);
  867. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_STARTTIME),
  868. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  869. UA_VariableNode *currenttime = UA_VariableNode_new();
  870. copyNames((UA_Node*)currenttime, "CurrentTime");
  871. currenttime->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME);
  872. currenttime->valueSource = UA_VALUESOURCE_DATASOURCE;
  873. currenttime->value.dataSource = (UA_DataSource) {.handle = NULL, .read = readCurrentTime,
  874. .write = NULL};
  875. addNodeInternal(server, (UA_Node*)currenttime,
  876. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), nodeIdHasComponent);
  877. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_CURRENTTIME),
  878. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  879. UA_VariableNode *state = UA_VariableNode_new();
  880. UA_ServerState *stateEnum = UA_ServerState_new();
  881. *stateEnum = UA_SERVERSTATE_RUNNING;
  882. copyNames((UA_Node*)state, "State");
  883. state->nodeId.identifier.numeric = UA_NS0ID_SERVER_SERVERSTATUS_STATE;
  884. state->value.variant.value.type = &UA_TYPES[UA_TYPES_SERVERSTATE];
  885. state->value.variant.value.arrayLength = 0;
  886. state->value.variant.value.data = stateEnum; // points into the other object.
  887. addNodeInternal(server, (UA_Node*)state, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS),
  888. nodeIdHasComponent);
  889. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_STATE),
  890. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  891. UA_VariableNode *buildinfo = UA_VariableNode_new();
  892. copyNames((UA_Node*)buildinfo, "BuildInfo");
  893. buildinfo->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO);
  894. UA_Variant_setScalarCopy(&buildinfo->value.variant.value,
  895. &server->config.buildInfo,
  896. &UA_TYPES[UA_TYPES_BUILDINFO]);
  897. addNodeInternal(server, (UA_Node*)buildinfo,
  898. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), nodeIdHasComponent);
  899. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO),
  900. nodeIdHasTypeDefinition, UA_EXPANDEDNODEID_NUMERIC(0, UA_NS0ID_BUILDINFOTYPE), UA_TRUE);
  901. UA_VariableNode *producturi = UA_VariableNode_new();
  902. copyNames((UA_Node*)producturi, "ProductUri");
  903. producturi->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTURI);
  904. producturi->value.variant.value.data = UA_String_new();
  905. *((UA_String*)producturi->value.variant.value.data) = UA_STRING_ALLOC(PRODUCT_URI);
  906. producturi->value.variant.value.type = &UA_TYPES[UA_TYPES_STRING];
  907. addNodeInternal(server, (UA_Node*)producturi,
  908. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), nodeIdHasComponent);
  909. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTURI),
  910. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  911. UA_VariableNode *manufacturername = UA_VariableNode_new();
  912. copyNames((UA_Node*)manufacturername, "ManufacturererName");
  913. manufacturername->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_MANUFACTURERNAME);
  914. UA_Variant_setScalarCopy(&manufacturername->value.variant.value,
  915. &server->config.buildInfo.manufacturerName,
  916. &UA_TYPES[UA_TYPES_STRING]);
  917. addNodeInternal(server, (UA_Node*)manufacturername,
  918. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), nodeIdHasComponent);
  919. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_MANUFACTURERNAME),
  920. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  921. UA_VariableNode *productname = UA_VariableNode_new();
  922. copyNames((UA_Node*)productname, "ProductName");
  923. productname->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTNAME);
  924. UA_Variant_setScalarCopy(&productname->value.variant.value, &server->config.buildInfo.productName,
  925. &UA_TYPES[UA_TYPES_STRING]);
  926. addNodeInternal(server, (UA_Node*)productname,
  927. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), nodeIdHasComponent);
  928. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_PRODUCTNAME),
  929. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  930. UA_VariableNode *softwareversion = UA_VariableNode_new();
  931. copyNames((UA_Node*)softwareversion, "SoftwareVersion");
  932. softwareversion->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_SOFTWAREVERSION);
  933. UA_Variant_setScalarCopy(&softwareversion->value.variant.value, &server->config.buildInfo.softwareVersion,
  934. &UA_TYPES[UA_TYPES_STRING]);
  935. addNodeInternal(server, (UA_Node*)softwareversion,
  936. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), nodeIdHasComponent);
  937. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_SOFTWAREVERSION),
  938. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  939. UA_VariableNode *buildnumber = UA_VariableNode_new();
  940. copyNames((UA_Node*)buildnumber, "BuildNumber");
  941. buildnumber->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDNUMBER);
  942. UA_Variant_setScalarCopy(&buildnumber->value.variant.value, &server->config.buildInfo.buildNumber,
  943. &UA_TYPES[UA_TYPES_STRING]);
  944. addNodeInternal(server, (UA_Node*)buildnumber,
  945. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), nodeIdHasComponent);
  946. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDNUMBER),
  947. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  948. UA_VariableNode *builddate = UA_VariableNode_new();
  949. copyNames((UA_Node*)builddate, "BuildDate");
  950. builddate->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDDATE);
  951. UA_Variant_setScalarCopy(&builddate->value.variant.value, &server->config.buildInfo.buildDate,
  952. &UA_TYPES[UA_TYPES_DATETIME]);
  953. addNodeInternal(server, (UA_Node*)builddate,
  954. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO), nodeIdHasComponent);
  955. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_BUILDINFO_BUILDNUMBER),
  956. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  957. UA_VariableNode *secondstillshutdown = UA_VariableNode_new();
  958. copyNames((UA_Node*)secondstillshutdown, "SecondsTillShutdown");
  959. secondstillshutdown->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_SECONDSTILLSHUTDOWN);
  960. secondstillshutdown->value.variant.value.data = UA_UInt32_new();
  961. secondstillshutdown->value.variant.value.type = &UA_TYPES[UA_TYPES_UINT32];
  962. addNodeInternal(server, (UA_Node*)secondstillshutdown,
  963. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), nodeIdHasComponent);
  964. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_SECONDSTILLSHUTDOWN),
  965. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  966. UA_VariableNode *shutdownreason = UA_VariableNode_new();
  967. copyNames((UA_Node*)shutdownreason, "ShutdownReason");
  968. shutdownreason->nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_SHUTDOWNREASON);
  969. shutdownreason->value.variant.value.data = UA_LocalizedText_new();
  970. shutdownreason->value.variant.value.type = &UA_TYPES[UA_TYPES_LOCALIZEDTEXT];
  971. addNodeInternal(server, (UA_Node*)shutdownreason,
  972. UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS), nodeIdHasComponent);
  973. addReferenceInternal(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_SERVERSTATUS_SHUTDOWNREASON),
  974. nodeIdHasTypeDefinition, expandedNodeIdBaseDataVariabletype, UA_TRUE);
  975. UA_RCU_UNLOCK();
  976. return server;
  977. }
  978. UA_StatusCode
  979. __UA_Server_write(UA_Server *server, const UA_NodeId *nodeId,
  980. const UA_AttributeId attributeId, const UA_DataType *type,
  981. const void *value) {
  982. UA_WriteValue wvalue;
  983. UA_WriteValue_init(&wvalue);
  984. wvalue.nodeId = *nodeId;
  985. wvalue.attributeId = attributeId;
  986. if(attributeId != UA_ATTRIBUTEID_VALUE)
  987. /* hacked cast. the target WriteValue is used as const anyway */
  988. UA_Variant_setScalar(&wvalue.value.value, (void*)(uintptr_t)value, type);
  989. else {
  990. if(type != &UA_TYPES[UA_TYPES_VARIANT])
  991. return UA_STATUSCODE_BADTYPEMISMATCH;
  992. wvalue.value.value = *(const UA_Variant*)value;
  993. }
  994. wvalue.value.hasValue = UA_TRUE;
  995. UA_StatusCode retval = Service_Write_single(server, &adminSession, &wvalue);
  996. return retval;
  997. }
  998. static UA_StatusCode
  999. setValueCallback(UA_Server *server, UA_Session *session, UA_VariableNode *node, UA_ValueCallback *callback) {
  1000. if(node->nodeClass != UA_NODECLASS_VARIABLE)
  1001. return UA_STATUSCODE_BADNODECLASSINVALID;
  1002. node->value.variant.callback = *callback;
  1003. return UA_STATUSCODE_GOOD;
  1004. }
  1005. UA_StatusCode UA_EXPORT
  1006. UA_Server_setVariableNode_valueCallback(UA_Server *server, const UA_NodeId nodeId,
  1007. const UA_ValueCallback callback) {
  1008. return UA_Server_editNode(server, &adminSession, &nodeId,
  1009. (UA_EditNodeCallback)setValueCallback, &callback);
  1010. }
  1011. static UA_StatusCode
  1012. setDataSource(UA_Server *server, UA_Session *session,
  1013. UA_VariableNode* node, UA_DataSource *dataSource) {
  1014. if(node->nodeClass != UA_NODECLASS_VARIABLE)
  1015. return UA_STATUSCODE_BADNODECLASSINVALID;
  1016. if(node->valueSource == UA_VALUESOURCE_VARIANT)
  1017. UA_Variant_deleteMembers(&node->value.variant.value);
  1018. node->value.dataSource = *dataSource;
  1019. node->valueSource = UA_VALUESOURCE_DATASOURCE;
  1020. return UA_STATUSCODE_GOOD;
  1021. }
  1022. UA_StatusCode
  1023. UA_Server_setVariableNode_dataSource(UA_Server *server, const UA_NodeId nodeId,
  1024. const UA_DataSource dataSource) {
  1025. return UA_Server_editNode(server, &adminSession, &nodeId,
  1026. (UA_EditNodeCallback)setDataSource, &dataSource);
  1027. }
  1028. static UA_StatusCode
  1029. setObjectTypeLifecycleManagement(UA_Server *server, UA_Session *session, UA_ObjectTypeNode* node,
  1030. UA_ObjectLifecycleManagement *olm) {
  1031. if(node->nodeClass != UA_NODECLASS_OBJECTTYPE)
  1032. return UA_STATUSCODE_BADNODECLASSINVALID;
  1033. node->lifecycleManagement = *olm;
  1034. return UA_STATUSCODE_GOOD;
  1035. }
  1036. UA_StatusCode UA_EXPORT
  1037. UA_Server_setObjectTypeNode_lifecycleManagement(UA_Server *server, UA_NodeId nodeId,
  1038. UA_ObjectLifecycleManagement olm) {
  1039. return UA_Server_editNode(server, &adminSession, &nodeId,
  1040. (UA_EditNodeCallback)setObjectTypeLifecycleManagement, &olm);
  1041. }
  1042. UA_StatusCode
  1043. __UA_Server_read(UA_Server *server, const UA_NodeId *nodeId, const UA_AttributeId attributeId, void *v) {
  1044. UA_ReadValueId item;
  1045. UA_ReadValueId_init(&item);
  1046. item.nodeId = *nodeId;
  1047. item.attributeId = attributeId;
  1048. UA_DataValue dv;
  1049. UA_DataValue_init(&dv);
  1050. Service_Read_single(server, &adminSession, UA_TIMESTAMPSTORETURN_NEITHER,
  1051. &item, &dv);
  1052. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1053. if(dv.hasStatus)
  1054. retval = dv.hasStatus;
  1055. else if(!dv.hasValue)
  1056. retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
  1057. if(retval != UA_STATUSCODE_GOOD) {
  1058. UA_DataValue_deleteMembers(&dv);
  1059. return retval;
  1060. }
  1061. if(attributeId == UA_ATTRIBUTEID_VALUE ||
  1062. attributeId == UA_ATTRIBUTEID_ARRAYDIMENSIONS)
  1063. memcpy(v, &dv.value, sizeof(UA_Variant));
  1064. else {
  1065. memcpy(v, dv.value.data, dv.value.type->memSize);
  1066. dv.value.data = NULL;
  1067. dv.value.arrayLength = 0;
  1068. UA_Variant_deleteMembers(&dv.value);
  1069. }
  1070. return UA_STATUSCODE_GOOD;
  1071. }
  1072. UA_BrowseResult
  1073. UA_Server_browse(UA_Server *server, UA_UInt32 maxrefs, const UA_BrowseDescription *descr) {
  1074. UA_BrowseResult result;
  1075. UA_BrowseResult_init(&result);
  1076. Service_Browse_single(server, &adminSession, NULL, descr, maxrefs, &result);
  1077. return result;
  1078. }
  1079. UA_BrowseResult
  1080. UA_Server_browseNext(UA_Server *server, UA_Boolean releaseContinuationPoint,
  1081. const UA_ByteString *continuationPoint) {
  1082. UA_BrowseResult result;
  1083. UA_BrowseResult_init(&result);
  1084. UA_Server_browseNext_single(server, &adminSession, releaseContinuationPoint,
  1085. continuationPoint, &result);
  1086. return result;
  1087. }
  1088. #ifdef UA_ENABLE_METHODCALLS
  1089. UA_CallMethodResult UA_Server_call(UA_Server *server, const UA_CallMethodRequest *request) {
  1090. UA_CallMethodResult result;
  1091. UA_CallMethodResult_init(&result);
  1092. Service_Call_single(server, &adminSession, request, &result);
  1093. return result;
  1094. }
  1095. #endif