mirror of
https://github.com/OpenSquawk/OpenSquawk
synced 2026-08-11 03:45:33 +08:00
Connect bridge telemetry to FlightLab with auto-advance triggers
Map raw bridge fields (ias_kt, on_ground, etc.) to FlightLabTelemetryState format, add direct telemetry polling endpoint for solo mode, and show sim condition panel in sidebar regardless of auto-advance toggle state. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
@@ -2,41 +2,36 @@ import { createError, defineEventHandler, readBody } from 'h3'
|
|||||||
import { BridgeToken } from '../../models/BridgeToken'
|
import { BridgeToken } from '../../models/BridgeToken'
|
||||||
import { getBridgeTokenFromHeader } from '../../utils/bridge'
|
import { getBridgeTokenFromHeader } from '../../utils/bridge'
|
||||||
import { flightlabTelemetryStore } from '../../utils/flightlabTelemetry'
|
import { flightlabTelemetryStore } from '../../utils/flightlabTelemetry'
|
||||||
|
import type { FlightLabTelemetryState } from '../../../shared/data/flightlab/types'
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Receives MSFS SimConnect telemetry data from an external bridge application.
|
* Receives telemetry data from an external bridge application.
|
||||||
*
|
*
|
||||||
* The bridge should POST telemetry data with an x-bridge-token header so we
|
* The bridge sends raw SimConnect-style fields which are mapped to the
|
||||||
* can route the data to the correct FlightLab WebSocket session.
|
* FlightLabTelemetryState format before storage.
|
||||||
*
|
|
||||||
* ──────────────────────────────────────────
|
|
||||||
* EXAMPLE REQUEST (from SimBridge app):
|
|
||||||
* ──────────────────────────────────────────
|
|
||||||
*
|
*
|
||||||
* POST /api/bridge/data
|
* POST /api/bridge/data
|
||||||
* x-bridge-token: <bridge-token>
|
* x-bridge-token: <bridge-token>
|
||||||
* Content-Type: application/json
|
|
||||||
*
|
|
||||||
* {
|
|
||||||
* "AIRSPEED_INDICATED": 145.2,
|
|
||||||
* "GROUND_VELOCITY": 142.8,
|
|
||||||
* "VERTICAL_SPEED": 0,
|
|
||||||
* "PLANE_ALTITUDE": 364,
|
|
||||||
* "PLANE_PITCH_DEGREES": 0.5,
|
|
||||||
* "TURB_ENG_N1_1": 87.3,
|
|
||||||
* "TURB_ENG_N1_2": 86.9,
|
|
||||||
* "SIM_ON_GROUND": true,
|
|
||||||
* "GEAR_HANDLE_POSITION": true,
|
|
||||||
* "FLAPS_HANDLE_INDEX": 2,
|
|
||||||
* "BRAKE_PARKING_POSITION": false,
|
|
||||||
* "AUTOPILOT_MASTER": false
|
|
||||||
* }
|
|
||||||
*
|
|
||||||
* ──────────────────────────────────────────
|
|
||||||
* RESPONSE: 204 No Content (success)
|
|
||||||
* 401 Unauthorized (missing/invalid token)
|
|
||||||
* ──────────────────────────────────────────
|
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
/** Map raw bridge field names to FlightLabTelemetryState keys */
|
||||||
|
function mapBridgeTelemetry(raw: Record<string, any>): FlightLabTelemetryState {
|
||||||
|
return {
|
||||||
|
AIRSPEED_INDICATED: raw.ias_kt ?? raw.AIRSPEED_INDICATED ?? 0,
|
||||||
|
GROUND_VELOCITY: raw.groundspeed_kt ?? raw.GROUND_VELOCITY ?? 0,
|
||||||
|
VERTICAL_SPEED: raw.vertical_speed_fpm ?? raw.VERTICAL_SPEED ?? 0,
|
||||||
|
PLANE_ALTITUDE: raw.altitude_ft_indicated ?? raw.altitude_ft_true ?? raw.PLANE_ALTITUDE ?? 0,
|
||||||
|
PLANE_PITCH_DEGREES: raw.pitch_deg ?? raw.PLANE_PITCH_DEGREES ?? 0,
|
||||||
|
TURB_ENG_N1_1: raw.n1_pct ?? raw.TURB_ENG_N1_1 ?? 0,
|
||||||
|
TURB_ENG_N1_2: raw.n1_pct_2 ?? raw.TURB_ENG_N1_2 ?? 0,
|
||||||
|
SIM_ON_GROUND: raw.on_ground ?? raw.SIM_ON_GROUND ?? false,
|
||||||
|
GEAR_HANDLE_POSITION: raw.gear_handle ?? raw.GEAR_HANDLE_POSITION ?? false,
|
||||||
|
FLAPS_HANDLE_INDEX: raw.flaps_index ?? raw.FLAPS_HANDLE_INDEX ?? 0,
|
||||||
|
BRAKE_PARKING_POSITION: raw.parking_brake ?? raw.BRAKE_PARKING_POSITION ?? false,
|
||||||
|
AUTOPILOT_MASTER: raw.autopilot_master ?? raw.AUTOPILOT_MASTER ?? false,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
export default defineEventHandler(async (event) => {
|
export default defineEventHandler(async (event) => {
|
||||||
const bridgeToken = getBridgeTokenFromHeader(event)
|
const bridgeToken = getBridgeTokenFromHeader(event)
|
||||||
if (!bridgeToken) {
|
if (!bridgeToken) {
|
||||||
@@ -52,12 +47,12 @@ export default defineEventHandler(async (event) => {
|
|||||||
const body = await readBody(event)
|
const body = await readBody(event)
|
||||||
const telemetryKeys = body && typeof body === 'object' ? Object.keys(body as Record<string, unknown>) : []
|
const telemetryKeys = body && typeof body === 'object' ? Object.keys(body as Record<string, unknown>) : []
|
||||||
console.info(
|
console.info(
|
||||||
`\x1b[35m[bridge:data]\x1b[0m token=\x1b[96m${bridgeToken.slice(0, 6)}...\x1b[0m user=\x1b[92m${userId}\x1b[0m telemetryKeys=\x1b[92m${telemetryKeys.length}\x1b[0m payload=`,
|
`\x1b[35m[bridge:data]\x1b[0m token=\x1b[96m${bridgeToken.slice(0, 6)}...\x1b[0m user=\x1b[92m${userId}\x1b[0m telemetryKeys=\x1b[92m${telemetryKeys.length}\x1b[0m`,
|
||||||
body,
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// Store telemetry and broadcast to WebSocket subscribers
|
// Map raw bridge fields to FlightLab format and store
|
||||||
flightlabTelemetryStore.update(userId, body)
|
const mapped = mapBridgeTelemetry(body)
|
||||||
|
flightlabTelemetryStore.update(userId, mapped)
|
||||||
|
|
||||||
event.node.res.statusCode = 204
|
event.node.res.statusCode = 204
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user