lib/PublicInbox/NNTP.pm | 2 +- lib/PublicInbox/Search.pm | 14 ++++++++++++++ t/nntpd.t | 2 ++ diff --git a/lib/PublicInbox/NNTP.pm b/lib/PublicInbox/NNTP.pm index 895e5023a50b702c17df31f82e86f1e203d97f9c..fb65ddc07dc060db7027bd86671d4f940776888a 100644 --- a/lib/PublicInbox/NNTP.pm +++ b/lib/PublicInbox/NNTP.pm @@ -336,7 +336,7 @@ my $opts = { asc => 1, limit => 1000, offset => 0 }; long_response($self, 0, long_response_limit, sub { my ($i) = @_; my $srch = $srch[0]; - my $res = $srch->query($ts, $opts); + my $res = $srch->query_ts($ts, $opts); my $msgs = $res->{msgs}; if (my $nr = scalar @$msgs) { more($self, '<' . diff --git a/lib/PublicInbox/Search.pm b/lib/PublicInbox/Search.pm index 802984b0ab8b7109bc0ca6e6b7ce6f721dc5c884..4dc274723d6ca8e34ca19821256308d47ea7058d 100644 --- a/lib/PublicInbox/Search.pm +++ b/lib/PublicInbox/Search.pm @@ -330,6 +330,20 @@ }; _do_enquire($self, $query, $opts); } +sub query_ts { + my ($self, $ts, $opts) = @_; + my $qp = $self->{qp_ts} ||= eval { + my $q = Search::Xapian::QueryParser->new; + $q->set_database($self->{skel} || $self->{xdb}); + $q->add_valuerangeprocessor( + Search::Xapian::NumberValueRangeProcessor->new(TS)); + $q + }; + my $query = $qp->parse_query($ts, QP_FLAGS); + $opts->{enquire} = enquire_skel($self); + _do_enquire($self, $query, $opts); +} + sub lookup_skeleton { my ($self, $mid) = @_; my $skel = $self->{skel} or return lookup_message($self, $mid); diff --git a/t/nntpd.t b/t/nntpd.t index ea0d293947b9d42114d94144a98927ae1ff50c42..de781d74b3b85bc88ab193865200dc78ba3982a9 100644 --- a/t/nntpd.t +++ b/t/nntpd.t @@ -228,6 +228,8 @@ 'XHDR References 1- works (empty string)'); is_deeply($n->xhdr(qw(list-id 1-)), {}, 'XHDR on invalid header returns empty'); + my $mids = $n->newnews(0, '*'); + is_deeply($mids, [''], 'NEWNEWS works'); { my $t0 = time; my $date = $n->date;