This repository has been archived by the owner on Jun 24, 2019. It is now read-only.
forked from cloudfoundry/bosh-cli
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dir_reader.go
70 lines (52 loc) · 1.74 KB
/
dir_reader.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
66
67
68
69
70
package job
import (
"path/filepath"
bosherr "github.com/cloudfoundry/bosh-utils/errors"
boshsys "github.com/cloudfoundry/bosh-utils/system"
boshjobman "github.com/cloudfoundry/bosh-cli/release/job/manifest"
. "github.com/cloudfoundry/bosh-cli/release/resource"
)
type DirReaderImpl struct {
archiveFactory ArchiveFunc
fs boshsys.FileSystem
}
func NewDirReaderImpl(archiveFactory ArchiveFunc, fs boshsys.FileSystem) DirReaderImpl {
return DirReaderImpl{archiveFactory: archiveFactory, fs: fs}
}
func (r DirReaderImpl) Read(path string) (*Job, error) {
manifest, files, err := r.collectFiles(path)
if err != nil {
return nil, bosherr.WrapErrorf(err, "Collecting job files")
}
archive := r.archiveFactory(files, nil, nil)
fp, err := archive.Fingerprint()
if err != nil {
return nil, err
}
job := NewJob(NewResource(manifest.Name, fp, archive))
job.PackageNames = manifest.Packages
// Does not read all manifest values...
return job, nil
}
func (r DirReaderImpl) collectFiles(path string) (boshjobman.Manifest, []File, error) {
var files []File
specPath := filepath.Join(path, "spec")
manifest, err := boshjobman.NewManifestFromPath(specPath, r.fs)
if err != nil {
return boshjobman.Manifest{}, nil, err
}
// Note that job's spec file is included (unlike for a package)
// to capture differences in metadata of the job
specFile := NewFile(specPath, path)
specFile.RelativePath = "job.MF"
files = append(files, specFile)
monitPath := filepath.Join(path, "monit")
if r.fs.FileExists(monitPath) {
files = append(files, NewFile(monitPath, path))
}
for src, _ := range manifest.Templates {
srcPath := filepath.Join(path, "templates", src)
files = append(files, NewFile(srcPath, path))
}
return manifest, files, nil
}