python/home
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Initial commit

Browse Source
This commit is contained in:
Thomas Klaehn 2022-05-23 16:20:14 +02:00
commit bc04332c92
13 changed files with 882 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
.vscode/launch.json vendored Normal file
View File

@ -0,0 +1,27 @@
{
// Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"name": "Python: Flask",
"type": "python",
"request": "launch",
"module": "flask",
"env": {
"FLASK_APP": "home/app.py",
"FLASK_ENV": "development",
"FLASK_DEBUG": "0"
},
"args": [
"run",
"--no-debugger",
"--no-reload",
"--host=0.0.0.0",
"--port=8000"
],
"jinja": true
}
]
}

10
home.service Normal file
View File

@ -0,0 +1,10 @@
[Unit]
Description=home service
After=multi-user.target
[Service]
Type=idle
ExecStart=gunicorn --bind 0.0.0.0:80 greenhouseui:app
[Install]
WantedBy=multi-user.target

1
home/__init__.py Normal file
View File

@ -0,0 +1 @@
from .app import app

206
home/app.py Normal file
View File

@ -0,0 +1,206 @@
"""Flask app"""
import datetime
import json
import os
import shutil
import threading
import time
import xmlrpc.client
from flask import Flask
from flask import render_template
from flask import make_response
from flask import request
from flask import jsonify
CONFIG_FILE = os.path.join(os.path.expanduser('~'), ".config/home/config.json")
class Control(threading.Thread):
"""Control"""
def __init__(self, config_file_name: str):
threading.Thread.__init__(self)
self.run_condition = True
self.config = None
self.config_file = config_file_name
self.water_state = []
def reload_config(self):
"""Reload config"""
try:
with open(self.config_file, "r", encoding="UTF-8") as handle:
self.config = json.load(handle)
except FileNotFoundError:
# create default config
os.makedirs(os.path.dirname(self.config_file), exist_ok=True)
shutil.copyfile("config.json", self.config_file)
with open(self.config_file, "r", encoding="UTF-8") as handle:
self.config = json.load(handle)
for _ in range(len(self.config['configs'])):
self.water_state.append(False)
def run(self):
while self.run_condition:
configs = self.config['configs']
water_index = 0
for config in configs:
water = config["water"]
autostate = water["autostate"]
if autostate:
times = water["times"]
idx = 0
now = datetime.datetime.now()
if int(now.hour) >= 12:
idx = 1
on_time_pattern = times[idx]['on_time']
on_time_pattern = on_time_pattern.split(':')
on_time = now.replace(hour=int(on_time_pattern[0]),
minute=int(on_time_pattern[1]),
second=0,
microsecond=0)
off_time_pattern = times[idx]['off_time']
off_time_pattern = off_time_pattern.split(':')
off_time = now.replace(hour=int(off_time_pattern[0]),
minute=int(off_time_pattern[1]),
second=0,
microsecond=0)
url = "http://" + config["host"] + ":" + str(config["port"])
if now > on_time and now <= off_time and not self.water_state[water_index]:
client = xmlrpc.client.ServerProxy(url)
client.switch_relay(water["relay"], True)
self.water_state[water_index] = client.get_relay_state(water["relay"])
elif now > off_time and self.water_state[water_index]:
client = xmlrpc.client.ServerProxy(url)
client.switch_relay(water["relay"], False)
self.water_state[water_index] = client.get_relay_state(water["relay"])
water_index += 1
time.sleep(1)
control = Control(CONFIG_FILE)
app = Flask(__name__)
@app.route('/', methods=['GET'])
def index():
"""Handle GET to index.html"""
return render_template('index.html')
@app.route('/hochbeet', methods=['GET'])
def hochbeet():
"""Handle GET to index.html"""
return render_template('hochbeet.html')
@app.route('/tomatentuppen', methods=['GET'])
def tomatentuppen():
"""Handle GET to index.html"""
return render_template('tomatentuppen.html')
@app.route('/sample/<idx>', methods=['GET'])
def get_sample(idx='0'):
"""Handle GET to /sample/<idx>"""
response = make_response("", 404)
with open(CONFIG_FILE, "r", encoding="UTF-8") as handle:
config = json.load(handle)
for cfg in config["configs"]:
if cfg["id"] == idx:
water = cfg["water"]
relay = int(water["relay"])
res = {}
url = "http://" + cfg["host"] + ":" + str(cfg["port"])
client = xmlrpc.client.ServerProxy(url)
water = {}
water['id'] = str(idx)
water['state'] = client.get_relay_state(relay)
res['water'] = water
response = make_response(jsonify(res), 200)
break
return response
@app.route('/sample/<idx>', methods=['PATCH'])
def patch_sample(idx='0'):
"""Handle PATCH to /sample"""
record = json.loads(request.data)
response = make_response("", 404)
if 'id' in record:
with open(CONFIG_FILE, "r", encoding="UTF-8") as handle:
config = json.load(handle)
for cfg in config["configs"]:
if cfg["id"] == idx:
water = cfg["water"]
relay = int(water["relay"])
url = "http://" + cfg["host"] + ":" + str(cfg["port"])
client = xmlrpc.client.ServerProxy(url)
client.switch_relay(relay, record["waterstate"])
response = make_response("", 204)
break
return response
@app.route('/config/<idx>', methods=['GET'])
def get_config(idx='0'):
"""Hadnle GET to config/<idx>"""
response = make_response("", 404)
with open(CONFIG_FILE, "r", encoding="UTF-8") as handle:
config = json.load(handle)
for cfg in config["configs"]:
if cfg["id"] == idx:
water = cfg["water"]
res = {}
res["water"] = water
response = make_response(jsonify(res), 200)
break
return response
@app.route('/config/<idx>', methods=['PATCH'])
def patch_config(idx="0"):
"""Handle PATCH to /config/<idx>"""
record = json.loads(request.data)
response = make_response("", 404)
config = None
with open(CONFIG_FILE, "r", encoding="UTF-8") as handle:
config = json.load(handle)
count = -1
for cfg in config["configs"]:
count += 1
if cfg["id"] == idx:
water = record['water']
if 'autostate' in water:
config["configs"][count]["water"]["autostate"] = water["autostate"]
if 'times' in water:
config["configs"][count]["water"]["times"] = water["times"]
break
if config:
with open(CONFIG_FILE, "w", encoding="UTF-8") as handle:
json.dump(config, handle)
# prepare answer
res = {}
water = {}
water['id'] = idx
water['autostate'] = config["configs"][count]["water"]["autostate"]
water['times'] = config["configs"][count]["water"]["times"]
res['water'] = water
response = make_response(jsonify(res), 200)
control.reload_config()
return response
def start_control():
"""Helper to start the control thread"""
control.reload_config()
control.start()
if __name__ == 'app':
start_control()
app.run(debug=True, host='0.0.0.0', port=8000)

