import type {
  ProductResponse,
  ResourcePage,
  ShopperCatalogResource,
} from "@moltin/sdk";
import { wait300 } from "../lib/product-helper";
import { getEpccImplicitClient } from "../lib/epcc-implicit-client";
import { Moltin as EPCCClient } from "@moltin/sdk";

export async function getProductById(
  productId: string,
  client?: EPCCClient
): Promise<ShopperCatalogResource<ProductResponse>> {
  return (client ?? getEpccImplicitClient()).ShopperCatalog.Products.With([
    "main_image",
    "files",
    "component_products",
  ]).Get({
    productId,
  });
}

export function getAllProducts(
  client?: EPCCClient
): Promise<ProductResponse[]> {
  return _getAllProductPages(client)();
}

const _getAllPages =
  <T, I>(
    nextPageRequestFn: (
      limit: number,
      offset: number,
      client?: EPCCClient
    ) => Promise<ResourcePage<T, I>>
  ) =>
  async (
    offset: number = 0,
    limit: number = 25,
    accdata: T[] = []
  ): Promise<T[]> => {
    const requestResp = await nextPageRequestFn(limit, offset);
    const {
      meta: {
        page: newPage,
        results: { total },
      },
      data: newData,
    } = requestResp;

    const updatedOffset = offset + newPage.total;
    const combinedData = [...accdata, ...newData];
    if (updatedOffset < total) {
      return wait300.then(() =>
        _getAllPages(nextPageRequestFn)(updatedOffset, limit, combinedData)
      );
    }
    return Promise.resolve(combinedData);
  };

const _getAllProductPages = (client?: EPCCClient) =>
  _getAllPages((limit = 25, offset = 0) =>
    (client ?? getEpccImplicitClient()).ShopperCatalog.Products.Limit(limit)
      .Offset(offset)
      .All()
  );