Admin Trading Monitor

flowchart TB subgraph UI["Admin Trading Monitor UI"] Dashboard["Stats Dashboard"] Tabs["7 Data Tabs"] Filters["Filter Controls"] end subgraph API["API Layer"] Monitor["/admin/trading/monitor"] RunDetail["/admin/trading/monitor/:runId"] StopRun["POST stop run"] end subgraph DataSources["Data Sources"] subgraph AlgoSystem["Algorithm Trading System"] AlgoRuns["algorithm_runs"] AlgoTrades["algorithm_trades"] AlgoKills["algorithm_kills"] AlgoStatus["algorithm_run_status"] AlgoMetrics["algorithm_live_metrics"] end subgraph MockSystem["Mock/Manual Trading System"] MockPortfolios["mock_portfolios"] MockTrades["mock_trades"] Positions["positions"] end subgraph BrokerSystem["Broker Execution"] BrokerOrders["broker_orders"] BrokerFills["broker_fills"] end subgraph BillingSystem["AI Billing"] CreditTx["ai_credit_transactions"] UserBilling["user_ai_billing"] end end UI --> API Monitor --> AlgoSystem Monitor --> MockSystem Monitor --> BrokerSystem Monitor --> BillingSystem RunDetail --> AlgoRuns StopRun --> AlgoRuns

flowchart LR subgraph Mock["1. MOCK MODE"] direction TB M1["Simulated $100k Credits"] M2["No Broker Connection"] M3["Internal Testing"] M4["Source: USER/AI/ALGO/AUTO"] end subgraph Paper["2. PAPER MODE"] direction TB P1["Connected Broker"] P2["Real Market Prices"] P3["Simulated Execution"] P4["Latency Tracking"] end subgraph Live["3. LIVE MODE"] direction TB L1["Real Money"] L2["Real Broker Execution"] L3["Full Latency Monitoring"] L4["Fill Rate Tracking"] end Mock -->|"Validate Performance"| Paper Paper -->|"Pass Graduation Gates"| Live style Mock fill:#1a1a2e,stroke:#f59e0b,color:#fff style Paper fill:#1a1a2e,stroke:#3b82f6,color:#fff style Live fill:#1a1a2e,stroke:#ef4444,color:#fff

sequenceDiagram participant Algo as Algorithm Executor participant API as Trading Monitor API participant Broker as Broker Adapter participant Exchange as Exchange/Market Algo->>Broker: submitOrder() Note over Algo,Broker: submitted_at = NOW() Broker->>Exchange: Place Order Exchange-->>Broker: Order Acknowledged Note over Broker,Exchange: accepted_at = NOW() Exchange-->>Broker: Fill(s) Note over Exchange: filled_at = NOW() Broker-->>Algo: OrderStatus API->>API: Calculate Latencies Note over API: accept_latency = accepted_at - submitted_at Note over API: fill_latency = filled_at - submitted_at

sequenceDiagram participant Sched as Scheduler participant Exec as Executor participant Price as Price Service participant Context as Context Prefetch participant PINN as PINN Models participant DSL as DSL Evaluator participant Broker as Broker (Live) Note over Sched,Exec: tick_started_at = NOW() Sched->>Exec: tickRun(runId) Exec->>Price: getCurrentPrice() + getHistoricalPrices() Price-->>Exec: Prices Note over Exec,Price: prices_fetched_at = NOW() Exec->>Context: prefetchTickContext() Note over Context: Bonds, Macro, Sentiment,
Prediction Markets Context-->>Exec: Context Data Note over Exec,Context: context_prefetched_at = NOW() opt PINN Models Enabled Exec->>PINN: runSizingPrediction() + getRegime() PINN-->>Exec: Predictions Note over Exec,PINN: pinn_predictions_at = NOW() end Note over Exec: entry_eval_started_at = NOW() Exec->>DSL: evaluateBoolean(entry.when, ctx) DSL-->>Exec: shouldEnter / shouldExit Note over Exec,DSL: decision_made_at = NOW() opt Trade Executed alt Live Mode Exec->>Broker: adapter.submitOrder() Note over Exec,Broker: trade_submitted_at = NOW() Broker-->>Exec: Fill Confirmation Note over Exec,Broker: trade_filled_at = NOW() else Paper Mode Exec->>Exec: simulateFill() end end Note over Exec: tick_completed_at = NOW() Exec->>Exec: recordDecisionLatency()

