view release on metacpan or  search on metacpan

lib/MHFS/HTTP/Server.pm  view on Meta::CPAN

    my $evp = MHFS::EventLoop::Poll->new;
    my %self = ( 'settings' => $settings, 'routes' => $routes, 'route_default' => sub { $_[0]->SendDirectory($settings->{'DOCUMENTROOT'}); }, 'plugins' => $plugins, 'sock' => $sock, 'evp' => $evp, 'uploaders' => [], 'sesh' =>
    { 'newindex' => 0, 'sessions' => {}}, 'resources' => {}, 'loaded_plugins' => {});
    bless \%self, $class;

    $evp->set($sock, \%self, POLLIN);

    my $fs = MHFS::FS->new($settings->{'SOURCES'});
    if(! $fs) {
        say "failed to open MHFS::FS";
        return undef;
    }
    $self{'fs'} = $fs;

    # load the plugins
    foreach my $pluginname (@{$plugins}) {
        eval "use $pluginname; 1;" or do {
            say __PACKAGE__.": module $pluginname not found!";
            next;
        };
        next if(defined $settings->{$pluginname}{'enabled'} && (!$settings->{$pluginname}{'enabled'}));
        my $plugin = $pluginname->new($settings, \%self);
        next if(! $plugin);

        foreach my $timer (@{$plugin->{'timers'}}) {
            say __PACKAGE__.': adding '.ref($plugin).' timer';
            $self{'evp'}->add_timer(@{$timer});
        }
        if(my $func = $plugin->{'uploader'}) {
            say __PACKAGE__.': adding '. ref($plugin) .' uploader';
            push (@{$self{'uploaders'}}, $func);
        }
        foreach my $route (@{$plugin->{'routes'}}) {
            say __PACKAGE__.': adding ' . ref($plugin) . ' route ' . $route->[0];
            push @{$self{'routes'}}, $route;
        }
        $plugin->{'server'} = \%self;
        $self{'loaded_plugins'}{$pluginname} = $plugin;
    }

    $evp->run();

    return \%self;
}

sub GetTextResource {
    my ($self, $filename) = @_;
    $self->{'resources'}{$filename} //= read_text_file($filename);
    return \$self->{'resources'}{$filename};
}

sub onReadReady {
    my ($server) = @_;
    # accept the connection
    my $csock = $server->{'sock'}->accept();
    if(! $csock) {
        say "server: cannot accept client";
        return 1;
    }

    # gather connection details and verify client host is acceptable
    my $peerhost = $csock->peerhost();
    if(! $peerhost) {
        say "server: no peerhost";
        return 1;
    }
    my $peerip = do {
        try { parse_ipv4($peerhost) }
        catch ($e) {
            say "server: error parsing ip $peerhost";
            return 1;
        }
    };
    my $ah;
    foreach my $allowedHost (@{$server->{'settings'}{'ARIPHOSTS_PARSED'}}) {
        if(($peerip & $allowedHost->{'subnetmask'}) == $allowedHost->{'ip'}) {
            $ah = $allowedHost;
            last;
        }
    }
    if(!$ah) {
        say "server: $peerhost not allowed";
        return 1;
    }
    my $peerport = $csock->peerport();
    if(! $peerport) {
        say "server: no peerport";
        return 1;
    }

    # finally create the client
    say "-------------------------------------------------";
    say "NEW CONN " . $peerhost . ':' . $peerport;
    my $cref = MHFS::HTTP::Server::Client->new($csock, $server, $ah, $peerip);
    return 1;
}

1;