/* 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) 2019 Kalycito Infotech Private Limited */ #include #include #include #include #include #include "open62541/types_generated_encoding_binary.h" #include "ua_pubsub.h" #include "ua_server_internal.h" #define UA_SUBSCRIBER_PORT 4801 /* Port for Subscriber*/ #define PUBLISH_INTERVAL 100 /* Publish interval*/ #define DATASET_WRITERD_ID 62541 /* DataSet Writer Id*/ #define WRITER_GROUP_ID 100 /* Writer group Id */ /* Global declaration for test cases */ UA_Server *server = NULL; UA_ServerConfig *config = NULL; UA_NodeId connection_test; UA_NodeId readerGroupTest; UA_NodeId publishedDataSetTest; /* setup() is to create an environment for test cases */ static void setup(void) { /*Add setup by creating new server with valid configuration */ server = UA_Server_new(); config = UA_Server_getConfig(server); UA_ServerConfig_setMinimal(config, UA_SUBSCRIBER_PORT, NULL); UA_Server_run_startup(server); config->pubsubTransportLayers = (UA_PubSubTransportLayer *) UA_malloc(sizeof(UA_PubSubTransportLayer)); if(!config->pubsubTransportLayers) { UA_ServerConfig_clean(config); } config->pubsubTransportLayers[0] = UA_PubSubTransportLayerUDPMP(); config->pubsubTransportLayersSize++; /* Add connection to the server */ UA_PubSubConnectionConfig connectionConfig; memset(&connectionConfig, 0, sizeof(UA_PubSubConnectionConfig)); connectionConfig.name = UA_STRING("UADP Test Connection"); UA_NetworkAddressUrlDataType networkAddressUrl = {UA_STRING_NULL, UA_STRING("opc.udp://224.0.0.22:4801/")}; 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, &connection_test); } /* teardown() is to delete the environment set for test cases */ static void teardown(void) { /*Call server delete functions */ UA_Server_run_shutdown(server); UA_Server_delete(server); } START_TEST(AddReaderGroupWithValidConfiguration) { /* To test if ReaderGroup has been added to the connection with valid configuration */ UA_StatusCode retVal; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); UA_NodeId localreaderGroup; retVal = UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); size_t readerGroupCount = 0; UA_ReaderGroup *readerGroup; LIST_FOREACH(readerGroup, &UA_PubSubConnection_findConnectionbyId(server, connection_test)->readerGroups, listEntry){ readerGroupCount++; } /* Check readerGroup count */ ck_assert_int_eq(readerGroupCount, 1); /* To Do: RemoveReaderGroup operation should be carried out when UA_Server_delete has been called */ UA_Server_removeReaderGroup(server, localreaderGroup); } END_TEST START_TEST(AddReaderGroupWithNullConfig) { /* Check the status of adding ReaderGroup when NULL configuration is given */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; retVal |= UA_Server_addReaderGroup(server, connection_test, NULL, NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); size_t readerGroupCount = 0; UA_ReaderGroup *readerGroup; LIST_FOREACH(readerGroup, &UA_PubSubConnection_findConnectionbyId(server, connection_test)->readerGroups, listEntry){ readerGroupCount++; } /* Check readerGroup count */ ck_assert_int_eq(readerGroupCount, 0); } END_TEST START_TEST(AddReaderGroupWithInvalidConnectionId) { /* Check status of adding ReaderGroup with invalid connection identifier */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), &readerGroupConfig, NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); size_t readerGroupCount = 0; UA_ReaderGroup *readerGroup; LIST_FOREACH(readerGroup, &UA_PubSubConnection_findConnectionbyId(server, connection_test)->readerGroups, listEntry){ readerGroupCount++; } /* Check readerGroup count */ ck_assert_int_eq(readerGroupCount, 0); } END_TEST START_TEST(RemoveReaderGroupWithInvalidIdentifier) { /* Check status of removing ReaderGroup when giving invalid ReaderGroup identifier */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_ReaderGroupConfig readerGroupConfig; UA_NodeId localreaderGroup; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* Delete the added readerGroup */ retVal |= UA_Server_removeReaderGroup(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX)); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); size_t readerGroupCount = 0; UA_ReaderGroup *readerGroup; LIST_FOREACH(readerGroup, &UA_PubSubConnection_findConnectionbyId(server, connection_test)->readerGroups, listEntry){ readerGroupCount++; } /* Check readerGroup count */ ck_assert_int_eq(readerGroupCount, 1); UA_Server_removeReaderGroup(server, localreaderGroup); } END_TEST START_TEST(UpdateReaderGroupWithInvalidIdentifier) { /* Check status of updating ReaderGroup with invalid identifier */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_ReaderGroupConfig readerGroupConfig; UA_NodeId localreaderGroup; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_ReaderGroup_updateConfig(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); UA_Server_removeReaderGroup(server, localreaderGroup); } END_TEST START_TEST(GetReaderGroupConfigWithInvalidConfig) { /* Check status of getting ReaderGroup configuration with invalid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_ReaderGroupConfig readerGroupConfig; UA_NodeId localreaderGroup; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_ReaderGroup_getConfig(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); UA_Server_removeReaderGroup(server, localreaderGroup); } END_TEST START_TEST(GetReaderGroupConfigWithInvalidIdentifier) { /* Check status of getting ReaderGroup configuration with invlaid identifier */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_ReaderGroupConfig readerGroupConfig; UA_NodeId localreaderGroup; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_ReaderGroup_getConfig(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), &readerGroupConfig); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); UA_Server_removeReaderGroup(server, localreaderGroup); } END_TEST START_TEST(GetReaderGroupConfigWithValidConfig) { /* Check status of getting ReaderGroup configuration with valid parameters */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_NodeId localreaderGroup; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_ReaderGroup_getConfig(server, localreaderGroup, &readerGroupConfig); /* To Do: DeleteMembers of readergroup config has to be a separate function */ UA_String_deleteMembers (&readerGroupConfig.name); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(AddDataSetReaderWithValidConfiguration) { /* Check status of adding DataSetReader to ReaderGroup with valid parameters*/ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_ReaderGroupConfig readerGroupConfig; UA_NodeId localDataSetreader; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); dataSetreaderConfig.name = UA_STRING("DataSetreader Test"); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(AddDataSetReaderWithNullConfig) { /* Check status of adding DataSetReader to ReaderGroup with invalid parameters */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); dataSetreaderConfig.name = UA_STRING("DataSetreader Test "); /* Remove the added DataSetReader */ retVal |= UA_Server_addDataSetReader(server, localreaderGroup, NULL, NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(RemoveDataSetReaderWithValidConfiguration) { /* Check status of adding DataSetReader to ReaderGroup with valid parameters */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_ReaderGroupConfig readerGroupConfig; UA_NodeId localDataSetreader; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); dataSetreaderConfig.name = UA_STRING("DataSetReader Test "); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_removeDataSetReader(server, localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(RemoveDataSetReaderWithInvalidIdentifier) { /* Check status of removing DataSetReader from ReaderGroup with invalid parameters */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); dataSetreaderConfig.name = UA_STRING("DataSetReader Test "); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, NULL, NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); /* Remove the added DataSetReader */ retVal |= UA_Server_removeDataSetReader(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX)); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(UpdateDataSetReaderConfigWithInvalidId) { /* Check status of updatting DataSetReader with invalid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_NodeId localDataSetreader; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_DataSetReader_updateConfig(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), localreaderGroup, &dataSetreaderConfig ); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(GetDataSetReaderConfigWithValidConfiguration) { /* Check status of getting DataSetReader with Valid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_NodeId localDataSetreader; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_DataSetReader_getConfig(server, localDataSetreader, &dataSetreaderConfig); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(GetDataSetReaderConfigWithInvalidConfiguration) { /* Check status of getting DataSetReader with Invalid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_NodeId localDataSetreader; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_DataSetReader_getConfig(server, localDataSetreader, NULL); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(GetDataSetReaderConfigWithInvalidIdentifier) { /* Check status of getting DataSetReader with Invalid Identifier */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_NodeId localDataSetreader; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_DataSetReader_getConfig(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), &dataSetreaderConfig); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(CreateTargetVariableWithInvalidConfiguration) { /* Check status to create target variable with invalid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_NodeId localDataSetreader; UA_TargetVariablesDataType localTargetVariable; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_DataSetReader_createTargetVariables(server, UA_NODEID_NUMERIC(0, UA_UINT32_MAX), &localTargetVariable); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(AddTargetVariableWithInvalidConfiguration) { /* Check status to create target variable with invalid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetreaderConfig; UA_NodeId localreaderGroup; UA_NodeId localDataSetreader; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetreaderConfig, 0, sizeof(dataSetreaderConfig)); retVal |= UA_Server_addDataSetReader(server, localreaderGroup, &dataSetreaderConfig, &localDataSetreader); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); retVal |= UA_Server_DataSetReader_addTargetVariables(NULL, &localreaderGroup, localDataSetreader, UA_PUBSUB_SDS_TARGET); ck_assert_int_ne(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(AddTargetVariableWithValidConfiguration) { /* Check status after creating target variables with Valid configuration */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_DataSetReaderConfig dataSetReaderConfig; UA_NodeId folderId; UA_QualifiedName folderBrowseName; UA_NodeId localreaderGroupIdentifier; UA_NodeId localDataSetreaderIdentifier; UA_ObjectAttributes oAttr = UA_ObjectAttributes_default; UA_ReaderGroupConfig readerGroupConfig; memset(&readerGroupConfig, 0, sizeof(readerGroupConfig)); readerGroupConfig.name = UA_STRING("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup(server, connection_test, &readerGroupConfig, &localreaderGroupIdentifier); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); memset(&dataSetReaderConfig, 0, sizeof(UA_DataSetReaderConfig)); UA_DataSetMetaDataType *pMetaData = &dataSetReaderConfig.dataSetMetaData; UA_DataSetMetaDataType_init (pMetaData); pMetaData->name = UA_STRING ("DataSet Test"); /* Static definition of number of fields size to 4 to create four different * targetVariables of distinct datatype */ pMetaData->fieldsSize = 1; pMetaData->fields = (UA_FieldMetaData*)UA_Array_new (pMetaData->fieldsSize, &UA_TYPES[UA_TYPES_FIELDMETADATA]); /* DateTime DataType */ UA_FieldMetaData_init (&pMetaData->fields[0]); UA_NodeId_copy (&UA_TYPES[UA_TYPES_DATETIME].typeId, &pMetaData->fields[0].dataType); pMetaData->fields[0].builtInType = UA_NS0ID_DATETIME; pMetaData->fields[0].valueRank = -1; /* scalar */ retVal |= UA_Server_addDataSetReader(server, localreaderGroupIdentifier, &dataSetReaderConfig, &localDataSetreaderIdentifier); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); folderBrowseName = UA_QUALIFIEDNAME (1, "Subscribed Variables"); UA_Server_addObjectNode (server, UA_NODEID_NULL, UA_NODEID_NUMERIC (0, UA_NS0ID_OBJECTSFOLDER), UA_NODEID_NUMERIC (0, UA_NS0ID_ORGANIZES), folderBrowseName, UA_NODEID_NUMERIC (0, UA_NS0ID_BASEOBJECTTYPE), oAttr, NULL, &folderId); retVal |= UA_Server_DataSetReader_addTargetVariables(server, &folderId, localDataSetreaderIdentifier, UA_PUBSUB_SDS_TARGET); UA_free(pMetaData->fields); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); } END_TEST START_TEST(SinglePublishSubscribe) { /* To check status after running both publisher and subscriber */ UA_StatusCode retVal = UA_STATUSCODE_GOOD; UA_PublishedDataSetConfig pdsConfig; UA_NodeId dataSetWriter; UA_NodeId readerIdentifier; UA_NodeId writerGroup; UA_DataSetReaderConfig readerConfig; memset(&pdsConfig, 0, sizeof(UA_PublishedDataSetConfig)); pdsConfig.publishedDataSetType = UA_PUBSUB_DATASET_PUBLISHEDITEMS; pdsConfig.name = UA_STRING("PublishedDataSet Test"); UA_Server_addPublishedDataSet(server, &pdsConfig, &publishedDataSetTest); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* Data Set Field */ UA_NodeId dataSetFieldId; 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, publishedDataSetTest, &dataSetFieldConfig, &dataSetFieldId); /* Writer group */ UA_WriterGroupConfig writerGroupConfig; memset(&writerGroupConfig, 0, sizeof(writerGroupConfig)); writerGroupConfig.name = UA_STRING("WriterGroup Test"); writerGroupConfig.publishingInterval = PUBLISH_INTERVAL; writerGroupConfig.enabled = UA_FALSE; writerGroupConfig.writerGroupId = WRITER_GROUP_ID; writerGroupConfig.encodingMimeType = UA_PUBSUB_ENCODING_UADP; retVal |= UA_Server_addWriterGroup(server, connection_test, &writerGroupConfig, &writerGroup); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* DataSetWriter */ UA_DataSetWriterConfig dataSetWriterConfig; memset(&dataSetWriterConfig, 0, sizeof(dataSetWriterConfig)); dataSetWriterConfig.name = UA_STRING("DataSetWriter Test"); dataSetWriterConfig.dataSetWriterId = DATASET_WRITERD_ID; dataSetWriterConfig.keyFrameCount = 10; retVal |= UA_Server_addDataSetWriter(server, writerGroup, publishedDataSetTest, &dataSetWriterConfig, &dataSetWriter); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* Reader Group */ UA_ReaderGroupConfig readerGroupConfig; memset (&readerGroupConfig, 0, sizeof (UA_ReaderGroupConfig)); readerGroupConfig.name = UA_STRING ("ReaderGroup Test"); retVal |= UA_Server_addReaderGroup (server, connection_test, &readerGroupConfig, &readerGroupTest); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* Data Set Reader */ memset (&readerConfig, 0, sizeof (UA_DataSetReaderConfig)); readerConfig.name = UA_STRING ("DataSetReader Test"); readerConfig.dataSetWriterId = DATASET_WRITERD_ID; /* Setting up Meta data configuration in DataSetReader for DateTime DataType */ UA_DataSetMetaDataType *pMetaData = &readerConfig.dataSetMetaData; /* FilltestMetadata function in subscriber implementation */ UA_DataSetMetaDataType_init (pMetaData); pMetaData->name = UA_STRING ("DataSet Test"); /* Static definition of number of fields size to 1 to create one targetVariable */ pMetaData->fieldsSize = 1; pMetaData->fields = (UA_FieldMetaData*)UA_Array_new (pMetaData->fieldsSize, &UA_TYPES[UA_TYPES_FIELDMETADATA]); /* DateTime DataType */ UA_FieldMetaData_init (&pMetaData->fields[0]); UA_NodeId_copy (&UA_TYPES[UA_TYPES_DATETIME].typeId, &pMetaData->fields[0].dataType); pMetaData->fields[0].builtInType = UA_NS0ID_DATETIME; pMetaData->fields[0].valueRank = -1; /* scalar */ retVal |= UA_Server_addDataSetReader (server, readerGroupTest, &readerConfig, &readerIdentifier); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* Add Subscribed Variables */ UA_NodeId folderId; UA_String folderName = readerConfig.dataSetMetaData.name; UA_ObjectAttributes oAttr = UA_ObjectAttributes_default; UA_QualifiedName folderBrowseName; if (folderName.length > 0) { oAttr.displayName.locale = UA_STRING ("en-US"); oAttr.displayName.text = folderName; folderBrowseName.namespaceIndex = 1; folderBrowseName.name = folderName; } else { oAttr.displayName = UA_LOCALIZEDTEXT ("en-US", "Subscribed Variables"); folderBrowseName = UA_QUALIFIEDNAME (1, "Subscribed Variables"); } UA_Server_addObjectNode (server, UA_NODEID_NULL, UA_NODEID_NUMERIC (0, UA_NS0ID_OBJECTSFOLDER), UA_NODEID_NUMERIC (0, UA_NS0ID_ORGANIZES), folderBrowseName, UA_NODEID_NUMERIC (0, UA_NS0ID_BASEOBJECTTYPE), oAttr, NULL, &folderId); retVal |= UA_Server_DataSetReader_addTargetVariables (server, &folderId, readerIdentifier, UA_PUBSUB_SDS_TARGET); ck_assert_int_eq(retVal, UA_STATUSCODE_GOOD); /* run server - publisher and subscriber */ UA_Server_run_iterate(server,true); UA_Server_run_iterate(server,true); UA_free(pMetaData->fields); }END_TEST int main(void) { TCase *tc_add_pubsub_readergroup = tcase_create("PubSub readerGroup items handling"); tcase_add_checked_fixture(tc_add_pubsub_readergroup, setup, teardown); /* Test cases for ReaderGroup functionality */ tcase_add_test(tc_add_pubsub_readergroup, AddReaderGroupWithValidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, AddReaderGroupWithNullConfig); tcase_add_test(tc_add_pubsub_readergroup, AddReaderGroupWithInvalidConnectionId); tcase_add_test(tc_add_pubsub_readergroup, RemoveReaderGroupWithInvalidIdentifier); tcase_add_test(tc_add_pubsub_readergroup, UpdateReaderGroupWithInvalidIdentifier); tcase_add_test(tc_add_pubsub_readergroup, GetReaderGroupConfigWithInvalidConfig); tcase_add_test(tc_add_pubsub_readergroup, GetReaderGroupConfigWithInvalidIdentifier); tcase_add_test(tc_add_pubsub_readergroup, GetReaderGroupConfigWithValidConfig); /* Test cases for DataSetReader functionality */ tcase_add_test(tc_add_pubsub_readergroup, AddDataSetReaderWithValidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, AddDataSetReaderWithNullConfig); tcase_add_test(tc_add_pubsub_readergroup, RemoveDataSetReaderWithValidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, RemoveDataSetReaderWithInvalidIdentifier); tcase_add_test(tc_add_pubsub_readergroup, UpdateDataSetReaderConfigWithInvalidId); tcase_add_test(tc_add_pubsub_readergroup, GetDataSetReaderConfigWithValidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, GetDataSetReaderConfigWithInvalidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, GetDataSetReaderConfigWithInvalidIdentifier); tcase_add_test(tc_add_pubsub_readergroup, CreateTargetVariableWithInvalidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, AddTargetVariableWithInvalidConfiguration); tcase_add_test(tc_add_pubsub_readergroup, AddTargetVariableWithValidConfiguration); /*Test case to run both publisher and subscriber */ TCase *tc_pubsub_publish_subscribe = tcase_create("Publisher publishing and Subscriber subscribing"); tcase_add_checked_fixture(tc_pubsub_publish_subscribe, setup, teardown); tcase_add_test(tc_pubsub_publish_subscribe, SinglePublishSubscribe); Suite *suite = suite_create("PubSub readerGroups/reader/Fields handling and publishing"); suite_add_tcase(suite, tc_add_pubsub_readergroup); suite_add_tcase(suite, tc_pubsub_publish_subscribe); SRunner *suiteRunner = srunner_create(suite); srunner_set_fork_status(suiteRunner, CK_NOFORK); srunner_run_all(suiteRunner,CK_NORMAL); int number_failed = srunner_ntests_failed(suiteRunner); srunner_free(suiteRunner); return (number_failed == 0) ? EXIT_SUCCESS : EXIT_FAILURE; }