SchedulerTestRunnerCli.php

<?php
/*
 SPDX-FileCopyrightText: © 2014 Siemens AG
 
 SPDX-License-Identifier: GPL-2.0-only
*/
 
namespace Fossology\Reuser\Test;
 
use Fossology\Lib\Test\TestPgDb;
 
include_once(__DIR__.'/../../../lib/php/Test/Agent/AgentTestMockHelper.php');
include_once(__DIR__.'/SchedulerTestRunner.php');
 
class SchedulerTestRunnerCli implements SchedulerTestRunner
{
  private $testDb;
 
  public function __construct(TestPgDb $testDb)
  {
    $this->testDb = $testDb;
  }
 
  public function run($uploadId, $userId=2, $groupId=2, $jobId=1, array $args=[])
  {
    $sysConf = $this->testDb->getFossSysConf();
 
    $agentName = "reuser";
 
    $agentDir = dirname(dirname(__DIR__));
 
    // Ensure VERSION is staged for the scheduler (create mods-enabled entry)
    $installCmd = 'install -D ' . escapeshellarg($agentDir . '/VERSION') . ' ' . escapeshellarg($sysConf . '/mods-enabled/' . $agentName . '/VERSION');
    system($installCmd);
 
    $execPath = $agentDir . '/agent/' . $agentName;
 
    $extraArgs = implode(' ', array_map('escapeshellarg', $args));
    $cmd = 'echo ' . escapeshellarg((string)$uploadId) . ' | ' . escapeshellarg($execPath) . ' --userID=' . escapeshellarg((string)$userId) . ' --groupID=' . escapeshellarg((string)$groupId) . ' --jobId=' . escapeshellarg((string)$jobId) . ' --scheduler_start -c ' . escapeshellarg($sysConf) . ($extraArgs !== '' ? ' ' . $extraArgs : '');
    $pipeFd = popen($cmd, 'r');
    $success = $pipeFd !== false;
 
    $output = "";
    $retCode = -1;
    if ($success) {
      while (($buffer = fgets($pipeFd, 4096)) !== false) {
        $output .= $buffer;
      }
      $retCode = pclose($pipeFd);
    } else {
      print "failed opening pipe to $cmd";
    }
 
    unlink("$sysConf/mods-enabled/$agentName/VERSION");
    rmdir("$sysConf/mods-enabled/$agentName");
    rmdir("$sysConf/mods-enabled");
 
    return array($success, $output, $retCode);
  }
}