fix: #2407

SocialGouv · Jan 28, 2025 · df79ef6 · df79ef6
1 parent 7a3f527
commit df79ef6
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 1 deletion.
diff --git a/packages/app/src/api/core-domain/repo/IReferentRepo.ts b/packages/app/src/api/core-domain/repo/IReferentRepo.ts
@@ -1,8 +1,10 @@
 import { type Referent } from "@common/core-domain/domain/Referent";
+import { type County } from "@common/core-domain/domain/valueObjects/County";
 import { type Region } from "@common/core-domain/domain/valueObjects/Region";
 import { type BulkRepo } from "@common/shared-domain";
 
 export interface IReferentRepo extends BulkRepo<Referent> {
+  getOneByCounty(county?: County): Promise<Referent | null>;
   getOneByRegion(region?: Region): Promise<Referent | null>;
   truncate(): Promise<void>;
 }
diff --git a/packages/app/src/api/core-domain/repo/impl/PostgresReferentRepo.ts b/packages/app/src/api/core-domain/repo/impl/PostgresReferentRepo.ts
@@ -1,6 +1,7 @@
 import { type ReferentRaw } from "@api/core-domain/infra/db/raw";
 import { sql } from "@api/shared-domain/infra/db/postgres";
 import { type Referent } from "@common/core-domain/domain/Referent";
+import { type County } from "@common/core-domain/domain/valueObjects/County";
 import { type Region } from "@common/core-domain/domain/valueObjects/Region";
 import { referentMap } from "@common/core-domain/mappers/referentMap";
 import { UnexpectedRepositoryError } from "@common/shared-domain";
@@ -55,6 +56,14 @@ export class PostgresReferentRepo implements IReferentRepo {
     return referentMap.toDomain(raw);
   }
 
+  public async getOneByCounty(county?: County): Promise<Referent | null> {
+    if (!county) return null;
+    const [raw] = await this.sql`select * from ${this.table} where county = ${county.getValue()} limit 1`;
+
+    if (!raw) return null;
+    return referentMap.toDomain(raw);
+  }
+
   public async save(item: Referent): Promise<UniqueID> {
     const raw = referentMap.toPersistence(item);
 

diff --git a/packages/app/src/api/core-domain/useCases/SendDeclarationReceipt.ts b/packages/app/src/api/core-domain/useCases/SendDeclarationReceipt.ts
@@ -34,7 +34,7 @@ export class SendDeclarationReceipt implements UseCase<Input, void> {
         throw new SendDeclarationReceiptNotFoundError(`No declaration found with siren ${siren} and year ${year}`);
       }
 
-      const referent = await this.referentRepo.getOneByRegion(declaration.declaration?.company?.region);
+      const referent = await this.referentRepo.getOneByCounty(declaration.declaration?.company?.county);
       const buffer = await this.jsxPdfService.buffer(DeclarationReceipt(declaration));
 
       const url = `${config.host}/index-egapro/declaration/${siren}/${year}`;