check_pubsub_publish_json.c 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  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. *
  5. * Copyright (c) 2017 - 2018 Fraunhofer IOSB (Author: Andreas Ebner)
  6. */
  7. #include <open62541/plugin/pubsub_udp.h>
  8. #include <open62541/server_config_default.h>
  9. #include <open62541/server_pubsub.h>
  10. #include <open62541/types.h>
  11. #include <open62541/types_generated_encoding_binary.h>
  12. #include "ua_pubsub.h"
  13. #include "ua_server_internal.h"
  14. #include <check.h>
  15. UA_Server *server = NULL;
  16. UA_NodeId connection1, writerGroup1, publishedDataSet1, dataSetWriter1;
  17. static void setup(void) {
  18. server = UA_Server_new();
  19. UA_ServerConfig *config = UA_Server_getConfig(server);
  20. UA_ServerConfig_setDefault(config);
  21. config->pubsubTransportLayers = (UA_PubSubTransportLayer *) UA_malloc(sizeof(UA_PubSubTransportLayer));
  22. config->pubsubTransportLayers[0] = UA_PubSubTransportLayerUDPMP();
  23. config->pubsubTransportLayersSize++;
  24. UA_Server_run_startup(server);
  25. UA_PubSubConnectionConfig connectionConfig;
  26. memset(&connectionConfig, 0, sizeof(UA_PubSubConnectionConfig));
  27. connectionConfig.name = UA_STRING("UADP Connection");
  28. UA_NetworkAddressUrlDataType networkAddressUrl = {UA_STRING_NULL, UA_STRING("opc.udp://224.0.0.22:4840/")};
  29. UA_Variant_setScalar(&connectionConfig.address, &networkAddressUrl,
  30. &UA_TYPES[UA_TYPES_NETWORKADDRESSURLDATATYPE]);
  31. connectionConfig.transportProfileUri = UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-udp-uadp");
  32. UA_Server_addPubSubConnection(server, &connectionConfig, &connection1);
  33. }
  34. static void teardown(void) {
  35. UA_Server_run_shutdown(server);
  36. UA_Server_delete(server);
  37. }
  38. START_TEST(SinglePublishDataSetField){
  39. UA_WriterGroupConfig writerGroupConfig;
  40. memset(&writerGroupConfig, 0, sizeof(writerGroupConfig));
  41. writerGroupConfig.messageSettings.encoding = UA_EXTENSIONOBJECT_DECODED;
  42. writerGroupConfig.messageSettings.content.decoded.type = &UA_TYPES[UA_TYPES_JSONDATASETWRITERMESSAGEDATATYPE];
  43. UA_JsonDataSetWriterMessageDataType d;
  44. d.dataSetMessageContentMask = UA_JSONDATASETMESSAGECONTENTMASK_SEQUENCENUMBER;
  45. writerGroupConfig.messageSettings.content.decoded.data = &d;
  46. writerGroupConfig.name = UA_STRING("WriterGroup 1");
  47. writerGroupConfig.publishingInterval = 10;
  48. writerGroupConfig.encodingMimeType = UA_PUBSUB_ENCODING_JSON;
  49. UA_Server_addWriterGroup(server, connection1, &writerGroupConfig, &writerGroup1);
  50. UA_Server_setWriterGroupOperational(server, writerGroup1);
  51. UA_PublishedDataSetConfig pdsConfig;
  52. memset(&pdsConfig, 0, sizeof(UA_PublishedDataSetConfig));
  53. pdsConfig.publishedDataSetType = UA_PUBSUB_DATASET_PUBLISHEDITEMS;
  54. pdsConfig.name = UA_STRING("PublishedDataSet 1");
  55. UA_Server_addPublishedDataSet(server, &pdsConfig, &publishedDataSet1);
  56. UA_DataSetWriterConfig dataSetWriterConfig;
  57. memset(&dataSetWriterConfig, 0, sizeof(dataSetWriterConfig));
  58. dataSetWriterConfig.name = UA_STRING("DataSetWriter 1");
  59. UA_Server_addDataSetWriter(server, writerGroup1, publishedDataSet1, &dataSetWriterConfig, &dataSetWriter1);
  60. UA_DataSetFieldConfig dataSetFieldConfig;
  61. memset(&dataSetFieldConfig, 0, sizeof(UA_DataSetFieldConfig));
  62. dataSetFieldConfig.dataSetFieldType = UA_PUBSUB_DATASETFIELD_VARIABLE;
  63. dataSetFieldConfig.field.variable.fieldNameAlias = UA_STRING("Server localtime");
  64. dataSetFieldConfig.field.variable.promotedField = UA_FALSE;
  65. dataSetFieldConfig.field.variable.publishParameters.publishedVariable = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_LOCALTIME);
  66. dataSetFieldConfig.field.variable.publishParameters.attributeId = UA_ATTRIBUTEID_VALUE;
  67. UA_Server_addDataSetField(server, publishedDataSet1, &dataSetFieldConfig, NULL);
  68. UA_WriterGroup *wg = UA_WriterGroup_findWGbyId(server, writerGroup1);
  69. UA_WriterGroup_publishCallback(server, wg);
  70. } END_TEST
  71. int main(void) {
  72. TCase *tc_pubsub_publish = tcase_create("PubSub publish");
  73. tcase_add_checked_fixture(tc_pubsub_publish, setup, teardown);
  74. tcase_add_test(tc_pubsub_publish, SinglePublishDataSetField);
  75. Suite *s = suite_create("PubSub publishing json via udp");
  76. suite_add_tcase(s, tc_pubsub_publish);
  77. SRunner *sr = srunner_create(s);
  78. srunner_set_fork_status(sr, CK_NOFORK);
  79. srunner_run_all(sr,CK_NORMAL);
  80. int number_failed = srunner_ntests_failed(sr);
  81. srunner_free(sr);
  82. return (number_failed == 0) ? EXIT_SUCCESS : EXIT_FAILURE;
  83. }