refacto: rename variables and types

gip-inclusion · Sep 17, 2024 · 8ddb106 · 8ddb106
1 parent 0f71abc
commit 8ddb106
Show file tree

Hide file tree

Showing 37 changed files with 1,133 additions and 1,071 deletions.
diff --git a/back/src/config/bootstrap/inclusionConnectAuthMiddleware.ts b/back/src/config/bootstrap/inclusionConnectAuthMiddleware.ts
@@ -1,6 +1,6 @@
 import { NextFunction, Request, Response } from "express";
 import { errors, inclusionConnectTokenExpiredMessage } from "shared";
-import { oAuthModeByFeatureFlags } from "../../domains/core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../domains/core/authentication/inclusion-connect/port/OAuthGateway";
 import { makeVerifyJwtES256 } from "../../domains/core/jwt";
 import { UnitOfWorkPerformer } from "../../domains/core/unit-of-work/ports/UnitOfWorkPerformer";
 
@@ -25,7 +25,7 @@ export const makeInclusionConnectAuthMiddleware = (
       const currentIcUser = await uowPerformer.perform(async (uow) =>
         uow.userRepository.getById(
           payload.userId,
-          oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+          oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
         ),
       );
       if (!currentIcUser)

diff --git a/back/src/domains/agency/use-cases/RegisterAgencyToInclusionConnectUser.ts b/back/src/domains/agency/use-cases/RegisterAgencyToInclusionConnectUser.ts
@@ -5,7 +5,7 @@ import {
   errors,
 } from "shared";
 import { TransactionalUseCase } from "../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { CreateNewEvent } from "../../core/events/ports/EventBus";
 import { UnitOfWork } from "../../core/unit-of-work/ports/UnitOfWork";
 import { UnitOfWorkPerformer } from "../../core/unit-of-work/ports/UnitOfWorkPerformer";
@@ -36,7 +36,7 @@ export class RegisterAgencyToInclusionConnectUser extends TransactionalUseCase<
 
     const user = await uow.userRepository.getById(
       inclusionConnectedPayload.userId,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
 
     if (!user)

diff --git a/back/src/domains/convention/use-cases/GetApiConsumersByConvention.ts b/back/src/domains/convention/use-cases/GetApiConsumersByConvention.ts
@@ -9,7 +9,7 @@ import {
   withConventionIdSchema,
 } from "shared";
 import { createTransactionalUseCase } from "../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 
 export type GetApiConsumersByConvention = ReturnType<
   typeof makeGetApiConsumersByConvention
@@ -33,7 +33,7 @@ export const makeGetApiConsumersByConvention = createTransactionalUseCase<
 
     const user = await uow.userRepository.getById(
       currentUser.id,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
 
     if (!user)

diff --git a/back/src/domains/convention/use-cases/GetConvention.ts b/back/src/domains/convention/use-cases/GetConvention.ts
@@ -6,7 +6,7 @@ import {
   ConventionReadDto,
   ConventionRelatedJwtPayload,
   InclusionConnectJwtPayload,
-  OAuthProvider,
+  OAuthGatewayProvider,
   WithConventionId,
   getIcUserRoleForAccessingConvention,
   stringToMd5,
@@ -15,7 +15,7 @@ import {
 import { ForbiddenError, NotFoundError } from "shared";
 import { conventionEmailsByRole } from "../../../utils/convention";
 import { TransactionalUseCase } from "../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { UserRepository } from "../../core/authentication/inclusion-connect/port/UserRepository";
 import { UnitOfWork } from "../../core/unit-of-work/ports/UnitOfWork";
 
@@ -46,7 +46,7 @@ export class GetConvention extends TransactionalUseCase<
       conventionId,
     );
 
-    const mode = oAuthModeByFeatureFlags(
+    const provider = oAuthProviderByFeatureFlags(
       await uow.featureFlagRepository.getAll(),
     );
 
@@ -55,7 +55,7 @@ export class GetConvention extends TransactionalUseCase<
         authPayload,
         uow,
         convention,
-        provider: mode,
+        provider: provider,
       });
     }
 
@@ -64,7 +64,7 @@ export class GetConvention extends TransactionalUseCase<
         authPayload,
         uow,
         convention,
-        mode,
+        provider: provider,
       });
     }
 
