Merge pull request #80 from ente-io/break_sync
Surface errors from the diff fetcher
This commit is contained in:
commit
8f580895c2
|
@ -19,18 +19,17 @@ class DiffFetcher {
|
||||||
|
|
||||||
Future<Diff> getEncryptedFilesDiff(
|
Future<Diff> getEncryptedFilesDiff(
|
||||||
int collectionID, int sinceTime, int limit) async {
|
int collectionID, int sinceTime, int limit) async {
|
||||||
return _dio.get(
|
try {
|
||||||
Configuration.instance.getHttpEndpoint() + "/collections/diff",
|
final response = await _dio.get(
|
||||||
options:
|
Configuration.instance.getHttpEndpoint() + "/collections/diff",
|
||||||
Options(headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
options: Options(
|
||||||
queryParameters: {
|
headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
||||||
"collectionID": collectionID,
|
queryParameters: {
|
||||||
"sinceTime": sinceTime,
|
"collectionID": collectionID,
|
||||||
"limit": limit,
|
"sinceTime": sinceTime,
|
||||||
},
|
"limit": limit,
|
||||||
).catchError((e) {
|
},
|
||||||
_logger.severe(e);
|
);
|
||||||
}).then((response) async {
|
|
||||||
final files = <File>[];
|
final files = <File>[];
|
||||||
if (response != null) {
|
if (response != null) {
|
||||||
Bus.instance.fire(RemoteSyncEvent(true));
|
Bus.instance.fire(RemoteSyncEvent(true));
|
||||||
|
@ -101,7 +100,10 @@ class DiffFetcher {
|
||||||
Bus.instance.fire(RemoteSyncEvent(false));
|
Bus.instance.fire(RemoteSyncEvent(false));
|
||||||
return Diff(<File>[], <File>[], 0);
|
return Diff(<File>[], <File>[], 0);
|
||||||
}
|
}
|
||||||
});
|
} catch (e, s) {
|
||||||
|
_logger.severe(e, s);
|
||||||
|
rethrow;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue