2017-07-10 20:02:44 +08:00
|
|
|
|
import yapi from '../yapi.js';
|
|
|
|
|
import projectModel from '../models/project.js'
|
|
|
|
|
import interfaceModel from '../models/interface.js'
|
|
|
|
|
import Mock from 'mockjs'
|
|
|
|
|
|
2017-07-05 16:17:58 +08:00
|
|
|
|
module.exports = async (ctx, next) => {
|
2017-07-10 20:02:44 +08:00
|
|
|
|
yapi.commons.log('mock Server running...')
|
2017-07-20 15:26:26 +08:00
|
|
|
|
let hostname = ctx.hostname;
|
2017-07-10 20:02:44 +08:00
|
|
|
|
let config = yapi.WEBCONFIG;
|
2017-07-11 12:12:43 +08:00
|
|
|
|
if(ctx.hostname === config.webhost){
|
2017-07-10 20:02:44 +08:00
|
|
|
|
if(next) await next();
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
let projectInst = yapi.getInst(projectModel), projects;
|
|
|
|
|
try{
|
|
|
|
|
projects = await projectInst.getByDomain(hostname);
|
|
|
|
|
}catch(e){
|
|
|
|
|
return ctx.body = yapi.commons.resReturn(null, 403, e.message);
|
|
|
|
|
}
|
2017-07-05 16:17:58 +08:00
|
|
|
|
|
2017-07-17 15:51:15 +08:00
|
|
|
|
let matchProject = false, maxBasepath = 0;
|
2017-07-10 20:02:44 +08:00
|
|
|
|
for(let i=0, l = projects.length; i< l; i++){
|
|
|
|
|
let project = projects[i];
|
|
|
|
|
if(ctx.path && ctx.path.indexOf(project.basepath) === 0 && project.basepath[project.basepath.length -1] === '/'){
|
2017-07-17 15:51:15 +08:00
|
|
|
|
matchProject.push(project);
|
|
|
|
|
if(project.basepath.length > maxBasepath){
|
|
|
|
|
maxBasepath = project.basepath.length;
|
|
|
|
|
matchProject = project;
|
|
|
|
|
}
|
2017-07-10 20:02:44 +08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2017-07-17 15:51:15 +08:00
|
|
|
|
if(matchProject === false){
|
2017-07-10 20:02:44 +08:00
|
|
|
|
return ctx.body = yapi.commons.resReturn(null, 400, '不存在的domain');
|
|
|
|
|
}
|
|
|
|
|
|
2017-07-17 15:51:15 +08:00
|
|
|
|
let project = matchProject, interfaceData;
|
2017-07-10 20:02:44 +08:00
|
|
|
|
let interfaceInst = yapi.getInst(interfaceModel);
|
|
|
|
|
try{
|
|
|
|
|
interfaceData = await interfaceInst.getByPath(project._id, ctx.path.substr(project.basepath.length));
|
|
|
|
|
|
|
|
|
|
if(!interfaceData || interfaceData.length === 0){
|
|
|
|
|
return ctx.body = yapi.commons.resReturn(null, 404, '不存在的api');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if(interfaceData.length > 1){
|
|
|
|
|
return ctx.body = yapi.commons.resReturn(null, 405, '存在多个api,请检查数据库');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
interfaceData = interfaceData[0];
|
|
|
|
|
|
|
|
|
|
if(interfaceData.res_body_type === 'json'){
|
|
|
|
|
return ctx.body = Mock.mock(
|
|
|
|
|
yapi.commons.json_parse(interfaceData.res_body)
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
return ctx.body = interfaceData.res_body;
|
|
|
|
|
}catch(e){
|
|
|
|
|
return ctx.body = yapi.commons.resReturn(null, 409, e.message);
|
|
|
|
|
}
|
|
|
|
|
|
2017-07-05 16:17:58 +08:00
|
|
|
|
|
|
|
|
|
}
|