Real-Time Brand Safety Monitoring for Video Ads

import { Mixpeek } from 'mixpeek';

const client = new Mixpeek({ apiKey: process.env.MIXPEEK_API_KEY });

// Connect to creative storage
await client.buckets.connect({
  collection_id: 'video-ads',
  bucket_uri: 's3://ad-network-creatives/',
  filters: {
    file_types: ['mp4', 'mov', 'webm']
  }
});

// Configure brand safety analysis
const brandSafetyConfig = {
  extractors: [
    'brand-safety-violence',
    'brand-safety-hate-speech',
    'brand-safety-adult-content',
    'brand-safety-drugs',
    'brand-safety-weapons',
    'brand-safety-profanity'
  ],
  threshold: 0.85, // Confidence threshold
  frame_sampling: 'all' // Analyze every frame
};

// Real-time creative check
async function checkCreativeSafety(creativeId: string) {
  const result = await client.retrieve({
    collection_id: 'video-ads',
    query: { object_id: creativeId },
    extractors: brandSafetyConfig.extractors
  });

  // Check for violations
  const violations = result.extractors.filter(
    e => e.confidence > brandSafetyConfig.threshold
  );

  return {
    safe: violations.length === 0,
    violations: violations.map(v => v.category),
    confidence: Math.max(...violations.map(v => v.confidence))
  };
}

// Webhook for violation alerts
await client.webhooks.create({
  url: 'https://your-domain.com/safety-alerts',
  events: ['safety_violation_detected'],
  filters: {
    min_confidence: 0.85
  }
});

async function processCreative(creativeId: string) {
  const safety = await checkCreativeSafety(creativeId);

  if (safety.safe) {
    // Auto-approve safe creatives
    await approveCreative(creativeId);
    return { status: 'approved', method: 'automated' };
  } else if (safety.confidence > 0.95) {
    // Auto-reject high-confidence violations
    await rejectCreative(creativeId, safety.violations);
    return { status: 'rejected', method: 'automated' };
  } else {
    // Escalate borderline cases to human review
    await escalateForReview(creativeId, safety);
    return { status: 'pending_review', method: 'human' };
  }
}