Merge pull request #7 from ReflectionsProjections/subscription

Subscription

package.json

@@ -3,8 +3,8 @@
     "private": true,
     "version": "0.0.0",
     "scripts": {
-        "dev": "ENV=DEVELOPMENT nodemon -w src/ -x tsx src/app.ts",
-        "start": "ENV=PRODUCTION tsx src/app.ts",
+        "dev": "nodemon -w src/ -x tsx src/app.ts",
+        "start": "tsx src/app.ts",
         "lint": "yarn prettier . --write",
         "kill": "kill -9 $(lsof -t -i :3000)",
         "build": "tsc"

src/app.ts

@@ -8,6 +8,7 @@ import bodyParser from "body-parser";
 import errorHandler from "./middleware/error-handler";
 
 import authRouter from "./services/auth/auth-router";
+import subscriptionRouter from "./services/subscription/subscription-router";
 
 const app = express();
 
@@ -20,7 +21,9 @@ app.use("/", morgan("dev"));
 
 app.use("/", bodyParser.json());
 
+// API routes
 app.use("/auth", authRouter);
+app.use("/subscription", subscriptionRouter);
 
 app.get("/status", (_, res) => {
     console.log(StatusCodes.OK);

src/config.ts

@@ -6,6 +6,8 @@ import { getEnv } from "./utilities";
 
 export const Environment = z.enum(["PRODUCTION", "DEVELOPMENT", "TESTING"]);
 
+export const MailingListName = z.enum(["rp_interest"]);
+
 export const Config = {
     DEFAULT_APP_PORT: 3000,
     ENV: Environment.parse(getEnv("ENV")),

src/database.ts

@@ -1,5 +1,9 @@
 import mongoose, { Schema } from "mongoose";
 import { RoleInfo, RoleSchema } from "./services/auth/auth-schema";
+import {
+    SubscriptionValidator,
+    SubscriptionSchema,
+} from "./services/subscription/subscription-schema";
 
 mongoose.set("toObject", { versionKey: false });
 
@@ -32,4 +36,9 @@ function initializeModel(
 // Example usage
 export const Database = {
     ROLES: initializeModel("roles", RoleSchema, RoleInfo),
+    SUBSCRIPTION: initializeModel(
+        "subscription",
+        SubscriptionSchema,
+        SubscriptionValidator
+    ),
 };

src/services/subscription/subscription-router.ts

@@ -0,0 +1,23 @@
+import { Router } from "express";
+import { StatusCodes } from "http-status-codes";
+import { SubscriptionValidator } from "./subscription-schema";
+import { Database } from "../../database";
+
+const subscriptionRouter = Router();
+
+// Create a new subscription
+subscriptionRouter.post("/", async (req, res, next) => {
+    try {
+        const subscriptionData = SubscriptionValidator.parse(req.body);
+        await Database.SUBSCRIPTION.findOneAndUpdate(
+            { mailingList: subscriptionData.mailingList },
+            { $push: { subscriptions: subscriptionData.email } },
+            { upsert: true, new: true }
+        );
+        return res.status(StatusCodes.CREATED).json(subscriptionData);
+    } catch (error) {
+        next(error);
+    }
+});
+
+export default subscriptionRouter;

src/services/subscription/subscription-schema.ts

@@ -0,0 +1,17 @@
+import mongoose from "mongoose";
+import { z } from "zod";
+import { MailingListName } from "../../config";
+
+// Zod schema for subscription
+const SubscriptionValidator = z.object({
+    email: z.string().email(),
+    mailingList: MailingListName,
+});
+
+// Mongoose schema for subscription
+const SubscriptionSchema = new mongoose.Schema({
+    email: { type: String, required: true },
+    mailingList: { type: String, required: true },
+});
+
+export { SubscriptionValidator, SubscriptionSchema };