create notifySlack functions

back/src/config/bootstrap/appConfig.ts

@@ -195,6 +195,10 @@ export class AppConfig {
     return this.env.DISCORD_WEBHOOK_URL;
   }
 
+  public get slackBotToken(): string | undefined {
+    return this.env.SLACK_BOT_TOKEN;
+  }
+
   public get documentGateway() {
     return this.#throwIfNotInArray({
       authorizedValues: ["NONE", "S3"],

back/src/config/helpers/handleHttpJsonResponseError.ts

@@ -4,7 +4,7 @@ import { Request, Response } from "express";
 import { HttpError, HttpErrorResponseBody } from "shared";
 import { ZodError } from "zod";
 import { LoggerParamsWithMessage, createLogger } from "../../utils/logger";
-import { notifyObjectDiscord } from "../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../utils/notifyTeam";
 
 const logger = createLogger(__filename);
 
@@ -105,5 +105,5 @@ const logErrorAndNotifyDiscord = (
   };
 
   logger.error(params);
-  notifyObjectDiscord(params);
+  notifyObjectToTeam(params);
 };

back/src/config/pg/kysely/kyselyUtils.ts

@@ -11,7 +11,7 @@ import {
 import { Pool, QueryResultRow } from "pg";
 import { Falsy } from "ramda";
 import { createLogger } from "../../../utils/logger";
-import { notifyObjectDiscord } from "../../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../../utils/notifyTeam";
 import { Database } from "./model/database";
 
 export const jsonBuildObject = <O extends Record<string, Expression<unknown>>>(
@@ -63,7 +63,7 @@ export const makeKyselyDb = (pool: Pool, options?: KyselyOptions): KyselyDb => {
             params: event.query.parameters,
           },
         };
-        notifyObjectDiscord(params);
+        notifyObjectToTeam(params);
         logger.error(params);
       } else if (event.queryDurationMillis > 1_000) {
         logger.warn({

back/src/domains/convention/adapters/france-travail-gateway/HttpFranceTravailGateway.ts

@@ -16,10 +16,7 @@ import {
   LoggerParamsWithMessage,
   createLogger,
 } from "../../../../utils/logger";
-import {
-  notifyDiscord,
-  notifyObjectDiscord,
-} from "../../../../utils/notifyDiscord";
+import { notifyObjectToTeam, notifyTeam } from "../../../../utils/notifyTeam";
 import { InMemoryCachingGateway } from "../../../core/caching-gateway/adapters/InMemoryCachingGateway";
 import {
   RetryStrategy,
@@ -175,7 +172,7 @@ export class HttpFranceTravailGateway implements FranceTravailGateway {
             },
           });
 
-          notifyDiscord(
+          notifyTeam(
             `HttpFranceTravailGateway notAxiosError ${
               ftConvention.originalId
             }: ${JSON.stringify(error)}`,
@@ -202,7 +199,7 @@ export class HttpFranceTravailGateway implements FranceTravailGateway {
             },
           });
 
-          notifyDiscord(
+          notifyTeam(
             `HttpFranceTravailGateway noResponseInAxiosError ${
               ftConvention.originalId
             }: ${JSON.stringify(error)}`,
@@ -255,7 +252,7 @@ export class HttpFranceTravailGateway implements FranceTravailGateway {
           },
         };
         logger.error(errorObject);
-        notifyObjectDiscord(errorObject);
+        notifyObjectToTeam(errorObject);
 
         return {
           status: error.response.status,

back/src/domains/core/authentication/ft-connect/adapters/ft-connect-gateway/HttpFtConnectGateway.ts

@@ -9,7 +9,7 @@ import {
   OpacifiedLogger,
   createLogger,
 } from "../../../../../../utils/logger";
-import { notifyObjectDiscord } from "../../../../../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../../../../../utils/notifyTeam";
 import { parseZodSchemaAndLogErrorOnParsingFailure } from "../../../../../../utils/schema.utils";
 import { AccessTokenDto } from "../../dto/AccessToken.dto";
 import { FtConnectAdvisorDto } from "../../dto/FtConnectAdvisor.dto";
@@ -141,7 +141,7 @@ export class HttpFtConnectGateway implements FtConnectGateway {
         (error) => {
           log.error({ error });
         },
-        (payload) => notifyDiscordOnNotError(payload),
+        (payload) => notifyTeamOnNotError(payload),
       );
       return manageFtConnectError(error, "exchangeCodeForAccessToken", {
         authorization: authorizationCode,
@@ -215,7 +215,7 @@ export class HttpFtConnectGateway implements FtConnectGateway {
         (error) => {
           log.error({ error });
         },
-        (payload) => notifyDiscordOnNotError(payload),
+        (payload) => notifyTeamOnNotError(payload),
       );
       return error instanceof ZodError
         ? false
@@ -256,7 +256,7 @@ export class HttpFtConnectGateway implements FtConnectGateway {
         (error) => {
           log.error({ error });
         },
-        (payload) => notifyDiscordOnNotError(payload),
+        (payload) => notifyTeamOnNotError(payload),
       );
       if (error instanceof ZodError) return undefined;
       return manageFtConnectError(error, "getUserInfo", {
@@ -297,11 +297,11 @@ export class HttpFtConnectGateway implements FtConnectGateway {
         (error) => {
           log.error({ error });
         },
-        (payload) => notifyDiscordOnNotError(payload),
+        (payload) => notifyTeamOnNotError(payload),
       );
       if (error instanceof ZodError) return [];
       if (isJobseekerButNoAdvisorsResponse(error)) {
-        notifyObjectDiscord({
+        notifyObjectToTeam({
           message: `isJobseekerButNoAdvisorsResponse for token: ${headers.Authorization}`,
           error,
         });
@@ -347,8 +347,8 @@ const errorChecker = (
   cbOnNotError: (stuff: unknown) => void,
 ): void => (error instanceof Error ? cbOnError(error) : cbOnNotError(error));
 
-const notifyDiscordOnNotError = (payload: unknown): void =>
-  notifyObjectDiscord({
+const notifyTeamOnNotError = (payload: unknown): void =>
+  notifyObjectToTeam({
     message: "Should have been an error.",
     payload,
   });

back/src/domains/core/authentication/inclusion-connect/use-cases/AuthenticateWithInclusionCode.ts

@@ -13,7 +13,7 @@ import {
   frontRoutes,
   queryParamsAsString,
 } from "shared";
-import { notifyDiscord } from "../../../../../utils/notifyDiscord";
+import { notifyTeam } from "../../../../../utils/notifyTeam";
 import {
   AgencyRightOfUser,
   removeAgencyRightsForUser,
@@ -148,7 +148,7 @@ export class AuthenticateWithInclusionCode extends TransactionalUseCase<
     };
 
     if (!newOrUpdatedAuthenticatedUser.externalId) {
-      notifyDiscord(
+      notifyTeam(
         `Usecase AuthenticateWithInclusionCode. No ongoing_oauths found for externalId:
           ${newOrUpdatedAuthenticatedUser.id}`,
       );

back/src/domains/core/events/adapters/EventCrawlerImplementations.ts

@@ -4,7 +4,7 @@ import {
   LoggerParamsWithMessage,
   createLogger,
 } from "../../../../utils/logger";
-import { notifyObjectDiscord } from "../../../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../../../utils/notifyTeam";
 import { UnitOfWorkPerformer } from "../../unit-of-work/ports/UnitOfWorkPerformer";
 import { DomainEvent, EventStatus } from "../events";
 import { EventBus } from "../ports/EventBus";
@@ -36,7 +36,7 @@ export class BasicEventCrawler implements EventCrawler {
       message: `${status} outbox ${count} exceeds ${limit}`,
     };
     logger.error(params);
-    notifyObjectDiscord(params);
+    notifyObjectToTeam(params);
   }
 
   public async processNewEvents(): Promise<void> {
@@ -104,7 +104,7 @@ export class BasicEventCrawler implements EventCrawler {
           message: "Processing event group is taking long",
           events: eventGroup,
         };
-        notifyObjectDiscord(warning);
+        notifyObjectToTeam(warning);
         logger.warn(warning);
       }, 30_000);
 
@@ -135,7 +135,7 @@ export class BasicEventCrawler implements EventCrawler {
         };
 
         logger.error(params);
-        notifyObjectDiscord({
+        notifyObjectToTeam({
           params,
         });
 

back/src/domains/core/events/adapters/InMemoryEventBus.ts

@@ -2,7 +2,7 @@ import * as Sentry from "@sentry/node";
 import { keys, prop } from "ramda";
 import { DateString, errorToString } from "shared";
 import { createLogger } from "../../../../utils/logger";
-import { notifyObjectDiscord } from "../../../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../../../utils/notifyTeam";
 import { TimeGateway } from "../../time-gateway/ports/TimeGateway";
 import { UnitOfWorkPerformer } from "../../unit-of-work/ports/UnitOfWorkPerformer";
 import {
@@ -118,7 +118,7 @@ export class InMemoryEventBus implements EventBus {
       const message = "Failed too many times, event will be Quarantined";
       logger.error({ events: [event], message });
       const { payload: _, publications: __, ...restEvent } = event;
-      notifyObjectDiscord({
+      notifyObjectToTeam({
         event: {
           ...restEvent,
           lastPublication: getLastPublication(event),

back/src/domains/establishment/adapters/PgFormEstablishmentRepository.ts

@@ -13,7 +13,7 @@ import {
   jsonStripNulls,
 } from "../../../config/pg/kysely/kyselyUtils";
 import { createLogger } from "../../../utils/logger";
-import { notifyObjectDiscord } from "../../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../../utils/notifyTeam";
 import { FormEstablishmentRepository } from "../ports/FormEstablishmentRepository";
 
 const logger = createLogger(__filename);
@@ -58,7 +58,7 @@ export class PgFormEstablishmentRepository
           message: "Cannot save form establishment ",
           error: castedError,
         });
-        notifyObjectDiscord({
+        notifyObjectToTeam({
           _message: `Cannot create form establishment with siret ${formEstablishment.siret}`,
           ...castedError,
         });

back/src/domains/establishment/adapters/pass-emploi/HttpPassEmploiGateway.ts

@@ -1,6 +1,6 @@
 import { createAxiosInstance } from "../../../../utils/axiosUtils";
 import { createLogger } from "../../../../utils/logger";
-import { notifyAndThrowErrorDiscord } from "../../../../utils/notifyDiscord";
+import { notifyToTeamAndThrowError } from "../../../../utils/notifyTeam";
 import {
   PassEmploiGateway,
   PassEmploiNotificationParams,
@@ -26,7 +26,7 @@ export class HttpPassEmploiGateway implements PassEmploiGateway {
     });
 
     if (response.status !== 202) {
-      notifyAndThrowErrorDiscord(
+      notifyToTeamAndThrowError(
         new Error(
           `Could not notify Pass-Emploi : ${response.status} ${response.statusText}`,
         ),

back/src/domains/establishment/use-cases/ContactEstablishment.ts

@@ -9,7 +9,7 @@ import {
   errors,
   normalizedMonthInDays,
 } from "shared";
-import { notifyAndThrowErrorDiscord } from "../../../utils/notifyDiscord";
+import { notifyToTeamAndThrowError } from "../../../utils/notifyTeam";
 import { TransactionalUseCase } from "../../core/UseCase";
 import { makeProvider } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { CreateNewEvent } from "../../core/events/ports/EventBus";
@@ -106,7 +106,7 @@ export class ContactEstablishment extends TransactionalUseCase<ContactEstablishm
     )?.appellationLabel;
 
     if (!appellationLabel) {
-      notifyAndThrowErrorDiscord(
+      notifyToTeamAndThrowError(
         errors.establishment.offerMissing({
           siret,
           appellationCode: contactRequest.appellationCode,

back/src/domains/establishment/use-cases/InsertEstablishmentAggregateFromFormEstablishement.ts

@@ -5,7 +5,7 @@ import {
   withFormEstablishmentSchema,
 } from "shared";
 import { rawAddressToLocation } from "../../../utils/address";
-import { notifyAndThrowErrorDiscord } from "../../../utils/notifyDiscord";
+import { notifyToTeamAndThrowError } from "../../../utils/notifyTeam";
 import { getNafAndNumberOfEmployee } from "../../../utils/siret";
 import { TransactionalUseCase } from "../../core/UseCase";
 import { AddressGateway } from "../../core/address/ports/AddressGateway";
@@ -110,7 +110,7 @@ export class InsertEstablishmentAggregateFromForm extends TransactionalUseCase<
     await uow.establishmentAggregateRepository
       .insertEstablishmentAggregate(establishmentAggregate)
       .catch((err) => {
-        notifyAndThrowErrorDiscord(
+        notifyToTeamAndThrowError(
           new Error(
             `Error when adding establishment aggregate with siret ${formEstablishment.siret} due to ${err}`,
           ),

back/src/domains/establishment/use-cases/LegacyContactEstablishment.ts

@@ -7,7 +7,7 @@ import {
   legacyContactEstablishmentRequestSchema,
   normalizedMonthInDays,
 } from "shared";
-import { notifyAndThrowErrorDiscord } from "../../../utils/notifyDiscord";
+import { notifyToTeamAndThrowError } from "../../../utils/notifyTeam";
 import { TransactionalUseCase } from "../../core/UseCase";
 import { makeProvider } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { CreateNewEvent } from "../../core/events/ports/EventBus";
@@ -100,7 +100,7 @@ export class LegacyContactEstablishment extends TransactionalUseCase<LegacyConta
     )?.appellationLabel;
 
     if (!appellationLabel) {
-      notifyAndThrowErrorDiscord(
+      notifyToTeamAndThrowError(
         errors.establishment.offerMissing({
           appellationCode: contactRequest.appellationCode,
           siret,

back/src/domains/establishment/use-cases/SuggestEditEstablishment.ts

@@ -6,7 +6,7 @@ import {
   immersionFacileNoReplyEmailSender,
   siretSchema,
 } from "shared";
-import { notifyObjectDiscord } from "../../../utils/notifyDiscord";
+import { notifyObjectToTeam } from "../../../utils/notifyTeam";
 import { TransactionalUseCase } from "../../core/UseCase";
 import { makeProvider } from "../../core/authentication/inclusion-connect/port/OAuthGateway";
 import { GenerateEditFormEstablishmentJwt } from "../../core/jwt";
@@ -82,6 +82,6 @@ export class SuggestEditEstablishment extends TransactionalUseCase<SiretDto> {
       followedIds: {
         establishmentSiret: siret,
       },
-    }).catch((error) => notifyObjectDiscord(error));
+    }).catch((error) => notifyObjectToTeam(error));
   }
 }