forex-scalping.com

Code: Select all

using System;
using System.IO;
using cAlgo.API;

namespace cAlgo.Robots
{
    [Robot(TimeZone = TimeZones.UTC, AccessRights = AccessRights.FileSystem)]
    public class FridaySpreadFilterLog : Robot
    {
        [Parameter("Max Spread Cap (Pips)", DefaultValue = 1.8, MinValue = 0.1, Step = 0.1)]
        public double MaxSpreadPips { get; set; }

        [Parameter("Friday Cutoff Hour", DefaultValue = 14, MinValue = 0, MaxValue = 23)]
        public int FridayCutoffHour { get; set; }

        private DateTime _lastBarTime;
        private string _filePath;

        protected override void OnStart()
        {
            // Safely route the CSV to the user's Documents/cAlgo folder
            string docsPath = Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments);
            _filePath = Path.Combine(docsPath, "cAlgo", "SkippedTradesLog.csv");
        }

        protected override void OnTick()
        {
            // 1. Evaluate once per bar to prevent CSV log spam
            var currentBarTime = Bars.OpenTimes.LastValue;
            if (_lastBarTime == currentBarTime)
                return;

            // 2. Time Logic: Broker Time
            bool isFriday = Server.Time.DayOfWeek == DayOfWeek.Friday;
            bool isAfterCutoff = Server.Time.Hour >= FridayCutoffHour;
            bool killzoneActive = isFriday && isAfterCutoff;

            // 3. Spread Logic
            // cTrader natively handles pricing digits; Symbol.PipSize safely calculates true pips
            double currentSpreadPips = Symbol.Spread / Symbol.PipSize;
            bool spreadExceeded = currentSpreadPips > MaxSpreadPips;

            // 4. Execution Logging
            if (spreadExceeded && !killzoneActive)
            {
                LogSkippedTrade("Spread Cap Exceeded", currentSpreadPips);
                _lastBarTime = currentBarTime; 
            }
            else if (killzoneActive)
            {
                LogSkippedTrade("Friday Cutoff Time Reached", currentSpreadPips);
                _lastBarTime = currentBarTime; 
            }
        }

        private void LogSkippedTrade(string reason, double spreadPips)
        {
            try
            {
                // Check if file is new to write the header row
                bool writeHeader = !File.Exists(_filePath) || new FileInfo(_filePath).Length == 0;
                
                using (StreamWriter sw = new StreamWriter(_filePath, append: true))
                {
                    if (writeHeader)
                    {
                        sw.WriteLine("Time,Symbol,Action,Reason,SpreadPips,Price");
                    }

                    sw.WriteLine($"{Server.Time:yyyy-MM-dd HH:mm:ss},{SymbolName},SKIP,{reason},{Math.Round(spreadPips, 1)},{Symbol.Ask}");
                }
                
                Print($"Logged Skip: {reason} | Spread: {Math.Round(spreadPips, 1)}");
            }
            catch (Exception ex)
            {
                Print($"Failed to write to CSV. Error: {ex.Message}");
            }
        }
    }
}