You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
286 lines
14 KiB
286 lines
14 KiB
"use strict";
|
|
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
|
|
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
|
|
return new (P || (P = Promise))(function (resolve, reject) {
|
|
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
|
|
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
|
|
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
|
|
step((generator = generator.apply(thisArg, _arguments || [])).next());
|
|
});
|
|
};
|
|
var __generator = (this && this.__generator) || function (thisArg, body) {
|
|
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
|
|
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
|
|
function verb(n) { return function (v) { return step([n, v]); }; }
|
|
function step(op) {
|
|
if (f) throw new TypeError("Generator is already executing.");
|
|
while (g && (g = 0, op[0] && (_ = 0)), _) try {
|
|
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
|
|
if (y = 0, t) op = [op[0] & 2, t.value];
|
|
switch (op[0]) {
|
|
case 0: case 1: t = op; break;
|
|
case 4: _.label++; return { value: op[1], done: false };
|
|
case 5: _.label++; y = op[1]; op = [0]; continue;
|
|
case 7: op = _.ops.pop(); _.trys.pop(); continue;
|
|
default:
|
|
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
|
|
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
|
|
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
|
|
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
|
|
if (t[2]) _.ops.pop();
|
|
_.trys.pop(); continue;
|
|
}
|
|
op = body.call(thisArg, _);
|
|
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
|
|
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
|
|
}
|
|
};
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.CLI = exports.getFFmpegVar = void 0;
|
|
var cliParsers_1 = require("./cliParsers");
|
|
var fs = require('fs');
|
|
var fancyTimeFormat = function (time) {
|
|
// Hours, minutes and seconds
|
|
// eslint-disable-next-line no-bitwise
|
|
var hrs = ~~(time / 3600);
|
|
// eslint-disable-next-line no-bitwise
|
|
var mins = ~~((time % 3600) / 60);
|
|
// eslint-disable-next-line no-bitwise
|
|
var secs = ~~time % 60;
|
|
// Output like "1:01" or "4:03:59" or "123:03:59"
|
|
var ret = '';
|
|
// if (hrs > 0) {
|
|
ret += "".concat(hrs, ":").concat(mins < 10 ? '0' : '');
|
|
// }
|
|
ret += "".concat(mins, ":").concat(secs < 10 ? '0' : '');
|
|
ret += "".concat(secs);
|
|
return ret;
|
|
};
|
|
// frame= 889 fps=106 q=26.0 Lsize= 25526kB time=00:00:35.69 bitrate=5858.3kbits/s speed=4.25x
|
|
var getFFmpegVar = function (_a) {
|
|
var str = _a.str, variable = _a.variable;
|
|
if (typeof str !== 'string') {
|
|
return '';
|
|
}
|
|
var idx = str.indexOf(variable);
|
|
var out = '';
|
|
var initSpacesEnded = false;
|
|
if (idx >= 0) {
|
|
var startIdx = idx + variable.length + 1;
|
|
for (var i = startIdx; i < str.length; i += 1) {
|
|
if (initSpacesEnded === true && str[i] === ' ') {
|
|
break;
|
|
}
|
|
else if (initSpacesEnded === false && str[i] !== ' ') {
|
|
initSpacesEnded = true;
|
|
}
|
|
if (initSpacesEnded === true && str[i] !== ' ') {
|
|
out += str[i];
|
|
}
|
|
}
|
|
}
|
|
return out;
|
|
};
|
|
exports.getFFmpegVar = getFFmpegVar;
|
|
var CLI = /** @class */ (function () {
|
|
function CLI(config) {
|
|
var _this = this;
|
|
// @ts-expect-error init
|
|
this.config = {};
|
|
this.progAVG = [];
|
|
this.oldOutSize = 0;
|
|
this.oldEstSize = 0;
|
|
this.oldProgress = 0;
|
|
this.lastProgCheck = 0;
|
|
this.updateETA = function (perc) {
|
|
if (perc > 0) {
|
|
if (_this.lastProgCheck === 0) {
|
|
_this.lastProgCheck = new Date().getTime();
|
|
_this.oldProgress = perc;
|
|
}
|
|
else if (perc !== _this.oldProgress) {
|
|
var n = new Date().getTime();
|
|
var secsSinceLastCheck = (n - _this.lastProgCheck) / 1000;
|
|
if (secsSinceLastCheck > 1) {
|
|
// eta total
|
|
var eta = Math.round((100 / (perc - _this.oldProgress)) * secsSinceLastCheck);
|
|
// eta remaining
|
|
eta *= ((100 - perc) / 100);
|
|
_this.progAVG.push(eta);
|
|
// let values = [2, 56, 3, 41, 0, 4, 100, 23];
|
|
var sum = _this.progAVG.reduce(
|
|
// eslint-disable-next-line
|
|
function (previous, current) { return (current += previous); });
|
|
var avg = sum / _this.progAVG.length;
|
|
// est size
|
|
var estSize = 0;
|
|
var outputFileSizeInGbytes = void 0;
|
|
try {
|
|
if (fs.existsSync(_this.config.outputFilePath)) {
|
|
var singleFileSize = fs.statSync(_this.config.outputFilePath);
|
|
singleFileSize = singleFileSize.size;
|
|
outputFileSizeInGbytes = singleFileSize / (1024 * 1024 * 1024);
|
|
if (outputFileSizeInGbytes !== _this.oldOutSize) {
|
|
_this.oldOutSize = outputFileSizeInGbytes;
|
|
estSize = outputFileSizeInGbytes
|
|
+ ((100 - perc) / perc) * outputFileSizeInGbytes;
|
|
_this.oldEstSize = estSize;
|
|
}
|
|
}
|
|
}
|
|
catch (err) {
|
|
// eslint-disable-next-line no-console
|
|
console.log(err);
|
|
}
|
|
_this.config.updateWorker({
|
|
ETA: fancyTimeFormat(avg),
|
|
outputFileSizeInGbytes: outputFileSizeInGbytes === undefined ? 0 : outputFileSizeInGbytes,
|
|
estSize: _this.oldEstSize === undefined ? 0 : _this.oldEstSize,
|
|
});
|
|
if (_this.progAVG.length > 30) {
|
|
_this.progAVG.splice(0, 1);
|
|
}
|
|
_this.lastProgCheck = n;
|
|
_this.oldProgress = perc;
|
|
}
|
|
}
|
|
}
|
|
};
|
|
this.parseOutput = function (data) {
|
|
var _a, _b, _c, _d, _e, _f, _g;
|
|
var str = "".concat(data);
|
|
//
|
|
if (_this.config.logFullCliOutput === true) {
|
|
_this.config.jobLog(str);
|
|
}
|
|
if (_this.config.cli.toLowerCase().includes('handbrake')) {
|
|
var percentage = (0, cliParsers_1.handbrakeParser)({
|
|
str: str,
|
|
});
|
|
if (percentage > 0) {
|
|
_this.updateETA(percentage);
|
|
_this.config.updateWorker({
|
|
percentage: percentage,
|
|
});
|
|
}
|
|
}
|
|
else if (_this.config.cli.toLowerCase().includes('ffmpeg')) {
|
|
var n = str.indexOf('fps');
|
|
var shouldUpdate = str.length >= 6 && n >= 6;
|
|
var fps = parseInt((0, exports.getFFmpegVar)({
|
|
str: str,
|
|
variable: 'fps',
|
|
}), 10);
|
|
var frameCount = 0;
|
|
try {
|
|
// @ts-expect-error type
|
|
var frameCountTmp = (_a = _this.config.inputFileObj.ffProbeData) === null || _a === void 0 ? void 0 : _a.streams.filter(function (row) { return row.codec_type === 'video'; })[0].nb_frames;
|
|
if (frameCountTmp
|
|
// @ts-expect-error type
|
|
&& !isNaN(frameCountTmp)) { // eslint-disable-line no-restricted-globals
|
|
// @ts-expect-error type
|
|
frameCount = frameCountTmp;
|
|
}
|
|
}
|
|
catch (err) {
|
|
// err
|
|
}
|
|
var percentage = (0, cliParsers_1.ffmpegParser)({
|
|
str: str,
|
|
frameCount: frameCount,
|
|
videoFrameRate: (_c = (_b = _this.config.inputFileObj) === null || _b === void 0 ? void 0 : _b.meta) === null || _c === void 0 ? void 0 : _c.VideoFrameRate,
|
|
ffprobeDuration: (_e = (_d = _this.config.inputFileObj.ffProbeData) === null || _d === void 0 ? void 0 : _d.format) === null || _e === void 0 ? void 0 : _e.duration,
|
|
metaDuration: (_g = (_f = _this.config.inputFileObj) === null || _f === void 0 ? void 0 : _f.meta) === null || _g === void 0 ? void 0 : _g.Duration,
|
|
});
|
|
if (shouldUpdate === true && fps > 0) {
|
|
_this.config.updateWorker({
|
|
fps: fps,
|
|
});
|
|
}
|
|
if (percentage > 0) {
|
|
_this.updateETA(percentage);
|
|
_this.config.updateWorker({
|
|
percentage: percentage,
|
|
});
|
|
}
|
|
}
|
|
else if (_this.config.cli.toLowerCase().includes('editready')) {
|
|
var percentage = (0, cliParsers_1.editreadyParser)({
|
|
str: str,
|
|
});
|
|
if (percentage > 0) {
|
|
_this.updateETA(percentage);
|
|
_this.config.updateWorker({
|
|
percentage: percentage,
|
|
});
|
|
}
|
|
}
|
|
};
|
|
this.runCli = function () { return __awaiter(_this, void 0, void 0, function () {
|
|
var childProcess, errorLogFull, cliExitCode;
|
|
var _this = this;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0:
|
|
childProcess = require('child_process');
|
|
errorLogFull = [];
|
|
// eslint-disable-next-line no-console
|
|
this.config.jobLog("Running ".concat(this.config.cli, " ").concat(this.config.spawnArgs.join(' ')));
|
|
return [4 /*yield*/, new Promise(function (resolve) {
|
|
try {
|
|
var opts = _this.config.spawnOpts || {};
|
|
var spawnArgs = _this.config.spawnArgs.map(function (row) { return row.trim(); }).filter(function (row) { return row !== ''; });
|
|
var thread = childProcess.spawn(_this.config.cli, spawnArgs, opts);
|
|
thread.stdout.on('data', function (data) {
|
|
// eslint-disable-next-line no-console
|
|
// console.log(data.toString());
|
|
errorLogFull.push(data.toString());
|
|
_this.parseOutput(data);
|
|
});
|
|
thread.stderr.on('data', function (data) {
|
|
// eslint-disable-next-line no-console
|
|
// console.log(data.toString());
|
|
errorLogFull.push(data.toString());
|
|
_this.parseOutput(data);
|
|
});
|
|
thread.on('error', function () {
|
|
// catches execution error (bad file)
|
|
// eslint-disable-next-line no-console
|
|
console.log(1, "Error executing binary: ".concat(_this.config.cli));
|
|
resolve(1);
|
|
});
|
|
// thread.stdout.pipe(process.stdout);
|
|
// thread.stderr.pipe(process.stderr);
|
|
thread.on('close', function (code) {
|
|
if (code !== 0) {
|
|
// eslint-disable-next-line no-console
|
|
console.log(code, 'CLI error');
|
|
}
|
|
resolve(code);
|
|
});
|
|
}
|
|
catch (err) {
|
|
// catches execution error (no file)
|
|
// eslint-disable-next-line no-console
|
|
console.log(1, "Error executing binary: ".concat(_this.config.cli));
|
|
resolve(1);
|
|
}
|
|
})];
|
|
case 1:
|
|
cliExitCode = _a.sent();
|
|
if (!this.config.logFullCliOutput) {
|
|
this.config.jobLog(errorLogFull.slice(-1000).join(''));
|
|
}
|
|
return [2 /*return*/, {
|
|
cliExitCode: cliExitCode,
|
|
errorLogFull: errorLogFull,
|
|
}];
|
|
}
|
|
});
|
|
}); };
|
|
this.config = config;
|
|
}
|
|
return CLI;
|
|
}());
|
|
exports.CLI = CLI;
|