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.spec.ts

@@ -15,6 +15,7 @@ import { AvatarServiceInterface } from '../auth/avatar.service.interface'
 import { Gn4PlatformMapper } from './gn4-platform.mapper'
 import { LangService } from '@geonetwork-ui/util/i18n'
 import {
+  datasetRecordsFixture,
   someUserFeedbacksFixture,
   userFeedbackFixture,
 } from '@geonetwork-ui/common/fixtures'
@@ -23,6 +24,7 @@ import {
   HttpTestingController,
 } from '@angular/common/http/testing'
 import { HttpClient, HttpEventType } from '@angular/common/http'
+import { CatalogRecord } from '@geonetwork-ui/common/domain/model/record'
 
 let geonetworkVersion: string
 
@@ -174,6 +176,11 @@ class LangServiceMock {
   iso3 = 'fre'
 }
 
+const associatedResources = {
+  onlines: [],
+  thumbnails: [],
+}
+
 class RecordsApiServiceMock {
   getAllResources = jest.fn(() =>
     of([
@@ -188,6 +195,8 @@ class RecordsApiServiceMock {
     ])
   )
   putResource = jest.fn(() => of(undefined))
+  getAssociatedResources = jest.fn(() => of(associatedResources))
+  delResource = jest.fn(() => of(undefined))
 }
 
 class UserfeedbackApiServiceMock {
@@ -769,6 +778,21 @@ describe('Gn4PlatformService', () => {
     })
   })
 
+  describe('cleanRecordAttachments', () => {
+    it('calls api service', async () => {
+      const record = datasetRecordsFixture() as unknown as CatalogRecord
+
+      service.cleanRecordAttachments(record)
+
+      expect(recordsApiService.getAssociatedResources).toHaveBeenCalledWith(
+        record.uniqueIdentifier
+      )
+      expect(recordsApiService.getAllResources).toHaveBeenCalledWith(
+        record.uniqueIdentifier
+      )
+    })
+  })
+
   describe('attachFileToRecord', () => {
     let file: File
     beforeEach(() => {

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.spec.ts

@@ -10,6 +10,8 @@ import { datasetRecordsFixture } from '@geonetwork-ui/common/fixtures'
 import { EditorService } from '../services/editor.service'
 import { RecordsRepositoryInterface } from '@geonetwork-ui/common/domain/repository/records-repository.interface'
 import { EditorPartialState } from './editor.reducer'
+import { MockProvider } from 'ng-mocks'
+import { Gn4PlatformService } from '@geonetwork-ui/api/repository'
 
 class EditorServiceMock {
   saveRecord = jest.fn((record) => of([record, '<xml>blabla</xml>']))
@@ -54,6 +56,9 @@ describe('EditorEffects', () => {
           provide: RecordsRepositoryInterface,
           useClass: RecordsRepositoryMock,
         },
+        MockProvider(Gn4PlatformService, {
+          cleanRecordAttachments: jest.fn(() => of(undefined)),
+        }),
       ],
     })
 
@@ -167,6 +172,16 @@ describe('EditorEffects', () => {
     })
   })
 
+  describe('cleanRecordAttachments$', () => {
+    it('dispatch markRecordAsChanged', () => {
+      actions = hot('-a-|', {
+        a: EditorActions.saveRecordSuccess(),
+      })
+      const expected = hot('---|')
+      expect(effects.cleanRecordAttachments$).toBeObservable(expected)
+    })
+  })
+
   describe('checkHasChangesOnOpen$', () => {
     describe('if the record has a draft', () => {
       it('dispatch markRecordAsChanged', () => {

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'
@@ -12,12 +12,14 @@ import {
   selectRecordSource,
 } 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(() =>
@@ -55,6 +57,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),