| /* 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 <open62541/plugin/pubsub.h> |
| #include <open62541/plugin/pubsub_udp.h> |
| #include <open62541/server_config_default.h> |
| #include <open62541/server_pubsub.h> |
| #include <open62541/types.h> |
| #include <open62541/types_generated.h> |
| |
| #include "ua_server_internal.h" |
| |
| #include <math.h> |
| #include <string.h> |
| |
| #include "check.h" |
| |
| UA_Server *server = NULL; |
| |
| UA_NodeId connection1, connection2, writerGroup1, writerGroup2, writerGroup3, |
| publishedDataSet1, publishedDataSet2, dataSetWriter1, dataSetWriter2, dataSetWriter3; |
| |
| static void setup(void) { |
| server = UA_Server_new(); |
| UA_ServerConfig *config = UA_Server_getConfig(server); |
| UA_ServerConfig_setDefault(config); |
| |
| config->pubsubTransportLayers = (UA_PubSubTransportLayer *) |
| UA_malloc(sizeof(UA_PubSubTransportLayer)); |
| config->pubsubTransportLayers[0] = UA_PubSubTransportLayerUDPMP(); |
| config->pubsubTransportLayersSize++; |
| |
| UA_Server_run_startup(server); |
| } |
| |
| static void teardown(void) { |
| UA_Server_run_shutdown(server); |
| UA_Server_delete(server); |
| } |
| |
| static void addPublishedDataSet(UA_String pdsName, UA_NodeId *assignedId){ |
| UA_PublishedDataSetConfig pdsConfig; |
| memset(&pdsConfig, 0, sizeof(UA_PublishedDataSetConfig)); |
| pdsConfig.publishedDataSetType = UA_PUBSUB_DATASET_PUBLISHEDITEMS; |
| pdsConfig.name = pdsName; |
| UA_Server_addPublishedDataSet(server, &pdsConfig, assignedId); |
| } |
| |
| static void addPubSubConnection(UA_String connectionName, UA_String addressUrl, UA_NodeId *assignedId){ |
| UA_PubSubConnectionConfig connectionConfig; |
| memset(&connectionConfig, 0, sizeof(UA_PubSubConnectionConfig)); |
| connectionConfig.name = connectionName; |
| UA_NetworkAddressUrlDataType networkAddressUrl = {UA_STRING_NULL, addressUrl}; |
| 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, assignedId); |
| } |
| |
| static void addWriterGroup(UA_NodeId parentConnection, UA_String name, UA_Duration interval, UA_NodeId *assignedId){ |
| UA_WriterGroupConfig writerGroupConfig; |
| memset(&writerGroupConfig, 0, sizeof(writerGroupConfig)); |
| writerGroupConfig.name = name; |
| writerGroupConfig.publishingInterval = interval; |
| writerGroupConfig.encodingMimeType = UA_PUBSUB_ENCODING_UADP; |
| UA_Server_addWriterGroup(server, parentConnection, &writerGroupConfig, assignedId); |
| } |
| |
| static void addDataSetWriter(UA_NodeId parentWriterGroup, UA_NodeId connectedPDS, UA_String name, UA_NodeId *assignedId){ |
| UA_DataSetWriterConfig dataSetWriterConfig; |
| memset(&dataSetWriterConfig, 0, sizeof(dataSetWriterConfig)); |
| dataSetWriterConfig.name = name; |
| UA_Server_addDataSetWriter(server, parentWriterGroup, connectedPDS, &dataSetWriterConfig, assignedId); |
| } |
| |
| static UA_Boolean doubleEqual(UA_Double a, UA_Double b, UA_Double maxAbsDelta){ |
| return fabs(a-b) < maxAbsDelta; |
| } |
| |
| static UA_NodeId |
| findSingleChildNode(UA_Server *server_, UA_QualifiedName targetName, UA_NodeId referenceTypeId, UA_NodeId startingNode){ |
| UA_NodeId resultNodeId; |
| UA_RelativePathElement rpe; |
| UA_RelativePathElement_init(&rpe); |
| rpe.referenceTypeId = referenceTypeId; |
| rpe.isInverse = false; |
| rpe.includeSubtypes = false; |
| rpe.targetName = targetName; |
| UA_BrowsePath bp; |
| UA_BrowsePath_init(&bp); |
| bp.startingNode = startingNode; |
| bp.relativePath.elementsSize = 1; |
| bp.relativePath.elements = &rpe; |
| UA_BrowsePathResult bpr = |
| UA_Server_translateBrowsePathToNodeIds(server_, &bp); |
| if(bpr.statusCode != UA_STATUSCODE_GOOD || |
| bpr.targetsSize < 1) |
| return UA_NODEID_NULL; |
| UA_NodeId_copy(&bpr.targets[0].targetId.nodeId, &resultNodeId); |
| UA_BrowsePathResult_deleteMembers(&bpr); |
| return resultNodeId; |
| } |
| |
| static void setupBasicPubSubConfiguration(void){ |
| addPubSubConnection(UA_STRING("Connection 1"), UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| addPubSubConnection(UA_STRING("Connection 2"), UA_STRING("opc.udp://224.0.0.22:4840/"), &connection2); |
| addPublishedDataSet(UA_STRING("PublishedDataSet 1"), &publishedDataSet1); |
| addPublishedDataSet(UA_STRING("PublishedDataSet 2"), &publishedDataSet2); |
| addWriterGroup(connection1, UA_STRING("WriterGroup 1"), 10, &writerGroup1); |
| addWriterGroup(connection1, UA_STRING("WriterGroup 2"), 100, &writerGroup2); |
| addWriterGroup(connection2, UA_STRING("WriterGroup 3"), 1000, &writerGroup3); |
| addDataSetWriter(writerGroup1, publishedDataSet1, UA_STRING("DataSetWriter 1"), &dataSetWriter1); |
| addDataSetWriter(writerGroup1, publishedDataSet2, UA_STRING("DataSetWriter 2"), &dataSetWriter2); |
| addDataSetWriter(writerGroup2, publishedDataSet2, UA_STRING("DataSetWriter 3"), &dataSetWriter3); |
| } |
| |
| START_TEST(AddSignlePubSubConnectionAndCheckInformationModelRepresentation){ |
| UA_String connectionName = UA_STRING("Connection 1"); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| UA_QualifiedName browseName; |
| UA_StatusCode retVal = UA_STATUSCODE_GOOD; |
| retVal |= UA_Server_readBrowseName(server, connection1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &connectionName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddRemoveAddSignlePubSubConnectionAndCheckInformationModelRepresentation){ |
| UA_String connectionName = UA_STRING("Connection 1"); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| UA_QualifiedName browseName; |
| UA_StatusCode retVal; |
| ck_assert_int_eq(UA_Server_removePubSubConnection(server, connection1), UA_STATUSCODE_GOOD); |
| retVal = UA_Server_readBrowseName(server, connection1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_BADNODEIDUNKNOWN); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| retVal = UA_Server_readBrowseName(server, connection1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &connectionName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddSinglePublishedDataSetAndCheckInformationModelRepresentation){ |
| UA_String pdsName = UA_STRING("PDS 1"); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| UA_QualifiedName browseName; |
| ck_assert_int_eq(UA_Server_readBrowseName(server, publishedDataSet1, &browseName), UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &pdsName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddRemoveAddSinglePublishedDataSetAndCheckInformationModelRepresentation){ |
| UA_String pdsName = UA_STRING("PDS 1"); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| UA_QualifiedName browseName; |
| UA_StatusCode retVal; |
| ck_assert_int_eq(UA_Server_removePublishedDataSet(server, publishedDataSet1), UA_STATUSCODE_GOOD); |
| retVal = UA_Server_readBrowseName(server, publishedDataSet1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_BADNODEIDUNKNOWN); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| retVal = UA_Server_readBrowseName(server, publishedDataSet1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &pdsName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddSingleWriterGroupAndCheckInformationModelRepresentation){ |
| UA_String connectionName = UA_STRING("Connection 1"); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| UA_String pdsName = UA_STRING("PDS 1"); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| UA_String wgName = UA_STRING("WriterGroup 1"); |
| addWriterGroup(connection1, wgName, 10, &writerGroup1); |
| UA_QualifiedName browseName; |
| ck_assert_int_eq(UA_Server_readBrowseName(server, writerGroup1, &browseName), UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &wgName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddRemoveAddSingleWriterGroupAndCheckInformationModelRepresentation){ |
| UA_String connectionName = UA_STRING("Connection 1"); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| UA_String pdsName = UA_STRING("PDS 1"); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| UA_String wgName = UA_STRING("WriterGroup 1"); |
| addWriterGroup(connection1, wgName, 10, &writerGroup1); |
| UA_QualifiedName browseName; |
| UA_StatusCode retVal; |
| ck_assert_int_eq(UA_Server_removeWriterGroup(server, writerGroup1), UA_STATUSCODE_GOOD); |
| retVal = UA_Server_readBrowseName(server, writerGroup1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_BADNODEIDUNKNOWN); |
| addWriterGroup(connection1, wgName, 10, &writerGroup1); |
| retVal = UA_Server_readBrowseName(server, writerGroup1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &wgName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddSingleDataSetWriterAndCheckInformationModelRepresentation){ |
| UA_String connectionName = UA_STRING("Connection 1"); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| UA_String pdsName = UA_STRING("PDS 1"); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| UA_String wgName = UA_STRING("WriterGroup 1"); |
| addWriterGroup(connection1, wgName, 10, &writerGroup1); |
| UA_String dswName = UA_STRING("DataSetWriter 1"); |
| addDataSetWriter(writerGroup1, publishedDataSet1, dswName, &dataSetWriter1); |
| UA_QualifiedName browseName; |
| ck_assert_int_eq(UA_Server_readBrowseName(server, dataSetWriter1, &browseName), UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &dswName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(AddRemoveAddSingleDataSetWriterAndCheckInformationModelRepresentation){ |
| UA_String connectionName = UA_STRING("Connection 1"); |
| addPubSubConnection(connectionName, UA_STRING("opc.udp://224.0.0.22:4840/"), &connection1); |
| UA_String pdsName = UA_STRING("PDS 1"); |
| addPublishedDataSet(pdsName, &publishedDataSet1); |
| UA_String wgName = UA_STRING("WriterGroup 1"); |
| addWriterGroup(connection1, wgName, 10, &writerGroup1); |
| UA_String dswName = UA_STRING("DataSetWriter 1"); |
| addDataSetWriter(writerGroup1, publishedDataSet1, dswName, &dataSetWriter1); |
| UA_QualifiedName browseName; |
| UA_StatusCode retVal; |
| ck_assert_int_eq(UA_Server_removeDataSetWriter(server, dataSetWriter1), UA_STATUSCODE_GOOD); |
| retVal = UA_Server_readBrowseName(server, dataSetWriter1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_BADNODEIDUNKNOWN); |
| addDataSetWriter(writerGroup1, publishedDataSet1, dswName, &dataSetWriter1); |
| retVal = UA_Server_readBrowseName(server, dataSetWriter1, &browseName); |
| ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); |
| ck_assert_int_eq(UA_String_equal(&browseName.name, &dswName), UA_TRUE); |
| UA_QualifiedName_deleteMembers(&browseName); |
| } END_TEST |
| |
| START_TEST(ReadPublishIntervalAndCompareWithInternalValue){ |
| setupBasicPubSubConfiguration(); |
| UA_NodeId publishIntervalId = findSingleChildNode(server, UA_QUALIFIEDNAME(0, "PublishingInterval"), |
| UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY), writerGroup1); |
| UA_Variant value; |
| UA_Variant_init(&value); |
| ck_assert_int_eq(UA_Server_readValue(server, publishIntervalId, &value), UA_STATUSCODE_GOOD); |
| ck_assert(UA_Variant_hasScalarType(&value, &UA_TYPES[UA_TYPES_DURATION])); |
| ck_assert(doubleEqual((UA_Double) *((UA_Duration *) value.data), 10, 0.05)); |
| UA_Variant_deleteMembers(&value); |
| } END_TEST |
| |
| START_TEST(WritePublishIntervalAndCompareWithInternalValue){ |
| setupBasicPubSubConfiguration(); |
| UA_NodeId publishIntervalId = findSingleChildNode(server, UA_QUALIFIEDNAME(0, "PublishingInterval"), |
| UA_NODEID_NUMERIC(0, UA_NS0ID_HASPROPERTY), writerGroup1); |
| UA_Variant value; |
| UA_Variant_init(&value); |
| UA_Duration interval = 100; |
| UA_Variant_setScalar(&value, &interval, &UA_TYPES[UA_TYPES_DURATION]); |
| ck_assert_int_eq(UA_Server_writeValue(server, publishIntervalId, value), UA_STATUSCODE_GOOD); |
| |
| ck_assert_int_eq(UA_Server_readValue(server, publishIntervalId, &value), UA_STATUSCODE_GOOD); |
| ck_assert(UA_Variant_hasScalarType(&value, &UA_TYPES[UA_TYPES_DURATION])); |
| ck_assert(doubleEqual((UA_Double) *((UA_Duration *) value.data), 100, 0.05)); |
| UA_Variant_deleteMembers(&value); |
| } END_TEST |
| |
| START_TEST(ReadAddressAndCompareWithInternalValue){ |
| setupBasicPubSubConfiguration(); |
| UA_NodeId address = findSingleChildNode(server, UA_QUALIFIEDNAME(0, "Address"), |
| UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT), connection1); |
| UA_NodeId url = findSingleChildNode(server, UA_QUALIFIEDNAME(0, "Url"), |
| UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT), address); |
| UA_NodeId networkInterface = findSingleChildNode(server, UA_QUALIFIEDNAME(0, "NetworkInterface"), |
| UA_NODEID_NUMERIC(0, UA_NS0ID_HASCOMPONENT), address); |
| UA_PubSubConnectionConfig connectionConfig; |
| memset(&connectionConfig, 0, sizeof(connectionConfig)); |
| UA_Server_getPubSubConnectionConfig(server, connection1, &connectionConfig); |
| UA_Variant value; |
| UA_Variant_init(&value); |
| ck_assert_int_eq(UA_Server_readValue(server, url, &value), UA_STATUSCODE_GOOD); |
| UA_NetworkAddressUrlDataType *networkAddressUrlDataType = (UA_NetworkAddressUrlDataType *)connectionConfig.address.data; |
| ck_assert(UA_Variant_hasScalarType(&value, &UA_TYPES[UA_TYPES_STRING])); |
| ck_assert(UA_String_equal(((UA_String *) value.data), &networkAddressUrlDataType->url)); |
| UA_Variant_deleteMembers(&value); |
| ck_assert_int_eq(UA_Server_readValue(server, networkInterface, &value), UA_STATUSCODE_GOOD); |
| ck_assert(UA_String_equal(((UA_String *) value.data), &networkAddressUrlDataType->networkInterface)); |
| UA_PubSubConnectionConfig_deleteMembers(&connectionConfig); |
| UA_Variant_deleteMembers(&value); |
| } END_TEST |
| |
| int main(void) { |
| TCase *tc_add_pubsub_informationmodel = tcase_create("PubSub add single elements and check information model representation"); |
| tcase_add_checked_fixture(tc_add_pubsub_informationmodel, setup, teardown); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddSignlePubSubConnectionAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddRemoveAddSignlePubSubConnectionAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddSinglePublishedDataSetAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddRemoveAddSinglePublishedDataSetAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddSingleWriterGroupAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddRemoveAddSingleWriterGroupAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddSingleDataSetWriterAndCheckInformationModelRepresentation); |
| tcase_add_test(tc_add_pubsub_informationmodel, AddRemoveAddSingleDataSetWriterAndCheckInformationModelRepresentation); |
| |
| TCase *tc_add_pubsub_writergroupelements = tcase_create("PubSub WriterGroup check properties"); |
| tcase_add_checked_fixture(tc_add_pubsub_writergroupelements, setup, teardown); |
| tcase_add_test(tc_add_pubsub_writergroupelements, ReadPublishIntervalAndCompareWithInternalValue); |
| tcase_add_test(tc_add_pubsub_writergroupelements, WritePublishIntervalAndCompareWithInternalValue); |
| |
| TCase *tc_add_pubsub_pubsubconnectionelements = tcase_create("PubSub Connection check properties"); |
| tcase_add_checked_fixture(tc_add_pubsub_pubsubconnectionelements, setup, teardown); |
| tcase_add_test(tc_add_pubsub_pubsubconnectionelements, ReadAddressAndCompareWithInternalValue); |
| |
| Suite *s = suite_create("PubSub WriterGroups/Writer/Fields handling and publishing"); |
| suite_add_tcase(s, tc_add_pubsub_informationmodel); |
| suite_add_tcase(s, tc_add_pubsub_writergroupelements); |
| suite_add_tcase(s, tc_add_pubsub_pubsubconnectionelements); |
| |
| 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; |
| } |