UploadVcsPage.php

<?php
/*
 SPDX-FileCopyrightText: © 2013 Hewlett-Packard Development Company, L.P.
 SPDX-FileCopyrightText: © 2015 Siemens AG
 
 SPDX-License-Identifier: GPL-2.0-only
*/
 
namespace Fossology\UI\Page;
 
use Fossology\UI\Page\UploadPageBase;
use Fossology\Lib\Auth\Auth;
use Symfony\Component\HttpFoundation\Request;
 
class UploadVcsPage extends UploadPageBase
{
  const NAME = "upload_vcs";
  const GETURL_PARAM = 'geturl';
 
  public function __construct()
  {
    parent::__construct(self::NAME, array(
        self::TITLE => _("Upload from Version Control System"),
        self::MENU_LIST => "Upload::From Version Control System",
        self::DEPENDENCIES => array("agent_unpack", "showjobs"),
        self::PERMISSION => Auth::PERM_WRITE
    ));
  }
 
  protected function handleView(Request $request, $vars)
  {
    $vars['vcstypeField'] = 'vcstype';
    $vars['usernameField'] = 'username';
    $vars['passwdField'] = 'passwd';
    $vars['geturlField'] = self::GETURL_PARAM;
    $vars['branchField'] = 'branch';
    $vars['nameField'] = 'name';
    return $this->render("upload_vcs.html.twig", $this->mergeWithDefault($vars));
  }
 
  protected function handleUpload(Request $request)
  {
    global $MODDIR;
    global $SYSCONFDIR;
    global $Plugins;
 
    $folderId = intval($request->get(self::FOLDER_PARAMETER_NAME));
    $description = stripslashes($request->get(self::DESCRIPTION_INPUT_NAME));
    $description = $this->basicShEscaping($description);
 
    $getUrlThatMightIncludeSpaces = trim($request->get(self::GETURL_PARAM));
    $getUrl = str_replace(" ", "%20", $getUrlThatMightIncludeSpaces);
 
    if (empty($getUrl)) {
      return array(false, _("Empty URL") . $getUrl, $description);
    }
    if (preg_match("@^((http)|(https))://([[:alnum:]]+)@i", $getUrl) != 1) {
      return array(false, _("Invalid URL") . $getUrl, $description);
    }
    $getUrl = $this->basicShEscaping($getUrl);
 
    if ($request->getSession()->get(self::UPLOAD_FORM_BUILD_PARAMETER_NAME)
        != $request->get(self::UPLOAD_FORM_BUILD_PARAMETER_NAME)) {
      $text = _("This seems to be a resent file.");
      return array(false, $text, $description);
    }
 
    if (empty($folderId)) {
      $text = _("Invalid Folder.");
      return array(false, $text, $description);
    }
    $setGlobal = ($request->get('globalDecisions')) ? 1 : 0;
 
    $public = $request->get('public');
    $publicPermission = ($public == self::PUBLIC_ALL) ? Auth::PERM_READ : Auth::PERM_NONE;
 
    $Name = trim($request->get('name'));
    if (empty($Name)) {
      $Name = basename($getUrl);
    }
    $ShortName = basename($Name);
    if (empty($ShortName)) {
      $ShortName = $Name;
    }
 
    /* Create an upload record. */
    $uploadMode = (1 << 2); // code for "it came from wget"
    $userId = Auth::getUserId();
    $groupId = Auth::getGroupId();
    $uploadId = JobAddUpload($userId, $groupId, $ShortName, $getUrl,
      $description, $uploadMode, $folderId, $publicPermission, $setGlobal);
    if (empty($uploadId)) {
      $text = _("Failed to insert upload record");
      return array(false, $text, $description);
    }
 
    /* Create the job: job "wget" */
    $jobpk = JobAddJob($userId, $groupId, "wget", $uploadId);
    if (empty($jobpk) || ($jobpk < 0)) {
      $text = _("Failed to insert job record");
      return array(false, $text, $description);
    }
 
    $VCSType = trim($request->get('vcstype'));
    $VCSType = $this->basicShEscaping($VCSType);
    $jq_args = "$uploadId - $getUrl $VCSType ";
 
    $Username = trim($request->get('username'));
    $Username = $this->basicShEscaping($Username);
    if (!empty($Username)) {
      $jq_args .= "--username $Username ";
    }
 
    $Passwd = trim($request->get('passwd'));
    $Passwd = $this->basicShEscaping($Passwd);
    if (!empty($Passwd)) {
      $jq_args .= "--password $Passwd ";
    }
 
    $Branch = trim(explode(' ',trim($request->get('branch')))[0]);
    if (!empty($Branch) && strcasecmp($VCSType,'git') == 0) {
      $jq_args .= "--single-branch --branch '$Branch'";
    }
 
    $jobqueuepk = JobQueueAdd($jobpk, "wget_agent", $jq_args, NULL, NULL);
    if (empty($jobqueuepk)) {
      $text = _("Failed to insert task 'wget_agent' into job queue");
      return array(false, $text, $description);
    }
    /* schedule agents */
    $unpackplugin = &$Plugins[plugin_find_id("agent_unpack") ];
    $unpackArgs = intval($request->get('scm')) == 1 ? '-I' : '';
    $ununpack_jq_pk = $unpackplugin->AgentAdd($jobpk, $uploadId, $ErrorMsg, array("wget_agent"), $unpackArgs);
    if ($ununpack_jq_pk < 0) {
      return array(false, _($ErrorMsg), $description);
    }
 
    $adj2nestplugin = &$Plugins[plugin_find_id("agent_adj2nest") ];
    $adj2nest_jq_pk = $adj2nestplugin->AgentAdd($jobpk, $uploadId, $ErrorMsg, array());
    if ($adj2nest_jq_pk < 0) {
      return array(false, _($ErrorMsg), $description);
    }
 
    $message = $this->postUploadAddJobs($request, $Name, $uploadId, $jobpk);
    return array(true, $message, $description, $uploadId);
  }
}
 
register_plugin(new UploadVcsPage());