Function GetPartitionedBackupFileNames

internal/stream_fetch_helper.go:153–195

(backup Backup, decompressor compression.Decompressor)

}

func GetPartitionedBackupFileNames(backup Backup, decompressor compression.Decompressor) ([][]string, error) {
	// list all files in backup folder:
	files, _, err := backup.Folder.GetSubFolder(backup.Name).ListFolder()
	if err != nil {
		return nil, fmt.Errorf("cannot list files in backup folder '%s' due to: %w", backup.Folder.GetPath(), err)
	}

	// prepare lookup table:
	fileNames := make(map[string]bool)
	for _, file := range files {
		filePath := path.Join(backup.Name, file.GetName())
		fileNames[filePath] = true
	}

	result := make([][]string, 0)
	partIdx := 0
	for {
		nextPartitionFirstFile := GetPartitionedSteamMultipartName(backup.Name, decompressor.FileExtension(), partIdx, 0)
		nextPartitionWholeFile := GetPartitionedStreamName(backup.Name, decompressor.FileExtension(), partIdx)
		if fileNames[nextPartitionFirstFile] {
			result = append(result, make([]string, 1))
			result[partIdx][0] = nextPartitionFirstFile
			fileIdx := 1
			for {
				nextPartitionFile := GetPartitionedSteamMultipartName(backup.Name, decompressor.FileExtension(), partIdx, fileIdx)
				if fileNames[nextPartitionFile] {
					result[partIdx] = append(result[partIdx], nextPartitionFile)
					fileIdx++
				} else {
					break
				}
			}
		} else if fileNames[nextPartitionWholeFile] {
			result = append(result, make([]string, 1))
			result[partIdx][0] = nextPartitionWholeFile
		} else {
			break
		}
		partIdx++
	}

	return result, nil
}