DeciderJobAgent.php

Go to the documentation of this file.

<?php
/*
 Author: Daniele Fognini
 SPDX-FileCopyrightText: © 2014 Siemens AG
 
 SPDX-License-Identifier: GPL-2.0-only
*/
namespace Fossology\DeciderJob;
 
use Fossology\Lib\Agent\Agent;
use Fossology\Lib\BusinessRules\AgentLicenseEventProcessor;
use Fossology\Lib\BusinessRules\ClearingDecisionProcessor;
use Fossology\Lib\BusinessRules\LicenseMap;
use Fossology\Lib\Dao\ClearingDao;
use Fossology\Lib\Dao\UploadDao;
use Fossology\Lib\Dao\HighlightDao;
use Fossology\Lib\Data\DecisionTypes;
use Fossology\Lib\Data\Tree\ItemTreeBounds;
 
define("CLEARING_DECISION_IS_GLOBAL", false);
 
include_once(__DIR__ . "/version.php");
 
class DeciderJobAgent extends Agent
{
  const FORCE_DECISION = 1;
 
  private $conflictStrategyId;
  private $uploadDao;
  private $clearingDecisionProcessor;
  private $agentLicenseEventProcessor;
  private $clearingDao;
  private $highlightDao;
  private $decisionIsGlobal = CLEARING_DECISION_IS_GLOBAL;
  private $decisionTypes;
  private $licenseMap = null;
  private $licenseMapUsage = null;
 
  function __construct($licenseMapUsage=null)
  {
    parent::__construct(AGENT_DECIDER_JOB_NAME, AGENT_DECIDER_JOB_VERSION, AGENT_DECIDER_JOB_REV);
 
    $this->uploadDao = $this->container->get('dao.upload');
    $this->clearingDao = $this->container->get('dao.clearing');
    $this->highlightDao = $this->container->get('dao.highlight');
    $this->decisionTypes = $this->container->get('decision.types');
    $this->clearingDecisionProcessor = $this->container->get('businessrules.clearing_decision_processor');
    $this->agentLicenseEventProcessor = $this->container->get('businessrules.agent_license_event_processor');
 
    $this->agentSpecifOptions = "k:";
    $this->licenseMapUsage = $licenseMapUsage;
  }
 
  function processClearingEventOfCurrentJob()
  {
    $userId = $this->userId;
    $groupId = $this->groupId;
    $jobId = $this->jobId;
 
    $eventsOfThisJob = $this->clearingDao->getEventIdsOfJob($jobId);
    foreach ($eventsOfThisJob as $uploadTreeId => $additionalEventsFromThisJob) {
      $containerBounds = $this->uploadDao->getItemTreeBounds($uploadTreeId);
      foreach ($this->loopContainedItems($containerBounds) as $itemTreeBounds) {
        $this->processClearingEventsForItem($itemTreeBounds, $userId, $groupId, $additionalEventsFromThisJob);
      }
    }
  }
 
  private function loopContainedItems($itemTreeBounds)
  {
    if (!$itemTreeBounds->containsFiles()) {
      return array($itemTreeBounds);
    }
    $result = array();
    $condition = "(ut.lft BETWEEN $1 AND $2) AND ((ut.ufile_mode & (3<<28)) = 0)";
    $params = array($itemTreeBounds->getLeft(), $itemTreeBounds->getRight());
    foreach ($this->uploadDao->getContainedItems($itemTreeBounds, $condition, $params) as $item) {
      $result[] = $item->getItemTreeBounds();
    }
    return $result;
  }
 
  function processUploadId($uploadId)
  {
    $args = $this->args;
    $this->conflictStrategyId = array_key_exists('k', $args) ? $args['k'] : null;
 
    $this->licenseMap = new LicenseMap($this->dbManager, $this->groupId, $this->licenseMapUsage);
 
    if ($this->conflictStrategyId == 'global') {
      $uploadTreeId = 0; // zero because we are checking candidate license for whole upload.
      if (!empty($this->clearingDao->getCandidateLicenseCountForCurrentDecisions($uploadTreeId, $uploadId))) {
        throw new \Exception( _("Cannot add candidate license as global decision\n") );
      }
      $this->heartbeat(1);
      $this->heartbeat($this->clearingDao->marklocalDecisionsAsGlobal($uploadId));
    } else {
      $this->processClearingEventOfCurrentJob();
    }
    return true;
  }
 
  protected function processClearingEventsForItem(ItemTreeBounds $itemTreeBounds, $userId, $groupId, $additionalEventsFromThisJob)
  {
    $this->dbManager->begin();
 
    $itemId = $itemTreeBounds->getItemId();
 
    switch ($this->conflictStrategyId) {
      case self::FORCE_DECISION:
        $createDecision = true;
        break;
 
      default:
        $createDecision = !$this->clearingDecisionProcessor->hasUnhandledScannerDetectedLicenses($itemTreeBounds, $groupId, $additionalEventsFromThisJob, $this->licenseMap);
    }
 
    if ($createDecision) {
      $this->clearingDecisionProcessor->makeDecisionFromLastEvents($itemTreeBounds, $userId, $groupId, DecisionTypes::IDENTIFIED, $this->decisionIsGlobal, $additionalEventsFromThisJob);
    } else {
      foreach ($additionalEventsFromThisJob as $eventId) {
        $this->clearingDao->copyEventIdTo($eventId, $itemId, $userId, $groupId);
      }
      $this->clearingDao->markDecisionAsWip($itemId, $userId, $groupId);
    }
    $this->heartbeat(1);
 
    $this->dbManager->commit();
  }
}