test_common.php

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

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

   This program 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 General Public License for more details.

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

function create_db()
{
  global $SYSCONF_DIR;
  global $DB_NAME;
  global $REPO_NAME;
  global $PG_CONN;
  global $DB_COMMAND;

  // print "DB_COMMAND is:$DB_COMMAND\n";
  exec($DB_COMMAND, $dbout, $rc);
  preg_match("/(\d+)/", $dbout[0], $matches);
  $test_name = $matches[1];
  $DB_NAME = "fosstest".$test_name;
  $REPO_NAME = "testDbRepo".$test_name;
  $SYSCONF_DIR = $dbout[0];
  $PG_CONN = pg_connect("host=localhost port=5432 dbname=$DB_NAME user=fossy password=fossy")
                   or die("Could not connect");
  // print "DB_NAME is:$DB_NAME, $SYSCONF_DIR\n";
}

function drop_db()
{
  global $PG_CONN;
  global $DB_COMMAND;
  global $DB_NAME;
  pg_close($PG_CONN);
  exec("$DB_COMMAND -d $DB_NAME");
}

function get_upload_id($upload_info)
{
  $upload_id = 0;
  preg_match("/UploadPk is: '(\d+)'/", $upload_info, $matches);
  $upload_id = $matches[1];
  if (!$upload_id) {
    return false;
  } else {
    return $upload_id;
  }
}



function connect_to_DB($fossology_testconfig)
{
  $test_pg_conn = FALSE;

  $db_conf_file = $fossology_testconfig . "/Db.conf";

  $test_pg_conn = pg_connect(
    str_replace(";", " ", file_get_contents($db_conf_file)));

  if (empty($test_pg_conn)) {
    print "Error - could not connect to test db via $db_conf_file\n";
  } else {
    print "Successfully connected to test db\n";
  }
  return ($test_pg_conn);
}

function check_agent_status($test_dbh, $agent_name, $upload_id)
{
  #global $PG_CONN;
  $ars_table_name = $agent_name."_ars";
  $count = 0;
  $sql = "SELECT upload_fk FROM $ars_table_name where upload_fk = $upload_id and ars_success=true;";
  // print "sql is:$sql\n";
  #$result = pg_query($PG_CONN, $sql);
  $result = pg_query($test_dbh, $sql);
  $count = pg_num_rows($result);
  pg_free_result($result);
  if (1 == $count) {
    return 1;
  } else {
    return 0;
  }
}

function check_file_uploadtree($test_dbh, $file_name, $upload_id)
{
  $count = 0;
  $sql = "SELECT uploadtree_pk FROM uploadtree where upload_fk = $upload_id and ufile_name = '$file_name';";
  // print "sql is:$sql\n";
  $result = pg_query($test_dbh, $sql);
  $count = pg_num_rows($result);
  pg_free_result($result);
  if ($count > 0) {
    return 1; // exist
  } else {
    return 0; // not exist
  }
}

function add_user($user='fossy', $password='fossy')
{
  global $PG_CONN;
  /* User does not exist.  Create it. */
  $Seed = rand() . rand();
  $Hash = sha1($Seed . $password);
  $sql = "SELECT * FROM users WHERE user_name = '$user';";
  $result = pg_query($PG_CONN, $sql);
  $row0 = pg_fetch_assoc($result);
  pg_free_result($result);
  if (empty($row0['user_name'])) {
    /* User does not exist.  Create it. */
    $SQL = "INSERT INTO users (user_name,user_desc,user_seed,user_pass," .
      "user_perm,user_email,email_notify,root_folder_fk)
        VALUES ('$user','Default Administrator','$Seed','$Hash',10,'$password','y',1);";
    // $text = _("*** Created default administrator: '$user' with password '$password'.");
    $result = pg_query($PG_CONN, $SQL);
    pg_free_result($result);
  }
}

function preparations()
{
  global $SYSCONF_DIR;
  global $REPO_NAME;
  add_proxy(); // add proxy
  if (is_dir("/srv/fossology/$REPO_NAME")) {
    exec("sudo chmod 2770 /srv/fossology/$REPO_NAME"); // change mode to 2770
    exec("sudo chown fossy /srv/fossology/$REPO_NAME -R"); // change owner of REPO to fossy
    exec("sudo chgrp fossy /srv/fossology/$REPO_NAME -R"); // change grp of REPO to fossy
  }
  if (is_dir($SYSCONF_DIR)) {
    exec("sudo chown fossy $SYSCONF_DIR -R"); // change owner of sysconfdir to fossy
    exec("sudo chgrp fossy $SYSCONF_DIR -R"); // change grp of sysconfdir to fossy
  }
}

function stop_scheduler()
{
  global $SYSCONF_DIR;
  $scheduler_path = "$SYSCONF_DIR/mods-enabled/scheduler/agent/fo_scheduler";
  exec("sudo $scheduler_path -k");  // kill the running scheduler
}

function scheduler_operation()
{
  global $SYSCONF_DIR;
  $scheduler_path = "/usr/local/share/fossology/scheduler/agent/fo_scheduler";
  exec("sudo $scheduler_path -k");  // kill the default scheduler if running
  $scheduler_path = "$SYSCONF_DIR/mods-enabled/scheduler/agent/fo_scheduler";
  exec("sudo $scheduler_path -k");  // kill the running scheduler
  exec("sudo $scheduler_path --daemon --reset --verbose=952 -c $SYSCONF_DIR"); // start the scheduler
}

function add_proxy($proxy_type='http_proxy', $porxy='web-proxy.cce.hp.com:8088')
{
  global $SYSCONF_DIR;

  $foss_conf = $SYSCONF_DIR."/fossology.conf";
  exec("sudo sed 's/.$proxy_type.*=.*/$proxy_type=$porxy/' $foss_conf >/tmp/fossology.conf");
  exec("sudo mv /tmp/fossology.conf $foss_conf");
}

function get_uploadtree_id($test_dbh, $upload_id)
{
  $sql = "SELECT uploadtree_pk from uploadtree where upload_fk =$upload_id order by uploadtree_pk limit 1;";
  $result = pg_query($test_dbh, $sql);
  $row = pg_fetch_assoc($result);
  $uploadtree_id = $row['uploadtree_pk'];
  pg_free_result($result);
  return $uploadtree_id;
}