[Components] notiff_io #16263

Actions
 - Create Notification

Author: luancazarine

components/notiff/actions/create-notification/create-notification.mjs

@@ -0,0 +1,23 @@
+import common from "../../../notiff_io/actions/create-notification/create-notification.mjs";
+import { adjustPropDefinitions } from "../../common/utils.mjs";
+import app from "../../notiff.app.mjs";
+
+const props = adjustPropDefinitions(common.props, app);
+
+export default {
+  ...common,
+  key: "notiff-create-notification",
+  name: "Create Notification",
+  description: "Send a new notification to a user or system via notiff.io. [See the documentation](https://notiff.io/articles/welcome-to-notiff-getting-started-with-your-notification-center)",
+  version: "0.0.1",
+  type: "action",
+  methods: {
+    getNotificationSourceId() {
+      return this.app.$auth.notification_source_id;
+    },
+  },
+  props: {
+    app,
+    ...props,
+  },
+};

components/notiff/common/utils.mjs

@@ -0,0 +1,37 @@
+export function adjustPropDefinitions(props, app) {
+  return Object.fromEntries(
+    Object.entries(props).map(([
+      key,
+      prop,
+    ]) => {
+      const {
+        propDefinition, ...otherValues
+      } = prop;
+      if (propDefinition) {
+        const [
+          , ...otherDefs
+        ] = propDefinition;
+        return [
+          key,
+          {
+            propDefinition: [
+              app,
+              ...otherDefs,
+            ],
+            ...otherValues,
+          },
+        ];
+      }
+      return [
+        key,
+        otherValues.type === "app"
+          ? null
+          : otherValues,
+      ];
+    })
+      .filter(([
+        key,
+        value,
+      ]) => key != "idNotificationSource" && (value)),
+  );
+}

components/notiff/notiff.app.mjs

@@ -1,11 +1,15 @@
+import notiffIo from "../notiff_io/notiff_io.app.mjs";
+
 export default {
+  ...notiffIo,
   type: "app",
   app: "notiff",
-  propDefinitions: {},
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    ...notiffIo.methods,
+    _headers() {
+      return {
+        "Content-Type": "application/json",
+      };
     },
   },
 };

components/notiff/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/notiff",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Notiff Components",
   "main": "notiff.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
-}
+}

components/notiff_io/actions/create-notification/create-notification.mjs

@@ -1,48 +1,55 @@
-import notiff_io from "../../notiff_io.app.mjs";
-import { axios } from "@pipedream/platform";
+import app from "../../notiff_io.app.mjs";
 
 export default {
   key: "notiff_io-create-notification",
   name: "Create Notification",
   description: "Send a new notification to a user or system via notiff.io. [See the documentation](https://notiff.io/articles/welcome-to-notiff-getting-started-with-your-notification-center)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
-    notiff_io,
+    app,
     idNotificationSource: {
-      propDefinition: [
-        notiff_io,
-        "idNotificationSource",
-      ],
+      type: "string",
+      label: "ID Notification Source",
+      description: "To get your Notification Source ID, sign in to Notiff, go to the Settings menu with the gear icon on the top right, click the \"Settings\" option. Copy your Notification Source ID from the list.",
+      secret: true,
     },
     title: {
       propDefinition: [
-        notiff_io,
+        app,
         "title",
       ],
     },
     description: {
       propDefinition: [
-        notiff_io,
+        app,
         "description",
       ],
     },
     url: {
       propDefinition: [
-        notiff_io,
+        app,
         "url",
       ],
     },
   },
+  methods: {
+    getNotificationSourceId() {
+      return this.idNotificationSource;
+    },
+  },
   async run({ $ }) {
-    const response = await this.notiff_io.sendNotification({
-      idNotificationSource: this.idNotificationSource,
-      title: this.title,
-      description: this.description,
-      url: this.url,
+    const response = await this.app.createNotification({
+      $,
+      data: {
+        id_notification_source: this.getNotificationSourceId(),
+        title: this.title,
+        description: this.description,
+        url: this.url,
+      },
     });
 
-    $.export("$summary", `Notification titled "${this.title}" created successfully`);
+    $.export("$summary", `Notification titled "${this.title}" created successfully!`);
     return response;
   },
 };

components/notiff_io/notiff_io.app.mjs

@@ -4,18 +4,6 @@ export default {
   type: "app",
   app: "notiff_io",
   propDefinitions: {
-    idNotificationSource: {
-      type: "string",
-      label: "Notification Source ID",
-      description: "The unique identifier for the notification source.",
-      async options() {
-        const sources = await this.listNotificationSources();
-        return sources.map((source) => ({
-          label: source.title,
-          value: source.id,
-        }));
-      },
-    },
     title: {
       type: "string",
       label: "Title",
@@ -33,44 +21,27 @@ export default {
     },
   },
   methods: {
-    authKeys() {
-      console.log(Object.keys(this.$auth));
-    },
     _baseUrl() {
       return "https://notiff.io/api/1.1/wf";
     },
-    async _makeRequest(opts = {}) {
-      const {
-        $ = this, method = "GET", path = "/", headers, ...otherOpts
-      } = opts;
+    _headers() {
+      return {
+        Authorization: `Bearer ${this.$auth.oauth_access_token}`,
+      };
+    },
+    _makeRequest({
+      $ = this, path, ...opts
+    }) {
       return axios($, {
-        ...otherOpts,
-        method,
         url: this._baseUrl() + path,
-        headers: {
-          "Authorization": `Bearer ${this.$auth.api_key}`,
-          ...headers,
-        },
-      });
-    },
-    async listNotificationSources(opts = {}) {
-      return this._makeRequest({
-        path: "/list_notification_sources",
+        headers: this._headers(),
         ...opts,
       });
     },
-    async sendNotification({
-      idNotificationSource, title, description, url,
-    }, opts = {}) {
+    createNotification(opts = {}) {
       return this._makeRequest({
         method: "POST",
         path: "/create_notification",
-        data: {
-          id_notification_source: idNotificationSource,
-          title,
-          description,
-          url,
-        },
         ...opts,
       });
     },

components/notiff_io/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/notiff_io",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Notiff (OAuth) Components",
   "main": "notiff_io.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
 }