fix: ajout de l'authsource pour airbyte (#3833)

Co-authored-by: Paul Gaucher <[email protected]>
mission-apprentissage · Sep 25, 2024 · 973f852 · 973f852
1 parent f14dc9b
commit 973f852
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git 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
@@ -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;