mirror of https://github.com/MaxLeiter/Drift
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
108 lines
2.8 KiB
TypeScript
108 lines
2.8 KiB
TypeScript
// nextjs typescript api handler
|
|
|
|
import { withMethods } from "@lib/api-middleware/with-methods"
|
|
|
|
import { authOptions } from "@lib/server/auth"
|
|
import { prisma, getPostById } from "@lib/server/prisma"
|
|
import { NextApiRequest, NextApiResponse } from "next"
|
|
import { unstable_getServerSession } from "next-auth/next"
|
|
import { File } from "@lib/server/prisma"
|
|
import * as crypto from "crypto"
|
|
import { getHtmlFromFile } from "@lib/server/get-html-from-drift-file"
|
|
import { getSession } from "next-auth/react"
|
|
import { parseQueryParam } from "@lib/server/parse-query-param"
|
|
|
|
const handler = async (req: NextApiRequest, res: NextApiResponse) => {
|
|
return await handlePost(req, res)
|
|
}
|
|
|
|
export default withMethods(["POST"], handler)
|
|
|
|
async function handlePost(req: NextApiRequest, res: NextApiResponse<any>) {
|
|
try {
|
|
const session = await unstable_getServerSession(req, res, authOptions)
|
|
if (!session || !session.user.id) {
|
|
return res.status(401).json({ error: "Unauthorized" })
|
|
}
|
|
|
|
const user = await prisma.user.findUnique({
|
|
where: {
|
|
id: session.user.id
|
|
}
|
|
})
|
|
|
|
if (!user) {
|
|
return res.status(404).json({ error: "User not found" })
|
|
}
|
|
|
|
const files = req.body.files as (Omit<File, "content" | "html"> & {
|
|
content: string
|
|
html: string
|
|
})[]
|
|
const fileTitles = files.map((file) => file.title)
|
|
const missingTitles = fileTitles.filter((title) => title === "")
|
|
if (missingTitles.length > 0) {
|
|
throw new Error("All files must have a title")
|
|
}
|
|
|
|
if (files.length === 0) {
|
|
throw new Error("You must submit at least one file")
|
|
}
|
|
|
|
let hashedPassword: string = ""
|
|
if (req.body.visibility === "protected") {
|
|
hashedPassword = crypto
|
|
.createHash("sha256")
|
|
.update(req.body.password)
|
|
.digest("hex")
|
|
}
|
|
|
|
const fileHtml = await Promise.all(
|
|
files.map(async (file) => {
|
|
return await getHtmlFromFile({
|
|
content: file.content,
|
|
title: file.title
|
|
})
|
|
})
|
|
)
|
|
|
|
const post = await prisma.post
|
|
.create({
|
|
data: {
|
|
title: req.body.title,
|
|
description: req.body.description,
|
|
visibility: req.body.visibility,
|
|
password: hashedPassword,
|
|
expiresAt: req.body.expiresAt,
|
|
parentId: req.body.parentId,
|
|
authorId: session.user.id,
|
|
files: {
|
|
create: files.map((file) => {
|
|
return {
|
|
title: file.title,
|
|
content: Buffer.from(file.content, "utf-8"),
|
|
sha: crypto
|
|
.createHash("sha256")
|
|
.update(file.content)
|
|
.digest("hex")
|
|
.toString(),
|
|
html: Buffer.from(
|
|
fileHtml[files.indexOf(file)] as string,
|
|
"utf-8"
|
|
),
|
|
userId: session.user.id
|
|
}
|
|
})
|
|
}
|
|
}
|
|
})
|
|
.catch((error) => {
|
|
return res.status(500).json(error)
|
|
})
|
|
|
|
return res.json(post)
|
|
} catch (error) {
|
|
return res.status(500).json(error)
|
|
}
|
|
}
|