package dag

import (
	"github.com/tidbcloud/dataflow-service-ng/app/container"
	"github.com/tidbcloud/dataflow-service-ng/app/workflow"
	dag_biz_changefeed "github.com/tidbcloud/dataflow-service-ng/app/workflow/dag/biz_changefeed"
)

func RegisterDags() error {
	if err := registerDags(container.Global().WorkflowModel); err != nil {
		return err
	}
	return nil
}

func registerDags(workflowModel workflow.Workflow) error {
	if err := workflowModel.RegisterDag(dag_biz_changefeed.GetCreateBizChangefeedDag()); err != nil {
		return err
	}
	if err := workflowModel.RegisterDag(dag_biz_changefeed.GetScaleBizChangefeedDag()); err != nil {
		return err
	}
	if err := workflowModel.RegisterDag(dag_biz_changefeed.GetDeleteBizChangefeedDag()); err != nil {
		return err
	}
	return nil
}