--- trunk/lib/Frey/Server.pm 2008/06/30 07:06:11 34 +++ trunk/lib/Frey/Server.pm 2008/07/02 12:36:59 48 @@ -4,7 +4,7 @@ use warnings; use Continuity; -use Continuity::REPL; +#use Continuity::REPL; use Data::Dump qw/dump/; use base 'Frey'; @@ -17,59 +17,42 @@ #$repl = Continuity::REPL->new; $server = Continuity->new( - port => 16001, - path_session => 1, - cookie_session => 'sid', - callback => \&main, + port => 16001, + path_session => 1, + cookie_session => 'sid', + callback => \&main, + debug_level => 1, + staticp => sub { $_[0]->url =~ m/\.(jpg|jpeg|gif|png|css|ico|js|html?)$/ }, ); -$server->debug_level( 2 ); -sub run { +sub run { $server->loop; } -my @callbacks; -my $callback_count; - -sub gen_link { - my ($text, $code) = @_; - $callbacks[$callback_count++] = $code; - return qq{$text}; -} - -sub process_links { - my $request = shift; - my $cb = $request->param('cb'); - if (exists $callbacks[$cb]) { - $callbacks[$cb]->($request); - delete $callbacks[$cb]; - } -} - # This is the main entrypoint. We are looking for one of three things -- a # pushstream, a sent message, or a request for the main HTML. We delegate each # of these cases, none of which will return (they all loop forever). sub main { - my ($req) = @_; + my ($req) = @_; - my $path = $req->request->url->path; - warn "REQUEST: $path\n"; + my $path = $req->request->url->path; + warn "REQUEST: $path\n"; warn $req->request->header('User_Agent'); #warn dump( $req ); - # If this is a request for the pushtream, then give them that - if($path =~ /pushstream/) { - pushstream($req); - } + # If this is a request for the pushtream, then give them that + if($path =~ /pushstream/) { + pushstream($req); + } - # If they are sending us a message, we give them a thread for that too - if($path =~ /sendmessage/) { - send_message($req); - } + # If they are sending us a message, we give them a thread for that too + if($path =~ /sendmessage/) { + send_message($req); + } - # Otherwise, lets give them page - send_page($req); + # Otherwise, lets give them page + send_page($req); } # Here we accept a connection to the browser, and keep it open. Meanwhile we