Implement syncstart command

Author: r3n33

command_interface.c

@@ -28,6 +28,7 @@ extern volatile bool update_rtc;
 
 extern volatile bool log_file_active;
 
+static bool cat_in_progress = false;
 static lfs_file_t file_command_interface;
 static uint8_t lfs_file_buf[4096]; // Must be cache size
 static struct lfs_file_config lfs_file_config;
@@ -189,7 +190,7 @@ void command_interface_process_byte(char incoming)
                 sprintf((char *)command_response_buffer, "cat,%s", filename);
                 m_ble_tx_logbuffer(command_response_buffer, (size_t)strlen((const char *)command_response_buffer));
                 bytes_sent = 0;
-                sync_in_progress = true;
+                cat_in_progress = true;
             }
         }
         else if(strncmp(command_input_buffer, "rm ", 3) == 0 && strlen(command_input_buffer) > 3)
@@ -241,7 +242,7 @@ void command_interface_process_byte(char incoming)
         }
         else if(strncmp(command_input_buffer, "version", 7) == 0)
         {
-            sprintf((char *)command_response_buffer, "version,0.9.1,beta");
+            sprintf((char *)command_response_buffer, "version,0.10.0,beta");
             m_ble_tx_logbuffer(command_response_buffer, strlen((const char *)command_response_buffer));
         }
         else if(strncmp(command_input_buffer, "getcfg", 6) == 0)
@@ -346,21 +347,40 @@ void command_interface_process_byte(char incoming)
 
             m_ble_tx_logbuffer(command_response_buffer, strlen((const char *)command_response_buffer));
         }
+        else if(strncmp(command_input_buffer, "syncstart", 9) == 0)
+        {
+            // Sync process is starting
+            NRF_LOG_INFO("syncstart command received");
+            NRF_LOG_FLUSH();
+            if (!sync_in_progress)
+            {
+                sync_in_progress = true;
+                NRF_LOG_INFO("sync_in_progress is now true");
+                NRF_LOG_FLUSH();
+            } else {
+                NRF_LOG_INFO("sync_in_progress was already true");
+                NRF_LOG_FLUSH();
+            }
+        }
         else if(strncmp(command_input_buffer, "syncstop", 8) == 0)
         {
             // Sync process was aborted by the user
             NRF_LOG_INFO("syncstop command received");
             NRF_LOG_FLUSH();
             if (sync_in_progress)
             {
-                int close_result = lfs_file_close(m_lfs, &file_command_interface);
-                NRF_LOG_INFO("lfs close result: %d", close_result);
-                NRF_LOG_FLUSH();
                 sync_in_progress = false;
             } else {
                 NRF_LOG_INFO("sync_in_progress was false");
                 NRF_LOG_FLUSH();
             }
+            if (cat_in_progress)
+            {
+                int close_result = lfs_file_close(m_lfs, &file_command_interface);
+                NRF_LOG_INFO("lfs close result: %d", close_result);
+                NRF_LOG_FLUSH();
+                cat_in_progress = false;
+            }
         }
         else if(strncmp(command_input_buffer, "snooze,", 7) == 0)
         {
@@ -439,7 +459,7 @@ void command_interface_continue_transfer(char* command)
             NRF_LOG_INFO("cat close result: %d", close_result);
             NRF_LOG_FLUSH();
 
-            sync_in_progress = false;
+            cat_in_progress = false;
         }
         else if(bytes_sent < file_command_interface.ctz.size)
         {

main.c

@@ -1866,6 +1866,13 @@ static void logging_timer_handler(void *p_context) {
 static void telemetry_timer_handler(void *p_context) {
 	(void)p_context;
 
+	if (sync_in_progress)
+	{
+		NRF_LOG_INFO("Skipping telemetry");
+		NRF_LOG_FLUSH();
+		return;
+	}
+
 	// Set flag to write data when a response is received
 	write_logdata_now = true;