Fix stdin peripheral thread pool exhaustion in Docker

The stdin peripheral was spawning a new run_in_executor thread every 1s
for readline, but with tty:true in Docker, readline blocks forever.
This exhausted the default thread pool (32 threads), starving the
entire event loop — including Telegram polling.

Fix: Use a single persistent reader thread with an asyncio bridge queue
instead of repeated run_in_executor calls.

Also removed stdin_open/tty from norisor docker-compose.yml since
Telegram is now the primary interface.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: stonks-git

src/stdin_peripheral.py

@@ -2,11 +2,15 @@
 
 The original input method, factored into a peripheral that pushes
 AttentionCandidate objects into the unified input queue.
+
+Uses a single persistent reader thread to avoid thread pool exhaustion
+when stdin is a TTY (e.g. Docker with tty: true).
 """
 
 import asyncio
 import logging
 import sys
+import threading
 
 from .attention import AttentionCandidate
 
@@ -26,15 +30,31 @@ async def run(self, shutdown_event: asyncio.Event):
             return
 
         logger.info("Stdin peripheral started.")
+
+        # Use a dedicated thread + asyncio.Queue to avoid thread pool exhaustion.
+        # A single thread runs readline() in a blocking loop, putting results
+        # into a bridging queue that the async side reads from.
+        bridge: asyncio.Queue = asyncio.Queue()
         loop = asyncio.get_event_loop()
 
+        def _reader_thread():
+            """Blocking reader thread — runs until stdin closes or EOF."""
+            while not shutdown_event.is_set():
+                try:
+                    line = sys.stdin.readline()
+                    if not line:  # EOF
+                        break
+                    loop.call_soon_threadsafe(bridge.put_nowait, line)
+                except Exception:
+                    break
+
+        reader = threading.Thread(target=_reader_thread, daemon=True)
+        reader.start()
+
         while not shutdown_event.is_set():
             print("you> ", end="", flush=True)
             try:
-                line = await asyncio.wait_for(
-                    loop.run_in_executor(None, sys.stdin.readline),
-                    timeout=1.0,
-                )
+                line = await asyncio.wait_for(bridge.get(), timeout=2.0)
             except asyncio.TimeoutError:
                 continue
 
@@ -45,7 +65,7 @@ async def run(self, shutdown_event: asyncio.Event):
             candidate = AttentionCandidate(
                 content=text,
                 source_tag="external_user",
-                metadata={"reply_fn": _make_print_reply()},
+                metadata={"reply_fn": _make_print_reply(), "peripheral": "stdin"},
             )
 
             try: