ztimson/weather-station
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ADSB enrichment

Browse Source
This commit is contained in:
Zakary Timson
2026-06-25 11:12:40 -04:00
parent 86cdaab197
commit f2afc09fac
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
client/src/services/airtraffic.ts
View File

@@ -7,6 +7,7 @@ import { fromLonLat } from 'ol/proj'
import { Style, Icon, Stroke } from 'ol/style' import { Style, Icon, Stroke } from 'ol/style'
import { Vector as VectorLayer } from 'ol/layer' import { Vector as VectorLayer } from 'ol/layer'
import { Vector as VectorSource } from 'ol/source' import { Vector as VectorSource } from 'ol/source'
import {adjustedInterval} from '@ztimson/utils';
const API = BASE + '/api' const API = BASE + '/api'
@@ -202,7 +203,7 @@ export class AirTrafficLayer {
private shapes: any = null private shapes: any = null
private data: any[] = [] private data: any[] = []
private clickHandler: ((e: any) => void) | null = null private clickHandler: ((e: any) => void) | null = null
private refreshTimer: ReturnType<typeof setInterval> | null = null private refreshTimer: any = null;
visible = false visible = false
constructor(map: Map) { this.map = map } constructor(map: Map) { this.map = map }
@@ -222,7 +223,7 @@ export class AirTrafficLayer {
this._draw() this._draw()
this._attachClick() this._attachClick()
this.refreshTimer = setInterval(async () => { this.refreshTimer = adjustedInterval(async () => {
await this._fetch() await this._fetch()
this._draw() this._draw()
this._refreshPopups() this._refreshPopups()

2
server/src/adsb.mjs
View File

@@ -46,7 +46,7 @@ async function importAircraftDb() {
const insert = db.prepare(`INSERT OR REPLACE INTO aircraft(icao, reg, type_code, flags, desc) VALUES (?,?,?,?,?)`); const insert = db.prepare(`INSERT OR REPLACE INTO aircraft(icao, reg, type_code, flags, desc) VALUES (?,?,?,?,?)`);
const run = db.transaction((rows) => { const run = db.transaction((rows) => {
for(const [icao, a] of Object.entries(rows)) { for(const [icao, a] of Object.entries(rows)) {
insert.run(icao.toUpperCase(), a.r || null, a.t || null, a.f || null, a.desc || null); insert.run(icao.toUpperCase().padStart(6, '0'), reg || null, type_code || null, flags || null, desc || null);
total++; total++;
} }
}); });