chore: failover implemented

src/app/modules/conclusion/conclusion.controller.ts

@@ -1,23 +1,14 @@
-import { Body, Controller, Get, Post, Query } from '@nestjs/common';
+import { Controller, Get, Query } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import { ConclusionService } from './conclusion.service';
-import {
-  ConclusionResponseDto,
-  GetConclusionDto,
-  GenerateConclusionDto,
-} from './conclusion.dto';
+import { ConclusionResponseDto, GetConclusionDto } from './conclusion.dto';
 import { Conclusion } from './conclusion.interface';
 
 @ApiTags('Conclusion')
 @Controller('Conclusion')
 export class ConclusionController {
   constructor(private readonly conclusionService: ConclusionService) {}
 
-  @Post('generate')
-  async generate(@Body() data: GenerateConclusionDto) {
-    return await this.conclusionService.generate(data.url);
-  }
-
   @Get()
   async get(@Query() data: GetConclusionDto): Promise<ConclusionResponseDto> {
     return this.buildResponse(await this.conclusionService.get(data.url));

src/app/modules/conclusion/conclusion.service.ts

@@ -13,29 +13,27 @@ export class ConclusionService {
     private readonly siteReportService: SiteReportService,
   ) {}
 
-  async generate(url: string) {
+  async generate(url: string): Promise<Conclusion> {
     const reports: SiteReportResponseDto[] =
       await this.siteReportService.getNotEq(url, 'trustPilot');
 
     const customerReviews = await this.siteReportService.getEqual(
       url,
       'trustPilot',
     );
-
     if (reports.length === 0) {
-      return `No reports found for ${url}`;
+      throw new Error(`No reports found for ${url}`);
     }
-
     try {
       const sumarizedObj = await this.summarize(reports);
       const sumarized = {
         ...JSON.parse(sumarizedObj),
         customerReviews: customerReviews.data,
       };
-      await this.create(sumarized);
-      return `${url} new conclusion generated`;
+      const result = await this.create(sumarized);
+      return result;
     } catch (error) {
-      return `Error generating conclusion for ${url}`;
+      throw new Error(error);
     }
   }
 
@@ -52,6 +50,23 @@ export class ConclusionService {
   }
 
   async get(url: string): Promise<Conclusion> {
-    return this.conclusionRepository.get(url);
+    let conclusion = await this.conclusionRepository.get(url);
+    if (!conclusion) {
+      const siteReportReviews = await this.siteReportService.getEqual(
+        url,
+        'trustPilot',
+      );
+      const siteReportAnalysis = await this.siteReportService.getNotEq(
+        url,
+        'trustPilot',
+      );
+      if (siteReportReviews && siteReportAnalysis) {
+        conclusion = await this.generate(url);
+      } else {
+        await this.siteReportService.crawler(url);
+        conclusion = await this.generate(url);
+      }
+    }
+    return conclusion;
   }
 }

src/app/modules/site-report/site-report.module.ts

@@ -1,5 +1,4 @@
 import { Module } from '@nestjs/common';
-import { SiteReportController } from './site-report.controller';
 import { SiteReportService } from './site-report.service';
 import { MongooseModule } from '@nestjs/mongoose';
 import { SiteReportSchema } from './site-report.schema';
@@ -13,7 +12,6 @@ import { ProviderModule } from '../provider/provider.module';
     ]),
     ProviderModule,
   ],
-  controllers: [SiteReportController],
   providers: [SiteReportService, SiteReportRepository],
   exports: [SiteReportService],
 })