eduvia/workavia-mail-front
11
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

feat: Add repository/interactor for get label changes

Browse Source
This commit is contained in:
dab246
2026-02-03 18:15:25 +07:00
committed by Dat H. Pham
parent 987ea410c5
commit c49e48ae1b
8 changed files with 163 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/labels/data/datasource/label_datasource.dart
+9
View File
@@ -1,6 +1,9 @@
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/session/session.dart';
import 'package:jmap_dart_client/jmap/core/state.dart';
import 'package:labels/model/label.dart';
import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
import 'package:tmail_ui_user/features/labels/data/model/label_change_response.dart';
abstract class LabelDatasource {
Future<List<Label>> getAllLabels(AccountId accountId);
@@ -10,4 +13,10 @@ abstract class LabelDatasource {
Future<Label> editLabel(AccountId accountId, EditLabelRequest labelRequest);
Future<void> deleteLabel(AccountId accountId, Label label);
Future<LabelChangeResponse> getLabelChanges(
Session session,
AccountId accountId,
State sinceState,
);
}
lib/features/labels/data/datasource_impl/label_datasource_impl.dart
+18
View File
@@ -1,6 +1,9 @@
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/session/session.dart';
import 'package:jmap_dart_client/jmap/core/state.dart';
import 'package:labels/model/label.dart';
import 'package:tmail_ui_user/features/labels/data/datasource/label_datasource.dart';
import 'package:tmail_ui_user/features/labels/data/model/label_change_response.dart';
import 'package:tmail_ui_user/features/labels/data/network/label_api.dart';
import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
@@ -38,4 +41,19 @@ class LabelDatasourceImpl extends LabelDatasource {
return await _labelApi.deleteLabel(accountId, label);
}).catchError(_exceptionThrower.throwException);
}
@override
Future<LabelChangeResponse> getLabelChanges(
Session session,
AccountId accountId,
State sinceState,
) {
return Future.sync(() async {
return await _labelApi.getLabelChangesWithResult(
session,
accountId,
sinceState,
);
}).catchError(_exceptionThrower.throwException);
}
}
lib/features/labels/data/repository/label_repository_impl.dart
+49
View File
@@ -1,7 +1,11 @@
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/id.dart';
import 'package:jmap_dart_client/jmap/core/session/session.dart';
import 'package:jmap_dart_client/jmap/core/state.dart';
import 'package:labels/model/label.dart';
import 'package:tmail_ui_user/features/labels/data/datasource/label_datasource.dart';
import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
import 'package:tmail_ui_user/features/labels/domain/model/label_changes_result.dart';
import 'package:tmail_ui_user/features/labels/domain/repository/label_repository.dart';
class LabelRepositoryImpl extends LabelRepository {
@@ -28,4 +32,49 @@ class LabelRepositoryImpl extends LabelRepository {
Future<void> deleteLabel(AccountId accountId, Label label) {
return _labelDatasource.deleteLabel(accountId, label);
}
@override
Future<LabelChangesResult> getLabelChanges(
Session session,
AccountId accountId,
State sinceState,
) async {
bool hasMoreChanges = true;
State? newSinceState = sinceState;
List<Label> createdLabels = [];
List<Label> updatedLabels = [];
List<Id> destroyedLabelIds = [];
State? newState;
while (hasMoreChanges && newSinceState != null) {
final changesResponse = await _labelDatasource.getLabelChanges(
session,
accountId,
sinceState,
);
hasMoreChanges = changesResponse.hasMoreChanges;
newSinceState = changesResponse.newStateChanges;
if (changesResponse.created?.isNotEmpty == true) {
createdLabels.addAll(changesResponse.created!);
}
if (changesResponse.updated?.isNotEmpty == true) {
updatedLabels.addAll(changesResponse.updated!);
}
if (changesResponse.destroyed?.isNotEmpty == true) {
destroyedLabelIds.addAll(changesResponse.destroyed!);
}
if (changesResponse.newStateChanges != null) {
newState = changesResponse.newStateChanges!;
}
}
return LabelChangesResult(
createdLabels: createdLabels,
updatedLabels: updatedLabels,
destroyedLabelIds: destroyedLabelIds,
newState: newState,
);
}
}