feat: fold ATNToken into RPB as inherited ERC20, deploy to shadownet

RPB now inherits ERC20/ERC20Votes/ERC20Burnable/ERC20Permit — deploying
an RPB gives you the jurisdiction token, agent registry, training
economics, inference accounting, and share system in one contract.

All contracts that referenced ATNToken externally (TaskContract,
ParticipantStaking, InferenceProviderBridge, ForcedErrorRegistry,
GuildRegistry, EvolutionProposal) updated to use RPB directly.
RPBFactory now supports registerRPB() for pre-deployed contracts.

RPB deployed to etherlink-shadownet at:
  0x57F68991572D639D0A1faD43aE86163334368Bf2
  Registry: 0xA2Ec6A1Aa7bd2bfF4f7AFF8d40247F302cFBBb2F

298 tests passing (includes new economic-loop.test.js with full e2e
coverage of alignment-weighted training rewards, share purchases,
dividends, inference pricing independence, and revenue splits).

Author: EightRice

atn/providers/bridge.py

@@ -36,8 +36,16 @@
 
 log = logging.getLogger(__name__)
 
-# Path to the bridge script relative to this file
-_BRIDGE_DIR = Path(__file__).resolve().parent.parent.parent / "bridge"
+# Locate the bridge directory: try importlib first (pip install), then relative path (dev)
+def _find_bridge_dir() -> Path:
+    try:
+        import bridge as _bridge_pkg
+        return Path(_bridge_pkg.__file__).resolve().parent
+    except ImportError:
+        pass
+    return Path(__file__).resolve().parent.parent.parent / "bridge"
+
+_BRIDGE_DIR = _find_bridge_dir()
 _BRIDGE_SCRIPT = _BRIDGE_DIR / "claude-bridge.ts"
 
 
@@ -777,14 +785,38 @@ async def _ensure_process(self) -> None:
         node_modules = self._bridge_script.parent / "node_modules"
         if not node_modules.exists():
             raise ProviderError(
-                f"Bridge dependencies not installed. Run: cd {self._bridge_script.parent} && bun install",
+                f"Bridge dependencies not installed. "
+                f"Run: cd {self._bridge_script.parent} && bun install  (or npm install)",
                 provider="claude_max",
             )
 
         # Fresh queue for new process
         self._event_queue = asyncio.Queue()
 
-        log.info("Spawning bridge: bun run %s", self._bridge_script)
+        # Resolve JS runtime: prefer bun, fall back to node
+        import shutil
+        runtime = shutil.which("bun")
+        runtime_args = ["run", str(self._bridge_script)]
+        if not runtime:
+            runtime = shutil.which("node")
+            if runtime:
+                # node needs the compiled .ts → use tsx or run .ts directly
+                # bun handles .ts natively; for node we need tsx or pre-compiled JS
+                tsx = shutil.which("tsx") or shutil.which("npx")
+                if tsx and "npx" in str(tsx):
+                    runtime_args = ["tsx", str(self._bridge_script)]
+                elif tsx:
+                    runtime = tsx
+                    runtime_args = [str(self._bridge_script)]
+                else:
+                    runtime_args = ["--import", "tsx", str(self._bridge_script)]
+        if not runtime:
+            raise ProviderError(
+                "Neither bun nor node found. Install bun: https://bun.sh/docs/installation",
+                provider="claude_max",
+            )
+
+        log.info("Spawning bridge: %s %s", runtime, " ".join(runtime_args))
 
         kwargs: dict[str, Any] = {}
         if sys.platform == "win32":