47
home/config.json Normal file
View File

@ -0,0 +1,47 @@
{
"configs":
[
{
"id": "hochbeet",
"host": "hochbeet",
"port": 64001,
"water":
{
"relay": 2,
"autostate": false,
"times":
[
{
"on_time": "7:00",
"off_time": "7:20"
},
{
"on_time": "19:00",
"off_time": "19:20"
}
]
}
},
{
"id": "tomatentuppen",
"host": "hochbeet",
"port": 64001,
"water":
{
"relay": 3,
"autostate": false,
"times":
[
{
"on_time": "7:00",
"off_time": "7:20"
},
{
"on_time": "19:00",
"off_time": "19:20"
}
]
}
}
]
}

4
home/gunicorn.conf.py Normal file
View File

@ -0,0 +1,4 @@
def post_worker_init(server):
from home.app import start_control
start_control()

73
home/static/css/style.css Normal file
View File

@ -0,0 +1,73 @@
html, body {
font-size: 22px !important;
font-family: arial, verdana, helvetica, sans-serif;
color: #b6b6b6;
background: #282929;
}
h1, h2, h3 {text-align: center;}
p {text-align: center;}
div {text-align: center;}
.center {
margin-left: auto;
margin-right: auto;
text-align: center;
}
input {
border: 1px #999999 solid;
background-color: #f6f6f6;
padding: 2px 4px 2px 4px;
margin: 0 0 0.5rem 0;
font-size: 1.0rem;
border-radius: 8px;
}
input[type="submit" i] {
color: #b6b6b6;
background-color: #282929;
padding: 10px;
margin: 10px 0;
border-color: #b6b6b6;
border-width: 3px;
border-radius: 18px;
font-size: 20px;
}
input[type="text"] {
border-radius: 8px;
}
td {
padding: 8px;
}
.table_left {
text-align: right;
}
footer {
position: fixed;
/* left: 50%; */
bottom: 20px;
/* transform: translate(-50%, -50%); */
margin: 0 auto;
}
a {
outline: none;
color: #b6b6b6;
text-decoration-line: none;
}
select {
color: #b6b6b6;
background-color: #282929;
padding: 10px;
margin: 10px 0;
border-color: #b6b6b6;
border-width: 3px;
border-radius: 16px;
font-size: 20px;
}

