2015-06-01 23:42:27 +00:00
|
|
|
package chrootarchive
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"io/ioutil"
|
|
|
|
"os"
|
|
|
|
"path/filepath"
|
|
|
|
|
2017-04-18 18:58:56 +00:00
|
|
|
"github.com/containers/pkg/archive"
|
|
|
|
"github.com/containers/pkg/longpath"
|
2015-06-01 23:42:27 +00:00
|
|
|
)
|
|
|
|
|
2015-07-30 20:04:36 +00:00
|
|
|
// applyLayerHandler parses a diff in the standard layer format from `layer`, and
|
2015-07-22 22:19:32 +00:00
|
|
|
// applies it to the directory `dest`. Returns the size in bytes of the
|
|
|
|
// contents of the layer.
|
2015-10-08 15:51:41 +00:00
|
|
|
func applyLayerHandler(dest string, layer archive.Reader, options *archive.TarOptions, decompress bool) (size int64, err error) {
|
2015-06-01 23:42:27 +00:00
|
|
|
dest = filepath.Clean(dest)
|
2015-08-10 22:21:30 +00:00
|
|
|
|
|
|
|
// Ensure it is a Windows-style volume path
|
2015-08-24 21:07:22 +00:00
|
|
|
dest = longpath.AddPrefix(dest)
|
2015-08-10 22:21:30 +00:00
|
|
|
|
2015-07-30 03:08:51 +00:00
|
|
|
if decompress {
|
|
|
|
decompressed, err := archive.DecompressStream(layer)
|
|
|
|
if err != nil {
|
|
|
|
return 0, err
|
|
|
|
}
|
|
|
|
defer decompressed.Close()
|
|
|
|
|
|
|
|
layer = decompressed
|
2015-06-01 23:42:27 +00:00
|
|
|
}
|
|
|
|
|
2017-01-12 19:00:28 +00:00
|
|
|
tmpDir, err := ioutil.TempDir(os.Getenv("temp"), "temp-storage-extract")
|
2015-06-01 23:42:27 +00:00
|
|
|
if err != nil {
|
2017-01-12 19:00:28 +00:00
|
|
|
return 0, fmt.Errorf("ApplyLayer failed to create temp-storage-extract under %s. %s", dest, err)
|
2015-06-01 23:42:27 +00:00
|
|
|
}
|
|
|
|
|
2015-10-08 15:51:41 +00:00
|
|
|
s, err := archive.UnpackLayer(dest, layer, nil)
|
2015-06-01 23:42:27 +00:00
|
|
|
os.RemoveAll(tmpDir)
|
|
|
|
if err != nil {
|
|
|
|
return 0, fmt.Errorf("ApplyLayer %s failed UnpackLayer to %s", err, dest)
|
|
|
|
}
|
|
|
|
|
|
|
|
return s, nil
|
|
|
|
}
|