Merge pull request #37 from kentibs/feat/newletter

feat: add newsletter subscription endpoint

prisma/migrations/20240127203910_test/migration.sql

@@ -0,0 +1,18 @@
+-- CreateTable
+CREATE TABLE "_news_letter" (
+    "newsLetterId" TEXT NOT NULL,
+    "email" TEXT NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3),
+
+    CONSTRAINT "_news_letter_pkey" PRIMARY KEY ("newsLetterId")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "_news_letter_email_key" ON "_news_letter"("email");
+
+-- CreateIndex
+CREATE INDEX "_news_letter_newsLetterId_idx" ON "_news_letter"("newsLetterId");
+
+-- CreateIndex
+CREATE INDEX "_news_letter_email_idx" ON "_news_letter"("email");

prisma/schema.prisma

@@ -111,6 +111,17 @@ model EventImage {
   @@map("_event_images")
 }
 
+model NewsLetter {
+  newsLetterId String    @id @default(uuid())
+  email        String    @unique @db.Text
+  createdAt    DateTime  @default(now())
+  updatedAt    DateTime? @updatedAt
+
+  @@index([newsLetterId])
+  @@index([email])
+  @@map("_news_letter")
+}
+
 // PRISMA COMMNANDS 
 
 // INITIALIZE PRISMA

src/app.ts

@@ -9,6 +9,7 @@ import { userRoutes } from "./routes/auth/userRoutes";
 import { tokenRoutes } from "./routes/token/tokenRoutes";
 import { eventRoutes } from "./routes/event/eventRoutes";
 import { monitoringRoutes } from "./routes/monitoring/monitoringRoutes";
+import { newsLetterRoutes } from "./routes/newsLetter/newsLetterRoutes";
 import {
   startRequestMonitoringTimer,
   endRequestMonitoringTimer,
@@ -36,6 +37,7 @@ app.use(startRequestMonitoringTimer);
 app.use("/api/v1/users", userRoutes);
 app.use("/api/v1/tokens", tokenRoutes);
 app.use("/api/v1/events", eventRoutes);
+app.use("/api/v1/newsletter", newsLetterRoutes);
 
 app.use(monitoringRoutes);
 app.use(endRequestMonitoringTimer);

src/controllers/newsLetterController.ts

@@ -0,0 +1,30 @@
+import { Request, Response, NextFunction } from "express";
+import { AppError } from "../utils/error";
+import { asyncHandler } from "../utils/asyncHandler";
+import { PrismaClient } from "@prisma/client";
+
+const prisma = new PrismaClient();
+const NewsLetter = prisma.newsLetter;
+
+export const subscribeToNewsLetter = asyncHandler(
+  async (req: Request, res: Response, next: NextFunction) => {
+    const email = req.body.email as string;
+
+    if (!email) return next(new AppError("Please provide your email", 400));
+
+    const savedEmail = await NewsLetter.findFirst({
+      where: { email: { equals: email } },
+    });
+
+    if (savedEmail) {
+      return next(new AppError("Provided email is already subscribed", 400));
+    }
+
+    await NewsLetter.create({ data: { email: email } });
+
+    res.status(201).json({
+      status: "success",
+      message: "Subscribed to SEG-MUK newsletter successfully",
+    });
+  }
+);

src/routes/newsLetter/newsLetterRoutes.ts

@@ -0,0 +1,8 @@
+import express from "express";
+import { subscribeToNewsLetter } from "../../controllers/newsLetterController";
+
+const router = express.Router();
+
+router.post("/subscribe", subscribeToNewsLetter);
+
+export { router as newsLetterRoutes };