Music Video Generation Callbacks

const express = require('express');
const fs = require('fs');
const https = require('https');
const app = express();

app.use(express.json());

app.post('/video-callback', (req, res) => {
  const { code, msg, data } = req.body;
  
  console.log('Received music video callback:', {
    taskId: data.task_id,
    status: code,
    message: msg
  });
  
  if (code === 200 && data.video_url) {
    // Video generation successful
    console.log(`Music video ready: ${data.video_url}`);
    
    // Download video file
    downloadVideoFile(data.video_url, data.task_id);
    
  } else {
    // Task failed
    console.log('Music video generation failed:', msg);
    
    // Handle failure cases...
    if (code === 400) {
      console.log('Invalid source audio or parameter error');
    } else if (code === 429) {
      console.log('Insufficient credits');
    } else if (code === 500) {
      console.log('Server internal error');
    }
  }
  
  // Return 200 status code to confirm callback received
  res.status(200).json({ status: 'received' });
});

function downloadVideoFile(url, taskId) {
  const filename = `video_${taskId}.mp4`;
  const file = fs.createWriteStream(filename);
  
  https.get(url, (response) => {
    response.pipe(file);
    
    file.on('finish', () => {
      file.close();
      console.log(`Video file downloaded: ${filename}`);
    });
  }).on('error', (err) => {
    console.error('Video download failed:', err.message);
  });
}

app.listen(3000, () => {
  console.log('Video callback server running on port 3000');
});