<root>
<document scada='0' projtype='1' schema='103' license='1,79829088,Q2XNNM' title='New Embedded Project' description='' fcversion='720898' target='ESP.ESP32.ESP32_WROOM_32' >
	<config data='' clkspd='240000000' simspd='0' usewdt='0' constif='0' Use3V3='0' />
	<plugins >
		<dll_models enabled='1' />
	</plugins>
	<supplement use='1' head='#undef A
#undef B
#include &quot;mosq_broker.h&quot;
#include &quot;mqtt_client.h&quot;
#define A 0
#define B 32

esp_mqtt_client_handle_t local_client = NULL;

static void local_mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data);


typedef struct {
    char topic[64];
    char data[128];
} mqtt_msg_t;

QueueHandle_t mqtt_queue;' body='static void local_mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) {
    esp_mqtt_event_handle_t event = event_data;

    switch ((esp_mqtt_event_id_t)event_id) {
        case MQTT_EVENT_CONNECTED:
            ESP_LOGI(&quot;CLIENT&quot;, &quot;Connected to local broker! Subscribing to all topics...&quot;);
            // Subscribe to the global wildcard to see everything
            esp_mqtt_client_subscribe(local_client, &quot;#&quot;, 0);
            break;

        case MQTT_EVENT_DATA: {
            // Extract the Topic
            mqtt_msg_t msg;
            snprintf(msg.topic, sizeof(msg.topic), &quot;%.*s&quot;, event-&gt;topic_len, event-&gt;topic);
            // Extract the Payload
            snprintf(msg.data, sizeof(msg.data), &quot;%.*s&quot;, event-&gt;data_len, event-&gt;data);

            xQueueSend(mqtt_queue, &amp;msg, pdMS_TO_TICKS(100));
            break;
        }
        
        case MQTT_EVENT_ERROR:
            ESP_LOGE(&quot;CLIENT&quot;, &quot;MQTT Error occurred&quot;);
            break;
            
        default:
            break;
    }
}' />
	<debug />
	<traces />
	<ghost >
		<FK2 >
			<data name='FK2D0' port='4294967295' pin='4294967295' />
			<data name='FK2D1' port='4294967295' pin='4294967295' />
			<data name='FK2D2' port='4294967295' pin='4294967295' />
			<data name='FK2D3' port='4294967295' pin='4294967295' />
			<data name='FK2D4' port='4294967295' pin='4294967295' />
			<data name='FK2D5' port='4294967295' pin='4294967295' />
			<data name='FK2D6' port='4294967295' pin='4294967295' />
			<data name='FK2D7' port='4294967295' pin='4294967295' />
			<data name='FK2D8' port='4294967295' pin='4294967295' />
			<data name='FK2D9' port='4294967295' pin='4294967295' />
			<data name='FK2D10' port='4294967295' pin='4294967295' />
			<data name='FK2D11' port='4294967295' pin='4294967295' />
			<data name='FK2D12' port='4294967295' pin='4294967295' />
			<data name='FK2D13' port='4294967295' pin='4294967295' />
			<data name='FK2D14' port='4294967295' pin='4294967295' />
			<data name='FK2D15' port='4294967295' pin='4294967295' />
			<data name='FK2A0' port='4294967295' pin='4294967295' />
			<data name='FK2A1' port='4294967295' pin='4294967295' />
			<data name='FK2A2' port='4294967295' pin='4294967295' />
			<data name='FK2A3' port='4294967295' pin='4294967295' />
			<data name='FK2A4' port='4294967295' pin='4294967295' />
			<data name='FK2A5' port='4294967295' pin='4294967295' />
		</FK2>
		<ICD >
			<data name='AnalogPrescaleValue' value='19' />
			<data name='DigitalSampleRate' value='100000' />
			<data name='BreakpointCount' value='8' />
			<data name='CallStackDepthCount' value='8' />
			<data name='ClockPort' value='1' />
			<data name='ClockPin' value='6' />
			<data name='DataPort' value='1' />
			<data name='DataPin' value='7' />
			<data name='UseDefaultPins' value='1' />
			<data name='WrapEnabled' value='1' />
			<data name='CommsDelayOverridden' value='0' />
			<data name='CommsDelay' value='1' />
			<data name='CalculatedCommsDelay' value='1' />
			<data name='AnalogEB2PrescaleValue' value='2' />
			<data name='DigitalEB2SampleRate' value='100000' />
		</ICD>
		<pins >
			<digital A='0' B='0' C='0' D='0' E='0' F='0' G='0' H='0' I='0' J='0' K='0' L='0' M='0' N='0' O='0' P='0' Q='0' R='0' S='0' T='0' U='0' V='0' W='0' X='0' Y='0' Z='0' />
			<analog A='0' B='0' C='0' D='0' E='0' F='0' G='0' H='0' I='0' J='0' K='0' L='0' M='0' N='0' O='0' P='0' Q='0' R='0' S='0' T='0' U='0' V='0' W='0' X='0' Y='0' Z='0' />
		</pins>
	</ghost>
	<components >
		<settings autoimg='0' center='1' unitscale='0' fixedscale='0' fixedx='25' fixedy='25' fixedz='25' headcode='0' />
		<definition guid='8da7ab98-8755-4322-9f08-c936043752c2' vstate='40' vmin='0' vmaj='1' srcleaf='' visiblename='' description='' category='' category2='' category3='' bIs2dOnly='0' bIs3dOnly='0' bIsWysiwyg='0' catenable='1' author='' manuname='' manucode='' sysinfo='0' keywords='' dynamic='1' scadaCompatible='0' embeddedCompatible='1' showmacros='1' iconpath='' />
		<component class_type='root' codename='ComponentRoot' panelId='-1' x='0' y='0' z='0' xsz='1' ysz='1' zsz='1' xang='0' yang='0' zang='0' xquat='0' yquat='0' zquat='0' wquat='1' visible='1' scadavisible='1' interactive='1' solid='1' layer='0' poslock='0' ancTop='0' ancBottom='0' ancLeft='0' ancRight='0' ancMinX='0' ancMinY='0' comp2dType='0' >
			<resources />
			<properties />
			<values />
			<events />
			<apis />
			<variables >
				<variable public='0' >
					<def class_type='variable' name='false' type='b1' description='' isconst='1' isHidden='0' isinit='1' usrinit='0' setinit='0' />
				</variable>
				<variable public='0' >
					<def class_type='variable' name='MQTT_Queue' type='u32' description='' isconst='0' isHidden='0' isinit='1' usrinit='0' setinit='0' />
				</variable>
				<variable public='0' >
					<def class_type='variable' name='MQTT_Client' type='u32' description='' isconst='0' isHidden='0' isinit='1' usrinit='0' setinit='0' />
				</variable>
				<variable public='0' >
					<def class_type='variable' name='MQTT_Task' type='u32' description='' isconst='0' isHidden='0' isinit='1' usrinit='0' setinit='0' />
				</variable>
				<variable public='0' >
					<def class_type='variable' name='true' type='b1' description='' isconst='1' isHidden='0' isinit='1' usrinit='1' setinit='1' />
				</variable>
			</variables>
			<macros >
				<macro >
					<flowline name='MQTT_Client' description='' statediag='0' >
						<return name='Return' type='v0' description='' isconst='0' isHidden='0' isinit='0' usrinit='' setinit='' />
						<local name='topic' type='T8' description='' isconst='0' isHidden='0' isinit='1' usrinit='&quot;&quot;' setinit='&quot;&quot;' >
							<array size='64' />
						</local>
						<local name='data' type='T8' description='' isconst='0' isHidden='0' isinit='1' usrinit='&quot;&quot;' setinit='&quot;&quot;' >
							<array size='128' />
						</local>
						<command class_type='loop' title='Loop' type='3' exp='1' for1='' for3='' >
							<flowline >
								<command class_type='native' title='Waits for an item in the receive queue' ccode='mqtt_msg_t msg;
xQueueReceive(mqtt_queue, &amp;msg, portMAX_DELAY);
snprintf(FCL_DATA, sizeof(FCL_DATA), &quot;%.*s&quot;, strlen(msg.data), msg.data);
snprintf(FCL_TOPIC, sizeof(FCL_TOPIC), &quot;%.*s&quot;, strlen(msg.topic), msg.topic);' language='C' />
								<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
									<argument exp='&quot;Got topic &quot;' />
								</command>
								<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
									<argument exp='.topic' />
								</command>
								<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
									<argument exp='&quot; - payload - &quot;' />
								</command>
								<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
									<argument exp='.data' />
								</command>
								<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
									<argument exp='&quot;\r\n&quot;' />
								</command>
							</flowline>
						</command>
					</flowline>
				</macro>
				<macro >
					<flowline name='MQTT_Broker' description='' statediag='0' >
						<return name='Return' type='v0' description='' isconst='0' isHidden='0' isinit='0' usrinit='' setinit='' />
						<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
							<argument exp='&quot;Starting broker\r\n&quot;' />
						</command>
						<command class_type='native' title='Code' ccode='struct mosq_broker_config config = {
        .host = &quot;0.0.0.0&quot;,   // Listen on all network interfaces
        .port = 1883,        // Standard MQTT port
        .tls_cfg = NULL      // Plain TCP (No TLS for this example)
    };

    // This function runs the Mosquitto event loop and blocks indefinitely
    int ret = mosq_broker_run(&amp;config);
