workflow

type GetFileHandler interface {
	Handle(context.Context, *GetFileQuery) (*WorkflowFile, error)
}

type GetFileQuery struct {
	ID          string `validate:"required"`
	WorkspaceID string `validate:"required"`
	WorkflowID  string `validate:"required"`
}

type GetHandler interface {
	Handle(context.Context, *GetQuery) (*Workflow, error)
}

type GetQuery struct {
	ID          string `validate:"required"`
	WorkspaceID string `validate:"required"`
}

type GetVersionHandler interface {
	Handle(context.Context, *GetVersionQuery) (*WorkflowVersion, error)
}

type GetVersionQuery struct {
	ID          string `validate:"required"`
	WorkspaceID string `validate:"required"`
	WorkflowID  string `validate:"required"`
}

type ListFilesHandler interface {
	Handle(context.Context, *ListFilesQuery) ([]*WorkflowFile, int, error)
}

type ListFilesQuery struct {
	Pg                *utils.Pagination        `json:"pg"`
	Filter            *ListWorkflowFilesFilter `json:"filter"`
	WorkspaceID       string                   `json:"workspaceID"`
	WorkflowID        string                   `json:"workflowID"`
	WorkflowVersionID string                   `json:"workflowVersionID,omitempty"`
}

type ListHandler interface {
	Handle(context.Context, *ListQuery) ([]*Workflow, int, error)
}

type ListQuery struct {
	Pg          *utils.Pagination
	Filter      *ListWorkflowsFilter
	WorkspaceID string
}

type ListVersionsHandler interface {
	Handle(context.Context, *ListVersionsQuery) ([]*WorkflowVersion, int, error)
}

type ListVersionsQuery struct {
	Pg          *utils.Pagination           `json:"pg"`
	WorkflowID  string                      `json:"workflowID"`
	WorkspaceID string                      `json:"workspaceID"`
	Filter      *ListWorkflowVersionsFilter `json:"filter"`
}

type ListWorkflowFilesFilter struct {
	IDs []string
}

type ListWorkflowVersionsFilter struct {
	IDs []string
}

type ListWorkflowsFilter struct {
	SearchWord string
	IDs        []string
	Exact      bool
}

type Queries struct {
	GetByID       GetHandler
	GetFile       GetFileHandler
	GetVersion    GetVersionHandler
	ListWorkflows ListHandler
	ListFiles     ListFilesHandler
	ListVersions  ListVersionsHandler
}

type ReadModel interface {
	GetById(ctx context.Context, workspaceID, id string) (*Workflow, error)
	GetByName(ctx context.Context, workspaceID, name string) (*Workflow, error)
	List(ctx context.Context, workspaceID string, pg *utils.Pagination, filter *ListWorkflowsFilter) ([]*Workflow, int, error)
	GetVersion(ctx context.Context, id string) (*WorkflowVersion, error)
	ListVersions(ctx context.Context, workflowID string, pg *utils.Pagination, filter *ListWorkflowVersionsFilter) ([]*WorkflowVersion, int, error)
	GetFile(ctx context.Context, id string) (*WorkflowFile, error)
	ListFiles(ctx context.Context, workflowVersionID string, pg *utils.Pagination, filter *ListWorkflowFilesFilter) ([]*WorkflowFile, int, error)
}

type Workflow struct {
	ID            string           `json:"id"`
	Name          string           `json:"name"`
	WorkspaceID   string           `json:"workflowID"`
	Description   string           `json:"description"`
	CreatedAt     time.Time        `json:"createdAt"`
	UpdatedAt     time.Time        `json:"updatedAt"`
	LatestVersion *WorkflowVersion `json:"latestVersion"`
}

type WorkflowFile struct {
	ID                string    `json:"id"`
	WorkflowVersionID string    `json:"workflowVersionID"`
	Path              string    `json:"path"`
	Content           string    `json:"content"`
	CreatedAt         time.Time `json:"createdAt"`
	UpdatedAt         time.Time `json:"updatedAt"`
}

type WorkflowFileInfo struct {
	ID   string `json:"id"`
	Path string `json:"path"`
}

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

type WorkflowVersion struct {
	ID               string              `json:"id"`
	Status           string              `json:"status"`
	Message          string              `json:"message"`
	Language         string              `json:"language"`
	LanguageVersion  string              `json:"languageVersion"`
	MainWorkflowPath string              `json:"mainWorkflowPath"`
	Inputs           []WorkflowParam     `json:"inputs,omitempty"`
	Outputs          []WorkflowParam     `json:"outputs,omitempty"`
	Graph            string              `json:"graph,omitempty"`
	Source           string              `json:"source"`
	Files            []*WorkflowFileInfo `json:"files"`
	Metadata         map[string]string   `json:"metadata,omitempty"`
	CreatedAt        time.Time           `json:"createdAt"`
	UpdatedAt        time.Time           `json:"updatedAt"`
}