Method ProcessChatMessage

services/openai_service.go:61–178

ProcessChatMessage processes a chat message with test case context for logging

(ctx context.Context, userMessage string, session *models.ChatSession, testCase string)

// ProcessChatMessage processes a chat message with test case context for logging
func (ai *OpenAIService) ProcessChatMessage(ctx context.Context, userMessage string, session *models.ChatSession, testCase string) (*models.ChatResponse, error) {
	// Generate session ID if not provided
	sessionID := session.SessionID
	if sessionID == "" {
		sessionID = ai.generateSessionID()
	}

	// Define the tools available to the AI
	t := ai.getToolDefinitions()

	// Build messages including conversation history
	messages := ai.buildMessagesFromSession(session, userMessage)

	var cartSummary *models.CartSummary
	var toolResults []models.ToolCallResult
	var responseMessage string

	// Track LLM request metrics
	var llmRequests int
	var totalLLMTime time.Duration

	// Maximum number of tool call iterations
	maxIterations := 5
	currentIteration := 0

	for currentIteration < maxIterations {
		// Track LLM request time
		llmStart := time.Now()

		// Prepare request parameters
		requestParams := openai.ChatCompletionNewParams{
			Model:       ai.defaultModel,
			Messages:    messages,
			Tools:       t,
			Temperature: param.Opt[float64]{Value: 0},
		}

		// Create the chat completion request
		completion, err := ai.client.Chat.Completions.New(ctx, requestParams)

		// Record LLM request metrics
		llmDuration := time.Since(llmStart)
		llmRequests++
		totalLLMTime += llmDuration

		// Log the request/response or error
		if ai.logger != nil {
			if err != nil {
				if logErr := ai.logger.LogError(testCase, currentIteration+1, requestParams, err, ai.baseURL); logErr != nil {
					fmt.Printf("Failed to log error: %v\n", logErr)
				}
			} else {
				if logErr := ai.logger.LogRequest(testCase, currentIteration+1, requestParams, completion, ai.baseURL); logErr != nil {
					fmt.Printf("Failed to log request: %v\n", logErr)
				}
			}
		}