Real-Time Threat Detection Across Multi-Camera Surveillance Networks

import { Mixpeek } from 'mixpeek';

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

// Connect to camera feeds
await client.integrations.connect({
  type: 'vms',
  platform: 'milestone', // or genetec, avigilon, etc.
  server_url: 'https://vms.facility.com',
  credentials: {
    username: process.env.VMS_USER,
    password: process.env.VMS_PASS
  }
});

// Configure threat detection
const securityConfig = {
  detections: [
    { type: 'intrusion', zones: ['perimeter', 'restricted_area'] },
    { type: 'loitering', threshold_seconds: 60 },
    { type: 'abandoned_object', threshold_seconds: 120 },
    { type: 'crowd_formation', threshold_count: 10 },
    { type: 'vehicle_intrusion', zones: ['pedestrian_area'] }
  ],
  alert_routing: {
    critical: ['sms', 'email', 'vms_popup'],
    warning: ['vms_popup', 'dashboard']
  }
};

await client.workflows.create({
  name: 'Facility Security',
  config: securityConfig
});

// Start baseline learning
await client.baseline.start({
  collection_id: 'facility-cameras',
  duration_days: 14,
  exclude_times: ['02:00-05:00'], // Exclude quiet periods
  feedback_enabled: true
});

// Monitor learning progress
const status = await client.baseline.status('facility-cameras');
console.log(`Learning progress: ${status.completion_percent}%`);
console.log(`Patterns identified: ${status.pattern_count}`);

// Real-time alert subscription
const alertStream = await client.alerts.subscribe({
  collection_id: 'facility-cameras',
  severity: ['critical', 'warning']
});

alertStream.on('alert', (alert) => {
  console.log(`Alert: ${alert.type} at ${alert.camera_name}`);
  console.log(`Confidence: ${alert.confidence}`);
  console.log(`Video clip: ${alert.clip_url}`);

  // Route to operator dashboard
  notifyOperator(alert);
});