Method Subscribe

coderd/x/chatd/chatd.go:4926–4953

(
	ctx context.Context,
	chatID uuid.UUID,
	requestHeader http.Header,
	afterMessageID int64,
)

}

func (p *Server) Subscribe(
	ctx context.Context,
	chatID uuid.UUID,
	requestHeader http.Header,
	afterMessageID int64,
) (
	[]codersdk.ChatStreamEvent,
	<-chan codersdk.ChatStreamEvent,
	func(),
	bool,
) {
	if p == nil {
		return nil, nil, nil, false
	}

	chat, err := p.db.GetChatByID(ctx, chatID)
	if err != nil {
		if dbauthz.IsNotAuthorizedError(err) {
			return nil, nil, nil, false
		}
		p.logger.Warn(ctx, "failed to load chat for stream subscription",
			slog.F("chat_id", chatID),
			slog.Error(err),
		)
		return subscribeWithInitialError(chatID, "failed to load initial snapshot")
	}
	return p.SubscribeAuthorized(ctx, chat, requestHeader, afterMessageID)
}

// SubscribeAuthorized subscribes an already-authorized chat to merged stream
// updates. The passed chat row proves authorization, but SubscribeAuthorized