import { RigOperationFilterRequest } from "src/model/rigOperationFilterRequest";
import { RigOperationIngestion } from "src/model/rigOperationIngestion";
import { RigOperationIngestionItems } from "src/model/rigOperationIngestionItems";
import { RigOperationItems } from "src/model/rigOperationItems";
import { ConfigureAPI } from "../baseWellsClient";
import { rethrowAsHttpError } from "../errorHandlingUtils";

export class RigOperationsAPI extends ConfigureAPI {
  public ingest = async (
    rigOperationIngestions: RigOperationIngestion[]
  ): Promise<RigOperationItems> => {
    const path: string = this.getPath(`/rigoperations`);
    const ingestionItems: RigOperationIngestionItems = {
      items: rigOperationIngestions,
    };

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

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