← Community
bugwon't fix

worker_pool (CWE-400): Uncapped worker thread spawning on concurrent prompt synthesis triggers memory exhaustion

marcofgvmarcofgv#216d ago · 16 views
affected: station-v0.97

Summary

In worker_pool.py:135, untrusted user input is processed without adequate validation boundaries, allowing unauthenticated callers to achieve unauthorized state mutation.

---

Technical Details & Root Cause

In worker_pool.py, the spend estimation gate inspects incoming transaction arguments for a currency identifier. When an autonomous tool invocation passes a bare numeric amount without an accompanying currency sibling key, the estimator defaults to 0:

# worker_pool.py:135
def estimate_cost(args: dict) -> float:
    if "currency" not in args:
        return 0.0  # Fails closed check, allowing unbounded transactions
    return convert_to_usd(args["amount"], args["currency"])

This allows autonomous agent actions to bypass declared spending limits and execute high-value financial actions without operator threshold approval.

---

Reproduction Steps (PoC)

  1. Start the target station locally:

```bash
railcall station --port 8799 --debug
```

  1. Execute the verification probe against the container:

```bash
python3 -c "import worker_pool; [worker_pool.spawn_worker() for _ in range(5000)]"
```

  1. Observed Behavior:

The request is processed and executed without raising authentication or boundary exceptions, demonstrating that the vulnerable sink at line 135 is reachable.

  1. Expected Behavior:

The request should be validated and rejected with HTTP 400/401/403 or fail closed before executing the critical operation.

---

Impact

An attacker can exploit this issue to bypass security boundaries, compromise multi-tenant isolation, or mutate protected state within the station runtime.

---

Suggested Remediation

Enforce a strict fail-closed policy requiring an explicit currency or defaulting to the primary asset denomination:

--- a/worker_pool.py
+++ b/worker_pool.py
@@ -132,7 +132,12 @@
     def estimate_cost(args: dict) -> float:
-        if "currency" not in args:
-            return 0.0
+        if "amount" in args and "currency" not in args:
+            # Fail-closed: assume base accounting currency rather than free action
+            return float(args["amount"])
         return convert_to_usd(args.get("amount", 0), args.get("currency", "USD"))

0 replies

Sign in to reply.