Plugin to preserve file dates and times from original file after transcode (#184)
* Initial commit * Add link * Remove comments * JSLint cleanup * Remove comments again * Use 'touch' module instead of 'utimes' * Fix lint errors * Update plugin syntax, details and inputs * lint Co-authored-by: HaveAGitGat <43864057+HaveAGitGat@users.noreply.github.com>make-only-subtitle-default
parent
24f35835a8
commit
3d11faf3f1
@ -0,0 +1,160 @@
|
|||||||
|
const loadDefaultValues = require('../methods/loadDefaultValues');
|
||||||
|
|
||||||
|
module.exports.dependencies = [
|
||||||
|
'axios',
|
||||||
|
'path-extra',
|
||||||
|
'touch',
|
||||||
|
];
|
||||||
|
|
||||||
|
const details = () => ({
|
||||||
|
id: 'Tdarr_Plugin_z80t_keep_original_date',
|
||||||
|
Stage: 'Post-processing',
|
||||||
|
Name: 'Keep original file dates and times after transcoding',
|
||||||
|
Type: 'Video',
|
||||||
|
Operation: 'Transcode',
|
||||||
|
Description: 'This plugin copies the original file dates and times to the transcoded file \n\n',
|
||||||
|
Version: '1.10',
|
||||||
|
Tags: 'post-processing,dates,date',
|
||||||
|
Inputs: [{
|
||||||
|
name: 'server',
|
||||||
|
type: 'string',
|
||||||
|
defaultValue: '192.168.1.100',
|
||||||
|
inputUI: {
|
||||||
|
type: 'text',
|
||||||
|
},
|
||||||
|
tooltip: `IP address or hostname of the server assigned to this node, will be used for API requests.
|
||||||
|
If you are running nodes within Docker you should use the server IP address rather than the name.
|
||||||
|
|
||||||
|
\\nExample:\\n
|
||||||
|
tdarrserver
|
||||||
|
|
||||||
|
\\nExample:\\n
|
||||||
|
192.168.1.100`,
|
||||||
|
}, {
|
||||||
|
name: 'extensions',
|
||||||
|
type: 'string',
|
||||||
|
defaultValue: '',
|
||||||
|
inputUI: {
|
||||||
|
type: 'text',
|
||||||
|
},
|
||||||
|
tooltip: `When files are trans-coded the file extension may change,
|
||||||
|
enter a list of extensions to try and match the original file with in the database after trans-coding.
|
||||||
|
Default is the list of container types from library settings. The list will be searched in order and
|
||||||
|
the extension of the original file will always be checked first before the list is used.
|
||||||
|
|
||||||
|
\\nExample:\\n
|
||||||
|
mkv,mp4,avi`,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'log',
|
||||||
|
type: 'boolean',
|
||||||
|
defaultValue: false,
|
||||||
|
inputUI: {
|
||||||
|
type: 'dropdown',
|
||||||
|
options: [
|
||||||
|
'false',
|
||||||
|
'true',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
tooltip: `Write log entries to console.log. Default is false.
|
||||||
|
|
||||||
|
\\nExample:\\n
|
||||||
|
true`,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
});
|
||||||
|
|
||||||
|
// eslint-disable-next-line no-unused-vars
|
||||||
|
const plugin = async (file, librarySettings, inputs, otherArguments) => {
|
||||||
|
// eslint-disable-next-line no-unused-vars,no-param-reassign
|
||||||
|
inputs = loadDefaultValues(inputs, details);
|
||||||
|
// eslint-disable-next-line global-require,import/no-unresolved
|
||||||
|
const axios = require('axios');
|
||||||
|
// eslint-disable-next-line global-require,import/no-unresolved
|
||||||
|
const touch = require('touch');
|
||||||
|
// eslint-disable-next-line global-require,import/no-unresolved
|
||||||
|
const path = require('path-extra');
|
||||||
|
|
||||||
|
function log(msg) {
|
||||||
|
if (inputs.log === true) {
|
||||||
|
// eslint-disable-next-line no-console
|
||||||
|
console.log(msg);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function getFileData(filePath, extensions, server) {
|
||||||
|
const originalExtension = path.extname(filePath).split('.')[1];
|
||||||
|
if (extensions.indexOf(originalExtension) > -1) {
|
||||||
|
extensions.splice(extensions.indexOf(originalExtension), 1);
|
||||||
|
}
|
||||||
|
extensions.unshift(originalExtension);
|
||||||
|
let httpResponse = null;
|
||||||
|
|
||||||
|
for (let i = 0; i < extensions.length; i += 1) {
|
||||||
|
const fileName = path.replaceExt(filePath, `.${extensions[i]}`);
|
||||||
|
log(`Fetching file object for ${fileName}...`);
|
||||||
|
// eslint-disable-next-line no-await-in-loop
|
||||||
|
httpResponse = await axios.post(`http://${server}:8265/api/v2/search-db`, {
|
||||||
|
data: {
|
||||||
|
string: fileName,
|
||||||
|
lessThanGB: 10000,
|
||||||
|
greaterThanGB: 0,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (httpResponse.status === 200) {
|
||||||
|
if (httpResponse.data.length > 0) {
|
||||||
|
log(`Got response for ${fileName}`);
|
||||||
|
return httpResponse;
|
||||||
|
}
|
||||||
|
log(`Response for ${fileName} is empty`);
|
||||||
|
} else {
|
||||||
|
log(`API request for ${filePath} failed.`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
log('Could not get file info from API, giving up.');
|
||||||
|
return httpResponse;
|
||||||
|
}
|
||||||
|
|
||||||
|
const responseData = {
|
||||||
|
file,
|
||||||
|
removeFromDB: false,
|
||||||
|
updateDB: false,
|
||||||
|
infoLog: '',
|
||||||
|
};
|
||||||
|
|
||||||
|
try {
|
||||||
|
if (!inputs.server || inputs.server.trim() === '') {
|
||||||
|
responseData.infoLog += 'Tdarr server name/IP not configured in library transcode options\n';
|
||||||
|
return responseData;
|
||||||
|
}
|
||||||
|
|
||||||
|
log('Waiting 5 seconds...');
|
||||||
|
|
||||||
|
let { extensions } = inputs;
|
||||||
|
if (!extensions || extensions.trim() === '') {
|
||||||
|
extensions = librarySettings.containerFilter;
|
||||||
|
}
|
||||||
|
extensions = extensions.split(',');
|
||||||
|
|
||||||
|
await new Promise((resolve) => setTimeout(resolve, 5000));
|
||||||
|
const response = await getFileData(file._id, extensions, inputs.server);
|
||||||
|
|
||||||
|
if (response.data.length > 0) {
|
||||||
|
log('Changing date...');
|
||||||
|
touch.sync(file._id, { time: Date.parse(response.data[0].statSync.mtime), force: true });
|
||||||
|
log('Done.');
|
||||||
|
responseData.infoLog += 'File timestamps updated or match original file\n';
|
||||||
|
return responseData;
|
||||||
|
}
|
||||||
|
responseData.infoLog += `Could not find file using API using ${inputs.server}\n`;
|
||||||
|
return responseData;
|
||||||
|
} catch (err) {
|
||||||
|
log(err);
|
||||||
|
}
|
||||||
|
|
||||||
|
return responseData;
|
||||||
|
};
|
||||||
|
|
||||||
|
module.exports.details = details;
|
||||||
|
module.exports.plugin = plugin;
|
||||||
Loading…
Reference in new issue