co⚡e: Sparkplug™ MQTT edge

{"payload":{"meta":{"Graph":{"@Type":"81297157","@Value":{"Guid":"(Guid)070fbc41-83aa-457a-b520-a064079b516d","ParentGuid":"(Guid)00000000-0000-0000-0000-000000000000","Name":"(string)FB_PrimaryHostMessageConsumer","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)ec6863e3-35a1-4237-b54f-4c4d98ebfb4e"}]}}}}]},"TypeGuid":"(Guid)6f9dac99-8de1-4efc-8465-68ac443b7d08","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":"6f9dac99","@Value":{"SpecialFunc":{"@Type":"0db3d7bb:Enum","@Value":"None"},"Implementation":{"@Type":"3b83b776","@Value":{"TextDocument":{"@Type":"f3878285","@Value":{"TextLines":{"@Type":"[a5de0b0b]","@Value":[{"@Type":"a5de0b0b","@Value":{"Id":"(long)1926","Tag":null,"Text":"(string)_RecvMesg REF= pMQTT^.GetSubscriberMessage( MessageTopic => _RecvTopic );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1927","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1928","Tag":null,"Text":"(string)//parses the topic"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1929","Tag":null,"Text":"(string)_TopicParser( pTopic := ADR( _RecvTopic ) );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1930","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1931","Tag":null,"Text":"(string)// log the topic in debug level"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1932","Tag":null,"Text":"(string)WriteHostLog( CmpLog.LogClass.LOG_DEBUG, 'Incoming message in topic: %s', TO_STRING( _RecvTopic ) );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1933","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1934","Tag":null,"Text":"(string)// Insert RemoteEdgeSeqChecker here"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2027","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2028","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2026","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1935","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1936","Tag":null,"Text":"(string)CASE _TopicParser.MessageType OF //SparkplugMessageTypes"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1937","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1938","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.NBIRTH: //Birth certificate for MQTT EoN nodes."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1939","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1940","Tag":null,"Text":"(string)        ConsumeNBIRTHMessage( pPrimaryHost := pPrimaryHost,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1941","Tag":null,"Text":"(string)                              GetEdgeError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1942","Tag":null,"Text":"(string)                              allocGroupIdError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1943","Tag":null,"Text":"(string)                              allocEdgetoGroupIdError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1944","Tag":null,"Text":"(string)                              ProcessNBIRTHerror =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1945","Tag":null,"Text":"(string)                              xProcessNBIRTHError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1946","Tag":null,"Text":"(string)                              GetGroupIDerror => );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1947","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1948","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.NDATA: //Node data message."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1949","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1950","Tag":null,"Text":"(string)        ConsumeNDATAMessage( pPrimaryHost := pPrimaryHost,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1951","Tag":null,"Text":"(string)                             GetEdgeError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1952","Tag":null,"Text":"(string)                             ProcessNDATAError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1953","Tag":null,"Text":"(string)                             xProcessNDATAError => );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1954","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1955","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.NDEATH: //Death certificate for MQTT EoN nodes."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1956","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1957","Tag":null,"Text":"(string)        ConsumeNDEATHMessage( pPrimaryHost := pPrimaryHost,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1958","Tag":null,"Text":"(string)                              GetEdgeError => );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1959","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1960","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.DBIRTH: //Birth certificate forDevices."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1961","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1962","Tag":null,"Text":"(string)        ConsumeDBIRTHMessage( pPrimaryHost := pPrimaryHost,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1963","Tag":null,"Text":"(string)                              GetDeviceError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1964","Tag":null,"Text":"(string)                              GetEdgeError =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1965","Tag":null,"Text":"(string)                              allocDevicetoEdge =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1966","Tag":null,"Text":"(string)                              ProcessDBIRTHerror =>,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1967","Tag":null,"Text":"(string)                              xProcessDBIRTHError => );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1968","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1969","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.DDEATH: //Death certificate for Devices."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1970","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1971","Tag":null,"Text":"(string)        ConsumeDDEATHMessage( pPrimaryHost := pPrimaryHost,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2002","Tag":null,"Text":"(string)                              GetDeviceError =>, "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2003","Tag":null,"Text":"(string)                              xGetDeviceError => );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1972","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1973","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.DDATA: // Device data message. "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1974","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1992","Tag":null,"Text":"(string)         ConsumeDDATAMessage( pPrimaryHost := pPrimaryHost,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2021","Tag":null,"Text":"(string)                              GetDeviceError=> , "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2022","Tag":null,"Text":"(string)                              ProcessDDATAError=> , "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2023","Tag":null,"Text":"(string)                              xProcessDDATAError=> );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1993","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1994","Tag":null,"Text":"(string)    SPStack.SparkplugMessageTypes.NCMD, //Node command message."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1996","Tag":null,"Text":"(string)        SPStack.SparkplugMessageTypes.DCMD, //Device command message."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1997","Tag":null,"Text":"(string)            SPStack.SparkplugMessageTypes.STATE: //Critical application state message"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1998","Tag":null,"Text":"(string)            ; //do nothing, ignore these"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1999","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2000","Tag":null,"Text":"(string)ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2001","Tag":null,"Text":"(string)    ; //{info 'TODO: maybe some sort of error??'}"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)209","Tag":null,"Text":"(string)END_CASE"}}]}}}}},"Interface":{"@Type":"a9ed5b7e","@Value":{"TextDocument":{"@Type":"f3878285","@Value":{"TextLines":{"@Type":"[a5de0b0b]","@Value":[{"@Type":"a5de0b0b","@Value":{"Id":"(long)1211","Tag":null,"Text":"(string)FUNCTION_BLOCK FB_PrimaryHostMessageConsumer"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1212","Tag":null,"Text":"(string)VAR_INPUT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1213","Tag":null,"Text":"(string)    pPrimaryHost : POINTER TO FB_PrimaryHost;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1214","Tag":null,"Text":"(string)    pMQTT : POINTER TO FB_PrimaryHostMQTT;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1215","Tag":null,"Text":"(string)END_VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1216","Tag":null,"Text":"(string)VAR_OUTPUT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1217","Tag":null,"Text":"(string)    xError : BOOL;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1218","Tag":null,"Text":"(string)    eError : SPStack.ERROR;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1219","Tag":null,"Text":"(string)END_VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1220","Tag":null,"Text":"(string)VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1230","Tag":null,"Text":"(string)    _TopicParser : FB_TopicParser;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2025","Tag":null,"Text":"(string)    _RecvMesg : REFERENCE TO SPStack.FB_Payload;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)2024","Tag":null,"Text":"(string)    _RecvTopic : WSTRING( SPStack.GC_Sparkplug.supported_string_lengths );"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1","Tag":null,"Text":"(string)END_VAR"}}]}}}}},"UniqueIdGenerator":"(string)2028","POULevel":{"@Type":"8e575c5b:Enum","@Value":"Standard"},"ChildObjectGuids":{"@Type":"ArrayList:IList","@Value":[]},"AddAttributeSubsequent":"(bool)False"}},"TypeInfos":{"0db3d7bb":"{0db3d7bb-cde0-4416-9a7b-ce49a0124323}","3b83b776":"{3b83b776-fb25-43b8-99f2-3c507c9143fc}","6f9dac99":"{6f9dac99-8de1-4efc-8465-68ac443b7d08}","8e575c5b":"{8e575c5b-1d37-49c6-941b-5c0ec7874787}","a5de0b0b":"{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}","a9ed5b7e":"{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}","ArrayList":"System.Collections.ArrayList","bool":"System.Boolean","f3878285":"{f3878285-8e4f-490b-bb1b-9acbb7eb04db}","long":"System.Int64","string":"System.String"}}},"FormatVersion":"1.0"}