root/lang/haxe/Tonyu2/httpd/Server.hx @ 35958

package httpd;
class Server {
        //public void onRequest(Request req,Response res) {}
        public static function start(port:Int, handler: Request->Response->Void) {
                var headp= ~/^(GET|POST|PUT|DELETE) ([^ ]+)/;
                var clenp= ~/^Content-Length: *([0-9]+)/i; 
        var s = new neko.net.Socket();
        s.bind(new neko.net.Host("localhost"),port);
        s.listen(1);
                var cnt=1;
        trace("Starting server...");
        while( true ) {
            var c : neko.net.Socket = s.accept();
            trace("Client connected...");
                        var method="";
                        var req=new Request();
                        var path="";
                        var len=0;
                        while( true ) {
                                var l = c.input.readLine();
                                
                                if (headp.match(l)) {
                                        method=headp.matched(1);
                                        path=headp.matched(2);
                                }
                                if (clenp.match(l)) {len=Std.parseInt(clenp.matched(1));   }
                                trace(""+cnt+": "+l);
                                if( l == "" ) {
                                        //s.close();
                                        //ar b=Bytes.alloc(len);
                                        if (method=="POST") {
                                                req.content=c.input.readString(len);
                                                break;
                                        }
                                        break;
                                }
                        }
                        var p;
                        var params=new Hash<String>();
                        var sp=req.content.split("&");
                        trace(req.content+"  -  "+sp.length+" / "+sp);
                        for (p in req.content.split("&")) {
                                var r=p.split("=");
                                r[1]=StringTools.urlDecode(r[1]);
                                params.set(r[0],r[1]);
                                trace(r[0] + " -> "+ r[1]);
                        }
                        
                        req.method=method;
                        req.path=path;
                        req.params=params;
                        
                        var res=new Response();                 
                        res.setHeader("Content-Type","text/html");
                        res.setHeader("Connection","close");
                        res.status="200 OK";
                        handler(req,res);
                        
                        res.setHeader("Content-Length",""+res.buf.length);
                        
                        trace(method+" - "+path+" - "+req);
                        
                        c.write("HTTP/1.1 "+res.status+"\n");
                        var k:String;
                        for (k in res.headerKeys()) {
                           c.write(k+": "+res.getHeader(k)+"\n");
                        }
            //c.write("Content-Length: "+res.buf.length+"\n");
                        //c.write("Content-Type: text/html; charset=utf-8\n");
                        //c.write("Connection: close\n");
                        c.write("\n");
                        c.write(res.buf);
            c.close();
        }
    
   }
}