feat(me): Added an effect cleanRecordAttachments on saveRecordSuccess…

… action that delete all ressources that are not used in the record.

libs/api/repository/src/lib/gn4/platform/gn4-platform.service.ts

@@ -1,5 +1,12 @@
 import { Injectable } from '@angular/core'
-import { combineLatest, Observable, of, switchMap } from 'rxjs'
+import {
+  combineLatest,
+  forkJoin,
+  mergeMap,
+  Observable,
+  of,
+  switchMap,
+} from 'rxjs'
 import { catchError, filter, map, shareReplay, tap } from 'rxjs/operators'
 import {
   MeApiService,
@@ -13,6 +20,7 @@ import {
 import { PlatformServiceInterface } from '@geonetwork-ui/common/domain/platform.service.interface'
 import { UserModel } from '@geonetwork-ui/common/domain/model/user/user.model'
 import {
+  CatalogRecord,
   Keyword,
   Organization,
   UserFeedback,
@@ -288,6 +296,44 @@ export class Gn4PlatformService implements PlatformServiceInterface {
     )
   }
 
+  cleanRecordAttachments(record: CatalogRecord): Observable<void> {
+    return combineLatest([
+      this.recordsApiService.getAssociatedResources(record.uniqueIdentifier),
+      this.recordsApiService.getAllResources(record.uniqueIdentifier),
+    ]).pipe(
+      map(([associatedResources, recordResources]) => {
+        const resourceIdsToKeep = [
+          ...((associatedResources as any).onlines ?? [])
+            .map((o) => o.title)
+            .map((o) => o['']),
+          ...((associatedResources as any).thumbnails ?? [])
+            .map((o) => o.title)
+            .map((o) => o['']),
+        ]
+
+        const resourceIdsToRemove = recordResources
+          .map((r) => r.filename)
+          .filter((resourceId) => !resourceIdsToKeep.includes(resourceId))
+
+        return resourceIdsToRemove
+      }),
+      mergeMap((resourceIdsToRemove) =>
+        forkJoin(
+          resourceIdsToRemove.map((attachementId) =>
+            this.recordsApiService.delResource(
+              record.uniqueIdentifier,
+              attachementId
+            )
+          )
+        ).pipe(map(() => undefined))
+      ),
+      catchError((error) => {
+        console.error('Error while cleaning attachments:', error)
+        throw error
+      })
+    )
+  }
+
   attachFileToRecord(recordUuid: string, file: File) {
     let sizeBytes = -1
     return this.recordsApiService

libs/common/domain/src/lib/platform.service.interface.ts

@@ -1,7 +1,7 @@
 import type { Observable } from 'rxjs'
 import type { UserModel } from './model/user/user.model'
 import type { Organization } from './model/record/organization.model'
-import { Keyword, UserFeedback } from './model/record'
+import { CatalogRecord, Keyword, UserFeedback } from './model/record'
 import { KeywordType } from './model/thesaurus'
 
 interface RecordAttachment {
@@ -49,6 +49,7 @@ export abstract class PlatformServiceInterface {
   abstract getRecordAttachments(
     recordUuid: string
   ): Observable<RecordAttachment[]>
+  abstract cleanRecordAttachments(recordUuid: CatalogRecord): Observable<void>
   abstract attachFileToRecord(
     recordUuid: string,
     file: File

libs/feature/editor/src/lib/+state/editor.effects.ts

@@ -1,6 +1,6 @@
 import { inject, Injectable } from '@angular/core'
 import { Actions, createEffect, ofType } from '@ngrx/effects'
-import { debounceTime, filter, of, withLatestFrom } from 'rxjs'
+import { debounceTime, EMPTY, filter, of, withLatestFrom } from 'rxjs'
 import { catchError, map, switchMap } from 'rxjs/operators'
 import * as EditorActions from './editor.actions'
 import { EditorService } from '../services/editor.service'
@@ -11,12 +11,14 @@ import {
   selectRecordAlreadySavedOnce,
 } from './editor.selectors'
 import { RecordsRepositoryInterface } from '@geonetwork-ui/common/domain/repository/records-repository.interface'
+import { Gn4PlatformService } from '@geonetwork-ui/api/repository'
 
 @Injectable()
 export class EditorEffects {
   private actions$ = inject(Actions)
   private editorService = inject(EditorService)
   private recordsRepository = inject(RecordsRepositoryInterface)
+  private gn4PlateformService = inject(Gn4PlatformService)
   private store = inject(Store)
 
   saveRecord$ = createEffect(() =>
@@ -53,6 +55,28 @@ export class EditorEffects {
     )
   )
 
+  cleanRecordAttachments$ = createEffect(
+    () =>
+      this.actions$.pipe(
+        ofType(EditorActions.saveRecordSuccess),
+        withLatestFrom(this.store.select(selectRecord)),
+        switchMap(([_, record]) => {
+          this.gn4PlateformService.cleanRecordAttachments(record).subscribe({
+            next: (_) => undefined,
+            error: (err) => {
+              console.error(err)
+            },
+          })
+          return EMPTY
+        }),
+        catchError((error) => {
+          console.error(error)
+          return EMPTY
+        })
+      ),
+    { dispatch: false }
+  )
+
   markAsChanged$ = createEffect(() =>
     this.actions$.pipe(
       ofType(EditorActions.updateRecordField),