import { Component, OnInit, OnDestroy } from "@angular/core";
import { Subject, Subscription, ReplaySubject } from "rxjs";
import { AppdataStore } from "../../../components/appdata/appdata.store";
import { HalService } from "../../../components/hal/hal.service";
import { FormGroup } from "@angular/forms";
import { Router } from "@angular/router";
import { TranslateService } from "@ngx-translate/core";
import { WidgetframeService } from "../../widgetframe/widgetframe.service";
import { WidgetConfig } from "../../widget.configuration";
import {
  WidgetComponent,
  WidgetId,
  WidgetConfiguration,
  WidgetConfigure,
  WidgetInput,
  WidgetOutput,
} from "../../widget.metadata";
import { NotificationsService } from "../../../components/notifications/services/notifications.service";

declare var require: any;

/**
 * Used in iPIM Analytics.
 *
 * Uses message input channel to recive a productNo and transfers it to backend
 */
@WidgetComponent("nm-linkexport")
@Component({
  selector: "nm-linkexport",
  template: ` <div></div> `,
})
export class LinkExportComponent implements OnDestroy {
  @WidgetConfiguration()
  private configuration: WidgetConfig;

  // The message input from the kibana iframe
  @WidgetInput("messages-output")
  private inputChannel: Subject<any> = new Subject<any>();

  @WidgetId()
  private _id: string;

  public href: Subject<String> = new ReplaySubject<String>(1);
  public formGroup: FormGroup;
  public action;
  public actionName;

  private subscription: Subscription;

  constructor(
    private _widgetframeService: WidgetframeService,
    private _halService: HalService,
    private _notificationService: NotificationsService,
    private _appdataStore: AppdataStore,
    private router: Router,
    private translateService: TranslateService
  ) {
    this.formGroup = new FormGroup({});
  }

  @WidgetConfigure()
  protected configureWidget(configuration: WidgetConfig) {
    this.actionName = this.configuration.configuration["actionName"];
    this.subscription = this.inputChannel.asObservable().subscribe((resp) => {
      if (this.configuration.configuration["actionHref"]) {
        this._widgetframeService
          .getData(this.configuration.configuration["actionHref"])
          .subscribe((data) => {
            if (this.actionName === resp.data.action) {
              this.action = data._actions[this.actionName];
              var uriTemplates = require("uri-templates");
              this.action.href = uriTemplates(this.action.href).fill({
                product: resp.data.data,
              });
              this._halService
                .execute(this.actionName, this.action)
                .subscribe((resp) => {
                  if (resp.response.message !== undefined) {
                    this._notificationService.success(
                      resp.response.title,
                      resp.response.message
                    );
                  } else {
                    this._notificationService.success(
                      this.translateService.instant("message.success.title"),
                      this.translateService.instant("message.success.body")
                    );
                  }
                });
            }
          });
      }
    });
  }

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