2013-06-26 21:55:11 -04:00
|
|
|
package vagrant
|
|
|
|
|
|
|
|
import (
|
|
|
|
"archive/tar"
|
2013-06-27 13:51:13 -04:00
|
|
|
"bytes"
|
2013-06-26 21:55:11 -04:00
|
|
|
"compress/gzip"
|
|
|
|
"encoding/json"
|
2013-06-27 13:51:13 -04:00
|
|
|
"github.com/mitchellh/packer/packer"
|
2013-06-26 21:55:11 -04:00
|
|
|
"io"
|
2013-06-27 17:06:14 -04:00
|
|
|
"log"
|
2013-06-26 21:55:11 -04:00
|
|
|
"os"
|
|
|
|
"path/filepath"
|
2013-06-27 13:51:13 -04:00
|
|
|
"text/template"
|
2013-06-26 21:55:11 -04:00
|
|
|
)
|
|
|
|
|
2013-06-27 13:51:13 -04:00
|
|
|
// OutputPathTemplate is the structure that is availalable within the
|
|
|
|
// OutputPath variables.
|
|
|
|
type OutputPathTemplate struct {
|
|
|
|
ArtifactId string
|
2013-07-01 18:07:09 -04:00
|
|
|
BuildName string
|
2013-06-27 13:51:13 -04:00
|
|
|
Provider string
|
|
|
|
}
|
|
|
|
|
2013-06-26 21:55:11 -04:00
|
|
|
// DirToBox takes the directory and compresses it into a Vagrant-compatible
|
|
|
|
// box. This function does not perform checks to verify that dir is
|
|
|
|
// actually a proper box. This is an expected precondition.
|
|
|
|
func DirToBox(dst, dir string) error {
|
2013-06-27 17:06:14 -04:00
|
|
|
log.Printf("Turning dir into box: %s", dir)
|
2013-06-26 21:55:11 -04:00
|
|
|
dstF, err := os.Create(dst)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
defer dstF.Close()
|
|
|
|
|
|
|
|
gzipWriter := gzip.NewWriter(dstF)
|
|
|
|
defer gzipWriter.Close()
|
|
|
|
|
|
|
|
tarWriter := tar.NewWriter(gzipWriter)
|
|
|
|
defer tarWriter.Close()
|
|
|
|
|
|
|
|
// This is the walk func that tars each of the files in the dir
|
|
|
|
tarWalk := func(path string, info os.FileInfo, prevErr error) error {
|
2013-07-02 11:46:00 -04:00
|
|
|
// If there was a prior error, return it
|
|
|
|
if prevErr != nil {
|
|
|
|
return prevErr
|
|
|
|
}
|
|
|
|
|
2013-06-27 17:06:14 -04:00
|
|
|
// Skip directories
|
|
|
|
if info.IsDir() {
|
|
|
|
log.Printf("Skiping directory '%s' for box '%s'", path, dst)
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
log.Printf("Box add: '%s' to '%s'", path, dst)
|
2013-06-26 21:55:11 -04:00
|
|
|
f, err := os.Open(path)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
defer f.Close()
|
|
|
|
|
|
|
|
header, err := tar.FileInfoHeader(info, "")
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
// We have to set the Name explicitly because it is supposed to
|
|
|
|
// be a relative path to the root. Otherwise, the tar ends up
|
|
|
|
// being a bunch of files in the root, even if they're actually
|
|
|
|
// nested in a dir in the original "dir" param.
|
|
|
|
header.Name, err = filepath.Rel(dir, path)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := tarWriter.WriteHeader(header); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if _, err := io.Copy(tarWriter, f); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// Tar.gz everything up
|
|
|
|
return filepath.Walk(dir, tarWalk)
|
|
|
|
}
|
|
|
|
|
2013-06-27 13:51:13 -04:00
|
|
|
// ProcessOutputPath takes an output path template and executes it,
|
|
|
|
// replacing variables with their respective values.
|
2013-07-01 18:07:09 -04:00
|
|
|
func ProcessOutputPath(path string, buildName string, provider string, artifact packer.Artifact) (string, error) {
|
2013-06-27 13:51:13 -04:00
|
|
|
var buf bytes.Buffer
|
|
|
|
|
|
|
|
tplData := &OutputPathTemplate{
|
|
|
|
ArtifactId: artifact.Id(),
|
2013-07-01 18:07:37 -04:00
|
|
|
BuildName: buildName,
|
2013-06-27 13:51:13 -04:00
|
|
|
Provider: provider,
|
|
|
|
}
|
|
|
|
|
|
|
|
t, err := template.New("output").Parse(path)
|
|
|
|
if err != nil {
|
|
|
|
return "", err
|
|
|
|
}
|
|
|
|
|
|
|
|
err = t.Execute(&buf, tplData)
|
|
|
|
return buf.String(), err
|
|
|
|
}
|
|
|
|
|
2013-06-26 21:55:11 -04:00
|
|
|
// WriteMetadata writes the "metadata.json" file for a Vagrant box.
|
|
|
|
func WriteMetadata(dir string, contents interface{}) error {
|
|
|
|
f, err := os.Create(filepath.Join(dir, "metadata.json"))
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
defer f.Close()
|
|
|
|
|
|
|
|
enc := json.NewEncoder(f)
|
|
|
|
return enc.Encode(contents)
|
|
|
|
}
|