--- trunk/lib/BackupPC/SearchLib.pm	2005/08/30 22:43:01	102
+++ trunk/lib/BackupPC/SearchLib.pm	2005/09/22 14:25:51	129
@@ -15,11 +15,7 @@
 my $dsn = $Conf{SearchDSN};
 my $db_user = $Conf{SearchUser} || '';
 
-my $index_path = $Conf{HyperEstraierIndex};
-if ($index_path) {
-	$index_path = $TopDir . '/' . $index_path;
-	$index_path =~ s#//#/#g;
-}
+my $hest_index_path = $Conf{HyperEstraierIndex};
 
 my $dbh;
 
@@ -175,19 +171,46 @@
 	return ($results, \@ret);
 }
 
+sub getHyperEstraier_url($) {
+	my ($use_hest) = @_;
+
+	return unless $use_hest;
+
+	use HyperEstraier;
+	my ($index_path, $index_node_url);
+
+	if ($use_hest =~ m#^http://#) {
+		$index_node_url = $use_hest;
+	} else {
+		$index_path = $TopDir . '/' . $index_path;
+		$index_path =~ s#//#/#g;
+	}
+	return ($index_path, $index_node_url);
+}
+
 sub getFilesHyperEstraier($) {
 	my ($param) = @_;
 
 	my $offset = $param->{'offset'} || 0;
 	$offset *= $on_page;
 
-	die "no index_path?" unless ($index_path);
+	die "no index_path?" unless ($hest_index_path);
 
 	use HyperEstraier;
 
+	my ($index_path, $index_node_url) = getHyperEstraier_url($hest_index_path);
+
 	# open the database
-	my $db = HyperEstraier::Database->new();
-	$db->open($index_path, $HyperEstraier::ESTDBREADER);
+	my $db;
+	if ($index_path) {
+		$db = HyperEstraier::Database->new();
+		$db->open($index_path, $HyperEstraier::ESTDBREADER);
+	} elsif ($index_node_url) {
+		$db ||= HyperEstraier::Node->new($index_node_url);
+		$db->set_auth('admin', 'admin');
+	} else {
+		die "BUG: unimplemented";
+	}
 
 	# create a search condition object
 	my $cond = HyperEstraier::Condition->new();
@@ -219,17 +242,32 @@
 	$cond->set_order( 'date NUMA' );
 
 	# get the result of search
-	my $result = $db->search($cond, 0);
-
 	my @res;
-	my $hits = $result->size;
+	my ($result, $hits);
+
+	if ($index_path) {
+		$result = $db->search($cond, 0);
+		$hits = $result->size;
+	} elsif ($index_node_url) {
+		$result = $db->search($cond, 0);
+		$hits = $result->doc_num;
+	} else {
+		die "BUG: unimplemented";
+	}
 
 	# for each document in result
 	for my $i ($offset .. ($offset + $on_page - 1)) {
 		last if ($i >= $hits);
 
-		my $id = $result->get($i);
-		my $doc = $db->get_doc($id, 0);
+		my $doc;
+		if ($index_path) {
+			my $id = $result->get($i);
+			$doc = $db->get_doc($id, 0);
+		} elsif ($index_node_url) {
+			$doc = $result->get_doc($i);
+		} else {
+			die "BUG: unimplemented";
+		}
 
 		my $row;
 		foreach my $c (qw/fid hname sname backupnum fiilename filepath date type size/) {
@@ -241,25 +279,49 @@
 	return ($hits, \@res);
 }
 
+sub getGzipName($$$)
+{
+	my ($host, $share, $backupnum) = @_;
+	my $ret = $Conf{GzipSchema};
+	
+	$share =~ s/\//_/g;
+	$ret =~ s/\\h/$host/ge;
+	$ret =~ s/\\s/$share/ge;
+	$ret =~ s/\\n/$backupnum/ge;
+	
+	return $ret;
+	
+}
+
 sub getBackupsNotBurned() {
 
 	my $dbh = get_dbh();
-	my $sql = q{ 
-	SELECT
-		backups.hostID		AS hostid,
-		min(hosts.name)		AS host,
-		min(shares.name)	AS share,
-		backups.num		AS backupnum,
-		min(backups.type)	AS type,
-		min(backups.date)	AS date,
-		min(backups.size)	AS size
-	FROM files 
-		INNER JOIN shares	ON files.shareID=shares.ID
-		INNER JOIN hosts	ON hosts.ID = shares.hostID
-		INNER JOIN backups	ON backups.num = files.backupnum and backups.hostID = hosts.ID AND backups.shareID = shares.ID
-	GROUP BY 
-		backups.hostID, backups.num, backups.shareid
-	ORDER BY min(backups.date)
+
+	my $sql = q{
+		SELECT 
+			backups.hostID AS hostID,
+			hosts.name AS host,
+			shares.name AS share,
+			backups.id AS backupnum,
+			backups.type AS type,
+			backups.date AS date,
+			backups.size AS size
+		FROM backups 
+		INNER JOIN shares	ON backups.shareID=shares.ID
+		INNER JOIN hosts	ON backups.hostID = hosts.ID
+		LEFT OUTER JOIN archive_backup ON archive_backup.backup_id = backups.id AND archive_backup.backup_id IS NULL
+		WHERE backups.size > 0
+		GROUP BY
+		        backups.hostID,
+			hosts.name,
+			shares.name,
+			backups.num,
+			backups.shareid,
+			backups.id,
+			backups.type,
+			backups.date,
+			backups.size
+		ORDER BY backups.date
 	};
 	my $sth = $dbh->prepare( $sql );
 	my @ret;
@@ -268,57 +330,317 @@
 	while ( my $row = $sth->fetchrow_hashref() ) {
 		$row->{'age'} = sprintf("%0.1f", ( (time() - $row->{'date'}) / 86400 ) );
 		$row->{'size'} = sprintf("%0.2f", $row->{'size'} / 1024 / 1024);
+		my (undef,undef,undef,undef,undef,undef,undef,$fs_size,undef,undef,undef,undef,undef) = 
+	        	stat( $Conf{InstallDir}.'/'.$Conf{GzipTempDir}.'/'.
+	        		getGzipName($row->{'host'}, $row->{share}, $row->{'backupnum'}));
+		$row->{'fs_size'} = $fs_size;
 		push @ret, $row;
 	}
       
 	return @ret;      
 }
 
-sub displayBackupsGrid()
-  {
-      my $retHTML = "";
-      
-	$retHTML .= <<EOF3;
+sub displayBackupsGrid() {
+
+	my $retHTML .= q{
+		<form id="forma" method="POST" action=};
+		$retHTML .= "\"".$MyURL."\"";
+		$retHTML .= q{?action=burn>
+	};
+
+	$retHTML .= <<'EOF3';
+<style>
+<!--
+
+div#fixedBox {
+	position: absolute;
+	bottom: 1em;
+	left: 0.5em;
+	padding: 0.5em;
+	width: 10em;
+	background: #e0f0e0;
+	border: 1px solid #00ff00;
+}
+@media screen {
+	div#fixedBox {
+		position: fixed;
+	}
+	/* Don't do this at home */
+	* html {
+		overflow-y: hidden;
+	}
+	* html body {
+		overflow-y: auto;
+		height: 100%;
+		padding: 0 1em 0 12em;
+		font-size: 100%;
+	}
+	* html div#fixedBox {
+		position: absolute;	
+	}
+	/* All done. */
+}
+
+#mContainer {
+	position: relative;
+	width: 100%;
+	height: 1.1em;
+	padding: 0px;
+	border: 1px solid #000000;
+}
+
+#gradient {
+	position: absolute;
+	top: 0px;
+	left: 0px;
+	width: 100%;
+	height: 100%;
+	display: block;
+	background-color: #ffff00;
+}
+
+#mask {
+	position: absolute;
+	top: 0px;
+	left: 0px;
+	width: 100%;
+	height: 100%;
+	display: block;
+	font-size: 1px;
+	background-color: #FFFFFF;
+	overflow: hidden;
+}
+
+#progressIndicator {
+	position: absolute;
+	top: 0px;
+	left: 0px;
+	width: 100%;
+	height: 100%;
+	display: block;
+	font-weight: bold;
+	color: #404040;
+	font-size: 10pt;
+	text-align: center;
+}
+
+-->
+</style>
 <script language="javascript" type="text/javascript">
 <!--
 
