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 must be an existing file.
  48
  49 If the epoch argument is missing it is calculated from the
  50 modification time of the file.
  51
  52 =head1 BUGS
  53
  54 This is slow: it calls aggregate twice with force which took 2 x 10-20 seconds on PAUSE.
  55
  56 =cut
  57
  58
  59 use strict;
  60 use warnings;
  61
  62 use File::Find qw(find);
  63 use lib "/home/k/sources/rersyncrecent/lib";
  64 use File::Rsync::Mirror::Recent;
  65 use Getopt::Long;
  66 use Pod::Usage qw(pod2usage);
  67
  68 our %Opt;
  69 GetOptions(\%Opt,
  70            @opt,
  71           ) or pod2usage(1);
  72
  73 if ($Opt{help}) {
  74     pod2usage(0);
  75 }
  76
  77 my $aggregate_only = 0;
  78 if (@ARGV == 1) {
  79     if ($Opt{force}) {
  80         $aggregate_only=1;
  81     } else {
  82         pod2usage(1);
  83     }
  84 } elsif (@ARGV >= 3) {
  85     pod2usage(1);
  86 }
  87
  88 my($principal,$file,$epoch) = @ARGV;
  89 my $recc = File::Rsync::Mirror::Recent->new
  90     (local => $principal);
  91 my($rf) = $recc->principal_recentfile;
  92
  93 unless ($aggregate_only) {
  94     unless (defined $epoch) {
  95         if ($Opt{delete}) {
  96             warn "not yet implemented???";
  97             my $news = $recc->news(contains => $file);
  98             if ($news) {
  99                 print YAML::Syck::Dump $news;
 100             }
 101             die "FIXME";
 102         } else {
 103             my(@stat) = stat $file or die "Could not stat '$file': $!";
 104             $epoch = $stat[9];
 105         }
 106     }
 107     my $type = $Opt{delete} ? "delete" : "add";
 108     $rf->update($file,$type,$epoch);
 109 }
 110 warn localtime()." starting first aggregate\n";
 111 $rf->aggregate(force => 1);
 112 warn localtime()." starting second aggregate\n";
 113 $rf->aggregate(force => 1);
 114 warn localtime()." finished\n";
 115
 116
 117 __END__
 118
 119
 120 # Local Variables:
 121 # mode: cperl
 122 # coding: utf-8
 123 # cperl-indent-level: 4
 124 # End: