ISA-Frontend/libs/remission/data-access/src/lib/services/remission-reason.service.ts

import { inject, Injectable } from '@angular/core';
import { ReturnService } from '@generated/swagger/inventory-api';
import { FetchReturnReasonParams, FetchReturnReasonSchema } from '../schemas';
import { ResponseArgsError, takeUntilAborted } from '@isa/common/data-access';
import { firstValueFrom } from 'rxjs';
import { KeyValueStringAndString } from '../models';

@Injectable({ providedIn: 'root' })
export class RemissionReasonService {
  #returnService = inject(ReturnService);

  async fetchReturnReasons(
    params: FetchReturnReasonParams,
    abortSignal?: AbortSignal,
  ): Promise<KeyValueStringAndString[]> {
    const { stockId } = FetchReturnReasonSchema.parse(params);

    let req$ = this.#returnService.ReturnGetReturnReasons({ stockId });

    if (abortSignal) {
      req$ = req$.pipe(takeUntilAborted(abortSignal));
    }

    const res = await firstValueFrom(req$);

    if (res.error) {
      throw new ResponseArgsError(res);
    }

    return res.result as KeyValueStringAndString[];
  }
}