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 BaseHTTPStreamProcessor = require('./basehttpstreamprocessor');
|
|
|
|
|
|
function HTTPFFMPEGProcessor()
|
|
{
|
|
BaseHTTPStreamProcessor.apply(this, arguments);
|
|
}
|
|
|
|
util.inherits(HTTPFFMPEGProcessor, BaseHTTPStreamProcessor);
|
|
|
|
|
|
|
|
HTTPFFMPEGProcessor.prototype.run = function()
|
|
{
|
|
this.output = new stream.PassThrough();
|
|
this.filename = helpers.createVariableFilename(this.cam.options.filename, this.now,
|
|
{
|
|
camId: this.camId
|
|
});
|
|
|
|
this.tempFilename = this.filename + '.recording';
|
|
|
|
|
|
var command = new FfmpegCommand();
|
|
command
|
|
.input(this.output)
|
|
.inputFormat(this.cam.options.inputFormat);
|
|
|
|
if (this.cam.options.inputFormat === 'mjpeg')
|
|
command.inputOption('-use_wallclock_as_timestamps 1');
|
|
|
|
command
|
|
.output(this.tempFilename)
|
|
.videoCodec(this.cam.options.videoCodec)
|
|
.outputFormat(this.cam.options.outputFormat);
|
|
|
|
command.on('error', function(err, stdout, stderr)
|
|
{
|
|
logger.error('FFmpeg output:' + err.message);
|
|
});
|
|
|
|
command.run();
|
|
|
|
HTTPFFMPEGProcessor.super_.prototype.run.call(this);
|
|
}
|
|
|
|
|
|
HTTPFFMPEGProcessor.prototype.getStream = function()
|
|
{
|
|
return this.output;
|
|
}
|
|
|
|
|
|
HTTPFFMPEGProcessor.prototype.cleanup = function()
|
|
{
|
|
if (this.output !== null)
|
|
{
|
|
this.output.end();
|
|
this.output = null;
|
|
}
|
|
|
|
fs.rename(this.tempFilename, this.filename, function(err)
|
|
{
|
|
if (err)
|
|
logger.error('Could not move ' + this.tempFilename + ' to ' + this.filename + ': ' + err);
|
|
});
|
|
}
|
|
|
|
module.exports = HTTPFFMPEGProcessor; |