mirror of
https://github.com/immich-app/immich
synced 2025-11-14 17:36:12 +00:00
rename TrashService to TrashSyncService to avoid duplicated names
revert changes in original trash.provider.dart
This commit is contained in:
parent
29ec1ddc02
commit
1682766ccb
7 changed files with 24 additions and 24 deletions
|
|
@ -1,7 +1,7 @@
|
||||||
import 'dart:async';
|
import 'dart:async';
|
||||||
|
|
||||||
import 'package:immich_mobile/domain/models/sync_event.model.dart';
|
import 'package:immich_mobile/domain/models/sync_event.model.dart';
|
||||||
import 'package:immich_mobile/domain/services/trash.service.dart';
|
import 'package:immich_mobile/domain/services/trash_sync.service.dart';
|
||||||
import 'package:immich_mobile/infrastructure/repositories/sync_api.repository.dart';
|
import 'package:immich_mobile/infrastructure/repositories/sync_api.repository.dart';
|
||||||
import 'package:immich_mobile/infrastructure/repositories/sync_stream.repository.dart';
|
import 'package:immich_mobile/infrastructure/repositories/sync_stream.repository.dart';
|
||||||
import 'package:immich_mobile/presentation/pages/dev/dev_logger.dart';
|
import 'package:immich_mobile/presentation/pages/dev/dev_logger.dart';
|
||||||
|
|
@ -13,17 +13,17 @@ class SyncStreamService {
|
||||||
|
|
||||||
final SyncApiRepository _syncApiRepository;
|
final SyncApiRepository _syncApiRepository;
|
||||||
final SyncStreamRepository _syncStreamRepository;
|
final SyncStreamRepository _syncStreamRepository;
|
||||||
final TrashService _trashService;
|
final TrashSyncService _trashSyncService;
|
||||||
final bool Function()? _cancelChecker;
|
final bool Function()? _cancelChecker;
|
||||||
|
|
||||||
SyncStreamService({
|
SyncStreamService({
|
||||||
required SyncApiRepository syncApiRepository,
|
required SyncApiRepository syncApiRepository,
|
||||||
required SyncStreamRepository syncStreamRepository,
|
required SyncStreamRepository syncStreamRepository,
|
||||||
required TrashService trashService,
|
required TrashSyncService trashSyncService,
|
||||||
bool Function()? cancelChecker,
|
bool Function()? cancelChecker,
|
||||||
}) : _syncApiRepository = syncApiRepository,
|
}) : _syncApiRepository = syncApiRepository,
|
||||||
_syncStreamRepository = syncStreamRepository,
|
_syncStreamRepository = syncStreamRepository,
|
||||||
_trashService = trashService,
|
_trashSyncService = trashSyncService,
|
||||||
_cancelChecker = cancelChecker;
|
_cancelChecker = cancelChecker;
|
||||||
|
|
||||||
bool get isCancelled => _cancelChecker?.call() ?? false;
|
bool get isCancelled => _cancelChecker?.call() ?? false;
|
||||||
|
|
@ -119,7 +119,7 @@ class SyncStreamService {
|
||||||
return _syncStreamRepository.deletePartnerV1(data.cast());
|
return _syncStreamRepository.deletePartnerV1(data.cast());
|
||||||
case SyncEntityType.assetV1:
|
case SyncEntityType.assetV1:
|
||||||
final remoteSyncAssets = data.cast<SyncAssetV1>();
|
final remoteSyncAssets = data.cast<SyncAssetV1>();
|
||||||
await _trashService.handleRemoteChanges(
|
await _trashSyncService.handleRemoteChanges(
|
||||||
remoteSyncAssets.map((e) => (checksum: e.checksum, deletedAt: e.deletedAt)),
|
remoteSyncAssets.map((e) => (checksum: e.checksum, deletedAt: e.deletedAt)),
|
||||||
);
|
);
|
||||||
return _syncStreamRepository.updateAssetsV1(remoteSyncAssets);
|
return _syncStreamRepository.updateAssetsV1(remoteSyncAssets);
|
||||||
|
|
|
||||||
|
|
@ -6,7 +6,7 @@ import 'package:immich_mobile/services/app_settings.service.dart';
|
||||||
import 'package:logging/logging.dart';
|
import 'package:logging/logging.dart';
|
||||||
import 'package:platform/platform.dart';
|
import 'package:platform/platform.dart';
|
||||||
|
|
||||||
class TrashService {
|
class TrashSyncService {
|
||||||
final AppSettingsService _appSettingsService;
|
final AppSettingsService _appSettingsService;
|
||||||
final RemoteAssetRepository _remoteAssetRepository;
|
final RemoteAssetRepository _remoteAssetRepository;
|
||||||
final DriftLocalAssetRepository _localAssetRepository;
|
final DriftLocalAssetRepository _localAssetRepository;
|
||||||
|
|
@ -15,7 +15,7 @@ class TrashService {
|
||||||
final Platform _platform;
|
final Platform _platform;
|
||||||
final Logger _logger = Logger('TrashService');
|
final Logger _logger = Logger('TrashService');
|
||||||
|
|
||||||
TrashService({
|
TrashSyncService({
|
||||||
required AppSettingsService appSettingsService,
|
required AppSettingsService appSettingsService,
|
||||||
required RemoteAssetRepository remoteAssetRepository,
|
required RemoteAssetRepository remoteAssetRepository,
|
||||||
required DriftLocalAssetRepository localAssetRepository,
|
required DriftLocalAssetRepository localAssetRepository,
|
||||||
|
|
@ -11,13 +11,13 @@ import 'package:immich_mobile/providers/infrastructure/cancel.provider.dart';
|
||||||
import 'package:immich_mobile/providers/infrastructure/db.provider.dart';
|
import 'package:immich_mobile/providers/infrastructure/db.provider.dart';
|
||||||
import 'package:immich_mobile/providers/infrastructure/platform.provider.dart';
|
import 'package:immich_mobile/providers/infrastructure/platform.provider.dart';
|
||||||
import 'package:immich_mobile/providers/infrastructure/storage.provider.dart';
|
import 'package:immich_mobile/providers/infrastructure/storage.provider.dart';
|
||||||
import 'package:immich_mobile/providers/infrastructure/trash.provider.dart';
|
import 'package:immich_mobile/providers/infrastructure/trash_sync.provider.dart';
|
||||||
|
|
||||||
final syncStreamServiceProvider = Provider(
|
final syncStreamServiceProvider = Provider(
|
||||||
(ref) => SyncStreamService(
|
(ref) => SyncStreamService(
|
||||||
syncApiRepository: ref.watch(syncApiRepositoryProvider),
|
syncApiRepository: ref.watch(syncApiRepositoryProvider),
|
||||||
syncStreamRepository: ref.watch(syncStreamRepositoryProvider),
|
syncStreamRepository: ref.watch(syncStreamRepositoryProvider),
|
||||||
trashService: ref.watch(trashServiceProvider),
|
trashSyncService: ref.watch(trashSyncServiceProvider),
|
||||||
cancelChecker: ref.watch(cancellationProvider),
|
cancelChecker: ref.watch(cancellationProvider),
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
|
|
|
||||||
|
|
@ -1,13 +1,13 @@
|
||||||
import 'package:hooks_riverpod/hooks_riverpod.dart';
|
import 'package:hooks_riverpod/hooks_riverpod.dart';
|
||||||
import 'package:immich_mobile/domain/services/trash.service.dart';
|
import 'package:immich_mobile/domain/services/trash_sync.service.dart';
|
||||||
import 'package:immich_mobile/providers/app_settings.provider.dart';
|
import 'package:immich_mobile/providers/app_settings.provider.dart';
|
||||||
import 'package:immich_mobile/providers/infrastructure/storage.provider.dart';
|
import 'package:immich_mobile/providers/infrastructure/storage.provider.dart';
|
||||||
import 'package:immich_mobile/repositories/local_files_manager.repository.dart';
|
import 'package:immich_mobile/repositories/local_files_manager.repository.dart';
|
||||||
|
|
||||||
import 'asset.provider.dart';
|
import 'asset.provider.dart';
|
||||||
|
|
||||||
final trashServiceProvider = Provider(
|
final trashSyncServiceProvider = Provider(
|
||||||
(ref) => TrashService(
|
(ref) => TrashSyncService(
|
||||||
appSettingsService: ref.watch(appSettingsServiceProvider),
|
appSettingsService: ref.watch(appSettingsServiceProvider),
|
||||||
remoteAssetRepository: ref.watch(remoteAssetRepositoryProvider),
|
remoteAssetRepository: ref.watch(remoteAssetRepositoryProvider),
|
||||||
localAssetRepository: ref.watch(localAssetRepository),
|
localAssetRepository: ref.watch(localAssetRepository),
|
||||||
|
|
@ -3,10 +3,6 @@ import 'package:immich_mobile/entities/asset.entity.dart';
|
||||||
import 'package:immich_mobile/services/trash.service.dart';
|
import 'package:immich_mobile/services/trash.service.dart';
|
||||||
import 'package:logging/logging.dart';
|
import 'package:logging/logging.dart';
|
||||||
|
|
||||||
final trashProvider = StateNotifierProvider<TrashNotifier, bool>((ref) {
|
|
||||||
return TrashNotifier(ref.watch(trashServiceProvider));
|
|
||||||
});
|
|
||||||
|
|
||||||
class TrashNotifier extends StateNotifier<bool> {
|
class TrashNotifier extends StateNotifier<bool> {
|
||||||
final TrashService _trashService;
|
final TrashService _trashService;
|
||||||
final _log = Logger('TrashNotifier');
|
final _log = Logger('TrashNotifier');
|
||||||
|
|
@ -43,3 +39,7 @@ class TrashNotifier extends StateNotifier<bool> {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
final trashProvider = StateNotifierProvider<TrashNotifier, bool>((ref) {
|
||||||
|
return TrashNotifier(ref.watch(trashServiceProvider));
|
||||||
|
});
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
import 'package:immich_mobile/domain/services/store.service.dart';
|
import 'package:immich_mobile/domain/services/store.service.dart';
|
||||||
import 'package:immich_mobile/domain/services/trash.service.dart';
|
import 'package:immich_mobile/domain/services/trash_sync.service.dart';
|
||||||
import 'package:immich_mobile/domain/services/user.service.dart';
|
import 'package:immich_mobile/domain/services/user.service.dart';
|
||||||
import 'package:immich_mobile/domain/utils/background_sync.dart';
|
import 'package:immich_mobile/domain/utils/background_sync.dart';
|
||||||
import 'package:immich_mobile/platform/native_sync_api.g.dart';
|
import 'package:immich_mobile/platform/native_sync_api.g.dart';
|
||||||
|
|
@ -19,4 +19,4 @@ class MockAppSettingsService extends Mock implements AppSettingsService {}
|
||||||
|
|
||||||
class MockUploadService extends Mock implements UploadService {}
|
class MockUploadService extends Mock implements UploadService {}
|
||||||
|
|
||||||
class MockTrashService extends Mock implements TrashService {}
|
class MockTrashSyncService extends Mock implements TrashSyncService {}
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,7 @@ import 'dart:async';
|
||||||
import 'package:flutter_test/flutter_test.dart';
|
import 'package:flutter_test/flutter_test.dart';
|
||||||
import 'package:immich_mobile/domain/models/sync_event.model.dart';
|
import 'package:immich_mobile/domain/models/sync_event.model.dart';
|
||||||
import 'package:immich_mobile/domain/services/sync_stream.service.dart';
|
import 'package:immich_mobile/domain/services/sync_stream.service.dart';
|
||||||
import 'package:immich_mobile/domain/services/trash.service.dart';
|
import 'package:immich_mobile/domain/services/trash_sync.service.dart';
|
||||||
import 'package:immich_mobile/infrastructure/repositories/sync_api.repository.dart';
|
import 'package:immich_mobile/infrastructure/repositories/sync_api.repository.dart';
|
||||||
import 'package:immich_mobile/infrastructure/repositories/sync_stream.repository.dart';
|
import 'package:immich_mobile/infrastructure/repositories/sync_stream.repository.dart';
|
||||||
import 'package:mocktail/mocktail.dart';
|
import 'package:mocktail/mocktail.dart';
|
||||||
|
|
@ -32,7 +32,7 @@ void main() {
|
||||||
late SyncStreamService sut;
|
late SyncStreamService sut;
|
||||||
late SyncStreamRepository mockSyncStreamRepo;
|
late SyncStreamRepository mockSyncStreamRepo;
|
||||||
late SyncApiRepository mockSyncApiRepo;
|
late SyncApiRepository mockSyncApiRepo;
|
||||||
late TrashService mockTrashService;
|
late TrashSyncService mockTrashService;
|
||||||
late Function(List<SyncEvent>, Function()) handleEventsCallback;
|
late Function(List<SyncEvent>, Function()) handleEventsCallback;
|
||||||
late _MockAbortCallbackWrapper mockAbortCallbackWrapper;
|
late _MockAbortCallbackWrapper mockAbortCallbackWrapper;
|
||||||
|
|
||||||
|
|
@ -42,7 +42,7 @@ void main() {
|
||||||
mockSyncStreamRepo = MockSyncStreamRepository();
|
mockSyncStreamRepo = MockSyncStreamRepository();
|
||||||
mockSyncApiRepo = MockSyncApiRepository();
|
mockSyncApiRepo = MockSyncApiRepository();
|
||||||
mockAbortCallbackWrapper = _MockAbortCallbackWrapper();
|
mockAbortCallbackWrapper = _MockAbortCallbackWrapper();
|
||||||
mockTrashService = MockTrashService();
|
mockTrashService = MockTrashSyncService();
|
||||||
when(() => mockAbortCallbackWrapper()).thenReturn(false);
|
when(() => mockAbortCallbackWrapper()).thenReturn(false);
|
||||||
|
|
||||||
when(() => mockSyncApiRepo.streamChanges(any())).thenAnswer((invocation) async {
|
when(() => mockSyncApiRepo.streamChanges(any())).thenAnswer((invocation) async {
|
||||||
|
|
@ -87,7 +87,7 @@ void main() {
|
||||||
sut = SyncStreamService(
|
sut = SyncStreamService(
|
||||||
syncApiRepository: mockSyncApiRepo,
|
syncApiRepository: mockSyncApiRepo,
|
||||||
syncStreamRepository: mockSyncStreamRepo,
|
syncStreamRepository: mockSyncStreamRepo,
|
||||||
trashService: mockTrashService,
|
trashSyncService: mockTrashService,
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
@ -153,7 +153,7 @@ void main() {
|
||||||
sut = SyncStreamService(
|
sut = SyncStreamService(
|
||||||
syncApiRepository: mockSyncApiRepo,
|
syncApiRepository: mockSyncApiRepo,
|
||||||
syncStreamRepository: mockSyncStreamRepo,
|
syncStreamRepository: mockSyncStreamRepo,
|
||||||
trashService: mockTrashService,
|
trashSyncService: mockTrashService,
|
||||||
cancelChecker: cancellationChecker.call,
|
cancelChecker: cancellationChecker.call,
|
||||||
);
|
);
|
||||||
await sut.sync();
|
await sut.sync();
|
||||||
|
|
@ -189,7 +189,7 @@ void main() {
|
||||||
sut = SyncStreamService(
|
sut = SyncStreamService(
|
||||||
syncApiRepository: mockSyncApiRepo,
|
syncApiRepository: mockSyncApiRepo,
|
||||||
syncStreamRepository: mockSyncStreamRepo,
|
syncStreamRepository: mockSyncStreamRepo,
|
||||||
trashService: mockTrashService,
|
trashSyncService: mockTrashService,
|
||||||
cancelChecker: cancellationChecker.call,
|
cancelChecker: cancellationChecker.call,
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue