graph/export.go
6e28d11d
 package graph
 
 import (
 	"encoding/json"
 	"io"
 	"io/ioutil"
 	"os"
377ed712
 	"path/filepath"
6e28d11d
 
6f4d8470
 	"github.com/Sirupsen/logrus"
30d5a42c
 	"github.com/docker/docker/pkg/archive"
6e28d11d
 	"github.com/docker/docker/pkg/parsers"
568f86eb
 	"github.com/docker/docker/registry"
6e28d11d
 )
 
 // CmdImageExport exports all images with the given tag. All versions
 // containing the same tag are exported. The resulting output is an
 // uncompressed tar ball.
 // name is the set of tags to export.
 // out is the writer where the images are written to.
2a14b7dd
 type ImageExportConfig struct {
 	Names     []string
 	Outstream io.Writer
 }
 
 func (s *TagStore) ImageExport(imageExportConfig *ImageExportConfig) error {
 
6e28d11d
 	// get image json
 	tempdir, err := ioutil.TempDir("", "docker-export-")
 	if err != nil {
c79b9bab
 		return err
6e28d11d
 	}
 	defer os.RemoveAll(tempdir)
 
 	rootRepoMap := map[string]Repository{}
b37fdc5d
 	addKey := func(name string, tag string, id string) {
6f4d8470
 		logrus.Debugf("add key [%s:%s]", name, tag)
b37fdc5d
 		if repo, ok := rootRepoMap[name]; !ok {
 			rootRepoMap[name] = Repository{tag: id}
 		} else {
 			repo[tag] = id
 		}
 	}
2a14b7dd
 	for _, name := range imageExportConfig.Names {
568f86eb
 		name = registry.NormalizeLocalName(name)
6f4d8470
 		logrus.Debugf("Serializing %s", name)
e64131d1
 		rootRepo := s.Repositories[name]
 		if rootRepo != nil {
 			// this is a base repo name, like 'busybox'
b37fdc5d
 			for tag, id := range rootRepo {
 				addKey(name, tag, id)
fa2c68a8
 				if err := s.exportImage(id, tempdir); err != nil {
c79b9bab
 					return err
e64131d1
 				}
6e28d11d
 			}
 		} else {
e64131d1
 			img, err := s.LookupImage(name)
 			if err != nil {
c79b9bab
 				return err
6e28d11d
 			}
e64131d1
 
 			if img != nil {
 				// This is a named image like 'busybox:latest'
 				repoName, repoTag := parsers.ParseRepositoryTag(name)
 
 				// check this length, because a lookup of a truncated has will not have a tag
 				// and will not need to be added to this map
 				if len(repoTag) > 0 {
b37fdc5d
 					addKey(repoName, repoTag, img.ID)
e64131d1
 				}
fa2c68a8
 				if err := s.exportImage(img.ID, tempdir); err != nil {
c79b9bab
 					return err
e64131d1
 				}
 
 			} else {
 				// this must be an ID that didn't get looked up just right?
fa2c68a8
 				if err := s.exportImage(name, tempdir); err != nil {
c79b9bab
 					return err
e64131d1
 				}
 			}
6e28d11d
 		}
6f4d8470
 		logrus.Debugf("End Serializing %s", name)
6e28d11d
 	}
 	// write repositories, if there is something to write
 	if len(rootRepoMap) > 0 {
377ed712
 		f, err := os.OpenFile(filepath.Join(tempdir, "repositories"), os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0644)
29a3bbf2
 		if err != nil {
 			f.Close()
 			return err
 		}
 		if err := json.NewEncoder(f).Encode(rootRepoMap); err != nil {
 			return err
 		}
 		if err := f.Close(); err != nil {
c79b9bab
 			return err
6e28d11d
 		}
 	} else {
6f4d8470
 		logrus.Debugf("There were no repositories to write")
6e28d11d
 	}
 
 	fs, err := archive.Tar(tempdir, archive.Uncompressed)
 	if err != nil {
c79b9bab
 		return err
6e28d11d
 	}
 	defer fs.Close()
 
2a14b7dd
 	if _, err := io.Copy(imageExportConfig.Outstream, fs); err != nil {
c79b9bab
 		return err
6e28d11d
 	}
2a14b7dd
 	logrus.Debugf("End export image")
c79b9bab
 	return nil
6e28d11d
 }
 
 // FIXME: this should be a top-level function, not a class method
fa2c68a8
 func (s *TagStore) exportImage(name, tempdir string) error {
6e28d11d
 	for n := name; n != ""; {
 		// temporary directory
377ed712
 		tmpImageDir := filepath.Join(tempdir, n)
6e28d11d
 		if err := os.Mkdir(tmpImageDir, os.FileMode(0755)); err != nil {
 			if os.IsExist(err) {
 				return nil
 			}
 			return err
 		}
 
 		var version = "1.0"
 		var versionBuf = []byte(version)
 
377ed712
 		if err := ioutil.WriteFile(filepath.Join(tmpImageDir, "VERSION"), versionBuf, os.FileMode(0644)); err != nil {
6e28d11d
 			return err
 		}
 
 		// serialize json
377ed712
 		json, err := os.Create(filepath.Join(tmpImageDir, "json"))
6e28d11d
 		if err != nil {
 			return err
 		}
fa2c68a8
 		imageInspectRaw, err := s.LookupRaw(n)
 		if err != nil {
6e28d11d
 			return err
 		}
fa2c68a8
 		written, err := json.Write(imageInspectRaw)
 		if err != nil {
 			return err
 		}
 		if written != len(imageInspectRaw) {
 			logrus.Warnf("%d byes should have been written instead %d have been written", written, len(imageInspectRaw))
 		}
6e28d11d
 
 		// serialize filesystem
377ed712
 		fsTar, err := os.Create(filepath.Join(tmpImageDir, "layer.tar"))
6e28d11d
 		if err != nil {
 			return err
 		}
ba001759
 		if err := s.ImageTarLayer(n, fsTar); err != nil {
6e28d11d
 			return err
 		}
 
 		// find parent
d07fe183
 		img, err := s.LookupImage(n)
 		if err != nil {
6e28d11d
 			return err
 		}
d07fe183
 		n = img.Parent
6e28d11d
 	}
 	return nil
 }