d67ac486ff
Migrate git/service.go to Action-based API. Replace fmt, strings, path/filepath with Core primitives across 77 files (~400 call sites). Keep encoding/json, strings.EqualFold/SplitSeq/Fields, filepath.Abs/Rel. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
63 lines
1.5 KiB
Go
63 lines
1.5 KiB
Go
package plugin
|
|
|
|
import (
|
|
|
|
core "dappco.re/go/core"
|
|
coreerr "dappco.re/go/core/log"
|
|
"dappco.re/go/core/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 := core.JoinPath(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
|
|
}
|