AI-generated set

Author: GTFalcao

components/roboflow/actions/classify-image/classify-image.mjs

@@ -1,12 +1,11 @@
 import roboflow from "../../roboflow.app.mjs";
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
+import { getFileStream } from "@pipedream/platform";
 
 export default {
   key: "roboflow-classify-image",
   name: "Classify Image",
   description: "Run inference on classification models hosted on Roboflow. [See the documentation](https://docs.roboflow.com/deploy/hosted-api/classification).",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     roboflow,
@@ -31,36 +30,23 @@ export default {
         "filePath",
       ],
     },
-    fileUrl: {
-      propDefinition: [
-        roboflow,
-        "fileUrl",
-      ],
-    },
   },
   async run({ $ }) {
-    if ((!this.filePath && !this.fileUrl) || (this.filePath && this.fileUrl)) {
-      throw new ConfigurationError("Exactly one of file Path or File URL must be specified.");
+    const stream = getFileStream(this.filePath);
+    const chunks = [];
+    for await (const chunk of stream) {
+      chunks.push(chunk);
     }
+    const data = Buffer.concat(chunks).toString("base64");
 
     const args = {
       datasetId: this.datasetId,
       $,
-    };
-
-    if (this.filePath) {
-      args.data = fs.readFileSync(this.filePath, {
-        encoding: "base64",
-      });
-      args.headers = {
+      data,
+      headers: {
         "Content-Type": "application/x-www-form-urlencoded",
-      };
-    }
-    if (this.fileUrl) {
-      args.params = {
-        image: this.fileUrl,
-      };
-    }
+      },
+    };
 
     const response = await this.roboflow.classifyImage(args);
 

components/roboflow/actions/detect-object-from-image/detect-object-from-image.mjs

@@ -1,12 +1,11 @@
 import roboflow from "../../roboflow.app.mjs";
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
+import { getFileStream } from "@pipedream/platform";
 
 export default {
   key: "roboflow-detect-object-from-image",
   name: "Detect Object From Image",
   description: "Run inference on your object detection models hosted on Roboflow. [See the documentation](https://docs.roboflow.com/deploy/hosted-api/object-detection).",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     roboflow,
@@ -31,36 +30,23 @@ export default {
         "filePath",
       ],
     },
-    fileUrl: {
-      propDefinition: [
-        roboflow,
-        "fileUrl",
-      ],
-    },
   },
   async run({ $ }) {
-    if ((!this.filePath && !this.fileUrl) || (this.filePath && this.fileUrl)) {
-      throw new ConfigurationError("Exactly one of file Path or File URL must be specified.");
+    const stream = getFileStream(this.filePath);
+    const chunks = [];
+    for await (const chunk of stream) {
+      chunks.push(chunk);
     }
+    const data = Buffer.concat(chunks).toString("base64");
 
     const args = {
       datasetId: this.datasetId,
       $,
-    };
-
-    if (this.filePath) {
-      args.data = fs.readFileSync(this.filePath, {
-        encoding: "base64",
-      });
-      args.headers = {
+      data,
+      headers: {
         "Content-Type": "application/x-www-form-urlencoded",
-      };
-    }
-    if (this.fileUrl) {
-      args.params = {
-        image: this.fileUrl,
-      };
-    }
+      },
+    };
 
     const response = await this.roboflow.detectObject(args);
 

components/roboflow/actions/upload-image/upload-image.mjs

@@ -1,14 +1,13 @@
 import roboflow from "../../roboflow.app.mjs";
-import { ConfigurationError } from "@pipedream/platform";
+import { getFileStream } from "@pipedream/platform";
 import utils from "../../common/utils.mjs";
-import fs from "fs";
 import FormData from "form-data";
 
 export default {
   key: "roboflow-upload-image",
   name: "Upload Image",
   description: "Upload an image to a project on the Roboflow platform. [See the documentation](https://docs.roboflow.com/datasets/adding-data/upload-api).",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     roboflow,
@@ -24,12 +23,6 @@ export default {
         "filePath",
       ],
     },
-    fileUrl: {
-      propDefinition: [
-        roboflow,
-        "fileUrl",
-      ],
-    },
     name: {
       type: "string",
       label: "Name",
@@ -38,33 +31,26 @@ export default {
     },
   },
   async run({ $ }) {
-    if ((!this.filePath && !this.fileUrl) || (this.filePath && this.fileUrl)) {
-      throw new ConfigurationError("Exactly one of file Path or File URL must be specified.");
-    }
-
     const args = {
       projectId: utils.extractSubstringAfterSlash(this.projectId),
       $,
     };
 
-    if (this.filePath) {
-      const formData = new FormData();
-      if (this.name) {
-        formData.append("name", this.name);
-      }
-      formData.append("file", fs.createReadStream(this.filePath));
-
-      args.data = formData;
-      args.headers = formData.getHeaders();
+    const formData = new FormData();
+    if (this.name) {
+      formData.append("name", this.name);
     }
 
-    if (this.fileUrl) {
-      const params = {
-        image: this.fileUrl,
+    if (this.filePath.startsWith("http")) {
+      args.params = {
+        image: this.filePath,
         name: this.name,
       };
-
-      args.params = params;
+    } else {
+      const stream = getFileStream(this.filePath);
+      formData.append("file", stream);
+      args.data = formData;
+      args.headers = formData.getHeaders();
     }
 
     const response = await this.roboflow.uploadImage(args);

components/roboflow/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/roboflow",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream Roboflow  Components",
   "main": "roboflow.app.mjs",
   "keywords": [
@@ -13,6 +13,6 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.5.1"
+    "@pipedream/platform": "^3.1.0"
   }
 }

components/roboflow/roboflow.app.mjs

@@ -37,9 +37,8 @@ export default {
     },
     filePath: {
       type: "string",
-      label: "File Path",
-      description: "The path to the image file saved to the `/tmp` directory (e.g. `/tmp/image.png`). [See the documentation](https://pipedream.com/docs/workflows/steps/code/nodejs/working-with-files/#the-tmp-directory).",
-      optional: true,
+      label: "File Path or URL",
+      description: "The file to process. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.jpg`)",
     },
     fileUrl: {
       type: "string",

components/salesforce_rest_api/actions/create-attachment/create-attachment.mjs

@@ -1,6 +1,6 @@
 import common, { getProps } from "../common/base-create-update.mjs";
 import attachment from "../../common/sobjects/attachment.mjs";
-import fs from "fs";
+import { getFileStream } from "@pipedream/platform";
 
 const docsLink = "https://developer.salesforce.com/docs/atlas.en-us.object_reference.meta/object_reference/sforce_api_objects_attachment.htm";
 
@@ -18,7 +18,7 @@ export default {
   key: "salesforce_rest_api-create-attachment",
   name: "Create Attachment",
   description: `Creates an Attachment on a parent object. [See the documentation](${docsLink})`,
-  version: "0.4.1",
+  version: "0.5.0",
   type: "action",
   props,
   async run({ $ }) {
@@ -34,9 +34,17 @@ export default {
     } = this;
     /* eslint-enable no-unused-vars */
 
-    const body =  filePathOrContent.includes("tmp/")
-      ? (await fs.promises.readFile(filePathOrContent)).toString("base64")
-      : filePathOrContent;
+    let body;
+    if (filePathOrContent.startsWith("http") || filePathOrContent.includes("tmp/")) {
+      const stream = getFileStream(filePathOrContent);
+      const chunks = [];
+      for await (const chunk of stream) {
+        chunks.push(chunk);
+      }
+      body = Buffer.concat(chunks).toString("base64");
+    } else {
+      body = filePathOrContent;
+    }
 
     const response = await salesforce.createRecord("Attachment", {
       $,

components/salesforce_rest_api/common/sobjects/attachment.mjs

@@ -9,8 +9,8 @@ export default {
     },
     filePathOrContent: {
       type: "string",
-      label: "File Path or Content",
-      description: "The path to a file in the `tmp` folder [(see the documentation)](https://pipedream.com/docs/code/nodejs/working-with-files). Alternatively, you can provide the base64-encoded file data.",
+      label: "File Path or URL",
+      description: "The file to attach. Provide either a file URL, a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`), or base64-encoded file data.",
     },
     ContentType: {
       type: "string",

components/salesforce_rest_api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/salesforce_rest_api",
-  "version": "1.5.0",
+  "version": "1.6.0",
   "description": "Pipedream Salesforce (REST API) Components",
   "main": "salesforce_rest_api.app.mjs",
   "keywords": [
@@ -10,7 +10,7 @@
   "homepage": "https://pipedream.com/apps/salesforce_rest_api",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "dependencies": {
-    "@pipedream/platform": "^3.0.0",
+    "@pipedream/platform": "^3.1.0",
     "fast-xml-parser": "^4.3.2",
     "handlebars": "^4.7.7",
     "lodash": "^4.17.21",

components/scoredetect/actions/create-timestamp-file/create-timestamp-file.mjs

@@ -1,12 +1,11 @@
 import scoreDetect from "../../scoredetect.app.mjs";
-import fs from "fs";
-import { axios } from "@pipedream/platform";
+import { getFileStream } from "@pipedream/platform";
 
 export default {
   key: "scoredetect-create-timestamp-file",
   name: "Create Certificate from File",
   description: "Creates a timestamped blockchain certificate using a provided file (local or URL). [See the documentation](https://api.scoredetect.com/docs/routes#create-certificate)",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     scoreDetect,
@@ -18,19 +17,10 @@ export default {
     },
   },
   async run({ $ }) {
-    const { fileOrUrl } = this;
-    const file = fileOrUrl.startsWith("http")
-      ? await axios($, {
-        url: fileOrUrl,
-        responseType: "arraybuffer",
-      })
-      : fs.createReadStream(fileOrUrl.includes("tmp/")
-        ? fileOrUrl
-        : `/tmp/${fileOrUrl}`);
-
+    const stream = getFileStream(this.fileOrUrl);
     const response = await this.scoreDetect.createCertificate({
       $,
-      file,
+      file: stream,
     });
 
     $.export("$summary", "Successfully created certificate");

components/scoredetect/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/scoredetect",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream ScoreDetect Components",
   "main": "scoredetect.app.mjs",
   "keywords": [
@@ -13,7 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.6.0",
+    "@pipedream/platform": "^3.1.0",
     "form-data": "^4.0.0"
   }
 }