@@ -89,6 +89,17 @@ class ThreadRepositoryImpl extends ThreadRepository {
8989 propertiesCreated: propertiesCreated,
9090 );
9191 }
92+ logTrace (
93+ 'ThreadRepositoryImpl::getAllEmail(): '
94+ 'CachedEmail = ${localEmailResponse .emailList ?.length }, '
95+ 'CachedNotFoundEmailIds = ${localEmailResponse .notFoundEmailIds ?.length }, '
96+ 'CachedState = ${localEmailResponse .state ?.value }, '
97+ 'NetworkEmail = ${networkEmailResponse .emailList ?.length }, '
98+ 'NetworkNotFoundEmailIds = ${networkEmailResponse .notFoundEmailIds ?.length }, '
99+ 'NetworkState = ${networkEmailResponse .state ?.value }, '
100+ 'Limit = ${limit ?.value }, '
101+ 'MailboxId = ${emailFilter ?.mailboxId ?.asString }' ,
102+ );
92103 yield networkEmailResponse;
93104 } else {
94105 yield localEmailResponse;
@@ -136,6 +147,13 @@ class ThreadRepositoryImpl extends ThreadRepository {
136147 return EmailsResponse (emailList: response.first, state: response.last);
137148 });
138149
150+ logTrace (
151+ 'ThreadRepositoryImpl::getAllEmail(): '
152+ 'DisplayedCachedEmail = ${newEmailResponse .emailList ?.length }, '
153+ 'DisplayedNotFoundEmailIds = ${newEmailResponse .notFoundEmailIds ?.length }, '
154+ 'DisplayedState = ${newEmailResponse .state ?.value }' ,
155+ );
156+
139157 yield newEmailResponse;
140158 }
141159
@@ -182,14 +200,17 @@ class ThreadRepositoryImpl extends ThreadRepository {
182200 );
183201
184202 final serverCount = serverResponse.emailList? .length ?? 0 ;
203+ final notFoundEmailIds = serverResponse.notFoundEmailIds ?? [];
204+ final stateResponse = cachedState ?? serverResponse.state;
185205
186- log (
206+ logTrace (
187207 'ThreadRepositoryImpl::forceQueryAllEmailsForWeb(): '
188- 'Server email count = $serverCount ' ,
208+ 'ServerEmailCount = $serverCount , '
209+ 'ServerNotFoundEmailIds = ${notFoundEmailIds .length }, '
210+ 'StateResponse = ${stateResponse ?.value }' ,
189211 );
190212
191- if (serverCount > 0 ||
192- (serverResponse.notFoundEmailIds? .isNotEmpty ?? false )) {
213+ if (serverCount > 0 || notFoundEmailIds.isNotEmpty) {
193214 await _updateEmailCache (
194215 accountId,
195216 session.username,
@@ -201,7 +222,7 @@ class ThreadRepositoryImpl extends ThreadRepository {
201222 // Combine server list + keep existing state
202223 yield EmailsResponse (
203224 emailList: serverResponse.emailList,
204- state: cachedState ?? serverResponse.state ,
225+ state: stateResponse ,
205226 );
206227 }
207228
0 commit comments