0ct0pu5/ente
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Handle contentLength errors

Browse source
This commit is contained in:
Vishnu Mohandas 2021-02-13 17:56:37 +05:30
parent 896f9a5ab8
commit 10c0a52bf2
1 changed files with 30 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
lib/utils/file_uploader.dart
View file

@ -436,21 +436,38 @@ class FileUploader {
return _uploadURLFetchInProgress;
}
Future<String> _putFile(UploadURL uploadURL, io.File file) async {
final fileSize = file.lengthSync().toString();
Future<String> _putFile(UploadURL uploadURL, io.File file,
{int contentLength}) async {
final fileSize = contentLength ?? file.lengthSync();
final startTime = DateTime.now().millisecondsSinceEpoch;
_logger.info("Putting file of size " + fileSize + " to " + uploadURL.url);
await _dio.put(uploadURL.url,
_logger.info(
"Putting file of size " + fileSize.toString() + " to " + uploadURL.url);
try {
await _dio.put(
uploadURL.url,
data: file.openRead(),
options: Options(headers: {
Headers.contentLengthHeader: await file.length(),
}));
_logger.info("Upload speed : " +
(file.lengthSync() /
(DateTime.now().millisecondsSinceEpoch - startTime))
.toString() +
" kilo bytes per second");
return uploadURL.objectKey;
options: Options(
headers: {
Headers.contentLengthHeader: fileSize,
},
),
);
_logger.info("Upload speed : " +
(file.lengthSync() /
(DateTime.now().millisecondsSinceEpoch - startTime))
.toString() +
" kilo bytes per second");
return uploadURL.objectKey;
} on DioError catch (e) {
if (e.message.startsWith(
"HttpException: Content size exceeds specified contentLength.")) {
return _putFile(uploadURL, file,
contentLength: file.readAsBytesSync().length);
} else {
throw e;
}
}
}
}