VATSWIM Implementation Tracker

Last Updated: 2026-03-25 Status: Phase 4 COMPLETE ✅ (Data Isolation) Repository: VATSIM PERTI/PERTI/

Quick Status

🎉 Latest: Data Isolation Complete (Phase 4)

All SWIM API endpoints now query exclusively from the SWIM_API database. Three sync daemons (swim_sync_daemon, swim_tmi_sync_daemon, refdata_sync_daemon) keep 25+ mirror tables fresh within the 5 DTU budget. See Phase 4 section below for full details.

SDKs

Client SDKs now available for all major platforms:

✅ Phase 0: Infrastructure (COMPLETE)

✅ Phase 1: REST API & Documentation (COMPLETE)

✅ Phase 2: Real-Time WebSocket (COMPLETE)

✅ Phase 3: SDKs & Integrations (COMPLETE)

Python SDK v2.0.0

Location: sdk/python/swim_client/

Install:

pip install swim-client
# or with async support:
pip install swim-client[async]

C# SDK v1.0.0

Location: sdk/csharp/SwimClient/

Install:

dotnet add package VatSim.Swim.Client

Java SDK v1.0.0

Location: sdk/java/swim-client/

Install (Maven):

<dependency>
    <groupId>org.vatsim.swim</groupId>
    <artifactId>swim-client</artifactId>
    <version>1.0.0</version>
</dependency>

JavaScript/TypeScript SDK v1.0.0

Location: sdk/javascript/

Install:

npm install @vatsim/swim-client

✅ Phase 4: Data Isolation (COMPLETE)

Added March 14, 2026.

All SWIM API endpoints now query exclusively from the SWIM_API database. Internal databases (VATSIM_TMI, VATSIM_ADL, VATSIM_REF, perti_site MySQL) are never accessed directly by API request handlers.

AOC Telemetry Support

Virtual Airlines can push flight sim telemetry via the ingest API:

Endpoints:

• POST /ingest/adl - Full flight data with telemetry
• POST /ingest/track - High-frequency position updates (1000/batch)

📁 File Structure

PERTI/
├── api/swim/v1/
│   ├── ingest/
│   │   ├── adl.php      # v3.2.0 - telemetry support
│   │   ├── track.php    # v1.2.0 - high-freq positions
│   │   └── metering.php
│   ├── ws/
│   │   └── WebSocketServer.php
│   ├── flights.php
│   └── positions.php
├── sdk/
│   ├── python/          # Python SDK v2.0.0
│   │   ├── swim_client/
│   │   │   ├── __init__.py
│   │   │   ├── client.py      # WebSocket client
│   │   │   ├── rest.py        # REST client
│   │   │   ├── models.py      # Data models
│   │   │   └── events.py      # Event types
│   │   ├── examples/
│   │   ├── pyproject.toml
│   │   └── README.md
│   ├── csharp/          # C# SDK v1.0.0
│   │   └── SwimClient/
│   │       ├── SwimRestClient.cs
│   │       ├── SwimWebSocketClient.cs
│   │       ├── Models/
│   │       ├── SwimClient.csproj
│   │       └── README.md
│   ├── java/            # Java SDK v1.0.0
│   │   └── swim-client/
│   │       ├── src/main/java/org/vatsim/swim/
│   │       │   ├── SwimRestClient.java
│   │       │   ├── SwimWebSocketClient.java
│   │       │   ├── SwimApiException.java
│   │       │   └── model/
│   │       ├── pom.xml
│   │       └── README.md
│   └── javascript/      # JavaScript/TypeScript SDK v1.0.0
│       ├── src/
│       │   ├── index.ts
│       │   ├── rest.ts
│       │   ├── websocket.ts
│       │   └── types.ts
│       ├── package.json
│       ├── tsconfig.json
│       └── README.md
└── docs/swim/
    ├── VATSWIM_API_Documentation.md
    ├── SWIM_TODO.md
    ├── openapi.yaml
    └── VATSIM_SWIM_API.postman_collection.json

