File Coverage

blib/lib/EV/Websockets.pm

Criterion	Covered	Total	%
statement	31	33	93.9
branch	8	14	57.1
condition	11	22	50.0
subroutine	7	7	100.0
pod			n/a
total	57	76	75.0

package EV::Websockets;
use strict;
use warnings;

use EV;

BEGIN {
    use XSLoader;
    our $VERSION = '0.09';
    XSLoader::load __PACKAGE__, $VERSION;
}

package EV::Websockets::Context;

# Parse a proxy value (typically from *_proxy env vars) into ($host, $port).
# Accepts an optional scheme prefix and userinfo, plain host:port, and IPv6
# bracket notation. Returns an empty list if no host can be extracted; the
# port defaults to 1080 when the value carries a host but no explicit port.
sub _parse_proxy {
    my ($url) = @_;
    return unless defined $url && length $url;
    return unless $url =~ m{^(?:\w+://)?(?:[^@]+\@)?(\[[\w:]+\]|[^:/]+)(?::(\d+))?};
    # Capture before the substitution below: a successful s/// resets $2.
    my ($host, $port) = ($1, $2);
    # Strip IPv6 brackets: lws wants a bare proxy host (the port is passed
    # separately), matching how connect() unwraps bracketed URL hosts.
    $host =~ s/^\[(.*)\]\z/$1/;
    return ($host, defined $port ? $port : 1080);
}

sub new {
    my ($class, %args) = @_;
    my $loop = $args{loop} // EV::default_loop;

    my $proxy      = $args{proxy};
    my $proxy_port = $args{proxy_port};

    if (!defined $proxy) {
        my $env_proxy = $ENV{https_proxy} // $ENV{http_proxy} // $ENV{all_proxy};
        my ($host, $port) = _parse_proxy($env_proxy);
        if (defined $host) {
            $proxy      = $host;
            $proxy_port = $port;
        }
    }

    $proxy      //= "";
    $proxy_port //= 0;

    return $class->_new($loop, $proxy, $proxy_port,
        $args{ssl_cert} // "", $args{ssl_key} // "", $args{ssl_ca} // "",
        exists $args{ssl_init} ? ($args{ssl_init} ? 1 : 0) : -1);
}

package EV::Websockets::Connection;

1;

__END__