TrackedLiveQuery.ts

import { RecordIdentity } from '@orbit/data';
import { SyncLiveQuery } from '@orbit/record-cache';

import { consume, dirty } from './tracked';
import { ReadonlyArray } from './readonly-array';

export class LiveQueryArray<M extends RecordIdentity> extends ReadonlyArray<M> {
  private readonly _liveQuery: SyncLiveQuery;
  private get _content(): M[] {
    return this._liveQuery.query() as M[];
  }

  readonly unsubscribe: () => void;

  [Symbol.iterator]() {
    consume(this);
    return this._content[Symbol.iterator]();
  }

  getAt(i: number): M | undefined {
    consume(this);
    return this._content[i];
  }

  constructor(liveQuery: SyncLiveQuery) {
    super();
    this._liveQuery = liveQuery;
    this.unsubscribe = this._liveQuery.subscribe(() => {
      dirty(this);
    });
  }
}