$dbh;
}
-sub get_last ($$) {
- my ($self, $url) = @_;
+sub get_last ($) {
+ my ($self) = @_;
my $sth = $self->{dbh}->prepare_cached(<<'', undef, 1);
SELECT uid_validity, uid FROM imap_last WHERE url = ?
- $sth->execute($url);
+ $sth->execute($self->{url});
$sth->fetchrow_array;
}
-sub update_last ($$$$) {
- my ($self, $url, $validity, $last) = @_;
+sub update_last ($$$) {
+ my ($self, $validity, $last) = @_;
my $sth = $self->{dbh}->prepare_cached(<<'');
INSERT OR REPLACE INTO imap_last (url, uid_validity, uid)
VALUES (?, ?, ?)
- $sth->execute($url, $validity, $last);
+ $sth->execute($self->{url}, $validity, $last);
}
sub new {
- my ($class, $dbname) = @_;
+ my ($class, $url) = @_;
# original name for compatibility with old setups:
- $dbname //= PublicInbox::Config->config_dir() . "/imap.sqlite3";
+ my $dbname = PublicInbox::Config->config_dir() . "/imap.sqlite3";
# use the new XDG-compliant name for new setups:
if (!-f $dbname) {
}
if (!-f $dbname) {
require File::Path;
- require File::Basename;;
+ require File::Basename;
File::Path::mkpath(File::Basename::dirname($dbname));
}
my $dbh = dbh_new($dbname);
- bless { dbname => $dbname, dbh => $dbh }, $class;
+ bless { dbname => $dbname, url => $url, dbh => $dbh }, $class;
}
1;
$mic;
}
-sub imap_import_msg ($$$$$$) {
- my ($self, $itrk, $url, $r_uidval, $uid, $raw) = @_;
+sub imap_import_msg ($$$$$) {
+ my ($self, $itrk, $r_uidval, $uid, $raw) = @_;
# our target audience expects LF-only, save storage
$$raw =~ s/\r\n/\n/sg;
- my $inboxes = $self->{imap}->{$url};
+ my $inboxes = $self->{imap}->{$itrk->{url}};
if (ref($inboxes)) {
for my $ibx (@$inboxes) {
my $eml = PublicInbox::Eml->new($$raw);
}
} elsif ($inboxes eq 'watchspam') {
my $eml = PublicInbox::Eml->new($raw);
- my $arg = [ $self, $eml, "$url UID:$uid" ];
+ my $arg = [ $self, $eml, "$itrk->{url} UID:$uid" ];
$self->{config}->each_inbox(\&remove_eml_i, $arg);
} else {
die "BUG: destination unknown $inboxes";
}
- $itrk->update_last($url, $r_uidval, $uid);
+ $itrk->update_last($r_uidval, $uid);
}
sub imap_fetch_all ($$$) {
return "E: $url cannot get UIDVALIDITY";
$r_uidnext //= $mic->uidnext($mbx) //
return "E: $url cannot get UIDNEXT";
- my $itrk = PublicInbox::IMAPTracker->new;
- my ($l_uidval, $l_uid) = $itrk->get_last($url);
+ my $itrk = PublicInbox::IMAPTracker->new($url);
+ my ($l_uidval, $l_uid) = $itrk->get_last;
$l_uidval //= $r_uidval; # first time
$l_uid //= 1;
if ($l_uidval != $r_uidval) {
}
# messages get deleted, so holes appear
defined(my $raw = delete $r->{$uid}->{$key}) or next;
- imap_import_msg($self, $itrk, $url, $r_uidval, $uid,
- \$raw);
+ imap_import_msg($self, $itrk, $r_uidval, $uid, \$raw);
last if $self->{quit};
}
_done_for_now($self);