factory

type APIFactory interface {
	// SubmitWorkRequest injects a canonical work request batch idempotently.
	SubmitWorkRequest(ctx context.Context, request interfaces.WorkRequest) (interfaces.WorkRequestSubmitResult, error)

	// SubscribeFactoryEvents returns canonical factory event history followed by
	// live events. The live stream closes when ctx is canceled.
	SubscribeFactoryEvents(ctx context.Context) (*interfaces.FactoryEventStream, error)

	// GetEngineStateSnapshot returns the aggregate observability snapshot for
	// service-facing consumers.
	GetEngineStateSnapshot(ctx context.Context) (*interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net], error)
}

type Clock interface {
	Now() time.Time
}

type CompletionDeliveryPlanner interface {
	DeliveryTickForDispatch(dispatch interfaces.WorkDispatch) (int, bool, error)
}

type CompletionRecorder func(interfaces.FactoryCompletionRecord)

type DispatchRecorder func(interfaces.FactoryDispatchRecord)

type DispatchResultHook interface {
	SubmitDispatch(ctx context.Context, dispatch interfaces.WorkDispatch) error
	OnTick(ctx context.Context, snapshot interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net]) ([]interfaces.WorkResult, error)
	WaitCh() <-chan struct{}
}

type Factory interface {
	WorkMover
	// Run starts the factory loop. Blocks until ctx is cancelled or all
	// work reaches terminal states.
	Run(ctx context.Context) error

	APIFactory

	// Pause pauses the factory loop. No transitions fire until resumed.
	Pause(ctx context.Context) error

	// GetFactoryEvents returns the current-process canonical event history.
	GetFactoryEvents(ctx context.Context) ([]factoryapi.FactoryEvent, error)

	// WaitToComplete returns a channel that is closed when all tokens reach
	// terminal or failed places and no dispatches are in flight. Callers can
	// block on this channel to know when the factory has finished all work
	// without having to manually drive ticks.
	WaitToComplete() <-chan struct{}
}

type FactoryConfig struct {
	Scheduler                 scheduler.Scheduler
	WorkerExecutors           map[string]workers.WorkerExecutor
	RuntimeConfig             interfaces.RuntimeDefinitionLookup
	WorkflowContext           *factory_context.FactoryContext
	RuntimeMode               interfaces.RuntimeMode
	Logger                    logging.Logger
	Clock                     Clock
	EventHistory              *events.FactoryEventHistory
	SubmissionRecorder        SubmissionRecorder
	FactoryEventRecorder      FactoryEventRecorder
	SubmissionHooks           []SubmissionHook
	DispatchRecorder          DispatchRecorder
	CompletionRecorder        CompletionRecorder
	CompletionDeliveryPlanner CompletionDeliveryPlanner
	// contains filtered or unexported fields
}

type FactoryEventRecorder func(factoryapi.FactoryEvent)

type FactoryOption func(*FactoryConfig)

type LogicalClock interface {
	Clock
	SetTick(tick int)
}

type RealClock struct{}

type SubmissionHook interface {
	Name() string
	Priority() int
	OnTick(ctx context.Context, input interfaces.SubmissionHookContext[interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net]]) (interfaces.SubmissionHookResult, error)
}

type SubmissionRecorder func(interfaces.FactorySubmissionRecord)

type WorkMover interface {
	MoveWork(ctx context.Context, workID string, stateName string, source interfaces.WorkStateChangeSource, requestID string) (interfaces.OperatorMoveResult, error)
}