From 761736a312a103ba522abac52a604564f9e788ce Mon Sep 17 00:00:00 2001
From: Eric Wong <e@80x24.org>
Date: Fri, 18 Sep 2015 01:37:53 +0000
Subject: read-only NNTP server

Implementing NEWNEWS, XHDR, XOVER efficiently will require
additional caching on top of msgmap.

This seems to work with lynx and slrnpull, haven't tried clients.

DO NOT run in production, yet, denial-of-service vulnerabilities
await!
---
 public-inbox-nntpd | 77 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 77 insertions(+)
 create mode 100644 public-inbox-nntpd

(limited to 'public-inbox-nntpd')

diff --git a/public-inbox-nntpd b/public-inbox-nntpd
new file mode 100644
index 00000000..7fec840e
--- /dev/null
+++ b/public-inbox-nntpd
@@ -0,0 +1,77 @@
+#!/usr/bin/perl -w
+# Copyright (C) 2015 all contributors <meta@public-inbox.org>
+# License: AGPLv3 or later (https://www.gnu.org/licenses/agpl-3.0.txt)
+use strict;
+use warnings;
+require Danga::Socket;
+use IO::Socket;
+use Socket qw(SO_KEEPALIVE IPPROTO_TCP TCP_NODELAY);
+require PublicInbox::NNTP;
+require PublicInbox::NewsGroup;
+my $nntpd = PublicInbox::NNTPD->new;
+my $refresh = sub { $nntpd->refresh_groups };
+
+my %opts = (
+	LocalAddr => '127.0.0.1:1133',
+	Type => SOCK_STREAM,
+	Proto => 'tcp',
+	Blocking => 0,
+	Reuse => 1,
+	Listen => 1024,
+);
+my $s = IO::Socket::INET->new(%opts) or die "Error creating socket: $@\n";
+$s->sockopt(SO_KEEPALIVE, 1);
+$s->setsockopt(IPPROTO_TCP, TCP_NODELAY, 1);
+
+$SIG{PIPE} = 'IGNORE';
+$SIG{HUP} = $refresh;
+$refresh->();
+
+Danga::Socket->AddOtherFds(fileno($s) => sub {
+	while (my $c = $s->accept) {
+		$c->blocking(0); # no accept4 :<
+		PublicInbox::NNTP->new($c, $nntpd);
+	}
+});
+Danga::Socket->EventLoop();
+
+package PublicInbox::NNTPD;
+use strict;
+use warnings;
+use fields qw(groups err out);
+
+sub new {
+	my ($class) = @_;
+	my $self = fields::new($class);
+	$self->{groups} = {};
+	$self;
+}
+
+sub refresh_groups {
+	my ($self) = @_;
+	require PublicInbox::Config;
+	my $pi_config = PublicInbox::Config->new;
+	my $new = {};
+	foreach my $k (keys %$pi_config) {
+		$k =~ /\Apublicinbox\.([^\.]+)\.mainrepo\z/ or next;
+		my $g = $1;
+		my $git_dir = $pi_config->{$k};
+		my $address = $pi_config->{"publicinbox.$g.address"};
+		my $ng = PublicInbox::NewsGroup->new($g, $git_dir, $address);
+		my $old_ng = $self->{groups}->{$g};
+
+		# Reuse the old one if possible since it can hold references
+		# to valid mm and gcf objects
+		if ($old_ng) {
+			$old_ng->update($ng);
+			$ng = $old_ng;
+		}
+
+		# Only valid if Msgmap works
+		$new->{$g} = $ng if $ng->mm;
+	}
+	# this will destroy old groups that got deleted
+	%{$self->{groups}} = %$new;
+};
+
+1;
-- 
cgit v1.2.3-24-ge0c7