feat: support browse files on web (#283)

pkg/download/downloader.go

@@ -540,18 +540,7 @@ func (d *Downloader) GetTask(id string) *Task {
 }
 
 func (d *Downloader) GetTasks() []*Task {
-	tasks := make([]*Task, len(d.tasks))
-	for i := 0; i < len(d.tasks); i++ {
-		tasks[i] = d.tasks[i]
-	}
-	// sort tasks by status, order by Status(if(running,1,0)) desc, CreatedAt desc
-	sort.Slice(tasks, func(i, j int) bool {
-		if tasks[i].Status != tasks[j].Status {
-			return tasks[i].Status == base.DownloadStatusRunning
-		}
-		return tasks[i].CreatedAt.After(tasks[j].CreatedAt)
-	})
-	return tasks
+	return d.tasks
 }
 
 func (d *Downloader) GetConfig() (*DownloaderStoreConfig, error) {

pkg/rest/server.go

@@ -105,9 +105,10 @@ func BuildServer(startCfg *model.StartConfig) (*http.Server, net.Listener, error
 	r.Methods(http.MethodDelete).Path("/api/v1/extensions/{identity}").HandlerFunc(DeleteExtension)
 	r.Methods(http.MethodGet).Path("/api/v1/extensions/{identity}/update").HandlerFunc(UpdateCheckExtension)
 	r.Methods(http.MethodPost).Path("/api/v1/extensions/{identity}/update").HandlerFunc(UpdateExtension)
-	r.PathPrefix("/fs/extensions").Handler(http.FileServer(new(extensionFileSystem)))
 	r.Path("/api/v1/proxy").HandlerFunc(DoProxy)
 	if startCfg.WebEnable {
+		r.PathPrefix("/fs/tasks").Handler(http.FileServer(new(taskFileSystem)))
+		r.PathPrefix("/fs/extensions").Handler(http.FileServer(new(extensionFileSystem)))
 		r.PathPrefix("/").Handler(http.FileServer(http.FS(startCfg.WebFS)))
 	}
 
@@ -138,30 +139,56 @@ func BuildServer(startCfg *model.StartConfig) (*http.Server, net.Listener, error
 	return srv, listener, nil
 }
 
+func resolvePath(urlPath string, prefix string) (identity string, path string, err error) {
+	// remove prefix
+	clearPath := strings.TrimPrefix(urlPath, prefix)
+	// match extension identity, eg: /fs/extensions/identity/xxx
+	reg := regexp.MustCompile(`^/([^/]+)/(.*)$`)
+	if !reg.MatchString(clearPath) {
+		err = os.ErrNotExist
+		return
+	}
+	matched := reg.FindStringSubmatch(clearPath)
+	if len(matched) != 3 {
+		err = os.ErrNotExist
+		return
+	}
+	return matched[1], matched[2], nil
+}
+
+// handle task file resource
+type taskFileSystem struct {
+}
+
+func (e *taskFileSystem) Open(name string) (http.File, error) {
+	// get extension identity
+	identity, path, err := resolvePath(name, "/fs/tasks")
+	if err != nil {
+		return nil, err
+	}
+	task := Downloader.GetTask(identity)
+	if task == nil {
+		return nil, os.ErrNotExist
+	}
+	return os.Open(filepath.Join(task.Meta.RootDirPath(), path))
+}
+
 // handle extension file resource
 type extensionFileSystem struct {
 }
 
 func (e *extensionFileSystem) Open(name string) (http.File, error) {
-	// remove prefix
-	path := strings.TrimPrefix(name, "/fs/extensions")
-	// match extension identity, eg: /fs/extensions/identity/xxx
-	reg := regexp.MustCompile(`^/([^/]+)/(.*)$`)
-	if !reg.MatchString(path) {
-		return nil, os.ErrNotExist
-	}
-	matched := reg.FindStringSubmatch(path)
-	if len(matched) != 3 {
-		return nil, os.ErrNotExist
-	}
 	// get extension identity
-	identity := matched[1]
+	identity, path, err := resolvePath(name, "/fs/extensions")
+	if err != nil {
+		return nil, err
+	}
 	extension, err := Downloader.GetExtension(identity)
 	if err != nil {
 		return nil, os.ErrNotExist
 	}
 	extensionPath := Downloader.ExtensionPath(extension)
-	return os.Open(filepath.Join(extensionPath, matched[2]))
+	return os.Open(filepath.Join(extensionPath, path))
 }
 
 func ReadJson(r *http.Request, w http.ResponseWriter, v any) bool {

pkg/rest/server_test.go

@@ -491,6 +491,7 @@ func doTest(handler func()) {
 		cfg.Init()
 		cfg.Storage = storage
 		cfg.StorageDir = ".test_storage"
+		cfg.WebEnable = true
 		fileListener := doStart(cfg)
 		defer func() {
 			if err := fileListener.Close(); err != nil {