💰 Cost Summary

🔗 API Endpoints

📝 Change Log

2026-03-25 Route Resolution API

• ✅ GET /routes/resolve — single route resolution via PostGIS expand_route()
• ✅ POST /routes/resolve — batch resolution (up to 50 routes) via expand_routes_batch()
• ✅ Origin/destination bookend auto-prepend/append logic
• ✅ Per-route independent error handling in batch mode
• ✅ ARTCC traversal with K-prefix normalization (KZNY → ZNY)
• ✅ Shared helpers: _build_full_route(), _format_result()

2026-03-14 Data Isolation (Phase 4 Complete)

• ✅ Migration 026 — swim_flights expansion (+34 cols, row_hash, 14 index drops)
• ✅ Migration 026 — 25 mirror tables (10 TMI + 4 flow + 4 CDM + 4 ref + 3 infra)
• ✅ Migration 026 — sp_Swim_BulkUpsert update (row-hash skip + change feed + 60 cols)
• ✅ swim_sync.php — add ~60 columns to ADL SELECT/JSON mapping
• ✅ swim_tmi_sync_daemon.php — new TMI sync daemon (5min operational, daily reference)
• ✅ refdata_sync_daemon.php — new reference data sync daemon (daily 06:00Z)
• ✅ All 48 SWIM endpoints migrated to SWIM_API-only queries
• ✅ PERTI_SWIM_ONLY optimization — skip non-SWIM DB connections
• ✅ WebSocket bug fix (pos.updated_at → pos.position_updated_utc)

2026-01-16 Session 5 (SDKs Complete)

• ✅ Enhanced Python SDK v2.0.0 - Added REST client, models
• ✅ Created C# SDK v1.0.0 - REST + WebSocket
• ✅ Created Java SDK v1.0.0 - REST + WebSocket
• ✅ Created JavaScript/TypeScript SDK v1.0.0 - REST + WebSocket
• ✅ Phase 3 COMPLETE

2026-01-16 Session 4 (AOC Telemetry)

• ✅ Added vertical_rate_fpm support to ingest/adl.php
• ✅ Added OOOI times support (out/off/on/in_utc)
• ✅ Added eta_utc/etd_utc support
• ✅ Fixed ingest/track.php database connection
• ✅ Updated Postman collection with AOC examples

2026-01-16 Session 3 (Phase 2 Complete)

• ✅ Database authentication implemented
• ✅ Tier-based connection limits
• ✅ Phase 2 COMPLETE

2026-01-16 Sessions 1-2

• ✅ WebSocket server deployed
• ✅ Python SDK (WebSocket only) created

🚀 Future Enhancements

📊 SDK Quick Reference

Python

from swim_client import SWIMRestClient, SWIMClient

rest = SWIMRestClient('api-key')
flights = rest.get_flights(dest_icao='KJFK')

ws = SWIMClient('api-key')
ws.subscribe(['flight.departed'])
ws.run()

C

using var rest = new SwimRestClient("api-key");
var flights = await rest.GetFlightsAsync(destIcao: "KJFK");

await using var ws = new SwimWebSocketClient("api-key");
ws.OnFlightDeparted += (s, e) => Console.WriteLine(e.Data.Callsign);
await ws.ConnectAsync();

Java

try (SwimRestClient rest = new SwimRestClient("api-key")) {
    List<Flight> flights = rest.getFlights("KJFK", null, "active");
}

SwimWebSocketClient ws = new SwimWebSocketClient("api-key");
ws.on("flight.departed", (data, ts) -> System.out.println(data.get("callsign")));
ws.connect();

JavaScript/TypeScript

const rest = new SwimRestClient('api-key');
const flights = await rest.getFlights({ dest_icao: 'KJFK' });

const ws = new SwimWebSocketClient('api-key');
ws.on('flight.departed', (data) => console.log(data.callsign));
await ws.connect();

Contact: dev@vatcscc.org