<?php

namespace Drupal\user_provisioning\ProviderSpecific\ResponseProcessor\UserResponseProcessor;

use Drupal\user_provisioning\Helpers\moUserProvisioningLogger;
use Drupal\user_provisioning\moUserProvisioningConstants;
use Drupal\user_provisioning\ProviderSpecific\ResponseProcessor\moResourceResponseProcessorInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Processes user API responses returned by SCIM endpoints.
 */
class moUserSCIMResponseProcessor implements moResourceResponseProcessorInterface {

  /**
   * Logger for response processing diagnostics.
   *
   * @var \Drupal\user_provisioning\Helpers\moUserProvisioningLogger
   *   Logger instance.
   */
  protected moUserProvisioningLogger $moLogger;

  public function __construct() {
    $this->moLogger = new moUserProvisioningLogger();
  }

  /**
   * Processes SCIM GET responses.
   *
   * @param \Psr\Http\Message\ResponseInterface $response
   *   Response received after the API call.
   *
   * @return array
   *   Status code, response content, and conflict status.
   */
  public function get(ResponseInterface $response): array {
    $status_code = $response->getStatusCode();
    $content = $response->getBody()->getContents();

    // Initializing as conflict is not determined.
    $conflict = moUserProvisioningConstants::SCIM_CONFLICT_UNDETERMINED;
    if ($status_code == 200) {
      $response_body = json_decode($content, TRUE);
      if (isset($response_body['totalResults'])) {
        if ($response_body['totalResults'] == 0) {

          // No conflict exists if no matching entity is found.
          $conflict = moUserProvisioningConstants::SCIM_NO_CONFLICT;
          $this->moLogger->addLog('No matching entity found, setting conflict status to SCIM_NO_CONFLICT.', __LINE__, __FUNCTION__, __FILE__);
        }
        else {
          // Conflict exists when one or more entities match requested query.
          $content = moUserProvisioningConstants::SCIM_CONFLICT;
          $this->moLogger->addLog('Conflict detected, one or more entities matched the query, setting conflict status to SCIM_CONFLICT.', __LINE__, __FUNCTION__, __FILE__);
        }
      }
    }
    return [$status_code, $content, $conflict];
  }

  /**
   * Processes SCIM POST responses.
   *
   * @param \Psr\Http\Message\ResponseInterface $response
   *   Response received after the API call.
   *
   * @return array
   *   Status code and the response content.
   */
  public function post(ResponseInterface $response): array {
    $status_code = $response->getStatusCode();
    $content = $response->getBody()->getContents();

    // @todo need to add the content and its details at the database to refer for future api calls.
    return [$status_code, $content];
  }

  /**
   * Processes SCIM PATCH responses.
   *
   * @param \Psr\Http\Message\ResponseInterface $response
   *   Response received after the API call.
   *
   * @return void
   */
  public function patch(ResponseInterface $response) {
    // @todo Implement patch() method.
  }

  /**
   * Processes SCIM PUT responses.
   *
   * @param \Psr\Http\Message\ResponseInterface $response
   *   Response received after the API call.
   *
   * @return void
   */
  public function put(ResponseInterface $response) {
    // @todo Implement put() method.
  }

  /**
   * Processes SCIM DELETE responses.
   *
   * @param \Psr\Http\Message\ResponseInterface $response
   *   Response received after the API call.
   *
   * @return void
   */
  public function delete(ResponseInterface $response) {
    // @todo Implement delete() method.
  }

  /**
   * Processes SCIM deactivation responses.
   */
  public function deactivate(ResponseInterface $response) {
    // @todo Implement deactivate() method.
  }

}
