eventloop

type BaseSignal struct {
	CtxPayload      *propagator.Payload `json:"ctx_payload"`
	SignalListeners []SignalListener    `json:"signal_listeners"`
	CGroup          string              `json:"cgroup`
}

type Client interface {
	Send(ctx context.Context, id string, signal Signal)
	Cancel(ctx context.Context, namespace, id string) error
	GetWorkflowStatus(ctx context.Context, namespace string, workflowID string) (enumsv1.WorkflowExecutionStatus, error)
	GetWorkflowCount(ctx context.Context, namespace string, workflowID string) (int64, error)
}

type EventLoopRequest struct {
	ID          string
	SandboxMode bool

	// state managed between different signals
	Version            string
	RestartCount       int
	VersionChangeCount int
}

type IDTemplateVars struct {
	// CallerID is the workflow ID of the workflow that is calling this workflow as a child. Set to "root" if there is no parent.
	CallerID string

	// Req is the request argument passed in to the workflow. This is the same as the argument passed to the invoked workflow function.
	Req any
}

type Params struct {
	fx.In

	V      *validator.Validate
	L      *zap.Logger
	Client temporalclient.Client
	MW     metrics.Writer
	Cfg    *internal.Config
	DB     *gorm.DB `name:"psql"`
}

type Signal interface {
	// WorkflowID returns the string ID of the event loop workflow to which this signal is being sent.
	WorkflowID(id string) string
	WorkflowName() string
	Namespace() string
	// Signal name is the same as temporal workflow type
	Name() string
	SignalType() SignalType

	// for managing intra-workflow communication
	Listeners() []SignalListener

	// ConcurrencyGroup returns the name of the concurrency group this signal belongs to.
	// Signals in different concurrency groups execute independently. Signals in the same group
	// execute sequentially in the order they are received by the event loop.
	//
	// The empty string identifies the default group.
	ConcurrencyGroup() string

	// for managing context
	GetOrg(ctx context.Context, id string, db *gorm.DB) (*app.Org, error)
	PropagateContext(ctx cctx.ValueContext) error
	GetWorkflowContext(ctx workflow.Context) workflow.Context
	GetContext(ctx context.Context) context.Context

	// lifecycle methods
	Validate(*validator.Validate) error
	Stop() bool
	Restart() bool
	Start() bool
}

type SignalDoneMessage struct {
	Result any   `json:"result"`
	Error  error `json:"error"`
}

type SignalListener struct {
	// WorkflowID is the id of the workflow that is waiting for a signal.
	WorkflowID string `json:"workflow_id"`
	// Namespace is the namespace of the workflow that is waiting for a signal.
	Namespace string `json:"namespace"`
	// SignalName is the name for the signal that the listening workflow is expecting. This value
	// should be dynamic and ephemeral.
	SignalName string `json:"signal_name"`
}

type SignalType string