Filter submitted session clips by current take

src/app/api/public/reviews/submit-session/route.ts

@@ -11,6 +11,24 @@ const sanitizeText = (value: FormDataEntryValue | null, max = 200) => {
   return value.trim().slice(0, max);
 };
 
+function collectExpectedClips(form: FormData) {
+  const count = Number(sanitizeText(form.get('clipCount'), 10));
+  const total = Number.isFinite(count) ? Math.max(0, Math.min(20, count)) : 0;
+  const expected = new Map<string, number>();
+
+  for (let i = 0; i < total; i++) {
+    const step = Number(sanitizeText(form.get(`clipStep${i}`), 10));
+    const takeId = Number(sanitizeText(form.get(`clipTakeId${i}`), 20));
+    const mediaType = sanitizeText(form.get(`clipMediaType${i}`), 12);
+    if (!Number.isInteger(step) || step < 1 || step > 20) continue;
+    if (!Number.isSafeInteger(takeId) || takeId < 0) continue;
+    if (mediaType !== 'video' && mediaType !== 'audio') continue;
+    expected.set(`${step}:${mediaType}`, takeId);
+  }
+
+  return expected;
+}
+
 export async function POST(req: NextRequest) {
   try {
     const form = await req.formData();
@@ -20,12 +38,16 @@ export async function POST(req: NextRequest) {
     const deviceKey = sanitizeText(form.get('deviceKey'), 200) || null;
     const tableId = sanitizeText(form.get('tableId'), 80) || null;
     const sessionId = sanitizeText(form.get('sessionId'), 100);
+    const expectedClips = collectExpectedClips(form);
 
     if (!consentAccepted) {
       return NextResponse.json({ error: 'Consent is required' }, { status: 400 });
     }
 
-    const clips = await listSessionClips(sessionId);
+    const clips = (await listSessionClips(sessionId)).filter((clip) => {
+      if (expectedClips.size === 0) return true;
+      return expectedClips.get(`${clip.step}:${clip.mediaType}`) === clip.takeId;
+    });
     const videoClips = clips
       .filter((clip) => clip.mediaType === 'video')
       .map((clip) => ({ filePath: clip.filePath, ext: clip.ext }));

src/app/preview/page.tsx

@@ -122,6 +122,11 @@ export default function PreviewPage() {
           deviceKey: ensureDeviceKey(),
           tableId: store.tableId,
           sessionId: store.sessionId,
+          clips: clipsToUpload.map((clip) => ({
+            step: clip.step,
+            takeId: clip.takeId,
+            mediaType: clip.mediaType,
+          })),
         });
 
         setPhase({ kind: 'polling', result });

src/lib/humeoApi.ts

@@ -85,6 +85,11 @@ export type SubmitSessionInput = Omit<
   'durationSeconds' | 'video' | 'videoFileName'
 > & {
   sessionId: string;
+  clips?: Array<{
+    step: number;
+    takeId: number;
+    mediaType: 'video' | 'audio';
+  }>;
 };
 
 export async function submit(input: SubmitInput): Promise<PublicSubmitResult> {
@@ -171,6 +176,14 @@ export async function submitSession(input: SubmitSessionInput): Promise<PublicSu
   form.append('deviceKey', input.deviceKey);
   form.append('sessionId', input.sessionId);
   if (input.tableId) form.append('tableId', input.tableId);
+  if (input.clips) {
+    form.append('clipCount', String(input.clips.length));
+    input.clips.forEach((clip, index) => {
+      form.append(`clipStep${index}`, String(clip.step));
+      form.append(`clipTakeId${index}`, String(clip.takeId));
+      form.append(`clipMediaType${index}`, clip.mediaType);
+    });
+  }
 
   const res = await fetch(endpoint('/api/public/reviews/submit-session'), {
     method: 'POST',