add: tinypng, todoist

Author: GTFalcao

components/tinypng/actions/compress-image/compress-image.mjs

@@ -1,23 +1,14 @@
-import { ConfigurationError } from "@pipedream/platform";
-import fs from "fs";
-import { IMAGE_TYPES } from "../../common/constants.mjs";
-import { checkTmp } from "../../common/utils.mjs";
+import { getFileStreamAndMetadata } from "@pipedream/platform";
 import tinypng from "../../tinypng.app.mjs";
 
 export default {
   key: "tinypng-compress-image",
   name: "Compress Image",
   description: "Compress a WebP, JPEG, or PNG image using the TinyPNG API. [See the documentation](https://tinypng.com/developers/reference#compressing-images)",
-  version: "0.0.1",
+  version: "0.1.0",
   type: "action",
   props: {
     tinypng,
-    url: {
-      propDefinition: [
-        tinypng,
-        "url",
-      ],
-    },
     file: {
       propDefinition: [
         tinypng,
@@ -26,36 +17,19 @@ export default {
     },
   },
   async run({ $ }) {
-    if (!this.url && !this.file) {
-      throw new Error("You must provide either a URL or a file for compression.");
-    }
-
-    let data;
-    let headers = {};
-
-    if (this.url) {
-      data = {
-        source: {
-          url: this.url,
-        },
-      };
-    }
-
-    if (this.file) {
-      const fileData = this.file.split(".");
-      const ext = fileData[1];
-
-      if (!IMAGE_TYPES.includes(ext)) {
-        throw new ConfigurationError("You can upload either WebP, JPEG or PNG.");
-      }
-      const file = fs.readFileSync(checkTmp(this.file));
-      data = file;
-      headers = {
-        "Content-Type": `image/${ext}`,
-        "content-disposition": "attachment; filename=" + fileData[0],
-      };
+    const {
+      stream, metadata,
+    } = await getFileStreamAndMetadata(this.file);
 
+    const chunks = [];
+    for await (const chunk of stream) {
+      chunks.push(chunk);
     }
+    const data = Buffer.concat(chunks);
+    const headers = {
+      "Content-Type": metadata.contentType,
+      "content-disposition": "attachment; filename=" + metadata.name,
+    };
 
     const response = await this.tinypng.compressImage({
       $,

components/tinypng/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/tinypng",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Pipedream TinyPNG AI Components",
   "main": "tinypng.app.mjs",
   "keywords": [
@@ -13,8 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.5.1",
-    "fs": "^0.0.1-security",
+    "@pipedream/platform": "^3.1.0",
     "stream": "^0.0.2",
     "util": "^0.12.5"
   }

components/tinypng/tinypng.app.mjs

@@ -5,17 +5,10 @@ export default {
   type: "app",
   app: "tinypng",
   propDefinitions: {
-    url: {
-      type: "string",
-      label: "Image URL",
-      description: "URL of the image to compress (WebP, JPEG, or PNG).",
-      optional: true,
-    },
     file: {
       type: "string",
-      label: "Image File",
-      description: "The path to the image file (WebP, JPEG, or PNG) saved to the `/tmp` directory (e.g. `/tmp/example.jpg`). [See the documentation](https://pipedream.com/docs/workflows/steps/code/nodejs/working-with-files/#the-tmp-directory).",
-      optional: true,
+      label: "Image Path or URL",
+      description: "The image to upload (WebP, JPEG, or PNG). Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.png`)",
     },
     imageId: {
       type: "string",

components/todoist/actions/import-tasks/import-tasks.mjs

@@ -1,12 +1,12 @@
 import todoist from "../../todoist.app.mjs";
-import fs from "fs";
 import converter from "json-2-csv";
+import { getFileStream } from "@pipedream/platform";
 
 export default {
   key: "todoist-import-tasks",
   name: "Import Tasks",
   description: "Import tasks into a selected project. [See Docs](https://developer.todoist.com/sync/v9/#add-an-item)",
-  version: "0.0.3",
+  version: "0.1.0",
   type: "action",
   props: {
     todoist,
@@ -37,7 +37,12 @@ export default {
       project,
     } = this;
 
-    const fileContents = (await fs.promises.readFile(path)).toString();
+    const stream = await getFileStream(path);
+    const chunks = [];
+    for await (const chunk of stream) {
+      chunks.push(chunk);
+    }
+    const fileContents = Buffer.concat(chunks).toString();
     const tasks = await converter.csv2jsonAsync(fileContents);
     // CREATE TASKS
     const data = tasks.map((task) => ({

components/todoist/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/todoist",
-  "version": "0.1.4",
+  "version": "0.2.0",
   "description": "Pipedream Todoist Components",
   "main": "todoist.app.mjs",
   "keywords": [
@@ -10,7 +10,7 @@
   "homepage": "https://pipedream.com/apps/todoist",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "dependencies": {
-    "@pipedream/platform": "^3.0.3",
+    "@pipedream/platform": "^3.1.0",
     "json-2-csv": "^3.15.1",
     "query-string": "^7.1.3",
     "tmp-promise": "^3.0.3",

components/todoist/todoist.app.mjs

@@ -255,8 +255,8 @@ export default {
     },
     path: {
       type: "string",
-      label: "File Path",
-      description: "Path to .csv file containing task data. Enter a static value (e.g., `/tmp/myFile.csv`) or reference prior step exports via the `steps` object (e.g., `{{steps.export_tasks.$return_value}}`).",
+      label: "File Path or URL",
+      description: "The .csv file to upload. Provide either a file URL or a path to a file in the `/tmp` directory (for example, `/tmp/myFile.csv`)",
     },
   },
   methods: {