From 7c2ad1a45b7982a9941d21115ffa8f63c4b5bc53 Mon Sep 17 00:00:00 2001
From: ske087 <scheianuionut@gmail.com>
Date: Mon, 17 Mar 2025 10:09:47 +0200
Subject: [PATCH] main app started

---
 __pycache__/db.cpython-311.pyc           | Bin 0 -> 744 bytes
 app.py                                   |  68 +++++++++++++++++++++++
 app_schema.txt                           |  45 +++++++++++++++
 instances/__pycache__/db.cpython-311.pyc | Bin 0 -> 1029 bytes
 instances/db.py                          |  11 ++++
 logs.db                                  | Bin 0 -> 16384 bytes
 6 files changed, 124 insertions(+)
 create mode 100644 __pycache__/db.cpython-311.pyc
 create mode 100644 app.py
 create mode 100644 app_schema.txt
 create mode 100644 instances/__pycache__/db.cpython-311.pyc
 create mode 100644 instances/db.py
 create mode 100644 logs.db

diff --git a/__pycache__/db.cpython-311.pyc b/__pycache__/db.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..3ddf1e6ac92e6750cbd9f454a808c881a285cb2e
GIT binary patch
literal 744
zcma)4Pixdb9G%H#H%rr0D}I3SP&6P7;z<x?wGp=6U7^XL)Wfoy8ES0)Y-c87OAG0;
zP?UnldhDqp{W2B=mw+I6^0u-)_2f+0EY!XD8|KY>zr4I*Ci!d_b3oMP#rG`;0r(|F
zQObmjZwqn)Fu*VXn*b{Vun94AfLZ!2EiG?i%$JftImcfGoB%FTi+VHV7@i4!KGg?c
zADkBZ7502R6L>!D9Kd~eD${2QE7udDOjKuVqH#Sj_m%(0hk-nCYflT}Ew+rid(rcC
zyXM-+tvzelsQv=AUb@KMs5`EMq-PHOTlcsh62?1W54rY+dms5xFX0a+f|8)KTZnGl
zp|~x)JYo5B)2w6~+X;M59%h;sM-lOOR`C+bVw!2>9q|%QL?aGEpJ!z+h#4`JOqJFQ
zdQ4s~LRWXJ*KtU!o^P!Xw$0<7)%0oGA@nVw7Va+hb~DY7eBQ=gYKT|lZL?PbQt(5+
zb^P?xqYHiMo4%B;46E}W^$+@c<Jd@RL$!QV@7G5F-dKl!04zK3GDp!7{HIzyTI;VJ
zHV4hLITT{Gzk1jhG}3&GMLaMSD!*60=@&p3B%c>>Rec=BI0?uTdQ(XG&#=1!MkNU0
S5G<tm7^xMwI0Cbf2mJ*yOPjp_

literal 0
HcmV?d00001

diff --git a/app.py b/app.py
new file mode 100644
index 0000000..c612c21
--- /dev/null
+++ b/app.py
@@ -0,0 +1,68 @@
+from flask import Flask, request, jsonify
+from datetime import datetime
+import sqlite3
+from instances.db import init_db
+
+app = Flask(__name__)
+
+# Variable to store the status of inputs and outputs
+status = {
+    "input1": "off",
+    "relay1": "off"
+}
+
+@app.route('/log', methods=['POST'])
+def log():
+    data = request.json
+    if not data:
+        return jsonify({"error": "No data provided"}), 400
+
+    # Extract data from the JSON payload
+    hostname = data.get('hostname', 'unknown')
+    ip_address = data.get('ip_address', 'unknown')
+    message = data.get('message', '')
+
+    print(f"Board hostname: {hostname}")
+    print(f"Board IP address: {ip_address}")
+    print(f"Message: {message}")
+
+    # Update the status of inputs and relays based on the message
+    if 'input1' in message:
+        status['input1'] = 'on' if 'input1 on' in message else 'off'
+        print(f"Input 1 is {status['input1']}")
+    if 'relay1' in message:
+        status['relay1'] = 'on' if 'relay1 on' in message else 'off'
+        print(f"Relay 1 status is {status['relay1']}")
+
+    # Record the log in the database
+    conn = sqlite3.connect('logs.db')
+    c = conn.cursor()
+    c.execute("INSERT INTO logs (timestamp, hostname, ip_address, message) VALUES (?, ?, ?, ?)",
+              (datetime.now().isoformat(), hostname, ip_address, message))
+    conn.commit()
+
+    # Update the board status in the database
+    c.execute('''INSERT OR REPLACE INTO boards (hostname, ip_address, input1, relay1)
+                 VALUES (?, ?, ?, ?)''',
+              (hostname, ip_address, status['input1'], status['relay1']))
+    conn.commit()
+    conn.close()
+
+    return jsonify({"message": "Log received"}), 200
+
+@app.route('/control', methods=['POST'])
+def control():
+    data = request.json
+    if not data:
+        return jsonify({"error": "No data provided"}), 400
+
+    # Control the relays based on the received data
+    if 'relay1' in data:
+        status['relay1'] = data['relay1']
+        print(f"Setting Relay 1 to {data['relay1']}")
+
+    return jsonify({"message": "Control command received"}), 200
+
+if __name__ == '__main__':
+    init_db()
+    app.run(host='0.0.0.0', port=80)
\ No newline at end of file
diff --git a/app_schema.txt b/app_schema.txt
new file mode 100644
index 0000000..24e4822
--- /dev/null
+++ b/app_schema.txt
@@ -0,0 +1,45 @@
+# Database Schema
+
+## Table: logs
+- timestamp: TEXT
+- hostname: TEXT
+- ip_address: TEXT
+- message: TEXT
+
+## Table: boards
+- hostname: TEXT PRIMARY KEY
+- ip_address: TEXT
+- input1: TEXT
+- input2: TEXT
+- input3: TEXT
+- input4: TEXT
+- relay1: TEXT
+- relay2: TEXT
+- relay3: TEXT
+- relay4: TEXT
+
+# Explanation of Functions in app.py
+
+## Function: init_db
+- Initializes the SQLite database.
+- Creates two tables: logs and boards.
+- The logs table stores log entries with timestamp, hostname, IP address, and message.
+- The boards table stores the status of each board with hostname, IP address, and status of inputs and relays.
+
+## Function: log
+- Endpoint: /log
+- Method: POST
+- Receives log messages from the ESP board.
+- Extracts hostname, IP address, and message from the JSON payload.
+- Prints the hostname, IP address, and message.
+- Updates the status of inputs and relays based on the message.
+- Records the log in the logs table.
+- Updates the board status in the boards table.
+
+## Function: control
+- Endpoint: /control
+- Method: POST
+- Receives control commands to update the status of relays.
+- Extracts the relay status from the JSON payload.
+- Prints the new relay status.
+- Updates the status of the relays.
\ No newline at end of file
diff --git a/instances/__pycache__/db.cpython-311.pyc b/instances/__pycache__/db.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..932f3dc5f39304de68870ff3b43bf8f3928eab42
GIT binary patch
literal 1029
zcma)5&1(}u6rb5_n$R@$1OI@z6kRM`v|a>JqFo`)hm!1}?Imn>hIHe8xw8=)TG)m_
zQ3@XGF{g_35AiH0h6S<U$y+3za&l&yjg3+94f~t-d++z&8;038+3Y-E20wmke1QOb
z<s>#?><q6k=Llecp$WDC7P?>yVps)I;v1Kg^|3J85)An_95FZoKI<A=bK+xo%>0uH
z-vhg#7tf33(SFSEWD?nfyRgT*&lnb_J3{bRWnxANdg4q&7MPyRI)YyEe{>kIyAjLn
zl<73+3a+=E2Nfl!DoD-UFDfYi5S1UPNZH6&)hgnedGxzo^9_qoU$b1KDjVuD+IFaK
zYZe((!>wr;dxX+)fT^k0I7>_IcmEhzcQg<GY2?%h^th5Q<tm$~plmLqnQ?~gw)`9M
zVK}*Yo~)iHx5mUHrnVE;L?o_>NL&+<vl>a73sdx|Y4~I{OzDno6WtHz^p-~*FHDi=
zL~r?o1suyV{4lAT4keNhid-5(o$@Dz(CE6n?N~&14S9{wC%)s#CBv&#iT8|nvSG7(
zwsk^fTwif_!jxefeht^XEGy=3jkXyC;B)5k;l0<l-)ELSWR`-petO|m=4IwZ_Andd
z`eO1R-^mXEyikST0Zgj!M}#cG{L^1)L*VJAz|&2Er<=m5m_8_U3j3vQDJb<BS?{dx
z7rVtET0=G+NP@?oXmqBxz+2@00)tWdj^*H%N$z?V8Rb6|y~<#afDrb<Vi2u?n1+`I
JU>2fAKLI}Y=OzFE

