state.service.ts

import {EventEmitter, Injectable} from '@angular/core';
import {ApiService, LshData, Parameters, RawData, TableInfoData} from './api.service';

@Injectable({
  providedIn: 'root'
})
/**
 * This service acts as the state of the entire application. Components can subscribe to EventEmitters within this state to update their
 * contents.
 */
export class StateService {
  /**
   * These are all LSH specific variables. The variables can be accessed using the getters and setters
   */
  private _rawData: RawData[];
  private _lshData: LshData;
  private _queryWindow: number[][];
  private _weights: number[];
  private _labels = {};
  private _lshParameters: number[];
  public windowSize = 120;
  public nrOfTables = 5;
  public hashSize = 5;
  public stepSize = 200;

  /**
   * These are all GUI variables
   */
  public loadingProgress = 0;
  public querySelectionMode = true;
  private _currentTab: number;
  private _sliderValue;

  /**
   * These are all EventEmitters. Subscribe to these if you want to be informed about an update in state.
   */
  public onNewData: EventEmitter<void> = new EventEmitter<void>();
  public onNewWindows: EventEmitter<void> = new EventEmitter<void>();
  public onNewQuery: EventEmitter<void> = new EventEmitter<void>();
  public onNewLshData: EventEmitter<void> = new EventEmitter<void>();

  public onNewLabels: EventEmitter<void> = new EventEmitter<void>();
  public onNewTab: EventEmitter<void> = new EventEmitter<void>();
  public onNewSlider: EventEmitter<number> = new EventEmitter<number>();

  constructor(private api: ApiService) {
     this.initialize();
  }

  /**
   * This function initializes the application. It retrieves the raw data and creates windows.
   */
  async initialize(): Promise<void> {
    this.loadingProgress = 0;
    await this.getRawData();
    this.loadingProgress = 50;
    await this.createWindows();
    this.loadingProgress = 100;
  }

  /**
   * This function resets the application. It re-creates the windows
   */
  async reset(): Promise<void> {
    this.loadingProgress = 50;
    await this.createWindows();
    this.loadingProgress = 100;
  }

  /**
   * This function retrieves the raw data
   */
  async getRawData(): Promise<void> {
    this.rawData = await this.api.readFile();
  }

  /**
   * This function creates the windows on the server side
   */
  async createWindows(): Promise<void> {
    await this.api.createWindows(this.parameters);
    this.onNewWindows.emit();
  }

  /**
   * This function performs the first iteration of LSH
   */
  async lshInitial(): Promise<void> {
    this._weights = Array(this._queryWindow.length).fill(1);
    this.lshData = await this.api.lshInitial(this._queryWindow);
    this._lshParameters = this.lshData.parameters;
  }

  /**
   * This function performs every other iteration of LSH
   */
  async update(labels, hashFunctions): Promise<void> {
    this._weights = await this.api.getWeights(this._queryWindow, labels, this._weights, hashFunctions);
    this.lshData = await this.api.lshUpdate(this._queryWindow, this._weights, this._lshParameters);
  }

  /**
   * This function retrieves additional information given a table
   */
  async getTableInfo(table: number[][]): Promise<TableInfoData> {
    return await this.api.getTableInfo(table);
  }

  /**
   * This function retrieves the query
   */
  async getQueryWindow(windowIndex: number | {[index: number]: boolean}): Promise<number[][]> {
    this.queryWindow = await this.api.getQueryWindow(windowIndex);
    console.log(this.queryWindow);
    return this._queryWindow;
  }

  /**
   * This function retrieves the window given the window index
   */
  async getWindow(indices: number[]): Promise<number[][][]> {
    return await this.api.getWindowByIndices(indices);
  }

  /**
   * These are all setters and getters
   */
  public set rawData(v: RawData[]) {
    this._rawData = v;
    console.log(this._rawData);
    this.onNewData.emit();
  }

  public get rawData(): RawData []{
    return this._rawData;
  }

  public set lshData(v: LshData) {
    console.log(v);
    this._lshData = v;
    this.onNewLshData.emit();
  }

  public get lshData(): LshData {
    return this._lshData;
  }

  public set labels(v) {
    this._labels = v;
    this.onNewLabels.emit();
  }

  public get labels() {
    return this._labels;
  }

  public set currentTab(v: number) {
    this._currentTab = v;
    this.onNewTab.emit();
  }

  public get currentTab(): number {
    return this._currentTab;
  }

  public set sliderValue(v: number) {
    this._sliderValue = v;
    this.onNewSlider.emit(v);
  }

  public get sliderValue(): number {
    return this._sliderValue;
  }

  public set queryWindow(v: number[][]) {
    this._queryWindow = v;
    this.onNewQuery.emit();
  }

  public get queryWindow(): number[][] {
    return this._queryWindow;
  }

  public get lshParameters(): number[] {
    return this._lshParameters;
  }

  public get parameters(): Parameters {
    return {
      windowsize: this.windowSize,
      hashsize: this.hashSize,
      tablesize: this.nrOfTables,
      stepsize: this.stepSize
    };
  }
}