package ports

import (
	"context"
	"errors"
	"time"

	"git.cin.su/m/Assistant/contracts/work"
)

var ErrAgentExecutorUnavailable = errors.New("agent executor unavailable")

type WorkerStore interface {
	ExecutionStore
	LoadDispatchIntent(context.Context, string) (work.AgentDispatchIntent, error)
	ClaimNextDispatch(context.Context, string, int64) (work.AgentDispatchQueueItem, error)
	CompleteDispatch(context.Context, string, string, work.AgentDispatchQueueState, int64) error
	RetryDispatch(context.Context, string, string, int64, time.Duration) error
	RecoverStaleClaims(context.Context, int64, int64) (int64, error)
}