UploadDaoTest.php

<?php
/*
 SPDX-FileCopyrightText: © 2014-2015 Siemens AG
 Author: Steffen Weber, Johannes Najjar
 
 SPDX-License-Identifier: GPL-2.0-only
*/
 
namespace Fossology\Lib\Dao;
 
use DateTime;
use Exception;
use Fossology\Lib\Data\Tree\Item;
use Fossology\Lib\Data\Tree\ItemTreeBounds;
use Fossology\Lib\Data\Upload\UploadEvents;
use Fossology\Lib\Db\DbManager;
use Fossology\Lib\Test\TestPgDb;
use Mockery as M;
 
class UploadDaoTest extends \PHPUnit\Framework\TestCase
{
  private $testDb;
  private $dbManager;
  private $uploadDao;
 
  protected function setUp() : void
  {
    $this->testDb = new TestPgDb();
    $this->dbManager = &$this->testDb->getDbManager();
 
    $this->testDb->createPlainTables(array('upload', 'uploadtree',
      'report_info', 'upload_events'));
 
    $this->dbManager->prepare($stmt = 'insert.upload',
        "INSERT INTO upload (upload_pk, uploadtree_tablename) VALUES ($1, $2)");
    $uploadArray = array(array(1, 'uploadtree'), array(2, 'uploadtree_a'));
    foreach ($uploadArray as $uploadEntry) {
      $this->dbManager->freeResult($this->dbManager->execute($stmt, $uploadEntry));
    }
    $logger = M::mock('Monolog\Logger'); // new Logger("UploadDaoTest");
    $logger->shouldReceive('debug');
    $uploadPermissionDao = M::mock('Fossology\Lib\Dao\UploadPermissionDao');
    $this->uploadDao = new UploadDao($this->dbManager, $logger, $uploadPermissionDao);
 
    $this->assertCountBefore = \Hamcrest\MatcherAssert::getCount();
  }
 
  protected function tearDown() : void
  {
    $this->addToAssertionCount(\Hamcrest\MatcherAssert::getCount()-$this->assertCountBefore);
    $this->testDb = null;
    $this->dbManager = null;
  }
 
  public function testGetFileTreeBounds()
  {
    $uploadTreeId = 103;
    $left = 1;
    $uploadId = 101;
    $this->dbManager->queryOnce("INSERT INTO uploadtree (uploadtree_pk, parent, upload_fk, pfile_fk, ufile_mode, lft, rgt, ufile_name)"
        . " VALUES ($uploadTreeId, NULL, $uploadId, 1, 33792, $left, 2, 'WXwindows.txt');",
        __METHOD__ . '.insert.data');
    $itemTreeBounds = $this->uploadDao->getItemTreeBounds($uploadTreeId);
    assertThat($itemTreeBounds, anInstanceOf('Fossology\Lib\Data\Tree\ItemTreeBounds'));
 
    assertThat($uploadId, equalTo($itemTreeBounds->getUploadId()));
    assertThat($left, equalTo($itemTreeBounds->getLeft()));
  }
 
  public function testGetNextItemWithEmptyArchive()
  {
    $this->prepareModularTable();
 
    $nextItem = $this->uploadDao->getNextItem(1, 1);
    assertThat($nextItem, is(nullValue()));
  }
 
  public function testGetPreviousItemWithEmptyArchive()
  {
    $this->prepareModularTable();
 
    $nextItem = $this->uploadDao->getPreviousItem(1, 1);
    assertThat($nextItem, is(nullValue()));
  }
 
  public function testGetNextItemWithSingleFile()
  {
    $subentries = $this->getSubentriesForSingleFile();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getNextItem(1, 1);
    assertThat($nextItem->getId(), is(6));
  }
 
  public function testGetPreviousItemWithSingleFile()
  {
    $subentries = $this->getSubentriesForSingleFile();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getPreviousItem(1, 1);
    assertThat($nextItem, is(nullValue()));
  }
 
  public function testGetNextItemWithNestedFile()
  {
    $subentries = $this->getSubentriesForNestedFile();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getNextItem(1, 1);
    assertThat($nextItem->getId(), is(8));
  }
 
  public function testGetPreviousItemWithNestedFile()
  {
    $subentries = $this->getSubentriesForNestedFile();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getPreviousItem(1, 1);
    assertThat($nextItem, is(nullValue()));
  }
 
  public function testGetNextItemWithFileAfterEmptyDirectory()
  {
    $subentries = $this->getSubentriesForFileAfterEmptyDirectory();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getNextItem(1, 1);
    assertThat($nextItem->getId(), is(8));
  }
 
  public function testGetPreviousItemWithFileAfterEmptyDirectory()
  {
    $subentries = $this->getSubentriesForFileAfterEmptyDirectory();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getPreviousItem(1, 1);
    assertThat($nextItem, is(nullValue()));
  }
 
