workflow

type Factory struct{}

type FileParam struct {
	Path    string
	Content string
}

type ImportWorkflowsEvent struct {
	WorkspaceID       string
	Schemas           []schema.WorkflowTypedSchema
	ImportFileBaseDir string
}

type ImportWorkflowsHandler struct {
	// contains filtered or unexported fields
}

type Param struct {
	ID            string
	Name          string
	WorkspaceID   string
	Description   string
	LatestVersion string
	CreateTime    time.Time
	UpdateTime    time.Time
	DeletedAt     time.Time
}

type Repository interface {
	Save(context.Context, *Workflow) error
	Get(context.Context, string, string) (*Workflow, error)
	Delete(context.Context, *Workflow) error
	List(ctx context.Context, workspaceID string) ([]string, error)
}

type Service interface {
	Create(ctx context.Context, workspaceID string, workflowOption *WorkflowOption) (string, error)
	Delete(ctx context.Context, workspaceID string, workflowID string) error
	Update(ctx context.Context, workspaceID string, workflowID string, workflowOption *WorkflowOption) error
	AddVersion(ctx context.Context, workspaceID string, workflowOption *WorkflowOption, versionOption *VersionOption) (string, *WorkflowVersion, error)
	UpdateVersion(ctx context.Context, workspaceID string, workflowOption *WorkflowOption, versionOption *VersionUpdateOption) error
}

type VersionOption struct {
	Language         string
	MainWorkflowPath string
	Source           string
	Url              string
	Tag              string
	Token            string
}

type VersionUpdateOption struct {
	Language         *string
	MainWorkflowPath *string
	Source           *string
	URL              *string
	Tag              *string
	Token            *string
}

type Workflow struct {
	// ID is the unique identifier of the workflow
	ID string
	// Name is the name of the workflow
	Name string
	// WorkspaceID is the ID of the workspace
	WorkspaceID string
	// Description is the description of the workflow
	Description string
	// LatestVersion is the latest version of the workflow
	LatestVersion string
	// Versions is the versions of the workflow
	Versions map[string]*WorkflowVersion
	// CreatedAt is the create time of workflow version
	CreatedAt time.Time
	// UpdatedAt is the update time of workflow version
	UpdatedAt time.Time
}

type WorkflowEvent struct {
	WorkspaceID string
	WorkflowID  string
	Event       string
}

type WorkflowFile struct {
	// ID is the unique identifier of the workflow file
	ID string
	// Path filename with path
	Path string
	// Content file content
	Content string
	// CreatedAt is the create time of workflow file
	CreatedAt time.Time
	// UpdatedAt is the update time of workflow file
	UpdatedAt time.Time
}

type WorkflowOption struct {
	ID          string
	Name        string
	Description *string
}

type WorkflowParam struct {
	// Name param name
	Name string `json:"name"`
	// Type param type
	Type string `json:"type"`
	// Optional param is optional
	Optional bool `json:"optional"`
	// Default param default value
	Default string `json:"default,omitempty"`
}

type WorkflowVersion struct {
	// ID is the unique identifier of the workflow version
	ID string
	// Status is the status of the workflow version
	Status string
	// Message is the message of the workflow version
	Message string
	// Language is the language of the workflow version
	Language string
	// LanguageVersion is the language version of the workflow version
	LanguageVersion string
	// MainWorkflowPath is the main file of the workflow version
	MainWorkflowPath string
	// Inputs is the inputs of the workflow version
	Inputs []WorkflowParam
	// Outputs is the outputs of the workflow version
	Outputs []WorkflowParam
	// Graph is the graph of the workflow version
	Graph string
	// Metadata is the metadata of the workflow version
	Metadata map[string]string
	// Source is the source of the workflow version, eg. git,file
	Source string
	// Files is the files of the workflow
	Files map[string]*WorkflowFile
	// CreatedAt is the create time of workflow version
	CreatedAt time.Time
	// UpdatedAt is the update time of workflow version
	UpdatedAt time.Time
}

type WorkflowVersionAddedEvent struct {
	WorkspaceID       string
	WorkflowID        string
	WorkflowVersionID string
	GitRepo           string
	GitTag            string
	GitToken          string
	//used to import workflow version from file. its priority is over Git
	FilesBaseDir string
}

type WorkflowVersionAddedHandler struct {
	// contains filtered or unexported fields
}

type WorkspaceDeletedHandler struct {
	// contains filtered or unexported fields
}