/* * Copyright (c) 2019, Mathias Küsel * MIT License */ #include #include #include namespace node_snap7 { Nan::Persistent S7Client::constructor; NAN_MODULE_INIT(S7Client::Init) { Nan::HandleScope scope; v8::Local tpl; tpl = Nan::New(S7Client::New); v8::Local name = Nan::New("S7Client") .ToLocalChecked(); tpl->SetClassName(name); tpl->InstanceTemplate()->SetInternalFieldCount(1); // Setup the prototype // Control functions Nan::SetPrototypeMethod( tpl , "Connect" , S7Client::Connect); Nan::SetPrototypeMethod( tpl , "ConnectTo" , S7Client::ConnectTo); Nan::SetPrototypeMethod( tpl , "SetConnectionParams" , S7Client::SetConnectionParams); Nan::SetPrototypeMethod( tpl , "SetConnectionType" , S7Client::SetConnectionType); Nan::SetPrototypeMethod( tpl , "Disconnect" , S7Client::Disconnect); Nan::SetPrototypeMethod( tpl , "GetParam" , S7Client::GetParam); Nan::SetPrototypeMethod( tpl , "SetParam" , S7Client::SetParam); // Data I/O Main functions Nan::SetPrototypeMethod( tpl , "ReadArea" , S7Client::ReadArea); Nan::SetPrototypeMethod( tpl , "WriteArea" , S7Client::WriteArea); Nan::SetPrototypeMethod( tpl , "ReadMultiVars" , S7Client::ReadMultiVars); Nan::SetPrototypeMethod( tpl , "WriteMultiVars" , S7Client::WriteMultiVars); // Directory functions Nan::SetPrototypeMethod( tpl , "ListBlocks" , S7Client::ListBlocks); Nan::SetPrototypeMethod( tpl , "GetAgBlockInfo" , S7Client::GetAgBlockInfo); Nan::SetPrototypeMethod( tpl , "GetPgBlockInfo" , S7Client::GetPgBlockInfo); Nan::SetPrototypeMethod( tpl , "ListBlocksOfType" , S7Client::ListBlocksOfType); // Blocks functions Nan::SetPrototypeMethod( tpl , "Upload" , S7Client::Upload); Nan::SetPrototypeMethod( tpl , "FullUpload" , S7Client::FullUpload); Nan::SetPrototypeMethod( tpl , "Download" , S7Client::Download); Nan::SetPrototypeMethod( tpl , "Delete" , S7Client::Delete); Nan::SetPrototypeMethod( tpl , "DBGet" , S7Client::DBGet); Nan::SetPrototypeMethod( tpl , "DBFill" , S7Client::DBFill); // Date/Time functions Nan::SetPrototypeMethod( tpl , "GetPlcDateTime" , S7Client::GetPlcDateTime); Nan::SetPrototypeMethod( tpl , "SetPlcDateTime" , S7Client::SetPlcDateTime); Nan::SetPrototypeMethod( tpl , "SetPlcSystemDateTime" , S7Client::SetPlcSystemDateTime); // System Info functions Nan::SetPrototypeMethod( tpl , "GetOrderCode" , S7Client::GetOrderCode); Nan::SetPrototypeMethod( tpl , "GetCpuInfo" , S7Client::GetCpuInfo); Nan::SetPrototypeMethod( tpl , "GetCpInfo" , S7Client::GetCpInfo); Nan::SetPrototypeMethod( tpl , "ReadSZL" , S7Client::ReadSZL); Nan::SetPrototypeMethod( tpl , "ReadSZLList" , S7Client::ReadSZLList); // Control functions Nan::SetPrototypeMethod( tpl , "PlcHotStart" , S7Client::PlcHotStart); Nan::SetPrototypeMethod( tpl , "PlcColdStart" , S7Client::PlcColdStart); Nan::SetPrototypeMethod( tpl , "PlcStop" , S7Client::PlcStop); Nan::SetPrototypeMethod( tpl , "CopyRamToRom" , S7Client::CopyRamToRom); Nan::SetPrototypeMethod( tpl , "Compress" , S7Client::Compress); // Security functions Nan::SetPrototypeMethod( tpl , "GetProtection" , S7Client::GetProtection); Nan::SetPrototypeMethod( tpl , "SetSessionPassword" , S7Client::SetSessionPassword); Nan::SetPrototypeMethod( tpl , "ClearSessionPassword" , S7Client::ClearSessionPassword); // Properties Nan::SetPrototypeMethod( tpl , "ExecTime" , S7Client::ExecTime); Nan::SetPrototypeMethod( tpl , "LastError" , S7Client::LastError); Nan::SetPrototypeMethod( tpl , "PDURequested" , S7Client::PDURequested); Nan::SetPrototypeMethod( tpl , "PDULength" , S7Client::PDULength); Nan::SetPrototypeMethod( tpl , "PlcStatus" , S7Client::PlcStatus); Nan::SetPrototypeMethod( tpl , "Connected" , S7Client::Connected); // Error to text function Nan::SetPrototypeMethod( tpl , "ErrorText" , S7Client::ErrorText); // Error codes Nan::SetPrototypeTemplate( tpl , Nan::New("errNegotiatingPDU").ToLocalChecked() , Nan::New(errNegotiatingPDU) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidParams").ToLocalChecked() , Nan::New(errCliInvalidParams) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliJobPending").ToLocalChecked() , Nan::New(errCliJobPending) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliTooManyItems").ToLocalChecked() , Nan::New(errCliTooManyItems) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidWordLen").ToLocalChecked() , Nan::New(errCliInvalidWordLen) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliPartialDataWritten").ToLocalChecked() , Nan::New(errCliPartialDataWritten) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliSizeOverPDU").ToLocalChecked() , Nan::New(errCliSizeOverPDU) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidPlcAnswer").ToLocalChecked() , Nan::New(errCliInvalidPlcAnswer) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliAddressOutOfRange").ToLocalChecked() , Nan::New(errCliAddressOutOfRange) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidTransportSize").ToLocalChecked() , Nan::New(errCliInvalidTransportSize) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliWriteDataSizeMismatch").ToLocalChecked() , Nan::New(errCliWriteDataSizeMismatch) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliItemNotAvailable").ToLocalChecked() , Nan::New(errCliItemNotAvailable) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidValue").ToLocalChecked() , Nan::New(errCliInvalidValue) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliCannotStartPLC").ToLocalChecked() , Nan::New(errCliCannotStartPLC) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliAlreadyRun").ToLocalChecked() , Nan::New(errCliAlreadyRun) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliCannotStopPLC").ToLocalChecked() , Nan::New(errCliCannotStopPLC) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliCannotCopyRamToRom").ToLocalChecked() , Nan::New(errCliCannotCopyRamToRom) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliCannotCompress").ToLocalChecked() , Nan::New(errCliCannotCompress) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliAlreadyStop").ToLocalChecked() , Nan::New(errCliAlreadyStop) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliFunNotAvailable").ToLocalChecked() , Nan::New(errCliFunNotAvailable) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliUploadSequenceFailed").ToLocalChecked() , Nan::New(errCliUploadSequenceFailed) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidDataSizeRecvd").ToLocalChecked() , Nan::New(errCliInvalidDataSizeRecvd) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidBlockType").ToLocalChecked() , Nan::New(errCliInvalidBlockType) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidBlockNumber").ToLocalChecked() , Nan::New(errCliInvalidBlockNumber) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidBlockSize").ToLocalChecked() , Nan::New(errCliInvalidBlockSize) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliDownloadSequenceFailed").ToLocalChecked() , Nan::New(errCliDownloadSequenceFailed) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInsertRefused").ToLocalChecked() , Nan::New(errCliInsertRefused) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliDeleteRefused").ToLocalChecked() , Nan::New(errCliDeleteRefused) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliNeedPassword").ToLocalChecked() , Nan::New(errCliNeedPassword) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidPassword").ToLocalChecked() , Nan::New(errCliInvalidPassword) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliNoPasswordToSetOrClear").ToLocalChecked() , Nan::New(errCliNoPasswordToSetOrClear) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliJobTimeout").ToLocalChecked() , Nan::New(errCliJobTimeout) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliPartialDataRead").ToLocalChecked() , Nan::New(errCliPartialDataRead) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliBufferTooSmall").ToLocalChecked() , Nan::New(errCliBufferTooSmall) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliFunctionRefused").ToLocalChecked() , Nan::New(errCliFunctionRefused) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliDestroying").ToLocalChecked() , Nan::New(errCliDestroying) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliInvalidParamNumber").ToLocalChecked() , Nan::New(errCliInvalidParamNumber) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("errCliCannotChangeParam").ToLocalChecked() , Nan::New(errCliCannotChangeParam) , v8::ReadOnly); // Client Connection Type Nan::SetPrototypeTemplate( tpl , Nan::New("CONNTYPE_PG").ToLocalChecked() , Nan::New(CONNTYPE_PG) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("CONNTYPE_OP").ToLocalChecked() , Nan::New(CONNTYPE_OP) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("CONNTYPE_BASIC").ToLocalChecked() , Nan::New(CONNTYPE_BASIC) , v8::ReadOnly); // CPU Status codes Nan::SetPrototypeTemplate( tpl , Nan::New("S7CpuStatusUnknown").ToLocalChecked() , Nan::New(S7CpuStatusUnknown) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7CpuStatusRun").ToLocalChecked() , Nan::New(S7CpuStatusRun) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7CpuStatusStop").ToLocalChecked() , Nan::New(S7CpuStatusStop) , v8::ReadOnly); // Area ID Nan::SetPrototypeTemplate( tpl , Nan::New("S7AreaPE").ToLocalChecked() , Nan::New(S7AreaPE) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7AreaPA").ToLocalChecked() , Nan::New(S7AreaPA) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7AreaMK").ToLocalChecked() , Nan::New(S7AreaMK) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7AreaDB").ToLocalChecked() , Nan::New(S7AreaDB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7AreaCT").ToLocalChecked() , Nan::New(S7AreaCT) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7AreaTM").ToLocalChecked() , Nan::New(S7AreaTM) , v8::ReadOnly); // Word Length Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLBit").ToLocalChecked() , Nan::New(S7WLBit) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLByte").ToLocalChecked() , Nan::New(S7WLByte) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLWord").ToLocalChecked() , Nan::New(S7WLWord) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLDWord").ToLocalChecked() , Nan::New(S7WLDWord) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLReal").ToLocalChecked() , Nan::New(S7WLReal) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLCounter").ToLocalChecked() , Nan::New(S7WLCounter) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("S7WLTimer").ToLocalChecked() , Nan::New(S7WLTimer) , v8::ReadOnly); // Block type Nan::SetPrototypeTemplate( tpl , Nan::New("Block_OB").ToLocalChecked() , Nan::New(Block_OB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("Block_DB").ToLocalChecked() , Nan::New(Block_DB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("Block_SDB").ToLocalChecked() , Nan::New(Block_SDB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("Block_FC").ToLocalChecked() , Nan::New(Block_FC) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("Block_SFC").ToLocalChecked() , Nan::New(Block_SFC) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("Block_FB").ToLocalChecked() , Nan::New(Block_FB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("Block_SFB").ToLocalChecked() , Nan::New(Block_SFB) , v8::ReadOnly); // Sub Block Type Nan::SetPrototypeTemplate( tpl , Nan::New("SubBlk_OB").ToLocalChecked() , Nan::New(SubBlk_OB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SubBlk_SDB").ToLocalChecked() , Nan::New(SubBlk_SDB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SubBlk_FC").ToLocalChecked() , Nan::New(SubBlk_FC) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SubBlk_SFC").ToLocalChecked() , Nan::New(SubBlk_SFC) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SubBlk_FB").ToLocalChecked() , Nan::New(SubBlk_FB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SubBlk_SFB").ToLocalChecked() , Nan::New(SubBlk_SFB) , v8::ReadOnly); // Block languages Nan::SetPrototypeTemplate( tpl , Nan::New("BlockLangAWL").ToLocalChecked() , Nan::New(BlockLangAWL) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BlockLangKOP").ToLocalChecked() , Nan::New(BlockLangKOP) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BlockLangFUP").ToLocalChecked() , Nan::New(BlockLangFUP) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BlockLangSCL").ToLocalChecked() , Nan::New(BlockLangSCL) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BlockLangDB").ToLocalChecked() , Nan::New(BlockLangDB) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BlockLangGRAPH").ToLocalChecked() , Nan::New(BlockLangGRAPH) , v8::ReadOnly); // Parameter Nan::SetPrototypeTemplate( tpl , Nan::New("LocalPort").ToLocalChecked() , Nan::New(p_u16_LocalPort) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("RemotePort").ToLocalChecked() , Nan::New(p_u16_RemotePort) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("PingTimeout").ToLocalChecked() , Nan::New(p_i32_PingTimeout) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SendTimeout").ToLocalChecked() , Nan::New(p_i32_SendTimeout) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("RecvTimeout").ToLocalChecked() , Nan::New(p_i32_RecvTimeout) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("WorkInterval").ToLocalChecked() , Nan::New(p_i32_WorkInterval) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SrcRef").ToLocalChecked() , Nan::New(p_u16_SrcRef) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("DstRef").ToLocalChecked() , Nan::New(p_u16_DstRef) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("SrcTSap").ToLocalChecked() , Nan::New(p_u16_SrcTSap) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("PDURequest").ToLocalChecked() , Nan::New(p_i32_PDURequest) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("MaxClients").ToLocalChecked() , Nan::New(p_i32_MaxClients) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BSendTimeout").ToLocalChecked() , Nan::New(p_i32_BSendTimeout) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("BRecvTimeout").ToLocalChecked() , Nan::New(p_i32_BRecvTimeout) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("RecoveryTime").ToLocalChecked() , Nan::New(p_u32_RecoveryTime) , v8::ReadOnly); Nan::SetPrototypeTemplate( tpl , Nan::New("KeepAliveTime").ToLocalChecked() , Nan::New(p_u32_KeepAliveTime) , v8::ReadOnly); constructor.Reset(tpl); Nan::Set(target, name, Nan::GetFunction(tpl).ToLocalChecked()); } NAN_METHOD(S7Client::New) { if (info.IsConstructCall()) { S7Client *s7client = new S7Client(); s7client->Wrap(info.This()); info.GetReturnValue().Set(info.This()); } else { v8::Local constructorHandle; constructorHandle = Nan::New(constructor); info.GetReturnValue().Set( Nan::NewInstance(Nan::GetFunction(constructorHandle).ToLocalChecked()).ToLocalChecked()); } } S7Client::S7Client() { snap7Client = new TS7Client(); uv_mutex_init(&mutex); } S7Client::~S7Client() { snap7Client->Disconnect(); delete snap7Client; constructor.Reset(); uv_mutex_destroy(&mutex); } int S7Client::GetByteCountFromWordLen(int WordLen) { switch (WordLen) { case S7WLBit: case S7WLByte: return 1; case S7WLWord: case S7WLCounter: case S7WLTimer: return 2; case S7WLReal: case S7WLDWord: return 4; default: return 0; } } void S7Client::FreeCallback(char *data, void *hint) { delete[] data; } void S7Client::FreeCallbackSZL(char *data, void *hint) { delete reinterpret_cast(data); } // Control functions NAN_METHOD(S7Client::Connect) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (!info[0]->IsFunction()) { int ret = s7client->snap7Client->Connect(); info.GetReturnValue().Set(Nan::New(ret == 0)); } else { Nan::Callback *callback = new Nan::Callback(info[0].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, CONNECT)); info.GetReturnValue().SetUndefined(); } } NAN_METHOD(S7Client::ConnectTo) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (info.Length() < 3) { return Nan::ThrowTypeError("Wrong number of arguments"); } if (!info[0]->IsString() || !info[1]->IsInt32() || !info[2]->IsInt32()) { return Nan::ThrowTypeError("Wrong arguments"); } Nan::Utf8String *remAddress = new Nan::Utf8String(info[0]); if (!info[3]->IsFunction()) { int ret = s7client->snap7Client->ConnectTo( **remAddress , Nan::To(info[1]).FromJust() , Nan::To(info[2]).FromJust()); delete remAddress; info.GetReturnValue().Set(Nan::New(ret == 0)); } else { Nan::Callback *callback = new Nan::Callback(info[3].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, CONNECTTO , remAddress, Nan::To(info[1]).FromJust(), Nan::To(info[2]).FromJust())); info.GetReturnValue().SetUndefined(); } } NAN_METHOD(S7Client::SetConnectionParams) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (!info[0]->IsString() || !info[1]->IsUint32() || !info[2]->IsUint32()) { return Nan::ThrowTypeError("Wrong arguments"); } Nan::Utf8String remAddress(info[0]); word LocalTSAP = Nan::To(info[1]).FromJust(); word RemoteTSAP = Nan::To(info[2]).FromJust(); int ret = s7client->snap7Client->SetConnectionParams( *remAddress , LocalTSAP , RemoteTSAP); info.GetReturnValue().Set(Nan::New(ret == 0)); } NAN_METHOD(S7Client::SetConnectionType) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (!info[0]->IsUint32()) { return Nan::ThrowTypeError("Wrong arguments"); } word type = Nan::To(info[0]).FromJust(); int ret = s7client->snap7Client->SetConnectionType(type); info.GetReturnValue().Set(Nan::New(ret == 0)); } NAN_METHOD(S7Client::Disconnect) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); int ret = s7client->snap7Client->Disconnect(); info.GetReturnValue().Set(Nan::New(ret == 0)); } NAN_METHOD(S7Client::GetParam) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (!info[0]->IsInt32()) { return Nan::ThrowTypeError("Wrong arguments"); } int pData; int returnValue = s7client->snap7Client->GetParam(Nan::To(info[0]).FromJust() , &pData); if (returnValue == 0) { info.GetReturnValue().Set(Nan::New(pData)); } else { info.GetReturnValue().Set(Nan::New(returnValue)); } } NAN_METHOD(S7Client::SetParam) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (!(info[0]->IsInt32() || info[1]->IsInt32())) { return Nan::ThrowTypeError("Wrong arguments"); } int pData = Nan::To(info[1]).FromJust(); int ret = s7client->snap7Client->SetParam(Nan::To(info[0]).FromJust(), &pData); info.GetReturnValue().Set(Nan::New(ret == 0)); } // Data I/O Main functions void IOWorker::Execute() { uv_mutex_lock(&s7client->mutex); switch (caller) { case CONNECTTO: returnValue = s7client->snap7Client->ConnectTo( **static_cast(pData), int1, int2); break; case CONNECT: returnValue = s7client->snap7Client->Connect(); break; case READAREA: returnValue = s7client->snap7Client->ReadArea(int1, int2, int3, int4 , int5, pData); break; case WRITEAREA: returnValue = s7client->snap7Client->WriteArea(int1, int2, int3, int4 , int5, pData); break; case READMULTI: returnValue = s7client->snap7Client->ReadMultiVars( static_cast(pData), int1); break; case WRITEMULTI: returnValue = s7client->snap7Client->WriteMultiVars( static_cast(pData), int1); break; case PLCSTATUS: returnValue = s7client->snap7Client->PlcStatus(); if ((returnValue == S7CpuStatusUnknown) || (returnValue == S7CpuStatusStop) || (returnValue == S7CpuStatusRun)) { int1 = returnValue; returnValue = 0; } break; case CLEARSESSIONPW: returnValue = s7client->snap7Client->ClearSessionPassword(); break; case SETSESSIONPW: returnValue = s7client->snap7Client->SetSessionPassword( **static_cast(pData)); break; case GETPROTECTION: returnValue = s7client->snap7Client->GetProtection( static_cast(pData)); break; case PLCSTOP: returnValue = s7client->snap7Client->PlcStop(); break; case PLCCOLDSTART: returnValue = s7client->snap7Client->PlcColdStart(); break; case PLCHOTSTART: returnValue = s7client->snap7Client->PlcHotStart(); break; case GETCPINFO: returnValue = s7client->snap7Client->GetCpInfo( static_cast(pData)); break; case GETCPUINFO: returnValue = s7client->snap7Client->GetCpuInfo( static_cast(pData)); break; case GETORDERCODE: returnValue = s7client->snap7Client->GetOrderCode( static_cast(pData)); break; case SETPLCSYSTEMDATETIME: returnValue = s7client->snap7Client->SetPlcSystemDateTime(); break; case GETPLCDATETIME: returnValue = s7client->snap7Client->GetPlcDateTime( static_cast(pData)); break; case SETPLCDATETIME: returnValue = s7client->snap7Client->SetPlcDateTime( static_cast(pData)); break; case COMPRESS: returnValue = s7client->snap7Client->Compress(int1); break; case COPYRAMTOROM: returnValue = s7client->snap7Client->CopyRamToRom(int1); break; case DBFILL: returnValue = s7client->snap7Client->DBFill(int1, int2); break; case DBGET: returnValue = s7client->snap7Client->DBGet(int1, pData, &int2); break; case DELETEBLOCK: returnValue = s7client->snap7Client->Delete(int1, int2); break; case DOWNLOAD: returnValue = s7client->snap7Client->Download(int1, pData, int2); break; case FULLUPLOAD: returnValue = s7client->snap7Client->FullUpload(int1, int2, pData, &int3); break; case UPLOAD: returnValue = s7client->snap7Client->Upload(int1, int2, pData, &int3); break; case LISTBLOCKSOFTYPE: returnValue = s7client->snap7Client->ListBlocksOfType(int1 , static_cast(pData), &int2); break; case GETAGBLOCKINFO: returnValue = s7client->snap7Client->GetAgBlockInfo(int1, int2 , static_cast(pData)); break; case LISTBLOCKS: returnValue = s7client->snap7Client->ListBlocks( static_cast(pData)); break; case READSZLLIST: returnValue = s7client->snap7Client->ReadSZLList( static_cast(pData), &int1); break; case READSZL: returnValue = s7client->snap7Client->ReadSZL(int1, int2 , static_cast(pData), &int3); break; } uv_mutex_unlock(&s7client->mutex); } void IOWorker::HandleOKCallback() { Nan::HandleScope scope; v8::Local argv1[1]; v8::Local argv2[2]; if (returnValue == 0) { argv2[0] = argv1[0] = Nan::Null(); } else { argv2[0] = argv1[0] = Nan::New(returnValue); } switch (caller) { case CONNECTTO: case SETSESSIONPW: delete static_cast(pData); callback->Call(1, argv1, async_resource); break; case CONNECT: case WRITEAREA: case CLEARSESSIONPW: case PLCSTOP: case PLCCOLDSTART: case PLCHOTSTART: case SETPLCSYSTEMDATETIME: case COPYRAMTOROM: case COMPRESS: case DBFILL: case DELETEBLOCK: case DOWNLOAD: callback->Call(1, argv1, async_resource); break; case READAREA: if (returnValue == 0) { argv2[1] = Nan::NewBuffer( static_cast(pData) , int4 * s7client->GetByteCountFromWordLen(int5) , S7Client::FreeCallback, NULL).ToLocalChecked(); } else { argv2[1] = Nan::Null(); delete[] static_cast(pData); } callback->Call(2, argv2, async_resource); break; case READMULTI: if (returnValue == 0) { argv2[1] = s7client->S7DataItemToArray(static_cast(pData) , int1, true); } else { for (int i = 0; i < int1; i++) { delete[] static_cast(static_cast(pData)[i].pdata); } delete[] static_cast(pData); argv2[1] = Nan::Null(); } callback->Call(2, argv2, async_resource); break; case WRITEMULTI: if (returnValue == 0) { argv2[1] = s7client->S7DataItemToArray(static_cast(pData) , int1, false); } else { delete[] static_cast(pData); argv2[1] = Nan::Null(); } callback->Call(2, argv2, async_resource); break; case GETPROTECTION: if (returnValue == 0) { argv2[1] = s7client->S7ProtectionToObject( static_cast(pData)); } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case GETCPINFO: if (returnValue == 0) { argv2[1] = s7client->S7CpInfoToObject( static_cast(pData)); } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case GETCPUINFO: if (returnValue == 0) { argv2[1] = s7client->S7CpuInfoToObject( static_cast(pData)); } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case GETORDERCODE: if (returnValue == 0) { argv2[1] = s7client->S7OrderCodeToObject( static_cast(pData)); } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case GETPLCDATETIME: if (returnValue == 0) { double timestamp = static_cast(mktime(static_cast(pData))); argv2[1] = Nan::New(timestamp * 1000).ToLocalChecked(); } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case SETPLCDATETIME: delete static_cast(pData); callback->Call(1, argv1, async_resource); break; case PLCSTATUS: if (returnValue == 0) { argv2[1] = Nan::New(int1); } else { argv2[1] = Nan::Null(); } callback->Call(2, argv2, async_resource); break; case DBGET: if (returnValue == 0) { argv2[1] = Nan::NewBuffer( static_cast(pData) , int2 , S7Client::FreeCallback , NULL).ToLocalChecked(); } else { argv2[1] = Nan::Null(); delete[] static_cast(pData); } callback->Call(2, argv2, async_resource); break; case FULLUPLOAD: case UPLOAD: if (returnValue == 0) { argv2[1] = Nan::NewBuffer( static_cast(pData) , int3 , S7Client::FreeCallback , NULL).ToLocalChecked(); } else { argv2[1] = Nan::Null(); delete[] static_cast(pData); } callback->Call(2, argv2, async_resource); break; case LISTBLOCKSOFTYPE: if (returnValue == 0) { argv2[1] = s7client->S7BlocksOfTypeToArray( static_cast(pData), int2); } else { argv2[1] = Nan::Null(); } delete[] static_cast(pData); callback->Call(2, argv2, async_resource); break; case GETAGBLOCKINFO: if (returnValue == 0) { v8::Local block_info = s7client->S7BlockInfoToObject( static_cast(pData)); argv2[1] = block_info; } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case LISTBLOCKS: if (returnValue == 0) { v8::Local blocks_list = s7client->S7BlocksListToObject( static_cast(pData)); argv2[1] = blocks_list; } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case READSZLLIST: if (returnValue == 0) { v8::Local szl_list = s7client->S7SZLListToArray( static_cast(pData), int1); argv2[1] = szl_list; } else { argv2[1] = Nan::Null(); } delete static_cast(pData); callback->Call(2, argv2, async_resource); break; case READSZL: if (returnValue == 0) { argv2[1] = Nan::NewBuffer( reinterpret_cast(static_cast(pData)) , int3 , S7Client::FreeCallbackSZL , NULL).ToLocalChecked(); } else { argv2[1] = Nan::Null(); delete static_cast(pData); } callback->Call(2, argv2, async_resource); break; } } NAN_METHOD(S7Client::ReadArea) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (info.Length() < 5) return Nan::ThrowTypeError("Wrong number of Arguments"); if (!info[0]->IsInt32() || !info[1]->IsInt32() || !info[2]->IsInt32() || !info[3]->IsInt32() || !info[4]->IsInt32()) return Nan::ThrowTypeError("Wrong arguments"); int amount = Nan::To(info[3]).FromJust(); int byteCount = s7client->GetByteCountFromWordLen(Nan::To(info[4]).FromJust()); int size = amount * byteCount; char *bufferData = new char[size]; if (!info[5]->IsFunction()) { int returnValue = s7client->snap7Client->ReadArea( Nan::To(info[0]).FromJust(), Nan::To(info[1]).FromJust() , Nan::To(info[2]).FromJust(), Nan::To(info[3]).FromJust() , Nan::To(info[4]).FromJust(), bufferData); if (returnValue == 0) { v8::Local ret = Nan::NewBuffer( bufferData , size , S7Client::FreeCallback , NULL).ToLocalChecked(); info.GetReturnValue().Set(ret); } else { delete[] bufferData; info.GetReturnValue().Set(Nan::False()); } } else { Nan::Callback *callback = new Nan::Callback(info[5].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, READAREA , bufferData, Nan::To(info[0]).FromJust(), Nan::To(info[1]).FromJust() , Nan::To(info[2]).FromJust(), Nan::To(info[3]).FromJust(), Nan::To(info[4]).FromJust())); info.GetReturnValue().SetUndefined(); } } NAN_METHOD(S7Client::WriteArea) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (info.Length() < 6) return Nan::ThrowTypeError("Wrong number of Arguments"); if (!info[0]->IsInt32() || !info[1]->IsInt32() || !info[2]->IsInt32() || !info[3]->IsInt32() || !info[4]->IsInt32() || !node::Buffer::HasInstance(info[5])) return Nan::ThrowTypeError("Wrong arguments"); if (!info[6]->IsFunction()) { info.GetReturnValue().Set(Nan::New( s7client->snap7Client->WriteArea(Nan::To(info[0]).FromJust() , Nan::To(info[1]).FromJust(), Nan::To(info[2]).FromJust() , Nan::To(info[3]).FromJust(), Nan::To(info[4]).FromJust() , node::Buffer::Data(info[5].As())) == 0)); } else { Nan::Callback *callback = new Nan::Callback(info[6].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, WRITEAREA , node::Buffer::Data(info[5].As()), Nan::To(info[0]).FromJust() , Nan::To(info[1]).FromJust(), Nan::To(info[2]).FromJust(), Nan::To(info[3]).FromJust() , Nan::To(info[4]).FromJust())); info.GetReturnValue().SetUndefined(); } } NAN_METHOD(S7Client::ReadMultiVars) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (info.Length() < 1) { return Nan::ThrowTypeError("Wrong number of arguments"); } if (!info[0]->IsArray()) { return Nan::ThrowTypeError("Wrong arguments"); } v8::Local data_arr = v8::Local::Cast(info[0]); int len = data_arr->Length(); if (len == 0) { return Nan::ThrowTypeError("Array needs at least 1 item"); } else if (len > MaxVars) { std::stringstream err; err << "Array exceeds max variables (" << MaxVars << ") that can be transferred with ReadMultiVars()"; return Nan::ThrowTypeError(err.str().c_str()); } for (int i = 0; i < len; i++) { if (!Nan::Get(data_arr, i).ToLocalChecked()->IsObject()) { return Nan::ThrowTypeError("Wrong argument structure"); } else { v8::Local data_obj = Nan::To(Nan::Get(data_arr, i).ToLocalChecked()).ToLocalChecked(); if (!Nan::Has(data_obj, Nan::New("Area").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("WordLen").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("Start").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("Amount").ToLocalChecked()).FromJust()) { return Nan::ThrowTypeError("Wrong argument structure"); } else if (!Nan::Get(data_obj, Nan::New("Area").ToLocalChecked()).ToLocalChecked()->IsInt32() || !Nan::Get(data_obj, Nan::New("WordLen").ToLocalChecked()).ToLocalChecked()->IsInt32() || !Nan::Get(data_obj, Nan::New("Start").ToLocalChecked()).ToLocalChecked()->IsInt32() || !Nan::Get(data_obj, Nan::New("Amount").ToLocalChecked()).ToLocalChecked()->IsInt32()) { return Nan::ThrowTypeError("Wrong argument structure"); } else if (Nan::To(Nan::Get(data_obj, Nan::New("Area").ToLocalChecked()).ToLocalChecked()).FromJust() == S7AreaDB) { if (!Nan::Has(data_obj, Nan::New("DBNumber").ToLocalChecked()).FromJust()) { return Nan::ThrowTypeError("Wrong argument structure"); } } else { Nan::Set(data_obj, Nan::New("DBNumber").ToLocalChecked(), Nan::New(0)); } } } PS7DataItem Items = new TS7DataItem[len]; v8::Local data_obj; int byteCount, size; for (int i = 0; i < len; i++) { data_obj = Nan::To(Nan::Get(data_arr, i).ToLocalChecked()).ToLocalChecked(); Items[i].Area = Nan::To(Nan::Get(data_obj, Nan::New("Area").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].WordLen = Nan::To(Nan::Get(data_obj, Nan::New("WordLen").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].DBNumber = Nan::To(Nan::Get(data_obj, Nan::New("DBNumber").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].Start = Nan::To(Nan::Get(data_obj, Nan::New("Start").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].Amount = Nan::To(Nan::Get(data_obj, Nan::New("Amount").ToLocalChecked()).ToLocalChecked()).FromJust(); byteCount = s7client->GetByteCountFromWordLen(Items[i].WordLen); size = Items[i].Amount * byteCount; Items[i].pdata = new char[size]; } if (!info[1]->IsFunction()) { int returnValue = s7client->snap7Client->ReadMultiVars(Items, len); if (returnValue == 0) { info.GetReturnValue().Set(s7client->S7DataItemToArray(Items, len, true)); } else { for (int i = 0; i < len; i++) { delete[] static_cast(Items[i].pdata); } delete[] Items; info.GetReturnValue().Set(Nan::False()); } } else { Nan::Callback *callback = new Nan::Callback(info[1].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, READMULTI , Items, len)); info.GetReturnValue().SetUndefined(); } } v8::Local S7Client::S7DataItemToArray( PS7DataItem Items , int len , bool readMulti ) { Nan::EscapableHandleScope scope; v8::Local res_arr = Nan::New(len); v8::Local res_obj; int byteCount, size; for (int i = 0; i < len; i++) { res_obj = Nan::New(); Nan::Set(res_obj, Nan::New("Result").ToLocalChecked() , Nan::New(Items[i].Result)); if (readMulti == true) { if (Items[i].Result == 0) { byteCount = S7Client::GetByteCountFromWordLen(Items[i].WordLen); size = byteCount * Items[i].Amount; Nan::Set( res_obj , Nan::New("Data").ToLocalChecked() , Nan::NewBuffer( static_cast(Items[i].pdata) , size , S7Client::FreeCallback , NULL).ToLocalChecked()); } else { delete[] static_cast(Items[i].pdata); Nan::Set(res_obj, Nan::New("Data").ToLocalChecked(), Nan::Null()); } } Nan::Set(res_arr, i, res_obj); } delete[] Items; return scope.Escape(res_arr); } NAN_METHOD(S7Client::WriteMultiVars) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); if (info.Length() < 1) { return Nan::ThrowTypeError("Wrong number of arguments"); } if (!info[0]->IsArray()) { return Nan::ThrowTypeError("Wrong arguments"); } v8::Local data_arr = v8::Local::Cast(info[0]); int len = data_arr->Length(); if (len == 0) { return Nan::ThrowTypeError("Array needs at least 1 item"); } else if (len > MaxVars) { std::stringstream err; err << "Array exceeds max variables (" << MaxVars << ") that can be transferred with WriteMultiVars()"; return Nan::ThrowTypeError(err.str().c_str()); } for (int i = 0; i < len; i++) { if (!Nan::Get(data_arr, i).ToLocalChecked()->IsObject()) { return Nan::ThrowTypeError("Wrong argument structure"); } else { v8::Local data_obj = Nan::To(Nan::Get(data_arr, i).ToLocalChecked()).ToLocalChecked(); if (!Nan::Has(data_obj, Nan::New("Area").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("WordLen").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("Start").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("Amount").ToLocalChecked()).FromJust() || !Nan::Has(data_obj, Nan::New("Data").ToLocalChecked()).FromJust()) { return Nan::ThrowTypeError("Wrong argument structure"); } else if (!Nan::Get(data_obj, Nan::New("Area").ToLocalChecked()).ToLocalChecked()->IsInt32() || !Nan::Get(data_obj, Nan::New("WordLen").ToLocalChecked()).ToLocalChecked()->IsInt32() || !Nan::Get(data_obj, Nan::New("Start").ToLocalChecked()).ToLocalChecked()->IsInt32() || !Nan::Get(data_obj, Nan::New("Amount").ToLocalChecked()).ToLocalChecked()->IsInt32() || !node::Buffer::HasInstance(Nan::Get(data_obj, Nan::New("Data").ToLocalChecked()).ToLocalChecked())) { return Nan::ThrowTypeError("Wrong argument structure"); } else if (Nan::To(Nan::Get(data_obj, Nan::New("Area").ToLocalChecked()).ToLocalChecked()).FromJust() == S7AreaDB) { if (!Nan::Has(data_obj, Nan::New("DBNumber").ToLocalChecked()).FromJust()) { return Nan::ThrowTypeError("Wrong argument structure"); } } else { Nan::Set(data_obj, Nan::New("DBNumber").ToLocalChecked(), Nan::New(0)); } } } PS7DataItem Items = new TS7DataItem[len]; v8::Local data_obj; for (int i = 0; i < len; i++) { data_obj = Nan::To(Nan::Get(data_arr, i).ToLocalChecked()).ToLocalChecked(); Items[i].Area = Nan::To(Nan::Get(data_obj, Nan::New("Area").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].WordLen = Nan::To(Nan::Get(data_obj, Nan::New("WordLen").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].DBNumber = Nan::To(Nan::Get(data_obj, Nan::New("DBNumber").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].Start = Nan::To(Nan::Get(data_obj, Nan::New("Start").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].Amount = Nan::To(Nan::Get(data_obj, Nan::New("Amount").ToLocalChecked()).ToLocalChecked()).FromJust(); Items[i].pdata = node::Buffer::Data(Nan::Get(data_obj, Nan::New("Data").ToLocalChecked()).ToLocalChecked().As()); } if (!info[1]->IsFunction()) { int returnValue = s7client->snap7Client->WriteMultiVars(Items, len); if (returnValue == 0) { info.GetReturnValue().Set(s7client->S7DataItemToArray(Items, len, false)); } else { delete[] Items; info.GetReturnValue().Set(Nan::False()); } } else { Nan::Callback *callback = new Nan::Callback(info[1].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, WRITEMULTI , Items, len)); info.GetReturnValue().SetUndefined(); } } // Directory functions NAN_METHOD(S7Client::ListBlocks) { S7Client *s7client = ObjectWrap::Unwrap(info.Holder()); PS7BlocksList BlocksList = new TS7BlocksList; if (!info[0]->IsFunction()) { int returnValue = s7client->snap7Client->ListBlocks(BlocksList); v8::Local blocks_list = s7client->S7BlocksListToObject( BlocksList); if (returnValue == 0) { delete BlocksList; info.GetReturnValue().Set(blocks_list); } else { delete BlocksList; info.GetReturnValue().Set(Nan::False()); } } else { Nan::Callback *callback = new Nan::Callback(info[0].As()); Nan::AsyncQueueWorker(new IOWorker(callback, s7client, LISTBLOCKS , BlocksList)); info.GetReturnValue().SetUndefined(); } } v8::Local S7Client::S7BlocksListToObject( PS7BlocksList BlocksList ) { Nan::EscapableHandleScope scope; v8::Local blocks_list = Nan::New(); Nan::Set(blocks_list, Nan::New("OBCount").ToLocalChecked() , Nan::New(BlocksList->OBCount)); Nan::Set(blocks_list, Nan::New("FBCount").ToLocalChecked() , Nan::New(BlocksList->FBCount)); Nan::Set(blocks_list, Nan::New("FCCount").ToLocalChecked() , Nan::New(BlocksList->FCCount)); Nan::Set(blocks_list, Nan::New