fix(ui): show BT restart notice after settings change

internal/protocol/http/fetcher.go

@@ -418,16 +418,6 @@ func (f *Fetcher) updateMaxConnTime(d time.Duration) {
 }
 
 func (f *Fetcher) Resolve(req *base.Request) error {
-	return f.ResolveContext(context.Background(), req)
-}
-
-// ResolveContext cancels the initial request while waiting for headers. Once
-// Resolve has returned, the retained response belongs to the fetcher and its
-// existing Pause/Close lifecycle controls the body and prefetch.
-func (f *Fetcher) ResolveContext(ctx context.Context, req *base.Request) error {
-	if err := ctx.Err(); err != nil {
-		return err
-	}
 	if err := base.ParseReqExtra[fhttp.ReqExtra](req); err != nil {
 		return err
 	}
@@ -439,8 +429,6 @@ func (f *Fetcher) ResolveContext(ctx context.Context, req *base.Request) error {
 	// This allows the response to be reused for downloading (important for one-time URLs)
 	// The body outlives Resolve, so the read timeout gets its own cancel func.
 	reqCtx, reqCancel := context.WithCancel(context.Background())
-	stopCancel := context.AfterFunc(ctx, reqCancel)
-	defer stopCancel()
 	httpReq, err := f.buildRequest(reqCtx, req)
 	if err != nil {
 		reqCancel()

pkg/api/resolve_release_test.go

@@ -1,36 +0,0 @@
-package api
-
-import (
-	"net/http"
-	"path/filepath"
-	"testing"
-
-	"github.com/GopeedLab/gopeed/pkg/base"
-	"github.com/GopeedLab/gopeed/pkg/download"
-	restmodel "github.com/GopeedLab/gopeed/pkg/rest/model"
-)
-
-func TestCancelledTorrentPreviewCanBeResolvedAgain(t *testing.T) {
-	d := download.NewDownloader(&download.DownloaderConfig{StorageDir: t.TempDir(), TempDir: t.TempDir()})
-	if err := d.Setup(); err != nil {
-		t.Fatal(err)
-	}
-	defer d.Close()
-	service, err := NewService(d)
-	if err != nil {
-		t.Fatal(err)
-	}
-	path, err := filepath.Abs("../../internal/protocol/bt/testdata/test.torrent")
-	if err != nil {
-		t.Fatal(err)
-	}
-	req := &restmodel.ResolveTask{Req: &base.Request{URL: path}}
-	first := serviceTestRequest[*download.ResolveResult](t, service, http.MethodPost, "/api/v1/resolve", req)
-	serviceTestRequest[any](t, service, http.MethodDelete, "/api/v1/resolve/"+first.ID, nil)
-	// Release is idempotent, including an old window disposing after Create.
-	serviceTestRequest[any](t, service, http.MethodDelete, "/api/v1/resolve/"+first.ID, nil)
-	second := serviceTestRequest[*download.ResolveResult](t, service, http.MethodPost, "/api/v1/resolve", req)
-	if second.Res.Hash != first.Res.Hash {
-		t.Fatalf("different torrent after release: %v", second)
-	}
-}

pkg/api/service.go

@@ -51,7 +51,6 @@ func NewService(downloader *download.Downloader) (*Service, error) {
 	service.routes = []RouteSpec{
 		newRoute(http.MethodGet, "/api/v1/info", service.info),
 		newRoute(http.MethodPost, "/api/v1/resolve", service.resolve),
-		newRoute(http.MethodDelete, "/api/v1/resolve/{id}", service.releaseResolve),
 		newRoute(http.MethodPost, "/api/v1/tasks", service.createTask),
 		newRoute(http.MethodPost, "/api/v1/tasks/batch", service.createTaskBatch),
 		newRoute(http.MethodPatch, "/api/v1/tasks/{id}", service.patchTask),
@@ -144,20 +143,13 @@ func (s *Service) resolve(ctx *Context) *Response {
 	if response := decodeRequest(ctx.Body, &request); response != nil {
 		return response
 	}
-	result, err := s.Downloader.ResolveWithID(request.ID, request.Req)
+	result, err := s.Downloader.Resolve(request.Req)
 	if err != nil {
 		return newErrorResponse(err.Error())
 	}
 	return newOKResponse(result)
 }
 
-func (s *Service) releaseResolve(ctx *Context) *Response {
-	if err := s.Downloader.ReleaseResolve(ctx.PathParam("id")); err != nil {
-		return newErrorResponse(err.Error())
-	}
-	return newOKResponse(nil)
-}
-
 func (s *Service) createTask(ctx *Context) *Response {
 	var request restmodel.CreateTask
 	if response := decodeRequest(ctx.Body, &request); response != nil {

pkg/download/downloader.go

@@ -116,7 +116,6 @@ type Downloader struct {
 
 	cfg            *DownloaderConfig
 	fetcherCache   map[string]fetcher.Fetcher
-	resolveStates  map[string]*resolveState
 	storage        Storage
 	tasks          []*Task
 	waitTasks      []*Task
@@ -154,7 +153,6 @@ func NewDownloader(cfg *DownloaderConfig) *Downloader {
 		cancelBackground: cancelBackground,
 		cfg:              cfg,
 		fetcherCache:     make(map[string]fetcher.Fetcher),
-		resolveStates:    make(map[string]*resolveState),
 		waitTasks:        make([]*Task, 0),
 		groups:           make(map[string]*TaskGroup),
 		creatingGroups:   make(map[string]struct{}),
@@ -561,156 +559,42 @@ func ensureResourceRequestRawURLs(parentReq *base.Request, res *base.Resource) {
 	}
 }
 
-// resolveState owns a Fetcher until Create transfers it to a task.
-// State transitions are protected by fetcherMapLock; closeOnce serializes cleanup.
-type contextResolver interface {
-	ResolveContext(context.Context, *base.Request) error
-}
-
-type resolveState struct {
-	ctx       context.Context
-	cancel    context.CancelFunc
-	fetcher   fetcher.Fetcher
-	cancelled bool
-	resolved  bool
-	claimed   bool
-	closeOnce sync.Once
-	closeErr  error
-}
-
-func (s *resolveState) close(f fetcher.Fetcher) error {
-	if f == nil {
-		return nil
+func (d *Downloader) Resolve(req *base.Request) (rr *ResolveResult, err error) {
+	rrId, err := gonanoid.New()
+	if err != nil {
+		return
 	}
-	s.closeOnce.Do(func() { s.closeErr = f.Close() })
-	return s.closeErr
-}
-
-func (d *Downloader) Resolve(req *base.Request) (*ResolveResult, error) {
-	return d.ResolveWithID("", req)
-}
-
-// ResolveWithID lets a preview cancel before metadata is available. Clients
-// that do not supply an ID retain the server-generated resource ID behavior.
-func (d *Downloader) ResolveWithID(id string, req *base.Request) (rr *ResolveResult, err error) {
-	if id == "" {
-		id, err = gonanoid.New()
-		if err != nil {
-			return nil, err
-		}
-	}
-	if req == nil {
-		return nil, errors.New("resolve request is required")
-	}
-	resolveCtx, cancel := context.WithCancel(d.backgroundCtx)
-	defer cancel()
-	state := &resolveState{ctx: resolveCtx, cancel: cancel}
-	d.fetcherMapLock.Lock()
-	if d.closed.Load() {
-		d.fetcherMapLock.Unlock()
-		return nil, errors.New("downloader is closed")
-	}
-	if d.resolveStates[id] != nil || d.fetcherCache[id] != nil {
-		d.fetcherMapLock.Unlock()
-		return nil, errors.New("resource id is already in use")
-	}
-	d.resolveStates[id] = state
-	d.fetcherMapLock.Unlock()
-	defer func() {
-		if err != nil || state.fetcher == nil {
-			d.fetcherMapLock.Lock()
-			if d.resolveStates[id] == state {
-				delete(d.resolveStates, id)
-			}
-			d.fetcherMapLock.Unlock()
-			_ = state.close(state.fetcher)
-		}
-	}()
 	ensureRequestRawURL(req)
+
 	res, err := d.triggerOnResolve(req)
 	if err != nil {
-		return nil, err
+		return
 	}
 	if res != nil && len(res.Files) > 0 {
-		return &ResolveResult{Res: res, SuggestedDownloadDir: d.suggestedDownloadDir(res)}, nil
-	}
-	f, err := d.buildFetcher(req.URL)
-	if err != nil {
-		return nil, err
-	}
-	d.fetcherMapLock.Lock()
-	state.fetcher = f
-	cancelled := state.cancelled || d.closed.Load()
-	d.fetcherMapLock.Unlock()
-	if cancelled {
-		return nil, errors.New("resource resolution cancelled")
-	}
-	if resolver, ok := f.(contextResolver); ok {
-		err = resolver.ResolveContext(state.ctx, req)
-	} else {
-		err = f.Resolve(req)
-	}
-	if err != nil {
-		return nil, err
-	}
-	d.fetcherMapLock.Lock()
-	defer d.fetcherMapLock.Unlock()
-	if state.cancelled || d.closed.Load() {
-		return nil, errors.New("resource resolution cancelled")
-	}
-	state.resolved = true
-	d.fetcherCache[id] = f
-	return &ResolveResult{ID: id, Res: f.Meta().Res, SuggestedDownloadDir: d.suggestedDownloadDir(f.Meta().Res)}, nil
-}
-
-// ReleaseResolve is idempotent. A resource already transferred to a task is
-// never closed by a late preview cancellation.
-func (d *Downloader) ReleaseResolve(id string) error {
-	d.fetcherMapLock.Lock()
-	state := d.resolveStates[id]
-	f := d.fetcherCache[id]
-	delete(d.fetcherCache, id)
-	delete(d.resolveStates, id)
-	if state != nil {
-		state.cancelled = true
-		state.cancel()
-		if state.claimed {
-			f = nil
-		} else {
-			f = state.fetcher
-			if _, cancellable := f.(contextResolver); cancellable && !state.resolved {
-				// Resolve owns unpublished response/prefetch state. Its context
-				// cancels the request; the returning resolver closes it once
-				// publication has stopped, including a racing response.
-				f = nil
-			}
+		rr = &ResolveResult{
+			Res:                  res,
+			SuggestedDownloadDir: d.suggestedDownloadDir(res),
 		}
+		return
 	}
-	d.fetcherMapLock.Unlock()
-	if state != nil {
-		return state.close(f)
-	}
-	if f != nil {
-		return f.Close()
-	}
-	return nil
-}
 
-func (d *Downloader) closeResolvedResources() {
+	fetcher, err := d.buildFetcher(req.URL)
+	if err != nil {
+		return
+	}
+	err = fetcher.Resolve(req)
+	if err != nil {
+		return
+	}
 	d.fetcherMapLock.Lock()
-	ids := make(map[string]struct{}, len(d.resolveStates)+len(d.fetcherCache))
-	for id := range d.resolveStates {
-		ids[id] = struct{}{}
-	}
-	for id := range d.fetcherCache {
-		ids[id] = struct{}{}
-	}
+	d.fetcherCache[rrId] = fetcher
 	d.fetcherMapLock.Unlock()
-	for id := range ids {
-		if err := d.ReleaseResolve(id); err != nil {
-			d.Logger.Warn().Err(err).Msg("close resolved resource failed")
-		}
+	rr = &ResolveResult{
+		ID:                   rrId,
+		Res:                  fetcher.Meta().Res,
+		SuggestedDownloadDir: d.suggestedDownloadDir(fetcher.Meta().Res),
 	}
+	return
 }
 
 func (d *Downloader) notifyRunning() {
@@ -984,34 +868,18 @@ func (d *Downloader) CreateWithOptions(rrId string, opts *base.Options) (string,
 func (d *Downloader) createResolved(rrId string, opts *base.Options, groupID string) (taskId string, err error) {
 	d.fetcherMapLock.Lock()
 	fetcher, ok := d.fetcherCache[rrId]
-	state := d.resolveStates[rrId]
-	if ok && state != nil {
-		state.claimed = true
-	}
 	delete(d.fetcherCache, rrId)
 	d.fetcherMapLock.Unlock()
 	if !ok {
 		return "", errors.New("invalid resource id")
 	}
-	// Failed creation returns ownership to the preview unless it was cancelled.
+	// Only one creator may use a resolved fetcher. Failed creation makes it
+	// available again; a persisted task consumes it even if starting fails.
 	defer func() {
-		d.fetcherMapLock.Lock()
-		cancelled := d.closed.Load() || (state != nil && state.cancelled)
-		if taskId == "" && !cancelled {
+		if taskId == "" {
+			d.fetcherMapLock.Lock()
 			d.fetcherCache[rrId] = fetcher
-			if state != nil {
-				state.claimed = false
-			}
-		} else if d.resolveStates[rrId] == state {
-			delete(d.resolveStates, rrId)
-		}
-		d.fetcherMapLock.Unlock()
-		if taskId == "" && cancelled {
-			if state != nil {
-				_ = state.close(fetcher)
-			} else {
-				_ = fetcher.Close()
-			}
+			d.fetcherMapLock.Unlock()
 		}
 	}()
 	if opts == nil {
@@ -1694,7 +1562,6 @@ func (d *Downloader) Close() error {
 		return nil
 	}
 	d.cancelBackground()
-	d.closeResolvedResources()
 	d.waitForExtensionGit()
 	if d.protocolJobs != nil {
 		d.protocolJobs.close()

pkg/download/resolve_lifecycle_test.go

@@ -1,224 +0,0 @@
-package download
-
-import (
-	"errors"
-	"fmt"
-	"github.com/GopeedLab/gopeed/internal/fetcher"
-	"net/http"
-	"net/http/httptest"
-	"testing"
-	"time"
-
-	"github.com/GopeedLab/gopeed/pkg/base"
-)
-
-func TestReleaseResolveCancelsPendingHTTPHeaders(t *testing.T) {
-	entered := make(chan struct{})
-	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { close(entered); <-r.Context().Done() }))
-	defer server.Close()
-	d := NewDownloader(&DownloaderConfig{Storage: NewMemStorage(), StorageDir: t.TempDir(), TempDir: t.TempDir()})
-	if err := d.Setup(); err != nil {
-		t.Fatal(err)
-	}
-	defer d.Close()
-	done := make(chan error, 1)
-	go func() {
-		_, err := d.ResolveWithID("pending-http", &base.Request{URL: server.URL + "/file"})
-		done <- err
-	}()
-	select {
-	case <-entered:
-	case <-time.After(time.Second):
-		t.Fatal("request did not start")
-	}
-	if err := d.ReleaseResolve("pending-http"); err != nil {
-		t.Fatal(err)
-	}
-	select {
-	case err := <-done:
-		if err == nil {
-			t.Fatal("cancelled Resolve succeeded")
-		}
-	case <-time.After(300 * time.Millisecond):
-		server.CloseClientConnections()
-		t.Fatal("ReleaseResolve did not cancel the request waiting for headers")
-	}
-	if len(d.fetcherCache) != 0 || len(d.resolveStates) != 0 {
-		t.Fatal("cancelled operation retained resources")
-	}
-}
-func TestReleaseResolveAfterCreateDoesNotCloseTask(t *testing.T) {
-	d := NewDownloader(&DownloaderConfig{Storage: NewMemStorage(), StorageDir: t.TempDir(), TempDir: t.TempDir(), FetchManagers: nil})
-	if err := d.Setup(); err != nil {
-		t.Fatal(err)
-	}
-	defer d.Close()
-	d.cfg.MaxRunning = 0
-	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.Write([]byte("ok")) }))
-	defer server.Close()
-	rr, err := d.Resolve(&base.Request{URL: server.URL})
-	if err != nil {
-		t.Fatal(err)
-	}
-	id, err := d.CreateWithOptions(rr.ID, &base.Options{Path: t.TempDir()})
-	if err != nil {
-		t.Fatal(err)
-	}
-	if err := d.ReleaseResolve(rr.ID); err != nil {
-		t.Fatal(err)
-	}
-	task := d.GetTask(id)
-	if task == nil {
-		t.Fatal("late release removed task")
-	}
-	if err := d.doStart(task); err != nil {
-		t.Fatal(err)
-	}
-	waitForTaskStatus(t, d, id, base.DownloadStatusDone, 3*time.Second)
-}
-func TestResolveRejectsClosedDownloader(t *testing.T) {
-	d := NewDownloader(&DownloaderConfig{StorageDir: t.TempDir(), TempDir: t.TempDir()})
-	if err := d.Setup(); err != nil {
-		t.Fatal(err)
-	}
-	d.Close()
-	if _, err := d.ResolveWithID("closed", &base.Request{URL: "http://127.0.0.1/"}); err == nil {
-		t.Fatalf("closed downloader accepted Resolve: %v", err)
-	}
-}
-
-func TestReleaseResolveCancelsPendingMagnetMetadata(t *testing.T) {
-	d := NewDownloader(&DownloaderConfig{Storage: NewMemStorage(), StorageDir: t.TempDir(), TempDir: t.TempDir()})
-	if err := d.Setup(); err != nil {
-		t.Fatal(err)
-	}
-	defer d.Close()
-	done := make(chan error, 1)
-	go func() {
-		_, err := d.ResolveWithID("pending-magnet", &base.Request{URL: "magnet:?xt=urn:btih:0123456789abcdef0123456789abcdef01234567"})
-		done <- err
-	}()
-	deadline := time.Now().Add(2 * time.Second)
-	for {
-		d.fetcherMapLock.Lock()
-		state := d.resolveStates["pending-magnet"]
-		ready := state != nil && state.fetcher != nil
-		d.fetcherMapLock.Unlock()
-		if ready {
-			break
-		}
-		if time.Now().After(deadline) {
-			t.Fatal("magnet resolve did not start")
-		}
-		time.Sleep(time.Millisecond)
-	}
-	if err := d.ReleaseResolve("pending-magnet"); err != nil {
-		t.Fatal(err)
-	}
-	select {
-	case err := <-done:
-		if err == nil {
-			t.Fatal("cancelled magnet Resolve succeeded")
-		}
-	case <-time.After(time.Second):
-		t.Fatal("cancelled magnet remained in metadata wait")
-	}
-	if len(d.fetcherCache) != 0 || len(d.resolveStates) != 0 {
-		t.Fatal("cancelled magnet retained its resource")
-	}
-}
-func TestCloseDrainsResolvedPreviewCache(t *testing.T) {
-	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.Write([]byte("ok")) }))
-	defer server.Close()
-	d := NewDownloader(&DownloaderConfig{Storage: NewMemStorage(), StorageDir: t.TempDir(), TempDir: t.TempDir()})
-	if err := d.Setup(); err != nil {
-		t.Fatal(err)
-	}
-	if _, err := d.Resolve(&base.Request{URL: server.URL}); err != nil {
-		t.Fatal(err)
-	}
-	if err := d.Close(); err != nil {
-		t.Fatal(err)
-	}
-	if len(d.fetcherCache) != 0 || len(d.resolveStates) != 0 {
-		t.Fatal("shutdown retained preview resources")
-	}
-}
-
-type cancelledCreationFetcher struct {
-	fetcher.Fetcher
-	entered chan struct{}
-	release chan struct{}
-	err     error
-}
-
-func (f *cancelledCreationFetcher) Patch(*base.Request, *base.Options) error {
-	close(f.entered)
-	<-f.release
-	return f.err
-}
-func TestReleaseResolveDuringCreationTransfersOrClosesOwnership(t *testing.T) {
-	for _, fail := range []bool{false, true} {
-		t.Run(fmt.Sprintf("fail=%v", fail), func(t *testing.T) {
-			d := NewDownloader(&DownloaderConfig{StorageDir: t.TempDir(), TempDir: t.TempDir()})
-			if err := d.Setup(); err != nil {
-				t.Fatal(err)
-			}
-			defer d.Close()
-			d.cfg.MaxRunning = 0
-			server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.Write([]byte("ok")) }))
-			defer server.Close()
-			rr, err := d.Resolve(&base.Request{URL: server.URL})
-			if err != nil {
-				t.Fatal(err)
-			}
-			f := &cancelledCreationFetcher{Fetcher: d.fetcherCache[rr.ID], entered: make(chan struct{}), release: make(chan struct{})}
-			if fail {
-				f.err = errors.New("creation failed")
-			}
-			d.fetcherMapLock.Lock()
-			d.fetcherCache[rr.ID] = f
-			d.fetcherMapLock.Unlock()
-			done := make(chan struct{})
-			var id string
-			var createErr error
-			go func() {
-				defer close(done)
-				id, createErr = d.CreateWithOptions(rr.ID, &base.Options{Path: t.TempDir(), Size: 2})
-			}()
-			select {
-			case <-f.entered:
-			case <-time.After(time.Second):
-				t.Fatal("creation did not claim resource")
-			}
-			if err := d.ReleaseResolve(rr.ID); err != nil {
-				t.Fatal(err)
-			}
-			close(f.release)
-			select {
-			case <-done:
-			case <-time.After(time.Second):
-				t.Fatal("creation did not return")
-			}
-			if len(d.fetcherCache) != 0 || len(d.resolveStates) != 0 {
-				t.Fatal("cancelled creation returned ownership to preview cache")
-			}
-			if fail {
-				if createErr == nil {
-					t.Fatal("expected creation failure")
-				}
-				return
-			}
-			if createErr != nil {
-				t.Fatal(createErr)
-			}
-			// The protocol manager persists its concrete Fetcher type.
-			task := d.GetTask(id)
-			task.fetcher = f.Fetcher
-			if err := d.doStart(task); err != nil {
-				t.Fatal(err)
-			}
-			waitForTaskStatus(t, d, id, base.DownloadStatusDone, 3*time.Second)
-		})
-	}
-}

pkg/rest/api.go

@@ -24,7 +24,7 @@ func Info(w http.ResponseWriter, r *http.Request) {
 func Resolve(w http.ResponseWriter, r *http.Request) {
 	var req model.ResolveTask
 	if ReadJson(r, w, &req) {
-		rr, err := Downloader.ResolveWithID(req.ID, req.Req)
+		rr, err := Downloader.Resolve(req.Req)
 		if err != nil {
 			WriteJson(w, model.NewErrorResult(err.Error()))
 			return

pkg/rest/model/task.go

@@ -3,7 +3,6 @@ package model
 import "github.com/GopeedLab/gopeed/pkg/base"
 
 type ResolveTask struct {
-	ID  string        `json:"id,omitempty"`
 	Req *base.Request `json:"req"`
 }
 

ui/flutter/lib/api/api.dart

@@ -81,9 +81,6 @@ Future<ResolveResult> resolve(ResolveTask resolveTask) {
   );
 }
 
-Future<void> releaseResolve(String id) =>
-    _parse<void>(() => _request('api/v1/resolve/${Uri.encodeComponent(id)}', method: 'DELETE'), null);
-
 Future<String> createTask(CreateTask createTask) {
   return _parse<String>(() => _request('api/v1/tasks', method: 'POST', data: createTask), (data) => data as String);
 }

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

@@ -8,10 +8,7 @@ part 'resolve_task.g.dart';
 class ResolveTask {
   Request? req;
 
-  @JsonKey(includeIfNull: false)
-  String? id;
-
-  ResolveTask({this.req, this.id});
+  ResolveTask({this.req});
 
   factory ResolveTask.fromJson(Map<String, dynamic> json) => _$ResolveTaskFromJson(json);
   Map<String, dynamic> toJson() => _$ResolveTaskToJson(this);

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

@@ -10,8 +10,7 @@ ResolveTask _$ResolveTaskFromJson(Map<String, dynamic> json) => ResolveTask(
   req: json['req'] == null
       ? null
       : Request.fromJson(json['req'] as Map<String, dynamic>),
-  id: json['id'] as String?,
 );
 
 Map<String, dynamic> _$ResolveTaskToJson(ResolveTask instance) =>
-    <String, dynamic>{'req': ?instance.req, 'id': ?instance.id};
+    <String, dynamic>{'req': ?instance.req};

ui/flutter/lib/app/application/app_runtime_controller.dart

@@ -53,6 +53,7 @@ class AppRuntimeState {
 class AppRuntimeController extends AsyncNotifier<AppRuntimeState> {
   static StartConfig? _defaultStartConfig;
   Future<void> _preferenceWrites = Future<void>.value();
+  bool _analyticsStarted = false;
 
   @override
   Future<AppRuntimeState> build() async {
@@ -73,6 +74,7 @@ class AppRuntimeController extends AsyncNotifier<AppRuntimeState> {
       startConfig
         ..apiEnable = true
         ..mcpEnable = config.api.mcpEnable;
+      await _initAnalytics(config);
     } else {
       startConfig
         ..apiEnable = config.api.enable
@@ -253,7 +255,8 @@ class AppRuntimeController extends AsyncNotifier<AppRuntimeState> {
   }
 
   Future<void> _initAnalytics(DownloaderConfig config) async {
-    if (!AnalyticsConfig.isConfigured || !config.extra.analyticsEnabled) return;
+    if (_analyticsStarted || !AnalyticsConfig.isConfigured || !config.extra.analyticsEnabled) return;
+    _analyticsStarted = true;
     try {
       final generatedClientId = await Analytics.instance.init(fallbackClientId: config.extra.deviceId);
       if (generatedClientId != null) {
@@ -262,6 +265,7 @@ class AppRuntimeController extends AsyncNotifier<AppRuntimeState> {
       }
       unawaited(Analytics.instance.logAppOpen());
     } catch (error, stackTrace) {
+      _analyticsStarted = false;
       logger.w('GA4 init failed', error, stackTrace);
     }
   }

ui/flutter/lib/app/application/downloader_config_init.dart

@@ -19,7 +19,7 @@ Future<DownloaderConfig> loadDownloaderConfig({
     config = await load();
   } catch (error, stackTrace) {
     onLoadError?.call(error, stackTrace);
-    config = DownloaderConfig();
+    config = DownloaderConfig()..extra.analyticsEnabled = false;
     loaded = false;
   }
   final changed = await initDownloaderConfig(config, defaultDownloadDir: defaultDownloadDir);

ui/flutter/lib/core/capabilities/app_capabilities.dart

@@ -93,10 +93,6 @@ void _bindGopeed(CapabilityRegistry registry, _ConfigStore configStore) {
       (p) => api.getMirrorCandidates(p['provider'] as String, p['url'] as String),
     )
     ..bind(GopeedMethods.resolve, api.resolve)
-    ..bind(GopeedMethods.releaseResolve, (id) async {
-      await api.releaseResolve(id);
-      return const RpcUnit();
-    })
     ..bind(GopeedMethods.createTask, api.createTask)
     ..bind(GopeedMethods.createTaskBatch, api.createTaskBatch)
     ..bind(GopeedMethods.patchTask, (params) async {

ui/flutter/lib/core/capabilities/gopeed_capability.dart

@@ -16,7 +16,6 @@ abstract final class GopeedMethods {
   static const triggerProtocolJob = RpcMethod<Map<String, dynamic>, RpcUnit>('gopeed.protocol.job.trigger');
   static const getMirrorCandidates = RpcMethod<Map<String, dynamic>, List<String>>('gopeed.mirrors.candidates');
   static const resolve = RpcMethod<ResolveTask, ResolveResult>('gopeed.resolve');
-  static const releaseResolve = RpcMethod<String, RpcUnit>('gopeed.releaseResolve');
   static const createTask = RpcMethod<CreateTask, String>('gopeed.task.create');
   static const createTaskBatch = RpcMethod<CreateTaskBatch, CreateTaskBatchResult>('gopeed.task.createBatch');
   static const patchTask = RpcMethod<Map<String, dynamic>, RpcUnit>('gopeed.task.patch');
@@ -51,7 +50,6 @@ class GopeedService {
   Future<List<String>> getMirrorCandidates(String provider, String url) =>
       _invoker.invoke(GopeedMethods.getMirrorCandidates, {'provider': provider, 'url': url});
   Future<ResolveResult> resolve(ResolveTask request) => _invoker.invoke(GopeedMethods.resolve, request);
-  Future<void> releaseResolve(String id) async => _invoker.invoke(GopeedMethods.releaseResolve, id);
 
   Future<String> createTask(CreateTask request) => _invoker.invoke(GopeedMethods.createTask, request);
 

ui/flutter/lib/features/settings/application/settings_controller.dart

@@ -19,6 +19,12 @@ class SettingsState {
   }
 }
 
+class SettingsSaveResult {
+  const SettingsSaveResult({required this.btRestartRequired});
+
+  final bool btRestartRequired;
+}
+
 class SettingsController extends AsyncNotifier<SettingsState> {
   Future<void> _saveTail = Future<void>.value();
   int _saveRevision = 0;
@@ -36,7 +42,7 @@ class SettingsController extends AsyncNotifier<SettingsState> {
     state = AsyncValue.data(SettingsState(config: config));
   }
 
-  Future<void> save(DownloaderConfig config) {
+  Future<SettingsSaveResult> save(DownloaderConfig config) {
     final snapshot = DownloaderConfig.fromJson(config.toJson());
     final revision = ++_saveRevision;
     state = AsyncValue.data(SettingsState(config: config, saving: true));
@@ -47,10 +53,15 @@ class SettingsController extends AsyncNotifier<SettingsState> {
     return result;
   }
 
-  Future<void> _save(DownloaderConfig config, int revision) async {
+  Future<SettingsSaveResult> _save(DownloaderConfig config, int revision) async {
     try {
       final service = ref.read(gopeedServiceProvider);
       final latest = await service.getConfig();
+      final previousBt = (
+        latest.protocolConfig.bt.listenPort,
+        latest.protocolConfig.bt.disableDht,
+        latest.protocolConfig.bt.disablePex,
+      );
       config.extra
         ..windowState = latest.extra.windowState
         ..bookmarks = latest.extra.bookmarks
@@ -64,6 +75,12 @@ class SettingsController extends AsyncNotifier<SettingsState> {
         ref.read(appRuntimeControllerProvider.notifier).replaceDownloaderConfig(saved);
         if (revision == _saveRevision) state = AsyncValue.data(SettingsState(config: saved));
       }
+      final savedBt = (
+        saved.protocolConfig.bt.listenPort,
+        saved.protocolConfig.bt.disableDht,
+        saved.protocolConfig.bt.disablePex,
+      );
+      return SettingsSaveResult(btRestartRequired: previousBt != savedBt);
     } finally {
       if (ref.mounted && revision == _saveRevision && state.value?.saving == true) {
         state = AsyncValue.data(state.requireValue.copyWith(saving: false));

ui/flutter/lib/features/settings/presentation/pages/settings_page.dart

@@ -625,7 +625,6 @@ class _SettingsPageState extends ConsumerState<SettingsPage> {
                   ),
                   SettingsItem(
                     title: context.l10n.enableDht,
-                    subtitle: context.l10n.restartRequired,
                     child: shad.Switch(
                       value: !config.protocolConfig.bt.disableDht,
                       onChanged: (value) => _mutateConfig((next) => next.protocolConfig.bt.disableDht = !value),
@@ -633,7 +632,6 @@ class _SettingsPageState extends ConsumerState<SettingsPage> {
                   ),
                   SettingsItem(
                     title: context.l10n.enablePex,
-                    subtitle: context.l10n.restartRequired,
                     child: shad.Switch(
                       value: !config.protocolConfig.bt.disablePex,
                       onChanged: (value) => _mutateConfig((next) => next.protocolConfig.bt.disablePex = !value),
@@ -1204,7 +1202,10 @@ class _SettingsPageState extends ConsumerState<SettingsPage> {
     final snapshot = DownloaderConfig.fromJson(config.toJson());
     _loadedSignature = _signature(snapshot);
     try {
-      await ref.read(settingsControllerProvider.notifier).save(snapshot);
+      final result = await ref.read(settingsControllerProvider.notifier).save(snapshot);
+      if (mounted && result.btRestartRequired) {
+        _toast(context.l10n.restartRequired, type: AppToastType.info);
+      }
       return true;
     } catch (error) {
       if (mounted) _toast(error.toString());

ui/flutter/lib/features/tasks/application/pending_download.dart

@@ -1,5 +1,3 @@
-import 'dart:developer' as developer;
-import 'package:uuid/uuid.dart';
 import 'package:path/path.dart' as path;
 
 import '../../../api/model/create_task_batch.dart';
@@ -18,8 +16,6 @@ class PendingDownload {
   final Request request;
   final Options options;
   ResolveResult? result;
-  String? _resolveID;
-  bool _cancelled = false;
   String? resolveError;
   String? createError;
   final Set<int> selected = {};
@@ -54,16 +50,11 @@ class PendingDownload {
   bool get hasSelection => !created && result != null && selected.isNotEmpty;
 
   Future<void> resolve(GopeedService service) async {
-    if (_cancelled || result != null || resolving) return;
+    if (result != null || resolving) return;
     resolving = true;
     resolveError = null;
     try {
-      _resolveID = const Uuid().v4();
-      result = await service.resolve(ResolveTask(req: request, id: _resolveID));
-      if (_cancelled) {
-        await _release(service, result!.id);
-        return;
-      }
+      result = await service.resolve(ResolveTask(req: request));
       selected.addAll(List.generate(files.isEmpty ? 1 : files.length, (index) => index));
     } catch (error) {
       resolveError = error.toString();
@@ -72,23 +63,6 @@ class PendingDownload {
     }
   }
 
-  /// Stop an outstanding preview and release any resource it already owns.
-  /// A response arriving after cancellation is released by resolve() as well.
-  Future<void> cancel(GopeedService service) async {
-    if (_cancelled || created) return;
-    _cancelled = true;
-    await _release(service, result?.id.isNotEmpty == true ? result!.id : _resolveID);
-  }
-
-  Future<void> _release(GopeedService service, String? id) async {
-    if (id == null || id.isEmpty) return;
-    try {
-      await service.releaseResolve(id);
-    } catch (error, stack) {
-      developer.log('Failed to release resolved resource', name: 'gopeed.resolve', error: error, stackTrace: stack);
-    }
-  }
-
   List<CreateTaskBatchItem> creationItems() {
     final indexes = selected.toList()..sort();
     if (result!.id.isNotEmpty || files.isEmpty) {

ui/flutter/lib/features/tasks/presentation/pages/create_task_window_page.dart

@@ -41,6 +41,7 @@ import '../../application/pending_download.dart';
 import '../../application/task_list_navigation.dart';
 import '../widgets/history_search_field.dart';
 import '../widgets/create_task_action_buttons.dart';
+import '../widgets/create_task_advanced_toggle.dart';
 import '../widgets/resolve_download_dialog.dart';
 
 class CreateTaskWindowPage extends ConsumerStatefulWidget {
@@ -560,20 +561,11 @@ class _CreateTaskWindowPageState extends ConsumerState<CreateTaskWindowPage> {
                     ),
                     const SizedBox(height: 20),
                     Align(
-                      alignment: Alignment.centerLeft,
-                      child: GestureDetector(
-                        onTap: _toggleAdvanced,
-                        child: Row(
-                          mainAxisSize: MainAxisSize.min,
-                          children: [
-                            Text(
-                              context.l10n.advanced,
-                              style: TextStyle(color: palette.textPrimary, fontSize: 14, fontWeight: FontWeight.w600),
-                            ),
-                            const SizedBox(width: 8),
-                            _TripleChevronIcon(expanded: _showAdvanced, color: palette.textSecondary),
-                          ],
-                        ),
+                      alignment: AlignmentDirectional.centerStart,
+                      child: CreateTaskAdvancedToggle(
+                        key: const ValueKey('create-task-advanced-toggle'),
+                        expanded: _showAdvanced,
+                        onPressed: _toggleAdvanced,
                       ),
                     ),
                     AnimatedCrossFade(
@@ -1933,30 +1925,6 @@ class _MiniInputAction extends StatelessWidget {
   }
 }
 
-class _TripleChevronIcon extends StatelessWidget {
-  const _TripleChevronIcon({required this.expanded, required this.color});
-
-  final bool expanded;
-  final Color color;
-
-  @override
-  Widget build(BuildContext context) {
-    final icon = expanded ? Icons.expand_less : Icons.expand_more;
-    return SizedBox(
-      width: 14,
-      height: 18,
-      child: Stack(
-        clipBehavior: Clip.none,
-        children: [
-          Positioned(top: 0, left: 0, child: Icon(icon, size: 14, color: color)),
-          Positioned(top: 4, left: 0, child: Icon(icon, size: 14, color: color)),
-          Positioned(top: 8, left: 0, child: Icon(icon, size: 14, color: color)),
-        ],
-      ),
-    );
-  }
-}
-
 class _SegmentButton extends StatelessWidget {
   const _SegmentButton({required this.label, required this.active, required this.onTap});
 

ui/flutter/lib/features/tasks/presentation/widgets/create_task_advanced_toggle.dart

@@ -0,0 +1,49 @@
+import 'package:shadcn_flutter/shadcn_flutter.dart';
+
+import '../../../../l10n/l10n.dart';
+import '../../../../shared/theme/app_design_tokens.dart';
+import '../../../../shared/theme/app_palette.dart';
+
+/// A quiet disclosure control with the same keyboard behavior as other buttons.
+class CreateTaskAdvancedToggle extends StatelessWidget {
+  const CreateTaskAdvancedToggle({super.key, required this.expanded, required this.onPressed});
+
+  final bool expanded;
+  final VoidCallback onPressed;
+
+  @override
+  Widget build(BuildContext context) {
+    final palette = AppPalette.of(context);
+    final reduceMotion = MediaQuery.disableAnimationsOf(context);
+    return Semantics(
+      expanded: expanded,
+      child: ButtonStyleOverride.inherit(
+        padding: (context, states, value) => const EdgeInsets.symmetric(vertical: AppDesignTokens.space12),
+        child: GhostButton(
+          onPressed: onPressed,
+          child: ConstrainedBox(
+            constraints: const BoxConstraints(minHeight: 20),
+            child: Row(
+              mainAxisSize: MainAxisSize.min,
+              children: [
+                Flexible(
+                  child: Text(
+                    context.l10n.advanced,
+                    style: TextStyle(color: palette.textPrimary, fontSize: 14, fontWeight: FontWeight.w600),
+                  ),
+                ),
+                const SizedBox(width: AppDesignTokens.space8),
+                AnimatedRotation(
+                  turns: expanded ? 0.5 : 0,
+                  duration: reduceMotion ? Duration.zero : const Duration(milliseconds: 180),
+                  curve: Curves.easeOutCubic,
+                  child: Icon(Icons.keyboard_arrow_down, size: 16, color: palette.textSecondary),
+                ),
+              ],
+            ),
+          ),
+        ),
+      ),
+    );
+  }
+}

ui/flutter/lib/features/tasks/presentation/widgets/resolve_download_dialog.dart

@@ -1,5 +1,3 @@
-import 'dart:async';
-
 import 'package:shadcn_flutter/shadcn_flutter.dart';
 import 'package:flutter/widgets.dart' as flutter show Flexible;
 
@@ -51,7 +49,6 @@ class _ResolveDownloadsDialogState extends State<_ResolveDownloadsDialog> {
   @override
   void dispose() {
     _cancelled = true;
-    _releasePreviews();
     super.dispose();
   }
 
@@ -67,15 +64,8 @@ class _ResolveDownloadsDialogState extends State<_ResolveDownloadsDialog> {
     }
   }
 
-  void _releasePreviews() {
-    for (final source in widget.sources) {
-      unawaited(source.cancel(widget.service));
-    }
-  }
-
   void _cancel() {
     _cancelled = true;
-    _releasePreviews();
     closeOverlay(context, false);
   }
 

ui/flutter/lib/l10n/app_ar.arb

@@ -208,7 +208,7 @@
   "categoryName": "اسم الفئة",
   "categoryPath": "مسار الفئة",
   "autoCategorizeByExtension": "تصنيف تلقائي حسب نوع الملف",
-  "autoCategorizeByExtensionDescription": "توجيه التنزيلات إلى مجلد الفئة تلقائيًا حسب امتداد الملف عند الحفظ في مجلد التنزيل الافتراضي.",
+  "autoCategorizeByExtensionDescription": "توجيه التنزيلات إلى مجلد الفئة تلقائيًا حسب امتداد الملف عند الحفظ في مجلد التنزيل الافتراضي",
   "categoryExtensions": "امتدادات الملفات",
   "categoryExtensionsUsageHint": "افصل الامتدادات بفواصل أو مسافات ثم اضغط Enter.",
   "categoryExtensionsEmptyHint": "بدون الامتدادات، لن تُحفظ الملفات في هذا التصنيف تلقائيًا.",

ui/flutter/lib/l10n/app_az.arb

@@ -215,7 +215,7 @@
   "categoryName": "Kateqoriyanın Adı",
   "categoryPath": "Kateqoriyanın Yolu",
   "autoCategorizeByExtension": "Fayl tipinə görə avtomatik kateqoriyalaşdırma",
-  "autoCategorizeByExtensionDescription": "Standart yükləmə qovluğuna yadda saxlanarkən yükləmələr fayl uzantısına görə avtomatik olaraq kateqoriya qovluğuna yönləndirilir.",
+  "autoCategorizeByExtensionDescription": "Standart yükləmə qovluğuna yadda saxlanarkən yükləmələr fayl uzantısına görə avtomatik olaraq kateqoriya qovluğuna yönləndirilir",
   "categoryExtensions": "Fayl uzantıları",
   "categoryExtensionsUsageHint": "Uzantıları vergül və ya boşluqla ayırın, sonra Enter-a basın.",
   "categoryExtensionsEmptyHint": "Uzantı yoxdursa, fayllar bu kateqoriyaya avtomatik olaraq saxlanmır.",

ui/flutter/lib/l10n/app_ca.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nom de la categoria",
   "categoryPath": "Ruta de la categoria",
   "autoCategorizeByExtension": "Categoritza automàticament segons el tipus de fitxer",
-  "autoCategorizeByExtensionDescription": "Les baixades es desen a la carpeta de categoria segons l'extensió del fitxer en utilitzar la carpeta de baixades predeterminada.",
+  "autoCategorizeByExtensionDescription": "Les baixades es desen a la carpeta de categoria segons l'extensió del fitxer en utilitzar la carpeta de baixades predeterminada",
   "categoryExtensions": "Extensions de fitxer",
   "categoryExtensionsUsageHint": "Separa les extensions amb comes o espais i prem Retorn.",
   "categoryExtensionsEmptyHint": "Sense extensions, els fitxers no es desaran aquí automàticament.",

ui/flutter/lib/l10n/app_de.arb

@@ -208,7 +208,7 @@
   "categoryName": "Kategoriename",
   "categoryPath": "Kategoriepfad",
   "autoCategorizeByExtension": "Nach Dateityp automatisch kategorisieren",
-  "autoCategorizeByExtensionDescription": "Downloads werden beim Speichern im Standard-Download-Ordner anhand der Dateiendung automatisch einem Kategorieordner zugeordnet.",
+  "autoCategorizeByExtensionDescription": "Downloads werden beim Speichern im Standard-Download-Ordner anhand der Dateiendung automatisch einem Kategorieordner zugeordnet",
   "categoryExtensions": "Dateiendungen",
   "categoryExtensionsUsageHint": "Trenne Endungen mit Kommas oder Leerzeichen und drücke Enter.",
   "categoryExtensionsEmptyHint": "Ohne Endungen werden Dateien nicht automatisch dieser Kategorie zugeordnet.",

ui/flutter/lib/l10n/app_en.arb

@@ -222,7 +222,7 @@
   "categoryName": "Category Name",
   "categoryPath": "Category Path",
   "autoCategorizeByExtension": "Auto-categorize by file type",
-  "autoCategorizeByExtensionDescription": "Automatically route downloads into a category folder based on the file name when saving to the default download folder.",
+  "autoCategorizeByExtensionDescription": "Automatically route downloads into a category folder based on the file name when saving to the default download folder",
   "categoryExtensions": "Associated Extensions",
   "categoryExtensionsUsageHint": "Separate suffixes with commas or spaces, then press Enter.",
   "categoryExtensionsEmptyHint": "Without extensions, files won't be saved into this category automatically.",

ui/flutter/lib/l10n/app_es.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nombre de categoría",
   "categoryPath": "Ruta de categoría",
   "autoCategorizeByExtension": "Categorizar automáticamente por tipo de archivo",
-  "autoCategorizeByExtensionDescription": "Las descargas se guardan automáticamente en la carpeta de categoría según la extensión del archivo al usar la carpeta de descargas predeterminada.",
+  "autoCategorizeByExtensionDescription": "Las descargas se guardan automáticamente en la carpeta de categoría según la extensión del archivo al usar la carpeta de descargas predeterminada",
   "categoryExtensions": "Extensiones de archivo",
   "categoryExtensionsUsageHint": "Separa las extensiones con comas o espacios y pulsa Intro.",
   "categoryExtensionsEmptyHint": "Sin extensiones, los archivos no se guardarán automáticamente en esta categoría.",

ui/flutter/lib/l10n/app_fa.arb

@@ -208,7 +208,7 @@
   "categoryName": "نام دسته‌بندی",
   "categoryPath": "مسیر دسته‌بندی",
   "autoCategorizeByExtension": "دسته‌بندی خودکار بر اساس نوع فایل",
-  "autoCategorizeByExtensionDescription": "هنگام ذخیره در پوشه پیش‌فرض دانلود، دانلودها بر اساس پسوند فایل به پوشه دسته مربوطه منتقل می‌شوند.",
+  "autoCategorizeByExtensionDescription": "هنگام ذخیره در پوشه پیش‌فرض دانلود، دانلودها بر اساس پسوند فایل به پوشه دسته مربوطه منتقل می‌شوند",
   "categoryExtensions": "پسوندهای فایل",
   "categoryExtensionsUsageHint": "پسوندها را با ویرگول یا فاصله جدا کنید و Enter را بزنید.",
   "categoryExtensionsEmptyHint": "بدون پسوندها، فایل‌ها به‌صورت خودکار در این دسته ذخیره نمی‌شوند.",

ui/flutter/lib/l10n/app_fr.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nom de la catégorie",
   "categoryPath": "Chemin de la catégorie",
   "autoCategorizeByExtension": "Catégoriser automatiquement selon le type de fichier",
-  "autoCategorizeByExtensionDescription": "Les téléchargements sont placés dans un dossier de catégorie selon l'extension du fichier lors de l'enregistrement dans le dossier de téléchargement par défaut.",
+  "autoCategorizeByExtensionDescription": "Les téléchargements sont placés dans un dossier de catégorie selon l'extension du fichier lors de l'enregistrement dans le dossier de téléchargement par défaut",
   "categoryExtensions": "Extensions de fichier",
   "categoryExtensionsUsageHint": "Séparez les extensions par virgules ou espaces, puis appuyez sur Entrée.",
   "categoryExtensionsEmptyHint": "Sans extensions, les fichiers ne seront pas enregistrés ici automatiquement.",

ui/flutter/lib/l10n/app_hu.arb

@@ -208,7 +208,7 @@
   "categoryName": "Kategória neve",
   "categoryPath": "Kategória útvonala",
   "autoCategorizeByExtension": "Automatikus kategorizálás fájltípus szerint",
-  "autoCategorizeByExtensionDescription": "Az alapértelmezett letöltési mappa használatakor a letöltések a fájl kiterjesztése alapján automatikusan a kategória mappájába kerülnek.",
+  "autoCategorizeByExtensionDescription": "Az alapértelmezett letöltési mappa használatakor a letöltések a fájl kiterjesztése alapján automatikusan a kategória mappájába kerülnek",
   "categoryExtensions": "Fájlkiterjesztések",
   "categoryExtensionsUsageHint": "A kiterjesztéseket vesszővel vagy szóközzel válaszd el, majd nyomd le az Enter billentyűt.",
   "categoryExtensionsEmptyHint": "Kiterjesztések nélkül a fájlok nem kerülnek automatikusan ebbe a kategóriába.",

ui/flutter/lib/l10n/app_id.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nama Kategori",
   "categoryPath": "Path Kategori",
   "autoCategorizeByExtension": "Kategorikan otomatis berdasarkan jenis file",
-  "autoCategorizeByExtensionDescription": "Unduhan dialihkan ke folder kategori berdasarkan ekstensi file saat disimpan ke folder unduhan bawaan.",
+  "autoCategorizeByExtensionDescription": "Unduhan dialihkan ke folder kategori berdasarkan ekstensi file saat disimpan ke folder unduhan bawaan",
   "categoryExtensions": "Ekstensi file",
   "categoryExtensionsUsageHint": "Pisahkan ekstensi dengan koma atau spasi, lalu tekan Enter.",
   "categoryExtensionsEmptyHint": "Tanpa ekstensi, file tidak akan otomatis disimpan ke kategori ini.",

ui/flutter/lib/l10n/app_it.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nome categoria",
   "categoryPath": "Percorso categoria",
   "autoCategorizeByExtension": "Categorizza automaticamente per tipo di file",
-  "autoCategorizeByExtensionDescription": "Il download viene instradato automaticamente nella cartella della categoria in base all'estensione quando si salva nella cartella di download predefinita.",
+  "autoCategorizeByExtensionDescription": "Il download viene instradato automaticamente nella cartella della categoria in base all'estensione quando si salva nella cartella di download predefinita",
   "categoryExtensions": "Estensioni file",
   "categoryExtensionsUsageHint": "Separa le estensioni con virgole o spazi e premi Invio.",
   "categoryExtensionsEmptyHint": "Senza estensioni, i file non verranno salvati qui automaticamente.",

ui/flutter/lib/l10n/app_ja.arb

@@ -208,7 +208,7 @@
   "categoryName": "カテゴリ名",
   "categoryPath": "カテゴリパス",
   "autoCategorizeByExtension": "ファイル種別で自動分類",
-  "autoCategorizeByExtensionDescription": "既定のダウンロードフォルダーに保存する際、拡張子に基づいて分類フォルダーへ自動的に振り分けます。",
+  "autoCategorizeByExtensionDescription": "既定のダウンロードフォルダーに保存する際、拡張子に基づいて分類フォルダーへ自動的に振り分けます",
   "categoryExtensions": "ファイル拡張子",
   "categoryExtensionsUsageHint": "カンマやスペースで拡張子を区切り、Enterで追加します。",
   "categoryExtensionsEmptyHint": "拡張子が未設定の場合、ファイルは自動的にこの分類へ保存されません。",

ui/flutter/lib/l10n/app_ko.arb

@@ -208,7 +208,7 @@
   "categoryName": "카테고리 이름",
   "categoryPath": "카테고리 경로",
   "autoCategorizeByExtension": "파일 형식별 자동 분류",
-  "autoCategorizeByExtensionDescription": "기본 다운로드 폴더에 저장할 때 확장자에 따라 분류 폴더로 자동 이동합니다.",
+  "autoCategorizeByExtensionDescription": "기본 다운로드 폴더에 저장할 때 확장자에 따라 분류 폴더로 자동 이동합니다",
   "categoryExtensions": "파일 확장자",
   "categoryExtensionsUsageHint": "쉼표나 공백으로 확장자를 구분하고 Enter를 눌러 추가하세요.",
   "categoryExtensionsEmptyHint": "확장자가 없으면 파일이 이 분류로 자동 저장되지 않습니다.",

ui/flutter/lib/l10n/app_pl.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nazwa kategorii",
   "categoryPath": "Ścieżka kategorii",
   "autoCategorizeByExtension": "Automatyczna kategorizacja według typu pliku",
-  "autoCategorizeByExtensionDescription": "Pobierane pliki są automatycznie zapisywane w folderze kategorii na podstawie rozszerzenia, gdy używany jest domyślny folder pobierania.",
+  "autoCategorizeByExtensionDescription": "Pobierane pliki są automatycznie zapisywane w folderze kategorii na podstawie rozszerzenia, gdy używany jest domyślny folder pobierania",
   "categoryExtensions": "Rozszerzenia plików",
   "categoryExtensionsUsageHint": "Rozdzielaj rozszerzenia przecinkami lub spacjami i naciskaj Enter.",
   "categoryExtensionsEmptyHint": "Bez rozszerzeń pliki nie będą automatycznie zapisywane w tej kategorii.",

ui/flutter/lib/l10n/app_pt.arb

@@ -208,7 +208,7 @@
   "categoryName": "Nome da Categoria",
   "categoryPath": "Caminho da Categoria",
   "autoCategorizeByExtension": "Categorizar automaticamente por tipo de arquivo",
-  "autoCategorizeByExtensionDescription": "Envia os downloads para a pasta da categoria com base na extensão ao salvar na pasta de download padrão.",
+  "autoCategorizeByExtensionDescription": "Envia os downloads para a pasta da categoria com base na extensão ao salvar na pasta de download padrão",
   "categoryExtensions": "Extensões de arquivo",
   "categoryExtensionsUsageHint": "Separe as extensões com vírgulas ou espaços e prima Enter.",
   "categoryExtensionsEmptyHint": "Sem extensões, os ficheiros não serão guardados aqui automaticamente.",

ui/flutter/lib/l10n/app_ru.arb

@@ -208,7 +208,7 @@
   "categoryName": "Название категории",
   "categoryPath": "Путь категории",
   "autoCategorizeByExtension": "Автокатегоризация по типу файла",
-  "autoCategorizeByExtensionDescription": "Загрузки автоматически сохраняются в папку категории по расширению файла, если выбрана папка загрузки по умолчанию.",
+  "autoCategorizeByExtensionDescription": "Загрузки автоматически сохраняются в папку категории по расширению файла, если выбрана папка загрузки по умолчанию",
   "categoryExtensions": "Расширения файлов",
   "categoryExtensionsUsageHint": "Разделяйте расширения запятыми или пробелами и нажимайте Enter.",
   "categoryExtensionsEmptyHint": "Без расширений файлы не будут автоматически сохранены в эту категорию.",

ui/flutter/lib/l10n/app_sk.arb

@@ -222,7 +222,7 @@
   "categoryName": "Názov kategórie",
   "categoryPath": "Cesta kategórie",
   "autoCategorizeByExtension": "Automatická kategorizácia podľa typu súboru",
-  "autoCategorizeByExtensionDescription": "Sťahovania sa pri ukladaní do predvoleného priečinka sťahovania automaticky presúvajú do priečinka kategórie podľa prípony súboru.",
+  "autoCategorizeByExtensionDescription": "Sťahovania sa pri ukladaní do predvoleného priečinka sťahovania automaticky presúvajú do priečinka kategórie podľa prípony súboru",
   "categoryExtensions": "Prípony súborov",
   "categoryExtensionsUsageHint": "Oddeľujte prípony čiarkami alebo medzerami a stlačte Enter.",
   "categoryExtensionsEmptyHint": "Bez prípon sa súbory automaticky neuložia do tejto kategórie.",

ui/flutter/lib/l10n/app_ta.arb

@@ -208,7 +208,7 @@
   "categoryName": "வகை பெயர்",
   "categoryPath": "வகை பாதை",
   "autoCategorizeByExtension": "கோப்பு வகை வாரியாக தானாக வகைப்படுத்து",
-  "autoCategorizeByExtensionDescription": "இயல்புநிலை பதிவிறக்கக் கோப்புறையில் சேமிக்கும்போது, கோப்பு நீட்டிப்பின் அடிப்படையில் வகைக் கோப்புறைக்கு தானாக அனுப்பப்படும்.",
+  "autoCategorizeByExtensionDescription": "இயல்புநிலை பதிவிறக்கக் கோப்புறையில் சேமிக்கும்போது, கோப்பு நீட்டிப்பின் அடிப்படையில் வகைக் கோப்புறைக்கு தானாக அனுப்பப்படும்",
   "categoryExtensions": "கோப்பு நீட்டிப்புகள்",
   "categoryExtensionsUsageHint": "நீட்டிப்புகளை காற்புள்ளிகள் அல்லது இடைவெளிகளால் பிரித்து Enter அழுத்தவும்.",
   "categoryExtensionsEmptyHint": "நீட்டிப்புகள் இல்லாததால், கோப்புகள் இந்த வகைப்பாட்டில் தானாகச் சேமிக்கப்படாது.",

ui/flutter/lib/l10n/app_tr.arb

@@ -208,7 +208,7 @@
   "categoryName": "Kategori Adı",
   "categoryPath": "Kategori Yolu",
   "autoCategorizeByExtension": "Dosya tipine göre otomatik sınıflandır",
-  "autoCategorizeByExtensionDescription": "Varsayılan indirme klasörüne kaydedilirken dosya uzantısına göre ilgili klasöre otomatik yönlendirir.",
+  "autoCategorizeByExtensionDescription": "Varsayılan indirme klasörüne kaydedilirken dosya uzantısına göre ilgili klasöre otomatik yönlendirir",
   "categoryExtensions": "Dosya uzantıları",
   "categoryExtensionsUsageHint": "Sonekleri virgül veya boşlukla ayırıp Enter'a basın.",
   "categoryExtensionsEmptyHint": "Uzantı yoksa dosyalar bu kategoriye otomatik olarak kaydedilmez.",

ui/flutter/lib/l10n/app_uk.arb

@@ -208,7 +208,7 @@
   "categoryName": "Назва категорії",
   "categoryPath": "Шлях категорії",
   "autoCategorizeByExtension": "Автокатегоризація за типом файлу",
-  "autoCategorizeByExtensionDescription": "Завантаження автоматично зберігаються в папку категорії за розширенням файлу, якщо вибрано папку завантаження за замовчуванням.",
+  "autoCategorizeByExtensionDescription": "Завантаження автоматично зберігаються в папку категорії за розширенням файлу, якщо вибрано папку завантаження за замовчуванням",
   "categoryExtensions": "Розширення файлів",
   "categoryExtensionsUsageHint": "Розділяйте розширення комами або пробілами та натискайте Enter.",
   "categoryExtensionsEmptyHint": "Без розширень файли не зберігатимуться в цю категорію автоматично.",

ui/flutter/lib/l10n/app_vi.arb

@@ -208,7 +208,7 @@
   "categoryName": "Tên danh mục",
   "categoryPath": "Đường dẫn danh mục",
   "autoCategorizeByExtension": "Tự động phân loại theo loại tệp",
-  "autoCategorizeByExtensionDescription": "Tải xuống sẽ được chuyển vào thư mục danh mục dựa trên phần mở rộng tệp khi lưu vào thư mục tải xuống mặc định.",
+  "autoCategorizeByExtensionDescription": "Tải xuống sẽ được chuyển vào thư mục danh mục dựa trên phần mở rộng tệp khi lưu vào thư mục tải xuống mặc định",
   "categoryExtensions": "Phần mở rộng tệp",
   "categoryExtensionsUsageHint": "Phân tách phần mở rộng bằng dấu phẩy hoặc khoảng trắng rồi nhấn Enter.",
   "categoryExtensionsEmptyHint": "Không có phần mở rộng, tệp sẽ không tự động được lưu vào danh mục này.",

ui/flutter/lib/l10n/app_zh.arb

@@ -208,7 +208,7 @@
   "categoryName": "分类名称",
   "categoryPath": "分类路径",
   "autoCategorizeByExtension": "按文件类型自动分类",
-  "autoCategorizeByExtensionDescription": "保存到默认下载目录时，根据文件后缀自动归入对应分类文件夹。",
+  "autoCategorizeByExtensionDescription": "保存到默认下载目录时，根据文件后缀自动归入对应分类文件夹",
   "categoryExtensions": "文件后缀关联",
   "categoryExtensionsUsageHint": "支持逗号/空格分隔后缀，按回车添加。",
   "categoryExtensionsEmptyHint": "未设置后缀，文件不会自动归入此分类。",

ui/flutter/lib/l10n/app_zh_TW.arb

@@ -208,7 +208,7 @@
   "categoryName": "分類名稱",
   "categoryPath": "分類路徑",
   "autoCategorizeByExtension": "按檔案類型自動分類",
-  "autoCategorizeByExtensionDescription": "儲存至預設下載目錄時，根據檔案副檔名自動歸入對應分類資料夾。",
+  "autoCategorizeByExtensionDescription": "儲存至預設下載目錄時，根據檔案副檔名自動歸入對應分類資料夾",
   "categoryExtensions": "檔案副檔名",
   "categoryExtensionsUsageHint": "支援逗號/空白分隔後綴，按回車新增。",
   "categoryExtensionsEmptyHint": "未設定後綴，檔案不會自動歸入此分類。",

ui/flutter/test/app/application/downloader_config_init_test.dart

@@ -32,8 +32,22 @@ void main() {
       // The in-memory fallback still gets usable defaults.
       expect(config.downloadDir, '/downloads');
       expect(config.categories, hasLength(4));
+      expect(config.extra.analyticsEnabled, isFalse);
     });
 
+    for (final analyticsEnabled in [false, true]) {
+      test('preserves the saved analytics preference ($analyticsEnabled)', () async {
+        final stored = configWith()..extra.analyticsEnabled = analyticsEnabled;
+        final config = await loadDownloaderConfig(
+          load: () async => stored,
+          save: (_) async {},
+          defaultDownloadDir: () async => '/downloads',
+        );
+
+        expect(config.extra.analyticsEnabled, analyticsEnabled);
+      });
+    }
+
     test('skips persist when init changed nothing', () async {
       var saved = 0;
       await loadDownloaderConfig(

ui/flutter/test/features/settings/application/settings_controller_test.dart

@@ -99,6 +99,43 @@ void main() {
     expect(saved.saving, isFalse);
   });
 
+  for (final field in ['port', 'DHT', 'PEX']) {
+    test('$field restart notice follows successful persisted changes only', () async {
+      var backend = DownloaderConfig();
+      var failNextSave = false;
+      final registry = CapabilityRegistry(createAppCapabilityCodecs())
+        ..bind(GopeedMethods.getConfig, (_) => DownloaderConfig.fromJson(backend.toJson()))
+        ..bind(GopeedMethods.putConfig, (config) {
+          if (failNextSave) {
+            failNextSave = false;
+            throw StateError('offline');
+          }
+          backend = DownloaderConfig.fromJson(config.toJson());
+          return const RpcUnit();
+        });
+      final container = _settingsContainer(registry);
+      addTearDown(container.dispose);
+      final initial = await container.read(settingsControllerProvider.future);
+      final controller = container.read(settingsControllerProvider.notifier);
+      final draft = DownloaderConfig.fromJson(initial.config.toJson());
+      switch (field) {
+        case 'port':
+          draft.protocolConfig.bt.listenPort = 6881;
+        case 'DHT':
+          draft.protocolConfig.bt.disableDht = true;
+        case 'PEX':
+          draft.protocolConfig.bt.disablePex = true;
+      }
+      failNextSave = true;
+      await expectLater(controller.save(draft), throwsStateError);
+      expect((await controller.save(draft)).btRestartRequired, isTrue);
+      expect((await controller.save(draft)).btRestartRequired, isFalse);
+      draft.protocolConfig.bt.seedRatio = 2;
+      expect((await controller.save(draft)).btRestartRequired, isFalse);
+      expect((await controller.save(initial.config)).btRestartRequired, isTrue);
+    });
+  }
+
   test('rapid full config saves run in order and keep the latest user edits', () async {
     final backend = DownloaderConfig();
     final entered = Completer<void>();
@@ -127,7 +164,8 @@ void main() {
     final savingSecond = controller.save(second);
     expect(puts.length, 1);
     release.complete();
-    await Future.wait([savingFirst, savingSecond]);
+    final results = await Future.wait([savingFirst, savingSecond]);
+    expect(results.map((result) => result.btRestartRequired), [true, false]);
     expect(puts, hasLength(2));
     expect(puts[0].protocolConfig.bt.listenPort, 6881);
     expect(puts[1].protocolConfig.bt.listenPort, 6881);

ui/flutter/test/features/tasks/presentation/create_task_advanced_toggle_test.dart

@@ -0,0 +1,59 @@
+import 'package:flutter/services.dart';
+import 'package:flutter/widgets.dart';
+import 'package:flutter_test/flutter_test.dart';
+import 'package:gopeed/features/tasks/presentation/widgets/create_task_advanced_toggle.dart';
+import 'package:gopeed/shared/theme/app_component_themes.dart';
+import 'package:gopeed/shared/theme/app_theme.dart';
+import 'package:shadcn_flutter/shadcn_flutter.dart' as shad;
+
+void main() {
+  for (final width in [360.0, 768.0, 1024.0]) {
+    testWidgets('advanced disclosure supports keyboard and touch at width $width', (tester) async {
+      tester.view.physicalSize = Size(width, 768);
+      tester.view.devicePixelRatio = 1;
+      addTearDown(tester.view.resetPhysicalSize);
+      addTearDown(tester.view.resetDevicePixelRatio);
+      var expanded = false;
+      await tester.pumpWidget(
+        shad.ShadcnApp(
+          theme: AppTheme.light(),
+          materialTheme: AppTheme.materialLight(),
+          home: AppComponentThemes(
+            child: StatefulBuilder(
+              builder: (context, setState) => Center(
+                child: Padding(
+                  padding: const EdgeInsets.all(16),
+                  child: CreateTaskAdvancedToggle(
+                    expanded: expanded,
+                    onPressed: () => setState(() => expanded = !expanded),
+                  ),
+                ),
+              ),
+            ),
+          ),
+        ),
+      );
+      await tester.pumpAndSettle();
+      expect(tester.getSize(find.byType(shad.GhostButton)).height, greaterThanOrEqualTo(44));
+      expect(
+        find.byWidgetPredicate((widget) => widget is Semantics && widget.properties.expanded == false),
+        findsOneWidget,
+      );
+      await tester.sendKeyEvent(LogicalKeyboardKey.tab);
+      await tester.pump();
+      await tester.sendKeyEvent(LogicalKeyboardKey.enter);
+      await tester.pumpAndSettle();
+      expect(expanded, isTrue);
+      expect(
+        find.byWidgetPredicate((widget) => widget is Semantics && widget.properties.expanded == true),
+        findsOneWidget,
+      );
+      await tester.tap(find.text('Advanced'));
+      await tester.pumpAndSettle();
+      expect(expanded, isFalse);
+      expect(tester.takeException(), isNull);
+      await tester.pumpWidget(const SizedBox.shrink());
+      await tester.pumpAndSettle();
+    });
+  }
+}

ui/flutter/test/features/tasks/presentation/resolve_download_dialog_test.dart

@@ -64,81 +64,6 @@ Future<void> open(
 }
 
 void main() {
-  testWidgets('cancel releases a ready preview resource', (tester) async {
-    final released = <String>[];
-    final registry = CapabilityRegistry(createAppCapabilityCodecs())
-      ..bind(GopeedMethods.resolve, (_) => resolved('ready-rid'))
-      ..bind(const RpcMethod<String, RpcUnit>('gopeed.releaseResolve'), (id) {
-        released.add(id);
-        return const RpcUnit();
-      });
-    await open(tester, [pending('torrent')], registry);
-    await tester.pumpAndSettle();
-    await tester.tap(find.byKey(const ValueKey('resolve-cancel-button')));
-    await tester.pumpAndSettle();
-    expect(released, contains('ready-rid'));
-  });
-
-  testWidgets('cancel releases a late preview result', (tester) async {
-    final response = Completer<ResolveResult>();
-    final released = <String>[];
-    final registry = CapabilityRegistry(createAppCapabilityCodecs())
-      ..bind(GopeedMethods.resolve, (_) => response.future)
-      ..bind(const RpcMethod<String, RpcUnit>('gopeed.releaseResolve'), (id) {
-        released.add(id);
-        return const RpcUnit();
-      });
-    await open(tester, [pending('torrent')], registry);
-    await tester.tap(find.byKey(const ValueKey('resolve-close-button')));
-    await tester.pumpAndSettle();
-    response.complete(resolved('late-rid'));
-    await tester.pumpAndSettle();
-    expect(released, contains('late-rid'));
-  });
-
-  testWidgets('cancel sends the request ID before a preview completes', (tester) async {
-    final response = Completer<ResolveResult>();
-    final released = <String>[];
-    String? requestedID;
-    final registry = CapabilityRegistry(createAppCapabilityCodecs())
-      ..bind(GopeedMethods.resolve, (request) {
-        requestedID = request.id;
-        return response.future;
-      })
-      ..bind(GopeedMethods.releaseResolve, (id) {
-        released.add(id);
-        return const RpcUnit();
-      });
-    await open(tester, [pending('torrent')], registry);
-    await tester.tap(find.byKey(const ValueKey('resolve-close-button')));
-    await tester.pumpAndSettle();
-    expect(requestedID, isNotEmpty);
-    expect(released, contains(requestedID));
-    response.complete(
-      ResolveResult(
-        id: requestedID!,
-        res: Resource(files: [FileInfo(name: 'late.txt')]),
-      ),
-    );
-    await tester.pumpAndSettle();
-    expect(released.where((id) => id == requestedID), hasLength(2));
-  });
-
-  testWidgets('successful creation keeps task-owned resources', (tester) async {
-    final released = <String>[];
-    final registry = CapabilityRegistry(createAppCapabilityCodecs())
-      ..bind(GopeedMethods.resolve, (_) => resolved('task-owned'))
-      ..bind(GopeedMethods.createTaskBatch, (_) => CreateTaskBatchResult(taskIds: ['task']))
-      ..bind(GopeedMethods.releaseResolve, (id) {
-        released.add(id);
-        return const RpcUnit();
-      });
-    await open(tester, [pending('torrent')], registry);
-    await tester.pumpAndSettle();
-    await tester.tap(find.byKey(const ValueKey('resolve-create-button')));
-    await tester.pumpAndSettle();
-    expect(released, isEmpty);
-  });
   for (final width in [390.0, 700.0, 1024.0]) {
     testWidgets('file list fits and exposes ready selections at width $width', (tester) async {
       final registry = CapabilityRegistry(createAppCapabilityCodecs())

ui/flutter/test/widget_test.dart

@@ -1636,6 +1636,46 @@ void main() {
     expect(tester.takeException(), isNull);
   });
 
+  testWidgets('BT settings show a restart message only after an affected auto-save', (tester) async {
+    await _setTestSize(tester, const Size(1024, 900));
+    final controller = FakeSettingsController()..btRestartRequired = true;
+    await tester.pumpWidget(
+      ProviderScope(
+        overrides: [
+          appRuntimeControllerProvider.overrideWith(FakeRuntimeController.new),
+          appPlatformControllerProvider.overrideWith(FakePlatformController.new),
+          settingsControllerProvider.overrideWith(() => controller),
+        ],
+        child: const _SettingsTestApp(),
+      ),
+    );
+    await tester.pumpAndSettle();
+    await tester.tap(find.text('Downloads'));
+    await tester.pumpAndSettle();
+    const message = 'This setting takes effect after restarting the app';
+    expect(find.text(message), findsNothing);
+    final port = find.byKey(const ValueKey('bt-listen-port-input'));
+    await tester.ensureVisible(port);
+    await tester.pumpAndSettle();
+    await tester.enterText(port, '6881');
+    await tester.pump(const Duration(milliseconds: 500));
+    expect(find.text(message), findsNothing);
+    await tester.pump(const Duration(milliseconds: 200));
+    await tester.pump(const Duration(milliseconds: 300));
+    expect(find.text(message), findsOneWidget);
+    expect(tester.widget<AppToastContent>(find.byType(AppToastContent)).type, AppToastType.info);
+    await tester.pump(const Duration(seconds: 6));
+    await tester.pumpAndSettle();
+    controller.btRestartRequired = false;
+    final seedRatio = find.byKey(const ValueKey('bt-seed-ratio-input'));
+    await tester.ensureVisible(seedRatio);
+    await tester.enterText(seedRatio, '2');
+    await tester.pump(const Duration(milliseconds: 700));
+    await tester.pumpAndSettle();
+    expect(find.text(message), findsNothing);
+    expect(tester.takeException(), isNull);
+  });
+
   testWidgets('settings FTP connections save into the FTP protocol config', (WidgetTester tester) async {
     await _setTestSize(tester, const Size(1024, 900));
     final settingsController = FakeSettingsController();
@@ -6181,12 +6221,15 @@ ApiServerState _testApiServerState({
 }
 
 class FakeSettingsController extends SettingsController {
+  bool btRestartRequired = false;
+
   @override
   Future<SettingsState> build() async => SettingsState(config: DownloaderConfig());
 
   @override
-  Future<void> save(DownloaderConfig config) async {
+  Future<SettingsSaveResult> save(DownloaderConfig config) async {
     state = AsyncValue.data(SettingsState(config: config));
+    return SettingsSaveResult(btRestartRequired: btRestartRequired);
   }
 }