Method tick

server/src/datasource.ts:278–314

()

  }

  private async tick(): Promise<void> {
    const now = Date.now();
    if (this.o.source === "api" && now < this.apiBackoffUntil) {
      const waitS = Math.ceil((this.apiBackoffUntil - now) / 1000);
      this.status = {
        ...this.status,
        ok: false,
        message: `API rate limited — retrying in ${waitS}s`,
      };
      this.o.onStatus(this.status);
      return;
    }
    const primary = await this.fetchList(this.o.source, now);
    if (primary === null) {
      this.status = {
        ...this.status,
        ok: false,
        message: this.lastError ?? "source fetch failed",
      };
      this.o.onStatus(this.status);
      return;
    }
    const supplement = this.o.source === "radio" && this.o.supplementApi;
    const merged = supplement ? mergeSources(primary, this.lastApi) : primary;
    for (const ac of merged) this.enrich(ac, now);
    this.last = merged;
    this.pruneSticky(now);
    this.status = {
      source: this.o.source,
      ok: true,
      count: merged.length,
      lastOk: now,
      message: supplement ? `radio + ${this.lastApi.length} via API` : undefined,
    };
    this.o.onSnapshot(now, merged);
    this.o.onStatus(this.status);
  }

  private enrich(ac: Aircraft, now: number): void {
    // Instant table lookups first.