mirror of
https://github.com/gohugoio/hugo.git
synced 2024-11-21 20:46:30 -05:00
1979f7d9c7
doesn't like this and shows an error when modifying a file in rapid succession.
121 lines
2 KiB
Go
121 lines
2 KiB
Go
package source
|
|
|
|
import (
|
|
"bytes"
|
|
"errors"
|
|
"io"
|
|
"io/ioutil"
|
|
"os"
|
|
"path"
|
|
"path/filepath"
|
|
"strings"
|
|
)
|
|
|
|
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
|
|
}
|
|
|
|
// section should be the first part of the path
|
|
dir, logical := path.Split(name)
|
|
parts := strings.Split(dir, "/")
|
|
section := parts[0]
|
|
|
|
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
|
|
}
|
|
data, err := ioutil.ReadFile(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
f.add(filePath, bytes.NewBuffer(data))
|
|
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] == '.'
|
|
}
|