check_services_view.c 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153
  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 <stdio.h>
  5. #include <stdlib.h>
  6. #include <pthread.h>
  7. #include <server/ua_server_internal.h>
  8. #include "check.h"
  9. #include "ua_server.h"
  10. #include "ua_config_standard.h"
  11. #include "ua_network_tcp.h"
  12. UA_Server *server_translate_browse;
  13. UA_Boolean *running_translate_browse;
  14. UA_ServerNetworkLayer nl_translate_browse;
  15. pthread_t server_thread_translate_browse;
  16. static void *serverloop_register(void *_) {
  17. while (*running_translate_browse)
  18. UA_Server_run_iterate(server_translate_browse, true);
  19. return NULL;
  20. }
  21. static void setup_server(void) {
  22. // start server
  23. running_translate_browse = UA_Boolean_new();
  24. *running_translate_browse = true;
  25. UA_ServerConfig config_register = UA_ServerConfig_standard;
  26. config_register.applicationDescription.applicationUri = UA_String_fromChars("urn:open62541.test.server_translate_browse");
  27. nl_translate_browse = UA_ServerNetworkLayerTCP(UA_ConnectionConfig_standard, 16664);
  28. config_register.networkLayers = &nl_translate_browse;
  29. config_register.networkLayersSize = 1;
  30. server_translate_browse = UA_Server_new(config_register);
  31. UA_Server_run_startup(server_translate_browse);
  32. pthread_create(&server_thread_translate_browse, NULL, serverloop_register, NULL);
  33. }
  34. static void teardown_server(void) {
  35. *running_translate_browse = false;
  36. pthread_join(server_thread_translate_browse, NULL);
  37. UA_Server_run_shutdown(server_translate_browse);
  38. UA_Boolean_delete(running_translate_browse);
  39. UA_String_deleteMembers(&server_translate_browse->config.applicationDescription.applicationUri);
  40. UA_Server_delete(server_translate_browse);
  41. nl_translate_browse.deleteMembers(&nl_translate_browse);
  42. }
  43. START_TEST(Service_Browse_WithBrowseName)
  44. {
  45. UA_Server *server = UA_Server_new(UA_ServerConfig_standard);
  46. UA_BrowseDescription bd;
  47. UA_BrowseDescription_init(&bd);
  48. bd.resultMask = UA_BROWSERESULTMASK_BROWSENAME;
  49. bd.nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
  50. bd.referenceTypeId = UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES);
  51. bd.browseDirection = UA_BROWSEDIRECTION_FORWARD;
  52. UA_BrowseResult br = UA_Server_browse(server, 0, &bd);
  53. ck_assert_int_eq(br.statusCode, UA_STATUSCODE_GOOD);
  54. ck_assert(br.referencesSize > 0);
  55. ck_assert(!UA_String_equal(&br.references[0].browseName.name, &UA_STRING_NULL));
  56. UA_BrowseResult_deleteMembers(&br);
  57. UA_Server_delete(server);
  58. }
  59. END_TEST
  60. START_TEST(Service_TranslateBrowsePathsToNodeIds)
  61. {
  62. UA_Client *client = UA_Client_new(UA_ClientConfig_standard);
  63. UA_StatusCode retVal = UA_Client_connect(client, "opc.tcp://localhost:16664");
  64. ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD);
  65. // Just for testing we want to translate the following path to its corresponding node id
  66. // /Objects/Server/ServerStatus/State
  67. // Equals the following node IDs:
  68. // /85/2253/2256/2259
  69. #define BROWSE_PATHS_SIZE 3
  70. char *paths[BROWSE_PATHS_SIZE] = {"Server", "ServerStatus", "State"};
  71. UA_UInt32 ids[BROWSE_PATHS_SIZE] = {UA_NS0ID_ORGANIZES, UA_NS0ID_HASCOMPONENT, UA_NS0ID_HASCOMPONENT};
  72. UA_BrowsePath browsePath;
  73. UA_BrowsePath_init(&browsePath);
  74. browsePath.startingNode = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
  75. browsePath.relativePath.elements = UA_Array_new(BROWSE_PATHS_SIZE, &UA_TYPES[UA_TYPES_RELATIVEPATHELEMENT]);
  76. browsePath.relativePath.elementsSize = BROWSE_PATHS_SIZE;
  77. for(size_t i = 0; i < BROWSE_PATHS_SIZE; i++) {
  78. UA_RelativePathElement *elem = &browsePath.relativePath.elements[i];
  79. elem->referenceTypeId = UA_NODEID_NUMERIC(0, ids[i]);
  80. elem->targetName = UA_QUALIFIEDNAME_ALLOC(0, paths[i]);
  81. }
  82. UA_TranslateBrowsePathsToNodeIdsRequest request;
  83. UA_TranslateBrowsePathsToNodeIdsRequest_init(&request);
  84. request.browsePaths = &browsePath;
  85. request.browsePathsSize = 1;
  86. UA_TranslateBrowsePathsToNodeIdsResponse response = UA_Client_Service_translateBrowsePathsToNodeIds(client, request);
  87. ck_assert_int_eq(response.responseHeader.serviceResult, UA_STATUSCODE_GOOD);
  88. ck_assert_int_eq(response.resultsSize, 1);
  89. ck_assert_int_eq(response.results[0].targetsSize, 1);
  90. ck_assert_int_eq(response.results[0].targets[0].targetId.nodeId.identifierType, UA_NODEIDTYPE_NUMERIC);
  91. ck_assert_int_eq(response.results[0].targets[0].targetId.nodeId.identifier.numeric, UA_NS0ID_SERVER_SERVERSTATUS_STATE);
  92. UA_BrowsePath_deleteMembers(&browsePath);
  93. UA_TranslateBrowsePathsToNodeIdsResponse_deleteMembers(&response);
  94. retVal = UA_Client_disconnect(client);
  95. ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD);
  96. UA_Client_delete(client);
  97. }
  98. END_TEST
  99. static Suite *testSuite_Service_TranslateBrowsePathsToNodeIds(void) {
  100. Suite *s = suite_create("Service_TranslateBrowsePathsToNodeIds");
  101. TCase *tc_browse = tcase_create("Browse Service");
  102. tcase_add_test(tc_browse, Service_Browse_WithBrowseName);
  103. suite_add_tcase(s, tc_browse);
  104. TCase *tc_translate = tcase_create("TranslateBrowsePathsToNodeIds");
  105. tcase_add_unchecked_fixture(tc_translate, setup_server, teardown_server);
  106. tcase_add_test(tc_translate, Service_TranslateBrowsePathsToNodeIds);
  107. suite_add_tcase(s, tc_translate);
  108. return s;
  109. }
  110. int main(void) {
  111. int number_failed = 0;
  112. Suite *s;
  113. SRunner *sr;
  114. s = testSuite_Service_TranslateBrowsePathsToNodeIds();
  115. sr = srunner_create(s);
  116. srunner_set_fork_status(sr, CK_NOFORK);
  117. srunner_run_all(sr, CK_NORMAL);
  118. number_failed += srunner_ntests_failed(sr);
  119. srunner_free(sr);
  120. return (number_failed == 0) ? EXIT_SUCCESS : EXIT_FAILURE;
  121. }