sub2api/backend/internal/service/openai_compact_stream_failure_created_at_test.go

//go:build unit

package service

import (
	"encoding/json"
	"net/http"
	"net/http/httptest"
	"strings"
	"testing"

	"github.com/gin-gonic/gin"
	"github.com/stretchr/testify/require"
)

// issue #5601：严格的 Responses 客户端把 created_at 当必填字段，缺失即
// `missing field 'created_at'`。writeOpenAICompactSSEFailureMessage 存在的理由就是
// 让 Codex 能把这帧识别成合法终止事件；解析不了就退化回它想避免的盲重连。
func TestWriteOpenAICompactSSEFailureMessage_CarriesCreatedAt(t *testing.T) {
	gin.SetMode(gin.TestMode)
	rec := httptest.NewRecorder()
	c, _ := gin.CreateTestContext(rec)
	c.Request = httptest.NewRequest(http.MethodPost, "/v1/responses", nil)

	writeOpenAICompactSSEFailureMessage(c, http.StatusBadGateway, "upstream_error", "boom")

	body := rec.Body.String()
	require.Contains(t, body, "event: response.failed")

	_, payload, found := strings.Cut(body, "data: ")
	require.True(t, found, "SSE 帧必须带 data 行: %q", body)

	var event struct {
		Type     string `json:"type"`
		Response struct {
			ID        string `json:"id"`
			Object    string `json:"object"`
			CreatedAt int64  `json:"created_at"`
			Status    string `json:"status"`
		} `json:"response"`
	}
	require.NoError(t, json.Unmarshal([]byte(strings.TrimSpace(payload)), &event))

	require.Equal(t, "response.failed", event.Type)
	require.Equal(t, "response", event.Response.Object)
	require.Equal(t, "failed", event.Response.Status)
	require.Greater(t, event.Response.CreatedAt, int64(0),
		"response.failed 必须带有效的 created_at，否则严格客户端读不出这帧")
}