Merge pull request #755 from elie222/fix/mark-processing

Author: elie222

apps/web/app/api/google/webhook/process-history-item.ts

@@ -65,6 +65,13 @@ export async function processHistoryItem(
     provider: "google",
   });
 
+  const isFree = await markMessageAsProcessing({ userEmail, messageId });
+
+  if (!isFree) {
+    logger.info("Skipping. Message already being processed.", loggerOptions);
+    return;
+  }
+
   if (type === HistoryEventType.LABEL_REMOVED) {
     logger.info("Processing label removed event for learning", loggerOptions);
     return handleLabelRemovedEvent(item, {
@@ -76,13 +83,6 @@ export async function processHistoryItem(
     return;
   }
 
-  const isFree = await markMessageAsProcessing({ userEmail, messageId });
-
-  if (!isFree) {
-    logger.info("Skipping. Message already being processed.", loggerOptions);
-    return;
-  }
-
   logger.info("Getting message", loggerOptions);
 
   try {

version.txt

@@ -1 +1 @@
-v2.9.0
+v2.9.1