Method downloadFiles

pkg/devspace/sync/downstream.go:312–395

downloadFiles downloads the given files from the remote server and writes the contents into the given writer

(writer io.WriteCloser, changes []*remote.Change)

// downloadFiles downloads the given files from the remote server and writes the contents into the given writer
func (d *downstream) downloadFiles(writer io.WriteCloser, changes []*remote.Change) error {
	defer writer.Close()

	// cancel after 1 hour
	ctx, cancel := context.WithTimeout(d.sync.ctx, time.Hour)
	defer cancel()

	// Print log message
	if len(changes) <= 3 || d.sync.Options.Verbose {
		for _, element := range changes {
			d.sync.log.Infof("Downstream - Download file '.%s', uncompressed: ~%0.2f KB", element.Path, float64(element.Size)/1024.0)
		}
	} else if len(changes) > 3 {
		filesize := int64(0)
		for _, v := range changes {
			filesize += v.Size
		}

		d.sync.log.Infof("Downstream - Download %d file(s) (Uncompressed: ~%0.2f KB)", len(changes), float64(filesize)/1024.0)
	}

	// Create new download client
	downloadClient, err := d.client.Download(ctx)
	if err != nil {
		return errors.Wrap(err, "download files")
	}

	// Send files to download
	downloadFiles := make([]string, 0, downloadFilesBufferSize)
	for _, change := range changes {
		downloadFiles = append(downloadFiles, change.Path)

		if len(downloadFiles) >= downloadFilesBufferSize {
			err = downloadClient.Send(&remote.Paths{
				Paths: downloadFiles,
			})
			if err != nil {
				return errors.Wrap(err, "send path")
			}

			downloadFiles = make([]string, 0, downloadFilesBufferSize)
		}
	}

	if len(downloadFiles) >= 0 {
		err = downloadClient.Send(&remote.Paths{
			Paths: downloadFiles,
		})
		if err != nil {
			return errors.Wrap(err, "send path")
		}
	}

	// We finish sending and start receiving the tar
	err = downloadClient.CloseSend()
	if err != nil {
		return errors.Wrap(err, "close send")
	}