package agent

import (
	"context"
	"log/slog"

	"github.com/tidbcloud/AgentTeam/internal/store/message"
)

func (h *MessageHandler) fanoutCommittedDelivery(ctx context.Context, workspaceID string, delivery message.MessageDelivery) {
	if h.fanout == nil {
		h.warn("message fanout is not configured", slog.String("message_id", delivery.MessageID))
		return
	}
	if delivery.AppMessage == nil {
		h.warn("message fanout delivery missing app message", slog.String("message_id", delivery.MessageID))
		return
	}
	h.fanout.EmitCommittedMessage(ctx, workspaceID, *delivery.AppMessage, delivery)
}