Method responses

initialize/handlers.go:445–593

(c *gin.Context)

}

func (h *Handler) responses(c *gin.Context) {
	var responsesRequest officialtypes.ResponsesAPIRequest
	err := c.BindJSON(&responsesRequest)
	if err != nil {
		c.JSON(400, gin.H{"error": gin.H{
			"message": "Request must be proper JSON",
			"type":    "invalid_request_error",
			"param":   nil,
			"code":    err.Error(),
		}})
		return
	}

	original_request, err := responsesRequest.ToAPIRequest()
	if err != nil {
		c.JSON(400, gin.H{"error": gin.H{
			"message": err.Error(),
			"type":    "invalid_request_error",
			"param":   "input",
			"code":    "invalid_request_error",
		}})
		return
	}

	proxyUrl := h.proxy.GetProxyIP()
	input_tokens := 0
	for _, message := range original_request.Messages {
		input_tokens += util.CountToken(message.Text())
	}
	secret, status, err := h.secretFromAuthorization(c, original_requestHasFiles(original_request), false, proxyUrl)
	if err != nil {
		c.JSON(status, gin.H{"error": gin.H{
			"message": err.Error(),
			"type":    "authorization_error",
			"param":   "Authorization",
			"code":    status,
		}})
		return
	}
	if secret == nil {
		c.JSON(400, gin.H{"error": "Not Account Found."})
		c.Abort()
		return
	}

	uid := uuid.NewString()
	client := bogdanfinn.NewStdClient()

	translated_request := chatgptrequestconverter.ConvertAPIRequest(original_request, secret, proxyUrl, client)

	// 按 conversationID 复用 ChatClientState，保持 DeviceID/SessionID 一致
	var clientState *chatgpt.ChatClientState
	if translated_request.ConversationID != "" {
		clientState = h.sessions.Get(translated_request.ConversationID)
	}
	if clientState == nil {
		clientState = chatgpt.NewChatClientState()
	}