fix: Skip processing if segments above 149

CapSoftware · Jun 4, 2024 · c00bc0c · c00bc0c · vercel · Jun 4, 2024
1 parent 99e34d0
commit c00bc0c
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/apps/web/app/api/upload/mux/create/route.ts b/apps/web/app/api/upload/mux/create/route.ts
@@ -125,6 +125,29 @@ export async function GET(request: NextRequest) {
     const videoSegmentKeys = (videoSegments.Contents || []).map(
       (object) => `s3://${bucket}/${object.Key}`
     );
+
+    if (videoSegmentKeys.length > 149) {
+      await db
+        .update(videos)
+        .set({ skipProcessing: true })
+        .where(eq(videos.id, videoId));
+      return new Response(
+        JSON.stringify({
+          message: "Number of inputs exceeds limit, skipping processing",
+        }),
+        {
+          status: 200,
+          headers: {
+            "Access-Control-Allow-Origin": allowedOrigins.includes(origin)
+              ? origin
+              : "null",
+            "Access-Control-Allow-Credentials": "true",
+            "Access-Control-Allow-Methods": "GET, OPTIONS",
+          },
+        }
+      );
+    }
+
     const audioSegmentKeys = (audioSegments.Contents || []).map(
       (object) => `s3://${bucket}/${object.Key}`
     );

diff --git a/packages/database/schema.ts b/packages/database/schema.ts
@@ -150,6 +150,7 @@ export const videos = mysqlTable(
     xStreamInfo: text("xStreamInfo"),
     jobId: varchar("jobId", { length: 255 }),
     jobStatus: varchar("jobStatus", { length: 255 }),
+    skipProcessing: boolean("skipProcessing").notNull().default(false),
     createdAt: timestamp("createdAt").notNull().defaultNow(),
     updatedAt: timestamp("updatedAt").notNull().defaultNow().onUpdateNow(),
   },