147
home/static/scripts/hochbeet.js Normal file
View File

@ -0,0 +1,147 @@
var on_switch_water = function() {
var state = true;
if(document.getElementById("water_switch").value == "ausschalten") {
state = false;
}
var json_str = JSON.stringify(
{
"id": "hochbeet",
"waterstate": state
}
);
patch_sample(json_str);
}
var on_switch_auto_state = function() {
var state = true;
if(document.getElementById("auto_switch").value == "ausschalten") {
state = false;
}
var json_str = JSON.stringify(
{
"id": "hochbeet",
"water":
{
"autostate": state
}
}
);
patch_config(json_str);
}
var on_change_config = function() {
var on_time_one = document.getElementById("water_on_one").value;
var off_time_one = document.getElementById("water_off_one").value;
var on_time_two = document.getElementById("water_on_two").value;
var off_time_two = document.getElementById("water_off_two").value;
var json_str = JSON.stringify(
{
"id": "hochbeet",
"water":
{
"times":
[
{
"on_time": on_time_one,
"off_time": off_time_one
},
{
"on_time": on_time_two,
"off_time": off_time_two
}
]
}
}
);
patch_config(json_str);
}
var http_patch_config = new XMLHttpRequest();
http_patch_config.onreadystatechange = function () {
if (http_patch_config.readyState === 4) {
var status = http_patch_config.status;
if (status === 0 || (status >= 200 && status < 400)) {
// The request has been completed successfully
parse_config(http_patch_config.responseText);
}
} else {
// request error
}
}
var patch_config = function(config) {
http_patch_config.abort();
http_patch_config.open("PATCH", "/config/hochbeet");
http_patch_config.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
http_patch_config.send(config);
}
var patch_http = new XMLHttpRequest();
var patch_sample = function(sample) {
patch_http.abort();
patch_http.open("PATCH", "/sample/hochbeet");
patch_http.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
patch_http.send(sample);
}
var parse_config = function (event) {
var config = JSON.parse(event)
var output = "einschalten"
var visibility = 'hidden'
if(config.water) {
if(config.water.autostate) {
output = "ausschalten"
visibility = "visible"
document.getElementById("water_on_one").value = config.water.times[0].on_time;
document.getElementById("water_off_one").value = config.water.times[0].off_time;
document.getElementById("water_on_two").value = config.water.times[1].on_time;
document.getElementById("water_off_two").value = config.water.times[1].off_time;
}
document.getElementById("auto_switch").value = output;
document.getElementById("water_times").style.visibility = visibility
}
}
var parse_sample = function (event) {
var sample = JSON.parse(event)
if(sample.water && sample.water.id == 'hochbeet') {
var switch_caption = "einschalten";
if(sample.water.state) {
switch_caption = "ausschalten";
}
document.getElementById("water_switch").value = switch_caption;
}
}
var http = new XMLHttpRequest();
http.onreadystatechange = function () {
if (http.readyState === 4) {
var status = http.status;
if (status === 0 || (status >= 200 && status < 400)) {
// The request has been completed successfully
parse_sample(http.responseText);
setTimeout(function () {
http.open("GET", 'sample/hochbeet');
http.send();
}, 500);
}
} else {
// request error
}
}
http.open("GET", "sample/hochbeet");
http.send();
var http_get_config = new XMLHttpRequest();
http_get_config.onreadystatechange = function () {
if (http_get_config.readyState === 4) {
var status = http_get_config.status;
if (status === 0 || (status >= 200 && status < 400)) {
// The request has been completed successfully
parse_config(http_get_config.responseText);
}
} else {
// request error
}
}
http_get_config.open("GET", "config/hochbeet");
http_get_config.send();

147
home/static/scripts/tomatentuppen.js Normal file
View File

