From 973f852a82bd0b02aea1191b7ef4c2187318c04c Mon Sep 17 00:00:00 2001
From: "Paul G." <ohpaul.g@gmail.com>
Date: Wed, 25 Sep 2024 09:14:01 +0200
Subject: [PATCH] fix: ajout de l'authsource pour airbyte (#3833)

Co-authored-by: Paul Gaucher <paul@paulinformatique.com>
---
 server/src/common/mongodb.ts                     | 5 ++++-
 server/src/jobs/hydrate/deca/hydrate-deca-raw.ts | 2 +-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/server/src/common/mongodb.ts b/server/src/common/mongodb.ts
index c93be625b..f4afebc3d 100644
--- a/server/src/common/mongodb.ts
+++ b/server/src/common/mongodb.ts
@@ -14,7 +14,10 @@ const ensureInitialization = (client: MongoClient | null): MongoClient => {
   return client;
 };
 
-export const getMongodbUri = (dbName = config.mongodb.dbName) => {
+export const getMongodbUri = (dbName: string = config.mongodb.dbName, withMainDbAuthent: boolean = false) => {
+  if (withMainDbAuthent) {
+    return `${config.mongodb.uri}${dbName}?${config.mongodb.options}&authSource=${config.mongodb.dbName}`;
+  }
   return `${config.mongodb.uri}${dbName}?${config.mongodb.options}`;
 };
 /**
diff --git a/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts b/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts
index 8abc2990f..b56a0c69d 100644
--- a/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts
+++ b/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts
@@ -21,7 +21,7 @@ import { __dirname } from "@/common/utils/esmUtils";
 
 const logger = parentLogger.child({ module: "job:hydrate:contrats-deca-raw" });
 
-const client = new MongoClient(getMongodbUri("airbyte") ?? "");
+const client = new MongoClient(getMongodbUri("airbyte", true));
 
 export async function hydrateDecaRaw() {
   let count = 0;