release: v1.6.7

.github/workflows/build.yml

@@ -4,17 +4,17 @@ on:
   workflow_dispatch:
     inputs:
       platform:
-        description: 'Build platform'
+        description: "Build platform"
         required: true
-        default: 'all'
+        default: "all"
       test:
-        description: 'Test mode'
+        description: "Test mode"
         required: true
         default: "false"
 
 env:
   GO_VERSION: "1.23"
-  FLUTTER_VERSION: "3.16.8"
+  FLUTTER_VERSION: "3.24.5"
 
 permissions:
   contents: write
@@ -97,11 +97,13 @@ jobs:
           PrivilegesRequired=lowest
           OutputBaseFilename=gopeed
           SetupIconFile=..\..\assets\icon\icon.ico
+          UninstallDisplayIcon={app}\{#MyAppExeName}
           Compression=lzma
           SolidCompression=yes
           WizardStyle=modern
           LanguageDetectionMethod=uilanguage
           ShowLanguageDialog=yes
+          CloseApplications=force
 
           [Languages]
           Name: "english"; MessagesFile: "compiler:Default.isl"
@@ -111,7 +113,7 @@ jobs:
           Name: "desktopicon"; Description: "{cm:CreateDesktopIcon}"; GroupDescription: "{cm:AdditionalIcons}"; Flags: unchecked
 
           [Files]
-          Source: ".\x64\runner\Release\*"; DestDir: "{app}"; Flags: ignoreversion recursesubdirs
+          Source: ".\x64\runner\Release\*"; DestDir: "{app}"; Flags: ignoreversion recursesubdirs;
           ; NOTE: Don't use "Flags: ignoreversion" on any shared system files
 
           [UninstallDelete]
@@ -366,7 +368,7 @@ jobs:
       - uses: actions/setup-java@v3
         with:
           distribution: "zulu"
-          java-version: "11"
+          java-version: "17"
       - uses: subosito/flutter-action@v2
         with:
           flutter-version: ${{ env.FLUTTER_VERSION }}
@@ -443,7 +445,7 @@ jobs:
         run: |
           VERSION=${VERSION:-$(date +%y%m%d%H%M)} # Use current time as version if not specified
           cd ui/flutter
-          flutter build web --web-renderer html
+          flutter build web --no-web-resources-cdn
           cd ../../
           cp -r ui/flutter/build/web cmd/web/dist
           mkdir -p dist/zip
@@ -533,7 +535,7 @@ jobs:
       - name: Build flutter web
         run: |
           cd ui/flutter
-          flutter build web --web-renderer html
+          flutter build web --no-web-resources-cdn
           cd ../../
           rm -rf cmd/web/dist
           cp -r ui/flutter/build/web cmd/web/dist

.github/workflows/test.yml

@@ -28,7 +28,7 @@ on:
 
 env:
   GO_VERSION: "1.23"
-  FLUTTER_VERSION: "3.16.8"
+  FLUTTER_VERSION: "3.24.5"
 
 jobs:
   #  lint:
@@ -73,17 +73,17 @@ jobs:
       - uses: subosito/flutter-action@v2
         with:
           flutter-version: ${{ env.FLUTTER_VERSION }}
-      - if: runner.os == 'windows'
+      - if: runner.os == 'windows-latest'
         run: |
           go build -tags nosqlite -ldflags="-w -s" -buildmode=c-shared -o ui/flutter/windows/libgopeed.dll github.com/GopeedLab/gopeed/bind/desktop
           cd ui/flutter
           flutter build windows
-      - if: runner.os == 'macOS'
+      - if: runner.os == 'macos-latest'
         run: |
           go build -tags nosqlite -ldflags="-w -s" -buildmode=c-shared -o ui/flutter/macos/Frameworks/libgopeed.dylib github.com/GopeedLab/gopeed/bind/desktop
           cd ui/flutter
           flutter build macos
-      - if: runner.os == 'Linux'
+      - if: runner.os == 'ubuntu-latest'
         run: |
           sudo apt-get update -y
           sudo apt-get install -y ninja-build libgtk-3-dev libayatana-appindicator3-dev
@@ -140,7 +140,7 @@ jobs:
       - name: Build
         run: |
           cd ui/flutter
-          flutter build web --web-renderer html
+          flutter build web --no-web-resources-cdn
           cd ../../
           rm -rf cmd/web/dist
           cp -r ui/flutter/build/web cmd/web/dist
@@ -160,7 +160,7 @@ jobs:
       - name: Build
         run: |
           cd ui/flutter
-          flutter build web --web-renderer html
+          flutter build web --no-web-resources-cdn
           cd ../../
           rm -rf cmd/web/dist
           cp -r ui/flutter/build/web cmd/web/dist

README.md

@@ -71,6 +71,11 @@ Visit ✈ [Official Website](https://gopeed.com) | 📖 [Official Docs](https://
             <td><code>IPA</code></td>
             <td><a href="https://gopeed.com/api/download?tpl=Gopeed-$version-ios.ipa">Link</a></td>
         </tr>
+        <tr>
+            <td>Qnap</td>
+            <td><code>QPKG</code></td>
+            <td><a href="https://gopeed.com/api/download?tpl=gopeed-qnap-$version-amd64.qpkg">Link</a></td>
+        </tr>
         <tr>
             <td>Web</td>
             <td></td>
@@ -115,7 +120,7 @@ This project is divided into two parts, the front end uses `flutter`, the back e
 ### Environment
 
 1. Golang 1.23+
-2. Flutter 3.16+
+2. Flutter 3.24+
 
 ### Clone
 
@@ -174,7 +179,7 @@ command:
 - android
 
 ```bash
-gomobile bind -tags nosqlite -ldflags="-w -s" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
+gomobile bind -tags nosqlite -ldflags="-w -s -checklinkname=0" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
 cd ui/flutter
 flutter build apk
 ```

README_ja-JP.md

@@ -71,6 +71,11 @@ Gopeed (正式名 Go Speed) は `Golang` + `Flutter` によって開発された
             <td><code>IPA</code></td>
             <td><a href="https://gopeed.com/api/download?tpl=Gopeed-$version-ios.ipa">Link</a></td>
         </tr>
+        <tr>
+            <td>Qnap</td>
+            <td><code>QPKG</code></td>
+            <td><a href="https://gopeed.com/api/download?tpl=gopeed-qnap-$version-amd64.qpkg">Link</a></td>
+        </tr>
         <tr>
             <td>Web</td>
             <td></td>
@@ -103,7 +108,7 @@ Gopeed (正式名 Go Speed) は `Golang` + `Flutter` によって開発された
 ### 環境
 
 1. Go 言語 1.23+
-2. Flutter 3.16+
+2. Flutter 3.24+
 
 ### クローン
 
@@ -162,7 +167,7 @@ gomobile init
 - android
 
 ```bash
-gomobile bind -tags nosqlite -ldflags="-w -s" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
+gomobile bind -tags nosqlite -ldflags="-w -s -checklinkname=0" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
 cd ui/flutter
 flutter build apk
 ```

README_vi-VN.md

@@ -71,6 +71,11 @@ Truy cập ✈ [Trang web chính thức](https://gopeed.com) | 📖 [Tài liệu
             <td><code>IPA</code></td>
             <td><a href="https://gopeed.com/api/download?tpl=Gopeed-$version-ios.ipa">Liên kết</a></td>
         </tr>
+        <tr>
+            <td>Qnap</td>
+            <td><code>QPKG</code></td>
+            <td><a href="https://gopeed.com/api/download?tpl=gopeed-qnap-$version-amd64.qpkg">Liên kết</a></td>
+        </tr>
         <tr>
             <td>Web</td>
             <td></td>
@@ -111,7 +116,7 @@ Dự án này được chia thành hai phần, phần giao diện sử dụng `f
 ### Environment
 
 1. Golang 1.23+
-2. Flutter 3.16+
+2. Flutter 3.24+
 
 ### Clone
 
@@ -170,7 +175,7 @@ command:
 - android
 
 ```bash
-gomobile bind -tags nosqlite -ldflags="-w -s" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
+gomobile bind -tags nosqlite -ldflags="-w -s -checklinkname=0" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
 cd ui/flutter
 flutter build apk
 ```

README_zh-CN.md

@@ -71,6 +71,11 @@ Gopeed（全称 Go Speed），直译过来中文名叫做`够快下载器`（不
             <td><code>IPA</code></td>
             <td><a href="https://gopeed.com/api/download?tpl=Gopeed-$version-ios.ipa">前往</a></td>
         </tr>
+        <tr>
+            <td>Qnap</td>
+            <td><code>QPKG</code></td>
+            <td><a href="https://gopeed.com/api/download?tpl=gopeed-qnap-$version-amd64.qpkg">前往</a></td>
+        </tr>
         <tr>
             <td>Web</td>
             <td></td>
@@ -115,7 +120,7 @@ Gopeed 还提供了浏览器扩展用于接管浏览器下载，支持 Chrome、
 ### 环境要求
 
 1. Golang 1.23+
-2. Flutter 3.16+
+2. Flutter 3.24+
 
 ### 克隆项目
 
@@ -174,7 +179,7 @@ gomobile init
 - android
 
 ```bash
-gomobile bind -tags nosqlite -ldflags="-w -s" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
+gomobile bind -tags nosqlite -ldflags="-w -s -checklinkname=0" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
 cd ui/flutter
 flutter build apk
 ```

README_zh-TW.md

@@ -71,6 +71,11 @@ Gopeed（全稱 Go Speed），是一款使用`Golang`+`Flutter`編寫的高速
             <td><code>IPA</code></td>
             <td><a href="https://gopeed.com/api/download?tpl=Gopeed-$version-ios.ipa">前往</a></td>
         </tr>
+        <tr>
+            <td>Qnap</td>
+            <td><code>QPKG</code></td>
+            <td><a href="https://gopeed.com/api/download?tpl=gopeed-qnap-$version-amd64.qpkg">前往</a></td>
+        </tr>
         <tr>
             <td>Web</td>
             <td></td>
@@ -111,7 +116,7 @@ go install github.com/GopeedLab/gopeed/cmd/gopeed@latest
 ### 開發環境
 
 1. Golang 1.23+
-2. Flutter 3.16+
+2. Flutter 3.24+
 
 ### 克隆項目
 
@@ -170,7 +175,7 @@ gomobile init
 - android
 
 ```bash
-gomobile bind -tags nosqlite -ldflags="-w -s" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
+gomobile bind -tags nosqlite -ldflags="-w -s -checklinkname=0" -o ui/flutter/android/app/libs/libgopeed.aar -target=android -androidapi 21 -javapkg="com.gopeed" github.com/GopeedLab/gopeed/bind/mobile
 cd ui/flutter
 flutter build apk
 ```

internal/protocol/bt/fetcher.go

@@ -11,7 +11,9 @@ import (
 	"github.com/GopeedLab/gopeed/pkg/util"
 	"github.com/anacrolix/torrent"
 	"github.com/anacrolix/torrent/metainfo"
+	"io"
 	"net/url"
+	"os"
 	"path/filepath"
 	"strings"
 	"sync"
@@ -359,17 +361,34 @@ func (f *Fetcher) addTorrent(req *base.Request, fromUpload bool) (err error) {
 	schema := util.ParseSchema(req.URL)
 	if schema == "MAGNET" {
 		f.torrent, err = client.AddMagnet(req.URL)
+	} else {
+		var reader io.Reader
+		if schema == "FILE" {
+			fileUrl, _ := url.Parse(req.URL)
+			filePath := fileUrl.Path[1:]
+			reader, err = os.Open(filePath)
+			if err != nil {
+				return
+			}
 		} else if schema == "DATA" {
 			_, data := util.ParseDataUri(req.URL)
-		buf := bytes.NewBuffer(data)
+			reader = bytes.NewBuffer(data)
-		var metaInfo *metainfo.MetaInfo
+		} else {
-		metaInfo, err = metainfo.Load(buf)
+			reader, err = os.Open(req.URL)
 			if err != nil {
+				return
+			}
+			defer reader.(io.Closer).Close()
+		}
+
+		var metaInfo *metainfo.MetaInfo
+		metaInfo, err = metainfo.Load(reader)
+		// Hotfix for https://github.com/anacrolix/torrent/issues/992, ignore "expected EOF" error
+		// TODO remove this after the issue is fixed
+		if err != nil && !strings.Contains(err.Error(), "expected EOF") {
 			return err
 		}
 		f.torrent, err = client.AddTorrent(metaInfo)
-	} else {
-		f.torrent, err = client.AddTorrentFromFile(req.URL)
 	}
 	if err != nil {
 		return

internal/protocol/bt/fetcher_test.go

@@ -11,6 +11,7 @@ import (
 	gohttp "net/http"
 	"net/url"
 	"os"
+	"path/filepath"
 	"reflect"
 	"testing"
 )
@@ -96,7 +97,7 @@ func doResolve(t *testing.T, fetcher fetcher.Fetcher) {
 			Hash: "8a55cfbd5ca5d11507364765936c4f9e55b253ed",
 		}
 		if !reflect.DeepEqual(want, fetcher.Meta().Res) {
-			t.Errorf("Resolve() got = %v, want %v", fetcher.Meta().Res, want)
+			t.Errorf("Resolve Single File Resolve() got = %v, want %v", fetcher.Meta().Res, want)
 		}
 	})
 
@@ -136,10 +137,29 @@ func doResolve(t *testing.T, fetcher fetcher.Fetcher) {
 			Hash: "ccbc92b0cd8deec16a2ef4be242a8c9243b1cedb",
 		}
 		if !reflect.DeepEqual(want, fetcher.Meta().Res) {
-			t.Errorf("Resolve() got = %v, want %v", fetcher.Meta().Res, want)
+			t.Errorf("Resolve Multi Files Resolve() got = %v, want %v", fetcher.Meta().Res, want)
 		}
 	})
 
+	t.Run("Resolve Unclean Torrent", func(t *testing.T) {
+		err := fetcher.Resolve(&base.Request{
+			URL: "./testdata/test.unclean.torrent",
+		})
+		if err != nil {
+			t.Errorf("Resolve Unclean Torrent Resolve() got = %v, want nil", err)
+		}
+	})
+
+	t.Run("Resolve file scheme Torrent", func(t *testing.T) {
+		file, _ := filepath.Abs("./testdata/test.unclean.torrent")
+		uri := "file:///" + file
+		err := fetcher.Resolve(&base.Request{
+			URL: uri,
+		})
+		if err != nil {
+			t.Errorf("Resolve file scheme Torrent Resolve() got = %v, want nil", err)
+		}
+	})
 }
 
 func TestFetcherManager_ParseName(t *testing.T) {

internal/protocol/http/fetcher.go

@@ -8,6 +8,7 @@ import (
 	"fmt"
 	"io"
 	"mime"
+	"net"
 	"net/http"
 	"net/http/cookiejar"
 	"net/url"
@@ -25,6 +26,9 @@ import (
 	"golang.org/x/sync/errgroup"
 )
 
+const connectTimeout = 15 * time.Second
+const readTimeout = 15 * time.Second
+
 type RequestError struct {
 	Code int
 	Msg  string
@@ -103,9 +107,9 @@ func (f *Fetcher) Resolve(req *base.Request) error {
 	if base.HttpCodePartialContent == httpResp.StatusCode || (base.HttpCodeOK == httpResp.StatusCode && httpResp.Header.Get(base.HttpHeaderAcceptRanges) == base.HttpHeaderBytes && strings.HasPrefix(httpResp.Header.Get(base.HttpHeaderContentRange), base.HttpHeaderBytes)) {
 		// response 206 status code, support breakpoint continuation
 		res.Range = true
-		// 解析资源大小: bytes 0-1000/1001 => 1001
+		// parse content length from Content-Range header, eg: bytes 0-1000/1001 or bytes 0-0/*
 		contentTotal := path.Base(httpResp.Header.Get(base.HttpHeaderContentRange))
-		if contentTotal != "" {
+		if contentTotal != "" && contentTotal != "*" {
 			parse, err := strconv.ParseInt(contentTotal, 10, 64)
 			if err != nil {
 				return err
@@ -146,7 +150,7 @@ func (f *Fetcher) Resolve(req *base.Request) error {
 			file.Name = filename
 		}
 	}
-	// Get file filePath by URL
+	// get file filePath by URL
 	if file.Name == "" {
 		file.Name = path.Base(httpReq.URL.Path)
 	}
@@ -250,23 +254,42 @@ func (f *Fetcher) Wait() (err error) {
 	return <-f.doneCh
 }
 
+type fetchResult struct {
+	err error
+}
+
 func (f *Fetcher) fetch() {
 	var ctx context.Context
 	ctx, f.cancel = context.WithCancel(context.Background())
 	f.eg, _ = errgroup.WithContext(ctx)
+	chunkErrs := make([]error, len(f.chunks))
 	for i := 0; i < len(f.chunks); i++ {
 		i := i
 		f.eg.Go(func() error {
-			return f.fetchChunk(i, ctx)
+			err := f.fetchChunk(i, ctx)
+			// if canceled, fail fast
+			if errors.Is(err, context.Canceled) {
+				return err
+			}
+			chunkErrs[i] = err
+			return nil
 		})
 	}
 
 	go func() {
 		err := f.eg.Wait()
-		// check if canceled
+		// error returned only if canceled, just return
-		if errors.Is(err, context.Canceled) {
+		if err != nil {
 			return
 		}
+		// check all fetch results, if any error, return
+		for _, chunkErr := range chunkErrs {
+			if chunkErr != nil {
+				err = chunkErr
+				break
+			}
+		}
+
 		f.file.Close()
 		// Update file last modified time
 		if f.config.UseServerCtime && f.meta.Res.Files[0].Ctime != nil {
@@ -289,25 +312,12 @@ func (f *Fetcher) fetchChunk(index int, ctx context.Context) (err error) {
 	for {
 		// if chunk is completed, return
 		if f.meta.Res.Range && chunk.Downloaded >= chunk.End-chunk.Begin+1 {
-			return
+			return nil
 		}
 
 		if chunk.retryTimes >= maxRetries {
-			if !f.meta.Res.Range {
 			return
 		}
-			// check if all failed
-			allFailed := true
-			for _, c := range f.chunks {
-				if chunk.Downloaded < chunk.End-chunk.Begin+1 && c.retryTimes < maxRetries {
-					allFailed = false
-					break
-				}
-			}
-			if allFailed {
-				return
-			}
-		}
 
 		var (
 			httpReq *http.Request
@@ -333,10 +343,9 @@ func (f *Fetcher) fetchChunk(index int, ctx context.Context) (err error) {
 				err = NewRequestError(resp.StatusCode, resp.Status)
 				return err
 			}
-			// Http request success, reset retry times
+			reader := NewTimeoutReader(resp.Body, readTimeout)
-			chunk.retryTimes = 0
 			for {
-				n, err := resp.Body.Read(buf)
+				n, err := reader.Read(buf)
 				if n > 0 {
 					_, err := f.file.WriteAt(buf[:n], chunk.Begin+chunk.Downloaded)
 					if err != nil {
@@ -351,7 +360,6 @@ func (f *Fetcher) fetchChunk(index int, ctx context.Context) (err error) {
 					return err
 				}
 			}
-			return nil
 		}()
 		if err != nil {
 			// If canceled, do not retry
@@ -419,6 +427,10 @@ func (f *Fetcher) buildRequest(ctx context.Context, req *base.Request) (httpReq
 		return
 	}
 	httpReq.Header = headers
+	// Override Host header
+	if host := headers.Get(base.HttpHeaderHost); host != "" {
+		httpReq.Host = host
+	}
 	return httpReq, nil
 }
 
@@ -452,6 +464,9 @@ func (f *Fetcher) splitChunk() (chunks []*chunk) {
 
 func (f *Fetcher) buildClient() *http.Client {
 	transport := &http.Transport{
+		DialContext: (&net.Dialer{
+			Timeout: connectTimeout,
+		}).DialContext,
 		Proxy: f.ctl.GetProxy(f.meta.Req.Proxy),
 		TLSClientConfig: &tls.Config{
 			InsecureSkipVerify: f.meta.Req.SkipVerifyCert,

internal/protocol/http/fetcher_test.go

@@ -11,6 +11,7 @@ import (
 	"net"
 	gohttp "net/http"
 	"net/url"
+	"strings"
 	"testing"
 	"time"
 )
@@ -59,6 +60,21 @@ func TestFetcher_Resolve(t *testing.T) {
 	}
 }
 
+func TestFetcher_ResolveWithHostHeader(t *testing.T) {
+	fetcher := buildFetcher()
+	err := fetcher.Resolve(&base.Request{
+		URL: "https://bing.com",
+		Extra: &http.ReqExtra{
+			Header: map[string]string{
+				"Host": "test",
+			},
+		},
+	})
+	if err == nil || !strings.Contains(err.Error(), "400") {
+		t.Errorf("Resolve() got = %v, want %v", err, "400")
+	}
+}
+
 func testResolve(startTestServer func() net.Listener, path string, want *base.Resource, t *testing.T) {
 	listener := startTestServer()
 	defer listener.Close()
@@ -132,6 +148,14 @@ func TestFetcher_DownloadLimit(t *testing.T) {
 	downloadNormal(listener, 8, t)
 }
 
+func TestFetcher_DownloadResponseBodyReadTimeout(t *testing.T) {
+	listener := test.StartTestLimitServer(16, readTimeout.Milliseconds()+5000)
+	defer listener.Close()
+
+	downloadError(listener, 1, t)
+	downloadError(listener, 4, t)
+}
+
 func TestFetcher_DownloadResume(t *testing.T) {
 	listener := test.StartTestFileServer()
 	defer listener.Close()

internal/protocol/http/timeout_reader.go

@@ -0,0 +1,40 @@
+package http
+
+import (
+	"context"
+	"io"
+	"time"
+)
+
+type TimeoutReader struct {
+	reader  io.Reader
+	timeout time.Duration
+}
+
+func NewTimeoutReader(r io.Reader, timeout time.Duration) *TimeoutReader {
+	return &TimeoutReader{
+		reader:  r,
+		timeout: timeout,
+	}
+}
+
+func (tr *TimeoutReader) Read(p []byte) (n int, err error) {
+	ctx, cancel := context.WithTimeout(context.Background(), tr.timeout)
+	defer cancel()
+
+	done := make(chan struct{})
+	var readErr error
+	var bytesRead int
+
+	go func() {
+		bytesRead, readErr = tr.reader.Read(p)
+		close(done)
+	}()
+
+	select {
+	case <-done:
+		return bytesRead, readErr
+	case <-ctx.Done():
+		return 0, ctx.Err()
+	}
+}

internal/protocol/http/timeout_reader_test.go

@@ -0,0 +1,51 @@
+package http
+
+import (
+	"bytes"
+	"context"
+	"errors"
+	"io"
+	"testing"
+	"time"
+)
+
+func TestTimeoutReader_Read(t *testing.T) {
+	data := []byte("Hello, World!")
+	reader := bytes.NewReader(data)
+	timeoutReader := NewTimeoutReader(reader, 1*time.Second)
+
+	buf := make([]byte, len(data))
+	n, err := timeoutReader.Read(buf)
+	if err != nil {
+		t.Fatalf("expected no error, got %v", err)
+	}
+	if n != len(data) {
+		t.Fatalf("expected to read %d bytes, read %d", len(data), n)
+	}
+	if !bytes.Equal(buf, data) {
+		t.Fatalf("expected %s, got %s", data, buf)
+	}
+}
+
+func TestTimeoutReader_ReadTimeout(t *testing.T) {
+	reader := &slowReader{delay: 2 * time.Second}
+	timeoutReader := NewTimeoutReader(reader, 1*time.Second)
+
+	buf := make([]byte, 8192)
+	_, err := timeoutReader.Read(buf)
+	if err == nil {
+		t.Fatal("expected timeout error, got nil")
+	}
+	if !errors.Is(err, context.DeadlineExceeded) {
+		t.Fatalf("expected %v, got %v", context.DeadlineExceeded, err)
+	}
+}
+
+type slowReader struct {
+	delay time.Duration
+}
+
+func (sr *slowReader) Read(p []byte) (n int, err error) {
+	time.Sleep(sr.delay)
+	return 0, io.EOF
+}

internal/test/httptest.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/rand"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"github.com/GopeedLab/gopeed/pkg/base"
 	"github.com/armon/go-socks5"
@@ -36,7 +37,7 @@ const (
 )
 
 func StartTestFileServer() net.Listener {
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		return http.FileServer(http.Dir(Dir))
 	})
 }
@@ -52,7 +53,7 @@ func (s *SlowFileServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 }
 
 func StartTestSlowFileServer(delay time.Duration) net.Listener {
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		return &SlowFileServer{
 			delay:   delay,
 			handler: http.FileServer(http.Dir(Dir)),
@@ -61,7 +62,7 @@ func StartTestSlowFileServer(delay time.Duration) net.Listener {
 }
 
 func StartTestCustomServer() net.Listener {
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		mux := http.NewServeMux()
 		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
 			file, err := os.Open(BuildFile)
@@ -88,7 +89,7 @@ func StartTestCustomServer() net.Listener {
 
 func StartTestRetryServer() net.Listener {
 	counter := 0
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		mux := http.NewServeMux()
 		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
 			counter++
@@ -108,7 +109,7 @@ func StartTestRetryServer() net.Listener {
 }
 
 func StartTestPostServer() net.Listener {
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		mux := http.NewServeMux()
 		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
 			if request.Method == "POST" && request.Header.Get("Authorization") != "" {
@@ -132,7 +133,7 @@ func StartTestPostServer() net.Listener {
 
 func StartTestErrorServer() net.Listener {
 	counter := 0
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		mux := http.NewServeMux()
 		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
 			counter++
@@ -149,7 +150,7 @@ func StartTestErrorServer() net.Listener {
 func StartTestLimitServer(maxConnections int32, delay int64) net.Listener {
 	var connections atomic.Int32
 
-	return startTestServer(func() http.Handler {
+	return startTestServer(func(sl *shutdownListener) http.Handler {
 		mux := http.NewServeMux()
 		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
 			defer func() {
@@ -165,12 +166,14 @@ func StartTestLimitServer(maxConnections int32, delay int64) net.Listener {
 			if r == "" {
 				writer.Header().Set("Content-Length", fmt.Sprintf("%d", BuildSize))
 				writer.WriteHeader(200)
+				(writer.(http.Flusher)).Flush()
+
 				file, err := os.Open(BuildFile)
 				if err != nil {
 					panic(err)
 				}
 				defer file.Close()
-				slowCopy(writer, file, delay)
+				slowCopy(sl, writer, file, delay)
 			} else {
 				// split range
 				s := strings.Split(r, "=")
@@ -204,6 +207,8 @@ func StartTestLimitServer(maxConnections int32, delay int64) net.Listener {
 				writer.Header().Set("Content-Range", fmt.Sprintf("bytes %d-%d/%d", start, end, BuildSize))
 				writer.Header().Set("Accept-Ranges", "bytes")
 				writer.WriteHeader(206)
+				(writer.(http.Flusher)).Flush()
+
 				file, err := os.Open(BuildFile)
 				if err != nil {
 					writer.WriteHeader(500)
@@ -211,7 +216,7 @@ func StartTestLimitServer(maxConnections int32, delay int64) net.Listener {
 				}
 				defer file.Close()
 				file.Seek(start, 0)
-				slowCopyN(writer, file, end-start+1, delay)
+				slowCopyN(sl, writer, file, end-start+1, delay)
 			}
 		})
 		return mux
@@ -219,9 +224,12 @@ func StartTestLimitServer(maxConnections int32, delay int64) net.Listener {
 }
 
 // slowCopyN copies n bytes from src to dst, speed limit is bytes per second
-func slowCopy(dst io.Writer, src io.Reader, delay int64) (written int64, err error) {
+func slowCopy(sl *shutdownListener, dst io.Writer, src io.Reader, delay int64) (written int64, err error) {
 	buf := make([]byte, 32*1024)
 	for {
+		if sl.isShutdown {
+			return 0, errors.New("server shutdown")
+		}
 		nr, er := src.Read(buf)
 		if nr > 0 {
 			nw, ew := dst.Write(buf[0:nr])
@@ -250,8 +258,8 @@ func slowCopy(dst io.Writer, src io.Reader, delay int64) (written int64, err err
 	return written, err
 }
 
-func slowCopyN(dst io.Writer, src io.Reader, n int64, delay int64) (written int64, err error) {
+func slowCopyN(sl *shutdownListener, dst io.Writer, src io.Reader, n int64, delay int64) (written int64, err error) {
-	written, err = slowCopy(dst, io.LimitReader(src, n), delay)
+	written, err = slowCopy(sl, dst, io.LimitReader(src, n), delay)
 	if written == n {
 		return n, nil
 	}
@@ -262,7 +270,7 @@ func slowCopyN(dst io.Writer, src io.Reader, n int64, delay int64) (written int6
 	return
 }
 
-func startTestServer(serverHandle func() http.Handler) net.Listener {
+func startTestServer(serverHandle func(sl *shutdownListener) http.Handler) net.Listener {
 	listener, err := net.Listen("tcp", "127.0.0.1:0")
 	if err != nil {
 		panic(err)
@@ -272,7 +280,7 @@ func startTestServer(serverHandle func() http.Handler) net.Listener {
 		panic(err)
 	}
 	defer file.Close()
-	// 随机生成一个文件
+	// Write random data
 	l := int64(8192)
 	buf := make([]byte, l)
 	size := int64(0)
@@ -289,21 +297,24 @@ func startTestServer(serverHandle func() http.Handler) net.Listener {
 		size += l
 	}
 	server := &http.Server{}
-	server.Handler = serverHandle()
+	sl := &shutdownListener{
-	go server.Serve(listener)
-
-	return &shutdownListener{
 		server:   server,
 		Listener: listener,
 	}
+	server.Handler = serverHandle(sl)
+	go server.Serve(listener)
+
+	return sl
 }
 
 type shutdownListener struct {
 	server     *http.Server
+	isShutdown bool
 	net.Listener
 }
 
 func (c *shutdownListener) Close() error {
+	c.isShutdown = true
 	closeErr := c.server.Shutdown(context.Background())
 	if err := ifExistAndRemove(BuildFile); err != nil {
 		fmt.Println(err)

pkg/base/constants.go

@@ -15,6 +15,7 @@ const (
 	HttpCodeOK             = 200
 	HttpCodePartialContent = 206
 
+	HttpHeaderHost               = "Host"
 	HttpHeaderRange              = "Range"
 	HttpHeaderAcceptRanges       = "Accept-Ranges"
 	HttpHeaderContentLength      = "Content-Length"

pkg/download/downloader.go

@@ -826,7 +826,7 @@ func (d *Downloader) watch(task *Task) {
 	}
 
 	// When delete a not resolved task, need check if the task resource is nil
-	if task.Meta.Res == nil {
+	if task.Meta.Res == nil || d.GetTask(task.ID) == nil {
 		return
 	}
 

pkg/download/extension.go

@@ -702,38 +702,34 @@ type OnDoneContext struct {
 	Task *Task `json:"task"`
 }
 
+// ExtensionTask is a wrapper of Task, it's used to interact with extension scripts.
+// Avoid extension scripts modifying task directly, use ExtensionTask to encapsulate task,
+// only some fields can be modified, such as request info.
 type ExtensionTask struct {
 	download *Downloader
-	task     *Task
 
-	Meta *ExtensionTaskMeta `json:"meta"`
+	*Task
-}
-
-// ExtensionTaskMeta restricts extension scripts to only modify request info
-type ExtensionTaskMeta struct {
-	Req *base.Request `json:"req"`
 }
 
 func NewExtensionTask(download *Downloader, task *Task) *ExtensionTask {
+	// restricts extension scripts to only modify request info
 	newTask := task.clone()
+	newTask.Meta.Req = task.Meta.Req
 	return &ExtensionTask{
-		task:     newTask,
 		download: download,
-		Meta: &ExtensionTaskMeta{
+		Task:     newTask,
-			Req: task.Meta.Req,
-		},
 	}
 }
 
 func (t *ExtensionTask) Continue() error {
 	return t.download.Continue(&TaskFilter{
-		IDs: []string{t.task.ID},
+		IDs: []string{t.ID},
 	})
 }
 
 func (t *ExtensionTask) Pause() error {
 	return t.download.Pause(&TaskFilter{
-		IDs: []string{t.task.ID},
+		IDs: []string{t.ID},
 	})
 }
 

pkg/util/url.go

@@ -10,7 +10,6 @@ import (
 
 func ParseSchema(url string) string {
 	index := strings.Index(url, ":")
-	// if no schema or windows path like C:\a.txt, return FILE
 	if index == -1 || index == 1 {
 		return ""
 	}

ui/flutter/lib/api/api.dart

@@ -129,12 +129,20 @@ Future<void> continueTask(String id) async {
   return _parse(() => _client.dio.put("/api/v1/tasks/$id/continue"), null);
 }
 
-Future<void> pauseAllTasks() async {
+Future<void> pauseAllTasks(List<String>? ids) async {
-  return _parse(() => _client.dio.put("/api/v1/tasks/pause"), null);
+  return _parse(
+      () => _client.dio.put("/api/v1/tasks/pause", queryParameters: {
+            "id": ids,
+          }),
+      null);
 }
 
-Future<void> continueAllTasks() async {
+Future<void> continueAllTasks(List<String>? ids) async {
-  return _parse(() => _client.dio.put("/api/v1/tasks/continue"), null);
+  return _parse(
+      () => _client.dio.put("/api/v1/tasks/continue", queryParameters: {
+            "id": ids,
+          }),
+      null);
 }
 
 Future<void> deleteTask(String id, bool force) async {
@@ -142,6 +150,15 @@ Future<void> deleteTask(String id, bool force) async {
       () => _client.dio.delete("/api/v1/tasks/$id?force=$force"), null);
 }
 
+Future<void> deleteTasks(List<String>? ids, bool force) async {
+  return _parse(
+      () => _client.dio.delete("/api/v1/tasks", queryParameters: {
+            "id": ids,
+            "force": force,
+          }),
+      null);
+}
+
 Future<DownloaderConfig> getConfig() async {
   return _parse(() => _client.dio.get("/api/v1/config"),
       (data) => DownloaderConfig.fromJson(data));

ui/flutter/lib/api/model/downloader_config.dart

@@ -80,6 +80,7 @@ class ExtraConfig {
   String locale;
   bool lastDeleteTaskKeep;
   bool defaultDirectDownload;
+  bool defaultBtClient;
 
   ExtraConfigBt bt = ExtraConfigBt();
 
@@ -88,6 +89,7 @@ class ExtraConfig {
     this.locale = '',
     this.lastDeleteTaskKeep = false,
     this.defaultDirectDownload = false,
+    this.defaultBtClient = true,
   });
 
   factory ExtraConfig.fromJson(Map<String, dynamic>? json) =>

ui/flutter/lib/api/model/downloader_config.g.dart

@@ -73,6 +73,7 @@ ExtraConfig _$ExtraConfigFromJson(Map<String, dynamic> json) => ExtraConfig(
       locale: json['locale'] as String? ?? '',
       lastDeleteTaskKeep: json['lastDeleteTaskKeep'] as bool? ?? false,
       defaultDirectDownload: json['defaultDirectDownload'] as bool? ?? false,
+      defaultBtClient: json['defaultBtClient'] as bool? ?? true,
     )..bt = ExtraConfigBt.fromJson(json['bt'] as Map<String, dynamic>);
 
 Map<String, dynamic> _$ExtraConfigToJson(ExtraConfig instance) =>
@@ -81,6 +82,7 @@ Map<String, dynamic> _$ExtraConfigToJson(ExtraConfig instance) =>
       'locale': instance.locale,
       'lastDeleteTaskKeep': instance.lastDeleteTaskKeep,
       'defaultDirectDownload': instance.defaultDirectDownload,
+      'defaultBtClient': instance.defaultBtClient,
       'bt': instance.bt.toJson(),
     };
 

ui/flutter/lib/api/model/options.dart

@@ -10,8 +10,8 @@ class Options {
   Object? extra;
 
   Options({
-    required this.name,
+    this.name = '',
-    required this.path,
+    this.path = '',
     this.selectFiles = const [],
     this.extra,
   });
@@ -24,12 +24,16 @@ class Options {
 
 @JsonSerializable()
 class OptsExtraHttp {
-  int connections = 0;
+  int connections;
-  bool autoTorrent = false;
+  bool autoTorrent;
 
-  OptsExtraHttp();
+  OptsExtraHttp({
+    this.connections = 0,
+    this.autoTorrent = false,
+  });
 
   factory OptsExtraHttp.fromJson(Map<String, dynamic> json) =>
       _$OptsExtraHttpFromJson(json);
+
   Map<String, dynamic> toJson() => _$OptsExtraHttpToJson(this);
 }

ui/flutter/lib/api/model/options.g.dart

@@ -7,10 +7,10 @@ part of 'options.dart';
 // **************************************************************************
 
 Options _$OptionsFromJson(Map<String, dynamic> json) => Options(
-      name: json['name'] as String,
+      name: json['name'] as String? ?? '',
-      path: json['path'] as String,
+      path: json['path'] as String? ?? '',
       selectFiles: (json['selectFiles'] as List<dynamic>?)
-              ?.map((e) => e as int)
+              ?.map((e) => (e as num).toInt())
               .toList() ??
           const [],
       extra: json['extra'],
@@ -34,9 +34,10 @@ Map<String, dynamic> _$OptionsToJson(Options instance) {
 }
 
 OptsExtraHttp _$OptsExtraHttpFromJson(Map<String, dynamic> json) =>
-    OptsExtraHttp()
+    OptsExtraHttp(
-      ..connections = json['connections'] as int
+      connections: (json['connections'] as num?)?.toInt() ?? 0,
-      ..autoTorrent = json['autoTorrent'] as bool;
+      autoTorrent: json['autoTorrent'] as bool? ?? false,
+    );
 
 Map<String, dynamic> _$OptsExtraHttpToJson(OptsExtraHttp instance) =>
     <String, dynamic>{

ui/flutter/lib/api/model/request.dart

@@ -6,9 +6,9 @@ part 'request.g.dart';
 class Request {
   String url;
   Object? extra;
-  Map<String, String>? labels = {};
+  Map<String, String>? labels;
   RequestProxy? proxy;
-  bool skipVerifyCert = false;
+  bool skipVerifyCert;
 
   Request({
     required this.url,
@@ -26,11 +26,15 @@ class Request {
 
 @JsonSerializable()
 class ReqExtraHttp {
-  String method = 'GET';
+  String method;
-  Map<String, String> header = {};
+  Map<String, String> header;
-  String body = '';
+  String body;
 
-  ReqExtraHttp();
+  ReqExtraHttp({
+    this.method = 'GET',
+    this.header = const {},
+    this.body = '',
+  });
 
   factory ReqExtraHttp.fromJson(Map<String, dynamic> json) =>
       _$ReqExtraHttpFromJson(json);
@@ -40,9 +44,11 @@ class ReqExtraHttp {
 
 @JsonSerializable()
 class ReqExtraBt {
-  List<String> trackers = [];
+  List<String> trackers;
 
-  ReqExtraBt();
+  ReqExtraBt({
+    this.trackers = const [],
+  });
 
   factory ReqExtraBt.fromJson(Map<String, dynamic> json) =>
       _$ReqExtraBtFromJson(json);
@@ -58,15 +64,22 @@ enum RequestProxyMode {
 
 @JsonSerializable()
 class RequestProxy {
-  RequestProxyMode mode = RequestProxyMode.follow;
+  RequestProxyMode mode;
-  String scheme = 'http';
+  String scheme;
-  String host = '';
+  String host;
-  String usr = '';
+  String usr;
-  String pwd = '';
+  String pwd;
 
-  RequestProxy();
+  RequestProxy({
+    this.mode = RequestProxyMode.follow,
+    this.scheme = 'http',
+    this.host = '',
+    this.usr = '',
+    this.pwd = '',
+  });
 
   factory RequestProxy.fromJson(Map<String, dynamic> json) =>
       _$RequestProxyFromJson(json);
+
   Map<String, dynamic> toJson() => _$RequestProxyToJson(this);
 }

ui/flutter/lib/api/model/request.g.dart

@@ -36,10 +36,14 @@ Map<String, dynamic> _$RequestToJson(Request instance) {
   return val;
 }
 
-ReqExtraHttp _$ReqExtraHttpFromJson(Map<String, dynamic> json) => ReqExtraHttp()
+ReqExtraHttp _$ReqExtraHttpFromJson(Map<String, dynamic> json) => ReqExtraHttp(
-  ..method = json['method'] as String
+      method: json['method'] as String? ?? 'GET',
-  ..header = Map<String, String>.from(json['header'] as Map)
+      header: (json['header'] as Map<String, dynamic>?)?.map(
-  ..body = json['body'] as String;
+            (k, e) => MapEntry(k, e as String),
+          ) ??
+          const {},
+      body: json['body'] as String? ?? '',
+    );
 
 Map<String, dynamic> _$ReqExtraHttpToJson(ReqExtraHttp instance) =>
     <String, dynamic>{
@@ -48,21 +52,26 @@ Map<String, dynamic> _$ReqExtraHttpToJson(ReqExtraHttp instance) =>
       'body': instance.body,
     };
 
-ReqExtraBt _$ReqExtraBtFromJson(Map<String, dynamic> json) => ReqExtraBt()
+ReqExtraBt _$ReqExtraBtFromJson(Map<String, dynamic> json) => ReqExtraBt(
-  ..trackers =
+      trackers: (json['trackers'] as List<dynamic>?)
-      (json['trackers'] as List<dynamic>).map((e) => e as String).toList();
+              ?.map((e) => e as String)
+              .toList() ??
+          const [],
+    );
 
 Map<String, dynamic> _$ReqExtraBtToJson(ReqExtraBt instance) =>
     <String, dynamic>{
       'trackers': instance.trackers,
     };
 
-RequestProxy _$RequestProxyFromJson(Map<String, dynamic> json) => RequestProxy()
+RequestProxy _$RequestProxyFromJson(Map<String, dynamic> json) => RequestProxy(
-  ..mode = $enumDecode(_$RequestProxyModeEnumMap, json['mode'])
+      mode: $enumDecodeNullable(_$RequestProxyModeEnumMap, json['mode']) ??
-  ..scheme = json['scheme'] as String
+          RequestProxyMode.follow,
-  ..host = json['host'] as String
+      scheme: json['scheme'] as String? ?? 'http',
-  ..usr = json['usr'] as String
+      host: json['host'] as String? ?? '',
-  ..pwd = json['pwd'] as String;
+      usr: json['usr'] as String? ?? '',
+      pwd: json['pwd'] as String? ?? '',
+    );
 
 Map<String, dynamic> _$RequestProxyToJson(RequestProxy instance) =>
     <String, dynamic>{

ui/flutter/lib/api/model/result.g.dart

@@ -11,7 +11,7 @@ Result<T> _$ResultFromJson<T>(
   T Function(Object? json) fromJsonT,
 ) =>
     Result<T>(
-      code: json['code'] as int,
+      code: (json['code'] as num).toInt(),
       msg: json['msg'] as String?,
       data: _$nullableGenericFromJson(json['data'], fromJsonT),
     );

ui/flutter/lib/app/modules/app/controllers/app_controller.dart

@@ -16,6 +16,7 @@ import 'package:window_manager/window_manager.dart';
 
 import '../../../../api/api.dart';
 import '../../../../api/model/downloader_config.dart';
+import '../../../../api/model/request.dart';
 import '../../../../core/common/start_config.dart';
 import '../../../../core/libgopeed_boot.dart';
 import '../../../../database/database.dart';
@@ -27,6 +28,9 @@ import '../../../../util/log_util.dart';
 import '../../../../util/package_info.dart';
 import '../../../../util/util.dart';
 import '../../../routes/app_pages.dart';
+import '../../create/controllers/create_controller.dart';
+import '../../create/dto/create_router_params.dart';
+import '../../redirect/views/redirect_view.dart';
 
 const unixSocketPath = 'gopeed.sock';
 
@@ -160,8 +164,7 @@ class AppController extends GetxController with WindowListener, TrayListener {
   }
 
   Future<void> _initDeepLinks() async {
-    // currently only support android
+    if (Util.isWeb()) {
-    if (!Util.isAndroid()) {
       return;
     }
 
@@ -169,13 +172,13 @@ class AppController extends GetxController with WindowListener, TrayListener {
 
     // Handle link when app is in warm state (front or background)
     _linkSubscription = _appLinks.uriLinkStream.listen((uri) async {
-      await _toCreate(uri);
+      await _handleDeepLink(uri);
     });
 
     // Check initial link if app was in cold state (terminated)
-    final uri = await _appLinks.getInitialAppLink();
+    final uri = await _appLinks.getInitialLink();
     if (uri != null) {
-      await _toCreate(uri);
+      await _handleDeepLink(uri);
     }
   }
 
@@ -218,11 +221,11 @@ class AppController extends GetxController with WindowListener, TrayListener {
       ),
       MenuItem(
         label: "startAll".tr,
-        onClick: (menuItem) async => {continueAllTasks()},
+        onClick: (menuItem) async => {continueAllTasks(null)},
       ),
       MenuItem(
         label: "pauseAll".tr,
-        onClick: (menuItem) async => {pauseAllTasks()},
+        onClick: (menuItem) async => {pauseAllTasks(null)},
       ),
       MenuItem(
         label: 'setting'.tr,
@@ -304,13 +307,38 @@ class AppController extends GetxController with WindowListener, TrayListener {
     }
   }
 
-  Future<void> _toCreate(Uri uri) async {
+  Future<void> _handleDeepLink(Uri uri) async {
-    final path = (uri.scheme == "magnet" ||
+    if (uri.scheme == "gopeed") {
+      if (uri.path == "/create") {
+        final params = uri.queryParameters["params"];
+        if (params?.isNotEmpty == true) {
+          final paramsJson = String.fromCharCodes(base64Decode(params!));
+          Get.rootDelegate.offAndToNamed(Routes.REDIRECT,
+              arguments: RedirectArgs(Routes.CREATE,
+                  arguments:
+                      CreateRouterParams.fromJson(jsonDecode(paramsJson))));
+          return;
+        }
+        Get.rootDelegate.offAndToNamed(Routes.CREATE);
+        return;
+      }
+      Get.rootDelegate.offAndToNamed(Routes.HOME);
+      return;
+    }
+
+    String path;
+    if (uri.scheme == "magnet" ||
         uri.scheme == "http" ||
-            uri.scheme == "https")
+        uri.scheme == "https") {
-        ? uri.toString()
+      path = uri.toString();
-        : (await toFile(uri.toString())).path;
+    } else if (uri.scheme == "file") {
-    await Get.rootDelegate.offAndToNamed(Routes.CREATE, arguments: path);
+      path = Util.isWindows() ? uri.path.substring(1) : uri.path;
+    } else {
+      path = (await toFile(uri.toString())).path;
+    }
+    Get.rootDelegate.offAndToNamed(Routes.REDIRECT,
+        arguments: RedirectArgs(Routes.CREATE,
+            arguments: CreateRouterParams(req: Request(url: path))));
   }
 
   String runningAddress() {

ui/flutter/lib/app/modules/create/controllers/create_controller.dart

@@ -9,7 +9,6 @@ import '../../app/controllers/app_controller.dart';
 
 class CreateController extends GetxController
     with GetSingleTickerProviderStateMixin {
-  // final files = [].obs;
   final RxList fileInfos = [].obs;
   final RxList openedFolders = [].obs;
   final selectedIndexes = <int>[].obs;

ui/flutter/lib/app/modules/create/dto/create_router_params.dart

@@ -0,0 +1,24 @@
+import 'package:json_annotation/json_annotation.dart';
+
+import '../../../../api/model/options.dart';
+import '../../../../api/model/request.dart';
+
+part 'create_router_params.g.dart';
+
+@JsonSerializable(explicitToJson: true)
+class CreateRouterParams {
+  Request? req;
+  Options? opt;
+
+  CreateRouterParams({
+    this.req,
+    this.opt,
+  });
+
+  factory CreateRouterParams.fromJson(
+      Map<String, dynamic> json,
+      ) =>
+      _$CreateRouterParamsFromJson(json);
+
+  Map<String, dynamic> toJson() => _$CreateRouterParamsToJson(this);
+}

ui/flutter/lib/app/modules/create/dto/create_router_params.g.dart

@@ -0,0 +1,31 @@
+// GENERATED CODE - DO NOT MODIFY BY HAND
+
+part of 'create_router_params.dart';
+
+// **************************************************************************
+// JsonSerializableGenerator
+// **************************************************************************
+
+CreateRouterParams _$CreateRouterParamsFromJson(Map<String, dynamic> json) =>
+    CreateRouterParams(
+      req: json['req'] == null
+          ? null
+          : Request.fromJson(json['req'] as Map<String, dynamic>),
+      opt: json['opt'] == null
+          ? null
+          : Options.fromJson(json['opt'] as Map<String, dynamic>),
+    );
+
+Map<String, dynamic> _$CreateRouterParamsToJson(CreateRouterParams instance) {
+  final val = <String, dynamic>{};
+
+  void writeNotNull(String key, dynamic value) {
+    if (value != null) {
+      val[key] = value;
+    }
+  }
+
+  writeNotNull('req', instance.req?.toJson());
+  writeNotNull('opt', instance.opt?.toJson());
+  return val;
+}

ui/flutter/lib/app/modules/create/views/create_view.dart

@@ -1,4 +1,6 @@
-import 'package:autoscale_tabbarview/autoscale_tabbarview.dart';
+import 'dart:convert';
+
+import 'package:contentsize_tabbarview/contentsize_tabbarview.dart';
 import 'package:desktop_drop/desktop_drop.dart';
 import 'package:file_picker/file_picker.dart';
 import 'package:flutter/material.dart';
@@ -12,6 +14,7 @@ import '../../../../api/model/create_task.dart';
 import '../../../../api/model/options.dart';
 import '../../../../api/model/request.dart';
 import '../../../../api/model/resolve_result.dart';
+import '../../../../api/model/task.dart';
 import '../../../../database/database.dart';
 import '../../../../util/input_formatter.dart';
 import '../../../../util/message.dart';
@@ -19,10 +22,11 @@ import '../../../../util/util.dart';
 import '../../../routes/app_pages.dart';
 import '../../../views/compact_checkbox.dart';
 import '../../../views/directory_selector.dart';
-import '../../../views/file_list_view.dart';
+import '../../../views/file_tree_view.dart';
 import '../../app/controllers/app_controller.dart';
 import '../../history/views/history_view.dart';
 import '../controllers/create_controller.dart';
+import '../dto/create_router_params.dart';
 
 class CreateView extends GetView<CreateController> {
   final _confirmFormKey = GlobalKey<FormState>();
@@ -36,9 +40,20 @@ class CreateView extends GetView<CreateController> {
   final _proxyPortController = TextEditingController();
   final _proxyUsrController = TextEditingController();
   final _proxyPwdController = TextEditingController();
-  final _httpUaController = TextEditingController();
+  final _httpHeaderControllers = [
-  final _httpCookieController = TextEditingController();
+    (
-  final _httpRefererController = TextEditingController();
+      name: TextEditingController(text: "User-Agent"),
+      value: TextEditingController()
+    ),
+    (
+      name: TextEditingController(text: "Cookie"),
+      value: TextEditingController()
+    ),
+    (
+      name: TextEditingController(text: "Referer"),
+      value: TextEditingController()
+    ),
+  ];
   final _btTrackerController = TextEditingController();
 
   final _availableSchemes = ["http:", "https:", "magnet:"];
@@ -60,14 +75,74 @@ class CreateView extends GetView<CreateController> {
       _pathController.text = appController.downloaderConfig.value.downloadDir;
     }
 
-    final String? filePath = Get.rootDelegate.arguments();
+    final CreateRouterParams? routerParams = Get.rootDelegate.arguments();
-    if (_urlController.text.isEmpty) {
+    if (routerParams?.req?.url.isNotEmpty ?? false) {
-      if (filePath?.isNotEmpty ?? false) {
+      // get url from route arguments
-        // get file path from route arguments
+      final url = routerParams!.req!.url;
-        _urlController.text = filePath!;
+      _urlController.text = url;
       _urlController.selection = TextSelection.fromPosition(
           TextPosition(offset: _urlController.text.length));
-      } else {
+      final uppercaseUrl = url.toUpperCase();
+      Protocol? protocol;
+      if (uppercaseUrl.startsWith("HTTP:") ||
+          uppercaseUrl.startsWith("HTTPS:")) {
+        protocol = Protocol.http;
+      }
+      if (uppercaseUrl.startsWith("MAGNET:") ||
+          uppercaseUrl.endsWith(".TORRENT")) {
+        protocol = Protocol.bt;
+      }
+      if (protocol != null) {
+        final extraHandlers = {
+          Protocol.http: () {
+            final reqExtra = ReqExtraHttp.fromJson(
+                jsonDecode(jsonEncode(routerParams.req!.extra)));
+            _httpHeaderControllers.clear();
+            reqExtra.header.forEach((key, value) {
+              _httpHeaderControllers.add(
+                (
+                  name: TextEditingController(text: key),
+                  value: TextEditingController(text: value),
+                ),
+              );
+            });
+            _skipVerifyCertController.value = routerParams.req!.skipVerifyCert;
+          },
+          Protocol.bt: () {
+            final reqExtra = ReqExtraBt.fromJson(
+                jsonDecode(jsonEncode(routerParams.req!.extra)));
+            _btTrackerController.text = reqExtra.trackers.join("\n");
+          },
+        };
+        if (routerParams.req?.extra != null) {
+          extraHandlers[protocol]?.call();
+        }
+
+        // handle options
+        if (routerParams.opt != null) {
+          _renameController.text = routerParams.opt!.name;
+          _pathController.text = routerParams.opt!.path;
+
+          final optionsHandlers = {
+            Protocol.http: () {
+              final opt = routerParams.opt!;
+              _renameController.text = opt.name;
+              _pathController.text = opt.path;
+              if (opt.extra != null) {
+                final optsExtraHttp =
+                    OptsExtraHttp.fromJson(jsonDecode(jsonEncode(opt.extra)));
+                _connectionsController.text =
+                    optsExtraHttp.connections.toString();
+              }
+            },
+            Protocol.bt: null,
+          };
+          if (routerParams.opt?.extra != null) {
+            optionsHandlers[protocol]?.call();
+          }
+        }
+      }
+    } else if (_urlController.text.isEmpty) {
       // read clipboard
       Clipboard.getData('text/plain').then((value) {
         if (value?.text?.isNotEmpty ?? false) {
@@ -86,7 +161,6 @@ class CreateView extends GetView<CreateController> {
         }
       });
     }
-    }
 
     return Scaffold(
       appBar: AppBar(
@@ -436,36 +510,84 @@ class CreateView extends GetView<CreateController> {
                                     )
                                   ],
                                 ),
-                                AutoScaleTabBarView(
+                                DefaultTabController(
-                                  controller: controller.advancedTabController,
+                                  length: 2,
+                                  child: ContentSizeTabBarView(
+                                    controller:
+                                        controller.advancedTabController,
                                     children: [
                                       Column(
                                         children: [
-                                        TextFormField(
+                                          ..._httpHeaderControllers.map((e) {
-                                            controller: _httpUaController,
+                                            return Row(
-                                            decoration: const InputDecoration(
+                                              children: [
-                                              labelText: 'User-Agent',
+                                                Flexible(
-                                            )),
+                                                  child: TextFormField(
-                                        TextFormField(
+                                                    controller: e.name,
-                                            controller: _httpCookieController,
+                                                    decoration: InputDecoration(
-                                            decoration: const InputDecoration(
+                                                      hintText:
-                                              labelText: 'Cookie',
+                                                          'httpHeaderName'.tr,
-                                            )),
+                                                    ),
-                                        TextFormField(
+                                                  ),
-                                            controller: _httpRefererController,
+                                                ),
-                                            decoration: const InputDecoration(
+                                                const Padding(
-                                              labelText: 'Referer',
+                                                    padding: EdgeInsets.only(
-                                            )),
+                                                        left: 10)),
+                                                Flexible(
+                                                  child: TextFormField(
+                                                    controller: e.value,
+                                                    decoration: InputDecoration(
+                                                      hintText:
+                                                          'httpHeaderValue'.tr,
+                                                    ),
+                                                  ),
+                                                ),
+                                                const Padding(
+                                                    padding: EdgeInsets.only(
+                                                        left: 10)),
+                                                IconButton(
+                                                  icon: const Icon(Icons.add),
+                                                  onPressed: () {
+                                                    _httpHeaderControllers.add(
+                                                      (
+                                                        name:
+                                                            TextEditingController(),
+                                                        value:
+                                                            TextEditingController(),
+                                                      ),
+                                                    );
+                                                    controller.showAdvanced
+                                                        .update((val) => val);
+                                                  },
+                                                ),
+                                                IconButton(
+                                                  icon:
+                                                      const Icon(Icons.remove),
+                                                  onPressed: () {
+                                                    if (_httpHeaderControllers
+                                                            .length <=
+                                                        1) {
+                                                      return;
+                                                    }
+                                                    _httpHeaderControllers
+                                                        .remove(e);
+                                                    controller.showAdvanced
+                                                        .update((val) => val);
+                                                  },
+                                                ),
+                                              ],
+                                            );
+                                          }),
                                           Padding(
                                             padding:
                                                 const EdgeInsets.only(top: 10),
                                             child: CompactCheckbox(
                                               label: 'skipVerifyCert'.tr,
-                                            value:
+                                              value: _skipVerifyCertController
-                                                _skipVerifyCertController.value,
+                                                  .value,
                                               onChanged: (bool? value) {
-                                              _skipVerifyCertController.value =
+                                                _skipVerifyCertController
-                                                  value ?? false;
+                                                    .value = value ?? false;
                                               },
                                               textStyle: const TextStyle(
                                                 color: Colors.grey,
@@ -486,6 +608,7 @@ class CreateView extends GetView<CreateController> {
                                         ],
                                       )
                                     ],
+                                  ),
                                 )
                               ],
                             ).paddingOnly(top: 16),
@@ -644,12 +767,10 @@ class CreateView extends GetView<CreateController> {
     if (controller.showAdvanced.value) {
       switch (controller.advancedTabController.index) {
         case 0:
-          final header = {
+          final header = Map<String, String>.fromEntries(_httpHeaderControllers
-            "User-Agent": _httpUaController.text,
+              .map((e) => MapEntry(e.name.text, e.value.text)));
-            "Cookie": _httpCookieController.text,
+          header.removeWhere(
-            "Referer": _httpRefererController.text,
+              (key, value) => key.trim().isEmpty || value.trim().isEmpty);
-          };
-          header.removeWhere((key, value) => value.trim().isEmpty);
           if (header.isNotEmpty) {
             reqExtra = ReqExtraHttp()..header = header;
           }
@@ -698,7 +819,13 @@ class CreateView extends GetView<CreateController> {
                     child: Form(
                         key: createFormKey,
                         autovalidateMode: AutovalidateMode.always,
-                        child: FileListView(files: rr.res.files)),
+                        child: FileTreeView(
+                          files: rr.res.files,
+                          initialValues: rr.res.files.asMap().keys.toList(),
+                          onSelectionChanged: (List<int> values) {
+                            controller.selectedIndexes.value = values;
+                          },
+                        )),
                   );
                 },
               ),

ui/flutter/lib/app/modules/redirect/bindings/redirect_binding.dart

@@ -0,0 +1,12 @@
+import 'package:get/get.dart';
+
+import '../controllers/redirect_controller.dart';
+
+class RedirectBinding extends Bindings {
+  @override
+  void dependencies() {
+    Get.lazyPut<RedirectController>(
+      () => RedirectController(),
+    );
+  }
+}

ui/flutter/lib/app/modules/redirect/controllers/redirect_controller.dart

@@ -0,0 +1,3 @@
+import 'package:get/get.dart';
+
+class RedirectController extends GetxController {}

ui/flutter/lib/app/modules/redirect/views/redirect_view.dart

@@ -0,0 +1,27 @@
+import 'package:flutter/material.dart';
+import 'package:get/get.dart';
+
+import '../controllers/redirect_controller.dart';
+
+class RedirectArgs {
+  final String page;
+  final dynamic arguments;
+
+  RedirectArgs(this.page, {this.arguments});
+}
+
+class RedirectView extends GetView<RedirectController> {
+  const RedirectView({Key? key}) : super(key: key);
+
+  @override
+  Widget build(BuildContext context) {
+    final redirectArgs = Get.rootDelegate.arguments() as RedirectArgs;
+    // Waiting for previous page controller to delete, avoid deleting controller that route page after redirect
+    WidgetsBinding.instance.addPostFrameCallback((_) async {
+      await Future.delayed(const Duration(milliseconds: 350));
+      Get.rootDelegate
+          .offAndToNamed(redirectArgs.page, arguments: redirectArgs.arguments);
+    });
+    return const SizedBox();
+  }
+}

ui/flutter/lib/app/modules/setting/views/setting_view.dart

@@ -17,6 +17,7 @@ import '../../../../util/locale_manager.dart';
 import '../../../../util/log_util.dart';
 import '../../../../util/message.dart';
 import '../../../../util/package_info.dart';
+import '../../../../util/scheme_register/scheme_register.dart';
 import '../../../../util/util.dart';
 import '../../../views/check_list_view.dart';
 import '../../../views/directory_selector.dart';
@@ -111,7 +112,7 @@ class SettingView extends GetView<SettingController> {
     });
 
     final buildDefaultDirectDownload =
-        _buildConfigItem('defaultDirectDownload'.tr, () {
+        _buildConfigItem('defaultDirectDownload', () {
       return appController.downloaderConfig.value.extra.defaultDirectDownload
           ? 'on'.tr
           : 'off'.tr;
@@ -161,7 +162,7 @@ class SettingView extends GetView<SettingController> {
     // Currently auto startup only support Windows and Linux
     final buildAutoStartup = !Util.isWindows() && !Util.isLinux()
         ? () => null
-        : _buildConfigItem('launchAtStartup'.tr, () {
+        : _buildConfigItem('launchAtStartup', () {
             return appController.autoStartup.value ? 'on'.tr : 'off'.tr;
           }, (Key key) {
             return Container(
@@ -229,8 +230,9 @@ class SettingView extends GetView<SettingController> {
         ],
       );
     });
-    final buildHttpUseServerCtime = _buildConfigItem('useServerCtime'.tr,
+    final buildHttpUseServerCtime = _buildConfigItem(
-        () => httpConfig.useServerCtime ? 'on'.tr : 'off'.tr, (Key key) {
+        'useServerCtime', () => httpConfig.useServerCtime ? 'on'.tr : 'off'.tr,
+        (Key key) {
       return Container(
         alignment: Alignment.centerLeft,
         child: Switch(
@@ -420,6 +422,37 @@ class SettingView extends GetView<SettingController> {
         ].where((e) => e != null).map((e) => e!).toList(),
       );
     });
+    final buildBtDefaultClientConfig = !Util.isWindows()
+        ? () => null
+        : _buildConfigItem('setAsDefaultBtClient', () {
+            return appController.downloaderConfig.value.extra.defaultBtClient
+                ? 'on'.tr
+                : 'off'.tr;
+          }, (Key key) {
+            return Container(
+              alignment: Alignment.centerLeft,
+              child: Switch(
+                value:
+                    appController.downloaderConfig.value.extra.defaultBtClient,
+                onChanged: (bool value) async {
+                  try {
+                    if (value) {
+                      registerDefaultTorrentClient();
+                    } else {
+                      unregisterDefaultTorrentClient();
+                    }
+                    appController.downloaderConfig.update((val) {
+                      val!.extra.defaultBtClient = value;
+                    });
+                    await debounceSave();
+                  } catch (e) {
+                    showErrorMessage(e);
+                    logger.e('register default torrent client fail', e);
+                  }
+                },
+              ),
+            );
+          });
 
     // ui config items start
     final buildTheme = _buildConfigItem(
@@ -947,6 +980,7 @@ class SettingView extends GetView<SettingController> {
                             buildBtTrackerSubscribeUrls(),
                             buildBtTrackers(),
                             buildBtSeedConfig(),
+                            buildBtDefaultClientConfig(),
                           ]),
                         )),
                         Text('ui'.tr),

ui/flutter/lib/app/modules/task/controllers/task_controller.dart

@@ -1,4 +1,6 @@
+import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
+import 'package:flutter/services.dart';
 import 'package:get/get.dart';
 import 'package:gopeed/api/model/task.dart';
 
@@ -6,5 +8,20 @@ class TaskController extends GetxController {
   final tabIndex = 0.obs;
   final scaffoldKey = GlobalKey<ScaffoldState>();
   final selectTask = Rx<Task?>(null);
-  final copyUrlDone = false.obs;
+
+  @override
+  void onInit() {
+    super.onInit();
+    if (kIsWeb) {
+      BrowserContextMenu.disableContextMenu();
+    }
+  }
+
+  @override
+  void onClose() {
+    super.onClose();
+    if (kIsWeb) {
+      BrowserContextMenu.enableContextMenu();
+    }
+  }
 }

ui/flutter/lib/app/modules/task/controllers/task_downloading_controller.dart

@@ -9,5 +9,13 @@ class TaskDownloadingController extends TaskListController {
           Status.pause,
           Status.wait,
           Status.error
-        ], (a, b) => b.createdAt.compareTo(a.createdAt));
+        ], (a, b) {
+          if (a.status == Status.running && b.status != Status.running) {
+            return -1;
+          } else if (a.status != Status.running && b.status == Status.running) {
+            return 1;
+          } else {
+            return b.updatedAt.compareTo(a.updatedAt);
+          }
+        });
 }

ui/flutter/lib/app/modules/task/controllers/task_list_controller.dart

@@ -12,6 +12,7 @@ abstract class TaskListController extends GetxController {
   TaskListController(this.statuses, this.compare);
 
   final tasks = <Task>[].obs;
+  final selectedTaskIds = <String>[].obs;
   final isRunning = false.obs;
 
   late final Timer _timer;

ui/flutter/lib/app/modules/task/views/task_downloaded_view.dart

@@ -9,6 +9,7 @@ class TaskDownloadedView extends GetView<TaskDownloadedController> {
 
   @override
   Widget build(BuildContext context) {
-    return BuildTaskListView(tasks: controller.tasks);
+    return BuildTaskListView(
+        tasks: controller.tasks, selectedTaskIds: controller.selectedTaskIds);
   }
 }

ui/flutter/lib/app/modules/task/views/task_downloading_view.dart

@@ -9,6 +9,7 @@ class TaskDownloadingView extends GetView<TaskDownloadingController> {
 
   @override
   Widget build(BuildContext context) {
-    return BuildTaskListView(tasks: controller.tasks);
+    return BuildTaskListView(
+        tasks: controller.tasks, selectedTaskIds: controller.selectedTaskIds);
   }
 }

ui/flutter/lib/app/modules/task/views/task_files_view.dart

@@ -7,10 +7,9 @@ import 'package:url_launcher/url_launcher.dart';
 
 import '../../../../api/api.dart' as api;
 import '../../../../util/browser_download/browser_download.dart';
-import '../../../../util/file_icon.dart';
-import '../../../../util/icons.dart';
 import '../../../../util/util.dart';
 import '../../../views/breadcrumb_view.dart';
+import '../../../views/file_icon.dart';
 import '../controllers/task_files_controller.dart';
 
 class TaskFilesView extends GetView<TaskFilesController> {
@@ -65,9 +64,8 @@ class TaskFilesView extends GetView<TaskFilesController> {
                         [meta.opts.path, meta.res!.name, fileRelativePath]);
                     final fileName = basename(filePath);
                     return ListTile(
-                      leading: file.isDirectory
+                      leading:
-                          ? const Icon(Icons.folder)
+                          Icon(fileIcon(fileName, isFolder: file.isDirectory)),
-                          : Icon(FaIcons.allIcons[findIcon(fileName)]),
                       title: Text(fileName),
                       subtitle: file.isDirectory
                           ? Text('items'.trParams({

ui/flutter/lib/app/routes/app_pages.dart

@@ -1,6 +1,4 @@
 import 'package:get/get.dart';
-import 'package:gopeed/app/modules/task/views/task_files_view.dart';
-import 'package:gopeed/app/modules/task/views/task_view.dart';
 
 import '../modules/create/bindings/create_binding.dart';
 import '../modules/create/views/create_view.dart';
@@ -8,12 +6,16 @@ import '../modules/extension/bindings/extension_binding.dart';
 import '../modules/extension/views/extension_view.dart';
 import '../modules/home/bindings/home_binding.dart';
 import '../modules/home/views/home_view.dart';
+import '../modules/redirect/bindings/redirect_binding.dart';
+import '../modules/redirect/views/redirect_view.dart';
 import '../modules/root/bindings/root_binding.dart';
 import '../modules/root/views/root_view.dart';
 import '../modules/setting/bindings/setting_binding.dart';
 import '../modules/setting/views/setting_view.dart';
 import '../modules/task/bindings/task_binding.dart';
 import '../modules/task/bindings/task_files_binding.dart';
+import '../modules/task/views/task_files_view.dart';
+import '../modules/task/views/task_view.dart';
 
 part 'app_routes.dart';
 
@@ -68,6 +70,11 @@ class AppPages {
             page: () => CreateView(),
             binding: CreateBinding(),
           ),
+          GetPage(
+            name: _Paths.REDIRECT,
+            page: () => const RedirectView(),
+            binding: RedirectBinding(),
+          ),
         ]),
   ];
 }

ui/flutter/lib/app/routes/app_routes.dart

@@ -3,6 +3,7 @@ part of 'app_pages.dart';
 
 abstract class Routes {
   Routes._();
+
   static const ROOT = _Paths.ROOT;
   static const HOME = _Paths.HOME;
   static const CREATE = _Paths.CREATE;
@@ -10,10 +11,12 @@ abstract class Routes {
   static const TASK_FILES = TASK + _Paths.TASK_FILES;
   static const EXTENSION = _Paths.HOME + _Paths.EXTENSION;
   static const SETTING = _Paths.HOME + _Paths.SETTING;
+  static const REDIRECT = _Paths.REDIRECT;
 }
 
 abstract class _Paths {
   _Paths._();
+
   static const ROOT = '/';
   static const HOME = '/home';
   static const CREATE = '/create';
@@ -21,4 +24,5 @@ abstract class _Paths {
   static const TASK_FILES = '/files';
   static const EXTENSION = '/extension';
   static const SETTING = '/setting';
+  static const REDIRECT = '/redirect';
 }

ui/flutter/lib/app/views/buid_task_list_view.dart

@@ -1,24 +1,28 @@
+import 'package:contextmenu_plus/contextmenu_plus.dart';
 import 'package:flutter/material.dart';
 import 'package:get/get.dart';
 import 'package:styled_widget/styled_widget.dart';
 
 import '../../api/api.dart';
 import '../../api/model/task.dart';
-import '../../util/file_icon.dart';
-import '../../util/icons.dart';
 import '../../util/message.dart';
 import '../../util/util.dart';
 import '../modules/app/controllers/app_controller.dart';
 import '../modules/task/controllers/task_controller.dart';
+import '../modules/task/controllers/task_downloaded_controller.dart';
+import '../modules/task/controllers/task_downloading_controller.dart';
 import '../modules/task/views/task_view.dart';
 import '../routes/app_pages.dart';
+import 'file_icon.dart';
 
 class BuildTaskListView extends GetView {
   final List<Task> tasks;
+  final List<String> selectedTaskIds;
 
   const BuildTaskListView({
     Key? key,
     required this.tasks,
+    required this.selectedTaskIds,
   }) : super(key: key);
 
   @override
@@ -57,11 +61,15 @@ class BuildTaskListView extends GetView {
       return task.status == Status.running;
     }
 
+    bool isSelect() {
+      return selectedTaskIds.contains(task.id);
+    }
+
     bool isFolderTask() {
       return task.isFolder;
     }
 
-    Future<void> showDeleteDialog(String id) {
+    Future<void> showDeleteDialog(List<String> ids) {
       final appController = Get.find<AppController>();
 
       final context = Get.context!;
@@ -70,7 +78,8 @@ class BuildTaskListView extends GetView {
           context: context,
           barrierDismissible: false,
           builder: (_) => AlertDialog(
-                title: Text('deleteTask'.tr),
+                title: Text(
+                    'deleteTask'.trParams({'count': ids.length.toString()})),
                 content: Obx(() => CheckboxListTile(
                     value: appController
                         .downloaderConfig.value.extra.lastDeleteTaskKeep,
@@ -96,7 +105,7 @@ class BuildTaskListView extends GetView {
                         final force = !appController
                             .downloaderConfig.value.extra.lastDeleteTaskKeep;
                         await appController.saveConfig();
-                        await deleteTask(id, force);
+                        await deleteTasks(ids, force);
                         Get.back();
                       } catch (e) {
                         showErrorMessage(e);
@@ -144,12 +153,35 @@ class BuildTaskListView extends GetView {
       list.add(IconButton(
         icon: const Icon(Icons.delete),
         onPressed: () {
-          showDeleteDialog(task.id);
+          showDeleteDialog([task.id]);
         },
       ));
       return list;
     }
 
+    Widget buildContextItem(IconData icon, String label, Function() onTap,
+        {bool enabled = true}) {
+      return ListTile(
+        dense: true,
+        visualDensity: const VisualDensity(vertical: -1),
+        minLeadingWidth: 12,
+        leading: Icon(icon, size: 18),
+        title: Text(label,
+            style: const TextStyle(
+              fontWeight: FontWeight.bold, // Make the text bold
+            )),
+        onTap: () async {
+          Get.back();
+          try {
+            await onTap();
+          } catch (e) {
+            showErrorMessage(e);
+          }
+        },
+        enabled: enabled,
+      );
+    }
+
     double getProgress() {
       final totalSize = task.meta.res?.size ?? 0;
       return totalSize <= 0 ? 0 : task.progress.downloaded / totalSize;
@@ -168,9 +200,79 @@ class BuildTaskListView extends GetView {
     }
 
     final taskController = Get.find<TaskController>();
+    final taskListController = taskController.tabIndex.value == 0
+        ? Get.find<TaskDownloadingController>()
+        : Get.find<TaskDownloadedController>();
 
-    return Card(
+    // Filter selected task ids that are still in the task list
+    filterSelectedTaskIds(Iterable<String> selectedTaskIds) => selectedTaskIds
+        .where((id) => tasks.any((task) => task.id == id))
+        .toList();
+
+    return ContextMenuArea(
+      width: 140,
+      builder: (context) => [
+        buildContextItem(Icons.checklist, 'selectAll'.tr, () {
+          if (tasks.isEmpty) return;
+
+          if (selectedTaskIds.isNotEmpty) {
+            taskListController.selectedTaskIds([]);
+          } else {
+            taskListController.selectedTaskIds(tasks.map((e) => e.id).toList());
+          }
+        }),
+        buildContextItem(Icons.check, 'select'.tr, () {
+          if (isSelect()) {
+            taskListController.selectedTaskIds(taskListController
+                .selectedTaskIds
+                .where((element) => element != task.id)
+                .toList());
+          } else {
+            taskListController.selectedTaskIds(
+                [...taskListController.selectedTaskIds, task.id]);
+          }
+        }),
+        const Divider(
+          indent: 8,
+          endIndent: 8,
+        ),
+        buildContextItem(Icons.play_arrow, 'continue'.tr, () async {
+          try {
+            await continueAllTasks(filterSelectedTaskIds(
+                {...taskListController.selectedTaskIds, task.id}));
+          } finally {
+            taskListController.selectedTaskIds([]);
+          }
+        }, enabled: !isDone() && !isRunning()),
+        buildContextItem(Icons.pause, 'pause'.tr, () async {
+          try {
+            await pauseAllTasks(filterSelectedTaskIds(
+                {...taskListController.selectedTaskIds, task.id}));
+          } finally {
+            taskListController.selectedTaskIds([]);
+          }
+        }, enabled: !isDone() && isRunning()),
+        buildContextItem(Icons.delete, 'delete'.tr, () async {
+          try {
+            await showDeleteDialog(filterSelectedTaskIds(
+                {...taskListController.selectedTaskIds, task.id}));
+          } finally {
+            taskListController.selectedTaskIds([]);
+          }
+        }),
+      ],
+      child: Obx(
+        () => Card(
             elevation: 4.0,
+            shape: isSelect()
+                ? RoundedRectangleBorder(
+                    borderRadius: BorderRadius.circular(8.0),
+                    side: BorderSide(
+                      color: Theme.of(context).colorScheme.primary,
+                      width: 2.0,
+                    ),
+                  )
+                : null,
             child: InkWell(
               onTap: () {
                 taskController.scaffoldKey.currentState?.openEndDrawer();
@@ -184,9 +286,11 @@ class BuildTaskListView extends GetView {
                 children: [
                   ListTile(
                       title: Text(task.name),
-                  leading: isFolderTask()
+                      leading: Icon(
-                      ? const Icon(FaIcons.folder)
+                        fileIcon(task.name,
-                      : Icon(FaIcons.allIcons[findIcon(task.name)])),
+                            isFolder: isFolderTask(),
+                            isBitTorrent: task.protocol == Protocol.bt),
+                      )),
                   Row(
                     children: [
                       Expanded(
@@ -215,6 +319,8 @@ class BuildTaskListView extends GetView {
                         ),
                 ],
               ),
-        )).padding(horizontal: 14, top: 8);
+            )).padding(horizontal: 14, top: 8),
+      ),
+    );
   }
 }

ui/flutter/lib/app/views/file_icon.dart

@@ -0,0 +1,76 @@
+import 'package:flutter/material.dart';
+
+import '../../icon/gopeed_icons.dart';
+
+final Map<IconData, List<String>> iconConfigMap = {
+  Gopeed.install: ['exe', 'msi', 'dmg', 'deb', 'rpm'],
+  Gopeed.android: ['apk'],
+  Gopeed.app_store_ios: ['ipa'],
+  Gopeed.file_bt: ['torrent'],
+  Gopeed.cd: ['iso'],
+  Gopeed.html5: ['html', 'htm'],
+  Gopeed.file_alt: ['txt', 'md', 'log', 'csv', 'tsv', 'json', 'yaml', 'yml'],
+  Gopeed.file_pdf: ['pdf'],
+  Gopeed.file_word: ['doc', 'docx'],
+  Gopeed.file_excel: ['xls', 'xlsx'],
+  Gopeed.file_powerpoint: ['ppt', 'pptx'],
+  Gopeed.file_archive: ['zip', 'rar', '7z', 'tar', 'gz', 'bz2', 'xz'],
+  Gopeed.file_image: [
+    'jpg',
+    'jpeg',
+    'png',
+    'gif',
+    'bmp',
+    'tiff',
+    'svg',
+    'webp'
+  ],
+  Gopeed.file_audio: ['mp3', 'wav', 'flac', 'aac', 'ogg', 'wma', 'm4a'],
+  Gopeed.file_video: ['mp4', 'avi', 'mkv', 'mov', 'wmv', 'flv', 'webm'],
+  Gopeed.file_code: [
+    'js',
+    'css',
+    'json',
+    'xml',
+    'java',
+    'cpp',
+    'dart',
+    'py',
+    'rb',
+    'php',
+    'ts',
+    'swift',
+    'go',
+    'rs'
+  ],
+  Gopeed.file: [''],
+};
+
+final Map<String, IconData> _iconCache = Map.fromEntries(
+  iconConfigMap.entries.expand(
+    (entry) => entry.value.map((ext) => MapEntry(ext, entry.key)),
+  ),
+);
+
+String fileExt(String? name) {
+  if (name == null) {
+    return '';
+  }
+
+  final ext = name.split('.').last;
+  if (ext.length > 8) {
+    return '';
+  }
+
+  return ext.toLowerCase();
+}
+
+IconData fileIcon(String? name,
+    {bool isFolder = false, bool isBitTorrent = false}) {
+  if (isFolder) {
+    return isBitTorrent ? Gopeed.folder_bt : Gopeed.folder;
+  }
+
+  final ext = fileExt(name);
+  return _iconCache[ext] ?? Gopeed.file;
+}

ui/flutter/lib/app/views/file_list_view.dart

@@ -1,303 +0,0 @@
-import 'dart:ui' as ui;
-
-import 'package:fluent_ui/fluent_ui.dart' as fluent;
-import 'package:flutter/material.dart';
-import 'package:get/get.dart';
-import '../../api/model/resource.dart';
-import 'package:path/path.dart' as path;
-
-import '../../util/file_icon.dart';
-import '../../util/icons.dart';
-import '../../util/util.dart';
-import '../modules/app/controllers/app_controller.dart';
-import '../modules/create/controllers/create_controller.dart';
-
-class FileListView extends GetView {
-  final List<FileInfo> files;
-
-  FileListView({
-    Key? key,
-    required this.files,
-  }) : super(key: key);
-  final parentController = Get.find<CreateController>();
-  final appController = Get.find<AppController>();
-
-  List findChildFileIdsR(List children) {
-    List res = [];
-    for (var k in children) {
-      if (parentController.fileInfos[k]['type'] == 'folder') {
-        res.addAll(
-            findChildFileIdsR(parentController.fileInfos[k]['children']));
-      } else {
-        res.add(parentController.fileInfos[k]['fileId']);
-      }
-    }
-    return res;
-  }
-
-  void clearDescendantFolderSizeR(int id) {
-    if (parentController.fileInfos[id]['type'] == 'folder') {
-      parentController.fileInfos[id]['size'] = 0;
-      for (var childId in parentController.fileInfos[id]['children']) {
-        clearDescendantFolderSizeR(childId);
-      }
-    }
-  }
-
-  void reduceAncestorFolderSizeR(int id, int size) {
-    int parentId = parentController.fileInfos[id]['parentId'];
-
-    if (parentId != -1) {
-      parentController.fileInfos[parentId]['size'] -= size;
-      reduceAncestorFolderSizeR(parentId, size);
-    }
-  }
-
-  int addDescendantFolderSizeR(int id) {
-    if (parentController.fileInfos[id]['type'] == 'folder') {
-      for (var childId in parentController.fileInfos[id]['children']) {
-        parentController.fileInfos[id]['size'] +=
-            addDescendantFolderSizeR(childId);
-      }
-    }
-    return parentController.fileInfos[id]['size'];
-  }
-
-  void addAncestorFolderSizeR(int id, int size) {
-    int parentId = parentController.fileInfos[id]['parentId'];
-    if (parentId != -1) {
-      parentController.fileInfos[parentId]['size'] += size;
-      addAncestorFolderSizeR(parentId, size);
-    }
-  }
-
-  List<fluent.TreeViewItem> buildTreeViewItemsR(int level, int parentId) {
-    List<fluent.TreeViewItem> res = [];
-    List children = parentController.fileInfos
-        .where((e) => e['level'] == level && e['parentId'] == parentId)
-        .toList();
-    for (int j = 0; j < children.length; j++) {
-      Map fileInfo = children[j];
-
-      if (fileInfo['type'] == 'folder') {
-        // folder
-        res.add(fluent.TreeViewItem(
-            // expanded: false, bug on init
-            value: fileInfo['id'],
-            onInvoked: (item, reason) async {
-              if (reason == fluent.TreeViewItemInvokeReason.selectionToggle) {
-                List childrenIds = findChildFileIdsR(fileInfo['children']);
-                if (item.selected == true) {
-                  parentController.selectedIndexes.addAll(childrenIds.cast());
-                  parentController.fileInfos[fileInfo['id']]['size'] = 0;
-                  addDescendantFolderSizeR(item.value);
-                  addAncestorFolderSizeR(item.value, fileInfo['size']);
-                  parentController.fileInfos.refresh();
-                } else {
-                  parentController.selectedIndexes
-                      .removeWhere((index) => childrenIds.contains(index));
-                  reduceAncestorFolderSizeR(item.value, fileInfo['size']);
-                  clearDescendantFolderSizeR(item.value);
-
-                  parentController.fileInfos.refresh();
-                }
-              }
-            },
-            leading: Obx(() {
-              return parentController.openedFolders.contains(fileInfo['id'])
-                  ? const Icon(FaIcons.folder_open,
-                      color: Colors.lightBlueAccent)
-                  : const Icon(FaIcons.folder, color: Colors.lightBlueAccent);
-            }),
-            onExpandToggle: (fluent.TreeViewItem item, bool getExpanded) async {
-              getExpanded
-                  ? parentController.openedFolders.add(item.value)
-                  : parentController.openedFolders.remove(item.value);
-            },
-            content: Row(mainAxisAlignment: MainAxisAlignment.end, children: [
-              Expanded(
-                child: Text(
-                  fileInfo['name'],
-                  overflow: TextOverflow.ellipsis,
-                  // style: context.textTheme.titleSmall,
-                ),
-              ),
-              Obx(() {
-                return parentController.fileInfos[fileInfo['id']]['size'] != 0
-                    ? Text(
-                        Util.fmtByte(
-                            parentController.fileInfos[fileInfo['id']]['size']),
-                        // style: context.textTheme.labelMedium,
-                        overflow: TextOverflow.ellipsis,
-                      )
-                    : const SizedBox.shrink();
-              })
-            ]),
-            children: buildTreeViewItemsR(
-                // parentController.fileInfos.where((e) => e['level'] > level).toList(),
-                level + 1,
-                fileInfo['id'])));
-      } else {
-        // file
-        res.add(fluent.TreeViewItem(
-          value: {'id': fileInfo['id'], 'fileId': fileInfo['fileId']},
-          selected: fileInfo['selected'],
-          onInvoked: (item, reason) async {
-            if (reason == fluent.TreeViewItemInvokeReason.selectionToggle) {
-              if (item.selected == true) {
-                parentController.selectedIndexes.add(item.value['fileId']);
-                addAncestorFolderSizeR(item.value['id'], fileInfo['size']);
-                parentController.fileInfos.refresh();
-              } else {
-                parentController.selectedIndexes.remove(item.value['fileId']);
-                reduceAncestorFolderSizeR(item.value['id'], fileInfo['size']);
-                parentController.fileInfos.refresh();
-              }
-            }
-          },
-          collapsable: false,
-          leading: fileInfo['name'].lastIndexOf('.') == -1
-              ? Icon(
-                  FaIcons.doc,
-                  color: appController.downloaderConfig.value.extra.themeMode ==
-                          'dark'
-                      ? Colors.white
-                      : Colors.black45,
-                )
-              : Icon(
-                  FaIcons.allIcons[findIcon(fileInfo['name'])],
-                  color: appController.downloaderConfig.value.extra.themeMode ==
-                          'dark'
-                      ? Colors.white
-                      : Colors.black45,
-                ),
-          content: Row(mainAxisAlignment: MainAxisAlignment.end, children: [
-            Expanded(
-                child: Text(
-              fileInfo['name'],
-              overflow: TextOverflow.ellipsis,
-              // style: context.textTheme.titleSmall,
-            )),
-            fileInfo['size'] > 0
-                ? Text(
-                    Util.fmtByte(
-                      fileInfo['size'],
-                    ),
-                    // style: context.textTheme.labelMedium,
-                    overflow: TextOverflow.ellipsis,
-                  )
-                : const SizedBox.shrink(),
-          ]),
-        ));
-      }
-    }
-
-    return res;
-  }
-
-  List<fluent.TreeViewItem> get items {
-    List infos = [];
-    int idNext = 0;
-    List selectedFileIds = [];
-    List openedFolders = [];
-    //make fileInfos list
-    for (var i = 0; i < files.length; i++) {
-      //parentId -1 means path root
-      int parentId = -1;
-      List folders = path.split(files[i].path);
-      for (var folder in folders) {
-        int indexInInfos = infos.lastIndexWhere((fileInfo) =>
-            fileInfo['name'] == folder && fileInfo['parentId'] == parentId);
-
-        if (indexInInfos != -1) {
-          //  folder exists
-          parentId = infos[indexInInfos]['id'];
-          // add size
-          infos[indexInInfos]['size'] += files[i].size;
-        } else {
-          // parent not exist
-          // create one and add index to parent's children
-          infos.add({
-            'level': folders.indexOf(folder),
-            'id': idNext,
-            'type': 'folder',
-            'name': folder,
-            'size': files[i].size,
-            'parentId': parentId,
-            'children': [],
-          });
-          openedFolders.add(idNext);
-          if (parentId != -1) {
-            infos[parentId]['children'].add(idNext);
-          }
-          parentId = idNext;
-          idNext++;
-        }
-      }
-      //add one file, add index to parent
-      infos.add({
-        'id': idNext,
-        'type': 'file',
-        'fileId': i,
-        'level': folders.length,
-        'name': files[i].name,
-        'size': files[i].size,
-        'parentId': parentId,
-        //TODO add unselected logic
-        'selected': true
-      });
-      selectedFileIds.add(i);
-      if (parentId != -1) {
-        infos[parentId]['children'].add(idNext);
-      }
-      idNext++;
-    }
-    parentController.fileInfos.value = infos;
-    parentController.selectedIndexes.value = selectedFileIds.cast();
-    parentController.openedFolders.value = openedFolders;
-    List<fluent.TreeViewItem> treeItems = buildTreeViewItemsR(0, -1);
-    return treeItems;
-  }
-
-  @override
-  Widget build(BuildContext context) {
-    return fluent.FluentTheme(
-        data: appController.downloaderConfig.value.extra.themeMode == 'system'
-            ? fluent.FluentThemeData(brightness: ui.window.platformBrightness)
-            : appController.downloaderConfig.value.extra.themeMode == 'light'
-                ? fluent.FluentThemeData(brightness: Brightness.light)
-                : fluent.FluentThemeData(brightness: Brightness.dark),
-        child: Column(
-          crossAxisAlignment: CrossAxisAlignment.start,
-          children: [
-            const Padding(padding: EdgeInsets.only(top: 10)),
-            Text(
-              'selectFile'.tr,
-              // style: TextStyle(color: themeData.hintColor),
-            ),
-            Expanded(
-                child: Container(
-                    margin: const EdgeInsets.only(top: 10),
-                    decoration: BoxDecoration(
-                        border: Border.all(color: Colors.grey, width: 1),
-                        borderRadius: BorderRadius.circular(5)),
-                    child: fluent.TreeView(
-                      selectionMode: fluent.TreeViewSelectionMode.multiple,
-                      shrinkWrap: false,
-                      // addRepaintBoundaries: false,
-                      usePrototypeItem: true,
-                      // cacheExtent: 20,
-                      // onItemInvoked: (item, reason) async => {},
-                      onSecondaryTap: (item, details) async {
-                        debugPrint(
-                            'onSecondaryTap $item at ${details.globalPosition}');
-                      },
-                      // onSelectionChanged: (selectedItems) async => {},
-                      narrowSpacing: true,
-                      items: items,
-                      // scrollPrimary: true,
-                    ))),
-          ],
-        ));
-  }
-}

ui/flutter/lib/app/views/file_tree_view.dart

@@ -0,0 +1,296 @@
+import 'package:checkable_treeview/checkable_treeview.dart';
+import 'package:flutter/material.dart';
+import 'package:get/get.dart';
+import 'package:toggle_switch/toggle_switch.dart';
+
+import '../../api/model/resource.dart';
+import '../../icon/gopeed_icons.dart';
+import '../../util/util.dart';
+import 'file_icon.dart';
+import 'responsive_builder.dart';
+import 'sort_icon_button.dart';
+
+const _toggleSwitchIcons = [
+  Gopeed.file_video,
+  Gopeed.file_audio,
+  Gopeed.file_image,
+];
+const _sizeGapWidth = 72.0;
+
+class FileTreeView extends StatefulWidget {
+  final List<FileInfo> files;
+  final List<int> initialValues;
+  final Function(List<int>) onSelectionChanged;
+
+  const FileTreeView(
+      {Key? key,
+      required this.files,
+      required this.initialValues,
+      required this.onSelectionChanged})
+      : super(key: key);
+
+  @override
+  State<FileTreeView> createState() => _FileTreeViewState();
+}
+
+class _FileTreeViewState extends State<FileTreeView> {
+  late GlobalKey<TreeViewState<int>> key;
+  late int totalSize;
+  int? toggleSwitchIndex;
+
+  @override
+  void initState() {
+    super.initState();
+    key = GlobalKey<TreeViewState<int>>();
+    totalSize = widget.files
+        .fold(0, (previousValue, element) => previousValue + element.size);
+    widget.onSelectionChanged(widget.initialValues);
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    final selectedFileCount =
+        key.currentState?.getSelectedValues().where((e) => e != null).length ??
+            widget.files.length;
+    final selectedFileSize = calcSelectedSize(null);
+
+    final filterRow = InkWell(
+      onTap: () {},
+      child: ToggleSwitch(
+        minHeight: 32,
+        cornerRadius: 8,
+        doubleTapDisable: true,
+        inactiveBgColor: Theme.of(context).dividerColor,
+        activeBgColor: [Theme.of(context).colorScheme.primary],
+        initialLabelIndex: toggleSwitchIndex,
+        icons: _toggleSwitchIcons,
+        onToggle: (index) {
+          toggleSwitchIndex = index;
+          if (index == null) {
+            key.currentState?.setSelectedValues(List.empty());
+            return;
+          }
+
+          final iconFileExtArr = iconConfigMap[_toggleSwitchIcons[index]] ?? [];
+          final selectedFileIndexes = widget.files
+              .asMap()
+              .entries
+              .where((e) => iconFileExtArr.contains(fileExt(e.value.name)))
+              .map((e) => e.key)
+              .toList();
+          key.currentState?.setSelectedValues(selectedFileIndexes);
+        },
+      ),
+    );
+    final countRow = Row(
+      children: [
+        Text('fileSelectedCount'.tr),
+        Text(
+          selectedFileCount.toString(),
+          style: Theme.of(context).textTheme.bodySmall,
+        ),
+        const SizedBox(width: 12),
+        Text('fileSelectedSize'.tr),
+        Text(
+          selectedFileCount > 0 && selectedFileSize == 0
+              ? 'unknown'.tr
+              : Util.fmtByte(selectedFileSize),
+          style: Theme.of(context).textTheme.bodySmall,
+        ),
+      ],
+    );
+
+    return Column(
+      crossAxisAlignment: CrossAxisAlignment.start,
+      children: [
+        Expanded(
+          child: Container(
+            decoration: BoxDecoration(
+              border: Border.all(color: Theme.of(context).dividerColor),
+              borderRadius: BorderRadius.circular(4),
+            ),
+            child: TreeView(
+              key: key,
+              nodes: buildTreeNodes(),
+              showExpandCollapseButton: true,
+              showSelectAll: true,
+              onSelectionChanged: (selectedValues) {
+                setState(() {});
+                widget.onSelectionChanged(selectedValues
+                    .where((e) => e != null)
+                    .map((e) => e!)
+                    .toList());
+              },
+              selectAllTrailing: (context) {
+                return Row(
+                  mainAxisAlignment: MainAxisAlignment.spaceBetween,
+                  children: [
+                    Row(
+                      mainAxisAlignment: MainAxisAlignment.end,
+                      children: [
+                        Text('name'.tr),
+                        SortIconButton(
+                          onStateChanged: (state) {
+                            switch (state) {
+                              case SortState.asc:
+                                key.currentState?.sort((p0, p1) {
+                                  return (p0.label as Text)
+                                      .data!
+                                      .compareTo((p1.label as Text).data!);
+                                });
+                                break;
+                              case SortState.desc:
+                                key.currentState?.sort((p0, p1) {
+                                  return (p1.label as Text)
+                                      .data!
+                                      .compareTo((p0.label as Text).data!);
+                                });
+                                break;
+                              default:
+                                key.currentState?.sort(null);
+                                break;
+                            }
+                          },
+                        ),
+                      ],
+                    ),
+                    Row(
+                      mainAxisAlignment: MainAxisAlignment.end,
+                      children: [
+                        Text('size'.tr),
+                        SortIconButton(
+                          onStateChanged: (state) {
+                            switch (state) {
+                              case SortState.asc:
+                                key.currentState?.sort((p0, p1) {
+                                  return calcSelectedSize(p0)
+                                      .compareTo(calcSelectedSize(p1));
+                                });
+                                break;
+                              case SortState.desc:
+                                key.currentState?.sort((p0, p1) {
+                                  return calcSelectedSize(p1)
+                                      .compareTo(calcSelectedSize(p0));
+                                });
+                                break;
+                              default:
+                                key.currentState?.sort(null);
+                                break;
+                            }
+                          },
+                        ),
+                      ],
+                    )
+                  ],
+                );
+              },
+            ),
+          ),
+        ),
+        const SizedBox(height: 12),
+        !ResponsiveBuilder.isNarrow(context)
+            ? Row(
+                mainAxisAlignment: MainAxisAlignment.spaceBetween,
+                crossAxisAlignment: CrossAxisAlignment.center,
+                children: [
+                  filterRow,
+                  countRow,
+                ],
+              )
+            : Column(
+                crossAxisAlignment: CrossAxisAlignment.start,
+                children: [
+                  filterRow,
+                  const SizedBox(height: 8),
+                  countRow,
+                ],
+              ),
+      ],
+    );
+  }
+
+  int calcSelectedSize(TreeNode<int>? node) {
+    if (key.currentState == null) {
+      return widget.files
+          .fold(0, (previousValue, element) => previousValue + element.size);
+    }
+
+    final selectedFileIndexes = node == null
+        ? key.currentState?.getSelectedValues()
+        : (node.value != null
+            ? [node.value]
+            : key.currentState?.getChildSelectedValues(node));
+
+    if (selectedFileIndexes == null) return 0;
+    return selectedFileIndexes.where((e) => e != null).map((e) => e!).fold(0,
+        (previousValue, element) => previousValue + widget.files[element].size);
+  }
+
+  List<TreeNode<int>> buildTreeNodes() {
+    final List<TreeNode<int>> rootNodes = [];
+    final Map<String, TreeNode<int>> dirNodes = {};
+
+    for (var i = 0; i < widget.files.length; i++) {
+      final file = widget.files[i];
+      final parts = file.path.split('/');
+      String currentPath = '';
+      TreeNode<int>? parentNode;
+
+      // Create or get directory nodes
+      for (final part in parts) {
+        if (part.isEmpty) continue;
+
+        currentPath += '/$part';
+        if (!dirNodes.containsKey(currentPath)) {
+          final node = TreeNode<int>(
+            label: Text(part),
+            icon: Icon(
+              fileIcon(part, isFolder: true),
+              size: 18,
+            ),
+            trailing: (context, node) {
+              final size = calcSelectedSize(node);
+              return size > 0
+                  ? Text(Util.fmtByte(calcSelectedSize(node)),
+                      style: Theme.of(context).textTheme.bodySmall)
+                  : const SizedBox(width: _sizeGapWidth);
+            },
+            children: [],
+          );
+          dirNodes[currentPath] = node;
+
+          if (parentNode == null) {
+            rootNodes.add(node);
+          } else {
+            parentNode.children.add(node);
+          }
+        }
+        parentNode = dirNodes[currentPath];
+      }
+
+      // Create file node using file.name
+      final fileNode = TreeNode<int>(
+        label: Text(file.name),
+        value: i,
+        icon: Icon(fileIcon(file.name, isFolder: false), size: 18),
+        trailing: (context, node) {
+          return file.size > 0
+              ? Text(Util.fmtByte(file.size),
+                  style: Theme.of(context).textTheme.bodySmall)
+              : const SizedBox(width: _sizeGapWidth);
+        },
+        isSelected: widget.initialValues.contains(i),
+        children: [],
+      );
+
+      // Add file node to parent or root
+      if (parentNode != null) {
+        parentNode.children.add(fileNode);
+      } else {
+        rootNodes.add(fileNode);
+      }
+    }
+
+    return rootNodes;
+  }
+}