AjaxAllJobStatus.php

<?php
/*
 SPDX-FileCopyrightText: © 2020 Siemens AG
 Author: Gaurav Mishra <mishra.gaurav@siemens.com>
 
 SPDX-License-Identifier: GPL-2.0-only
*/
namespace Fossology\UI\Ajax;
 
use Fossology\Lib\Auth\Auth;
use Fossology\Lib\Db\DbManager;
use Fossology\Lib\Plugin\DefaultPlugin;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpFoundation\JsonResponse;
use Fossology\Lib\Dao\ShowJobsDao;
 
class AjaxAllJobStatus extends DefaultPlugin
{
 
  const NAME = "ajax_all_job_status";
 
  private $dbManager;
 
  private $showJobDao;
 
  function __construct()
  {
    parent::__construct(self::NAME,
      array(
        self::PERMISSION => Auth::PERM_READ,
        self::REQUIRES_LOGIN => false
      ));
 
    $this->dbManager = $this->getObject('db.manager');
    $this->showJobDao = $this->getObject('dao.show_jobs');
  }
 
  public function handle(Request $request)
  {
    $results = $this->showJobDao->getJobsForAll();
    $uniqueTypes = array_unique(array_column($results, 'job'));
    $data = array();
 
    foreach ($uniqueTypes as $type) {
      $data[$type] = [];
      $data[$type]['running'] = 0;
      $data[$type]['pending'] = 0;
      $data[$type]['eta'] = 0;
      foreach ($results as $row) {
        if ($row['job'] != $type || empty($row['status'])) {
          continue;
        }
        $data[$type][$row['status']] ++;
        $newEta = $this->showJobDao->getEstimatedTime($row['jq_job_fk'],
          $row['job'], 0, $row['upload_fk'], 1);
        if (! empty($newEta)) {
          $data[$type]['eta'] = ($newEta > $data[$type]['eta']) ? $newEta:$data[$type]['eta'];
        }
      }
    }
 
    $returnData = array();
    foreach ($data as $agent => $row) {
      $dataRow = [
        "name" => $agent,
        "running" => $row["running"],
        "pending" => $row["pending"]
      ];
      if ($row['eta'] == 0) {
        $dataRow['eta'] = "N/A";
      } else {
        $dataRow['eta'] = intval($row["eta"] / 3600) .
          gmdate(":i:s", $row["eta"]);
      }
      $returnData[] = $dataRow;
    }
    $output = "";
    $error_msg = "";
    $schedStatus = "Running";
    $systemLoad = get_system_load_average();
    if (! fo_communicate_with_scheduler("status", $output, $error_msg)
      && strstr($error_msg, "Connection refused") !== false) {
      $schedStatus = "Stopped";
    }
    return new JsonResponse(["data" => $returnData, "scheduler" => $schedStatus, "systemLoad" => $systemLoad]);
  }
}
 
register_plugin(new AjaxAllJobStatus());