From d1d7f93fc34ec8495a478908d3d91e0052c5dd79 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Wed, 29 May 2024 17:58:28 +0800
Subject: [PATCH] time each steps in the update home job

---
 packages/api/src/jobs/update_home.ts | 26 +++++++++++++++++++++-----
 packages/api/src/services/score.ts   |  1 -
 2 files changed, 21 insertions(+), 6 deletions(-)

diff --git a/packages/api/src/jobs/update_home.ts b/packages/api/src/jobs/update_home.ts
index 504b9aaa9..64ab91ff1 100644
--- a/packages/api/src/jobs/update_home.ts
+++ b/packages/api/src/jobs/update_home.ts
@@ -389,8 +389,12 @@ export const updateHome = async (data: UpdateHomeJobData) => {
 
   logger.info(`Updating home for user ${userId}`)
 
+  logger.profile('selecting')
   const candidates = await selectCandidates(user)
-  logger.info(`Found ${candidates.length} candidates`)
+  logger.profile('selecting', {
+    level: 'info',
+    message: `Found ${candidates.length} candidates`,
+  })
 
   if (candidates.length <= 10) {
     logger.info('Not enough candidates found')
@@ -399,20 +403,32 @@ export const updateHome = async (data: UpdateHomeJobData) => {
 
   // TODO: integrity check on candidates
 
-  logger.info('Ranking candidates')
+  logger.profile('ranking')
   const rankedCandidates = await rankCandidates(userId, candidates)
   if (rankedCandidates.length === 0) {
     logger.info('No candidates found')
     return
   }
+  logger.profile('ranking', {
+    level: 'info',
+    message: `Ranked ${rankedCandidates.length} candidates`,
+  })
 
   // TODO: filter candidates
 
-  logger.info('Mix home items to create sections')
+  logger.profile('mixing')
   const rankedSections = mixHomeItems(rankedCandidates)
-  logger.info(`Created ${rankedSections.length} sections`)
+  logger.profile('mixing', {
+    level: 'info',
+    message: `Created ${rankedSections.length} sections`,
+  })
 
-  logger.info('Appending sections to home')
+  logger.profile('saving')
   await appendSectionsToHome(userId, rankedSections, cursor)
+  logger.profile('saving', {
+    level: 'info',
+    message: 'Sections appended to home',
+  })
+
   logger.info('Home updated for user', { userId })
 }
diff --git a/packages/api/src/services/score.ts b/packages/api/src/services/score.ts
index 545049999..bad4519be 100644
--- a/packages/api/src/services/score.ts
+++ b/packages/api/src/services/score.ts
@@ -37,7 +37,6 @@ export const getScores = async (
     method: 'POST',
     headers: {
       'Content-Type': 'application/json',
-      // Authorization: `Bearer ${token}`,
     },
     body: JSON.stringify(data),
   })