+ 'load_notifications' => array('lang' => 'LOAD_NOTIFICATIONS', 'validate' => 'bool', 'type' => 'radio:yes_no', 'explain' => true),

+ 'board_contact' => array('lang' => 'CONTACT_EMAIL', 'validate' => 'email', 'type' => 'text:25:100', 'explain' => true),

+ 'board_email' => array('lang' => 'ADMIN_EMAIL', 'validate' => 'email', 'type' => 'text:25:100', 'explain' => true),

+ $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));

+ else if (empty($mark_ary))

+ {

+ trigger_error($user->lang['NO_USERS'] . adm_back_link($this->u_action . '&action=list&g=' . $group_id), E_USER_WARNING);

+ }

+ group_user_attributes('default', $group_id, $mark_ary, false, $group_name, $group_row);

+ trigger_error($user->lang['GROUP_DEFS_UPDATED'] . adm_back_link($this->u_action . '&action=list&g=' . $group_id));

+ }

+ else

+ {

+ confirm_box(false, $user->lang['CONFIRM_OPERATION'], build_hidden_fields(array(

+ 'mark' => $mark_ary,

+ 'g' => $group_id,

+ 'i' => $id,

+ 'mode' => $mode,

+ 'action' => $action))

+ );

+ }

+ break;

+ case 'set_default_on_all':

+ if (confirm_box(true))

+ $group_name = ($group_row['group_type'] == GROUP_SPECIAL) ? $user->lang['G_' . $group_row['group_name']] : $group_row['group_name'];

+

+

+ trigger_error($user->lang['GROUP_DEFS_UPDATED'] . adm_back_link($this->u_action . '&action=list&g=' . $group_id));

+ confirm_box(false, $user->lang['CONFIRM_OPERATION'], build_hidden_fields(array(

+ 'mark' => $mark_ary,

+ 'g' => $group_id,

+ 'i' => $id,

+ 'mode' => $mode,

+ 'action' => $action))

+ );

+ if (empty($mark_ary))

+ {

+ trigger_error($user->lang['NO_USERS'] . adm_back_link($this->u_action . '&action=list&g=' . $group_id), E_USER_WARNING);

+ }

+ 'U_DEFAULT_ALL' => "{$this->u_action}&action=set_default_on_all&g=$group_id",

+ *

+ * @param string $module

+ * @param bool|string $module_class

+ * @param bool $use_all_available Use all available instead of just all

+ * enabled extensions

+ * @return array

+ function get_module_infos($module = '', $module_class = false, $use_all_available = false)

+ ->get_classes(true, $use_all_available);

+ 'title' => 'ACP_EXTENSION_MANAGEMENT',

+ 'main' => array('title' => 'ACP_EXTENSIONS', 'auth' => 'acl_a_extensions', 'cat' => array('ACP_EXTENSION_MANAGEMENT')),

+define('NOTIFICATION_TYPES_TABLE', $table_prefix . 'notification_types');

+define('NOTIFICATIONS_TABLE', $table_prefix . 'notifications');

+define('USER_NOTIFICATIONS_TABLE', $table_prefix . 'user_notifications');

+ 'lang' => array_filter($user->lang['datetime'], 'is_string'),

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

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_1_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.1')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_10 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.10', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_10_rc3');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.10')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_10_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.10-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_9');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.add', array('email_max_chunk_size', 50)),

+

+ array('config.update', array('version', '3.0.10-rc1')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_10_rc2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.10-rc2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_10_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.10-rc2')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_10_rc3 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.10-rc3', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_10_rc2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.10-rc3')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_11 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.11', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11_rc2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.11')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_11_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.11-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_10');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'cleanup_deactivated_styles'))),

+ array('custom', array(array(&$this, 'delete_orphan_private_messages'))),

+

+ array('config.update', array('version', '3.0.11-rc1')),

+ );

+ }

+

+ public function cleanup_deactivated_styles()

+ {

+ // Updates users having current style a deactivated one

+ $sql = 'SELECT style_id

+ FROM ' . STYLES_TABLE . '

+ WHERE style_active = 0';

+ $result = $this->sql_query($sql);

+

+ $deactivated_style_ids = array();

+ while ($style_id = $this->db->sql_fetchfield('style_id', false, $result))

+ {

+ $deactivated_style_ids[] = (int) $style_id;

+ }

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

+

+ if (!empty($deactivated_style_ids))

+ {

+ $sql = 'UPDATE ' . USERS_TABLE . '

+ SET user_style = ' . (int) $this->config['default_style'] .'

+ WHERE ' . $this->db->sql_in_set('user_style', $deactivated_style_ids);

+ $this->sql_query($sql);

+ }

+ }

+

+ public function delete_orphan_private_messages()

+ {

+ // Delete orphan private messages

+ $batch_size = 500;

+

+ $sql_array = array(

+ 'SELECT' => 'p.msg_id',

+ 'FROM' => array(

+ PRIVMSGS_TABLE => 'p',

+ ),

+ 'LEFT_JOIN' => array(

+ array(

+ 'FROM' => array(PRIVMSGS_TO_TABLE => 't'),

+ 'ON' => 'p.msg_id = t.msg_id',

+ ),

+ ),

+ 'WHERE' => 't.user_id IS NULL',

+ );

+ $sql = $this->db->sql_build_query('SELECT', $sql_array);

+

+ $result = $this->db->sql_query_limit($sql, $batch_size);

+

+ $delete_pms = array();

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

+ {

+ $delete_pms[] = (int) $row['msg_id'];

+ }

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

+

+ if (!empty($delete_pms))

+ {

+ $sql = 'DELETE FROM ' . PRIVMSGS_TABLE . '

+ WHERE ' . $this->db->sql_in_set('msg_id', $delete_pms);

+ $this->sql_query($sql);

+

+ // Return false to have the Migrator call this function again

+ return false;

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_11_rc2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.11-rc2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11_rc1');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_novalue' => array('BOOL', 0),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_novalue',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.11-rc2')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+/** @todo DROP LOGIN_ATTEMPT_TABLE.attempt_id in 3.0.12-RC1 **/

+

+class phpbb_db_migration_data_30x_3_0_12_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.12-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'update_module_auth'))),

+ array('custom', array(array(&$this, 'update_bots'))),

+ array('custom', array(array(&$this, 'disable_bots_from_receiving_pms'))),

+

+ array('config.update', array('version', '3.0.12-rc1')),

+ );

+ }

+

+ public function disable_bots_from_receiving_pms()

+ {

+ // Disable receiving pms for bots

+ $sql = 'SELECT user_id

+ FROM ' . BOTS_TABLE;

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

+

+ $bot_user_ids = array();

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

+ {

+ $bot_user_ids[] = (int) $row['user_id'];

+ }

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

+

+ if (!empty($bot_user_ids))

+ {

+ $sql = 'UPDATE ' . USERS_TABLE . '

+ SET user_allow_pm = 0

+ WHERE ' . $this->db->sql_in_set('user_id', $bot_user_ids);

+ $this->sql_query($sql);

+ }

+ }

+

+ public function update_module_auth()

+ {

+ $sql = 'UPDATE ' . MODULES_TABLE . '

+ SET module_auth = \'acl_u_sig\'

+ WHERE module_class = \'ucp\'

+ AND module_basename = \'profile\'

+ AND module_mode = \'signature\'';

+ $this->sql_query($sql);

+ }

+

+ public function update_bots()

+ {

+ // Update bots

+ if (!function_exists('user_delete'))

+ {

+ include($this->phpbb_root_path . 'includes/functions_user.' . $this->php_ext);

+ }

+

+ $bots_updates = array(

+ // Bot Deletions

+ 'NG-Search [Bot]' => false,

+ 'Nutch/CVS [Bot]' => false,

+ 'OmniExplorer [Bot]' => false,

+ 'Seekport [Bot]' => false,

+ 'Synoo [Bot]' => false,

+ 'WiseNut [Bot]' => false,

+

+ // Bot Updates

+ // Bot name to bot user agent map

+ 'Baidu [Spider]' => 'Baiduspider',

+ 'Exabot [Bot]' => 'Exabot',

+ 'Voyager [Bot]' => 'voyager/',

+ 'W3C [Validator]' => 'W3C_Validator',

+ );

+

+ foreach ($bots_updates as $bot_name => $bot_agent)

+ {

+ $sql = 'SELECT user_id

+ FROM ' . USERS_TABLE . '

+ WHERE user_type = ' . USER_IGNORE . "

+ AND username_clean = '" . $this->db->sql_escape(utf8_clean_string($bot_name)) . "'";

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

+ $bot_user_id = (int) $this->db->sql_fetchfield('user_id');

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

+

+ if ($bot_user_id)

+ {

+ if ($bot_agent === false)

+ {

+ $sql = 'DELETE FROM ' . BOTS_TABLE . "

+ WHERE user_id = $bot_user_id";

+ $this->sql_query($sql);

+

+ user_delete('remove', $bot_user_id);

+ }

+ else

+ {

+ $sql = 'UPDATE ' . BOTS_TABLE . "

+ SET bot_agent = '" . $this->db->sql_escape($bot_agent) . "'

+ WHERE user_id = $bot_user_id";

+ $this->sql_query($sql);

+ }

+ }

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_1_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.1-rc1', '>=');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'forums' => array(

+ 'display_subforum_list' => array('BOOL', 1),

+ ),

+ $this->table_prefix . 'sessions' => array(

+ 'session_forum_id' => array('UINT', 0),

+ ),

+ ),

+ 'drop_keys' => array(

+ $this->table_prefix . 'groups' => array(

+ 'group_legend',

+ ),

+ ),

+ 'add_index' => array(

+ $this->table_prefix . 'sessions' => array(

+ 'session_forum_id' => array('session_forum_id'),

+ ),

+ $this->table_prefix . 'groups' => array(

+ 'group_legend_name' => array('group_legend', 'group_name'),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'forums' => array(

+ 'display_subforum_list',

+ ),

+ $this->table_prefix . 'sessions' => array(

+ 'session_forum_id',

+ ),

+ ),

+ 'add_index' => array(

+ $this->table_prefix . 'groups' => array(

+ 'group_legend' => array('group_legend'),

+ ),

+ ),

+ 'drop_keys' => array(

+ $this->table_prefix . 'sessions' => array(

+ 'session_forum_id',

+ ),

+ $this->table_prefix . 'groups' => array(

+ 'group_legend_name',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'fix_unset_last_view_time'))),

+ array('custom', array(array(&$this, 'reset_smiley_size'))),

+

+ array('config.update', array('version', '3.0.1-rc1')),

+ );

+ }

+

+ public function fix_unset_last_view_time()

+ {

+ $sql = 'UPDATE ' . $this->table_prefix . "topics

+ SET topic_last_view_time = topic_last_post_time

+ WHERE topic_last_view_time = 0";

+ $this->sql_query($sql);

+ }

+

+ public function reset_smiley_size()

