Merge pull request #726 from divysam/feat/request-body-size-limits-569

feat(backend): add request body size limits and campaign description validation (#569)

Author: ritik4ever

backend/src/index.ts

@@ -864,7 +864,7 @@ app.use((err: unknown, req: Request, res: Response, next: express.NextFunction)
       success: false,
       error: {
         code: 'PAYLOAD_TOO_LARGE',
-        message: 'Request payload size exceeds the maximum allowed limit',
+        message: `Request body exceeds the ${bodySizeLimit} maximum limit.`, 
         requestId: (req as RequestWithId).requestId,
       },
     });

backend/src/openapi.ts

@@ -428,6 +428,11 @@ const validationErrorResponse = {
   content: { 'application/json': { schema: registeredSchemas.ApiError } },
 };
 
+const payloadTooLargeResponse = {
+  description: 'Request body exceeds the 64KB maximum limit',
+  content: { 'application/json': { schema: registeredSchemas.ApiError } },
+};
+
 registry.registerPath({
   method: 'get',
   path: '/api/health',
@@ -537,6 +542,7 @@ registry.registerPath({
       content: { 'application/json': { schema: registeredSchemas.CampaignDetailResponse } },
     },
     400: validationErrorResponse,
+    413: payloadTooLargeResponse,
   },
 });
 
@@ -638,6 +644,7 @@ registry.registerPath({
     },
     400: validationErrorResponse,
     404: notFoundResponse,
+    413: payloadTooLargeResponse,
     429: { description: 'Rate limit exceeded' },
   },
 });
@@ -662,6 +669,7 @@ registry.registerPath({
     },
     400: validationErrorResponse,
     404: notFoundResponse,
+    413: payloadTooLargeResponse,
     429: { description: 'Rate limit exceeded' },
   },
 });
@@ -686,6 +694,7 @@ registry.registerPath({
     },
     400: validationErrorResponse,
     404: notFoundResponse,
+    413: payloadTooLargeResponse,
     429: { description: 'Rate limit exceeded' },
   },
 });
@@ -711,6 +720,7 @@ registry.registerPath({
     },
     400: validationErrorResponse,
     404: notFoundResponse,
+    413: payloadTooLargeResponse,
     429: { description: 'Rate limit exceeded' },
   },
 });

backend/src/services/cache.ts

@@ -31,6 +31,9 @@ export async function initRedisCache(): Promise<void> {
     await redisClient.connect();
     isConnected = true;
 
+    logInfo('redis_connected', {}, config.logLevel);
+  } catch (error) {
+    logError(error instanceof Error ? error : new Error(String(error)), { event: 'redis_connection_failed' }, config.logLevel);
     redisClient = null;
     isConnected = false;
   } catch {