usecase

type Agent interface {
	Handle(ctx context.Context, msg model.Message) (string, error)
}

type ChatServiceDeps struct {
	// Agent is the message handler (tool-calling loop).
	Agent Agent
	// DB is the database used to open a transaction for publishing chat_reply.
	// If nil, no event is published (ChatService acts as a thin wrapper).
	DB *sql.DB
	// Events is the domain event store; if nil, chat_reply is not published.
	Events model.EventStore
	// Broker is the in-memory SSE broker; Notify is called after commit (nil allowed).
	Broker model.Broker
}

type ClientVoiceConsumerDeps struct {
	DB      *sql.DB
	History model.History
	Events  model.EventStore
	Broker  model.Broker
	Chat    model.ChatService
	// Tasks is used to resolve the optional project hint from job.ProjectID.
	// May be nil; hint resolution is skipped when nil.
	Tasks  model.TaskStore
	Logger *slog.Logger
}

type PairingBroadcaster interface {
	Subscribe(pairID string) (<-chan model.PairingResult, func())
	Notify(pairID string, result model.PairingResult)
}

type PairingDeps struct {
	DB              *sql.DB
	PairingStore    model.PairingStore
	DeviceStore     model.DeviceStore
	Sender          PairingNotifier
	Broadcaster     PairingBroadcaster
	OwnerChatID     int64
	LinkTTL         time.Duration
	LongPoll        time.Duration
	ExternalBaseURL string
	Now             func() time.Time
	// Rand is used for generating bearer tokens.
	// Defaults to crypto/rand.Reader when nil.
	Rand   io.Reader
	Logger *slog.Logger
	// Relay is the push relay client. Defaults to NilRelayClient (push disabled) when nil.
	Relay push.RelayClient
}

type PairingNotifier interface {
	SendMagicLink(ctx context.Context, chatID int64, deviceName, magicURL string) error
}

type ProjectServiceDeps struct {
	// DB is the database used to open write transactions.
	DB *sql.DB
	// Tasks is the task and project store (write methods are tx-aware).
	Tasks model.TaskStore
	// Meta is the channel metadata store (write methods are tx-aware).
	Meta model.MetaStore
	// Events is the domain event store; shares the same transaction.
	Events model.EventStore
	// Devices is the client device store (source of active device IDs).
	Devices model.DeviceStore
	// Queue is the push job queue (enqueued within the tx).
	Queue model.PushQueue
	// Broker is the in-memory SSE broker; Notify is called after commit.
	Broker model.Broker
}

type TaskServiceDeps struct {
	// DB is the database used to open write transactions.
	DB *sql.DB
	// Tasks is the task and project store (write methods are tx-aware).
	Tasks model.TaskStore
	// Events is the domain event store; shares the same transaction.
	Events model.EventStore
	// Devices is the client device store (source of active device IDs).
	Devices model.DeviceStore
	// Queue is the push job queue (enqueued within the tx).
	Queue model.PushQueue
	// Broker is the in-memory SSE broker; Notify is called after commit.
	Broker model.Broker
}