Function ArchiveCreate

cmd/archive/create/create.go:298–388

ArchiveCreate - compresses/archive source to destination

(ctx context.Context, dst fs.Fs, dstFile string, src fs.Fs, format string, prefix string)

// ArchiveCreate - compresses/archive source to destination
func ArchiveCreate(ctx context.Context, dst fs.Fs, dstFile string, src fs.Fs, format string, prefix string) error {
	var err error
	var list archivesFileInfoList
	var compArchive archives.CompressedArchive
	var totalLength int64

	// check id dst is valid
	err = CheckValidDestination(ctx, dst, dstFile)
	if err != nil {
		return err
	}

	ci := fs.GetConfig(ctx)
	fi := filter.GetConfig(ctx)
	// get archive format
	compArchive, err = getCompressor(format, dstFile)
	if err != nil {
		return err
	}
	// get source files
	err = walk.ListR(ctx, src, "", false, ci.MaxDepth, walk.ListAll, func(entries fs.DirEntries) error {
		// get directories
		entries.ForDir(func(o fs.Directory) {
			var metadata fs.Metadata
			if ci.Metadata {
				metadata = loadMetadata(ctx, o)
			}
			if fi.Include(o.Remote(), o.Size(), o.ModTime(ctx), metadata) {
				info := files.NewArchiveFileInfo(ctx, o, prefix, metadata)
				list = append(list, info)
			}
		})
		// get files
		entries.ForObject(func(o fs.Object) {
			var metadata fs.Metadata
			if ci.Metadata {
				metadata = loadMetadata(ctx, o)
			}
			if fi.Include(o.Remote(), o.Size(), o.ModTime(ctx), metadata) {
				info := files.NewArchiveFileInfo(ctx, o, prefix, metadata)
				list = append(list, info)
				totalLength += o.Size()
			}
		})
		return nil
	})
	if err != nil {
		return err
	} else if list.Len() == 0 {
		return fmt.Errorf("no files found in source")
	}
	sort.Stable(list)
	// create archive
	if ci.DryRun {
		// write nowhere
		counter := files.NewCountWriter(nil)
		err = compArchive.Archive(ctx, counter, list)
		// log totals