mirror of
https://github.com/moby/moby.git
synced 2026-01-11 18:51:37 +00:00
fabe66322f
This function was deprecated in 54a556a5ef,
and the package is now internal to the daemon, so we can remove it.
Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
85 lines
1.9 KiB
Go
85 lines
1.9 KiB
Go
package remotecontext
|
|
|
|
import (
|
|
"encoding/hex"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/moby/moby/v2/daemon/builder"
|
|
"github.com/moby/moby/v2/pkg/pools"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
// NewLazySource creates a new LazyContext. LazyContext defines a hashed build
|
|
// context based on a root directory. Individual files are hashed first time
|
|
// they are asked. It is not safe to call methods of LazyContext concurrently.
|
|
func NewLazySource(root string) (builder.Source, error) {
|
|
return &lazySource{
|
|
root: root,
|
|
sums: make(map[string]string),
|
|
}, nil
|
|
}
|
|
|
|
type lazySource struct {
|
|
root string
|
|
sums map[string]string
|
|
}
|
|
|
|
func (c *lazySource) Root() string {
|
|
return c.root
|
|
}
|
|
|
|
func (c *lazySource) Close() error {
|
|
return nil
|
|
}
|
|
|
|
func (c *lazySource) Hash(path string) (string, error) {
|
|
cleanPath, fullPath, err := normalize(path, c.root)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
relPath, err := filepath.Rel(c.root, fullPath)
|
|
if err != nil {
|
|
return "", errors.WithStack(convertPathError(err, cleanPath))
|
|
}
|
|
|
|
fi, err := os.Lstat(fullPath)
|
|
if err != nil {
|
|
// Backwards compatibility: a missing file returns a path as hash.
|
|
// This is reached in the case of a broken symlink.
|
|
return relPath, nil
|
|
}
|
|
|
|
sum, ok := c.sums[relPath]
|
|
if !ok {
|
|
sum, err = c.prepareHash(relPath, fi)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
}
|
|
|
|
return sum, nil
|
|
}
|
|
|
|
func (c *lazySource) prepareHash(relPath string, fi os.FileInfo) (string, error) {
|
|
p := filepath.Join(c.root, relPath)
|
|
h, err := NewFileHash(p, relPath, fi)
|
|
if err != nil {
|
|
return "", errors.Wrapf(err, "failed to create hash for %s", relPath)
|
|
}
|
|
if fi.Mode().IsRegular() && fi.Size() > 0 {
|
|
f, err := os.Open(p)
|
|
if err != nil {
|
|
return "", errors.Wrapf(err, "failed to open %s", relPath)
|
|
}
|
|
defer f.Close()
|
|
if _, err := pools.Copy(h, f); err != nil {
|
|
return "", errors.Wrapf(err, "failed to copy file data for %s", relPath)
|
|
}
|
|
}
|
|
sum := hex.EncodeToString(h.Sum(nil))
|
|
c.sums[relPath] = sum
|
|
return sum, nil
|
|
}
|