internal

type ActivityInfo struct {
	// Name describes public activity name.
	Name string `json:"name"`
}

type Cancel struct {
	// CommandIDs to be canceled.
	CommandIDs []uint64 `json:"ids"`
}

type CancelExternalWorkflow struct {
	Namespace  string `json:"namespace"`
	WorkflowID string `json:"workflowID"`
	RunID      string `json:"runID"`
}

type CancelWorkflow struct {
	// RunID workflow run id.
	RunID string `json:"runId"`
}

type CompleteWorkflow struct{}

type Context struct {
	// TaskQueue associates the message batch with the specific task queue in an underlying worker.
	TaskQueue string `json:"taskQueue,omitempty"`
	// TickTime associated current or historical time with message batch.
	TickTime string `json:"tickTime,omitempty"`
	// Replay indicates that the current message batch is historical.
	Replay bool `json:"replay,omitempty"`
	// History
	HistoryLen int `json:"history_length,omitempty"`
	// HistorySize returns the current byte size of history when called.
	// This value may change throughout the life of the workflow.
	HistorySize int `json:"history_size,omitempty"`
	// RoadRunner run ID
	RrID string `json:"rr_id"`
	// GetContinueAsNewSuggested returns true if the server is configured to suggest 'continue as new',
	// and it is suggested.
	// This value may change throughout the life of the workflow.
	ContinueAsNewSuggested bool `json:"continue_as_new_suggested"`
}

type ContinueAsNew struct {
	// Result defines workflow execution result.
	Name string `json:"name"`

	// Options for continued as a new workflow.
	Options struct {
		TaskQueueName       string
		WorkflowRunTimeout  time.Duration
		WorkflowTaskTimeout time.Duration
	} `json:"options"`
}

type DestroyWorkflow struct {
	// RunID workflow run id.
	RunID string `json:"runId"`
}

type ExecuteActivity struct {
	// Name defines activity name.
	Name string `json:"name"`
	// Options to run activity.
	Options bindings.ExecuteActivityOptions `json:"options,omitempty"`
}

type ExecuteChildWorkflow struct {
	// Name defines workflow name.
	Name string `json:"name"`
	// Options to run activity.
	Options bindings.WorkflowOptions `json:"options,omitempty"`
}

type ExecuteLocalActivity struct {
	// Name defines activity name.
	Name string `json:"name"`
	// Options to run activity.
	Options ExecuteLocalActivityOptions `json:"options,omitempty"`
}

type ExecuteLocalActivityOptions struct {
	ScheduleToCloseTimeout time.Duration
	StartToCloseTimeout    time.Duration
	RetryPolicy            *commonpb.RetryPolicy
}

type GetChildWorkflowExecution struct {
	// ID of child workflow command.
	ID uint64 `json:"id"`
}

type GetStackTrace struct {
	// RunID workflow run id.
	RunID string `json:"runId"`
}

type GetVersion struct {
	ChangeID     string `json:"changeID"`
	MinSupported int    `json:"minSupported"`
	MaxSupported int    `json:"maxSupported"`
}

type GetWorkerInfo struct {
	RRVersion string `json:"rr_version"`
	WWPID     int    `json:"ww_pid"`
}

type InvokeActivity struct {
	// Name defines activity name.
	Name string `json:"name"`

	// Info contains execution context.
	Info activity.Info `json:"info"`

	// HeartbeatDetails indicates that the payload also contains last heartbeat details.
	HeartbeatDetails int `json:"heartbeatDetails,omitempty"`
}

type InvokeLocalActivity struct {
	// Name defines activity name.
	Name string `json:"name"`

	// Info contains execution context.
	Info activity.Info `json:"info"`
}

type InvokeQuery struct {
	// RunID workflow run id.
	RunID string `json:"runId"`
	// Name of the query.
	Name string `json:"name"`
}

type InvokeSignal struct {
	// RunID workflow run id.
	RunID string `json:"runId"`

	// Name of the signal.
	Name string `json:"name"`
}

type InvokeUpdate struct {
	// UpdateID is Workflow update ID
	UpdateID string `json:"updateId"`
	// RunID workflow run id.
	RunID string `json:"runId"`
	// Name of the query.
	Name string `json:"name"`
	// Type of the update request.
	Type string `json:"type"`
}

type Message struct {
	// ID contains ID of the command, response or error.
	ID uint64 `json:"id"`
	// Command of the message in unmarshalled form. Pointer.
	Command any `json:"command,omitempty"`
	// Failure associated with command id.
	Failure *failure.Failure `json:"failure,omitempty"`
	// Payloads contain message-specific payloads in binary format.
	Payloads *commonpb.Payloads `json:"payloads,omitempty"`
	// Header
	Header *commonpb.Header `json:"header,omitempty"`
}

type NewTimer struct {
	// Milliseconds defines timer duration.
	Milliseconds int `json:"ms"`
	// Summary is a simple string identifying this timer. While it can be
	// normal text, it is best to treat as a timer ID. This value will be
	// visible in UI and CLI.
	//
	// NOTE: Experimental
	Summary string `json:"summary"`
}

type Panic struct {
	// Message to include in the error.
	Message string `json:"message"`
}

type SideEffect struct{}

type SignalExternalWorkflow struct {
	Namespace         string `json:"namespace"`
	WorkflowID        string `json:"workflowID"`
	RunID             string `json:"runID"`
	Signal            string `json:"signal"`
	ChildWorkflowOnly bool   `json:"childWorkflowOnly"`
}

type StartWorkflow struct {
	// Info to define workflow context.
	Info *workflow.Info `json:"info"`
	// LastCompletion contains offset of last completion results.
	LastCompletion int `json:"lastCompletion,omitempty"`
	// Typed search attributes
	SearchAttributes map[string]*TypedSearchAttribute `json:"search_attributes,omitempty"`
}

type TypedSearchAttribute struct {
	Type      TypedSearchAttributeType      `json:"type"`
	Operation TypedSearchAttributeOperation `json:"operation,omitempty"`
	Value     any                           `json:"value"`
}

type TypedSearchAttributeOperation string

type TypedSearchAttributeType string

type UndefinedResponse struct {
	Message string `json:"message"`
}

type UpdateCompleted struct {
	ID string `json:"id"`
}

type UpdateValidated struct {
	ID string `json:"id"`
}

type UpsertMemo struct {
	// Memos to update.
	Memo map[string]any `json:"memo"`
}

type UpsertWorkflowSearchAttributes struct {
	SearchAttributes map[string]any `json:"searchAttributes"`
}

type UpsertWorkflowTypedSearchAttributes struct {
	SearchAttributes map[string]*TypedSearchAttribute `json:"search_attributes"`
}

type WorkerInfo struct {
	// TaskQueue assigned to the worker.
	TaskQueue string `json:"TaskQueue"`
	// Options describe worker options.
	Options worker.Options `json:"options,omitempty"`
	// PhpSdkVersion is the underlying PHP-SDK version
	PhpSdkVersion string `json:"PhpSdkVersion,omitempty"`
	// Flags are internal worker flags.
	Flags map[string]string `json:"Flags,omitempty"`
	// Workflows provided by the worker.
	Workflows []WorkflowInfo
	// Activities provided by the worker.
	Activities []ActivityInfo
}

type WorkflowInfo struct {
	// Name of the workflow.
	Name string `json:"name"`
	// Queries pre-defined for the workflow type.
	Queries []string `json:"queries"`
	// Signals pre-defined for the workflow type.
	Signals []string `json:"signals"`
	// VersioningBehavior for the workflow.
	VersioningBehavior workflow.VersioningBehavior `json:"versioning_behavior,omitempty"`
}