feat: adding the storing method

apps/drec-api/src/drec.module.ts

@@ -63,6 +63,7 @@ import { UserLoginSessionEntity } from './pods/user/user_login_session.entity';
 import { DeviceLateongoingIssueCertificateEntity } from './pods/device/device_lateongoing_certificate.entity';
 import { CertificateSettingEntity } from './pods/device-group/certificate_setting.entity';
 import { HttpModule } from '@nestjs/axios';
+import { FileProcessingEntity } from './pods/file/file-processing.entity';
 
 const getEnvFilePath = () => {
   const pathsToTest = [
@@ -113,6 +114,7 @@ export const entities = [
   ...IssuerEntities,
   ...OnChainCertificateEntities,
   ...OffChainCertificateEntities,
+  FileProcessingEntity,
 ];
 
 const OriginAppTypeOrmModule = () => {

apps/drec-api/src/pods/file/file-processing.entity.ts

@@ -17,9 +17,6 @@ export enum FileProcessingType {
 
 @Entity('file_processing_jobs')
 export class FileProcessingEntity extends ExtendedBaseEntity {
-  constructor() {
-    super();
-  }
 
   @PrimaryGeneratedColumn('uuid')
   id: string;

apps/drec-api/src/pods/reads/reads.module.ts

@@ -18,6 +18,7 @@ import { DeltaFirstRead } from './delta_firstread.entity';
 import { BullModule } from '@nestjs/bull';
 import { FileModule } from '../file';
 import { ReadsProcessor } from './reads.processor';
+import { FileProcessingEntity } from '../file/file-processing.entity';
 const baseReadServiceProvider = {
   provide: BASE_READ_SERVICE,
   useFactory: (configService: ConfigService<Record<string, any>>) => {
@@ -36,6 +37,7 @@ const baseReadServiceProvider = {
       AggregateMeterRead,
       HistoryIntermediate_MeterRead,
       DeltaFirstRead,
+      FileProcessingEntity
     ]),
     BullModule.registerQueue({
       name: 'reads-queue',

apps/drec-api/src/pods/reads/reads.processor.ts

@@ -47,6 +47,8 @@ export class ReadsProcessor {
           measurement,
         );
         results.success++;
+        console.log("read", read)
+        await this.readsService.storeFileProccesingJobs(read, 2);
       } catch (error) {
         this.logger.error(`Error processing read: ${error.message}`);
         results.failed.push({

apps/drec-api/src/pods/reads/reads.service.ts

@@ -59,6 +59,8 @@ import {
 import { FileService } from '../file';
 import { InjectQueue } from '@nestjs/bull';
 import { Queue } from 'bull';
+import { MeterReadingCSV } from './parser/meter-reading-csv.parser';
+import { FileProcessingEntity, FileProcessingStatus, FileProcessingType } from '../file/file-processing.entity';
 
 export type TUserBaseEntity = ExtendedBaseEntity & IAggregateintermediate;
 
@@ -82,6 +84,8 @@ export class ReadsService {
     private readonly organizationService: OrganizationService,
     private readonly eventBus: EventBus,
     private readonly fileService: FileService,
+    @InjectRepository(FileProcessingEntity)
+    private readonly fileProcessingRepository: Repository<FileProcessingEntity>,
     @InjectQueue('reads-queue') private readsQueue: Queue,
   ) {
     const url = process.env.INFLUXDB_URL || 'http://localhost:8086';
@@ -131,6 +135,18 @@ export class ReadsService {
 
     return aggregatedReads;
   }
+
+  async storeFileProccesingJobs(record: MeterReadingCSV, user: any ): Promise<void> {
+    const successful = {
+      userId: user,
+      fileId: record.deviceId,
+      organizationId: user.organizationId,
+      status: FileProcessingStatus.Completed,
+      type: FileProcessingType.AddMeterRead,
+    }
+    await this.fileProcessingRepository.save(successful);
+    console.log('success')
+  }
   async storeFailedReads(
     meterId: string,
     read: number,