added password security, added health and wanted monitoring

Author: kodobrody

.env.example

@@ -2,4 +2,5 @@ SONARR_URL=
 RADARR_URL=
 SONARR_API_KEY=
 RADARR_API_KEY=
-BASE_PATH=
+BASE_PATH=
+PAGE_PASSWORD=

app/api/login/route.ts

@@ -0,0 +1,36 @@
+import { NextResponse } from 'next/server';
+
+export async function POST(req: Request) {
+  try {
+    const { password } = await req.json();
+
+    if (!password || password !== process.env.PAGE_PASSWORD) {
+      return NextResponse.json(
+        { error: 'Password is required' },
+        { status: 400 }
+      );
+    }
+
+    const response = NextResponse.json(
+      { success: true },
+      { status: 200 }
+    );
+
+    response.cookies.set({
+      name: 'password',
+      value: password,
+      httpOnly: true,
+      secure: process.env.NODE_ENV === 'production',
+      sameSite: 'strict',
+      path: '/',
+      maxAge: 60 * 60 * 24 * 10000
+    });
+
+    return response;
+  } catch {
+    return NextResponse.json(
+      { error: 'Invalid JSON' },
+      { status: 400 }
+    );
+  }
+}

app/api/radarr/downloads/route.ts

@@ -1,6 +1,6 @@
 import { NextResponse } from 'next/server';
 import { DownloadType } from '@/types/Download';
-import { RadarrQueue } from '@/types/RadarrQueue';
+import { RadarrQueue } from '@/types/Radarr';
 
 export async function GET() {
   const response = await fetch(`${process.env.RADARR_URL}/api/v3/queue?apikey=${process.env.RADARR_API_KEY}`);
@@ -21,7 +21,7 @@ export async function GET() {
     const movieName = movieData.title;
     const progress = Math.round(100 - (record.sizeleft / record.size * 100));
     const size = `${(record.size / 1024 / 1024 / 1024).toFixed(1)} GB`;
-    
+
     const downloadedSize = record.size - record.sizeleft;
     const addedTime = new Date(record.added).getTime(); // convert added time to milliseconds
     const currentTime = Date.now(); // current time in milliseconds

app/api/radarr/health/route.ts

@@ -0,0 +1,17 @@
+import { NextResponse } from 'next/server';
+import { SonarrHealthItem } from '@/types/Sonarr';
+
+const PAGE_SIZE = 1000;
+
+export async function GET() {
+  const radarrResponse = await fetch(`${process.env.RADARR_URL}/api/v3/health?apikey=${process.env.RADARR_API_KEY}&pageSize=${PAGE_SIZE}&includeSeries=true`);
+  const radarrHealthData: SonarrHealthItem[] = await radarrResponse.json();
+
+  console.log("Radarr Health Data:", radarrHealthData);
+
+  if (!radarrHealthData.length) {
+    return NextResponse.json([], { status: 200 });
+  }
+
+  return NextResponse.json(radarrHealthData, { status: 200 });
+}

app/api/radarr/wanted/route.ts

@@ -0,0 +1,23 @@
+import { NextResponse } from 'next/server';
+import { RadarrWantedType } from '@/types/Radarr';
+import { RadarrQueue } from '@/types/Radarr';
+
+export async function GET() {
+  const response = await fetch(`${process.env.RADARR_URL}/api/v3/wanted/missing?apikey=${process.env.RADARR_API_KEY}`);
+  const radarrData: RadarrQueue = await response.json();
+
+  if (!radarrData.records) {
+    return NextResponse.json([], { status: 200 });
+  }
+
+  const responseObject: RadarrWantedType[] = radarrData.records.map((record) => {
+    return {
+      id: record.id,
+      title: record.title,
+      airDate: record.digitalRelease,
+      releaseDate: record.releaseDate
+    };
+  });
+
+  return NextResponse.json(responseObject, { status: 200 });
+}

app/api/sonarr/downloads/route.ts

@@ -1,6 +1,6 @@
 import { NextResponse } from 'next/server';
 import { DownloadType } from '@/types/Download';
-import { SonarrQueue } from '@/types/SonarrQueue';
+import { SonarrQueue } from '@/types/Sonarr';
 
 export async function GET() {
   const response = await fetch(`${process.env.SONARR_URL}/api/v3/queue?apikey=${process.env.SONARR_API_KEY}`);
@@ -24,7 +24,7 @@ export async function GET() {
     const fqTitle = `${seriesName} - S${seasonNumber}E${episodeNumber}`;
     const progress = Math.round(100 - (record.sizeleft / record.size * 100));
     const size = `${(record.size / 1024 / 1024 / 1024).toFixed(1)} GB`;
-    
+
     const downloadedSize = record.size - record.sizeleft;
     const addedTime = new Date(record.added).getTime(); // convert added time to milliseconds
     const currentTime = Date.now(); // current time in milliseconds

app/api/sonarr/health/route.ts

@@ -0,0 +1,15 @@
+import { NextResponse } from 'next/server';
+import { SonarrHealthItem } from '@/types/Sonarr';
+
+const PAGE_SIZE = 1000;
+
+export async function GET() {
+  const sonarrResponse = await fetch(`${process.env.SONARR_URL}/api/v3/health?apikey=${process.env.SONARR_API_KEY}&pageSize=${PAGE_SIZE}&includeSeries=true`);
+  const sonarrHealthData: SonarrHealthItem[] = await sonarrResponse.json();
+
+  if (!sonarrHealthData.length) {
+    return NextResponse.json([], { status: 200 });
+  }
+
+  return NextResponse.json(sonarrHealthData, { status: 200 });
+}

app/api/sonarr/wanted/route.ts

@@ -0,0 +1,23 @@
+import { NextResponse } from 'next/server';
+import { SonarrQueue } from '@/types/Sonarr';
+
+const PAGE_SIZE = 1000;
+
+export async function GET() {
+  const sonarrResponse = await fetch(`${process.env.SONARR_URL}/api/v3/wanted/missing?apikey=${process.env.SONARR_API_KEY}&pageSize=${PAGE_SIZE}&includeSeries=true`);
+  const sonarrData: SonarrQueue = await sonarrResponse.json();
+
+  if (!sonarrData.records) {
+    return NextResponse.json([], { status: 200 });
+  }
+
+  const response = sonarrData.records.map(record => ({
+    id: record.id,
+    title: `${record.series.title} - S${record.seasonNumber}E${record.episodeNumber}`,
+    seriesTitle: record.series.title,
+    releaseDate: record.airDate,
+    seriesId: record.seriesId
+  }))
+
+  return NextResponse.json(response, { status: 200 });
+}