  public function testGetNextItemWithMultipleFiles()
  {
    $subentries = $this->getSubentriesForMultipleFiles();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getNextItem(1, 6);
    assertThat($nextItem->getId(), is(7));
  }
 
  public function testGetPreviousItemWithMultipleFiles()
  {
    $subentries = $this->getSubentriesForMultipleFiles();
    $this->prepareModularTable($subentries);
 
    $nextItem = $this->uploadDao->getPreviousItem(1, 6);
    assertThat($nextItem, anInstanceOf(Item::class));
    assertThat($nextItem->getId(), is(8));
  }
 
  protected function prepareUploadTree($uploadTreeArray = array())
  {
    $this->dbManager->prepare($stmt = 'insert.uploadtree',
        "INSERT INTO uploadtree (uploadtree_pk, parent, upload_fk, pfile_fk, ufile_mode, lft, rgt, ufile_name) VALUES ($1, $2, $3, $4, $5, $6, $7, $8)");
    foreach ($uploadTreeArray as $uploadTreeEntry) {
      $this->dbManager->freeResult($this->dbManager->execute($stmt, $uploadTreeEntry));
    }
  }
 
 
  protected function prepareModularTable($subentries = array())
  {
    $right_base = 5 + count($subentries) * 2;
 
    $uploadTreeArray = array_merge(
        array(
            array(1, null, 1, 1, 536904704, 1, $right_base + 5, 'archive.tar.gz'),
            array(2, 1, 1, 0, 805323776, 2, $right_base + 4, 'artifact.dir'),
            array(3, 2, 1, 2, 536903680, 3, $right_base + 3, 'archive.tar'),
            array(4, 3, 1, 0, 805323776, 4, $right_base + 2, 'artifact.dir'),
            array(5, 4, 1, 0, 536888320, 5, $right_base + 1, 'archive')),
        $subentries);
    $this->prepareUploadTree($uploadTreeArray);
  }
 
  protected function getSubentriesForSingleFile()
  {
    return array(array(6, 5, 1, 3, 33188, 6, 10, 'README'));
  }
 
  protected function getSubentriesForNestedFile()
  {
    return array(
        array(6, 5, 1, 0, 536888320, 7, 12, 'docs'),
        array(7, 6, 1, 0, 536888320, 8, 11, 'txt'),
        array(8, 7, 1, 3, 33188, 9, 10, 'README')
    );
  }
 
  protected function getSubentriesForFileAfterEmptyDirectory()
  {
    return array(
        array(6, 5, 1, 0, 536888320, 7, 10, 'docs'),
        array(7, 6, 1, 0, 536888320, 8, 9, 'txt'),
        array(8, 5, 1, 3, 33188, 11, 12, 'README')
    );
  }
 
  protected function getSubentriesForMultipleFiles()
  {
    return array(
        array(6, 5, 1, 3, 33188, 9, 10, 'INSTALL'),
        array(7, 5, 1, 4, 33188, 11, 12, 'README'),
        array(8, 5, 1, 5, 33188, 7, 8, 'COPYING')
    );
  }
 
  private $entries = array(
      3653, 3668, 3683, 3685, 3671, 3665, 3676, 3675, 3681, 3677, 3673, 3658, 3660, 3686,
  );
 
