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

After thorough testing, some renaming and refactoring

Browse source
This commit is contained in:
jeanchristophe.mqt@gmail.com 2024-03-31 11:50:22 +02:00
parent 5198d4b805
commit f9e9215bcb
2 changed files with 56 additions and 50 deletions
Download patch file Download diff file Expand all files Collapse all files

62
FlowPluginsTs/CommunityFlowPlugins/tools/notifyRadarrOrSonarr/2.0.0/index.ts
View file

@ -72,49 +72,47 @@ interface IHTTPHeaders {
'X-Api-Key': string,
Accept: string,
}
interface IParsedRequestResult {
interface IParseResponse {
data: {
movie?: { id: number },
series?: { id: number },
},
}
interface IRefreshType {
appName: string,
interface IArrApp {
name: string,
host: string,
headers: IHTTPHeaders,
content: string,
delegates: {
getIdFromParseResponse: (parseRequestResult: IParsedRequestResult) => number,
getIdFromParseResponse: (parseResponse: IParseResponse) => number,
buildRefreshResquestData: (id: number) => string
}
}
const getId = async (
args: IpluginInputArgs,
arr: string,
arrHost: string, headers: IHTTPHeaders,
arrApp: IArrApp,
fileName: string,
refreshType: IRefreshType,
)
: Promise<number> => {
const imdbId = /\b(tt|nm|co|ev|ch|ni)\d{7,10}\b/i.exec(fileName)?.at(0) ?? '';
let id = (imdbId !== '')
? Number(
(await args.deps.axios({
method: 'get',
url: `${arrHost}/api/v3/${arr === 'radarr' ? 'movie' : 'series'}/lookup?term=imdb:${imdbId}`,
headers,
})).data?.at(0)?.id ?? -1,
)
? Number((await args.deps.axios({
method: 'get',
url: `${arrApp.host}/api/v3/${arrApp.name === 'radarr' ? 'movie' : 'series'}/lookup?term=imdb:${imdbId}`,
headers: arrApp.headers,
})).data?.at(0)?.id ?? -1)
: -1;
args.jobLog(`${refreshType.content} ${id !== -1 ? `${id} found` : 'not found'} for imdb '${imdbId}'`);
args.jobLog(`${arrApp.content} ${id !== -1 ? `'${id}' found` : 'not found'} for imdb '${imdbId}'`);
if (id === -1) {
id = refreshType.delegates.getIdFromParseResponse(
id = arrApp.delegates.getIdFromParseResponse(
(await args.deps.axios({
method: 'get',
url: `${arrHost}/api/v3/parse?title=${encodeURIComponent(getFileName(fileName))}`,
headers,
url: `${arrApp.host}/api/v3/parse?title=${encodeURIComponent(getFileName(fileName))}`,
headers: arrApp.headers,
})),
);
args.jobLog(`${refreshType.content} ${id !== -1 ? `${id} found` : 'not found'} for '${getFileName(fileName)}'`);
args.jobLog(`${arrApp.content} ${id !== -1 ? `'${id}' found` : 'not found'} for '${getFileName(fileName)}'`);
}
return id;
};
@ -136,35 +134,39 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
'X-Api-Key': String(args.inputs.arr_api_key),
Accept: 'application/json',
};
const refreshType: IRefreshType = arr === 'radarr'
const arrApp: IArrApp = arr === 'radarr'
? {
appName: 'Radarr',
name: arr,
host: arrHost,
headers,
content: 'Movie',
delegates: {
getIdFromParseResponse:
(parseRequestResult: IParsedRequestResult) => Number(parseRequestResult.data?.movie?.id ?? -1),
(parseResponse: IParseResponse) => Number(parseResponse?.data?.movie?.id ?? -1),
buildRefreshResquestData:
(id) => JSON.stringify({ name: 'RefreshMovie', movieIds: [id] }),
},
}
: {
appName: 'Sonarr',
name: arr,
host: arrHost,
headers,
content: 'Serie',
delegates: {
getIdFromParseResponse:
(parseRequestResult: IParsedRequestResult) => Number(parseRequestResult.data?.series?.id ?? -1),
(parseResponse: IParseResponse) => Number(parseResponse?.data?.series?.id ?? -1),
buildRefreshResquestData:
(id) => JSON.stringify({ name: 'RefreshSeries', seriesId: id }),
},
};
args.jobLog('Going to force scan');
args.jobLog(`Refreshing ${refreshType.appName}...`);
args.jobLog(`Refreshing ${arrApp.name}...`);
let id = await getId(args, arr, arrHost, headers, originalFileName, refreshType);
let id = await getId(args, arrApp, originalFileName);
// Useful in some edge cases
if (id === -1 && currentFileName !== originalFileName) {
id = await getId(args, arr, arrHost, headers, currentFileName, refreshType);
id = await getId(args, arrApp, currentFileName);
}
// Checking that the file has been found
@ -172,13 +174,13 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
// Using command endpoint to queue a refresh task
await args.deps.axios({
method: 'post',
url: `${arrHost}/api/v3/command`,
url: `${arrApp.host}/api/v3/command`,
headers,
data: refreshType.delegates.buildRefreshResquestData(id),
data: arrApp.delegates.buildRefreshResquestData(id),
});
refreshed = true;
args.jobLog(`✔ ${refreshType.content} ${id} refreshed in ${refreshType.appName}.`);
args.jobLog(`✔ ${arrApp.content} '${id}' refreshed in ${arrApp.name}.`);
}
return {