Method applyChatLifecycleTransition

coderd/x/chatd/chatd.go:2344–2358

(
	ctx context.Context,
	chatID uuid.UUID,
	action string,
	kind codersdk.ChatWatchEventKind,
	transition func(context.Context, uuid.UUID) ([]database.Chat, error),
)

}

func (p *Server) applyChatLifecycleTransition(
	ctx context.Context,
	chatID uuid.UUID,
	action string,
	kind codersdk.ChatWatchEventKind,
	transition func(context.Context, uuid.UUID) ([]database.Chat, error),
) error {
	updatedChats, err := transition(ctx, chatID)
	if err != nil {
		return xerrors.Errorf("%s chat: %w", action, err)
	}

	p.publishChatPubsubEvents(updatedChats, kind)
	return nil
}

// DeleteQueued removes a queued user message and publishes the queue update.
func (p *Server) DeleteQueued(