SelfPrivacy
/
selfprivacy.org.app
10
7
Fork 5
Code Issues 75 Pull Requests 3 Projects 1 Releases 24 Wiki Activity

refactor: Optimistic state update when removing all finished jobs

pull/440/head
Inex Code 2024-01-29 20:14:12 +04:00
parent 831a0e95eb
commit bdd00683cd
2 changed files with 24 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/logic/bloc/server_jobs/server_jobs_bloc.dart
View File

@ -61,16 +61,7 @@ class ServerJobsBloc extends Bloc<ServerJobsEvent, ServerJobsState> {
final RemoveAllFinishedJobs event,
final Emitter<ServerJobsState> emit,
) async {
final List<ServerJob> finishedJobs = state.serverJobList
.where(
(final ServerJob job) =>
job.status == JobStatusEnum.finished ||
job.status == JobStatusEnum.error,
)
.toList();
for (final ServerJob job in finishedJobs) {
await getIt<ApiConnectionRepository>().removeServerJob(job.uid);
}
await getIt<ApiConnectionRepository>().removeAllFinishedServerJobs();
}
@override

23
lib/logic/get_it/api_connection_repository.dart
View File

@ -42,6 +42,29 @@ class ApiConnectionRepository {
_dataStream.add(_apiData);
}
Future<void> removeAllFinishedServerJobs() async {
final List<ServerJob> finishedJobs = _apiData.serverJobs.data
?.where(
(final ServerJob element) =>
element.status == JobStatusEnum.finished ||
element.status == JobStatusEnum.error,
)
.toList() ??
[];
// Optimistically remove the jobs from the list
_apiData.serverJobs.data?.removeWhere(
(final ServerJob element) =>
element.status == JobStatusEnum.finished ||
element.status == JobStatusEnum.error,
);
_dataStream.add(_apiData);
await Future.forEach<ServerJob>(
finishedJobs,
(final ServerJob job) async => removeServerJob(job.uid),
);
}
void dispose() {
_dataStream.close();
_connectionStatusStream.close();