gabehf
/
Tdarr_Plugins
mirror of https://github.com/gabehf/Tdarr_Plugins.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Variables and functions names refactoring

Browse Source
make-only-subtitle-default
jeanchristophe.mqt@gmail.com 2 years ago
parent ad66948622
commit 09ba9b5dc6
2 changed files with 36 additions and 25 deletions
Show Stats Download Patch File Download Diff File

39
FlowPlugins/CommunityFlowPlugins/tools/applyRadarrOrSonarrNamingPolicy/1.0.0/index.js
Unescape View File

@ -1,4 +1,15 @@
"use strict"; "use strict";
var __assign = (this && this.__assign) || function () {
__assign = Object.assign || function(t) {
for (var s, i = 1, n = arguments.length; i < n; i++) {
s = arguments[i];
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
t[p] = s[p];
}
return t;
};
return __assign.apply(this, arguments);
};
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) { return new (P || (P = Promise))(function (resolve, reject) {
@ -101,7 +112,7 @@ var details = function () { return ({
}); }; }); };
exports.details = details; exports.details = details;
var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function () { var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function () {
var lib, _a, arr, arr_api_key, arr_host, arrHost, fileName, rename, destinationPath, episodeNumber_1; var lib, _a, arr, arr_api_key, arr_host, arrHost, fileName, getNewPath, pathWithNewName, episodeNumber_1;
return __generator(this, function (_b) { return __generator(this, function (_b) {
switch (_b.label) { switch (_b.label) {
case 0: case 0:
@ -112,12 +123,12 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
arr_host = String(args.inputs.arr_host).trim(); arr_host = String(args.inputs.arr_host).trim();
arrHost = arr_host.endsWith('/') ? arr_host.slice(0, -1) : arr_host; arrHost = arr_host.endsWith('/') ? arr_host.slice(0, -1) : arr_host;
fileName = (0, fileUtils_1.getFileName)(args.inputFileObj._id); fileName = (0, fileUtils_1.getFileName)(args.inputFileObj._id);
rename = function (delegates) { return __awaiter(void 0, void 0, void 0, function () { getNewPath = function (delegates) { return __awaiter(void 0, void 0, void 0, function () {
var destinationPath, headers, parseRequestConfig, parseRequestResult, id, previewRenameRequestConfig, previewRenameRequestResult, fileToRename; var pathWithNewName, headers, parseRequestConfig, parseRequestResult, id, previewRenameRequestConfig, previewRenameRequestResult, fileToRename;
return __generator(this, function (_a) { return __generator(this, function (_a) {
switch (_a.label) { switch (_a.label) {
case 0: case 0:
destinationPath = ''; pathWithNewName = '';
args.jobLog('Going to force rename'); args.jobLog('Going to force rename');
args.jobLog("Renaming ".concat(arr === 'radarr' ? 'Radarr' : 'Sonarr', "...")); args.jobLog("Renaming ".concat(arr === 'radarr' ? 'Radarr' : 'Sonarr', "..."));
headers = { headers = {
@ -145,16 +156,16 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
previewRenameRequestResult = _a.sent(); previewRenameRequestResult = _a.sent();
fileToRename = delegates.getFileToRename(previewRenameRequestResult); fileToRename = delegates.getFileToRename(previewRenameRequestResult);
if (!(fileToRename !== undefined)) return [3 /*break*/, 4]; if (!(fileToRename !== undefined)) return [3 /*break*/, 4];
destinationPath = "".concat((0, fileUtils_1.getFileAbosluteDir)(args.inputFileObj._id), "/").concat((0, fileUtils_1.getFileName)(fileToRename.newPath), ".").concat((0, fileUtils_1.getContainer)(fileToRename.newPath)); pathWithNewName = "".concat((0, fileUtils_1.getFileAbosluteDir)(args.inputFileObj._id), "/").concat((0, fileUtils_1.getFileName)(fileToRename.newPath), ".").concat((0, fileUtils_1.getContainer)(fileToRename.newPath));
return [4 /*yield*/, (0, fileMoveOrCopy_1.default)({ return [4 /*yield*/, (0, fileMoveOrCopy_1.default)({
operation: 'move', operation: 'move',
sourcePath: args.inputFileObj._id, sourcePath: args.inputFileObj._id,
destinationPath: destinationPath, destinationPath: pathWithNewName,
args: args, args: args,
})]; })];
case 3: case 3:
_a.sent(); _a.sent();
args.jobLog("\u2714 Renamed ".concat(arr === 'radarr' ? 'movie' : 'serie', " ").concat(id, " : '").concat(args.inputFileObj._id, "' => '").concat(destinationPath, "'.")); args.jobLog("\u2714 Renamed ".concat(arr === 'radarr' ? 'movie' : 'serie', " ").concat(id, " : '").concat(args.inputFileObj._id, "' => '").concat(pathWithNewName, "'."));
return [3 /*break*/, 5]; return [3 /*break*/, 5];
case 4: case 4:
args.jobLog('✔ No rename necessary.'); args.jobLog('✔ No rename necessary.');
@ -163,13 +174,13 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
case 6: case 6:
args.jobLog("\u2714 No ".concat(arr === 'radarr' ? 'movie' : 'serie', " with a file named '").concat(fileName, "'.")); args.jobLog("\u2714 No ".concat(arr === 'radarr' ? 'movie' : 'serie', " with a file named '").concat(fileName, "'."));
_a.label = 7; _a.label = 7;
case 7: return [2 /*return*/, destinationPath]; case 7: return [2 /*return*/, pathWithNewName];
} }
}); });
}); }; }); };
destinationPath = ''; pathWithNewName = '';
if (!(arr === 'radarr')) return [3 /*break*/, 2]; if (!(arr === 'radarr')) return [3 /*break*/, 2];
return [4 /*yield*/, rename({ return [4 /*yield*/, getNewPath({
getId: function (parseRequestResult) { var _a, _b, _c, _d; return String((_d = (_c = (_b = (_a = parseRequestResult.data) === null || _a === void 0 ? void 0 : _a.movie) === null || _b === void 0 ? void 0 : _b.movieFile) === null || _c === void 0 ? void 0 : _c.movieId) !== null && _d !== void 0 ? _d : -1); }, getId: function (parseRequestResult) { var _a, _b, _c, _d; return String((_d = (_c = (_b = (_a = parseRequestResult.data) === null || _a === void 0 ? void 0 : _a.movie) === null || _b === void 0 ? void 0 : _b.movieFile) === null || _c === void 0 ? void 0 : _c.movieId) !== null && _d !== void 0 ? _d : -1); },
getPreviewRenameResquestUrl: function (id, parseRequestResult) { return "".concat(arrHost, "/api/v3/rename?movieId=").concat(id); }, getPreviewRenameResquestUrl: function (id, parseRequestResult) { return "".concat(arrHost, "/api/v3/rename?movieId=").concat(id); },
getFileToRename: function (previewRenameRequestResult) { getFileToRename: function (previewRenameRequestResult) {
@ -180,12 +191,12 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
} }
})]; })];
case 1: case 1:
destinationPath = _b.sent(); pathWithNewName = _b.sent();
return [3 /*break*/, 5]; return [3 /*break*/, 5];
case 2: case 2:
if (!(arr === 'sonarr')) return [3 /*break*/, 4]; if (!(arr === 'sonarr')) return [3 /*break*/, 4];
episodeNumber_1 = 0; episodeNumber_1 = 0;
return [4 /*yield*/, rename({ return [4 /*yield*/, getNewPath({
getId: function (parseRequestResult) { var _a, _b, _c; return String((_c = (_b = (_a = parseRequestResult.data) === null || _a === void 0 ? void 0 : _a.series) === null || _b === void 0 ? void 0 : _b.id) !== null && _c !== void 0 ? _c : -1); }, getId: function (parseRequestResult) { var _a, _b, _c; return String((_c = (_b = (_a = parseRequestResult.data) === null || _a === void 0 ? void 0 : _a.series) === null || _b === void 0 ? void 0 : _b.id) !== null && _c !== void 0 ? _c : -1); },
getPreviewRenameResquestUrl: function (id, parseRequestResult) { getPreviewRenameResquestUrl: function (id, parseRequestResult) {
episodeNumber_1 = parseRequestResult.data.parsedEpisodeInfo.episodeNumbers[0]; episodeNumber_1 = parseRequestResult.data.parsedEpisodeInfo.episodeNumbers[0];
@ -199,13 +210,13 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
} }
})]; })];
case 3: case 3:
destinationPath = _b.sent(); pathWithNewName = _b.sent();
return [3 /*break*/, 5]; return [3 /*break*/, 5];
case 4: case 4:
args.jobLog('No arr specified in plugin inputs.'); args.jobLog('No arr specified in plugin inputs.');
_b.label = 5; _b.label = 5;
case 5: return [2 /*return*/, { case 5: return [2 /*return*/, {
outputFileObj: destinationPath !== '' ? { _id: destinationPath } : args.inputFileObj, outputFileObj: pathWithNewName !== '' ? __assign(__assign({}, args.inputFileObj), { _id: pathWithNewName }) : args.inputFileObj,
outputNumber: 1, outputNumber: 1,
variables: args.variables, variables: args.variables,
}]; }];

22
FlowPluginsTs/CommunityFlowPlugins/tools/applyRadarrOrSonarrNamingPolicy/1.0.0/index.ts
Unescape View File

@ -76,15 +76,15 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
const arrHost = arr_host.endsWith('/') ? arr_host.slice(0, -1) : arr_host; const arrHost = arr_host.endsWith('/') ? arr_host.slice(0, -1) : arr_host;
const fileName = getFileName(args.inputFileObj._id); const fileName = getFileName(args.inputFileObj._id);
interface IRenameDelegates { interface IGetNewPathDelegates {
getId: (parseRequestResult: any) => string, getId: (parseRequestResult: any) => string,
getPreviewRenameResquestUrl: (id: string, parseRequestResult: any) => string, getPreviewRenameResquestUrl: (id: string, parseRequestResult: any) => string,
getFileToRename: (previewRenameRequestResult: any) => any getFileToRename: (previewRenameRequestResult: any) => any
} }
const rename = async (delegates: IRenameDelegates) const getNewPath = async (delegates: IGetNewPathDelegates)
: Promise<string> => { : Promise<string> => {
let destinationPath = ''; let pathWithNewName = '';
args.jobLog('Going to force rename'); args.jobLog('Going to force rename');
args.jobLog(`Renaming ${arr === 'radarr' ? 'Radarr' : 'Sonarr'}...`); args.jobLog(`Renaming ${arr === 'radarr' ? 'Radarr' : 'Sonarr'}...`);
@ -118,26 +118,26 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
// Only if there is a rename to execute // Only if there is a rename to execute
if (fileToRename !== undefined) { if (fileToRename !== undefined) {
destinationPath = `${getFileAbosluteDir(args.inputFileObj._id)}/${getFileName(fileToRename.newPath)}.${getContainer(fileToRename.newPath)}`; pathWithNewName = `${getFileAbosluteDir(args.inputFileObj._id)}/${getFileName(fileToRename.newPath)}.${getContainer(fileToRename.newPath)}`;
await fileMoveOrCopy({ await fileMoveOrCopy({
operation: 'move', operation: 'move',
sourcePath: args.inputFileObj._id, sourcePath: args.inputFileObj._id,
destinationPath: destinationPath, destinationPath: pathWithNewName,
args, args,
}); });
args.jobLog(`✔ Renamed ${arr === 'radarr' ? 'movie' : 'serie'} ${id} : '${args.inputFileObj._id}' => '${destinationPath}'.`); args.jobLog(`✔ Renamed ${arr === 'radarr' ? 'movie' : 'serie'} ${id} : '${args.inputFileObj._id}' => '${pathWithNewName}'.`);
} else } else
args.jobLog('✔ No rename necessary.'); args.jobLog('✔ No rename necessary.');
} else } else
args.jobLog(`✔ No ${arr === 'radarr' ? 'movie' : 'serie'} with a file named '${fileName}'.`); args.jobLog(`✔ No ${arr === 'radarr' ? 'movie' : 'serie'} with a file named '${fileName}'.`);
return destinationPath; return pathWithNewName;
}; };
let destinationPath = ''; let pathWithNewName = '';
if (arr === 'radarr') { if (arr === 'radarr') {
destinationPath = await rename({ pathWithNewName = await getNewPath({
getId: (parseRequestResult) => String(parseRequestResult.data?.movie?.movieFile?.movieId ?? -1), getId: (parseRequestResult) => String(parseRequestResult.data?.movie?.movieFile?.movieId ?? -1),
getPreviewRenameResquestUrl: (id, parseRequestResult) => `${arrHost}/api/v3/rename?movieId=${id}`, getPreviewRenameResquestUrl: (id, parseRequestResult) => `${arrHost}/api/v3/rename?movieId=${id}`,
getFileToRename: (previewRenameRequestResult) => getFileToRename: (previewRenameRequestResult) =>
@ -147,7 +147,7 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
}); });
} else if (arr === 'sonarr') { } else if (arr === 'sonarr') {
let episodeNumber = 0; let episodeNumber = 0;
destinationPath = await rename({ pathWithNewName = await getNewPath({
getId: (parseRequestResult) => String(parseRequestResult.data?.series?.id ?? -1), getId: (parseRequestResult) => String(parseRequestResult.data?.series?.id ?? -1),
getPreviewRenameResquestUrl: (id, parseRequestResult) => { getPreviewRenameResquestUrl: (id, parseRequestResult) => {
episodeNumber = parseRequestResult.data.parsedEpisodeInfo.episodeNumbers[0]; episodeNumber = parseRequestResult.data.parsedEpisodeInfo.episodeNumbers[0];
@ -163,7 +163,7 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
} }
return { return {
outputFileObj: destinationPath !== '' ? { _id: destinationPath } : args.inputFileObj, outputFileObj: pathWithNewName !== '' ? { ...args.inputFileObj, _id: pathWithNewName } : args.inputFileObj,
outputNumber: 1, outputNumber: 1,
variables: args.variables, variables: args.variables,
}; };

Write Preview
Loading…
Cancel
Save