show a specific error for dot-only usernames

Entering "." or ".." in the create user dialog showed the message listing periods as allowed characters, which didn't explain the rejection. The dialog now checks for dot-only names separately and shows its own message.

frigate/api/auth.py

@@ -912,7 +912,7 @@ def create_user(
     HASH_ITERATIONS = request.app.frigate_config.auth.hash_iterations
     config_roles = list(request.app.frigate_config.auth.roles.keys())
 
-    if not re.match("^[A-Za-z0-9._]+$", body.username):
+    if not re.match(r"^(?!\.+$)[A-Za-z0-9._]+$", body.username):
         return JSONResponse(content={"message": "Invalid username"}, status_code=400)
 
     if body.role not in config_roles:

frigate/comms/config_updater.py

@@ -1,7 +1,6 @@
 """Facilitates communication between processes."""
 
 import multiprocessing as mp
-import threading
 from _pickle import UnpicklingError
 from multiprocessing.synchronize import Event as MpEvent
 from typing import Any
@@ -19,11 +18,9 @@ class ConfigPublisher:
         self.socket = self.context.socket(zmq.PUB)
         self.socket.bind(SOCKET_PUB_SUB)
         self.stop_event: MpEvent = mp.Event()
-        self.lock = threading.Lock()
 
     def publish(self, topic: str, payload: Any) -> None:
         """There is no communication back to the processes."""
-        with self.lock:
         self.socket.send_string(topic, flags=zmq.SNDMORE)
         self.socket.send_pyobj(payload)
 

frigate/comms/embeddings_updater.py

@@ -1,7 +1,6 @@
 """Facilitates communication between processes."""
 
 import logging
-import threading
 from collections.abc import Callable
 from enum import Enum
 from typing import Any
@@ -79,21 +78,14 @@ class EmbeddingsRequestor:
         self.context = zmq.Context()
         self.socket = self.context.socket(zmq.REQ)
         self.socket.connect(SOCKET_REP_REQ)
-        self.lock = threading.Lock()
 
     def send_data(self, topic: str, data: Any) -> Any:
         """Sends data and then waits for reply."""
-        # an overlapping call fails fast so a slow reply can't stall the API
-        if not self.lock.acquire(blocking=False):
-            return ""
-
         try:
             self.socket.send_json((topic, data))
             return self.socket.recv_json()
         except zmq.ZMQError:
             return ""
-        finally:
-            self.lock.release()
 
     def stop(self) -> None:
         self.socket.close()

frigate/comms/inter_process.py

@@ -73,11 +73,9 @@ class InterProcessRequestor:
         self.context = zmq.Context()
         self.socket = self.context.socket(zmq.REQ)
         self.socket.connect(SOCKET_REP_REQ)
-        self.lock = threading.Lock()
 
     def send_data(self, topic: str, data: Any) -> Any:
         """Sends data and then waits for reply."""
-        with self.lock:
         try:
             self.socket.send_json((topic, data))
             return self.socket.recv_json()

frigate/comms/webpush.py

@@ -70,7 +70,6 @@ class WebPushClient(Communicator):
             for c in self.config.cameras.values()
         }
         self.suspension_broadcaster: Callable[[str, Any, bool], None] | None = None
