hooks

type ActivityCacheHitInfo struct {
	InstanceID   string
	WorkflowName string
	ActivityID   string
	ActivityName string
	CachedResult any
}

type ActivityCompleteInfo struct {
	InstanceID   string
	WorkflowName string
	ActivityID   string
	ActivityName string
	OutputData   any
	Duration     time.Duration
	IsReplay     bool
}

type ActivityFailedInfo struct {
	InstanceID   string
	WorkflowName string
	ActivityID   string
	ActivityName string
	Error        error
	Duration     time.Duration
	Attempt      int
}

type ActivityRetryInfo struct {
	InstanceID   string
	WorkflowName string
	ActivityID   string
	ActivityName string
	Attempt      int
	MaxAttempts  int
	NextDelay    time.Duration
	Error        error
}

type ActivityStartInfo struct {
	InstanceID   string
	WorkflowName string
	ActivityID   string
	ActivityName string
	InputData    any
	IsReplay     bool
}

type EventReceivedInfo struct {
	EventType   string
	EventID     string
	EventSource string
	InstanceID  string
}

type EventTimeoutInfo struct {
	InstanceID   string
	WorkflowName string
	EventType    string
}

type EventWaitCompleteInfo struct {
	InstanceID   string
	WorkflowName string
	EventType    string
	Duration     time.Duration
}

type EventWaitStartInfo struct {
	InstanceID   string
	WorkflowName string
	EventType    string
	Timeout      *time.Duration
}

type NoOpHooks struct{}

type ReplayCompleteInfo struct {
	InstanceID    string
	WorkflowName  string
	CacheHits     int
	NewActivities int
	Duration      time.Duration
}

type ReplayStartInfo struct {
	InstanceID     string
	WorkflowName   string
	HistoryEvents  int
	ResumeActivity string
}

type TimerFiredInfo struct {
	InstanceID   string
	WorkflowName string
	TimerID      string
	FiredAt      time.Time
}

type TimerStartInfo struct {
	InstanceID   string
	WorkflowName string
	TimerID      string
	ExpiresAt    time.Time
}

type WorkflowCancelledInfo struct {
	InstanceID   string
	WorkflowName string
	Reason       string
	Duration     time.Duration
}

type WorkflowCompleteInfo struct {
	InstanceID   string
	WorkflowName string
	OutputData   any
	Duration     time.Duration
}

type WorkflowFailedInfo struct {
	InstanceID   string
	WorkflowName string
	Error        error
	Duration     time.Duration
}

type WorkflowHooks interface {
	// Workflow lifecycle
	OnWorkflowStart(ctx context.Context, info WorkflowStartInfo)
	OnWorkflowComplete(ctx context.Context, info WorkflowCompleteInfo)
	OnWorkflowFailed(ctx context.Context, info WorkflowFailedInfo)
	OnWorkflowCancelled(ctx context.Context, info WorkflowCancelledInfo)

	// Activity lifecycle
	OnActivityStart(ctx context.Context, info ActivityStartInfo)
	OnActivityComplete(ctx context.Context, info ActivityCompleteInfo)
	OnActivityFailed(ctx context.Context, info ActivityFailedInfo)
	OnActivityRetry(ctx context.Context, info ActivityRetryInfo)

	// Event handling
	OnEventReceived(ctx context.Context, info EventReceivedInfo)
	OnEventWaitStart(ctx context.Context, info EventWaitStartInfo)
	OnEventWaitComplete(ctx context.Context, info EventWaitCompleteInfo)
	OnEventTimeout(ctx context.Context, info EventTimeoutInfo)

	// Timer handling
	OnTimerStart(ctx context.Context, info TimerStartInfo)
	OnTimerFired(ctx context.Context, info TimerFiredInfo)

	// Replay
	OnReplayStart(ctx context.Context, info ReplayStartInfo)
	OnReplayComplete(ctx context.Context, info ReplayCompleteInfo)
	OnActivityCacheHit(ctx context.Context, info ActivityCacheHitInfo)
}

type WorkflowStartInfo struct {
	InstanceID   string
	WorkflowName string
	InputData    any
	StartTime    time.Time
}