add cache to lbb get company by siret

gip-inclusion · Feb 12, 2025 · d85e724 · d85e724
1 parent a9da571
commit d85e724
Showing 1 changed file with 46 additions and 32 deletions.
diff --git a/back/src/domains/establishment/adapters/la-bonne-boite/HttpLaBonneBoiteGateway.ts b/back/src/domains/establishment/adapters/la-bonne-boite/HttpLaBonneBoiteGateway.ts
@@ -132,40 +132,54 @@ export class HttpLaBonneBoiteGateway implements LaBonneBoiteGateway {
     siret: SiretDto,
     romeDto: RomeDto,
   ): Promise<SearchResultDto | null> {
-    return this.#limiter
-      .schedule(async () =>
-        this.httpClient.getCompany({
-          headers: {
-            authorization: await this.#makeAutorization(),
-          },
-          queryParams: {
+    const cachedGetLbbResult = this.withCache({
+      overrideCacheDurationInHours: 24 * 3,
+      logParams: {
+        partner: "laBonneBoite",
+        route: this.lbbRoute.getCompany,
+      },
+      getCacheKey: (siret) => `lbb_${siret}`,
+      cb: async (siret): Promise<LaBonneBoiteApiResultV2Props[]> => {
+        return this.httpClient
+          .getCompany({
+            headers: {
+              authorization: await this.#makeAutorization(),
+            },
+            queryParams: {
+              siret,
+            },
+          })
+          .then((response) => {
+            if (response.status !== 200)
+              throw new Error(JSON.stringify(response));
+            return response.body?.items ?? [];
+          });
+      },
+    });
+    return this.#limiter.schedule(async () =>
+      cachedGetLbbResult(siret)
+        .then((result) => {
+          const item = result
+            .map(
+              (props: LaBonneBoiteApiResultV2Props) =>
+                new LaBonneBoiteCompanyDto(props),
+            )
+            .filter((result) => result.isCompanyRelevant())
+            .map((result) => result.toSearchResult(romeDto))
+            .at(0);
+
+          return item ?? null;
+        })
+        .catch((error) => {
+          logger.error({
+            error: castError(error),
+            message: "fetchCompanyBySiret_error",
             siret,
-          },
+            romeLabel: romeDto.romeLabel,
+          });
+          throw error;
         }),
-      )
-      .then((response) => {
-        if (response.status !== 200) throw new Error(JSON.stringify(response));
-
-        const item = response.body?.items
-          ?.map(
-            (props: LaBonneBoiteApiResultV2Props) =>
-              new LaBonneBoiteCompanyDto(props),
-          )
-          .filter((result) => result.isCompanyRelevant())
-          .map((result) => result.toSearchResult(romeDto))
-          .at(0);
-
-        return item ?? null;
-      })
-      .catch((error) => {
-        logger.error({
-          error: castError(error),
-          message: "fetchCompanyBySiret_error",
-          siret,
-          romeLabel: romeDto.romeLabel,
-        });
-        throw error;
-      });
+    );
   }
 
   async #makeAutorization(): Promise<string> {