common-buckets.php

Go to the documentation of this file.

<?php
/***********************************************************
 Copyright (C) 2010-2014 Hewlett-Packard Development Company, L.P.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License version 2.1 as published by the Free Software Foundation.

 This library is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 Lesser General Public License for more details.

 You should have received a copy of the GNU Lesser General Public License
 along with this library; if not, write to the Free Software Foundation, Inc.0
 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 ***********************************************************/

function SelectBucketDataset($upload_pk, &$ars_pk, $id="selectbucketdataset", $extra="")
{
  global $PG_CONN;

  /* schedule bucket */
  $NoData = ActiveHTTPscript("Schedule");
  $NoData .= "<script language='javascript'>\n";
  $NoData .= "function Schedule_Reply()\n";
  $NoData .= "  {\n";
  $NoData .= "  if ((Schedule.readyState==4) && (Schedule.status==200))\n";
  $NoData .= "    document.getElementById('msgdiv').innerHTML = Schedule.responseText;\n";
  $NoData .= "  }\n";
  $NoData .= "</script>\n";

  $NoData .= "<form name='formy' method='post'>\n";
  $NoData .= "<div id='msgdiv'>\n";
  $NoData .= _("No data available.");
  $NoData .= "<input type='button' name='scheduleAgent' value='Schedule Agent'";
  $NoData .= "onClick='Schedule_Get(\"" . Traceback_uri() . "?mod=schedule_agent&upload=$upload_pk&agent=agent_bucket \")'>\n";
  $NoData .= "</input>";
  $NoData .= "</div> \n";
  $NoData .= "</form>\n";

  $name = $id;
  $select = "<select name='$name' id='$id' $extra>";

  /* get the bucketpool recs */
  $sql = "select ars_pk, bucketpool_pk, bucketpool_name, version from bucketpool, bucket_ars where active='Y' and bucketpool_fk=bucketpool_pk and ars_success=True and upload_fk='$upload_pk' order by ars_starttime desc";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  $NumRows = pg_num_rows($result);
  if ($NumRows == 0) {
    return $NoData;
  }
  $rows = pg_fetch_all($result);
  pg_free_result($result);
  if ($NumRows == 1) {
    $ars_pk = $rows[0]['ars_pk'];
    return ""; /* only one row */
  }

  /* Find the users default_bucketpool_fk */
  $sql = "select default_bucketpool_fk from users where user_pk='$_SESSION[UserId]'";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  $row = pg_fetch_assoc($result);
  $DefaultBucketpool_pk = $row['default_bucketpool_fk'];
  pg_free_result($result);

  /* Find the default selected row if ars_pk wasn't passed in */
  if (empty($ars_pk)) {
    foreach ($rows as $row) {
      if ($row['bucketpool_pk'] == $DefaultBucketpool_pk) {
        $ars_pk = $row['ars_pk'];
        break;
      }
    }
    reset($rows);
  }

  //  $select .= "<option value=''";
  foreach ($rows as $row) {
    $select .= "<option value='$row[ars_pk]'";

    if (empty($ars_pk)) {
      $select .= " SELECTED ";
      $ars_pk = $row["ars_pk"];
    } else if ($ars_pk == $row['ars_pk']) {
      $select .= " SELECTED ";
    }

    $select .= ">$row[bucketpool_name], v $row[version]\n";
  }
  $select .= "</select>";
  return $select;
}

function SelectBucketPool($selected, $active='Y')
{
  global $PG_CONN;

  $id = "default_bucketpool_fk";
  $name = $id;
  $select = "<select name='$name' id='$id' class='ui-render-select2'>";

  /* get the bucketpool recs */
  if ($active == 'Y') {
    $Where = "where active='Y'";
  } else {
    $Where = "";
  }
  $sql = "select * from bucketpool $Where order by bucketpool_name asc,version desc";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);

  while ($row = pg_fetch_assoc($result)) {
    $select .= "<option value='$row[bucketpool_pk]'";
    if ($row['bucketpool_pk'] == $selected) {
      $select .= " SELECTED ";
    }
    $select .= ">$row[bucketpool_name], v $row[version]</option>\n";
  }
  $select .= "</select>";
  return $select;
}

