import {
  merge,
  Observable,
  Subject,
  timer,
  forkJoin,
  BehaviorSubject,
} from "rxjs";
import { ChangeDetectionStrategy, Component, OnDestroy } from "@angular/core";
import { WidgetConfig } from "../../widget.configuration";
import {
  WidgetComponent,
  WidgetConfiguration,
  WidgetConfigure,
  WidgetId,
} from "../../widget.metadata";
import { WidgetframeService } from "../../widgetframe/widgetframe.service";
import { CurrentLocaleService } from "../../../components/i18n/currentLocale.service";
import { Link } from "../../../components/hal/hal";
import { Router } from "@angular/router";
import { AppsLoaderService } from "../../../components/apps/apps-loader.service";
import {
  first,
  pluck,
  takeUntil,
  tap,
  throttleTime,
  mapTo,
  switchMap,
} from "rxjs/operators";
import { NgUnsubscribe } from "../../../ng-unsubscribe";
import { TranslateService } from "@ngx-translate/core";
import { HalService } from "../../../components/hal/hal.service";

/**
 * This class represents WorkListComponent.
 */
@WidgetComponent("nm-worklists")
@Component({
  selector: "nm-worklists",
  templateUrl: "./worklists.component.html",
  styleUrls: ["./worklists.component.scss"],
  changeDetection: ChangeDetectionStrategy.OnPush,
})
export class WorklistsComponentWidget implements OnDestroy {
  @WidgetConfiguration()
  public configuration: WidgetConfig;

  @WidgetId()
  public _id;

  public worklists = new BehaviorSubject<any[]>([]);
  public title: string;
  public infoText: string;
  private _refresh = new Subject<any>();
  private unsubscribe = NgUnsubscribe.create();
  public _refreshButtonVisible = false;

  constructor(
    private currentLocaleService: CurrentLocaleService,
    private widgetframeService: WidgetframeService,
    private appsLoaderService: AppsLoaderService,
    private router: Router,
    private translateService: TranslateService,
    private halService: HalService
  ) {}

  @WidgetConfigure()
  protected configureWidget(configuration: WidgetConfig) {
    let url = (<Link>configuration._links["data"]).href;
    merge(
      timer(0, this.configuration.configuration.interval).pipe(mapTo("timer")),
      this.currentLocaleService.getCurrentLocale().pipe(mapTo("locale")),
      this._refresh.pipe(mapTo("refresh"))
    )
      .pipe(
        takeUntil(this.unsubscribe),
        throttleTime(100),
        switchMap((type) => {
          if (
            this._refreshButtonVisible &&
            type !== "refresh" &&
            this.configuration.configuration.triggerDynamicSearch == "true"
          ) {
            return this.doRefresh().pipe(
              switchMap(() => this.widgetframeService.getData(url))
            );
          }
          return this.widgetframeService.getData(url);
        }),
        pluck("_embedded", "worklists"),
        tap(
          (worklistArray) =>
            (this._refreshButtonVisible = worklistArray.some(
              (_worklist) => _worklist.isDynamicWorklist
            ))
        )
      )
      .subscribe(this.worklists);
  }

  openWorklists(worklist) {
    // check if worklist app is installed
    this.appsLoaderService.apps.pipe(first()).subscribe((apps) => {
      if (apps.find((entry) => entry.identifier === "worklist")) {
        this.router.navigateByUrl(
          `/apps/worklist?worklist=${worklist.identifier}`
        );
      }
    });
  }

  refreshWorkList(worklist, event) {
    event.stopPropagation();
    this.halService
      .execute("refresh", worklist._actions.refresh)
      .subscribe(this._refresh);
  }

  doRefresh(): Observable<any> {
    const observables = this.worklists.value
      .filter((wl) => wl.isDynamicWorklist)
      .map((wl) => this.halService.execute("refresh", wl._actions.refresh));

    return forkJoin(...observables);
  }
  refreshAllDynamicWorkLists() {
    this.doRefresh().subscribe(this._refresh);
  }

  getLongSyncInfo(worklist): string {
    let pre = this.translateService.instant("web.label.last-synchronization");
    return pre + ": " + new Date(worklist.lastModified).toLocaleString();
  }

  ngOnDestroy() {
    if (this.unsubscribe) {
      this.unsubscribe.destroy();
    }
  }
}