add: scrapfly, fix: several

GTFalcao · GTFalcao · commit 0033db0589e7 · 2025-06-17T03:16:45.000-03:00
diff --git a/components/meistertask/actions/create-attachment/create-attachment.mjs b/components/meistertask/actions/create-attachment/create-attachment.mjs
@@ -60,7 +60,7 @@ export default {
 
     const {
       stream, metadata,
-    } = getFileStreamAndMetadata(filepath);
+    } = await getFileStreamAndMetadata(filepath);
     data.append("local", stream, {
       contentType: metadata.contentType,
       knownLength: metadata.size,
diff --git a/components/pdffiller/actions/upload-document/upload-document.mjs b/components/pdffiller/actions/upload-document/upload-document.mjs
@@ -27,7 +27,7 @@ export default {
   async run({ $ }) {
     const {
       stream, metadata,
-    } = getFileStreamAndMetadata(this.file);
+    } = await getFileStreamAndMetadata(this.file);
     const data = new FormData();
     data.append("file", stream, {
       contentType: metadata.contentType,
diff --git a/components/pixelbin/actions/upload-file/upload-file.mjs b/components/pixelbin/actions/upload-file/upload-file.mjs
@@ -82,7 +82,7 @@ export default {
 
     const {
       stream, metadata: fileMetadata,
-    } = getFileStreamAndMetadata(filePath);
+    } = await getFileStreamAndMetadata(filePath);
     const data = new FormData();
     data.append("file", stream, {
       contentType: fileMetadata.contentType,
diff --git a/components/platerecognizer/actions/run-recognition/run-recognition.mjs b/components/platerecognizer/actions/run-recognition/run-recognition.mjs
@@ -41,7 +41,7 @@ export default {
   },
   async run({ $ }) {
 
-    const stream = getFileStream(this.imageFileOrUrl);
+    const stream = await getFileStream(this.imageFileOrUrl);
     const chunks = [];
     for await (const chunk of stream) {
       chunks.push(chunk);
diff --git a/components/printautopilot/actions/add-pdf-to-queue/add-pdf-to-queue.mjs b/components/printautopilot/actions/add-pdf-to-queue/add-pdf-to-queue.mjs
@@ -27,7 +27,7 @@ export default {
     },
   },
   async run({ $ }) {
-    const stream = getFileStream(this.filePath);
+    const stream = await getFileStream(this.filePath);
     const chunks = [];
     for await (const chunk of stream) {
       chunks.push(chunk);
diff --git a/components/printify/actions/create-product/create-product.mjs b/components/printify/actions/create-product/create-product.mjs
@@ -1,5 +1,4 @@
 import { getFileStream } from "@pipedream/platform";
-import { checkTmp } from "../../common/utils.mjs";
 import printify from "../../printify.app.mjs";
 
 export default {
@@ -155,7 +154,7 @@ export default {
     }
     for (let i = 1; i <= this.imageCount; i++) {
       const imageString = this[`imagePath_${i}`];
-      const stream = getFileStream(checkTmp(imageString));
+      const stream = await getFileStream(imageString);
       const chunks = [];
       for await (const chunk of stream) {
         chunks.push(chunk);
diff --git a/components/printnode/actions/send-print-job/send-print-job.mjs b/components/printnode/actions/send-print-job/send-print-job.mjs
@@ -69,7 +69,7 @@ export default {
       printnode, contentType, filePath, ...props
     } = this;
 
-    const stream = getFileStream(filePath);
+    const stream = await getFileStream(filePath);
     const chunks = [];
     for await (const chunk of stream) {
       chunks.push(chunk);
diff --git a/components/ragie/actions/create-document/create-document.mjs b/components/ragie/actions/create-document/create-document.mjs
@@ -53,7 +53,7 @@ export default {
     const data = new FormData();
     const {
       stream, metadata,
-    } = getFileStreamAndMetadata(this.file);
+    } = await getFileStreamAndMetadata(this.file);
     data.append("file", stream, {
       contentType: metadata.contentType,
       knownLength: metadata.size,
diff --git a/components/ragie/actions/update-document-file/update-document-file.mjs b/components/ragie/actions/update-document-file/update-document-file.mjs
@@ -34,7 +34,7 @@ export default {
     const data = new FormData();
     const {
       stream, metadata,
-    } = getFileStreamAndMetadata(this.file);
+    } = await getFileStreamAndMetadata(this.file);
     data.append("file", stream, {
       contentType: metadata.contentType,
       knownLength: metadata.size,
diff --git a/components/raindrop/actions/parse-bookmark-file/parse-bookmark-file.mjs b/components/raindrop/actions/parse-bookmark-file/parse-bookmark-file.mjs
@@ -20,7 +20,7 @@ export default {
     const form = new FormData();
     const {
       stream, metadata,
-    } = getFileStreamAndMetadata(this.filePath);
+    } = await getFileStreamAndMetadata(this.filePath);
     form.append("import", stream, {
       contentType: metadata.contentType,
       knownLength: metadata.size,
diff --git a/components/ramp/actions/upload-receipt/upload-receipt.mjs b/components/ramp/actions/upload-receipt/upload-receipt.mjs
@@ -42,7 +42,7 @@ export default {
       `--${boundary}\r\n` +
       `Content-Disposition: attachment; name="receipt"; filename="${this.filePath.split("/").pop()}"\r\n\r\n`;
 
-    const stream = getFileStream(this.filePath);
+    const stream = await getFileStream(this.filePath);
     const chunks = [];
     for await (const chunk of stream) {
       chunks.push(chunk);
diff --git a/components/reform/actions/extract-data-from-document/extract-data-from-document.mjs b/components/reform/actions/extract-data-from-document/extract-data-from-document.mjs
@@ -29,7 +29,7 @@ export default {
     const formData = new FormData();
     const {
       stream, metadata,
-    } = getFileStreamAndMetadata(this.document);
+    } = await getFileStreamAndMetadata(this.document);
     formData.append("document", stream, {
       filename: metadata.name,
       contentType: metadata.contentType,
diff --git a/components/salesforce_rest_api/actions/create-attachment/create-attachment.mjs b/components/salesforce_rest_api/actions/create-attachment/create-attachment.mjs
@@ -36,7 +36,7 @@ export default {
 
     let body;
     if (filePathOrContent.startsWith("http") || filePathOrContent.includes("tmp/")) {
-      const stream = getFileStream(filePathOrContent);
+      const stream = await getFileStream(filePathOrContent);
       const chunks = [];
       for await (const chunk of stream) {
         chunks.push(chunk);
diff --git a/components/scoredetect/actions/create-timestamp-file/create-timestamp-file.mjs b/components/scoredetect/actions/create-timestamp-file/create-timestamp-file.mjs
@@ -17,7 +17,7 @@ export default {
     },
   },
   async run({ $ }) {
-    const stream = getFileStream(this.fileOrUrl);
+    const stream = await getFileStream(this.fileOrUrl);
     const response = await this.scoreDetect.createCertificate({
       $,
       file: stream,
diff --git a/components/scrapfly/actions/ai-data-extraction/ai-data-extraction.mjs b/components/scrapfly/actions/ai-data-extraction/ai-data-extraction.mjs
@@ -65,7 +65,7 @@ export default {
       throw new ConfigurationError("You must provide at least **Extraction Template**, **Extraction Prompt** or **Extraction Model**");
     }
 
-    const stream = getFileStream(this.body);
+    const stream = await getFileStream(this.body);
     const chunks = [];
     for await (const chunk of stream) {
       chunks.push(chunk);
diff --git a/components/scrapfly/scrapfly.app.mjs b/components/scrapfly/scrapfly.app.mjs
@@ -13,7 +13,7 @@ export default {
     body: {
       type: "string",
       label: "File Path or URL",
-      description: "The file containing the content of the page you want to extract data from. The content must be in the format specified by the `content-type` header or via the `content_type` HTTP parameter. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`)",
+      description: "The file containing the content of the page you want to extract data from. The content must be in the format specified by `Content Type`. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`)",
     },
     contentType: {
       type: "string",
