import { defaultHandler, defaultResponder } from "@documenso/lib/server";
import prisma from "@documenso/prisma";
import { NextApiRequest, NextApiResponse } from "next";
import { getUserFromToken } from "@documenso/lib/server";
import formidable, { Files } from "formidable";
import { getToken } from "next-auth/jwt";

export const config = {
  api: {
    bodyParser: false,
  },
};

// POST /documents
async function postHandler(req: NextApiRequest, res: NextApiResponse) {
  const form = formidable();

  const user = await getUserFromToken(req, res);
  if (!user) return;
  form.parse(req, async (err, fields, files) => {
    if (err) throw err;

    const uploadedDocument: any = files["document"];
    const title = uploadedDocument[0].originalFilename;
    const path = uploadedDocument[0].filepath;
    const fs = require("fs");
    const buffer = fs.readFileSync(path);
    const documentAsBase64EncodedString = buffer.toString("base64");
    await prisma
      .$transaction([
        prisma.document.create({
          data: {
            title: title,
            userId: user?.id,
            document: documentAsBase64EncodedString,
          },
        }),
      ])
      .then((document) => {
        return res.status(201).send(document[0].id);
      })
      .catch((err) => {
        throw err;
      });
  });
}

async function getHandler(req: NextApiRequest, res: NextApiResponse) {
  let user = await getUserFromToken(req, res);
  if (!user) return;

  return res.status(200).json(
    await prisma.document.findMany({
      where: {
        userId: user?.id,
      },
      select: {
        id: true,
        title: true,
        status: true,
        Recipient: true,
      },
    })
  );
}

export default defaultHandler({
  GET: Promise.resolve({ default: defaultResponder(getHandler) }),
  POST: Promise.resolve({ default: defaultResponder(postHandler) }),
});