pie title Typical Tick Latency Distribution "Price Fetch" : 15 "Context Prefetch" : 35 "PINN Predictions" : 30 "Rule Evaluation" : 5 "Broker Submit+Fill" : 15

flowchart TD Slow["Slow Tick Detected
(>5000ms)"] Slow --> CheckPrice{"Price Fetch
Slow?"} CheckPrice -->|Yes| PriceFix["Check:
• Yahoo API limits
• Network latency
• Symbol validation"] CheckPrice -->|No| CheckContext{"Context
Slow?"} CheckContext -->|Yes| ContextFix["Check:
• FRED rate limits
• Bond data availability
• Sentiment backlog"] CheckContext -->|No| CheckPinn{"PINN
Slow?"} CheckPinn -->|Yes| PinnFix["Check:
• TensorFlow init
• Model complexity
• Cache misses"] CheckPinn -->|No| CheckRules{"Rules
Slow?"} CheckRules -->|Yes| RulesFix["Check:
• Complex DSL
• Many symbols
• Heavy indicators"] CheckRules -->|No| CheckBroker{"Broker
Slow?"} CheckBroker -->|Yes| BrokerFix["Check:
• Connection issues
• Order queue
• Market hours"] style Slow fill:#ef4444,stroke:#ef4444,color:#fff style PriceFix fill:#22c55e,stroke:#22c55e,color:#fff style ContextFix fill:#22c55e,stroke:#22c55e,color:#fff style PinnFix fill:#22c55e,stroke:#22c55e,color:#fff style RulesFix fill:#22c55e,stroke:#22c55e,color:#fff style BrokerFix fill:#22c55e,stroke:#22c55e,color:#fff

flowchart TD Trade["Incoming Trade"] Trade --> CheckSignal{"Has signal_id?"} CheckSignal -->|Yes| CheckConfidence{"signal_confidence >= 0.85?"} CheckSignal -->|No| CheckAlgo{"Has algorithms_used?"} CheckConfidence -->|Yes| Auto["AUTONOMOUS
Full AI control"] CheckConfidence -->|No| AI["AI_SIGNAL
AI-assisted"] CheckAlgo -->|Yes| Algo["ALGORITHM
Rule-based"] CheckAlgo -->|No| User["USER
Manual trade"] style Auto fill:#ef4444,stroke:#ef4444,color:#fff style AI fill:#3b82f6,stroke:#3b82f6,color:#fff style Algo fill:#a855f7,stroke:#a855f7,color:#fff style User fill:#6b7280,stroke:#6b7280,color:#fff

sequenceDiagram participant Admin as Super Admin participant UI as Trading Monitor UI participant API as /admin/trading/monitor/:runId participant Executor as Algorithm Executor participant Broker as Broker Adapter participant DB as Database Admin->>UI: Click "Stop" button UI->>UI: Confirm dialog Admin->>UI: Confirm stop UI->>API: POST /admin/trading/monitor/:runId API->>API: requireSuperAdmin() API->>Executor: stopRun(userId, runId) alt Paper Mode Executor->>Executor: flattenAllPositions() Executor->>DB: Record closing trades at market else Live Mode Executor->>Broker: closeAll() Broker-->>Executor: Positions flattened end Executor->>DB: Update run ended_at Executor->>DB: Delete algorithm_run_status API->>DB: INSERT algorithm_kills
(triggered_by='admin') API-->>UI: { success: true } UI->>UI: Refresh monitor data