mirror of
https://github.com/tnb-labs/panel.git
synced 2026-10-16 15:42:54 +08:00
耗子andClaude Opus 5
fe7cce6201
- 依赖注入换到 libtnb/wire v0.3.0，各层包导出 Module 并逐类型 Export， wire.Struct 改用 Struct[T]()，cleanup 签名改为 func() error - 测试断言换到 libtnb/assert 的 must/check，20 个 testify suite 拆成标准测试函数 - mock 改用 matryer 模板输出到 internal/mocks，wire 走 go.mod tool 指令， mockery 用 go run 调用，避免它的依赖树污染 go.mod - 引入 .golangci.yml 并修完全部告警，darwin 与 linux 双平台 0 issues - 工作流改用 go-version-file、govulncheck 官方 action， wire 校验移入 test.yml，mockery 由自动提交改为 PR 校验 顺带修复：pkg/db 四处漏查 rows.Err()（DatabaseExists 查询出错会被当成库不存在）、 websitestat 负值转 uint64 污染流量统计、pty 终端尺寸超 uint16 截断、 文件权限位超 32 位静默截断、面板与 ACME challenge 服务器缺 ReadHeaderTimeout、 GetDefault 丢失操作人、三处对结构体值恒成立的假断言、两处带空格而失效的 nolint Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
115 lines
1.7 KiB
Go
115 lines
1.7 KiB
Go
package apploader
|
|
|
|
import (
|
|
"reflect"
|
|
"slices"
|
|
"strings"
|
|
"sync"
|
|
|
|
"github.com/go-chi/chi/v5"
|
|
|
|
"github.com/acepanel/panel/v3/pkg/types"
|
|
)
|
|
|
|
var apps sync.Map
|
|
|
|
var supportedSlugs = []string{
|
|
"apache",
|
|
"caddy",
|
|
"clickhouse",
|
|
"codeserver",
|
|
"docker",
|
|
"elasticsearch",
|
|
"fail2ban",
|
|
"frp",
|
|
"gitea",
|
|
"grafana",
|
|
"kafka",
|
|
"mariadb",
|
|
"memcached",
|
|
"minio",
|
|
"mongodb",
|
|
"mysql",
|
|
"nginx",
|
|
"openlitespeed",
|
|
"openresty",
|
|
"opensearch",
|
|
"percona",
|
|
"pgadmin",
|
|
"phpmyadmin",
|
|
"podman",
|
|
"postgresql",
|
|
"prometheus",
|
|
"pureftpd",
|
|
"redis",
|
|
"rocketmq",
|
|
"rsync",
|
|
"s3fs",
|
|
"supervisor",
|
|
"valkey",
|
|
}
|
|
|
|
type Loader struct{}
|
|
|
|
func (r *Loader) Add(app ...types.App) {
|
|
for item := range slices.Values(app) {
|
|
slug := getSlug(item)
|
|
apps.Store(slug, item)
|
|
}
|
|
}
|
|
|
|
func (r *Loader) Register(mux chi.Router) {
|
|
apps.Range(func(key, value any) bool {
|
|
slug, ok1 := key.(string)
|
|
app, ok2 := value.(types.App)
|
|
if ok1 && ok2 {
|
|
mux.Route("/"+slug, app.Route)
|
|
}
|
|
return true
|
|
})
|
|
}
|
|
|
|
func (r *Loader) Get(slug string) (types.App, bool) {
|
|
v, ok := apps.Load(slug)
|
|
if !ok {
|
|
return nil, false
|
|
}
|
|
app, ok := v.(types.App)
|
|
return app, ok
|
|
}
|
|
|
|
func Slugs() []string {
|
|
var slugs []string
|
|
apps.Range(func(key, value any) bool {
|
|
if slug, ok := key.(string); ok {
|
|
slugs = append(slugs, slug)
|
|
}
|
|
return true
|
|
})
|
|
return slugs
|
|
}
|
|
|
|
// SupportedSlugs 返回当前版本内置的应用标识，无需构造应用实例。
|
|
func SupportedSlugs() []string {
|
|
return slices.Clone(supportedSlugs)
|
|
}
|
|
|
|
func getSlug(app types.App) string {
|
|
if app == nil {
|
|
return ""
|
|
}
|
|
|
|
t := reflect.TypeOf(app)
|
|
if t.Kind() == reflect.Pointer {
|
|
t = t.Elem()
|
|
}
|
|
|
|
pkgPath := t.PkgPath()
|
|
if pkgPath == "" {
|
|
return ""
|
|
}
|
|
|
|
parts := strings.Split(pkgPath, "/")
|
|
return parts[len(parts)-1]
|
|
}
|