ef5c83c04e
- Delete pkg/io/ entirely (all consumers now use go-io)
- Delete pkg/log/{errors.go,log.go} duplicates (now in go-log)
- Rewrite pkg/log/log.go as thin re-export layer over go-log
- Keep pkg/log/{service.go,rotation.go} (framework/go-io deps)
- Swap internal pkg/ imports to go-io/go-log across ~30 files
Co-Authored-By: Virgil <virgil@lethean.io>
63 lines
1.5 KiB
Go
63 lines
1.5 KiB
Go
package plugin
|
|
|
|
import (
|
|
"path/filepath"
|
|
|
|
coreerr "forge.lthn.ai/core/go-log"
|
|
"forge.lthn.ai/core/go-io"
|
|
)
|
|
|
|
// Loader loads plugins from the filesystem.
|
|
type Loader struct {
|
|
medium io.Medium
|
|
baseDir string
|
|
}
|
|
|
|
// NewLoader creates a new plugin loader.
|
|
func NewLoader(m io.Medium, baseDir string) *Loader {
|
|
return &Loader{
|
|
medium: m,
|
|
baseDir: baseDir,
|
|
}
|
|
}
|
|
|
|
// Discover finds all plugin directories under baseDir and returns their manifests.
|
|
// Directories without a valid plugin.json are silently skipped.
|
|
func (l *Loader) Discover() ([]*Manifest, error) {
|
|
entries, err := l.medium.List(l.baseDir)
|
|
if err != nil {
|
|
return nil, coreerr.E("plugin.Loader.Discover", "failed to list plugin directory", err)
|
|
}
|
|
|
|
var manifests []*Manifest
|
|
for _, entry := range entries {
|
|
if !entry.IsDir() {
|
|
continue
|
|
}
|
|
|
|
manifest, err := l.LoadPlugin(entry.Name())
|
|
if err != nil {
|
|
// Skip directories without valid manifests
|
|
continue
|
|
}
|
|
|
|
manifests = append(manifests, manifest)
|
|
}
|
|
|
|
return manifests, nil
|
|
}
|
|
|
|
// LoadPlugin loads a single plugin's manifest by name.
|
|
func (l *Loader) LoadPlugin(name string) (*Manifest, error) {
|
|
manifestPath := filepath.Join(l.baseDir, name, "plugin.json")
|
|
manifest, err := LoadManifest(l.medium, manifestPath)
|
|
if err != nil {
|
|
return nil, coreerr.E("plugin.Loader.LoadPlugin", "failed to load plugin: "+name, err)
|
|
}
|
|
|
|
if err := manifest.Validate(); err != nil {
|
|
return nil, coreerr.E("plugin.Loader.LoadPlugin", "invalid plugin manifest: "+name, err)
|
|
}
|
|
|
|
return manifest, nil
|
|
}
|