--- trunk/lib/Frey/Server.pm 2008/06/30 07:13:35 36 +++ trunk/lib/Frey/Server.pm 2008/06/30 20:02:06 37 @@ -17,14 +17,14 @@ #$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, ); $server->debug_level( 2 ); -sub run { +sub run { $server->loop; } @@ -33,8 +33,10 @@ sub gen_link { my ($text, $code) = @_; - $callbacks[$callback_count++] = $code; - return qq{$text}; + $callbacks[$callback_count] = $code; + my $out = qq{$text}; + $callback_count++; + return $out; } sub process_links { @@ -42,7 +44,7 @@ my $cb = $request->param('cb'); if (exists $callbacks[$cb]) { $callbacks[$cb]->($request); - delete $callbacks[$cb]; +# delete $callbacks[$cb]; } } @@ -50,26 +52,45 @@ # 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); + } + + if ( $path =~ m/test/ ) { + use Data::Dumper; + $Data::Dumper::Deparse = 1; + + my $x = 0; + my $continue = 1; + my $link1 = gen_link('+' => sub { $x++ }); + my $link2 = gen_link('-' => sub { $x-- }); + my $out = gen_link('X' => sub { $continue = 0 }); + while ( $continue ) { + warn "## x = $x ",dump( $req->params ); + $req->print("\$x is now: $x"); + $req->print($link1, ' ', $link2, ' ', $out); + $req->print('
'.Dumper( @callbacks ).'
'); + $req->next; + process_links($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