[kimi] Fix GITEA_API configuration in triage scripts (#951) (#994)

src/infrastructure/world/adapters/mock.py

@@ -7,7 +7,7 @@ without a running game server.
 from __future__ import annotations
 
 import logging
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from datetime import UTC, datetime
 
 from infrastructure.world.interface import WorldInterface
@@ -81,9 +81,7 @@ class MockWorldAdapter(WorldInterface):
 
     def act(self, command: CommandInput) -> ActionResult:
         logger.debug("MockWorldAdapter.act(%s)", command.action)
-        self.action_log.append(
-            _ActionLog(command=command, timestamp=datetime.now(UTC))
-        )
+        self.action_log.append(_ActionLog(command=command, timestamp=datetime.now(UTC)))
         return ActionResult(
             status=ActionStatus.SUCCESS,
             message=f"Mock executed: {command.action}",
@@ -92,8 +90,10 @@ class MockWorldAdapter(WorldInterface):
 
     def speak(self, message: str, target: str | None = None) -> None:
         logger.debug("MockWorldAdapter.speak(%r, target=%r)", message, target)
-        self.speech_log.append({
-            "message": message,
-            "target": target,
-            "timestamp": datetime.now(UTC).isoformat(),
-        })
+        self.speech_log.append(
+            {
+                "message": message,
+                "target": target,
+                "timestamp": datetime.now(UTC).isoformat(),
+            }
+        )

src/infrastructure/world/adapters/tes3mp.py

@@ -35,14 +35,10 @@ class TES3MPWorldAdapter(WorldInterface):
     # -- lifecycle ---------------------------------------------------------
 
     def connect(self) -> None:
-        raise NotImplementedError(
-            "TES3MPWorldAdapter.connect() — wire up TES3MP server socket"
-        )
+        raise NotImplementedError("TES3MPWorldAdapter.connect() — wire up TES3MP server socket")
 
     def disconnect(self) -> None:
-        raise NotImplementedError(
-            "TES3MPWorldAdapter.disconnect() — close TES3MP server socket"
-        )
+        raise NotImplementedError("TES3MPWorldAdapter.disconnect() — close TES3MP server socket")
 
     @property
     def is_connected(self) -> bool:
@@ -51,9 +47,7 @@ class TES3MPWorldAdapter(WorldInterface):
     # -- core contract (stubs) ---------------------------------------------
 
     def observe(self) -> PerceptionOutput:
-        raise NotImplementedError(
-            "TES3MPWorldAdapter.observe() — poll TES3MP for player/NPC state"
-        )
+        raise NotImplementedError("TES3MPWorldAdapter.observe() — poll TES3MP for player/NPC state")
 
     def act(self, command: CommandInput) -> ActionResult:
         raise NotImplementedError(
@@ -61,6 +55,4 @@ class TES3MPWorldAdapter(WorldInterface):
         )
 
     def speak(self, message: str, target: str | None = None) -> None:
-        raise NotImplementedError(
-            "TES3MPWorldAdapter.speak() — send chat message via TES3MP"
-        )
+        raise NotImplementedError("TES3MPWorldAdapter.speak() — send chat message via TES3MP")

src/infrastructure/world/interface.py

@@ -27,14 +27,14 @@ class WorldInterface(ABC):
 
     # -- lifecycle (optional overrides) ------------------------------------
 
-    def connect(self) -> None:
+    def connect(self) -> None:  # noqa: B027
         """Establish connection to the game world.
 
         Default implementation is a no-op.  Override to open sockets,
         authenticate, etc.
         """
 
-    def disconnect(self) -> None:
+    def disconnect(self) -> None:  # noqa: B027
         """Tear down the connection.
 
         Default implementation is a no-op.

src/infrastructure/world/types.py

@@ -10,10 +10,10 @@ from __future__ import annotations
 
 from dataclasses import dataclass, field
 from datetime import UTC, datetime
-from enum import Enum
+from enum import StrEnum
 
 
-class ActionStatus(str, Enum):
+class ActionStatus(StrEnum):
     """Outcome of an action dispatched to the world."""
 
     SUCCESS = "success"

src/loop/heartbeat.py

@@ -17,7 +17,7 @@ from __future__ import annotations
 import asyncio
 import logging
 import time
-from dataclasses import asdict, dataclass, field
+from dataclasses import dataclass, field
 from datetime import UTC, datetime
 
 from loop.phase1_gather import gather
@@ -32,6 +32,7 @@ logger = logging.getLogger(__name__)
 # Cycle log entry
 # ---------------------------------------------------------------------------
 
+
 @dataclass
 class CycleRecord:
     """One observe → reason → act → reflect cycle."""
@@ -50,6 +51,7 @@ class CycleRecord:
 # Heartbeat
 # ---------------------------------------------------------------------------
 
+
 class Heartbeat:
     """Manages the recurring cognitive loop with optional world adapter.
 
@@ -268,14 +270,17 @@ class Heartbeat:
         try:
             from infrastructure.ws_manager.handler import ws_manager
 
-            await ws_manager.broadcast("heartbeat.cycle", {
-                "cycle_id": record.cycle_id,
-                "timestamp": record.timestamp,
-                "action": record.action_taken,
-                "action_status": record.action_status,
-                "reasoning_summary": record.reasoning_summary[:300],
-                "observation": record.observation,
-                "duration_ms": record.duration_ms,
-            })
+            await ws_manager.broadcast(
+                "heartbeat.cycle",
+                {
+                    "cycle_id": record.cycle_id,
+                    "timestamp": record.timestamp,
+                    "action": record.action_taken,
+                    "action_status": record.action_status,
+                    "reasoning_summary": record.reasoning_summary[:300],
+                    "observation": record.observation,
+                    "duration_ms": record.duration_ms,
+                },
+            )
         except (ImportError, AttributeError, ConnectionError, RuntimeError) as exc:
             logger.debug("Heartbeat broadcast skipped: %s", exc)