rewrite Linux nodatacow use in pure Perl w/o system

[public-inbox.git] / lib / PublicInbox / IMAPTracker.pm

diff --git a/lib/PublicInbox/IMAPTracker.pm b/lib/PublicInbox/IMAPTracker.pm
index fe8135823840de7b3f6099658ddbf12307f3ee6d..4efa8a7e7e38b774ee09709b1de027d7c4cd8b79 100644 (file)
--- a/lib/PublicInbox/IMAPTracker.pm
+++ b/lib/PublicInbox/IMAPTracker.pm
@@ -1,4 +1,4 @@
-# Copyright (C) 2018-2021 all contributors <meta@public-inbox.org>
+# Copyright (C) all contributors <meta@public-inbox.org>
 # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
 package PublicInbox::IMAPTracker;
 use strict;
@@ -39,20 +39,12 @@ sub dbh_new ($) {
        $dbh;
 }
 
-sub get_last ($;$) {
-       my ($self, $validity) = @_;
-       my $sth;
-       if (defined $validity) {
-               $sth = $self->{dbh}->prepare_cached(<<'', undef, 1);
-SELECT uid_validity, uid FROM imap_last WHERE url = ? AND uid_validity = ?
-
-               $sth->execute($self->{url}, $validity);
-       } else {
-               $sth = $self->{dbh}->prepare_cached(<<'', undef, 1);
+sub get_last ($) {
+       my ($self) = @_;
+       my $sth = $self->{dbh}->prepare_cached(<<'', undef, 1);
 SELECT uid_validity, uid FROM imap_last WHERE url = ?
 
-               $sth->execute($self->{url});
-       }
+       $sth->execute($self->{url});
        $sth->fetchrow_array;
 }
 
@@ -70,27 +62,24 @@ VALUES (?, ?, ?)
 }
 
 sub new {
-       my ($class, $url, $dbname) = @_;
+       my ($class, $url) = @_;
 
-       unless (defined($dbname)) {
-               # original name for compatibility with old setups:
-               $dbname = PublicInbox::Config->config_dir() . '/imap.sqlite3';
+       # original name for compatibility with old setups:
+       my $dbname = PublicInbox::Config->config_dir() . '/imap.sqlite3';
 
-               # use the new XDG-compliant name for new setups:
-               if (!-f $dbname) {
-                       $dbname = ($ENV{XDG_DATA_HOME} //
-                                       (($ENV{HOME} // '/nonexistent').
-                                        '/.local/share')) .
-                               '/public-inbox/imap.sqlite3';
-               }
+       # use the new XDG-compliant name for new setups:
+       if (!-f $dbname) {
+               $dbname = ($ENV{XDG_DATA_HOME} //
+                       (($ENV{HOME} // '/nonexistent').'/.local/share')) .
+                       '/public-inbox/imap.sqlite3';
        }
        if (!-f $dbname) {
                require File::Path;
-               require File::Basename;
-               require PublicInbox::Spawn;
-               File::Path::mkpath(File::Basename::dirname($dbname));
+               require PublicInbox::Syscall;
+               my ($dir) = ($dbname =~ m!(.*?/)[^/]+\z!);
+               File::Path::mkpath($dir);
+               PublicInbox::Syscall::nodatacow_dir($dir);
                open my $fh, '+>>', $dbname or die "failed to open $dbname: $!";
-               PublicInbox::Spawn::nodatacow_fd(fileno($fh));
        }
        my $self = bless { lock_path => "$dbname.lock", url => $url }, $class;
        $self->lock_acquire;