lib/BackupPC/SearchLib.pm

#!/usr/bin/perl
package BackupPC::SearchLib;

use strict;
use BackupPC::CGI::Lib qw(:all);
use BackupPC::Attrib qw(:all);
use DBI;
use DateTime;
use vars qw(%In $MyURL);
use Time::HiRes qw/time/;

my $on_page = 100;
my $pager_pages = 10;

my $dsn = $Conf{SearchDSN};
my $db_user = $Conf{SearchUser} || '';

my $hest_index_path = $Conf{HyperEstraierIndex};

my $dbh;

sub get_dbh {
        $dbh ||= DBI->connect($dsn, $db_user, "", { RaiseError => 1, AutoCommit => 1 } );
        return $dbh;
}

sub getUnits() {
        my @ret;

        my $dbh = get_dbh();
        my $sth = $dbh->prepare(qq{
                SELECT
                        shares.id       as id,
                        hosts.name || ':' || shares.name as share
                FROM shares
                JOIN hosts on hostid = hosts.id
                ORDER BY share
        } );
        $sth->execute();
        push @ret, { 'id' => '', 'share' => '-'};       # dummy any

        while ( my $row = $sth->fetchrow_hashref() ) {
                push @ret, $row;
        }
        return @ret;
}

sub epoch_to_iso {
        my $t = shift || return;
        my $iso = BackupPC::Lib::timeStamp(undef, $t);
        $iso =~ s/\s/&nbsp;/g;
        return $iso;
}

sub dates_from_form($) {
        my $param = shift || return;

        sub mk_epoch_date($$) {
                my ($name,$suffix) = @_;

                my $yyyy = $param->{ $name . '_year_' . $suffix} || return undef;
                my $mm .= $param->{ $name . '_month_' . $suffix} ||
                        ( $suffix eq 'from' ? 1 : 12);
                my $dd .= $param->{ $name . '_day_' . $suffix} ||
                        ( $suffix eq 'from' ? 1 : 31);

                $yyyy =~ s/\D//g;
                $mm =~ s/\D//g;
                $dd =~ s/\D//g;

                my $dt = new DateTime(
                        year => $yyyy,
                        month => $mm,
                        day => $dd
                );
                print STDERR "mk_epoch_date($name,$suffix) [$yyyy-$mm-$dd] = " . $dt->ymd . " " . $dt->hms . "\n";
                return $dt->epoch || 'NULL';
        }

        my @ret = (
                mk_epoch_date('search_backup', 'from'),
                mk_epoch_date('search_backup', 'to'),
                mk_epoch_date('search', 'from'),
                mk_epoch_date('search', 'to'),
        );

        return @ret;

}


sub getWhere($) {
        my $param = shift || return;

        my ($backup_from, $backup_to, $files_from, $files_to) = dates_from_form($param);

        my @conditions;
        push @conditions, qq{ backups.date >= $backup_from } if ($backup_from);
        push @conditions, qq{ backups.date <= $backup_to } if ($backup_to);
        push @conditions, qq{ files.date >= $files_from } if ($files_from);
        push @conditions, qq{ files.date <= $files_to } if ($files_to);

        print STDERR "backup: $backup_from - $backup_to files: $files_from - $files_to cond:" . join(" | ",@conditions);

        push( @conditions, ' files.shareid = ' . $param->{'search_share'} ) if ($param->{'search_share'});
        push (@conditions, " upper(files.path) LIKE upper('%".$param->{'search_filename'}."%')") if ($param->{'search_filename'});

        return join(" and ", @conditions);
}


