feat: route last revisions pending (#175)

Author: fufeck

src/modules/revision/revision.controller.ts

@@ -27,6 +27,7 @@ import { RevisionWithClientDTO } from './dto/revision_with_client.dto';
 import { RevisionQueryDto } from './dto/status_revisions.dto';
 import { AnciennesCommunesDTO } from './dto/ancienne_commune.dto';
 import { ValidationCogPipe } from '@/lib/class/pipes/validation_cog.pipe';
+
 @ApiTags('revisions')
 @Controller('')
 export class RevisionController {
@@ -138,6 +139,24 @@ export class RevisionController {
     res.send(data);
   }
 
+  @Get('revisions-lasts-pending')
+  @ApiOperation({
+    summary: 'Find lasts revisions pending',
+    operationId: 'findLastsRevisionInPending',
+  })
+  @ApiQuery({ name: 'page', required: false, schema: { type: 'number' } })
+  @ApiQuery({ name: 'limit', required: false, schema: { type: 'number' } })
+  async findLastsRevisionInPending(
+    @Query('page') page: number,
+    @Query('limit') limit: number,
+    @Res() res: Response,
+  ) {
+    const lastsRevisionsPending =
+      await this.revisionService.findLastsRevisionInPending(page, limit);
+
+    res.status(HttpStatus.OK).json(lastsRevisionsPending);
+  }
+
   @Get('revisions/:revisionId')
   @ApiOperation({
     summary: 'Find one revision',

src/modules/revision/revision.service.ts

@@ -130,6 +130,41 @@ export class RevisionService {
     return query.getRawMany();
   }
 
+  async findLastsRevisionInPending(page = 1, limit = 10): Promise<any> {
+    const offset = (page - 1) * limit;
+    const result = await this.revisionRepository.query(
+      `SELECT 
+        last_revisions.id,
+        code_commune AS "codeCommune",
+        status,
+        last_revisions.created_at AS "createdAt",
+        legacy_id AS "legacyId",
+        validation
+        FROM (
+            SELECT DISTINCT ON (code_commune) *
+            FROM revisions
+            ORDER BY code_commune, created_at DESC
+        ) last_revisions
+        LEFT JOIN clients on clients.id = last_revisions.client_id
+        WHERE status = 'pending'
+        ORDER BY last_revisions.created_at DESC
+        LIMIT $1 OFFSET $2`,
+      [limit, offset],
+    );
+
+    const [{ total }] = await this.revisionRepository.query(`
+      SELECT COUNT(*) as total
+      FROM (
+          SELECT DISTINCT ON (code_commune) *
+          FROM revisions
+          ORDER BY code_commune, created_at DESC
+      ) last_revisions
+      WHERE status = 'pending'
+    `);
+
+    return { result, total };
+  }
+
   async findFirsts(): Promise<RevisionAgg[]> {
     const query = this.revisionRepository
       .createQueryBuilder('revisions')