ANTOOZA-BACKEND/Application/Helpers/StockMasterDelist.cs

namespace Application.Helpers;

/// <summary>
/// 종목마스터 동기화의 상폐(delist) sweep 안전 가드 (순수 로직, DB 비의존 — 테스트 가능).
/// 기존에는 3개 시장 합계 건수만 검증(count > 0)한 뒤 스냅샷에 없는 활성 종목을 전부 MarkDelisted 하여,
/// 한 시장만 빈/부분 응답이어도 그 시장 전체(예: KOSDAQ ~1,700종목)가 하루 동안 비활성 노출되는 문제가 있었다.
/// 시장별로 스냅샷 건수를 보존해 아래 두 가드를 통과한 시장에서만 상폐 sweep 을 허용한다:
///   1) 스냅샷 rows == 0 인 시장 → 상폐 보류 (빈 응답 = API 장애/미반영 가능성)
///   2) 스냅샷이 기존 활성 종목수의 <see cref="MinSnapshotRatio"/> 미만인 시장 → 상폐 보류 (부분 응답 방어)
/// 활성 종목이 0 인 시장(최초 적재)은 비교 기준이 없으므로 허용한다.
/// </summary>
public static class StockMasterDelist
{
    /// <summary>시장별 스냅샷 건수가 기존 활성 종목수 대비 이 비율 미만이면 부분 응답으로 간주해 상폐를 보류한다.</summary>
    public const double MinSnapshotRatio = 0.8;

    /// <param name="snapshotCountByMarket">시장별 이번 스냅샷 건수 (수집 대상 전 시장 포함 — 0건 시장도 키 존재)</param>
    /// <param name="activeCountByMarket">시장별 기존 활성 종목수 (없는 시장은 0 취급)</param>
    /// <returns>상폐 sweep 을 수행해도 안전한 시장 목록</returns>
    public static IReadOnlyList<TMarket> GetDelistableMarkets<TMarket>(IReadOnlyDictionary<TMarket, int> snapshotCountByMarket, IReadOnlyDictionary<TMarket, int> activeCountByMarket) where TMarket : struct
    {
        var result = new List<TMarket>();

        foreach (var (market, snapshotCount) in snapshotCountByMarket)
        {
            if (!CanDelist(snapshotCount, activeCountByMarket.TryGetValue(market, out var activeCount) ? activeCount : 0))
            {
                continue;
            }

            result.Add(market);
        }

        return result;
    }

    /// <summary>단일 시장의 상폐 sweep 허용 여부 — 빈 스냅샷(0건) 또는 활성 대비 80% 미만이면 보류.</summary>
    public static bool CanDelist(int snapshotCount, int activeCount)
    {
        if (snapshotCount == 0)
        {
            return false;
        }

        if (activeCount > 0 && snapshotCount < activeCount * MinSnapshotRatio)
        {
            return false;
        }

        return true;
    }
}