Function runChecks

internal/nodeapi/check.go:455–499

(ctx context.Context, client *http.Client)

}

func runChecks(ctx context.Context, client *http.Client) []serviceCheckResult {
results := make([]serviceCheckResult, len(streamServices))
var wg sync.WaitGroup

for i, svc := range streamServices {
wg.Add(1)
go func(idx int, s streamServiceDef) {
defer wg.Done()
result := serviceCheckResult{Service: s.name}

if s.customCheck != nil {
result.Unlocked, result.Region, result.Note = s.customCheck(ctx, client)
results[idx] = result
return
}

req, err := http.NewRequestWithContext(ctx, http.MethodGet, s.url, nil)
if err != nil {
result.Note = "请求构建失败"
results[idx] = result
return
}
req.Header.Set("User-Agent", checkUserAgent)
req.Header.Set("Accept-Language", "en-US,en;q=0.9")
req.Header.Set("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8")

resp, err := client.Do(req)
if err != nil {
result.Note = "连接超时"
results[idx] = result
return
}
defer resp.Body.Close()

body, _ := io.ReadAll(io.LimitReader(resp.Body, 65536))
result.Unlocked, result.Region, result.Note = s.checkFn(
resp.StatusCode, resp.Request.URL.String(), string(body),
)
results[idx] = result
}(i, svc)
}

wg.Wait()
return results
}

// checkSpotify 参考 HsukqiLee/MediaUnlockTest checks/Spotify.go：
// 通过 signup API 触发账号创建预检，返回 status/Country/is_country_launched 判定。