sub getFiles($) {
        my ($param) = @_;

        my $offset = $param->{'offset'} || 0;
        $offset *= $on_page;

        my $dbh = get_dbh();

        my $sql_cols = qq{
                files.id                        AS fid,
                hosts.name                      AS hname,
                shares.name                     AS sname,
                files.backupnum                 AS backupnum,
                files.path                      AS filepath,
                files.date                      AS date,
                files.type                      AS type,
                files.size                      AS size
        };

        my $sql_from = qq{
                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 = files.shareID
        };

        my $sql_where;
        my $where = getWhere($param);
        $sql_where = " WHERE ". $where if ($where);

        my $sql_order = qq{
                ORDER BY files.date
                LIMIT $on_page
                OFFSET ?
        };

        my $sql_count = qq{ select count(files.id) $sql_from $sql_where };
        my $sql_results = qq{ select $sql_cols $sql_from $sql_where $sql_order };

        my $sth = $dbh->prepare($sql_count);
        $sth->execute();
        my ($results) = $sth->fetchrow_array();

        $sth = $dbh->prepare($sql_results);
        $sth->execute( $offset );

        if ($sth->rows != $results) {
                my $bug = "$0 BUG: [[ $sql_count ]] = $results while [[ $sql_results ]] = " . $sth->rows;
                $bug =~ s/\s+/ /gs;
                print STDERR "$bug\n";
        }

        my @ret;
      
        while (my $row = $sth->fetchrow_hashref()) {
                push @ret, $row;
        }
     
        $sth->finish();
        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 ($hest_index_path);

        use HyperEstraier;

        my ($index_path, $index_node_url) = getHyperEstraier_url($hest_index_path);

        # open the database
        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();

        my $q = $param->{'search_filename'};
        my $shareid = $param->{'search_share'};

        if (length($q) > 0) {
                # exact match
                $cond->add_attr("filepath ISTRINC $q");

                $q =~ s/(.)/$1 /g;
                # set the search phrase to the search condition object
                $cond->set_phrase($q);
        }

        my ($backup_from, $backup_to, $files_from, $files_to) = dates_from_form($param);

        $cond->add_attr("backup_date NUMGE $backup_from") if ($backup_from);
        $cond->add_attr("backup_date NUMLE $backup_to") if ($backup_to);

        $cond->add_attr("date NUMGE $files_from") if ($files_from);
        $cond->add_attr("date NUMLE $files_to") if ($files_to);

        $cond->add_attr("shareid NUMEQ $shareid") if ($shareid);

#       $cond->set_max( $offset + $on_page );
        $cond->set_options( $HyperEstraier::Condition::SURE );
        $cond->set_order( 'date NUMA' );

        # get the result of search
        my @res;
        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 $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/) {
                        $row->{$c} = $doc->attr($c);
                }
                push @res, $row;
        }

        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 getGzipSize($$)
{
        my ($hostID, $backupNum) = @_;
        my $ret;
        my $sql;
        my $dbh = get_dbh();
        
        $sql = q{ 
                                SELECT hosts.name  as host,
                                           shares.name as share,
                                           backups.num as backupnum
                                FROM hosts, backups, shares
                                WHERE shares.id=backups.shareid AND
                                          hosts.id =backups.hostid AND
                                          hosts.id=? AND
                                          backups.num=?
                        };
        my $sth = $dbh->prepare($sql);
        $sth->execute($hostID, $backupNum);

        my $row = $sth->fetchrow_hashref();
        
        my (undef,undef,undef,undef,undef,undef,undef,$ret,undef,undef,undef,undef,undef) = 
                        stat( $Conf{InstallDir}.'/'.$Conf{GzipTempDir}.'/'.
                                getGzipName($row->{'host'}, $row->{share}, $row->{'backupnum'}));
        
        return $ret;    
}

sub getBackupsNotBurned() {

        my $dbh = get_dbh();

        my $sql = q{
                SELECT 
                        backups.hostID AS hostID,
                        hosts.name AS host,
                        shares.name AS share,
                        backups.num AS backupnum,
                        backups.type AS type,
                        backups.date AS date,
                        backups.size AS size,
                        backups.id AS id
                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 
                WHERE backups.size > 0 AND archive_backup.backup_id IS NULL
                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;
        $sth->execute();

        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 .= q{
                <form id="forma" method="POST" action="}.$MyURL.q{?action=burn">
        };

        $retHTML .= <<'EOF3';
<style type="text/css">
<!--
DIV#fixedBox {
        position: absolute;
        top: 50em;
        left: -24%;
        padding: 0.5em;
        width: 20%;
        background-color: #E0F0E0;
        border: 1px solid #00C000;
}

DIV#fixedBox, DIV#fixedBox INPUT, DIV#fixedBox TEXTAREA {
        font-size: 10pt;
}

FORM>DIV#fixedBox {
        position: fixed !important;
        left: 0.5em !important;
        top: auto !important;
        bottom: 1em !important;
        width: 15% !important;
}

DIV#fixedBox INPUT[type=text], DIV#fixedBox TEXTAREA {
        border: 1px solid #00C000;
}

DIV#fixedBox #note {
        display: block;
        width: 100%;
}

DIV#fixedBox #submitBurner {
        display: block;
        width: 100%;
        margin-top: 0.5em;
        cursor: pointer;
}

* HTML {
        overflow-y: hidden;
}

* HTML BODY {
        overflow-y: auto;
        height: 100%;
        font-size: 100%;
}

* HTML DIV#fixedBox {
        position: absolute;
}

#mContainer, #gradient, #mask, #progressIndicator {
        display: block;
        width: 100%;
        font-size: 10pt;
        font-weight: bold;
        text-align: center;
        vertical-align: middle;
        padding: 1px;
}

