How to Convert a Code into a Pipedream Action?

Help
1

This topic was automatically generated from Slack. You can find the original thread here.

can you help me convert this code into a Pipedream action?

const stream = require("stream");
const { promisify } = require("util");
const fs = require("fs");
const { default: got } = await import("got");

// Upload file using the large file interface
// https://pipedream.com/docs/workflows/steps/triggers/#large-file-support
// This code downloads the file to the /tmp directory
const f = `/tmp/${steps.trigger.event.body.video.filename}`
const pipeline = promisify(stream.pipeline);
await pipeline(
  got.stream(steps.trigger.event.body.video.url),
  fs.createWriteStream(f)
);

// Get file info
const ffmpegPath = require('@ffmpeg-installer/ffmpeg').path;
const exec = promisify(require('child_process').exec);
return await exec(`${ffmpegPath} -i ${f} /tmp/video.avi`);
2

Sure, I can help you convert this code into a Pipedream action. Below is the converted code using the Pipedream component structure: import { axios } from "@pipedream/platform"; import stream from "stream"; import { promisify } from "util"; import fs from "fs"; import got from "got"; import { path as ffmpegPath } from "@ffmpeg-installer/ffmpeg"; import { exec as execCb } from "child_process"; const exec = promisify(execCb); export default defineComponent({ props: { // Define any props you need here }, async run({ steps, $ }) { // Upload file using the large file interface // https://pipedream.com/docs/workflows/steps/triggers/#large-file-support // This code downloads the file to the /tmp directory const f = `/tmp/${steps.trigger.event.body.video.filename}`; const pipeline = promisify(stream.pipeline); await pipeline( got.stream(steps.trigger.event.body.video.url), fs.createWriteStream(f) ); // Get file info return await exec(`${ffmpegPath} -i ${f} /tmp/video.avi`); }, }); ### Explanation: 1. Imports: Imported necessary modules at the top of the file. 2. Component Definition: Used defineComponent to define the Pipedream component. 3. Props: You can define any props you need within the props object. 4. Run Method: The main logic is placed inside the run method. 5. Pipeline and File Handling: Used promisify to handle the stream pipeline and download the file to the /tmp directory. 6. FFmpeg Execution: Used exec to run the FFmpeg command to process the video file. Feel free to modify the props and other parts of the code as needed. If you have any specific requirements or additional questions, please let me know!

3

can you make videoFilename and videoUrl as props instead?

4

Sure! Here is an example of how you can define videoFilename and videoUrl as props in a Pipedream component: import { axios } from "@pipedream/platform"; export default defineComponent({ props: { videoFilename: { type: "string", label: "Video Filename", description: "The name of the video file", }, videoUrl: { type: "string", label: "Video URL", description: "The URL of the video", }, }, async run({ steps, $ }) { const { videoFilename, videoUrl } = this; // Example usage of the props const response = await axios($, { url: videoUrl, responseType: 'stream', }); const filePath = `/tmp/${videoFilename}`; const writer = require('fs').createWriteStream(filePath); response.data.pipe(writer); return { filePath }; }, }); In this example, videoFilename and videoUrl are defined as props with type, label, and description. These props can be used within the run method to handle the video file and URL dynamically.