import { authorizationMiddleware } from "#lib/middleware/authorization.js";
import { prisma, UnterlageSchema } from "#lib/server/prisma";
import { APIError, defineApiRoute } from "astro-typesafe-api/server";
import { z } from "zod";
import { UUidWithPrefix } from "#components/Ausweis/types.js";

export const PUT = defineApiRoute({
	input: z.array(UUidWithPrefix),
	output: z.void(),
	middleware: authorizationMiddleware,
	async fetch(input, ctx, user) {
		const aufnahme = await prisma.aufnahme.findUnique({
			where: {
				uid: ctx.params.uid
			}
		})

		if (!aufnahme) {
			throw new APIError({
				code: "NOT_FOUND",
				message: "Aufnahme existiert nicht oder gehört einem anderen Benutzer."
			})
		}

		prisma.$transaction(async tx => {
			for (const uid of input) {
				const img = await tx.unterlage.update({
					where: {
						uid,
						aufnahme_id: null
					},
					data: {
						aufnahme_id: aufnahme.id
					},
					select: {
						uid: true
					}
				})
	
				if (!img) {
					throw new APIError({
						code: "NOT_FOUND",
						message: "Unterlage existiert nicht oder gehört bereits zu einer anderen Aufnahme."
					})
				}
			}
		})
	},
})

export const GET = defineApiRoute({
	middleware: authorizationMiddleware,
	output: z.array(UnterlageSchema.pick({
		kategorie: true,
		uid: true
	})),
	async fetch(input, ctx, user) {
		const { uid } = ctx.params;

		const aufnahme = await prisma.aufnahme.findUnique({
			where: {
				uid,
				benutzer_id: user.id
			},
			select: {
				benutzer_id: true,
				unterlagen: {
					select: {
						kategorie: true,
						uid: true,
						mime: true,
						name: true
					}
				}
			}
		})

		if (!aufnahme) {
			throw new APIError({
				code: "NOT_FOUND",
				message: "Aufnahme existiert nicht oder gehört einem anderen Benutzer."
			})
		}

		return aufnahme.unterlagen
	},
})