New Components - alerty

components/alerty/actions/notify-devices/notify-devices.mjs

@@ -0,0 +1,73 @@
+import alerty from "../../alerty.app.mjs";
+import { URGENCY_OPTIONS } from "../../common/constants.mjs";
+import { parseObject } from "../../common/utils.mjs";
+
+export default {
+  key: "alerty-notify-devices",
+  name: "Notify Devices",
+  description: "Sends a notification to active devices. [See the documentation](https://alerty.dev/api/notify)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    alerty,
+    message: {
+      type: "string",
+      label: "Message",
+      description: "The message to be included in the push notification.",
+    },
+    title: {
+      type: "string",
+      label: "Title",
+      description: "Title for your notification message.",
+      optional: true,
+    },
+    image: {
+      type: "string",
+      label: "Image URL",
+      description: "URL of an image to be displayed in the notification.",
+      optional: true,
+    },
+    icon: {
+      type: "string",
+      label: "Icon URL",
+      description: "URL of an image to be used as an icon by the notification. Default: Alerty Logo",
+      optional: true,
+    },
+    deviceId: {
+      type: "string[]",
+      label: "Device ID",
+      description: "Specific device IDs to send the notification to. If no Device Id is included, the push message will be sent to all active devices on your account.",
+      optional: true,
+    },
+    urgency: {
+      type: "string",
+      label: "Urgency",
+      description: "Urgency of the notification. Default: very-low",
+      options: URGENCY_OPTIONS,
+      optional: true,
+    },
+    actions: {
+      type: "string[]",
+      label: "Actions",
+      description: "Actions for the notification, each item should be a JSON string. Example: { \"action\": \"https://example.com\", \"title\": \"Open Site\", \"icon\": \"https://example.com/icon.png\" }",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const response = await this.alerty.makeRequest({
+      $,
+      data: {
+        message: this.message,
+        title: this.title,
+        image: this.image,
+        icon: this.icon,
+        device_id: parseObject(this.deviceId),
+        urgency: this.urgency,
+        actions: parseObject(this.actions),
+      },
+    });
+
+    $.export("$summary", `Notification sent with message: "${this.message}"`);
+    return response;
+  },
+};

components/alerty/alerty.app.mjs

@@ -1,11 +1,26 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "alerty",
-  propDefinitions: {},
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return `${this.$auth.notification_url}`;
+    },
+    _headers() {
+      return {
+        Authorization: `Bearer ${this.$auth.api_key}`,
+      };
+    },
+    makeRequest({
+      $ = this, ...opts
+    }) {
+      return axios($, {
+        method: "POST",
+        url: this._baseUrl(),
+        headers: this._headers(),
+        ...opts,
+      });
     },
   },
-};
+};

components/alerty/common/constants.mjs

@@ -0,0 +1,6 @@
+export const URGENCY_OPTIONS = [
+  "very-low",
+  "low",
+  "normal",
+  "high",
+];

components/alerty/common/utils.mjs

@@ -0,0 +1,24 @@
+export const parseObject = (obj) => {
+  if (!obj) return undefined;
+
+  if (Array.isArray(obj)) {
+    return obj.map((item) => {
+      if (typeof item === "string") {
+        try {
+          return JSON.parse(item);
+        } catch (e) {
+          return item;
+        }
+      }
+      return item;
+    });
+  }
+  if (typeof obj === "string") {
+    try {
+      return JSON.parse(obj);
+    } catch (e) {
+      return obj;
+    }
+  }
+  return obj;
+};

components/alerty/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/alerty",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Alerty Components",
   "main": "alerty.app.mjs",
   "keywords": [
@@ -11,5 +11,9 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.1"
   }
-}
+}
+