import Axios, { AxiosRequestConfig, AxiosResponse } from "axios";
import { IBaseUrl } from "./base-urls/base-url-interfaces";
import { IEloquaCredentials } from "./eloqua-credentials";
import { Depth, IListRequestOptions, IListResponse } from "./rest-api-interfaces";

export class RestClient {
  constructor(
    private credentials: IEloquaCredentials,
    private baseUrls: IBaseUrl,
  ) {
  }

  public getList<T>(
    endpointPath: string,
    options?: IListRequestOptions,
  ): Promise<IListResponse<T>> {
    return Axios.get(
      this.makeStandardAbsoluteUrl(endpointPath),
      this.getRestConfig(options),
    ).then((response) => {
      return this.readResponse<IListResponse<T>>(response);
    }).catch((error) => {
      throw error;
    });
  }

  public getItem<T>(
    endpointPath: string,
    id: number,
    depth?: Depth,
  ): Promise<T> {
    const options = depth ? { depth } : null;
    return Axios.get(
      this.makeStandardAbsoluteUrl(endpointPath, id),
      this.getRestConfig(options),
    ).then((response) => {
      return this.readResponse<T>(response);
    }).catch((error) => {
      throw error;
    });
  }

  private getRestConfig(options?: { [key: string]: any } | null): AxiosRequestConfig {
    const config: AxiosRequestConfig = {
      auth: {
        password: this.credentials.password,
        username: `${this.credentials.siteName}\\${this.credentials.userName}`,
      },
    };

    if (options) {
      config.params = options;
    }

    return config;
  }

  private makeStandardAbsoluteUrl(apiPath: string, id?: number) {
    if (id) {
      return `${this.baseUrls.urls.base}${apiPath}/${id}`;
    } else {
      return `${this.baseUrls.urls.base}${apiPath}`;
    }
  }

  private readResponse<T>(response: AxiosResponse) {
    if (response.status === 200 && typeof response.data !== "undefined") {
      return response.data as T;
    } else {
      throw new Error(response.statusText);
    }
  }
}