+ {

+ // Update smiley sizes

+ $smileys = array('icon_e_surprised.gif', 'icon_eek.gif', 'icon_cool.gif', 'icon_lol.gif', 'icon_mad.gif', 'icon_razz.gif', 'icon_redface.gif', 'icon_cry.gif', 'icon_evil.gif', 'icon_twisted.gif', 'icon_rolleyes.gif', 'icon_exclaim.gif', 'icon_question.gif', 'icon_idea.gif', 'icon_arrow.gif', 'icon_neutral.gif', 'icon_mrgreen.gif', 'icon_e_ugeek.gif');

+

+ foreach ($smileys as $smiley)

+ {

+ if (file_exists($this->phpbb_root_path . 'images/smilies/' . $smiley))

+ {

+ list($width, $height) = getimagesize($this->phpbb_root_path . 'images/smilies/' . $smiley);

+

+ $sql = 'UPDATE ' . SMILIES_TABLE . '

+ SET smiley_width = ' . $width . ', smiley_height = ' . $height . "

+ WHERE smiley_url = '" . $this->db->sql_escape($smiley) . "'";

+

+ $this->sql_query($sql);

+ }

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_2_rc2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.2')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_2_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.2-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.add', array('referer_validation', '1')),

+ array('config.add', array('check_attachment_content', '1')),

+ array('config.add', array('mime_triggers', 'body|head|html|img|plaintext|a href|pre|script|table|title')),

+

+ array('config.update', array('version', '3.0.2-rc1')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_2_rc2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.2-rc2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_2_rc1');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'change_columns' => array(

+ $this->table_prefix . 'drafts' => array(

+ 'draft_subject' => array('STEXT_UNI', ''),

+ ),

+ $this->table_prefix . 'forums' => array(

+ 'forum_last_post_subject' => array('STEXT_UNI', ''),

+ ),

+ $this->table_prefix . 'posts' => array(

+ 'post_subject' => array('STEXT_UNI', '', 'true_sort'),

+ ),

+ $this->table_prefix . 'privmsgs' => array(

+ 'message_subject' => array('STEXT_UNI', ''),

+ ),

+ $this->table_prefix . 'topics' => array(

+ 'topic_title' => array('STEXT_UNI', '', 'true_sort'),

+ 'topic_last_post_subject' => array('STEXT_UNI', ''),

+ ),

+ ),

+ 'drop_keys' => array(

+ $this->table_prefix . 'sessions' => array(

+ 'session_forum_id',

+ ),

+ ),

+ 'add_index' => array(

+ $this->table_prefix . 'sessions' => array(

+ 'session_fid' => array('session_forum_id'),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'add_index' => array(

+ $this->table_prefix . 'sessions' => array(

+ 'session_forum_id' => array(

+ 'session_forum_id',

+ ),

+ ),

+ ),

+ 'drop_keys' => array(

+ $this->table_prefix . 'sessions' => array(

+ 'session_fid',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.2-rc2')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_3 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.3', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_3_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.3')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_3_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.3-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_2');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'styles_template' => array(

+ 'template_inherits_id' => array('UINT:4', 0),

+ 'template_inherit_path' => array('VCHAR', ''),

+ ),

+ $this->table_prefix . 'groups' => array(

+ 'group_max_recipients' => array('UINT', 0),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'styles_template' => array(

+ 'template_inherits_id',

+ 'template_inherit_path',

+ ),

+ $this->table_prefix . 'groups' => array(

+ 'group_max_recipients',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.add', array('enable_queue_trigger', '0')),

+ array('config.add', array('queue_trigger_posts', '3')),

+ array('config.add', array('pm_max_recipients', '0')),

+ array('custom', array(array(&$this, 'set_group_default_max_recipients'))),

+ array('config.add', array('dbms_version', $this->db->sql_server_info(true))),

+ array('permission.add', array('u_masspm_group', true, 'u_masspm')),

+ array('custom', array(array(&$this, 'correct_acp_email_permissions'))),

+

+ array('config.update', array('version', '3.0.3-rc1')),

+ );

+ }

+

+ public function correct_acp_email_permissions()

+ {

+ $sql = 'UPDATE ' . $this->table_prefix . 'modules

+ SET module_auth = \'acl_a_email && cfg_email_enable\'

+ WHERE module_class = \'acp\'

+ AND module_basename = \'email\'';

+ $this->sql_query($sql);

+ }

+

+ public function set_group_default_max_recipients()

+ {

+ // Set maximum number of recipients for the registered users, bots, guests group

+ $sql = 'UPDATE ' . GROUPS_TABLE . ' SET group_max_recipients = 5

+ WHERE ' . $this->db->sql_in_set('group_name', array('GUESTS', 'REGISTERED', 'REGISTERED_COPPA', 'BOTS'));

+ $this->sql_query($sql);

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_4 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.4', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_4_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'rename_log_delete_topic'))),

+

+ array('config.update', array('version', '3.0.4')),

+ );

+ }

+

+ public function rename_log_delete_topic()

+ {

+ if ($this->db->sql_layer == 'oracle')

+ {

+ // log_operation is CLOB - but we can change this later

+ $sql = 'UPDATE ' . $this->table_prefix . "log

+ SET log_operation = 'LOG_DELETE_TOPIC'

+ WHERE log_operation LIKE 'LOG_TOPIC_DELETED'";

+ $this->sql_query($sql);

+ }

+ else

+ {

+ $sql = 'UPDATE ' . $this->table_prefix . "log

+ SET log_operation = 'LOG_DELETE_TOPIC'

+ WHERE log_operation = 'LOG_TOPIC_DELETED'";

+ $this->sql_query($sql);

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_4_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.4-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_3');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_profile' => array('BOOL', 0),

+ ),

+ ),

+ 'change_columns' => array(

+ $this->table_prefix . 'styles' => array(

+ 'style_id' => array('UINT', NULL, 'auto_increment'),

+ 'template_id' => array('UINT', 0),

+ 'theme_id' => array('UINT', 0),

+ 'imageset_id' => array('UINT', 0),

+ ),

+ $this->table_prefix . 'styles_imageset' => array(

+ 'imageset_id' => array('UINT', NULL, 'auto_increment'),

+ ),

+ $this->table_prefix . 'styles_imageset_data' => array(

+ 'image_id' => array('UINT', NULL, 'auto_increment'),

+ 'imageset_id' => array('UINT', 0),

+ ),

+ $this->table_prefix . 'styles_theme' => array(

+ 'theme_id' => array('UINT', NULL, 'auto_increment'),

+ ),

+ $this->table_prefix . 'styles_template' => array(

+ 'template_id' => array('UINT', NULL, 'auto_increment'),

+ ),

+ $this->table_prefix . 'styles_template_data' => array(

+ 'template_id' => array('UINT', 0),

+ ),

+ $this->table_prefix . 'forums' => array(

+ 'forum_style' => array('UINT', 0),

+ ),

+ $this->table_prefix . 'users' => array(

+ 'user_style' => array('UINT', 0),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_profile',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'update_custom_profile_fields'))),

+

+ array('config.update', array('version', '3.0.4-rc1')),

+ );

+ }

+

+ public function update_custom_profile_fields()

+ {

+ // Update the Custom Profile Fields based on previous settings to the new format

+ $sql = 'SELECT field_id, field_required, field_show_on_reg, field_hide

+ FROM ' . PROFILE_FIELDS_TABLE;

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

+

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

+ {

+ $sql_ary = array(

+ 'field_required' => 0,

+ 'field_show_on_reg' => 0,

+ 'field_hide' => 0,

+ 'field_show_profile'=> 0,

+ );

+

+ if ($row['field_required'])

+ {

+ $sql_ary['field_required'] = $sql_ary['field_show_on_reg'] = $sql_ary['field_show_profile'] = 1;

+ }

+ else if ($row['field_show_on_reg'])

+ {

+ $sql_ary['field_show_on_reg'] = $sql_ary['field_show_profile'] = 1;

+ }

+ else if ($row['field_hide'])

+ {

+ // Only administrators and moderators can see this CPF, if the view is enabled, they can see it, otherwise just admins in the acp_users module

+ $sql_ary['field_hide'] = 1;

+ }

+ else

+ {

+ // equivelant to "none", which is the "Display in user control panel" option

+ $sql_ary['field_show_profile'] = 1;

+ }

+

+ $this->sql_query('UPDATE ' . $this->table_prefix . 'profile_fields SET ' . $this->db->sql_build_array('UPDATE', $sql_ary) . ' WHERE field_id = ' . $row['field_id'], $errored, $error_ary);

+ }

+

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

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_5 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.5', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_5_rc1part2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.5')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_5_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.5-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_4');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'change_columns' => array(

+ $this->table_prefix . 'forums' => array(

+ 'forum_style' => array('UINT', 0),

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ $search_indexing_state = $this->config['search_indexing_state'];

+

+ return array(

+ array('config.add', array('captcha_gd_wave', 0)),

+ array('config.add', array('captcha_gd_3d_noise', 1)),

+ array('config.add', array('captcha_gd_fonts', 1)),

+ array('config.add', array('confirm_refresh', 1)),

+ array('config.add', array('max_num_search_keywords', 10)),

+ array('config.remove', array('search_indexing_state')),

+ array('config.add', array('search_indexing_state', $search_indexing_state, true)),

+ array('custom', array(array(&$this, 'hash_old_passwords'))),

+ array('custom', array(array(&$this, 'update_ichiro_bot'))),

+ );

+ }

+

+ public function hash_old_passwords()

+ {

+ $sql = 'SELECT user_id, user_password

+ FROM ' . $this->table_prefix . 'users

+ WHERE user_pass_convert = 1';

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

+

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

+ {

+ if (strlen($row['user_password']) == 32)

+ {

+ $sql_ary = array(

+ 'user_password' => phpbb_hash($row['user_password']),

+ );

+

+ $this->sql_query('UPDATE ' . $this->table_prefix . 'users SET ' . $this->db->sql_build_array('UPDATE', $sql_ary) . ' WHERE user_id = ' . $row['user_id']);

+ }

+ }

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

+ }

+

+ public function update_ichiro_bot()

+ {

+ // Adjust bot entry

+ $sql = 'UPDATE ' . $this->table_prefix . "bots

+ SET bot_agent = 'ichiro/'

+ WHERE bot_agent = 'ichiro/2'";

+ $this->sql_query($sql);

+ }

+

+ public function remove_duplicate_auth_options()

+ {

+ // Before we are able to add a unique key to auth_option, we need to remove duplicate entries

+ $sql = 'SELECT auth_option

+ FROM ' . $this->table_prefix . 'acl_options

+ GROUP BY auth_option

+ HAVING COUNT(*) >= 2';

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

+

+ $auth_options = array();

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

+ {

+ $auth_options[] = $row['auth_option'];

+ }

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

+

+ // Remove specific auth options

+ if (!empty($auth_options))

+ {

+ foreach ($auth_options as $option)

+ {

+ // Select auth_option_ids... the largest id will be preserved

+ $sql = 'SELECT auth_option_id

+ FROM ' . ACL_OPTIONS_TABLE . "

+ WHERE auth_option = '" . $db->sql_escape($option) . "'

+ ORDER BY auth_option_id DESC";

+ // sql_query_limit not possible here, due to bug in postgresql layer

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

+

+ // Skip first row, this is our original auth option we want to preserve

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

+

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

+ {

+ // Ok, remove this auth option...

+ $this->sql_query('DELETE FROM ' . ACL_OPTIONS_TABLE . ' WHERE auth_option_id = ' . $row['auth_option_id']);

+ $this->sql_query('DELETE FROM ' . ACL_ROLES_DATA_TABLE . ' WHERE auth_option_id = ' . $row['auth_option_id']);

+ $this->sql_query('DELETE FROM ' . ACL_GROUPS_TABLE . ' WHERE auth_option_id = ' . $row['auth_option_id']);

+ $this->sql_query('DELETE FROM ' . ACL_USERS_TABLE . ' WHERE auth_option_id = ' . $row['auth_option_id']);

+ }

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

+ }

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_5_rc1part2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.5-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_5_rc1');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'drop_keys' => array(

+ $this->table_prefix . 'acl_options' => array('auth_option'),

+ ),

+ 'add_unique_index' => array(

+ $this->table_prefix . 'acl_options' => array(

+ 'auth_option' => array('auth_option'),

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.5-rc1')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_6 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.6', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_6_rc4');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.6')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_6_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.6-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_5');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'confirm' => array(

+ 'attempts' => array('UINT', 0),

+ ),

+ $this->table_prefix . 'users' => array(

+ 'user_new' => array('BOOL', 1),

+ 'user_reminded' => array('TINT:4', 0),

+ 'user_reminded_time' => array('TIMESTAMP', 0),

+ ),

+ $this->table_prefix . 'groups' => array(

+ 'group_skip_auth' => array('BOOL', 0, 'after' => 'group_founder_manage'),

+ ),

+ $this->table_prefix . 'privmsgs' => array(

+ 'message_reported' => array('BOOL', 0),

+ ),

+ $this->table_prefix . 'reports' => array(

+ 'pm_id' => array('UINT', 0),

+ ),

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_on_vt' => array('BOOL', 0),

+ ),

+ $this->table_prefix . 'forums' => array(

+ 'forum_options' => array('UINT:20', 0),

+ ),

+ ),

+ 'change_columns' => array(

+ $this->table_prefix . 'users' => array(

+ 'user_options' => array('UINT:11', 230271),

+ ),

+ ),

+ 'add_index' => array(

+ $this->table_prefix . 'reports' => array(

+ 'post_id' => array('post_id'),

+ 'pm_id' => array('pm_id'),

+ ),

+ $this->table_prefix . 'posts' => array(

+ 'post_username' => array('post_username:255'),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'confirm' => array(

+ 'attempts',

+ ),

+ $this->table_prefix . 'users' => array(

+ 'user_new',

+ 'user_reminded',

+ 'user_reminded_time',

+ ),

+ $this->table_prefix . 'groups' => array(

+ 'group_skip_auth',

+ ),

+ $this->table_prefix . 'privmsgs' => array(

+ 'message_reported',

+ ),

+ $this->table_prefix . 'reports' => array(

+ 'pm_id',

+ ),

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_on_vt',

+ ),

+ $this->table_prefix . 'forums' => array(

+ 'forum_options',

+ ),

+ ),

+ 'drop_keys' => array(

+ $this->table_prefix . 'reports' => array(

+ 'post_id',

+ 'pm_id',

+ ),

+ $this->table_prefix . 'posts' => array(

+ 'post_username',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.add', array('captcha_plugin', 'phpbb_captcha_nogd')),

+ array('if', array(

+ ($this->config['captcha_gd']),

+ array('config.update', array('captcha_plugin', 'phpbb_captcha_gd')),

+ )),

+

+ array('config.add', array('feed_enable', 0)),

+ array('config.add', array('feed_limit', 10)),

+ array('config.add', array('feed_overall_forums', 1)),

+ array('config.add', array('feed_overall_forums_limit', 15)),

+ array('config.add', array('feed_overall_topics', 0)),

+ array('config.add', array('feed_overall_topics_limit', 15)),

+ array('config.add', array('feed_forum', 1)),

+ array('config.add', array('feed_topic', 1)),

+ array('config.add', array('feed_item_statistics', 1)),

+

+ array('config.add', array('smilies_per_page', 50)),

+ array('config.add', array('allow_pm_report', 1)),

+ array('config.add', array('min_post_chars', 1)),

+ array('config.add', array('allow_quick_reply', 1)),

+ array('config.add', array('new_member_post_limit', 0)),

+ array('config.add', array('new_member_group_default', 0)),

+ array('config.add', array('delete_time', $this->config['edit_time'])),

+

+ array('config.add', array('allow_avatar', 0)),

+ array('if', array(

+ ($this->config['allow_avatar_upload'] || $this->config['allow_avatar_local'] || $this->config['allow_avatar_remote']),

+ array('config.update', array('allow_avatar', 1)),

+ )),

+ array('config.add', array('allow_avatar_remote_upload', 0)),

+ array('if', array(

+ ($this->config['allow_avatar_remote'] && $this->config['allow_avatar_upload']),

+ array('config.update', array('allow_avatar_remote_upload', 1)),

+ )),

+

+ array('module.add', array(

+ 'acp',

+ 'ACP_BOARD_CONFIGURATION',

+ array(

+ 'module_basename' => 'acp_board',

+ 'modes' => array('feed'),

+ ),

+ )),

+ array('module.add', array(

+ 'acp',

+ 'ACP_CAT_USERS',

+ array(

+ 'module_basename' => 'acp_users',

+ 'modes' => array('warnings'),

+ ),

+ )),

+ array('module.add', array(

+ 'acp',

+ 'ACP_SERVER_CONFIGURATION',

+ array(

+ 'module_basename' => 'acp_send_statistics',

+ 'modes' => array('send_statistics'),

+ ),

+ )),

+ array('module.add', array(

+ 'acp',

+ 'ACP_FORUM_BASED_PERMISSIONS',

+ array(

+ 'module_basename' => 'acp_permissions',

+ 'modes' => array('setting_forum_copy'),

+ ),

+ )),

+ array('module.add', array(

+ 'mcp',

+ 'MCP_REPORTS',

+ array(

+ 'module_basename' => 'mcp_pm_reports',

+ 'modes' => array('pm_reports','pm_reports_closed','pm_report_details'),

+ ),

+ )),

+ array('custom', array(array(&$this, 'add_newly_registered_group'))),

+ array('custom', array(array(&$this, 'set_user_options_default'))),

+

+ array('config.update', array('version', '3.0.6-rc1')),

+ );

+ }

+

+ public function set_user_options_default()

+ {

+ // 229376 is the added value to enable all three signature options

+ $sql = 'UPDATE ' . USERS_TABLE . ' SET user_options = user_options + 229376';

+ $this->sql_query($sql);

+ }

+

+ public function add_newly_registered_group()

+ {

+ // Add newly_registered group... but check if it already exists (we always supported running the updater on any schema)

+ $sql = 'SELECT group_id

+ FROM ' . GROUPS_TABLE . "

+ WHERE group_name = 'NEWLY_REGISTERED'";

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

+ $group_id = (int) $this->db->sql_fetchfield('group_id');

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

+

+ if (!$group_id)

+ {

+ $sql = 'INSERT INTO ' . GROUPS_TABLE . " (group_name, group_type, group_founder_manage, group_colour, group_legend, group_avatar, group_desc, group_desc_uid, group_max_recipients) VALUES ('NEWLY_REGISTERED', 3, 0, '', 0, '', '', '', 5)";

+ $this->sql_query($sql);

+

+ $group_id = $this->db->sql_nextid();

+ }

+

+ // Insert new user role... at the end of the chain

+ $sql = 'SELECT role_id

+ FROM ' . ACL_ROLES_TABLE . "

+ WHERE role_name = 'ROLE_USER_NEW_MEMBER'

+ AND role_type = 'u_'";

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

+ $u_role = (int) $this->db->sql_fetchfield('role_id');

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

+

+ if (!$u_role)

+ {

+ $sql = 'SELECT MAX(role_order) as max_order_id

+ FROM ' . ACL_ROLES_TABLE . "

+ WHERE role_type = 'u_'";

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

+ $next_order_id = (int) $this->db->sql_fetchfield('max_order_id');

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

+

+ $next_order_id++;

+

+ $sql = 'INSERT INTO ' . ACL_ROLES_TABLE . " (role_name, role_description, role_type, role_order) VALUES ('ROLE_USER_NEW_MEMBER', 'ROLE_DESCRIPTION_USER_NEW_MEMBER', 'u_', $next_order_id)";

+ $this->sql_query($sql);

+ $u_role = $this->db->sql_nextid();

+

+ // Now add the correct data to the roles...

+ // The standard role says that new users are not able to send a PM, Mass PM, are not able to PM groups

+ $sql = 'INSERT INTO ' . ACL_ROLES_DATA_TABLE . " (role_id, auth_option_id, auth_setting) SELECT $u_role, auth_option_id, 0 FROM " . ACL_OPTIONS_TABLE . " WHERE auth_option LIKE 'u_%' AND auth_option IN ('u_sendpm', 'u_masspm', 'u_masspm_group')";

+ $this->sql_query($sql);

+

+ // Add user role to group

+ $sql = 'INSERT INTO ' . ACL_GROUPS_TABLE . " (group_id, forum_id, auth_option_id, auth_role_id, auth_setting) VALUES ($group_id, 0, 0, $u_role, 0)";

+ $this->sql_query($sql);

+ }

+

+ // Insert new forum role

+ $sql = 'SELECT role_id

+ FROM ' . ACL_ROLES_TABLE . "

+ WHERE role_name = 'ROLE_FORUM_NEW_MEMBER'

+ AND role_type = 'f_'";

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

+ $f_role = (int) $this->db->sql_fetchfield('role_id');

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

+

+ if (!$f_role)

+ {

+ $sql = 'SELECT MAX(role_order) as max_order_id

+ FROM ' . ACL_ROLES_TABLE . "

+ WHERE role_type = 'f_'";

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

+ $next_order_id = (int) $this->db->sql_fetchfield('max_order_id');

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

+

+ $next_order_id++;

+

+ $sql = 'INSERT INTO ' . ACL_ROLES_TABLE . " (role_name, role_description, role_type, role_order) VALUES ('ROLE_FORUM_NEW_MEMBER', 'ROLE_DESCRIPTION_FORUM_NEW_MEMBER', 'f_', $next_order_id)";

+ $this->sql_query($sql);

+ $f_role = $this->db->sql_nextid();

+

+ $sql = 'INSERT INTO ' . ACL_ROLES_DATA_TABLE . " (role_id, auth_option_id, auth_setting) SELECT $f_role, auth_option_id, 0 FROM " . ACL_OPTIONS_TABLE . " WHERE auth_option LIKE 'f_%' AND auth_option IN ('f_noapprove')";

+ $this->sql_query($sql);

+ }

+

+ // Set every members user_new column to 0 (old users) only if there is no one yet (this makes sure we do not execute this more than once)

+ $sql = 'SELECT 1

+ FROM ' . USERS_TABLE . '

+ WHERE user_new = 0';

+ $result = $this->db->sql_query_limit($sql, 1);

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

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

+

+ if (!$row)

+ {

+ $sql = 'UPDATE ' . USERS_TABLE . ' SET user_new = 0';

+ $this->sql_query($sql);

+ }

+

+ // To mimick the old "feature" we will assign the forum role to every forum, regardless of the setting (this makes sure there are no "this does not work!!!! YUO!!!" posts...

+ // Check if the role is already assigned...

+ $sql = 'SELECT forum_id

+ FROM ' . ACL_GROUPS_TABLE . '

+ WHERE group_id = ' . $group_id . '

+ AND auth_role_id = ' . $f_role;

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

+ $is_options = (int) $this->db->sql_fetchfield('forum_id');

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

+

+ // Not assigned at all... :/

+ if (!$is_options)

+ {

+ // Get postable forums

+ $sql = 'SELECT forum_id

+ FROM ' . FORUMS_TABLE . '

+ WHERE forum_type != ' . FORUM_LINK;

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

+

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

+ {

+ $this->sql_query('INSERT INTO ' . ACL_GROUPS_TABLE . ' (group_id, forum_id, auth_option_id, auth_role_id, auth_setting) VALUES (' . $group_id . ', ' . (int) $row['forum_id'] . ', 0, ' . $f_role . ', 0)');

+ }

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

+ }

+

+ // Clear permissions...

+ include_once($this->phpbb_root_path . 'includes/acp/auth.' . $this->php_ext);

+ $auth_admin = new auth_admin();

+ $auth_admin->acl_clear_prefetch();

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_6_rc2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.6-rc2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_6_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.6-rc2')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_6_rc3 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.6-rc3', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_6_rc2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'update_cp_fields'))),