@ -0,0 +1,147 @@
var on_switch_water = function() {
var state = true;
if(document.getElementById("water_switch").value == "ausschalten") {
state = false;
}
var json_str = JSON.stringify(
{
"id": "tomatentuppen",
"waterstate": state
}
);
patch_sample(json_str);
}
var on_switch_auto_state = function() {
var state = true;
if(document.getElementById("auto_switch").value == "ausschalten") {
state = false;
}
var json_str = JSON.stringify(
{
"id": "tomatentuppen",
"water":
{
"autostate": state
}
}
);
patch_config(json_str);
}
var on_change_config = function() {
var on_time_one = document.getElementById("water_on_one").value;
var off_time_one = document.getElementById("water_off_one").value;
var on_time_two = document.getElementById("water_on_two").value;
var off_time_two = document.getElementById("water_off_two").value;
var json_str = JSON.stringify(
{
"id": "tomatentuppen",
"water":
{
"times":
[
{
"on_time": on_time_one,
"off_time": off_time_one
},
{
"on_time": on_time_two,
"off_time": off_time_two
}
]
}
}
);
patch_config(json_str);
}
var http_patch_config = new XMLHttpRequest();
http_patch_config.onreadystatechange = function () {
if (http_patch_config.readyState === 4) {
var status = http_patch_config.status;
if (status === 0 || (status >= 200 && status < 400)) {
// The request has been completed successfully
parse_config(http_patch_config.responseText);
}
} else {
// request error
}
}
var patch_config = function(config) {
http_patch_config.abort();
http_patch_config.open("PATCH", "/config/tomatentuppen");
http_patch_config.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
http_patch_config.send(config);
}
var patch_http = new XMLHttpRequest();
var patch_sample = function(sample) {
patch_http.abort();
patch_http.open("PATCH", "/sample/tomatentuppen");
patch_http.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
patch_http.send(sample);
}
var parse_config = function (event) {
var config = JSON.parse(event)
var output = "einschalten"
var visibility = 'hidden'
if(config.water) {
if(config.water.autostate) {
output = "ausschalten"
visibility = "visible"
document.getElementById("water_on_one").value = config.water.times[0].on_time;
document.getElementById("water_off_one").value = config.water.times[0].off_time;
document.getElementById("water_on_two").value = config.water.times[1].on_time;
document.getElementById("water_off_two").value = config.water.times[1].off_time;
}
document.getElementById("auto_switch").value = output;
document.getElementById("water_times").style.visibility = visibility
}
}
var parse_sample = function (event) {
var sample = JSON.parse(event)
if(sample.water && sample.water.id == 'tomatentuppen') {
var switch_caption = "einschalten";
if(sample.water.state) {
switch_caption = "ausschalten";
}
document.getElementById("water_switch").value = switch_caption;
}
}
var http = new XMLHttpRequest();
http.onreadystatechange = function () {
if (http.readyState === 4) {
var status = http.status;
if (status === 0 || (status >= 200 && status < 400)) {
// The request has been completed successfully
parse_sample(http.responseText);
setTimeout(function () {
http.open("GET", 'sample/tomatentuppen');
http.send();
}, 500);
}
} else {
// request error
}
}
http.open("GET", "sample/tomatentuppen");
http.send();
var http_get_config = new XMLHttpRequest();
http_get_config.onreadystatechange = function () {
if (http_get_config.readyState === 4) {
var status = http_get_config.status;
if (status === 0 || (status >= 200 && status < 400)) {
// The request has been completed successfully
parse_config(http_get_config.responseText);
}
} else {
// request error
}
}
http_get_config.open("GET", "config/tomatentuppen");
http_get_config.send();

76
home/templates/hochbeet.html Normal file
View File

@ -0,0 +1,76 @@
<!DOCTYPE html>
<html>
<head>
<title>Hochbeet</title>
<meta name="viewport" content="width=device-width, initial-scale=1">
<link href="/static/css/style.css" rel="stylesheet">
<script src="/static/scripts/hochbeet.js"></script>
</head>
<body>
<h1>Hochbeet</h1>
<table class="center">
<tr>
<td class="left">Bewässerung</td>
<td class="input">
<input id="water_switch" type="submit" value="" onclick="on_switch_water()"></input>
</td>
</tr>
<tr>
<td class="left">Zeigesteuerte Bewässerung </td>
<td class="input">
<input id="auto_switch" type="submit" value="einschalten" onclick="on_switch_auto_state()"></input>
</td>
</tr>
</table>
<div id="water_times" style="visibility:hidden;">
<table class="center">
<tr>
<td>Vormittag</td>
<td>
<table>
<tr>
<td>Einschaltzeit</td>
<td class="input">
<input type="text" id="water_on_one" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
<tr>
<td>Ausschaltzeit</td>
<td class="input">
<input type="text" id="water_off_one" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
</table>
</td>
</tr>
<tr>
<td>Nachmittag</td>
<td>
<table>
<tr>
<td>Einschaltzeit</td>
<td class="input">
<input type="text" id="water_on_two" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
<tr>
<td>Ausschaltzeit</td>
<td class="input">
<input type="text" id="water_off_two" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
</table>
</td>
</tr>
</table>
</div>
</body>
<footer>
<nav>
<a href="/">Home</a>&nbsp|&nbsp
<a href="/hochbeet" class="center">Hochbeet</a>&nbsp|&nbsp
<a href="/tomatentuppen" class="center">Tomatentuppen</a>
</nav>
</footer>
</html>

