12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
import {  Handler,  HandlerBuilderGetter,  HandlerGetter,  Res,} from "./handler.ts";import { Pipe } from "./pipe.ts";
export class Line implements Handler {  pipes: Pipe[];
  constructor() {    this.pipes = new Array<Pipe>();  }
  /**   * Handle the res, run pipes one by one.   * Run Single Pipe with timeout.   * Run Parallel Pipe directly.   */  async handle(res: Res): Promise<Res> {    for (const pipe of this.pipes) {      res = await pipe.handle(res);    }    return res;  }
  /** Handle the res, return a list of Res for every step*/  async handleVerbosely(res: Res): Promise<Res[]> {    let reses = [];    for (const pipe of this.pipes) {      res = await pipe.handle(res);      reses.push(JSON.parse(JSON.stringify(res)));    }    return reses;  }}
export function buildLine(  conf: any[],  builders?: HandlerBuilderGetter,  handlers?: HandlerGetter,): Line {  let line = new Line();
  for (const pipeConf of conf) {    line.pipes.push(new Pipe(pipeConf, builders, handlers));  }
  return line;}
export function buildLineWithJson(  jsonConf: string,  builders?: HandlerBuilderGetter,  handlers?: HandlerGetter,): Line {  const conf = JSON.parse(jsonConf);  return buildLine(conf, builders, handlers);}