workflows

func CancelExecution(ctx context.Context, authService authorization.Authorization, encryptor crypto.Encryptor, organizationID string, registry *registry.Registry, workflowID, executionID uuid.UUID) (*pb.CancelExecutionResponse, error)

func CreateWorkflow(ctx context.Context, registry *registry.Registry, organizationID string, pbWorkflow *pb.Workflow) (*pb.CreateWorkflowResponse, error)

func DeleteNodeQueueItem(ctx context.Context, registry *registry.Registry, workflowID, nodeID, itemID string) (*pb.DeleteNodeQueueItemResponse, error)

func DeleteWorkflow(ctx context.Context, registry *registry.Registry, organizationID uuid.UUID, id string) (*pb.DeleteWorkflowResponse, error)

func DescribeWorkflow(ctx context.Context, registry *registry.Registry, organizationID string, id string) (*pb.DescribeWorkflowResponse, error)

func EmitNodeEvent(
	ctx context.Context,
	orgID uuid.UUID,
	workflowID uuid.UUID,
	nodeID string,
	channel string,
	data map[string]any,
) (*pb.EmitNodeEventResponse, error)

func ExpandNodes(organizationID string, nodes []models.Node) ([]models.Node, error)

func InvokeNodeExecutionAction(
	ctx context.Context,
	authService authorization.Authorization,
	encryptor crypto.Encryptor,
	registry *registry.Registry,
	orgID uuid.UUID,
	workflowID uuid.UUID,
	executionID uuid.UUID,
	actionName string,
	parameters map[string]any,
) (*pb.InvokeNodeExecutionActionResponse, error)

func InvokeNodeTriggerAction(
	ctx context.Context,
	authService authorization.Authorization,
	encryptor crypto.Encryptor,
	registry *registry.Registry,
	orgID uuid.UUID,
	workflowID uuid.UUID,
	nodeID string,
	actionName string,
	parameters map[string]any,
	webhookBaseURL string,
) (*pb.InvokeNodeTriggerActionResponse, error)

func ListChildExecutions(ctx context.Context, registry *registry.Registry, workflowID, executionID uuid.UUID) (*pb.ListChildExecutionsResponse, error)

func ListEventExecutions(ctx context.Context, registry *registry.Registry, workflowID, eventID string) (*pb.ListEventExecutionsResponse, error)

func ListNodeEvents(ctx context.Context, registry *registry.Registry, workflowID uuid.UUID, nodeID string, limit uint32, before *timestamppb.Timestamp) (*pb.ListNodeEventsResponse, error)

func ListNodeExecutions(ctx context.Context, registry *registry.Registry, workflowID, nodeID string, pbStates []pb.WorkflowNodeExecution_State, pbResults []pb.WorkflowNodeExecution_Result, limit uint32, before *timestamppb.Timestamp) (*pb.ListNodeExecutionsResponse, error)

func ListNodeQueueItems(ctx context.Context, registry *registry.Registry, workflowID, nodeID string, limit uint32, before *timestamppb.Timestamp) (*pb.ListNodeQueueItemsResponse, error)

func ListWorkflowEvents(ctx context.Context, registry *registry.Registry, workflowID uuid.UUID, limit uint32, before *timestamppb.Timestamp) (*pb.ListWorkflowEventsResponse, error)

func ListWorkflows(ctx context.Context, registry *registry.Registry, organizationID string, includeTemplates bool) (*pb.ListWorkflowsResponse, error)

func NodeExecutionResultReasonToProto(reason string) pb.WorkflowNodeExecution_ResultReason

func NodeExecutionResultToProto(result string) pb.WorkflowNodeExecution_Result

func NodeExecutionStateToProto(state string) pb.WorkflowNodeExecution_State

func ParseWorkflow(registry *registry.Registry, orgID string, workflow *pb.Workflow) ([]models.Node, []models.Edge, error)

func ProtoToNodeExecutionResult(result pb.WorkflowNodeExecution_Result) (string, error)

func ProtoToNodeExecutionState(state pb.WorkflowNodeExecution_State) (string, error)

func ResolveExecutionErrors(ctx context.Context, workflowID uuid.UUID, executionIDs []uuid.UUID) (*pb.ResolveExecutionErrorsResponse, error)

func SerializeNodeExecutions(executions []models.WorkflowNodeExecution, childExecutions []models.WorkflowNodeExecution) ([]*pb.WorkflowNodeExecution, error)

func SerializeNodeExecutionsForSingleNode(node *models.WorkflowNode, executions []models.WorkflowNodeExecution) ([]*pb.WorkflowNodeExecution, error)

func SerializeNodeQueueItems(queueItems []models.WorkflowNodeQueueItem) ([]*pb.WorkflowNodeQueueItem, error)

func SerializeWorkflow(workflow *models.Workflow, includeStatus bool) (*pb.Workflow, error)

func SerializeWorkflowEvent(event models.WorkflowEvent) (*pb.WorkflowEvent, error)

func SerializeWorkflowEventWithExecutions(event models.WorkflowEvent, executions []models.WorkflowNodeExecution, childExecutions []models.WorkflowNodeExecution) (*pb.WorkflowEventWithExecutions, error)

func SerializeWorkflowEvents(events []models.WorkflowEvent) ([]*pb.WorkflowEvent, error)

func SerializeWorkflowEventsWithExecutions(events []models.WorkflowEvent, executionsByEventID map[string][]models.WorkflowNodeExecution, childExecutionsByEventID map[string][]models.WorkflowNodeExecution) ([]*pb.WorkflowEventWithExecutions, error)

func UpdateWorkflow(ctx context.Context, encryptor crypto.Encryptor, registry *registry.Registry, organizationID string, id string, pbWorkflow *pb.Workflow, webhookBaseURL string) (*pb.UpdateWorkflowResponse, error)