+

+ array('config.update', array('version', '3.0.6-rc3')),

+ );

+ }

+

+ public function update_cp_fields()

+ {

+ // Update the Custom Profile Fields based on previous settings to the new format

+ $sql = 'UPDATE ' . PROFILE_FIELDS_TABLE . '

+ SET field_show_on_vt = 1

+ WHERE field_hide = 0

+ AND (field_required = 1 OR field_show_on_reg = 1 OR field_show_profile = 1)';

+ $this->sql_query($sql);

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_6_rc4 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.6-rc4', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_6_rc3');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.6-rc4')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_7 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.7', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_7_rc2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.7')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_7_pl1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.7-pl1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_7');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.7-pl1')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_7_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.7-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_6');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'drop_keys' => array(

+ $this->table_prefix . 'log' => array(

+ 'log_time',

+ ),

+ ),

+ 'add_index' => array(

+ $this->table_prefix . 'topics_track' => array(

+ 'topic_id' => array('topic_id'),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'add_index' => array(

+ $this->table_prefix . 'log' => array(

+ 'log_time' => array('log_time'),

+ ),

+ ),

+ 'drop_keys' => array(

+ $this->table_prefix . 'topics_track' => array(

+ 'topic_id',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.add', array('feed_overall', 1)),

+ array('config.add', array('feed_http_auth', 0)),

+ array('config.add', array('feed_limit_post', $this->config['feed_limit'])),

+ array('config.add', array('feed_limit_topic', $this->config['feed_overall_topics_limit'])),

+ array('config.add', array('feed_topics_new', $this->config['feed_overall_topics'])),

+ array('config.add', array('feed_topics_active', $this->config['feed_overall_topics'])),

+ array('custom', array(array(&$this, 'delete_text_templates'))),

+

+ array('config.update', array('version', '3.0.7-rc1')),

+ );

+ }

+

+ public function delete_text_templates()

+ {

+ // Delete all text-templates from the template_data

+ $sql = 'DELETE FROM ' . STYLES_TEMPLATE_DATA_TABLE . '

+ WHERE template_filename ' . $this->db->sql_like_expression($this->db->any_char . '.txt');

+ $this->sql_query($sql);

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_7_rc2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.7-rc2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_7_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'update_email_hash'))),

+

+ array('config.update', array('version', '3.0.7-rc2')),

+ );

+ }

+

+ public function update_email_hash($start = 0)

+ {

+ $limit = 1000;

+

+ $sql = 'SELECT user_id, user_email, user_email_hash

+ FROM ' . USERS_TABLE . '

+ WHERE user_type <> ' . USER_IGNORE . "

+ AND user_email <> ''";

+ $result = $this->db->sql_query_limit($sql, $limit, $start);

+

+ $i = 0;

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

+ {

+ $i++;

+

+ // Snapshot of the phpbb_email_hash() function

+ // We cannot call it directly because the auto updater updates the DB first. :/

+ $user_email_hash = sprintf('%u', crc32(strtolower($row['user_email']))) . strlen($row['user_email']);

+

+ if ($user_email_hash != $row['user_email_hash'])

+ {

+ $sql_ary = array(

+ 'user_email_hash' => $user_email_hash,

+ );

+

+ $sql = 'UPDATE ' . USERS_TABLE . '

+ SET ' . $this->db->sql_build_array('UPDATE', $sql_ary) . '

+ WHERE user_id = ' . (int) $row['user_id'];

+ $this->sql_query($sql);

+ }

+ }

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

+

+ if ($i < $limit)

+ {

+ // Completed

+ return;

+ }

+

+ // Return the next start, will be sent to $start when this function is called again

+ return $start + $limit;

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_8 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.8', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_8_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.8')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_8_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.8-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_7_pl1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array(&$this, 'update_file_extension_group_names'))),

+ array('custom', array(array(&$this, 'update_module_auth'))),

+ array('custom', array(array(&$this, 'update_bots'))),

+ array('custom', array(array(&$this, 'delete_orphan_shadow_topics'))),

+ array('module.add', array(

+ 'acp',

+ 'ACP_MESSAGES',

+ array(

+ 'module_basename' => 'acp_board',

+ 'modes' => array('post'),

+ ),

+ )),

+ array('config.add', array('load_unreads_search', 1)),

+ array('config.update_if_equals', array(600, 'queue_interval', 60)),

+ array('config.update_if_equals', array(50, 'email_package_size', 20)),

+

+ array('config.update', array('version', '3.0.8-rc1')),

+ );

+ }

+

+ public function update_file_extension_group_names()

+ {

+ // Update file extension group names to use language strings.

+ $sql = 'SELECT lang_dir

+ FROM ' . LANG_TABLE;

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

+

+ $extension_groups_updated = array();

+ while ($lang_dir = $this->db->sql_fetchfield('lang_dir'))

+ {

+ $lang_dir = basename($lang_dir);

+

+ // The language strings we need are either in language/.../acp/attachments.php

+ // in the update package if we're updating to 3.0.8-RC1 or later,

+ // or they are in language/.../install.php when we're updating from 3.0.7-PL1 or earlier.

+ // On an already updated board, they can also already be in language/.../acp/attachments.php

+ // in the board root.

+ $lang_files = array(

+ "{$this->phpbb_root_path}install/update/new/language/$lang_dir/acp/attachments.{$this->php_ext}",

+ "{$this->phpbb_root_path}language/$lang_dir/install.{$this->php_ext}",

+ "{$this->phpbb_root_path}language/$lang_dir/acp/attachments.{$this->php_ext}",

+ );

+

+ foreach ($lang_files as $lang_file)

+ {

+ if (!file_exists($lang_file))

+ {

+ continue;

+ }

+

+ $lang = array();

+ include($lang_file);

+

+ foreach($lang as $lang_key => $lang_val)

+ {

+ if (isset($extension_groups_updated[$lang_key]) || strpos($lang_key, 'EXT_GROUP_') !== 0)

+ {

+ continue;

+ }

+

+ $sql_ary = array(

+ 'group_name' => substr($lang_key, 10), // Strip off 'EXT_GROUP_'

+ );

+

+ $sql = 'UPDATE ' . EXTENSION_GROUPS_TABLE . '

+ SET ' . $this->db->sql_build_array('UPDATE', $sql_ary) . "

+ WHERE group_name = '" . $this->db->sql_escape($lang_val) . "'";

+ $this->sql_query($sql);

+

+ $extension_groups_updated[$lang_key] = true;

+ }

+ }

+ }

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

+ }

+

+ public function update_module_auth()

+ {

+ $sql = 'UPDATE ' . MODULES_TABLE . '

+ SET module_auth = \'cfg_allow_avatar && (cfg_allow_avatar_local || cfg_allow_avatar_remote || cfg_allow_avatar_upload || cfg_allow_avatar_remote_upload)\'

+ WHERE module_class = \'ucp\'

+ AND module_basename = \'profile\'

+ AND module_mode = \'avatar\'';

+ $this->sql_query($sql);

+ }

+

+ public function update_bots()

+ {

+ $bot_name = 'Bing [Bot]';

+ $bot_name_clean = utf8_clean_string($bot_name);

+

+ $sql = 'SELECT user_id

+ FROM ' . USERS_TABLE . "

+ WHERE username_clean = '" . $this->db->sql_escape($bot_name_clean) . "'";

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

+ $bing_already_added = (bool) $this->db->sql_fetchfield('user_id');

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

+

+ if (!$bing_already_added)

+ {

+ $bot_agent = 'bingbot/';

+ $bot_ip = '';

+ $sql = 'SELECT group_id, group_colour

+ FROM ' . GROUPS_TABLE . "

+ WHERE group_name = 'BOTS'";

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

+ $group_row = $this->db->sql_fetchrow($result);

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

+

+ if (!$group_row)

+ {

+ // default fallback, should never get here

+ $group_row['group_id'] = 6;

+ $group_row['group_colour'] = '9E8DA7';

+ }

+

+ if (!function_exists('user_add'))

+ {

+ include($this->phpbb_root_path . 'includes/functions_user.' . $this->php_ext);

+ }

+

+ $user_row = array(

+ 'user_type' => USER_IGNORE,

+ 'group_id' => $group_row['group_id'],

+ 'username' => $bot_name,

+ 'user_regdate' => time(),

+ 'user_password' => '',

+ 'user_colour' => $group_row['group_colour'],

+ 'user_email' => '',

+ 'user_lang' => $this->config['default_lang'],

+ 'user_style' => $this->config['default_style'],

+ 'user_timezone' => 0,

+ 'user_dateformat' => $this->config['default_dateformat'],

+ 'user_allow_massemail' => 0,

+ );

+

+ $user_id = user_add($user_row);

+

+ $sql = 'INSERT INTO ' . BOTS_TABLE . ' ' . $this->db->sql_build_array('INSERT', array(

+ 'bot_active' => 1,

+ 'bot_name' => (string) $bot_name,

+ 'user_id' => (int) $user_id,

+ 'bot_agent' => (string) $bot_agent,

+ 'bot_ip' => (string) $bot_ip,

+ ));

+

+ $this->sql_query($sql);

+ }

+ }

+

+ public function delete_orphan_shadow_topics()

