[91f2a2]: / project / sparkplug™_mqtt_edge_and_host-stack_b9741afd / function_blocks_8ad6e219 / fb_primaryhost_ec6863e3 / fb_primaryhostmessageconsumer_0bdfb382 / 0bdfb382e83f44ce8b28d26c6658b28d.object Maximize Restore History
1 lines (1 with data), 28.9 kB
1 | {"payload":{"meta":{"Graph":{"@Type":"81297157","@Value":{"Guid":"(Guid)0bdfb382-e83f-44ce-8b28-d26c6658b28d","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)861","Tag":null,"Text":"(string)_RecvMesg REF= pMQTT^.GetSubscriberMessage(MessageTopic => _RecvTopic);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)862","Tag":null,"Text":"(string)_TopicParser(pTopic := ADR(_RecvTopic)); //parses the topic"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)863","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)864","Tag":null,"Text":"(string)CASE _TopicParser.MessageType OF //SparkplugMessageTypes"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)865","Tag":null,"Text":"(string) SparkplugMessageTypes.NBIRTH: //Birth certificate for MQTT EoN nodes."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)866","Tag":null,"Text":"(string) _MyEdge REF= pPrimaryHost^.GetEdge(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)867","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)868","Tag":null,"Text":"(string) eError => _HandledError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)869","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)870","Tag":null,"Text":"(string) CASE _HandledError OF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)871","Tag":null,"Text":"(string) ERROR.GroupIDNotFound: // ==> DETECTED NEW GROUP!"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)872","Tag":null,"Text":"(string) _MyGroupId REF= pPrimaryHost^.allocGroupId(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)873","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)874","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)875","Tag":null,"Text":"(string) IF eError = ERROR.NO_ERROR THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)876","Tag":null,"Text":"(string) _MyEdge REF= pPrimaryHost^.allocEdgetoGroupId(EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)877","Tag":null,"Text":"(string) itfGroupID := _MyGroupId.itfGroupID,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)878","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)879","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)880","Tag":null,"Text":"(string) IF eError = ERROR.NO_ERROR THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)881","Tag":null,"Text":"(string) _MyEdge.ProcessNBIRTH(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)882","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)883","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)884","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)885","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)886","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)887","Tag":null,"Text":"(string) //eError := eError;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)888","Tag":null,"Text":"(string) END_IF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)889","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)890","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)891","Tag":null,"Text":"(string) //eError := eError;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)892","Tag":null,"Text":"(string) END_IF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)893","Tag":null,"Text":"(string) ERROR.EdgeIDNotFound: // ==> DETECTED NEW EDGE!"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)894","Tag":null,"Text":"(string) _MyGroupId REF= pPrimaryHost^.GetGroupID(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)895","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)896","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)897","Tag":null,"Text":"(string) IF eError = ERROR.NO_ERROR THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)898","Tag":null,"Text":"(string) _MyEdge REF= pPrimaryHost^.allocEdgetoGroupId(EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)899","Tag":null,"Text":"(string) itfGroupID := _MyGroupId.itfGroupID,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)900","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)901","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)902","Tag":null,"Text":"(string) IF eError = ERROR.NO_ERROR THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)903","Tag":null,"Text":"(string) _MyEdge.ProcessNBIRTH(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)904","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)905","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)906","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)907","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)908","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)909","Tag":null,"Text":"(string) //eError := eError;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)910","Tag":null,"Text":"(string) END_IF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)911","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)912","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)913","Tag":null,"Text":"(string) //eError := eError;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)914","Tag":null,"Text":"(string) END_IF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)915","Tag":null,"Text":"(string) ERROR.NO_ERROR: // ==> UPDATE EXISTING EDGE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)916","Tag":null,"Text":"(string) _MyEdge.ProcessNBIRTH(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)917","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)918","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)919","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)920","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)921","Tag":null,"Text":"(string) ; //{info 'TODO: maybe some sort of error??'}"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)922","Tag":null,"Text":"(string) END_CASE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)923","Tag":null,"Text":"(string) SparkplugMessageTypes.NDATA: //Node data message."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)924","Tag":null,"Text":"(string) _MyEdge REF= pPrimaryHost^.GetEdge(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)925","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)926","Tag":null,"Text":"(string) eError => _HandledError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)927","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)928","Tag":null,"Text":"(string) CASE _HandledError OF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)929","Tag":null,"Text":"(string) ERROR.NO_ERROR: // ==> UPDATE EXISTING EDGE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)930","Tag":null,"Text":"(string) _MyEdge.ProcessNDATA(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)931","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)932","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)933","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)934","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)935","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)936","Tag":null,"Text":"(string) eError := Error.EdgeIDNotFound;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)937","Tag":null,"Text":"(string) WriteStackLog(gc_sparkplug.CMP_HOST,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)938","Tag":null,"Text":"(string) CmpLog.LogClass.LOG_WARNING,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)939","Tag":null,"Text":"(string) 'PrimaryHost process NDATA metric error: %s',"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)940","Tag":null,"Text":"(string) TO_STRING(_HandledError));"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)941","Tag":null,"Text":"(string) END_CASE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)942","Tag":null,"Text":"(string) SparkplugMessageTypes.NDEATH: //Death certificate for MQTT EoN nodes."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)943","Tag":null,"Text":"(string) _MyEdge REF= pPrimaryHost^.GetEdge(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)944","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)945","Tag":null,"Text":"(string) eError => _HandledError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)946","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)947","Tag":null,"Text":"(string) CASE _HandledError OF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)948","Tag":null,"Text":"(string) ERROR.NO_ERROR: // ==> UPDATE EXISTING EDGE "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)949","Tag":null,"Text":"(string) _MyEdge.ProcessNDEATH();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)950","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)951","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)952","Tag":null,"Text":"(string) eError := Error.OhMy_ThatShouldNotHaveHappened;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)953","Tag":null,"Text":"(string) WriteStackLog(gc_sparkplug.CMP_HOST,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)954","Tag":null,"Text":"(string) CmpLog.LogClass.LOG_ERROR,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)955","Tag":null,"Text":"(string) 'PrimaryHost process NDEATH metric error: %s',"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)956","Tag":null,"Text":"(string) TO_STRING(_HandledError));"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)957","Tag":null,"Text":"(string) END_CASE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)958","Tag":null,"Text":"(string) SparkplugMessageTypes.DBIRTH: //Birth certificate forDevices."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)959","Tag":null,"Text":"(string) //TODO: Check if edge is online (isQualityOK). If not OK, DO NOT process the DBIRTH, instead just send a NCMD/Rebirth"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)960","Tag":null,"Text":"(string) _MyDevice REF= pPrimaryHost^.GetDevice(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)961","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)962","Tag":null,"Text":"(string) DeviceId := _TopicParser.DeviceId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)963","Tag":null,"Text":"(string) eError => _HandledError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)964","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)965","Tag":null,"Text":"(string) CASE _HandledError OF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)966","Tag":null,"Text":"(string) ERROR.GroupIDNotFound: // ==> DETECTED NEW GROUP! must rebirth the edge"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)967","Tag":null,"Text":"(string) eError := ERROR.NotImplemented;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)968","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)969","Tag":null,"Text":"(string) WriteStackLog(gc_sparkplug.CMP_HOST,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)970","Tag":null,"Text":"(string) CmpLog.LogClass.LOG_WARNING,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)971","Tag":null,"Text":"(string) 'DBIRTH Received with no existing groupID, but haven$'t implemented NCMD Rebirth yet %s',"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)972","Tag":null,"Text":"(string) '');"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)973","Tag":null,"Text":"(string) ERROR.EdgeIDNotFound: // ==> DETECTED NEW EDGE! must rebirth the edge"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)974","Tag":null,"Text":"(string) eError := ERROR.NotImplemented;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)975","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)976","Tag":null,"Text":"(string) WriteStackLog(gc_sparkplug.CMP_HOST,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)977","Tag":null,"Text":"(string) CmpLog.LogClass.LOG_WARNING,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)978","Tag":null,"Text":"(string) 'DBIRTH Received with no existing edge, but haven$'t implemented NCMD Rebirth yet %s',"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)979","Tag":null,"Text":"(string) '');"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)980","Tag":null,"Text":"(string) ERROR.DeviceIDNotFound: // ==> DETECTED NEW DEVICE!"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)981","Tag":null,"Text":"(string) _MyEdge REF= pPrimaryHost^.GetEdge(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)982","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)983","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)984","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)985","Tag":null,"Text":"(string) IF eError = ERROR.NO_ERROR THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)986","Tag":null,"Text":"(string) _MyDevice REF= pPrimaryHost^.allocDevicetoEdge(DeviceName := _TopicParser.DeviceId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)987","Tag":null,"Text":"(string) itfEdge := _MyEdge.itfRemoteEoN,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)988","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)989","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)990","Tag":null,"Text":"(string) IF eError = ERROR.NO_ERROR THEN"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)991","Tag":null,"Text":"(string) _MyDevice.ProcessDBIRTH(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)992","Tag":null,"Text":"(string) NodeName := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)993","Tag":null,"Text":"(string) GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)994","Tag":null,"Text":"(string) DeviceName := _TopicParser.DeviceId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)995","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)996","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)997","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)998","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)999","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1000","Tag":null,"Text":"(string) //eError := eError;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1001","Tag":null,"Text":"(string) END_IF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1002","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1003","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1004","Tag":null,"Text":"(string) //eError := eError;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1005","Tag":null,"Text":"(string) END_IF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1006","Tag":null,"Text":"(string) ERROR.NO_ERROR: // ==> UPDATE EXISTING DEVICE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1007","Tag":null,"Text":"(string) _MyDevice.ProcessDBIRTH(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1008","Tag":null,"Text":"(string) NodeName := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1009","Tag":null,"Text":"(string) GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1010","Tag":null,"Text":"(string) DeviceName := _TopicParser.DeviceId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1011","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1012","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1013","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1014","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1015","Tag":null,"Text":"(string) ; //{info 'TODO: maybe some sort of error??'}"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1016","Tag":null,"Text":"(string) END_CASE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1017","Tag":null,"Text":"(string) SparkplugMessageTypes.DDEATH: //Death certificate for Devices."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1018","Tag":null,"Text":"(string) _MyDevice REF= pPrimaryHost^.GetDevice(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1019","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1020","Tag":null,"Text":"(string) DeviceId := _TopicParser.DeviceId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1021","Tag":null,"Text":"(string) eError => _HandledError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1022","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1023","Tag":null,"Text":"(string) CASE _HandledError OF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1024","Tag":null,"Text":"(string) ERROR.NO_ERROR: // ==> UPDATE EXISTING EDGE "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1025","Tag":null,"Text":"(string) _MyDevice.ProcessDDEATH();"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1026","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1027","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1028","Tag":null,"Text":"(string) eError := Error.OhMy_ThatShouldNotHaveHappened;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1029","Tag":null,"Text":"(string) WriteStackLog(gc_sparkplug.CMP_HOST,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1030","Tag":null,"Text":"(string) CmpLog.LogClass.LOG_ERROR,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1031","Tag":null,"Text":"(string) 'PrimaryHost process DDEATH metric error: %s',"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1032","Tag":null,"Text":"(string) TO_STRING(_HandledError));"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1033","Tag":null,"Text":"(string) END_CASE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1034","Tag":null,"Text":"(string) SparkplugMessageTypes.DDATA: // Device data message. "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1035","Tag":null,"Text":"(string) _MyDevice REF= pPrimaryHost^.GetDevice(GroupId := _TopicParser.GroupId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1036","Tag":null,"Text":"(string) EdgeId := _TopicParser.EdgeId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1037","Tag":null,"Text":"(string) DeviceId := _TopicParser.DeviceId,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1038","Tag":null,"Text":"(string) eError => _HandledError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1039","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1040","Tag":null,"Text":"(string) CASE _HandledError OF"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1041","Tag":null,"Text":"(string) ERROR.NO_ERROR: // ==> UPDATE EXISTING EDGE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1042","Tag":null,"Text":"(string) _MyDevice.ProcessDDATA(itfPrimaryHost := pPrimaryHost^,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1043","Tag":null,"Text":"(string) pMessage := _RecvMesg,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1044","Tag":null,"Text":"(string) xError => xError,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1045","Tag":null,"Text":"(string) eError => eError);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1046","Tag":null,"Text":"(string) ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1047","Tag":null,"Text":"(string) xError := TRUE;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1048","Tag":null,"Text":"(string) eError := Error.DeviceIDNotFound;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1049","Tag":null,"Text":"(string) WriteStackLog(gc_sparkplug.CMP_HOST,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1050","Tag":null,"Text":"(string) CmpLog.LogClass.LOG_ERROR,"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1051","Tag":null,"Text":"(string) 'PrimaryHost process DDATA metric error: %s',"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1052","Tag":null,"Text":"(string) TO_STRING(_HandledError));"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1053","Tag":null,"Text":"(string) END_CASE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1054","Tag":null,"Text":"(string) SparkplugMessageTypes.NCMD, //Node command message."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1055","Tag":null,"Text":"(string) SparkplugMessageTypes.DCMD, //Device command message."}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1056","Tag":null,"Text":"(string) SparkplugMessageTypes.STATE: //Critical application state message"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1057","Tag":null,"Text":"(string) ; //do nothing, ignore these"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1058","Tag":null,"Text":"(string)ELSE"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1059","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)841","Tag":null,"Text":"(string)FUNCTION_BLOCK FB_PrimaryHostMessageConsumer"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)842","Tag":null,"Text":"(string)VAR_INPUT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)843","Tag":null,"Text":"(string) pPrimaryHost : POINTER TO FB_PrimaryHost;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)844","Tag":null,"Text":"(string) pMQTT : POINTER TO FB_PrimaryHostMQTT;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)845","Tag":null,"Text":"(string)END_VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)846","Tag":null,"Text":"(string)VAR_OUTPUT"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)847","Tag":null,"Text":"(string) xError : BOOL;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)848","Tag":null,"Text":"(string) eError : ERROR;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)849","Tag":null,"Text":"(string)END_VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)850","Tag":null,"Text":"(string)VAR"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)851","Tag":null,"Text":"(string) //_itfPrimaryHost : IPrimaryHost;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)852","Tag":null,"Text":"(string)"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)853","Tag":null,"Text":"(string) _MQTT_eError : MQTT.MQTT_ERROR;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)854","Tag":null,"Text":"(string) _RecvMesg : REFERENCE TO FB_PayloadSimpleDecoder;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)855","Tag":null,"Text":"(string) _RecvTopic : WSTRING(GC_Sparkplug.supported_string_lengths);"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)856","Tag":null,"Text":"(string) _HandledError : ERROR; // an error that will be given back by a function, but we can handle the error. "}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)857","Tag":null,"Text":"(string) _MyGroupId : REFERENCE TO FB_GroupId;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)858","Tag":null,"Text":"(string) _MyEdge : REFERENCE TO FB_RemoteEdge;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)859","Tag":null,"Text":"(string) _MyDevice : REFERENCE TO FB_RemoteDevice;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)860","Tag":null,"Text":"(string) _TopicParser : FB_TopicParser;"}},{"@Type":"a5de0b0b","@Value":{"Id":"(long)1","Tag":null,"Text":"(string)END_VAR"}}]}}}}},"UniqueIdGenerator":"(string)1059","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"} |