/// <summary>
/// HistoryEmulationConnector, исправляющий некорректное время логов.
///
/// Проблема: StockSharp MarketEmulator.ProcessCandles генерирует Clone-свечи
/// с State=Active и LocalTime внутри периода свечи (OpenTime/HighTime/LowTime).
/// Clone с HighTime/LowTime может иметь LocalTime больше, чем ServerTime
/// следующей реальной свечи (но другого таймфрейма).
///
/// Решение: буферизуем Clone-свечи (State != Finished), а при получении
/// следующего реального сообщения обрабатываем буфер в порядке возрастания
/// времени, затем — само сообщение. Это гарантирует строгое возрастание
/// времени и корректное поведение ProcessTime в MarketEmulator.
/// </summary>
public class FixedHistoryEmulationConnector : HistoryEmulationConnector {
    private readonly List<Message> _cloneBuffer = new();

    public FixedHistoryEmulationConnector(
        IEnumerable<Security> securities,
        IEnumerable<Portfolio> portfolios,
        IStorageRegistry storage
    ) : base(securities, portfolios, storage) {
    }

    /// <summary>
    /// Алгоритм обработки сообщений:
    /// 1. Clone-свечи (State != Finished) буферизуются в отсортированном порядке
    ///    (вставка через бинарный поиск) — их LocalTime может превышать ServerTime
    ///    следующей реальной свечи, что ломает timeSpan в эмуляторе.
    /// 2. Перед обработкой реального сообщения из буфера извлекаются все свечи
    ///    с LocalTime &lt; currentTime сообщения (уже отсортированы!) и передаются в base.
    /// 3. Свечи с LocalTime >= currentTime остаются в буфере до следующего реального сообщения.
    /// </summary>
    protected override void OnProcessMessage(Message message) {
        if (message is CandleMessage { State: not CandleStates.Finished }) {
            InsertSorted(message);
            return;
        }

        if (_cloneBuffer.Count > 0) {
            var currentTime = message.LocalTime;

            // Бинарный поиск первого элемента с LocalTime >= currentTime
            var splitIndex = BinarySearchFirstGreaterOrEqual(_cloneBuffer, currentTime);

            // Обрабатываем все элементы до splitIndex (они уже отсортированы)
            for (var i = 0; i < splitIndex; i++)
                base.OnProcessMessage(_cloneBuffer[i]);

            // Удаляем обработанные элементы
            _cloneBuffer.RemoveRange(0, splitIndex);
        }

        base.OnProcessMessage(message);
    }

    /// <summary>
    /// Вставка сообщения в буфер с сохранением сортировки по LocalTime.
    /// Использует бинарный поиск O(log n) + вставку O(n).
    /// Для типичного случая (возрастающее время) вставка происходит в конец — O(1).
    /// </summary>
    private void InsertSorted(Message message) {
        var index = _cloneBuffer.BinarySearch(message, LocalTimeComparer.Instance);
        if (index < 0)
            index = ~index;
        _cloneBuffer.Insert(index, message);
    }

    /// <summary>
    /// Бинарный поиск первого элемента с LocalTime >= target.
    /// Возвращает индекс, по которому можно разделить список:
    /// все элементы до индекса имеют LocalTime &lt; target.
    /// </summary>
    private static int BinarySearchFirstGreaterOrEqual(List<Message> list, DateTimeOffset target) {
        int left = 0, right = list.Count;
        while (left < right) {
            int mid = (left + right) / 2;
            if (list[mid].LocalTime < target)
                left = mid + 1;
            else
                right = mid;
        }
        return left;
    }

    protected override void DisposeManaged() {
        _cloneBuffer.Clear();
        base.DisposeManaged();
    }

    private sealed class LocalTimeComparer : IComparer<Message> {
        public static readonly LocalTimeComparer Instance = new();
        public int Compare(Message? x, Message? y) => x!.LocalTime.CompareTo(y!.LocalTime);
    }
}