+ {

+ // Delete shadow topics pointing to not existing topics

+ $batch_size = 500;

+

+ // Set of affected forums we have to resync

+ $sync_forum_ids = array();

+

+ $sql_array = array(

+ 'SELECT' => 't1.topic_id, t1.forum_id',

+ 'FROM' => array(

+ TOPICS_TABLE => 't1',

+ ),

+ 'LEFT_JOIN' => array(

+ array(

+ 'FROM' => array(TOPICS_TABLE => 't2'),

+ 'ON' => 't1.topic_moved_id = t2.topic_id',

+ ),

+ ),

+ 'WHERE' => 't1.topic_moved_id <> 0

+ AND t2.topic_id IS NULL',

+ );

+ $sql = $this->db->sql_build_query('SELECT', $sql_array);

+ $result = $this->db->sql_query_limit($sql, $batch_size);

+

+ $topic_ids = array();

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

+ {

+ $topic_ids[] = (int) $row['topic_id'];

+

+ $sync_forum_ids[(int) $row['forum_id']] = (int) $row['forum_id'];

+ }

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

+

+ if (!empty($topic_ids))

+ {

+ $sql = 'DELETE FROM ' . TOPICS_TABLE . '

+ WHERE ' . $this->db->sql_in_set('topic_id', $topic_ids);

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

+

+ // Sync the forums we have deleted shadow topics from.

+ sync('forum', 'forum_id', $sync_forum_ids, true, true);

+

+ return false;

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_9 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.9', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_9_rc4');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.9')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_9_rc1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.9-rc1', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_8');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_tables' => array(

+ $this->table_prefix . 'login_attempts' => array(

+ 'COLUMNS' => array(

+ // this column was removed from the database updater

+ // after 3.0.9-RC3 was released. It might still exist

+ // in 3.0.9-RCX installations and has to be dropped in

+ // 3.0.12 after the db_tools class is capable of properly

+ // removing a primary key.

+ // 'attempt_id' => array('UINT', NULL, 'auto_increment'),

+ 'attempt_ip' => array('VCHAR:40', ''),

+ 'attempt_browser' => array('VCHAR:150', ''),

+ 'attempt_forwarded_for' => array('VCHAR:255', ''),

+ 'attempt_time' => array('TIMESTAMP', 0),

+ 'user_id' => array('UINT', 0),

+ 'username' => array('VCHAR_UNI:255', 0),

+ 'username_clean' => array('VCHAR_CI', 0),

+ ),

+ //'PRIMARY_KEY' => 'attempt_id',

+ 'KEYS' => array(

+ 'att_ip' => array('INDEX', array('attempt_ip', 'attempt_time')),

+ 'att_for' => array('INDEX', array('attempt_forwarded_for', 'attempt_time')),

+ 'att_time' => array('INDEX', array('attempt_time')),

+ 'user_id' => array('INDEX', 'user_id'),

+ ),

+ ),

+ ),

+ 'change_columns' => array(

+ $this->table_prefix . 'bbcodes' => array(

+ 'bbcode_id' => array('USINT', 0),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_tables' => array(

+ $this->table_prefix . 'login_attempts',

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.add', array('ip_login_limit_max', 50)),

+ array('config.add', array('ip_login_limit_time', 21600)),

+ array('config.add', array('ip_login_limit_use_forwarded', 0)),

+ array('custom', array(array(&$this, 'update_file_extension_group_names'))),

+ array('custom', array(array(&$this, 'fix_firebird_qa_captcha'))),

+

+ array('config.update', array('version', '3.0.9-rc1')),

+ );

+ }

+

+ public function update_file_extension_group_names()

+ {

+ // Update file extension group names to use language strings, again.

+ $sql = 'SELECT group_id, group_name

+ FROM ' . EXTENSION_GROUPS_TABLE . '

+ WHERE group_name ' . $this->db->sql_like_expression('EXT_GROUP_' . $this->db->any_char);

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

+

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

+ {

+ $sql_ary = array(

+ 'group_name' => substr($row['group_name'], 10), // Strip off 'EXT_GROUP_'

+ );

+

+ $sql = 'UPDATE ' . EXTENSION_GROUPS_TABLE . '

+ SET ' . $this->db->sql_build_array('UPDATE', $sql_ary) . '

+ WHERE group_id = ' . $row['group_id'];

+ $this->sql_query($sql);

+ }

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

+ }

+

+ public function fix_firebird_qa_captcha()

+ {

+ // Recover from potentially broken Q&A CAPTCHA table on firebird

+ // Q&A CAPTCHA was uninstallable, so it's safe to remove these

+ // without data loss

+ if ($this->db_tools->sql_layer == 'firebird')

+ {

+ $tables = array(

+ $this->table_prefix . 'captcha_questions',

+ $this->table_prefix . 'captcha_answers',

+ $this->table_prefix . 'qa_confirm',

+ );

+ foreach ($tables as $table)

+ {

+ if ($this->db_tools->sql_table_exists($table))

+ {

+ $this->db_tools->sql_table_drop($table);

+ }

+ }

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_9_rc2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.9-rc2', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_9_rc1');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.9-rc2')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_9_rc3 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.9-rc3', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_9_rc2');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.9-rc3')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_30x_3_0_9_rc4 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.0.9-rc4', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_9_rc3');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('version', '3.0.9-rc4')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_dev extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return version_compare($this->config['version'], '3.1.0-dev', '>=');

+ }

+

+ static public function depends_on()

+ {

+ return array(

+ 'phpbb_db_migration_data_310_extensions',

+ 'phpbb_db_migration_data_310_style_update_p2',

+ 'phpbb_db_migration_data_310_timezone_p2',

+ 'phpbb_db_migration_data_310_reported_posts_display',

+ );

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'groups' => array(

+ 'group_teampage' => array('UINT', 0, 'after' => 'group_legend'),

+ ),

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_on_pm' => array('BOOL', 0),

+ ),

+ $this->table_prefix . 'styles' => array(

+ 'style_path' => array('VCHAR:100', ''),

+ 'bbcode_bitfield' => array('VCHAR:255', 'kNg='),

+ 'style_parent_id' => array('UINT:4', 0),

+ 'style_parent_tree' => array('TEXT', ''),

+ ),

+ $this->table_prefix . 'reports' => array(

+ 'reported_post_text' => array('MTEXT_UNI', ''),

+ 'reported_post_uid' => array('VCHAR:8', ''),

+ 'reported_post_bitfield' => array('VCHAR:255', ''),

+ ),

+ ),

