Make data unique and in order

influx_frontend.py

@@ -17,10 +17,12 @@ client = influxdb_client.InfluxDBClient(
     org=config['DB_ORG']
 )
 
+
 @app.route('/success')
 def success():
     return "Form success!"
 
+
 @app.route('/', methods=['GET', 'POST'])
 def main_page():
     query_api = client.query_api()
@@ -29,13 +31,10 @@ def main_page():
     |> filter(fn: (r) => r["_measurement"] == "2016_odyssey")\
     |> filter(fn: (r) => r["_field"] == "odometer")\
     |> sort(columns: ["_value"], desc: false)\
+    |> yield(name: "last")\
     |> limit(n:10)'
 
     result = query_api.query(org=config['DB_ORG'], query=query)
-    print()
-    print()
-    print(result)
-    print()
     results = []
     for table in result:
         for record in table.records:
@@ -46,15 +45,25 @@ def main_page():
                 temp['oilhealth'] = record['oilhealth']
             except KeyError:
                 pass
+            try:
+                temp['fuel'] = record['fuel']
+                temp['fuelcost'] = record['fuelcost']
+            except KeyError:
+                pass
             results.append(temp)
             # .append((record.get_time(), record.get_field(), record.get_value()))
-    print(results)
-    print(len(results))
-    print()
     newlist = sorted(results, key=itemgetter('time'), reverse=True)
-    print(newlist)
-    data= results
-    return render_template('index.html', data=newlist)
+    oldlist = newlist  # temporary to strip the non-unique data
+    newlist = []
+    for value in oldlist:
+        if value in newlist:
+            continue
+        else:
+            newlist.append(value)
+
+    # print(newlist)
+    return render_template('index.html', data=newlist[:10])
+
 
 @app.route('/add_time', methods=['POST', 'GET'])
 def add_time():
@@ -110,10 +119,9 @@ def add_time():
     print("Submitting data to DB: {0}".format(json_body))
     # client.write_points(json_body)
 
-
-    
     return redirect(url_for('main_page'))
 
+
 @app.route('/repeat_last_odometer/<odometer>')
 def repeat_last_odometer(odometer):
     '''Retrieve the passed in odometer value and submit as a new entry'''
@@ -123,21 +131,26 @@ def repeat_last_odometer(odometer):
     print("Putting %s to database for %s" % (odometer, timestamp))
 
     write_api = client.write_api(write_options=SYNCHRONOUS)
-    point = influxdb_client.Point("2016_odyssey").time(timestamp).field("odometer", float(odometer))
+    point = influxdb_client.Point("2016_odyssey").time(
+        timestamp).field("odometer", float(odometer))
     write_api.write(bucket="gas", org=config['DB_ORG'], record=point)
     return redirect(url_for('main_page'))
 
+
 @app.route('/admin')
 def admin_index():
     return 'admin'
 
+
 @app.route('/login')
 def login():
     pass
 
+
 @app.route('/logout')
 def logout():
     pass
 
+
 if __name__ == '__main__':
     app.run(debug=True, host='0.0.0.0', port='9001')

templates/index.html

@@ -59,11 +59,27 @@
 </form>
 <br>
 Last Mileage
-<ul>
+<table class="table table-striped">
+<thead>
+  <tr>
+    <th scope="col">Odometer</th>
+    <th scope="col">Time</th>
+    <th scope="col">Oil</th>
+    <th scope="col">Litres</th>
+    <th scope="col">$/Litre</th>
+  </tr>
+</thead>
+<tbody>
   {% for point in data %}
-  <li>
-  {{ point['time'] }} = {{ point['odometer'] }}, {{point['oilhealth']}}
-  </li>
+  <tr>
+    <th scope="row">{{ point['odometer'] }}</th>
+    <td>{{ point['time'] }}</td>
+    <td>{{ point['oilhealth'] }}</td>
+    <td>{{ point['fuel'] }}</td>
+    <td>{{ point['fuelcost'] }}</td>
+  </tr>
   {% endfor %}
+</tbody>
+</table>
+
 {% endblock %}
-</ul>