diff options
author | Eric Wong <e@80x24.org> | 2021-09-21 07:41:59 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2021-09-21 19:18:36 +0000 |
commit | c1cfe2c2ff17bca3cafb9dea4d7a7697eeab9683 (patch) | |
tree | dcad22ec6df905ca6f19f00744b33fa1356e8946 /lib/PublicInbox/LeiSavedSearch.pm | |
parent | 21fd0da3bcfba4d3564d262f88d3fd7479b6d5ee (diff) | |
download | public-inbox-c1cfe2c2ff17bca3cafb9dea4d7a7697eeab9683.tar.gz |
Avoid slurping gigantic (e.g. 100000) result sets into a single response if a giant limit is specified, and instead use 10000 as a window for the mset with a given offset. We'll also warn and hint towards about the --limit= switch when the estimated result set is larger than the default limit.
Diffstat (limited to 'lib/PublicInbox/LeiSavedSearch.pm')
-rw-r--r-- | lib/PublicInbox/LeiSavedSearch.pm | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/lib/PublicInbox/LeiSavedSearch.pm b/lib/PublicInbox/LeiSavedSearch.pm index 637456e4..3e10f780 100644 --- a/lib/PublicInbox/LeiSavedSearch.pm +++ b/lib/PublicInbox/LeiSavedSearch.pm @@ -29,6 +29,8 @@ sub BOOL_FIELDS () { qw(external local remote import-remote import-before threads) } +sub SINGLE_FIELDS () { qw(limit dedupe output) } + sub lss_dir_for ($$;$) { my ($lei, $dstref, $on_fs) = @_; my $pfx; @@ -89,9 +91,9 @@ sub list { } @$out } -sub translate_dedupe ($$$) { - my ($self, $lei, $dd) = @_; - $dd //= 'content'; +sub translate_dedupe ($$) { + my ($self, $lei) = @_; + my $dd = $lei->{opt}->{dedupe} // 'content'; return 1 if $dd eq 'content'; # the default return $self->{"-dedupe_$dd"} = 1 if ($dd eq 'oid' || $dd eq 'mid'); $lei->fail("--dedupe=$dd requires --no-save"); @@ -128,8 +130,7 @@ sub new { # new saved search "lei q --save" File::Path::make_path($dir); # raises on error $self->{-cfg} = {}; my $f = $self->{'-f'} = "$dir/lei.saved-search"; - my $dd = $lei->{opt}->{dedupe}; - translate_dedupe($self, $lei, $dd) or return; + translate_dedupe($self, $lei) or return; open my $fh, '>', $f or return $lei->fail("open $f: $!"); my $sq_dst = PublicInbox::Config::squote_maybe($dst); my $q = $lei->{mset_opt}->{q_raw} // die 'BUG: {q_raw} missing'; @@ -139,15 +140,14 @@ sub new { # new saved search "lei q --save" $q = "\tq = ".cquote_val($q); } $dst = "$lei->{ovv}->{fmt}:$dst" if $dst !~ m!\Aimaps?://!i; + $lei->{opt}->{output} = $dst; print $fh <<EOM; ; to refresh with new results, run: lei up $sq_dst ; `maxuid' and `lastresult' lines are maintained by "lei up" for optimization [lei] $q [lei "q"] - output = $dst EOM - print $fh "\tdedupe = $dd\n" if $dd; for my $k (ARRAY_FIELDS) { my $ary = $lei->{opt}->{$k} // next; for my $x (@$ary) { @@ -158,6 +158,10 @@ EOM my $val = $lei->{opt}->{$k} // next; print $fh "\t$k = ".($val ? 1 : 0)."\n"; } + for my $k (SINGLE_FIELDS) { + my $val = $lei->{opt}->{$k} // next; + print $fh "\t$k = $val\n"; + } close($fh) or return $lei->fail("close $f: $!"); $self->{lock_path} = "$self->{-f}.flock"; $self->{-ovf} = "$dir/over.sqlite3"; |