+ 'change_columns' => array(

+ $this->table_prefix . 'groups' => array(

+ 'group_legend' => array('UINT', 0),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'groups' => array(

+ 'group_teampage',

+ ),

+ $this->table_prefix . 'profile_fields' => array(

+ 'field_show_on_pm',

+ ),

+ $this->table_prefix . 'styles' => array(

+ 'style_path',

+ 'bbcode_bitfield',

+ 'style_parent_id',

+ 'style_parent_tree',

+ ),

+ $this->table_prefix . 'reports' => array(

+ 'reported_post_text',

+ 'reported_post_uid',

+ 'reported_post_bitfield',

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('config.update', array('search_type', 'phpbb_search_' . $this->config['search_type'])),

+

+ array('config.add', array('fulltext_postgres_ts_name', 'simple')),

+ array('config.add', array('fulltext_postgres_min_word_len', 4)),

+ array('config.add', array('fulltext_postgres_max_word_len', 254)),

+ array('config.add', array('fulltext_sphinx_stopwords', 0)),

+ array('config.add', array('fulltext_sphinx_indexer_mem_limit', 512)),

+

+ array('config.add', array('load_jquery_cdn', 0)),

+ array('config.add', array('load_jquery_url', '//ajax.googleapis.com/ajax/libs/jquery/1.6.2/jquery.min.js')),

+

+ array('config.add', array('use_system_cron', 0)),

+

+ array('config.add', array('legend_sort_groupname', 0)),

+ array('config.add', array('teampage_forums', 1)),

+ array('config.add', array('teampage_memberships', 1)),

+

+ array('config.add', array('load_cpf_pm', 0)),

+

+ array('config.add', array('display_last_subject', 1)),

+

+ array('config.add', array('assets_version', 1)),

+

+ array('config.add', array('site_home_url', '')),

+ array('config.add', array('site_home_text', '')),

+

+ array('permission.add', array('u_chgprofileinfo', true, 'u_sig')),

+

+ array('module.add', array(

+ 'acp',

+ 'ACP_GROUPS',

+ array(

+ 'module_basename' => 'acp_groups',

+ 'modes' => array('position'),

+ ),

+ )),

+ array('module.add', array(

+ 'acp',

+ 'ACP_ATTACHMENTS',

+ array(

+ 'module_basename' => 'acp_attachments',

+ 'modes' => array('manage'),

+ ),

+ )),

+ array('module.add', array(

+ 'acp',

+ 'ACP_STYLE_MANAGEMENT',

+ array(

+ 'module_basename' => 'acp_styles',

+ 'modes' => array('install', 'cache'),

+ ),

+ )),

+ array('module.add', array(

+ 'ucp',

+ 'UCP_PROFILE',

+ array(

+ 'module_basename' => 'ucp_profile',

+ 'modes' => array('autologin_keys'),

+ ),

+ )),

+ // Module will be renamed later

+ array('module.add', array(

+ 'acp',

+ 'ACP_CAT_STYLES',

+ 'ACP_LANGUAGE'

+ )),

+

+ array('module.remove', array(

+ 'acp',

+ false,

+ 'ACP_TEMPLATES',

+ )),

+ array('module.remove', array(

+ 'acp',

+ false,

+ 'ACP_THEMES',

+ )),

+ array('module.remove', array(

+ 'acp',

+ false,

+ 'ACP_IMAGESETS',

+ )),

+

+ array('custom', array(array($this, 'rename_module_basenames'))),

+ array('custom', array(array($this, 'rename_styles_module'))),

+ array('custom', array(array($this, 'add_group_teampage'))),

+ array('custom', array(array($this, 'update_group_legend'))),

+ array('custom', array(array($this, 'localise_global_announcements'))),

+ array('custom', array(array($this, 'update_ucp_pm_basename'))),

+ array('custom', array(array($this, 'update_ucp_profile_auth'))),

+ array('custom', array(array($this, 'move_customise_modules'))),

+

+ array('config.update', array('version', '3.1.0-dev')),

+ );

+ }

+

+ public function move_customise_modules()

+ {

+ // Move language management to new location in the Customise tab

+ // First get language module id

+ $sql = 'SELECT module_id FROM ' . MODULES_TABLE . "

+ WHERE module_basename = 'acp_language'";

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

+ $language_module_id = $this->db->sql_fetchfield('module_id');

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

+ // Next get language management module id of the one just created

+ $sql = 'SELECT module_id FROM ' . MODULES_TABLE . "

+ WHERE module_langname = 'ACP_LANGUAGE'";

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

+ $language_management_module_id = $this->db->sql_fetchfield('module_id');

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

+

+ if (!class_exists('acp_modules'))

+ {

+ include($this->phpbb_root_path . 'includes/acp/acp_modules.' . $this->php_ext);

+ }

+ // acp_modules calls adm_back_link, which is undefined at this point

+ if (!function_exists('adm_back_link'))

+ {

+ include($this->phpbb_root_path . 'includes/functions_acp.' . $this->php_ext);

+ }

+ $module_manager = new acp_modules();

+ $module_manager->module_class = 'acp';

+ $module_manager->move_module($language_module_id, $language_management_module_id);

+ }

+

+ public function update_ucp_pm_basename()

+ {

+ $sql = 'SELECT module_id, module_basename

+ FROM ' . MODULES_TABLE . "

+ WHERE module_basename <> 'ucp_pm' AND

+ module_langname='UCP_PM'";

+ $result = $this->db->sql_query_limit($sql, 1);

+

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

+ {

+ // This update is still not applied. Applying it

+

+ $sql = 'UPDATE ' . MODULES_TABLE . "

+ SET module_basename = 'ucp_pm'

+ WHERE module_id = " . (int) $row['module_id'];

+

+ $this->sql_query($sql);

+ }

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

+ }

+

+ public function update_ucp_profile_auth()

+ {

+ // Update the auth setting for the module

+ $sql = 'UPDATE ' . MODULES_TABLE . "

+ SET module_auth = 'acl_u_chgprofileinfo'

+ WHERE module_class = 'ucp'

+ AND module_basename = 'ucp_profile'

+ AND module_mode = 'profile_info'";

+ $this->sql_query($sql);

+ }

+

+ public function rename_styles_module()

+ {

+ // Rename styles module to Customise

+ $sql = 'UPDATE ' . MODULES_TABLE . "

+ SET module_langname = 'ACP_CAT_CUSTOMISE'

+ WHERE module_langname = 'ACP_CAT_STYLES'";

+ $this->sql_query($sql);

+ }

+

+ public function rename_module_basenames()

+ {

+ // rename all module basenames to full classname

+ $sql = 'SELECT module_id, module_basename, module_class

+ FROM ' . MODULES_TABLE;

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

+

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

+ {

+ $module_id = (int) $row['module_id'];

+ unset($row['module_id']);

+

+ if (!empty($row['module_basename']) && !empty($row['module_class']))

+ {

+ // all the class names start with class name or with phpbb_ for auto loading

+ if (strpos($row['module_basename'], $row['module_class'] . '_') !== 0 &&

+ strpos($row['module_basename'], 'phpbb_') !== 0)

+ {

+ $row['module_basename'] = $row['module_class'] . '_' . $row['module_basename'];

+

+ $sql_update = $this->db->sql_build_array('UPDATE', $row);

+

+ $sql = 'UPDATE ' . MODULES_TABLE . '

+ SET ' . $sql_update . '

+ WHERE module_id = ' . $module_id;

+ $this->sql_query($sql);

+ }

+ }

+ }

+

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

+ }

+

+ public function add_group_teampage()

+ {

+ $sql = 'UPDATE ' . GROUPS_TABLE . '

+ SET group_teampage = 1

+ WHERE group_type = ' . GROUP_SPECIAL . "

+ AND group_name = 'ADMINISTRATORS'";

+ $this->sql_query($sql);

+

+ $sql = 'UPDATE ' . GROUPS_TABLE . '

+ SET group_teampage = 2

+ WHERE group_type = ' . GROUP_SPECIAL . "

+ AND group_name = 'GLOBAL_MODERATORS'";

+ $this->sql_query($sql);

+ }

+

+ public function update_group_legend()

+ {

+ $sql = 'SELECT group_id

+ FROM ' . GROUPS_TABLE . '

+ WHERE group_legend = 1

+ ORDER BY group_name ASC';

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

+

+ $next_legend = 1;

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

+ {

+ $sql = 'UPDATE ' . GROUPS_TABLE . '

+ SET group_legend = ' . $next_legend . '

+ WHERE group_id = ' . (int) $row['group_id'];

+ $this->sql_query($sql);

+

+ $next_legend++;

+ }

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

+ }

+

+ public function localise_global_announcements()

+ {

+ // Localise Global Announcements

+ $sql = 'SELECT topic_id, topic_approved, (topic_replies + 1) AS topic_posts, topic_last_post_id, topic_last_post_subject, topic_last_post_time, topic_last_poster_id, topic_last_poster_name, topic_last_poster_colour

+ FROM ' . TOPICS_TABLE . '

+ WHERE forum_id = 0

+ AND topic_type = ' . POST_GLOBAL;

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

+

+ $global_announcements = $update_lastpost_data = array();

+ $update_lastpost_data['forum_last_post_time'] = 0;

+ $update_forum_data = array(

+ 'forum_posts' => 0,

+ 'forum_topics' => 0,

+ 'forum_topics_real' => 0,

+ );

+

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

+ {

+ $global_announcements[] = (int) $row['topic_id'];

+

+ $update_forum_data['forum_posts'] += (int) $row['topic_posts'];

+ $update_forum_data['forum_topics_real']++;

+ if ($row['topic_approved'])

+ {

+ $update_forum_data['forum_topics']++;

+ }

+

+ if ($update_lastpost_data['forum_last_post_time'] < $row['topic_last_post_time'])

+ {

+ $update_lastpost_data = array(

+ 'forum_last_post_id' => (int) $row['topic_last_post_id'],

+ 'forum_last_post_subject' => $row['topic_last_post_subject'],

+ 'forum_last_post_time' => (int) $row['topic_last_post_time'],

+ 'forum_last_poster_id' => (int) $row['topic_last_poster_id'],

+ 'forum_last_poster_name' => $row['topic_last_poster_name'],

+ 'forum_last_poster_colour' => $row['topic_last_poster_colour'],

+ );

+ }

+ }

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

+

+ if (!empty($global_announcements))

+ {

+ // Update the post/topic-count for the forum and the last-post if needed

+ $sql = 'SELECT forum_id

+ FROM ' . FORUMS_TABLE . '

+ WHERE forum_type = ' . FORUM_POST;

+ $result = $this->db->sql_query_limit($sql, 1);

+ $ga_forum_id = $this->db->sql_fetchfield('forum_id');

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

+

+ $sql = 'SELECT forum_last_post_time

+ FROM ' . FORUMS_TABLE . '

+ WHERE forum_id = ' . $ga_forum_id;

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

+ $lastpost = (int) $this->db->sql_fetchfield('forum_last_post_time');

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

+

+ $sql_update = 'forum_posts = forum_posts + ' . $update_forum_data['forum_posts'] . ', ';

+ $sql_update .= 'forum_topics_real = forum_topics_real + ' . $update_forum_data['forum_topics_real'] . ', ';

+ $sql_update .= 'forum_topics = forum_topics + ' . $update_forum_data['forum_topics'];

+ if ($lastpost < $update_lastpost_data['forum_last_post_time'])

+ {

+ $sql_update .= ', ' . $this->db->sql_build_array('UPDATE', $update_lastpost_data);

+ }

+

+ $sql = 'UPDATE ' . FORUMS_TABLE . '

+ SET ' . $sql_update . '

+ WHERE forum_id = ' . $ga_forum_id;

+ $this->sql_query($sql);

+

+ // Update some forum_ids

+ $table_ary = array(TOPICS_TABLE, POSTS_TABLE, LOG_TABLE, DRAFTS_TABLE, TOPICS_TRACK_TABLE);

+ foreach ($table_ary as $table)

+ {

+ $sql = "UPDATE $table

+ SET forum_id = $ga_forum_id

+ WHERE " . $this->db->sql_in_set('topic_id', $global_announcements);

+ $this->sql_query($sql);

+ }

+ unset($table_ary);

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_extensions extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return $this->db_tools->sql_table_exists($this->table_prefix . 'ext');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_tables' => array(

+ $this->table_prefix . 'ext' => array(

+ 'COLUMNS' => array(

+ 'ext_name' => array('VCHAR', ''),

+ 'ext_active' => array('BOOL', 0),

+ 'ext_state' => array('TEXT', ''),

+ ),

+ 'KEYS' => array(

+ 'ext_name' => array('UNIQUE', 'ext_name'),

+ ),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_tables' => array(

+ $this->table_prefix . 'ext',

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ // Module will be renamed later

+ array('module.add', array(

+ 'acp',

+ 'ACP_CAT_STYLES',

+ 'ACP_EXTENSION_MANAGEMENT'

+ )),

+ array('module.add', array(

+ 'acp',

+ 'ACP_EXTENSION_MANAGEMENT',

+ array(

+ 'module_basename' => 'acp_extensions',

+ 'modes' => array('main'),

+ ),

+ )),

+ array('permission.add', array('a_extensions', true, 'a_styles')),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_notifications extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return $this->db_tools->sql_table_exists($this->table_prefix . 'notifications');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_310_dev');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_tables' => array(

+ $this->table_prefix . 'notification_types' => array(

+ 'COLUMNS' => array(

+ 'notification_type' => array('VCHAR:255', ''),

+ 'notification_type_enabled' => array('BOOL', 1),

+ ),

+ 'PRIMARY_KEY' => array('notification_type', 'notification_type_enabled'),

+ ),

+ $this->table_prefix . 'notifications' => array(

+ 'COLUMNS' => array(

+ 'notification_id' => array('UINT', NULL, 'auto_increment'),

+ 'item_type' => array('VCHAR:255', ''),

+ 'item_id' => array('UINT', 0),

+ 'item_parent_id' => array('UINT', 0),

+ 'user_id' => array('UINT', 0),

+ 'notification_read' => array('BOOL', 0),

+ 'notification_time' => array('TIMESTAMP', 1),

+ 'notification_data' => array('TEXT_UNI', ''),

+ ),

+ 'PRIMARY_KEY' => 'notification_id',

+ 'KEYS' => array(

+ 'item_ident' => array('INDEX', array('item_type', 'item_id')),

+ 'user' => array('INDEX', array('user_id', 'notification_read')),

+ ),

+ ),

+ $this->table_prefix . 'user_notifications' => array(

+ 'COLUMNS' => array(

+ 'item_type' => array('VCHAR:255', ''),

+ 'item_id' => array('UINT', 0),

+ 'user_id' => array('UINT', 0),

+ 'method' => array('VCHAR:255', ''),

+ 'notify' => array('BOOL', 1),

+ ),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_tables' => array(

+ $this->table_prefix . 'notification_types',

+ $this->table_prefix . 'notifications',

+ $this->table_prefix . 'user_notifications',

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('module.add', array(

+ 'ucp',

+ 'UCP_MAIN',

+ array(

+ 'module_basename' => 'ucp_notifications',

+ 'modes' => array('notification_list'),

+ ),

+ )),

+ array('module.add', array(

+ 'ucp',

+ 'UCP_PREFS',

+ array(

+ 'module_basename' => 'ucp_notifications',

+ 'modes' => array('notification_options'),

+ ),

+ )),

+ array('config.add', array('load_notifications', 1)),

+ array('custom', array(array($this, 'convert_notifications'))),

+ );

+ }

+

+ public function convert_notifications()

+ {

+ $convert_notifications = array(

+ array(

+ 'check' => ($this->config['allow_topic_notify']),

+ 'item_type' => 'post',

+ ),

+ array(

+ 'check' => ($this->config['allow_forum_notify']),

+ 'item_type' => 'topic',

+ ),

+ array(

+ 'check' => ($this->config['allow_bookmarks']),

+ 'item_type' => 'bookmark',

+ ),

+ array(

+ 'check' => ($this->config['allow_privmsg']),

+ 'item_type' => 'pm',

+ ),

+ );

+

+ foreach ($convert_notifications as $convert_data)

+ {

+ if ($convert_data['check'])

+ {

+ $sql = 'SELECT user_id, user_notify_type

+ FROM ' . USERS_TABLE . '

+ WHERE user_notify = 1';

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

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

+ {

+ $this->sql_query('INSERT INTO ' . $this->table_prefix . 'user_notifications ' . $this->db->sql_build_array('INSERT', array(

+ 'item_type' => $convert_data['item_type'],

+ 'item_id' => 0,

+ 'user_id' => $row['user_id'],

+ 'method' => '',

+ )));

+

+ if ($row['user_notify_type'] == NOTIFY_EMAIL || $row['user_notify_type'] == NOTIFY_BOTH)

+ {

+ $this->sql_query('INSERT INTO ' . $this->table_prefix . 'user_notifications ' . $this->db->sql_build_array('INSERT', array(

+ 'item_type' => $convert_data['item_type'],

+ 'item_id' => 0,

+ 'user_id' => $row['user_id'],

+ 'method' => 'email',

+ )));

+ }

+

+ if ($row['user_notify_type'] == NOTIFY_IM || $row['user_notify_type'] == NOTIFY_BOTH)

+ {

+ $this->sql_query('INSERT INTO ' . $this->table_prefix . 'user_notifications ' . $this->db->sql_build_array('INSERT', array(

+ 'item_type' => $convert_data['item_type'],

+ 'item_id' => 0,

+ 'user_id' => $row['user_id'],

+ 'method' => 'jabber',

+ )));

+ }

+ }

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

+ }

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_reported_posts_display extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return $this->db_tools->sql_column_exists($this->table_prefix . 'reports', 'reported_post_enable_bbcode');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'reports' => array(

+ 'reported_post_enable_bbcode' => array('BOOL', 1),

+ 'reported_post_enable_smilies' => array('BOOL', 1),

+ 'reported_post_enable_magic_url' => array('BOOL', 1),

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'reports' => array(

+ 'reported_post_enable_bbcode',

+ 'reported_post_enable_smilies',

+ 'reported_post_enable_magic_url',

+ ),

+ ),

+ );

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_style_update_p1 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return !$this->db_tools->sql_table_exists($this->table_prefix . 'styles_imageset');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11');

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array($this, 'styles_update'))),

+ );

+ }

+

+ public function styles_update()

+ {

+ // Get list of valid 3.1 styles

+ $available_styles = array('prosilver');

+

+ $iterator = new DirectoryIterator($this->phpbb_root_path . 'styles');

+ $skip_dirs = array('.', '..', 'prosilver');

+ foreach ($iterator as $fileinfo)

+ {

+ if ($fileinfo->isDir() && !in_array($fileinfo->getFilename(), $skip_dirs) && file_exists($fileinfo->getPathname() . '/style.cfg'))

+ {

+ $style_cfg = parse_cfg_file($fileinfo->getPathname() . '/style.cfg');

+ if (isset($style_cfg['phpbb_version']) && version_compare($style_cfg['phpbb_version'], '3.1.0-dev', '>='))

+ {

+ // 3.1 style

+ $available_styles[] = $fileinfo->getFilename();

+ }

+ }

+ }

+

+ // Get all installed styles

+ if ($this->db_tools->sql_table_exists($this->table_prefix . 'styles_imageset'))

+ {

+ $sql = 'SELECT s.style_id, t.template_path, t.template_id, t.bbcode_bitfield, t.template_inherits_id, t.template_inherit_path, c.theme_path, c.theme_id, i.imageset_path

+ FROM ' . STYLES_TABLE . ' s, ' . $this->table_prefix . 'styles_template t, ' . $this->table_prefix . 'styles_theme c, ' . $this->table_prefix . "styles_imageset i

+ WHERE t.template_id = s.template_id

+ AND c.theme_id = s.theme_id

+ AND i.imageset_id = s.imageset_id";

+ }

+ else

+ {

+ $sql = 'SELECT s.style_id, t.template_path, t.template_id, t.bbcode_bitfield, t.template_inherits_id, t.template_inherit_path, c.theme_path, c.theme_id

+ FROM ' . STYLES_TABLE . ' s, ' . $this->table_prefix . 'styles_template t, ' . $this->table_prefix . "stles_theme c

+ WHERE t.template_id = s.template_id

+ AND c.theme_id = s.theme_id";

+ }

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

+

+ $styles = array();

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

+ {

+ $styles[] = $row;

+ }

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

+

+ // Decide which styles to keep, all others will be deleted

+ $valid_styles = array();

+ foreach ($styles as $style_row)

+ {

+ if (

+ // Delete styles with parent style (not supported yet)

+ $style_row['template_inherits_id'] == 0 &&

+ // Check if components match

+ $style_row['template_path'] == $style_row['theme_path'] && (!isset($style_row['imageset_path']) || $style_row['template_path'] == $style_row['imageset_path']) &&

+ // Check if components are valid

+ in_array($style_row['template_path'], $available_styles)

+ )

+ {

+ // Valid style. Keep it

+ $sql_ary = array(

+ 'style_path' => $style_row['template_path'],

+ 'bbcode_bitfield' => $style_row['bbcode_bitfield'],

+ 'style_parent_id' => 0,

+ 'style_parent_tree' => '',

+ );

+ $this->sql_query('UPDATE ' . STYLES_TABLE . '

+ SET ' . $this->db->sql_build_array('UPDATE', $sql_ary) . '

+ WHERE style_id = ' . $style_row['style_id']);

+ $valid_styles[] = (int) $style_row['style_id'];

+ }

+ }

+

+ // Remove old entries from styles table

+ if (!sizeof($valid_styles))

+ {

+ // No valid styles: remove everything and add prosilver

+ $this->sql_query('DELETE FROM ' . STYLES_TABLE, $errored, $error_ary);

+

+ $sql_ary = array(

+ 'style_name' => 'prosilver',

+ 'style_copyright' => '&copy; phpBB Group',

+ 'style_active' => 1,

+ 'style_path' => 'prosilver',

+ 'bbcode_bitfield' => 'lNg=',

+ 'style_parent_id' => 0,

+ 'style_parent_tree' => '',

+

+ // Will be removed in the next step

+ 'imageset_id' => 0,

+ 'template_id' => 0,

+ 'theme_id' => 0,

+ );

+

+ $sql = 'INSERT INTO ' . STYLES_TABLE . ' ' . $this->db->sql_build_array('INSERT', $sql_ary);

+ $this->sql_query($sql);

+

+ $sql = 'SELECT style_id

+ FROM ' . $table . "

+ WHERE style_name = 'prosilver'";

+ $result = $this->sql_query($sql);

+ $default_style = $this->db->sql_fetchfield($result);

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

+

+ set_config('default_style', $default_style);

+

+ $sql = 'UPDATE ' . USERS_TABLE . ' SET user_style = 0';

+ $this->sql_query($sql);

+ }

+ else

+ {

+ // There are valid styles in styles table. Remove styles that are outdated

+ $this->sql_query('DELETE FROM ' . STYLES_TABLE . '

+ WHERE ' . $this->db->sql_in_set('style_id', $valid_styles, true));

+

+ // Change default style

+ if (!in_array($this->config['default_style'], $valid_styles))

+ {

+ $this->sql_query('UPDATE ' . CONFIG_TABLE . "

+ SET config_value = '" . $valid_styles[0] . "'

+ WHERE config_name = 'default_style'");

+ }

+

+ // Reset styles for users

+ $this->sql_query('UPDATE ' . USERS_TABLE . '

+ SET user_style = 0

+ WHERE ' . $this->db->sql_in_set('user_style', $valid_styles, true));

+ }

+ }

+}

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_style_update_p2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return !$this->db_tools->sql_table_exists($this->table_prefix . 'styles_imageset');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_310_style_update_p1');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'styles' => array(

+ 'imageset_id',

+ 'template_id',

+ 'theme_id',

+ ),

+ ),

+

+ 'drop_tables' => array(

+ $this->table_prefix . 'styles_imageset',

+ $this->table_prefix . 'styles_imageset_data',

+ $this->table_prefix . 'styles_template',

+ $this->table_prefix . 'styles_template_data',

+ $this->table_prefix . 'styles_theme',

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'styles' => array(

+ 'imageset_id' => array('UINT', 0),

+ 'template_id' => array('UINT', 0),

+ 'theme_id' => array('UINT', 0),

+ ),

+ ),

+

+ 'add_tables' => array(

+ $this->table_prefix . 'styles_imageset' => array(

+ 'COLUMNS' => array(

+ 'imageset_id' => array('UINT', NULL, 'auto_increment'),

+ 'imageset_name' => array('VCHAR_UNI:255', ''),

+ 'imageset_copyright' => array('VCHAR_UNI', ''),

+ 'imageset_path' => array('VCHAR:100', ''),

+ ),

+ 'PRIMARY_KEY' => 'imageset_id',

+ 'KEYS' => array(

+ 'imgset_nm' => array('UNIQUE', 'imageset_name'),

+ ),

+ ),

+ $this->table_prefix . 'styles_imageset_data' => array(

+ 'COLUMNS' => array(

+ 'image_id' => array('UINT', NULL, 'auto_increment'),

+ 'image_name' => array('VCHAR:200', ''),

+ 'image_filename' => array('VCHAR:200', ''),

+ 'image_lang' => array('VCHAR:30', ''),

+ 'image_height' => array('USINT', 0),

+ 'image_width' => array('USINT', 0),

+ 'imageset_id' => array('UINT', 0),

+ ),

+ 'PRIMARY_KEY' => 'image_id',

+ 'KEYS' => array(

+ 'i_d' => array('INDEX', 'imageset_id'),

+ ),

+ ),

+ $this->table_prefix . 'styles_template' => array(

+ 'COLUMNS' => array(

+ 'template_id' => array('UINT', NULL, 'auto_increment'),

+ 'template_name' => array('VCHAR_UNI:255', ''),

+ 'template_copyright' => array('VCHAR_UNI', ''),

+ 'template_path' => array('VCHAR:100', ''),

+ 'bbcode_bitfield' => array('VCHAR:255', 'kNg='),

+ 'template_storedb' => array('BOOL', 0),

+ 'template_inherits_id' => array('UINT:4', 0),

+ 'template_inherit_path' => array('VCHAR', ''),

+ ),

+ 'PRIMARY_KEY' => 'template_id',

+ 'KEYS' => array(

+ 'tmplte_nm' => array('UNIQUE', 'template_name'),

+ ),

+ ),

+ $this->table_prefix . 'styles_template_data' => array(

+ 'COLUMNS' => array(

+ 'template_id' => array('UINT', 0),

+ 'template_filename' => array('VCHAR:100', ''),

+ 'template_included' => array('TEXT', ''),

+ 'template_mtime' => array('TIMESTAMP', 0),

+ 'template_data' => array('MTEXT_UNI', ''),

+ ),

+ 'KEYS' => array(

+ 'tid' => array('INDEX', 'template_id'),

+ 'tfn' => array('INDEX', 'template_filename'),

+ ),

+ ),

+ $this->table_prefix . 'styles_theme' => array(

+ 'COLUMNS' => array(

+ 'theme_id' => array('UINT', NULL, 'auto_increment'),

+ 'theme_name' => array('VCHAR_UNI:255', ''),

+ 'theme_copyright' => array('VCHAR_UNI', ''),

+ 'theme_path' => array('VCHAR:100', ''),

+ 'theme_storedb' => array('BOOL', 0),

+ 'theme_mtime' => array('TIMESTAMP', 0),

+ 'theme_data' => array('MTEXT_UNI', ''),

+ ),

+ 'PRIMARY_KEY' => 'theme_id',

+ 'KEYS' => array(

+ 'theme_name' => array('UNIQUE', 'theme_name'),

+ ),

+ ),

+ ),

+ );

+ }

