DOP-4599 logging

mongodb · Jun 6, 2024 · dbf9c6e · dbf9c6e
1 parent 25b5e1e
commit dbf9c6e
Show file tree

Hide file tree

Showing 6 changed files with 7 additions and 2 deletions.
diff --git a/api/controllers/v1/slack.ts b/api/controllers/v1/slack.ts
@@ -236,6 +236,7 @@ export const DeployRepo = async (event: any = {}): Promise<any> => {
   }
   if (deployable.length > 0) {
     try {
+      console.log('deploying repos');
       await deployRepo(deployable, consoleLogger, jobRepository, c.get('jobsQueueUrl'));
     } catch (e) {
       return prepResponse(401, 'text/plain', `${e} error deploying repos`);

diff --git a/src/enhanced/utils/job/handle-job.ts b/src/enhanced/utils/job/handle-job.ts
@@ -66,6 +66,7 @@ export async function handleJob(jobId: string, db: mongodb.Db) {
 
   try {
     await jobManager.startSpecificJob(jobId);
+    console.log('in enhanced app handle job');
   } catch (err) {
     consoleLogger.info('enhancedApp', err);
   }

diff --git a/src/onDemandApp.ts b/src/onDemandApp.ts
@@ -72,6 +72,7 @@ async function init(): Promise<void> {
   );
   try {
     await jobManager.startSpecificJob(c.get('jobId'));
+    console.log('in onDemandApp');
   } catch (err) {
     consoleLogger.info('onDemandApp', err);
   }

diff --git a/src/repositories/baseRepository.ts b/src/repositories/baseRepository.ts
@@ -28,6 +28,7 @@ export abstract class BaseRepository {
 
   protected async insertMany(docs: Array<any>, errorMsg: string): Promise<any> {
     try {
+      console.log('inserting many');
       const insertManyResult = await this.promiseTimeoutS(
         this._config.get('MONGO_TIMEOUT_S'),
         this._collection.insertMany(docs),
@@ -36,6 +37,7 @@ export abstract class BaseRepository {
       if (insertManyResult?.insertedIds) {
         return insertManyResult.insertedIds;
       }
+      console.log('returned null for insertMany??');
       return null;
     } catch (error) {
       this._logger.error(`${this._repoName}:upsert`, `Failed to insert job (${JSON.stringify(docs)}) error: ${error}`);

diff --git a/src/repositories/jobRepository.ts b/src/repositories/jobRepository.ts
@@ -71,7 +71,7 @@ export class JobRepository extends BaseRepository {
     // Insertion/re-enqueueing should be sent to jobs queue and updates for an existing job should be sent to jobUpdates Queue
     this._logger.info(
       'insertBulkJobs',
-      `Total Jobs Expected : ${jobs.length}, Jobs: ${JSON.stringify(jobIds)}, Total Jobs Sent: ${jobIds.length}`
+      `Total Jobs Expected : ${jobs.length}, Jobs: ${JSON.stringify(jobIds)}, Total Jobs Sent: ${jobIds.keys().length}`
     );
     await Promise.all(
       Object.values(jobIds).map(async (jobId: string) => {

diff --git a/src/repositories/repoEntitlementsRepository.ts b/src/repositories/repoEntitlementsRepository.ts
@@ -52,14 +52,14 @@ export class RepoEntitlementsRepository extends BaseRepository {
       throw new Error('getIsAdmin function must be given at least one argument');
     }
     let query;
-    console.log('getIsAdmin function called');
     if (slackUserId) {
       query = { slack_user_id: slackUserId };
     } else query = { github_username: githubUsername };
     const entitlementsObject = await this.findOne(
       query,
       `Mongo Timeout Error: Timedout while retrieving entitlements for ${slackUserId}`
     );
+    console.log(`getIsAdmin function called, ${entitlementsObject?.admin}`);
     return entitlementsObject?.admin;
   }