-    function checkAll(location)
-    {
-      for (var i=0;i<document.forma.elements.length;i++)
-      {
-        var e = document.forma.elements[i];
-        if ((e.checked || !e.checked) && e.name != \'all\') {
-            if (eval("document.forma."+location+".checked")) {
-                e.checked = true;
-            } else {
-                e.checked = false;
-            }
-        }
-      }
-    }
+var debug_div = null;
+var media_size = 4400 * 1024;
+
+function debug(msg) {
+//	return; // Disable debugging
+
+	if (! debug_div) debug_div = document.getElementById('debug');
+
+	// this will create debug div if it doesn't exist.
+	if (! debug_div) {
+		debug_div = document.createElement('div');
+		if (document.body) document.body.appendChild(debug_div);
+		else debug_div = null;
+	}
+	if (debug_div) {
+		debug_div.appendChild(document.createTextNode(msg));
+		debug_div.appendChild(document.createElement("br"));
+	}
+}
+
+
+var element_id_cache = Array();
+
+function element_id(name,element) {
+	if (! element_id_cache[name]) {
+		element_id_cache[name] = self.document.getElementById(name);
+	}
+	return element_id_cache[name];
+}
+
+function checkAll(location) {
+	var len = element_id('forma').elements.length;
+	var check_all = element_id('allFiles');
+	var suma = 0;
+
+	for (var i = 0; i < len; i++) {
+
+		var e = element_id('forma').elements[i];
+		if (e.name != 'all' && e.name.substr(0,3) == 'fcb') {
+			if (check_all.checked) {
+				var el = element_id("fss" + e.name.substr(3));
+				var size = parseInt(el.value) || 0;
+				debug('suma: '+suma+' size: '+size);
+				if ((suma + size) < media_size) {
+					suma += size;
+					e.checked = true;
+				} else {
+					break;
+				}
+			} else {
+				e.checked = false;
+			}
+		}
+	}
+	update_sum(suma);
+}
+
+function update_sum(suma) {
+	element_id('forma').totalsize.value = suma;
+	pbar_set(suma, media_size);
+	debug('total size: '+suma);
+}
+
+function sumiraj(e) {
+	var suma = parseInt(element_id('forma').totalsize.value) || 0;
+	var len = element_id('forma').elements.length;
+	if (e) {
+		var size = parseInt( element_id("fss" + e.name.substr(3)).value );
+		if (e.checked) {
+			suma += size;
+		} else {
+			suma -= size;
+		}
+	} else {
+		suma = 0;
+		for (var i = 0; i < len; i++) {
+			var e = element_id('forma').elements[i];
+			if (e.name != 'all' && e.checked && e.name.substr(0,3) == 'fcb') {
+				var el = element_id("fss" + e.name.substr(3));
+				if (el && el.value) suma += parseInt(el.value) || 0;
+			}
+		}
+	}
+	update_sum(suma);
+    	return suma;
+}
+
+/* progress bar */
+
+var _pbar_width = 0;
+var _pbar_warn = 10;	// change color in last 10%
+
+function pbar_reset() {
+	element_id("mask").style.left = "0px";
+	_pbar_width = element_id("mContainer").offsetWidth - 2;
+	element_id("mask").style.width = _pbar_width + "px";
+	element_id("progressIndicator").style.zIndex  = 10;
+	element_id("mask").style.display = "block";
+	element_id("progressIndicator").innerHTML = "0";
+}
+
+function dec2hex(d) {
+        var hch="0123456789ABCDEF";
+        var a=d%16;
+        var q=(d-a)/16;
+        return hch.charAt(q)+hch.charAt(a);
+}
+
+
+function pbar_set(amount, max) {
+
+	debug('pbar_set( '+amount+' , '+max+' )');
+
+	curWidth = parseInt(element_id("mask").offsetWidth);
+	curLeft = parseInt(element_id("mask").offsetLeft);
+
+
+	var pcnt = Math.floor( amount * 100 / max );
+	var p90 = 100 - _pbar_warn;
+	var pcol = pcnt - p90;
+	if (pcol < _pbar_warn) {
+		if (pcol < 0) pcol = 0;
+		var e = element_id("submitBurner");
+		if (e && e.disabled) {
+			debug('enable_button');
+			var a = e.getAttributeNode('disabled') || null;
+			if (a) e.removeAttributeNode(a);
+		}
+	} else if (pcol > _pbar_warn) {
+		debug('disable button');
+		pcol = _pbar_warn;
+		var e = element_id("submitBurner");
+		if (! e.disabled) e.disabled = true;
+	}
+	var col_g = Math.floor( ( _pbar_warn - pcol ) * 255 / _pbar_warn );
+	var col = '#ff' + dec2hex( col_g ) + '00';
+
+	//debug('pcol: '+pcol+' g:'+col_g+' _pbar_warn:'+ _pbar_warn + ' color: '+col);
+	element_id("gradient").style.backgroundColor = col;
+
+	var size = parseInt( _pbar_width * amount / max );
+
+	curWidth = _pbar_width - size;
+	curLeft = size ;
+
+	//debug('size: '+size+' curWidth '+curWidth+' curLeft: '+curLeft);
+
+	element_id("progressIndicator").innerHTML = pcnt + '%';
+	//element_id("progressIndicator").innerHTML = amount;
+
+	if (curLeft > _pbar_width) {
+		element_id("mask").style.display = "none";
+		return;
+	} else {
+		element_id("mask").style.display = "";
+	}
+
+	//if(parseInt(element_id("mask").offsetWidth)>10)
+	element_id("mask").style.width = curWidth + "px";
+	element_id("mask").style.left = curLeft + "px";
+
+}
+
+if (!self.body) self.body = new Object();
+self.onload = self.document.onload = self.body.onload = function() {
+	pbar_reset();
+	sumiraj();
+}
+
 //-->
