adding reconnect to fota

apps/fota/fota-firmware.c

@@ -48,6 +48,19 @@ else
   espconn_disconnect(pespconn);
 }
 
+LOCAL void ICACHE_FLASH_ATTR
+upgrade_recon_cb(void *arg, sint8 err)
+{
+  //error occured , tcp connection broke. user can try to reconnect here.
+  INFO("reconnect callback, error code %d !!!\n",err);
+  struct espconn *pespconn = (struct espconn *)arg;
+  fota_cdn_t *fota_cdn = (fota_cdn_t *)pespconn->reverse;
+if (fota_cdn->secure)
+  espconn_secure_disconnect(pespconn);
+else
+  espconn_disconnect(pespconn);
+}
+
 /**
   * @brief  Tcp client disconnect success callback function.
   * @param  arg: contain the ip link information
@@ -136,7 +149,11 @@ upgrade_dns_found(const char *name, ip_addr_t *ipaddr, void *arg)
     os_memcpy(pespconn->proto.tcp->remote_ip, &ipaddr->addr, 4);
   }
   // check for new version
-  start_esp_connect(fota_cdn->conn, fota_cdn->secure, upgrade_connect_cb, upgrade_discon_cb);
+  start_esp_connect(fota_cdn->conn,
+    fota_cdn->secure,
+    upgrade_connect_cb,
+    upgrade_discon_cb,
+    upgrade_recon_cb);
 }
 
 void ICACHE_FLASH_ATTR
@@ -173,7 +190,11 @@ start_cdn(fota_cdn_t *fota_cdn, char *version, char *host, char *url, char *prot
   if (UTILS_StrToIP(fota_cdn->host, &fota_cdn->conn->proto.tcp->remote_ip)) {
     INFO("Firmware client: Connect to %s:%d\r\n", fota_cdn->host, fota_cdn->port);
     // check for new version
-    start_esp_connect(fota_cdn->conn, fota_cdn->secure, upgrade_connect_cb, upgrade_discon_cb);
+    start_esp_connect(fota_cdn->conn,
+      fota_cdn->secure,
+      upgrade_connect_cb,
+      upgrade_discon_cb,
+      upgrade_recon_cb);
   }
   // else, use dns query to get ip address
   else {

apps/fota/fota-info.c

@@ -138,6 +138,18 @@ get_version_disconnect_cb(void *arg)
   clear_espconn((struct espconn *)arg);
 }
 
+void ICACHE_FLASH_ATTR
+get_version_recon_cb(void *arg, sint8 err)
+{
+  //error occured , tcp connection broke. user can try to reconnect here.
+  INFO("reconnect callback, error code %d !!!\n",err);
+#if (FOTA_SECURE)
+  espconn_secure_disconnect((struct espconn *)arg);
+#else
+  espconn_disconnect((struct espconn *)arg);
+#endif
+}
+
 /**
   * @brief  Get version connection version
   * @param  arg: contain the ip link information

apps/fota/fota-info.h

@@ -3,5 +3,6 @@
 
 void get_version_disconnect_cb(void *arg);
 void get_version_connect_cb(void *arg);
+void get_version_recon_cb(void *arg, sint8 err);
 
 #endif

apps/fota/fota-util.c

@@ -140,10 +140,12 @@ convert_version(const char *version_str, uint32_t len, uint32_t *version_bin)
 }
 
 void ICACHE_FLASH_ATTR
-start_esp_connect(struct espconn *conn, uint8_t secure, void *connect_cb, void *disconnect_cb)
+start_esp_connect(struct espconn *conn, uint8_t secure, void *connect_cb, void *disconnect_cb, void *reconn_cb)
 {
   espconn_regist_connectcb(conn, connect_cb);
   espconn_regist_disconcb(conn, disconnect_cb);
+  espconn_regist_reconcb(conn, reconn_cb);
+
   // INFO("Dest ip: %d.%d.%d.%d:%d\n",
   //   conn->proto.tcp->remote_ip[0],
   //   conn->proto.tcp->remote_ip[1],

apps/fota/fota-util.h

@@ -8,7 +8,7 @@
 
 int8_t convert_version(const char *version_str, uint32_t len, uint32_t *version_bin);
 int8_t parse_fota(const char *json, uint32_t len, char **version, char **host, char **url, char **protocol);
-void start_esp_connect(struct espconn *conn, uint8_t secure, void *conn_cb, void *disconn_cb);
+void start_esp_connect(struct espconn *conn, uint8_t secure, void *conn_cb, void *disconn_cb, void *reconn_cb);
 void clear_espconn(struct espconn *conn);
 
 #endif

apps/fota/fota.c

@@ -39,7 +39,11 @@ fota_dns_found(const char *name, ip_addr_t *ipaddr, void *arg)
   }
 
   // check for new version
-  start_esp_connect(pespconn, FOTA_SECURE, get_version_connect_cb, get_version_disconnect_cb);
+  start_esp_connect(pespconn,
+    FOTA_SECURE,
+    get_version_connect_cb,
+    get_version_disconnect_cb,
+    get_version_recon_cb);
 }
 
 // is called periodically to check for next version
@@ -61,7 +65,11 @@ fota_ticktock(fota_client_t *fota_client)
   if (UTILS_StrToIP(fota_client->host, &fota_client->conn->proto.tcp->remote_ip)) {
     INFO("FOTA client: Connect to ip %s:%d\r\n", fota_client->host, fota_client->port);
     // check for new version
-    start_esp_connect(fota_client->conn, FOTA_SECURE, get_version_connect_cb, get_version_disconnect_cb);
+    start_esp_connect(fota_client->conn,
+      FOTA_SECURE,
+      get_version_connect_cb,
+      get_version_disconnect_cb,
+      get_version_recon_cb);
   }
   // else, use dns query to get ip address
   else {