Merge branch 'fix_await_warnings' into onnx

This commit is contained in:
vishnukvmd 2023-12-17 02:51:15 +05:30
commit 411ac66a91
47 changed files with 133 additions and 116 deletions

View file

@ -106,9 +106,11 @@ Future<void> _runBackgroundTask(String taskId, {String mode = 'normal'}) async {
await _sync('bgTaskActiveProcess');
BackgroundFetch.finish(taskId);
} else {
// ignore: unawaited_futures
_runWithLogs(
() async {
_logger.info("Starting background task in $mode mode");
// ignore: unawaited_futures
_runInBackground(taskId);
},
prefix: "[bg]",
@ -152,7 +154,7 @@ Future<void> _init(bool isBackground, {String via = ''}) async {
_logger.info("Initializing... inBG =$isBackground via: $via");
final SharedPreferences preferences = await SharedPreferences.getInstance();
await _logFGHeartBeatInfo();
_scheduleHeartBeat(preferences, isBackground);
unawaited(_scheduleHeartBeat(preferences, isBackground));
AppLifecycleService.instance.init(preferences);
if (isBackground) {
AppLifecycleService.instance.onAppInBackground('init via: $via');
@ -185,15 +187,15 @@ Future<void> _init(bool isBackground, {String via = ''}) async {
SearchService.instance.init();
StorageBonusService.instance.init(preferences);
if (Platform.isIOS) {
// ignore: unawaited_futures
PushService.instance.init().then((_) {
FirebaseMessaging.onBackgroundMessage(
_firebaseMessagingBackgroundHandler,
);
});
}
FeatureFlagService.instance.init();
SemanticSearchService.instance.init(preferences);
unawaited(FeatureFlagService.instance.init());
unawaited(SemanticSearchService.instance.init(preferences));
// Can not including existing tf/ml binaries as they are not being built
// from source.
// See https://gitlab.com/fdroid/fdroiddata/-/merge_requests/12671#note_1294346819
@ -242,6 +244,7 @@ Future<void> _scheduleHeartBeat(
DateTime.now().microsecondsSinceEpoch,
);
Future.delayed(kHeartBeatFrequency, () async {
// ignore: unawaited_futures
_scheduleHeartBeat(prefs, isBackground);
});
}
@ -281,7 +284,7 @@ Future<void> _killBGTask([String? taskId]) async {
DateTime.now().microsecondsSinceEpoch,
);
final prefs = await SharedPreferences.getInstance();
prefs.remove(kLastBGTaskHeartBeatTime);
await prefs.remove(kLastBGTaskHeartBeatTime);
if (taskId != null) {
BackgroundFetch.finish(taskId);
}
@ -299,6 +302,7 @@ Future<void> _firebaseMessagingBackgroundHandler(RemoteMessage message) async {
}
} else {
// App is dead
// ignore: unawaited_futures
_runWithLogs(
() async {
_logger.info("Background push received");

View file

@ -147,7 +147,7 @@ class CollectionsService {
);
}
await _updateDB(updatedCollections);
_prefs.setInt(_collectionsSyncTimeKey, maxUpdationTime);
await _prefs.setInt(_collectionsSyncTimeKey, maxUpdationTime);
watch.logAndReset("till DB insertion ${updatedCollections.length}");
for (final collection in fetchedCollections) {
_cacheLocalPathAndCollection(collection);

View file

@ -142,7 +142,7 @@ class EntityService {
await _db.upsertEntities(entities);
}
}
_prefs.setInt(_getEntityLastSyncTimePrefix(type), maxSyncTime);
await _prefs.setInt(_getEntityLastSyncTimePrefix(type), maxSyncTime);
if (hasMoreItems) {
_logger.info("Diff limit reached, pulling again");
await _remoteToLocalSync(type);

View file

@ -83,7 +83,7 @@ class FeatureFlagService {
.getDio()
.get("https://static.ente.io/feature_flags.json");
final flagsResponse = FeatureFlags.fromMap(response.data);
_prefs.setString(_featureFlagsKey, flagsResponse.toJson());
await _prefs.setString(_featureFlagsKey, flagsResponse.toJson());
_featureFlags = flagsResponse;
} catch (e) {
_logger.severe("Failed to sync feature flags ", e);

View file

@ -1,3 +1,4 @@
import "dart:async";
import 'dart:convert';
import 'dart:typed_data';
@ -149,7 +150,7 @@ extension HiddenService on CollectionsService {
await dialog.hide();
} on AssertionError catch (e) {
await dialog.hide();
showErrorDialog(context, "Oops", e.message as String);
unawaited(showErrorDialog(context, "Oops", e.message as String));
return false;
} catch (e, s) {
_logger.severe("Could not hide", e, s);

View file

@ -24,7 +24,7 @@ class LocalAuthenticationService {
Configuration.instance.shouldShowLockScreen(),
);
if (!result) {
unawaited(showToast(context, infoMessage));
showToast(context, infoMessage);
return false;
} else {
return true;

View file

@ -352,7 +352,7 @@ class LocalSyncService {
PhotoManager.addChangeCallback((value) async {
_logger.info("Something changed on disk");
_changeCallbackDebouncer.run(() async {
checkAndSync();
unawaited(checkAndSync());
});
});
PhotoManager.startChangeNotify();
@ -363,9 +363,9 @@ class LocalSyncService {
await _existingSync!.future;
}
if (hasGrantedLimitedPermissions()) {
syncAll();
unawaited(syncAll());
} else {
sync().then((value) => _refreshDeviceFolderCountAndCover());
unawaited(sync().then((value) => _refreshDeviceFolderCountAndCover()));
}
}
}

View file

@ -75,7 +75,7 @@ class NotificationService {
?.requestPermission();
}
if (result != null) {
_preferences.setBool(keyGrantedNotificationPermission, result);
await _preferences.setBool(keyGrantedNotificationPermission, result);
}
}

View file

@ -35,6 +35,7 @@ class PushService {
await _configurePushToken();
} else {
Bus.instance.on<SignedInEvent>().listen((_) async {
// ignore: unawaited_futures
_configurePushToken();
});
}

View file

@ -74,6 +74,7 @@ class RemoteSyncService {
Bus.instance.on<LocalPhotosUpdatedEvent>().listen((event) async {
if (event.type == EventType.addedOrUpdated) {
if (_existingSync == null) {
// ignore: unawaited_futures
sync();
}
}
@ -141,6 +142,7 @@ class RemoteSyncService {
if (hasMoreFilesToBackup && !_shouldThrottleSync()) {
// Skipping a resync to ensure that files that were ignored in this
// session are not processed now
// ignore: unawaited_futures
sync();
} else {
_logger.info("Fire backup completed event");
@ -959,6 +961,7 @@ class RemoteSyncService {
'creating notification for ${collection?.displayName} '
'shared: $sharedFilesIDs, collected: $collectedFilesIDs files',
);
// ignore: unawaited_futures
NotificationService.instance.showNotification(
collection!.displayName,
totalCount.toString() + " new 📸",

View file

@ -240,6 +240,7 @@ class SyncService {
final now = DateTime.now().microsecondsSinceEpoch;
if ((now - lastNotificationShownTime) > microSecondsInDay) {
await _prefs.setInt(kLastStorageLimitExceededNotificationPushTime, now);
// ignore: unawaited_futures
NotificationService.instance.showNotification(
"Storage limit exceeded",
"Sorry, we had to pause your backups",

View file

@ -86,6 +86,7 @@ class UpdateService {
if (shouldUpdate &&
hasBeen3DaysSinceLastNotification &&
_latestVersion!.shouldNotify) {
// ignore: unawaited_futures
NotificationService.instance.showNotification(
"Update available",
"Click to install our best version yet",

View file

@ -740,8 +740,7 @@ class UserService {
);
await dialog.hide();
if (response.statusCode == 200) {
showShortToast(context, S.of(context).authenticationSuccessful)
.ignore();
showShortToast(context, S.of(context).authenticationSuccessful);
await _saveConfiguration(response);
await Navigator.of(context).pushAndRemoveUntil(
MaterialPageRoute(
@ -756,7 +755,7 @@ class UserService {
await dialog.hide();
_logger.severe(e);
if (e.response != null && e.response!.statusCode == 404) {
showToast(context, "Session expired").ignore();
showToast(context, "Session expired");
await Navigator.of(context).pushAndRemoveUntil(
MaterialPageRoute(
builder: (BuildContext context) {
@ -810,7 +809,7 @@ class UserService {
} on DioError catch (e) {
_logger.severe(e);
if (e.response != null && e.response!.statusCode == 404) {
showToast(context, S.of(context).sessionExpired).ignore();
showToast(context, S.of(context).sessionExpired);
Navigator.of(context).pushAndRemoveUntil(
MaterialPageRoute(
builder: (BuildContext context) {
@ -1016,11 +1015,9 @@ class UserService {
);
await dialog.hide();
Bus.instance.fire(TwoFactorStatusChangeEvent(false));
unawaited(
showShortToast(
context,
S.of(context).twofactorAuthenticationHasBeenDisabled,
),
showShortToast(
context,
S.of(context).twofactorAuthenticationHasBeenDisabled,
);
} catch (e) {
await dialog.hide();

View file

@ -1,3 +1,4 @@
import "dart:async";
import 'dart:convert';
import "package:dropdown_button2/dropdown_button2.dart";
@ -344,6 +345,7 @@ class _DeleteAccountPageState extends State<DeleteAccountPage> {
],
);
// ignore: unawaited_futures
showDialog(
context: context,
builder: (BuildContext context) {

View file

@ -68,7 +68,7 @@ class _LoginPageState extends State<LoginPage> {
isFormValid: _emailIsValid,
buttonText: S.of(context).logInLabel,
onPressedFunction: () async {
UserService.instance.setEmail(_email!);
await UserService.instance.setEmail(_email!);
SrpAttributes? attr;
bool isEmailVerificationEnabled = true;
try {
@ -80,6 +80,7 @@ class _LoginPageState extends State<LoginPage> {
}
}
if (attr != null && !isEmailVerificationEnabled) {
// ignore: unawaited_futures
Navigator.of(context).push(
MaterialPageRoute(
builder: (BuildContext context) {

View file

@ -1,3 +1,5 @@
import "dart:async";
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:logging/logging.dart';
@ -445,6 +447,7 @@ class _PasswordEntryPageState extends State<PasswordEntryPage> {
await dialog.hide();
Configuration.instance.setVolatilePassword(null);
Bus.instance.fire(AccountConfiguredEvent());
// ignore: unawaited_futures
Navigator.of(context).pushAndRemoveUntil(
MaterialPageRoute(
builder: (BuildContext context) {
@ -460,6 +463,7 @@ class _PasswordEntryPageState extends State<PasswordEntryPage> {
}
}
// ignore: unawaited_futures
routeToPage(
context,
RecoveryKeyPage(
@ -475,6 +479,7 @@ class _PasswordEntryPageState extends State<PasswordEntryPage> {
_logger.severe(e);
await dialog.hide();
if (e is UnsupportedError) {
// ignore: unawaited_futures
showErrorDialog(
context,
S.of(context).insecureDevice,

View file

@ -120,6 +120,7 @@ class _PasswordReentryPageState extends State<PasswordReentryPage> {
firstButtonLabel: S.of(context).useRecoveryKey,
);
if (dialogChoice!.action == ButtonAction.first) {
// ignore: unawaited_futures
Navigator.of(context).push(
MaterialPageRoute(
builder: (BuildContext context) {

View file

@ -1,3 +1,4 @@
import "dart:async";
import 'dart:io';
import 'package:bip39/bip39.dart' as bip39;

View file

@ -54,6 +54,7 @@ class _RecoveryPageState extends State<RecoveryPage> {
await Configuration.instance.recover(_recoveryKey.text.trim());
await dialog.hide();
showShortToast(context, S.of(context).recoverySuccessful);
// ignore: unawaited_futures
Navigator.of(context).pushReplacement(
MaterialPageRoute(
builder: (BuildContext context) {
@ -72,6 +73,7 @@ class _RecoveryPageState extends State<RecoveryPage> {
if (e is AssertionError) {
errMessage = '$errMessage : ${e.message}';
}
// ignore: unawaited_futures
showErrorDialog(
context,
S.of(context).incorrectRecoveryKeyTitle,

View file

@ -84,7 +84,7 @@ class _RequestPasswordVerificationPageState
onPressedFunction: () async {
FocusScope.of(context).unfocus();
final dialog = createProgressDialog(context, context.l10n.pleaseWait);
dialog.show();
await dialog.show();
try {
final attributes = Configuration.instance.getKeyAttributes()!;
final Uint8List keyEncryptionKey = await CryptoUtil.deriveKey(
@ -98,17 +98,18 @@ class _RequestPasswordVerificationPageState
keyEncryptionKey,
CryptoUtil.base642bin(attributes.keyDecryptionNonce),
);
dialog.show();
await dialog.show();
// pop
await widget.onPasswordVerified(keyEncryptionKey);
dialog.hide();
await dialog.hide();
Navigator.of(context).pop(true);
} catch (e, s) {
_logger.severe("Error while verifying password", e, s);
dialog.hide();
await dialog.hide();
if (widget.onPasswordError != null) {
widget.onPasswordError!();
} else {
// ignore: unawaited_futures
showErrorDialog(
context,
context.l10n.incorrectPasswordTitle,

View file

@ -121,6 +121,7 @@ class _SessionsPageState extends State<SessionsPage> {
} catch (e) {
await dialog.hide();
_logger.severe('failed to terminate');
// ignore: unawaited_futures
showErrorDialog(
context,
S.of(context).oops,
@ -184,7 +185,7 @@ class _SessionsPageState extends State<SessionsPage> {
if (isLoggingOutFromThisDevice) {
await UserService.instance.logout(context);
} else {
_terminateSession(session);
await _terminateSession(session);
}
},
),

View file

@ -114,7 +114,7 @@ class _TwoFactorAuthenticationPageState
child: OutlinedButton(
onPressed: _code.length == 6
? () async {
_verifyTwoFactorCode(_code);
await _verifyTwoFactorCode(_code);
}
: null,
child: Text(S.of(context).verify),

View file

@ -251,7 +251,7 @@ class _TwoFactorSetupPageState extends State<TwoFactorSetupPage>
OutlinedButton(
onPressed: _code.length == 6
? () async {
_enableTwoFactor(_code);
await _enableTwoFactor(_code);
}
: null,
child: Text(S.of(context).confirm),

View file

@ -97,6 +97,7 @@ class _VerifyRecoveryPageState extends State<VerifyRecoveryPage> {
recoveryKey = CryptoUtil.bin2hex(
await UserService.instance.getOrCreateRecoveryKey(context),
);
// ignore: unawaited_futures
routeToPage(
context,
RecoveryKeyPage(

View file

@ -1,3 +1,5 @@
import "dart:async";
import 'package:flutter/cupertino.dart';
import "package:photo_manager/photo_manager.dart";
import "package:photos/core/configuration.dart";
@ -184,7 +186,7 @@ extension CollectionFileActions on CollectionActions {
if (files.isNotEmpty) {
await CollectionsService.instance.addToCollection(collectionID, files);
}
RemoteSyncService.instance.sync(silently: true);
unawaited(RemoteSyncService.instance.sync(silently: true));
await dialog?.hide();
return true;
} catch (e, s) {
@ -214,11 +216,11 @@ extension CollectionFileActions on CollectionActions {
return true;
} catch (e, s) {
logger.severe(e, s);
showShortToast(
context,
markAsFavorite
? S.of(context).sorryCouldNotAddToFavorites
: S.of(context).sorryCouldNotRemoveFromFavorites,
showShortToast(
context,
markAsFavorite
? S.of(context).sorryCouldNotAddToFavorites
: S.of(context).sorryCouldNotRemoveFromFavorites,
);
} finally {
await dialog.hide();

View file

@ -115,7 +115,7 @@ class CollectionActions {
S.of(context).creatingLink,
isDismissible: true,
);
dialog.show();
await dialog.show();
try {
// create album with emptyName, use collectionCreationTime on UI to
// show name
@ -143,10 +143,10 @@ class CollectionActions {
await collectionsService.addToCollection(collection.id, files);
logger.finest("creating public link for the newly created album");
await CollectionsService.instance.createShareUrl(collection);
dialog.hide();
await dialog.hide();
return collection;
} catch (e, s) {
dialog.hide();
await dialog.hide();
await showGenericErrorDialog(context: context, error: e);
logger.severe("Failing to create link for selected files", e, s);
}
@ -467,9 +467,7 @@ class CollectionActions {
}
if (!isCollectionOwner && split.ownedByOtherUsers.isNotEmpty) {
unawaited(
showShortToast(context, S.of(context).canOnlyRemoveFilesOwnedByYou),
);
showShortToast(context, S.of(context).canOnlyRemoveFilesOwnedByYou);
return;
}

View file

@ -1,3 +1,5 @@
import "dart:async";
import "package:flutter/cupertino.dart";
import "package:modal_bottom_sheet/modal_bottom_sheet.dart";
import "package:photos/generated/l10n.dart";

View file

@ -189,6 +189,7 @@ class AlbumRowItemWidget extends StatelessWidget {
),
onTap: () async {
final thumbnail = await CollectionsService.instance.getCover(c);
// ignore: unawaited_futures
routeToPage(
context,
CollectionPage(

View file

@ -120,7 +120,7 @@ class AlbumVerticalListWidget extends StatelessWidget {
}
} else {
Navigator.pop(context);
await showToast(
showToast(
context,
S.of(context).createAlbumActionHint,
);

View file

@ -400,13 +400,11 @@ class _StripeSubscriptionPageState extends State<StripeSubscriptionPage> {
: await _billingService.cancelStripeSubscription();
await _fetchSub();
} catch (e) {
unawaited(
showShortToast(
context,
isAutoRenewDisabled
? S.of(context).failedToRenew
: S.of(context).failedToCancel,
),
showShortToast(
context,
isAutoRenewDisabled
? S.of(context).failedToRenew
: S.of(context).failedToCancel,
);
}
await _dialog.hide();

View file

@ -225,7 +225,7 @@ class BackupSectionWidgetState extends State<BackupSectionWidget> {
showShortToast(
context,
S.of(context).remindToEmptyEnteTrash,
).ignore();
);
},
);
}

View file

@ -50,7 +50,7 @@ class DebugSectionWidget extends StatelessWidget {
trailingIconIsMuted: true,
onTap: () async {
await LocalSyncService.instance.resetLocalSync();
showShortToast(context, "Done").ignore();
showShortToast(context, "Done");
},
),
sectionOptionSpacing,
@ -64,7 +64,7 @@ class DebugSectionWidget extends StatelessWidget {
onTap: () async {
await IgnoredFilesService.instance.reset();
SyncService.instance.sync().ignore();
showShortToast(context, "Done").ignore();
showShortToast(context, "Done");
},
),
sectionOptionSpacing,

View file

@ -279,7 +279,7 @@ class _SecuritySectionWidgetState extends State<SecuritySectionWidget> {
}
await UserService.instance.updateEmailMFA(isEnabled);
} catch (e) {
showToast(context, S.of(context).somethingWentWrong).ignore();
showToast(context, S.of(context).somethingWentWrong);
}
}
}

View file

@ -139,7 +139,7 @@ class OutgoingAlbumEmptyState extends StatelessWidget {
labelText: S.of(context).shareYourFirstAlbum,
icon: Icons.add,
onTap: () async {
await showToast(
showToast(
context,
S.of(context).shareAlbumHint,
);

View file

@ -502,11 +502,9 @@ class _FileSelectionActionsWidgetState
Future<void> _onCreatedSharedLinkClicked() async {
if (split.ownedByCurrentUser.isEmpty) {
unawaited(
showShortToast(
context,
S.of(context).canOnlyCreateLinkForFilesOwnedByYou,
),
showShortToast(
context,
S.of(context).canOnlyCreateLinkForFilesOwnedByYou,
);
return;
}
@ -570,7 +568,7 @@ class _FileSelectionActionsWidgetState
final String url =
"${_cachedCollectionForSharedLink!.publicURLs?.first?.url}#$collectionKey";
await Clipboard.setData(ClipboardData(text: url));
unawaited(showShortToast(context, S.of(context).linkCopiedToClipboard));
showShortToast(context, S.of(context).linkCopiedToClipboard);
}
}

View file

@ -22,7 +22,6 @@ import 'package:photos/ui/common/loading_widget.dart';
import 'package:photos/utils/file_util.dart';
import 'package:photos/utils/image_util.dart';
import 'package:photos/utils/thumbnail_util.dart';
import "package:photos/utils/toast_util.dart";
class ZoomableImage extends StatefulWidget {
final EnteFile photo;
@ -262,12 +261,6 @@ class _ZoomableImageState extends State<ZoomableImage>
final bool shouldFixPosition = previewImageProvider != null && _isZooming;
ImageInfo? finalImageInfo;
if (shouldFixPosition) {
if (kDebugMode) {
showToast(
context,
'Updating photo scale zooming and scale: ${_photoViewController.scale}',
).ignore();
}
final prevImageInfo = await getImageInfo(previewImageProvider);
finalImageInfo = await getImageInfo(finalImageProvider);
final scale = _photoViewController.scale! /
@ -303,9 +296,6 @@ class _ZoomableImageState extends State<ZoomableImage>
if (h != enteFile.height || w != enteFile.width) {
final logMessage =
'Updating aspect ratio for from ${enteFile.height}x${enteFile.width} to ${h}x$w';
if (kDebugMode && (enteFile.height != 0 || enteFile.width != 0)) {
showToast(context, logMessage).ignore();
}
_logger.info(logMessage);
await FileMagicService.instance.updatePublicMagicMetadata([
enteFile,

View file

@ -79,11 +79,9 @@ class _FavoriteWidgetState extends State<FavoriteWidget> {
} catch (e, s) {
_logger.severe(e, s);
hasError = true;
unawaited(
showToast(
context,
S.of(context).sorryCouldNotRemoveFromFavorites,
),
showToast(
context,
S.of(context).sorryCouldNotRemoveFromFavorites,
);
}
}

View file

@ -141,7 +141,7 @@ class GalleryState extends State<Gallery> {
// todo: Assign ID to Gallery and fire generic event with ID &
// target index/date
if (mounted && event.selectedIndex == 0) {
_itemScroller.scrollTo(
await _itemScroller.scrollTo(
index: 0,
duration: const Duration(milliseconds: 150),
);

View file

@ -131,12 +131,10 @@ class _GalleryAppBarWidgetState extends State<GalleryAppBarWidget> {
if (galleryType != GalleryType.ownedCollection &&
galleryType != GalleryType.hiddenOwnedCollection &&
galleryType != GalleryType.quickLink) {
unawaited(
showToast(
context,
'Type of galler $galleryType is not supported for '
'rename',
),
showToast(
context,
'Type of galler $galleryType is not supported for '
'rename',
);
return;
@ -269,7 +267,7 @@ class _GalleryAppBarWidgetState extends State<GalleryAppBarWidget> {
showToast(
context,
S.of(context).remindToEmptyDeviceTrash,
).ignore();
);
}
},
);
@ -614,7 +612,7 @@ class _GalleryAppBarWidgetState extends State<GalleryAppBarWidget> {
context,
);
} else {
unawaited(showToast(context, S.of(context).somethingWentWrong));
showToast(context, S.of(context).somethingWentWrong);
}
},
),

View file

@ -216,7 +216,7 @@ class AddPhotosPhotoWidget extends StatelessWidget {
},
);
} else {
showErrorDialog(
await showErrorDialog(
context,
context.l10n.oops,
context.l10n.somethingWentWrong + (kDebugMode ? "\n$e" : ""),

View file

@ -22,6 +22,7 @@ class GoToMapWidget extends StatelessWidget {
onTap: () async {
final bool result = await requestForMapEnable(context);
if (result) {
// ignore: unawaited_futures
Navigator.of(context).push(
MaterialPageRoute(
builder: (context) => MapScreen(

View file

@ -35,6 +35,7 @@ class SearchTabEmptyState extends StatelessWidget {
labelText: S.of(context).addYourPhotosNow,
icon: Icons.arrow_forward_outlined,
onTap: () async {
// ignore: unawaited_futures
routeToPage(
context,
BackupFolderSelectionPage(

View file

@ -127,9 +127,9 @@ Future<void> deleteFilesFromEverywhere(
),
);
if (hasLocalOnlyFiles && Platform.isAndroid) {
await showShortToast(context, S.of(context).filesDeleted);
showShortToast(context, S.of(context).filesDeleted);
} else {
await showShortToast(context, S.of(context).movedToTrash);
showShortToast(context, S.of(context).movedToTrash);
}
}
if (uploadedFilesToBeTrashed.isNotEmpty) {

View file

@ -106,6 +106,7 @@ class FileUploader {
);
_logger.info("BG task was found dead, cleared all locks");
}
// ignore: unawaited_futures
_pollBackgroundUploadStatus();
}
Bus.instance.on<LocalPhotosUpdatedEvent>().listen((event) {

View file

@ -165,9 +165,10 @@ Future<File?> getFileFromServer(
},
);
}
downloadFuture.then((downloadedFile) {
// ignore: unawaited_futures
downloadFuture.then((downloadedFile) async {
completer.complete(downloadedFile);
_fileDownloadsInProgress.remove(downloadID);
await _fileDownloadsInProgress.remove(downloadID);
_progressCallbacks.remove(downloadID);
});
}
@ -197,7 +198,7 @@ Future<File?> _getLivePhotoFromServer(
_downloadLivePhoto(file, progressCallback: progressCallback);
}
final livePhoto = await _livePhotoDownloadsTracker[file.uploadedFileID];
_livePhotoDownloadsTracker.remove(downloadID);
await _livePhotoDownloadsTracker.remove(downloadID);
if (livePhoto == null) {
return null;
}

View file

@ -116,7 +116,7 @@ Future<void> changeSortOrder(
);
} catch (e, s) {
_logger.severe("failed to update collection visibility", e, s);
unawaited(showShortToast(context, S.of(context).somethingWentWrong));
showShortToast(context, S.of(context).somethingWentWrong);
rethrow;
}
}
@ -136,7 +136,7 @@ Future<void> updateOrder(
);
} catch (e, s) {
_logger.severe("failed to update order", e, s);
unawaited(showShortToast(context, S.of(context).somethingWentWrong));
showShortToast(context, S.of(context).somethingWentWrong);
rethrow;
}
}
@ -162,7 +162,7 @@ Future<void> changeCoverPhoto(
);
} catch (e, s) {
_logger.severe("failed to update cover", e, s);
unawaited(showShortToast(context, S.of(context).somethingWentWrong));
showShortToast(context, S.of(context).somethingWentWrong);
rethrow;
}
}
@ -181,7 +181,7 @@ Future<bool> editTime(
);
return true;
} catch (e) {
showShortToast(context, S.of(context).somethingWentWrong).ignore();
showShortToast(context, S.of(context).somethingWentWrong);
return false;
}
}
@ -240,7 +240,7 @@ Future<bool> editFileCaption(
return true;
} catch (e) {
if (context != null) {
unawaited(showShortToast(context, S.of(context).somethingWentWrong));
showShortToast(context, S.of(context).somethingWentWrong);
}
return false;
}
@ -267,7 +267,7 @@ Future<void> _updatePublicMetadata(
await FileMagicService.instance.updatePublicMagicMetadata(files, update);
if (context != null) {
if (showDoneToast) {
await showShortToast(context, S.of(context).done);
showShortToast(context, S.of(context).done);
}
await dialog?.hide();
}

View file

@ -1,3 +1,4 @@
import "dart:async";
import 'dart:io';
import 'package:flutter/material.dart';
@ -5,7 +6,7 @@ import 'package:flutter_easyloading/flutter_easyloading.dart';
import 'package:fluttertoast/fluttertoast.dart';
import 'package:photos/ente_theme_data.dart';
Future showToast(
void showToast(
BuildContext context,
String message, {
toastLength = Toast.LENGTH_LONG,
@ -13,14 +14,16 @@ Future showToast(
}) async {
if (Platform.isAndroid) {
await Fluttertoast.cancel();
return Fluttertoast.showToast(
msg: message,
toastLength: toastLength,
gravity: ToastGravity.BOTTOM,
timeInSecForIosWeb: 1,
backgroundColor: Theme.of(context).colorScheme.toastBackgroundColor,
textColor: Theme.of(context).colorScheme.toastTextColor,
fontSize: 16.0,
unawaited(
Fluttertoast.showToast(
msg: message,
toastLength: toastLength,
gravity: ToastGravity.BOTTOM,
timeInSecForIosWeb: 1,
backgroundColor: Theme.of(context).colorScheme.toastBackgroundColor,
textColor: Theme.of(context).colorScheme.toastTextColor,
fontSize: 16.0,
),
);
} else {
EasyLoading.instance
@ -29,18 +32,20 @@ Future showToast(
..textColor = Theme.of(context).colorScheme.toastTextColor
..userInteractions = true
..loadingStyle = EasyLoadingStyle.custom;
return EasyLoading.showToast(
message,
duration: Duration(
seconds:
(toastLength == Toast.LENGTH_LONG ? iosLongToastLengthInSec : 1),
unawaited(
EasyLoading.showToast(
message,
duration: Duration(
seconds:
(toastLength == Toast.LENGTH_LONG ? iosLongToastLengthInSec : 1),
),
toastPosition: EasyLoadingToastPosition.bottom,
dismissOnTap: false,
),
toastPosition: EasyLoadingToastPosition.bottom,
dismissOnTap: false,
);
}
}
Future<void> showShortToast(context, String message) {
return showToast(context, message, toastLength: Toast.LENGTH_SHORT);
void showShortToast(context, String message) {
showToast(context, message, toastLength: Toast.LENGTH_SHORT);
}