release: v1.6.7

.github/workflows/build.yml

@@ -14,7 +14,7 @@ on:
 
 env:
   GO_VERSION: "1.23"
-  FLUTTER_VERSION: "3.24.3"
+  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]
@@ -441,8 +443,9 @@ jobs:
         env:
           VERSION: ${{ needs.get-release.outputs.version }}
         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
@@ -468,6 +471,39 @@ jobs:
               || true
             done
           done
+          sudo apt update -y
+          sudo apt install -y pv python2 bsdmainutils
+          wget -O qdk2_0.32.bionic_amd64.deb "https://github.com/qnap-dev/qdk2/releases/download/v0.32/qdk2_0.32.bionic_amd64.deb"
+          dpkg -X qdk2_0.32.bionic_amd64.deb qdk2 # Direct installs will fail due to missing dependencies!
+          [[ -d qdk2 ]] || exit 1
+          export PATH=$(pwd)/qdk2/usr/bin:$(pwd)/qdk2/usr/share/qdk2/QDK/bin:${PATH}
+          wget -O Gopeed.template.tar.gz "https://github.com/GopeedLab/QpkgBuild/raw/refs/heads/master/template/Gopeed.template.tar.gz"
+          tar -zxf Gopeed.template.tar.gz
+          [[ -d Gopeed ]] || exit 1
+          goos=linux
+          goarch_arr=(amd64 arm64)
+          for goarch in "${goarch_arr[@]}"; do
+            qarch=x86_64
+            [[ "${goarch}" == "arm64" ]] && qarch=arm_64
+            name=gopeed-web-v${VERSION}-${goos}-${goarch}
+            cp dist/${name}/${name}/* Gopeed/${qarch}/
+          done
+          cd Gopeed
+          sed -i -e 's/__QPKG_VER__/${VERSION}/g' qpkg.cfg
+          qbuild || exit 1
+          for f in build/*; do echo ">>> build=[${f}]"; done
+          goos=qnap
+          goarch_arr=(amd64 arm64)
+          for goarch in "${goarch_arr[@]}"; do
+            qarch=x86_64
+            [[ "${goarch}" == "arm64" ]] && qarch=arm_64
+            sname=Gopeed_${VERSION}_${qarch}.qpkg
+            dname=gopeed-${goos}-v${VERSION}-${goarch}.qpkg
+            echo "sname=${sname}, dname=${dname}"
+            [[ -f build/${sname} ]] && cp -ra build/${sname} ../dist/zip/${dname}
+          done
+          for f in ../dist/zip/*; do echo ">>> dist=[${f}]"; done
+          cd ..
       - name: Upload
         uses: shogo82148/actions-upload-release-asset@v1
         with:
@@ -499,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.24.3"
+  FLUTTER_VERSION: "3.24.5"
 
 jobs:
   #  lint:
@@ -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

Dockerfile

@@ -8,14 +8,13 @@ RUN CGO_ENABLED=0 go build -tags nosqlite,web \
       -ldflags="-s -w -X github.com/GopeedLab/gopeed/pkg/base.Version=$VERSION -X github.com/GopeedLab/gopeed/pkg/base.InDocker=true" \
       -o dist/gopeed github.com/GopeedLab/gopeed/cmd/web
 
-FROM alpine:3.14.2
+FROM alpine:3.18
 LABEL maintainer="monkeyWie"
 WORKDIR /app
 COPY --from=go /app/dist/gopeed ./
 COPY entrypoint.sh ./entrypoint.sh
 RUN apk update && \
-    apk upgrade --no-cache && \
+    apk add --no-cache su-exec ; \
-    apk add --no-cache bash su-exec; \
     chmod +x ./entrypoint.sh && \
     rm -rf /var/cache/apk/*
 VOLUME ["/app/storage"]

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>
@@ -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>
@@ -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>
@@ -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>
@@ -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>
@@ -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
 ```

docker-compose.yml

@@ -1,12 +1,15 @@
-version: '3'
-
 services:
     gopeed:
       container_name: gopeed
       ports:
-      - "9999:9999" # HTTP port (host:container)
+        - 9999:9999 # HTTP port (host:container)
-    image: liwei2633/gopeed
+      environment:
+        - PUID=0
+        - PGID=0
+        - UMASK=022
       volumes:
         - ~/gopeed/Downloads:/app/Downloads # mount download path
         #- ~/gopeed/storage:/app/storage # if you need to mount storage path, uncomment this line
       restart: unless-stopped
+      image: liwei2633/gopeed
+      # command: -u Username -p Password # optional authentication

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)
 	}
@@ -162,9 +166,6 @@ func (f *Fetcher) Resolve(req *base.Request) error {
 func (f *Fetcher) Create(opts *base.Options) error {
 	f.meta.Opts = opts
 
-	if err := base.ParseReqExtra[fhttp.ReqExtra](f.meta.Req); err != nil {
-		return err
-	}
 	if err := base.ParseOptsExtra[fhttp.OptsExtra](f.meta.Opts); err != nil {
 		return err
 	}
@@ -198,6 +199,12 @@ func (f *Fetcher) Start() (err error) {
 	if err != nil {
 		return err
 	}
+
+	// Avoid request extra modified by extension
+	if err = base.ParseReqExtra[fhttp.ReqExtra](f.meta.Req); err != nil {
+		return err
+	}
+
 	if f.chunks == nil {
 		f.chunks = f.splitChunk()
 	}
@@ -247,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 {
@@ -286,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
@@ -330,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 {
@@ -348,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
@@ -416,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
 }
 
@@ -449,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

@@ -204,33 +204,29 @@ func (d *Downloader) Setup() error {
 
 						current := task.fetcher.Progress().TotalDownloaded()
 						tick := float64(d.cfg.RefreshInterval) / 1000
+						downloadDataChanged := false
 						if task.Status == base.DownloadStatusRunning {
+							downloadDataChanged = current != task.Progress.Downloaded
 							task.Progress.Used = task.timer.Used()
 							task.Progress.Speed = task.calcSpeed(task.speedArr, current-task.Progress.Downloaded, tick)
 							task.Progress.Downloaded = current
 						}
+
+						uploadDataChanged := false
 						if task.Uploading {
 							uploader := task.fetcher.(fetcher.Uploader)
 							currentUploaded := uploader.UploadedBytes()
+							uploadDataChanged = currentUploaded != task.Progress.Uploaded
 							task.Progress.UploadSpeed = task.calcSpeed(task.uploadSpeedArr, currentUploaded-task.Progress.Uploaded, tick)
 							task.Progress.Uploaded = currentUploaded
 						}
 						d.emit(EventKeyProgress, task)
 
-						// store fetcher progress
+						// store fetcher progress when download/upload data changed
-						data, err := task.fetcherManager.Store(task.fetcher)
+						if !downloadDataChanged && !uploadDataChanged {
-						if err != nil {
-							d.Logger.Error().Stack().Err(err).Msgf("serialize fetcher failed: %s", task.ID)
-							return
-						}
-						if err := d.storage.Put(bucketSave, task.ID, data); err != nil {
-							d.Logger.Error().Stack().Err(err).Msgf("persist fetcher failed: %s", task.ID)
-							return
-						}
-						if err := d.storage.Put(bucketTask, task.ID, task); err != nil {
-							d.Logger.Error().Stack().Err(err).Msgf("persist task failed: %s", task.ID)
 							return
 						}
+						d.saveTask(task)
 					}()
 				}
 			}
@@ -273,6 +269,23 @@ func (d *Downloader) setupFetcher(fm fetcher.FetcherManager, fetcher fetcher.Fet
 	fetcher.Setup(ctl)
 }
 
+func (d *Downloader) saveTask(task *Task) error {
+	data, err := task.fetcherManager.Store(task.fetcher)
+	if err != nil {
+		d.Logger.Error().Stack().Err(err).Msgf("serialize fetcher failed: %s", task.ID)
+		return err
+	}
+	if err := d.storage.Put(bucketSave, task.ID, data); err != nil {
+		d.Logger.Error().Stack().Err(err).Msgf("persist fetcher failed: %s", task.ID)
+		return err
+	}
+	if err := d.storage.Put(bucketTask, task.ID, task); err != nil {
+		d.Logger.Error().Stack().Err(err).Msgf("persist task failed: %s", task.ID)
+		return err
+	}
+	return nil
+}
+
 func (d *Downloader) Resolve(req *base.Request) (rr *ResolveResult, err error) {
 	rrId, err := gonanoid.New()
 	if err != nil {
@@ -813,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
 	}
 
@@ -1005,8 +1018,6 @@ func (d *Downloader) doStart(task *Task) (err error) {
 			return
 		}
 		isCreate = task.Status == base.DownloadStatusReady
-
-		d.triggerOnStart(task)
 		task.updateStatus(base.DownloadStatusRunning)
 
 		return
@@ -1023,6 +1034,7 @@ func (d *Downloader) doStart(task *Task) (err error) {
 		task.lock.Lock()
 		defer task.lock.Unlock()
 
+		d.triggerOnStart(task)
 		if task.Meta.Res == nil {
 			err := task.fetcher.Resolve(task.Meta.Req)
 			if err != nil {
@@ -1064,7 +1076,7 @@ func (d *Downloader) doStart(task *Task) (err error) {
 		if err := task.fetcher.Start(); err != nil {
 			return err
 		}
-		if err := d.storage.Put(bucketTask, task.ID, task.clone()); err != nil {
+		if err := d.saveTask(task); err != nil {
 			return err
 		}
 		d.emit(EventKeyStart, task)

pkg/download/extension.go

@@ -702,20 +702,22 @@ 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 {
-	*Task
-
 	download *Downloader
+
+	*Task
 }
 
 func NewExtensionTask(download *Downloader, task *Task) *ExtensionTask {
+	// restricts extension scripts to only modify request info
 	newTask := task.clone()
-	// Assign the pointer of the properties that the extension supports modification
+	newTask.Meta.Req = task.Meta.Req
-	newTask.Meta = task.Meta
-	newTask.Status = task.Status
 	return &ExtensionTask{
-		Task:     newTask,
 		download: download,
+		Task:     newTask,
 	}
 }
 

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.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;
+}