Merge pull request #8 from spark/bug-fixes

Verify chunk_saved_status logic - make OTA Update more reliable

Author: Zachary Crockett

src/spark_protocol.cpp

@@ -876,9 +876,16 @@ bool SparkProtocol::handle_received_message(void)
       unsigned int given_crc = queue[8] << 24 | queue[9] << 16 | queue[10] << 8 | queue[11];
       if (callback_calculate_crc(queue + 13, len - 13 - queue[len - 1]) == given_crc)
       {
-        callback_save_firmware_chunk(queue + 13, len - 13 - queue[len - 1]);
-        chunk_received(msg_to_send + 2, token, ChunkReceivedCode::OK);
-        ++chunk_index;
+    	unsigned short next_chunk_index = callback_save_firmware_chunk(queue + 13, len - 13 - queue[len - 1]);
+        if (next_chunk_index > chunk_index)
+        {
+          chunk_received(msg_to_send + 2, token, ChunkReceivedCode::OK);
+        }
+        else
+        {
+          chunk_missed(msg_to_send + 2, next_chunk_index);
+        }
+        chunk_index = next_chunk_index;
       }
       else
       {

src/spark_protocol.h

@@ -64,7 +64,7 @@ struct SparkCallbacks
   void (*prepare_for_firmware_update)(void);
   void (*finish_firmware_update)(void);
   long unsigned int (*calculate_crc)(unsigned char *buf, long unsigned int buflen);
-  void (*save_firmware_chunk)(unsigned char *buf, long unsigned int buflen);
+  unsigned short (*save_firmware_chunk)(unsigned char *buf, long unsigned int buflen);
   void (*signal)(bool on);
   system_tick_t (*millis)();
 };
@@ -142,7 +142,7 @@ class SparkProtocol
     void (*callback_prepare_for_firmware_update)(void);
     void (*callback_finish_firmware_update)(void);
     long unsigned int (*callback_calculate_crc)(unsigned char *buf, long unsigned int buflen);
-    void (*callback_save_firmware_chunk)(unsigned char *buf, long unsigned int buflen);
+    unsigned short (*callback_save_firmware_chunk)(unsigned char *buf, long unsigned int buflen);
     void (*callback_signal)(bool on);
     system_tick_t (*callback_millis)();