Method untarNext

pkg/devspace/sync/tar.go:67–165

(destPath string, tarReader *tar.Reader)

}

func (u *Unarchiver) untarNext(destPath string, tarReader *tar.Reader) (bool, error) {
	u.syncConfig.fileIndex.fileMapMutex.Lock()
	defer u.syncConfig.fileIndex.fileMapMutex.Unlock()

	header, err := tarReader.Next()
	if err != nil {
		if err != io.EOF {
			return false, errors.Wrap(err, "tar next")
		}

		return false, nil
	}

	relativePath := getRelativeFromFullPath("/"+header.Name, "")
	outFileName := path.Join(destPath, relativePath)
	baseName := path.Dir(outFileName)

	// Check if newer file is there and then don't override?
	stat, err := os.Stat(outFileName)
	if err == nil && !u.forceOverride {
		if stat.ModTime().Unix() > header.FileInfo().ModTime().Unix() {
			// Update filemap otherwise we download and download again
			u.syncConfig.fileIndex.fileMap[relativePath] = &FileInformation{
				Name:        relativePath,
				Mtime:       stat.ModTime().Unix(),
				Mode:        stat.Mode(),
				Size:        stat.Size(),
				IsDirectory: stat.IsDir(),
			}

			if !stat.IsDir() {
				u.syncConfig.log.Infof("Downstream - Don't override %s because file has newer mTime timestamp", relativePath)
			}
			return true, nil
		}
	}

	if err := u.createAllFolders(baseName, 0755); err != nil {
		return false, err
	}

	if header.FileInfo().IsDir() {
		if err := u.createAllFolders(outFileName, 0755); err != nil {
			return false, err
		}

		u.syncConfig.fileIndex.CreateDirInFileMap(relativePath)
		return true, nil
	}

	// Create base dir in file map if it not already exists
	u.syncConfig.fileIndex.CreateDirInFileMap(getRelativeFromFullPath(baseName, destPath))

	// Create / Override file
	outFile, err := os.Create(outFileName)
	if err != nil {
		// Try again after 5 seconds
		time.Sleep(time.Second * 5)