refactor: Support edge nodes to obtain task stdout and stderr through the central API

Author: SenCoder

src/models/task_meta.go

@@ -292,12 +292,22 @@ func (m *TaskMeta) HostStrs() ([]string, error) {
 }
 
 func (m *TaskMeta) Stdouts() ([]TaskHost, error) {
+	if !config.C.IsCenter {
+		path := fmt.Sprintf("/ibex/v1/task/%d/stdout", m.Id)
+		return poster.GetByUrlsWithResp[[]TaskHost](config.C.CenterApi, path)
+	}
+
 	var ret []TaskHost
 	err := DB().Table(tht(m.Id)).Where("id=?", m.Id).Select("id", "host", "status", "stdout").Order("ii").Find(&ret).Error
 	return ret, err
 }
 
 func (m *TaskMeta) Stderrs() ([]TaskHost, error) {
+	if !config.C.IsCenter {
+		path := fmt.Sprintf("/ibex/v1/task/%d/stderr", m.Id)
+		return poster.GetByUrlsWithResp[[]TaskHost](config.C.CenterApi, path)
+	}
+
 	var ret []TaskHost
 	err := DB().Table(tht(m.Id)).Where("id=?", m.Id).Select("id", "host", "status", "stderr").Order("ii").Find(&ret).Error
 	return ret, err

src/pkg/poster/post.go

@@ -28,3 +28,9 @@ func PostByUrlsWithResp[T any](centerApi conf.CenterApi, path string, v interfac
 
 	return poster.PostByUrlsWithResp[T](n9eCtx, path, v)
 }
+
+func GetByUrlsWithResp[T any](centerApi conf.CenterApi, path string) (t T, err error) {
+	n9eCtx := NewN9eCtx(centerApi)
+
+	return poster.GetByUrls[T](n9eCtx, path)
+}