stop reprocessing polled events and log the silent ones

The finalizer drops an event from memory when done, so the poller treated an
already-processed MQTT event as new - and claimed in the log that MQTT never
announced it. Keep a memory of handled ids.

Also log events that yield no face: 17 of 20 events over 19 hours produced no
log line at all here, which makes a working install indistinguishable from a
dead one - exactly the confusion reported in the community thread.

Author: skycryer

CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to FaceID. The Home Assistant app shows this file in the
 update dialog; standalone users can watch GitHub releases.
 
+## 0.6.10 — 2026-07-26
+
+- **Fixed: polled events could be processed twice.** The finalizer clears an event from
+  memory once it is done, so the poller then saw a fully processed MQTT event as new and
+  ran it again — while logging the untruth "never announced by MQTT". It now remembers
+  the last 1000 event ids it handled.
+- **The log no longer goes silent when nothing is recognised.** Events without a usable
+  face are the normal case (back to camera, too far away), but they were dropped without
+  a word — making a healthy install look identical to a broken one. Both "no snapshot"
+  and "no face >= min_face_px" are now logged. Measured here: over 19 hours, 17 of 20
+  events held no face at all, and the log said nothing about any of them.
+
 ## 0.6.9 — 2026-07-26
 
 - **Fixed: no Home Assistant entities unless you listed your cameras.** An empty

app/mqtt_listener.py

@@ -50,6 +50,9 @@ def __init__(self, cfg: dict, engine, gallery, frigate):
         self.frigate_topic = str(f.get("frigate_topic_prefix", "frigate")).strip("/") or "frigate"
         self._polled: deque = deque(maxlen=500)   # schon gesehene IDs
         self._announced: set = set()              # Kameras mit angemeldetem Sensor
+        # Der Finalizer raeumt self.events nach der Verarbeitung ab — ohne dieses
+        # Gedaechtnis haelt der Poller ein fertig verarbeitetes Ereignis fuer neu.
+        self._handled: deque = deque(maxlen=1000)
         self.prefix = str(f.get("mqtt_prefix", "faceid")).strip("/") or "faceid"
         self.present: dict[str, dict[str, float]] = {}  # camera -> {person: zuletzt gesehen}
         self._last_presence: dict[str, list] = {}  # zuletzt publizierter Stand je Kamera
@@ -117,6 +120,8 @@ def _on_message(self, client, userdata, msg):
         eid = after.get("id")
         if not eid:
             return
+        if eid not in self._handled:
+            self._handled.append(eid)
         self._ensure_discovery(cam)
         st = self.events.setdefault(
             eid,
@@ -154,9 +159,14 @@ def _process(self, eid: str):
         st["attempts"] += 1
         img = self.frigate.snapshot(eid, crop=True)
         if img is None:
+            log.info("Event %s (%s): kein Snapshot von Frigate", eid, st["camera"])
             return
         face = FaceEngine.best_face(self.engine.faces(img), min_px=self.min_face_px)
         if face is None:
+            # Der haeufigste Normalfall (Ruecken zur Kamera, zu weit weg) — trotzdem
+            # protokollieren, sonst sieht ein stiller Log wie ein Defekt aus.
+            log.info("Event %s (%s): Versuch %d, kein Gesicht >= %dpx im Snapshot",
+                     eid, st["camera"], st["attempts"], self.min_face_px)
             return
         emb = face.normed_embedding
         slug, name, score = self.gallery.match(emb)
@@ -220,7 +230,8 @@ def _poller(self):
             since = time.time()
             for ev in batch:
                 eid = ev.get("id")
-                if not eid or eid in self._polled or eid in self.events:
+                if (not eid or eid in self._polled or eid in self.events
+                        or eid in self._handled):
                     continue
                 cam = ev.get("camera", "")
                 if self.cameras and cam not in self.cameras:

faceid-addon/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to FaceID. The Home Assistant app shows this file in the
 update dialog; standalone users can watch GitHub releases.
 
+## 0.6.10 — 2026-07-26
+
+- **Fixed: polled events could be processed twice.** The finalizer clears an event from
+  memory once it is done, so the poller then saw a fully processed MQTT event as new and
+  ran it again — while logging the untruth "never announced by MQTT". It now remembers
+  the last 1000 event ids it handled.
+- **The log no longer goes silent when nothing is recognised.** Events without a usable
+  face are the normal case (back to camera, too far away), but they were dropped without
+  a word — making a healthy install look identical to a broken one. Both "no snapshot"
+  and "no face >= min_face_px" are now logged. Measured here: over 19 hours, 17 of 20
+  events held no face at all, and the log said nothing about any of them.
+
 ## 0.6.9 — 2026-07-26
 
 - **Fixed: no Home Assistant entities unless you listed your cameras.** An empty

faceid-addon/app/mqtt_listener.py

@@ -50,6 +50,9 @@ def __init__(self, cfg: dict, engine, gallery, frigate):
         self.frigate_topic = str(f.get("frigate_topic_prefix", "frigate")).strip("/") or "frigate"
         self._polled: deque = deque(maxlen=500)   # schon gesehene IDs
         self._announced: set = set()              # Kameras mit angemeldetem Sensor
+        # Der Finalizer raeumt self.events nach der Verarbeitung ab — ohne dieses
+        # Gedaechtnis haelt der Poller ein fertig verarbeitetes Ereignis fuer neu.
+        self._handled: deque = deque(maxlen=1000)
         self.prefix = str(f.get("mqtt_prefix", "faceid")).strip("/") or "faceid"
         self.present: dict[str, dict[str, float]] = {}  # camera -> {person: zuletzt gesehen}
         self._last_presence: dict[str, list] = {}  # zuletzt publizierter Stand je Kamera
@@ -117,6 +120,8 @@ def _on_message(self, client, userdata, msg):
         eid = after.get("id")
         if not eid:
             return
+        if eid not in self._handled:
+            self._handled.append(eid)
         self._ensure_discovery(cam)
         st = self.events.setdefault(
             eid,
@@ -154,9 +159,14 @@ def _process(self, eid: str):
         st["attempts"] += 1
         img = self.frigate.snapshot(eid, crop=True)
         if img is None:
+            log.info("Event %s (%s): kein Snapshot von Frigate", eid, st["camera"])
             return
         face = FaceEngine.best_face(self.engine.faces(img), min_px=self.min_face_px)
         if face is None:
+            # Der haeufigste Normalfall (Ruecken zur Kamera, zu weit weg) — trotzdem
+            # protokollieren, sonst sieht ein stiller Log wie ein Defekt aus.
+            log.info("Event %s (%s): Versuch %d, kein Gesicht >= %dpx im Snapshot",
+                     eid, st["camera"], st["attempts"], self.min_face_px)
             return
         emb = face.normed_embedding
         slug, name, score = self.gallery.match(emb)
@@ -220,7 +230,8 @@ def _poller(self):
             since = time.time()
             for ev in batch:
                 eid = ev.get("id")
-                if not eid or eid in self._polled or eid in self.events:
+                if (not eid or eid in self._polled or eid in self.events
+                        or eid in self._handled):
                     continue
                 cam = ev.get("camera", "")
                 if self.cameras and cam not in self.cameras:

faceid-addon/config.yaml

@@ -1,5 +1,5 @@
 name: FaceID
-version: "0.6.9"
+version: "0.6.10"
 slug: faceid
 description: Face recognition for Frigate — trainable gallery, clustered unknown review, HA sensors
 url: https://github.com/SkyTechNerds/faceid