gabehf/Tdarr_Plugins
1
0
Fork 0
mirror of https://github.com/gabehf/Tdarr_Plugins.git synced 2026-03-15 02:05:54 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge branch 'kill_thread' of https://github.com/HaveAGitGat/Tdarr_Plugins into kill_thread

Browse source
This commit is contained in:
HaveAGitGat 2023-12-07 06:49:51 +00:00
commit 8ca3dde779
1 changed files with 41 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

50
FlowPlugins/FlowHelpers/1.0.0/cliUtils.js
View file

@ -224,6 +224,29 @@ var CLI = /** @class */ (function () {
} }
} }
}; };
// eslint-disable-next-line @typescript-eslint/no-explicit-any,@typescript-eslint/explicit-module-boundary-types
this.killThread = function (thread) {
var killArray = [
'SIGKILL',
'SIGHUP',
'SIGTERM',
'SIGINT',
];
try {
thread.kill();
}
catch (err) {
// err
}
killArray.forEach(function (com) {
try {
thread.kill(com);
}
catch (err) {
// err
}
});
};
this.runCli = function () { return __awaiter(_this, void 0, void 0, function () { this.runCli = function () { return __awaiter(_this, void 0, void 0, function () {
var childProcess, errorLogFull, cliExitCode; var childProcess, errorLogFull, cliExitCode;
var _this = this; var _this = this;
@ -232,26 +255,35 @@ var CLI = /** @class */ (function () {
case 0: case 0:
childProcess = require('child_process'); childProcess = require('child_process');
errorLogFull = []; errorLogFull = [];
// eslint-disable-next-line no-console
this.config.jobLog("Running ".concat(this.config.cli, " ").concat(this.config.spawnArgs.join(' '))); this.config.jobLog("Running ".concat(this.config.cli, " ").concat(this.config.spawnArgs.join(' ')));
return [4 /*yield*/, new Promise(function (resolve) { return [4 /*yield*/, new Promise(function (resolve) {
try { try {
var opts = _this.config.spawnOpts || {}; var opts = _this.config.spawnOpts || {};
var spawnArgs = _this.config.spawnArgs.map(function (row) { return row.trim(); }).filter(function (row) { return row !== ''; }); 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); var thread_1 = childProcess.spawn(_this.config.cli, spawnArgs, opts);
thread.stdout.on('data', function (data) { process.on('exit', function () {
// eslint-disable-next-line no-console try {
// console.log(data.toString()); // eslint-disable-next-line no-console
console.log('Main thread exiting, cleaning up running CLI');
_this.killThread(thread_1);
}
catch (err) {
// eslint-disable-next-line no-console
console.log('Error running cliUtils on Exit function');
// eslint-disable-next-line no-console
console.log(err);
}
});
thread_1.stdout.on('data', function (data) {
errorLogFull.push(data.toString()); errorLogFull.push(data.toString());
_this.parseOutput(data); _this.parseOutput(data);
}); });
thread.stderr.on('data', function (data) { thread_1.stderr.on('data', function (data) {
// eslint-disable-next-line no-console // eslint-disable-next-line no-console
// console.log(data.toString());
errorLogFull.push(data.toString()); errorLogFull.push(data.toString());
_this.parseOutput(data); _this.parseOutput(data);
}); });
thread.on('error', function () { thread_1.on('error', function () {
// catches execution error (bad file) // catches execution error (bad file)
// eslint-disable-next-line no-console // eslint-disable-next-line no-console
console.log(1, "Error executing binary: ".concat(_this.config.cli)); console.log(1, "Error executing binary: ".concat(_this.config.cli));
@ -259,7 +291,7 @@ var CLI = /** @class */ (function () {
}); });
// thread.stdout.pipe(process.stdout); // thread.stdout.pipe(process.stdout);
// thread.stderr.pipe(process.stderr); // thread.stderr.pipe(process.stderr);
thread.on('close', function (code) { thread_1.on('close', function (code) {
if (code !== 0) { if (code !== 0) {
// eslint-disable-next-line no-console // eslint-disable-next-line no-console
console.log(code, 'CLI error'); console.log(code, 'CLI error');