check_services_view.c 8.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226
  1. /* This Source Code Form is subject to the terms of the Mozilla Public
  2. * License, v. 2.0. If a copy of the MPL was not distributed with this
  3. * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
  4. #include <open62541/client_config_default.h>
  5. #include <open62541/server.h>
  6. #include <open62541/server_config_default.h>
  7. #include "server/ua_server_internal.h"
  8. #include "ua_network_tcp.h"
  9. #include <check.h>
  10. #include <stdio.h>
  11. #include <stdlib.h>
  12. #include "thread_wrapper.h"
  13. UA_Server *server_translate_browse;
  14. UA_ServerConfig *server_translate_config;
  15. UA_Boolean *running_translate_browse;
  16. THREAD_HANDLE server_thread_translate_browse;
  17. THREAD_CALLBACK(serverloop_register) {
  18. while (*running_translate_browse)
  19. UA_Server_run_iterate(server_translate_browse, true);
  20. return 0;
  21. }
  22. static void setup_server(void) {
  23. // start server
  24. running_translate_browse = UA_Boolean_new();
  25. *running_translate_browse = true;
  26. server_translate_config = UA_ServerConfig_new_default();
  27. UA_String_deleteMembers(&server_translate_config->applicationDescription.applicationUri);
  28. server_translate_config->applicationDescription.applicationUri =
  29. UA_String_fromChars("urn:open62541.test.server_translate_browse");
  30. server_translate_browse = UA_Server_new(server_translate_config);
  31. UA_Server_run_startup(server_translate_browse);
  32. THREAD_CREATE(server_thread_translate_browse, serverloop_register);
  33. }
  34. static void teardown_server(void) {
  35. *running_translate_browse = false;
  36. THREAD_JOIN(server_thread_translate_browse);
  37. UA_Server_run_shutdown(server_translate_browse);
  38. UA_Boolean_delete(running_translate_browse);
  39. UA_Server_delete(server_translate_browse);
  40. UA_ServerConfig_delete(server_translate_config);
  41. }
  42. static size_t
  43. browseWithMaxResults(UA_Server *server, UA_NodeId nodeId, UA_UInt32 maxResults) {
  44. UA_BrowseDescription bd;
  45. UA_BrowseDescription_init(&bd);
  46. bd.nodeId = nodeId;
  47. bd.resultMask = UA_BROWSERESULTMASK_ALL;
  48. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  49. UA_BrowseResult br = UA_Server_browse(server, maxResults, &bd);
  50. ck_assert_int_eq(br.statusCode, UA_STATUSCODE_GOOD);
  51. ck_assert(br.referencesSize > 0);
  52. size_t total = br.referencesSize;
  53. UA_ByteString cp = br.continuationPoint;
  54. br.continuationPoint = UA_BYTESTRING_NULL;
  55. UA_BrowseResult_deleteMembers(&br);
  56. while(cp.length > 0) {
  57. br = UA_Server_browseNext(server, false, &cp);
  58. ck_assert(br.referencesSize > 0);
  59. UA_ByteString_deleteMembers(&cp);
  60. cp = br.continuationPoint;
  61. br.continuationPoint = UA_BYTESTRING_NULL;
  62. total += br.referencesSize;
  63. UA_BrowseResult_deleteMembers(&br);
  64. }
  65. return total;
  66. }
  67. START_TEST(Service_Browse_WithMaxResults) {
  68. UA_ServerConfig *config = UA_ServerConfig_new_default();
  69. UA_Server *server = UA_Server_new(config);
  70. UA_BrowseDescription bd;
  71. UA_BrowseDescription_init(&bd);
  72. bd.resultMask = UA_BROWSERESULTMASK_ALL;
  73. bd.nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER);
  74. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  75. UA_BrowseResult br = UA_Server_browse(server, 0, &bd);
  76. ck_assert_int_eq(br.statusCode, UA_STATUSCODE_GOOD);
  77. ck_assert(br.referencesSize > 0);
  78. size_t total = br.referencesSize;
  79. UA_BrowseResult_deleteMembers(&br);
  80. for(UA_UInt32 i = 1; i <= total; i++) {
  81. size_t sum_total =
  82. browseWithMaxResults(server, UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER), i);
  83. ck_assert_int_eq(total, sum_total);
  84. }
  85. UA_Server_delete(server);
  86. UA_ServerConfig_delete(config);
  87. }
  88. END_TEST
  89. START_TEST(Service_Browse_WithBrowseName) {
  90. UA_ServerConfig *config = UA_ServerConfig_new_default();
  91. UA_Server *server = UA_Server_new(config);
  92. UA_BrowseDescription bd;
  93. UA_BrowseDescription_init(&bd);
  94. bd.resultMask = UA_BROWSERESULTMASK_BROWSENAME;
  95. bd.nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
  96. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES);
  97. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  98. UA_BrowseResult br = UA_Server_browse(server, 0, &bd);
  99. ck_assert_int_eq(br.statusCode, UA_STATUSCODE_GOOD);
  100. ck_assert(br.referencesSize > 0);
  101. ck_assert(!UA_String_equal(&br.references[0].browseName.name, &UA_STRING_NULL));
  102. UA_BrowseResult_deleteMembers(&br);
  103. UA_Server_delete(server);
  104. UA_ServerConfig_delete(config);
  105. }
  106. END_TEST
  107. START_TEST(Service_TranslateBrowsePathsToNodeIds) {
  108. UA_Client *client = UA_Client_new();
  109. UA_ClientConfig_setDefault(UA_Client_getConfig(client));
  110. UA_StatusCode retVal = UA_Client_connect(client, "opc.tcp://localhost:4840");
  111. ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD);
  112. // Just for testing we want to translate the following path to its corresponding node id
  113. // /Objects/Server/ServerStatus/State
  114. // Equals the following node IDs:
  115. // /85/2253/2256/2259
  116. #define BROWSE_PATHS_SIZE 3
  117. char *paths[BROWSE_PATHS_SIZE] = {"Server", "ServerStatus", "State"};
  118. UA_UInt32 ids[BROWSE_PATHS_SIZE] = {UA_NS0ID_ORGANIZES, UA_NS0ID_HASCOMPONENT, UA_NS0ID_HASCOMPONENT};
  119. UA_BrowsePath browsePath;
  120. UA_BrowsePath_init(&browsePath);
  121. browsePath.startingNode = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
  122. browsePath.relativePath.elements = (UA_RelativePathElement*)UA_Array_new(BROWSE_PATHS_SIZE, &UA_TYPES[UA_TYPES_RELATIVEPATHELEMENT]);
  123. browsePath.relativePath.elementsSize = BROWSE_PATHS_SIZE;
  124. for(size_t i = 0; i < BROWSE_PATHS_SIZE; i++) {
  125. UA_RelativePathElement *elem = &browsePath.relativePath.elements[i];
  126. elem->referenceTypeId = UA_NODEID_NUMERIC(0, ids[i]);
  127. elem->targetName = UA_QUALIFIEDNAME_ALLOC(0, paths[i]);
  128. }
  129. UA_TranslateBrowsePathsToNodeIdsRequest request;
  130. UA_TranslateBrowsePathsToNodeIdsRequest_init(&request);
  131. request.browsePaths = &browsePath;
  132. request.browsePathsSize = 1;
  133. UA_TranslateBrowsePathsToNodeIdsResponse response = UA_Client_Service_translateBrowsePathsToNodeIds(client, request);
  134. ck_assert_int_eq(response.responseHeader.serviceResult, UA_STATUSCODE_GOOD);
  135. ck_assert_int_eq(response.resultsSize, 1);
  136. ck_assert_int_eq(response.results[0].targetsSize, 1);
  137. ck_assert_int_eq(response.results[0].targets[0].targetId.nodeId.identifierType, UA_NODEIDTYPE_NUMERIC);
  138. ck_assert_int_eq(response.results[0].targets[0].targetId.nodeId.identifier.numeric, UA_NS0ID_SERVER_SERVERSTATUS_STATE);
  139. UA_BrowsePath_deleteMembers(&browsePath);
  140. UA_TranslateBrowsePathsToNodeIdsResponse_deleteMembers(&response);
  141. retVal = UA_Client_disconnect(client);
  142. ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD);
  143. UA_Client_delete(client);
  144. }
  145. END_TEST
  146. START_TEST(BrowseSimplifiedBrowsePath) {
  147. UA_QualifiedName objectsName = UA_QUALIFIEDNAME(0, "Objects");
  148. UA_BrowsePathResult bpr =
  149. UA_Server_browseSimplifiedBrowsePath(server_translate_browse,
  150. UA_NODEID_NUMERIC(0, UA_NS0ID_ROOTFOLDER),
  151. 1, &objectsName);
  152. ck_assert_int_eq(bpr.targetsSize, 1);
  153. UA_BrowsePathResult_deleteMembers(&bpr);
  154. }
  155. END_TEST
  156. static Suite *testSuite_Service_TranslateBrowsePathsToNodeIds(void) {
  157. Suite *s = suite_create("Service_TranslateBrowsePathsToNodeIds");
  158. TCase *tc_browse = tcase_create("Browse Service");
  159. tcase_add_test(tc_browse, Service_Browse_WithBrowseName);
  160. tcase_add_test(tc_browse, Service_Browse_WithMaxResults);
  161. suite_add_tcase(s, tc_browse);
  162. TCase *tc_translate = tcase_create("TranslateBrowsePathsToNodeIds");
  163. tcase_add_unchecked_fixture(tc_translate, setup_server, teardown_server);
  164. tcase_add_test(tc_translate, Service_TranslateBrowsePathsToNodeIds);
  165. tcase_add_test(tc_translate, BrowseSimplifiedBrowsePath);
  166. suite_add_tcase(s, tc_translate);
  167. return s;
  168. }
  169. int main(void) {
  170. int number_failed = 0;
  171. Suite *s;
  172. SRunner *sr;
  173. s = testSuite_Service_TranslateBrowsePathsToNodeIds();
  174. sr = srunner_create(s);
  175. srunner_set_fork_status(sr, CK_NOFORK);
  176. srunner_run_all(sr, CK_NORMAL);
  177. number_failed += srunner_ntests_failed(sr);
  178. srunner_free(sr);
  179. return (number_failed == 0) ? EXIT_SUCCESS : EXIT_FAILURE;
  180. }