#gradient, #mask, #progressIndicator {
        left: 0;
        border-width: 1px;
        border-style: solid;
        border-color: #000000;
        color: #404040;
        margin: 0.4em;
        position: absolute;
        margin-left: -1px;
        margin-top: -1px;
        margin-bottom: -1px;
        overflow: hidden;
}

#mContainer {
        display: block;
        position: relative;
        padding: 0px;
        margin-top: 0.4em;
        margin-bottom: 0.5em;
}

#gradient {
        z-index: 1;
        background-color: #FFFF00;
}

#mask {
        z-index: 2;
        background-color: #FFFFFF;
}

#progressIndicator {
        z-index: 3;
        background-color: transparent;
}
-->
</style>
<script type="text/javascript">
<!--

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 f = element_id('forma') || null;
        if (!f) return false;

        var len = f.elements.length;
        var check_all = element_id('allFiles');
        var suma = check_all.checked ? (parseInt(f.elements['totalsize'].value) || 0) : 0;

        for (var i = 0; i < len; i++) {
                var e = f.elements[i];
                if (e.name != 'all' && e.name.substr(0, 3) == 'fcb') {
                        if (check_all.checked) {
                                if (e.checked) continue;
                                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').elements['totalsize'].value = suma;
        pbar_set(suma, media_size);
        debug('total size: ' + suma);
}

function sumiraj(e) {
        var suma = parseInt(element_id('forma').elements['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 = null;
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("mask").style.display = "block";
        element_id("progressIndicator").style.zIndex  = 10;
        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+')');

        if (_pbar_width == null) {
                var _mc = element_id("mContainer");
                if (_pbar_width == null) _pbar_width = parseInt(_mc.offsetWidth ? (_mc.offsetWidth - 2) : 0) || null;
                if (_pbar_width == null) _pbar_width = parseInt(_mc.clientWidth ? (_mc.clientWidth + 2) : 0) || null;
                if (_pbar_width == null) _pbar_width = 0;
        }

        var pcnt = Math.floor(amount * 100 / max);
        var p90 = 100 - _pbar_warn;
        var pcol = pcnt - p90;
        if (Math.round(pcnt) <= 100) {
                if (pcol < 0) pcol = 0;
                var e = element_id("submitBurner");
                debug('enable_button');
                e.disabled = false;
                var a = e.getAttributeNode('disabled') || null;
                if (a) e.removeAttributeNode(a);
        } else {
                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;

        element_id("progressIndicator").innerHTML = pcnt + '%';
        //element_id("progressIndicator").innerHTML = amount;

        element_id("mask").style.clip = 'rect(' + Array(
                '0px',
                element_id("mask").offsetWidth + 'px',
                element_id("mask").offsetHeight + 'px',
                Math.round(_pbar_width * amount / max) + 'px'
        ).join(' ') + ')';
}

if (!self.body) self.body = new Object();
self.onload = self.document.onload = self.body.onload = function() {
        //pbar_reset();
        sumiraj();
};

// -->
</script>
<div id="fixedBox">

Size: <input type="text" name="totalsize" size="7" readonly="readonly" style="text-align:right;" value="0" /> kB

<div id="mContainer">
        <div id="gradient">&nbsp;</div>
        <div id="mask">&nbsp;</div>
        <div id="progressIndicator">0%</div>
</div>
<br/>

Note:
<textarea name="note" cols="10" rows="5" id="note"></textarea>

<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{
                        <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"', '');

        my $i = 0;
        my $host = '';

        foreach my $backup ( getBackupsNotBurned() ) {

                if ($host ne $backup->{'host'}) {
                        $i++;
                        $host = $backup->{'host'};
                }
                my $ftype = "";

                my $checkbox_key = $backup->{'hostid'}. '_' .$backup->{'backupnum'} . '_' . $backup->{'id'};

                $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' . $checkbox_key . '" value="' . $checkbox_key . '" 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>' .
                        '<td align="right">' . $backup->{'fs_size'} .
                        '<input type="hidden" iD="fss'.$checkbox_key .'" value="'. $backup->{'fs_size'} .'"></td>' .

                        "</tr>\n";
        }

        $retHTML .= "</table>";
        $retHTML .= "</form>";
      
        return $retHTML;
}      

sub displayGrid($) {
        my ($param) = @_;

        my $offset = $param->{'offset'};
        my $hilite = $param->{'search_filename'};

        my $retHTML = "";
 
        my $start_t = time();

        my ($results, $files);
        if ($param->{'use_hest'} && length($hilite) > 0) {
                ($results, $files) = getFilesHyperEstraier($param);
        } else {
                ($results, $files) = getFiles($param);
        }

        my $dur_t = time() - $start_t;
        my $dur = sprintf("%0.4fs", $dur_t);

        my ($from, $to) = (($offset * $on_page) + 1, ($offset * $on_page) + $on_page);

        if ($results <= 0) {
                $retHTML .= qq{
                        <p style="color: red;">No results found...</p>
                };
                return $retHTML;
        } else {
                # DEBUG
                #use Data::Dumper;
                #$retHTML .= '<pre>' . Dumper($files) . '</pre>';
        }


        $retHTML .= qq{
        <div>
        Found <b>$results files</b> showing <b>$from - $to</b> (took $dur)
        </div>
        <table style="fview" width="100%" border="0" cellpadding="2" cellspacing="0">
                <tr class="fviewheader"> 
                <td></td>
                <td align="center">Share</td>
                <td align="center">Type and Name</td>
                <td align="center">#</td>
                <td align="center">Size</td>
                <td align="center">Date</td>
                <td align="center">Media</td>
                </tr>
        };

        my $file;

        sub hilite_html($$) {
                my ($html, $search) = @_;
                $html =~ s#($search)#<b>$1</b>#gis;
                return $html;
        }

        sub restore_link($$$$$$) {
                my $type = shift;
                my $action = 'RestoreFile';
                $action = 'browse' if (lc($type) eq 'dir');
                return sprintf(qq{<a href="?action=%s&host=%s&num=%d&share=%s&dir=%s">%s</a>}, $action, @_);
        }

        my $i = $offset * $on_page;

        foreach $file (@{ $files }) {
                $i++;

                my $typeStr  = BackupPC::Attrib::fileType2Text(undef, $file->{'type'});
                $retHTML .= qq{<tr class="fviewborder">};

                $retHTML .= qq{<td class="fviewborder">$i</td>};

                $retHTML .=
                        qq{<td class="fviewborder" align="right">} . $file->{'hname'} . ':' . $file->{'sname'} . qq{</td>} .
                        qq{<td class="fviewborder"><img src="$Conf{CgiImageDirURL}/icon-$typeStr.gif" alt="$typeStr" align="middle">&nbsp;} . hilite_html( $file->{'filepath'}, $hilite ) . qq{</td>} .
                        qq{<td class="fviewborder" align="center">} . restore_link( $typeStr, ${EscURI( $file->{'hname'} )}, $file->{'backupnum'}, ${EscURI( $file->{'sname'})}, ${EscURI( $file->{'filepath'} )}, $file->{'backupnum'} ) . qq{</td>} .
                        qq{<td class="fviewborder" align="right">} . $file->{'size'} . qq{</td>} .
                        qq{<td class="fviewborder">} . epoch_to_iso( $file->{'date'} ) . qq{</td>} .
                        qq{<td class="fviewborder">} . '?' . qq{</td>};

                $retHTML .= "</tr>";
        }
        $retHTML .= "</table>";

        # all variables which has to be transfered
        foreach my $n (qw/search_day_from search_month_from search_year_from search_day_to search_month_to search_year_to search_backup_day_from search_backup_month_from search_backup_year_from search_backup_day_to search_backup_month_to search_backup_year_to search_filename offset/) {
                $retHTML .= qq{<INPUT TYPE="hidden" NAME="$n" VALUE="$In{$n}">\n};
        }

        my $del = '';
        my $max_page = int( $results / $on_page );
        my $page = 0;

        sub page_link($$$) {
                my ($param,$page,$display) = @_;

                $param->{'offset'} = $page;

                my $html = '<a href = "' . $MyURL;
                my $del = '?';
                foreach my $k (keys %{ $param }) {
                        if ($param->{$k}) {
                                $html .= $del . $k . '=' . ${EscURI( $param->{$k} )};
                                $del = '&';
                        }
                }
                $html .= '">' . $display . '</a>';
        }

        $retHTML .= '<div style="text-align: center;">';

        if ($offset > 0) {
                $retHTML .= page_link($param, $offset - 1, '&lt;&lt;') . ' ';
        }

        while ($page <= $max_page) {
                if ($page == $offset) {
                        $retHTML .= $del . '<b>' . ($page + 1) . '</b>';
                } else {
                        $retHTML .= $del . page_link($param, $page, $page + 1);
                }

                if ($page < $offset - $pager_pages && $page != 0) {
                        $retHTML .= " ... ";
                        $page = $offset - $pager_pages;
                        $del = '';
                } elsif ($page > $offset + $pager_pages && $page != $max_page) {
                        $retHTML .= " ... ";
                        $page = $max_page;
                        $del = '';
                } else {
                        $del = ' | ';
                        $page++;
                }
        }

        if ($offset < $max_page) {
                $retHTML .= ' ' . page_link($param, $offset + 1, '&gt;&gt;');
        }

        $retHTML .= "</div>";

        return $retHTML;
}

1;