1 # Copyright all contributors <meta@public-inbox.org>
2 # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
4 # "lei add-watch" command
5 package PublicInbox::LeiAddWatch;
8 use parent qw(PublicInbox::LeiInput);
11 my ($lei, @argv) = @_;
12 my $cfg = $lei->_lei_cfg(1);
13 my $self = bless {}, __PACKAGE__;
14 $lei->{opt}->{'mail-sync'} = 1; # for prepare_inputs
15 my $state = $lei->{opt}->{'state'} // 'import-rw';
16 $lei->watch_state_ok($state) or
17 return $lei->fail("invalid state: $state");
18 my $vmd_mod = $self->vmd_mod_extract(\@argv);
19 return $lei->fail(join("\n", @{$vmd_mod->{err}})) if $vmd_mod->{err};
20 $self->prepare_inputs($lei, \@argv) or return;
22 while (my ($type, $vals) = each %$vmd_mod) {
23 push @vmd, "$type:$_" for @$vals;
25 my $vmd0 = shift @vmd;
26 for my $w (@{$self->{inputs}}) {
27 # clobber existing, allow multiple
29 $lei->_config("watch.$w.vmd", '--replace-all', $vmd0);
31 $lei->_config("watch.$w.vmd", $v);
34 next if defined $cfg->{"watch.$w.state"};
35 $lei->_config("watch.$w.state", $state);
37 $lei->_lei_store(1); # create
38 $lei->lms(1)->lms_write_prepare->add_folders(@{$self->{inputs}});
39 delete $lei->{cfg}; # force reload
40 $lei->refresh_watches;