+}

+* @package migration

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+class phpbb_db_migration_data_310_timezone extends phpbb_db_migration

+ public function effectively_installed()

+ {

+ return !$this->db_tools->sql_column_exists($this->table_prefix . 'users', 'user_dst');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_30x_3_0_11');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'change_columns' => array(

+ $this->table_prefix . 'users' => array(

+ 'user_timezone' => array('VCHAR:100', ''),

+ ),

+ ),

+ );

+ }

+

+ public function update_data()

+ {

+ return array(

+ array('custom', array(array($this, 'update_timezones'))),

+ );

+ }

+

+ public function update_timezones()

+ {

+ // Update user timezones

+ $sql = 'SELECT user_dst, user_timezone

+ FROM ' . $this->table_prefix . 'users

+ GROUP BY user_timezone, user_dst';

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

+

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

+ {

+ $sql = 'UPDATE ' . $this->table_prefix . "users

+ SET user_timezone = '" . $this->db->sql_escape($this->convert_phpbb30_timezone($row['user_timezone'], $row['user_dst'])) . "'

+ WHERE user_timezone = '" . $this->db->sql_escape($row['user_timezone']) . "'

+ AND user_dst = " . (int) $row['user_dst'];

+ $this->sql_query($sql);

+ }

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

+

+ // Update board default timezone

+ $sql = 'UPDATE ' . $this->table_prefix . "config

+ SET config_value = '" . $this->convert_phpbb30_timezone($this->config['board_timezone'], $this->config['board_dst']) . "'

+ WHERE config_name = 'board_timezone'";

+ $this->sql_query($sql);

+ }

+

+ public function convert_phpbb30_timezone($timezone, $dst)

+<?php

+/**

+*

+* @package migration

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-license.php GNU Public License v2

+*

+*/

+

+class phpbb_db_migration_data_310_timezone_p2 extends phpbb_db_migration

+{

+ public function effectively_installed()

+ {

+ return !$this->db_tools->sql_column_exists($this->table_prefix . 'users', 'user_dst');

+ }

+

+ static public function depends_on()

+ {

+ return array('phpbb_db_migration_data_310_timezone');

+ }

+

+ public function update_schema()

+ {

+ return array(

+ 'drop_columns' => array(

+ $this->table_prefix . 'users' => array(

+ 'user_dst',

+ ),

+ ),

+ );

+ }

+

+ public function revert_schema()

+ {

+ return array(

+ 'add_columns' => array(

+ $this->table_prefix . 'users' => array(

+ 'user_dst' => array('BOOL', 0),

+ ),

+ ),

+ );

+ }

+}

+

+ /**

+ * 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);

+ $module = $this->get_module_info($class, $basename);

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

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

+ $module_info = $this->get_module_info($class, $basename);

+ $this->remove($class, $parent, $info['title']);

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

+

+ /**

+ * Wrapper for acp_modules::get_module_infos()

+ *

+ * @param string $class Module Class

+ * @param string $basename Module Basename

+ * @return array Module Information

+ */

+ protected function get_module_info($class, $basename)

+ {

+ if (!class_exists('acp_modules'))

+ {

+ include($this->phpbb_root_path . 'includes/acp/acp_modules.' . $this->php_ext);

+ }

+ $acp_modules = new acp_modules();

+ $module = $acp_modules->get_module_infos($basename, $class, true);

+

+ if (empty($module))

+ {

+ throw new phpbb_db_migration_exception('MODULE_INFO_FILE_NOT_EXIST', $class, $basename);

+ }

+

+ return array_pop($module);

+ }

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

+ return;

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

+ /** @var phpbb_extension_manager */

+ protected $extension_manager;

+

+ * Set Extension Manager (required)

+ *

+ * Not in constructor to prevent circular reference error

+ */

+ public function set_extension_manager(phpbb_extension_manager $extension_manager)

+ {

+ $this->extension_manager = $extension_manager;

+ }

+

+ /**

+ // prevent errors in case the table does not exist yet

+ $this->db->sql_return_on_error(true);

+

+ if (!$this->db->sql_error_triggered)

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

+ {

+ $this->migration_state[$migration['migration_name']] = $migration;

+ $this->migration_state[$migration['migration_name']]['migration_depends_on'] = unserialize($migration['migration_depends_on']);

+ }

+

+ $this->db->sql_return_on_error(false);

+ public function load_migrations($path, $check_fulfillable = true)

+ $migrations = array();

+ $finder = $this->extension_manager->get_finder();

+ $files = $finder

+ ->extension_directory("/")

+ ->find_from_paths(array('/' => $path));

+ foreach ($files as $file)

+ {

+ $migrations[$file['path'] . $file['filename']] = '';

+ }

+ $migrations = $finder->get_classes_from_files($migrations);

+ foreach ($migrations as $migration)

+ {

+ if (!in_array($migration, $this->migrations))

+ $this->migrations[] = $migration;

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

+ if ($unfulfillable !== false)

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

+ if (!isset($this->migration_state[$name]))

+ if ($migration->effectively_installed())

+ {

+ $state = array(

+ 'migration_depends_on' => $migration->depends_on(),

+ 'migration_schema_done' => true,

+ 'migration_data_done' => true,

+ 'migration_data_state' => '',

+ 'migration_start_time' => 0,

+ 'migration_end_time' => 0,

+ );

+ }

+ else

+ $this->insert_migration($name, $state);

+ $result = $this->process_data_step($migration->revert_data(), '', false);

+ $this->insert_migration($name, $state);

+ * Insert/Update migration row into the database

+ if (isset($this->migration_state[$name]))

+ {

+ $sql = 'UPDATE ' . $this->migrations_table . '

+ SET ' . $this->db->sql_build_array('UPDATE', $migration_row) . "

+ WHERE migration_name = '" . $this->db->sql_escape($name) . "'";

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

+ }

+ else

+ {

+ $migration_row['migration_name'] = $name;

+ $sql = 'INSERT INTO ' . $this->migrations_table . '

+ ' . $this->db->sql_build_array('INSERT', $migration_row);

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

+ }

+ * @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;

+ }

+

+ * @param bool $use_all_available Use all available instead of just all

+ * enabled extensions

+ public function get_classes($cache = true, $use_all_available = false)

+ $files = $this->find($cache, false, $use_all_available);

+ return $this->get_classes_from_files($files);

+ }

+

+ /**

+ * Get class names from a list of files

+ *

+ * @param array $files Array of files (from find())

+ * @return array Array of class names

+ */

+ public function get_classes_from_files($files)

+ {

+ * @param bool $use_all_available Use all available instead of just all

+ * enabled extensions

+ public function get_directories($cache = true, $use_all_available = false, $extension_keys = false)

+ return $this->find_with_root_path($cache, true, $use_all_available, $extension_keys);

+ * @param bool $use_all_available Use all available instead of just all

+ * enabled extensions

+ public function get_files($cache = true, $use_all_available = false)

+ return $this->find_with_root_path($cache, false, $use_all_available);

+ * @param bool $use_all_available Use all available instead of just all

+ * enabled extensions

+ protected function find_with_root_path($cache = true, $is_dir = false, $use_all_available = false, $extension_keys = false)

+ $items = $this->find($cache, $is_dir, $use_all_available);

+ * @param bool $use_all_available Use all available instead of just all

+ * enabled extensions

+ public function find($cache = true, $is_dir = false, $use_all_available = false)

+ if ($use_all_available)

+ {

+ $extensions = $this->extension_manager->all_available();

+ }

+ else

+ {

+ $extensions = $this->extension_manager->all_enabled();

+ }

+ if ($this->query['core_path'])

+ $extensions['/'] = $this->phpbb_root_path . $this->query['core_path'];

+ $file_list = $this->find_from_paths($extensions, $cache, $is_dir);

+ foreach ($file_list as $file)

+ {

+ $files[$file['named_path']] = $file['ext_name'];

+ }

+ return $files;

+ }

+

+ /**

+ * Finds all file system entries matching the configured options from

+ * an array of paths

+ *

+ * @param array $extensions Array of extensions (name => full relative path)

+ * @param bool $cache Whether the result should be cached

+ * @param bool $is_dir Directories will be returned when true, only files

+ * otherwise

+ * @return array An array of paths to found items

+ */

+ public function find_from_paths($extensions, $cache = true, $is_dir = false)

+ {

+ $this->query['is_dir'] = $is_dir;

+ $query = md5(serialize($this->query) . serialize($extensions));

+

+ if (!defined('DEBUG') && $cache && isset($this->cached_queries[$query]))

+ return $this->cached_queries[$query];

+ $files = array();

+

+ $files[] = array(

+ 'named_path' => str_replace(DIRECTORY_SEPARATOR, '/', $location . $name . substr($relative_path, 1)),

+ 'ext_name' => $ext_name,

+ 'path' => str_replace(array(DIRECTORY_SEPARATOR, $this->phpbb_root_path), array('/', ''), $file_info->getPath()) . '/',

+ 'filename' => $filename,

+ );

+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, $extension_table, $phpbb_root_path, $php_ext = '.php', phpbb_cache_driver_interface $cache = null, $cache_name = '_ext')

+ $this->container = $container;

+ * Set migrator (get around circular reference)

+ */

+ public function set_migrator(phpbb_db_migrator $migrator)

+ {

+ $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;

+ }

+* Sets a configuration option's value.

+*

+* Please note that this function does not update the is_dynamic value for

+* an already existing config option.

+*

+* @param string $config_name The configuration option's name

+* @param string $config_value New configuration value

+* @param bool $is_dynamic Whether this variable should be cached (false) or

+* if it changes too frequently (true) to be

+* efficiently cached.

+*

+* @return null

+* Increments an integer config value directly in the database.

+*

+* @param string $config_name The configuration option's name

+* @param int $increment Amount to increment by

+* @param bool $is_dynamic Whether this variable should be cached (false) or

+* if it changes too frequently (true) to be

+* efficiently cached.

+*

+* @return null

+ global $request, $phpbb_container;

