package embedding

// 本文件是 M49 的**出口回归探针**：令牌守卫上移进 trace.UpstreamError 之后，
// embedding 这一处一行没改也应当自动安全 —— 兼容层把散文塞进 error.code /
// error.type 时，错误文本与日志里都搜不到它，而 status / body_bytes 照旧。
//
// 断言形状是「摘掉 trace.UpstreamError 里的守卫就变红」：这里没有任何本地守卫。
// 这一处最敏感：/embeddings 的 input 就是她的记忆正文，回显它的散文不能进日志。

import (
	"bytes"
	"context"
	"io"
	"log/slog"
	"net/http"
	"strings"
	"testing"

	"git.yeij.top/AskaEth/Cyrene_v2/internal/config"
)

// TestAPIEmbedder_Non200DropsFreeTextErrorCode 400 报文的 error.code / error.type
// 里带散文 ⇒ 两个字段整体消失，而状态码与体积摘要仍在。
func TestAPIEmbedder_Non200DropsFreeTextErrorCode(t *testing.T) {
	t.Parallel()
	const prose = "Invalid value: '她刚才说的那句话'"
	rt := roundTripFunc(func(*http.Request) (*http.Response, error) {
		body := `{"error":{"code":"` + prose + `","type":"` + prose + `"}}`
		return &http.Response{
			StatusCode: http.StatusBadRequest,
			Body:       io.NopCloser(strings.NewReader(body)),
			Header:     http.Header{"Content-Type": []string{"application/json"}},
		}, nil
	})
	emb := NewAPI(
		config.EmbeddingConfig{APIURL: "https://embed.example.com/v1/embeddings"},
		WithRoundTripper(rt),
	)

	_, err := emb.Embed(context.Background(), []string{"hi"})
	if err == nil {
		t.Fatal("400 却报成功")
	}

	var logBuf bytes.Buffer
	slog.New(slog.NewJSONHandler(&logBuf, nil)).Error("embed call failed", "err", err)
	for _, surface := range []string{err.Error(), logBuf.String()} {
		if strings.Contains(surface, "她刚才说的那句话") {
			t.Fatalf("上游 error.code/type 里的散文进了错误或日志：%s", surface)
		}
	}
	for _, want := range []string{"status=400", "body_bytes="} {
		if !strings.Contains(err.Error(), want) {
			t.Fatalf("错误里缺少 %q：%v", want, err)
		}
	}
}