-</script>      
+</script>
+<div id="fixedBox">
+
+Size:
+<input type="text" name="totalsize" size="7" readonly>
+
+<div id="mContainer">
+	<div id="gradient"></div>
+	<div id="mask"></div>
+	<div id="progressIndicator">&nbsp;</div>
+</div>
+
+<br/>
+Note:
+<br/>
+<textarea name="note" cols="10" rows="5">
+</textarea>
+<br/>
+<input type="submit" id="submitBurner" value="Burn selected" name="submitBurner">
+
+</div>
+<div id="debug" style="float: right; width: 10em; border: 1px #ff0000 solid; background-color: #ffe0e0; -moz-opacity: 0.7;">
+no debug output yet
+</div>
 EOF3
 	$retHTML .= q{
-		<form name="forma" method="GET" action="$MyURL?action=burn">
-		<input type="hidden" value="burn" name="action">
-		<input type="hidden" value="results" name="search_results">
-		<table style="fview" border="0" cellspacing="0" cellpadding="2">
-		<tr class="tableheader">
-		<td class="tableheader">
-			<input type="checkbox" name="allFiles" onClick="checkAll('allFiles');">
-		</td>
-		<td align="center">Share</td>
-		<td align="center">Backup no</td>
-		<td align="center">Type</td>
-		<td align="center">date</td>
-		<td align="center">age/days</td>
-		<td align="center">size/MB</td>
-		</tr>
-
-		<tr><td colspan=7 style="tableheader">
-		<input type="submit" value="Burn selected backups on medium" name="submitBurner">
-		</td></tr>
+			<input type="hidden" value="burn" name="action">
+			<input type="hidden" value="results" name="search_results">
+			<table style="fview" border="0" cellspacing="0" cellpadding="2">
+			<tr class="tableheader">
+			<td class="tableheader">
+				<input type="checkbox" name="allFiles" id="allFiles" onClick="checkAll('allFiles');">
+			</td>
+			<td align="center">Share</td>
+			<td align="center">Backup no</td>
+			<td align="center">Type</td>
+			<td align="center">date</td>
+			<td align="center">age/days</td>
+			<td align="center">size/MB</td>
+			<td align="center">gzip size</td>
+			</tr>
+
 	};
 
 	my @color = (' bgcolor="#e0e0e0"', '');
