WIP: Sync prod to main

app/api/subs/route.ts

@@ -1,8 +1,8 @@
 import { getAuthTokenOrNull } from '@/helpers/oauth/helpers'
-import guildProfileSchema from '@/models/Guild'
 import { NextResponse } from 'next/server'
 import connectDb from '@/lib/mongodb'
 import { stripe } from '@/lib/stripe'
+import { prisma } from '@/lib/prisma'
 
 interface StripeSubscriptionRequest {
 	monthly: string
@@ -27,7 +27,14 @@ export async function POST(req: Request) {
 	const { priceId, serverId, monthly } =
 		(await req.json()) as StripeSubscriptionRequest
 
-	const server = await guildProfileSchema.findOne({ guildID: serverId })
+	const server = await prisma.guild.findFirst({
+		where: {
+			guildID: serverId
+		},
+		select: {
+			premiumExpiration: true
+		}
+	})
 
 	if (!serverId) {
 		return NextResponse.json(

app/api/webhook/route.ts

@@ -1,7 +1,7 @@
-import guildProfileSchema from '@/models/Guild'
 import type { NextRequest } from 'next/server'
 import { NextResponse } from 'next/server'
 import { stripe } from '@/lib/stripe'
+import { prisma } from '@/lib/prisma'
 import type Stripe from 'stripe'
 
 export async function POST(request: NextRequest) {
@@ -47,18 +47,29 @@ export async function POST(request: NextRequest) {
 					)
 				}
 				try {
-					await guildProfileSchema.findOneAndUpdate(
-						{ guildID: serverId },
-						{
+					await prisma.guild.upsert({
+						where: {
+							guildID: serverId
+						},
+						create: {
 							guildID: serverId,
 							premiumUser: userId,
 							premium: 1,
+							pending: true,
 							premiumExpiration: new Date(
 								subscription.current_period_end * 1000
-							)
+							),
+							language: 'en_US'
 						},
-						{ upsert: true }
-					)
+						update: {
+							premiumUser: userId,
+							premium: 1,
+							pending: true,
+							premiumExpiration: new Date(
+								subscription.current_period_end * 1000
+							)
+						}
+					})
 				} catch (error) {
 					console.error(error)
 					return NextResponse.json(
@@ -71,6 +82,84 @@ export async function POST(request: NextRequest) {
 				}
 				break
 
+			case 'invoice.paid':
+			case 'invoice.payment_succeeded':
+				const invoice: Stripe.Invoice = event.data.object
+
+				if (invoice.subscription_details === null)
+					return NextResponse.json(
+						{ message: 'No subscription details found', status: 400 },
+						{ status: 400 }
+					)
+
+				const userIdInvoice = invoice.subscription_details.metadata?.userId
+				const serverIdInvoice = invoice.subscription_details.metadata?.serverId
+				const tierInvoice =
+					invoice.subscription_details.metadata?.monthly === 'true' ?
+						'monthly'
+					:	'yearly'
+
+				if (!userIdInvoice || !serverIdInvoice || !tierInvoice) {
+					console.error('One or more variables are undefined.')
+					return NextResponse.json(
+						{ message: 'One or more variables are missing', status: 400 },
+						{ status: 400 }
+					)
+				}
+				switch (invoice.billing_reason) {
+					case 'subscription_create':
+						try {
+							await prisma.guild.update({
+								// @ts-ignore
+								where: {
+									guildID: serverIdInvoice
+								},
+								data: {
+									pending: false,
+									premiumExpiration: new Date(
+										invoice.lines.data[0].period.end * 1000
+									)
+								}
+							})
+						} catch (error) {
+							console.error(error)
+							return NextResponse.json(
+								{
+									message: 'An error occurred while updating the database.',
+									status: 500
+								},
+								{ status: 500 }
+							)
+						}
+						break
+					case 'subscription_update':
+						try {
+							await prisma.guild.update({
+								// @ts-ignore
+								where: {
+									guildID: serverIdInvoice
+								},
+								data: {
+									pending: false,
+									premiumExpiration: new Date(
+										invoice.lines.data[0].period.end * 1000
+									)
+								}
+							})
+						} catch (error) {
+							console.error(error)
+							return NextResponse.json(
+								{
+									message: 'An error occurred while updating the database.',
+									status: 500
+								},
+								{ status: 500 }
+							)
+						}
+						break
+				}
+				break
+
 			// in the event of a subscription being updated
 			case 'customer.subscription.updated':
 				const subscriptionUpdated: Stripe.Subscription = event.data.object
@@ -89,16 +178,19 @@ export async function POST(request: NextRequest) {
 					)
 				}
 
-				await guildProfileSchema.findOneAndUpdate(
-					{ guildID: serverIdUpdated },
-					{
+				await prisma.guild.update({
+					// @ts-ignore
+					where: {
+						guildID: serverIdUpdated
+					},
+					data: {
 						premium: 1,
 						premiumExpiration: new Date(
 							subscriptionUpdated.current_period_end * 1000
 						)
-					},
-					{ upsert: true }
-				)
+					}
+				})
+
 				break
 
 			// in the event of a subscription being deleted
@@ -119,14 +211,17 @@ export async function POST(request: NextRequest) {
 					)
 				}
 				try {
-					await guildProfileSchema.findOneAndUpdate(
-						{ guildID: serverIdDeleted },
-						{
-							premiumUser: null,
+					await prisma.guild.update({
+						// @ts-ignore
+						where: {
+							guildID: serverIdDeleted
+						},
+						data: {
 							premium: 0,
-							premiumExpiration: null
+							premiumExpiration: null,
+							premiumUser: null
 						}
-					)
+					})
 				} catch (error) {
 					console.error(error)
 					return NextResponse.json(