import { ConfigureAPI } from "../baseWellsClient";
import { rethrowAsHttpError } from "../errorHandlingUtils";
import {
  NdsAggregateItems,
  NdsItems,
  NdsAggregateRequest,
  NdsIngestionItems,
  NdsFilterRequest,
  NdsIngestion,
} from "src";

export class NdsAPI extends ConfigureAPI {
  public ingest = async (ndsIngestions: NdsIngestion[]): Promise<NdsItems> => {
    const path: string = this.getPath(`/nds`);
    const ingestionItems: NdsIngestionItems = { items: ndsIngestions };

    return await this.client
      .asyncPost<NdsItems>(path, { data: ingestionItems })
      .then((response) => response.data)
      .catch((err) => {
        throw rethrowAsHttpError(err);
      });
  };

  public list = async (ndsFilter: NdsFilterRequest): Promise<NdsItems> => {
    const path: string = this.getPath(`/nds/list`);
    return await this.client
      .asyncPost<NdsItems>(path, { data: ndsFilter })
      .then((response) => response.data)
      .catch((err) => {
        throw rethrowAsHttpError(err);
      });
  };

  public aggregate = async (
    request: NdsAggregateRequest
  ): Promise<NdsAggregateItems> => {
    const path: string = this.getPath(`/nds/aggregate`);
    return await this.client
      .asyncPost<NdsAggregateItems>(path, { data: request })
      .then((response) => response.data)
      .catch((err) => {
        throw rethrowAsHttpError(err);
      });
  };
}