import type {
  Application,
  FeathersService,
  Id,
  NullableId,
  Paginated,
  Params,
  Service
} from '@feathersjs/feathers';
import type { OperatorFunction } from 'rxjs';
import { Observable } from 'rxjs';

type ListStrategy = any;

export interface Options {
  idField: string;
  dataField?: string;
  sorter?: (query: any, options: any) => any;

  /**
   * a filter function factory
   */
  matcher?: (query: any) => (element: any) => boolean;

  listStrategies?: { [name: string]: ListStrategy };
  listStrategy?: 'always' | 'smart' | 'never' | string | ListStrategy;
  pipe?: OperatorFunction<any, any> | Array<OperatorFunction<any, any>>;
}

export interface ReactiveServiceMixin<T> {
  created$: Observable<T>;
  updated$: Observable<T>;
  patched$: Observable<T>;
  removed$: Observable<T>;
  reset$: Observable<T>;
  never(source$: Observable<T>): Observable<T>;
  always(source$: Observable<T>, options: Options, args: any): Observable<T>;
  smart(source$: Observable<T>, options: Options, args: any): Observable<T>;
}

declare module '@feathersjs/feathers' {
  interface ServiceAddons<A = Application, S = Service> {
    watch(options?: Partial<Options>): ReactiveService<S>; // TODO: Was <T>, correct?
    rx(options?: Partial<Options>): FeathersService; // Service<S>; // TODO: Was <T>, correct?
    reset(): void; // TODO: TODO: Added during typescript migration - check!
  }

  interface ReactiveService<T> {
    /**
     * Retrieves a list of all resources from the service.
     * Provider parameters will be passed as params.query
     */
    find(params?: Params): Observable<T | T[] | Paginated<T>>;

    /**
     * Retrieves a single resource with the given id from the service.
     */
    get(id: Id | string, params?: Params): Observable<T>;

    /**
     * Creates a new resource with data.
     */
    create(data: Partial<T[]>, params?: Params): Observable<T[]>;
    create(data: Partial<T>, params?: Params): Observable<T>;

    /**
     * Replaces the resource identified by id with data.
     * Update multiples resources with id equal `null`
     */
    update(id: NullableId, data: T, params?: Params): Observable<T | T[]>;

    /**
     * Merges the existing data of the resource identified by id with the new data.
     * Implement patch additionally to update if you want to separate between partial and full updates and support the PATCH HTTP method.
     * Patch multiples resources with id equal `null`
     */
    patch(
      id: NullableId,
      data: Partial<T>,
      params?: Params
    ): Observable<T | T[]>;

    /**
     * Removes the resource with id.
     * Delete multiple resources with id equal `null`
     */
    remove(id: NullableId, params?: Params): Observable<T | T[]>;
  }
}