feat: Add Plugin Support

cmd/common.go

@@ -17,6 +17,7 @@ func Init() {
 	bootstrap.Log()
 	bootstrap.InitDB()
 	data.InitData()
+	bootstrap.InitPlugins()
 	bootstrap.InitStreamLimit()
 	bootstrap.InitIndex()
 	bootstrap.InitUpgradePatch()

go.mod

@@ -9,6 +9,7 @@ require (
 	github.com/OpenListTeam/sftpd-openlist v1.0.1
 	github.com/OpenListTeam/tache v0.2.0
 	github.com/OpenListTeam/times v0.1.0
+	github.com/OpenListTeam/wazero-wasip2 v0.0.0-20251015145605-cd3a2c9131d9
 	github.com/OpenListTeam/wopan-sdk-go v0.1.5
 	github.com/ProtonMail/go-crypto v1.3.0
 	github.com/SheltonZhu/115driver v1.1.1
@@ -63,6 +64,7 @@ require (
 	github.com/stretchr/testify v1.10.0
 	github.com/t3rm1n4l/go-mega v0.0.0-20241213151442-a19cff0ec7b5
 	github.com/tchap/go-patricia/v2 v2.3.3
+	github.com/tetratelabs/wazero v1.9.0
 	github.com/u2takey/ffmpeg-go v0.5.0
 	github.com/upyun/go-sdk/v3 v3.0.4
 	github.com/winfsp/cgofuse v1.6.0
@@ -177,7 +179,7 @@ require (
 	github.com/boombuler/barcode v1.0.1-0.20190219062509-6c824513bacc // indirect
 	github.com/bytedance/sonic v1.13.3 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
-	github.com/coreos/go-semver v0.3.1 // indirect
+	github.com/coreos/go-semver v0.3.1
 	github.com/crackcomm/go-gitignore v0.0.0-20170627025303-887ab5e44cc3 // indirect
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
 	github.com/decred/dcrd/dcrec/secp256k1/v4 v4.1.0 // indirect
@@ -283,3 +285,5 @@ require (
 )
 
 // replace github.com/OpenListTeam/115-sdk-go => ../../OpenListTeam/115-sdk-go
+
+replace google.golang.org/genproto => google.golang.org/genproto/googleapis/rpc v0.0.0-20250603155806-513f23925822

go.sum

@@ -51,6 +51,8 @@ github.com/OpenListTeam/tache v0.2.0 h1:Q4MjuyECn0CZCf1ZF91JaVaZTaps1mOTAm8bFj8s
 github.com/OpenListTeam/tache v0.2.0/go.mod h1:qmnZ/VpY2DUlmjg3UoDeNFy/LRqrw0biN3hYEEGc/+A=
 github.com/OpenListTeam/times v0.1.0 h1:qknxw+qj5CYKgXAwydA102UEpPcpU8TYNGRmwRyPYpg=
 github.com/OpenListTeam/times v0.1.0/go.mod h1:Jx7qen5NCYzKk2w14YuvU48YYMcPa1P9a+EJePC15Pc=
+github.com/OpenListTeam/wazero-wasip2 v0.0.0-20251015145605-cd3a2c9131d9 h1:yddTD9Fxh6bLMLmG0hSR7Eh6XkoK0RMlE4N1e6/+Iy8=
+github.com/OpenListTeam/wazero-wasip2 v0.0.0-20251015145605-cd3a2c9131d9/go.mod h1:+BpydPG2cUQHYFwH3/lVmvXyMl/zxHW+XM+XTSzqu2Q=
 github.com/OpenListTeam/wopan-sdk-go v0.1.5 h1:iKKcVzIqBgtGDbn0QbdWrCazSGxXFmYFyrnFBG+U8dI=
 github.com/OpenListTeam/wopan-sdk-go v0.1.5/go.mod h1:otynv0CgSNUClPpUgZ44qCZGcMRe0dc83Pkk65xAunI=
 github.com/ProtonMail/go-crypto v1.3.0 h1:ILq8+Sf5If5DCpHQp4PbZdS1J7HDFRXz/+xKBiRGFrw=
@@ -654,6 +656,8 @@ github.com/taruti/bytepool v0.0.0-20160310082835-5e3a9ea56543 h1:6Y51mutOvRGRx6K
 github.com/taruti/bytepool v0.0.0-20160310082835-5e3a9ea56543/go.mod h1:jpwqYA8KUVEvSUJHkCXsnBRJCSKP1BMa81QZ6kvRpow=
 github.com/tchap/go-patricia/v2 v2.3.3 h1:xfNEsODumaEcCcY3gI0hYPZ/PcpVv5ju6RMAhgwZDDc=
 github.com/tchap/go-patricia/v2 v2.3.3/go.mod h1:VZRHKAb53DLaG+nA9EaYYiaEx6YztwDlLElMsnSHD4k=
+github.com/tetratelabs/wazero v1.9.0 h1:IcZ56OuxrtaEz8UYNRHBrUa9bYeX9oVY93KspZZBf/I=
+github.com/tetratelabs/wazero v1.9.0/go.mod h1:TSbcXCfFP0L2FGkRPxHphadXPjo1T6W+CseNNY7EkjM=
 github.com/tklauser/go-sysconf v0.3.15 h1:VE89k0criAymJ/Os65CSn1IXaol+1wrsFHEB8Ol49K4=
 github.com/tklauser/go-sysconf v0.3.15/go.mod h1:Dmjwr6tYFIseJw7a3dRLJfsHAMXZ3nEnL/aZY+0IuI4=
 github.com/tklauser/numcpus v0.10.0 h1:18njr6LDBk1zuna922MgdjQuJFjrdppsZG60sHGfjso=

internal/bootstrap/plugin.go

@@ -0,0 +1,22 @@
+// internal/bootstrap/plugin.go
+package bootstrap
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/OpenListTeam/OpenList/v4/internal/plugin"
+)
+
+// InitPlugins 初始化插件管理器
+func InitPlugins() {
+	// 2. 创建并初始化 Manager
+	// "data" 目录应从配置中获取
+	manager, err := plugin.NewManager(context.Background(), "data")
+	if err != nil {
+		// 在启动时，如果插件系统失败，应该 panic
+		panic(fmt.Sprintf("Failed to initialize plugin manager: %v", err))
+	}
+
+	plugin.PluginManager = manager
+}

internal/db/db.go

@@ -12,7 +12,7 @@ var db *gorm.DB
 
 func Init(d *gorm.DB) {
 	db = d
-	err := AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem), new(model.SearchNode), new(model.TaskItem), new(model.SSHPublicKey), new(model.SharingDB))
+	err := AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem), new(model.SearchNode), new(model.TaskItem), new(model.SSHPublicKey), new(model.SharingDB), new(model.Plugin))
 	if err != nil {
 		log.Fatalf("failed migrate database: %s", err.Error())
 	}

