substr($folder, 0, 0) = 'maildir:'; # add prefix
my $lse = $self->{lse} //= $self->{lei}->{sto}->search;
my $lms = $self->{-lms_ro} //= $self->{lei}->lms; # may be 0 or undef
- my $oidbin = $lms ? $lms->name_oidbin($folder, $bn) : undef;
- my @docids = defined($oidbin) ? $lse->over->oidbin_exists($oidbin) : ();
+ my @oidbin = $lms ? $lms->name_oidbin($folder, $bn) : ();
+ @oidbin > 1 and $self->{lei}->err("W: $folder/*/$$bn not unique:\n",
+ map { "\t".unpack('H*', $_)."\n" } @oidbin);
+ my %seen;
+ my @docids = sort { $a <=> $b } grep { !$seen{$_}++ }
+ map { $lse->over->oidbin_exists($_) } @oidbin;
my $vmd = $self->{-import_kw} ? { kw => $kw } : undef;
if (scalar @docids) {
$lse->kw_changed(undef, $kw, \@docids) or return;
sub ck_update_kw { # via wq_io_do
my ($self, $url, $uid, $kw) = @_;
- my $oidbin = $self->{-lms_ro}->imap_oidbin($url, $uid) // return;
- my @docids = $self->{over}->oidbin_exists($oidbin) or return;
+ my @oidbin = $self->{-lms_ro}->num_oidbin($url, $uid);
+ my $uid_url = "$url/;UID=$uid";
+ @oidbin > 1 and $self->{lei}->err("W: $uid_url not unique:\n",
+ map { "\t".unpack('H*', $_)."\n" } @oidbin);
+ my %seen;
+ my @docids = sort { $a <=> $b } grep { !$seen{$_}++ }
+ map { $self->{over}->oidbin_exists($_) } @oidbin;
$self->{lse}->kw_changed(undef, $kw, \@docids) or return;
- $self->{verbose} and
- $self->{lei}->qerr('# '.unpack('H*', $oidbin)." => @$kw\n");
+ $self->{verbose} and $self->{lei}->qerr("# $uid_url => @$kw\n");
$self->{sto}->wq_do('set_eml_vmd', undef, { kw => $kw }, \@docids);
}
my ($lei, $uid_uri) = @_;
my $ent = {};
my $lms = $lei->lms or return $ent;
- my $oidhex = $lms->imap_oid($lei, $uid_uri);
- if (ref(my $err = $oidhex)) { # arg2folder error
- $lei->qerr(@{$err->{qerr}}) if $err->{qerr};
- }
- $ent->{$$uid_uri} = $oidhex;
+ my @oidhex = $lms->imap_oidhex($lei, $uid_uri);
+ $ent->{$$uid_uri} = @oidhex == 1 ? $oidhex[0] :
+ ((@oidhex == 0) ? undef : \@oidhex);
$ent;
}
}
$end //= $beg;
for my $art ($beg..$end) {
- my $oidbin = $lms->imap_oidbin($folders->[0], $art);
- $ent->{$art} = $oidbin ? unpack('H*', $oidbin) : undef;
+ my @oidhex = map { unpack('H*', $_) }
+ $lms->num_oidbin($folders->[0], $art);
+ $ent->{$art} = @oidhex == 1 ? $oidhex[0] :
+ ((@oidhex == 0) ? undef : \@oidhex);
}
$ret;
}
my $lms = $lei->lms or return;
# cf. LeiXsearch->lcat_dump
if (defined $uri->uid) {
- my $oidhex = $lms->imap_oid($lei, $uri);
- if (ref(my $err = $oidhex)) { # art2folder error
- $lei->qerr(@{$err->{qerr}}) if $err->{qerr};
- }
- push @{$lei->{lcat_blob}}, $oidhex;
+ my @oidhex = $lms->imap_oidhex($lei, $uri);
+ push @{$lei->{lcat_blob}}, @oidhex;
} elsif (defined(my $fid = $lms->fid_for($$uri))) {
push @{$lei->{lcat_fid}}, $fid;
} else {
oidbin VARBINARY NOT NULL,
fid INTEGER NOT NULL, /* folder ID */
uid INTEGER NOT NULL, /* NNTP article number, IMAP UID, MH number */
+ /* not UNIQUE(fid, uid), since we may have broken servers */
UNIQUE (oidbin, fid, uid)
)
oidbin VARBINARY NOT NULL,
fid INTEGER NOT NULL, /* folder ID */
name VARBINARY NOT NULL, /* Maildir basename, JMAP blobId */
+ /* not UNIQUE(fid, name), since we may have broken software */
UNIQUE (oidbin, fid, name)
)
}
}
-sub imap_oidbin ($$$) {
- my ($self, $url, $uid) = @_; # $url MUST have UIDVALIDITY
- my $fid = $self->{fmap}->{$url} //= fid_for($self, $url) // return;
+sub num_oidbin ($$$) {
+ my ($self, $url, $uid) = @_; # $url MUST have UIDVALIDITY if IMAP
+ my $fid = $self->{fmap}->{$url} //= fid_for($self, $url) // return ();
my $sth = $self->{dbh}->prepare_cached(<<EOM, undef, 1);
-SELECT oidbin FROM blob2num WHERE fid = ? AND uid = ?
+SELECT oidbin FROM blob2num WHERE fid = ? AND uid = ? ORDER BY _rowid_
EOM
$sth->execute($fid, $uid);
- $sth->fetchrow_array;
+ map { $_->[0] } @{$sth->fetchall_arrayref};
}
sub name_oidbin ($$$) {
SELECT oidbin FROM blob2name WHERE fid = ? AND name = ?
EOM
$sth->execute($fid, $nm);
- $sth->fetchrow_array;
+ map { $_->[0] } @{$sth->fetchall_arrayref};
}
-sub imap_oid {
+sub imap_oidhex {
my ($self, $lei, $uid_uri) = @_;
my $mailbox_uri = $uid_uri->clone;
$mailbox_uri->uid(undef);
if (my $err = $self->arg2folder($lei, $folders)) {
if ($err->{fail}) {
$lei->qerr("# no sync information for $mailbox_uri");
- return;
}
$lei->qerr(@{$err->{qerr}}) if $err->{qerr};
}
- my $oidbin = imap_oidbin($self, $folders->[0], $uid_uri->uid);
- $oidbin ? unpack('H*', $oidbin) : undef;
+ map { unpack('H*',$_) } num_oidbin($self, $folders->[0], $uid_uri->uid)
}
1;
my ($folder, $bn) = ($f =~ m!\A(.+?)/(?:new|cur)/([^/]+)\z!) or
die "BUG: $f was not from a Maildir?";
substr($folder, 0, 0) = 'maildir:'; # add prefix
- return if defined($self->{lms}->name_oidbin($folder, $bn));
+ return if scalar($self->{lms}->name_oidbin($folder, $bn));
my $eml = eml_from_path($f) // return;
my $oidbin = $self->{lei}->git_oid($eml)->digest;
$self->{lms}->set_src($oidbin, $folder, \$bn);