Engineering systems built to last.

// Subscribe to real-time updates
const socket = new WebSocket(url);
socket.onopen = () => {
  socket.send(JSON.stringify({
    type: 'subscribe',
    channels: ['updates', 'orders']
  }));
};

socket.onmessage = (event) => {
  const data = JSON.parse(event.data);
  handleUpdate(data);
};

// Return a snapshot for a channel
function getUpdates(request, state) {
  const channel = request.query.channel;
  const updates = state.get(channel) ?? [];

  return {
    status: 200,
    body: {
      channel,
      updates
    }
  };
}

// Process queued background work
async function processJob(job) {
  try {
    await handleTask(job.payload);
    await job.ack();
  } catch (error) {
    await job.retry(error);
  }
}

queue.consume(processJob);

// Illustrative runtime configuration
const config = {
  transport: 'websocket',
  channels: ['updates', 'orders'],
  delivery: {
    retries: 3,
    timeoutMs: 5000
  },
  observability: {
    logs: true,
    metrics: true
  }
};