Generate Music Callbacks

// app/api/webhook/suno/route.ts
import { NextRequest, NextResponse } from 'next/server';

interface SunoTrackItem {
  id: string;
  audio_url: string;
  stream_audio_url: string;
  image_url: string;
  prompt: string;
  model_name: string;
  title: string;
  tags: string;
  createTime: number;
  duration: number;
  source_audio_url?: string;
  source_image_url?: string;
  source_stream_audio_url?: string;
}

interface SunoCallbackPayload {
  code: number;
  msg: string;
  data: {
    callbackType: 'text' | 'first' | 'complete' | 'error';
    task_id: string;
    data?: SunoTrackItem[];
  };
}

export async function POST(req: NextRequest) {
  try {
    const payload: SunoCallbackPayload = await req.json();
    const { code, msg, data } = payload;

    console.log(`[Webhook] Task ${data?.task_id} -> Stage: ${data?.callbackType} (Code: ${code})`);

    if (code === 200 && data) {
      if (data.callbackType === 'complete') {
        // Both dual-track variations generated successfully
        console.log(`[Complete] Total audio tracks: ${data.data?.length || 0}`);
        for (const track of data.data || []) {
          console.log(`Track: "${track.title}" (${track.duration}s)`);
          console.log(`- MP3 URL: ${track.audio_url}`);
          console.log(`- Stream URL: ${track.stream_audio_url}`);
          console.log(`- Artwork: ${track.image_url}`);
          // Persist to database or dispatch async download job
        }
      } else if (data.callbackType === 'first') {
        // First track is ready for quick preview
        console.log(`[First Track Ready] URL: ${data.data?.[0]?.audio_url}`);
      } else if (data.callbackType === 'text') {
        // Title and lyrics planning ready
        console.log('[Text Ready] Lyrics and metadata planned');
      }
    } else {
      console.error(`Task generation failed: ${msg}`);
    }

    // Always acknowledge receipt immediately with HTTP 200
    return NextResponse.json({ code: 200, msg: 'success' });
  } catch (error) {
    console.error('Webhook error:', error);
    return NextResponse.json({ code: 500, msg: 'Internal server error' }, { status: 500 });
  }
}