release: v1.4.3

.github/release-drafter.yml

@@ -11,6 +11,8 @@ categories:
       - 'fix'
       - 'bugfix'
       - 'bug'
+  - title: '🧪 Tests'
+    label: 'test'
   - title: '🧰 Maintenance'
     label: 'chore'
   - title: '📖 Document'

.github/workflows/build.yml

@@ -44,7 +44,7 @@ jobs:
           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
-          $mingw = "C:\ProgramData\Chocolatey\lib\mingw\tools\install\mingw64\bin"
+          $mingw = "C:\Program Files\Git\mingw64\bin"
           $system = "C:\Windows\System32"
           $release = "build\windows\runner\Release\"
           cp $mingw\libstdc++-6.dll $release

README.md

@@ -13,7 +13,8 @@
 
 ## Introduction
 
-Gopeed (full name Go Speed), a high-speed downloader developed by `Golang` + `Flutter`, supports (HTTP, BitTorrent, Magnet) protocol, and supports all platforms.
+Gopeed (full name Go Speed), a high-speed downloader developed by `Golang` + `Flutter`, supports (HTTP, BitTorrent, Magnet) protocol, and supports all platforms. In addition to basic download functions, Gopeed is also a highly customizable downloader that supports implementing more features through integration with [APIs](https://docs.gopeed.com/dev-api.html) or installation and development of [extensions](https://docs.gopeed.com/dev-extension.html).
+
 
 Visit ✈ [Official Website](https://gopeed.com) | 📖 [Develop Docs](https://docs.gopeed.com)
 

README_ja-JP.md

@@ -13,7 +13,7 @@
 
 ## はじめに
 
-Gopeed (正式名 Go Speed) は `Golang` + `Flutter` によって開発された高速ダウンローダーで、(HTTP、BitTorrent、Magnet) プロトコルをサポートし、すべてのプラットフォームをサポートします。
+Gopeed (正式名 Go Speed) は `Golang` + `Flutter` によって開発された高速ダウンローダーで、(HTTP、BitTorrent、Magnet) プロトコルをサポートし、すべてのプラットフォームをサポートします。基本的なダウンロード機能に加え、[APIs](https://docs.gopeed.com/dev-api.html)との連動や[拡張機能](https://docs.gopeed.com/dev-extension.html)のインストール・開発による追加機能にも対応した、カスタマイズ性の高いダウンローダーです。
 
 見て下さい ✈ [公式ウェブサイト](https://gopeed.com) | 📖 [開発ドキュメント](https://docs.gopeed.com)
 

README_zh-CN.md

@@ -13,7 +13,7 @@
 
 ## 介绍
 
-Gopeed（全称 Go Speed），是一款由`Golang`+`Flutter`开发的高速下载器，支持（HTTP、BitTorrent、Magnet）协议下载，并且支持全平台使用。
+Gopeed（全称 Go Speed），是一款由`Golang`+`Flutter`开发的高速下载器，支持（HTTP、BitTorrent、Magnet）协议下载，并且支持全平台使用。除了基本的下载功能外，Gopeed 还是一款高度可定制化的下载器，支持通过对接[APIs](https://docs.gopeed.com/zh/dev-api.html)或者安装和开发[扩展](https://docs.gopeed.com/zh/dev-extension.html)来实现更多的功能。
 
 访问 ✈ [官方网站](https://gopeed.com/zh-CN) | 📖 [开发文档](https://docs.gopeed.com/zh/)
 

internal/protocol/http/fetcher.go

@@ -18,6 +18,7 @@ import (
 	"os"
 	"path"
 	"strconv"
+	"time"
 )
 
 type RequestError struct {
@@ -37,6 +38,8 @@ type chunk struct {
 	Begin      int64
 	End        int64
 	Downloaded int64
+
+	retryTimes int
 }
 
 func newChunk(begin int64, end int64) *chunk {
@@ -255,24 +258,43 @@ func (f *Fetcher) fetch() {
 
 func (f *Fetcher) fetchChunk(index int, ctx context.Context) (err error) {
 	chunk := f.chunks[index]
+	chunk.retryTimes = 0
 
 	httpReq, err := buildRequest(ctx, f.meta.Req)
 	if err != nil {
 		return err
 	}
 	var (
-		client = buildClient()
-		buf    = make([]byte, 8192)
+		client     = buildClient()
+		buf        = make([]byte, 8192)
+		maxRetries = 3
 	)
-	// 重试5次
-	for i := 0; i < 5; i++ {
+	// retry until all remain chunks failed
+	for true {
 		// if chunk is completed, return
 		if f.meta.Res.Range && chunk.Downloaded >= chunk.End-chunk.Begin+1 {
 			return
 		}
+
+		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 (
-			resp  *http.Response
-			retry bool
+			resp *http.Response
 		)
 		if f.meta.Res.Range {
 			httpReq.Header.Set(base.HttpHeaderRange,
@@ -292,35 +314,45 @@ func (f *Fetcher) fetchChunk(index int, ctx context.Context) (err error) {
 			return nil
 		}()
 		if err != nil {
-			// retry request
+			// If canceled, do not retry
+			if errors.Is(err, context.Canceled) {
+				return
+			}
+			// retry request after 1 second
+			chunk.retryTimes = chunk.retryTimes + 1
+			time.Sleep(time.Second)
 			continue
 		}
-		// 请求成功就重置错误次数，连续失败5次才终止
-		i = 0
-		retry, err = func() (bool, error) {
+		// Http request success, reset retry times
+		chunk.retryTimes = 0
+		err = func() error {
 			defer resp.Body.Close()
 			for {
 				n, err := resp.Body.Read(buf)
 				if n > 0 {
 					_, err := f.file.WriteAt(buf[:n], chunk.Begin+chunk.Downloaded)
 					if err != nil {
-						return false, err
+						return err
 					}
 					chunk.Downloaded += int64(n)
 				}
 				if err != nil {
-					if err != io.EOF {
-						return true, err
+					if err == io.EOF {
+						return nil
 					}
-					break
+					return err
 				}
 			}
-			return false, nil
 		}()
-		if !retry {
-			// 下载成功，跳出重试
-			break
+		// if chunk is completed, reset other not complete chunks retry times
+		if err == nil {
+			for _, c := range f.chunks {
+				if c != chunk && c.retryTimes > 0 {
+					c.retryTimes = 0
+				}
+			}
 		}
+		break
 	}
 	return
 }
@@ -438,9 +470,7 @@ func (fb *FetcherBuilder) Restore() (v any, f func(meta *fetcher.FetcherMeta, v
 		fetcher.meta = meta
 		base.ParseReqExtra[fhttp.ReqExtra](fetcher.meta.Req)
 		base.ParseOptsExtra[fhttp.OptsExtra](fetcher.meta.Opts)
-		if len(fd.Chunks) == 0 {
-			fetcher.chunks = fetcher.splitChunk()
-		} else {
+		if len(fd.Chunks) > 0 {
 			fetcher.chunks = fd.Chunks
 		}
 		return fetcher

internal/protocol/http/fetcher_test.go

@@ -76,7 +76,7 @@ func testResolve(startTestServer func() net.Listener, path string, want *base.Re
 func TestFetcher_DownloadNormal(t *testing.T) {
 	listener := test.StartTestFileServer()
 	defer listener.Close()
-	// 正常下载
+
 	downloadNormal(listener, 1, t)
 	downloadNormal(listener, 5, t)
 	downloadNormal(listener, 8, t)
@@ -86,7 +86,7 @@ func TestFetcher_DownloadNormal(t *testing.T) {
 func TestFetcher_DownloadContinue(t *testing.T) {
 	listener := test.StartTestFileServer()
 	defer listener.Close()
-	// 暂停继续
+
 	downloadContinue(listener, 1, t)
 	downloadContinue(listener, 5, t)
 	downloadContinue(listener, 8, t)
@@ -96,7 +96,7 @@ func TestFetcher_DownloadContinue(t *testing.T) {
 func TestFetcher_DownloadChunked(t *testing.T) {
 	listener := test.StartTestCustomServer()
 	defer listener.Close()
-	// chunked编码下载
+
 	downloadNormal(listener, 1, t)
 	downloadNormal(listener, 2, t)
 }
@@ -104,24 +104,33 @@ func TestFetcher_DownloadChunked(t *testing.T) {
 func TestFetcher_DownloadPost(t *testing.T) {
 	listener := test.StartTestPostServer()
 	defer listener.Close()
-	// post下载
+
 	downloadPost(listener, 1, t)
 }
 
 func TestFetcher_DownloadRetry(t *testing.T) {
 	listener := test.StartTestRetryServer()
 	defer listener.Close()
-	// chunked编码下载
+
 	downloadNormal(listener, 1, t)
 }
 
 func TestFetcher_DownloadError(t *testing.T) {
 	listener := test.StartTestErrorServer()
 	defer listener.Close()
-	// chunked编码下载
+
 	downloadError(listener, 1, t)
 }
 
+func TestFetcher_DownloadLimit(t *testing.T) {
+	listener := test.StartTestLimitServer()
+	defer listener.Close()
+
+	downloadNormal(listener, 1, t)
+	downloadNormal(listener, 2, t)
+	downloadNormal(listener, 8, t)
+}
+
 func TestFetcher_DownloadResume(t *testing.T) {
 	listener := test.StartTestFileServer()
 	defer listener.Close()

internal/test/httptest.go

@@ -9,6 +9,9 @@ import (
 	"net"
 	"net/http"
 	"os"
+	"strconv"
+	"strings"
+	"sync/atomic"
 	"time"
 )
 
@@ -81,7 +84,7 @@ func StartTestRetryServer() net.Listener {
 		mux := http.NewServeMux()
 		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
 			counter++
-			if counter != 1 && counter < 5 {
+			if counter != 1 && counter < 2 {
 				writer.WriteHeader(500)
 				return
 			}
@@ -134,6 +137,79 @@ func StartTestErrorServer() net.Listener {
 	})
 }
 
+// StartTestLimitServer connections limit server
+func StartTestLimitServer() net.Listener {
+	var connections atomic.Int32
+
+	return startTestServer(func() http.Handler {
+		mux := http.NewServeMux()
+		mux.HandleFunc("/"+BuildName, func(writer http.ResponseWriter, request *http.Request) {
+			defer func() {
+				connections.Add(-1)
+			}()
+			connections.Add(1)
+			if connections.Load() > 4 {
+				writer.WriteHeader(403)
+				return
+			}
+
+			r := request.Header.Get("Range")
+			if r == "" {
+				writer.Header().Set("Content-Length", fmt.Sprintf("%d", BuildSize))
+				writer.WriteHeader(200)
+				file, err := os.Open(BuildFile)
+				if err != nil {
+					panic(err)
+				}
+				defer file.Close()
+				io.Copy(writer, file)
+			} else {
+				// split range
+				s := strings.Split(r, "=")
+				if len(s) != 2 {
+					writer.WriteHeader(400)
+					return
+				}
+				s = strings.Split(s[1], "-")
+				if len(s) != 2 {
+					writer.WriteHeader(400)
+					return
+				}
+				start, err := strconv.ParseInt(s[0], 10, 64)
+				if err != nil {
+					writer.WriteHeader(400)
+					return
+				}
+				end, err := strconv.ParseInt(s[1], 10, 64)
+				if err != nil {
+					writer.WriteHeader(400)
+					return
+				}
+				if start < 0 || end < 0 || start > end {
+					writer.WriteHeader(400)
+					return
+				}
+				if end >= BuildSize {
+					end = BuildSize - 1
+				}
+				writer.Header().Set("Content-Length", fmt.Sprintf("%d", end-start+1))
+				writer.Header().Set("Content-Range", fmt.Sprintf("bytes %d-%d/%d", start, end, BuildSize))
+				writer.Header().Set("Accept-Ranges", "bytes")
+				writer.WriteHeader(206)
+				file, err := os.Open(BuildFile)
+				if err != nil {
+					writer.WriteHeader(500)
+					return
+				}
+				defer file.Close()
+				file.Seek(start, 0)
+				io.CopyN(writer, file, end-start+1)
+			}
+		})
+		return mux
+	})
+}
+
 func startTestServer(serverHandle func() http.Handler) net.Listener {
 	listener, err := net.Listen("tcp", "127.0.0.1:0")
 	if err != nil {

pkg/base/model.go

@@ -9,6 +9,15 @@ import (
 type Request struct {
 	URL   string `json:"url"`
 	Extra any    `json:"extra"`
+	// Labels is used to mark the download task
+	Labels map[string]string `json:"labels"`
+}
+
+func (r *Request) Validate() error {
+	if r.URL == "" {
+		return fmt.Errorf("invalid request url")
+	}
+	return nil
 }
 
 // Resource download resource
@@ -36,7 +45,6 @@ func (r *Resource) Validate() error {
 		}
 	}
 	return nil
-
 }
 
 func (r *Resource) CalcSize() {

pkg/download/downloader.go

@@ -9,7 +9,6 @@ import (
 	"github.com/GopeedLab/gopeed/pkg/util"
 	gonanoid "github.com/matoous/go-nanoid/v2"
 	"github.com/virtuald/go-paniclog"
-	"math"
 	"os"
 	"path/filepath"
 	"sort"
@@ -28,6 +27,8 @@ const (
 	bucketConfig = "config"
 	// downloader extension bucket
 	bucketExtension = "extension"
+	// downloader extension storage bucket
+	bucketExtensionStorage = "extension_storage"
 )
 
 var (
@@ -54,11 +55,13 @@ type Downloader struct {
 	fetcherCache    map[string]fetcher.Fetcher
 	storage         Storage
 	tasks           []*Task
+	waitTasks       []*Task
 	listener        Listener
 
-	lock           *sync.Mutex
-	fetcherMapLock *sync.RWMutex
-	closed         atomic.Bool
+	lock               *sync.Mutex
+	fetcherMapLock     *sync.RWMutex
+	checkDuplicateLock *sync.Mutex
+	closed             atomic.Bool
 
 	extensions []*Extension
 }
@@ -70,14 +73,15 @@ func NewDownloader(cfg *DownloaderConfig) *Downloader {
 	cfg.Init()
 
 	d := &Downloader{
-		cfg: cfg,
-
+		cfg:             cfg,
 		fetcherBuilders: make(map[string]fetcher.FetcherBuilder),
 		fetcherCache:    make(map[string]fetcher.Fetcher),
+		waitTasks:       make([]*Task, 0),
+		storage:         cfg.Storage,
 
-		storage:        cfg.Storage,
-		lock:           &sync.Mutex{},
-		fetcherMapLock: &sync.RWMutex{},
+		lock:               &sync.Mutex{},
+		fetcherMapLock:     &sync.RWMutex{},
+		checkDuplicateLock: &sync.Mutex{},
 
 		extensions: make([]*Extension, 0),
 	}
@@ -97,7 +101,7 @@ func NewDownloader(cfg *DownloaderConfig) *Downloader {
 
 func (d *Downloader) Setup() error {
 	// setup storage
-	if err := d.storage.Setup([]string{bucketTask, bucketSave, bucketConfig, bucketExtension}); err != nil {
+	if err := d.storage.Setup([]string{bucketTask, bucketSave, bucketConfig, bucketExtension, bucketExtensionStorage}); err != nil {
 		return err
 	}
 	// load config from storage
@@ -246,6 +250,33 @@ func (d *Downloader) Resolve(req *base.Request) (rr *ResolveResult, err error) {
 	return
 }
 
+func (d *Downloader) notifyRunning() {
+	go func() {
+		d.lock.Lock()
+		defer d.lock.Unlock()
+
+		remainRunningCount := d.remainRunningCount()
+		if remainRunningCount == 0 {
+			return
+		}
+		if len(d.waitTasks) > 0 {
+			wt := d.waitTasks[0]
+			d.waitTasks = d.waitTasks[1:]
+			d.doStart(wt)
+		}
+	}()
+}
+
+func (d *Downloader) remainRunningCount() int {
+	runningCount := 0
+	for _, t := range d.tasks {
+		if t.Status == base.DownloadStatusRunning {
+			runningCount++
+		}
+	}
+	return d.cfg.MaxRunning - runningCount
+}
+
 func (d *Downloader) CreateDirect(req *base.Request, opts *base.Options) (taskId string, err error) {
 	var fetcher fetcher.Fetcher
 	fetcher, err = d.buildFetcher(req.URL)
@@ -279,10 +310,21 @@ func (d *Downloader) Pause(id string) (err error) {
 	if task == nil {
 		return ErrTaskNotFound
 	}
-	if err = d.doPause(task, base.DownloadStatusPause); err != nil {
-		return err
-	}
-	return d.notifyRunning()
+
+	func() {
+		task.lock.Lock()
+		defer task.lock.Unlock()
+
+		if task.Status == base.DownloadStatusPause {
+			return
+		}
+		err = d.doPause(task)
+		if err != nil {
+			return
+		}
+		d.notifyRunning()
+	}()
+	return
 }
 
 func (d *Downloader) Continue(id string) (err error) {
@@ -290,109 +332,164 @@ func (d *Downloader) Continue(id string) (err error) {
 	if task == nil {
 		return ErrTaskNotFound
 	}
-	d.tryRunning(func(remain int) {
-		if remain == 0 {
-			// no more task can be running, need to doPause a running task
+
+	func() {
+		d.lock.Lock()
+		defer d.lock.Unlock()
+
+		remainRunningCount := d.remainRunningCount()
+		if remainRunningCount == 0 {
 			for _, t := range d.tasks {
 				if t.Status == base.DownloadStatusRunning {
-					err = d.doPause(t, base.DownloadStatusWait)
+					if err = d.doPause(t); err != nil {
+						return
+					}
+					t.Status = base.DownloadStatusWait
+					d.waitTasks = append(d.waitTasks, t)
 					break
 				}
 			}
 		}
-		if err != nil {
+	}()
+
+	func() {
+		task.lock.Lock()
+		defer task.lock.Unlock()
+
+		if task.Status == base.DownloadStatusRunning {
 			return
 		}
-	})
-	if err != nil {
-		return
-	}
-	return d.doContinue(task)
+
+		if err = d.doStart(task); err != nil {
+			return
+		}
+	}()
+	return
 }
 
 func (d *Downloader) PauseAll() (err error) {
-	d.lock.Lock()
-	defer d.lock.Unlock()
-	return d.doPauseAll()
-}
+	func() {
+		d.lock.Lock()
+		defer d.lock.Unlock()
+
+		// Clear wait tasks
+		d.waitTasks = d.waitTasks[:0]
+	}()
 
-func (d *Downloader) ContinueAll() (err error) {
-	d.lock.Lock()
-	defer d.lock.Unlock()
-	runningCount := 0
-	continueTasks := make([]*Task, 0)
 	for _, task := range d.tasks {
-		if task.Status == base.DownloadStatusRunning {
-			runningCount++
-		} else if task.Status != base.DownloadStatusDone {
-			continueTasks = append(continueTasks, task)
-		}
-	}
-	// calculate how many tasks can be continued, can't exceed maxRunning
-	continueCount := int(math.Min(float64(d.cfg.MaxRunning-runningCount), float64(len(continueTasks))))
-	for i := 0; i < continueCount; i++ {
-		if err = d.doContinue(continueTasks[i]); err != nil {
+		err = func() error {
+			task.lock.Lock()
+			defer task.lock.Unlock()
+
+			return d.doPause(task)
+		}()
+		if err != nil {
 			return
 		}
 	}
+
+	return
+}
+
+func (d *Downloader) ContinueAll() (err error) {
+	continuedTasks := make([]*Task, 0)
+
+	func() {
+		d.lock.Lock()
+		defer d.lock.Unlock()
+		// calculate how many tasks can be continued, can't exceed maxRunning
+		remainCount := d.remainRunningCount()
+		for _, task := range d.tasks {
+			if task.Status != base.DownloadStatusRunning && task.Status != base.DownloadStatusDone {
+				if len(continuedTasks) < remainCount {
+					continuedTasks = append(continuedTasks, task)
+				} else {
+					task.Status = base.DownloadStatusWait
+					d.waitTasks = append(d.waitTasks, task)
+				}
+			}
+		}
+	}()
+
+	for _, task := range continuedTasks {
+		tt := task
+		err = func() error {
+			tt.lock.Lock()
+			defer tt.lock.Unlock()
+
+			return d.doStart(tt)
+		}()
+		if err != nil {
+			return
+		}
+	}
+
 	return
 }
 
 func (d *Downloader) Delete(id string, force bool) (err error) {
-	d.lock.Lock()
-	defer d.lock.Unlock()
 	task := d.GetTask(id)
 	if task == nil {
 		return ErrTaskNotFound
 	}
-	task.lock.Lock()
-	defer task.lock.Unlock()
-	if task.fetcher != nil {
-		err = task.fetcher.Close()
-		if err != nil {
-			return
-		}
-	}
-	for i, t := range d.tasks {
-		if t.ID == id {
-			d.tasks = append(d.tasks[:i], d.tasks[i+1:]...)
-			break
-		}
-	}
-	err = d.storage.Delete(bucketTask, id)
-	if err != nil {
-		return
-	}
-	err = d.storage.Delete(bucketSave, id)
-	if err != nil {
-		return
-	}
-	if force && task.Meta.Res != nil {
-		if task.Meta.Res.Name != "" {
-			if err = os.RemoveAll(task.Meta.FolderPath()); err != nil {
-				return
+
+	func() {
+		d.lock.Lock()
+		defer d.lock.Unlock()
+
+		for i, t := range d.tasks {
+			if t.ID == id {
+				d.tasks = append(d.tasks[:i], d.tasks[i+1:]...)
 			}
-		} else {
-			if err = util.SafeRemove(task.Meta.SingleFilepath()); err != nil {
+		}
+	}()
+
+	err = d.doDelete(task, force)
+	if err != nil {
+		return
+	}
+	d.notifyRunning()
+	return
+}
+
+func (d *Downloader) doDelete(task *Task, force bool) (err error) {
+	err = func() error {
+		if task.fetcher != nil {
+			if err := task.fetcher.Close(); err != nil {
 				return err
 			}
 		}
-	}
-	d.emit(EventKeyDelete, task)
-	if task.Status == base.DownloadStatusRunning {
-		if err = d.doNotifyRunning(); err != nil {
+		if err := d.storage.Delete(bucketTask, task.ID); err != nil {
 			return err
 		}
+		if err := d.storage.Delete(bucketSave, task.ID); err != nil {
+			return err
+		}
+		if force && task.Meta.Res != nil {
+			if task.Meta.Res.Name != "" {
+				if err := os.RemoveAll(task.Meta.FolderPath()); err != nil {
+					return err
+				}
+			} else {
+				if err := util.SafeRemove(task.Meta.SingleFilepath()); err != nil {
+					return err
+				}
+			}
+		}
+		d.emit(EventKeyDelete, task)
+		task = nil
+		return nil
+	}()
+	if err != nil {
+		d.Logger.Error().Stack().Err(err).Msgf("delete task failed, task id: %s", task.ID)
 	}
-	task = nil
+
 	return
 }
 
 func (d *Downloader) Close() error {
-	d.lock.Lock()
-	defer d.lock.Unlock()
 	d.closed.Store(true)
-	if err := d.doPauseAll(); err != nil {
+	if err := d.PauseAll(); err != nil {
 		return err
 	}
 	return d.storage.Close()
@@ -427,6 +524,9 @@ func (d *Downloader) emit(eventKey EventKey, task *Task, errs ...error) {
 			Task: task,
 			Err:  err,
 		})
+		if eventKey == EventKeyError {
+			d.emit(EventKeyFinally, task, err)
+		}
 	}
 }
 
@@ -492,11 +592,9 @@ func (d *Downloader) watch(task *Task) {
 		task.Status = base.DownloadStatusDone
 		d.storage.Put(bucketTask, task.ID, task.clone())
 		d.emit(EventKeyDone, task)
+		d.emit(EventKeyFinally, task, err)
 	}
-	d.emit(EventKeyFinally, task, err)
-	if task.Status == EventKeyDone {
-		d.notifyRunning()
-	}
+	d.notifyRunning()
 }
 
 func (d *Downloader) restoreFetcher(task *Task) error {
@@ -524,6 +622,12 @@ func (d *Downloader) restoreFetcher(task *Task) error {
 			task.fetcher = fb.Build()
 		}
 		d.setupFetcher(task.fetcher)
+		if task.fetcher.Meta().Req == nil {
+			task.fetcher.Meta().Req = task.Meta.Req
+		}
+		if task.fetcher.Meta().Res == nil {
+			task.fetcher.Meta().Res = task.Meta.Res
+		}
 		go d.watch(task)
 	}
 	task.fetcher.Create(task.Meta.Opts)
@@ -568,145 +672,120 @@ func (d *Downloader) doCreate(fetcher fetcher.Fetcher, opts *base.Options) (task
 	func() {
 		d.lock.Lock()
 		defer d.lock.Unlock()
+
 		d.tasks = append(d.tasks, task)
-	}()
-	go d.watch(task)
-	go d.tryRunning(func(remain int) {
-		if remain > 0 {
-			if err = d.start(task); err != nil {
-				d.Logger.Error().Stack().Err(err).Msgf("start task failed, task id: %s", task.ID)
-				return
-			}
-		}
-	})
-	return
-}
 
-func (d *Downloader) tryRunning(cb func(remain int)) {
-	runningCount := 0
-	for _, task := range d.tasks {
-		if task.Status == base.DownloadStatusRunning {
-			runningCount++
-		}
-	}
-	cb(d.cfg.MaxRunning - runningCount)
-}
-
-func (d *Downloader) notifyRunning() error {
-	d.lock.Lock()
-	defer d.lock.Unlock()
-
-	return d.doNotifyRunning()
-}
-
-func (d *Downloader) doNotifyRunning() error {
-	for _, task := range d.tasks {
-		if task.Status == base.DownloadStatusReady || task.Status == base.DownloadStatusWait {
-			return d.doContinue(task)
-		}
-	}
-	return nil
-}
-
-func (d *Downloader) doPauseAll() (err error) {
-	for _, task := range d.tasks {
-		if err = d.doPause(task, base.DownloadStatusPause); err != nil {
+		remainRunningCount := d.remainRunningCount()
+		if remainRunningCount == 0 {
+			task.Status = base.DownloadStatusWait
+			d.waitTasks = append(d.waitTasks, task)
 			return
 		}
-	}
+
+		d.doStart(task)
+	}()
+
+	go d.watch(task)
 	return
 }
 
-func (d *Downloader) start(task *Task) error {
-	task.lock.Lock()
-	defer task.lock.Unlock()
-	isCreate := task.Status == base.DownloadStatusReady
-	task.Status = base.DownloadStatusRunning
-	if task.Meta.Res == nil {
-		err := task.fetcher.Resolve(task.Meta.Req)
+func (d *Downloader) doStart(task *Task) (err error) {
+	if task.Status != base.DownloadStatusRunning && task.Status != base.DownloadStatusDone {
+		err := d.restoreFetcher(task)
 		if err != nil {
-			task.Status = base.DownloadStatusError
-			d.emit(EventKeyError, task, err)
+			d.Logger.Error().Stack().Err(err).Msgf("restore fetcher failed, task id: %s", task.ID)
 			return err
 		}
-		isCreate = true
 	}
 
-	if isCreate {
-		d.lock.Lock()
-		defer d.lock.Unlock()
-		// check if the download file is duplicated and rename it automatically.
-		if task.Meta.Res.Name != "" {
-			fullDirPath := task.Meta.FolderPath()
-			newName, err := util.CheckDuplicateAndRename(fullDirPath)
-			if err != nil {
-				return err
-			}
-			task.Meta.Opts.Name = newName
-		} else {
-			fullFilePath := task.Meta.SingleFilepath()
-			newName, err := util.CheckDuplicateAndRename(fullFilePath)
-			if err != nil {
-				return err
-			}
-			task.Meta.Opts.Name = newName
+	cloneTask := task.clone()
+	isCreate := task.Status == base.DownloadStatusReady
+	task.Status = base.DownloadStatusRunning
+
+	doStart := func() error {
+		task.lock.Lock()
+		defer task.lock.Unlock()
+
+		req := d.triggerOnStart(cloneTask)
+		if req != nil {
+			task.Meta.Req = req
+			task.fetcher.Meta().Req = req
 		}
-	}
-	if err := d.doStart(task); err != nil {
-		task.Status = base.DownloadStatusError
-		d.emit(EventKeyError, task, err)
-		return err
-	}
-	return nil
-}
 
-func (d *Downloader) doStart(task *Task) error {
-	task.Progress.Speed = 0
-	task.timer.Start()
-	if err := d.storage.Put(bucketTask, task.ID, task.clone()); err != nil {
-		return err
-	}
-	if err := task.fetcher.Start(); err != nil {
-		return err
-	}
-	d.emit(EventKeyStart, task)
-	return nil
-}
+		if task.Meta.Res == nil {
+			err := task.fetcher.Resolve(task.Meta.Req)
+			if err != nil {
+				task.Status = base.DownloadStatusError
+				d.emit(EventKeyError, task, err)
+				return err
+			}
+			task.Meta.Res = task.fetcher.Meta().Res
+		}
 
-func (d *Downloader) doPause(task *Task, status base.Status) (err error) {
-	task.lock.Lock()
-	defer task.lock.Unlock()
-	if task.Status != base.DownloadStatusDone {
-		task.Status = status
-		task.timer.Pause()
-		task.fetcher.Pause()
-		d.storage.Put(bucketTask, task.ID, task.clone())
-		d.emit(EventKeyPause, task)
+		if isCreate {
+			d.checkDuplicateLock.Lock()
+			defer d.checkDuplicateLock.Unlock()
+			// check if the download file is duplicated and rename it automatically.
+			if task.Meta.Res.Name != "" {
+				fullDirPath := task.Meta.FolderPath()
+				newName, err := util.CheckDuplicateAndRename(fullDirPath)
+				if err != nil {
+					return err
+				}
+				task.Meta.Opts.Name = newName
+			} else {
+				fullFilePath := task.Meta.SingleFilepath()
+				newName, err := util.CheckDuplicateAndRename(fullFilePath)
+				if err != nil {
+					return err
+				}
+				task.Meta.Opts.Name = newName
+			}
+		}
+
+		task.Progress.Speed = 0
+		task.timer.Start()
+		if err := d.storage.Put(bucketTask, task.ID, task.clone()); err != nil {
+			return err
+		}
+		if err := task.fetcher.Start(); err != nil {
+			return err
+		}
+		d.emit(EventKeyStart, task)
+		return nil
 	}
+	go func() {
+		err := doStart()
+		if err != nil {
+			d.Logger.Error().Stack().Err(err).Msgf("start task failed, task id: %s", task.ID)
+		}
+	}()
+
 	return
 }
 
-func (d *Downloader) doContinue(task *Task) (err error) {
+func (d *Downloader) doPause(task *Task) (err error) {
 	err = func() error {
-		task.lock.Lock()
-		defer task.lock.Unlock()
-		if task.Status != base.DownloadStatusRunning && task.Status != base.DownloadStatusDone {
-			err := d.restoreFetcher(task)
-			if err != nil {
+		if task.Status != base.DownloadStatusDone {
+			task.Status = base.DownloadStatusPause
+			task.timer.Pause()
+			if task.fetcher != nil {
+				if err := task.fetcher.Pause(); err != nil {
+					return err
+				}
+			}
+			if err := d.storage.Put(bucketTask, task.ID, task.clone()); err != nil {
 				return err
 			}
+			d.emit(EventKeyPause, task)
 		}
 		return nil
 	}()
 	if err != nil {
+		d.Logger.Error().Stack().Err(err).Msgf("pause task failed, task id: %s", task.ID)
 		return
 	}
-	go func() {
-		if err := d.start(task); err != nil {
-			d.Logger.Error().Stack().Err(err).Msgf("start task failed, task id: %s", task.ID)
-			return
-		}
-	}()
+
 	return
 }
 

pkg/download/extension.go

@@ -33,6 +33,7 @@ type ActivationEvent string
 
 const (
 	EventOnResolve ActivationEvent = "onResolve"
+	EventOnStart   ActivationEvent = "onStart"
 	//EventOnError   ActivationEvent = "onError"
 	//EventOnDone    ActivationEvent = "onDone"
 )
@@ -47,7 +48,7 @@ func (d *Downloader) InstallExtensionByFolder(path string, devMode bool) (*Exten
 		return nil, err
 	}
 
-	// if dev mode, don't copy the extension to the extensions' directory
+	// if dev mode, don't copy to the extensions' directory
 	if devMode {
 		ext.DevMode = true
 		ext.DevPath, _ = filepath.Abs(path)
@@ -229,23 +230,70 @@ func (d *Downloader) parseExtensionByPath(path string) (*Extension, error) {
 }
 
 func (d *Downloader) triggerOnResolve(req *base.Request) (res *base.Resource) {
+	doTrigger(d,
+		EventOnResolve,
+		req,
+		&OnResolveContext{
+			Req: req,
+		},
+		func(ext *Extension, gopeed *Instance, ctx *OnResolveContext) {
+			// Validate resource structure
+			if ctx.Res != nil && len(ctx.Res.Files) > 0 {
+				if err := ctx.Res.Validate(); err != nil {
+					gopeed.Logger.logger.Warn().Err(err).Msgf("[%s] resource invalid", ext.buildIdentity())
+					return
+				}
+				ctx.Res.CalcSize()
+			}
+			res = ctx.Res
+		},
+	)
+	return
+}
+
+func (d *Downloader) triggerOnStart(task *Task) (req *base.Request) {
+	doTrigger(d,
+		EventOnStart,
+		task.Meta.Req,
+		&OnStartContext{
+			Task: task,
+		},
+		func(ext *Extension, gopeed *Instance, ctx *OnStartContext) {
+			// Validate request structure
+			if ctx.Task.Meta.Req != nil {
+				if err := ctx.Task.Meta.Req.Validate(); err != nil {
+					gopeed.Logger.logger.Warn().Err(err).Msgf("[%s] request invalid", ext.buildIdentity())
+					return
+				}
+				req = ctx.Task.Meta.Req
+			}
+		},
+	)
+	return
+}
+
+func doTrigger[T any](d *Downloader, event ActivationEvent, req *base.Request, ctx T, handler func(ext *Extension, gopeed *Instance, ctx T)) {
 	// init extension global object
 	gopeed := &Instance{
 		Events: make(InstanceEvents),
 	}
-	ctx := &Context{
-		Req: req,
-	}
 	var err error
 	for _, ext := range d.extensions {
 		if ext.Disabled {
 			continue
 		}
 		for _, script := range ext.Scripts {
-			if script.match(EventOnResolve, req.URL) {
+			if script.match(event, req) {
+				gopeed.Info = NewExtensionInfo(ext)
 				gopeed.Logger = newInstanceLogger(ext, d.ExtensionLogger)
+				gopeed.Settings = parseSettings(ext.Settings)
+				gopeed.Storage = &ContextStorage{
+					storage:  d.storage,
+					identity: ext.buildIdentity(),
+				}
 				scriptFilePath := filepath.Join(d.ExtensionPath(ext), script.Entry)
 				if _, err = os.Stat(scriptFilePath); os.IsNotExist(err) {
+					gopeed.Logger.logger.Error().Err(err).Msgf("[%s] script file not exist", ext.buildIdentity())
 					continue
 				}
 				func() {
@@ -256,13 +304,16 @@ func (d *Downloader) triggerOnResolve(req *base.Request) (res *base.Resource) {
 						return
 					}
 					defer scriptFile.Close()
-					ctx.Settings = parseSettings(ext.Settings)
 					var scriptBuf []byte
 					scriptBuf, err = io.ReadAll(scriptFile)
 					if err != nil {
 						gopeed.Logger.logger.Error().Err(err).Msgf("[%s] read script file failed", ext.buildIdentity())
 						return
 					}
+					// Init request labels
+					if req.Labels == nil {
+						req.Labels = make(map[string]string)
+					}
 					engine := engine.NewEngine()
 					defer engine.Close()
 					err = engine.Runtime.Set("gopeed", gopeed)
@@ -275,21 +326,13 @@ func (d *Downloader) triggerOnResolve(req *base.Request) (res *base.Resource) {
 						gopeed.Logger.logger.Error().Err(err).Msgf("[%s] run script failed", ext.buildIdentity())
 						return
 					}
-					if fn, ok := gopeed.Events[EventOnResolve]; ok {
+					if fn, ok := gopeed.Events[event]; ok {
 						_, err = engine.CallFunction(fn, ctx)
 						if err != nil {
-							gopeed.Logger.logger.Error().Err(err).Msgf("[%s] call function failed: %s", EventOnResolve, ext.buildIdentity())
+							gopeed.Logger.logger.Error().Err(err).Msgf("[%s] call function failed: %s", ext.buildIdentity(), event)
 							return
 						}
-						// calculate resource total size
-						if ctx.Res != nil && len(ctx.Res.Files) > 0 {
-							if err = ctx.Res.Validate(); err != nil {
-								gopeed.Logger.logger.Warn().Err(err).Msgf("[%s] resource invalid", ext.buildIdentity())
-								return
-							}
-							ctx.Res.CalcSize()
-						}
-						res = ctx.Res
+						handler(ext, gopeed, ctx)
 					}
 				}()
 			}
@@ -378,8 +421,50 @@ func (e *Extension) update(newExt *Extension) error {
 	e.Homepage = newExt.Homepage
 	e.Repository = newExt.Repository
 	e.Scripts = newExt.Scripts
-	// don't override settings
-	//e.Settings = newExt.Settings
+	// merge settings
+	// if new setting not exist in old settings, append it
+	for _, newSetting := range newExt.Settings {
+		var exist bool
+		for _, setting := range e.Settings {
+			if setting.Name == newSetting.Name {
+				exist = true
+				break
+			}
+		}
+		if !exist {
+			e.Settings = append(e.Settings, newSetting)
+		}
+	}
+	// if old setting not exist in new settings, remove it
+	for i := 0; i < len(e.Settings); i++ {
+		var exist bool
+		for _, setting := range newExt.Settings {
+			if setting.Name == e.Settings[i].Name {
+				exist = true
+				break
+			}
+		}
+		if !exist {
+			e.Settings = append(e.Settings[:i], e.Settings[i+1:]...)
+			i--
+		}
+	}
+	// if new setting exist in old settings, update it
+	for _, newSetting := range newExt.Settings {
+		for _, setting := range e.Settings {
+			if setting.Name == newSetting.Name {
+				setting.Title = newSetting.Title
+				setting.Description = newSetting.Description
+				setting.Options = newSetting.Options
+				// if type changed, reset value
+				if setting.Type != newSetting.Type {
+					setting.Type = newSetting.Type
+					setting.Value = newSetting.Value
+				}
+				break
+			}
+		}
+	}
 	e.UpdatedAt = time.Now()
 	return nil
 }
@@ -392,30 +477,46 @@ type Repository struct {
 type Script struct {
 	// Event active event name
 	Event string `json:"event"`
-	// Matches match request url pattern list
-	Matches []string `json:"matches"`
+	// Match rules
+	Match *Match `json:"match"`
 	// Entry js script file path
 	Entry string `json:"entry"`
 }
 
-func (s *Script) match(event ActivationEvent, url string) bool {
+func (s *Script) match(event ActivationEvent, req *base.Request) bool {
 	if s.Event == "" {
 		return false
 	}
 	if s.Event != string(event) {
 		return false
 	}
-	if len(s.Matches) == 0 {
+	if s.Match == nil || (len(s.Match.Urls) == 0 && len(s.Match.Labels) == 0) {
 		return false
 	}
-	for _, match := range s.Matches {
-		if util.Match(match, url) {
+
+	// match url
+	for _, url := range s.Match.Urls {
+		if util.Match(url, req.URL) {
+			return true
+		}
+	}
+
+	// match label
+	for _, label := range s.Match.Labels {
+		if _, ok := req.Labels[label]; ok {
 			return true
 		}
 	}
 	return false
 }
 
+type Match struct {
+	// Urls match expression, refer to https://developer.chrome.com/docs/extensions/mv3/match_patterns/
+	Urls []string `json:"urls"`
+	// Labels match request labels
+	Labels []string `json:"labels"`
+}
+
 type SettingType string
 
 const (
@@ -442,10 +543,13 @@ type Option struct {
 	Value any    `json:"value"`
 }
 
-// Instance inject to js context
+// Instance inject to js context when extension script is activated
 type Instance struct {
-	Events InstanceEvents  `json:"events"`
-	Logger *InstanceLogger `json:"logger"`
+	Events   InstanceEvents  `json:"events"`
+	Info     *ExtensionInfo  `json:"info"`
+	Logger   *InstanceLogger `json:"logger"`
+	Settings map[string]any  `json:"settings"`
+	Storage  *ContextStorage `json:"storage"`
 }
 
 type InstanceEvents map[ActivationEvent]goja.Callable
@@ -458,6 +562,10 @@ func (h InstanceEvents) OnResolve(fn goja.Callable) {
 	h.register(EventOnResolve, fn)
 }
 
+func (h InstanceEvents) OnStart(fn goja.Callable) {
+	h.register(EventOnStart, fn)
+}
+
 //func (h InstanceEvents) OnError(fn goja.Callable) {
 //	h.register(HookEventOnError, fn)
 //}
@@ -466,6 +574,24 @@ func (h InstanceEvents) OnResolve(fn goja.Callable) {
 //	h.register(HookEventOnDone, fn)
 //}
 
+type ExtensionInfo struct {
+	Identity string `json:"identity"`
+	Name     string `json:"name"`
+	Author   string `json:"author"`
+	Title    string `json:"title"`
+	Version  string `json:"version"`
+}
+
+func NewExtensionInfo(ext *Extension) *ExtensionInfo {
+	return &ExtensionInfo{
+		Identity: ext.buildIdentity(),
+		Name:     ext.Name,
+		Author:   ext.Author,
+		Title:    ext.Title,
+		Version:  ext.Version,
+	}
+}
+
 type InstanceLogger struct {
 	identity string
 	devMode  bool
@@ -506,10 +632,13 @@ func newInstanceLogger(extension *Extension, logger *logger.Logger) *InstanceLog
 	}
 }
 
-type Context struct {
-	Req      *base.Request  `json:"req"`
-	Res      *base.Resource `json:"res"`
-	Settings map[string]any `json:"settings"`
+type OnResolveContext struct {
+	Req *base.Request  `json:"req"`
+	Res *base.Resource `json:"res"`
+}
+
+type OnStartContext struct {
+	Task *Task `json:"task"`
 }
 
 func parseSettings(settings []*Setting) map[string]any {
@@ -547,3 +676,50 @@ func tryParse(val any, settingType SettingType) any {
 		return nil
 	}
 }
+
+type ContextStorage struct {
+	storage  Storage
+	identity string
+}
+
+func (s *ContextStorage) Get(key string) any {
+	raw := s.getRawData()
+	if v, ok := raw[key]; ok {
+		return v
+	}
+	return nil
+}
+
+func (s *ContextStorage) Set(key string, value string) {
+	raw := s.getRawData()
+	raw[key] = value
+	s.storage.Put(bucketExtensionStorage, s.identity, raw)
+}
+
+func (s *ContextStorage) Remove(key string) {
+	raw := s.getRawData()
+	delete(raw, key)
+	s.storage.Put(bucketExtensionStorage, s.identity, raw)
+}
+
+func (s *ContextStorage) Keys() []string {
+	raw := s.getRawData()
+	keys := make([]string, 0)
+	for k := range raw {
+		keys = append(keys, k)
+	}
+	return keys
+}
+
+func (s *ContextStorage) Clear() {
+	s.storage.Delete(bucketExtensionStorage, s.identity)
+}
+
+func (s *ContextStorage) getRawData() map[string]string {
+	var data map[string]string
+	s.storage.Get(bucketExtensionStorage, s.identity, &data)
+	if data == nil {
+		data = make(map[string]string)
+	}
+	return data
+}

pkg/download/extension_test.go

@@ -1,10 +1,12 @@
 package download
 
 import (
+	"errors"
 	"github.com/GopeedLab/gopeed/internal/logger"
 	"github.com/GopeedLab/gopeed/pkg/base"
 	"os"
 	"testing"
+	"time"
 )
 
 func TestDownloader_InstallExtensionByFolder(t *testing.T) {
@@ -93,6 +95,15 @@ func TestDownloader_InstallExtensionByGitFull(t *testing.T) {
 }
 
 func TestDownloader_UpgradeExtension(t *testing.T) {
+	getSetting := func(settings []*Setting, name string) *Setting {
+		for _, setting := range settings {
+			if setting.Name == name {
+				return setting
+			}
+		}
+		return nil
+	}
+
 	setupDownloader(func(downloader *Downloader) {
 		installedExt, err := downloader.InstallExtensionByFolder("./testdata/extensions/update", false)
 		if err != nil {
@@ -120,14 +131,116 @@ func TestDownloader_UpgradeExtension(t *testing.T) {
 			t.Fatal("extension update fail")
 		}
 
+		// check setting update
+		s1 := getSetting(upgradeExt.Settings, "s1")
+		if s1.Title == "S1 old" {
+			t.Fatal("setting update fail")
+		}
+		// check setting type update
+		s2 := getSetting(upgradeExt.Settings, "s2")
+		if s2.Type == "number" {
+			t.Fatal("setting type update fail")
+		}
+		// check setting remove
+		d1 := getSetting(upgradeExt.Settings, "d1")
+		if d1 != nil {
+			t.Fatal("setting remove fail")
+		}
+		// check setting add
+		s3 := getSetting(upgradeExt.Settings, "s3")
+		if s3 == nil {
+			t.Fatal("setting add fail")
+		}
+
 		rr, err := downloader.Resolve(&base.Request{
-			URL: "https://github.com/GopeedLab/gopeed/releases",
+			URL: "https://test.com",
 		})
 		if err != nil {
 			t.Fatal(err)
 		}
-		if len(rr.Res.Files) == 1 {
-			t.Fatal("resolve error")
+		if rr.Res.Name != "test" {
+			t.Fatal("script update fail")
+		}
+	})
+}
+
+func TestDownloader_ExtensionByOnStart(t *testing.T) {
+	downloadAndCheck := func(req *base.Request) {
+		setupDownloader(func(downloader *Downloader) {
+			if _, err := downloader.InstallExtensionByFolder("./testdata/extensions/on_start", false); err != nil {
+				t.Fatal(err)
+			}
+			errCh := make(chan error, 1)
+			downloader.Listener(func(event *Event) {
+				if event.Key == EventKeyFinally {
+					errCh <- event.Err
+				}
+			})
+			id, err := downloader.CreateDirect(req, nil)
+			if err != nil {
+				t.Fatal(err)
+			}
+			select {
+			case err = <-errCh:
+				break
+			case <-time.After(time.Second * 10):
+				err = errors.New("timeout")
+			}
+			if err != nil {
+				panic("extension on start download error: " + err.Error())
+			}
+			task := downloader.GetTask(id)
+			if task.Meta.Req.URL != "https://github.com" {
+				panic("extension on start modify url error")
+			}
+			if task.Meta.Req.Labels["modified"] != "true" {
+				panic("extension on start modify label error")
+			}
+		})
+	}
+
+	// url match
+	downloadAndCheck(&base.Request{
+		URL: "https://github.com/gopeed/test/404",
+	})
+
+	// label match
+	downloadAndCheck(&base.Request{
+		URL: "https://xxx.com",
+		Labels: map[string]string{
+			"test": "true",
+		},
+	})
+}
+
+func TestDownloader_Extension_Errors(t *testing.T) {
+	setupDownloader(func(downloader *Downloader) {
+		if _, err := downloader.InstallExtensionByFolder("./testdata/extensions/script_error", false); err != nil {
+			t.Fatal(err)
+		}
+		rr, err := downloader.Resolve(&base.Request{
+			URL: "https://github.com/test",
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+		if len(rr.Res.Files) == 2 {
+			t.Fatal("script error catch failed")
+		}
+	})
+
+	setupDownloader(func(downloader *Downloader) {
+		if _, err := downloader.InstallExtensionByFolder("./testdata/extensions/function_error", false); err != nil {
+			t.Fatal(err)
+		}
+		rr, err := downloader.Resolve(&base.Request{
+			URL: "https://github.com/test",
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+		if len(rr.Res.Files) == 2 {
+			t.Fatal("function error catch failed")
 		}
 	})
 }
@@ -170,6 +283,23 @@ func TestDownloader_Extension_Settings(t *testing.T) {
 	})
 }
 
+func TestDownloader_ExtensionStorage(t *testing.T) {
+	setupDownloader(func(downloader *Downloader) {
+		if _, err := downloader.InstallExtensionByFolder("./testdata/extensions/storage", false); err != nil {
+			t.Fatal(err)
+		}
+		rr, err := downloader.Resolve(&base.Request{
+			URL: "https://github.com/test",
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+		if len(rr.Res.Files) == 1 {
+			t.Fatal("resolve error")
+		}
+	})
+}
+
 func TestDownloader_SwitchExtension(t *testing.T) {
 	setupDownloader(func(downloader *Downloader) {
 		installedExt, err := downloader.InstallExtensionByFolder("./testdata/extensions/basic", false)

pkg/download/storage.go

@@ -222,6 +222,9 @@ func (b *BoltStorage) Pop(bucket string, key string, v any) error {
 	if err != nil {
 		return err
 	}
+	if len(data) == 0 {
+		return nil
+	}
 	return json.Unmarshal(data, v)
 }
 

pkg/download/testdata/extensions/basic/index.js

@@ -6,6 +6,9 @@ gopeed.events.onResolve(async function (ctx) {
                 size: 1024,
                 req: {
                     url: ctx.req.url + "/" + i,
+                    labels:{
+                        "from": gopeed.info.name,
+                    }
                 }
             }),
         ),

pkg/download/testdata/extensions/basic/manifest.json

@@ -5,9 +5,11 @@
   "scripts": [
     {
       "event": "onResolve",
-      "matches": [
-        "*://github.com/*"
-      ],
+      "match": {
+        "urls": [
+          "*://github.com/*"
+        ]
+      },
       "entry": "index.js"
     }
   ],

pkg/download/testdata/extensions/extra/index.js

@@ -0,0 +1,18 @@
+gopeed.events.onResolve(async function (ctx) {
+    ctx.res = {
+        name: "test",
+        files: Array(2).fill(true).map((_, i) => ({
+                name: `test-${i}.txt`,
+                size: 1024,
+                req: {
+                    url: ctx.req.url + "/" + i,
+                    extra: {
+                        headers: {
+                            'User-Agent': ctx.settings.ua,
+                        },
+                    }
+                }
+            }),
+        ),
+    };
+});

pkg/download/testdata/extensions/extra/manifest.json

@@ -0,0 +1,22 @@
+{
+  "name": "extra",
+  "title": "gopeed extension extra test",
+  "version": "0.0.1",
+  "scripts": [
+    {
+      "event": "onResolve",
+      "matches": [
+        "*://github.com/*"
+      ],
+      "entry": "index.js"
+    }
+  ],
+  "settings": [
+    {
+      "name": "ua",
+      "title": "User-Agent",
+      "type": "string",
+      "value": "gopeed"
+    }
+  ]
+}

pkg/download/testdata/extensions/function_error/index.js

@@ -0,0 +1,16 @@
+gopeed.events.onResolve(async function (ctx) {
+    const aaa = {};
+    gopeed.logger.info(aaa.bbb.ccc);
+
+    ctx.res = {
+        name: "test",
+        files: Array(2).fill(true).map((_, i) => ({
+                name: `test-${i}.txt`,
+                size: 1024,
+                req: {
+                    url: ctx.req.url + "/" + i,
+                }
+            }),
+        ),
+    };
+});

pkg/download/testdata/extensions/function_error/manifest.json

@@ -0,0 +1,23 @@
+{
+  "name": "function-error",
+  "title": "gopeed extension function error test",
+  "version": "0.0.1",
+  "scripts": [
+    {
+      "event": "onResolve",
+      "match": {
+        "urls": [
+          "*://github.com/*"
+        ]
+      },
+      "entry": "index.js"
+    }
+  ],
+  "settings": [
+    {
+      "name": "ua",
+      "title": "User-Agent",
+      "type": "string"
+    }
+  ]
+}

pkg/download/testdata/extensions/on_start/index.js

@@ -0,0 +1,5 @@
+gopeed.events.onStart(async function (ctx) {
+    ctx.task.meta.req.url = "https://github.com";
+    ctx.task.meta.req.labels['modified'] = 'true';
+});
+

pkg/download/testdata/extensions/on_start/manifest.json

@@ -0,0 +1,19 @@
+{
+  "name": "on-start",
+  "title": "gopeed extension on start event test",
+  "version": "0.0.1",
+  "scripts": [
+    {
+      "event": "onStart",
+      "match": {
+        "urls": [
+          "*://github.com/*"
+        ],
+        "labels": [
+          "test"
+        ]
+      },
+      "entry": "index.js"
+    }
+  ]
+}

pkg/download/testdata/extensions/script_error/index.js

@@ -0,0 +1,16 @@
+const aaa = {};
+gopeed.logger.info(aaa.bbb.ccc);
+
+gopeed.events.onResolve(async function (ctx) {
+    ctx.res = {
+        name: "test",
+        files: Array(2).fill(true).map((_, i) => ({
+                name: `test-${i}.txt`,
+                size: 1024,
+                req: {
+                    url: ctx.req.url + "/" + i,
+                }
+            }),
+        ),
+    };
+});

pkg/download/testdata/extensions/script_error/manifest.json

@@ -0,0 +1,23 @@
+{
+  "name": "script-error",
+  "title": "gopeed extension script error test",
+  "version": "0.0.1",
+  "scripts": [
+    {
+      "event": "onResolve",
+      "match": {
+        "urls": [
+          "*://github.com/*"
+        ]
+      },
+      "entry": "index.js"
+    }
+  ],
+  "settings": [
+    {
+      "name": "ua",
+      "title": "User-Agent",
+      "type": "string"
+    }
+  ]
+}

pkg/download/testdata/extensions/settings_all/index.js

@@ -1,31 +1,31 @@
 gopeed.events.onResolve(async function (ctx) {
-    if (ctx.settings.string != null) {
+    if (gopeed.settings.string != null) {
         throw new Error("string is not null");
     }
-    if (ctx.settings.number != null) {
+    if (gopeed.settings.number != null) {
         throw new Error("number is not null");
     }
-    if (ctx.settings.boolean != null) {
+    if (gopeed.settings.boolean != null) {
         throw new Error("boolean is not null");
     }
 
-    if (ctx.settings.stringDefault !== "default") {
+    if (gopeed.settings.stringDefault !== "default") {
         throw new Error("string default value is incorrect");
     }
-    if (ctx.settings.numberDefault !== 1) {
+    if (gopeed.settings.numberDefault !== 1) {
         throw new Error("number default value is incorrect");
     }
-    if (ctx.settings.booleanDefault !== true) {
+    if (gopeed.settings.booleanDefault !== true) {
         throw new Error("boolean default value is incorrect");
     }
 
-    if (ctx.settings.stringValued !== "valued") {
+    if (gopeed.settings.stringValued !== "valued") {
         throw new Error("string value is incorrect");
     }
-    if (ctx.settings.numberValued !== 1.1) {
+    if (gopeed.settings.numberValued !== 1.1) {
         throw new Error("number value is incorrect");
     }
-    if (ctx.settings.booleanValued !== true) {
+    if (gopeed.settings.booleanValued !== true) {
         throw new Error("boolean value is incorrect");
     }
 

pkg/download/testdata/extensions/settings_all/manifest.json

@@ -5,9 +5,11 @@
   "scripts": [
     {
       "event": "onResolve",
-      "matches": [
-        "*://*/*"
-      ],
+      "match": {
+        "urls": [
+          "*://*/*"
+        ]
+      },
       "entry": "index.js"
     }
   ],

pkg/download/testdata/extensions/settings_empty/index.js

@@ -1,5 +1,5 @@
 gopeed.events.onResolve(async function (ctx) {
-    if (Object.keys(ctx.settings).length > 0){
+    if (Object.keys(gopeed.settings).length > 0){
         throw new Error("settings is not empty");
     }
 

pkg/download/testdata/extensions/settings_empty/manifest.json

@@ -5,9 +5,11 @@
   "scripts": [
     {
       "event": "onResolve",
-      "matches": [
-        "*://*/*"
-      ],
+      "match": {
+        "urls": [
+          "*://*/*"
+        ]
+      },
       "entry": "index.js"
     }
   ]

pkg/download/testdata/extensions/storage/index.js

@@ -0,0 +1,49 @@
+gopeed.events.onResolve(async function (ctx) {
+    const key = "key"
+    const value1 = "value1", value2 = JSON.stringify({a: 1, b: "2"})
+
+    if (gopeed.storage.get(key) !== null) {
+        throw new Error("storage get null error")
+    }
+    gopeed.storage.remove(key)
+    if(gopeed.storage.keys().length !== 0) {
+        throw new Error("storage keys null error")
+    }
+
+    gopeed.storage.set(key, value1)
+    if (gopeed.storage.get(key) !== value1) {
+        throw new Error("storage put1 error")
+    }
+
+    gopeed.storage.set(key, value2)
+    if (gopeed.storage.get(key) !== value2) {
+        throw new Error("storage put2 error")
+    }
+
+    if(gopeed.storage.keys().length !== 1) {
+        throw new Error("storage keys error")
+    }
+
+    gopeed.storage.remove(key)
+    if (gopeed.storage.get(key) !== null) {
+        throw new Error("storage delete error")
+    }
+
+    gopeed.storage.set(key, value1)
+    gopeed.storage.clear()
+    if (gopeed.storage.get(key) !== null) {
+        throw new Error("storage clear error")
+    }
+
+    ctx.res = {
+        name: "test",
+        files: Array(2).fill(true).map((_, i) => ({
+                name: `test-${i}.txt`,
+                size: 1024,
+                req: {
+                    url: ctx.req.url + "/" + i,
+                }
+            }),
+        ),
+    };
+});

pkg/download/testdata/extensions/storage/manifest.json

@@ -0,0 +1,23 @@
+{
+  "name": "storage",
+  "title": "gopeed extension storage test",
+  "version": "0.0.1",
+  "scripts": [
+    {
+      "event": "onResolve",
+      "match": {
+        "urls": [
+          "*://*/*"
+        ]
+      },
+      "entry": "index.js"
+    }
+  ],
+  "settings": [
+    {
+      "name": "ua",
+      "title": "User-Agent",
+      "type": "string"
+    }
+  ]
+}

pkg/download/testdata/extensions/update/manifest.json

@@ -1,21 +1,47 @@
 {
-  "name": "github-release",
+  "name": "extension-test",
   "author": "gopeed",
-  "title": "Github Release",
-  "description": "Download github release assets",
+  "title": "Gopeed Extension Test",
+  "description": "Test extension settings and upgrade",
   "version": "0.0.1",
   "homepage": "https://gopeed.com",
   "repository": {
     "url": "https://github.com/GopeedLab/gopeed-extension-samples",
-    "directory": "github-release-sample"
+    "directory": "extension-test"
   },
   "scripts": [
     {
       "event": "onResolve",
-      "matches": [
-        "*://github.com/*/releases/*"
-      ],
+      "match": {
+        "urls": [
+          "*://*/*"
+        ]
+      },
       "entry": "index.js"
     }
+  ],
+  "settings": [
+    {
+      "name": "s1",
+      "title": "S1 old",
+      "description": "Test setting update",
+      "type": "string",
+      "required": true
+    },
+    {
+      "name": "s2",
+      "title": "s2 number old",
+      "description": "Test setting type update",
+      "type": "number",
+      "required": true,
+      "value": 1
+    },
+    {
+      "name": "d1",
+      "title": "Delete test",
+      "description": "Test setting delete",
+      "type": "string",
+      "required": true
+    }
   ]
 }

pkg/rest/server_test.go

@@ -204,19 +204,16 @@ func TestPauseAllAndContinueALLTasks(t *testing.T) {
 
 		// continue all
 		httpRequestCheckOk[any](http.MethodPut, "/api/v1/tasks/continue", nil)
-		time.Sleep(time.Millisecond * 100)
 		tasks := httpRequestCheckOk[[]*download.Task](http.MethodGet, fmt.Sprintf("/api/v1/tasks?status=%s", base.DownloadStatusRunning), nil)
 		if len(tasks) != cfg.MaxRunning {
 			t.Errorf("ContinueAllTasks() got = %v, want %v", len(tasks), cfg.MaxRunning)
 		}
 		// pause all
 		httpRequestCheckOk[any](http.MethodPut, "/api/v1/tasks/pause", nil)
-		time.Sleep(time.Millisecond * 500)
 		tasks = httpRequestCheckOk[[]*download.Task](http.MethodGet, fmt.Sprintf("/api/v1/tasks?status=%s", base.DownloadStatusPause), nil)
 		if len(tasks) != total {
 			t.Errorf("PauseAllTasks() got = %v, want %v", len(tasks), total)
 		}
-
 	})
 }
 

ui/flutter/assets/locales/en_US.json

@@ -65,6 +65,9 @@
   "extensionInstallSuccess": "Installed successfully",
   "extensionUpdateSuccess": "Updated successfully",
   "extensionDelete": "Delete Extension",
-  "extensionAlreadyLatest": "It's already the latest version"
+  "extensionAlreadyLatest": "It's already the latest version",
+  "history": "History",
+  "clearHistory": "Clear History",
+  "noHistoryFound": "No History Found"
 }
 

ui/flutter/assets/locales/zh_CN.json

@@ -65,5 +65,8 @@
   "extensionInstallSuccess": "安装成功",
   "extensionUpdateSuccess": "更新成功",
   "extensionDelete": "删除扩展",
-  "extensionAlreadyLatest": "已经是最新版本"
-}
+  "extensionAlreadyLatest": "已经是最新版本",
+  "history": "历史记录",
+  "clearHistory": "清空历史记录",
+  "noHistoryFound": "暂无历史记录"
+}

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

@@ -16,6 +16,7 @@ class Extension {
   List<Setting>? settings;
   bool disabled;
   bool devMode;
+  String devPath;
 
   Extension({
     required this.identity,
@@ -29,6 +30,7 @@ class Extension {
     required this.repository,
     required this.disabled,
     required this.devMode,
+    required this.devPath,
   });
 
   factory Extension.fromJson(Map<String, dynamic> json) =>

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

@@ -20,6 +20,7 @@ Extension _$ExtensionFromJson(Map<String, dynamic> json) => Extension(
           : Repository.fromJson(json['repository'] as Map<String, dynamic>),
       disabled: json['disabled'] as bool,
       devMode: json['devMode'] as bool,
+      devPath: json['devPath'] as String,
     )..settings = (json['settings'] as List<dynamic>?)
         ?.map((e) => Setting.fromJson(e as Map<String, dynamic>))
         .toList();
@@ -46,6 +47,7 @@ Map<String, dynamic> _$ExtensionToJson(Extension instance) {
   writeNotNull('settings', instance.settings?.map((e) => e.toJson()).toList());
   val['disabled'] = instance.disabled;
   val['devMode'] = instance.devMode;
+  val['devPath'] = instance.devPath;
   return val;
 }
 

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

@@ -6,10 +6,12 @@ part 'request.g.dart';
 class Request {
   String url;
   Object? extra;
+  Map<String, String>? labels = {};
 
   Request({
     required this.url,
     this.extra,
+    this.labels,
   });
 
   factory Request.fromJson(Map<String, dynamic> json) =>

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

@@ -9,6 +9,9 @@ part of 'request.dart';
 Request _$RequestFromJson(Map<String, dynamic> json) => Request(
       url: json['url'] as String,
       extra: json['extra'],
+      labels: (json['labels'] as Map<String, dynamic>?)?.map(
+        (k, e) => MapEntry(k, e as String),
+      ),
     );
 
 Map<String, dynamic> _$RequestToJson(Request instance) {
@@ -23,6 +26,7 @@ Map<String, dynamic> _$RequestToJson(Request instance) {
   }
 
   writeNotNull('extra', instance.extra);
+  writeNotNull('labels', instance.labels);
   return val;
 }
 

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

@@ -202,6 +202,10 @@ class AppController extends GetxController with WindowListener, TrayListener {
         onClick: (menuItem) => {windowManager.destroy()},
       ),
     ]);
+    if (!Util.isLinux()) {
+      // Linux seems not support setToolTip, refer to: https://github.com/GopeedLab/gopeed/issues/241
+      await trayManager.setToolTip('Gopeed');
+    }
     await trayManager.setContextMenu(menu);
     trayManager.addListener(this);
   }

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

@@ -4,10 +4,10 @@ import 'package:file_picker/file_picker.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter/services.dart';
 import 'package:get/get.dart';
+import 'package:gopeed/app/modules/history/controller/history_controller.dart';
+import 'package:gopeed/app/modules/history/views/history_view.dart';
 import 'package:path/path.dart' as path;
-
 import 'package:rounded_loading_button/rounded_loading_button.dart';
-
 import '../../../../api/api.dart';
 import '../../../../api/model/create_task.dart';
 import '../../../../api/model/options.dart';
@@ -32,6 +32,7 @@ class CreateView extends GetView<CreateController> {
   final _httpCookieController = TextEditingController();
   final _httpRefererController = TextEditingController();
   final _btTrackerController = TextEditingController();
+  final _historyController = HistoryController();
 
   final _availableSchemes = ["http:", "https:", "magnet:"];
 
@@ -91,121 +92,200 @@ class CreateView extends GetView<CreateController> {
             FocusScope.of(context).requestFocus(FocusNode());
           },
           child: Padding(
-              padding:
-                  const EdgeInsets.symmetric(vertical: 16.0, horizontal: 24.0),
-              child: Form(
-                  key: _resolveFormKey,
-                  autovalidateMode: AutovalidateMode.onUserInteraction,
-                  child: Column(children: [
-                    Row(children: [
-                      Expanded(
-                        child: TextFormField(
-                          autofocus: true,
-                          controller: _urlController,
-                          minLines: 1,
-                          maxLines: 5,
-                          decoration: InputDecoration(
-                            hintText: _hitText(),
-                            hintStyle: const TextStyle(fontSize: 12),
-                            labelText: 'downloadLink'.tr,
-                            icon: const Icon(Icons.link),
-                            suffixIcon: IconButton(
-                              onPressed: () {
-                                _urlController.clear();
-                                controller.clearFileDataUri();
-                              },
-                              icon: const Icon(Icons.clear),
-                            ),
+            padding:
+                const EdgeInsets.symmetric(vertical: 16.0, horizontal: 24.0),
+            child: Form(
+              key: _resolveFormKey,
+              autovalidateMode: AutovalidateMode.onUserInteraction,
+              child: Column(
+                children: [
+                  Row(children: [
+                    Expanded(
+                      child: TextFormField(
+                        autofocus: true,
+                        controller: _urlController,
+                        minLines: 1,
+                        maxLines: 5,
+                        decoration: InputDecoration(
+                          hintText: _hitText(),
+                          hintStyle: const TextStyle(fontSize: 12),
+                          labelText: 'downloadLink'.tr,
+                          icon: const Icon(Icons.link),
+                          suffixIcon: IconButton(
+                            onPressed: () {
+                              _urlController.clear();
+                              controller.clearFileDataUri();
+                            },
+                            icon: const Icon(Icons.clear),
                           ),
-                          validator: (v) {
-                            return v!.trim().isNotEmpty
-                                ? null
-                                : 'downloadLinkValid'.tr;
-                          },
-                          onChanged: (v) async {
-                            controller.clearFileDataUri();
-                            if (controller.oldUrl.value.isEmpty) {
-                              recognizeMagnetUri(v);
-                            }
-                            controller.oldUrl.value = v;
-                          },
+                        ),
+                        validator: (v) {
+                          return v!.trim().isNotEmpty
+                              ? null
+                              : 'downloadLinkValid'.tr;
+                        },
+                        onChanged: (v) async {
+                          controller.clearFileDataUri();
+                          if (controller.oldUrl.value.isEmpty) {
+                            recognizeMagnetUri(v);
+                          }
+                          controller.oldUrl.value = v;
+                        },
+                      ),
+                    ),
+                    IconButton(
+                      icon: const Icon(Icons.folder_open),
+                      onPressed: () async {
+                        var pr = await FilePicker.platform.pickFiles(
+                            type: FileType.custom,
+                            allowedExtensions: ["torrent"]);
+                        if (pr != null) {
+                          if (!Util.isWeb()) {
+                            _urlController.text = pr.files[0].path ?? "";
+                            return;
+                          }
+                          _urlController.text = pr.files[0].name;
+                          controller.setFileDataUri(pr.files[0].bytes!);
+                        }
+                      },
+                    ),
+                    IconButton(
+                      icon: const Icon(Icons.history_rounded),
+                      onPressed: () async {
+                        List<String> resultOfHistories =
+                            await _historyController.getAllHistory();
+                        // reversing: display last entered history first
+                        List<String> reverseResultOfHistories =
+                            resultOfHistories.reversed.toList();
+                        // show dialog box to list history
+                        if (context.mounted) {
+                          showGeneralDialog(
+                            barrierColor: Colors.black.withOpacity(0.5),
+                            transitionBuilder: (context, a1, a2, widget) {
+                              return Transform.scale(
+                                scale: a1.value,
+                                child: Opacity(
+                                  opacity: a1.value,
+                                  child: HistoryView(
+                                    isHistoryListEmpty:
+                                        reverseResultOfHistories.isEmpty,
+                                    historyList: ListView.builder(
+                                      itemCount: reverseResultOfHistories.length,
+                                      itemBuilder: (context, index) {
+                                        return GestureDetector(
+                                          onTap: () {
+                                            _urlController.text =
+                                                reverseResultOfHistories[index];
+                                            Navigator.pop(context);
+                                          },
+                                          child: MouseRegion(
+                                            cursor: SystemMouseCursors.click,
+                                            child: Container(
+                                              padding:
+                                                  const EdgeInsets.symmetric(
+                                                horizontal: 8.0,
+                                                vertical: 8.0,
+                                              ),
+                                              margin:
+                                                  const EdgeInsets.symmetric(
+                                                horizontal: 10.0,
+                                                vertical: 8.0,
+                                              ),
+                                              decoration: BoxDecoration(
+                                                color: Theme.of(context)
+                                                    .colorScheme
+                                                    .background,
+                                                borderRadius:
+                                                    BorderRadius.circular(10.0),
+                                              ),
+                                              child: Text(
+                                                reverseResultOfHistories[index]
+                                                    .toString(),
+                                              ),
+                                            ),
+                                          ),
+                                        );
+                                      },
+                                    ),
+                                  ),
+                                ),
+                              );
+                            },
+                            transitionDuration:
+                                const Duration(milliseconds: 250),
+                            barrierDismissible: true,
+                            barrierLabel: '',
+                            context: context,
+                            pageBuilder: (context, animation1, animation2) {
+                              return const Text('PAGE BUILDER');
+                            },
+                          );
+                        }
+                      },
+                    ),
+                  ]
+                      //.where((e) => e != null).map((e) => e!).toList(),
+                      ),
+                  Obx(
+                    () => Visibility(
+                      visible: controller.showAdvanced.value,
+                      child: Padding(
+                        padding: const EdgeInsets.only(left: 40, top: 15),
+                        child: Column(
+                          children: [
+                            TabBar(
+                              controller: controller.advancedTabController,
+                              tabs: const [
+                                Tab(
+                                  text: 'HTTP',
+                                ),
+                                Tab(
+                                  text: 'BitTorrent',
+                                )
+                              ],
+                            ),
+                            AutoScaleTabBarView(
+                              controller: controller.advancedTabController,
+                              children: [
+                                Column(
+                                  children: [
+                                    TextFormField(
+                                        controller: _httpUaController,
+                                        decoration: const InputDecoration(
+                                          labelText: 'User-Agent',
+                                        )),
+                                    TextFormField(
+                                        controller: _httpCookieController,
+                                        decoration: const InputDecoration(
+                                          labelText: 'Cookie',
+                                        )),
+                                    TextFormField(
+                                        controller: _httpRefererController,
+                                        decoration: const InputDecoration(
+                                          labelText: 'Referer',
+                                        )),
+                                  ],
+                                ),
+                                Column(
+                                  children: [
+                                    TextFormField(
+                                        controller: _btTrackerController,
+                                        maxLines: 5,
+                                        decoration: InputDecoration(
+                                          labelText: 'Trakers',
+                                          hintText: 'addTrackerHit'.tr,
+                                        )),
+                                  ],
+                                )
+                              ],
+                            )
+                          ],
                         ),
                       ),
-                      IconButton(
-                          icon: const Icon(Icons.folder_open),
-                          onPressed: () async {
-                            var pr = await FilePicker.platform.pickFiles(
-                                type: FileType.custom,
-                                allowedExtensions: ["torrent"]);
-                            if (pr != null) {
-                              if (!Util.isWeb()) {
-                                _urlController.text = pr.files[0].path ?? "";
-                                return;
-                              }
-                              _urlController.text = pr.files[0].name;
-                              controller.setFileDataUri(pr.files[0].bytes!);
-                            }
-                          }),
-                    ]
-                        //.where((e) => e != null).map((e) => e!).toList(),
-                        ),
-                    Obx(() => Visibility(
-                        visible: controller.showAdvanced.value,
-                        child: Padding(
-                          padding: const EdgeInsets.only(left: 40, top: 15),
-                          child: Column(
-                            children: [
-                              TabBar(
-                                controller: controller.advancedTabController,
-                                tabs: const [
-                                  Tab(
-                                    text: 'HTTP',
-                                  ),
-                                  Tab(
-                                    text: 'BitTorrent',
-                                  )
-                                ],
-                              ),
-                              AutoScaleTabBarView(
-                                controller: controller.advancedTabController,
-                                children: [
-                                  Column(
-                                    children: [
-                                      TextFormField(
-                                          controller: _httpUaController,
-                                          decoration: const InputDecoration(
-                                            labelText: 'User-Agent',
-                                          )),
-                                      TextFormField(
-                                          controller: _httpCookieController,
-                                          decoration: const InputDecoration(
-                                            labelText: 'Cookie',
-                                          )),
-                                      TextFormField(
-                                          controller: _httpRefererController,
-                                          decoration: const InputDecoration(
-                                            labelText: 'Referer',
-                                          )),
-                                    ],
-                                  ),
-                                  Column(
-                                    children: [
-                                      TextFormField(
-                                          controller: _btTrackerController,
-                                          maxLines: 5,
-                                          decoration: InputDecoration(
-                                            labelText: 'Trakers',
-                                            hintText: 'addTrackerHit'.tr,
-                                          )),
-                                    ],
-                                  )
-                                ],
-                              )
-                            ],
-                          ),
-                        ))),
-                    Center(
-                        child: Padding(
+                    ),
+                  ),
+                  Center(
+                    child: Padding(
                       padding: const EdgeInsets.only(top: 15),
                       child: Column(
                         children: [
@@ -241,8 +321,12 @@ class CreateView extends GetView<CreateController> {
                           ),
                         ],
                       ),
-                    )),
-                  ]))),
+                    ),
+                  ),
+                ],
+              ),
+            ),
+          ),
         ),
       ),
     );
@@ -273,9 +357,9 @@ class CreateView extends GetView<CreateController> {
         // check if is multi line urls
         final urls = Util.textToLines(_urlController.text);
         ResolveResult rr;
-        bool isMuiltiLine = false;
+        bool isMultiLine = false;
         if (urls.length > 1) {
-          isMuiltiLine = true;
+          isMultiLine = true;
           rr = ResolveResult(
               res: Resource(
                   files: urls
@@ -287,12 +371,14 @@ class CreateView extends GetView<CreateController> {
           final submitUrl = Util.isWeb() && controller.fileDataUri.isNotEmpty
               ? controller.fileDataUri.value
               : _urlController.text;
+          // add final submitUrl to the history
+          _historyController.addHistory(submitUrl);
           rr = await resolve(Request(
             url: submitUrl,
             extra: parseReqExtra(_urlController.text),
           ));
         }
-        await _showResolveDialog(rr, isMuiltiLine);
+        await _showResolveDialog(rr, isMultiLine);
       }
     } catch (e) {
       showErrorMessage(e);

ui/flutter/lib/app/modules/extension/views/extension_view.dart

@@ -21,6 +21,7 @@ import '../../../../api/model/install_extension.dart';
 import '../../../../api/model/switch_extension.dart';
 import '../../../../util/util.dart';
 import '../../../views/icon_button_loading.dart';
+import '../../../views/responsive_builder.dart';
 import '../controllers/extension_controller.dart';
 
 class ExtensionView extends GetView<ExtensionController> {
@@ -96,7 +97,7 @@ class ExtensionView extends GetView<ExtensionController> {
                     itemBuilder: (context, index) {
                       final extension = controller.extensions[index];
                       return SizedBox(
-                        height: 112,
+                        height: ResponsiveBuilder.isNarrow(context) ? 152 : 112,
                         child: Card(
                           elevation: 4.0,
                           child: Column(
@@ -110,14 +111,22 @@ class ExtensionView extends GetView<ExtensionController> {
                                           height: 48,
                                         )
                                       : Util.isWeb()
-                                          ? Image.network(join(
-                                              '/fs/extensions/${extension.identity}/${extension.icon}'))
+                                          ? Image.network(
+                                              join(
+                                                  '/fs/extensions/${extension.identity}/${extension.icon}'),
+                                              width: 48,
+                                              height: 48,
+                                            )
                                           : Image.file(
-                                              File(path.join(
-                                                  Util.getStorageDir(),
-                                                  "extensions",
-                                                  extension.identity,
-                                                  extension.icon)),
+                                              extension.devMode
+                                                  ? File(path.join(
+                                                      extension.devPath,
+                                                      extension.icon))
+                                                  : File(path.join(
+                                                      Util.getStorageDir(),
+                                                      "extensions",
+                                                      extension.identity,
+                                                      extension.icon)),
                                               width: 48,
                                               height: 48,
                                             ),
@@ -137,23 +146,35 @@ class ExtensionView extends GetView<ExtensionController> {
                                   title: Row(
                                     children: () {
                                       final list = [
-                                        Text(extension.title),
+                                        ResponsiveBuilder.isNarrow(context)
+                                            ? Expanded(
+                                                child: Text(
+                                                  extension.title,
+                                                  overflow:
+                                                      TextOverflow.ellipsis,
+                                                ),
+                                              )
+                                            : Text(extension.title),
                                         const SizedBox(width: 8),
-                                        Chip(
-                                          label: Text('v${extension.version}'),
-                                        )
+                                        buildChip('v${extension.version}'),
                                       ];
                                       if (extension.devMode) {
                                         list.add(const SizedBox(width: 8));
-                                        list.add(Chip(
-                                          label: Text('dev'.tr),
-                                          backgroundColor: Colors.redAccent,
+                                        list.add(buildChip(
+                                          'dev',
+                                          bgColor: Colors.blue.shade300,
                                         ));
                                       }
                                       return list;
                                     }(),
                                   ),
-                                  subtitle: Text(extension.description),
+                                  subtitle: ResponsiveBuilder.isNarrow(context)
+                                      ? Text(
+                                          extension.description,
+                                          maxLines: 2,
+                                          overflow: TextOverflow.ellipsis,
+                                        )
+                                      : Text(extension.description),
                                 ),
                               ),
                               Row(
@@ -225,6 +246,14 @@ class ExtensionView extends GetView<ExtensionController> {
     );
   }
 
+  Widget buildChip(String text, {Color? bgColor}) {
+    return Chip(
+      padding: const EdgeInsets.all(0),
+      backgroundColor: bgColor,
+      label: Text(text, style: const TextStyle(fontSize: 12)),
+    );
+  }
+
   Future<void> _showSettingDialog(Extension extension) async {
     final formKey = GlobalKey<FormBuilderState>();
     final confrimController = RoundedLoadingButtonController();
@@ -248,9 +277,32 @@ class ExtensionView extends GetView<ExtensionController> {
                       Expanded(
                         child: SingleChildScrollView(
                           child: Column(
-                              children: extension.settings!
-                                  .map((e) => _buildSettingItem(e))
-                                  .toList()),
+                              children: extension.settings!.map((e) {
+                            final settingItem = _buildSettingItem(e);
+
+                            return Row(
+                              crossAxisAlignment: CrossAxisAlignment.end,
+                              children: [
+                                SizedBox(
+                                        width: 20,
+                                        child: e.description.isEmpty
+                                            ? null
+                                            : Tooltip(
+                                                message: e.description,
+                                                child: const CircleAvatar(
+                                                    radius: 10,
+                                                    backgroundColor:
+                                                        Colors.grey,
+                                                    child: Icon(
+                                                      Icons.question_mark,
+                                                      size: 10,
+                                                    )),
+                                              ))
+                                    .paddingOnly(right: 10),
+                                Expanded(child: settingItem),
+                              ],
+                            );
+                          }).toList()),
                         ),
                       ),
                     ]),
@@ -316,8 +368,7 @@ class ExtensionView extends GetView<ExtensionController> {
         FormFieldValidator<String>? validator, TextInputType? keyBoardType) {
       return FormBuilderTextField(
         name: setting.name,
-        decoration: InputDecoration(
-            labelText: setting.title, hintText: setting.description),
+        decoration: InputDecoration(labelText: setting.title),
         initialValue: setting.value?.toString(),
         inputFormatters: inputFormatter != null ? [inputFormatter] : null,
         keyboardType: keyBoardType,
@@ -332,7 +383,8 @@ class ExtensionView extends GetView<ExtensionController> {
       return FormBuilderDropdown<String>(
         name: setting.name,
         decoration: InputDecoration(
-            labelText: setting.title, hintText: setting.description),
+          labelText: setting.title,
+        ),
         initialValue: setting.value?.toString(),
         validator: FormBuilderValidators.compose([
           requiredValidator,

ui/flutter/lib/app/modules/history/controller/history_controller.dart

@@ -0,0 +1,26 @@
+import 'package:shared_preferences/shared_preferences.dart';
+
+class HistoryController {
+  // Get History in List<String>
+  Future<List<String>> getAllHistory() async {
+    SharedPreferences preferences = await SharedPreferences.getInstance();
+    List<String>? historyList = preferences.getStringList('history');
+    if(historyList == null) {
+      return [];
+    }
+    return historyList;
+  }
+
+  // Get Existing History & Add New History
+  void addHistory(String historyText) async {
+    SharedPreferences preferences = await SharedPreferences.getInstance();
+    List<String> existingHistoryData = await getAllHistory();
+    existingHistoryData.add(historyText);
+    preferences.setStringList('history', existingHistoryData);
+  }
+
+  void clearHistory() async {
+    SharedPreferences preferences = await SharedPreferences.getInstance();
+    preferences.remove('history');
+  }
+}

ui/flutter/lib/app/modules/history/views/history_view.dart

@@ -0,0 +1,111 @@
+import 'package:flutter/material.dart';
+import 'package:get/get.dart';
+import 'package:gopeed/app/modules/history/controller/history_controller.dart';
+
+class HistoryView extends StatefulWidget {
+  const HistoryView({
+    super.key,
+    required this.isHistoryListEmpty,
+    required this.historyList,
+  });
+
+  final bool isHistoryListEmpty;
+  final Widget historyList;
+
+  @override
+  State<HistoryView> createState() => _HistoryViewState();
+}
+
+class _HistoryViewState extends State<HistoryView> {
+  @override
+  Widget build(BuildContext context) {
+    final Size size = MediaQuery.sizeOf(context);
+    return Scaffold(
+      backgroundColor: Colors.transparent,
+      body: Dialog(
+        shape: RoundedRectangleBorder(borderRadius: BorderRadius.circular(16)),
+        elevation: 0,
+        backgroundColor: Colors.transparent,
+        child: Container(
+          width: size.width * 0.8,
+          height: size.height * 0.8,
+          decoration: BoxDecoration(
+            color: Theme.of(context).colorScheme.surface,
+            borderRadius: BorderRadius.circular(10.0),
+          ),
+          child: Column(
+            children: <Widget>[
+              Padding(
+                padding: const EdgeInsets.all(8.0),
+                child: Row(
+                  mainAxisAlignment: MainAxisAlignment.spaceBetween,
+                  crossAxisAlignment: CrossAxisAlignment.center,
+                  children: <Widget>[
+                    Row(
+                      mainAxisAlignment: MainAxisAlignment.start,
+                      children: <Widget>[
+                        Icon(
+                          Icons.history_rounded,
+                          size: Theme.of(context)
+                              .textTheme
+                              .headlineSmall
+                              ?.fontSize,
+                        ),
+                        const SizedBox(width: 8.0),
+                        Text(
+                          'history'.tr,
+                          style: Theme.of(context).textTheme.headlineSmall,
+                        ),
+                      ],
+                    ),
+                    Row(
+                      children: <Widget>[
+                        IconButton(
+                          onPressed: () {
+                            HistoryController _controller = HistoryController();
+                            _controller.clearHistory();
+                            Navigator.pop(context);
+                          },
+                          tooltip: "clearHistory".tr,
+                          icon: const Icon(
+                            Icons.history_toggle_off_rounded,
+                          ),
+                        ),
+                        IconButton(
+                          onPressed: () => Navigator.pop(context),
+                          icon: const Icon(
+                            Icons.close_rounded,
+                          ),
+                        ),
+                      ],
+                    ),
+                  ],
+                ),
+              ),
+              Expanded(
+                child: Center(
+                  child: Column(
+                    mainAxisAlignment: MainAxisAlignment.center,
+                    children: widget.isHistoryListEmpty
+                        ? <Widget>[
+                            const Icon(
+                              Icons.manage_history_rounded,
+                            ),
+                            const SizedBox(height: 10.0),
+                            Text(
+                              'noHistoryFound'.tr,
+                            ),
+                          ]
+                        : <Widget>[
+                            Expanded(child: widget.historyList),
+                          ],
+                  ),
+                ),
+              ),
+            ],
+          ),
+        ),
+      ),
+    );
+  }
+}

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

@@ -12,6 +12,12 @@ class FileItem {
   FileItem(this.isDirectory, this.path, this.name, this.size);
 
   String get fullPath => "${path == "/" ? path : "$path/"}$name";
+
+  String filePath(String optName) {
+    return optName.isEmpty
+        ? fullPath
+        : "${path == "/" ? path : "$path/"}$optName";
+  }
 }
 
 class TaskFilesController extends GetxController {

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

@@ -1,6 +1,7 @@
 import 'package:flutter/material.dart';
 import 'package:get/get.dart';
 import 'package:open_file/open_file.dart';
+import 'package:path/path.dart';
 import 'package:share_plus/share_plus.dart';
 
 import '../../../../util/file_icon.dart';
@@ -52,13 +53,17 @@ class TaskFilesView extends GetView<TaskFilesController> {
                   itemBuilder: (context, index) {
                     final meta = controller.task.value!.meta;
                     final file = fileList[index];
-                    final filePath = Util.safePathJoin(
-                        [meta.opts.path, meta.res!.name, file.fullPath]);
+                    final filePath = Util.safePathJoin([
+                      meta.opts.path,
+                      meta.res!.name,
+                      file.filePath(meta.opts.name)
+                    ]);
+                    final fileName = basename(filePath);
                     return ListTile(
                       leading: file.isDirectory
                           ? const Icon(Icons.folder)
                           : Icon(FaIcons.allIcons[findIcon(file.name)]),
-                      title: Text(fileList[index].name),
+                      title: Text(fileName),
                       subtitle: file.isDirectory
                           ? Text('items'.trParams({
                               'count': controller

ui/flutter/lib/generated/locales.g.dart

@@ -82,6 +82,9 @@ class LocaleKeys {
   static const extensionUpdateSuccess = 'extensionUpdateSuccess';
   static const extensionDelete = 'extensionDelete';
   static const extensionAlreadyLatest = 'extensionAlreadyLatest';
+  static const history = 'history';
+  static const clearHistory = 'clearHistory';
+  static const noHistoryFound = 'noHistoryFound';
 }
 
 class Locales {
@@ -155,6 +158,9 @@ class Locales {
     'extensionUpdateSuccess': 'Updated successfully',
     'extensionDelete': 'Delete Extension',
     'extensionAlreadyLatest': 'It\'s already the latest version',
+    'history': 'History',
+    'clearHistory': 'Clear History',
+    'noHistoryFound': 'No History Found',
   };
   static const fa_IR = {
     'label': 'فارسی',
@@ -407,6 +413,9 @@ class Locales {
     'extensionUpdateSuccess': '更新成功',
     'extensionDelete': '删除扩展',
     'extensionAlreadyLatest': '已经是最新版本',
+    'history': '历史记录',
+    'clearHistory': '清空历史记录',
+    'noHistoryFound': '没有历史记录',
   };
   static const zh_TW = {
     'label': '中文 (正體) ',

ui/flutter/lib/util/util.dart

@@ -29,6 +29,7 @@ class Util {
 
   static String safePathJoin(List<String> paths) {
     return paths
+        .where((e) => e.isNotEmpty)
         .map((e) => safeDir(e))
         .join("/")
         .replaceAll(RegExp(r'//'), "/");
@@ -93,6 +94,10 @@ class Util {
     return !kIsWeb && Platform.isMacOS;
   }
 
+  static isLinux() {
+    return !kIsWeb && Platform.isLinux;
+  }
+
   static isWeb() {
     return kIsWeb;
   }

ui/flutter/pubspec.yaml

@@ -15,7 +15,7 @@ publish_to: "none" # Remove this line if you wish to publish to pub.dev
 # In iOS, build-name is used as CFBundleShortVersionString while build-number used as CFBundleVersion.
 # Read more about iOS versioning at
 # https://developer.apple.com/library/archive/documentation/General/Reference/InfoPlistKeyReference/Articles/CoreFoundationKeys.html
-version: 1.4.0+1
+version: 1.4.3+1
 
 environment:
   sdk: '>=3.0.0 <4.0.0'
@@ -41,7 +41,7 @@ dependencies:
   context_menus: ^1.0.2
   json_annotation: ^4.8.1
   dio: ^5.2.1
-  path_provider: ^2.0.11
+  path_provider: ^2.1.1
   file_picker: 5.3.1
   macos_secure_bookmarks: ^0.2.1
   rounded_loading_button: ^2.1.0