import { HttpClient, HttpParams } from '@angular/common/http';
import { Injectable, inject } from '@angular/core';
import { Observable } from 'rxjs';

import { DataTableQuery, DataTableResult } from '../../../../shared/components/data-table/data-table.types';
import {
  CreateExchangeRateRequest,
  ExchangeRateDto,
  ExchangeRateLookupDto,
  UpdateExchangeRateRequest,
  UpdateExchangeRateStatusRequest
} from '../models/exchange-rate.model';
import { EXCHANGE_RATE_ENDPOINTS } from './exchange-rate.endpoints';

@Injectable({
  providedIn: 'root'
})
export class ExchangeRateService {
  private readonly http = inject(HttpClient);

  getExchangeRateDataTable(
    query: DataTableQuery & Record<string, unknown>
  ): Observable<DataTableResult<ExchangeRateDto>> {
    return this.http.post<DataTableResult<ExchangeRateDto>>(EXCHANGE_RATE_ENDPOINTS.dataTable, query);
  }

  createExchangeRate(request: CreateExchangeRateRequest): Observable<ExchangeRateDto> {
    return this.http.post<ExchangeRateDto>(EXCHANGE_RATE_ENDPOINTS.create, request);
  }

  updateExchangeRate(id: string, request: UpdateExchangeRateRequest): Observable<ExchangeRateDto> {
    return this.http.put<ExchangeRateDto>(EXCHANGE_RATE_ENDPOINTS.update(id), request);
  }

  updateStatus(id: string, request: UpdateExchangeRateStatusRequest): Observable<ExchangeRateDto> {
    return this.http.patch<ExchangeRateDto>(EXCHANGE_RATE_ENDPOINTS.changeStatus(id), request);
  }

  deleteExchangeRate(id: string): Observable<void> {
    return this.http.delete<void>(EXCHANGE_RATE_ENDPOINTS.delete(id));
  }

  getExchangeRateById(id: string): Observable<ExchangeRateDto> {
    return this.http.get<ExchangeRateDto>(EXCHANGE_RATE_ENDPOINTS.getById(id));
  }

  autocomplete(term: string | null, limit = 10): Observable<readonly ExchangeRateLookupDto[]> {
    let params = new HttpParams().set('limit', limit);
    const normalizedTerm = term?.trim();

    if (normalizedTerm) {
      params = params.set('term', normalizedTerm);
    }

    return this.http.get<readonly ExchangeRateLookupDto[]>(EXCHANGE_RATE_ENDPOINTS.autocomplete, { params });
  }
}