internal/db/plugin.go

@@ -0,0 +1,47 @@
+package db
+
+import (
+	"context"
+
+	"github.com/OpenListTeam/OpenList/v4/internal/model"
+	"gorm.io/gorm"
+)
+
+// CreatePlugin 在数据库中插入一条新的插件记录
+// 如果记录已存在，则会更新它 (Upsert)
+func CreatePlugin(ctx context.Context, plugin *model.Plugin) error {
+	return db.WithContext(ctx).Save(plugin).Error
+}
+
+// GetPluginByID 从数据库中根据 ID 查询单个插件
+func GetPluginByID(ctx context.Context, id string) (*model.Plugin, error) {
+	var plugin model.Plugin
+	err := db.WithContext(ctx).First(&plugin, "id = ?", id).Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil // 返回 nil, nil 表示未找到
+		}
+		return nil, err
+	}
+	return &plugin, nil
+}
+
+// GetAllPlugins 从数据库中获取所有已安装的插件
+func GetAllPlugins(ctx context.Context) ([]*model.Plugin, error) {
+	var plugins []*model.Plugin
+	err := db.WithContext(ctx).Find(&plugins).Error
+	return plugins, err
+}
+
+// DeletePluginByID 从数据库中根据 ID 删除一个插件
+func DeletePluginByID(ctx context.Context, id string) error {
+	return db.WithContext(ctx).Delete(&model.Plugin{}, "id = ?", id).Error
+}
+
+// UpdatePluginStatus 更新指定插件的状态和消息
+func UpdatePluginStatus(ctx context.Context, pluginID string, status model.PluginStatus, message string) error {
+	return db.WithContext(ctx).Model(&model.Plugin{}).Where("id = ?", pluginID).Updates(map[string]interface{}{
+		"status":  status,
+		"message": message,
+	}).Error
+}

