import AConnector from 'pipes-nodejs-sdk/dist/lib/Connector/AConnector';
import ProcessDto from 'pipes-nodejs-sdk/dist/lib/Utils/ProcessDto';
import HttpMethods from 'pipes-nodejs-sdk/dist/lib/Transport/HttpMethods';
import { FORM } from 'pipes-nodejs-sdk/dist/lib/Application/Base/AApplication';
import Magento2Application, { MAGENTO_URL } from '../Magento2Application';
import { IOrderJson } from '../Connector/Magento2GetOrder';

// eslint-disable-next-line max-len
export const GET_ORDERS_ENDPOINT = 'index.php/rest/default/V1/orders?searchCriteria[page_size]={items_per_page}&searchCriteria[currentPage]={current_page}';

const ITEMS_PER_PAGE = 100;

export default class Magento2GetOrders extends AConnector {
  public getName = (): string => 'shoptet-get-order-pages';

  public async processAction(_dto: ProcessDto): Promise<ProcessDto> {
    const dto = _dto;
    const app = this._application as Magento2Application;
    const currentPage = Number(dto.getBatchCursor('1'));
    const { userName } = dto.jsonData as { userName: string };
    const appInstall = await this._getApplicationInstall(userName);
    const host = appInstall.getSettings()[FORM][MAGENTO_URL];
    const url = `${host}/${GET_ORDERS_ENDPOINT}`
      .replace('{items_per_page}', ITEMS_PER_PAGE.toString())
      .replace('{current_page}', currentPage.toString());

    const requestDto = await app.getRequestDto(
      dto,
      appInstall,
      HttpMethods.GET,
      url,
    );

    const res = await this._sender.send(requestDto, [200, 404]);
    const {
      // eslint-disable-next-line @typescript-eslint/naming-convention
      total_count,
      items,
    } = res.jsonBody as IResponseJson;

    if (currentPage < total_count) {
      dto.setBatchCursor((currentPage + 1).toString());
    }
    dto.jsonData = items as IOutputJson;

    return dto;
  }
}

interface IResponseJson {
  items: IOrderJson[],
  // eslint-disable-next-line @typescript-eslint/naming-convention
  total_count: number
}

type IOutputJson = IOrderJson[];