function GetFileBuckets($nomosagent_pk, $bucketagent_pk, $uploadtree_pk, $bucketpool_pk)
{
  global $PG_CONN;
  $BuckArray = array();

  if (empty($nomosagent_pk) || empty($bucketagent_pk) || empty($uploadtree_pk)) {
    Fatal(
      "Missing parameter: nomosagent_pk $nomosagent_pk, bucketagent_pk: $bucketagent_pk, uploadtree_pk: $uploadtree_pk<br>",
      __FILE__, __LINE__);
  }

  /* Find lft and rgt bounds for this $uploadtree_pk  */
  $sql = "SELECT lft,rgt,upload_fk FROM uploadtree
            WHERE uploadtree_pk = $uploadtree_pk";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  if (pg_num_rows($result) < 1) {
    pg_free_result($result);
    return $BuckArray;
  }
  $row = pg_fetch_assoc($result);
  $lft = $row["lft"];
  $rgt = $row["rgt"];
  $upload_pk = $row["upload_fk"];
  pg_free_result($result);

  /*select all the buckets for this tree */
  $sql = "SELECT distinct(bucket_fk) as bucket_pk
            from bucket_file, bucket_def,
                (SELECT distinct(pfile_fk) as PF from uploadtree
                   where upload_fk=$upload_pk
                     and ((ufile_mode & (1<<28))=0)
                     and uploadtree.lft BETWEEN $lft and $rgt) as SS
            where PF=pfile_fk and agent_fk=$bucketagent_pk
                  and bucket_file.nomosagent_fk=$nomosagent_pk
                    and bucket_pk=bucket_fk
                    and bucketpool_fk=$bucketpool_pk";

  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  while ($row = pg_fetch_assoc($result)) {
    $BuckArray[] = $row['bucket_pk'];
  }
  pg_free_result($result);

  return $BuckArray;
}


function GetFileBuckets_string($nomosagent_pk, $bucketagent_pk, $uploadtree_pk,
                               $bucketDefArray, $delimiter, $color)
{
  $outstr = "";
  $defrec = current($bucketDefArray);
  $bucketpool_pk = $defrec['bucketpool_fk'];
  $BuckArray = GetFileBuckets($nomosagent_pk, $bucketagent_pk, $uploadtree_pk, $bucketpool_pk);
  if (empty($BuckArray)) {
    return "";
  }

  /* convert array of bucket_pk's to array of bucket names */
  $BuckNames = array();
  foreach ($BuckArray as $bucket_pk) {
    $BuckNames[$bucket_pk] = $bucketDefArray[$bucket_pk]['bucket_name'];
  }

  /* sort $BuckArray */
  natcasesort($BuckNames);

  $first = true;
  foreach ($BuckNames as $bucket_name) {
    if ($first) {
      $first = false;
    } else {
      $outstr .= $delimiter . " ";
    }

    if ($color) {
      $bucket_pk = array_search($bucket_name, $BuckNames);
      $bucket_color = $bucketDefArray[$bucket_pk]['bucket_color'];
      $outstr .= "<span style='background-color:$bucket_color'>";
      $outstr .= $bucket_name;
      $outstr .= "</span>";
    } else {
      $outstr .= $bucket_name;
    }
  }

  return $outstr;
}


function BucketInTree($bucket_pk, $uploadtree_pk)
{
  global $PG_CONN;
  $BuckArray = array();

  if (empty($bucket_pk) || empty($uploadtree_pk)) {
    Fatal(
      "Missing parameter: bucket_pk: $bucket_pk, uploadtree_pk: $uploadtree_pk<br>",
      __FILE__, __LINE__);
  }

  /* Find lft and rgt bounds for this $uploadtree_pk  */
  $sql = "SELECT lft,rgt, upload_fk FROM uploadtree WHERE uploadtree_pk = $uploadtree_pk";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  if (pg_num_rows($result) < 1) {
    pg_free_result($result);
    return false;
  }
  $row = pg_fetch_assoc($result);
  $lft = $row["lft"];
  $rgt = $row["rgt"];
  $upload_fk = $row["upload_fk"];
  pg_free_result($result);

  /* search for bucket in tree */
  $sql = "SELECT bucket_fk from bucket_file,
            (SELECT distinct(pfile_fk) as PF from uploadtree
               where uploadtree.lft BETWEEN $lft and $rgt and upload_fk='$upload_fk') as SS
          where PF=pfile_fk and bucket_fk='$bucket_pk' limit 1";

  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  if (pg_num_rows($result) == 0) {
    $rv = false;
  } else {
    $rv = true;
  }
  pg_free_result($result);

  return $rv;
}


function initBucketDefArray($bucketpool_pk)
{
  global $PG_CONN;

  $sql = "select * from bucket_def where bucketpool_fk=$bucketpool_pk";
  $result_name = pg_query($PG_CONN, $sql);
  DBCheckResult($result_name, $sql, __FILE__, __LINE__);
  $bucketDefArray = array();
  while ($name_row = pg_fetch_assoc($result_name)) {
    $bucketDefArray[$name_row['bucket_pk']] = $name_row;
  }
  pg_free_result($result_name);
  return $bucketDefArray;
}