-
Notifications
You must be signed in to change notification settings - Fork 0
/
view.go
65 lines (57 loc) · 1.65 KB
/
view.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package project
import (
"strings"
"github.com/pkg/errors"
"admini.dev/admini/app/lib/schema"
"admini.dev/admini/app/source"
"admini.dev/admini/app/util"
)
type View struct {
Project *Project `json:"project"`
Sources source.Sources `json:"sources,omitempty"`
Schemata schema.Schemata `json:"schemata,omitempty"`
}
func (s *Service) LoadView(key string, logger util.Logger) (*View, error) {
if strings.HasPrefix(key, SourceProjectPrefix) {
return s.LoadSourceProject(strings.TrimPrefix(key, SourceProjectPrefix), logger)
}
p, err := s.LoadRequired(key, false, logger)
if err != nil {
return nil, err
}
src, err := s.sourcesFor(p, logger)
if err != nil {
return nil, err
}
sch, err := s.schemataFor(key, logger)
if err != nil {
return nil, err
}
return &View{Project: p, Sources: src, Schemata: sch}, nil
}
func (s *Service) schemataFor(key string, logger util.Logger) (schema.Schemata, error) {
p, err := s.LoadRequired(key, false, logger)
if err != nil {
return nil, errors.Wrapf(err, "can't load project [%s]", key)
}
ret := map[string]*schema.Schema{}
for _, sch := range p.Sources {
x, err := s.sources.LoadSchema(sch)
if err != nil {
return nil, errors.Wrapf(err, "can't load schema [%s] for project [%s]", sch, p.Key)
}
ret[sch] = x
}
return ret, nil
}
func (s *Service) sourcesFor(p *Project, logger util.Logger) (source.Sources, error) {
ret := make(source.Sources, 0, len(p.Sources))
for _, sch := range p.Sources {
x, err := s.sources.Load(sch, false, logger)
if err != nil {
return nil, errors.Wrapf(err, "can't load source [%s] for project [%s]", sch, p.Key)
}
ret = append(ret, x)
}
return ret, nil
}