import { IProcessingRunInfo } from './i-processing-run-info';
import { ProcessingService } from '../providers/processing.service';
import { IProcessingRunDefinition } from './i-processing-run-definition';
import { IDesiredManifestEntry } from './i-desired-manifest-entry';
import { BehaviorSubject, Observable } from 'rxjs';
import { filter } from 'rxjs/operators';
import { IProcessingRunSummary } from './i-processing-run-summary';
import { IAchSummary } from './i-ach-summary';
export class ManifestEntry {
  batchUri: string;
  processingExecutionName: string;
  processingRunDefinitionUrl: string;

  private timeSubject = new BehaviorSubject<string>(null);
  private statusSubject = new BehaviorSubject<string>(null);
  private fiCountSubject = new BehaviorSubject<number>(null);
  private amountSubject = new BehaviorSubject<string>(null);
  private lockedSubject = new BehaviorSubject<boolean>(null);
  private exceptionsSubject = new BehaviorSubject<string>(null);
  private definitionSubject = new BehaviorSubject<IProcessingRunDefinition>(null);
  private processingRunSummarySubject = new BehaviorSubject<IProcessingRunSummary>(null);
  private processingRunInfoSubject = new BehaviorSubject<IProcessingRunInfo>(null);
  private achSummarySubject = new BehaviorSubject<IAchSummary>(null);
  private creditAmountSubject = new BehaviorSubject<number>(null);
  private debitAmountSubject = new BehaviorSubject<number>(null);

  time$: Observable<string> = this.timeSubject.asObservable();
  status$: Observable<string> = this.statusSubject.asObservable();
  fiCount$: Observable<number> = this.fiCountSubject.asObservable();
  amount$: Observable<string> = this.amountSubject.asObservable();
  wasLocked$: Observable<boolean> = this.lockedSubject.asObservable();
  exceptions$: Observable<string> = this.exceptionsSubject.asObservable();
  definition$: Observable<IProcessingRunDefinition> = this.definitionSubject.asObservable();
  processingRunSummary$: Observable<IProcessingRunSummary> = this.processingRunSummarySubject.asObservable();
  processingRunInfo$: Observable<IProcessingRunInfo> = this.processingRunInfoSubject.asObservable();
  achSummary$: Observable<IAchSummary> = this.achSummarySubject.asObservable();

  constructor(entry?: IDesiredManifestEntry, service?: ProcessingService) {
    if (!entry) {
      return;
    }
    this.batchUri = entry.BatchUri;
    this.processingExecutionName = entry.ProcessingExecutionName;
    this.processingRunDefinitionUrl = entry.ProcessingRunDefinitionUrl;
    this.timeSubject.next(entry.time);
    this.definition$ = entry.definition$;
    if (!this.definition$) {
      return;
    }
    this.definition$.pipe(filter(def => def !== null && def !== undefined)).subscribe(definition => {
      this.statusSubject.next(definition.Status);
      const execution = definition.Executions[definition.Executions.length - 1];
      this.lockedSubject.next(execution.WasLocked);
      // todo get brian to add these fields to the definition file
      this.amountSubject.next('0');
      this.exceptionsSubject.next('0');
      this.fiCountSubject.next(0);
      // this.processingRunSummary$ = service.getProcessingRunSummary$(execution.ProcessingRunSummaryUri);
      // this.processingRunInfo$ = service.getProcessingRunInfo$(execution.ProcessingRunInfoUri);
      // this.achSummary$ = service.getAchSummary$(execution.AchSummaryUri);
    });
  }
}