ext/open62541/tests/pubsub/check_pubsub_informationmodel.c - a71ch-crypto-support - Git at Google

 /* 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;
 }
	/* 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;
	}