Method tryAutoPromoteQueuedMessage

coderd/x/chatd/chatd.go:5898–5960

tryAutoPromoteQueuedMessage pops the next queued message and converts it into a pending user message inside the caller's transaction. Queued messages were already admitted through SendMessage, so this preserves FIFO order without re-checking usage limits.

(
	ctx context.Context,
	tx database.Store,
	chat database.Chat,
)

// messages were already admitted through SendMessage, so this preserves FIFO
// order without re-checking usage limits.
func (p *Server) tryAutoPromoteQueuedMessage(
	ctx context.Context,
	tx database.Store,
	chat database.Chat,
) (*database.ChatMessage, []database.ChatQueuedMessage, bool, error) {
	logger := p.logger.With(slog.F("chat_id", chat.ID))

	queuedMessages, err := tx.GetChatQueuedMessages(ctx, chat.ID)
	if err != nil {
		return nil, nil, false, xerrors.Errorf("get queued messages: %w", err)
	}
	if len(queuedMessages) == 0 {
		return nil, nil, false, nil
	}
	nextQueued := queuedMessages[0]
	effectiveModelConfigID, err := resolveQueuedMessageModelConfigID(
		ctx,
		tx,
		chat,
		nextQueued.ModelConfigID,
	)
	if err != nil {
		return nil, nil, false, err
	}

	poppedQueued, err := tx.PopNextQueuedMessage(ctx, chat.ID)
	if err != nil {
		return nil, nil, false, xerrors.Errorf("pop next queued message: %w", err)
	}
	if poppedQueued.ID != nextQueued.ID {
		return nil, nil, false, xerrors.New("popped queued message out of order")
	}

	msgParams := database.InsertChatMessagesParams{ //nolint:exhaustruct // Fields populated by appendUserChatMessage.
		ChatID: chat.ID,
	}
	queuedUserMsg := newUserChatMessage(
		nextQueued.APIKeyID.String,
		pqtype.NullRawMessage{
			RawMessage: nextQueued.Content,
			Valid:      len(nextQueued.Content) > 0,
		},
		database.ChatMessageVisibilityBoth,
		effectiveModelConfigID,
		chatprompt.CurrentContentVersion,
	)
	queuedUserMsg = queuedUserMsg.withCreatedBy(chat.OwnerID)
	appendUserChatMessage(&msgParams, queuedUserMsg)
	msgs, err := insertChatMessageWithStore(ctx, tx, msgParams)
	if err != nil {
		return nil, nil, false, xerrors.Errorf("insert promoted message: %w", err)
	}
	msg := msgs[0]

	remainingQueuedMessages, err := tx.GetChatQueuedMessages(ctx, chat.ID)
	if err != nil {
		logger.Error(ctx, "failed to load remaining queued messages after auto-promotion",
			slog.F("queued_message_id", nextQueued.ID), slog.Error(err))