bin/rrr-dirtyupdate

   1 #!/usr/bin/perl -- -*- mode: cperl -*-
   2
   3 =head1 NAME
   4
   5 rrr-dirtyupdate - add a file with an old timestamp to the dataset
   6
   7 =head1 SYNOPSIS
   8
   9   rrr-dirtyupdate [options] principalfile file [epoch]
  10
  11   rrr-dirtyupdate --force principalfile
  12
  13 =head1 OPTIONS
  14
  15 =over 8
  16
  17 =cut
  18
  19 my @opt = <<'=back' =~ /B<--(\S+)>/g;
  20
  21 =item B<--delete>
  22
  23 Inject a delete event. If the epoch argument is missing, find the
  24 according file event and set epoch to that epoch plus 1.
  25
  26 =item B<--force|f>
  27
  28 Force this run even without any arguments. E.g. just for the side
  29 effect of running an aggregate call.
  30
  31 =item B<--help|h>
  32
  33 Prints a brief message and exists.
  34
  35 =item B<--verbose|v+>
  36
  37 More feedback.
  38
  39 =back
  40
  41 =head1 DESCRIPTION
  42
  43 When you later discover missing files...
  44
  45 The principalfile argument is the path to local principal recentfile.
  46
  47 The file argument is a relative path calculated from the localroot
  48 directory of the recentfile object.
  49
  50 If the epoch argument is missing it is calculated from the
  51 modification time of the file.
  52
  53 =head1 BUGS
  54
  55 This is slow: it calls aggregate twice with force which took 2 x 10-20 seconds on PAUSE.
  56
  57 =cut
  58
  59
  60 use strict;
  61 use warnings;
  62
  63 use File::Find qw(find);
  64 use lib "/home/k/sources/rersyncrecent/lib";
  65 use File::Rsync::Mirror::Recent;
  66 use File::Spec;
  67 use Getopt::Long;
  68 use Pod::Usage qw(pod2usage);
  69
  70 our %Opt;
  71 GetOptions(\%Opt,
  72            @opt,
  73           ) or pod2usage(1);
  74
  75 if ($Opt{help}) {
  76     pod2usage(0);
  77 }
  78
  79 my $aggregate_only = 0;
  80 if (@ARGV == 1) {
  81     if ($Opt{force}) {
  82         $aggregate_only=1;
  83     } else {
  84         pod2usage(1);
  85     }
  86 } elsif (@ARGV >= 3) {
  87     pod2usage(1);
  88 }
  89
  90 my($principal,$file,$epoch) = @ARGV;
  91 my $recc = File::Rsync::Mirror::Recent->new
  92     (local => $principal);
  93 my($rf) = $recc->principal_recentfile;
  94 my $abs_file = File::Spec->catfile($rf->localroot,$file);
  95
  96 unless ($aggregate_only) {
  97     unless (defined $epoch) {
  98         if ($Opt{delete}) {
  99             my $news = $recc->news(contains => { path => $file });
 100             if (@$news) {
 101                 print "Found file:\n", YAML::Syck::Dump $news;
 102                 $epoch = $news->[0]{epoch} + 1;
 103             } else {
 104                 die "didn't find '$file' in this recentfile collection";
 105             }
 106         } else {
 107             my(@stat) = stat $abs_file or die "Could not stat '$abs_file': $!";
 108             $epoch = $stat[9];
 109         }
 110     }
 111     my $type = $Opt{delete} ? "delete" : "add";
 112     $rf->update($abs_file,$type,$epoch);
 113 }
 114 warn localtime()." starting first aggregate\n";
 115 $rf->aggregate(force => 1);
 116 warn localtime()." starting second aggregate\n";
 117 $rf->aggregate(force => 1);
 118 warn localtime()." finished\n";
 119
 120
 121 __END__
 122
 123
 124 # Local Variables:
 125 # mode: cperl
 126 # coding: utf-8
 127 # cperl-indent-level: 4
 128 # End: