Better logs

indexnetwork · Jun 2, 2024 · f971f28 · f971f28
1 parent 31a0263
commit f971f28
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/api/src/libs/indexer.js b/api/src/libs/indexer.js
@@ -251,8 +251,7 @@ class Indexer {
     }
   }
   async processSubscription(chatId, subscription, item) {
-    console.log(chatId, item, `newUpdate`);
-    console.log("New update triggered, fetching item data", item.id);
+    console.log("New update triggered, fetching item data", chatId, item.id);
     const subscriptionResp = await redis.hGet(`subscriptions`, chatId);
     if (!subscriptionResp) {
       return;
@@ -273,7 +272,7 @@ class Indexer {
           responseType: "text",
         },
       );
-      console.log("Update evaluation response", resp.data);
+      console.log(`Update evaluation response for ${chatId}`, resp.data);
       if (resp.data && !resp.data.includes("NOT_RELEVANT")) {
         await redis.publish(`newUpdate:${chatId}`, resp.data);
       }

diff --git a/api/src/packages/api.js b/api/src/packages/api.js
@@ -520,14 +520,12 @@ app.delete(
 // Validators
 app.use(errorMiddleware);
 
-//app.get("/discovery/stream", );
-
 app.ws("/discovery/:chatId/updates", discoveryController.updates);
 
 const start = async () => {
   console.log("Starting API ...", port);
   await redis.connect();
-  await pubSubClient.connect()
+  await pubSubClient.connect();
 
   await setIndexedModelParams(app);
 

diff --git a/api/src/packages/consumer.js b/api/src/packages/consumer.js
@@ -42,16 +42,16 @@ async function start() {
     const streamId = parsedData.commitId.baseID.toString();
     const op = parsedData.eventType === 0 ? "c" : "u";
 
-    console.log("New event: ", modelId, streamId, op);
-
     try {
       switch (modelId) {
         case runtimeDefinition.models.IndexItem.id:
           switch (op) {
             case "c":
+              console.log(`IndexItem ${streamId} created`);
               await indexer.createIndexItemEvent(streamId);
               break;
             case "u":
+              console.log(`IndexItem ${streamId} updated`);
               await indexer.updateIndexItemEvent(streamId);
               break;
           }
@@ -63,16 +63,19 @@ async function start() {
               // We'll index objects only if they belong to an index.
               break;
             case "u":
+              console.log(`WebPage ${streamId} updated`);
               await indexer.updateWebPageEvent(streamId);
               break;
           }
           break;
         case runtimeDefinition.models.Embedding.id:
           switch (op) {
             case "c":
+              console.log(`Embedding ${streamId} created`);
               await indexer.createEmbeddingEvent(streamId);
               break;
             case "u":
+              console.log(`Embedding ${streamId} updated`);
               await indexer.updateEmbeddingEvent(streamId);
               break;
           }