feat(strm): add driver-level sign expiry and rotate action

- add SignExpireHours for STRM-specific sign duration

- add RotateSignNow to trigger immediate local STRM rewrite

- auto reset rotate flag after scheduling background rotation

Author: okatu-loli

drivers/strm/driver.go

@@ -11,6 +11,8 @@ import (
 	"github.com/alist-org/alist/v3/internal/errs"
 	"github.com/alist-org/alist/v3/internal/fs"
 	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/internal/op"
+	log "github.com/sirupsen/logrus"
 )
 
 type Strm struct {
@@ -70,6 +72,20 @@ func (d *Strm) Init(ctx context.Context) error {
 	if d.SaveLocalMode == "" {
 		d.SaveLocalMode = SaveLocalInsertMode
 	}
+	if d.SignExpireHours < 0 {
+		d.SignExpireHours = 0
+	}
+	if d.RotateSignNow {
+		d.RotateSignNow = false
+		op.MustSaveDriverStorage(d)
+		if d.SaveStrmToLocal && strings.TrimSpace(d.SaveStrmLocalPath) != "" {
+			go func() {
+				log.Infof("strm: start rotating signs for [%s]", d.MountPath)
+				d.rotateAllLocal(context.Background())
+				log.Infof("strm: finished rotating signs for [%s]", d.MountPath)
+			}()
+		}
+	}
 	return nil
 }
 
@@ -159,6 +175,36 @@ func (d *Strm) listVirtualRoots() []model.Obj {
 	return objs
 }
 
+func (d *Strm) rotateAllLocal(ctx context.Context) {
+	for alias, roots := range d.aliases {
+		virtualRoot := "/"
+		if !d.autoFlatten {
+			virtualRoot = "/" + alias
+		}
+		for _, realRoot := range roots {
+			d.walkAndSync(ctx, virtualRoot, realRoot)
+		}
+	}
+}
+
+func (d *Strm) walkAndSync(ctx context.Context, virtualDir, realDir string) {
+	objs, err := fs.List(ctx, realDir, &fs.ListArgs{NoLog: true, Refresh: true})
+	if err != nil {
+		log.Warnf("strm: rotate list failed %s: %v", realDir, err)
+		return
+	}
+	mapped := d.mapListedObjects(ctx, realDir, objs)
+	d.syncLocalDirWithMode(ctx, virtualDir, mapped, SaveLocalUpdateMode)
+	for _, obj := range objs {
+		if !obj.IsDir() {
+			continue
+		}
+		childVirtual := stdpath.Join(virtualDir, obj.GetName())
+		childReal := stdpath.Join(realDir, obj.GetName())
+		d.walkAndSync(ctx, childVirtual, childReal)
+	}
+}
+
 func (d *Strm) mapListedObjects(ctx context.Context, realDir string, listed []model.Obj) []model.Obj {
 	ret := make([]model.Obj, 0, len(listed))
 	for _, obj := range listed {

drivers/strm/meta.go

@@ -20,6 +20,8 @@ type Addition struct {
 	EncodePath        bool   `json:"encodePath" default:"true" required:"true" help:"Encode path in strm content"`
 	WithoutUrl        bool   `json:"withoutUrl" default:"false" help:"Generate path-only strm content"`
 	WithSign          bool   `json:"withSign" default:"false" help:"Append sign query to generated URL"`
+	SignExpireHours   int    `json:"SignExpireHours" type:"number" default:"0" help:"Driver-level sign expiration in hours. 0 uses global link_expiration"`
+	RotateSignNow     bool   `json:"RotateSignNow" type:"bool" default:"false" help:"Set true and save to rotate signs now (rewrite local STRM), then auto reset to false"`
 	SaveStrmToLocal   bool   `json:"SaveStrmToLocal" default:"false" help:"Save generated files to local disk"`
 	SaveStrmLocalPath string `json:"SaveStrmLocalPath" type:"text" help:"Local path for generated files"`
 	SaveLocalMode     string `json:"SaveLocalMode" type:"select" help:"Local save mode" options:"insert,update,sync" default:"insert"`

drivers/strm/util.go

@@ -11,6 +11,7 @@ import (
 	"path/filepath"
 	"sort"
 	"strings"
+	"time"
 
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/internal/fs"
@@ -128,7 +129,7 @@ func (d *Strm) buildStrmLine(ctx context.Context, realPath string) string {
 		if strings.Contains(pathPart, "?") {
 			sep = "&"
 		}
-		pathPart += sep + "sign=" + sign.Sign(realPath)
+		pathPart += sep + "sign=" + d.generateSign(realPath)
 	}
 	joined := stdpath.Join(d.normalizedPrefix, pathPart)
 	if !strings.HasPrefix(joined, "/") {
@@ -170,13 +171,17 @@ func (d *Strm) linkRealFile(ctx context.Context, realPath string, args model.Lin
 		if api == "" {
 			api = common.GetApiUrl(nil)
 		}
-		return &model.Link{URL: fmt.Sprintf("%s/p%s?sign=%s", api, utils.EncodePath(realPath, true), sign.Sign(realPath))}, nil
+		return &model.Link{URL: fmt.Sprintf("%s/p%s?sign=%s", api, utils.EncodePath(realPath, true), d.generateSign(realPath))}, nil
 	}
 	link, _, linkErr := op.Link(ctx, storage, actualPath, args)
 	return link, linkErr
 }
 
 func (d *Strm) syncLocalDir(ctx context.Context, virtualDir string, objs []model.Obj) {
+	d.syncLocalDirWithMode(ctx, virtualDir, objs, d.normalizedMode)
+}
+
+func (d *Strm) syncLocalDirWithMode(ctx context.Context, virtualDir string, objs []model.Obj, mode string) {
 	if !d.SaveStrmToLocal || strings.TrimSpace(d.SaveStrmLocalPath) == "" {
 		return
 	}
@@ -204,12 +209,12 @@ func (d *Strm) syncLocalDir(ctx context.Context, virtualDir string, objs []model
 			log.Warnf("strm: build local payload failed %s: %v", localPath, err)
 			continue
 		}
-		if err = d.writeLocal(localPath, payload); err != nil {
+		if err = d.writeLocal(localPath, payload, mode); err != nil {
 			log.Warnf("strm: write local failed %s: %v", localPath, err)
 		}
 	}
 
-	if d.normalizedMode == SaveLocalSyncMode {
+	if mode == SaveLocalSyncMode {
 		d.syncDeleteExtras(localDir, expected)
 	}
 }
@@ -259,19 +264,19 @@ func readLinkBytes(ctx context.Context, link *model.Link) ([]byte, error) {
 	return io.ReadAll(res.RawBody())
 }
 
-func (d *Strm) writeLocal(path string, payload []byte) error {
-	if d.normalizedMode == SaveLocalInsertMode && utils.Exists(path) {
+func (d *Strm) writeLocal(path string, payload []byte, mode string) error {
+	if mode == SaveLocalInsertMode && utils.Exists(path) {
 		return nil
 	}
 	if st, err := os.Stat(path); err == nil && st.IsDir() {
-		if d.normalizedMode != SaveLocalSyncMode {
+		if mode != SaveLocalSyncMode {
 			return nil
 		}
 		if err = os.RemoveAll(path); err != nil {
 			return err
 		}
 	}
-	if d.normalizedMode != SaveLocalInsertMode {
+	if mode != SaveLocalInsertMode {
 		if old, err := os.ReadFile(path); err == nil {
 			if bytes.Equal(old, payload) {
 				return nil
@@ -303,3 +308,10 @@ func (d *Strm) syncDeleteExtras(localDir string, expected map[string]bool) {
 		}
 	}
 }
+
+func (d *Strm) generateSign(path string) string {
+	if d.SignExpireHours > 0 {
+		return sign.WithDuration(path, time.Duration(d.SignExpireHours)*time.Hour)
+	}
+	return sign.Sign(path)
+}