refacor: add subtask register

apache · Jun 22, 2023 · 0e2daef · 0e2daef
1 parent e2e7fac
commit 0e2daef
Showing 1 changed file with 10 additions and 12 deletions.
diff --git a/backend/plugins/feishu/impl/impl.go b/backend/plugins/feishu/impl/impl.go
@@ -25,7 +25,6 @@ import (
 	"github.com/apache/incubator-devlake/core/errors"
 	"github.com/apache/incubator-devlake/core/plugin"
 	helper "github.com/apache/incubator-devlake/helpers/pluginhelper/api"
-	"github.com/apache/incubator-devlake/helpers/pluginhelper/subtaskmeta_sorter"
 	"github.com/apache/incubator-devlake/plugins/feishu/api"
 	"github.com/apache/incubator-devlake/plugins/feishu/models"
 	"github.com/apache/incubator-devlake/plugins/feishu/models/migrationscripts"
@@ -43,16 +42,6 @@ var _ interface {
 	plugin.CloseablePluginTask
 } = (*Feishu)(nil)
 
-var sortedSubtaskPlugins []plugin.SubTaskMeta
-
-func init() {
-	var err error
-	sortedSubtaskPlugins, err = subtaskmeta_sorter.NewTableSorter(tasks.SubtaskMetas).Sort()
-	if err != nil {
-		panic(err)
-	}
-}
-
 type Feishu struct{}
 
 func (p Feishu) Init(basicRes context.BasicRes) errors.Error {
@@ -89,7 +78,16 @@ func (p Feishu) ScopeConfig() dal.Tabler {
 }
 
 func (p Feishu) SubTaskMetas() []plugin.SubTaskMeta {
-	return sortedSubtaskPlugins
+	return []plugin.SubTaskMeta{
+		tasks.CollectChatMeta,
+		tasks.ExtractChatItemMeta,
+
+		tasks.CollectMessageMeta,
+		tasks.ExtractMessageMeta,
+
+		tasks.CollectMeetingTopUserItemMeta,
+		tasks.ExtractMeetingTopUserItemMeta,
+	}
 }
 
 func (p Feishu) PrepareTaskData(taskCtx plugin.TaskContext, options map[string]interface{}) (interface{}, errors.Error) {