add: sendgrid, sftp

Author: GTFalcao

components/sendgrid/actions/send-email-multiple-recipients/send-email-multiple-recipients.mjs

@@ -1,5 +1,6 @@
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
+import {
+  ConfigurationError, getFileStream,
+} from "@pipedream/platform";
 import mime from "mime";
 import validate from "validate.js";
 import common from "../common/common.mjs";
@@ -9,7 +10,7 @@ export default {
   key: "sendgrid-send-email-multiple-recipients",
   name: "Send Email Multiple Recipients",
   description: "This action sends a personalized e-mail to multiple specified recipients. [See the docs here](https://docs.sendgrid.com/api-reference/mail-send/mail-send)",
-  version: "0.0.6",
+  version: "0.1.0",
   type: "action",
   props: {
     ...common.props,
@@ -156,8 +157,8 @@ export default {
         };
         props[`attachmentsPath${i}`] = {
           type: "string",
-          label: `Attachment File Path ${i}`,
-          description: "The path to your file in /tmp dir. [See the documentation](https://pipedream.com/docs/code/nodejs/working-with-files/#writing-a-file-to-tmp) for how to work with tmp dir.",
+          label: `Attachment File Path or URL ${i}`,
+          description: "The file to upload. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`).",
           optional: true,
         };
       }
@@ -208,10 +209,13 @@ export default {
     }
     const attachments = [];
     for (let i = 1; i <= this.numberOfAttachments; i++) {
-      const filepath = this.checkTmp(this["attachmentsPath" + i]);
-      const content = fs.readFileSync(filepath, {
-        encoding: "base64",
-      });
+      const filepath = this["attachmentsPath" + i];
+      const stream = await getFileStream(filepath);
+      const chunks = [];
+      for await (const chunk of stream) {
+        chunks.push(chunk);
+      }
+      const content = Buffer.concat(chunks).toString("base64");
       const type = mime.getType(filepath);
       attachments.push({
         content,

components/sendgrid/actions/send-email-single-recipient/send-email-single-recipient.mjs

@@ -1,4 +1,4 @@
-import fs from "fs";
+import { getFileStream } from "@pipedream/platform";
 import mime from "mime";
 import validate from "validate.js";
 import common from "../common/common.mjs";
@@ -8,7 +8,7 @@ export default {
   key: "sendgrid-send-email-single-recipient",
   name: "Send Email Single Recipient",
   description: "This action sends a personalized e-mail to the specified recipient. [See the docs here](https://docs.sendgrid.com/api-reference/mail-send/mail-send)",
-  version: "0.0.8",
+  version: "0.1.0",
   type: "action",
   props: {
     ...common.props,
@@ -178,8 +178,8 @@ export default {
         };
         props[`attachmentsPath${i}`] = {
           type: "string",
-          label: `Attachment File Path ${i}`,
-          description: "The path to your file in /tmp dir. [See the documentation](https://pipedream.com/docs/code/nodejs/working-with-files/#writing-a-file-to-tmp) for how to work with tmp dir.",
+          label: `Attachment File Path or URL ${i}`,
+          description: "The file to upload. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`).",
           optional: true,
         };
       }
@@ -227,10 +227,13 @@ export default {
     }
     const attachments = [];
     for (let i = 1; i <= this.numberOfAttachments; i++) {
-      const filepath = this.checkTmp(this["attachmentsPath" + i]);
-      const content = fs.readFileSync(filepath, {
-        encoding: "base64",
-      });
+      const filepath = this["attachmentsPath" + i];
+      const stream = await getFileStream(filepath);
+      const chunks = [];
+      for await (const chunk of stream) {
+        chunks.push(chunk);
+      }
+      const content = Buffer.concat(chunks).toString("base64");
       const type = mime.getType(filepath);
       attachments.push({
         content,

components/sendgrid/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/sendgrid",
-  "version": "0.4.2",
+  "version": "0.5.0",
   "description": "Pipedream Sendgrid Components",
   "main": "sendgrid.app.mjs",
   "keywords": [
@@ -10,7 +10,7 @@
   "homepage": "https://pipedream.com/apps/sendgrid",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "dependencies": {
-    "@pipedream/platform": "^3.0.3",
+    "@pipedream/platform": "^3.1.0",
     "@sendgrid/client": "^7.6.2",
     "@sendgrid/eventwebhook": "^7.4.5",
     "async-retry": "^1.3.1",

components/sftp/actions/upload-file/upload-file.mjs

@@ -1,12 +1,13 @@
 import app from "../../sftp.app.mjs";
-import fs from "fs";
-import { ConfigurationError } from "@pipedream/platform";
+import {
+  ConfigurationError, getFileStream,
+} from "@pipedream/platform";
 
 export default {
   key: "sftp-upload-file",
   name: "Upload File",
   description: "Uploads a file or string in UTF-8 format to the SFTP server. [See the documentation](https://github.com/theophilusx/ssh2-sftp-client#org99d1b64)",
-  version: "0.3.0",
+  version: "0.4.0",
   type: "action",
   props: {
     app,
@@ -30,11 +31,11 @@ export default {
   },
   async run({ $ }) {
     if (!this.data && !this.file) {
-      throw new ConfigurationError("Either `Data` or `File` must be provided.");
+      throw new ConfigurationError("Either `Data` or `File Path or URL` must be provided.");
     }
 
     const buffer = this.file ?
-      fs.readFileSync(this.file) :
+      (await getFileStream(this.file)) :
       Buffer.from(this.data);
 
     const response = await this.app.put({

components/sftp/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/sftp",
-  "version": "0.4.1",
+  "version": "0.5.0",
   "description": "Pipedream SFTP Components",
   "main": "sftp.app.mjs",
   "keywords": [
@@ -10,7 +10,7 @@
   "homepage": "https://pipedream.com/apps/sftp",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "dependencies": {
-    "@pipedream/platform": "^3.0.3",
+    "@pipedream/platform": "^3.1.0",
     "ssh2-sftp-client": "^11.0.0"
   },
   "gitHead": "e12480b94cc03bed4808ebc6b13e7fdb3a1ba535",

components/sftp/sftp.app.mjs

@@ -1,22 +1,14 @@
 import Client from "ssh2-sftp-client";
-import fs from "fs";
 
 export default {
   type: "app",
   app: "sftp",
   propDefinitions: {
     file: {
       type: "string",
-      label: "File",
-      description: "Local file on `/tmp` folder to upload to the remote server.",
+      label: "File Path or URL",
+      description: "The file to upload. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`).",
       optional: true,
-      options() {
-        return fs.readdirSync("/tmp", {
-          withFileTypes: true,
-        })
-          .filter((file) => !file.isDirectory())
-          .map((file) => file.name);
-      },
     },
   },
   methods: {