node -e " 
  const WS = require('ws');
  const ws = new WS('ws://<TODO>:3000');
  ws.on('error', e => console.log('Error:', e.message));
  const send = (c, p) => { console.log('>>> ' + c); ws.send(JSON.stringify({ messageId: Date.now(), command: c, ...p })); };
  const fmt = d => d.toISOString().slice(0,10).replace(/-/g,'');

  ws.on('open', () => {
    console.log('Connected!');
    send('set_api_schema', {schemaVersion:21});
    send('start_listening');
  });

  ws.on('message', d => {
    const m = JSON.parse(d);
    console.log('<<< type:', m.type, 'event:', m.event?.event || m.result?.state ? 'state' : '');

    if (m.result?.state?.stations) {
      console.log('Stations:', m.result.state.stations);
      const t = new Date(), n = new Date(t); n.setDate(n.getDate()+1);
      m.result.state.stations.forEach(s => send('station.database_query_by_date', {
        serialNumber:s, serialNumbers:[], startDate:fmt(t), endDate:fmt(n), eventType:0, detectionType:0, storageType:0
      }));
    }

    if (m.event?.event === 'database query by date') {
      console.log('=== RESULTS ===');
      console.log('Events:', m.event.data?.length || 0);
      if (m.event.data?.[0]) console.log(JSON.stringify(m.event.data[0], null, 2));
      ws.close(); process.exit();
    }
  });

  setTimeout(() => { console.log('Timeout'); process.exit(1); }, 30000);
  "