Update video_processing.yaml

video_processing.yaml

@@ -1,9 +1,10 @@
 _id: video_processing
+version: 1
 title: en=Video processing;ru=Работа с видео
 description: Using FFmpeg process videos
-version: 1
-url: https://huggingface.co/PiperMy/Node-Packages/resolve/main/video_processing.yaml
 readme: ""
+author: Anton Breslavskii | https://github.com/breslavsky
+url: https://huggingface.co/PiperMy/Node-Packages/resolve/main/video_processing.yaml
 nodes:
   split_video_by_frames:
     _id: split_video_by_frames
@@ -35,47 +36,48 @@ nodes:
         type: image[]
     package: video_processing
     script: |-
-      const ffmpeg = require('fluent-ffmpeg');
-      const path = require('path');
-      const fs = require('fs/promises');
-      const { fileTypeFromBuffer } = require('file-type');
+      export async function run({ inputs }) {
+          const { video, fps } = inputs;
 
-      (async () => {
-        const { video, fps } = inputs;
+          const { FatalError, NextNode } = DEFINITIONS;
+          const ffmpeg = require('fluent-ffmpeg');
+          const path = require('path');
+          const fs = require('fs/promises');
+          const { fileTypeFromBuffer } = require('file-type');
 
-        const frames = [];
+          const frames = [];
 
-        await useTempFolder(async (tmpFolder) => {
-          
-          const { data } = await download(video);
-          const { ext } = await fileTypeFromBuffer(data);
-          const videoPath = path.join(tmpFolder, `source.${ext}`);
-          await fs.writeFile(videoPath, data);
-          
-          await new Promise((resolve, reject) => {
-            ffmpeg(videoPath)
-              .outputOptions([
-                `-r ${fps || 12}`,
-                '-q:v 1'
-              ])
-              .output(`${tmpFolder}/%05d.jpg`)
-              .on('start', (cmd) => log(cmd))
-              .on('end', () => resolve())
-              .on('error', (err) => reject(err))
-              .run();
-          });
+          await useTempFolder(async (tmpFolder) => {
+
+              const { data } = await download(video);
+              const { ext } = await fileTypeFromBuffer(data);
+              const videoPath = path.join(tmpFolder, `source.${ext}`);
+              await fs.writeFile(videoPath, data);
 
-          const files = await fs.readdir(tmpFolder);
-          for (const file of files) {
-            if (file.endsWith('jpg')) {
-              frames.push(await fs.readFile(path.join(tmpFolder, file)));
-            }
-          }
+              await new Promise((resolve, reject) => {
+                  ffmpeg(videoPath)
+                      .outputOptions([
+                          `-r ${fps || 12}`,
+                          '-q:v 1'
+                      ])
+                      .output(`${tmpFolder}/%05d.jpg`)
+                      .on('start', (cmd) => console.log(cmd))
+                      .on('end', () => resolve())
+                      .on('error', (err) => reject(new FatalError(err)))
+                      .run();
+              });
 
-        });
+              const files = await fs.readdir(tmpFolder);
+              for (const file of files) {
+                  if (file.endsWith('jpg')) {
+                      frames.push(await fs.readFile(path.join(tmpFolder, file)));
+                  }
+              }
+
+          });
 
-        return next({outputs: { frames }});
-      })();
+          return NextNode.from({ outputs: { frames } });
+      }
     source: catalog
     title: en=Split video by frames;ru=Разбить видео по кадрам
     version: 6