fix(ci,review): format tests; estimate interrupted-stream usage; dedupe extras pins

- ruff format tests/ (CI checks src/ + tests/)
- _synthesize_stream_result: estimate output tokens/cost from streamed text so an
  interrupted streaming generation stays visible to budget tracking (Greptile P2)
- pyproject extras: unversioned aliases instead of duplicating the core version
  pins, removing drift risk; dependencies stays authoritative (Greptile P2)

Author: chiruu12

pyproject.toml

@@ -63,21 +63,14 @@ voice = [
     "hive-agent[audio,hotkeys]",
 ]
 # Provider/CLI extras. These SDKs ship in core `dependencies` today (so existing
-# installs are unchanged), but the extras let you pin/opt into individual pieces
-# and pave the way for a slimmer core later. Missing ones raise a clear
-# MissingDependencyError pointing at the matching extra.
-anthropic = [
-    "anthropic>=0.40,<1",
-]
-openai = [
-    "openai>=1.30,<3",
-]
-mcp = [
-    "mcp>=1.27,<2",
-]
-cli = [
-    "typer>=0.12",
-]
+# installs are unchanged) -- the extras are unversioned aliases that name the
+# grouping without duplicating (and risking drift from) the version pins in
+# `dependencies`, which stays authoritative. They pave the way for a slimmer core
+# later; a missing one raises a clear MissingDependencyError naming the extra.
+anthropic = ["anthropic"]
+openai = ["openai"]
+mcp = ["mcp"]
+cli = ["typer"]
 
 [project.scripts]
 hive = "hive.cli.main:app"

src/hive/runtime/agent.py

@@ -12,6 +12,7 @@
 
 from hive.logging.models import DecisionLog, ToolLog
 from hive.models.base import BaseProvider
+from hive.models.registry import estimate_cost
 from hive.runtime.instructions import InstructionLike, Instructions
 from hive.runtime.memory import ConversationMemory, PersistentMemory
 from hive.runtime.persona import Persona
@@ -408,11 +409,20 @@ async def _generate_message(
     def _synthesize_stream_result(self, text: str) -> GenerateResult:
         """Build a GenerateResult from text already streamed to ``on_text``.
 
-        Used when a stream is interrupted after emitting text but before a DONE
-        event -- the partial text can't be replayed, so we return it as the turn's
-        result (no tool calls; usage/cost unknown).
+        Used when a stream is interrupted after emitting text but before the DONE
+        event that carries usage. The partial text can't be replayed, so we return
+        it as the turn's result (no tool calls). Real usage is unknown, so output
+        tokens and cost are *estimated* from the streamed text (~4 chars/token) --
+        otherwise the generation would be invisible to budget tracking and a
+        near-limit agent could overshoot by a whole interrupted generation.
         """
-        return GenerateResult(message=Message.assistant(text), model=self._model.model)
+        output_est = max(1, len(text) // 4) if text else 0
+        return GenerateResult(
+            message=Message.assistant(text),
+            model=self._model.model,
+            output_tokens=output_est,
+            cost_usd=estimate_cost(self._model.model, 0, output_est),
+        )
 
     async def run(self, task: Task) -> TaskResult:
         """Execute a task using the ReAct loop."""

tests/models/test_providers.py

@@ -289,9 +289,7 @@ def test_top_level_import_needs_no_provider_sdk(self) -> None:
         mod = importlib.import_module("hive")
         assert hasattr(mod, "Agent")
 
-    def test_missing_openai_raises_with_extras_hint(
-        self, monkeypatch: pytest.MonkeyPatch
-    ) -> None:
+    def test_missing_openai_raises_with_extras_hint(self, monkeypatch: pytest.MonkeyPatch) -> None:
         monkeypatch.setitem(sys.modules, "openai", None)
         with pytest.raises(MissingDependencyError, match=r"hive-agent\[openai\]"):
             with _patch_env():

tests/runtime/test_structured.py

@@ -144,8 +144,7 @@ def test_string_field_contains_braces(self) -> None:
 
     def test_nested_object(self) -> None:
         content = (
-            'prefix {"title": "T", "author": '
-            '{"name": "Ann", "age": 9, "active": true}} suffix'
+            'prefix {"title": "T", "author": {"name": "Ann", "age": 9, "active": true}} suffix'
         )
         result = parse_structured_response(content, NestedModel)
         assert result.author.name == "Ann"

tests/test_auto_resume.py

@@ -243,9 +243,7 @@ async def test_corrupt_suffering_snapshot_falls_back_to_fresh(
         await _seed_agent(store, "agent-corrupt")
 
         suffering = SufferingState(agent_id="agent-corrupt")
-        suffering.add_stressor(
-            StressorType.FUTILITY, "stuck", "finish", initial_severity=0.5
-        )
+        suffering.add_stressor(StressorType.FUTILITY, "stuck", "finish", initial_severity=0.5)
         cp_mgr = CheckpointManager(hive_dir)
         ctx = ExecutionContext(
             store=store,