co⚡e: Sparkplug™ MQTT edge

CODESYS + MQTT + Sparkplug B = 'Plug & Play' IIoT

Brought to you by: hermsen, i-campbell
MIT License
Diff of /trunk/mqttsparkplugb/mqttsparkplugb-example/Device_1/Plc Logic/Application/PRG_FB_EoN_Node/svnobj [r525] .. [r526] Maximize Restore

Switch to side-by-side view

--- a/trunk/mqttsparkplugb/mqttsparkplugb-example/Device_1/Plc Logic/Application/PRG_FB_EoN_Node/svnobj
+++ b/trunk/mqttsparkplugb/mqttsparkplugb-example/Device_1/Plc Logic/Application/PRG_FB_EoN_Node/svnobj
@@ -1,43 +1,4 @@
-Gx_l.<!0…jüoç0¯½ëðA®System.StringL{6f9dac99-8de1-4efc-8465-68ac443b7d08}SpecialFuncL{0db3d7bb-cde0-4416-9a7b-ce49a0124323}NoneImplementationL{3b83b776-fb25-43b8-99f2-3c507c9143fc}TextDocument	L{f3878285-8e4f-490b-bb1b-9acbb7eb04db}
-TextLinesL{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}Id
longTagTextScenario();bGenerateDateTimer( IN := NOT GenerateDateTimer.Q,X                   PT := GenerateDataPeriod,^                   ET => GenerateDataElapsed );6IF GenerateDateTimer.Q THEN,    GenerateEoNData();2    GenerateDeviceData();END_IFRIF NOT StillGettingClientCertificate THENT    EoN( ServerUrl           := ServerUrl,V         ServerPort          := ServerPort,T         KeepAlive           := KeepAlive,Z         CleanSession        := CleanSession,R         Username            := Username,R         Password            := Password, N         UseTLS              := UseTLS,!L         hCert               := hCert,"P         GroupId             := GroupId,#R         NodeName            := NodeName,$V         DeviceName          := DeviceName,%\         publishPeriod       := publishPeriod,&         arSparkplugBoolean  := SparkPlugBSimpleTypes.arSparkplugBoolean_D1,'         arSparkplugDateTime := SparkPlugBSimpleTypes.arSparkplugDateTime_D1,(         arSparkplugFloat    := SparkPlugBSimpleTypes.arSparkplugFloat_D1,)         arSparkplugDouble   := SparkPlugBSimpleTypes.arSparkplugDouble_D1,*         arSparkplugInt8     := SparkPlugBSimpleTypes.arSparkplugInt8_D1,+         arSparkplugInt16    := SparkPlugBSimpleTypes.arSparkplugInt16_D1,,         arSparkplugInt32    := SparkPlugBSimpleTypes.arSparkplugInt32_D1,-         arSparkplugInt64    := SparkPlugBSimpleTypes.arSparkplugInt64_D1,.         arSparkplugUInt8    := SparkPlugBSimpleTypes.arSparkplugUInt8_D1,/         arSparkplugUInt16   := SparkPlugBSimpleTypes.arSparkplugUInt16_D1,0         arSparkplugUInt32   := SparkPlugBSimpleTypes.arSparkplugUInt32_D1,1         arSparkplugUInt64   := SparkPlugBSimpleTypes.arSparkplugUInt64_D1,2         arSparkplugUUID     := SparkPlugBSimpleTypes.arSparkplugUUID_D1,3         arSparkplugText     := SparkPlugBSimpleTypes.arSparkplugText_D1,4         arSparkplugString   := SparkPlugBSimpleTypes.arSparkplugString_D1,5f         ConnectionState     => EoNConnectionState,6d         NumberOfDevices     => NumberOfDevices );7ELSE8v    //The below method creates a Client Certificate for you9    //It generates a CSR and sends it to test.mosquitto.org to be signed:    AdditionalStepsToRegisterAClientCertificateWithtest_mosquitto_org();;IF Test THEN<$    Temp := EoN;  =     Temp := 0;  >TMyDevice1( Name                := "FT001",?r           Description         := "MyFlowTransmitter001",@N           ItfEoNInstance      := Temp,Ab           PluggedIntoEoN      => PluggedIntoEoN,Bd           DeviceState         => MyDevice1State, C           arSparkplugBoolean  := SparkPlugBSimpleTypes.arSparkplugBoolean_D1,D           arSparkplugDateTime := SparkPlugBSimpleTypes.arSparkplugDateTime_D1,E           arSparkplugFloat    := SparkPlugBSimpleTypes.arSparkplugFloat_D1,F           arSparkplugDouble   := SparkPlugBSimpleTypes.arSparkplugDouble_D1,G           arSparkplugInt8     := SparkPlugBSimpleTypes.arSparkplugInt8_D1,H           arSparkplugInt16    := SparkPlugBSimpleTypes.arSparkplugInt16_D1,I           arSparkplugInt32    := SparkPlugBSimpleTypes.arSparkplugInt32_D1,J           arSparkplugInt64    := SparkPlugBSimpleTypes.arSparkplugInt64_D1,K           arSparkplugUInt8    := SparkPlugBSimpleTypes.arSparkplugUInt8_D1,L           arSparkplugUInt16   := SparkPlugBSimpleTypes.arSparkplugUInt16_D1,M           arSparkplugUInt32   := SparkPlugBSimpleTypes.arSparkplugUInt32_D1,N           arSparkplugUInt64   := SparkPlugBSimpleTypes.arSparkplugUInt64_D1,O           arSparkplugUUID     := SparkPlugBSimpleTypes.arSparkplugUUID_D1,P           arSparkplugText     := SparkPlugBSimpleTypes.arSparkplugText_D1,Q           arSparkplugString   := SparkPlugBSimpleTypes.arSparkplugString_D1);RfDevice1MetricsCount := MyDevice1.NumberOfMetrics();SInterfaceTL{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}U.PROGRAM PRG_FB_EoN_NodeVVARWN    Init                : BOOL := TRUE;Xz    EoN                 : SparkplugB.FB_Edge_Of_Network_Node;Y~    EoNConnectionState  : SparkplugB.SparkplugSessionStateType;Z@    NumberOfDevices     : UDINT;[^    MyDevice1           : SparkplugB.FB_Device;\>    Device1MetricsCount : DINT;]J    TestScenario        : USINT := 1;^B    ServerUrl           : STRING;_>    ServerPort          : UINT;`>    KeepAlive           : UINT;av    CleanSession        : BOOL                    := FALSE;bp    Username            : WSTRING                 := "";cp    Password            : WSTRING                 := "";dv    UseTLS              : BOOL                    := FALSE;eļ    hCert               : SysTypes.RTS_IEC_HANDLE := SysTypes.RTS_INVALID_HANDLE; // Handle to the client certificate (optional) only used if UseTLS is TRUEf    GroupId             : WSTRING                 := "SparkplugBDevice";g    NodeName            : WSTRING                 := "EdgeOfNetworkNode1";h    DeviceName          : WSTRING                 := "EmulatedDevice";i°    publishPeriod       : UINT                    := 5000; // equals 5 seconds interval jŽ    //(scantime of this program = 250ms) so 20:1 (update rate = 20 scans to 1 publish)k>    GenerateDataPeriod  : TIME;l>    GenerateDataElapsed : TIME;m<    GenerateDateTimer   : TON;n`    Timestamp           : SparkplugB.T_DateTime;oR    Str                 : ChangingString;p    //These are specific for registering certificates at test.mqtt.orgq|    getClientCert                  : SparkplugB.GetClientCert;rt    RegisterCSR                    : Web_Client.WebClient;sR    countClientCert                : INT;tf    httpPost                       : WSTRING(2048);uT    StillGettingClientCertificate  : BOOL;vf    wsCSRorClientCertOut           : WSTRING(2048);wv    WaitForTheServerToRegisterCert : TON := ( PT := T#1S );x4    PluggedIntoEoN : BOOL;y`    MyDevice1State : SparkplugB.DeviceStateType;z     Test : BOOL;{^    Temp : SparkplugB.ISparkplugDeviceProtocol;|END_VAR}"UniqueIdGenerator~3704POULevelL{8e575c5b-1d37-49c6-941b-5c0ec7874787}Standard ChildObjectGuids8System.Collections.ArrayList,AddAttributeSubsequentboolÐÐ-ÐÐ	E
-JÐÐ
-ÚÐ-ÐÐ
.ÚÐ-ÐÐ
/ÚÐ-ÐÐ
0ÚÐ-ÐÐ
1ÚÐ-ÐÐ
2ÚÐ-ÐÐ
3ÚÐ-ÐÐ
4ÚÐ-ÐÐ
5ÚÐ-ÐÐ
6ÚÐ-ÐÐ
7ÚÐ-ÐÐ
8ÚÐ-ÐÐ
9ÚÐ-ÐÐ
:ÚÐ-ÐÐ
;ÚÐ-ÐÐ
<ÚÐ-ÐÐ
=ÚÐ-ÐÐ
>ÚÐ-ÐÐ
?ÚÐ- ÐÐ
@ÚÐ-!ÐÐ
AÚÐ-"ÐÐ
BÚÐ-#ÐÐ
CÚÐ-$ÐÐ
DÚÐ-%ÐÐ
EÚÐ-&ÐÐ
FÚÐ-'ÐÐ
GÚÐ-(ÐÐ
HÚÐ-)ÐÐ
IÚÐ-*ÐÐ
JÚÐ-+ÐÐ
KÚÐ-,ÐÐ
LÚÐ--ÐÐ
MÚÐ-.ÐÐ
NÚÐ-/ÐÐ
OÚÐ-0ÐÐ
PÚÐ-1ÐÐ
QÚÐ-2ÐÐ
RÚÐ-3ÐÐ
SÚÐ-4ÐÐ
TÚÐ-5ÐÐ
UÚÐ-6ÐÐ
VÚÐ-7ÐÐ
WÚÐ-8ÐÐ
XÚÐ-9ÐÐ
YÚÐ-:ÐÐ
ZÚÐ-ÐÐ
rÚÐ-ÐÐ
qÚÐ-;ÐÐ
sÚÐ-<ÐÐ
wÚÐ-7ÐÐ
xÚÐ-=ÐÐ
tÚÐ-ÐÐ
pÚÐ-ÐÐ
\ÚÐ->ÐÐ
]ÚÐ-?ÐÐ
^ÚÐ-@ÐÐ
_ÚÐ-AÐÐ
`ÚÐ-BÐÐ
aÚÐ-CÐÐ
bÚÐ-DÐÐ
cÚÐ-EÐÐ
dÚÐ-FÐÐ
eÚÐ-GÐÐ
fÚÐ-HÐÐ
gÚÐ-IÐÐ
hÚÐ-JÐÐ
iÚÐ-KÐÐ
jÚÐ-LÐÐ
kÚÐ-MÐÐ
lÚÐ-NÐÐ
mÚÐ-OÐÐ
nÚÐ-PÐÐ
oÚÐ-QÐÐ
ÚÐ-RÐSTÐ	E
-*ÐÐ
Z
-ÚÐ-UÐÐ
[
-ÚÐ-VÐÐ
\
-ÚÐ-WÐÐ
]
-ÚÐ-XÐÐ
^
-ÚÐ-YÐÐ
_
-ÚÐ-ZÐÐ
`
-ÚÐ-[ÐÐ
a
-ÚÐ-\ÐÐ
b
-ÚÐ-]ÐÐ
c
-ÚÐ-^ÐÐ
d
-ÚÐ-_ÐÐ
e
-ÚÐ-`ÐÐ
f
-ÚÐ-aÐÐ
g
-ÚÐ-bÐÐ
h
-ÚÐ-cÐÐ
i
-ÚÐ-dÐÐ
j
-ÚÐ-eÐÐ
k
-ÚÐ-fÐÐ
l
-ÚÐ-gÐÐ
m
-ÚÐ-hÐÐ
n
-ÚÐ-iÐÐ
o
-ÚÐ-jÐÐ
p
-ÚÐ-kÐÐ
q
-ÚÐ-lÐÐ
r
-ÚÐ-mÐÐ
s
-ÚÐ-nÐÐ
t
-ÚÐ-oÐÐ
u
-ÚÐ-ÐÐ
v
-ÚÐ-pÐÐ
w
-ÚÐ-qÐÐ
x
-ÚÐ-rÐÐ
y
-ÚÐ-sÐÐ
z
-ÚÐ-tÐÐ
{
-ÚÐ-uÐÐ
|
-ÚÐ-vÐÐ
}
-ÚÐ-wÐÐ
~
-ÚÐ-ÐÐ

-ÚÐ-xÐÐ

-ÚÐ-yÐÐ
uÚÐ-zÐÐ
vÚÐ-{ÐÐ
ÚÐ-|Ð}-~Ð-Ð
\ No newline at end of file
+Gx_lL<!0…jüo1\lr†ëhÜSystem.StringL{6f9dac99-8de1-4efc-8465-68ac443b7d08}SpecialFuncL{0db3d7bb-cde0-4416-9a7b-ce49a0124323}NoneImplementationL{3b83b776-fb25-43b8-99f2-3c507c9143fc}TextDocument	L{f3878285-8e4f-490b-bb1b-9acbb7eb04db}
+TextLinesL{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}Id
longTagTextScenario();bGenerateDateTimer( IN := NOT GenerateDateTimer.Q,X                   PT := GenerateDataPeriod,^                   ET => GenerateDataElapsed );6IF GenerateDateTimer.Q THEN,    GenerateEoNData();2    GenerateDeviceData();END_IFRIF NOT StillGettingClientCertificate THENT    EoN( ServerUrl           := ServerUrl,V         ServerPort          := ServerPort,T         KeepAlive           := KeepAlive,Z         CleanSession        := CleanSession,R         Username            := Username,R         Password            := Password, N         UseTLS              := UseTLS,!L         hCert               := hCert,"P         GroupId             := GroupId,#R         NodeName            := NodeName,$V         DeviceName          := DeviceName,%\         publishPeriod       := publishPeriod,&         arSparkplugBoolean  := SparkPlugBSimpleTypes.arSparkplugBoolean_EoN,'         arSparkplugDateTime := SparkPlugBSimpleTypes.arSparkplugDateTime_EoN,(         arSparkplugFloat    := SparkPlugBSimpleTypes.arSparkplugFloat_EoN,)         arSparkplugDouble   := SparkPlugBSimpleTypes.arSparkplugDouble_EoN,*         arSparkplugInt8     := SparkPlugBSimpleTypes.arSparkplugInt8_EoN,+         arSparkplugInt16    := SparkPlugBSimpleTypes.arSparkplugInt16_EoN,,         arSparkplugInt32    := SparkPlugBSimpleTypes.arSparkplugInt32_EoN,-         arSparkplugInt64    := SparkPlugBSimpleTypes.arSparkplugInt64_EoN,.         arSparkplugUInt8    := SparkPlugBSimpleTypes.arSparkplugUInt8_EoN,/         arSparkplugUInt16   := SparkPlugBSimpleTypes.arSparkplugUInt16_EoN,0         arSparkplugUInt32   := SparkPlugBSimpleTypes.arSparkplugUInt32_EoN,1         arSparkplugUInt64   := SparkPlugBSimpleTypes.arSparkplugUInt64_EoN,2         arSparkplugUUID     := SparkPlugBSimpleTypes.arSparkplugUUID_EoN,3         arSparkplugText     := SparkPlugBSimpleTypes.arSparkplugText_EoN,4         arSparkplugString   := SparkPlugBSimpleTypes.arSparkplugString_EoN,5f         ConnectionState     => EoNConnectionState,6d         NumberOfDevices     => NumberOfDevices );7ELSE8v    //The below method creates a Client Certificate for you9    //It generates a CSR and sends it to test.mosquitto.org to be signed:    AdditionalStepsToRegisterAClientCertificateWithtest_mosquitto_org();;IF PlugIt THEN<$    Temp := EoN;  =     Temp := 0;  >TMyDevice1( Name                := "FT001",?r           Description         := "MyFlowTransmitter001",@N           ItfEoNInstance      := Temp,Ab           PluggedIntoEoN      => PluggedIntoEoN,Bd           DeviceState         => MyDevice1State, C           arSparkplugBoolean  := SparkPlugBSimpleTypes.arSparkplugBoolean_D1,D           arSparkplugDateTime := SparkPlugBSimpleTypes.arSparkplugDateTime_D1,E           arSparkplugFloat    := SparkPlugBSimpleTypes.arSparkplugFloat_D1,F           arSparkplugDouble   := SparkPlugBSimpleTypes.arSparkplugDouble_D1,G           arSparkplugInt8     := SparkPlugBSimpleTypes.arSparkplugInt8_D1,H           arSparkplugInt16    := SparkPlugBSimpleTypes.arSparkplugInt16_D1,I           arSparkplugInt32    := SparkPlugBSimpleTypes.arSparkplugInt32_D1,J           arSparkplugInt64    := SparkPlugBSimpleTypes.arSparkplugInt64_D1,K           arSparkplugUInt8    := SparkPlugBSimpleTypes.arSparkplugUInt8_D1,L           arSparkplugUInt16   := SparkPlugBSimpleTypes.arSparkplugUInt16_D1,M           arSparkplugUInt32   := SparkPlugBSimpleTypes.arSparkplugUInt32_D1,N           arSparkplugUInt64   := SparkPlugBSimpleTypes.arSparkplugUInt64_D1,O           arSparkplugUUID     := SparkPlugBSimpleTypes.arSparkplugUUID_D1,P           arSparkplugText     := SparkPlugBSimpleTypes.arSparkplugText_D1,Q           arSparkplugString   := SparkPlugBSimpleTypes.arSparkplugString_D1);RfDevice1MetricsCount := MyDevice1.NumberOfMetrics();SInterfaceTL{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}U.PROGRAM PRG_FB_EoN_NodeVVARWN    Init                : BOOL := TRUE;Xz    EoN                 : SparkplugB.FB_Edge_Of_Network_Node;Y~    EoNConnectionState  : SparkplugB.SparkplugSessionStateType;Z@    NumberOfDevices     : UDINT;[^    MyDevice1           : SparkplugB.FB_Device;\>    Device1MetricsCount : DINT;]J    TestScenario        : USINT := 1;^B    ServerUrl           : STRING;_>    ServerPort          : UINT;`>    KeepAlive           : UINT;av    CleanSession        : BOOL                    := FALSE;bp    Username            : WSTRING                 := "";cp    Password            : WSTRING                 := "";dv    UseTLS              : BOOL                    := FALSE;eļ    hCert               : SysTypes.RTS_IEC_HANDLE := SysTypes.RTS_INVALID_HANDLE; // Handle to the client certificate (optional) only used if UseTLS is TRUEf    GroupId             : WSTRING                 := "SparkplugBDevice";g    NodeName            : WSTRING                 := "EdgeOfNetworkNode1";h    DeviceName          : WSTRING                 := "EmulatedDevice";i°    publishPeriod       : UINT                    := 5000; // equals 5 seconds interval jŽ    //(scantime of this program = 250ms) so 20:1 (update rate = 20 scans to 1 publish)k>    GenerateDataPeriod  : TIME;l>    GenerateDataElapsed : TIME;m<    GenerateDateTimer   : TON;n`    Timestamp           : SparkplugB.T_DateTime;oR    Str                 : ChangingString;p    //These are specific for registering certificates at test.mqtt.orgq|    getClientCert                  : SparkplugB.GetClientCert;rt    RegisterCSR                    : Web_Client.WebClient;sR    countClientCert                : INT;tf    httpPost                       : WSTRING(2048);uT    StillGettingClientCertificate  : BOOL;vf    wsCSRorClientCertOut           : WSTRING(2048);wv    WaitForTheServerToRegisterCert : TON := ( PT := T#1S );x4    PluggedIntoEoN : BOOL;y`    MyDevice1State : SparkplugB.DeviceStateType;z4    PlugIt : BOOL := TRUE;{^    Temp : SparkplugB.ISparkplugDeviceProtocol;|END_VAR}"UniqueIdGenerator~3817POULevelL{8e575c5b-1d37-49c6-941b-5c0ec7874787}Standard ChildObjectGuids8System.Collections.ArrayList,AddAttributeSubsequentboolÐÐ-ÐÐ	E
+IÐÐ
¢ÚÐ-ÐÐ
£ÚÐ-ÐÐ
¤ÚÐ-ÐÐ
¥ÚÐ-ÐÐ
¦ÚÐ-ÐÐ
§ÚÐ-ÐÐ
¨ÚÐ-ÐÐ
©ÚÐ-ÐÐ
ªÚÐ-ÐÐ
«ÚÐ-ÐÐ
¬ÚÐ-ÐÐ
ÚÐ-ÐÐ
®ÚÐ-ÐÐ
¯ÚÐ-ÐÐ
°ÚÐ-ÐÐ
±ÚÐ-ÐÐ
²ÚÐ-ÐÐ
³ÚÐ- ÐÐ
´ÚÐ-!ÐÐ
µÚÐ-"ÐÐ
¶ÚÐ-#ÐÐ
·ÚÐ-$ÐÐ
¸ÚÐ-%ÐÐ
¹ÚÐ-&ÐÐ
ºÚÐ-'ÐÐ
»ÚÐ-(ÐÐ
¼ÚÐ-)ÐÐ
½ÚÐ-*ÐÐ
¾ÚÐ-+ÐÐ
¿ÚÐ-,ÐÐ
ÀÚÐ--ÐÐ
ÁÚÐ-.ÐÐ
ÂÚÐ-/ÐÐ
ÃÚÐ-0ÐÐ
ÄÚÐ-1ÐÐ
ÅÚÐ-2ÐÐ
ÆÚÐ-3ÐÐ
ÇÚÐ-4ÐÐ
ÈÚÐ-5ÐÐ
ÉÚÐ-6ÐÐ
ÊÚÐ-7ÐÐ
ËÚÐ-8ÐÐ
ÌÚÐ-9ÐÐ
ÍÚÐ-:ÐÐ
ÎÚÐ-ÐÐ
ÏÚÐ-ÐÐ
ÐÚÐ-;ÐÐ
ÑÚÐ-<ÐÐ
ÒÚÐ-7ÐÐ
ÓÚÐ-=ÐÐ
ÔÚÐ-ÐÐ
ÕÚÐ-ÐÐ
ÖÚÐ->ÐÐ
×ÚÐ-?ÐÐ
ØÚÐ-@ÐÐ
ÙÚÐ-AÐÐ
ÚÚÐ-BÐÐ
ÛÚÐ-CÐÐ
ÜÚÐ-DÐÐ
ÝÚÐ-EÐÐ
ÞÚÐ-FÐÐ
ßÚÐ-GÐÐ
àÚÐ-HÐÐ
áÚÐ-IÐÐ
âÚÐ-JÐÐ
ãÚÐ-KÐÐ
äÚÐ-LÐÐ
åÚÐ-MÐÐ
æÚÐ-NÐÐ
çÚÐ-OÐÐ
èÚÐ-PÐÐ
éÚÐ-QÐÐ
ÚÐ-RÐSTÐ	E
+*ÐÐ
yÚÐ-UÐÐ
zÚÐ-VÐÐ
{ÚÐ-WÐÐ
|ÚÐ-XÐÐ
}ÚÐ-YÐÐ
~ÚÐ-ZÐÐ
ÚÐ-[ÐÐ
ÚÐ-\ÐÐ
ÚÐ-]ÐÐ
ÚÐ-^ÐÐ
ÚÐ-_ÐÐ
ÚÐ-`ÐÐ
ÚÐ-aÐÐ
ÚÐ-bÐÐ
ÚÐ-cÐÐ
ÚÐ-dÐÐ
ÚÐ-eÐÐ
ÚÐ-fÐÐ
ÚÐ-gÐÐ
ÚÐ-hÐÐ
ÚÐ-iÐÐ
ÚÐ-jÐÐ
ÚÐ-kÐÐ
ÚÐ-lÐÐ
ÚÐ-mÐÐ
ÚÐ-nÐÐ
ÚÐ-oÐÐ
ÚÐ-ÐÐ
ÚÐ-pÐÐ
ÚÐ-qÐÐ
ÚÐ-rÐÐ
ÚÐ-sÐÐ
ÚÐ-tÐÐ
ÚÐ-uÐÐ
ÚÐ-vÐÐ
ÚÐ-wÐÐ
ÚÐ-ÐÐ
ÚÐ-xÐÐ
ÚÐ-yÐÐ
 ÚÐ-zÐÐ
¡ÚÐ-{ÐÐ
ÚÐ-|Ð}-~Ð-Ð
\ No newline at end of file