/* This work is licensed under a Creative Commons CCZero 1.0 Universal License. * See http://creativecommons.org/publicdomain/zero/1.0/ for more information. */ #include <signal.h> #include "open62541.h" static UA_Boolean running = true; static void stopHandler(int sig) { UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "received ctrl-c"); running = false; } #ifdef UA_ENABLE_SUBSCRIPTIONS static void handler_events(const UA_UInt32 monId, const size_t nEventFields, const UA_Variant *eventFields, void *context) { UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Notification"); for(size_t i = 0; i < nEventFields; ++i) { if (UA_Variant_hasScalarType(&eventFields[i], &UA_TYPES[UA_TYPES_UINT16])) { UA_UInt16 severity = *(UA_UInt16 *)eventFields[i].data; UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Severity: %u", severity); } else if (UA_Variant_hasScalarType(&eventFields[i], &UA_TYPES[UA_TYPES_LOCALIZEDTEXT])) { UA_LocalizedText *lt = (UA_LocalizedText *)eventFields[i].data; UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Message: '%.*s'", (int)lt->text.length, lt->text.data); } else { UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Don't know how to handle type: '%s'", eventFields[i].type->typeName); } } } const size_t nSelectClauses = 2; static UA_SimpleAttributeOperand * setupSelectClauses(void) { UA_SimpleAttributeOperand *selectClauses = (UA_SimpleAttributeOperand*) UA_Array_new(nSelectClauses, &UA_TYPES[UA_TYPES_SIMPLEATTRIBUTEOPERAND]); if(!selectClauses) return NULL; for(size_t i =0; i<nSelectClauses; ++i) { UA_SimpleAttributeOperand_init(&selectClauses[i]); } selectClauses[0].typeDefinitionId = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEEVENTTYPE); selectClauses[0].browsePathSize = 1; selectClauses[0].browsePath = (UA_QualifiedName*)UA_Array_new(selectClauses[0].browsePathSize, &UA_TYPES[UA_TYPES_QUALIFIEDNAME]); if(!selectClauses[0].browsePath) { UA_SimpleAttributeOperand_delete(selectClauses); return NULL; } selectClauses[0].attributeId = UA_ATTRIBUTEID_VALUE; selectClauses[0].browsePath[0] = UA_QUALIFIEDNAME_ALLOC(0, "Message"); selectClauses[1].typeDefinitionId = UA_NODEID_NUMERIC(0, UA_NS0ID_BASEEVENTTYPE); selectClauses[1].browsePathSize = 1; selectClauses[1].browsePath = (UA_QualifiedName*)UA_Array_new(selectClauses[1].browsePathSize, &UA_TYPES[UA_TYPES_QUALIFIEDNAME]); if(!selectClauses[1].browsePath) { UA_SimpleAttributeOperand_deleteMembers(selectClauses); UA_SimpleAttributeOperand_delete(selectClauses); return NULL; } selectClauses[1].attributeId = UA_ATTRIBUTEID_VALUE; selectClauses[1].browsePath[0] = UA_QUALIFIEDNAME_ALLOC(0, "Severity"); return selectClauses; } #endif int main(int argc, char *argv[]) { signal(SIGINT, stopHandler); signal(SIGTERM, stopHandler); UA_Client *client = UA_Client_new(UA_ClientConfig_default); UA_StatusCode retval = UA_Client_connect(client, "opc.tcp://uademo.prosysopc.com:53530/OPCUA/SimulationServer"); if(retval != UA_STATUSCODE_GOOD) { UA_Client_delete(client); return (int)retval; } #ifdef UA_ENABLE_SUBSCRIPTIONS /* Create a subscription */ UA_UInt32 subId = 0; retval = UA_Client_Subscriptions_new(client, UA_SubscriptionSettings_default, &subId); if(!subId) { UA_Client_disconnect(client); UA_Client_delete(client); return (int)retval; } UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Create subscription succeeded, id %u", subId); /* Add a MonitoredItem */ UA_NodeId monitorThis = UA_NODEID_NUMERIC(0, 2253); // Root->Objects->Server UA_UInt32 monId = 0; UA_SimpleAttributeOperand *selectClauses = setupSelectClauses(); if(!selectClauses){ UA_Client_Subscriptions_remove(client, subId); UA_Client_disconnect(client); UA_Client_delete(client); return (int)UA_STATUSCODE_BADOUTOFMEMORY; } UA_Client_Subscriptions_addMonitoredEvent(client, subId, monitorThis, UA_ATTRIBUTEID_EVENTNOTIFIER, selectClauses, nSelectClauses, NULL, 0, &handler_events, NULL, &monId); if (!monId) { UA_Array_delete(selectClauses, nSelectClauses, &UA_TYPES[UA_TYPES_SIMPLEATTRIBUTEOPERAND]); UA_Client_Subscriptions_remove(client, subId); UA_Client_disconnect(client); UA_Client_delete(client); return (int)retval; } UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Monitoring 'Root->Objects->Server', id %u", subId); while (running) UA_Client_Subscriptions_manuallySendPublishRequest(client); /* Delete the subscription */ if(!UA_Client_Subscriptions_remove(client, subId)) UA_LOG_INFO(UA_Log_Stdout, UA_LOGCATEGORY_USERLAND, "Subscription removed"); #endif UA_Client_disconnect(client); UA_Client_delete(client); return (int) UA_STATUSCODE_GOOD; }