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;
        }

          // Receive null or 'toBeArchived'
          $supannState = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);

        if ($supannState !== 'toBeArchived') {
            // 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 successfully archived.";
            $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2');
        } else {
            throw new Exception("Unexpected HTTP status code: " . $webServiceCall->getHttpStatusCode());
        }
      } catch (Exception $e) {
          $result[$task['dn']]['result'] = "Error archiving user: " . $e->getMessage();
          $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], $e->getMessage());