karae/server.py at master · Coyls/karae · GitHub

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
from typing import Any, List
from simple_websocket_server import WebSocketServer, WebSocket
from utils.protocol import ProtocolDecodeur
from datetime import date, datetime, time
import subprocess
from plant import Plant

"""
class Sensor:
    value = 0
    lastTrigger = datetime(2000,1,1)

    def __init__(self, delta : int, filePath :str ):
        self.delta = delta
        file = open(filePath, "r")
        lastTrigger = file.readline()
        if lastTrigger != "":
            self.lastTrigger = datetime.strptime(lastTrigger, '%Y-%m-%d %H:%M:%S.%f')


    def setValue(self, val : int):
        self.value = val
        self.setLastActivation()

    def setLastActivation(self):
        print("Set last trigger : ", datetime.now())
        file = open("./db/last-trigger.txt", "w")
        file.write(f"{datetime.now()}")
        self.lastTrigger = datetime.now()

    def canActivate(self) -> bool:
        now = datetime.now()
        res = now - self.lastTrigger
        print("Total Second : ", int(res.total_seconds()))
        return True if res.total_seconds() >= self.delta else False

class Storage:
    proximity = Sensor(100, "empty.txt")
    temp = Sensor(10, "empty.txt")
    switch = Sensor(10,"empty.txt")
    humidityGround = Sensor(10, "./db/last-trigger.txt")

    def setValue(self, key: str, val: str):
        if key == "/button":
            print("Button")
        if key == "/temp":
            self.temp.setValue(int(val))
            print(val)
        if key == "/proximity":
            if self.proximity.canActivate():
                self.proximity.setValue(int(val))
                subprocess.run(['espeak','-vfr+f4','-s150', "Bonjour, Humain !"])
        if key == "/switch":
            self.switch.setValue(int(val))
        if key == "/humidity-ground":
            self.humidityGround.setValue(int(val))
            subprocess.run(['espeak','-vfr+f4','-s150', "Merci Humain !"])

class Command:

    def __init__(self, cmd: str) -> None:
        self.cmd = cmd

    def use(self):
        return subprocess.run(self.cmd.split(" "))

class Hub:

    storage = Storage()

    def handle(self, client: WebSocket):
        dataTr = ProtocolDecodeur(client.data)
        [key, val] = dataTr.getKeyValue()

        if key == "/name":
            print(key , val)
            client.connectionManager.setClientName(client,val)
        else:
            self.storage.setValue(key, val)

            if key == "/switch" and self.storage.proximity.value == 1:
                lastWatering = self.storage.proximity.lastTrigger
                last = f"La plante à été aroser pour la derniere fois le {lastWatering.day}, {lastWatering.month} à {lastWatering.hour} heures et {lastWatering.minute} minutes."
                subprocess.run(['espeak','-vfr+f4','-s150',f"la temperature est de {self.storage.temp.value} degré"])
                subprocess.run(['espeak','-vfr+f4','-s150', last])
                print(last)
                time.sleep(2)
 """
class SensorConnection(WebSocket):

    plant = Plant()

    def handle(self):
        self.plant.handle(self)

    def connected(self):
        self.plant.connectionManager.addClient(self)

    def handle_close(self):
        self.plant.connectionManager.removeClient(self)


server = WebSocketServer('', 8000, SensorConnection)
server.serve_forever()