updates

Author: michelle0927

components/elmah_io/sources/new-error/new-error.mjs

@@ -2,7 +2,7 @@ import elmah_io from "../../elmah_io.app.mjs";
 import constants from "../common/constants.mjs";
 import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 
-const QUERY = "isNew:true AND (severity:Error OR severity:Fatal)";
+const QUERY = "severity:Error OR severity:Fatal";
 
 export default {
   name: "New Error",
@@ -36,15 +36,15 @@ export default {
     emitEvent(event) {
       this.$emit(event, {
         id: event.id,
-        summary: `New error with id ${event.id}`,
+        summary: `New error with ID ${event.id}`,
         ts: Date.parse(event.dateTime),
       });
     },
     _setLastEventDatetime(datetime) {
       this.db.set("lastEventDatetime", datetime);
     },
     _getLastEventDatetime() {
-      this.db.get("lastEventDatetime");
+      return this.db.get("lastEventDatetime");
     },
   },
   hooks: {
@@ -57,11 +57,17 @@ export default {
         },
       });
 
+      if (!messages.length) {
+        return;
+      }
+
       messages.forEach(this.emitEvent);
+      this._setLastEventDatetime(messages[0].dateTime);
     },
   },
   async run() {
     let page = 0;
+    const lastEventDatetime = this._getLastEventDatetime();
 
     while (page >= 0) {
       const messages = await this.elmah_io.getMessages({
@@ -70,10 +76,18 @@ export default {
           pageIndex: page,
           pageSize: constants.DEFAULT_PAGE_SIZE,
           query: QUERY,
+          from: lastEventDatetime
+            ? lastEventDatetime
+            : undefined,
         },
       });
 
+      if (!messages.length) {
+        return;
+      }
+
       messages.forEach(this.emitEvent);
+      this._setLastEventDatetime(messages[0].dateTime);
 
       page++;