  protected function getTestFileStructure()
  {
    $isFile = 33188;
    $isContainer = 536888320;
    return array(
        array(3650, NULL, 32, 3286, 536904704, 1, 76, 'uploadDaoTest.tar'),
        array(3651, 3650, 32, 0, 805323776, 2, 75, 'artifact.dir'),
        array(3652, 3651, 32, 0, 536888320, 3, 74, 'uploadDaoTest'),
 
        array(3653, 3652, 32, 3287, $isFile, 4, 5, 'A'),
        array(3663, 3652, 32, 3287, $isContainer, 6, 7, 'B'),
        array(3668, 3652, 32, 3294, $isFile, 8, 9, 'C'),
        array(3682, 3652, 32, 0, $isContainer, 10, 16, 'D'),
        array(3683, 3682, 32, 3303, $isFile, 11, 12, 'E'),
        // * D/F_NoLic 13:14
        array(3685, 3682, 32, 3305, $isFile, 14, 15, 'G'),
        array(3669, 3652, 32, 0, $isContainer, 16, 23, 'H'),
        // * H/I_NoLic
        array(3671, 3669, 32, 3296, $isFile, 19, 20, 'J'),
        // * H/K_NoLic 21:22
        array(3661, 3652, 32, 0, $isContainer, 24, 37, 'L'),
        array(3666, 3661, 32, 0, $isContainer, 25, 28, 'L1'),
        array(3667, 3666, 32, 0, $isContainer, 26, 27, 'L1a'),  // * L/L1/L1a_NoLic 26:27
        array(3664, 3661, 32, 0, $isContainer, 29, 32, 'L2'),
        array(3665, 3664, 32, 3292, $isFile, 30, 31, 'L2a'),
        array(3662, 3661, 32, 0, $isContainer, 33, 36, 'L3'),
        // * L/L3/L3a_NoLic 34:35
        array(3654, 3652, 32, 0, $isContainer, 38, 41, 'M'),
        array(3655, 3654, 32, 0, $isContainer, 39, 40, 'M1'),
        array(3674, 3652, 32, 0, $isContainer, 42, 57, 'N'),
        array(3676, 3674, 32, 3293, $isFile, 43, 44, 'N1'),
        array(3678, 3674, 32, 0, $isContainer, 45, 48, 'N2'),
        // * N/N2/N2a_NoLic 46:47
        array(3675, 3674, 32, 3299, $isFile, 49, 50, 'N3'),
        array(3680, 3674, 32, 0, $isContainer, 51, 54, 'N4'),
        array(3681, 3680, 32, 3302, $isFile, 52, 53, 'N4a'),
        array(3677, 3674, 32, 3300, $isFile, 55, 56, 'N5'),
        array(3673, 3652, 32, 3298, $isFile, 58, 59, 'O'),
        array(3656, 3652, 32, 0, $isContainer, 60, 69, 'P'),
        //   * P/P1_NoLic 61:62
        array(3657, 3656, 32, 0, $isContainer, 63, 66, 'P2'),
        array(3658, 3657, 32, 3288, $isFile, 64, 65, 'P2a'),
        array(3660, 3656, 32, 3290, 33188, 67, 68, 'P3'),
        array(3686, 3652, 32, 3306, 33188, 70, 71, 'R'),
        //   * S_NoLic 72:73
    );
  }
 
  public function testGetNextItemUsesRecursiveAndRegularSearchAsFallback()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
 
