import { HttpError } from "@cognite/sdk-core";
import { TimeMeasurement } from "src/model/timeMeasurement";
import { TimeMeasurementFilterRequest } from "src/model/timeMeasurementFilterRequest";
import { TimeMeasurementItems } from "src/model/timeMeasurementItems";
import { ConfigureAPI } from "../baseWellsClient";
import { rethrowAsHttpError } from "../errorHandlingUtils";

export class TimeMeasurementsAPI extends ConfigureAPI {
  public ingest = async (
    ingestions: TimeMeasurement[]
  ): Promise<TimeMeasurementItems> => {
    const path = this.getPath("/measurements/time");
    const ingestionItems: TimeMeasurementItems = { items: ingestions };

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

  public list = async (
    filter: TimeMeasurementFilterRequest
  ): Promise<TimeMeasurementItems> => {
    const path = this.getPath(`/measurements/time/list`);

    return await this.client
      .asyncPost<TimeMeasurementItems>(path, { data: filter })
      .then((response) => response.data)
      .catch((err) => {
        throw new HttpError(err.status, err.data.error.message, {});
      });
  };
}