#include <uaserver_config.h>
#include <opcua_statuscodes.h>
#include <uaserver_read.h>
#include <uaserver_basenode.h>
#include <uaserver_utilities.h>
#include <uaserver_p_atomic.h>
#include "custom_provider_helper.h"
OPCUA_BEGIN_EXTERN_C
{
OpcUa_ReadRequest *pReq;
OpcUa_ReadResponse *pRes;
OpcUa_Int32 i;
OpcUa_BaseNode *pNode;
OpcUa_NodeId *pNodeId = OpcUa_Null;
OpcUa_InitializeStatus(OpcUa_Module_Server, "CustomProvider_ReadAsync");
OpcUa_ReturnErrorIfArgumentNull(a_pReadCtx);
pReq = a_pReadCtx->pRequest;
pRes = a_pReadCtx->pResponse;
for (i = 0; i < pReq->NoOfNodesToRead; i++)
{
if (pReq->NodesToRead[i].NodeId.NamespaceIndex == g_uCustomProvider_NamespaceIndex)
{
pNodeId = &(pReq->NodesToRead[i].NodeId);
if (pNode)
{
UserDataCommon *pUserData = OpcUa_Null;
if ( (a_pReadCtx->pRequest->NodesToRead[i].AttributeId == OpcUa_Attributes_Value &&
OpcUa_BaseNode_GetType(pNode) == eVariable &&
{
pRes->Results[i].StatusCode = OpcUa_BadNotReadable;
continue;
}
if (pUserData != OpcUa_Null &&
a_pReadCtx->pRequest->NodesToRead[i].AttributeId == OpcUa_Attributes_Value)
{
switch (pUserData->Type)
{
case UserDataTemperature:
{
TemperatureSensor *pSensor = (TemperatureSensor*)pUserData;
pRes->Results[i].Value.Datatype = OpcUaType_Double;
pRes->Results[i].Value.Value.Double = *pSensor->pValue;
pRes->Results[i].StatusCode = OpcUa_Good;
break;
}
case UserDataMachineSwitch:
{
MachineSwitch *pSwitch = (MachineSwitch*)pUserData;
pRes->Results[i].Value.Datatype = OpcUaType_Boolean;
pRes->Results[i].Value.Value.Boolean = *pSwitch->pValue;
pRes->Results[i].StatusCode = OpcUa_Good;
break;
}
default:
{
pRes->Results[i].StatusCode = OpcUa_BadNotReadable;
break;
}
}
if (OpcUa_IsGood(pRes->Results[i].StatusCode))
{
if (a_pReadCtx->pRequest->TimestampsToReturn == OpcUa_TimestampsToReturn_Source ||
a_pReadCtx->pRequest->TimestampsToReturn == OpcUa_TimestampsToReturn_Both)
{
pRes->Results[i].SourceTimestamp = OpcUa_DateTime_UtcNow();
}
if (a_pReadCtx->pRequest->TimestampsToReturn == OpcUa_TimestampsToReturn_Server ||
a_pReadCtx->pRequest->TimestampsToReturn == OpcUa_TimestampsToReturn_Both)
{
pRes->Results[i].ServerTimestamp = OpcUa_DateTime_UtcNow();
}
}
}
else
{
}
}
else
{
pRes->Results[i].StatusCode = OpcUa_BadNodeIdUnknown;
}
}
}
OpcUa_ReturnStatusCode;
OpcUa_BeginErrorHandling;
OpcUa_FinishErrorHandling;
}
OPCUA_END_EXTERN_C