add: xero_accounting_api, zerobounce, zip_archive_api

GTFalcao · GTFalcao · commit 8636bd205501 · 2025-06-18T06:10:26.000-03:00
diff --git a/components/xero_accounting_api/actions/upload-file/upload-file.mjs b/components/xero_accounting_api/actions/upload-file/upload-file.mjs
@@ -1,13 +1,14 @@
 // legacy_hash_id: a_B0i8rE
-import fs from "fs";
 import FormData from "form-data";
-import { axios } from "@pipedream/platform";
+import {
+  axios, getFileStreamAndMetadata,
+} from "@pipedream/platform";
 
 export default {
   key: "xero_accounting_api-upload-file",
   name: "Upload File",
   description: "Uploads a file to the specified document.",
-  version: "0.2.1",
+  version: "1.0.0",
   type: "action",
   props: {
     xero_accounting_api: {
@@ -18,9 +19,10 @@ export default {
       type: "string",
       description: "Id of the organization tenant to use on the Xero Accounting API. See [Get Tenant Connections](https://pipedream.com/@sergio/xero-accounting-api-get-tenant-connections-p_OKCzOgn/edit) for a workflow example on how to pull this data.",
     },
-    attachment_filename: {
+    filePathOrUrl: {
       type: "string",
-      description: "Name of the file to upload as an attachment to the Xero document.",
+      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`)",
     },
     document_type: {
       type: "string",
@@ -50,17 +52,24 @@ export default {
       throw new Error("Must provide tenant_id parameter.");
     }
 
-    let data = new FormData();
-    const file = fs.createReadStream(`/tmp/${this.attachment_filename}`);
-    data.append("file", file);
+    const {
+      stream, metadata,
+    } = await getFileStreamAndMetadata(this.filePathOrUrl);
+    const data = new FormData();
+    data.append("file", stream, {
+      contentType: metadata.contentType,
+      knownLength: metadata.size,
+      filename: metadata.name,
+    });
 
     //Sends the request against Xero Accounting API
     return await axios($, {
       method: "post",
-      url: `https://api.xero.com/api.xro/2.0/${this.document_type}/${this.document_id}/Attachments/${attachment_filename}`,
+      url: `https://api.xero.com/api.xro/2.0/${this.document_type}/${this.document_id}/Attachments/${metadata.name}`,
       headers: {
         "Authorization": `Bearer ${this.xero_accounting_api.$auth.oauth_access_token}`,
         "xero-tenant-id": this.tenant_id,
+        ...data.getHeaders(),
       },
       data,
     });
diff --git a/components/xero_accounting_api/package.json b/components/xero_accounting_api/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/xero_accounting_api",
-  "version": "0.2.1",
+  "version": "0.3.0",
   "description": "Pipedream Xero Components",
   "main": "xero_accounting_api.app.mjs",
   "keywords": [
@@ -10,7 +10,7 @@
   "homepage": "https://pipedream.com/apps/xero_accounting_api",
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "dependencies": {
-    "@pipedream/platform": "^1.4.0"
+    "@pipedream/platform": "^3.1.0"
   },
   "publishConfig": {
     "access": "public"
diff --git a/components/zerobounce/actions/file-validation/file-validation.mjs b/components/zerobounce/actions/file-validation/file-validation.mjs
@@ -1,20 +1,19 @@
 import zerobounce from "../../zerobounce.app.mjs";
-import fs from "fs";
 import FormData from "form-data";
-import path from "path";
+import { getFileStreamAndMetadata } from "@pipedream/platform";
 
 export default {
   key: "zerobounce-file-validation",
   name: "Validate Emails in File",
   description: "Performs email validation on all the addresses contained in a provided file. [See the documentation](https://www.zerobounce.net/docs/email-validation-api-quickstart/)",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     zerobounce,
     filePath: {
       type: "string",
-      label: "File Path",
-      description: "The path to a csv or txt file in the `/tmp` directory. [See the documentation on working with files](https://pipedream.com/docs/code/nodejs/working-with-files/#writing-a-file-to-tmp)",
+      label: "File Path or URL",
+      description: "The csv or txt file to validate. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.csv`)",
     },
     emailAddressColumn: {
       type: "integer",
@@ -74,14 +73,15 @@ export default {
         ({ resume_url: returnUrl } = $.flow.rerun(600000, null, 1));
       }
 
-      const filePath = this.filePath.includes("tmp/")
-        ? this.filePath
-        : `/tmp/${this.filePath}`;
-      const fileName = path.basename(filePath);
-      const fileContent = fs.readFileSync(filePath);
-
+      const {
+        stream, metadata,
+      } = await getFileStreamAndMetadata(this.filePath);
       const formData = new FormData();
-      formData.append("file", fileContent, fileName);
+      formData.append("file", stream, {
+        contentType: metadata.contentType,
+        knownLength: metadata.size,
+        filename: metadata.name,
+      });
       formData.append("email_address_column", this.emailAddressColumn);
       formData.append("api_key", this.zerobounce.$auth.api_key);
       if (this.firstNameColumn) {
diff --git a/components/zerobounce/package.json b/components/zerobounce/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/zerobounce",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream ZeroBounce Components",
   "main": "zerobounce.app.mjs",
   "keywords": [
@@ -13,7 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^3.0.3",
+    "@pipedream/platform": "^3.1.0",
     "form-data": "^4.0.1",
     "path": "^0.12.7"
   }
diff --git a/components/zip_archive_api/actions/compress-files/compress-files.mjs b/components/zip_archive_api/actions/compress-files/compress-files.mjs
@@ -1,21 +1,17 @@
 import app from "../../zip_archive_api.app.mjs";
-import fs from "fs";
 import FormData from "form-data";
+import {
+  getFileStreamAndMetadata, writeFile,
+} from "@pipedream/platform";
 
 export default {
   key: "zip_archive_api-compress-files",
   name: "Compress Files",
   description: "Compress files provided through URLs into a zip folder. [See the documentation](https://archiveapi.com/rest-api/file-compression/)",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     app,
-    uploadType: {
-      propDefinition: [
-        app,
-        "uploadType",
-      ],
-    },
     archiveName: {
       propDefinition: [
         app,
@@ -42,38 +38,32 @@ export default {
     },
   },
   async run({ $ }) {
-    let data = {
-      files: this.files,
-      archiveName: this.archiveName,
-      compressionLevel: this.compressionLevel,
-      password: this.password,
-    };
-
-    if (this.uploadType === "File") {
-      data = new FormData();
+    const data = new FormData();
 
-      if (this.password) data.append("Password", this.password);
-      if (this.compressionLevel) data.append("CompressionLevel", this.compressionLevel);
-      data.append("ArchiveName", this.archiveName);
+    if (this.password) data.append("Password", this.password);
+    if (this.compressionLevel) data.append("CompressionLevel", this.compressionLevel);
+    data.append("ArchiveName", this.archiveName);
 
-      for (const file of this.files) {
-        data.append("Files", fs.createReadStream(file));
-      }
+    for (const file of this.files) {
+      const {
+        stream, metadata,
+      } = await getFileStreamAndMetadata(file);
+      data.append("Files", stream, {
+        contentType: metadata.contentType,
+        knownLength: metadata.size,
+        filename: metadata.name,
+      });
     }
 
-    const headers = this.uploadType === "File"
-      ? data.getHeaders()
-      : {};
-
     const response = await this.app.compressFiles({
       $,
       data,
-      headers,
+      headers: data.getHeaders(),
       responseType: "arraybuffer",
     });
 
     const tmpPath = `/tmp/${this.archiveName}`;
-    fs.writeFileSync(tmpPath, response);
+    await writeFile(tmpPath, response);
 
     $.export("$summary", `Successfully compressed the files into '${tmpPath}'`);
 
diff --git a/components/zip_archive_api/package.json b/components/zip_archive_api/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/zip_archive_api",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream Zip Archive API Components",
   "main": "zip_archive_api.app.mjs",
   "keywords": [
@@ -13,7 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.6.5",
+    "@pipedream/platform": "^3.1.0",
     "form-data": "^4.0.0"
   }
 }
diff --git a/components/zip_archive_api/zip_archive_api.app.mjs b/components/zip_archive_api/zip_archive_api.app.mjs
@@ -30,13 +30,8 @@ export default {
     },
     files: {
       type: "string[]",
-      label: "Files URLs",
-      description: "The URLs or path of the files to be compressed",
-    },
-    file: {
-      type: "string",
-      label: "File URL",
-      description: "The URL or path of the archive to extract the files from",
+      label: "File Paths or URLs",
+      description: "The files to upload. For each entry, provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`)",
     },
   },
   methods: {

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@pipedream/zip_archive_api",`
`3`		`- "version": "0.1.0",`
	`3`	`+ "version": "0.2.0",`
`4`	`4`	`"description": "Pipedream Zip Archive API Components",`
`5`	`5`	`"main": "zip_archive_api.app.mjs",`
`6`	`6`	`"keywords": [`
`@@ -13,7 +13,7 @@`
`13`	`13`	`"access": "public"`
`14`	`14`	`},`
`15`	`15`	`"dependencies": {`
`16`		`- "@pipedream/platform": "^1.6.5",`
	`16`	`+ "@pipedream/platform": "^3.1.0",`
`17`	`17`	`"form-data": "^4.0.0"`
`18`	`18`	`}`
`19`	`19`	`}`