Merge pull request #19154 from civicrm/5.33

[civicrm-core.git] / CRM / Utils / SoapServer.php

<?php
/*
 +--------------------------------------------------------------------+
 | Copyright CiviCRM LLC. All rights reserved.                        |
 |                                                                    |
 | This work is published under the GNU AGPLv3 license with some      |
 | permitted exceptions and without any warranty. For full license    |
 | and copyright information, see https://civicrm.org/licensing       |
 +--------------------------------------------------------------------+
 */

/**
 * This class handles all SOAP client requests.
 *
 * @package CRM
 * @copyright CiviCRM LLC https://civicrm.org/licensing
 */
class CRM_Utils_SoapServer {

  /**
   * Number of seconds we should let a soap process idle
   * @var int
   */
  public static $soap_timeout = 0;

  /**
   * Cache the actual UF Class
   * @var string
   */
  public $ufClass;

  /**
   * Class constructor.  This caches the real user framework class locally,
   * so we can use it for authentication and validation.
   *
   * @internal param string $uf The userframework class
   */
  public function __construct() {
    // any external program which call SoapServer is responsible for
    // creating and attaching the session
    $args = func_get_args();
    $this->ufClass = array_shift($args);
  }

  /**
   * Simple ping function to test for liveness.
   *
   * @param string $var
   *   The string to be echoed.
   *
   * @return string
   */
  public function ping($var) {
    $session = CRM_Core_Session::singleton();
    $key = $session->get('key');
    $session->set('key', $var);
    return "PONG: $var ($key)";
  }

  /**
   * Verify a SOAP key.
   *
   * @param string $key
   *   The soap key generated by authenticate().
   *
   * @throws SoapFault
   */
  public function verify($key) {
    $session = CRM_Core_Session::singleton();

    $soap_key = $session->get('soap_key');
    $t = time();

    if ($key !== sha1($soap_key)) {
      throw new SoapFault('Client', 'Invalid key');
    }

    if (self::$soap_timeout &&
      $t > ($session->get('soap_time') + self::$soap_timeout)
    ) {
      throw new SoapFault('Client', 'Expired key');
    }

    // otherwise, we're ok.  update the timestamp

    $session->set('soap_time', $t);
  }

  /**
   * Authentication wrapper to the UF Class.
   *
   * @param string $name
   *   Login name.
   * @param string $pass
   *   Password.
   *
   * @param bool $loadCMSBootstrap
   *
   * @throws SoapFault
   * @return string
   *   The SOAP Client key
   */
  public function authenticate($name, $pass, $loadCMSBootstrap = FALSE) {
    require_once str_replace('_', DIRECTORY_SEPARATOR, $this->ufClass) . '.php';

    if ($this->ufClass == 'CRM_Utils_System_Joomla'
      || $this->ufClass == 'CRM_Utils_System_WordPress') {
      $loadCMSBootstrap = TRUE;
    }

    $result = CRM_Utils_System::authenticate($name, $pass, $loadCMSBootstrap);

    if (empty($result)) {
      throw new SoapFault('Client', 'Invalid login');
    }

    $session = CRM_Core_Session::singleton();
    $session->set('soap_key', $result[2]);
    $session->set('soap_time', time());

    return sha1($result[2]);
  }

  /**
   * MAILER API.
   *
   * @param string $key
   * @param int $job
   * @param int $queue
   * @param string $hash
   * @param string $body
   *
   * @return array|int
   * @throws \SoapFault
   */
  public function mailer_event_bounce($key, $job, $queue, $hash, $body) {
    $this->verify($key);
    $params = [
      'job_id' => $job,
      'time_stamp' => date('YmdHis'),
      'event_queue_id' => $queue,
      'hash' => $hash,
      'body' => $body,
      'version' => 3,
    ];
    $result = civicrm_api('Mailing', 'event_bounce', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * Mailer event unsubscribe.
   *
   * @param string $key
   * @param int $job
   * @param int $queue
   * @param string $hash
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_unsubscribe($key, $job, $queue, $hash) {
    $this->verify($key);
    $params = [
      'job_id' => $job,
      'time_stamp' => date('YmdHis'),
      'org_unsubscribe' => 0,
      'event_queue_id' => $queue,
      'hash' => $hash,
      'version' => 3,
    ];
    $result = civicrm_api('MailingGroup', 'event_unsubscribe', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param $job
   * @param $queue
   * @param $hash
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_domain_unsubscribe($key, $job, $queue, $hash) {
    $this->verify($key);
    $params = [
      'job_id' => $job,
      'time_stamp' => date('YmdHis'),
      'org_unsubscribe' => 1,
      'event_queue_id' => $queue,
      'hash' => $hash,
      'version' => 3,
    ];
    $result = civicrm_api('MailingGroup', 'event_domain_unsubscribe', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param $job
   * @param $queue
   * @param $hash
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_resubscribe($key, $job, $queue, $hash) {
    $this->verify($key);
    $params = [
      'job_id' => $job,
      'time_stamp' => date('YmdHis'),
      'org_unsubscribe' => 0,
      'event_queue_id' => $queue,
      'hash' => $hash,
      'version' => 3,
    ];
    $result = civicrm_api('MailingGroup', 'event_resubscribe', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param $email
   * @param $domain
   * @param $group
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_subscribe($key, $email, $domain, $group) {
    $this->verify($key);
    $params = [
      'email' => $email,
      'group_id' => $group,
      'version' => 3,
    ];
    $result = civicrm_api('MailingGroup', 'event_subscribe', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param $contact
   * @param $subscribe
   * @param $hash
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_confirm($key, $contact, $subscribe, $hash) {
    $this->verify($key);
    $params = [
      'contact_id' => $contact,
      'subscribe_id' => $subscribe,
      'time_stamp' => date('YmdHis'),
      'event_subscribe_id' => $subscribe,
      'hash' => $hash,
      'version' => 3,
    ];
    $result = civicrm_api('Mailing', 'event_confirm', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param $job
   * @param $queue
   * @param $hash
   * @param $bodyTxt
   * @param $rt
   * @param null $bodyHTML
   * @param null $fullEmail
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_reply($key, $job, $queue, $hash, $bodyTxt, $rt, $bodyHTML = NULL, $fullEmail = NULL) {
    $this->verify($key);
    $params = [
      'job_id' => $job,
      'event_queue_id' => $queue,
      'hash' => $hash,
      'bodyTxt' => $bodyTxt,
      'replyTo' => $rt,
      'bodyHTML' => $bodyHTML,
      'fullEmail' => $fullEmail,
      'time_stamp' => date('YmdHis'),
      'version' => 3,
    ];
    $result = civicrm_api('Mailing', 'event_reply', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param $job
   * @param $queue
   * @param $hash
   * @param $email
   *
   * @return array|int
   * @throws SoapFault
   */
  public function mailer_event_forward($key, $job, $queue, $hash, $email) {
    $this->verify($key);
    $params = [
      'job_id' => $job,
      'event_queue_id' => $queue,
      'hash' => $hash,
      'email' => $email,
      'version' => 3,
    ];
    $result = civicrm_api('Mailing', 'event_forward', $params);
    return CRM_Utils_Array::encode_items($result);
  }

  /**
   * @param $key
   * @param array $params
   *
   * @return array|int
   * @throws SoapFault
   */
  public function get_contact($key, $params) {
    $this->verify($key);
    $params['version'] = 3;
    $result = civicrm_api('contact', 'get', $params);
    return CRM_Utils_Array::encode_items($result);
  }

}