Events WebSocket

const computerId = 'a3bb189e-8bf9-3888-9912-ace4e6543002';
const apiKey = process.env.ORGO_API_KEY;

// Step 1: Get the computer password
const res = await fetch(
  `https://www.orgo.ai/api/computers/${computerId}/vnc-password`,
  { headers: { 'Authorization': `Bearer ${apiKey}` } }
);
const { password } = await res.json();

// Step 2: Connect to events stream
const ws = new WebSocket(
  `wss://${computerId}.orgo.dev/events?token=${password}`
);

ws.onopen = () => {
  // Subscribe to the events you care about
  ws.send(JSON.stringify({
    type: 'subscribe',
    event_types: ['window_focus', 'clipboard', 'file_change', 'idle', 'active']
  }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);

  switch (msg.type) {
    case 'event':
      const { type, timestamp, data } = msg.event;
      console.log(`[${timestamp}] ${type}:`, data);

      // React to specific events
      if (type === 'window_focus') {
        console.log(`User switched to: ${data.title}`);
      }
      if (type === 'clipboard') {
        console.log(`Clipboard: ${data.content}`);
      }
      if (type === 'idle') {
        console.log(`Desktop idle for ${data.idle_seconds}s`);
      }
      break;

    case 'subscribed':
      console.log('Subscription confirmed');
      break;

    case 'error':
      console.error('Event error:', msg.message);
      break;
  }
};

// Later: add more subscriptions
ws.send(JSON.stringify({
  type: 'subscribe',
  event_types: ['process_start', 'process_stop']
}));

// Or unsubscribe from some
ws.send(JSON.stringify({
  type: 'unsubscribe',
  event_types: ['idle', 'active']
}));