Scottcjn · kuanglaodi2-sudo · Mar 14, 2026 · Mar 18, 2026
diff --git a/docs/DEVELOPER_TRACTION_Q1_2026.md b/docs/DEVELOPER_TRACTION_Q1_2026.md
diff --git a/docs/RIP-305-cross-chain-airdrop.md b/docs/RIP-305-cross-chain-airdrop.md
diff --git a/ergo-anchor/rustchain_ergo_anchor.py b/ergo-anchor/rustchain_ergo_anchor.py
diff --git a/miners/clawrtc/pow_miners.py b/miners/clawrtc/pow_miners.py
diff --git a/miners/linux/rustchain_living_museum.py b/miners/linux/rustchain_living_museum.py
diff --git a/miners/linux/warthog_sidecar.py b/miners/linux/warthog_sidecar.py
diff --git a/miners/macos/intel/rustchain_mac_miner_v2.4.py b/miners/macos/intel/rustchain_mac_miner_v2.4.py
diff --git a/miners/macos/rustchain_mac_miner_v2.4.py b/miners/macos/rustchain_mac_miner_v2.4.py
diff --git a/miners/macos/rustchain_mac_miner_v2.5.py b/miners/macos/rustchain_mac_miner_v2.5.py
diff --git a/miners/power8/fingerprint_checks_power8.py b/miners/power8/fingerprint_checks_power8.py
diff --git a/miners/power8/rustchain_power8_miner.py b/miners/power8/rustchain_power8_miner.py
diff --git a/node/arch_cross_validation.py b/node/arch_cross_validation.py
diff --git a/node/beacon_x402.py b/node/beacon_x402.py
diff --git a/node/rip_200_round_robin_1cpu1vote_v2.py b/node/rip_200_round_robin_1cpu1vote_v2.py
diff --git a/node/rom_clustering_server.py b/node/rom_clustering_server.py
diff --git a/node/rom_fingerprint_db.py b/node/rom_fingerprint_db.py
diff --git a/node/rustchain_bft_consensus.py b/node/rustchain_bft_consensus.py
diff --git a/node/rustchain_block_producer.py b/node/rustchain_block_producer.py
diff --git a/node/rustchain_ergo_anchor.py b/node/rustchain_ergo_anchor.py
diff --git a/node/rustchain_hardware_database.py b/node/rustchain_hardware_database.py
diff --git a/node/rustchain_migration.py b/node/rustchain_migration.py
diff --git a/node/rustchain_p2p_gossip.py b/node/rustchain_p2p_gossip.py
diff --git a/node/rustchain_tx_handler.py b/node/rustchain_tx_handler.py
@@ -6341,3 +6341,100 @@ def check_hardware_wallet_consistency(hardware_id, miner_wallet, conn):
             return False, f'hardware_bound_to_different_wallet:{bound_wallet[:20]}'
 
     return True, 'ok'
