Initial commit of RustForge terminal and AI components

Author: Ashutosh0x

.cargo/config.toml

@@ -0,0 +1,11 @@
+[build]
+rustflags = ["-C", "target-cpu=native"]
+
+[profile.release]
+opt-level = 3
+lto = "fat"
+codegen-units = 1
+panic = "abort"
+debug = false
+incremental = false
+overflow-checks = false

.github/workflows/ci.yml

@@ -0,0 +1,31 @@
+name: CI
+on: [push, pull_request]
+
+env:
+  CARGO_TERM_COLOR: always
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        uses: dtolnay/rust-toolchain@stable
+        with:
+            components: clippy, rustfmt
+      - name: Cache cargo
+        uses: actions/cache@v4
+        with:
+          path: |
+            ~/.cargo/registry
+            ~/.cargo/git
+            target
+          key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
+      - name: Cargo fmt
+        run: cargo fmt --all -- --check
+      - name: Clippy
+        run: cargo clippy --all-targets --all-features -- -D warnings
+      - name: Build
+        run: cargo build --workspace --release
+      - name: Run tests
+        run: cargo test --workspace

.gitignore

@@ -0,0 +1,7 @@
+/target
+/C:\rust-target
+**/*.rs.bk
+.env
+.idea
+.vscode
+/Cargo.lock

BUILD_INSTRUCTIONS.md

@@ -0,0 +1,19 @@
+# 🛑 CRITICAL: Windows SDK Missing
+
+The project cannot build because the **Windows 10 SDK** (or Windows 11 SDK) is missing from your Visual Studio installation. This component contains `kernel32.lib`, which is required for linking.
+
+## 🛠️ Step-by-Step Fix
+
+1.  **Open Visual Studio Installer** (search in Start Menu).
+2.  Click **"Modify"** next to "Visual Studio Build Tools 2022".
+3.  Go to the **"Individual components"** tab at the top.
+4.  Search for **"Windows 10 SDK"** (e.g. `Windows 10 SDK (10.0.19041.0)`).
+5.  **Check the box** next to it.
+6.  Click **"Modify"** in the bottom right corner.
+7.  **Restart your computer** after installation.
+
+## 🏃 Run the Bot
+After fixing the SDK, simply run:
+```powershell
+run_bot.bat
+```

Cargo.toml

@@ -0,0 +1,31 @@
+[workspace]
+resolver = "2"
+members = [
+  "crates/common",
+  "crates/ingestion",
+  "crates/parser",
+  "crates/feature",
+  "crates/strategy",
+  "crates/model",
+  "crates/risk",
+  "crates/executor",
+  "crates/signer",
+  "crates/relay",
+  "crates/daemon",
+  "crates/event_bus",
+  "crates/cli",
+  "crates/tui",
+  "crates/web",
+  "crates/tests",
+  "crates/persistence",
+  "crates/web-dashboard",
+  "crates/ai",
+  "crates/dashboard"
+]
+
+[profile.release]
+opt-level = 3
+lto = true
+codegen-units = 1
+panic = "abort"
+strip = true

README.md

@@ -0,0 +1,109 @@
+# RustForge Terminal (rust-finance)
+
+<div align="center">
+  <img src="https://img.shields.io/badge/Rust-000000?style=for-the-badge&logo=rust&logoColor=white" alt="Rust" />
+  <img src="https://img.shields.io/badge/Tokio-1A2421?style=for-the-badge&logo=Rust&logoColor=white" alt="Tokio" />
+  <img src="https://img.shields.io/badge/Solana-14F195?style=for-the-badge&logo=Solana&logoColor=white" alt="Solana" />
+  <img src="https://img.shields.io/badge/Anthropic-FF7F50?style=for-the-badge&logo=Anthropic&logoColor=white" alt="Anthropic" />
+  <img src="https://img.shields.io/badge/Ratatui-0A0C0F?style=for-the-badge&logo=Linux&logoColor=white" alt="Ratatui" />
+  <img src="https://img.shields.io/badge/WebSocket-010101?style=for-the-badge&logo=socket.io&logoColor=white" alt="WebSocket" />
+</div>
+
+A high-performance, low-latency trading terminal and daemon built completely in Rust. Engineered for direct connection to market data streams (Finnhub, Alpaca), real-time AI signal analysis, and Solana-based trade execution.
+
+## System Architecture
+
+```mermaid
+graph TD;
+    subgraph External Sources
+        NYSE[Market Exchanges]
+        NASDAQ[Market Exchanges]
+        Crypto[Crypto WSS]
+    end
+
+    subgraph Data Pipeline
+        Ingestion(Ingestion Crate)
+        Normalizer(Normalizer)
+        Ingestion --> Normalizer
+    end
+
+    NYSE --> Ingestion
+    NASDAQ --> Ingestion
+    Crypto --> Ingestion
+
+    subgraph Core Infrastructure
+        EventBus[TCP Event Bus]
+        Daemon((Core Daemon Engine))
+        DB[(Persistence Layer)]
+        
+        Normalizer -- Market Events --> EventBus
+        EventBus <--> Daemon
+        Daemon --> DB
+    end
+
+    subgraph Intelligence & Execution
+        AI_Dexter(Dexter Analyst AI)
+        AI_Miro(MiroFish Swarm AI)
+        AnthropicAPI[Anthropic Claude 3.5]
+        
+        Relay(Network Relay & Node Selector)
+        RPC[Solana Mainnet RPC Nodes]
+
+        Daemon <--> AI_Dexter
+        Daemon <--> AI_Miro
+        AI_Dexter <--> AnthropicAPI
+        AI_Miro <--> AnthropicAPI
+        
+        Daemon --> Relay
+        Relay --> RPC
+    end
+
+    subgraph Interfaces
+        TUI[Terminal User Interface - Ratatui]
+        Web[Web Dashboard]
+        
+        EventBus --> TUI
+        EventBus --> Web
+    end
+```
+
+## Workspace Crates
+
+The workspace is organized into discrete, highly decoupled crates:
+
+* **`daemon`**: The central orchestrator. It manages the Tokio asynchronous runtime, spawns the EventBus, starts ingestion pipelines, controls the AI analyst intervals, and routes signals to the execution engine.
+* **`tui`**: A standalone Ratatui application featuring an advanced 3-column layout mimicking professional desktop terminals. It subscribes to the `event_bus` to render watchlists, deep order books, high-res braille charts, and live AI intelligence.
+* **`ai`**: Contains `DexterAnalyst` and `MiroFishSimulator`. Interacts natively with Anthropic APIs to detect catalysts, perform fundamental analysis, and run swarm probability algorithms on market feeds.
+* **`ingestion`**: Connects to `Finnhub` and `Alpaca` WebSockets. Normalizes trade and quote data into a standard `MarketEvent` format and pumps it into the system at extremely low latency.
+* **`relay`**: Handles network routing and edge measurement. Specifically benchmarks multiple RPC nodes (Helius, Triton, QuickNode) and routes transactions through the lowest-latency path available.
+* **`event_bus`**: A custom-built, lightweight TCP broadcasting system that decouples producers and consumers. Allows the TUI and Web Dashboards to run in entirely separate processes from the Daemon.
+* **`persistence`**: Storage layer designed to record transactional records, system P&L tracking, and order history.
+* **`common`**: Shared models, structs, commands, and `BotEvent` enumerations used across all systems to guarantee strict typing on inter-process communications.
+
+## Configuration & Usage
+
+The system expects several environment variables to be set for external API integrations:
+
+```sh
+export ANTHROPIC_API_KEY="..."
+export FINNHUB_API_KEY="..."
+export ALPACA_API_KEY="..."
+export ALPACA_SECRET_KEY="..."
+export USE_MOCK="1" # Enables mocked market generation for UI testing
+```
+
+### Running the System
+
+Start the background daemon process first:
+```sh
+cargo run -p daemon --release
+```
+
+In a separate terminal, launch the Terminal User Interface:
+```sh
+cargo run -p tui --release
+```
+
+## UI and Visual Constraints
+
+The TUI utilizes `Constraint::Length` and custom Ratatui widget styling to enforce a strict immutable grid layout. Custom hex colors have been applied globally to match a proprietary theme design.

assets/config.example.toml

@@ -0,0 +1,18 @@
+# Example Configuration
+
+[network]
+rpc_url = "https://api.mainnet-beta.solana.com"
+ws_url = "wss://api.mainnet-beta.solana.com"
+
+[trading]
+program_id = "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"
+max_position_size = 0.5 # SOL
+min_confidence = 0.85
+
+[strategy]
+type = "simple"
+volume_threshold = 5000000 # lamports
+
+[logging]
+level = "info"
+format = "pretty"

check_env.ps1

@@ -0,0 +1,37 @@
+Write-Host "Checking RL Trading Bot Prerequisites..." -ForegroundColor Cyan
+
+# 1. Check Rust
+if (Get-Command cargo -ErrorAction SilentlyContinue) {
+    Write-Host "✅ Rust/Cargo detected" -ForegroundColor Green
+    cargo --version
+} else {
+    Write-Host "❌ Rust not found. Install from rustup.rs" -ForegroundColor Red
+}
+
+# 2. Check VS Build Tools
+$vcvars = "C:\Program Files (x86)\Microsoft Visual Studio\2022\BuildTools\VC\Auxiliary\Build\vcvars64.bat"
+if (Test-Path $vcvars) {
+    Write-Host "✅ VS Build Tools detected" -ForegroundColor Green
+} else {
+    Write-Host "❌ VS Build Tools NOT found at standard path." -ForegroundColor Red
+    Write-Host "   Path checked: $vcvars" -ForegroundColor Gray
+}
+
+# 3. Check Windows SDK (kernel32.lib)
+$kits10 = "C:\Program Files (x86)\Windows Kits\10\Lib"
+if (Test-Path $kits10) {
+    Write-Host "✅ Windows SDK Libs folder detected" -ForegroundColor Green
+    
+    $kernel32 = Get-ChildItem -Path $kits10 -Filter "kernel32.lib" -Recurse -ErrorAction SilentlyContinue | Select-Object -First 1
+    if ($kernel32) {
+        Write-Host "✅ kernel32.lib found at: $($kernel32.FullName)" -ForegroundColor Green
+    } else {
+        Write-Host "❌ kernel32.lib NOT found in Windows Kits folder." -ForegroundColor Red
+        Write-Host "   Please Modify VS Build Tools -> Individual Components -> Windows 10 SDK" -ForegroundColor Yellow
+    }
+} else {
+    Write-Host "❌ Windows Kits\10\Lib folder NOT found." -ForegroundColor Red
+    Write-Host "   Is the Windows 10/11 SDK installed?" -ForegroundColor Yellow
+}
+
+Write-Host "`nTo fix missing components, run the Visual Studio Installer and modify 'Visual Studio Build Tools 2022'." -ForegroundColor Cyan

crates/ai/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "ai"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+common = { path = "../common" }
+tokio = { version = "1.0", features = ["full"] }
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+reqwest = { version = "0.11", features = ["json"] }
+tracing = "0.1"
+anyhow = "1.0"
+chumsky = "0.9" # Optional depending on parsing needs
+event_bus = { path = "../event_bus" }

crates/ai/src/analyst.rs

@@ -0,0 +1,20 @@
+use anyhow::Result;
+use common::events::{BotEvent, ControlCommand};
+use tokio::sync::mpsc;
+use tracing::{info, error};
+
+pub struct DexterAnalyst {
+    // API logic to come
+}
+
+impl DexterAnalyst {
+    pub fn new() -> Self {
+        Self {}
+    }
+
+    pub async fn run(&self) -> Result<()> {
+        info!("Dexter Analyst started - waiting for data...");
+        // This will listen for MarketEvents and periodically ping Claude
+        Ok(())
+    }
+}