extractFileToDisk function
Future<void>
extractFileToDisk(
- String inputPath,
- String outputPath, {
- String? password,
- int? bufferSize,
- ArchiveCallback? callback,
Implementation
Future<void> extractFileToDisk(String inputPath, String outputPath,
{String? password, int? bufferSize, ArchiveCallback? callback}) async {
Directory? tempDir;
var archivePath = inputPath;
final futures = <Future<void>>[];
if (inputPath.endsWith('tar.gz') || inputPath.endsWith('tgz')) {
tempDir = Directory.systemTemp.createTempSync('dart_archive');
archivePath = path.join(tempDir.path, 'temp.tar');
final input = InputFileStream(inputPath);
final output = OutputFileStream(archivePath, bufferSize: bufferSize);
GZipDecoder().decodeStream(input, output);
futures.add(input.close());
futures.add(output.close());
} else if (inputPath.endsWith('tar.bz2') || inputPath.endsWith('tbz')) {
tempDir = Directory.systemTemp.createTempSync('dart_archive');
archivePath = path.join(tempDir.path, 'temp.tar');
final input = InputFileStream(inputPath);
final output = OutputFileStream(archivePath, bufferSize: bufferSize);
BZip2Decoder().decodeStream(input, output);
futures.add(input.close());
futures.add(output.close());
} else if (inputPath.endsWith('tar.xz') || inputPath.endsWith('txz')) {
tempDir = Directory.systemTemp.createTempSync('dart_archive');
archivePath = path.join(tempDir.path, 'temp.tar');
final input = InputFileStream(inputPath);
final output = OutputFileStream(archivePath, bufferSize: bufferSize);
XZDecoder().decodeStream(input, output);
futures.add(input.close());
futures.add(output.close());
}
if (futures.isNotEmpty) {
await Future.wait(futures);
futures.clear();
}
InputStream? toClose;
Archive archive;
if (archivePath.endsWith('tar')) {
final input = InputFileStream(archivePath);
archive = TarDecoder().decodeStream(input, callback: callback);
toClose = input;
} else if (archivePath.endsWith('zip')) {
final input = InputFileStream(archivePath);
archive = ZipDecoder()
.decodeStream(input, password: password, callback: callback);
toClose = input;
} else {
throw ArgumentError.value(inputPath, 'inputPath',
'Must end tar.gz, tgz, tar.bz2, tbz, tar.xz, txz, tar or zip.');
}
for (final file in archive) {
final filePath = path.join(outputPath, path.normalize(file.name));
if (!_isWithinOutputPath(outputPath, filePath)) {
continue;
}
if (file.isSymbolicLink) {
if (!_isValidSymLink(outputPath, file)) {
continue;
}
}
if (file.isDirectory && !file.isSymbolicLink) {
Directory(filePath).createSync(recursive: true);
continue;
}
if (file.isSymbolicLink) {
final link = Link(filePath);
final p = path.normalize(file.symbolicLink ?? "");
link.createSync(p, recursive: true);
} else if (file.isFile) {
final output = OutputFileStream(filePath, bufferSize: bufferSize);
try {
file.writeContent(output);
} catch (err) {
//print(err);
}
if ((Platform.isMacOS || Platform.isLinux || Platform.isAndroid) &&
posix.isPosixSupported) {
posix.chmod(filePath, file.unixPermissions.toRadixString(8));
}
futures.add(output.close());
}
}
futures.add(toClose.close());
if (futures.isNotEmpty) {
await Future.wait(futures);
futures.clear();
}
futures.add(archive.clear());
if (futures.isNotEmpty) {
await Future.wait(futures);
futures.clear();
}
if (tempDir != null) {
futures.add(tempDir.delete(recursive: true));
}
if (futures.isNotEmpty) {
await Future.wait(futures);
futures.clear();
}
}