+ $user->add_lang(array('install', 'acp/extensions', 'migrator'));

+ try

+ if ($phpbb_extension_manager->enable_step($ext_name))

+ {

+ $template->assign_var('S_NEXT_STEP', true);

+ meta_refresh(0, $this->u_action . '&action=enable&ext_name=' . urlencode($ext_name));

+ }

+ }

+ catch (phpbb_db_migration_exception $e)

+ {

+ $template->assign_var('MIGRATOR_ERROR', $e->getLocalisedMessage($user));

+ try

+ if ($phpbb_extension_manager->purge_step($ext_name))

+ {

+ $template->assign_var('S_NEXT_STEP', true);

+ meta_refresh(0, $this->u_action . '&action=purge&ext_name=' . urlencode($ext_name));

+ }

+ }

+ catch (phpbb_db_migration_exception $e)

+ {

+ $template->assign_var('MIGRATOR_ERROR', $e->getLocalisedMessage($user));

+ function phpbb_db_tools(phpbb_db_driver $db, $return_statements = false)

+

+ /**

+ * Get the parameters

+ *

+ * @return array

+ */

+ public function getParameters()

+ {

+ return $this->parameters;

+ }

+

+ /**

+ * Get localised message (with $user->lang())

+ *

+ * @param phpbb_user $user

+ * @return string

+ */

+ public function getLocalisedMessage(phpbb_user $user)

+ {

+ $parameters = $this->getParameters();

+ array_unshift($parameters, $this->getMessage());

+

+ return call_user_func_array(array($user, 'lang'), $parameters);

+ }

+ throw new phpbb_db_migration_exception('CONFIG_ALREADY_EXIST', $config_name);

+ throw new phpbb_db_migration_exception('MODULE_NOT_EXIST', $parent);

+ throw new phpbb_db_migration_exception('MODULE_NOT_EXIST', $parent);

+ throw new phpbb_db_migration_exception('MODULE_NOT_REMOVABLE', $module_id, $result);

+ throw new phpbb_db_migration_exception('PERMISSION_ALREADY_EXIST', $auth_option);

+ return;

+ throw new phpbb_db_migration_exception('ROLE_NOT_EXIST', $old_role_name);

+ $unfulfillable = $this->unfulfillable($name);

+ if ($unfulfillable !== false)

+ throw new phpbb_db_migration_exception('MIGRATION_NOT_FULFILLABLE', $name, $unfulfillable);

+ * @return bool|string False if fulfillable, string of missing migration name if unfulfillable

+ return $name;

+ $unfulfillable = $this->unfulfillable($depend);

+ if ($unfulfillable !== false)

+ return $unfulfillable;

+ if ($this->unfulfillable($name) !== false)

+use Symfony\Component\DependencyInjection\ContainerInterface;

+

+ /** @var ContainerInterface */

+ protected $container;

+

+ /**

+ * Constructor

+ *

+ * @param ContainerInterface $container Container object

+ */

+ public function __construct(ContainerInterface $container)

+ {

+ $this->container = $container;

+ }

+

+use Symfony\Component\DependencyInjection\ContainerInterface;

+

+ /** @var ContainerInterface */

+ protected $container;

+

+ protected $migrator;

+ * @param ContainerInterface $container A container

+ public function __construct(ContainerInterface $container, phpbb_db_driver $db, phpbb_config $config, phpbb_db_migrator $migrator, $extension_table, $phpbb_root_path, $php_ext = '.php', phpbb_cache_driver_interface $cache = null, $cache_name = '_ext')

+ $this->container = $container;

+ $this->migrator = $migrator;

+ return new $extension_class_name($this->container);

+ return new phpbb_extension_base($this->container);

+ // Returns false if not completed

+ if (!$this->handle_migrations($name, 'enable'))

+ {

+ return true;

+ }

+

+ // Returns false if not completed

+ if (!$this->handle_migrations($name, 'purge'))

+ {

+ return true;

+ }

+

+

+ /**

+ * Handle installing/reverting migrations

+ *

+ * @param string $extension_name Name of the extension

+ * @param string $mode enable or purge

+ * @return bool True if completed, False if not completed

+ */

+ protected function handle_migrations($extension_name, $mode)

+ {

+ $migrations_path = $this->phpbb_root_path . $this->get_extension_path($extension_name) . 'migrations/';

+ if (!file_exists($migrations_path) || !is_dir($migrations_path))

+ {

+ return true;

+ }

+

+ $migrations = $this->migrator->load_migrations($migrations_path);

+

+ // What is a safe limit of execution time? Half the max execution time should be safe.

+ $safe_time_limit = (ini_get('max_execution_time') / 2);

+ $start_time = time();

+

+ if ($mode == 'enable')

+ {

+ while (!$this->migrator->finished())

+ {

+ $this->migrator->update();

+

+ // Are we approaching the time limit? If so we want to pause the update and continue after refreshing

+ if ((time() - $start_time) >= $safe_time_limit)

+ {

+ return false;

+ }

+ }

+ }

+ else if ($mode == 'purge')

+ {

+ foreach ($migrations as $migration)

+ {

+ while ($this->migrator->migration_state($migration) !== false)

+ {

+ $this->migrator->revert($migration);

+

+ // Are we approaching the time limit? If so we want to pause the update and continue after refreshing

+ if ((time() - $start_time) >= $safe_time_limit)

+ {

+ return false;

+ }

+ }

+ }

+ }

+

+ return true;

+ }

+ function obtain_ids($search_key, &$result_count, &$id_ary, &$start, $per_page, $sort_dir)

+ // Change start parameter in case out of bounds

+ if ($result_count)

+ {

+ if ($start < 0)

+ {

+ $start = 0;

+ }

+ else if ($start >= $result_count)

+ {

+ $start = floor(($result_count - 1) / $per_page) * $per_page;

+ }

+ }

+

+ public function keyword_search($type, $fields, $terms, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ if ($start < 0)

+ {

+ $start = 0;

+ }

+

+ $sql_found_rows = 'SELECT FOUND_ROWS() as result_count';

+ $result = $this->db->sql_query($sql_found_rows);

+ if ($start >= $result_count)

+ {

+ $start = floor(($result_count - 1) / $per_page) * $per_page;

+

+ $result = $this->db->sql_query_limit($sql, $this->config['search_block_size'], $start);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $id_ary[] = (int) $row[$field];

+ }

+ $this->db->sql_freeresult($result);

+

+ $id_ary = array_unique($id_ary);

+ }

+

+ public function author_search($type, $firstpost_only, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ if ($start < 0)

+ {

+ $start = 0;

+ }

+

+ $sql_found_rows = 'SELECT FOUND_ROWS() as result_count';

+ $result = $this->db->sql_query($sql_found_rows);

+ if ($start >= $result_count)

+ {

+ $start = floor(($result_count - 1) / $per_page) * $per_page;

+

+ $result = $this->db->sql_query_limit($sql, $this->config['search_block_size'], $start);

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $id_ary[] = (int) $row[$field];

+ }

+ $this->db->sql_freeresult($result);

+

+ $id_ary = array_unique($id_ary);

+ }

+

+ public function keyword_search($type, $fields, $terms, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ $sql_calc = $this->db->sql_build_query('SELECT', $sql_array_copy);

+ $this->db->sql_query($sql_calc);

+ $sql_count = 'SELECT FOUND_ROWS() as total_results';

+ $result = $this->db->sql_query($sql_count);

+ if ($start >= $total_results)

+ {

+ $start = floor(($total_results - 1) / $per_page) * $per_page;

+

+ $result = $this->db->sql_query_limit($sql, $this->config['search_block_size'], $start);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $id_ary[] = (int) $row[(($type == 'posts') ? 'post_id' : 'topic_id')];

+ }

+ $this->db->sql_freeresult($result);

+

+ }

+

+ public function author_search($type, $firstpost_only, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ $sql_calc = str_replace('SELECT ' . $select, 'SELECT DISTINCT SQL_CALC_FOUND_ROWS p.post_id', $sql);

+ $this->db->sql_query($sql_calc);

+ $sql_count = 'SELECT FOUND_ROWS() as total_results';

+ $result = $this->db->sql_query($sql_count);

+ if ($start >= $total_results)

+ {

+ $start = floor(($total_results - 1) / $per_page) * $per_page;

+

+ $result = $this->db->sql_query_limit($sql, $this->config['search_block_size'], $start);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $id_ary[] = (int) $row[$field];

+ }

+ $this->db->sql_freeresult($result);

+ }

+

+ public function keyword_search($type, $fields, $terms, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ if ($start < 0)

+ {

+ $start = 0;

+ }

+

+ if ($start >= $result_count)

+ {

+ $start = floor(($result_count - 1) / $per_page) * $per_page;

+

+ $result = $this->db->sql_query_limit($sql, $this->config['search_block_size'], $start);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $id_ary[] = $row[$field];

+ }

+ $this->db->sql_freeresult($result);

+

+ $id_ary = array_unique($id_ary);

+ }

+

+ public function author_search($type, $firstpost_only, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ if ($start < 0)

+ {

+ $start = 0;

+ }

+

+ if ($start >= $result_count)

+ {

+ $start = floor(($result_count - 1) / $per_page) * $per_page;

+

+ $result = $this->db->sql_query_limit($sql, $this->config['search_block_size'], $start);

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $id_ary[] = (int) $row[$field];

+ }

+ $this->db->sql_freeresult($result);

+

+ $id_ary = array_unique($id_ary);

+ }

+

+ public function keyword_search($type, $fields, $terms, $sort_by_sql, $sort_key, $sort_dir, $sort_days, $ex_fid_ary, $m_approve_fid_ary, $topic_id, $author_ary, $author_name, &$id_ary, &$start, $per_page)

+ $result_count = $result['total_found'];

+

+ if ($start >= $result_count)

+ {

+ $start = floor(($result_count - 1) / $per_page) * $per_page;

+

+ $this->sphinx->SetLimits((int) $start, (int) $per_page, SPHINX_MAX_MATCHES);

+ $result = $this->sphinx->Query($search_query_prefix . str_replace('&quot;', '"', $this->search_query), $this->indexes);

+

+ // Could be connection to localhost:9312 failed (errno=111,

+ // msg=Connection refused) during rotate, retry if so

+ $retries = SPHINX_CONNECT_RETRIES;

+ while (!$result && (strpos($this->sphinx->GetLastError(), "errno=111,") !== false) && $retries--)

+ {

+ usleep(SPHINX_CONNECT_WAIT_TIME);

+ $result = $this->sphinx->Query($search_query_prefix . str_replace('&quot;', '"', $this->search_query), $this->indexes);

+ }

+ }

+

+ <dt><label for="fulltext_sphinx_config_file">' . $this->user->lang['FULLTEXT_SPHINX_CONFIG_FILE'] . $this->user->lang['COLON'] . '</label><br /><span>' . $this->user->lang['FULLTEXT_SPHINX_CONFIG_FILE_EXPLAIN'] . '</span></dt>

+ <dd>' . (($this->config_generate()) ? '<textarea readonly="readonly" rows="6" id="sphinx_config_data">' . htmlspecialchars($this->config_file_data) . '</textarea>' : $this->config_file_data) . '</dd>

+ send_status_line(401, 'Unauthorized');