internal/driver/item.go

@@ -19,6 +19,10 @@ type Info struct {
 	Config     Config `json:"config"`
 }
 
+type IGetItem interface {
+	GetItems() []Item
+}
+
 type IRootPath interface {
 	GetRootPath() string
 }

internal/model/plugin.go

@@ -0,0 +1,42 @@
+package model
+
+import "time"
+
+// PluginStatus 定义了插件的几种可能状态
+type PluginStatus string
+
+const (
+	// StatusActive 表示插件已成功加载并正在运行
+	StatusActive PluginStatus = "active"
+	// StatusInactive 表示插件已安装但未加载（例如，等待重启）
+	StatusInactive PluginStatus = "inactive"
+	// StatusError 表示插件在加载或运行时遇到错误
+	StatusError PluginStatus = "error"
+)
+
+type Plugin struct {
+	// 插件的唯一标识符，例如 "com.openlist.driver.s3"
+	// 这是主键
+	ID string `gorm:"primaryKey" json:"id"`
+
+	// --- 来自插件元数据 ---
+	Name        string `json:"name"`
+	Version     string `json:"version"`
+	Author      string `json:"author"`
+	Description string `gorm:"type:text" json:"description"`
+	IconURL     string `json:"icon_url"`
+
+	// --- 管理器需要的信息 ---
+	// 插件的下载源地址
+	SourceURL string `json:"source_url"`
+	// Wasm 文件在本地的存储路径
+	WasmPath string `json:"wasm_path"`
+
+	// 新增状态字段
+	Status  PluginStatus `gorm:"default:'inactive'" json:"status"`
+	Message string       `gorm:"type:text" json:"message"` // 用于存储错误信息
+
+	// --- GORM 自动管理字段 ---
+	CreatedAt time.Time `json:"-"`
+	UpdatedAt time.Time `json:"-"`
+}

internal/op/driver.go

@@ -15,12 +15,27 @@ type DriverConstructor func() driver.Driver
 var driverMap = map[string]DriverConstructor{}
 var driverInfoMap = map[string]driver.Info{}
 
-func RegisterDriver(driver DriverConstructor) {
+func RegisterDriver(driver DriverConstructor) error {
 	// log.Infof("register driver: [%s]", config.Name)
 	tempDriver := driver()
+	if tempDriver == nil {
+		return errors.New("register driver is null")
+	}
 	tempConfig := tempDriver.Config()
+
+	if driverMap[tempConfig.Name] != nil {
+		return errors.New("driver is registered")
+	}
 	registerDriverItems(tempConfig, tempDriver.GetAddition())
 	driverMap[tempConfig.Name] = driver
+	return nil
+}
+
+func UnRegisterDriver(driver DriverConstructor) {
+	if tempDriver := driver(); tempDriver != nil {
+		tempConfig := tempDriver.Config()
+		delete(driverMap, tempConfig.Name)
+	}
 }
 
 func GetDriver(name string) (DriverConstructor, error) {
@@ -45,12 +60,18 @@ func GetDriverInfoMap() map[string]driver.Info {
 
 func registerDriverItems(config driver.Config, addition driver.Additional) {
 	// log.Debugf("addition of %s: %+v", config.Name, addition)
-	tAddition := reflect.TypeOf(addition)
-	for tAddition.Kind() == reflect.Pointer {
-		tAddition = tAddition.Elem()
+	var additionalItems []driver.Item
+	if v, ok := addition.(driver.IGetItem); ok {
+		additionalItems = v.GetItems()
+	} else {
+		tAddition := reflect.TypeOf(addition)
+		for tAddition.Kind() == reflect.Pointer {
+			tAddition = tAddition.Elem()
+		}
+		additionalItems = getAdditionalItems(tAddition, config.DefaultRoot)
 	}
+
 	mainItems := getMainItems(config)
-	additionalItems := getAdditionalItems(tAddition, config.DefaultRoot)
 	driverInfoMap[config.Name] = driver.Info{
 		Common:     mainItems,
 		Additional: additionalItems,