backported lwl mqtt code

Author: Manwlis

code/CM7/Core/Src/freertos.c

@@ -203,9 +203,6 @@ void StartDefaultTask(void *argument)
 			lwl_init();
 			lwl_enter_record( TEST_LWL_ID , TEST_TEST_LWL_ID , "h" , t );
 		}
-		if( input == 'd' )
-			dump_log();
-
 		if( input == 's')
 		{
 			float lux;

code/CM7/Core/lwl/lwl.c

@@ -142,3 +142,32 @@ void dump_log()
 	HAL_UART_Transmit(&hcom_uart [COM_ActiveLogPort], (uint8_t *) &index , sizeof(index) , COM_POLL_TIMEOUT );
 	HAL_UART_Transmit(&hcom_uart [COM_ActiveLogPort], lwl_data.buffer , LWL_BUFFER_SIZE , COM_POLL_TIMEOUT );
 }
+
+
+#if __has_include("mqtt_client.h")
+#include "mqtt_client.h"
+void dump_log_mqtt()
+{
+	// make sure it does not change while dumping. We may loose a few entries while dumping but it is better than corrupting the data.
+	lwl_driver.is_initialized = false;
+
+	uint8_t metadata[ sizeof(lwl_data.next_entry_index) + sizeof(uint32_t) ];
+	memcpy( &(metadata[0]) , &(lwl_data.next_entry_index) , sizeof(lwl_data.next_entry_index) );
+	memcpy( &(metadata[sizeof(lwl_data.next_entry_index)]) , &(uint32_t){LWL_BUFFER_SIZE} , sizeof(uint32_t) );
+
+	mqtt_publish( mqtt_data.client , MQTT_PUB_LWL_INDEX_ID , metadata , sizeof(metadata) , 0 , 0 , NULL , NULL );
+
+	int32_t current_sent_size = 0;
+	for( int32_t remaining_data = LWL_BUFFER_SIZE ; remaining_data > 0 ; remaining_data -= current_sent_size )
+	{
+		const int32_t payload_max_size = MQTT_OUTPUT_RINGBUF_SIZE - sizeof(MQTT_PUB_LWL_DATA_ID) - 5; // dont know why -5. According to mqtt, largest outgoing publish message = topic+payloads
+		current_sent_size = ( remaining_data > payload_max_size ) ? payload_max_size : remaining_data ;
+
+		err_t rv;
+		do{
+			rv = mqtt_publish( mqtt_data.client , MQTT_PUB_LWL_DATA_ID , &(lwl_data.buffer[LWL_BUFFER_SIZE - remaining_data]) , current_sent_size , 0 , 0 , NULL , NULL );
+		} while( rv == ERR_MEM );
+	}
+	lwl_driver.is_initialized = true;
+}
+#endif

code/CM7/Core/lwl/lwl.h

@@ -36,6 +36,9 @@
 /* Exported functions prototypes ---------------------------------------------*/
 void lwl_init();
 void lwl_enter_record( uint8_t module_id , char functionality_id[] , const char* fmt , ... );
-void dump_log();
+
+#if __has_include("mqtt_client.h")
+void dump_log_mqtt();
+#endif
 
 #endif /* LWL_LWL_H_ */