update

routes/webhook.js

@@ -64,9 +64,10 @@ router.post('/kb/reindex', async (req, res) => {
   if (!kb) {
     winston.warn("(webhook) Kb content not found with id ", content_id);
     // Assuming the content has been deleted. The scheduler should be stopped and deleted.
-    let aiReindexService = new AiReindexService(content_id);
-    let deleteResponse = await aiReindexService.delete().catch((err) => {
+    let aiReindexService = new AiReindexService();
+    let deleteResponse = await aiReindexService.delete(content_id).catch((err) => {
       winston.error("(webhook) Error deleting scheduler ", err);
+      winston.error("(webhook) Error deleting scheduler " + err);
       return res.status(500).send({ success: false, message: "Content no longer exists. Error deleting scheduler", error: err })
     });
     winston.debug("(webhook) delete response: ", deleteResponse);

services/aiReindexService.js

@@ -30,10 +30,12 @@ class AiReindexService {
 
         return new Promise( async (resolve, reject) => {
 
+            console.log("search and delete scheduler for content ", content_id)
             let scheduler = await this.findScheduler(content_id).catch((err) => {
                 reject(err);
             })
 
+            console.log("scheduler: ", scheduler)
             winston.verbose("(AiReindexService) delete() - scheduler: ", scheduler);
 
             if (!scheduler) {
@@ -73,6 +75,7 @@ class AiReindexService {
                 }
             }).then((response) => {
 
+                console.log("schedulers found: ", response.data.data)
                 let scheduler = response.data.data.find(s => s.processDefinitionName === "auto-reindex-" + id);
                 if (!scheduler) {
                     resolve(null);