import { PfeBusinessService, STATE_EXPRESSION } from '@allianz/ngx-pfe';
import { DfValueProviderService } from '@allianz/taly-core/dynamic-form';
import { Injectable, inject } from '@angular/core';
import { Observable, of } from 'rxjs';

@Injectable()
export class PfeDfValueProviderService implements DfValueProviderService {
  private pfeBusinessService = inject(PfeBusinessService);

  /**
   * If the value is JSON PATH EXPRESSION retrieves the state value else retrieves
   * the value
   * @param value Value that we want to check on state
   */
  getValue(value: unknown): Observable<unknown> {
    if (typeof value !== 'string') {
      return of(value);
    }

    if (value.startsWith(STATE_EXPRESSION)) {
      return this.pfeBusinessService.getObservableForExpressionKey(value, true);
    } else {
      return of(value);
    }
  }
}