esp32cam_capture_diff_node

src/esp32cam_capture_diff_node.py

@@ -0,0 +1,76 @@
+#!/usr/bin/env python3
+import asyncio
+import logging
+import os.path
+import tempfile
+
+from home.config import config
+from home.camera.esp32 import WebClient
+from home.util import parse_addr, send_datagram, stringify
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+from typing import Optional
+
+logger = logging.getLogger(__name__)
+cam: Optional[WebClient] = None
+
+
+async def pyssim(fn1: str, fn2: str) -> float:
+    args = [config['pyssim_path'], fn1, fn2]
+    proc = await asyncio.create_subprocess_exec(*args,
+                                                stdout=asyncio.subprocess.PIPE,
+                                                stderr=asyncio.subprocess.PIPE)
+    stdout, stderr = await proc.communicate()
+    if proc.returncode != 0:
+        logger.error(f'pyssim({fn1}, {fn2}): pyssim returned {proc.returncode}, stderr: {stderr.decode().strip()}')
+
+    return float(stdout.decode().strip())
+
+
+class ESP32CamCaptureDiffNode:
+    def __init__(self):
+        self.client = WebClient(parse_addr(config['esp32cam_web_addr']))
+        self.directory = tempfile.gettempdir()
+        self.nextpic = 1
+        self.first = True
+        self.server_addr = parse_addr(config['node']['server_addr'])
+
+        self.scheduler = AsyncIOScheduler()
+        self.scheduler.add_job(self.capture, 'interval', seconds=config['node']['interval'])
+        self.scheduler.start()
+
+    async def capture(self):
+        logger.debug('capture: start')
+
+        filename = self.getfilename()
+        if not await self.client.capture(os.path.join(self.directory, filename)):
+            logger.error('failed to capture')
+            return
+
+        self.nextpic = 1 if self.nextpic == 2 else 2
+        if not self.first:
+            diff = await pyssim(filename, os.path.join(self.directory, self.getfilename()))
+            n = 0
+            if diff < 0.93:
+                n = 3
+            elif n < 0.955:
+                n = 1
+            if n > 0:
+                send_datagram(stringify([config['node']['name'], n]), self.server_addr)
+                logger.info(f'diff = {diff}')
+        self.first = False
+
+        logger.debug('capture: done')
+
+    def getfilename(self):
+        return os.path.join(self.directory, f'{self.nextpic}.jpg')
+
+
+if __name__ == '__main__':
+    config.load('esp32cam_capture_diff_node')
+
+    loop = asyncio.get_event_loop()
+    ESP32CamCaptureDiffNode()
+    try:
+        loop.run_forever()
+    except KeyboardInterrupt:
+        pass