Request/Response

Fetch on-demand data using an RPC-style pattern over the same Socket.IO connection.

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#3b82f6', 'primaryTextColor': '#fff', 'primaryBorderColor': '#60a5fa', 'lineColor': '#60a5fa', 'actorTextColor': '#fff', 'actorBkg': '#1e3a5f', 'actorBorder': '#3b82f6'}}}%%
sequenceDiagram
    participant C as 📱 Client
    participant S as 🖥️ Server
    participant API as 🌐 External APIs

    C->>S: 📤 request { type: 'pireps', params: {...} }
    S->>API: 🔍 Fetch PIREPs
    API->>S: 🌦️ PIREP data
    S->>C: 📥 response { data: [...] }

Making Requests

import { v4 as uuid } from 'uuid';

function request(socket, type, params) {
  return new Promise((resolve, reject) => {
    const request_id = uuid();

    const onResponse = (data) => {
      if (data.request_id === request_id) {
        socket.off('response', onResponse);
        socket.off('error', onError);
        resolve(data.data);
      }
    };

    const onError = (err) => {
      if (err.request_id === request_id) {
        socket.off('response', onResponse);
        socket.off('error', onError);
        reject(new Error(err.error));
      }
    };

    socket.on('response', onResponse);
    socket.on('error', onError);
    socket.emit('request', { type, request_id, params });
  });
}

// Usage
const pireps = await request(socket, 'pireps', {
  lat: 47.5,
  lon: -122.3,
  radius: 150
});

Available Requests

Type	Required	Optional	Description
`metars`	`lat`, `lon`	`radius`, `hours`, `limit`	METARs for airports in area
`metar`	`station`	`hours`	Single station METAR
`taf`	`station`	—	Terminal Aerodrome Forecast
`pireps`	`lat`, `lon`	`radius`, `hours`	Pilot Reports (turbulence, icing)
`sigmets`	—	`hazard`, `lat`, `lon`, `radius`	Active SIGMETs