Class DataCollection

www/data-module/src/data/DataCollection.ts:30–209

}

export class DataCollection<DataType extends BaseClass> implements IDataCollection {
  restPath!: string;
  query!: Query;
  accessor!: IDataAccessor;
  socketPath!: string;
  endpoint!: string;
  socketPathRE!: RegExp;
  queryExecutor!: DataQuery;
  descriptor!: IDataDescriptor<DataType>;
  webSocketClient!: WebSocketClient;
  isOpen: boolean = false;
  internalId: number = 0;

  @observable resolved: boolean = false;
  // does not contain elements that have been filtered out and off limits
  @observable array: IObservableArray<DataType> = observable<DataType>([]);
  // does not contain elements that have been filtered out
  @observable byId: ObservableMap<string, DataType> = observable.map<string, DataType>();

  // includes IDs of all elements received before resolved becomes true. This is necessary to
  // track which elements have been received, but filtered out.
  idsBeforeResolve = new Set<string>();

  constructor(internalId: number = 0) {
    makeObservable(this);
    this.internalId = internalId;
  }

  listener(data: any) {
    const key = data.k;
    const message = data.m;
    // Test if the message is for me
    if (this.socketPathRE.test(key)) {
      this.put(message);
      this.recomputeQuery();
    }
  }

  isValid() {
    if (this.accessor === undefined) {
      return false;
    }
    return this.accessor.isOpen();
  }

  isResolved() {
    return this.resolved;
  }

  subscribe() {
    return this.webSocketClient.subscribe(this.socketPath, this);
  }

  open(restPath: string, query: Query, accessor: IDataAccessor,
       descriptor: IDataDescriptor<DataType>, webSocketClient: WebSocketClient) {
    this.restPath = restPath;
    this.query = query;
    this.accessor = accessor;