Skip to content

Commit

Permalink
Revert "back out solr connector"
Browse files Browse the repository at this point in the history 
This reverts commit 1714e95.
  • Loading branch information
@pwtyler
pwtyler committed Nov 14, 2024
1 parent dcba7b4 commit 65a5c94
Showing 1 changed file with 105 additions and 109 deletions.
214 changes: 105 additions & 109 deletions src/Plugin/SolrConnector/PantheonSolrConnector.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,8 @@
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\search_api_pantheon\Services\PantheonGuzzle;
use Drupal\search_api_pantheon\Services\SolariumClient as PantheonSolariumClient;
use Drupal\Core\Logger\LoggerChannelFactoryInterface;
use Drupal\Core\Datetime\DateFormatterInterface;
use Drupal\Core\Messenger\MessengerInterface;
use Drupal\search_api_pantheon\Services\Reload;

/**
* Pantheon Solr connector.
Expand Down Expand Up @@ -64,27 +63,29 @@ class PantheonSolrConnector extends SolrConnectorPluginBase implements
*/
protected $messenger;

/**
* The container.
*
* @var \Symfony\Component\DependencyInjection\ContainerInterface
*/
protected ContainerInterface $container;

/**
* Class constructor.
*/
public function __construct(
array $configuration,
$plugin_id,
array $plugin_definition,
LoggerChannelFactoryInterface $logger_factory,
PantheonGuzzle $pantheon_guzzle,
PantheonSolariumClient $solarium_client,
DateFormatterInterface $date_formatter,
MessengerInterface $messenger
array $configuration,
$plugin_id,
array $plugin_definition,
ContainerInterface $container,
) {
parent::__construct($configuration, $plugin_id, $plugin_definition);
$this->pantheonGuzzle = $pantheon_guzzle;
$this->solariumClient = $solarium_client;
$this->dateFormatter = $date_formatter;
$this->messenger = $messenger;
$this->setLogger($logger_factory->get('PantheonSearch'));
$this->configuration['core'] = self::getPlatformConfig()['core'];
$this->configuration['schema'] = self::getPlatformConfig()['schema'];
parent::__construct(array_merge($configuration, self::getPlatformConfig()), $plugin_id, $plugin_definition);
$this->pantheonGuzzle = $container->get('search_api_pantheon.pantheon_guzzle');
$this->solariumClient = $container->get('search_api_pantheon.solarium_client');
$this->dateFormatter = $container->get('date.formatter');
$this->messenger = $container->get('messenger');
$this->setLogger($container->get('logger.factory')->get('PantheonSearch'));
$this->container = $container;
$this->connect();
}

Expand All @@ -98,21 +99,17 @@ public function __construct(
* @throws \Exception
*/
public static function create(
ContainerInterface $container,
array $configuration,
$plugin_id,
$plugin_definition
) {
ContainerInterface $container,
array $configuration,
$plugin_id,
$plugin_definition
) {
return new static(
$configuration,
$plugin_id,
$plugin_definition,
$container->get('logger.factory'),
$container->get('search_api_pantheon.pantheon_guzzle'),
$container->get('search_api_pantheon.solarium_client'),
$container->get('date.formatter'),
$container->get('messenger')
);
$configuration,
$plugin_id,
$plugin_definition,
$container,
);
}

