updates to use getFileStream

Author: michelle0927

components/api4ai/actions/alcohol-label-recognition/alcohol-label-recognition.mjs

@@ -5,7 +5,7 @@ export default {
   name: "Alcohol Label Recognition",
   description: "Accurately identifies alcohol labels using advanced intelligent technologies. Powered by API4AI.",
   key: "api4ai-alcohol-label-recognition",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/actions/background-removal/background-removal.mjs

@@ -8,7 +8,7 @@ export default {
   description:
     "Automatically and quickly remove image background with high accuracy. Powered by API4AI.",
   key: "api4ai-background-removal",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/actions/brand-recognition/brand-recognition.mjs

@@ -5,7 +5,7 @@ export default {
   name: "Brand Recognition",
   description: "The service processes input image and responds with a list of found brand logos. Powered by API4AI.",
   key: "api4ai-brand-recognition",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/actions/car-image-background-removal/car-image-background-removal.mjs

@@ -8,7 +8,7 @@ export default {
   description:
     "Remove Background for car images. Powered by API4AI.",
   key: "api4ai-car-image-background-removal",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/actions/furniture-and-household-item-recognition/furniture-and-household-item-recognition.mjs

@@ -5,7 +5,7 @@ export default {
   name: "Furniture & Household Item Recognition",
   description: "This API provides identification of furniture & household items with advanced intelligent detection, categorization, and counting technologies. Powered by API4AI.",
   key: "api4ai-furniture-and-household-item-recognition",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/actions/image-anonymization/image-anonymization.mjs

@@ -7,7 +7,7 @@ export default {
   name: "Image Anonymization",
   description: "Performs actual image anonymization. Powered by API4AI.",
   key: "api4ai-image-anonymization",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/actions/nsfw-image-recognition/nsfw-image-recognition.mjs

@@ -6,7 +6,7 @@ export default {
   description:
     "Content moderation solution for NSFW (Not Safe For Work) sexual images identification. Powered by API4AI.",
   key: "api4ai-nsfw-image-recognition",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     app,

components/api4ai/api4ai.app.mjs

@@ -1,6 +1,7 @@
-import { axios } from "@pipedream/platform";
+import {
+  axios, getFileStreamAndMetadata,
+} from "@pipedream/platform";
 import FormData from "form-data";
-import fs from "node:fs";
 
 export default {
   type: "app",
@@ -9,63 +10,32 @@ export default {
     image: {
       type: "string",
       label: "Image",
-      description: "Input image. Various types are accepted:\n  * a **path** to a file\n  * a **URL** to a file\n  * a file's content encoded as a **base64** string\n  * a file's content as a **Buffer** encoded in JSON\n  * a file's content as an **Array** of bytes",
+      description: "Input image. Provide either a file URL or a path to a file in the /tmp directory (for example, /tmp/myFlie.pdf).",
     },
   },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
-    },
+    streamToBuffer(stream) {
+      return new Promise((resolve, reject) => {
+        const chunks = [];
 
-    /**
-     * Make HTTP request.
-     *
-     * @param {Object} $ - Pipedream.
-     * @param {string} url - API Endpoint URL.
-     * @param {*} image - Input image.
-     *     Various types are accepted:
-     *       - a path to a file
-     *       - a URL to a file
-     *       - a file's content encoded as a base64 string
-     *       - a file's content as a Buffer encoded in JSON
-     *       - a file's content as an Array of bytes
-     * @param {Object} params - Query parameters.
-     * @returns Axios response.
-     */
+        stream.on("data", (chunk) => chunks.push(chunk));
+        stream.on("end", () => resolve(Buffer.concat(chunks)));
+        stream.on("error", reject);
+      });
+    },
     async makeRequest($, url, image, params = {}) {
       // Prepare form data.
-      const base64regex = /^([0-9a-zA-Z+/]{4})*(([0-9a-zA-Z+/]{2}==)|([0-9a-zA-Z+/]{3}=))?$/;
-      const urlregex = /^(http|ftp)s?:\/\/(www\.)?[-a-zA-Z0-9@:%._+~#=]{1,256}\.[a-zA-Z0-9()]{1,6}\b([-a-zA-Z0-9()@:%_+.~#?&//=]*)/;
       const form = new FormData();
-      if (urlregex.test(image)) {
-        console.log("Input image considered as URL");
-        form.append("url", image);
-      }
-      else {
-        let buf;
-        if (image instanceof Buffer) {
-          console.log("Input image considered as Buffer");
-          buf = image;
-        }
-        else if ((image instanceof Object) && image.type === "Buffer") {
-          console.log("Input image considered as JSON object with Buffer");
-          buf = Buffer.from(image);
-        }
-        else if (image instanceof Array) {
-          console.log("Input image considered as Array");
-          buf = Buffer.from(image);
-        }
-        else if (base64regex.test(image)) {
-          console.log("Input image considered as base64 string");
-          buf = Buffer.from(image, "base64");
-        }
-        else {
-          console.log("Input image considered as file path");
-          buf = fs.readFileSync(image);
-        }
-        form.append("image", buf);
-      }
+      const {
+        stream, metadata,
+      } = await getFileStreamAndMetadata(image);
+
+      const buffer = await this.streamToBuffer(stream);
+      form.append("image", buffer, {
+        contentType: metadata.contentType,
+        knownLength: metadata.size,
+        filename: metadata.name,
+      });
 
       // Prepare headers.
       const headers = {

components/api4ai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/api4ai",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream API4AI Components",
   "main": "api4ai.app.mjs",
   "keywords": [
@@ -27,7 +27,7 @@
   "homepage": "https://pipedream.com/apps/api4ai",
   "author": "API4AI Team <[email protected]> (https://api4.ai/)",
   "dependencies": {
-    "@pipedream/platform": "^1.6.2",
+    "@pipedream/platform": "^3.1.0",
     "form-data": "^4.0.0"
   },
   "publishConfig": {

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

@@ -1,14 +1,12 @@
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
-import got from "got";
+import { getFileStream } from "@pipedream/platform";
 import consts from "../../common/consts.mjs";
 import dropbox from "../../dropbox.app.mjs";
 
 export default {
   name: "Upload a File",
   description: "Uploads a file to a selected folder. [See the documentation](https://dropbox.github.io/dropbox-sdk-js/Dropbox.html#filesUpload__anchor)",
   key: "dropbox-upload-file",
-  version: "0.0.14",
+  version: "0.0.15",
   type: "action",
   props: {
     dropbox,
@@ -27,17 +25,10 @@ export default {
       label: "File Name",
       description: "The name of your new file (make sure to include the file extension).",
     },
-    fileUrl: {
+    file: {
       type: "string",
-      label: "File URL",
-      description: "The URL of the file you want to upload to Dropbox. Must specify either File URL or File Path.",
-      optional: true,
-    },
-    filePath: {
-      type: "string",
-      label: "File Path",
-      description: "The path to the file, e.g. /tmp/myFile.csv . Must specify either File URL or File Path.",
-      optional: true,
+      label: "File",
+      description: "Provide either a file URL or a path to a file in the /tmp directory (for example, /tmp/myFlie.pdf).",
     },
     autorename: {
       type: "boolean",
@@ -67,8 +58,7 @@ export default {
   },
   async run({ $ }) {
     const {
-      fileUrl,
-      filePath,
+      file,
       path,
       name,
       autorename,
@@ -78,13 +68,7 @@ export default {
       clientModified,
     } = this;
 
-    if (!fileUrl && !filePath) {
-      throw new ConfigurationError("Must specify either File URL or File Path.");
-    }
-
-    const contents = fileUrl
-      ? await got.stream(fileUrl)
-      : fs.createReadStream(filePath);
+    const contents = await getFileStream(file);
 
     let normalizedPath = this.dropbox.getNormalizedPath(path, true);