LatestScannerProxy.php

<?php
/*
Copyright (C) 2014, Siemens AG

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.
*/

namespace Fossology\Lib\Proxy;

class LatestScannerProxy extends DbViewProxy
{
  const ARS_SUFFIX = '_ars';
  private $uploadId;
  private $columns = 'agent_pk, agent_name';

  public function __construct($uploadId, $agentNames=array('nomos','monk'), $dbViewName='latest_scanner', $andEnabled = "AND agent_enabled")
  {
    if (empty($agentNames)) {
      throw new \Exception('empty set of scanners');
    }
    $this->uploadId = $uploadId;
    $subqueries = array();
    foreach ($agentNames as $name) {
      // NOTE: this query fails if the ars-table is not yet created.
      $subqueries[] = "SELECT * FROM (SELECT $this->columns FROM $name".self::ARS_SUFFIX.", agent
        WHERE agent_fk=agent_pk AND upload_fk=$uploadId $andEnabled ORDER BY agent_fk DESC limit 1) latest_$name";
    }
    $dbViewQuery = implode(' UNION ',$subqueries);
    parent::__construct($dbViewQuery, $dbViewName."_".implode("_",$agentNames));
  }

  public function materialize()
  {
    if (!is_int($this->uploadId)) {
      throw new \Exception('cannot materialize LatestScannerProxy because upload Id is no number');
    }
    parent::materialize();
  }

  public function getNameToIdMap()
  {
    if (!is_int($this->uploadId)) {
      throw new \Exception('cannot map LatestScannerProxy because upload Id is no number');
    }
    global $container;
    $dbManager = $container->get('db.manager');
    $stmt = __METHOD__.".$this->dbViewName";
    if ($this->materialized) {
      $stmt .= '.m';
      $sql = "SELECT * FROM $this->dbViewName";
    } else {
      $sql = $this->dbViewQuery;
    }
    $map = array();

    if (! empty($sql)) {
      $dbManager->prepare($stmt, $sql);
      $res = $dbManager->execute($stmt, array());
      while ($row = $dbManager->fetchArray($res)) {
        $map[$row['agent_name']] = $row['agent_pk'];
      }
      $dbManager->freeResult($res);
    }
    return $map;
  }
}