@@ -795,7 +827,7 @@ async def _ensure_process(self) -> None:
         env.pop("CLAUDECODE", None)
 
         self._process = await asyncio.create_subprocess_exec(
-            "bun", "run", str(self._bridge_script),
+            runtime, *runtime_args,
             stdin=asyncio.subprocess.PIPE,
             stdout=asyncio.subprocess.PIPE,
             stderr=asyncio.subprocess.PIPE,

atn/runtime/provider_manager.py

@@ -856,7 +856,11 @@ async def _validate_api_key(self, provider_id: str, api_key: str) -> None:
 
     async def _ensure_bridge_deps(self) -> None:
         """Auto-install bridge dependencies (bun install) if missing."""
-        bridge_dir = Path(__file__).resolve().parent.parent.parent / "bridge"
+        try:
+            import bridge as _bridge_pkg
+            bridge_dir = Path(_bridge_pkg.__file__).resolve().parent
+        except ImportError:
+            bridge_dir = Path(__file__).resolve().parent.parent.parent / "bridge"
         pkg_json = bridge_dir / "package.json"
         node_modules = bridge_dir / "node_modules"
         cli_js = node_modules / "@anthropic-ai" / "claude-agent-sdk" / "cli.js"
@@ -868,27 +872,31 @@ async def _ensure_bridge_deps(self) -> None:
             log.warning("Bridge package.json not found at %s", bridge_dir)
             return
 
-        # Check bun is available
+        # Check bun is available; auto-install if missing
         import shutil
         bun = shutil.which("bun")
         if not bun:
-            # Try installing bun via npm
+            bun = await self._auto_install_bun()
+        if not bun:
+            # Fall back to npm if available
             npm = shutil.which("npm")
             if npm:
-                log.info("Installing bun via npm...")
+                log.info("bun not available, falling back to npm install...")
                 try:
                     proc = await asyncio.create_subprocess_exec(
-                        npm, "install", "-g", "bun",
+                        npm, "install",
+                        cwd=str(bridge_dir),
                         stdout=asyncio.subprocess.PIPE,
                         stderr=asyncio.subprocess.PIPE,
                     )
-                    await asyncio.wait_for(proc.communicate(), timeout=120)
-                    bun = shutil.which("bun")
+                    stdout, stderr = await asyncio.wait_for(proc.communicate(), timeout=120)
+                    if proc.returncode == 0:
+                        log.info("Bridge dependencies installed via npm")
+                    return
                 except Exception as e:
-                    log.warning("Failed to install bun: %s", e)
-
-        if not bun:
-            log.warning("bun not found — cannot auto-install bridge dependencies")
+                    log.warning("npm install failed: %s", e)
+            log.warning("Neither bun nor npm found — cannot auto-install bridge dependencies. "
+                        "Install bun: https://bun.sh/docs/installation")
             return
 
         # Run bun install in the bridge directory
@@ -911,8 +919,51 @@ async def _ensure_bridge_deps(self) -> None:
         except Exception as e:
             log.warning("Failed to install bridge dependencies: %s", e)
 
+    async def _auto_install_bun(self) -> str | None:
+        """Download and install bun without requiring npm/node."""
+        import shutil
+        import sys
+
+        log.info("bun not found — attempting automatic install...")
+        try:
+            if sys.platform == "win32":
+                # PowerShell one-liner from bun.sh
+                proc = await asyncio.create_subprocess_exec(
+                    "powershell", "-Command",
+                    "irm bun.sh/install.ps1 | iex",
+                    stdout=asyncio.subprocess.PIPE,
+                    stderr=asyncio.subprocess.PIPE,
+                )
+            else:
+                # Unix: curl | bash
+                proc = await asyncio.create_subprocess_shell(
+                    "curl -fsSL https://bun.sh/install | bash",
+                    stdout=asyncio.subprocess.PIPE,
+                    stderr=asyncio.subprocess.PIPE,
+                )
+            await asyncio.wait_for(proc.communicate(), timeout=120)
+            if proc.returncode == 0:
+                # Bun installs to ~/.bun/bin — refresh PATH
+                bun_bin = Path.home() / ".bun" / "bin"
+                if bun_bin.exists():
+                    os.environ["PATH"] = str(bun_bin) + os.pathsep + os.environ.get("PATH", "")
+                bun = shutil.which("bun")
+                if bun:
+                    log.info("bun installed successfully: %s", bun)
+                    return bun
+            log.warning("bun install script exited with code %s", proc.returncode)
+        except asyncio.TimeoutError:
+            log.warning("bun install timed out")
+        except Exception as e:
+            log.warning("Failed to auto-install bun: %s", e)
+        return None
+
     def _resolve_sdk_cli(self) -> Path | None:
-        bridge_dir = Path(__file__).resolve().parent.parent.parent / "bridge"
+        try:
+            import bridge as _bridge_pkg
+            bridge_dir = Path(_bridge_pkg.__file__).resolve().parent
+        except ImportError:
+            bridge_dir = Path(__file__).resolve().parent.parent.parent / "bridge"
         cli_js = bridge_dir / "node_modules" / "@anthropic-ai" / "claude-agent-sdk" / "cli.js"
         if cli_js.exists():
             return cli_js

bridge/__init__.py

@@ -0,0 +1 @@
+# Bridge package — TypeScript source shipped as package data.

contracts/bridge/InferenceProviderBridge.sol

@@ -4,7 +4,6 @@ pragma solidity ^0.8.20;
 import "../interfaces/IInferenceProvider.sol";
 import "../core/RPB.sol";
 import "../core/ParticipantStaking.sol";
-import "../tokens/ATNToken.sol";
 import "../utils/AutonetLib.sol";
 import "@openzeppelin/contracts/access/Ownable.sol";
 import "@openzeppelin/contracts/utils/ReentrancyGuard.sol";
@@ -23,7 +22,7 @@ import "@openzeppelin/contracts/utils/ReentrancyGuard.sol";
  *      - Spot-check triggered: payment staged, verifier reviews output
  *      - No spot-check (93%): immediate provider payout
  *   6. On completion, bridge mints ATN to provider from burn pool
- *      (requires this contract is an authorized minter on ATNToken)
+ *      (requires this contract is an authorized minter on RPB)
  *   7. PROTOCOL_FEE_BPS is retained as jackpot pool for verification rewards
  *
  * Key design decisions:
@@ -34,7 +33,6 @@ import "@openzeppelin/contracts/utils/ReentrancyGuard.sol";
  */
 contract InferenceProviderBridge is IInferenceProvider, Ownable, ReentrancyGuard {
     RPB public immutable rpb;
-    ATNToken public immutable atnToken;
     ParticipantStaking public immutable staking;
 
     // ============ BME Economics Parameters ============
@@ -115,7 +113,6 @@ contract InferenceProviderBridge is IInferenceProvider, Ownable, ReentrancyGuard
     ) Ownable(_owner) {
         rpb = RPB(_rpb);
         staking = ParticipantStaking(_staking);
-        atnToken = rpb.atnToken();
     }
 
     // ============ Admin Functions ============
@@ -172,7 +169,7 @@ contract InferenceProviderBridge is IInferenceProvider, Ownable, ReentrancyGuard
 
         // BME Step 1: Burn ATN from user immediately
         // No token holds — tokens are destroyed, provider gets fresh minted tokens
-        atnToken.burnFrom(msg.sender, fee);
+        rpb.burnFrom(msg.sender, fee);
         totalBurned += fee;
 
         // Split: provider amount vs protocol fee (goes to jackpot pool)
@@ -341,7 +338,7 @@ contract InferenceProviderBridge is IInferenceProvider, Ownable, ReentrancyGuard
             // Award jackpot to the verifier (msg.sender)
             if (jackpotPool >= verificationJackpotAmount) {
                 jackpotPool -= verificationJackpotAmount;
-                atnToken.mint(msg.sender, verificationJackpotAmount);
+                rpb.mint(msg.sender, verificationJackpotAmount);
                 emit JackpotAwarded(msg.sender, verificationJackpotAmount);
             }
 
@@ -382,7 +379,7 @@ contract InferenceProviderBridge is IInferenceProvider, Ownable, ReentrancyGuard
      *      Then calls rpb.recordInferenceBME() to update RPB accounting so
      *      shareholders can claim dividends.
      *
-     *      Requires this contract is an authorized minter on ATNToken and an
+     *      Requires this contract is an authorized minter on RPB and an
      *      authorized disburser on RPB.
      */
     function _settleInference(
@@ -402,13 +399,13 @@ contract InferenceProviderBridge is IInferenceProvider, Ownable, ReentrancyGuard
 
         // Mint to each recipient
         if (providerPayment > 0) {
-            atnToken.mint(provider, providerPayment);
+            rpb.mint(provider, providerPayment);
         }
         if (treasuryPayment > 0) {
-            atnToken.mint(rpb.dao(), treasuryPayment);
+            rpb.mint(rpb.dao(), treasuryPayment);
         }
         if (shareholderPayment > 0) {
-            atnToken.mint(address(rpb), shareholderPayment);
+            rpb.mint(address(rpb), shareholderPayment);
         }
 
         // Update RPB accounting for dividend tracking

contracts/core/ForcedErrorRegistry.sol

@@ -3,7 +3,7 @@ pragma solidity ^0.8.20;
 
 import "../utils/AutonetLib.sol";
 import "./ParticipantStaking.sol";
-import "../tokens/ATNToken.sol";
+import "./RPB.sol";
 
 /**
  * @title ForcedErrorRegistry
@@ -19,7 +19,7 @@ import "../tokens/ATNToken.sol";
  * might rubber-stamp everything since real errors are rare.
  */
 contract ForcedErrorRegistry {
-    ATNToken public immutable atnToken;
+    RPB public immutable rpb;
     ParticipantStaking public immutable staking;
     address public governance;
 
@@ -61,8 +61,8 @@ contract ForcedErrorRegistry {
 
     // ============ Constructor ============
 
-    constructor(address _atnToken, address _staking, address _governance) {
-        atnToken = ATNToken(_atnToken);
+    constructor(address _rpb, address _staking, address _governance) {
+        rpb = RPB(_rpb);
         staking = ParticipantStaking(_staking);
         governance = _governance;
     }
@@ -73,7 +73,7 @@ contract ForcedErrorRegistry {
      * @dev Fund the jackpot pool. Anyone can contribute.
      */
     function fundJackpotPool(uint256 _amount) external {
-        require(atnToken.transferFrom(msg.sender, address(this), _amount), "Transfer failed");
+        require(rpb.transferFrom(msg.sender, address(this), _amount), "Transfer failed");
         jackpotPool += _amount;
         emit JackpotFunded(msg.sender, _amount);
     }
@@ -146,7 +146,7 @@ contract ForcedErrorRegistry {
 
         // Award jackpot (already reserved from pool during injection)
         uint256 award = fe.jackpotAmount;
-        require(atnToken.transfer(msg.sender, award), "Jackpot transfer failed");
+        require(rpb.transfer(msg.sender, award), "Jackpot transfer failed");
 
         emit ForcedErrorCaught(_taskId, msg.sender, award);
     }

contracts/core/ParticipantStaking.sol

@@ -1,7 +1,7 @@
 // SPDX-License-Identifier: MIT
 pragma solidity ^0.8.20;
 
-import "../tokens/ATNToken.sol";
+import "./RPB.sol";
 import "../utils/AutonetLib.sol";
 
 /**
@@ -12,7 +12,7 @@ import "../utils/AutonetLib.sol";
 contract ParticipantStaking {
     using AutonetLib for AutonetLib.ParticipantRole;
 
-    ATNToken public immutable atnToken;
+    RPB public immutable rpb;
     address public governance;
 
     mapping(address => AutonetLib.StakeInfo) public stakes;
@@ -39,12 +39,12 @@ contract ParticipantStaking {
         _;
     }
 
-    constructor(address _atnToken, address _governance) {
-        atnToken = ATNToken(_atnToken);
+    constructor(address _rpb, address _governance) {
+        rpb = RPB(_rpb);
         governance = _governance;
 
         // Default minimum stakes (in wei)
-        uint8 decimals = atnToken.decimals();
+        uint8 decimals = rpb.decimals();
         minStakeAmount[AutonetLib.ParticipantRole.PROPOSER] = 100 * (10**decimals);
         minStakeAmount[AutonetLib.ParticipantRole.SOLVER] = 50 * (10**decimals);
         minStakeAmount[AutonetLib.ParticipantRole.COORDINATOR] = 500 * (10**decimals);
@@ -93,7 +93,7 @@ contract ParticipantStaking {
             active: true
         });
 
-        require(atnToken.transferFrom(msg.sender, address(this), _amount), "Transfer failed");
+        require(rpb.transferFrom(msg.sender, address(this), _amount), "Transfer failed");
         emit Staked(msg.sender, _role, _amount);
     }
 
@@ -103,7 +103,7 @@ contract ParticipantStaking {
         require(userStake.lockupUntil == 0, "Unstake in progress");
 
         userStake.amount += _amount;
-        require(atnToken.transferFrom(msg.sender, address(this), _amount), "Transfer failed");
+        require(rpb.transferFrom(msg.sender, address(this), _amount), "Transfer failed");
         emit Staked(msg.sender, userStake.role, _amount);
     }
 
@@ -130,7 +130,7 @@ contract ParticipantStaking {
         userStake.role = AutonetLib.ParticipantRole.NONE;
         userStake.lockupUntil = 0;
 
-        require(atnToken.transfer(msg.sender, amount), "Transfer failed");
+        require(rpb.transfer(msg.sender, amount), "Transfer failed");
         emit Unstaked(msg.sender, role, amount);
     }
 
@@ -142,7 +142,7 @@ contract ParticipantStaking {
         userStake.amount -= _amount;
 
         // Burn slashed tokens so they don't stay locked in the contract
-        atnToken.burn(_amount);
+        rpb.burn(_amount);
 
         emit Slashed(_participant, userStake.role, _amount, _reason);