import { Page } from "puppeteer";
import puppeteer from "puppeteer-extra";
import StealthPlugin from "puppeteer-extra-plugin-stealth";
import Good from "./Good";
import Merchant from "./Merchant";

export default class BandH extends Merchant {
  public constructor() {
    super();
  }

  public get prettyName(): string {
    return "B&H";
  }

  public async checkGoods(): Promise<void> {
    if (this.goods.length <= 0) return;
    if (!this.hasActiveGood()) return;

    const verbose = this.store.config?.verbose;

    this.browser = await puppeteer
      .use(StealthPlugin())
      // HACK: required due to an issue with puppeteer types support in puppeteer-extra
      // see https://github.com/berstend/puppeteer-extra/issues/428#issuecomment-778679665 for details
      // @ts-ignore
      .launch({ headless: false })
      .catch((err) => {
        throw err;
      });

    const check = async (good: Good) => {
      if (!good.disabled) {
        const page = await this.browser?.newPage().catch((err) => {
          throw err;
        });
        if (page) {
          if (verbose) {
            this.log?.info(`checking for ${good.name} at ${good.URL}...`);
          }
          await this.priceCheck(page, good)
            .catch((err) => {
              this.log?.error(err.message);
            })
            .finally(async () => {
              await page.close().catch((err) => {
                this.log?.error(err.message);
                throw err;
              });
            });
        }
      } else {
        if (verbose) {
          this.log?.info(`skipping due to disabled configuration: ${good.URL}`);
        }
      }
    };

    await Promise.all(this.goods.map(check))
      .catch((err) => {
        this.log?.error(err.message);
      })
      .finally(async () => {
        await this.browser?.close().catch((err) => {
          throw err;
        });
      });
  }

  public async priceCheck(page: Page, good: Good): Promise<void> {
    await page
      .goto(good.URL, { waitUntil: "networkidle2" })
      .then((res) => {
        if (res.status() > 400) {
          throw this.responseError(res, good);
        }
      })
      .catch((err) => this.requestError(err, good));

    const priceString = await page
      .$eval("[data-selenium='pricingPrice']", (el) => el.textContent)
      .catch((err) => {
        this.handleNotFoundPrice(good);
        throw err;
      });

    if (!priceString) return;
    const price = this.parsePrice(priceString);

    this.handleFoundPrice(price, good);

    if (price < good.price) {
      await this.handleDiscount(price, good);
    }
  }
}