boot.py

import sys
from connections import WiFiManager, BluetoothManager
from entities import command, communicate, action
from controller import sensorsController, modulesController, memoryController
from modules import Relay

blue = BluetoothManager("ACS #9181")

sensors_connected = []

commands = command.Command()

commands.add(
    "list-wifi",
    lambda: list(map(lambda e: blue.send(str(e)), WiFiManager.getList()))
)
commands.add(
    "connect-wifi",
    lambda: 
        blue.send("connected to wifi") 
        if WiFiManager.connect([blue.send("SSID: "), blue.read()][1], [blue.send("Password: "), blue.read()][1])
        else blue.send("failed to connect to wifi")
)
commands.add(
    "disconnect-wifi",
    lambda: [WiFiManager.disconnect(), blue.send("disconnected from wifi")]
)
commands.add(
    "exit",
    lambda: [blue.send("Bye!"), sys.exit()]
)
commands.add(
    "add-sensor",
    lambda:
        sensorsController.SensorsController.add(
            [blue.send("Type JSON: "), 
             communicate.Communicate.str_to_json(blue.read_until_find("}"))][1])
)
commands.add(
    "remove-sensor",
    lambda:
        sensorsController.SensorsController.remove(
            [blue.send("Port: "), communicate.Communicate.str_to_json(blue.read_until_find("}"))["port"]][1]
        )
)
commands.add(
    "list-sensors",
    lambda: 
        list((map(lambda element: blue.send(str(element) + "\n"), (memoryController.MemoryController.listSensors())))
    )
)
commands.add(
    "add-module",
    lambda:
        modulesController.ModuleController.add(
            [blue.send("Type JSON: "), 
             communicate.Communicate.str_to_json(blue.read_until_find("}"))][1])
)
commands.add(
    "remove-module",
    lambda:
        modulesController.ModuleController.remove(
            [blue.send("Port: "), 
             communicate.Communicate.str_to_json(blue.read_until_find("}"))["port"]][1]
        )
)
commands.add(
    "list-modules",
    lambda:
        memoryController.MemoryController.listModules()
)

def irrigate(relay: Relay, time_in_seconds: float):
    water_flow_ml_by_ms = 100/1500 # full kitchen faucet flow example 
    relay.onIn(time_in_seconds)

    return water_flow_ml_by_ms * (time_in_seconds*1000)

def getTimer():
    time = 0
    return time

def start(relay):
    relay.setValue(0)

def end(relay):
    relay.setValue(1)

def getSensor(sensor: dict):
    ldr = sensorsController.SensorsController.add(sensor)
    blue.send(str(sensorsController.SensorsController.get(ldr["port"])))

action_irrigate = action.Action("irrigate", irrigate, "Open solenoide to allow water flow")

commands.add(
    "trigger",
    lambda: action_irrigate.effect(relay = Relay(2), time_in_seconds=3)
)
commands.add(
    "start",
    lambda: start(relay = Relay(2))
)
commands.add(
    "end",
    lambda: end(relay = Relay(2))
)
commands.add(
    "get-sensor",
    lambda: blue.send(str(getSensor({"port": 27, "min": 0, "max": 100, "type": "ldr"})))
)


invite = False

while True:
    # while not blue.isConnected():
    try:
        msg = blue.read()
        msg = communicate.Communicate.str_to_json(msg)
        commands.get(msg["name"])()
        
    except Exception as e:
        print(e)