view release on metacpan or  search on metacpan

examples/hello-world.pl  view on Meta::CPAN

#!/usr/bin/perl

use v5.14;
use warnings;

use Net::Async::HTTP::Server;
use IO::Async::Loop;

use HTTP::Response;

use Getopt::Long;

GetOptions(
   'ssl|S' => \my $SSL,
   'metrics=s' => \my $METRICS,
) or exit 1;

require IO::Async::SSL if $SSL;

my $prometheus;
if( $METRICS ) {
   require Metrics::Any::Adapter;
   Metrics::Any::Adapter->import( $METRICS );

   if( $METRICS eq "Prometheus" ) {
      require Net::Prometheus;
      $prometheus = Net::Prometheus->new;
   }
}

my $loop = IO::Async::Loop->new();

my $httpserver = Net::Async::HTTP::Server->new(
   on_request => sub {
      my $self = shift;
      my ( $req ) = @_;

      my $response = HTTP::Response->new( 200 );
      if( $prometheus and $req->path eq "/metrics" ) {
         $response->add_content( $prometheus->render );
      }
      else {
         $response->add_content( "Hello, world!\n" );
      }

      $response->content_type( "text/plain" );

      $response->content_length( length $response->content );

      $req->respond( $response );
   },
);

$loop->add( $httpserver );

$httpserver->listen(
   addr => {
      family   => "inet6",
      socktype => "stream",
      port     => $SSL ? 8443 : 8080,
   },
   on_listen_error => sub { die "Cannot listen - $_[-1]\n" },
   ( $SSL ? (
      extensions    => [ 'SSL' ],
      SSL_key_file  => "t/privkey.pem",
      SSL_cert_file => "t/server.pem", )
      : () ),
);

my $sockhost = $httpserver->read_handle->sockhost;
$sockhost = "[$sockhost]" if $sockhost =~ m/:/; # IPv6 numerical

printf "Listening on %s://%s:%d\n",
   ( $SSL ? "https" : "http" ),
   $sockhost, $httpserver->read_handle->sockport;

$loop->run;