-        self.config_lock = threading.Lock()
         self.last_camera_notification_time: dict[str, float] = {
             c.name: 0  # type: ignore[misc]
             for c in self.config.cameras.values()
@@ -206,7 +205,6 @@ class WebPushClient(Communicator):
 
     def publish(self, topic: str, payload: Any, retain: bool = False) -> None:
         """Wrapper for publishing when client is in valid state."""
-        with self.config_lock:
         # check for updated global config (notifications, auth)
         while True:
             config_topic, config_payload = (

frigate/data_processing/post/object_descriptions.py

@@ -105,10 +105,6 @@ class ObjectDescriptionProcessor(PostProcessorApi):
                         logger.debug(f"{camera} sending early request to GenAI")
 
                         self.early_request_sent[data["id"]] = True
-
-                        if camera_config.objects.genai.debug_save_thumbnails:
-                            self._save_debug_thumbnails(data["id"])
-
                         # Copy thumbnails to avoid holding references after cleanup
                         thumbnails_copy = [
                             data["thumbnail"][:] if data.get("thumbnail") else None
@@ -301,7 +297,26 @@ class ObjectDescriptionProcessor(PostProcessorApi):
         )
 
         if camera_config.objects.genai.debug_save_thumbnails and num_thumbnails > 0:
-            self._save_debug_thumbnails(event_id)
+            logger.debug(f"Saving {num_thumbnails} thumbnails for event {event_id}")
+
+            Path(os.path.join(CLIPS_DIR, f"genai-requests/{event_id}")).mkdir(
+                parents=True, exist_ok=True
+            )
+
+            for idx, data in enumerate(self.tracked_events[event_id], 1):
+                jpg_bytes: bytes | None = data["thumbnail"]
+
+                if jpg_bytes is None:
+                    logger.warning(f"Unable to save thumbnail {idx} for {event_id}.")
+                else:
+                    with open(
+                        os.path.join(
+                            CLIPS_DIR,
+                            f"genai-requests/{event_id}/{idx}.jpg",
+                        ),
+                        "wb",
+                    ) as j:
+                        j.write(jpg_bytes)
 
         # Generate the description. Call happens in a thread since it is network bound.
         threading.Thread(
@@ -317,30 +332,6 @@ class ObjectDescriptionProcessor(PostProcessorApi):
         # Clean up tracked events and early request state
         self.cleanup_event(event_id)
 
-    def _save_debug_thumbnails(self, event_id: str) -> None:
-        """Write the tracked thumbnails for an event to the genai-requests dir."""
-        tracked = self.tracked_events.get(event_id, [])
-        logger.debug(f"Saving {len(tracked)} thumbnails for event {event_id}")
-
-        Path(os.path.join(CLIPS_DIR, f"genai-requests/{event_id}")).mkdir(
-            parents=True, exist_ok=True
-        )
-
-        for idx, data in enumerate(tracked, 1):
-            jpg_bytes: bytes | None = data["thumbnail"]
-
-            if jpg_bytes is None:
-                logger.warning(f"Unable to save thumbnail {idx} for {event_id}.")
-            else:
-                with open(
-                    os.path.join(
-                        CLIPS_DIR,
-                        f"genai-requests/{event_id}/{idx}.jpg",
-                    ),
-                    "wb",
-                ) as j:
-                    j.write(jpg_bytes)
-
     def _genai_embed_description(self, event: Event, thumbnails: list[bytes]) -> None:
         """Embed the description for an event."""
         start = datetime.datetime.now().timestamp()

frigate/test/http_api/test_http_users.py

@@ -0,0 +1,33 @@
+"""Tests for user creation."""
+
+from unittest.mock import MagicMock
+
+from frigate.models import User
+from frigate.test.http_api.base_http_test import AuthTestClient, BaseTestHttp
+
+PASSWORD = "a-valid-password-123"
+
+
+class TestCreateUser(BaseTestHttp):
+    def setUp(self):
+        super().setUp([User])
+        self.app = super().create_app()
+        self.app.config_publisher = MagicMock()
+
+    def _create(self, username: str):
+        with AuthTestClient(self.app) as client:
+            return client.post(
+                "/users",
+                json={"username": username, "password": PASSWORD, "role": "viewer"},
+            )
+
+    def test_rejects_dot_only_usernames(self):
+        # browsers resolve these as URL path segments, so the per-user
+        # endpoints can never be reached for them
+        for username in (".", "..", "..."):
+            assert self._create(username).status_code == 400
+            assert User.get_or_none(User.username == username) is None
+
+    def test_accepts_username_containing_dots(self):
+        assert self._create("john.doe_1").status_code == 200
+        assert User.get_or_none(User.username == "john.doe_1") is not None

frigate/test/test_comms_thread_safety.py

@@ -1,193 +0,0 @@
-"""Tests for sharing one zmq socket wrapper across threads."""
-
-import os
-import random
-import tempfile
-import threading
-import time
-import unittest
-from unittest.mock import patch
-
-import zmq
-
-from frigate.comms import config_updater, embeddings_updater, inter_process
-from frigate.comms.config_updater import ConfigPublisher, ConfigSubscriber
-from frigate.comms.embeddings_updater import EmbeddingsRequestor
-from frigate.comms.inter_process import InterProcessRequestor
-from frigate.comms.webpush import WebPushClient
-
-THREADS = 8
-CALLS = 100
-
-# nothing reads until the end, so the total stays under the default zmq HWM
-PUBLISH_CALLS = 100
-
-
-class TestSharedRequestor(unittest.TestCase):
-    def setUp(self) -> None:
-        self.tmp = tempfile.TemporaryDirectory()
-        self.address = f"ipc://{os.path.join(self.tmp.name, 'comms')}"
-        self.stop = threading.Event()
-        self.context = zmq.Context()
-        self.responder = self.context.socket(zmq.REP)
-        self.responder.bind(self.address)
-        self.responder_thread = threading.Thread(target=self._respond)
-        self.responder_thread.start()
-
-    def tearDown(self) -> None:
-        self.stop.set()
-        self.responder_thread.join()
-        self.responder.close(linger=0)
-        self.context.destroy(linger=0)
-        self.tmp.cleanup()
-
-    def _respond(self) -> None:
-        while not self.stop.is_set():
-            ready, _, _ = zmq.select([self.responder], [], [], 0.1)
-
-            if ready:
-                self.responder.recv_json()
-                time.sleep(random.uniform(0, 0.002))
-                self.responder.send_json(["ok"])
-
-    def _call_from_threads(self, requestor) -> list:
-        results: list = []
-
-        def call() -> None:
-            for _ in range(CALLS):
-                # jitter lands some calls on the instant another reply arrives
-                time.sleep(random.uniform(0, 0.002))
-                results.append(requestor.send_data("topic", {"key": "value"}))
-
-        threads = [threading.Thread(target=call, daemon=True) for _ in range(THREADS)]
-
-        for thread in threads:
-            thread.start()
-
-        for thread in threads:
-            thread.join(30)
-
-        self.assertFalse(any(thread.is_alive() for thread in threads))
-        return results
-
-    def test_inter_process_requestor_waits_for_overlapping_calls(self) -> None:
-        with patch.object(inter_process, "SOCKET_REP_REQ", self.address):
-            requestor = InterProcessRequestor()
-
-        results = self._call_from_threads(requestor)
-        self.assertEqual(results, [["ok"]] * THREADS * CALLS)
-        requestor.stop()
-
-    def test_embeddings_requestor_survives_overlapping_calls(self) -> None:
-        with patch.object(embeddings_updater, "SOCKET_REP_REQ", self.address):
-            requestor = EmbeddingsRequestor()
-
-        # an overlapping call may fail fast, but the socket has to stay usable
-        results = self._call_from_threads(requestor)
-        self.assertEqual(len(results), THREADS * CALLS)
-        self.assertEqual(requestor.send_data("topic", {}), ["ok"])
-        requestor.stop()
-
-
-class TestSharedConfigPublisher(unittest.TestCase):
-    def test_frames_stay_paired_across_threads(self) -> None:
-        with tempfile.TemporaryDirectory() as tmp:
-            address = f"ipc://{os.path.join(tmp, 'config')}"
-
-            with patch.object(config_updater, "SOCKET_PUB_SUB", address):
-                publisher = ConfigPublisher()
-                subscriber = ConfigSubscriber("config/")
-
-            # a subscription that is still connecting drops messages
-            subscriber.socket.setsockopt(zmq.RCVTIMEO, 5000)
-
-            while True:
-                publisher.publish("config/ready", None)
-
-                if zmq.select([subscriber.socket], [], [], 0.05)[0]:
-                    break
-
-            def publish(index: int) -> None:
-                topic = f"config/cameras/camera_{index}"
-
-                for _ in range(PUBLISH_CALLS):
-                    publisher.publish(topic, topic)
-
-            threads = [
-                threading.Thread(target=publish, args=(i,)) for i in range(THREADS)
-            ]
-
-            for thread in threads:
-                thread.start()
-
-            for thread in threads:
-                thread.join()
-
-            publisher.publish("config/done", None)
-            received = 0
-
-            while True:
-                topic = subscriber.socket.recv_string()
-                payload = subscriber.socket.recv_pyobj()
-
-                if topic == "config/done":
-                    break
-
-                if topic != "config/ready":
-                    self.assertEqual(topic, payload)
-                    received += 1
-
-            self.assertEqual(received, THREADS * PUBLISH_CALLS)
-            subscriber.stop()
-            publisher.stop()
-
-
-class FakeConfigSubscriber:
-    """Records whether two threads read at the same time."""
-
-    def __init__(self) -> None:
-        self.reading = threading.Lock()
-        self.overlapped = False
-
-    def _read(self) -> None:
-        if not self.reading.acquire(blocking=False):
-            self.overlapped = True
-            return
-
-        time.sleep(0.001)
-        self.reading.release()
-
-    def check_for_update(self) -> tuple[None, None]:
-        self._read()
-        return (None, None)
-
-    def check_for_updates(self) -> dict:
-        self._read()
-        return {}
-
-
-class TestSharedWebPushClient(unittest.TestCase):
-    def test_config_subscribers_read_by_one_thread_at_a_time(self) -> None:
-        client = WebPushClient.__new__(WebPushClient)
-        client.config_lock = threading.Lock()
-        client.global_config_subscriber = FakeConfigSubscriber()
-        client.config_subscriber = FakeConfigSubscriber()
-
-        def publish() -> None:
-            for _ in range(20):
-                client.publish("topic", "payload")
-
-        threads = [threading.Thread(target=publish) for _ in range(THREADS)]
-
-        for thread in threads:
-            thread.start()
-
-        for thread in threads:
-            thread.join()
-
-        self.assertFalse(client.global_config_subscriber.overlapped)
-        self.assertFalse(client.config_subscriber.overlapped)
-
-
-if __name__ == "__main__":
-    unittest.main()

web/public/locales/en/views/settings.json

@@ -1054,6 +1054,7 @@
         "title": "Create New User",
         "desc": "Add a new user account and specify a role for access to areas of the Frigate UI.",
         "usernameOnlyInclude": "Username may only include letters, numbers, . or _",
+        "usernameOnlyDots": "Username cannot contain only periods",
         "confirmPassword": "Please confirm your password"
       },
       "deleteUser": {

web/src/components/overlay/CreateUserDialog.tsx

@@ -82,6 +82,9 @@ export default function CreateUserDialog({
         .min(1, t("users.dialog.form.usernameIsRequired"))
         .regex(/^[A-Za-z0-9._]+$/, {
           message: t("users.dialog.createUser.usernameOnlyInclude"),
+        })
+        .regex(/[^.]/, {
+          message: t("users.dialog.createUser.usernameOnlyDots"),
         }),
       password: z
         .string()