Archive.php

<?php

use FusionDirectory\Rest\WebServiceCall;

class Archive implements EndpointInterface
{
  private TaskGateway $gateway;

  public function __construct (TaskGateway $gateway)
  {
      $this->gateway = $gateway;
  }

    /**
     * @return array
     * Part of the interface of orchestrator plugin to treat GET method
     */
  public function processEndPointGet (): array
  {
      // Retrieve tasks of type 'archive'
      return $this->gateway->getObjectTypeTask('archive');
  }

    /**
     * @param array|null $data
     * @return array
     * @throws Exception
     * Note: Part of the interface of orchestrator plugin to treat PATCH method
     */
  public function processEndPointPatch (array $data = NULL): array
  {
      $result = [];
      $archiveTasks = $this->gateway->getObjectTypeTask('archive');

      // Initialize the WebServiceCall object for login
      $webServiceCall = new WebServiceCall($_ENV['FUSION_DIRECTORY_API_URL'] . '/login', 'POST');
      $webServiceCall->setCurlSettings(); // Perform login and set the token

    foreach ($archiveTasks as $task) {
      try {
        if (!$this->gateway->statusAndScheduleCheck($task)) {
            // Skip this task if it does not meet the status and schedule criteria
            continue;
        }

        // Retrieve the desired supann status from the main task
        $desiredSupannStatus = $this->getArchiveTaskBehaviorFromMainTask($task['fdtasksgranularmaster'][0]);

        // Retrieve the current supann status of the user
        $currentSupannStatus = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);

        // Check if the current supann status matches the desired status
        if (!$this->isSupannStatusMatching($desiredSupannStatus, $currentSupannStatus)) {
            // The task does not meet the criteria for archiving and can therefore be suppressed
            $result[$task['dn']]['result'] = "User does not meet the criteria for archiving.";
            $this->gateway->removeSubTask($task['dn']);
            continue;
        }

        // Set the archive endpoint and method using the same WebServiceCall object
        $archiveUrl = $_ENV['FUSION_DIRECTORY_API_URL'] . '/archive/user/' . rawurlencode($task['fdtasksgranulardn'][0]);
        $webServiceCall->setCurlSettings($archiveUrl, NULL, 'POST'); // Update settings for the archive request
        $response = $webServiceCall->execute();

        // Check if the HTTP status code is 204
        if ($webServiceCall->getHttpStatusCode() === 204) {
            $result[$task['dn']]['result'] = "User " . $task['fdtasksgranulardn'][0] . " successfully archived.";
            $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2');
        } else {
            throw new Exception("Unexpected HTTP status code: " . $webServiceCall->getHttpStatusCode());