From bd92d0847be05681ff713a2e3b72e02dd33ca7aa Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Thu, 9 May 2024 15:15:22 +0800
Subject: [PATCH] add some logs

---
 packages/api/src/routers/digest_router.ts | 2 ++
 packages/api/src/routers/task_router.ts   | 5 +++++
 2 files changed, 7 insertions(+)

diff --git a/packages/api/src/routers/digest_router.ts b/packages/api/src/routers/digest_router.ts
index 86f4cb632..c47ce93aa 100644
--- a/packages/api/src/routers/digest_router.ts
+++ b/packages/api/src/routers/digest_router.ts
@@ -347,9 +347,11 @@ export function digestRouter() {
 
       // cancel and remove the digest job
       await removeDigestJobs(userId)
+      logger.info(`Digest job removed: ${userId}`)
 
       // delete digest
       await deleteDigest(userId)
+      logger.info(`Digest deleted: ${userId}`)
 
       res.send({
         success: true,
diff --git a/packages/api/src/routers/task_router.ts b/packages/api/src/routers/task_router.ts
index a4e47f5f8..cd88d185a 100644
--- a/packages/api/src/routers/task_router.ts
+++ b/packages/api/src/routers/task_router.ts
@@ -55,11 +55,13 @@ export function taskRouter() {
     try {
       const job = await getJob(req.params.id)
       if (!job || !job.id) {
+        logger.info('Task not found')
         return res.sendStatus(404)
       }
 
       const jobState = await job.getState()
       if (jobState === 'active') {
+        logger.error('Task is active')
         // cannot delete active task
         return res.status(400).send('Task is active')
       }
@@ -68,9 +70,12 @@ export function taskRouter() {
       await job.remove()
 
       if (['completed', 'failed'].includes(jobState)) {
+        logger.info('Task removed')
         return res.status(200).send('Task removed')
       }
 
+      // job is waiting or delayed
+      logger.info('Task cancelled')
       res.status(200).send('Task cancelled')
     } catch (e) {
       logger.error('failed to delete task', e)