' language='C' />
						<command class_type='call' title='Component Macro' component='UART1' macro='SendString' >
							<argument exp='&quot;Broker exited?\r\n&quot;' />
						</command>
						<command class_type='native' title='Clean up the task' ccode='vTaskDelete(NULL);' language='C' />
					</flowline>
				</macro>
				<macro >
					<flowline name='Main' description='' statediag='0' >
						<return name='Return' type='v0' description='' isconst='0' isHidden='0' isinit='0' usrinit='' setinit='' />
						<local name='got_data' type='u16' description='' isconst='0' isHidden='0' isinit='1' usrinit='0' setinit='0' />
						<local name='payload' type='T8' description='' isconst='0' isHidden='0' isinit='1' usrinit='&quot;&quot;' setinit='&quot;&quot;' >
							<array size='128' />
						</local>
						<local name='sz' type='u32' description='' isconst='0' isHidden='0' isinit='1' usrinit='0' setinit='0' />
						<command class_type='call' title='User Macro' macro='Initialise' />
						<command class_type='loop' title='Loop' type='3' exp='1' for1='' for3='' >
							<flowline >
								<command class_type='delay' title='Delay' exp='10' type='1' />
							</flowline>
						</command>
					</flowline>
				</macro>
				<macro >
					<flowline name='Initialise' description='' statediag='0' >
						<return name='Return' type='v0' description='' isconst='0' isHidden='0' isinit='0' usrinit='' setinit='' />
						<local name='ap' type='u8' description='' isconst='0' isHidden='0' isinit='1' usrinit='0' setinit='0' />
						<command class_type='call' title='Component Macro' component='UART1' macro='Initialise' />
						<command class_type='call' title='Component Macro' component='NetworkComms1' macro='Initialise' />
						<command class_type='call' title='Component Macro' component='WLAN_ESP32' macro='Initialise' />
						<command class_type='call' title='Component Macro' disable='1' component='WLAN_ESP32' macro='CreateAccessPoint' >
							<return exp='.ap' />
							<argument exp='&quot;ESP32Access&quot;' />
							<argument exp='&quot;pswd1234&quot;' />
							<argument exp='4' />
							<argument exp='2' />
						</command>
						<command class_type='loop' title='Loop' type='1' exp='.ap' for1='' for3='' >
							<flowline >
								<command class_type='call' title='Component Macro' component='WLAN_ESP32' macro='ConnectToSSID' >
									<return exp='.ap' />
									<argument exp='&quot;SSID&quot;' />
									<argument exp='&quot;PASSWORD&quot;' />
									<argument exp='200' />
								</command>
								<command class_type='delay' title='Delay' exp='100' type='1' />
							</flowline>
						</command>
						<command class_type='delay' title='Delay' exp='5' type='2' />
						<command class_type='native' title='Code' ccode='mqtt_queue = xQueueCreate(5, sizeof(mqtt_msg_t));
