Method nightmare

initialize/handlers.go:259–443

(c *gin.Context)

}

func (h *Handler) nightmare(c *gin.Context) {
	var original_request officialtypes.APIRequest
	err := c.BindJSON(&original_request)
	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
	}
	if len(original_request.Messages) == 0 {
		c.JSON(400, gin.H{"error": gin.H{
			"message": "Missing required parameter: messages",
			"type":    "invalid_request_error",
			"param":   "messages",
			"code":    "missing_required_parameter",
		}})
		return
	}
	proxyUrl := h.proxy.GetProxyIP()
	input_tokens := countMessagesTokens(original_request.Messages)
	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()

	// 工具调用模式判定:客户端声明了 tools 且未被显式禁用。
	// 启用时强制 stream=false(sandbox 重试需要缓冲);走独立 handleToolCalling 路径。
	toolsEnabled := toolCallingEnabled(original_request.Tools)
	if toolsEnabled && os.Getenv("STREAM_MODE") != "false" {
		original_request.Stream = false
	}

	// Convert the chat request to a ChatGPT request
	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 {