+
+
+
+# === WALLET HISTORY ENDPOINT (Bounty #908) ===
+@app.route('/wallet/history', methods=['GET'])
+def get_wallet_history():
+    '''
+    Get transaction history for a given wallet/miner ID.
+
+    Query params:
+        - miner_id: Wallet/miner ID to query
+        - limit: Number of transactions to return (default: 50)
+        - offset: Offset for pagination (default: 0)
+
+    Returns:
+        JSON with transaction history including rewards and transfers
+    '''
+    miner_id = request.args.get('miner_id')
+    limit = int(request.args.get('limit', 50))
+    offset = int(request.args.get('offset', 0))
+
+    if not miner_id:
+        return jsonify({'ok': False, 'error': 'miner_id is required'}), 400
+
+    try:
+        transactions = []
+
+        # Query epoch_rewards for mining rewards
+        c = conn.cursor()
+        c.execute('''
+            SELECT 'reward' as type, amount, epoch, timestamp, tx_hash
+            FROM epoch_rewards 
+            WHERE miner_id = ?
+            ORDER BY epoch DESC
+            LIMIT ? OFFSET ?
+        ''', (miner_id, limit, offset))
+
+        for row in c.fetchall():
+            transactions.append({
+                'type': 'reward',
+                'amount': row[0],
+                'epoch': row[1],
+                'timestamp': row[2],
+                'tx_hash': row[3]
+            })
+
+        # Query ledger for transfers
+        c.execute('''
+            SELECT 'transfer_in' as type, from_wallet, amount, timestamp, tx_hash
+            FROM ledger 
+            WHERE to_wallet = ?
+            ORDER BY timestamp DESC
+            LIMIT ? OFFSET ?
+        ''', (miner_id, limit, offset))
+
+        for row in c.fetchall():
+            transactions.append({
+                'type': 'transfer_in',
+                'from': row[1],
+                'amount': row[2],
+                'timestamp': row[3],
+                'tx_hash': row[4]
+            })
+
+        c.execute('''
+            SELECT 'transfer_out' as type, to_wallet, amount, timestamp, tx_hash
+            FROM ledger 
+            WHERE from_wallet = ?
+            ORDER BY timestamp DESC
+            LIMIT ? OFFSET ?
+        ''', (miner_id, limit, offset))
+
+        for row in c.fetchall():
+            transactions.append({
+                'type': 'transfer_out',
+                'to': row[1],
+                'amount': row[2],
+                'timestamp': row[3],
+                'tx_hash': row[4]
+            })
+
+        # Sort by timestamp descending
+        transactions.sort(key=lambda x: x.get('timestamp', ''), reverse=True)
+
+        # Get total count
+        c.execute('SELECT COUNT(*) FROM epoch_rewards WHERE miner_id = ?', (miner_id,))
+        total = c.fetchone()[0]
+
+        return jsonify({
+            'ok': True,
+            'miner_id': miner_id,
+            'transactions': transactions[:limit],
+            'total': total
+        })
+
+    except Exception as e:
+        return jsonify({'ok': False, 'error': str(e)}), 500
diff --git a/node/rustchain_x402.py b/node/rustchain_x402.py
@@ -1,114 +1,114 @@
-"""
-RustChain x402 Integration — Swap Info + Coinbase Wallet Linking
-Adds /wallet/swap-info and /wallet/link-coinbase endpoints.
-
-Usage in rustchain server:
-    import rustchain_x402
-    rustchain_x402.init_app(app, DB_PATH)
-"""
-
-import logging
-import os
-import sqlite3
-import time
-
-from flask import jsonify, request
-
-log = logging.getLogger("rustchain.x402")
-
-# Import shared config
-try:
-    import sys
-    sys.path.insert(0, "/root/shared")
-    from x402_config import SWAP_INFO, WRTC_BASE, USDC_BASE, AERODROME_POOL
-    X402_CONFIG_OK = True
-except ImportError:
-    log.warning("x402_config not found — using inline swap info")
-    X402_CONFIG_OK = False
-    SWAP_INFO = {
-        "wrtc_contract": "0x5683C10596AaA09AD7F4eF13CAB94b9b74A669c6",
-        "usdc_contract": "0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913",
-        "aerodrome_pool": "0x4C2A0b915279f0C22EA766D58F9B815Ded2d2A3F",
-        "swap_url": "https://aerodrome.finance/swap?from=0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913&to=0x5683C10596AaA09AD7F4eF13CAB94b9b74A669c6",
-        "network": "Base (eip155:8453)",
-        "reference_price_usd": 0.10,
-    }
-
-
-COINBASE_MIGRATION = "ALTER TABLE balances ADD COLUMN coinbase_address TEXT DEFAULT NULL"
-
-
-def _run_migration(db_path):
-    """Add coinbase_address column to balances if missing."""
-    conn = sqlite3.connect(db_path)
-    cursor = conn.execute("PRAGMA table_info(balances)")
-    existing = {row[1] for row in cursor.fetchall()}
-    if "coinbase_address" not in existing:
-        try:
-            conn.execute(COINBASE_MIGRATION)
-            conn.commit()
-            log.info("Added coinbase_address column to balances")
-        except sqlite3.OperationalError:
-            pass
-    conn.close()
-
-
-def init_app(app, db_path):
-    """Register x402 routes on the RustChain Flask app."""
-
-    try:
-        _run_migration(db_path)
-    except Exception as e:
-        log.error(f"RustChain x402 migration failed: {e}")
-
-    @app.route("/wallet/swap-info", methods=["GET"])
-    def wallet_swap_info():
-        """Returns Aerodrome pool info for USDC→wRTC swap guidance."""
-        return jsonify(SWAP_INFO)
-
-    @app.route("/wallet/link-coinbase", methods=["PATCH", "POST"])
-    def wallet_link_coinbase():
-        """Link a Coinbase Base address to a miner_id. Requires admin key."""
-        admin_key = request.headers.get("X-Admin-Key", "") or request.headers.get("X-API-Key", "")
-        expected = os.environ.get("RC_ADMIN_KEY", "rustchain_admin_key_2025_secure64")
-        if admin_key != expected:
-            return jsonify({"error": "Unauthorized — admin key required"}), 401
-
-        data = request.get_json(silent=True) or {}
-        miner_id = data.get("miner_id", "").strip()
-        coinbase_address = data.get("coinbase_address", "").strip()
-
-        if not miner_id:
-            return jsonify({"error": "miner_id is required"}), 400
-        if not coinbase_address or not coinbase_address.startswith("0x") or len(coinbase_address) != 42:
-            return jsonify({"error": "Invalid Base address (must be 0x + 40 hex chars)"}), 400
-
-        conn = sqlite3.connect(db_path)
-        row = conn.execute(
-            "SELECT miner_id FROM balances WHERE miner_id = ?", (miner_id,)
-        ).fetchone()
-        if not row:
-            # Try miner_pk
-            row = conn.execute(
-                "SELECT miner_id FROM balances WHERE miner_pk = ?", (miner_id,)
-            ).fetchone()
-        if not row:
-            conn.close()
-            return jsonify({"error": f"Miner '{miner_id}' not found in balances"}), 404
-
-        actual_id = row[0]
-        conn.execute(
-            "UPDATE balances SET coinbase_address = ? WHERE miner_id = ?",
-            (coinbase_address, actual_id),
-        )
-        conn.commit()
-        conn.close()
-
-        return jsonify({
-            "ok": True,
-            "miner_id": actual_id,
-            "coinbase_address": coinbase_address,
-            "network": "Base (eip155:8453)",
-        })
-
-    log.info("RustChain x402 module initialized")
+"""
+RustChain x402 Integration — Swap Info + Coinbase Wallet Linking
+Adds /wallet/swap-info and /wallet/link-coinbase endpoints.
+
+Usage in rustchain server:
+    import rustchain_x402
+    rustchain_x402.init_app(app, DB_PATH)
+"""
+
+import logging
+import os
+import sqlite3
+import time
+
+from flask import jsonify, request
+
+log = logging.getLogger("rustchain.x402")
+
+# Import shared config
+try:
+    import sys
+    sys.path.insert(0, "/root/shared")
+    from x402_config import SWAP_INFO, WRTC_BASE, USDC_BASE, AERODROME_POOL
+    X402_CONFIG_OK = True
+except ImportError:
+    log.warning("x402_config not found — using inline swap info")
+    X402_CONFIG_OK = False
+    SWAP_INFO = {
+        "wrtc_contract": "0x5683C10596AaA09AD7F4eF13CAB94b9b74A669c6",
+        "usdc_contract": "0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913",
+        "aerodrome_pool": "0x4C2A0b915279f0C22EA766D58F9B815Ded2d2A3F",
+        "swap_url": "https://aerodrome.finance/swap?from=0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913&to=0x5683C10596AaA09AD7F4eF13CAB94b9b74A669c6",
+        "network": "Base (eip155:8453)",
+        "reference_price_usd": 0.10,
+    }
+
+
+COINBASE_MIGRATION = "ALTER TABLE balances ADD COLUMN coinbase_address TEXT DEFAULT NULL"
+
+
+def _run_migration(db_path):
+    """Add coinbase_address column to balances if missing."""
+    conn = sqlite3.connect(db_path)
+    cursor = conn.execute("PRAGMA table_info(balances)")
+    existing = {row[1] for row in cursor.fetchall()}
+    if "coinbase_address" not in existing:
+        try:
+            conn.execute(COINBASE_MIGRATION)
+            conn.commit()
+            log.info("Added coinbase_address column to balances")
+        except sqlite3.OperationalError:
+            pass
+    conn.close()
+
+
+def init_app(app, db_path):
+    """Register x402 routes on the RustChain Flask app."""
+
+    try:
+        _run_migration(db_path)
+    except Exception as e:
+        log.error(f"RustChain x402 migration failed: {e}")
+
+    @app.route("/wallet/swap-info", methods=["GET"])
+    def wallet_swap_info():
+        """Returns Aerodrome pool info for USDC→wRTC swap guidance."""
+        return jsonify(SWAP_INFO)
+
+    @app.route("/wallet/link-coinbase", methods=["PATCH", "POST"])
+    def wallet_link_coinbase():
+        """Link a Coinbase Base address to a miner_id. Requires admin key."""
+        admin_key = request.headers.get("X-Admin-Key", "") or request.headers.get("X-API-Key", "")
+        expected = os.environ.get("RC_ADMIN_KEY", "rustchain_admin_key_2025_secure64")
+        if admin_key != expected:
+            return jsonify({"error": "Unauthorized — admin key required"}), 401
+
+        data = request.get_json(silent=True) or {}
+        miner_id = data.get("miner_id", "").strip()
+        coinbase_address = data.get("coinbase_address", "").strip()
+
+        if not miner_id:
+            return jsonify({"error": "miner_id is required"}), 400
+        if not coinbase_address or not coinbase_address.startswith("0x") or len(coinbase_address) != 42:
+            return jsonify({"error": "Invalid Base address (must be 0x + 40 hex chars)"}), 400
+
+        conn = sqlite3.connect(db_path)
+        row = conn.execute(
+            "SELECT miner_id FROM balances WHERE miner_id = ?", (miner_id,)
+        ).fetchone()
+        if not row:
+            # Try miner_pk
+            row = conn.execute(
+                "SELECT miner_id FROM balances WHERE miner_pk = ?", (miner_id,)
+            ).fetchone()
+        if not row:
+            conn.close()
+            return jsonify({"error": f"Miner '{miner_id}' not found in balances"}), 404
+
+        actual_id = row[0]
+        conn.execute(
+            "UPDATE balances SET coinbase_address = ? WHERE miner_id = ?",
+            (coinbase_address, actual_id),
+        )
+        conn.commit()
+        conn.close()
+
+        return jsonify({
+            "ok": True,
+            "miner_id": actual_id,
+            "coinbase_address": coinbase_address,
+            "network": "Base (eip155:8453)",
+        })
+
+    log.info("RustChain x402 module initialized")