package service

import (
	"context"
	"strings"
	"time"

	"gitea.redpowerfuture.com/red-future/common/oss"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/util/gconv"
)

// modelCallMaxRetries 上游调用最大重试次数
const modelCallMaxRetries = 10

// retryWait 指数退避等待（第 attempt 次重试，等待 1<<attempt 秒）。
// 返回 nil 表示可继续重试；ctx 已取消返回 ctx.Err()，调用方应停止。
func retryWait(ctx context.Context, attempt int) error {
	wait := time.Duration(1<<attempt) * time.Second
	select {
	case <-ctx.Done():
		return ctx.Err()
	case <-time.After(wait):
		return nil
	}
}

// firstText 取任意值首位文本：数组取首个元素，其余原样转字符串
func firstText(v any) string {
	if arr, ok := v.([]any); ok && len(arr) > 0 {
		return gconv.String(arr[0])
	}
	return gconv.String(v)
}

// extractChunkText 从流式分片字段取值并转存 OSS，返回首位文本（数组取首个元素，去掉首尾空白）。
// 空值 / 仅空白 / 数组全空 返回空串。
func extractChunkText(ctx context.Context, v any) string {
	if v == nil || g.IsEmpty(v) {
		return ""
	}
	return strings.TrimSpace(firstText(oss.TempURLToOSS(ctx, v)))
}