spider

type AddActionRequest struct {
	TenantID   string            `json:"tenant_id"`
	WorkflowID string            `json:"workflow_id"`
	Key        string            `json:"key"`
	ActionID   string            `json:"action_id"`
	Config     map[string]string `json:"config"`
	Map        map[string]Mapper `json:"map"`
	Meta       map[string]string `json:"meta,omitempty"`
}

type CreateFlowRequest struct {
	ID          string            `json:"id"`
	TenantID    string            `json:"tenant_id"`
	Name        string            `json:"name"`
	TriggerType FlowTriggerType   `json:"trigger_type"`
	Meta        map[string]string `json:"meta,omitempty"`
}

type Flow struct {
	ID          string            `json:"id"`
	TenantID    string            `json:"tenant_id"`
	Name        string            `json:"name"`
	TriggerType FlowTriggerType   `json:"trigger_type"`
	Meta        map[string]string `json:"meta,omitempty"`
	Status      FlowStatus        `json:"status"`
	Version     uint64            `json:"version"`
}

type FlowListResponse struct {
	Flows    []WorkflowInfo `json:"flows"`
	Total    int64          `json:"total"`
	Page     int            `json:"page"`
	PageSize int            `json:"page_size"`
}

type FlowStatus string

type FlowTriggerType string

type InitMongodDBWorkflowStorageAdapterOpt struct {
	BetaAutoSetupSchema bool
}

type InitNATSWorkerMessengerAdapterOpt struct {
	BetaAutoSetupNATS bool
}

type InitNATSWorkflowMessengerAdapterOpt struct {
	BetaAutoSetupNATS bool
}

type InputMessage struct {
	SessionID  string
	TaskID     string
	TenantID   string
	WorkflowID string
	// TODO
	// WorkflowActionID string
	Key      string
	ActionID string
	Values   string
}

type InputMessageContext struct {
	Context    context.Context
	Timestamp  time.Time
	SendOutput func(metaOutput string, values string) error
}

type MDFlow struct {
	ID          string            `bson:"_id"`
	Version     uint64            `bson:"version"`
	Name        string            `bson:"name"`
	TenantID    string            `bson:"tenant_id"`
	TriggerType FlowTriggerType   `bson:"trigger_type"`
	Meta        map[string]string `bson:"meta,omitempty"`
	Status      FlowStatus        `bson:"status"`
}

type MDWorkflowAction struct {
	ID         string            `bson:"_id"`
	Key        string            `bson:"key"`         // Composite unique index
	TenantID   string            `bson:"tenant_id"`   // Composite unique index
	WorkflowID string            `bson:"workflow_id"` // Composite unique index
	ActionID   string            `bson:"action_id"`
	Config     map[string]string `bson:"config"`
	Map        map[string]Mapper `bson:"map"`
	Meta       map[string]string `bson:"meta,omitempty"`
	Disabled   bool              `bson:"disabled"`
}

type MDWorkflowActionDep struct {
	ID         string `bson:"_id"`
	WorkflowID string `bson:"workflow_id"` // Composite unique index
	Key        string `bson:"key"`         // Composite unique index
	MetaOutput string `bson:"meta_output"` // Composite unique index
	DepKey     string `bson:"dep_key"`     // Composite unique index
}

type MDWorkflowSessionContext struct {
	ID         string                            `bson:"_id"`
	WorkflowID string                            `bson:"workflow_id"` // Composite unique index
	SessionID  string                            `bson:"session_id"`  // Composite unique index
	TaskID     string                            `bson:"task_id"`     // Composite unique index
	Value      map[string]map[string]interface{} `bson:"value"`
}

type Mapper struct {
	Mode  MapperMode `json:"mode"`
	Value string     `json:"value"`
}

type MapperMode string

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

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

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

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

type NatsInputMessage struct {
	SessionID  string `json:"session_id"`
	TaskID     string `json:"task_id"`
	WorkflowID string `json:"workflow_id"`
	TenantID   string `json:"tenant_id"`
	// TODO
	// WorkflowActionID string `json:"workflow_action_id"`
	Key      string `json:"key"`
	ActionID string `json:"action_id"`
	Values   string `json:"values"`
}

type NatsOutputMessage struct {
	SessionID  string `json:"session_id"`
	TaskID     string `json:"task_id"`
	WorkflowID string `json:"workflow_id"`
	TenantID   string `json:"tenant_id"`
	// TODO
	// WorkflowActionID string `json:"workflow_action_id"`
	MetaOutput string `json:"meta_output"`
	Key        string `json:"key"`
	ActionID   string `json:"action_id"`
	Values     string `json:"values"`
}

type NatsTriggerMessage struct {
	WorkflowID string `json:"workflow_id"`
	TenantID   string `json:"tenant_id"`
	// TODO
	// WorkflowActionID string `json:"workflow_action_id"`
	MetaOutput string `json:"meta_output"`
	Key        string `json:"key"`
	ActionID   string `json:"action_id"`
	Values     string `json:"values"`
}

type OutputMessage struct {
	SessionID  string
	TaskID     string
	TenantID   string
	WorkflowID string
	// TODO
	// WorkflowActionID string
	Key        string
	ActionID   string
	MetaOutput string
	Values     string
}

