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/fossologyTestRepo/$REPO_NAME")) {
      exec("sudo chmod 2770 /srv/fossologyTestRepo/$REPO_NAME"); // change mode to 2770
      exec("sudo chown fossy /srv/fossologyTestRepo/$REPO_NAME -R"); // change owner of REPO to fossy
      exec("sudo chgrp fossy /srv/fossologyTestRepo/$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;
}

?>