102 lines
2.1 KiB
Go
102 lines
2.1 KiB
Go
|
package app
|
||
|
|
||
|
import (
|
||
|
"context"
|
||
|
"path/filepath"
|
||
|
|
||
|
"gitlab.com/wpetit/goweb/logger"
|
||
|
"gopkg.in/yaml.v2"
|
||
|
|
||
|
"forge.cadoles.com/arcad/edge/pkg/bundle"
|
||
|
"github.com/pkg/errors"
|
||
|
)
|
||
|
|
||
|
type FilesystemLoader struct {
|
||
|
searchPatterns []string
|
||
|
}
|
||
|
|
||
|
type LoadedApp struct {
|
||
|
App *App
|
||
|
Bundle bundle.Bundle
|
||
|
}
|
||
|
|
||
|
func (l *FilesystemLoader) Load(ctx context.Context) ([]*LoadedApp, error) {
|
||
|
apps := make([]*LoadedApp, 0)
|
||
|
|
||
|
for _, seachPattern := range l.searchPatterns {
|
||
|
absSearchPattern, err := filepath.Abs(seachPattern)
|
||
|
if err != nil {
|
||
|
return nil, errors.Wrapf(err, "could not generate absolute path for '%s'", seachPattern)
|
||
|
}
|
||
|
|
||
|
logger.Debug(ctx, "searching apps in filesystem", logger.F("searchPattern", absSearchPattern))
|
||
|
|
||
|
files, err := filepath.Glob(absSearchPattern)
|
||
|
if err != nil {
|
||
|
return nil, errors.Wrapf(err, "could not search files with pattern '%s'", absSearchPattern)
|
||
|
}
|
||
|
|
||
|
for _, f := range files {
|
||
|
loopCtx := logger.With(ctx, logger.F("file", f))
|
||
|
|
||
|
logger.Debug(loopCtx, "found app bundle")
|
||
|
|
||
|
b, err := bundle.FromPath(f)
|
||
|
if err != nil {
|
||
|
logger.Error(loopCtx, "could not load bundle", logger.E(errors.WithStack(err)))
|
||
|
|
||
|
continue
|
||
|
}
|
||
|
|
||
|
logger.Debug(loopCtx, "loading app manifest")
|
||
|
|
||
|
appManifest, err := LoadAppManifest(b)
|
||
|
if err != nil {
|
||
|
logger.Error(loopCtx, "could not load app manifest", logger.E(errors.WithStack(err)))
|
||
|
|
||
|
continue
|
||
|
}
|
||
|
|
||
|
g := &App{
|
||
|
ID: appManifest.ID,
|
||
|
Manifest: appManifest,
|
||
|
}
|
||
|
|
||
|
apps = append(apps, &LoadedApp{
|
||
|
App: g,
|
||
|
Bundle: b,
|
||
|
})
|
||
|
}
|
||
|
}
|
||
|
|
||
|
return apps, nil
|
||
|
}
|
||
|
|
||
|
func NewFilesystemLoader(searchPatterns ...string) *FilesystemLoader {
|
||
|
return &FilesystemLoader{
|
||
|
searchPatterns: searchPatterns,
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func LoadAppManifest(b bundle.Bundle) (*Manifest, error) {
|
||
|
reader, _, err := b.File("arcad.yml")
|
||
|
if err != nil {
|
||
|
return nil, errors.Wrap(err, "could not read arcad.yml")
|
||
|
}
|
||
|
|
||
|
defer func() {
|
||
|
if err := reader.Close(); err != nil {
|
||
|
panic(errors.WithStack(err))
|
||
|
}
|
||
|
}()
|
||
|
|
||
|
manifest := &Manifest{}
|
||
|
|
||
|
decoder := yaml.NewDecoder(reader)
|
||
|
if err := decoder.Decode(manifest); err != nil {
|
||
|
return nil, errors.Wrap(err, "could not decode arcad.yml")
|
||
|
}
|
||
|
|
||
|
return manifest, nil
|
||
|
}
|