@@ -333,23 +655,31 @@
 			$host = $backup->{'host'};
 		}
 		my $ftype = "";
-	    
-		$retHTML .= "<tr" . $color[$i %2 ] . ">";
-		$retHTML .= '<td class="fview"><input type="checkbox" name="fcb' .
-				$backup->{'hostid'}.'_'.$backup->{'backupnum'} . 
-				'" value="' . $backup->{'hostid'}.'_'.$backup->{'backupnum'} .
-				'"></td>';
-	    
+
+		$retHTML .=
+			'<tr' . $color[$i %2 ] . '>
+			<td class="fview">';
+		# FIXME
+		$backup->{'fs_size'} = int($backup->{'size'} * 1024);
+		if (($backup->{'fs_size'} || 0) > 0) {
+			$retHTML .= '
+			<input type="checkbox" name="fcb' .
+			$backup->{'hostid'}.'_'.$backup->{'backupnum'} . 
+			'" value="' . $backup->{'hostid'}.'_'.$backup->{'backupnum'} .
+			'" onClick="sumiraj(this);">';
+		}
 		$retHTML .=
+			'</td>' .
 			'<td align="right">' . $backup->{'host'} . ':' . $backup->{'share'} . '</td>' .
 			'<td align="center">' . $backup->{'backupnum'} . '</td>' .
 			'<td align="center">' . $backup->{'type'} . '</td>' .
 			'<td align="center">' . epoch_to_iso( $backup->{'date'} ) . '</td>' .
 			'<td align="center">' . $backup->{'age'} . '</td>' .
 			'<td align="right">' . $backup->{'size'} . '</td>' .
-			"</tr>\n";
-
+			'<td align="right">' . $backup->{'fs_size'} .
+			'<input type="hidden" iD="fss'.$backup->{'hostid'}.'_'.$backup->{'backupnum'} . '" value="'. $backup->{'fs_size'} .'"></td>' .
 
+			"</tr>\n";
 	}
 
 	$retHTML .= "</table>";