SugarNode-TS/source/system/module/mvc/mvc.ts

//HTTP服务
import HTTP = require('http');
import URL  = require('url');

//表单处理器
import formidable = require('formidable')
//路由控制器
import Router from './lib/router';
//模型控制器
import Module from './lib/module';
import ControllerClass from './lib/controller';
(global as any).CONTROLLER = ControllerClass;

const IncomingForm = formidable.IncomingForm;
class MVC {
    constructor(option:{root_path:string,server_port:number}) {
        //定义全局MVC框架变量
        const Root = `${SYSTEM.ROOTPATH}/${option.root_path}`;
        SYSTEM.MVC = {
            ROOT:Root,
            PORT:option.server_port,
            PATH:{
                MODULE:`${Root}/module`,
                CONTROLLER:`${Root}/controller`,
                VIEW:`${Root}/view`,
            },
            ROUTER_MAP:null,
            EJS:require('ejs')
        };
        //初始化Module控制器
        Module.init();
        //初始化MVC应用目录
        Object.keys(SYSTEM.MVC.PATH).forEach((path)=>{
            try{
                FILE.statSync(SYSTEM.MVC.PATH[path]);
            }catch(e:any){
                if(e.code=='ENOENT'){
                    FILE.mkdirsSync(SYSTEM.MVC.PATH[path]);
                }
            }
        });
        //加载路由Map文件或初始化
        const mapFile = `${SYSTEM.MVC.ROOT}/map.json`;
        try{
            FILE.statSync(mapFile);
            SYSTEM.MVC.ROUTER_MAP = JSON.parse(FILE.readFileSync(mapFile,'UTF-8'));
        }catch(e:any){
            if(e.code=='ENOENT'){
                FILE.writeFileSync(mapFile,'{}','UTF-8');
            }else{
                LOGGER.error(`MVC Router map file [${mapFile}] parse error!`);
            }
            SYSTEM.MVC.ROUTER_MAP = {};
        }
        try{
            HTTP.createServer(this._serverHandler).listen(SYSTEM.MVC.PORT);
            LOGGER.info(`Http MVC Server start at port [${SYSTEM.MVC.PORT}]`);
        }catch(e:any){
            LOGGER.error(`Http MVC Server start failed at port [${SYSTEM.MVC.PORT}]`);
            LOGGER.error(e.stack);
        }
    }
    protected _serverHandler(req?:HTTP.IncomingMessage,res?:HTTP.ServerResponse){
        if(!req) return;
        const RequestData:RequestData = {
            req,res,
            path:'' as string|null,
            COOKIE:{} as any,
            GET:{},
            POST:{},
            UPLOAD:{}
        }
        req.headers.cookie && req.headers.cookie.split(';').forEach((Cookie)=>{
            const parts:Array<string> = Cookie.split('=');
            let key = parts.shift();
            if (key){
                key = key.trim();
                const value = parts.join('=').trim();
                RequestData.COOKIE[key] = value;
            }
        });
        const URLParse = URL.parse(req.url as string,true);
        if(URLParse){
            RequestData.path = URLParse.pathname,
            RequestData.GET = URLParse.query;
        }
        if(req.method && req.method.toLowerCase()=='post'){
            new IncomingForm().parse(req, (err, fields, files)=>{
                RequestData.POST = fields;
                RequestData.UPLOAD = files;
                Router.run(RequestData);
            });
        }else{
            Router.run(RequestData);
        }
    }
}

module.exports = MVC;