🎨 #310 TOO_MANY_REQUESTS Errorを生成する関数を共通化

src/app/api/_utils/http.ts

@@ -0,0 +1,22 @@
+import { httpStatusCode } from '@/constants';
+import { NextResponse } from 'next/server';
+
+const tooManyRequestsResponseBody = {
+  type: 'TOO_MANY_REQUESTS',
+  title: 'Too many requests.',
+  detail: 'Too many requests from this IP. Please try again after some time.',
+} as const;
+
+export const createTooManyRequestsError = (): NextResponse<
+  typeof tooManyRequestsResponseBody
+> => {
+  const responseBody = {
+    type: 'TOO_MANY_REQUESTS',
+    title: 'Too many requests.',
+    detail: 'Too many requests from this IP. Please try again after some time.',
+  } as const;
+
+  const status = httpStatusCode.tooManyRequests;
+
+  return NextResponse.json(responseBody, { status });
+};

src/app/api/_utils/index.ts

@@ -0,0 +1 @@
+export * from './http';

src/app/api/cat-images/validation-results/route.ts

@@ -1,4 +1,5 @@
 import { issueClientCredentialsAccessToken } from '@/api';
+import { createTooManyRequestsError } from '@/app/api/_utils/http';
 import {
   httpStatusCode,
   upstashRedisRestToken,
@@ -62,16 +63,7 @@ const isAcceptableCatImageResponse = (
 export const POST = async (request: NextRequest): Promise<Response> => {
   const { success } = await rateLimit.limit(request.ip ?? 'anonymous');
   if (!success) {
-    const responseBody = {
-      type: 'TOO_MANY_REQUESTS',
-      title: 'Too many requests.',
-      detail:
-        'Too many requests from this IP. Please try again after some time.',
-    };
-
-    const status = httpStatusCode.tooManyRequests;
-
-    return NextResponse.json(responseBody, { status });
+    return createTooManyRequestsError();
   }
 
   const requestBody = (await request.json()) as CatImageValidationRequestBody;

src/app/api/lgtm-images/recently-created/route.ts

@@ -2,6 +2,7 @@ import {
   isFetchLgtmImagesResponseBody,
   issueClientCredentialsAccessToken,
 } from '@/api';
+import { createTooManyRequestsError } from '@/app/api/_utils/http';
 import {
   httpStatusCode,
   upstashRedisRestToken,
@@ -34,16 +35,7 @@ const rateLimit = new Ratelimit({
 export const GET = async (request: NextRequest): Promise<Response> => {
   const { success } = await rateLimit.limit(request.ip ?? 'anonymous');
   if (!success) {
-    const responseBody = {
-      type: 'TOO_MANY_REQUESTS',
-      title: 'Too many requests.',
-      detail:
-        'Too many requests from this IP. Please try again after some time.',
-    };
-
-    const status = httpStatusCode.tooManyRequests;
-
-    return NextResponse.json(responseBody, { status });
+    return createTooManyRequestsError();
   }
 
   const accessToken = await issueClientCredentialsAccessToken();

src/app/api/lgtm-images/route.ts

@@ -2,6 +2,7 @@ import {
   isFetchLgtmImagesResponseBody,
   issueClientCredentialsAccessToken,
 } from '@/api';
+import { createTooManyRequestsError } from '@/app/api/_utils/http';
 import {
   httpStatusCode,
   upstashRedisRestToken,
@@ -38,16 +39,7 @@ const rateLimit = new Ratelimit({
 export const GET = async (request: NextRequest): Promise<Response> => {
   const { success } = await rateLimit.limit(request.ip ?? 'anonymous');
   if (!success) {
-    const responseBody = {
-      type: 'TOO_MANY_REQUESTS',
-      title: 'Too many requests.',
-      detail:
-        'Too many requests from this IP. Please try again after some time.',
-    };
-
-    const status = httpStatusCode.tooManyRequests;
-
-    return NextResponse.json(responseBody, { status });
+    return createTooManyRequestsError();
   }
 
   const accessToken = await issueClientCredentialsAccessToken();
@@ -119,8 +111,13 @@ const isUploadLgtmImageResponse = (
   return validation(uploadLgtmImageResponseSchema, value).isValidate;
 };
 
-export const POST = async (req: Request): Promise<Response> => {
-  const requestBody = (await req.json()) as UploadLgtmImageRequestBody;
+export const POST = async (request: NextRequest): Promise<Response> => {
+  const { success } = await rateLimit.limit(request.ip ?? 'anonymous');
+  if (!success) {
+    return createTooManyRequestsError();
+  }
+
+  const requestBody = (await request.json()) as UploadLgtmImageRequestBody;
   const validationResult = validateUploadLgtmImageRequestBody(requestBody);
   if (!validationResult.isValidate && validationResult.invalidParams) {
     const validationErrorBody = {