feat(alias): support load balance

drivers/alias/meta.go

@@ -6,17 +6,15 @@ import (
 )
 
 type Addition struct {
-	// Usually one of two
-	// driver.RootPath
-	// define other
-	Paths               string `json:"paths" required:"true" type:"text"`
-	ProtectSameName     bool   `json:"protect_same_name" default:"true" required:"false" help:"Protects same-name files from Delete or Rename"`
-	ParallelWrite       bool   `json:"parallel_write" type:"bool" default:"false"`
-	DownloadConcurrency int    `json:"download_concurrency" default:"0" required:"false" type:"number" help:"Need to enable proxy"`
-	DownloadPartSize    int    `json:"download_part_size" default:"0" type:"number" required:"false" help:"Need to enable proxy. Unit: KB"`
-	Writable            bool   `json:"writable" type:"bool" default:"false"`
-	ProviderPassThrough bool   `json:"provider_pass_through" type:"bool" default:"false"`
-	DetailsPassThrough  bool   `json:"details_pass_through" type:"bool" default:"false"`
+	Paths                string `json:"paths" required:"true" type:"text"`
+	ReadConflictPolicy   string `json:"read_conflict_policy" type:"select" options:"first,random,all" default:"first"`
+	WriteConflictPolicy  string `json:"write_conflict_policy" type:"select" options:"disabled,first,deterministic,deterministic_or_all,all,all_strict" default:"disabled" help:"How the driver handles identical backend paths when renaming, removing, or making directories."`
+	PutConflictPolicy    string `json:"put_conflict_policy" type:"select" options:"disabled,first,deterministic,deterministic_or_all,all,all_strict,random,quota,quota_strict" default:"disabled" help:"How the driver handles identical backend paths when uploading, copying, moving, or decompressing."`
+	FileConsistencyCheck bool   `json:"file_consistency_check" type:"bool" default:"false"`
+	DownloadConcurrency  int    `json:"download_concurrency" default:"0" required:"false" type:"number" help:"Need to enable proxy"`
+	DownloadPartSize     int    `json:"download_part_size" default:"0" type:"number" required:"false" help:"Need to enable proxy. Unit: KB"`
+	ProviderPassThrough  bool   `json:"provider_pass_through" type:"bool" default:"false"`
+	DetailsPassThrough   bool   `json:"details_pass_through" type:"bool" default:"false"`
 }
 
 var config = driver.Config{
@@ -31,10 +29,6 @@ var config = driver.Config{
 
 func init() {
 	op.RegisterDriver(func() driver.Driver {
-		return &Alias{
-			Addition: Addition{
-				ProtectSameName: true,
-			},
-		}
+		return &Alias{}
 	})
 }

drivers/alias/types.go

@@ -1 +1,78 @@
 package alias
+
+import (
+	"time"
+
+	"github.com/OpenListTeam/OpenList/v4/internal/model"
+	"github.com/OpenListTeam/OpenList/v4/pkg/utils"
+	"github.com/pkg/errors"
+)
+
+const (
+	DisabledWP             = "disabled"
+	FirstRWP               = "first"
+	DeterministicWP        = "deterministic"
+	DeterministicOrAllWP   = "deterministic_or_all"
+	AllRWP                 = "all"
+	AllStrictWP            = "all_strict"
+	RandomBalancedRP       = "random"
+	BalancedByQuotaP       = "quota"
+	BalancedByQuotaStrictP = "quota_strict"
+)
+
+var (
+	ValidReadConflictPolicy  = []string{FirstRWP, RandomBalancedRP, AllRWP}
+	ValidWriteConflictPolicy = []string{DisabledWP, FirstRWP, DeterministicWP, DeterministicOrAllWP, AllRWP,
+		AllStrictWP}
+	ValidPutConflictPolicy = []string{DisabledWP, FirstRWP, DeterministicWP, DeterministicOrAllWP, AllRWP,
+		AllStrictWP, RandomBalancedRP, BalancedByQuotaP, BalancedByQuotaStrictP}
+)
+
+var (
+	ErrPathConflict     = errors.New("path conflict")
+	ErrSamePathLeak     = errors.New("leak some of same-name dirs")
+	ErrNoEnoughSpace    = errors.New("none of same-name dirs has enough space")
+	ErrNotEnoughSrcObjs = errors.New("cannot move fewer objs to more paths, please try copying")
+)
+
+type BalancedObjs []model.Obj
+
+func (b BalancedObjs) GetSize() int64 {
+	return b[0].GetSize()
+}
+
+func (b BalancedObjs) ModTime() time.Time {
+	return b[0].ModTime()
+}
+
+func (b BalancedObjs) CreateTime() time.Time {
+	return b[0].CreateTime()
+}
+
+func (b BalancedObjs) IsDir() bool {
+	return b[0].IsDir()
+}
+
+func (b BalancedObjs) GetHash() utils.HashInfo {
+	return b[0].GetHash()
+}
+
+func (b BalancedObjs) GetName() string {
+	return b[0].GetName()
+}
+
+func (b BalancedObjs) GetPath() string {
+	return b[0].GetPath()
+}
+
+func (b BalancedObjs) GetID() string {
+	return b[0].GetID()
+}
+
+func (b BalancedObjs) Unwrap() model.Obj {
+	return b[0]
+}
+
+var _ model.Obj = (BalancedObjs)(nil)
+
+type tempObj struct{ model.Object }