in commands/util.go [813:893]
func unpackTar(inpath string) error {
exists, err := FileExists(inpath)
if err != nil {
return err
}
if !exists {
errMsg := wski18n.T("File '{{.name}}' is not a valid file or it does not exist",
map[string]interface{}{
"name": inpath,
})
whiskErr := whisk.MakeWskErrorFromWskError(errors.New(errMsg), err, whisk.EXIT_CODE_ERR_USAGE,
whisk.DISPLAY_MSG, whisk.DISPLAY_USAGE)
return whiskErr
}
tarFileReader, err := os.Open(inpath)
if err != nil {
whisk.Debug(whisk.DbgError, "os.Open(%s) failed: %s\n", inpath, err)
errStr := wski18n.T("Error opening tar file '{{.name}}': {{.err}}",
map[string]interface{}{"name": inpath, "err": err})
werr := whisk.MakeWskError(errors.New(errStr), whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
return werr
}
defer tarFileReader.Close()
// Loop through the files in the tarfile
tReader := tar.NewReader(tarFileReader)
for {
item, err := tReader.Next()
if err == io.EOF {
whisk.Debug(whisk.DbgError, "EOF reach during untar\n")
break // end of tar
}
if err != nil {
whisk.Debug(whisk.DbgError, "tReader.Next() failed: %s\n", err)
errStr := wski18n.T("Error reading tar file '{{.name}}': {{.err}}",
map[string]interface{}{"name": inpath, "err": err})
werr := whisk.MakeWskError(errors.New(errStr), whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
return werr
}
whisk.Debug(whisk.DbgInfo, "tar file item - %#v\n", item)
switch item.Typeflag {
case tar.TypeDir:
if err := os.MkdirAll(item.Name, os.FileMode(item.Mode)); err != nil {
whisk.Debug(whisk.DbgError, "os.MkdirAll(%s, %d) failed: %s\n", item.Name, item.Mode, err)
errStr := wski18n.T("Unable to create directory '{{.dir}}' while untarring '{{.name}}': {{.err}}",
map[string]interface{}{"dir": item.Name, "name": inpath, "err": err})
werr := whisk.MakeWskError(errors.New(errStr), whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
return werr
}
case tar.TypeReg:
untarFile, err := os.OpenFile(item.Name, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, os.FileMode(item.Mode))
defer untarFile.Close()
if err != nil {
whisk.Debug(whisk.DbgError, "os.Create(%s) failed: %s\n", item.Name, err)
errStr := wski18n.T("Unable to create file '{{.file}}' while untarring '{{.name}}': {{.err}}",
map[string]interface{}{"file": item.Name, "name": inpath, "err": err})
werr := whisk.MakeWskError(errors.New(errStr), whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
return werr
}
if _, err := io.Copy(untarFile, tReader); err != nil {
whisk.Debug(whisk.DbgError, "io.Copy() of '%s' failed: %s\n", item.Name, err)
errStr := wski18n.T("Unable to untar file '{{.name}}': {{.err}}",
map[string]interface{}{"name": item.Name, "err": err})
werr := whisk.MakeWskError(errors.New(errStr), whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
return werr
}
default:
whisk.Debug(whisk.DbgError, "Unexpected tar file type of %q\n", item.Typeflag)
errStr := wski18n.T("Unable to untar '{{.name}}' due to unexpected tar file type\n",
map[string]interface{}{"name": item.Name})
werr := whisk.MakeWskError(errors.New(errStr), whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
return werr
}
}
return nil
}