dexcom_dumper: send INSERTION_TIME records when doing remote update

1 files changed, 8 insertions, 6 deletions

diff --git a/dexcom_reader/dexcom_dumper.py b/dexcom_reader/dexcom_dumper.py
index 2e372f1..7edb067 100644
--- a/dexcom_reader/dexcom_dumper.py
+++ b/dexcom_reader/dexcom_dumper.py
@@ -184,6 +184,7 @@ def poll():
                                 print_verbose('Error: could not connect to remote host.')
                         else:
                                 traceback.print_exc()
+                                dexcom_reconnect()
                         sleep_verbose(10)
 
 def poll_remote():
@@ -196,11 +197,11 @@ def poll_remote():
                 if n == 0:
                         send_ping(now)
                 if r:
-                        try:
-                                # TODO: track how long this takes & adjust sleep accordingly
-                                remote_update('METER_DATA')
-                        except:
-                                traceback.print_exc()
+                        for t in ['METER_DATA', 'INSERTION_TIME']: # TODO: track how long this takes & adjust sleep accordingly
+                                try:
+                                        remote_update(t)
+                                except:
+                                        traceback.print_exc()
                         next_reading = (r.system_time - now + timedelta(minutes=5, seconds=2)).total_seconds()
                         sleep_verbose(max(10, next_reading))
                 else:
@@ -257,6 +258,7 @@ def remote_update(rectype):
                 #print_verbose("Latest record on server: %s" % when.isoformat())
 
         (rs, r) = since_and_first(when, rectype)
+        connected(True)
         if len(rs):
                 print_verbose("Sending %d %s record%s... " % (len(rs), rectype, '' if len(rs) == 1 else 's'), newline=False)
                 result = POST(url_path, toJSON(rs))
@@ -266,7 +268,7 @@ def remote_update(rectype):
                 return (0, r)
 
 def test():
-        remote_update('EGV_DATA')
+        remote_update('USER_EVENT_DATA')
 
 def test0():
         for t in parseable_record_types():