fix: import bal data from api depot

BaseAdresseNationale · Dec 12, 2023 · f6750ef · f6750ef
1 parent 29e4824
commit f6750ef
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 5 deletions.
diff --git a/apps/api/src/modules/base_locale/sub_modules/populate/populate.service.ts b/apps/api/src/modules/base_locale/sub_modules/populate/populate.service.ts
@@ -14,10 +14,10 @@ export class PopulateService {
 
   private async extractFromApiDepot(codeCommune: string) {
     try {
-      const response =
+      const fileData =
         await this.apiDepotService.downloadCurrentRevisionFile(codeCommune);
 
-      const result = await extractFromCsv(response.data, codeCommune);
+      const result = await extractFromCsv(fileData, codeCommune);
 
       if (!result.isValid) {
         throw new Error('Invalid CSV file');

diff --git a/libs/shared/src/modules/api_depot/api_depot.module.ts b/libs/shared/src/modules/api_depot/api_depot.module.ts
@@ -6,6 +6,7 @@ import { ApiDepotService } from './api_depot.service';
 
 @Module({
   imports: [
+    ConfigModule,
     HttpModule.registerAsync({
       imports: [ConfigModule],
       useFactory: async (configService: ConfigService) => ({

diff --git a/libs/shared/src/modules/api_depot/api_depot.service.ts b/libs/shared/src/modules/api_depot/api_depot.service.ts
@@ -7,10 +7,14 @@ import * as hasha from 'hasha';
 import { Habilitation } from './types/habilitation.type';
 import { BaseLocale } from '@/shared/schemas/base_locale/base_locale.schema';
 import { Revision } from '@/shared/modules/api_depot/types/revision.type';
+import { ConfigService } from '@nestjs/config';
 
 @Injectable()
 export class ApiDepotService {
-  constructor(private readonly httpService: HttpService) {}
+  constructor(
+    private readonly httpService: HttpService,
+    private readonly configService: ConfigService,
+  ) {}
 
   async findOneHabiliation(habilitationId: string): Promise<Habilitation> {
     const { data } = await firstValueFrom(
@@ -200,8 +204,11 @@ export class ApiDepotService {
     return revisions;
   }
 
-  public async downloadCurrentRevisionFile(codeCommune: string) {
-    const currentRevisionUrl = `/communes/${codeCommune}/current-revision/files/bal/download`;
+  public async downloadCurrentRevisionFile(
+    codeCommune: string,
+  ): Promise<Buffer> {
+    const apiDepotUrl = this.configService.get<string>('API_DEPOT_URL');
+    const currentRevisionUrl = `${apiDepotUrl}/communes/${codeCommune}/current-revision/files/bal/download`;
 
     const response = await this.httpService.axiosRef({
       url: currentRevisionUrl,