forex-scalping.com

Code: Select all

using System;
using System.Diagnostics;
using System.IO;
using System.Text;
using System.Collections.Concurrent;
using cAlgo.API;

namespace cAlgo.Robots
{
    [Robot(TimeZone = TimeZones.UTC, AccessRights = AccessRights.FileSystem)]
    public class InstitutionalExecutionAuditor : Robot
    {
        [Parameter("Audit Log Filename", DefaultValue = "cTrader_Microstructure_Audit.csv")]
        public string LogFileName { get; set; }

        private string _filePath;
        private readonly ConcurrentQueue<string> _telemetryQueue = new ConcurrentQueue<string>();
        
        // Timer for high-resolution profiling
        private readonly Stopwatch _executionTimer = new Stopwatch();

        protected override void OnStart()
        {
            string docPath = Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments);
            _filePath = Path.Combine(docPath, LogFileName);

            InitializeScorecardEngine();

            // Offload disk I/O to a background timer (every 2 seconds)
            Timer.Start(2);
            
            Print($"[ENGINE] Microstructure Auditor active. I/O decoupled.");
        }

        private void InitializeScorecardEngine()
        {
            if (!File.Exists(_filePath))
            {
                string header = "Timestamp_UTC,Symbol,Type,Latency_ms,Intended_Px,Filled_Px,Slip_Pips,Spread_Pips,Order_State\n";
                File.WriteAllText(_filePath, header);
            }
        }

        // =========================================================================
        // HOT PATH: SYNCHRONOUS EXECUTION WRAPPER
        // =========================================================================
        public void ExecuteAuditedOrder(TradeType direction, double volume)
        {
            // 1. Capture snapshot of liquidity strictly prior to FIX dispatch
            double intendedPx = direction == TradeType.Buy ? Symbol.Ask : Symbol.Bid;
            double spreadPips = (Symbol.Ask - Symbol.Bid) / Symbol.PipSize;

            // 2. Hardware-level latency profiling
            _executionTimer.Restart();
            
            // 3. Dispatch to Liquidity Provider
            TradeResult result = ExecuteMarketOrder(direction, SymbolName, volume, "Inst_Audit");
            
            _executionTimer.Stop();
            double latencyMs = _executionTimer.Elapsed.TotalMilliseconds;

            // 4. Calculate Execution Drag
            if (result.IsSuccessful)
            {
                double filledPx = result.Position.EntryPrice;
                double slipPips = direction == TradeType.Buy 
                    ? (filledPx - intendedPx) / Symbol.PipSize 
                    : (intendedPx - filledPx) / Symbol.PipSize;

                QueueTelemetry(direction, latencyMs, intendedPx, filledPx, slipPips, spreadPips, "FILLED");
            }
            else
            {
                QueueTelemetry(direction, latencyMs, intendedPx, 0, 0, spreadPips, $"REJECT_{result.Error}");
            }
        }

        // =========================================================================
        // TELEMETRY QUEUEING (NON-BLOCKING)
        // =========================================================================
        private void QueueTelemetry(TradeType dir, double lat, double req, double fill, double slip, double spread, string state)
        {
            string record = $"{Server.Time:yyyy-MM-dd HH:mm:ss.fff},{SymbolName},{dir},{lat:F2},{req},{fill},{slip:F2},{spread:F2},{state}";
            _telemetryQueue.Enqueue(record);
        }

        // =========================================================================
        // BACKGROUND I/O FLUSH
        // =========================================================================
        protected override void OnTimer()
        {
            if (_telemetryQueue.IsEmpty) return;

            var sb = new StringBuilder();
            while (_telemetryQueue.TryDequeue(out string record))
            {
                sb.AppendLine(record);
            }

            try
            {
                File.AppendAllText(_filePath, sb.ToString());
            }
            catch (Exception ex)
            {
                Print($"[I/O FAULT] Failed to flush telemetry: {ex.Message}");
            }
        }

        // =========================================================================
        // LIGHTWEIGHT TERMINAL UI
        // =========================================================================
        protected override void OnTick()
        {
            double spread = (Symbol.Ask - Symbol.Bid) / Symbol.PipSize;
            Chart.DrawStaticText("micro_dash", 
                $"INSTITUTIONAL AUDITOR\nSpread: {spread:F1} pips\nQueue Depth: {_telemetryQueue.Count}", 
                VerticalAlignment.Top, HorizontalAlignment.Right, Color.DimGray);
        }
    }
}