fix: prefix

Author: izadoesdev

apps/basket/src/routes/email.ts

@@ -77,54 +77,57 @@ async function checkEmailDuplicate(
 	return false;
 }
 
-const app = new Elysia({ prefix: '/email' })
-	.post('/', async ({ body, request }: { body: unknown; request: Request }) => {
-		// Validate API key
-		if (!validateApiKey(request)) {
-			return {
-				status: 'error',
-				message: 'Invalid or missing API key',
-			};
-		}
+const app = new Elysia()
+	.post(
+		'/email',
+		async ({ body, request }: { body: unknown; request: Request }) => {
+			// Validate API key
+			if (!validateApiKey(request)) {
+				return {
+					status: 'error',
+					message: 'Invalid or missing API key',
+				};
+			}
 
-		// Validate schema
-		const parseResult = emailEventSchema.safeParse(body);
-		if (!parseResult.success) {
-			return {
-				status: 'error',
-				message: 'Invalid email event schema',
-				errors: parseResult.error.issues,
-			};
-		}
+			// Validate schema
+			const parseResult = emailEventSchema.safeParse(body);
+			if (!parseResult.success) {
+				return {
+					status: 'error',
+					message: 'Invalid email event schema',
+					errors: parseResult.error.issues,
+				};
+			}
 
-		const emailData = parseResult.data;
-		const emailHash = hashEmailId(emailData.email_id, emailData.domain);
-		const eventTime = emailData.event_time || Date.now();
+			const emailData = parseResult.data;
+			const emailHash = hashEmailId(emailData.email_id, emailData.domain);
+			const eventTime = emailData.event_time || Date.now();
 
-		if (await checkEmailDuplicate(emailHash, eventTime)) {
-			return { status: 'success', message: 'Duplicate event ignored' };
-		}
+			if (await checkEmailDuplicate(emailHash, eventTime)) {
+				return { status: 'success', message: 'Duplicate event ignored' };
+			}
 
-		try {
-			await insertEmailEvent(emailData);
-			return {
-				status: 'success',
-				type: 'email',
-				event_id: emailHash,
-			};
-		} catch (error) {
-			logger.error('Email event processing failed', {
-				error: error as Error,
-				domain: emailData.domain,
-			});
-			return {
-				status: 'error',
-				message: 'Failed to process email event',
-			};
+			try {
+				await insertEmailEvent(emailData);
+				return {
+					status: 'success',
+					type: 'email',
+					event_id: emailHash,
+				};
+			} catch (error) {
+				logger.error('Email event processing failed', {
+					error: error as Error,
+					domain: emailData.domain,
+				});
+				return {
+					status: 'error',
+					message: 'Failed to process email event',
+				};
+			}
 		}
-	})
+	)
 	.post(
-		'/batch',
+		'/email/batch',
 		async ({ body, request }: { body: unknown; request: Request }) => {
 			// Validate API key
 			if (!validateApiKey(request)) {