package source import ( "errors" "io" "os" "path" "path/filepath" ) type Input interface { Files() []*File } type File struct { name string LogicalName string Contents io.Reader Section string Dir string } type Filesystem struct { files []*File Base string AvoidPaths []string } func (f *Filesystem) Files() []*File { if len(f.files) < 1 { f.captureFiles() } return f.files } var errMissingBaseDir = errors.New("source: missing base directory") func (f *Filesystem) add(name string, reader io.Reader) (err error) { if name, err = f.getRelativePath(name); err != nil { return err } dir, logical := path.Split(name) _, section := path.Split(path.Dir(name)) if section == "." { section = "" } f.files = append(f.files, &File{ name: name, LogicalName: logical, Contents: reader, Section: section, Dir: dir, }) return } func (f *Filesystem) getRelativePath(name string) (final string, err error) { if filepath.IsAbs(name) && f.Base == "" { return "", errMissingBaseDir } name = filepath.Clean(name) base := filepath.Clean(f.Base) name, err = filepath.Rel(base, name) if err != nil { return "", err } name = filepath.ToSlash(name) return name, nil } func (f *Filesystem) captureFiles() { walker := func(filePath string, fi os.FileInfo, err error) error { if err != nil { return nil } if fi.IsDir() { if f.avoid(filePath) { return filepath.SkipDir } return nil } else { if ignoreDotFile(filePath) { return nil } file, err := os.Open(filePath) if err != nil { return err } f.add(filePath, file) return nil } } filepath.Walk(f.Base, walker) } func (f *Filesystem) avoid(filePath string) bool { for _, avoid := range f.AvoidPaths { if avoid == filePath { return true } } return false } func ignoreDotFile(filePath string) bool { return filepath.Base(filePath)[0] == '.' }