Method uploadFilePart

commands/file_uploader.go:238–251

(filePart *os.File, fileName string, pb *pb.ProgressBar)

}

func (f *FileUploader) uploadFilePart(filePart *os.File, fileName string, pb *pb.ProgressBar) (*models.FileMetadata, error) {
	defer filePart.Close()
	fileInfo, err := filePart.Stat()
	if err != nil {
		return nil, fmt.Errorf("could not stat file part %q of file %q", filePart.Name(), fileName)
	}

	file := &progressBarReader{file: filePart, fileName: fileInfo.Name(), pb: pb}
	uploadedFile, err := f.mtaClient.UploadMtaFile(file, fileInfo.Size(), &f.namespace)
	if err != nil {
		return nil, fmt.Errorf("could not upload file %s: %s", terminal.EntityNameColor(fileName), err)
	}
	return uploadedFile, nil
}

func (f *FileUploader) isFileAlreadyUploaded(newFilePath string, fileInfo os.FileInfo, oldFiles []*models.FileMetadata, alreadyUploadedFiles *[]*models.FileMetadata) bool {
	for _, oldFile := range oldFiles {