Changeset 11792

Timestamp:

05/17/08 23:09:46 (5 years ago)

Author:

yappo

Message:

add Interface::Standalone

Files:

• lang/perl/HTTP-Engine/trunk/lib/HTTP/Engine/Interface/Standalone.pm (copied) (copied from lang/perl/HTTP-Engine/branches/class-component/lib/HTTP/Engine/Interface/Standalone.pm) (9 diffs)

lang/perl/HTTP-Engine/trunk/lib/HTTP/Engine/Interface/Standalone.pm

@@ -1 +1 @@
 package HTTP::Engine::Interface::Standalone;
-use strict;
-use warnings;
-use base 'HTTP::Engine::Plugin';
-use HTTP::Engine::Role;
+use Moose;
 with 'HTTP::Engine::Role::Interface';
 
@@ -13 +10 @@
 use constant should_write_response_line => 1;
 
-sub read_chunk {
+has host => (
+    is      => 'rw',
+    isa     => 'Str',
+    default => '127.0.0.1',
+);
+
+has port => (
+    is      => 'rw',
+    isa     => 'Int',
+    default => 80,
+);
+
+has keepalive => (
+    is      => 'ro',
+    isa     => 'Bool',
+    default => 0,
+);
+
+has fork => (
+    is      => 'ro',
+    isa     => 'Bool',
+    default => 0,
+);
+
+has allowed => (
+    is      => 'rw',
+    isa     => 'HashRef',
+    default => sub { { '127.0.0.1' => '255.255.255.255' } },
+);
+
+has argv => (
+    is      => 'ro',
+    isa     => 'ArrayRef',
+    default => sub { [] },
+);
+
+
+use HTTP::Engine::ResponseWriter;
+HTTP::Engine::RequestBuilder->meta->add_method( _read_chunk  => sub {
     shift;
     # support for non-blocking IO
@@ -30 +65 @@
         }
     }
-}
-
-before prepare_read => sub {
+});
+
+HTTP::Engine::RequestBuilder->meta->add_before_method_modifier( _prepare_read => sub {
     my $self = shift;
     # Set the input handle to non-blocking
     *STDIN->blocking(0);
-};
-
-before write_headers => sub {
-    my($self, $res) = @_;
-
-    $res->headers->date(time);
-    $res->headers->header(
-        Connection => $self->_keep_alive ? 'keep-alive' : 'close'
+});
+
+use HTTP::Engine::ResponseWriter;
+my $is_keepalive;
+HTTP::Engine::ResponseWriter->meta->add_before_method_modifier( finalize => sub {
+    my($self, $c) = @_;
+
+    $c->res->headers->date(time);
+    $c->res->headers->header(
+        Connection => $is_keepalive ? 'keep-alive' : 'close'
     );
-};
+});
 
 sub run {
-    my($self, $c) = @_;
-    my $host = $self->config->{host} || '';
-    my $port = $self->config->{port} || 80;
-    $self->_keep_alive($self->config->{keepalive});
+    my($self, ) = @_;
+
+    $is_keepalive = sub { $self->keepalive };
+
+    my $host = $self->host;
+    my $port = $self->port;
 
     # Setup address
@@ -75 +114 @@
     $url .= ":$port" unless $port == 80;
 
-    $c->log( info => "You can connect to your server at $url\n");
-
     my $restart = 0;
-    my $allowed = $self->config->{allowed} || { '127.0.0.1' => '255.255.255.255' };
+    my $allowed = $self->allowed;
     my $parent = $$;
     my $pid    = undef;
@@ -93 +130 @@
         unless (uc $method eq 'RESTART') {
             # Fork
-            next if $self->config->{fork} && ($pid = fork);
-            $self->_handler($c, $port, $method, $uri, $protocol);
+            next if $self->fork && ($pid = fork);
+            $self->_handler($port, $method, $uri, $protocol);
             $daemon->close if defined $pid;
         } else {
@@ -119 +156 @@
         $SIG{CHLD} = 'DEFAULT';
         wait;
-        exec $^X . ' "' . $0 . '" ' . join(' ', @{ $self->config->{argv} });
+        exec $^X . ' "' . $0 . '" ' . join(' ', @{ $self->argv });
     }
 
@@ -126 +163 @@
 
 sub _handler {
-    my($self, $c, $port, $method, $uri, $protocol) = @_;
+    my($self, $port, $method, $uri, $protocol) = @_;
 
     # Ignore broken pipes as an HTTP server should
@@ -178 +215 @@
         }
         # Pass flow control to HTTP::Engine
-        $c->handle_request;
+        $self->handle_request;
 
         my $connection = lc $ENV{HTTP_CONNECTION};
         last
-          unless $self->_keep_alive()
+          unless $self->keepalive
           && index($connection, 'keep-alive') > -1
           && index($connection, 'te') == -1          # opera stuff
@@ -192 +229 @@
     sysread(Remote, my $buf, 4096) if $sel->can_read(0); # IE bk
     close Remote;
-}
-
-sub _keep_alive {
-    my($self, $keepalive) = @_;
-
-    my $r = $self->{_keepalive} || 0;
-    $self->{_keepalive} = $keepalive if defined $keepalive;
-
-    $r;
 }