feat: v1/campaign public api endpoint (#335)

Co-authored-by: cubic-dev-ai[bot] <191113872+cubic-dev-ai[bot]@users.noreply.github.com>

apps/web/src/server/public-api/api/campaigns/get-campaigns.ts

@@ -0,0 +1,126 @@
+import { createRoute, z } from "@hono/zod-openapi";
+import { CampaignStatus, Prisma } from "@prisma/client";
+import { PublicAPIApp } from "~/server/public-api/hono";
+import { db } from "~/server/db";
+
+const statuses = Object.values(CampaignStatus) as [CampaignStatus];
+
+const route = createRoute({
+	method: "get",
+	path: "/v1/campaigns",
+	request: {
+		query: z.object({
+			page: z.string().optional().openapi({
+				description: "Page number for pagination (default: 1)",
+				example: "1",
+			}),
+			status: z.enum(statuses).optional().openapi({
+				description: "Filter campaigns by status",
+				example: "DRAFT",
+			}),
+			search: z.string().optional().openapi({
+				description: "Search campaigns by name or subject",
+				example: "newsletter",
+			}),
+		}),
+	},
+	responses: {
+		200: {
+			description: "Get list of campaigns",
+			content: {
+				"application/json": {
+					schema: z.object({
+						campaigns: z.array(
+							z.object({
+								id: z.string(),
+								name: z.string(),
+								from: z.string(),
+								subject: z.string(),
+								createdAt: z.string().datetime(),
+								updatedAt: z.string().datetime(),
+								status: z.string(),
+								scheduledAt: z.string().datetime().nullable(),
+								total: z.number().int(),
+								sent: z.number().int(),
+								delivered: z.number().int(),
+								unsubscribed: z.number().int(),
+							})
+						),
+						totalPage: z.number().int(),
+					}),
+				},
+			},
+		},
+	},
+});
+
+function getCampaigns(app: PublicAPIApp) {
+	app.openapi(route, async (c) => {
+		const team = c.var.team;
+		const pageParam = c.req.query("page");
+		const statusParam = c.req.query("status") as
+			| Prisma.EnumCampaignStatusFilter<"Campaign">
+			| undefined;
+		const searchParam = c.req.query("search");
+
+		const page = pageParam ? Number(pageParam) : 1;
+		const limit = 30;
+		const offset = (page - 1) * limit;
+
+		const whereConditions: Prisma.CampaignWhereInput = {
+			teamId: team.id,
+		};
+
+		if (statusParam) {
+			whereConditions.status = statusParam;
+		}
+
+		if (searchParam) {
+			whereConditions.OR = [
+				{
+					name: {
+						contains: searchParam,
+						mode: "insensitive",
+					},
+				},
+				{
+					subject: {
+						contains: searchParam,
+						mode: "insensitive",
+					},
+				},
+			];
+		}
+
+		const countP = db.campaign.count({ where: whereConditions });
+
+		const campaignsP = db.campaign.findMany({
+			where: whereConditions,
+			select: {
+				id: true,
+				name: true,
+				from: true,
+				subject: true,
+				createdAt: true,
+				updatedAt: true,
+				status: true,
+				scheduledAt: true,
+				total: true,
+				sent: true,
+				delivered: true,
+				unsubscribed: true,
+			},
+			orderBy: {
+				createdAt: "desc",
+			},
+			skip: offset,
+			take: limit,
+		});
+
+		const [campaigns, count] = await Promise.all([campaignsP, countP]);
+
+		return c.json({ campaigns, totalPage: Math.ceil(count / limit) });
+	});
+}
+
+export default getCampaigns;

apps/web/src/server/public-api/index.ts

@@ -18,6 +18,7 @@ import deleteDomain from "./api/domains/delete-domain";
 import sendBatch from "./api/emails/batch-email";
 import createCampaign from "./api/campaigns/create-campaign";
 import getCampaign from "./api/campaigns/get-campaign";
+import getCampaigns from "./api/campaigns/get-campaigns";
 import scheduleCampaign from "./api/campaigns/schedule-campaign";
 import pauseCampaign from "./api/campaigns/pause-campaign";
 import resumeCampaign from "./api/campaigns/resume-campaign";
@@ -50,6 +51,7 @@ deleteContact(app);
 /**Campaign related APIs */
 createCampaign(app);
 getCampaign(app);
+getCampaigns(app);
 scheduleCampaign(app);
 pauseCampaign(app);
 resumeCampaign(app);