cut video to clips and then merge clips

README.md

cut video to clips and then merge clips

flow.json

[{"id":"77de1242.7f835c","type":"function-npm","z":"2f73cdd.dbeac32","name":"proccess clips","func":"var base64 = require('file-base64');\nvar ffmpeg = require('fluent-ffmpeg');\nlet videoUrl = flow.get('videoUrl');\nlet videoClone = ('videoClone.mp4');\nvar fileExt = '.mp4';\nvar series = msg.payload;\nvar i = 0;\nvar len = series.length;\n\nfunction generateVideoCore(from, to) {\n  return new Promise(function(resolve, reject) {\n    generateVideov2(from, to).then(function() {\n      if (i === 0) {\n        mergeVideos(['test' + fileExt], 'output' + fileExt).then(function () {\n          cloneVideo('output' + fileExt, 'tmp' + fileExt).then(function () {\n            resolve('ok');\n          })\n        });\n      } else {\n        mergeVideos(['tmp' + fileExt, 'test' + fileExt], 'output' + fileExt).then(function () {\n          cloneVideo('output' + fileExt, 'tmp' + fileExt).then(function () {\n            resolve('ok');\n          })\n        });\n      }\n    });\n  });\n}\n\n\nfunction generateVideov2(from, to) {\n  return new Promise(function(resolve, reject) {\n    var formatFrom = new Date(from).toISOString().substr(11, 8);\n    var duration = (to - from) / 1000;\n\n    ffmpeg(videoClone) //./sos_4-16_anadarko.mp4\n    .setStartTime(formatFrom)\n    .setDuration(duration)\n    .output('test' + fileExt)\n\n    .on('end', function(err) {   \n      if(!err) {\n        resolve('ok');\n      }            \n    })\n    .on('error', function(err){\n      reject('error');\n    }).run();\n  });\n}\n\nfunction mergeVideos(videoNames, videoOut) {\n  return new Promise(function(resolve, reject) {\n    var mergedVideo = ffmpeg();\n    videoNames.forEach(function(videoName){\n      mergedVideo = mergedVideo.addInput(videoName);\n    });\n    mergedVideo.mergeToFile(videoOut, '/tmp/')\n    .on('end', function() {\n        node.error('merged');\n      resolve('ok');\n    })\n    .on('error', function(err) {\n      reject('err.message');\n    });\n  });\n}\n\nfunction cloneVideo(videoIn, videoOut) {\n  return new Promise(function(resolve, reject) {\n    ffmpeg(videoIn) //output.mp4\n    .clone()\n    .save(videoOut) //tmp.mp4\n    .on('end', function() {\n      resolve('ok');\n    })\n    .on('error', function(err) {\n      reject('err.message');\n    });\n  });\n}\n\nfunction recursive(from, to) {\n    node.error('merging');\n  generateVideoCore(from, to).then(function (data) {\n    i++;\n    if (i <= len - 1) {\n      recursive(series[i].startTimeMs, series[i].stopTimeMs);\n    } else {\n      base64.encode('output' + fileExt, function(err, base64String) {\n        msg.payload = base64String;\n        flow.set('video', base64String);\n        node.send(msg);\n      });\n    }\n  });\n}\ncloneVideo(videoUrl, videoClone).then(()=>{\n    recursive(series[i].startTimeMs, series[i].stopTimeMs);\n})\n","outputs":1,"noerr":0,"x":404.0173645019531,"y":326.0103940963745,"wires":[["ae623b1b.3aeb58","2e62b79f.d8afb8"]]}]