TF-4368 Add more log trace for getAllEmail & forceQueryAllEmailsForWeb

This commit is contained in:
dab246
2026-03-17 10:16:44 +07:00
committed by Dat H. Pham
parent 9854592a4c
commit 2d19bc908d
@@ -89,6 +89,17 @@ class ThreadRepositoryImpl extends ThreadRepository {
propertiesCreated: propertiesCreated, propertiesCreated: propertiesCreated,
); );
} }
logTrace(
'ThreadRepositoryImpl::getAllEmail(): '
'CachedEmail = ${localEmailResponse.emailList?.length}, '
'CachedNotFoundEmailIds = ${localEmailResponse.notFoundEmailIds?.length}, '
'CachedState = ${localEmailResponse.state?.value}, '
'NetworkEmail = ${networkEmailResponse.emailList?.length}, '
'NetworkNotFoundEmailIds = ${networkEmailResponse.notFoundEmailIds?.length}, '
'NetworkState = ${networkEmailResponse.state?.value}, '
'Limit = ${limit?.value}, '
'MailboxId = ${emailFilter?.mailboxId?.asString}',
);
yield networkEmailResponse; yield networkEmailResponse;
} else { } else {
yield localEmailResponse; yield localEmailResponse;
@@ -136,6 +147,13 @@ class ThreadRepositoryImpl extends ThreadRepository {
return EmailsResponse(emailList: response.first, state: response.last); return EmailsResponse(emailList: response.first, state: response.last);
}); });
logTrace(
'ThreadRepositoryImpl::getAllEmail(): '
'DisplayedCachedEmail = ${newEmailResponse.emailList?.length}, '
'DisplayedNotFoundEmailIds = ${newEmailResponse.notFoundEmailIds?.length}, '
'DisplayedState = ${newEmailResponse.state?.value}',
);
yield newEmailResponse; yield newEmailResponse;
} }
@@ -182,14 +200,17 @@ class ThreadRepositoryImpl extends ThreadRepository {
); );
final serverCount = serverResponse.emailList?.length ?? 0; final serverCount = serverResponse.emailList?.length ?? 0;
final notFoundEmailIds = serverResponse.notFoundEmailIds ?? [];
final stateResponse = cachedState ?? serverResponse.state;
log( logTrace(
'ThreadRepositoryImpl::forceQueryAllEmailsForWeb(): ' 'ThreadRepositoryImpl::forceQueryAllEmailsForWeb(): '
'Server email count = $serverCount', 'ServerEmailCount = $serverCount, '
'ServerNotFoundEmailIds = ${notFoundEmailIds.length}, '
'StateResponse = ${stateResponse?.value}',
); );
if (serverCount > 0 || if (serverCount > 0 || notFoundEmailIds.isNotEmpty) {
(serverResponse.notFoundEmailIds?.isNotEmpty ?? false)) {
await _updateEmailCache( await _updateEmailCache(
accountId, accountId,
session.username, session.username,
@@ -201,7 +222,7 @@ class ThreadRepositoryImpl extends ThreadRepository {
// Combine server list + keep existing state // Combine server list + keep existing state
yield EmailsResponse( yield EmailsResponse(
emailList: serverResponse.emailList, emailList: serverResponse.emailList,
state: cachedState ?? serverResponse.state, state: stateResponse,
); );
} }