/**
Expand All @@ -129,6 +126,7 @@ public static function getPlatformConfig() {
'path' => getenv('PANTHEON_INDEX_PATH'),
'core' => getenv('PANTHEON_INDEX_CORE'),
'schema' => getenv('PANTHEON_INDEX_SCHEMA'),
'reload_path' => getenv('PANTHEON_INDEX_RELOAD_PATH'),
];
}

Expand Down Expand Up @@ -170,9 +168,9 @@ public function defaultConfiguration() {
* Form render array.
*/
public function buildConfigurationForm(
array $form,
FormStateInterface $form_state
) {
array $form,
FormStateInterface $form_state
) {
$form = parent::buildConfigurationForm($form, $form_state);

$fields = [
Expand Down Expand Up @@ -208,9 +206,9 @@ function ($field_name) use ($fields) {
* Form state object.
*/
public function validateConfigurationForm(
array &$form,
FormStateInterface $form_state
) {
array &$form,
FormStateInterface $form_state
) {
}

/**
Expand All @@ -222,9 +220,9 @@ public function validateConfigurationForm(
* Form state object.
*/
public function submitConfigurationForm(
array &$form,
FormStateInterface $form_state
) {
array &$form,
FormStateInterface $form_state
) {
$configuration = array_merge($this->defaultConfiguration(), $form_state->getValues());

$this->setConfiguration($configuration);
Expand Down Expand Up @@ -293,16 +291,16 @@ public function getStatsSummary() {
}

$summary = [
'@pending_docs' => '',
'@autocommit_time_seconds' => '',
'@autocommit_time' => '',
'@deletes_by_id' => '',
'@deletes_by_query' => '',
'@deletes_total' => '',
'@schema_version' => '',
'@core_name' => '',
'@index_size' => '',
];
'@pending_docs' => '',
'@autocommit_time_seconds' => '',
'@autocommit_time' => '',
'@deletes_by_id' => '',
'@deletes_by_query' => '',
'@deletes_total' => '',
'@schema_version' => '',
'@core_name' => '',
'@index_size' => '',
];

if (empty($stats) || empty($indexStats)) {
return $summary;
Expand All @@ -311,33 +309,33 @@ public function getStatsSummary() {
$max_time = -1;
$update_handler_stats = $stats['UPDATE']['updateHandler']['stats'] ?? -1;
$summary['@pending_docs'] =
(int) $update_handler_stats['UPDATE.updateHandler.docsPending'] ?? -1;
(int) $update_handler_stats['UPDATE.updateHandler.docsPending'] ?? -1;
if (
isset(
$update_handler_stats['UPDATE.updateHandler.softAutoCommitMaxTime']
)
) {
isset(
$update_handler_stats['UPDATE.updateHandler.softAutoCommitMaxTime']
)
) {
$max_time =
(int) $update_handler_stats['UPDATE.updateHandler.softAutoCommitMaxTime'];
(int) $update_handler_stats['UPDATE.updateHandler.softAutoCommitMaxTime'];
}
$summary['@deletes_by_id'] =
(int) $update_handler_stats['UPDATE.updateHandler.deletesById'] ?? -1;
(int) $update_handler_stats['UPDATE.updateHandler.deletesById'] ?? -1;
$summary['@deletes_by_query'] =
(int) $update_handler_stats['UPDATE.updateHandler.deletesByQuery'] ?? -1;
(int) $update_handler_stats['UPDATE.updateHandler.deletesByQuery'] ?? -1;
$summary['@core_name'] =
$stats['CORE']['core']['class'] ??
$this->t('No information available.');
$stats['CORE']['core']['class'] ??
$this->t('No information available.');
$summary['@index_size'] =
$indexStats['numDocs'] ?? $this->t('No information available.');
$indexStats['numDocs'] ?? $this->t('No information available.');

$summary['@autocommit_time_seconds'] = $max_time / 1000;
$summary['@autocommit_time'] = $this->dateFormatter
->formatInterval($max_time / 1000);
$summary['@deletes_total'] =
(
intval($summary['@deletes_by_id'] ?? 0)
+ intval($summary['@deletes_by_query'] ?? 0)
) ?? -1;
(
intval($summary['@deletes_by_id'] ?? 0)
+ intval($summary['@deletes_by_query'] ?? 0)
) ?? -1;
$summary['@schema_version'] = $this->getSchemaVersionString(TRUE);
return $summary;
}
Expand All @@ -346,9 +344,9 @@ public function getStatsSummary() {
* {@inheritdoc}
*/
public function useTimeout(
string $timeout = self::QUERY_TIMEOUT,
?Endpoint $endpoint = NULL
) {
string $timeout = self::QUERY_TIMEOUT,
?Endpoint $endpoint = NULL
) {
}

/**
Expand All @@ -360,25 +358,25 @@ public function viewSettings() {
$view_settings = [];

$view_settings[] = [
'label' => $this->t('Pantheon Sitename'),
'info' => $this->getEndpoint()->getCore(),
];
'label' => $this->t('Pantheon Sitename'),
'info' => $this->getEndpoint()->getCore(),
];
$view_settings[] = [
'label' => $this->t('Pantheon Environment'),
'info' => getenv('PANTHEON_ENVIRONMENT'),
];
'label' => $this->t('Pantheon Environment'),
'info' => getenv('PANTHEON_ENVIRONMENT'),
];
$view_settings[] = [
'label' => $this->t('Schema Version'),
'info' => $this->getSchemaVersion(TRUE),
];
'label' => $this->t('Schema Version'),
'info' => $this->getSchemaVersion(TRUE),
];

$core_info = $this->getCoreInfo(TRUE);
foreach ($core_info['core'] as $key => $value) {
if (is_string($value)) {
$view_settings[] = [
'label' => ucwords($key),
'info' => $value,
];
'label' => ucwords($key),
'info' => $value,
];
}
}

Expand All @@ -404,11 +402,9 @@ public function getEndpoint($key = 'search_api_solr') {
* @return bool
* Success or Failure.
*/
public function reloadCore() {
$this->logger->notice(
$this->t('Reload Core action for Pantheon Solr is automatic when Schema is updated.')
);
return TRUE;
public function reloadCore(): bool {
$rl = new Reload($this->container->get("logger.factory"), $this->pantheonGuzzle);
return $rl->reloadServer();
}

/**
Expand Down Expand Up @@ -462,29 +458,29 @@ protected function createClient(array &$configuration) {
*/
protected function getStatsQuery(string $handler) {
return json_decode(
$this->pantheonGuzzle
->get(
$handler,
[
'query' =>
[
'stats' => 'true',
'wt' => 'json',
'accept' => 'application/json',
'contenttype' => 'application/json',
'json.nl' => 'flat',
],
'headers' =>
[
'Content-Type' => 'application/json',
'Accept' => 'application/json',
],
]
)
->getBody(),
TRUE,
JSON_THROW_ON_ERROR
);
$this->pantheonGuzzle
->get(
$handler,
[
'query' =>
[
'stats' => 'true',
'wt' => 'json',
'accept' => 'application/json',
'contenttype' => 'application/json',
'json.nl' => 'flat',
],
'headers' =>
[
'Content-Type' => 'application/json',
'Accept' => 'application/json',
],
]
)
->getBody(),
TRUE,
JSON_THROW_ON_ERROR
);
}

}

0 comments on commit 65a5c94

Please sign in to comment.