add: microsoft_onedrive, mistral_ai, onlyoffice_docspace

Author: GTFalcao

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

@@ -1,13 +1,14 @@
 import onedrive from "../../microsoft_onedrive.app.mjs";
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
+import {
+  ConfigurationError, getFileStream,
+} from "@pipedream/platform";
 import { fileTypeFromStream } from "file-type";
 
 export default {
   name: "Upload File",
   description: "Upload a file to OneDrive. [See the documentation](https://learn.microsoft.com/en-us/onedrive/developer/rest-api/api/driveitem_put_content?view=odsp-graph-online)",
   key: "microsoft_onedrive-upload-file",
-  version: "0.1.2",
+  version: "0.2.0",
   type: "action",
   props: {
     onedrive,
@@ -21,8 +22,8 @@ export default {
     },
     filePath: {
       type: "string",
-      label: "File Path",
-      description: "The path to the 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).",
+      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`)",
     },
     filename: {
       type: "string",
@@ -39,7 +40,7 @@ export default {
       throw new ConfigurationError("You must specify the **Upload Folder ID**.");
     }
 
-    let stream = fs.createReadStream(filePath);
+    let stream = await getFileStream(filePath);
     let name = filename;
 
     if (!filename.includes(".")) {
@@ -48,7 +49,7 @@ export default {
       name = `${filename}.${extension}`;
 
       stream.destroy();
-      stream = fs.createReadStream(filePath);
+      stream = await getFileStream(filePath);
     }
 
     const response = await this.onedrive.uploadFile({

components/microsoft_onedrive/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/microsoft_onedrive",
-  "version": "1.6.2",
+  "version": "1.7.0",
   "description": "Pipedream Microsoft OneDrive components",
   "main": "microsoft_onedrive.app.mjs",
   "homepage": "https://pipedream.com/apps/microsoft-onedrive",
@@ -10,7 +10,7 @@
   },
   "dependencies": {
     "@microsoft/microsoft-graph-client": "^3.0.1",
-    "@pipedream/platform": "^3.0.3",
+    "@pipedream/platform": "^3.1.0",
     "bottleneck": "^2.19.5",
     "file-type": "^18.7.0",
     "isomorphic-fetch": "^3.0.0",

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

@@ -1,20 +1,19 @@
 import mistralAI from "../../mistral_ai.app.mjs";
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
+import { getFileStream } from "@pipedream/platform";
 import FormData from "form-data";
 
 export default {
   key: "mistral_ai-upload-file",
   name: "Upload File",
   description: "Upload a file that can be used across various endpoints. [See the Documentation](https://docs.mistral.ai/api/#tag/files/operation/files_api_routes_upload_file)",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     mistralAI,
     filePath: {
       type: "string",
-      label: "File Path",
-      description: "The path to a file in the `/tmp` directory. The size of individual files can be a maximum of 512 MB. The Fine-tuning API only supports .jsonl files. [See the Pipedream 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 file to upload. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.txt`)",
     },
     purpose: {
       type: "string",
@@ -29,15 +28,7 @@ export default {
     },
   },
   async run({ $ }) {
-    const filePath = this.filePath.startsWith("/tmp/")
-      ? this.filePath
-      : `/tmp/${this.filePath}`;
-
-    if (!fs.existsSync(filePath)) {
-      throw new ConfigurationError(`File \`${filePath}\` not found`);
-    }
-
-    const fileContent = fs.createReadStream(filePath);
+    const fileContent = await getFileStream(this.filePath);
     const form = new FormData();
     form.append("file", fileContent);
     if (this.purpose) {

components/mistral_ai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/mistral_ai",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream Mistral AI Components",
   "main": "mistral_ai.app.mjs",
   "keywords": [
@@ -13,7 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^3.0.3",
+    "@pipedream/platform": "^3.1.0",
     "form-data": "^4.0.2"
   }
 }

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

@@ -5,7 +5,7 @@ export default {
   key: "onlyoffice_docspace-upload-file",
   name: "Upload File",
   description: "Uploads a file to the specified room. [See the documentation](https://api.onlyoffice.com/docspace/method/files/post/api/2.0/files/%7bfolderid%7d/upload)",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     app,
@@ -19,8 +19,8 @@ export default {
     },
     file: {
       type: "string",
-      label: "File",
-      description: "File path of a file previously downloaded in Pipedream E.g. (`/tmp/my-file.txt`). [Download a file to the `/tmp` directory](https://pipedream.com/docs/code/nodejs/http-requests/#download-a-file-to-the-tmp-directory)",
+      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`)",
     },
   },
   methods: {

components/onlyoffice_docspace/common/utils.mjs

@@ -1,17 +1,14 @@
-import { createReadStream } from "fs";
+import { getFileStream } from "@pipedream/platform";
 import FormData from "form-data";
 import constants from "./constants.mjs";
 
-function buildFormData(formData, data, parentKey) {
+async function buildFormData(formData, data, parentKey) {
   if (data && typeof(data) === "object") {
-    Object.keys(data)
-      .forEach((key) => {
-        buildFormData(formData, data[key], parentKey && `${parentKey}[${key}]` || key);
-      });
-
+    for (const key of Object.keys(data)) {
+      await buildFormData(formData, data[key], parentKey && `${parentKey}[${key}]` || key);
+    }
   } else if (data && constants.FILE_PROP_NAMES.some((prop) => parentKey.includes(prop))) {
-    formData.append(parentKey, createReadStream(data));
-
+    formData.append(parentKey, await getFileStream(data));
   } else if (data) {
     formData.append(parentKey, (data).toString());
   }

components/onlyoffice_docspace/package.json

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