Method runChat

coderd/x/chatd/chatd.go:7099–8424

(
	ctx context.Context,
	chat database.Chat,
	generatedTitle *generatedChatTitle,
	logger slog.Logger,
)

}

func (p *Server) runChat(
	ctx context.Context,
	chat database.Chat,
	generatedTitle *generatedChatTitle,
	logger slog.Logger,
) (runChatResult, error) {
	result := runChatResult{}
	var (
		model         fantasy.LanguageModel
		modelConfig   database.ChatModelConfig
		providerKeys  chatprovider.ProviderAPIKeys
		callConfig    codersdk.ChatModelCallConfig
		messages      []database.ChatMessage
		err           error
		debugEnabled  bool
		debugProvider string
		modelRoute    resolvedModelRoute
		debugModel    string
	)

	messages, err = p.db.GetChatMessagesForPromptByChatID(ctx, chat.ID)
	if err != nil {
		return result, xerrors.Errorf("get chat messages: %w", err)
	}
	modelOpts := modelBuildOptionsFromMessages(messages)
	if modelOpts.ActiveAPIKeyID != "" {
		ctx = aibridge.WithDelegatedAPIKeyID(ctx, modelOpts.ActiveAPIKeyID)
	}

	// Load MCP server configs and user tokens in parallel with model
	// resolution. These queries have no dependencies on each other and all
	// hit different tables.
	var (
		mcpConfigs []database.MCPServerConfig
		mcpTokens  []database.MCPServerUserToken
	)
	var g errgroup.Group
	g.Go(func() error {
		var err error
		model, modelConfig, providerKeys, modelRoute, debugEnabled, debugProvider, debugModel, err = p.resolveChatModel(ctx, chat, modelOpts)
		if err != nil {
			return err
		}
		if len(modelConfig.Options) > 0 {
			if err := json.Unmarshal(modelConfig.Options, &callConfig); err != nil {
				return xerrors.Errorf("parse model call config: %w", err)
			}
		}
		return nil
	})
	if len(chat.MCPServerIDs) > 0 {
		g.Go(func() error {
			var err error
			mcpConfigs, err = p.db.GetMCPServerConfigsByIDs(
				ctx, chat.MCPServerIDs,
			)
			if err != nil {
				logger.Warn(ctx,