Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/mets-rebuild.corals.io/wp-content/plugins/searchwp/includes/ |
<?php
/**
* SearchWP CLI.
*
* @package SearchWP
* @author Jon Christopher
*/
namespace SearchWP;
/**
* Class CLI is responsible for adding WP CLI commands.
*
* @since 4.0
*/
class CLI {
/**
* Constructor.
*
* @since 4.0
* @return void
*/
public function __construct() {
if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
return;
}
\WP_CLI::add_command( 'searchwp index', [ $this, 'index' ] );
\WP_CLI::add_command( 'searchwp reindex', [ $this, 'reindex' ] );
\WP_CLI::add_command( 'searchwp diagnostics', [ $this, 'diagnostics' ] );
}
/**
* Trigger the Indexer, optionally rebuilding it.
*
* ## OPTIONS
*
* [--site=<all|ids>]
* : Which site(s) to consider, comma separated IDs or `all`.
*
* [--rebuild]
* : Whether to rebuild the index before indexing.
*
* @since 4.0
*/
public static function index( $args = [], $assoc_args = [] ) {
gc_enable();
add_filter( 'searchwp\debug', '__return_false', 99999 );
$arguments = wp_parse_args( $assoc_args, [
'rebuild' => false,
'site' => 'all',
] );
$all_sites = function_exists( 'get_sites' ) ? get_sites( [ 'fields' => 'ids' ] ) : get_current_blog_id();
// Process the site id argument.
if ( is_numeric( $arguments['site'] ) ) {
// Single numeric site id.
$arguments['site'] = absint( $arguments['site'] );
$arguments['site'] = in_array( $arguments['site'], (array) $all_sites, true ) ? $arguments['site'] : false;
} elseif ( false !== strpos( $arguments['site'], ',' ) ) {
// Comma-separated list of site ids.
$arguments['site'] = array_filter( array_unique( array_map( function ( $site ) {
return is_numeric( $site ) ? absint( $site ) : false;
}, explode( ',', $arguments['site'] ) ) ) );
$arguments['site'] = array_intersect( $arguments['site'], (array) $all_sites );
$arguments['site'] = ! empty( $arguments['site'] ) ? $arguments['site'] : false;
} elseif ( $arguments['site'] !== 'all' ) {
// Unexpected input format.
$arguments['site'] = false;
}
// Bail if the sites with the provided ids don't exist.
if ( $arguments['site'] === false ) {
\WP_CLI::error( 'Incorrect site ID(s).' );
}
// Process all sites if 'all' or no site id is specified.
if ( $arguments['site'] === 'all' ) {
$arguments['site'] = $all_sites;
}
// Make sure we avoid unnecessary loops in the next block.
if ( is_array( $arguments['site'] ) && count( $arguments['site'] ) === 1 ) {
$arguments['site'] = reset( $arguments['site'] );
}
// If we're working with multiple sites, iterate over each with separate, individual site commands.
// We need to do this because we need to ensure that plugins are loaded on subsites.
if ( is_array( $arguments['site'] ) ) {
foreach ( $arguments['site'] as $site_id ) {
$subsite_url = get_site_url( $site_id );
$command = "searchwp index --site={$site_id} --url={$subsite_url}";
if ( ! empty( $arguments['rebuild'] ) ) {
$command .= ' --rebuild';
}
\WP_CLI::runcommand( $command );
}
} elseif ( get_current_blog_id() != $arguments['site'] ) {
$site_id = $arguments['site'];
$subsite_url = get_site_url( $site_id );
$command = "searchwp index --site={$site_id} --url={$subsite_url}";
if ( ! empty( $arguments['rebuild'] ) ) {
$command .= ' --rebuild';
}
\WP_CLI::runcommand( $command );
} else {
// Build the index for the submitted site.
$index = \SearchWP::$index;
$indexer = \SearchWP::$indexer;
// Prevent the indexer from running because this supercedes it.
$indexer->pause();
$indexer->_destroy_queue();
if ( ! empty( $arguments['rebuild'] ) ) {
\WP_CLI::line( 'Dropping index for site ' . $arguments['site'] );
$index->drop_site( $arguments['site'] );
}
$entries = self::setup_site_entries();
if ( ! empty( $entries ) ) {
$progress = \WP_CLI\Utils\make_progress_bar( 'Building index:', count( $entries ) );
foreach ( $entries as $key => $entry ) {
$source = $index->get_source_by_name( $entry['source'] );
$entry = apply_filters( 'searchwp\indexer\entry', new Entry( $source, $entry['id'] ) );
if ( ! $entry instanceof Entry ) {
$progress->tick();
continue;
}
if ( false === $index->add( $entry ) ) {
$index->mark_entry_as( $entry, 'omitted' );
}
// Clean up variables and cache usage (because it doesn't apply here).
unset( $entry );
unset( $source );
unset( $entries[ $key ] );
gc_collect_cycles();
$progress->tick();
}
$progress->finish();
}
$indexer->unpause();
\WP_CLI::success( 'Index built!' );
}
}
/**
* Reindex entries.
*
* ## OPTIONS
*
* <id>...
* : ID(s) of entries (for the Source) to reindex (space separated).
*
* [--source=<source>]
* : Source of entries to reindex. Omit (or use `post`) as a shortcut for all WP_Post-based Sources.
*
* ## EXAMPLES
*
* # Reindex WP_Post 114
* $ wp searchwp reindex 114
*
* # Reindex WP_Posts 88 and 314
* $ wp searchwp reindex 88 314
*
* # Reindex all WP_Posts of Page post type
* $ wp searchwp reindex $(wp post list --post_type=page --format=ids)
*
* # Reindex WP_User 2
* $ wp searchwp reindex 2 --source=User
*
* @since 4.1
*/
public static function reindex( $args = [], $assoc_args = [] ) {
$arguments = wp_parse_args( $assoc_args, [
'source' => 'post',
] );
$ids = array_unique( array_filter( array_map( 'trim', $args ) ) );
if ( empty( $ids ) ) {
\WP_CLI::error( 'No ID(s) provided.' );
}
$index = \SearchWP::$index;
foreach ( $ids as $entry_id ) {
global $wpdb;
// Maybe look up source name.
$source = $arguments['source'];
if ( 'post' === $arguments['source'] ) {
$source = self::normalize_source_for_entry_id( $arguments['source'], $entry_id );
}
if ( empty( $source ) ) {
// This Entry wasn't indexed in the first place, so we'll prep to index it.
$source = 'post' . SEARCHWP_SEPARATOR . get_post_type( $entry_id );
} else {
// Index drop.
$wpdb->query( $wpdb->prepare( "
DELETE FROM {$index->get_tables()['index']->table_name}
WHERE id = %s AND source = %s AND site = %d",
$entry_id,
$source,
get_current_blog_id()
) );
// Status drop.
$wpdb->query( $wpdb->prepare( "
DELETE FROM {$index->get_tables()['status']->table_name}
WHERE id = %s AND source = %s AND site = %d",
$entry_id,
$source,
get_current_blog_id()
) );
}
$entry = apply_filters( 'searchwp\indexer\entry', new Entry( $source, $entry_id ) );
if ( ! $entry instanceof Entry ) {
\WP_CLI::error( $source . ' [' . $entry_id . '] is not a valid Entry' );
continue;
}
$index->introduce( new \SearchWP\Entries( $index->get_source_by_name( $source ), [ $entry_id ] ) );
if ( false === $index->add( $entry ) ) {
$index->mark_entry_as( $entry, 'omitted' );
\WP_CLI::error( $source . ' [' . $entry_id . '] failed to index' );
} else {
\WP_CLI::line( 'Reindexed ' . $source . ' [' . $entry_id . ']' );
}
}
\WP_CLI::success( 'Done!' );
}
/**
* Diagnose information about the index.
*
* ## OPTIONS
*
* <id>
* : ID of Entry to diagnose.
*
* <tokens|status>
* : Whether to retrieve the tokens for or status of the Entry.
*
* [--source=<source>]
* : Source of Entry to diagnose. Omit (or use `post`) as a shortcut for any WP_Post-based Source.
*
* @since 4.1
*/
public static function diagnostics( $args = [], $assoc_args = [] ) {
$operation = $args[0];
$entry_id = $args[1];
$arguments = wp_parse_args( $assoc_args, [
'source' => 'post',
] );
$source = self::normalize_source_for_entry_id( $arguments['source'], $entry_id );
switch ( $operation ) {
case 'tokens':
$entry = new \SearchWP\Entry( \SearchWP::$index->get_source_by_name( $source ), $entry_id );
$tokens = \SearchWP::$index->get_tokens_for_entry( $entry );
$tokens = array_unique( $tokens );
sort( $tokens );
\WP_CLI::line( wp_json_encode( $tokens ) );
break;
case 'status':
$status = \SearchWP::$index->get_source_id_status( $source, $entry_id );
if ( $status->queued ) {
\WP_CLI::line( 'queued:' . strtotime( $status->queued ) );
} else if ( $status->indexed ) {
\WP_CLI::line( 'indexed:' . strtotime( $status->indexed ) );
} else if ( $status->omitted ) {
\WP_CLI::line( 'omitted:' . strtotime( $status->omitted ) );
}
break;
}
}
/**
* Retrieves unindexed site entries and introduces them to the Index.
*
* @since 4.0
* @return array
*/
private static function setup_site_entries() {
global $wpdb;
$entries = [];
$index = \SearchWP::$index;
foreach ( Settings::get_engines( true ) as $engine ) {
foreach ( $engine->get_sources() as $source ) {
$site = get_current_blog_id();
$timestamp = current_time( 'mysql' );
while ( ! empty ( $unindexed_entries_ids = $source->get_unhandled_ids( 100 ) ) ) {
$these_entries = array_map( function( $entry_id ) use ( $source, $site ) {
return [
'source' => $source->get_name(),
'id' => $entry_id,
'site' => $site,
];
}, $unindexed_entries_ids );
unset( $unindexed_entries_ids );
// Introduce these Entries to the Index.
$values = [];
$placeholders = [];
foreach ( $these_entries as $this_entry ) {
array_push(
$values,
$this_entry['id'],
$this_entry['source'],
$timestamp,
$site
);
$placeholders[] = '( %s, %s, %s, %d )';
}
$wpdb->query( $wpdb->prepare( "
INSERT INTO {$index->get_tables()['status']->table_name}
( id, source, queued, site )
VALUES " . implode( ', ', $placeholders ),
$values
) );
$entries = array_merge( $entries, $these_entries );
unset( $these_entries );
}
}
}
return $entries;
}
/**
* Many commands allow for the --source to be omitted, which then assumes a WP_Post Source which needs to be retrieved based on ID.
*
* @since 4.1
* @param string $source_name The Source name.
* @param string $entry_id The Entry ID.
* @return string The Source name.
*/
private static function normalize_source_for_entry_id( $source_name, $entry_id ) {
global $wpdb;
if ( 'post' === $source_name ) {
$index = \SearchWP::$index;
$source_name = $wpdb->get_var( $wpdb->prepare( "
SELECT source FROM {$index->get_tables()['status']->table_name}
WHERE id = %s AND source LIKE %s AND site = %d",
$entry_id,
'post' . SEARCHWP_SEPARATOR . '%',
get_current_blog_id()
) );
}
return $source_name;
}
}