HTTP_PROXY results from the CPAN

POE-Component-Client-HTTP
      "<html><head><title>Test</title></head>" .
      "<body>HTTP/0.9 Allows documents with no status and no headers!</body>" .
      "</html>"
    ),
    sub {
      my $response = shift;
      ok(
        $response->code() == 200 &&
        $response->content() =~ /Allows documents/ &&
        $response->protocol() eq 'HTTP/0.9' &&
        $response->header('Content-Type') =~ /html/,
        "HTTP 0.9 supports no status and no headers, no LF"
      );
    },
  ],
  # A multi-line HTTP/0.9 response.
  [
    (
      "<html><head><title>Test</title></head>" . $LF .
      "<body>HTTP/0.9 Allows documents with no status and no headers!" . $LF .
      "</body></html>" . $LF
    ),
    sub {
      my $response = shift;
      ok(
        $response->code() == 200 &&
        $response->content() =~ /Allows documents/ &&
        $response->protocol() eq 'HTTP/0.9' &&
        $response->header('Content-Type') =~ /html/ &&
        $response->content() =~ m!</html>!,
        "HTTP 0.9 supports no status and no headers, multiple lines"
      )
    },
  ],
  # A response with no known transfer encoding.
  [
    (
      "HTTP/1.1 200 OK$CRLF" .
      "Connection: close$CRLF" .
      "Transfer-Encoding: zort,poit,narf$CRLF" .
      "Content-type: text/plain$CRLF" .
      $CRLF .
      "7$CRLF" .
      "chunk 1$CRLF" .
      "0$CRLF"
    ),
    sub {
      my $response = shift;
      ok(
        $response->code() == 200 &&
        $response->header("Transfer-Encoding") eq "zort, poit, narf",
        "no known transfer encodings"
      );
    },
  ],
);

# We are testing against a localhost server.
# Don't proxy, because localhost takes on new meaning.
BEGIN {
  delete $ENV{HTTP_PROXY};
}

# Spawn one server per test response.
{
  foreach (@tests) {
    POE::Component::Server::TCP->new(
      Alias               => "server_$_",
      Address             => "127.0.0.1",
      Port                => 0,
      Started             => \&register_port,
      ClientInputFilter   => "POE::Filter::Line",
      ClientOutputFilter  => "POE::Filter::Stream",
      ClientInput         => \&parse_next_request,
    );
  }

  sub register_port {
    push(
      @server_ports,
      (sockaddr_in($_[HEAP]->{listener}->getsockname()))[0]
    );
  }

  sub parse_next_request {
    my $input = $_[ARG0];

    DEBUG and diag "got line: [$input]";
    return if $input ne "";

    my $response = $tests[$test_number][0];
    $_[HEAP]->{client}->put($response);

    $response =~ s/$CRLF/{CRLF}/g;
    DEBUG and diag "sending: [$response]";

    $_[KERNEL]->yield("shutdown");
  }
}

# Spawn the HTTP user-agent component.
POE::Component::Client::HTTP->spawn();

# Create a client session to drive the HTTP component.
POE::Session->create(
  inline_states => {
    _start => sub {
      $_[KERNEL]->yield("run_next_test");
    },
    run_next_test => sub {
      my $port    = $server_ports[$test_number];
      $_[KERNEL]->post(
        weeble => request => response =>
        GET "http://127.0.0.1:${port}/"
      );
    },
    response => sub {
      my $response = $_[ARG1][0];
      my $test     = $tests[$test_number][1];
      $test->($response);
( run in 1.236 second using v1.01-cache-2.11-cpan-71847e10f99 )