import pipeline, { Middleware } from './pipeline';

const step1: Middleware<any, any> = (req, res, next) => {
    if (req.body) {
        console.log(`STEP 1: \n req: ${JSON.stringify(req)}\n res: ${JSON.stringify(res)}`);
        next();
    }
}

const step2: Middleware<any, any> = async (req, res, next) => {
    await setTimeout(() => {
        res.status = 200;
        console.log(`STEP 2: \n req: ${JSON.stringify(req)}\n res: ${JSON.stringify(res)}`);
        next();
    }, 2000);
}

const step3: Middleware<any, any> = (req, res, next) => {
    console.log(`STEP 3: \n req: ${JSON.stringify(req)}\n res: ${JSON.stringify(res)}`);
    next();
}

const req = { body: {}};
const res = {};

pipeline(req, res, step1, step2, step3);