Extend Music Callbacks

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

interface ExtendedTrackItem {
  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 ExtendCallbackPayload {
  code: number;
  msg: string;
  data: {
    callbackType: 'text' | 'first' | 'complete' | 'error';
    task_id: string;
    data?: ExtendedTrackItem[];
  };
}

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

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

    if (code === 200 && data) {
      if (data.callbackType === 'complete') {
        console.log(`Extended tracks generated: ${data.data?.length || 0}`);
        for (const track of data.data || []) {
          console.log(`Track: "${track.title}" (Extended Duration: ${track.duration}s)`);
          console.log(`- MP3 URL: ${track.audio_url}`);
          console.log(`- Original Source: ${track.source_audio_url}`);
        }
      } else if (data.callbackType === 'first') {
        console.log(`[First Extended Track Ready] Stream: ${data.data?.[0]?.stream_audio_url}`);
      } else if (data.callbackType === 'text') {
        console.log('[Text Ready] Extended lyrics and structure planned');
      }
    } else {
      console.error(`Music extension 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 });
  }
}