delete-helper.php

<?php

include_once dirname(dirname(__DIR__)) . "/lib/php/common.php";
include_once "DeleteResponse.php";
include_once "DeleteMessages.php";
use Fossology\DelAgent\UI\DeleteMessages;
use Fossology\DelAgent\UI\DeleteResponse;

function TryToDelete($uploadpk, $user_pk, $group_pk, $uploadDao)
{
  if (! $uploadDao->isEditable($uploadpk, $group_pk)) {
    $returnMessage = DeleteMessages::NO_PERMISSION;
    return new DeleteResponse($returnMessage);
  }

  $rc = DeleteUpload(intval($uploadpk), $user_pk, $group_pk, $uploadDao);

  if (! empty($rc)) {
    $returnMessage = DeleteMessages::SCHEDULING_FAILED;
    return new DeleteResponse($returnMessage);
  }

  /* Need to refresh the screen */
  $URL = Traceback_uri() . "?mod=showjobs&upload=$uploadpk ";
  $LinkText = _("View Jobs");
  $returnMessage = DeleteMessages::SUCCESS;
  return new DeleteResponse($returnMessage,
    " <a href=$URL>$LinkText</a>");
}

function DeleteUpload($uploadpk, $user_pk, $group_pk, $Depends = NULL)
{
  /* Prepare the job: job "Delete" */
  $jobpk = JobAddJob($user_pk, $group_pk, "Delete", $uploadpk);
  if (empty($jobpk) || ($jobpk < 0)) {
    $text = _("Failed to create job record");
    return ($text);
  }
  /* Add job: job "Delete" has jobqueue item "delagent" */
  $jqargs = "DELETE UPLOAD $uploadpk";
  $jobqueuepk = JobQueueAdd($jobpk, "delagent", $jqargs, NULL, NULL);
  if (empty($jobqueuepk)) {
    $text = _("Failed to place delete in job queue");
    return ($text);
  }

  /* Tell the scheduler to check the queue. */
  $success  = fo_communicate_with_scheduler("database", $output, $error_msg);
  if (!$success) {
    $error_msg = _("Is the scheduler running? Your jobs have been added to job queue.");
    $URL = Traceback_uri() . "?mod=showjobs&upload=$uploadpk ";
    $LinkText = _("View Jobs");
    $msg = "$error_msg <a href=$URL>$LinkText</a>";
    return $msg;
  }
  return (null);
} // Delete()

function initDeletion($uploadpks)
{
  if (sizeof($uploadpks) <= 0) {
    return DisplayMessage("No uploads selected");
  }

  $V = "";
  $errorMessages = [];
  $deleteResponse = null;
  for ($i=0; $i < sizeof($uploadpks); $i++) {
    $deleteResponse = TryToDelete(intval($uploadpks[$i]));

    if ($deleteResponse->getDeleteMessageCode() != DeleteMessages::SUCCESS) {
      $errorMessages[] = $deleteResponse;
    }
  }

  if (sizeof($uploadpks) == 1) {
    $V .= DisplayMessage($deleteResponse->getDeleteMessageString().$deleteResponse->getAdditionalMessage());
  } else {
    $displayMessage = "";

    if (in_array(DeleteMessages::SCHEDULING_FAILED, $errorMessages)) {
      $displayMessage .= "<br/>Scheduling failed for " .
        array_count_values($errorMessages)[DeleteMessages::SCHEDULING_FAILED] . " uploads<br/>";
    }

    if (in_array(DeleteMessages::NO_PERMISSION, $errorMessages)) {
      $displayMessage .= "No permission to delete " .
        array_count_values($errorMessages)[DeleteMessages::NO_PERMISSION]. " uploads<br/>";
    }

    $displayMessage .= "Deletion of " .
      (sizeof($uploadpks)-sizeof($errorMessages)) . " projects queued";
    $V .= DisplayMessage($displayMessage);
  }
  return $V;
}