+ // Mark all forums read (index page)

+

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ // Mark all topic notifications read for this user

+ $phpbb_notifications->mark_notifications_read(array(

+ 'topic',

+ 'quote',

+ 'bookmark',

+ 'post',

+ 'approve_topic',

+ 'approve_post',

+ ), false, $user->data['user_id'], $post_time);

+

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->mark_notifications_read_by_parent(array(

+ 'topic',

+ 'approve_topic',

+ ), $forum_id, $user->data['user_id'], $post_time);

+

+ // Mark all post/quote notifications read for this user in this forum

+ $topic_ids = array();

+ $sql = 'SELECT topic_id

+ FROM ' . TOPICS_TABLE . '

+ WHERE ' . $db->sql_in_set('forum_id', $forum_id);

+ $result = $db->sql_query($sql);

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

+ {

+ $topic_ids[] = $row['topic_id'];

+ }

+ $db->sql_freeresult($result);

+

+ $phpbb_notifications->mark_notifications_read_by_parent(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ 'approve_post',

+ ), $topic_ids, $user->data['user_id'], $post_time);

+

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ // Mark post notifications read for this user in this topic

+ $phpbb_notifications->mark_notifications_read(array(

+ 'topic',

+ 'approve_topic',

+ ), $topic_id, $user->data['user_id'], $post_time);

+

+ $phpbb_notifications->mark_notifications_read_by_parent(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ 'approve_post',

+ ), $topic_id, $user->data['user_id'], $post_time);

+

+ global $phpbb_dispatcher, $request, $phpbb_container;

+ // Output the notifications

+ $notifications = false;

+ if ($config['load_notifications'] && $user->data['user_id'] != ANONYMOUS && $user->data['user_type'] != USER_IGNORE)

+ {

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $notifications = $phpbb_notifications->load_notifications(array(

+ 'all_unread' => true,

+ 'limit' => 5,

+ ));

+

+ foreach ($notifications['notifications'] as $notification)

+ {

+ $template->assign_block_vars('notifications', $notification->prepare_for_display());

+ }

+ }

+

+

+ 'UNREAD_NOTIFICATIONS_COUNT' => ($notifications !== false) ? $notifications['unread_count'] : '',

+ 'NOTIFICATIONS_COUNT' => ($notifications !== false) ? $user->lang('NOTIFICATIONS_COUNT', $notifications['unread_count']) : '',

+ 'U_VIEW_ALL_NOTIFICATIONS' => append_sid("{$phpbb_root_path}ucp.$phpEx", 'i=ucp_notifications'),

+ 'U_NOTIFICATION_SETTINGS' => append_sid("{$phpbb_root_path}ucp.$phpEx", 'i=ucp_notifications&amp;mode=notification_options'),

+ 'S_NOTIFICATIONS_DISPLAY' => $config['load_notifications'],

+

+

+ case 'email':

+ if (!preg_match('/^' . get_preg_expression('email') . '$/i', $cfg_array[$config_name]))

+ {

+ $error[] = $user->lang['EMAIL_INVALID_EMAIL'];

+ }

+ break;

+

+ global $db, $config, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->delete_notifications(array(

+ 'topic',

+ 'approve_topic',

+ 'topic_in_queue',

+ ), $topic_ids);

+

+ global $db, $config, $phpbb_root_path, $phpEx, $auth, $user, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->delete_notifications(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ 'approve_post',

+ 'post_in_queue',

+ ), $post_ids);

+

+ * Generates a valid message id to be used in emails

+ *

+ * @return string message id

+ */

+ function generate_message_id()

+ {

+ global $config;

+

+ $domain = 'phpbb.generated';

+ if ($config['server_name'])

+ {

+ $domain = $config['server_name'];

+ }

+ else if (!empty($_SERVER['SERVER_NAME']))

+ {

+ $domain = $_SERVER['SERVER_NAME'];

+ }

+

+ return md5(unique_id(time())) . '@' . $domain;

+ }

+

+ /**

+ $headers[] = 'Message-ID: <' . $this->generate_message_id() . '>';

+ generate_pagination(append_sid("{$phpbb_root_path}posting.$phpEx", 'mode=smilies&amp;f=' . $forum_id), $smiley_count, $config['smilies_per_page'], $start);

+ global $db, $auth, $user, $config, $phpEx, $template, $phpbb_root_path, $phpbb_container;

+ $notification_data = array_merge($data, array(

+ 'topic_title' => (isset($data['topic_title'])) ? $data['topic_title'] : $subject,

+ 'post_username' => $username,

+ 'poster_id' => $poster_id,

+ 'post_text' => $data['message'],

+ 'post_time' => $current_time,

+ 'post_subject' => $subject,

+ ));

+

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ if ($post_approval)

+ switch ($mode)

+ {

+ case 'post':

+ $phpbb_notifications->add_notifications(array(

+ 'quote',

+ 'topic',

+ ), $notification_data);

+ break;

+

+ case 'reply':

+ case 'quote':

+ $phpbb_notifications->add_notifications(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ ), $notification_data);

+ break;

+

+ case 'edit_topic':

+ case 'edit_first_post':

+ case 'edit':

+ case 'edit_last_post':

+ $phpbb_notifications->update_notifications(array(

+ 'quote',

+ 'bookmark',

+ 'topic',

+ 'post',

+ ), $notification_data);

+ break;

+ }

+ }

+ else

+ {

+ switch ($mode)

+ {

+ case 'post':

+ $phpbb_notifications->add_notifications('topic_in_queue', $notification_data);

+ break;

+

+ case 'reply':

+ case 'quote':

+ $phpbb_notifications->add_notifications('post_in_queue', $notification_data);

+ break;

+

+ case 'edit_topic':

+ case 'edit_first_post':

+ case 'edit':

+ case 'edit_last_post':

+ $phpbb_notifications->delete_notifications('topic', $data['topic_id']);

+

+ $phpbb_notifications->delete_notifications(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ ), $data['post_id']);

+ break;

+ }

+ global $db, $user, $phpbb_container;

+

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->mark_notifications_read('pm', $msg_id, $user_id);

+ global $db, $user, $phpbb_root_path, $phpEx, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->delete_notifications('pm', array_keys($delete_rows));

+

+ global $db, $user, $phpbb_root_path, $phpEx, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+

+ $phpbb_notifications->delete_notifications('pm', $delivered_msg);

+

+ $phpbb_notifications->delete_notifications('pm', $undelivered_msg);

+

+ $phpbb_notifications->delete_notifications('pm', $delete_ids);

+ global $db, $auth, $config, $phpEx, $template, $user, $phpbb_root_path, $phpbb_container;

+ $pm_data = array_merge($data, array(

+ 'message_subject' => $subject,

+ 'recipients' => $recipients,

+ ));

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+ if ($mode == 'edit')

+ $phpbb_notifications->update_notifications('pm', $pm_data);

+ else

+ $phpbb_notifications->add_notifications('pm', $pm_data);

+ return $data['msg_id'];

+ global $config, $phpbb_root_path, $phpEx, $action, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->mark_notifications_read_by_parent('report_pm', $report_id, $user->data['user_id']);

+

+ global $config, $phpbb_root_path, $phpEx, $action, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+

+ $phpbb_notifications->mark_notifications_read('topic_in_queue', $topic_id, $user->data['user_id']);

+ $phpbb_notifications->mark_notifications_read('post_in_queue', $post_id, $user->data['user_id']);

+

+ global $request, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ // Handle notifications

+ $phpbb_notifications->delete_notifications('topic_in_queue', $post_data['topic_id']);

+

+ $phpbb_notifications->add_notifications(array(

+ 'quote',

+ 'topic',

+ ), $post_data);

+

+ $phpbb_notifications->mark_notifications_read('quote', $post_data['post_id'], $user->data['user_id']);

+ $phpbb_notifications->mark_notifications_read('topic', $post_data['topic_id'], $user->data['user_id']);

+

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('approve_topic', $post_data);

+ }

+ $phpbb_notifications->delete_notifications('post_in_queue', $post_id);

+

+ $phpbb_notifications->add_notifications(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ ), $post_data);

+

+ $phpbb_notifications->mark_notifications_read(array(

+ 'quote',

+ 'bookmark',

+ 'post',

+ ),$post_data['post_id'], $user->data['user_id']);

+

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('approve_post', $post_data);

+ }

+ global $request, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ foreach ($post_info as $post_id => $post_data)

+ {

+ if ($post_id == $post_data['topic_first_post_id'] && $post_id == $post_data['topic_last_post_id'])

+ {

+ $phpbb_notifications->delete_notifications('topic_in_queue', $post_data['topic_id']);

+ }

+ else

+ {

+ $phpbb_notifications->delete_notifications('post_in_queue', $post_id);

+ }

+ }

+ // Handle notifications

+ $post_data['disapprove_reason'] = '';

+ $post_data['disapprove_reason'] = $lang_reasons[$post_data['user_lang']];

+ $post_data['disapprove_reason'] .= ($reason) ? "\n\n" . $reason : '';

+ if ($post_id == $post_data['topic_first_post_id'] && $post_id == $post_data['topic_last_post_id'])

+ {

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('disapprove_topic', $post_data);

+ }

+ }

+ else

+ {

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('disapprove_post', $post_data);

+ }

+ }

+ global $config, $phpbb_root_path, $phpEx, $action, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->mark_notifications_read('report_post', $post_id, $user->data['user_id']);

+

+ global $phpEx, $phpbb_root_path, $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notification_manager');

+

+ $phpbb_notifications->add_notifications('report_pm_closed', array_merge($post_info[$post_id], array(

+ 'reporter' => $reporter['user_id'],

+ 'closer_id' => $user->data['user_id'],

+ 'from_user_id' => $post_info[$post_id]['author_id'],

+ )));

+

+ $phpbb_notifications->delete_notifications('report_pm', $post_id);

+ $phpbb_notifications->add_notifications('report_post_closed', array_merge($post_info[$post_id], array(

+ 'reporter' => $reporter['user_id'],

+ 'closer_id' => $user->data['user_id'],

+ )));

+ $phpbb_notifications->delete_notifications('report_post', $post_id);

+ }

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

+* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2

+*

+*/

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Notifications service class

+* @package notifications

+*/

+class phpbb_notification_manager

