🏗️ Migrate overseerr by id to tRPC

This commit is contained in:
Meier Lukas
2023-06-10 15:35:48 +02:00
parent 3b368949ba
commit 0a53602701
3 changed files with 80 additions and 16 deletions

View File

@@ -1,8 +1,11 @@
import { TRPCError } from '@trpc/server';
import axios from 'axios';
import { z } from 'zod';
import Consola from 'consola';
import { getConfig } from '~/tools/config/getConfig';
import { createTRPCRouter, publicProcedure } from '../trpc';
import { MovieResult } from '~/modules/overseerr/Movie';
import { TvShowResult } from '~/modules/overseerr/TvShow';
export const overseerrRouter = createTRPCRouter({
all: publicProcedure
@@ -41,4 +44,64 @@ export const overseerrRouter = createTRPCRouter({
.then((res) => res.data);
return data;
}),
byId: publicProcedure
.input(
z.object({
configName: z.string(),
id: z.number(),
type: z.union([z.literal('movie'), z.literal('tv')]),
})
)
.query(async ({ input }) => {
const config = getConfig(input.configName);
const app = config.apps.find(
(app) => app.integration?.type === 'overseerr' || app.integration?.type === 'jellyseerr'
);
const apiKey = app?.integration?.properties.find((x) => x.field === 'apiKey')?.value;
if (!apiKey) {
throw new TRPCError({
code: 'BAD_REQUEST',
message: 'No app found',
});
}
const appUrl = new URL(app.url);
if (input.type === 'movie') {
const movie = await axios
.get(`${appUrl.origin}/api/v1/movie/${input.id}`, {
headers: {
// Set X-Api-Key to the value of the API key
'X-Api-Key': apiKey,
},
})
.then((res) => res.data as MovieResult)
.catch((err) => {
Consola.error(err);
throw new TRPCError({
code: 'INTERNAL_SERVER_ERROR',
message: 'Something went wrong',
});
});
return movie;
}
const tv = await axios
.get(`${appUrl.origin}/api/v1/tv/${input.id}`, {
headers: {
// Set X-Api-Key to the value of the API key
'X-Api-Key': apiKey,
},
})
.then((res) => res.data as TvShowResult)
.catch((err) => {
Consola.error(err);
throw new TRPCError({
code: 'INTERNAL_SERVER_ERROR',
message: 'Something went wrong',
});
});
return tv;
}),
});