Financial Video GenerationCompliance-Ready at Scale

import CreativeAI from '@creativeai/node-sdk';

const client = new CreativeAI({ apiKey: process.env.CREATIVEAI_API_KEY });

// Generate personalized portfolio video
async function generatePortfolioVideo(clientData) {
  // Create script from client data
  const script = await generateScript({
    name: clientData.name,
    portfolioValue: clientData.portfolioValue,
    ytdReturn: clientData.ytdReturn,
    topHoldings: clientData.topHoldings,
    recommendations: clientData.recommendations
  });

  // Submit video generation job
  const job = await client.videos.generate({
    model: 'auto', // Multi-model failover
    prompt: script,
    duration: 60, // 60 seconds for detailed review
    aspect_ratio: '16:9',
    webhook_url: process.env.WEBHOOK_URL + '/financial-video-complete',
    metadata: {
      client_id: clientData.id,
      video_type: 'portfolio_review',
      generated_at: new Date().toISOString(),
      compliance_hash: hashScript(script)
    }
  });

  // Log for audit trail
  await logAuditTrail({
    job_id: job.id,
    client_id: clientData.id,
    prompt_hash: hashScript(script),
    timestamp: new Date().toISOString()
  });

  return job.id;
}

// Webhook handler
app.post('/webhook/financial-video-complete', async (req, res) => {
  const signature = req.headers['x-creativeai-signature'];
  const payload = JSON.stringify(req.body);

  // Verify HMAC signature
  if (!verifySignature(payload, signature)) {
    return res.status(401).json({ error: 'Invalid signature' });
  }

  const { id, output_url, metadata } = req.body;

  // Store video reference (not the video itself)
  await storeVideoReference({
    job_id: id,
    client_id: metadata.client_id,
    video_url: output_url,
    compliance_hash: metadata.compliance_hash,
    expires_at: new Date(Date.now() + 24 * 60 * 60 * 1000) // 24 hours
  });

  // Notify client
  await notifyClient(metadata.client_id, output_url);

  res.json({ received: true });
});