class SchemaPoster in Search API Pantheon 8

Class SchemaPoster.

@package Drupal\search_api_pantheon

Hierarchy

• class \Drupal\search_api_pantheon\SchemaPoster

1 file declares its use of SchemaPoster

PantheonSolrConnector.php in src/Plugin/SolrConnector/PantheonSolrConnector.php

Provide a connection to Pantheon's Solr instance.

1 string reference to 'SchemaPoster'

search_api_pantheon.services.yml in ./search_api_pantheon.services.yml

search_api_pantheon.services.yml

1 service uses SchemaPoster

search_api_pantheon.schema_poster in ./search_api_pantheon.services.yml

Drupal\search_api_pantheon\SchemaPoster

File

src/SchemaPoster.php, line 18

Post a schema file to to the Pantheon Solr server.

Namespace

Drupal\search_api_pantheon

class SchemaPoster {

  /**
   * Drupal\Core\Logger\LoggerChannelFactory definition.
   *
   * @var Drupal\Core\Logger\LoggerChannelFactory
   */
  protected $loggerFactory;

  /**
   * GuzzleHttp\Client definition.
   *
   * @var GuzzleHttp\Client
   */
  protected $httpClient;

  /**
   * Constructor.
   */
  public function __construct(LoggerChannelFactoryInterface $logger_factory, Client $http_client) {
    $this->loggerFactory = $logger_factory;
    $this->httpClient = $http_client;
  }

  /**
   * Post a schema file to to the Pantheon Solr server.
   */
  public function postSchema($schema) {

    // Check for empty schema.
    if (filesize($schema) < 1) {
      $this->loggerFactory
        ->get('search_api_pantheon')
        ->error('Empty schema not posting');
      return NULL;
    }

    // Check for invalid XML.
    $schema_file = file_get_contents($schema);
    if (!@simplexml_load_string($schema_file)) {
      $this->loggerFactory
        ->get('search_api_pantheon')
        ->error('Schema is not XML - not posting');
      return NULL;
    }
    $ch = curl_init();
    $host = getenv('PANTHEON_INDEX_HOST');
    $path = 'sites/self/environments/' . $_ENV['PANTHEON_ENVIRONMENT'] . '/index';
    $client_cert = $_SERVER['HOME'] . '/certs/binding.pem';
    $url = 'https://' . $host . '/' . $path;
    $file = fopen($schema, 'r');

    // Set URL and other appropriate options.
    $opts = array(
      CURLOPT_URL => $url,
      CURLOPT_PORT => getenv('PANTHEON_INDEX_PORT'),
      CURLOPT_RETURNTRANSFER => 1,
      CURLOPT_SSLCERT => $client_cert,
      CURLOPT_HTTPHEADER => array(
        'Content-type:text/xml; charset=utf-8',
      ),
      CURLOPT_PUT => TRUE,
      CURLOPT_BINARYTRANSFER => 1,
      CURLOPT_INFILE => $file,
      CURLOPT_INFILESIZE => filesize($schema),
    );
    curl_setopt_array($ch, $opts);
    $response = curl_exec($ch);
    $info = curl_getinfo($ch);
    $success_codes = array(
      '200',
      '201',
      '202',
      '204',
    );
    $success = in_array($info['http_code'], $success_codes);
    fclose($file);
    if (!$success) {
      $this->loggerFactory
        ->get('search_api_pantheon')
        ->error('Schema failed to post');
    }
    else {
      $this->loggerFactory
        ->get('search_api_pantheon')
        ->info('Schema posted');
    }
    return $success;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
SchemaPoster::$httpClient	protected	property	GuzzleHttp\Client definition.
SchemaPoster::$loggerFactory	protected	property	Drupal\Core\Logger\LoggerChannelFactory definition.
SchemaPoster::postSchema	public	function	Post a schema file to to the Pantheon Solr server.
SchemaPoster::__construct	public	function	Constructor.