+{

+ /** @var array */

+ protected $notification_types;

+

+ /** @var array */

+ protected $notification_methods;

+

+ /** @var ContainerBuilder */

+ protected $phpbb_container;

+

+ /** @var phpbb_user_loader */

+ protected $user_loader;

+

+ /** @var phpbb_db_driver */

+ protected $db;

+

+ /** @var phpbb_user */

+ protected $user;

+

+ /** @var string */

+ protected $phpbb_root_path;

+

+ /** @var string */

+ protected $php_ext;

+

+ /** @var string */

+ protected $notification_types_table;

+

+ /** @var string */

+ protected $notifications_table;

+

+ /** @var string */

+ protected $user_notifications_table;

+

+ /**

+ * Notification Constructor

+ *

+ * @param array $notification_types

+ * @param array $notification_methods

+ * @param ContainerBuilder $phpbb_container

+ * @param phpbb_user_loader $user_loader

+ * @param phpbb_db_driver $db

+ * @param phpbb_user $user

+ * @param string $phpbb_root_path

+ * @param string $php_ext

+ * @param string $notification_types_table

+ * @param string $notifications_table

+ * @param string $user_notifications_table

+ * @return phpbb_notification_manager

+ */

+ public function __construct($notification_types, $notification_methods, $phpbb_container, phpbb_user_loader $user_loader, phpbb_db_driver $db, $user, $phpbb_root_path, $php_ext, $notification_types_table, $notifications_table, $user_notifications_table)

+ {

+ $this->notification_types = $notification_types;

+ $this->notification_methods = $notification_methods;

+ $this->phpbb_container = $phpbb_container;

+

+ $this->user_loader = $user_loader;

+ $this->db = $db;

+ $this->user = $user;

+

+ $this->phpbb_root_path = $phpbb_root_path;

+ $this->php_ext = $php_ext;

+

+ $this->notification_types_table = $notification_types_table;

+ $this->notifications_table = $notifications_table;

+ $this->user_notifications_table = $user_notifications_table;

+ }

+

+ /**

+ * Load the user's notifications

+ *

+ * @param array $options Optional options to control what notifications are loaded

+ * notification_id Notification id to load (or array of notification ids)

+ * user_id User id to load notifications for (Default: $user->data['user_id'])

+ * order_by Order by (Default: notification_time)

+ * order_dir Order direction (Default: DESC)

+ * limit Number of notifications to load (Default: 5)

+ * start Notifications offset (Default: 0)

+ * all_unread Load all unread notifications? If set to true, count_unread is set to true (Default: false)

+ * count_unread Count all unread notifications? (Default: false)

+ * count_total Count all notifications? (Default: false)

+ * @return array Array of information based on the request with keys:

+ * 'notifications' array of notification type objects

+ * 'unread_count' number of unread notifications the user has if count_unread is true in the options

+ * 'total_count' number of notifications the user has if count_total is true in the options

+ */

+ public function load_notifications(array $options = array())

+ {

+ // Merge default options

+ $options = array_merge(array(

+ 'notification_id' => false,

+ 'user_id' => $this->user->data['user_id'],

+ 'order_by' => 'notification_time',

+ 'order_dir' => 'DESC',

+ 'limit' => 0,

+ 'start' => 0,

+ 'all_unread' => false,

+ 'count_unread' => false,

+ 'count_total' => false,

+ ), $options);

+

+ // If all_unread, count_unread must be true

+ $options['count_unread'] = ($options['all_unread']) ? true : $options['count_unread'];

+

+ // Anonymous users and bots never receive notifications

+ if ($options['user_id'] == $this->user->data['user_id'] && ($this->user->data['user_id'] == ANONYMOUS || $this->user->data['user_type'] == USER_IGNORE))

+ {

+ return array(

+ 'notifications' => array(),

+ 'unread_count' => 0,

+ 'total_count' => 0,

+ );

+ }

+

+ $notifications = $user_ids = array();

+ $load_special = array();

+ $total_count = $unread_count = 0;

+

+ if ($options['count_unread'])

+ {

+ // Get the total number of unread notifications

+ $sql = 'SELECT COUNT(n.notification_id) AS unread_count

+ FROM ' . $this->notifications_table . ' n, ' . $this->notification_types_table . ' nt

+ WHERE n.user_id = ' . (int) $options['user_id'] . '

+ AND n.notification_read = 0

+ AND nt.notification_type = n.item_type

+ AND nt.notification_type_enabled = 1';

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

+ $unread_count = (int) $this->db->sql_fetchfield('unread_count', $result);

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

+ }

+

+ if ($options['count_total'])

+ {

+ // Get the total number of notifications

+ $sql = 'SELECT COUNT(n.notification_id) AS total_count

+ FROM ' . $this->notifications_table . ' n, ' . $this->notification_types_table . ' nt

+ WHERE n.user_id = ' . (int) $options['user_id'] . '

+ AND nt.notification_type = n.item_type

+ AND nt.notification_type_enabled = 1';

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

+ $total_count = (int) $this->db->sql_fetchfield('total_count', $result);

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

+ }

+

+ if (!$options['count_total'] || $total_count)

+ {

+ $rowset = array();

+

+ // Get the main notifications

+ $sql = 'SELECT n.*

+ FROM ' . $this->notifications_table . ' n, ' . $this->notification_types_table . ' nt

+ WHERE n.user_id = ' . (int) $options['user_id'] .

+ (($options['notification_id']) ? ((is_array($options['notification_id'])) ? ' AND ' . $this->db->sql_in_set('n.notification_id', $options['notification_id']) : ' AND n.notification_id = ' . (int) $options['notification_id']) : '') . '

+ AND nt.notification_type = n.item_type

+ AND nt.notification_type_enabled = 1

+ ORDER BY n.' . $this->db->sql_escape($options['order_by']) . ' ' . $this->db->sql_escape($options['order_dir']);

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

+

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

+ {

+ $rowset[$row['notification_id']] = $row;

+ }

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

+

+ // Get all unread notifications

+ if ($unread_count && $options['all_unread'] && !empty($rowset))

+ {

+ $sql = 'SELECT n.*

+ FROM ' . $this->notifications_table . ' n, ' . $this->notification_types_table . ' nt

+ WHERE n.user_id = ' . (int) $options['user_id'] . '

+ AND n.notification_read = 0

+ AND ' . $this->db->sql_in_set('n.notification_id', array_keys($rowset), true) . '

+ AND nt.notification_type = n.item_type

+ AND nt.notification_type_enabled = 1

+ ORDER BY n.' . $this->db->sql_escape($options['order_by']) . ' ' . $this->db->sql_escape($options['order_dir']);

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

+

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

+ {

+ $rowset[$row['notification_id']] = $row;

+ }

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

+ }

+

+ foreach ($rowset as $row)

+ {

+ $notification = $this->get_item_type_class($row['item_type'], $row);

+

+ // Array of user_ids to query all at once

+ $user_ids = array_merge($user_ids, $notification->users_to_query());

+

+ // Some notification types also require querying additional tables themselves

+ if (!isset($load_special[$row['item_type']]))

+ {

+ $load_special[$row['item_type']] = array();

+ }

+ $load_special[$row['item_type']] = array_merge($load_special[$row['item_type']], $notification->get_load_special());

+

+ $notifications[$row['notification_id']] = $notification;

+ }

+

+ $this->user_loader->load_users($user_ids);

+

+ // Allow each type to load its own special items

+ foreach ($load_special as $item_type => $data)

+ {

+ $item_class = $this->get_item_type_class($item_type);

+

+ $item_class->load_special($data, $notifications);

+ }

+ }

+

+ return array(

+ 'notifications' => $notifications,

+ 'unread_count' => $unread_count,

+ 'total_count' => $total_count,

+ );

+ }

+

+ /**

+ * Mark notifications read

+ *

+ * @param bool|string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types). False to mark read for all item types

+ * @param bool|int|array $item_id Item id or array of item ids. False to mark read for all item ids

+ * @param bool|int|array $user_id User id or array of user ids. False to mark read for all user ids

+ * @param bool|int $time Time at which to mark all notifications prior to as read. False to mark all as read. (Default: False)

+ */

+ public function mark_notifications_read($item_type, $item_id, $user_id, $time = false)

+ {

+ $time = ($time !== false) ? $time : time();

+

+ $sql = 'UPDATE ' . $this->notifications_table . "

+ SET notification_read = 1

+ WHERE notification_time <= " . (int) $time .

+ (($item_type !== false) ? ' AND ' . (is_array($item_type) ? $this->db->sql_in_set('item_type', $item_type) : " item_type = '" . $this->db->sql_escape($item_type) . "'") : '') .

+ (($item_id !== false) ? ' AND ' . (is_array($item_id) ? $this->db->sql_in_set('item_id', $item_id) : 'item_id = ' . (int) $item_id) : '');

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

+ }

+

+ /**

+ * Mark notifications read from a parent identifier

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param bool|int|array $item_parent_id Item parent id or array of item parent ids. False to mark read for all item parent ids

+ * @param bool|int|array $user_id User id or array of user ids. False to mark read for all user ids

+ * @param bool|int $time Time at which to mark all notifications prior to as read. False to mark all as read. (Default: False)

+ */

+ public function mark_notifications_read_by_parent($item_type, $item_parent_id, $user_id, $time = false)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->mark_notifications_read_by_parent($type, $item_parent_id, $user_id, $time);

+ }

+

+ return;

+ }

+

+ $time = ($time !== false) ? $time : time();

+

+ $sql = 'UPDATE ' . $this->notifications_table . "

+ SET notification_read = 1

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND notification_time <= " . (int) $time .

+ (($item_parent_id !== false) ? ' AND ' . (is_array($item_parent_id) ? $this->db->sql_in_set('item_parent_id', $item_parent_id) : 'item_parent_id = ' . (int) $item_parent_id) : '') .

+ (($user_id !== false) ? ' AND ' . (is_array($user_id) ? $this->db->sql_in_set('user_id', $user_id) : 'user_id = ' . (int) $user_id) : '');

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

+ }

+

+ /**

+ * Mark notifications read

+ *

+ * @param int|array $notification_id Notification id or array of notification ids.

+ * @param bool|int $time Time at which to mark all notifications prior to as read. False to mark all as read. (Default: False)

+ */

+ public function mark_notifications_read_by_id($notification_id, $time = false)

+ {

+ $time = ($time !== false) ? $time : time();

+

+ $sql = 'UPDATE ' . $this->notifications_table . "

+ SET notification_read = 1

+ WHERE notification_time <= " . (int) $time . '

+ AND ' . ((is_array($notification_id)) ? $this->db->sql_in_set('notification_id', $notification_id) : 'notification_id = ' . (int) $notification_id);

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

+ }

+

+ /**

+ * Add a notification

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * Note: If you send an array of types, any user who could receive multiple notifications from this single item will only receive

+ * a single notification. If they MUST receive multiple notifications, call this function multiple times instead of sending an array

+ * @param array $data Data specific for this type that will be inserted

+ * @param array $options Optional options to control what notifications are loaded

+ * ignore_users array of data to specify which users should not receive certain types of notifications

+ * @return array Information about what users were notified and how they were notified

+ */

+ public function add_notifications($item_type, $data, array $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ if (is_array($item_type))

+ {

+ $notified_users = array();

+ $temp_options = $options;

+

+ foreach ($item_type as $type)

+ {

+ $temp_options['ignore_users'] = $options['ignore_users'] + $notified_users;

+ $notified_users += $this->add_notifications($type, $data, $temp_options);

+ }

+

+ return $notified_users;

+ }

+

+ $item_id = $this->get_item_type_class($item_type)->get_item_id($data);

+

+ // find out which users want to receive this type of notification

+ $notify_users = $this->get_item_type_class($item_type)->find_users_for_notification($data, $options);

+

+ $this->add_notifications_for_users($item_type, $data, $notify_users);

+

+ return $notify_users;

+ }

+

+ /**

+ * Add a notification for specific users

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param array $data Data specific for this type that will be inserted

+ * @param array $notify_users User list to notify

+ */

+ public function add_notifications_for_users($item_type, $data, $notify_users)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->add_notifications_for_users($type, $data, $notify_users);

+ }

+

+ return;

+ }

+

+ $sql = 'SELECT notification_type

+ FROM ' . $this->notification_types_table . "

+ WHERE notification_type = '" . $this->db->sql_escape($item_type) . "'";

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

+

+ if ($this->db->sql_fetchrow($result) === false)

+ {

+ // Does not exist in the database, must add the item type

+ $sql = 'INSERT INTO ' . $this->notification_types_table . ' ' . $this->db->sql_build_array('INSERT', array(

+ 'notification_type' => $item_type,

+ 'notification_type_enabled' => 1,

+ ));

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

+ }

+

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

+

+ $item_id = $this->get_item_type_class($item_type)->get_item_id($data);

+

+ $user_ids = array();

+ $notification_objects = $notification_methods = array();

+ $new_rows = array();

+

+ // Never send notifications to the anonymous user!

+ unset($notify_users[ANONYMOUS]);

+

+ // Make sure not to send new notifications to users who've already been notified about this item

+ // This may happen when an item was added, but now new users are able to see the item

+ $sql = 'SELECT n.user_id

+ FROM ' . $this->notifications_table . ' n, ' . $this->notification_types_table . " nt

+ WHERE n.item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND n.item_id = " . (int) $item_id . '

+ AND nt.notification_type = n.item_type

+ AND nt.notification_type_enabled = 1';

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

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

+ {

+ unset($notify_users[$row['user_id']]);

+ }

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

+

+ if (!sizeof($notify_users))

+ {

+ return;

+ }

+

+ // Allow notifications to perform actions before creating the insert array (such as run a query to cache some data needed for all notifications)

+ $notification = $this->get_item_type_class($item_type);

+ $pre_create_data = $notification->pre_create_insert_array($data, $notify_users);

+ unset($notification);

+

+ // Go through each user so we can insert a row in the DB and then notify them by their desired means

+ foreach ($notify_users as $user => $methods)

+ {

+ $notification = $this->get_item_type_class($item_type);

+

+ $notification->user_id = (int) $user;

+

+ // Store the creation array in our new rows that will be inserted later

+ $new_rows[] = $notification->create_insert_array($data, $pre_create_data);

+

+ // Users are needed to send notifications

+ $user_ids = array_merge($user_ids, $notification->users_to_query());

+

+ foreach ($methods as $method)

+ {

+ // setup the notification methods and add the notification to the queue

+ if ($method) // blank means we just insert it as a notification, but do not notify them by any other means

+ {

+ if (!isset($notification_methods[$method]))

+ {

+ $notification_methods[$method] = $this->get_method_class($method);

+ }

+

+ $notification_methods[$method]->add_to_queue($notification);

+ }

+ }

+ }

+

+ // insert into the db

+ $this->db->sql_multi_insert($this->notifications_table, $new_rows);

+

+ // We need to load all of the users to send notifications

+ $this->user_loader->load_users($user_ids);

+

+ // run the queue for each method to send notifications

+ foreach ($notification_methods as $method)

+ {

+ $method->notify();

+ }

+ }

+

+ /**

+ * Update a notification

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param array $data Data specific for this type that will be updated

+ */

+ public function update_notifications($item_type, $data)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->update_notifications($type, $data);

+ }

+

+ return;

+ }

+

+ $notification = $this->get_item_type_class($item_type);

+

+ // Allow the notifications class to over-ride the update_notifications functionality

+ if (method_exists($notification, 'update_notifications'))

+ {

+ // Return False to over-ride the rest of the update

+ if ($notification->update_notifications($data) === false)

+ {

+ return;

+ }

+ }

+

+ $item_id = $notification->get_item_id($data);

+ $update_array = $notification->create_update_array($data);

+

+ $sql = 'UPDATE ' . $this->notifications_table . '

+ SET ' . $this->db->sql_build_array('UPDATE', $update_array) . "

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND item_id = " . (int) $item_id;

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

+ }

+

+ /**

+ * Delete a notification

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $item_id is identical for the specified types)

+ * @param int|array $item_id Identifier within the type (or array of ids)

+ * @param array $data Data specific for this type that will be updated

+ */

+ public function delete_notifications($item_type, $item_id)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->delete_notifications($type, $item_id);

+ }

+

+ return;

+ }

+

+ $sql = 'DELETE FROM ' . $this->notifications_table . "

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND " . (is_array($item_id) ? $this->db->sql_in_set('item_id', $item_id) : 'item_id = ' . (int) $item_id);

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

+ }

+

+ /**

+ * Get all of the subscription types

+ *

+ * @return array Array of item types

+ */

+ public function get_subscription_types()

+ {

+ $subscription_types = array();

+

+ foreach ($this->notification_types as $type_name => $data)

+ {

+ $type = $this->get_item_type_class($type_name);

+

+ if ($type instanceof phpbb_notification_type_interface && $type->is_available())

+ {

+ $options = array_merge(array(

+ 'id' => $type->get_type(),

+ 'lang' => 'NOTIFICATION_TYPE_' . strtoupper($type->get_type()),

+ 'group' => 'NOTIFICATION_GROUP_MISCELLANEOUS',

+ ), (($type::$notification_option !== false) ? $type::$notification_option : array()));

+

+ $subscription_types[$options['group']][$options['id']] = $options;

+ }

+ }

+

+ // Move Miscellaneous to the very last section

+ if (isset($subscription_types['NOTIFICATION_GROUP_MISCELLANEOUS']))

+ {

+ $miscellaneous = $subscription_types['NOTIFICATION_GROUP_MISCELLANEOUS'];

+ unset($subscription_types['NOTIFICATION_GROUP_MISCELLANEOUS']);

+ $subscription_types['NOTIFICATION_GROUP_MISCELLANEOUS'] = $miscellaneous;

+ }

+

+ return $subscription_types;

+ }

+

+ /**

+ * Get all of the subscription methods

+ *

+ * @return array Array of methods

+ */

+ public function get_subscription_methods()

+ {

+ $subscription_methods = array();

+

+ foreach ($this->notification_methods as $method_name => $data)

+ {

+ $method = $this->get_method_class($method_name);

+

+ if ($method instanceof phpbb_notification_method_interface && $method->is_available())

+ {

+ $subscription_methods[$method_name] = array(

+ 'id' => $method->get_type(),

+ 'lang' => 'NOTIFICATION_METHOD_' . strtoupper($method->get_type()),

+ );

+ }

+ }

+

+ return $subscription_methods;

+ }

+

+ /**

+ * Get global subscriptions (item_id = 0)

+ *

+ * @param bool|int $user_id The user_id to add the subscription for (bool false for current user)

+ *

+ * @return array Subscriptions

+ */

+ public function get_global_subscriptions($user_id = false)

+ {

+ $user_id = ($user_id === false) ? $this->user->data['user_id'] : $user_id;

+

+ $subscriptions = array();

+

+ foreach ($this->get_subscription_types() as $group_name => $types)

+ {

+ foreach ($types as $id => $type)

+ {

+ $sql = 'SELECT method, notify

+ FROM ' . $this->user_notifications_table . '

+ WHERE user_id = ' . (int) $user_id . "

+ AND item_type = '" . $this->db->sql_escape($id) . "'