    // L1 -> N1
    $nextItem = $this->uploadDao->getNextItem(32, 3666);
    assertThat($nextItem->getId(), is(3665));
  }
 
  public function testGetPrevItemUsesRecursiveAndRegularSearchAsFallback()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
 
    $nextItem = $this->uploadDao->getPreviousItem(32, 3666);
    assertThat($nextItem->getId(), is(3671));
  }
 
  public function testGetNextItemUsesRecursiveOnly()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
 
    $nextItem = $this->uploadDao->getNextItem(32, 3674);
    assertThat($nextItem->getId(), is(3676));
  }
 
  public function testGetPrevItemUsesRecursiveOnly()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
 
    $nextItem = $this->uploadDao->getPreviousItem(32, 3674);
    assertThat($nextItem->getId(), is(3665));
  }
 
  public function testGetNextFull()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
 
    $previousId = 3650;
    foreach ($this->entries as $entry) {
      $nextItem = $this->uploadDao->getNextItem(32, $previousId);
      assertThat($nextItem->getId(), is($entry));
      $previousId = $entry;
    }
 
    $nextItem = $this->uploadDao->getNextItem(32, $previousId);
    assertThat($nextItem, is(nullValue()));
  }
 
  public function testGetPreviousFull()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
 
    $entries = array_reverse($this->entries);
 
    $previousId = $entries[0];
    foreach (array_slice($entries, 1) as $entry) {
      $previousItem = $this->uploadDao->getPreviousItem(32, $previousId);
      assertThat($previousItem->getId(), is($entry));
      $previousId = $entry;
    }
 
    $previousItem = $this->uploadDao->getPreviousItem(32, $previousId);
    assertThat($previousItem, is(nullValue()));
  }
 
 
  public function testCountNonArtifactDescendants()
  {
    $this->dbManager->queryOnce('ALTER TABLE uploadtree RENAME TO uploadtree_a');
    $this->testDb->insertData(array('uploadtree_a'));
 
    $artifact = new ItemTreeBounds(2,'uploadtree_a', 1, 2, 3);
    $artifactDescendants = $this->uploadDao->countNonArtifactDescendants($artifact);
    assertThat($artifactDescendants, is(0));
 
    $zip = new ItemTreeBounds(1,'uploadtree_a', 1, 1, 24);
    $zipDescendants = $this->uploadDao->countNonArtifactDescendants($zip);
    assertThat($zipDescendants, is(count(array(6,7,8,10,11,12)) ) );
  }
 
 
  public function testGetUploadParent()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
    $topId = $this->uploadDao->getUploadParent(32);
    assertThat($topId,equalTo(3650));
  }
 
  public function testGetUploadParentFromBrokenTree()
  {
    $this->expectException(Exception::class);
    $this->expectExceptionMessage("Missing upload tree parent for upload");
    $this->prepareUploadTree(array(array(4651, 3650, 33, 0, 805323776, 2, 75, 'artifact.dir')));
    $this->uploadDao->getUploadParent(33);
  }
 
  public function testGetUploadParentFromNonExistingTree()
  {
    $this->expectException(Exception::class);
    $this->expectExceptionMessage("Missing upload tree parent for upload");
    $this->uploadDao->getUploadParent(34);
  }
 
  public function testGetUploadHashes()
  {
    $this->testDb->createPlainTables(array('pfile'));
    $this->dbManager->queryOnce('TRUNCATE upload');
    $this->testDb->insertData(array('upload','pfile'));
    // (pfile_pk, pfile_md5, pfile_sha1, pfile_sha256, pfile_size) := (755, 'E7295A5773D0EA17D53CBE6293924DD4', '93247C8DB814F0A224B75B522C1FA4DC92DC3078', 'E29ABC32DB8B6241D598BC7C76681A7623D176D85F99E738A56C0CB684C367E1', 10240)
    $hashes = $this->uploadDao->getUploadHashes(44);
    assertThat($hashes,equalTo(array('md5'=>'E7295A5773D0EA17D53CBE6293924DD4','sha1'=>'93247C8DB814F0A224B75B522C1FA4DC92DC3078','sha256'=>'E29ABC32DB8B6241D598BC7C76681A7623D176D85F99E738A56C0CB684C367E1')));
  }
 
  public function testGetFatItem()
  {
    $this->prepareUploadTree($this->getTestFileStructure());
    $isContainer = 536888320;
    $itemM1a = 13655;
    $this->prepareUploadTree(array(array($itemM1a, 3655, 32, 0, $isContainer, 39+0, 40-0, 'M1a')));
    $this->dbManager->queryOnce('UPDATE uploadtree SET realparent=parent WHERE ufile_mode&(1<<28)=0',__METHOD__.'.fixRealparent');
 
    $fatA = $this->uploadDao->getFatItemId($itemA=3653, 32, 'uploadtree');
    assertThat($fatA,equalTo($itemA));
    $fatB = $this->uploadDao->getFatItemId($itemBEmpty=3663, 32, 'uploadtree');
    assertThat($fatB, equalTo($itemBEmpty));
    $fatD = $this->uploadDao->getFatItemId($itemDFolder=3682, 32, 'uploadtree');
    assertThat($fatD, equalTo($itemDFolder));
    $fatL1 = $this->uploadDao->getFatItemId($itemL1ToFolder=3666, 32, 'uploadtree');
    assertThat($fatL1, equalTo(3667));
    $fatL2 = $this->uploadDao->getFatItemId($itemL2ToItem=3664, 32, 'uploadtree');
    assertThat($fatL2, equalTo(3665));
 
    $fatM = $this->uploadDao->getFatItemId(3654, 32, 'uploadtree');
    assertThat($fatM, equalTo($itemM1a));
  }
 
  public function testGetAssigneeDate()
  {
    $time_now = new DateTime();
    $time_1_day = DateTime::createFromFormat("U",
      strtotime($time_now->format(DATE_ATOM) . " +1 day"));
    $this->dbManager->insertTableRow("upload_events", [
      "upload_fk" => 2,
      "event_ts" => $time_now->format(DATE_ATOM),
      "event_type" => UploadEvents::ASSIGNEE_EVENT
    ]);
    $this->dbManager->insertTableRow("upload_events", [
      "upload_fk" => 2,
      "event_ts" => $time_1_day->format(DATE_ATOM),
      "event_type" => UploadEvents::UPLOAD_CLOSED_EVENT
    ]);
    $assigneeDate = $this->uploadDao->getAssigneeDate(2);
    assertThat(strtotime($assigneeDate), equalTo($time_now->getTimestamp()));
    self::assertThat($this->uploadDao->getAssigneeDate(3), self::equalTo(null));
  }
 
  public function testGetClosedDate()
  {
    $time_now = new DateTime();
    $time_1_day = DateTime::createFromFormat("U",
      strtotime($time_now->format(DATE_ATOM) . " +1 day"));
    $this->dbManager->insertTableRow("upload_events", [
      "upload_fk" => 2,
      "event_ts" => $time_now->format(DATE_ATOM),
      "event_type" => UploadEvents::ASSIGNEE_EVENT
    ]);
    $this->dbManager->insertTableRow("upload_events", [
      "upload_fk" => 2,
      "event_ts" => $time_1_day->format(DATE_ATOM),
      "event_type" => UploadEvents::UPLOAD_CLOSED_EVENT
    ]);
    $assigneeDate = $this->uploadDao->getClosedDate(2);
    assertThat(strtotime($assigneeDate), equalTo($time_1_day->getTimestamp()));
    self::assertThat($this->uploadDao->getClosedDate(3), self::equalTo(null));
  }
}