1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
# snag
# Matt Kohls
# (c) 2023
from flask import (
Blueprint, flash, g, redirect, render_template, request, url_for, json
)
from werkzeug.exceptions import abort
from datetime import datetime
from snag.db import get_db
bp = Blueprint('data', __name__, url_prefix='/data')
# Process json data
#
# Expects something like this:
# {
# "scheme": "1",
# "deviceId": 1,
# "readings": [
# {
# "env": "outdoor",
# "temp": 123
# },
# {
# "env": "enclosed",
# "temp": 456
# }
# ],
# "status": [
# {
# "heater": "off",
# "battery": 10
# }
# ]
# }
def unpack_json_scheme_1(req):
try:
deviceId = req['deviceId']
db = get_db()
# Status only has one object in it, and is optional
if 'status' in req:
if 'timeStamp' in req['status'][0]:
now = req['status'][0]['timeStamp']
else:
now = datetime.now()
battery = req['status'][0]['battery']
heater = req['status'][0]['heater']
db.execute('INSERT INTO device_status (date, deviceId, batteryCharge, heaterRunning) VALUES (?, ?, ?, ?)', [now, deviceId, battery, heater])
for environment in req['readings']:
env = environment['environment']
temp = environment['temperature']
humidity = environment['humidity']
pressure = environment['pressure']
now = environment['timeStamp']
if env == 'outdoor':
lux = environment['lux']
uv = environment['uv']
db.execute('INSERT INTO env_outdoor (date, deviceId, temperature, humidity, pressure, lux, uv_intensity) VALUES (?, ?, ?, ?, ?, ?, ?)', [now, deviceId, temp, humidity, pressure, lux, uv])
elif env == 'indoor':
db.execute('INSERT INTO env_indoor (date, deviceId, temperature, humidity, pressure) VALUES (?, ?, ?, ?, ?)', [now, deviceId, temp, humidity, pressure])
elif env == 'enclosed':
light = environment['light']
db.execute('INSERT INTO env_enclosed (date, deviceId, temperature, humidity, pressure, light) VALUES (?, ?, ?, ?, ?, ?)', [now, deviceId, temp, humidity, pressure, light])
else:
raise 'Bad reading environment'
db.commit()
except Exception as err:
print(err)
return "Bad JSON", 400
return "Data received", 200
@bp.route('/json', methods=['POST'])
def add_json_data():
if request.is_json:
req = request.get_json()
if 'scheme' in req:
if req['scheme'] == '1':
return unpack_json_scheme_1(req)
else:
abort(400, "Unknown scheme")
else:
abort(400, "Unknown JSON")
else:
abort(400, "Unknown payload type")
@bp.route('/devices', methods=['GET'])
def get_devices():
db = get_db()
out = []
devices = db.execute('SELECT * FROM devices ORDER BY deviceId').fetchall()
for device in devices:
envList = []
envs = db.execute('SELECT * FROM device_env WHERE deviceId = ?', [device['deviceId']]).fetchall()
for env in envs:
envDict = {
"environment" : env["environment"],
# "environmentDesc" : env["environmentDescription"]
}
envList.append(envDict)
deviceLine = {
"deviceId" : device["deviceId"],
"deviceName" : device["deviceName"],
"deviceDescription" : device["deviceLocation"]
}
deviceLine['environments'] = envList
out.append(deviceLine)
return out
|