xTaskCreate(FCM_MQTT_Broker, &quot;MQTT Broker&quot;, 4096, 0, 1, &amp;FCV_MQTT_TASK);
' language='C' />
						<command class_type='delay' title='Delay' exp='5' type='2' />
						<command class_type='native' title='Code' ccode='xTaskCreate(FCM_MQTT_Client, &quot;MQTT Client&quot;, 8192, 0, 5, &amp;FCV_MQTT_CLIENT);
' language='C' />
						<command class_type='native' title='Code' ccode='esp_mqtt_client_config_t mqtt_cfg = {
        .broker.address.uri = &quot;mqtt://127.0.0.1&quot;, 
        .credentials.client_id = &quot;Internal_Monitor&quot;, 
    };
    

local_client = esp_mqtt_client_init(&amp;mqtt_cfg);    
esp_mqtt_client_register_event(local_client, ESP_EVENT_ANY_ID, local_mqtt_event_handler, NULL);
esp_mqtt_client_start(local_client);
' language='C' />
					</flowline>
				</macro>
			</macros>
			<component class_type='ref' guid='f0f54e46-0848-4930-9bb6-eff9a34ed229' vmin='4' vmaj='2' codename='WLAN_ESP32' panelId='0' x='123' y='-124' z='0' xsz='25.1778' ysz='25.1392' zsz='25' xang='0' yang='0' zang='0' xquat='0' yquat='0' zquat='0' wquat='1' visible='1' scadavisible='1' interactive='1' solid='1' layer='2' poslock='1' ancTop='0' ancBottom='0' ancLeft='0' ancRight='0' ancMinX='0' ancMinY='0' comp2dType='0' >
				<resources />
				<properties />
				<values >
					<value target='Verbose' data='0' />
					<value target='SSIDScanSize' data='8' />
					<value target='RemapIndex' data='22' />
					<value target='TCP_Base1::interface' data='6' />
					<value target='TCP_Base1::ConsoleData' data='1' />
				</values>
				<events />
				<apis />
				<variables />
				<macros />
			</component>
			<component class_type='ref' guid='91049bf5-2436-42dc-947a-c30c86463d98' vmin='5' vmaj='1' codename='NetworkComms1' panelId='0' x='120.5' y='-119.5' z='1' xsz='1.00704' ysz='1.00565' zsz='1' xang='0' yang='0' zang='0' xquat='0' yquat='0' zquat='0' wquat='1' visible='1' scadavisible='1' interactive='1' solid='1' layer='2' poslock='0' ancTop='0' ancBottom='0' ancLeft='0' ancRight='0' ancMinX='0' ancMinY='0' comp2dType='0' >
				<resources />
				<properties />
				<values >
					<value target='Component' data='0' />
					<value target='LibraryComponent1::OutputIcon::LinkTo' data='001' />
					<value target='TCPIP_Channel' data='000' />
					<value target='RemapIndex' data='22' />
					<value target='Status' data='Supported' />
					<value target='Sim' data='0' />
					<value target='SimControl' data='000' />
					<value target='NetworkInterface' data='000' />
					<value target='IPAddress' data='172.17.96.1' />
				</values>
				<events />
				<apis />
				<variables />
				<macros />
			</component>
			<component class_type='ref' guid='c73616d1-7ad0-45d9-aada-69ccfa4c5efc' vmin='0' vmaj='3' codename='UART1' panelId='0' x='123' y='-124' z='2' xsz='25.1778' ysz='25.1392' zsz='25' xang='0' yang='0' zang='0' xquat='0' yquat='0' zquat='0' wquat='1' visible='1' scadavisible='1' interactive='1' solid='1' layer='2' poslock='1' ancTop='0' ancBottom='0' ancLeft='0' ancRight='0' ancMinX='0' ancMinY='0' comp2dType='0' >
				<resources />
				<properties />
				<values >
					<value target='cal_uart::CHANNEL' data='001' />
					<value target='cal_uart::BAUD_LIST' data='009' />
					<value target='cal_uart::BAUD' data='115200' />
					<value target='cal_uart::DBITS' data='008' />
					<value target='cal_uart::RETURN' data='001' />
					<value target='cal_uart::ECHO' data='000' />
					<value target='cal_uart::UseTX' data='1' />
					<value target='cal_uart::TX' data='$PORTA.1' />
					<value target='cal_uart::OutputPins' data='000' />
					<value target='cal_uart::TXAlt' data='0' />
					<value target='cal_uart::UseRX' data='1' />
					<value target='cal_uart::RX' data='$PORTA.3' />
					<value target='cal_uart::InputPins' data='001' />
					<value target='cal_uart::RXAlt' data='0' />
					<value target='cal_uart::FLOWEN' data='000' />
					<value target='cal_uart::RTS' data='$PORTB.2' />
					<value target='cal_uart::CTS' data='$PORTB.1' />
					<value target='label' data='UART' />
					<value target='cal_uart::ScopeTraces' data='0' />
					<value target='cal_uart::ConsoleData' data='1' />
					<value target='cal_uart::ConsoleFormat' data='000' />
					<value target='cal_uart::ConsoleColumns' data='64' />
					<value target='cal_uart::DataSource' data='000' />
					<value target='cal_uart::com_port' data='000' />
					<value target='cal_uart::Injector' data='000' />
					<value target='cal_uart::APIUseDDR' data='' />
					<value target='cal_uart::APIDDRPin' data='' />
					<value target='cal_uart::APIDDRRXState' data='' />
					<value target='cal_uart::APIUseFC' data='' />
					<value target='cal_uart::APICTSPin' data='' />
					<value target='cal_uart::APIRTSPin' data='' />
				</values>
				<events />
				<apis />
				<variables />
				<macros />
			</component>
			<component class_type='ref' guid='459c9cfb-82e3-40ad-9456-54fc40ba5e6c' vmin='1' vmaj='1' codename='MQTTClient1' panelId='0' x='123' y='-119.5' z='4' xsz='25.1778' ysz='25.1413' zsz='25' xang='0' yang='0' zang='0' xquat='0' yquat='0' zquat='0' wquat='1' visible='1' scadavisible='1' interactive='1' solid='1' layer='2' poslock='0' ancTop='0' ancBottom='0' ancLeft='0' ancRight='0' ancMinX='0' ancMinY='0' comp2dType='0' >
				<resources />
				<properties />
				<values >
					<value target='NETWORK_COMPONENT' data='0' />
					<value target='LibraryComponent1::OutputIcon::LinkTo' data='001' />
					<value target='HOST' data='127.0.0.1' />
					<value target='PORT' data='1883' />
					<value target='CLIENT' data='Loopback' />
					<value target='TIMEOUT' data='1000' />
					<value target='ReadTimeout' data='50' />
					<value target='KEEP_ALIVE' data='5' />
					<value target='AUTHENTICATION' data='000' />
					<value target='MaxPacketSize' data='260' />
					<value target='NAME' data='' />
					<value target='PASSWORD' data='' />
				</values>
				<events />
				<apis />
				<variables />
				<macros />
			</component>
		</component>
	</components>
	<scadaresourcelookup />
	<keymap />
	<panel2d shadows='0' lighting='2' brightness='0' >
		<background rgb='7292207' img='' style='0' />
		<camera xe='0' ye='0' ze='400.51' xt='0' yt='0' zt='0' xquat='0' yquat='0' zquat='0' wquat='1' />
		<viewport dx='128' dy='128' zoom='38.6707' fix_topleft='0' />
		<page x='1000' y='1000' show='0' rgb='7360576' />
		<winpos ID='7005' RectRecentFloat='1270,427,1920,877' RectRecentDocked='0,0,351,397' RecentFrameAlignment='16384' RecentRowIndex='0' IsFloating='0' MRUWidth='32767' PinState='0' IsMaximized='0' IsVisible='0' />
	</panel2d>
	<panel3d shadows='0' lighting='2' brightness='0' perspective='1' >
		<background rgb='8409120' img='' style='0' />
		<table rgb='7360576' img='' style='0' size='0' />
		<camera xe='0' ye='0' ze='781.66' xt='0' yt='0' zt='0' xquat='0' yquat='0' zquat='0' wquat='1' />
		<camerakey0 xe='0' ye='0' ze='300' xt='0' yt='0' zt='0' xquat='0' yquat='0' zquat='0' wquat='1' />
		<camerakey1 xe='-3.67394e-14' ye='0' ze='-300' xt='0' yt='0' zt='0' xquat='0' yquat='1' zquat='0' wquat='6.12323e-17' />
		<camerakey2 xe='0' ye='-300' ze='6.66134e-14' xt='0' yt='0' zt='0' xquat='-0.707107' yquat='0' zquat='0' wquat='0.707107' />
		<camerakey3 xe='-3.67394e-14' ye='300' ze='6.66134e-14' xt='0' yt='0' zt='0' xquat='-4.32978e-17' yquat='0.707107' zquat='0.707107' wquat='4.32978e-17' />
		<camerakey4 xe='-300' ye='-6.66134e-14' ze='6.66134e-14' xt='0' yt='0' zt='0' xquat='-0.5' yquat='0.5' zquat='0.5' wquat='0.5' />
		<camerakey5 xe='300' ye='-6.66134e-14' ze='6.66134e-14' xt='0' yt='0' zt='0' xquat='-0.5' yquat='-0.5' zquat='-0.5' wquat='0.5' />
		<camerakey6 xe='-173.205' ye='-173.205' ze='173.205' xt='0' yt='0' zt='0' xquat='-0.424708' yquat='0.17592' zquat='0.339851' wquat='0.820473' />
		<winpos ID='7004' RectRecentFloat='556,304,1206,754' RectRecentDocked='0,0,210,1690' RecentFrameAlignment='16384' RecentRowIndex='0' IsFloating='0' MRUWidth='32767' PinState='0' IsMaximized='0' IsVisible='0' />
	</panel3d>
	<panels2d count='1' >
		<panel2d_0 id='0' name='NewPanel' type='0' >
			<winpos ID='1171' RectRecentFloat='1368,264,2018,714' RectRecentDocked='0,0,650,450' RecentFrameAlignment='16384' RecentRowIndex='0' IsFloating='1' MRUWidth='32767' PinState='0' IsMaximized='0' IsVisible='0' />
			<background fill='288230376151053813' showgrid='1' gridstyle='1' gridsize='10' gridbrush='71776119075691740' snaptogrid='1' fitcomp='0' disp_x='300' disp_y='400' scale='100' disp_col='16777215' />
		</panel2d_0>
	</panels2d>
	<layout >
		<view type='0' name='Main' mode='0' placement='LAAAAAAAAAABAAAA---------------------wUAAAAzAAAA1AIAAI8GAAA' zoom='200' scrollx='0' scrolly='0' flags='0' />
		<view type='0' name='Initialise' mode='0' placement='LAAAAAAAAAABAAAA---------------------wUAAAAzAAAA1AIAAI8GAAA' zoom='170' scrollx='0' scrolly='264' flags='0' />
		<view type='0' name='MQTT_Broker' mode='0' placement='LAAAAAAAAAABAAAA---------------------wUAAAAzAAAA1AIAAI8GAAA' zoom='260' scrollx='0' scrolly='0' flags='0' />
		<view type='0' name='MQTT_Client' mode='0' placement='LAAAAAAAAAABAAAA---------------------wUAAAAzAAAA1AIAAI8GAAA' zoom='190' scrollx='110' scrolly='0' flags='0' />
	</layout>
</document>
</root>
