import { sourceT as Source } from '../wonka_types.gen';

/* pipe definitions for source + operators composition */

function pipe<T, A>(source: Source<T>, op1: (source: Source<T>) => Source<A>): Source<A>;

function pipe<T, A, B>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>
): Source<B>;

function pipe<T, A, B, C>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>
): Source<C>;

function pipe<T, A, B, C, D>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>
): Source<D>;

function pipe<T, A, B, C, D, E>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>
): Source<E>;

function pipe<T, A, B, C, D, E, F>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  op6: (source: Source<E>) => Source<F>
): Source<F>;

function pipe<T, A, B, C, D, E, F, G>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  op6: (source: Source<E>) => Source<F>,
  op7: (source: Source<F>) => Source<G>
): Source<G>;

function pipe<T, A, B, C, D, E, F, G, H>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  op6: (source: Source<E>) => Source<F>,
  op7: (source: Source<F>) => Source<G>,
  op8: (source: Source<G>) => Source<H>
): Source<H>;

/* pipe definitions for source + operators + consumer composition */

function pipe<T, R>(source: Source<T>, consumer: (source: Source<T>) => R): R;

function pipe<T, A, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  consumer: (source: Source<A>) => R
): R;

function pipe<T, A, B, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  consumer: (source: Source<B>) => R
): R;

function pipe<T, A, B, C, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  consumer: (source: Source<C>) => R
): R;

function pipe<T, A, B, C, D, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  consumer: (source: Source<D>) => R
): R;

function pipe<T, A, B, C, D, E, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  consumer: (source: Source<E>) => R
): R;

function pipe<T, A, B, C, D, E, F, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  op6: (source: Source<E>) => Source<F>,
  consumer: (source: Source<F>) => R
): R;

function pipe<T, A, B, C, D, E, F, G, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  op6: (source: Source<E>) => Source<F>,
  op7: (source: Source<F>) => Source<G>,
  consumer: (source: Source<G>) => R
): R;

function pipe<T, A, B, C, D, E, F, G, H, R>(
  source: Source<T>,
  op1: (source: Source<T>) => Source<A>,
  op2: (source: Source<A>) => Source<B>,
  op3: (source: Source<B>) => Source<C>,
  op4: (source: Source<C>) => Source<D>,
  op5: (source: Source<D>) => Source<E>,
  op6: (source: Source<E>) => Source<F>,
  op7: (source: Source<F>) => Source<G>,
  op8: (source: Source<G>) => Source<H>,
  consumer: (source: Source<H>) => R
): R;

function pipe() {
  let x = arguments[0];
  for (let i = 1, l = arguments.length; i < l; i++)
    x = arguments[i](x);
  return x;
}

export { pipe };