24
home/templates/index.html Normal file
View File

@ -0,0 +1,24 @@
<!DOCTYPE html>
<html>
<head>
<title>Home</title>
<meta name="viewport" content="width=device-width, initial-scale=1">
<link href="/static/css/style.css" rel="stylesheet">
</head>
<body>
<h1>Home</h1>
<div class="center">
<a href="/hochbeet" class="center">Hochbeet</a><br>
<a href="/tomatentuppen" class="center">Tomatentuppen</a>
</div>
</body>
<footer>
<nav>
<a href="/">Home</a>&nbsp|&nbsp
<a href="/hochbeet" class="center">Hochbeet</a>&nbsp|&nbsp
<a href="/tomatentuppen" class="center">Tomatentuppen</a>
</nav>
</footer>
</html>

76
home/templates/tomatentuppen.html Normal file
View File

@ -0,0 +1,76 @@
<!DOCTYPE html>
<html>
<head>
<title>Tomatentuppen</title>
<meta name="viewport" content="width=device-width, initial-scale=1">
<link href="/static/css/style.css" rel="stylesheet">
<script src="/static/scripts/tomatentuppen.js"></script>
</head>
<body>
<h1>Tomatentuppen</h1>
<table class="center">
<tr>
<td class="left">Bewässerung</td>
<td class="input">
<input id="water_switch" type="submit" value="" onclick="on_switch_water()"></input>
</td>
</tr>
<tr>
<td class="left">Zeigesteuerte Bewässerung </td>
<td class="input">
<input id="auto_switch" type="submit" value="einschalten" onclick="on_switch_auto_state()"></input>
</td>
</tr>
</table>
<div id="water_times" style="visibility:hidden;">
<table class="center">
<tr>
<td>Vormittag</td>
<td>
<table>
<tr>
<td>Einschaltzeit</td>
<td class="input">
<input type="text" id="water_on_one" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
<tr>
<td>Ausschaltzeit</td>
<td class="input">
<input type="text" id="water_off_one" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
</table>
</td>
</tr>
<tr>
<td>Nachmittag</td>
<td>
<table>
<tr>
<td>Einschaltzeit</td>
<td class="input">
<input type="text" id="water_on_two" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
<tr>
<td>Ausschaltzeit</td>
<td class="input">
<input type="text" id="water_off_two" style="width: 70px;" onchange="on_change_config()"></input>
</td>
</tr>
</table>
</td>
</tr>
</table>
</div>
</body>
<footer>
<nav>
<a href="/">Home</a>&nbsp|&nbsp
<a href="/hochbeet" class="center">Hochbeet</a>&nbsp|&nbsp
<a href="/tomatentuppen" class="center">Tomatentuppen</a>
</nav>
</footer>
</html>

44
setup.py Normal file
View File

@ -0,0 +1,44 @@
import os
import shutil
import stat
from setuptools import setup
from setuptools.command.install import install
NAME = 'home'
VERSION = '1'
AUTHOR = 'Thomas Klaehn'
EMAIL = 'tkl@blackfinn.de'
PACKAGES = ['home']
REQUIRES = ['Flask', 'gunicorn']
CONFIG_FILE = 'config.json'
PACKAGE_DATA = {'home': ['config.json', 'templates/*', 'static/css/*', 'static/scripts/*']}
SERVICEDIR = "/lib/systemd/system"
DAEMON_START_SCRIPT = os.path.join(SERVICEDIR, 'home.service')
LOGFILE = "/var/log/home.log"
class Install(install):
"""Installer"""
def run(self):
install.run(self)
os.makedirs(SERVICEDIR, exist_ok=True)
shutil.copyfile('home.service', os.path.join(SERVICEDIR, DAEMON_START_SCRIPT))
os.chmod(DAEMON_START_SCRIPT, stat.S_IRUSR | stat.S_IWUSR | stat.S_IRGRP | stat.S_IROTH)
try:
open(LOGFILE, 'r', encoding="UTF-8")
except FileNotFoundError:
os.makedirs(os.path.dirname(LOGFILE), exist_ok=True)
open(LOGFILE, 'x', encoding="UTF-8")
os.chmod(LOGFILE, stat.S_IRUSR | stat.S_IWUSR | stat.S_IRGRP | stat.S_IWGRP | stat.S_IROTH | stat.S_IWOTH)
setup(name=NAME, version=VERSION, long_description=__doc__, author=AUTHOR, author_email=EMAIL,
packages=PACKAGES, include_package_data=True, package_data=PACKAGE_DATA, zip_safe=False,
install_requires=REQUIRES,
cmdclass={
'install': Install
}
)