Elmah.io - add error handling and alert prop (PipedreamHQ#17032)

* add error handling and alert prop

* pnpm-lock.yaml

* updates

Author: michelle0927

components/elmah_io/elmah_io.app.mjs

@@ -1,20 +1,22 @@
-import { axios } from "@pipedream/platform";
+import {
+  axios, ConfigurationError,
+} from "@pipedream/platform";
 
 export default {
   type: "app",
   app: "elmah_io",
   propDefinitions: {
     logId: {
       label: "Log ID",
-      description: "The ID of the log",
+      description: "The ID of the log. Requires that your api key have the `logs_read` permission.",
       type: "string",
       async options() {
         const logs = await this.getLogs();
 
-        return logs.map((log) => ({
+        return logs?.map((log) => ({
           label: log.name,
           value: log.id,
-        }));
+        })) || [];
       },
     },
   },
@@ -28,14 +30,22 @@ export default {
     async _makeRequest({
       $ = this, path, ...args
     }) {
-      return axios($, {
-        ...args,
-        url: `${this._apiUrl()}${path}`,
-        params: {
-          ...args?.params,
-          api_key: this._apiKey(),
-        },
-      });
+      try {
+        return await axios($, {
+          ...args,
+          url: `${this._apiUrl()}${path}`,
+          params: {
+            ...args?.params,
+            api_key: this._apiKey(),
+          },
+        });
+      } catch (error) {
+        if (error.response?.status === 401) {
+          console.log(error);
+          throw new ConfigurationError(`${error.response.data.title} ${error.response.data.detail}`);
+        }
+        throw error;
+      }
     },
     async getLogs(args = {}) {
       return this._makeRequest({

components/elmah_io/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/elmah_io",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "description": "Pipedream elmah.io Components",
   "main": "elmah_io.app.mjs",
   "keywords": [
@@ -14,6 +14,6 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.2.0"
+    "@pipedream/platform": "^3.1.0"
   }
 }

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

@@ -2,13 +2,13 @@ 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",
-  version: "0.0.3",
+  version: "0.0.4",
   key: "elmah_io-new-error",
-  description: "Emit new event on each new error",
+  description: "Emit new event on each new error. [See the documentation](https://api.elmah.io/swagger/index.html#/Messages/Messages_GetAll)",
   type: "source",
   dedupe: "unique",
   props: {
@@ -26,20 +26,25 @@ export default {
         "logId",
       ],
     },
+    alert: {
+      type: "alert",
+      alertType: "info",
+      content: "Note: This source requires that your api key have the `logs_read` and `messages_read` permissions.",
+    },
   },
   methods: {
     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: {
@@ -52,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({
@@ -65,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++;