forex-scalping.com

Code: Select all

protected override void OnStart()
{
    InitializeStatePersistence();
    LoadState();
    
    // Subscribe to the global position closed event for memory cleanup
    Positions.Closed += OnPositionClosed;
}

private void OnPositionClosed(PositionClosedEventArgs args)
{
    // Only clean up targets belonging to this specific bot and symbol
    if (args.Position.Label == BotLabel && args.Position.SymbolName == SymbolName)
    {
        if (_scaleOutTargets.Remove(args.Position.Id))
        {
            // Save the state immediately after purging the closed ID
            SaveState();
            Print($"[State Cleaned] Purged Position ID {args.Position.Id} from state file.");
        }
    }
}

Code: Select all

if (result.IsSuccessful)
{
    double targetPrice = tradeType == TradeType.Buy 
        ? result.Position.EntryPrice + (slPips * Symbol.PipSize * TargetRR)
        : result.Position.EntryPrice - (slPips * Symbol.PipSize * TargetRR);

    _scaleOutTargets[result.Position.Id] = Math.Round(targetPrice, Symbol.Digits);
    
    // Persist the new target to disk
    SaveState(); 
    
    Print($"[Scale Out Target Set] {targetPrice}");
}

Code: Select all

TradeResult closeResult = ClosePosition(position, scaleOutVolume);

if (closeResult.IsSuccessful)
{
    // Remove from dictionary so it only scales out once
    _scaleOutTargets.Remove(position.Id);
    
    // Persist the removal to disk
    SaveState();
}

Code: Select all

// --- State Tracking for Retries ---
private Dictionary<int, DateTime> _lastCloseAttempts = new Dictionary<int, DateTime>();

[Parameter("Retry Cooldown (ms)", DefaultValue = 500, Group = "Trade Management")]
public int RetryCooldownMs { get; set; }

Code: Select all

protected override void OnTick()
{
    var position = Positions.Find(BotLabel, SymbolName);
    if (position == null) return;

    // 1. Check if the position has a registered scale-out target
    if (_scaleOutTargets.TryGetValue(position.Id, out double targetPrice))
    {
        // 2. Evaluate if the real market price has crossed the target
        bool isTargetHit = position.TradeType == TradeType.Buy 
            ? Symbol.Bid >= targetPrice 
            : Symbol.Ask <= targetPrice;

        if (isTargetHit)
        {
            // 3. COOLDOWN THROTTLE: Prevent API spam during requote storms
            if (_lastCloseAttempts.TryGetValue(position.Id, out DateTime lastAttempt))
            {
                if ((Server.Time - lastAttempt).TotalMilliseconds < RetryCooldownMs)
                {
                    return; // Skip this tick, cooldown has not expired
                }
            }

            double scaleOutVolume = Symbol.NormalizeVolumeInUnits(position.VolumeInUnits / 2, RoundingMode.Down);
            
            if (scaleOutVolume >= Symbol.VolumeInUnitsMin)
            {
                // Log the attempt time BEFORE firing the API call
                _lastCloseAttempts[position.Id] = Server.Time;

                Print($"[Attempting Scale-Out] Requesting {scaleOutVolume} units at {targetPrice}");
                TradeResult closeResult = ClosePosition(position, scaleOutVolume);

                // 4. RESULT HANDLING
                if (closeResult.IsSuccessful)
                {
                    Print($"[Scale-Out Success] 50% partial executed.");
                    
                    // Purge state and save to JSON
                    _scaleOutTargets.Remove(position.Id);
                    _lastCloseAttempts.Remove(position.Id);
                    SaveState(); 
                }
                else
                {
                    // API FAILED (Requote, Off-Quotes, Timeout, Margin)
                    // We DO NOT remove the target from _scaleOutTargets.
                    // The next tick that arrives after the RetryCooldownMs will try again.
                    Print($"[API Error] Scale-out failed: {closeResult.Error}. Retrying in {RetryCooldownMs}ms.");
                }
            }
            else
            {
                // Position is mathematically too small to divide further.
                // Remove the target so we stop checking.
                _scaleOutTargets.Remove(position.Id);
                SaveState();
            }
        }
    }
}

Code: Select all

private void OnPositionClosed(PositionClosedEventArgs args)
{
    if (args.Position.Label == BotLabel && args.Position.SymbolName == SymbolName)
    {
        // Clean up JSON persistence
        if (_scaleOutTargets.Remove(args.Position.Id))
        {
            SaveState();
        }
        
        // Clean up the cooldown memory
        _lastCloseAttempts.Remove(args.Position.Id);
    }
}

Code: Select all

[Parameter("Move to Breakeven on Scale-Out", DefaultValue = true, Group = "Trade Management")]
public bool MoveToBreakeven { get; set; }

[Parameter("Breakeven Extra Buffer (Pips)", DefaultValue = 0.5, Group = "Trade Management", 
           ToolTip = "Small offset added to the entry price to cover broker commissions and swap costs.")]
public double BreakevenExtraPips { get; set; }