import qs from 'qs'
import type { ApiClient } from './ApiClient'
import type { CrudApi, GetByIdQuery, ListQuery, Paginated } from './types'
export type {
  WhereClause,
  IncludeItem,
  ListQuery,
  GetByIdQuery,
  Paginated,
  HasGetMany,
  HasGetById,
  HasCreate,
  HasUpdateById,
  HasDeleteById,
  CrudApi,
} from './types'

export class BaseCrudApi<
  TResponse,
  TCreate,
  TUpdate = TCreate,
  TQuery extends ListQuery<TResponse> = ListQuery<TResponse>,
> implements CrudApi<TResponse, TCreate, TUpdate, TQuery> {
  public readonly client: ApiClient
  public readonly basePath: string

  constructor(client: ApiClient, basePath: string) {
    this.client = client
    this.basePath = basePath.replace(/\/$/, '')
    this.getMany = this.getMany.bind(this)
    this.getOne = this.getOne.bind(this)
    this.getById = this.getById.bind(this)
    this.create = this.create.bind(this)
    this.updateById = this.updateById.bind(this)
    this.deleteById = this.deleteById.bind(this)
  }

  getMany(
    query: TQuery & { paginate: false },
    headers?: Record<string, string>,
  ): Promise<TResponse[]>
  getMany(
    query?: TQuery & { paginate?: true },
    headers?: Record<string, string>,
  ): Promise<Paginated<TResponse>>
  getMany(
    query?: TQuery,
    headers?: Record<string, string>,
  ): Promise<Paginated<TResponse> | TResponse[]> {
    const queryString = query ? `?${qs.stringify(query)}` : ''
    return this.client.get<Paginated<TResponse> | TResponse[]>(
      `${this.basePath}${queryString}`,
      headers,
    )
  }

  /**
   * Returns the first resource matching the query, or `null` when none match.
   * Convenience over `getMany` with `limit: 1`.
   * @permissions $resourceName.view
   */
  async getOne(query?: TQuery, headers?: Record<string, string>): Promise<TResponse | null> {
    const results = await this.getMany(
      { ...query, limit: 1, paginate: false } as TQuery & { paginate: false },
      headers,
    )
    return results[0] ?? null
  }

  /**
   * Returns a single resource by ID.
   * @permissions $resourceName.view
   */
  getById(
    id: string,
    query?: GetByIdQuery<TResponse>,
    headers?: Record<string, string>,
  ): Promise<TResponse> {
    const queryString = query ? `?${qs.stringify(query)}` : ''
    return this.client.get<TResponse>(`${this.basePath}/${id}${queryString}`, headers)
  }

  /**
   * Creates a new resource.
   * @permissions $resourceName.create
   */
  create(body: TCreate, headers?: Record<string, string>): Promise<TResponse> {
    return this.client.post<TResponse, TCreate>(this.basePath, body, headers)
  }

  /**
   * Updates an existing resource by ID.
   * @permissions $resourceName.update
   */
  updateById(id: string, body: TUpdate, headers?: Record<string, string>): Promise<TResponse> {
    return this.client.put<TResponse, TUpdate>(`${this.basePath}/${id}`, body, headers)
  }

  /**
   * Deletes a resource by ID.
   * @permissions $resourceName.delete
   */
  deleteById(id: string, headers?: Record<string, string>): Promise<TResponse> {
    return this.client.delete<TResponse>(`${this.basePath}/${id}`, headers)
  }
}