64 lines
2.4 KiB
TypeScript
64 lines
2.4 KiB
TypeScript
import { genCode } from 'app/pubUtils/util';
|
|
import { MsgEncrypt } from "app/pubUtils/sysUtil";
|
|
import { Context } from 'egg';
|
|
|
|
module.exports = options => {
|
|
return async function parmsDecode(ctx: Context, next) {
|
|
let url = ctx.request.url;
|
|
ctx.logcode = genCode(10);
|
|
if(url.indexOf("/dev") == 0 || url.indexOf("/web") == 0 || url.indexOf("/cb") == 0) {
|
|
ctx.service.utils.log('INFO', `[${ctx.request.url}] [${ctx.logcode}] request: ${JSON.stringify(ctx.request.body)}`);
|
|
await next();
|
|
ctx.service.utils.log('INFO', `[${ctx.request.url}] [${ctx.logcode}] res: ${JSON.stringify(ctx.body)}`)
|
|
return;
|
|
}
|
|
if (options.threshold && ctx.length < options.threshold) return;
|
|
const reqBody = ctx.request.body;
|
|
const reqHeader = ctx.request.header;
|
|
|
|
console.log(ctx.app.config.decodeParm)
|
|
if(ctx.app.config.decodeParm == false) {
|
|
await next();
|
|
return;
|
|
}
|
|
|
|
if (!reqBody.data) return;
|
|
|
|
let msgEncrypt = new MsgEncrypt({ encodeK: reqHeader['k'], encodeV: reqHeader['v'] });
|
|
const { aesKey, aesIV } = msgEncrypt.getKv();
|
|
|
|
console.log(`encode str ${msgEncrypt.encryptMsg(reqBody)}`);
|
|
|
|
try {
|
|
let decryptResult = msgEncrypt.decryptMsg(reqBody.data);
|
|
if(!decryptResult) throw new Error('params parse err');
|
|
|
|
ctx.request.body = decryptResult;
|
|
console.log('req body', ctx.request.body);
|
|
ctx.service.utils.log('INFO', `[${ctx.request.url}] [${ctx.logcode}] request: ${JSON.stringify(ctx.request.body)}`)
|
|
} catch (e) {
|
|
console.error('parms parse err');
|
|
ctx.service.utils.log('ERROR', `[${ctx.request.url}] [${ctx.logcode}] request: parms parse err`)
|
|
|
|
}
|
|
|
|
try{
|
|
await next();
|
|
} catch(e) {
|
|
ctx.service.utils.log('ERROR', `[${ctx.request.url}] [${ctx.logcode}] err: ${(<Error>e).stack}`);
|
|
throw e;
|
|
}
|
|
const resBody = ctx.body;
|
|
console.log('return value:', JSON.stringify(resBody));
|
|
let resBodyWithEncrypt = msgEncrypt.encryptMsg(resBody);
|
|
if (resBodyWithEncrypt) {
|
|
ctx.body = { result: resBodyWithEncrypt, aesKey, aesIV };
|
|
ctx.service.utils.log('INFO', `[${ctx.request.url}] [${ctx.logcode}] res: ${JSON.stringify(resBody)}`)
|
|
} else {
|
|
ctx.body = { result: msgEncrypt.encryptMsg({ status: 3, data: 'internal err' }), aesKey, aesIV };
|
|
ctx.service.utils.log('ERROR', `[${ctx.request.url}] [${ctx.logcode}] res: ${resBody}`)
|
|
}
|
|
};
|
|
};
|
|
|