remove quality analysis in datastore

src/data/repositories/IssueD2Repository.ts

@@ -331,8 +331,8 @@ export class IssueD2Repository implements IssueRepository {
         );
 
         const statusFilter = this.buildFilterMultipleValue(
-            filter.actions,
-            this.metadata.dataElements.action.id
+            filter.status,
+            this.metadata.dataElements.status.id
         );
 
         const actionsFilter = this.buildFilterMultipleValue(

src/data/repositories/QualityAnalysisD2Repository.ts

@@ -134,18 +134,28 @@ export class QualityAnalysisD2Repository implements QualityAnalysisRepository {
         });
     }
 
-    remove(id: Id[]): FutureData<void> {
+    remove(id: Id): FutureData<void> {
         return apiToFuture(
-            this.api.tracker.post(
+            this.api.tracker.postAsync(
                 { importStrategy: "DELETE" },
-                { trackedEntities: id.map(id => ({ trackedEntity: id })) }
+                { trackedEntities: [{ trackedEntity: id }] }
             )
-        ).flatMap(d2Response => {
-            if (d2Response.status === "ERROR") {
-                return Future.error(new Error(d2Response.message));
-            } else {
-                return Future.success(undefined);
-            }
+        ).flatMap(d2JobResponse => {
+            return apiToFuture(
+                // this rule is being applied outside the context of testing-library
+                // more info here: https://github.com/testing-library/eslint-plugin-testing-library/blob/main/docs/rules/await-async-utils.md
+                // eslint-disable-next-line testing-library/await-async-utils
+                this.api.system.waitFor("TRACKER_IMPORT_JOB", d2JobResponse.response.id)
+            ).flatMap(d2Response => {
+                if (d2Response?.status === "ERROR") {
+                    return Future.error(new Error(d2Response.message));
+                } else {
+                    const dataStore = this.api.dataStore(DATA_QUALITY_NAMESPACE);
+                    return apiToFuture(dataStore.delete(id)).flatMap(() => {
+                        return Future.success(undefined);
+                    });
+                }
+            });
         });
     }
 

src/domain/repositories/QualityAnalysisRepository.ts

@@ -7,7 +7,7 @@ export interface QualityAnalysisRepository {
     get(options: QualityAnalysisOptions): FutureData<QualityAnalysisPaginated>;
     getById(id: Id): FutureData<QualityAnalysis>;
     save(qualityAnalysis: QualityAnalysis[]): FutureData<void>;
-    remove(id: Id[]): FutureData<void>;
+    remove(id: Id): FutureData<void>;
 }
 
 export type Pagination = {

src/domain/usecases/RemoveQualityUseCase.ts

@@ -1,11 +1,19 @@
 import { FutureData } from "$/data/api-futures";
 import { Id } from "$/domain/entities/Ref";
 import { QualityAnalysisRepository } from "$/domain/repositories/QualityAnalysisRepository";
+import { Future } from "$/domain/entities/generic/Future";
 
 export class RemoveQualityUseCase {
     constructor(private qualityAnalysisRepository: QualityAnalysisRepository) {}
 
     execute(qualityAnalysisIds: Id[]): FutureData<void> {
-        return this.qualityAnalysisRepository.remove(qualityAnalysisIds);
+        const concurrencyRequest = 5;
+        const $requests = Future.parallel(
+            qualityAnalysisIds.map(issue => this.qualityAnalysisRepository.remove(issue)),
+            { concurrency: concurrencyRequest }
+        );
+        return $requests.flatMap(() => {
+            return Future.success(undefined);
+        });
     }
 }