77 lines
1.7 KiB
JavaScript
77 lines
1.7 KiB
JavaScript
var fs = require('fs');
|
|
var util = require('util');
|
|
var stream = require('stream');
|
|
var FfmpegCommand = require('fluent-ffmpeg');
|
|
|
|
var helpers = require('./helpers');
|
|
var logger = require('./logger');
|
|
var BaseProcessor = require('./baseprocessor');
|
|
|
|
|
|
function FFMPEGProcessor()
|
|
{
|
|
BaseProcessor.apply(this, arguments);
|
|
}
|
|
|
|
util.inherits(FFMPEGProcessor, BaseProcessor);
|
|
|
|
|
|
|
|
FFMPEGProcessor.prototype.run = function()
|
|
{
|
|
var self = this;
|
|
var filename = helpers.createVariableFilename(this.cam.options.filename, this.now,
|
|
{
|
|
camId: this.camId
|
|
});
|
|
|
|
var tempFilename = filename + '.recording';
|
|
var cleanup = function()
|
|
{
|
|
fs.rename(tempFilename, filename, function(err)
|
|
{
|
|
if (err)
|
|
logger.error('Could not move ' + tempFilename + ' to ' + filename + ': ' + err);
|
|
|
|
self.doEnd();
|
|
});
|
|
}
|
|
|
|
|
|
var command = new FfmpegCommand();
|
|
command
|
|
.input(this.cam.options.input)
|
|
.inputOptions(['-t ' + Math.ceil(this.cam.options.time / 1000),
|
|
'-rtsp_transport tcp']);
|
|
|
|
if (typeof(this.cam.options.inputFormat) !== 'undefined')
|
|
{
|
|
command.inputFormat(this.cam.options.inputFormat);
|
|
if (this.cam.options.inputFormat === 'mjpeg')
|
|
command.inputOption('-use_wallclock_as_timestamps 1');
|
|
}
|
|
|
|
command
|
|
.output(tempFilename)
|
|
.videoCodec(this.cam.options.videoCodec)
|
|
.outputFormat(this.cam.options.outputFormat);
|
|
|
|
command.on('error', function(err, stdout, stderr)
|
|
{
|
|
logger.error('FFmpeg output:' + err.message);
|
|
cleanup();
|
|
});
|
|
|
|
command.on('end', function()
|
|
{
|
|
cleanup();
|
|
});
|
|
|
|
self.doStart();
|
|
command.run();
|
|
|
|
FFMPEGProcessor.super_.prototype.run.call(this);
|
|
}
|
|
|
|
|
|
module.exports = FFMPEGProcessor; |