Cxn.php

<?php
/**
 * Cxn controller class.
 *
 * CiviConnect endpoint, replacement for CiviCRM's 'extern/cxn.php'.
 *
 * @since 0.1
 */

namespace CiviCRM_WP_REST\Controller;

class Cxn extends Base {

	/**
	 * The base route.
	 *
	 * @since 0.1
	 * @var string
	 */
	protected $rest_base = 'cxn';

	/**
	 * Registers routes.
	 *
	 * @since 0.1
	 */
	public function register_routes() {

		register_rest_route( $this->get_namespace(), $this->get_rest_base(), [
			[
				'methods' => \WP_REST_Server::ALLMETHODS,
				'callback' => [ $this, 'get_item' ]
			]
		] );

	}

	/**
	 * Get items.
	 *
	 * @since 0.1
	 * @param WP_REST_Request $request
	 */
	public function get_item( $request ) {

		/**
		 * Filter request params.
		 *
		 * @since 0.1
		 * @param array $params
		 * @param WP_REST_Request $request
		 */
		$params = apply_filters( 'civi_wp_rest/controller/cxn/params', $request->get_params(), $request );

		// init connection server
		$cxn = \CRM_Cxn_BAO_Cxn::createApiServer();

		/**
		 * Filter connection server object.
		 *
		 * @param Civi\Cxn\Rpc\ApiServer $cxn
		 * @param array $params
		 * @param WP_REST_Request $request
		 */
		$cxn = apply_filters( 'civi_wp_rest/controller/cxn/instance', $cxn, $params, $request );

		try {

			$result = $cxn->handle( $request->get_body() );

		} catch ( Civi\Cxn\Rpc\Exception\CxnException $e ) {

			return $this->civi_rest_error( $e->getMessage() );

		} catch ( Civi\Cxn\Rpc\Exception\ExpiredCertException $e ) {

			return $this->civi_rest_error( $e->getMessage() );

		} catch ( Civi\Cxn\Rpc\Exception\InvalidCertException $e ) {

			return $this->civi_rest_error( $e->getMessage() );

		} catch ( Civi\Cxn\Rpc\Exception\InvalidMessageException $e ) {

			return $this->civi_rest_error( $e->getMessage() );

		} catch ( Civi\Cxn\Rpc\Exception\GarbledMessageException $e ) {

			return $this->civi_rest_error( $e->getMessage() );

		}

		/**
		 * Bypass WP and send request from Cxn.
		 */
		add_filter( 'rest_pre_serve_request', function( $served, $response, $request, $server ) use ( $result ) {

			// Civi\Cxn\Rpc\Message->send()
			$result->send();

			return true;

		}, 10, 4 );

		return rest_ensure_response( $result );

	}

	/**
	 * Item schema.
	 *
	 * @since 0.1
	 * @return array $schema
	 */
	public function get_item_schema() {}

	/**
	 * Item arguments.
	 *
	 * @since 0.1
	 * @return array $arguments
	 */
	public function get_item_args() {}

}