feat(entity-archival): add entity archival

gh-1778

Author: yeshamavani

packages/archival/src/aws-s3/export-archive-data.provider.ts

@@ -14,9 +14,8 @@ export class ExportArchiveDataProvider
     private readonly config: AwsS3Config,
   ) {}
   value(): ExportDataExternalSystem {
-    return async (seletedEntries: AnyObject[]) => {
-      return this.exportToCsv(seletedEntries);
-    };
+    return async (seletedEntries: AnyObject[]) =>
+      this.exportToCsv(seletedEntries);
   }
   async exportToCsv(seletedEntries: AnyObject[]): Promise<string> {
     const csvRows = [];

packages/archival/src/aws-s3/import-archive-data.provider.ts

@@ -14,9 +14,7 @@ export class ImportArchiveDataProvider
   implements Provider<ImportDataExternalSystem>
 {
   value(): ValueOrPromise<ImportDataExternalSystem> {
-    return async (fileName: string) => {
-      return this.getFileContent(fileName);
-    };
+    return async (fileName: string) => this.getFileContent(fileName);
   }
 
   async getFileContent(fileName: string): Promise<AnyObject[]> {
@@ -40,27 +38,25 @@ export class ImportArchiveDataProvider
       const csvData = data.Body!.toString('utf-8');
 
       const jsonArray: AnyObject[] = await new Promise((resolve, reject) => {
-        const results: any[] = [];
+        const results: AnyObject[] = [];
         stream.Readable.from(csvData)
           .pipe(csv())
-          .on('data', (data: any) => results.push(data))
+          .on('data', (data: AnyObject) => results.push(data))
           .on('end', () => resolve(results))
           .on('error', reject);
       });
       const headers = Object.keys(jsonArray[0]);
       for (const entry of jsonArray) {
         for (const key of headers) {
-          if (entry.hasOwnProperty(key)) {
-            const value = entry[key];
-            if (value === '') {
-              entry[key] = null;
-            } else if (
-              typeof value === 'string' &&
-              /^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.\d{3}Z$/.test(value)
-            ) {
-              entry[key] = new Date(value);
-            } else entry[key] = value;
-          }
+          const value = entry[key];
+          if (value === '') {
+            entry[key] = null;
+          } else if (
+            typeof value === 'string' &&
+            /^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.\d{3}Z$/.test(value)
+          ) {
+            entry[key] = new Date(value);
+          } else entry[key] = value;
         }
       }
       return jsonArray;

packages/archival/src/mixins/archival.mixin.ts

@@ -28,7 +28,6 @@ export function ArchivalRepositoryMixin<
   T extends UserModifiableEntity,
   ID,
   Relations extends object,
-  //sonarignore:end
   R extends ArchiveMixinBase<T, ID, Relations>,
 >(superClass: R, opts: AnyObject): R & AbstractConstructor<IArchiveMixin> {
   abstract class MixedRepository extends superClass implements IArchiveMixin {
@@ -103,7 +102,7 @@ export function ArchivalRepositoryMixin<
       return (
         optionsActorId ??
         // eslint-disable-next-line @typescript-eslint/no-explicit-any
-        (user[this.actorIdKey ?? 'id'] as any)?.toString() ?? //NOSOAR
+        (user[this.actorIdKey ?? 'id'] as any)?.toString() ?? //NOSONAR
         '0'
       );
     }

packages/archival/src/services/import-archived-data.service.ts

@@ -28,7 +28,7 @@ import {
 
 @injectable({scope: BindingScope.TRANSIENT})
 export class ImportArchivedDataService {
-  repo: any;
+  repo: AnyObject;
   constructor(
     @repository(JobDetailsRepository)
     public jobDetailsRepo: JobDetailsRepository,
@@ -110,6 +110,7 @@ export class ImportArchivedDataService {
 
   async getFilteredData() {}
 
+  // sonarignore:start
   private async getRepositoryByModelName<T extends Entity>(
     modelName: string,
   ): Promise<DefaultCrudRepository<T, any> | undefined> {
@@ -126,7 +127,7 @@ export class ImportArchivedDataService {
         return repository as DefaultCrudRepository<T, any>;
       }
     }
-
+    // sonarignore:end
     return undefined; // Return undefined if no matching repository is found
   }
 }

packages/archival/src/types.ts

@@ -1,11 +1,4 @@
-import {
-  AnyObject,
-  Count,
-  Entity,
-  Filter,
-  Options,
-  Where,
-} from '@loopback/repository';
+import {AnyObject, Count, Filter, Options, Where} from '@loopback/repository';
 import {UserModifiableEntity} from '@sourceloop/core';
 import {ArchiveMapping} from './models';
 
@@ -25,7 +18,7 @@ export const DEFAULT_ARCHIVAL_OPTIONS: ArchivalComponentOptions = {
 
 export type AbstractConstructor<T> = abstract new (
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  ...args: any[]
+  ...args: any[] //NOSONAR
 ) => T;
 
 export type MixinBaseClass<T> = AbstractConstructor<T>;
@@ -101,13 +94,6 @@ export type GetJobDetailsFn = (
 
 export const ArchivalDbSourceName = 'ArchivalDB';
 
-export interface LoopBackModelClass<T extends Entity> {
-  new (): T;
-  modelName: string;
-  definition?: any; // Adjust the type as needed
-  relations?: any; // Adjust the type as needed
-}
-
 export interface IBuildWhereConditionService {
   buildConditionForInsert(where: AnyObject | undefined): Promise<AnyObject>;
   buildConditionForFetch(