Method applyCreates

pkg/devspace/sync/upstream.go:764–823

(files []*FileInformation)

}

func (u *upstream) applyCreates(files []*FileInformation) (map[string]*FileInformation, error) {
	files, err := u.filterChanges(files)
	if err != nil {
		return nil, err
	} else if len(files) == 0 {
		return nil, nil
	}

	size := int64(0)
	for _, c := range files {
		if c.IsDirectory {
			// Print changes
			if u.sync.Options.Verbose || len(files) <= 3 {
				u.sync.log.Infof("Upstream - Upload Folder '%s'", u.getRelativeUpstreamPath(c.Name))
			}
		} else {
			if u.sync.Options.Verbose || len(files) <= 3 {
				u.sync.log.Infof("Upstream - Upload File '%s'", u.getRelativeUpstreamPath(c.Name))
			}

			size += c.Size
		}
	}

	u.sync.log.Infof("Upstream - Upload %d create change(s) (Uncompressed ~%0.2f KB)", len(files), float64(size)/1024.0)
	defer u.sync.log.Debugf("Upstream - Done Uploading")

	// Create a pipe for reading and writing
	reader, writer := io.Pipe()
	defer reader.Close()
	defer writer.Close()

	var archiver *Archiver
	errorChan := make(chan error)
	go func() {
		var compressErr error
		archiver, compressErr = u.compress(writer, files, u.ignoreMatcher)
		errorChan <- compressErr
	}()

	// upload the archive
	err = u.uploadArchive(reader)
	if err != nil {
		return nil, errors.Wrap(err, "upload archive")
	}

	// check if there was a compressing error
	err = <-errorChan
	if err != nil {
		return nil, errors.Wrap(err, "compress archive")
	}

	// finally update written files
	for _, element := range archiver.WrittenFiles() {
		u.sync.fileIndex.CreateDirInFileMap(path.Dir(element.Name))
		u.sync.fileIndex.fileMap[element.Name] = element
	}