/* 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 2018 (c) basysKom GmbH (Author: Peter Rustler) */ #include "ua_types.h" #include "ua_server.h" #include "ua_client.h" #include "client/ua_client_internal.h" #include "ua_client_highlevel.h" #include "ua_config_default.h" #include "ua_network_tcp.h" #include "check.h" #include "testing_clock.h" #include "testing_networklayers.h" #include "thread_wrapper.h" #include #ifdef UA_ENABLE_STATUSCODE_DESCRIPTIONS #define ASSERT_STATUSCODE(a,b) ck_assert_str_eq(UA_StatusCode_name(a),UA_StatusCode_name(b)); #else #define ASSERT_STATUSCODE(a,b) ck_assert_uint_eq((a),(b)); #endif UA_Server *server; UA_ServerConfig *config; UA_Boolean running; THREAD_HANDLE server_thread; UA_Client *client; UA_NodeId parentNodeId; UA_NodeId parentReferenceNodeId; UA_NodeId outNodeId; THREAD_CALLBACK(serverloop) { while(running) UA_Server_run_iterate(server, true); return 0; } static void setup(void) { running = true; config = UA_ServerConfig_new_default(); server = UA_Server_new(config); UA_StatusCode retval = UA_Server_run_startup(server); ASSERT_STATUSCODE(retval, UA_STATUSCODE_GOOD); THREAD_CREATE(server_thread, serverloop); /* Define the attribute of the uint32 variable node */ UA_VariableAttributes attr = UA_VariableAttributes_default; UA_UInt32 myUint32 = 40; UA_Variant_setScalar(&attr.value, &myUint32, &UA_TYPES[UA_TYPES_UINT32]); attr.description = UA_LOCALIZEDTEXT("en-US","the answer"); attr.displayName = UA_LOCALIZEDTEXT("en-US","the answer"); attr.dataType = UA_TYPES[UA_TYPES_UINT32].typeId; attr.accessLevel = UA_ACCESSLEVELMASK_READ | UA_ACCESSLEVELMASK_WRITE; /* Add the variable node to the information model */ UA_NodeId uint32NodeId = UA_NODEID_STRING(1, "the.answer"); UA_QualifiedName uint32Name = UA_QUALIFIEDNAME(1, "the answer"); parentNodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER); parentReferenceNodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_ORGANIZES); UA_NodeId_init(&outNodeId); ASSERT_STATUSCODE(UA_Server_addVariableNode(server, uint32NodeId, parentNodeId, parentReferenceNodeId, uint32Name, UA_NODEID_NUMERIC(0, UA_NS0ID_BASEDATAVARIABLETYPE), attr, NULL, &outNodeId) , UA_STATUSCODE_GOOD); client = UA_Client_new(UA_ClientConfig_default); retval = UA_Client_connect(client, "opc.tcp://localhost:4840"); ASSERT_STATUSCODE(retval, UA_STATUSCODE_GOOD); UA_Client_recv = client->connection.recv; client->connection.recv = UA_Client_recvTesting; } static void teardown(void) { /* cleanup */ UA_Client_disconnect(client); UA_Client_delete(client); UA_NodeId_deleteMembers(&parentNodeId); UA_NodeId_deleteMembers(&parentReferenceNodeId); UA_NodeId_deleteMembers(&outNodeId); running = false; THREAD_JOIN(server_thread); UA_Server_run_shutdown(server); UA_Server_delete(server); UA_ServerConfig_delete(config); } static UA_StatusCode setUInt32(UA_Client *thisClient, UA_NodeId node, UA_UInt32 value) { UA_Variant variant; UA_Variant_setScalar(&variant, &value, &UA_TYPES[UA_TYPES_UINT32]); return UA_Client_writeValueAttribute(thisClient, node, &variant); } static void dataChangeNotificationCallback(UA_Server *thisServer, UA_UInt32 monitoredItemId, void *monitoredItemContext, const UA_NodeId *nodeId, void *nodeContext, UA_UInt32 attributeId, const UA_DataValue *value) { static size_t count = 0; static UA_UInt32 lastValue = 100; UA_UInt32 currentValue = *((UA_UInt32*)value->value.data); ck_assert_uint_ne(lastValue, currentValue); lastValue = currentValue; if (count++ == 10) { UA_Server_deleteMonitoredItem(server, monitoredItemId); running = false; } } START_TEST(Server_LocalMonitoredItem) { ASSERT_STATUSCODE(setUInt32(client, outNodeId, 0), UA_STATUSCODE_GOOD); UA_MonitoredItemCreateRequest monitorRequest = UA_MonitoredItemCreateRequest_default(outNodeId); monitorRequest.requestedParameters.samplingInterval = (double)100; monitorRequest.monitoringMode = UA_MONITORINGMODE_REPORTING; UA_MonitoredItemCreateResult result = UA_Server_createDataChangeMonitoredItem(server, UA_TIMESTAMPSTORETURN_BOTH, monitorRequest, NULL, &dataChangeNotificationCallback); ASSERT_STATUSCODE(result.statusCode, UA_STATUSCODE_GOOD); UA_UInt32 count = 0; while (running) { ASSERT_STATUSCODE(setUInt32(client, outNodeId, count++), UA_STATUSCODE_GOOD); UA_fakeSleep(100); UA_realSleep(100); } } END_TEST static Suite* testSuite_Client(void) { Suite *s = suite_create("Local Monitored Item"); TCase *tc_server = tcase_create("Local Monitored Item Basic"); tcase_add_checked_fixture(tc_server, setup, teardown); tcase_add_test(tc_server, Server_LocalMonitoredItem); suite_add_tcase(s, tc_server); return s; } int main(void) { Suite *s = testSuite_Client(); 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; }