BathroomPump.py

gistfile1.txt

#!/usr/bin/python3
import logging
import datetime

from PySide2.QtCore import QObject, Slot
from PySide2.QtCore import QTimer

logger = logging.getLogger(__name__)
logger.setLevel(logging.DEBUG)


class BathroomPump(QObject):
    def __init__(self, sensors, relay, pir, parent=None):
        QObject.__init__(self, parent)
        self.sensors = sensors
        self.timer = QTimer(self)
        self.pumpRelay = sensors.QtSensor(relay)
        self.pumpPIR = sensors.QtSensor(pir)
        self.lastPumpedAt = datetime.datetime.min
        self.pumpPIR.triggered.connect(self.checkPump)
        self.pumpOccasionally = datetime.timedelta(minutes=30)
        logger.debug("Bathroom Pump Created")

    async def init(self):
        # There should be no retained MQTT so just make sure we're off
        self.pumpRelay.off()
        logger.debug("Bathroom Pump Initialised")

    @Slot()
    def checkPump(self):
        logger.debug("Bathroom Pump Checking")
        now = datetime.datetime.now()
        if (now - self.lastPumpedAt) < self.pumpOccasionally:
            return
        self.lastPumpedAt = now
        logger.debug("Bathroom Pump On")
        self.pumpRelay.on()
        QTimer.singleShot(30000, self.pumpOff)

    @Slot()
    def pumpOff(self):
        logger.debug("Bathroom Pump Off")
        self.pumpRelay.off()