Method FetchVergexDataBatch

kernel/engine.go:1113–1218

(ctx context.Context, symbols []string)

}

func (e *StrategyEngine) FetchVergexDataBatch(ctx context.Context, symbols []string) map[string]*vergex.MarketAnalysis {
	result := make(map[string]*vergex.MarketAnalysis)
	if e == nil || e.config == nil || e.config.CoinSource.SourceType != "vergex_signal" {
		return result
	}
	if e.vergexClient == nil {
		logger.Warnf("⚠️ Vergex signal data skipped: claw402 wallet is not configured")
		return result
	}
	if ctx == nil {
		ctx = context.Background()
	}

	source := e.config.CoinSource
	marketType := source.VergexMarketType
	if marketType == "" {
		marketType = vergex.DefaultMarketType
	}
	chain := source.VergexChain
	chain = vergex.QueryChain(chain)

	seen := make(map[string]bool)
	limited := make([]string, 0, store.MaxCandidateCoins)
	for _, symbol := range symbols {
		symbol = vergexDetailSymbolForLookup(marketType, symbol)
		if symbol == "" {
			continue
		}
		if seen[symbol] {
			continue
		}
		seen[symbol] = true
		limited = append(limited, symbol)
		if len(limited) >= store.MaxCandidateCoins+store.MaxPositions {
			break
		}
	}

	type vergexAnalysisResult struct {
		symbol   string
		analysis *vergex.MarketAnalysis
	}

	resultCh := make(chan vergexAnalysisResult, len(limited))
	var wg sync.WaitGroup
	sem := make(chan struct{}, vergexDetailSymbolConcurrency)
	for _, symbol := range limited {
		symbol := symbol
		querySymbol := vergex.QuerySymbol(symbol)
		if querySymbol == "" {
			continue
		}
		itemMarketType := marketType
		itemCategory := ""
		var ranking *vergex.SignalRankItem
		if cached, ok := e.vergexRankingCache[symbol]; ok && cached != nil {
			ranking = cached
			if cached.MarketType != "" {