about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2021-03-21 13:24:05 +0200
committerEric Wong <e@80x24.org>2021-03-22 03:40:59 -0400
commit4766972757103d6a571902409e1fc0809cf822b0 (patch)
tree3d37eac99b47ba59cf8cc9b429db157532e3345a
parent300309cebbf802463f2d7d235f2cf33d28f0760a (diff)
downloadpublic-inbox-4766972757103d6a571902409e1fc0809cf822b0.tar.gz
This makes it slightly easier to implement future commands,
since there'll be a couple more relatively self-contained
ones.
-rw-r--r--lib/PublicInbox/LEI.pm22
-rw-r--r--lib/PublicInbox/LeiConvert.pm6
-rw-r--r--lib/PublicInbox/LeiImport.pm6
-rw-r--r--lib/PublicInbox/LeiP2q.pm6
4 files changed, 15 insertions, 25 deletions
diff --git a/lib/PublicInbox/LEI.pm b/lib/PublicInbox/LEI.pm
index bf97a680..b6d21af6 100644
--- a/lib/PublicInbox/LEI.pm
+++ b/lib/PublicInbox/LEI.pm
@@ -598,7 +598,12 @@ sub dispatch {
         }
         my $func = "lei_$cmd";
         $func =~ tr/-/_/;
-        if (my $cb = __PACKAGE__->can($func)) {
+        my $cb = __PACKAGE__->can($func) // ($CMD{$cmd} ? do {
+                my $mod = "PublicInbox::Lei\u$cmd";
+                ($INC{"PublicInbox/Lei\u$cmd.pm"} //
+                        eval("require $mod")) ? $mod->can($func) : undef;
+        } : undef);
+        if ($cb) {
                 optparse($self, $cmd, \@argv) or return;
                 if (my $chdir = $self->{opt}->{C}) {
                         for my $d (@$chdir) {
@@ -685,21 +690,6 @@ sub lei_config {
         x_it($self, $?) if $?;
 }
 
-sub lei_import {
-        require PublicInbox::LeiImport;
-        PublicInbox::LeiImport->call(@_);
-}
-
-sub lei_convert {
-        require PublicInbox::LeiConvert;
-        PublicInbox::LeiConvert->call(@_);
-}
-
-sub lei_p2q {
-        require PublicInbox::LeiP2q;
-        PublicInbox::LeiP2q->call(@_);
-}
-
 sub lei_init {
         my ($self, $dir) = @_;
         my $cfg = _lei_cfg($self, 1);
diff --git a/lib/PublicInbox/LeiConvert.pm b/lib/PublicInbox/LeiConvert.pm
index fcc67f0b..8d3b221a 100644
--- a/lib/PublicInbox/LeiConvert.pm
+++ b/lib/PublicInbox/LeiConvert.pm
@@ -77,11 +77,11 @@ sub do_convert { # via wq_do
         delete $self->{wcb}; # commit
 }
 
-sub call { # the main "lei convert" method
-        my ($cls, $lei, @inputs) = @_;
+sub lei_convert { # the main "lei convert" method
+        my ($lei, @inputs) = @_;
         my $opt = $lei->{opt};
         $opt->{kw} //= 1;
-        my $self = $lei->{cnv} = bless {}, $cls;
+        my $self = $lei->{cnv} = bless {}, __PACKAGE__;
         my $in_fmt = $opt->{'in-format'};
         my (@f, @d);
         $opt->{dedupe} //= 'none';
diff --git a/lib/PublicInbox/LeiImport.pm b/lib/PublicInbox/LeiImport.pm
index ae24a1fa..0e2a96e8 100644
--- a/lib/PublicInbox/LeiImport.pm
+++ b/lib/PublicInbox/LeiImport.pm
@@ -63,13 +63,13 @@ sub import_start {
         while ($op && $op->{sock}) { $op->event_step }
 }
 
-sub call { # the main "lei import" method
-        my ($cls, $lei, @inputs) = @_;
+sub lei_import { # the main "lei import" method
+        my ($lei, @inputs) = @_;
         my $sto = $lei->_lei_store(1);
         $sto->write_prepare($lei);
         my ($net, @f, @d);
         $lei->{opt}->{kw} //= 1;
-        my $self = $lei->{imp} = bless { inputs => \@inputs }, $cls;
+        my $self = $lei->{imp} = bless { inputs => \@inputs }, __PACKAGE__;
         if ($lei->{opt}->{stdin}) {
                 @inputs and return $lei->fail("--stdin and @inputs do not mix");
                 $lei->check_input_format or return;
diff --git a/lib/PublicInbox/LeiP2q.pm b/lib/PublicInbox/LeiP2q.pm
index c5718603..302d7864 100644
--- a/lib/PublicInbox/LeiP2q.pm
+++ b/lib/PublicInbox/LeiP2q.pm
@@ -174,9 +174,9 @@ sub do_p2q { # via wq_do
         $lei->out(@q, "\n");
 }
 
-sub call { # the "lei patch-to-query" entry point
-        my ($cls, $lei, $input) = @_;
-        my $self = $lei->{p2q} = bless {}, $cls;
+sub lei_p2q { # the "lei patch-to-query" entry point
+        my ($lei, $input) = @_;
+        my $self = $lei->{p2q} = bless {}, __PACKAGE__;
         if ($lei->{opt}->{stdin}) {
                 $self->{0} = delete $lei->{0}; # guard from lei_atfork_child
         } else {