literal 0
HcmV?d00001

diff --git a/instances/db.py b/instances/db.py
new file mode 100644
index 0000000..b1b8311
--- /dev/null
+++ b/instances/db.py
@@ -0,0 +1,11 @@
+import sqlite3
+
+def init_db():
+    conn = sqlite3.connect('logs.db')
+    c = conn.cursor()
+    c.execute('''CREATE TABLE IF NOT EXISTS logs
+                 (timestamp TEXT, hostname TEXT, ip_address TEXT, message TEXT)''')
+    c.execute('''CREATE TABLE IF NOT EXISTS boards
+                 (hostname TEXT PRIMARY KEY, ip_address TEXT, input1 TEXT, input2 TEXT, input3 TEXT, input4 TEXT, relay1 TEXT, relay2 TEXT, relay3 TEXT, relay4 TEXT)''')
+    conn.commit()
+    conn.close()
\ No newline at end of file
diff --git a/logs.db b/logs.db
new file mode 100644
index 0000000000000000000000000000000000000000..2c6aec5955657343e0aefe39dca6fd20de9ba67d
GIT binary patch
literal 16384
zcmeI0%Wl&^6hQ5y&%9hHP1RMsDHN4jGvgUQvVlG#wNOM!v!JWUZJZJ*FJc#!O`)v#
z03;+ngcTAJU%?6qi7(&_n2Bph+i8`o5Y-*oNv<C!_a2W&WA8lOs)xQ_Yj>MosGG`^
zqN>URT~`#v;Ohuq<Cfq*`eQZTamBZx82f5gd!r<C$BOnYcdYGPaWw1#17H9QfB`T7
z2EYIq00UqE41j@aYT%@l7@wV+Q{TQ0y}gFN*Y>*AAo@(Mm5M9nqF!EE-74zQwv>Lp
zEk17tVasd!db#+ltZ$b#AFq^l^+(0sdwRW7@v7CX9|XOfd_${q7~=kb^ao~tKu?3N
z-|$|==k$X3oL&&0(+i?=?k*+AX7A6bO1)L}kAfEs{(N2W4#RdYu0)koaP%#nrzgb4
zeW{Mm&djJMPkJI6?Snw9i8B(!7Kwte-t>deYj#dkKBGjUfgc@s2a&P6S^nSo$uElb
zNo#0#azAn(a;01*`!#!%H8MXlA2ZvTvGnJ3H@%qpo_e2pm>T5=Ljwa~01SWuFaQR?
z02ugJ2G;YVEAtD>1QE83%w=qsF)AQdV9c;hi#f~>I=z`D!N{;J12faWWK&Fpb)xfG
ztM3JVb!|pamM&6=flbOBbS0%Drr3UU<CcK13lPdvaZQ)lQpl>9^6T|LuN}7b!+N__
zZyjt*%So7%h>c8nQBu-P8HpBnPL_qR<qn?H4LOPD#B6HY&fuge8ObbAY7p#DlMGJM
z<RnZDOcAk%@RXC0NP(J$OD)H?2G1!gCt=fYZ0fQhNEsOki=4P_bV=8i_JXvW#B<`k
zfZr#BSC^8JkjM$Sh|(cQlX4O!{BChE#e?TGah`<S0&@$LlT4Rk`OPcyv_39K{ewwF
z!nWbK7`gKPbYU<V6O{hJ<dnku62=6}D~l=dU@|H%itDi)O4$%aja*U`<^v(Mken2y
zga3|@NqJF-8YW>blMf^@B`zu<E6Nd9$|B6NhPd-pIf?6Gyis{NvTH7$|5fdq!WU>@
z01SWuFaQR?02lxRU;qq&0Wbgtz`%cI;C4Pezc9^{7OV7KQoB~;ON#GSwO<Nfpn(A}
j00zJS7ytuc01SWuFaQR?02lxR*Tz6LIj{bCA&~zKwyQyo

literal 0
HcmV?d00001