ajax-schedule-agent.php

<?php

use Fossology\Lib\Auth\Auth;
use Symfony\Component\HttpFoundation\Response;
/***********************************************************
 Copyright (C) 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.
***********************************************************/

define("TITLE_AJAX_SCHEDULE_AGENT", _("Schedule agent"));

class ajax_schedule_agent extends FO_Plugin
{
  function __construct()
  {
    $this->Name       = "schedule_agent";
    $this->Title      = TITLE_AJAX_SCHEDULE_AGENT;
    $this->DBaccess   = PLUGIN_DB_READ;
    parent::__construct();
  }


  public function Output()
  {
    global $Plugins;
    global $PG_CONN;
    $UploadPk = GetParm("upload",PARM_INTEGER);
    $Agent = GetParm("agent",PARM_STRING);
    if (empty($UploadPk) || empty($Agent)) {
      return new Response('missing parameter', Response::HTTP_BAD_REQUEST,
        array('Content-type' => 'text/plain'));
    }
    $sql = "SELECT upload_pk, upload_filename FROM upload WHERE upload_pk = '$UploadPk'";
    $result = pg_query($PG_CONN, $sql);
    DBCheckResult($result, $sql, __FILE__, __LINE__);
    if (pg_num_rows($result) < 1) {
      $errMsg = __FILE__ . ":" . __LINE__ . " " . _("Upload") . " " . $UploadPk .
        " " . _("not found");
      return new Response($errMsg, Response::HTTP_BAD_REQUEST,
        array('Content-type' => 'text/plain'));
    }
    $UploadRow = pg_fetch_assoc($result);
    $ShortName = $UploadRow['upload_filename'];
    pg_free_result($result);

    $user_pk = Auth::getUserId();
    $group_pk = Auth::getGroupId();
    $job_pk = JobAddJob($user_pk, $group_pk, $ShortName, $UploadPk);

    $Dependencies = array();
    $P = &$Plugins[plugin_find_id($Agent)];
    $rv = $P->AgentAdd($job_pk, $UploadPk, $ErrorMsg, $Dependencies);
    if ($rv <= 0) {
      $text = _("Scheduling of Agent(s) failed: ");
      return new Response($text . $rv . $ErrorMsg, Response::HTTP_BAD_REQUEST,
        array('Content-type' => 'text/plain'));
    }

    $status = GetRunnableJobList();
    $scheduler_msg = "";
    if (empty($status)) {
      $scheduler_msg .= _("Is the scheduler running? ");
    }

    $URL = Traceback_uri() . "?mod=showjobs&upload=$UploadPk";
    /* Need to refresh the screen */
    $text = _("Your jobs have been added to job queue.");
    $LinkText = _("View Jobs");
    $msg = "$scheduler_msg"."$text <a href=$URL>$LinkText</a>";
    $this->vars['message'] = $msg;
    return new Response($msg, Response::HTTP_OK, array('Content-type'=>'text/plain'));
  }
}

$NewPlugin = new ajax_schedule_agent;
$NewPlugin->Initialize();