Function genPipelineBackOut

src/back/SocketServerMiddleware.ts:18–48

(...middlewares: MiddlewareRes[])

}

export function genPipelineBackOut(...middlewares: MiddlewareRes[]): PipelineRes {
  const stack: MiddlewareRes[] = middlewares;

  const push: PipelineRes['push'] = (...middlewares) => {
    stack.push(...middlewares);
  };

  const execute: PipelineRes['execute'] = async (context) => {
    let prevIndex = -1;

    const runner = async (index: number): Promise<void> => {
      if (index === prevIndex) {
        throw new Error('next() called multiple times');
      }

      prevIndex = index;

      const middleware = stack[index];

      if (middleware) {
        await middleware(context, () => {
          return runner(index + 1);
        });
      }
    };

    await runner(0);
  };

  return { push, execute };
}