import * as fs from 'fs'; import { ILocalUser } from '../../models/user'; import { IApp } from '../../models/app'; import { IEndpointMeta } from './endpoints'; type Params = { [P in keyof T['params']]: T['params'][P]['transform'] extends Function ? ReturnType : ReturnType[0]; }; export default function (meta: T, cb: (params: Params, user: ILocalUser, app: IApp, file?: any, cleanup?: Function) => Promise): (params: any, user: ILocalUser, app: IApp, file?: any) => Promise { return (params: any, user: ILocalUser, app: IApp, file?: any) => { function cleanup() { fs.unlink(file.path, () => {}); } if (meta.requireFile && file == null) return Promise.reject('file required'); const [ps, pserr] = getParams(meta, params); if (pserr) { if (file) cleanup(); return Promise.reject(pserr); } return cb(ps, user, app, file, cleanup); }; } function getParams(defs: T, params: any): [Params, Error] { const x: any = {}; let err: Error = null; Object.entries(defs.params).some(([k, def]) => { const [v, e] = def.validator.get(params[k]); if (e) { err = new Error(e.message); err.name = 'INVALID_PARAM'; (err as any).param = k; return true; } else { if (v === undefined && def.default) { x[k] = def.default; } else { x[k] = v; } if (def.transform) x[k] = def.transform(x[k]); return false; } }); return [x, err]; }