/* This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. * * Copyright (c) 2017 - 2018 Fraunhofer IOSB (Author: Andreas Ebner) */ #include "ua_server_pubsub.h" #include "src_generated/ua_types_generated_encoding_binary.h" #include "ua_types.h" #include "ua_pubsub.h" #include "ua_config_default.h" #include "ua_network_pubsub_udp.h" #include "ua_server_internal.h" #include "check.h" #include "stdio.h" UA_Server *server = NULL; UA_ServerConfig *config = NULL; UA_NodeId connection1, writerGroup1, publishedDataSet1, dataSetWriter1; static void setup(void) { config = UA_ServerConfig_new_default(); config->pubsubTransportLayers = (UA_PubSubTransportLayer *) UA_malloc(sizeof(UA_PubSubTransportLayer)); if(!config->pubsubTransportLayers) { UA_ServerConfig_delete(config); } config->pubsubTransportLayers[0] = UA_PubSubTransportLayerUDPMP(); config->pubsubTransportLayersSize++; server = UA_Server_new(config); UA_Server_run_startup(server); UA_PubSubConnectionConfig connectionConfig; memset(&connectionConfig, 0, sizeof(UA_PubSubConnectionConfig)); connectionConfig.name = UA_STRING("UADP Connection"); UA_NetworkAddressUrlDataType networkAddressUrl = {UA_STRING_NULL, UA_STRING("opc.udp://224.0.0.22:4840/")}; UA_Variant_setScalar(&connectionConfig.address, &networkAddressUrl, &UA_TYPES[UA_TYPES_NETWORKADDRESSURLDATATYPE]); connectionConfig.transportProfileUri = UA_STRING("http://opcfoundation.org/UA-Profile/Transport/pubsub-udp-uadp"); UA_Server_addPubSubConnection(server, &connectionConfig, &connection1); } static void teardown(void) { UA_Server_run_shutdown(server); UA_Server_delete(server); UA_ServerConfig_delete(config); } START_TEST(SinglePublishDataSetField){ UA_WriterGroupConfig writerGroupConfig; memset(&writerGroupConfig, 0, sizeof(writerGroupConfig)); writerGroupConfig.messageSettings.encoding = UA_EXTENSIONOBJECT_DECODED; writerGroupConfig.messageSettings.content.decoded.type = &UA_TYPES[UA_TYPES_JSONDATASETWRITERMESSAGEDATATYPE]; UA_JsonDataSetWriterMessageDataType d; d.dataSetMessageContentMask = UA_JSONDATASETMESSAGECONTENTMASK_SEQUENCENUMBER; writerGroupConfig.messageSettings.content.decoded.data = &d; writerGroupConfig.name = UA_STRING("WriterGroup 1"); writerGroupConfig.publishingInterval = 10; writerGroupConfig.encodingMimeType = UA_PUBSUB_ENCODING_JSON; UA_Server_addWriterGroup(server, connection1, &writerGroupConfig, &writerGroup1); UA_PublishedDataSetConfig pdsConfig; memset(&pdsConfig, 0, sizeof(UA_PublishedDataSetConfig)); pdsConfig.publishedDataSetType = UA_PUBSUB_DATASET_PUBLISHEDITEMS; pdsConfig.name = UA_STRING("PublishedDataSet 1"); UA_Server_addPublishedDataSet(server, &pdsConfig, &publishedDataSet1); UA_DataSetWriterConfig dataSetWriterConfig; memset(&dataSetWriterConfig, 0, sizeof(dataSetWriterConfig)); dataSetWriterConfig.name = UA_STRING("DataSetWriter 1"); UA_Server_addDataSetWriter(server, writerGroup1, publishedDataSet1, &dataSetWriterConfig, &dataSetWriter1); UA_DataSetFieldConfig dataSetFieldConfig; memset(&dataSetFieldConfig, 0, sizeof(UA_DataSetFieldConfig)); dataSetFieldConfig.dataSetFieldType = UA_PUBSUB_DATASETFIELD_VARIABLE; dataSetFieldConfig.field.variable.fieldNameAlias = UA_STRING("Server localtime"); dataSetFieldConfig.field.variable.promotedField = UA_FALSE; dataSetFieldConfig.field.variable.publishParameters.publishedVariable = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_LOCALTIME); dataSetFieldConfig.field.variable.publishParameters.attributeId = UA_ATTRIBUTEID_VALUE; UA_Server_addDataSetField(server, publishedDataSet1, &dataSetFieldConfig, NULL); UA_WriterGroup *wg = UA_WriterGroup_findWGbyId(server, writerGroup1); UA_WriterGroup_publishCallback(server, wg); } END_TEST int main(void) { TCase *tc_pubsub_publish = tcase_create("PubSub publish"); tcase_add_checked_fixture(tc_pubsub_publish, setup, teardown); tcase_add_test(tc_pubsub_publish, SinglePublishDataSetField); Suite *s = suite_create("PubSub publishing json via udp"); suite_add_tcase(s, tc_pubsub_publish); SRunner *sr = srunner_create(s); srunner_set_fork_status(sr, CK_NOFORK); srunner_run_all(sr,CK_NORMAL); int number_failed = srunner_ntests_failed(sr); srunner_free(sr); return (number_failed == 0) ? EXIT_SUCCESS : EXIT_FAILURE; }