type OutputMessageContext struct {
	Context   context.Context
	Timestamp time.Time
}

type TriggerMessage struct {
	TenantID   string
	WorkflowID string
	// TODO
	// WorkflowActionID string
	Key        string
	ActionID   string
	MetaOutput string
	Values     string
}

type TriggerMessageContext struct {
	Context   context.Context
	Timestamp time.Time
}

type UpdateActionRequest struct {
	TenantID   string            `json:"tenant_id"`
	WorkflowID string            `json:"workflow_id"`
	Key        string            `json:"key"`
	Config     map[string]string `json:"config"`
	Map        map[string]Mapper `json:"map"`
	Meta       map[string]string `json:"meta,omitempty"`
}

type UpdateFlowRequest struct {
	TenantID    string            `json:"tenant_id"`
	FlowID      string            `json:"flow_id"`
	Name        string            `json:"name"`
	TriggerType FlowTriggerType   `json:"trigger_type"`
	Meta        map[string]string `json:"meta,omitempty"`
	Status      FlowStatus        `json:"status"`
}

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

type WorkerConfig struct {
	WorkflowActionID string            `json:"workflow_action_id"`
	TenantID         string            `json:"tenant_id"`
	WorkflowID       string            `json:"workflow_id"`
	Key              string            `json:"key"`
	Config           map[string]string `json:"config"`
	Meta             map[string]string `json:"meta,omitempty"`
}

type WorkerMessengerAdapter interface {
	ListenInputMessages(ctx context.Context, h func(c InputMessageContext, message InputMessage) error) error
	SendTriggerMessage(ctx context.Context, message TriggerMessage) error
	SendOutputMessage(ctx context.Context, message OutputMessage) error
	Close(ctx context.Context) error
}

type WorkerStorageAdapter interface {
	GetAllConfigs(ctx context.Context, actionID string) ([]WorkerConfig, error)
	Close(ctx context.Context) error
}

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

type WorkflowAction struct {
	ID         string            `json:"id"`
	Key        string            `json:"key"`
	TenantID   string            `json:"tenant_id"`
	WorkflowID string            `json:"workflow_id"`
	ActionID   string            `json:"action_id"`
	Config     map[string]string `json:"config"`
	Map        map[string]Mapper `json:"map"`
	Meta       map[string]string `json:"meta,omitempty"`
	Disabled   bool              `json:"disabled"`
}

type WorkflowInfo struct {
	ID          string            `json:"id"`
	TenantID    string            `json:"tenant_id"`
	Name        string            `json:"name"`
	TriggerType FlowTriggerType   `json:"trigger_type"`
	Status      FlowStatus        `json:"status"`
	Version     uint64            `json:"version"`
	Meta        map[string]string `json:"meta,omitempty"`
}

type WorkflowMessengerAdapter interface {
	ListenTriggerMessages(ctx context.Context, h func(c TriggerMessageContext, message TriggerMessage) error) error
	ListenOutputMessages(ctx context.Context, h func(c OutputMessageContext, message OutputMessage) error) error
	SendInputMessage(ctx context.Context, message InputMessage) error
	Close(ctx context.Context) error
}

type WorkflowPeer struct {
	ParentKey  string `json:"parent_key"`
	MetaOutput string `json:"meta_output"`
	ChildKey   string `json:"child_key"`
}

type WorkflowStorageAdapter interface {
	QueryWorkflowAction(ctx context.Context, tenantID, workflowID, key string) (*WorkflowAction, error)
	QueryWorkflowActionDependencies(ctx context.Context, tenantID, workflowID, key, metaOutput string) ([]WorkflowAction, error)
	AddAction(ctx context.Context, req *AddActionRequest) (*WorkflowAction, error)
	DeleteAction(ctx context.Context, tenantID, workflowID, key string) error
	DeleteAllActions(ctx context.Context, tenantID, workflowID string) error
	AddDep(ctx context.Context, tenantID, workflowID, key, metaOutput, key2 string) error
	DeleteAllDeps(ctx context.Context, tenantID, workflowID string) error
	GetSessionContext(ctx context.Context, workflowID, sessionID, taskID string) (map[string]map[string]interface{}, error)
	CreateSessionContext(ctx context.Context, workflowID, sessionID, taskID string, value map[string]map[string]interface{}) error
	DeleteSessionContext(ctx context.Context, workflowID, sessionID, taskID string) error
	DisableWorkflowAction(ctx context.Context, tenantID, workflowID, key string) error
	ListFlows(ctx context.Context, tenantID string, page, pageSize int) (*FlowListResponse, error)
	GetWorkflowActions(ctx context.Context, tenantID, workflowID string) ([]WorkflowAction, error)
	GetWorkflowPeers(ctx context.Context, tenantID, workflowID string) ([]WorkflowPeer, error)
	UpdateAction(ctx context.Context, req *UpdateActionRequest) (*WorkflowAction, error)
	CreateFlow(ctx context.Context, req *CreateFlowRequest) (*Flow, error)
	GetFlow(ctx context.Context, tenantID, flowID string) (*Flow, error)
	UpdateFlow(ctx context.Context, req *UpdateFlowRequest) (*Flow, error)
	DeleteFlow(ctx context.Context, tenantID, flowID string) error
	Close(ctx context.Context) error
}