@@ -80,7 +80,7 @@ export class GetConvention extends TransactionalUseCase<
     authPayload: ConventionDomainPayload;
     convention: ConventionReadDto;
     uow: UnitOfWork;
-    provider: OAuthProvider;
+    provider: OAuthGatewayProvider;
   }): Promise<ConventionReadDto> {
     const agency = await uow.agencyRepository.getById(convention.agencyId);
     if (!agency) {
@@ -106,14 +106,14 @@ export class GetConvention extends TransactionalUseCase<
     authPayload,
     convention,
     uow,
-    mode,
+    provider,
   }: {
     authPayload: InclusionConnectJwtPayload;
     convention: ConventionReadDto;
     uow: UnitOfWork;
-    mode: OAuthProvider;
+    provider: OAuthGatewayProvider;
   }): Promise<ConventionReadDto> {
-    const user = await uow.userRepository.getById(authPayload.userId, mode);
+    const user = await uow.userRepository.getById(authPayload.userId, provider);
     if (!user)
       throw new NotFoundError(`No user found with id '${authPayload.userId}'`);
 
@@ -150,7 +150,7 @@ export class GetConvention extends TransactionalUseCase<
     convention: ConventionReadDto;
     agency: AgencyDto;
     userRepository: UserRepository;
-    provider: OAuthProvider;
+    provider: OAuthGatewayProvider;
   }): Promise<boolean> {
     const emailsByRole = conventionEmailsByRole(convention, agency)[
       authPayload.role
@@ -188,7 +188,7 @@ export class GetConvention extends TransactionalUseCase<
     authPayload: ConventionDomainPayload;
     userRepository: UserRepository;
     agencyId: AgencyId;
-    provider: OAuthProvider;
+    provider: OAuthGatewayProvider;
   }) {
     if (authPayload.role !== "counsellor" && authPayload.role !== "validator")
       return false;

diff --git a/back/src/domains/convention/use-cases/RenewConvention.ts b/back/src/domains/convention/use-cases/RenewConvention.ts
@@ -11,7 +11,7 @@ import {
 } from "shared";
 import { BadRequestError, ForbiddenError, NotFoundError } from "shared";
 import { TransactionalUseCase } from "../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { UnitOfWork } from "../../core/unit-of-work/ports/UnitOfWork";
 import { UnitOfWorkPerformer } from "../../core/unit-of-work/ports/UnitOfWorkPerformer";
 import { AddConvention } from "./AddConvention";
@@ -95,7 +95,7 @@ export class RenewConvention extends TransactionalUseCase<
 
     const inclusionConnectedUser = await uow.userRepository.getById(
       jwtPayload.userId,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
     if (!inclusionConnectedUser)
       throw new NotFoundError(

diff --git a/back/src/domains/convention/use-cases/SignConvention.ts b/back/src/domains/convention/use-cases/SignConvention.ts
@@ -14,7 +14,7 @@ import {
 } from "shared";
 import { ForbiddenError, NotFoundError } from "shared";
 import { TransactionalUseCase } from "../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { DomainTopic } from "../../core/events/events";
 import { CreateNewEvent } from "../../core/events/ports/EventBus";
 import { TimeGateway } from "../../core/time-gateway/ports/TimeGateway";
@@ -113,7 +113,7 @@ export class SignConvention extends TransactionalUseCase<
       return { role: jwtPayload.role, icUser: undefined };
     const icUser = await uow.userRepository.getById(
       jwtPayload.userId,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
     if (!icUser)
       throw new NotFoundError(`No user found with id '${jwtPayload.userId}'`);

diff --git a/back/src/domains/convention/use-cases/UpdateConventionStatus.ts b/back/src/domains/convention/use-cases/UpdateConventionStatus.ts
@@ -6,7 +6,7 @@ import {
   ConventionStatus,
   Email,
   InclusionConnectedUser,
-  OAuthProvider,
+  OAuthGatewayProvider,
   Role,
   UpdateConventionStatusRequestDto,
   UserId,
@@ -20,7 +20,7 @@ import {
   validatedConventionStatuses,
 } from "shared";
 import { TransactionalUseCase } from "../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { ConventionRequiresModificationPayload } from "../../core/events/eventPayload.dto";
 import {
   DomainTopic,
@@ -85,14 +85,14 @@ export class UpdateConventionStatus extends TransactionalUseCase<
         agencyId: conventionRead.agencyId,
       });
 
-    const mode = oAuthModeByFeatureFlags(
+    const provider = oAuthProviderByFeatureFlags(
       await uow.featureFlagRepository.getAll(),
     );
 
     const { user, roleInPayload } = await this.#getRoleInPayloadOrUser(
       uow,
       payload,
-      mode,
+      provider,
     );
 
     const roles = roleInPayload
@@ -184,7 +184,7 @@ export class UpdateConventionStatus extends TransactionalUseCase<
                       uow,
                       payload,
                       conventionRead,
-                      mode,
+                      provider,
                     ),
                     triggeredBy,
                   }
@@ -210,15 +210,15 @@ export class UpdateConventionStatus extends TransactionalUseCase<
   async #getRoleInPayloadOrUser(
     uow: UnitOfWork,
     payload: UpdateConventionStatusSupportedJwtPayload,
-    mode: OAuthProvider,
+    provider: OAuthGatewayProvider,
   ): Promise<
     | { user: InclusionConnectedUser; roleInPayload: undefined }
     | { user: undefined; roleInPayload: Role }
   > {
     if ("role" in payload)
       return { roleInPayload: payload.role, user: undefined };
 
-    const user = await uow.userRepository.getById(payload.userId, mode);
+    const user = await uow.userRepository.getById(payload.userId, provider);
     if (!user)
       throw errors.user.notFound({
         userId: payload.userId,
@@ -260,9 +260,9 @@ export class UpdateConventionStatus extends TransactionalUseCase<
     uow: UnitOfWork,
     userId: UserId,
     agencyId: AgencyId,
-    mode: OAuthProvider,
+    provider: OAuthGatewayProvider,
   ): Promise<string> {
-    const user = await uow.userRepository.getById(userId, mode);
+    const user = await uow.userRepository.getById(userId, provider);
     if (!user) throw errors.user.notFound({ userId });
     const userAgencyRights = user.agencyRights.find(
       (agencyRight) => agencyRight.agency.id === agencyId,
@@ -300,7 +300,7 @@ export class UpdateConventionStatus extends TransactionalUseCase<
     uow: UnitOfWork,
     payload: UpdateConventionStatusSupportedJwtPayload,
     originalConvention: ConventionDto,
-    mode: OAuthProvider,
+    provider: OAuthGatewayProvider,
   ): Promise<string> => {
     const getEmailFromEmailHash = async (
       agencyId: AgencyId,
@@ -329,7 +329,7 @@ export class UpdateConventionStatus extends TransactionalUseCase<
         uow,
         payload.userId,
         originalConvention.agencyId,
-        mode,
+        provider,
       );
       return agencyIcUserEmail;
     }

diff --git a/back/src/domains/convention/use-cases/notifications/NotifyIcUserAgencyRightChanged.ts b/back/src/domains/convention/use-cases/notifications/NotifyIcUserAgencyRightChanged.ts
@@ -1,6 +1,6 @@
 import { UserParamsForAgency, errors, userParamsForAgencySchema } from "shared";
 import { TransactionalUseCase } from "../../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { SaveNotificationAndRelatedEvent } from "../../../core/notifications/helpers/Notification";
 import { UnitOfWork } from "../../../core/unit-of-work/ports/UnitOfWork";
 import { UnitOfWorkPerformer } from "../../../core/unit-of-work/ports/UnitOfWorkPerformer";
@@ -30,7 +30,7 @@ export class NotifyIcUserAgencyRightChanged extends TransactionalUseCase<
 
     const user = await uow.userRepository.getById(
       params.userId,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
     if (!user) throw errors.user.notFound({ userId: params.userId });
 

diff --git a/back/src/domains/convention/use-cases/notifications/NotifyIcUserAgencyRightRejected.ts b/back/src/domains/convention/use-cases/notifications/NotifyIcUserAgencyRightRejected.ts
@@ -4,7 +4,7 @@ import {
   rejectIcUserRoleForAgencyParamsSchema,
 } from "shared";
 import { TransactionalUseCase } from "../../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { SaveNotificationAndRelatedEvent } from "../../../core/notifications/helpers/Notification";
 import { UnitOfWork } from "../../../core/unit-of-work/ports/UnitOfWork";
 import { UnitOfWorkPerformer } from "../../../core/unit-of-work/ports/UnitOfWorkPerformer";
@@ -35,7 +35,7 @@ export class NotifyIcUserAgencyRightRejected extends TransactionalUseCase<
 
     const user = await uow.userRepository.getById(
       params.userId,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
 
     if (!user) throw errors.user.notFound({ userId: params.userId });

diff --git a/...onvention/use-cases/partners-errored-convention/MarkPartnersErroredConventionAsHandled.ts b/...onvention/use-cases/partners-errored-convention/MarkPartnersErroredConventionAsHandled.ts
@@ -5,7 +5,7 @@ import {
   markPartnersErroredConventionAsHandledRequestSchema,
 } from "shared";
 import { TransactionalUseCase } from "../../../core/UseCase";
-import { oAuthModeByFeatureFlags } from "../../../core/authentication/inclusion-connect/port/OAuthGateway";
+import { oAuthProviderByFeatureFlags } from "../../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { CreateNewEvent } from "../../../core/events/ports/EventBus";
 import { TimeGateway } from "../../../core/time-gateway/ports/TimeGateway";
 import { UnitOfWork } from "../../../core/unit-of-work/ports/UnitOfWork";
@@ -45,7 +45,7 @@ export class MarkPartnersErroredConventionAsHandled extends TransactionalUseCase
 
     const currentUser = await uow.userRepository.getById(
       userId,
-      oAuthModeByFeatureFlags(await uow.featureFlagRepository.getAll()),
+      oAuthProviderByFeatureFlags(await uow.featureFlagRepository.getAll()),
     );
     if (!currentUser) throw errors.user.notFound({ userId });
     const userAgencyRights = currentUser.agencyRights.find(

diff --git a/...re/authentication/inclusion-connect/adapters/PgOngoingOAuthRepository.integration.test.ts b/...re/authentication/inclusion-connect/adapters/PgOngoingOAuthRepository.integration.test.ts
@@ -1,5 +1,10 @@
 import { Pool } from "pg";
-import { IdentityProvider, User, expectToEqual, oAuthProviders } from "shared";
+import {
+  IdentityProvider,
+  User,
+  expectToEqual,
+  oAuthGatewayProviders,
+} from "shared";
 import {
   KyselyDb,
   makeKyselyDb,
@@ -31,7 +36,7 @@ describe("PgOngoingOAuthRepository", () => {
     await pool.end();
   });
 
-  describe.each(oAuthProviders)("with mode '%s'", (mode) => {
+  describe.each(oAuthGatewayProviders)("with mode '%s'", (mode) => {
     it("saves an ongoing OAuth, then gets it from its states, then updates it", async () => {
       const state = "11111111-1111-1111-1111-111111111111";