co⚡e: Sparkplug™ MQTT edge

{"payload":{"meta":{"Graph":{"@Type":"81297157","@Value":{"Guid":"(Guid)8d253849-9444-46e9-a209-6dd9b8052de4","ParentGuid":"(Guid)af25efb2-e7d3-4d17-9b46-1d6d5c77fe77","Name":"(string)PublishDeviceMessagesContinous","Properties":{"@Type":"2c41fa04:IDictionary","@Value":[{"@Key":"(Guid)829a18f2-c514-4f6e-9634-1df173429203","@Value":{"@Type":"829a18f2","@Value":{"ParentObjects":{"@Type":"fa2ee218:IDictionary","@Value":[{"@Key":"(Guid)21af5390-2942-461a-bf89-951aaf6999f1","@Value":"(Guid)4e702dba-b0a2-4aa4-9db8-7302ca943bf8"}]}}}}]},"TypeGuid":"(Guid)f8a58466-d7f6-439f-bbb8-d4600e41d099","EmbeddedTypeGuids":{"@Type":"[Guid]","@Value":["(Guid)a9ed5b7e-75c5-4651-af16-d2c27e98cb94","(Guid)3b83b776-fb25-43b8-99f2-3c507c9143fc"]}}},"TypeInfos":{"2c41fa04":"{2c41fa04-1834-41c1-816e-303c7aa2c05b}","81297157":"{81297157-7ec9-45ce-845e-84cab2b88ade}","829a18f2":"{829a18f2-c514-4f6e-9634-1df173429203}","fa2ee218":"{fa2ee218-a39b-4b6d-b249-49dbddbd168a}","Guid":"System.Guid","string":"System.String"}},"object":{"Graph":{"@Type":"f8a58466","@Value":{"Implementation":{"@Type":"3b83b776","@Value":{"TextDocument":{"@Type":"f3878285","@Value":{"TextLines":{"@Type":"[a5de0b0b]","@Value":[{"@Type":"a5de0b0b","@Value":{"Id":"(long)303","Tag":null,"Text":"(string)// pEdge^.readyForPublish()"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)304","Tag":null,"Text":"(string)// pEdge^.getMessage()"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)305","Tag":null,"Text":"(string)// return pEdge^.PublisherDone with _MQTT.PublisherDone();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)306","Tag":null,"Text":"(string)IF THIS^.readyForPublish() THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)307","Tag":null,"Text":"(string)    THIS^.getMessage( pSparkplugB => _pSparkplugBfromDeviceX,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)308","Tag":null,"Text":"(string)                      pPayload =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)309","Tag":null,"Text":"(string)                      pTopic => _pTopicfromDeviceX,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)310","Tag":null,"Text":"(string)                      timeout => );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)311","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)312","Tag":null,"Text":"(string)    _pSparkplugBfromDeviceX^.SetSeq( THIS^._SparkplugB.GetSeqNum() );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)313","Tag":null,"Text":"(string)    _pSparkplugBfromDeviceX^.Encode( Enable := TRUE );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)314","Tag":null,"Text":"(string)    REPEAT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)315","Tag":null,"Text":"(string)        _pSparkplugBfromDeviceX^();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)316","Tag":null,"Text":"(string)        EncodeError := _pSparkplugBfromDeviceX^.EncodeError( eError => Encode_eError );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)317","Tag":null,"Text":"(string)        _EncodeDone := _pSparkplugBfromDeviceX^.Encoded();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)318","Tag":null,"Text":"(string)    UNTIL"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)319","Tag":null,"Text":"(string)        _EncodeDone OR EncodeError"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)320","Tag":null,"Text":"(string)    END_REPEAT;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)321","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)322","Tag":null,"Text":"(string)    _pSparkplugBfromDeviceX^.Encode( Enable := FALSE );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)323","Tag":null,"Text":"(string)    _pSparkplugBfromDeviceX^.GetEncodedBlob( Blob := _BlobfromDeviceX,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)324","Tag":null,"Text":"(string)                                             BlobSize := _BlobSizefromDeviceX );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)325","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)326","Tag":null,"Text":"(string)    _MQTT.EnablePublisher();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)327","Tag":null,"Text":"(string)    REPEAT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)328","Tag":null,"Text":"(string)        THIS^._MQTT.publish( Topic := _pTopicfromDeviceX^, // we need the topic, not the pointer ;-)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)329","Tag":null,"Text":"(string)                             pbMessage := ADR( _BlobfromDeviceX ),"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)344","Tag":null,"Text":"(string)                             MessageSize :=  _BlobSizefromDeviceX ,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)330","Tag":null,"Text":"(string)                             Qos := MQTT.MQTT_QOS.QoS0,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)331","Tag":null,"Text":"(string)                             Retained := FALSE );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)332","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)333","Tag":null,"Text":"(string)        THIS^._MQTT();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)334","Tag":null,"Text":"(string)    UNTIL"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)335","Tag":null,"Text":"(string)        _MQTT.PublisherDone() OR _MQTT.PublisherError()"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)336","Tag":null,"Text":"(string)    END_REPEAT;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)337","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)338","Tag":null,"Text":"(string)    _MQTT.DisablePublisher();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)339","Tag":null,"Text":"(string)    publishError := _MQTT.PublisherError( eError => Publish_eError );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)340","Tag":null,"Text":"(string)    _PublishDone := _MQTT.PublisherDone(); // Prevents invoking method twice"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)341","Tag":null,"Text":"(string)    THIS^.PublisherDone := _PublishDone;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)342","Tag":null,"Text":"(string)    PublishDeviceMessagesContinous := _PublishDone;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)63","Tag":null,"Text":"(string)END_IF"}}]}}}}},"Interface":{"@Type":"a9ed5b7e","@Value":{"TextDocument":{"@Type":"f3878285","@Value":{"TextLines":{"@Type":"[a5de0b0b]","@Value":[{"@Type":"a5de0b0b","@Value":{"Id":"(long)205","Tag":null,"Text":"(string)// Returns TRUE when Done"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)206","Tag":null,"Text":"(string){attribute 'hide'}"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)207","Tag":null,"Text":"(string)METHOD PublishDeviceMessagesContinous : BOOL"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)208","Tag":null,"Text":"(string)VAR_OUTPUT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)209","Tag":null,"Text":"(string)    EncodeError : BOOL := FALSE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)210","Tag":null,"Text":"(string)    Encode_eError : SPStack.ERROR;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)211","Tag":null,"Text":"(string)    PublishError : BOOL := FALSE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)212","Tag":null,"Text":"(string)    Publish_eError : MQTT.MQTT_ERROR;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)213","Tag":null,"Text":"(string)END_VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)214","Tag":null,"Text":"(string)VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)215","Tag":null,"Text":"(string)    _EncodeDone : BOOL;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)216","Tag":null,"Text":"(string)    _PublishDone : BOOL;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)217","Tag":null,"Text":"(string)    _BlobfromDeviceX : ARRAY[0..MQTT.MQTTParam.g_udiMaxPayloadSize] OF BYTE; // buffer for encoded messages"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)218","Tag":null,"Text":"(string)    _BlobSizefromDeviceX : UDINT; // current encoded message size    "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)219","Tag":null,"Text":"(string)    _pSparkplugBfromDeviceX : POINTER TO SPStack.FB_SparkplugBSimple; // pointer to the SparkplugBSimple instance from a Device X"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)220","Tag":null,"Text":"(string)    _pTopicfromDeviceX : POINTER TO WSTRING(SPStack.GC_sparkplug.supported_string_lengths); // resembles the topic under which the message is posted"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)221","Tag":null,"Text":"(string)END_VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1","Tag":null,"Text":"(string)"}}]}}}}}}},"TypeInfos":{"3b83b776":"{3b83b776-fb25-43b8-99f2-3c507c9143fc}","a5de0b0b":"{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}","a9ed5b7e":"{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}","f3878285":"{f3878285-8e4f-490b-bb1b-9acbb7eb04db}","f8a58466":"{f8a58466-d7f6-439f-bbb8-d4600e41d099}","long":"System.Int64","string":"System.String"}}},"FormatVersion":"1.0"}