--- trunk/bin/BackupPC_burnArchiveCLI 2005/10/11 17:55:48 175 +++ trunk/bin/BackupPC_burnArchiveCLI 2005/10/13 21:19:08 200 @@ -1,9 +1,7 @@ -#!/usr/local/bin/perl +#!/usr/bin/perl use strict; -#use lib "__INSTALLDIR__/lib"; -# FIXME -use lib "/data/backuppc/lib"; +use lib "__INSTALLDIR__/lib"; use DBI; use BackupPC::Lib; @@ -11,12 +9,20 @@ use Time::HiRes qw/time/; use POSIX qw/strftime/; use Term::Menus; +use File::Which; use Data::Dumper; my $debug = 0; $|=1; +my $cdr_opts = 'dev=/dev/hdc blank=fast -v -eject'; + +my $bin; +foreach my $c (qw/mkisofs cdrecord eject/) { + $bin->{$c} = which($c) || die "$0 needs $c, install it\n"; +} + my $start_t = time(); my $t_fmt = '%Y-%m-%d %H:%M:%S'; @@ -34,7 +40,7 @@ my $tar_dir = $Conf{InstallDir}.'/'; $tar_dir .= $Conf{GzipTempDir} || die "GzipTempDir isn't defined in configuration"; -die "problem with $tar_dir, check GzipTempDir in configuration\n" unless (-d $tar_dir && -w $tar_dir); +die "problem with $tar_dir, check GzipTempDir in configuration\n" unless (-d $tar_dir); my $iso_dir = $Conf{InstallDir}.'/'; $iso_dir .= $Conf{ISOTempDir} || die "ISOTempDir isn't defined in configuration"; @@ -55,6 +61,93 @@ return strftime($t_fmt,localtime()); } +sub dumpArchive2XML($$$) +{ + my ($dbh, $dvd_nr, $filename) = @_; + my %archive; + my $output = new IO::File(">$filename"); + my $writer = new XML::Writer(OUTPUT=>$output, NEWLINES => 1); + + $writer->pi('xml-stylesheet', 'href="archive.css" type="text/css"'); + + my $files_sql = q{ + SELECT + files.path AS path, + files.date AS date, + files.type AS type, + files.size AS size + FROM files, backups, shares + WHERE files.backupnum=backups.num AND + files.shareid=shares.id AND + shares.hostid=backups.hostid AND + backups.id=? + }; + + my $backups_sql = q{ + SELECT + backups.id AS backup_id, + hosts.name AS host, + backups.num AS num, + backups.date AS date, + shares.name AS share, + backups.size AS backup_size, + backups.inc_size AS compress_size + FROM backups, archive_backup, hosts, shares + WHERE archive_backup.backup_id = backups.id + AND hosts.id=backups.hostid + AND shares.id=backups.shareid + AND archive_backup.archive_id = ? + }; + + my $sth = $dbh->prepare("SELECT dvd_nr, total_size, note, username, date,id FROM archive WHERE dvd_nr=?"); + $sth->execute($dvd_nr); + my $row = $sth->fetchrow_hashref(); + + my $row_h; + foreach my $hide (qw/id note/) { + $row_h->{$hide} = $row->{$hide} || ''; + delete $row->{$hide}; + } + + $writer->startTag("archive", %{$row}); + + $writer->startTag("note"); + $writer->characters( $row_h->{'note'} ); + $writer->endTag("note"); + + my $sth_backups = $dbh->prepare( $backups_sql ); + $sth_backups->execute( $row_h->{'id'} ); + + while (my $row = $sth_backups->fetchrow_hashref()) { + + my $sth_files = $dbh->prepare( $files_sql); + $sth_files->execute($row->{'backup_id'}); + + delete($row->{'backup_id'}); + $row->{'date'} = strftime($t_fmt,gmtime($row->{'date'})); + + $writer->startTag( "backup", %{$row} ); + + while (my $row = $sth_files->fetchrow_hashref()) { + # convert filetype to string + $row->{'type'} = BackupPC::Attrib::fileType2Text(undef, $row->{'type'}); + $row->{'date'} = strftime($t_fmt,gmtime($row->{'date'})); + my $path = $row->{'path'}; delete $row->{'path'}; + + $writer->startTag("file", %{$row}); + $writer->characters( $path ); + $writer->endTag("file"); + } + $writer->endTag("backup"); + } + + $writer->endTag("archive"); + $writer->end(); + +} + + + #----- main my $sth = $dbh->prepare( qq{ @@ -132,9 +225,11 @@ my $sth_archive_backup = $dbh->prepare( qq{ select backup_id, + archive_id, hosts.name as host, shares.name as share, - backups.num as num + backups.num as num, + backups.parts as parts from archive_backup join archive on archive_id = archive.id join backups on backup_id = backups.id @@ -143,6 +238,12 @@ where archive.dvd_nr = ? }); +my $sth_archive_burned = $dbh->prepare( qq{ + insert into archive_burned + (archive_id, iso_size, part) + values ( (select id from archive where dvd_nr =?), ?, ?) +}); + foreach my $arc (@archives_to_burn) { exit if ($arc eq ']quit['); @@ -155,29 +256,109 @@ print "Working on DVD #$dvd_nr in $tmp_dir\n"; - my $iso_file = "${iso_dir}/${dvd_nr}.iso"; + my $part_path = ''; + my $part_nr = 1; + my $parts = 0; + + $sth_archive_backup->execute($dvd_nr); - skip "ISO $iso_file allready exists" if (-e $iso_file); + my $disk_name = 'unknown disk'; + my $iso_size = 0; - $sth_archive_backup->execute($dvd_nr); + do { - print "Running mkisofs now...\n"; + # do we need to re-execute query for multi-part increments? + $sth_archive_backup->execute($dvd_nr) if ($parts > 1); - my $cmd = qq{ mkisofs -A BackupPC -gui -J -r -T --input-charset ISO-8859-2 -V $dvd_nr -o $iso_file -path-list - }; + my $row = $sth_archive_backup->fetchrow_hashref || die "can't fetch row"; - open(my $mkisofs, "| $cmd 2>&1") || skip "can't run $cmd: $!"; - while (my $row = $sth_archive_backup->fetchrow_hashref) { - my $tar_file = BackupPC::SearchLib::getGzipName($row->{'host'}, $row->{'share'}, $row->{'num'}); - skip "can't find increment $tar_file: $!" unless (-r "$tar_dir/$tar_file"); - print $mkisofs "$tar_dir/$tar_file\n"; - } + $parts = $row->{'parts'} || die "no parts?"; + $disk_name = $dvd_nr; - while(! -e $iso_file) { - sleep 1; - } + if ($parts > 1) { + # parts start with 0, so we have -1 here + $part_path = '.' . ($part_nr - 1); + $disk_name .= '.' . $part_nr; + } + + print "Processing part $part_nr/$parts\n"; + + my $list_file = my $iso_file = my $xml_file = "${iso_dir}/${dvd_nr}"; + $list_file .= $part_path . '.list'; + $iso_file .= $part_path . '.iso'; + $xml_file .= '.xml'; + + # + # check if ISO file exists + # + + if (! -e $iso_file) { + + open(my $list, "> $list_file") || skip "can't open $list_file: $!"; - print "Created $iso_file in ", fmt_time(time() - $t), "\n"; + my $inc = 0; + + do { + my $tar_file = BackupPC::SearchLib::getGzipName($row->{'host'}, $row->{'share'}, $row->{'num'}); + if (-f "$tar_dir/$tar_file") { + skip "can't find increment $tar_file: $!" unless (-r "$tar_dir/$tar_file"); + print $list "$tar_dir/$tar_file\n"; + } else { + my $len = length("$parts"); + my $nr = sprintf("%0${len}d", ($part_nr - 1)); + print $list "$tar_dir/$tar_file/part$nr\n"; + } + $inc++; + } while ($row = $sth_archive_backup->fetchrow_hashref); + + # add file list and note in xml + dumpArchive2XML($dbh, $dvd_nr, $xml_file) unless (-f $xml_file); + print $list "$xml_file\n"; + + # add css file for archive + my $css_file = $Conf{CgiImageDir} . '/archive.css'; + if (-r $css_file) { + print $list "$css_file\n"; + } else { + print "WARNING: missing $css_file, not added to iso image!\n"; + } + + close($list); + + print "Running mkisofs now for $inc increments, disk $disk_name\n"; + + my $cmd = $bin->{'mkisofs'} . qq{ -A BackupPC -gui -J -r -T --input-charset ISO-8859-2 -V $disk_name -o $iso_file -path-list $list_file }; + + system($cmd) == 0 or skip "can't run $cmd: $?"; + + $iso_size = (stat($iso_file))[7]; + + print "Created $iso_file [$iso_size bytes] in ", fmt_time(time() - $t), "\n"; + + } else { + print "ISO $iso_file allready exists\n"; + } + + print "\nREADY TO BURN MEDIA $disk_name please insert blank media and press ENTER\n\n"; + + system($bin->{'eject'}) == 0 or skip "can't run eject: $?"; + + my $wait = ; + + my $cmd = $bin->{'cdrecord'} . ' ' . $cdr_opts . ' ' . $iso_file; + +# system($cmd) == 0 or skip "can't run $cmd: $?"; + print "## $cmd\n"; + + print "\n\nPLEASE REMOVE DVD MEDIA AND LABEL IT WITH $disk_name\n\n"; + + $sth_archive_burned->execute($dvd_nr, $iso_size, $part_nr); + + print "Media burn for $disk_name recorded\n"; + + $part_nr++; + } until ($part_nr > $parts); SKIP: @@ -186,6 +367,11 @@ #my $tar_file = BackupPC::SearchLib::getGzipName($row->{'host'}, $row->{'share'}, $row->{'num'}); #print curr_time, sprintf(" %s:%s %-3d ", $row->{'host'}, $row->{'share'}, $row->{'num'}), " -> $tar_file "; +print "Recoding finished, exiting...\n"; + $sth->finish; +$sth_archive_backup->finish; +$sth_archive_burned->finish; + $dbh->disconnect;