organized routes and routes and added rate limiter

server/routers/org/createOrg.ts

@@ -0,0 +1,45 @@
+import { Request, Response, NextFunction } from 'express';
+import { z } from 'zod';
+import { db } from '@server/db';
+import { orgs } from '@server/db/schema';
+import response from "@server/utils/response";
+import HttpCode from '@server/types/HttpCode';
+import createHttpError from 'http-errors';
+
+const createOrgSchema = z.object({
+  name: z.string().min(1).max(255),
+  domain: z.string().min(1).max(255),
+});
+
+export async function createOrg(req: Request, res: Response, next: NextFunction): Promise<any> {
+  try {
+    const parsedBody = createOrgSchema.safeParse(req.body);
+    if (!parsedBody.success) {
+      return next(
+        createHttpError(
+          HttpCode.BAD_REQUEST,
+          parsedBody.error.errors.map(e => e.message).join(', ')
+        )
+      );
+    }
+
+    const { name, domain } = parsedBody.data;
+
+    const newOrg = await db.insert(orgs).values({
+      name,
+      domain,
+    }).returning();
+
+    return res.status(HttpCode.CREATED).send(
+      response({
+        data: newOrg[0],
+        success: true,
+        error: false,
+        message: "Organization created successfully",
+        status: HttpCode.CREATED,
+      })
+    );
+  } catch (error) {
+    next(error);
+  }
+}

server/routers/org/deleteOrg.ts

@@ -0,0 +1,53 @@
+import { Request, Response, NextFunction } from 'express';
+import { z } from 'zod';
+import { db } from '@server/db';
+import { orgs } from '@server/db/schema';
+import { eq } from 'drizzle-orm';
+import response from "@server/utils/response";
+import HttpCode from '@server/types/HttpCode';
+import createHttpError from 'http-errors';
+
+const deleteOrgSchema = z.object({
+  orgId: z.string().transform(Number).pipe(z.number().int().positive())
+});
+
+export async function deleteOrg(req: Request, res: Response, next: NextFunction): Promise<any> {
+  try {
+    const parsedParams = deleteOrgSchema.safeParse(req.params);
+    if (!parsedParams.success) {
+      return next(
+        createHttpError(
+          HttpCode.BAD_REQUEST,
+          parsedParams.error.errors.map(e => e.message).join(', ')
+        )
+      );
+    }
+
+    const { orgId } = parsedParams.data;
+
+    const deletedOrg = await db.delete(orgs)
+      .where(eq(orgs.orgId, orgId))
+      .returning();
+
+    if (deletedOrg.length === 0) {
+      return next(
+        createHttpError(
+          HttpCode.NOT_FOUND,
+          `Organization with ID ${orgId} not found`
+        )
+      );
+    }
+
+    return res.status(HttpCode.OK).send(
+      response({
+        data: null,
+        success: true,
+        error: false,
+        message: "Organization deleted successfully",
+        status: HttpCode.OK,
+      })
+    );
+  } catch (error) {
+    next(error);
+  }
+}

server/routers/org/getOrg.ts

@@ -0,0 +1,54 @@
+import { Request, Response, NextFunction } from 'express';
+import { z } from 'zod';
+import { db } from '@server/db';
+import { orgs } from '@server/db/schema';
+import { eq } from 'drizzle-orm';
+import response from "@server/utils/response";
+import HttpCode from '@server/types/HttpCode';
+import createHttpError from 'http-errors';
+
+const getOrgSchema = z.object({
+  orgId: z.string().transform(Number).pipe(z.number().int().positive())
+});
+
+export async function getOrg(req: Request, res: Response, next: NextFunction): Promise<any> {
+  try {
+    const parsedParams = getOrgSchema.safeParse(req.params);
+    if (!parsedParams.success) {
+      return next(
+        createHttpError(
+          HttpCode.BAD_REQUEST,
+          parsedParams.error.errors.map(e => e.message).join(', ')
+        )
+      );
+    }
+
+    const { orgId } = parsedParams.data;
+
+    const org = await db.select()
+      .from(orgs)
+      .where(eq(orgs.orgId, orgId))
+      .limit(1);
+
+    if (org.length === 0) {
+      return next(
+        createHttpError(
+          HttpCode.NOT_FOUND,
+          `Organization with ID ${orgId} not found`
+        )
+      );
+    }
+
+    return res.status(HttpCode.OK).send(
+      response({
+        data: org[0],
+        success: true,
+        error: false,
+        message: "Organization retrieved successfully",
+        status: HttpCode.OK,
+      })
+    );
+  } catch (error) {
+    next(error);
+  }
+}

server/routers/org/index.ts

@@ -0,0 +1,4 @@
+export * from "./getOrg";
+export * from "./createOrg";
+export * from "./deleteOrg";
+export * from "./updateOrg";

server/routers/org/updateOrg.ts

@@ -0,0 +1,72 @@
+import { Request, Response, NextFunction } from 'express';
+import { z } from 'zod';
+import { db } from '@server/db';
+import { orgs } from '@server/db/schema';
+import { eq } from 'drizzle-orm';
+import response from "@server/utils/response";
+import HttpCode from '@server/types/HttpCode';
+import createHttpError from 'http-errors';
+
+const updateOrgParamsSchema = z.object({
+  orgId: z.string().transform(Number).pipe(z.number().int().positive())
+});
+
+const updateOrgBodySchema = z.object({
+  name: z.string().min(1).max(255).optional(),
+  domain: z.string().min(1).max(255).optional(),
+}).refine(data => Object.keys(data).length > 0, {
+  message: "At least one field must be provided for update"
+});
+
+export async function updateOrg(req: Request, res: Response, next: NextFunction): Promise<any> {
+  try {
+    const parsedParams = updateOrgParamsSchema.safeParse(req.params);
+    if (!parsedParams.success) {
+      return next(
+        createHttpError(
+          HttpCode.BAD_REQUEST,
+          parsedParams.error.errors.map(e => e.message).join(', ')
+        )
+      );
+    }
+
+    const parsedBody = updateOrgBodySchema.safeParse(req.body);
+    if (!parsedBody.success) {
+      return next(
+        createHttpError(
+          HttpCode.BAD_REQUEST,
+          parsedBody.error.errors.map(e => e.message).join(', ')
+        )
+      );
+    }
+
+    const { orgId } = parsedParams.data;
+    const updateData = parsedBody.data;
+
+    const updatedOrg = await db.update(orgs)
+      .set(updateData)
+      .where(eq(orgs.orgId, orgId))
+      .returning();
+
+    if (updatedOrg.length === 0) {
+      return next(
+        createHttpError(
+          HttpCode.NOT_FOUND,
+          `Organization with ID ${orgId} not found`
+        )
+      );
+    }
+
+    return res.status(HttpCode.OK).send(
+      response({
+        data: updatedOrg[0],
+        success: true,
+        error: false,
+        message: "Organization updated successfully",
+        status: HttpCode.OK,
+      })
+    );
+  } catch (error) {
+    next(error);
+  }
+}