$schema_data['phpbb_notifications'] = array(

'COLUMNS' => array(

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

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

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

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

'unread' => array('BOOL', 1),

'time' => array('TIMESTAMP', 1),

'data' => array('TEXT_UNI', ''),

),

$schema_data['phpbb_user_notifications'] = array(

'COLUMNS' => array(

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

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

),

'PRIMARY_KEY' => array(

'item_type',

// Mark all forums read (index page)

// Mark all topic notifications read for this user

if ($config['load_db_lastread'] && $user->data['is_registered'])

{

$forum_id = array($forum_id);

}

// Mark all post/quote notifications read for this user in this forum

$topic_ids = array();

}

$db->sql_freeresult($result);

// Add 0 to forums array to mark global announcements correctly

// $forum_id[] = 0;

}

// Mark post notifications read for this user in this topic

if ($config['load_db_lastread'] && $user->data['is_registered'])

{

set_config_count('num_topics', $approved_topics * (-1), true);

}

return $return;

}

delete_topics('topic_id', $remove_topics, $auto_sync, $post_count_sync, false);

}

return sizeof($post_ids);

}

switch ($mode)

{

case 'post':

break;

case 'reply':

case 'quote':

break;

case 'edit_topic':

case 'edit_first_post':

case 'edit':

case 'edit_last_post':

break;

}

}

switch ($mode)

{

case 'post':

break;

case 'reply':

case 'quote':

break;

case 'edit_topic':

case 'edit_first_post':

case 'edit':

case 'edit_last_post':

break;

}

}

global $db, $user, $phpbb_notifications;

$sql = 'UPDATE ' . PRIVMSGS_TO_TABLE . "

SET pm_unread = 0

$user->data['user_unread_privmsg'] -= $num_unread;

}

// Now we have to check which messages we can delete completely

$sql = 'SELECT msg_id

AND ' . $db->sql_in_set('msg_id', $delivered_msg);

$db->sql_query($sql);

}

if (!empty($undelivered_msg))

WHERE ' . $db->sql_in_set('msg_id', $undelivered_msg);

$db->sql_query($sql);

}

}

WHERE ' . $db->sql_in_set('msg_id', $delete_ids);

$db->sql_query($sql);

}

}

if ($mode == 'edit')

{

}

else

{

}

return $data['msg_id'];

trigger_error('NO_REPORT');

}

$pm_id = $report['pm_id'];

$report_id = $report['report_id'];

{

$post_id = (int) $topic_info[$topic_id]['topic_first_post_id'];

}

else

{

}

}

$post_info = get_post_data(array($post_id), 'm_approve', true);

{

if ($post_id == $post_data['topic_first_post_id'] && $post_id == $post_data['topic_last_post_id'])

{

if ($notify_poster)

{

}

}

else

{

if ($notify_poster)

{

}

}

}

{

if ($post_id == $post_data['topic_first_post_id'] && $post_id == $post_data['topic_last_post_id'])

{

}

else

{

}

}

{

if ($notify_poster)

{

}

}

else

{

if ($notify_poster)

{

}

}

}

trigger_error('NO_REPORT');

}

if (!$report_id && $report['report_closed'])

{

if ($pm)

{

'reporter' => $reporter['user_id'],

'closer_id' => $user->data['user_id'],

'from_user_id' => $post_info[$post_id]['author_id'],

)));

}

else

{

'reporter' => $reporter['user_id'],

'closer_id' => $user->data['user_id'],

)));

}

}

}

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

}

{

$sql = 'SELECT *

FROM ' . NOTIFICATIONS_TABLE . '

ORDER BY ' . $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']);

$rowset[$row['notification_id']] = $row;

}

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

{

}

}

return array(

$time = ($time) ?: time();

$sql = 'UPDATE ' . NOTIFICATIONS_TABLE . "

SET unread = 0

WHERE time <= " . $time .

$time = ($time) ?: time();

$sql = 'UPDATE ' . NOTIFICATIONS_TABLE . "

SET unread = 0

WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

return $notified_users;

}

// find out which users want to receive this type of notification

$this->add_notifications_for_users($item_type, $data, $notify_users);

return;

}

$user_ids = array();

$notification_objects = $notification_methods = array();

}

// Allow notifications to perform actions before creating the insert array (such as run a query to cache some data needed for all notifications)

$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->user_id = (int) $user;

{

if (!isset($notification_methods[$method]))

{

}

$notification_methods[$method]->add_to_queue($notification);

return;

}

// Allow the notifications class to over-ride the update_notifications functionality

{

// Return False to over-ride the rest of the update

{

return;

}

}

$update_array = $notification->create_update_array($data);

$sql = 'UPDATE ' . NOTIFICATIONS_TABLE . '

return;

}

$sql = 'DELETE FROM ' . 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);

{

$subscription_types = array();

{

$class = $this->get_item_type_class($class_name);

{

$options = array_merge(array(

'group' => 'NOTIFICATION_GROUP_MISCELLANEOUS',

), (($class_name::$notification_option !== false) ? $class_name::$notification_option : array()));

{

$subscription_methods = array();

{

$method = $this->get_method_class($class_name);

if ($method instanceof phpbb_notification_method_interface && $method->is_available())

{

}

}

*/

public function add_subscription($item_type, $item_id = 0, $method = '', $user_id = false)

{

$user_id = ($user_id === false) ? $this->user->data['user_id'] : $user_id;

$sql = 'INSERT INTO ' . USER_NOTIFICATIONS_TABLE . ' ' .

*/

public function delete_subscription($item_type, $item_id = 0, $method = '', $user_id = false)

{

$user_id = ($user_id === false) ? $this->user->data['user_id'] : $user_id;

$sql = 'DELETE FROM ' . USER_NOTIFICATIONS_TABLE . "

}

/**

* Helper to get the notifications item type class and set it up

*/

public function get_item_type_class($item_type, $data = array())

{

$item = new $item_type($this, $this->db, $this->cache, $this->template, $this->extension_manager, $this->user, $this->auth, $this->config, $this->phpbb_root_path, $this->php_ext);

$item->set_initial_data($data);

$subscription_files = array();

->core_path('includes/' . $path)

->extension_directory($path)

}

}

);

/**

* Is available

*/

public function is_available()

);

/**

* Is available

*/

public function is_available()

public function __toString()

{

}

/**

// Defaults

$this->data = array_merge(array(

'item_id' => static::get_item_id($type_data),

'item_parent_id' => static::get_item_parent_id($type_data),

'time' => time(),

$sql = 'SELECT *

FROM ' . USER_NOTIFICATIONS_TABLE . "

AND item_id = " . (int) $item_id;

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

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

protected $language_key = 'NOTIFICATION_BOOKMARK';

/**

*/

/**

* Find the users who want to receive notifications

$sql = 'SELECT *

FROM ' . USER_NOTIFICATIONS_TABLE . "

AND " . $this->db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

$update_notifications = array();

$sql = 'SELECT *

FROM ' . NOTIFICATIONS_TABLE . "

AND item_parent_id = " . (int) self::get_item_parent_id($post) . '

AND unread = 1

AND is_enabled = 1';

// Do not create a new notification

unset($notify_users[$row['user_id']]);

$sql = 'UPDATE ' . NOTIFICATIONS_TABLE . '

SET ' . $this->db->sql_build_array('UPDATE', $notification->add_responders($post)) . '

WHERE notification_id = ' . $row['notification_id'];

);

/**

* Get the HTML formatted title of this notification

*

* @return string

);

/**

* Get the HTML formatted title of this notification

*

* @return string

public function set_initial_data($data);

/**

* Get the id of the item

*

* @param array $type_data The type specific data

class phpbb_notification_type_pm extends phpbb_notification_type_base

{

/**

*/

/**

* Get the id of the

$sql = 'SELECT *

FROM ' . USER_NOTIFICATIONS_TABLE . "

AND " . $this->db->sql_in_set('user_id', array_keys($pm['recipients'])) . '

AND user_id <> ' . $pm['from_user_id'];

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

* Array of data (including keys 'id', 'lang', and 'group')

*/

public static $notification_option = array(

'group' => 'NOTIFICATION_GROUP_POSTING',

);

/**

* Get the id of the item

*

* @param array $post The data from the post

$sql = 'SELECT *

FROM ' . USER_NOTIFICATIONS_TABLE . "

AND " . $this->db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

$update_notifications = array();

$sql = 'SELECT *

FROM ' . NOTIFICATIONS_TABLE . "

AND item_parent_id = " . (int) self::get_item_parent_id($post) . '

AND unread = 1

AND is_enabled = 1';

// Do not create a new notification

unset($notify_users[$row['user_id']]);

$sql = 'UPDATE ' . NOTIFICATIONS_TABLE . '

SET ' . $this->db->sql_build_array('UPDATE', $notification->add_responders($post)) . '

WHERE notification_id = ' . $row['notification_id'];

protected $permission = 'm_approve';

/**

* Is available

*/

public function is_available()

protected $language_key = 'NOTIFICATION_QUOTE';

/**

*/

/**

* Find the users who want to receive notifications

$sql = 'SELECT *

FROM ' . USER_NOTIFICATIONS_TABLE . "

AND " . $this->db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

$update_notifications = array();

$sql = 'SELECT *

FROM ' . NOTIFICATIONS_TABLE . "

AND item_parent_id = " . (int) self::get_item_parent_id($post) . '

AND unread = 1

AND is_enabled = 1';

// Do not create a new notification

unset($notify_users[$row['user_id']]);

$sql = 'UPDATE ' . NOTIFICATIONS_TABLE . '

SET ' . $this->db->sql_build_array('UPDATE', $notification->add_responders($post)) . '

WHERE notification_id = ' . $row['notification_id'];

$old_notifications = array();

$sql = 'SELECT user_id

FROM ' . NOTIFICATIONS_TABLE . "

AND item_id = " . self::get_item_id($post) . '

AND is_enabled = 1';

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

}

// Add the necessary notifications

// Remove the necessary notifications

if (!empty($remove_notifications))

{

$sql = 'DELETE FROM ' . NOTIFICATIONS_TABLE . "

AND item_id = " . self::get_item_id($post) . '

AND ' . $this->db->sql_in_set('user_id', $remove_notifications);

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

);

/**

* Get the id of the parent

*

* @param array $pm The data from the pm

}

/**

* Find the users who want to receive notifications

*

* @param array $pm Data from

);

/**

* Find the users who want to receive notifications

*

* @param array $post Data from the post

}

/**

* Find the users who want to receive notifications

*

* @param array $post Data from

* Array of data (including keys 'id', 'lang', and 'group')

*/

public static $notification_option = array(

'group' => 'NOTIFICATION_GROUP_POSTING',

);

/**

* Get the id of the item

*

* @param array $post The data from the post

$sql = 'SELECT *

FROM ' . USER_NOTIFICATIONS_TABLE . "

AND " . $this->db->sql_in_set('user_id', $auth_read[$topic['forum_id']]['f_read']);

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

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

}

/**

* Find the users who want to receive notifications

*

* @param array $topic Data from the topic

$template->assign_block_vars($block . '.notification_methods', array(

'METHOD' => $method,

'SUBSCRIBED' => (isset($subscriptions[$type]) && in_array($method, $subscriptions[$type])) ? true : false,

));

$template->assign_block_vars($block, array(

'METHOD' => $method,

));

}

}

NOTIFICATIONS_TABLE => array(

'COLUMNS' => array(

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

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

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

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

'unread' => array('BOOL', 1),

'time' => array('TIMESTAMP', 1),

'data' => array('TEXT_UNI', ''),

),

),

USER_NOTIFICATIONS_TABLE => array(

'COLUMNS' => array(

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

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

),

'PRIMARY_KEY' => array(

'item_type',

# Table: 'phpbb_notifications'

CREATE TABLE phpbb_notifications (

notification_id INTEGER NOT NULL,

item_id INTEGER DEFAULT 0 NOT NULL,

item_parent_id INTEGER DEFAULT 0 NOT NULL,

user_id INTEGER DEFAULT 0 NOT NULL,

unread INTEGER DEFAULT 1 NOT NULL,

time INTEGER DEFAULT 1 NOT NULL,

data BLOB SUB_TYPE TEXT CHARACTER SET UTF8 DEFAULT '' NOT NULL

);;

CREATE INDEX phpbb_notifications_user_id ON phpbb_notifications(user_id);;

CREATE INDEX phpbb_notifications_time ON phpbb_notifications(time);;

CREATE INDEX phpbb_notifications_unread ON phpbb_notifications(unread);;

CREATE GENERATOR phpbb_notifications_gen;;

SET GENERATOR phpbb_notifications_gen TO 0;;

# Table: 'phpbb_user_notifications'

CREATE TABLE phpbb_user_notifications (

item_id INTEGER DEFAULT 0 NOT NULL,

user_id INTEGER DEFAULT 0 NOT NULL,

);;

ALTER TABLE phpbb_user_notifications ADD PRIMARY KEY (item_type, item_id, user_id, method);;

*/

CREATE TABLE [phpbb_notifications] (

[notification_id] [int] IDENTITY (1, 1) NOT NULL ,

[item_id] [int] DEFAULT (0) NOT NULL ,

[item_parent_id] [int] DEFAULT (0) NOT NULL ,

[user_id] [int] DEFAULT (0) NOT NULL ,

[unread] [int] DEFAULT (1) NOT NULL ,

[time] [int] DEFAULT (1) NOT NULL ,

[data] [varchar] (4000) DEFAULT ('') NOT NULL

) ON [PRIMARY]

CREATE INDEX [unread] ON [phpbb_notifications]([unread]) ON [PRIMARY]

GO

GO

Table: 'phpbb_user_notifications'

*/

CREATE TABLE [phpbb_user_notifications] (

[item_id] [int] DEFAULT (0) NOT NULL ,

[user_id] [int] DEFAULT (0) NOT NULL ,

) ON [PRIMARY]

GO

# Table: 'phpbb_notifications'

CREATE TABLE phpbb_notifications (

notification_id mediumint(8) UNSIGNED NOT NULL auto_increment,

item_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

item_parent_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

user_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

unread tinyint(1) UNSIGNED DEFAULT '1' NOT NULL,

time int(11) UNSIGNED DEFAULT '1' NOT NULL,

data blob NOT NULL,

PRIMARY KEY (notification_id),

KEY user_id (user_id),

KEY time (time),

KEY unread (unread),

);

# Table: 'phpbb_user_notifications'

CREATE TABLE phpbb_user_notifications (

item_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

user_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

PRIMARY KEY (item_type, item_id, user_id, method),

KEY it (item_type),

KEY uid (user_id)

# Table: 'phpbb_notifications'

CREATE TABLE phpbb_notifications (

notification_id mediumint(8) UNSIGNED NOT NULL auto_increment,

item_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

item_parent_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

user_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

unread tinyint(1) UNSIGNED DEFAULT '1' NOT NULL,

time int(11) UNSIGNED DEFAULT '1' NOT NULL,

data text NOT NULL,

PRIMARY KEY (notification_id),

KEY user_id (user_id),

KEY time (time),

KEY unread (unread),

) CHARACTER SET `utf8` COLLATE `utf8_bin`;

# Table: 'phpbb_user_notifications'

CREATE TABLE phpbb_user_notifications (

item_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

user_id mediumint(8) UNSIGNED DEFAULT '0' NOT NULL,

PRIMARY KEY (item_type, item_id, user_id, method),

KEY it (item_type),

KEY uid (user_id)

*/

CREATE TABLE phpbb_notifications (

notification_id number(8) NOT NULL,

item_id number(8) DEFAULT '0' NOT NULL,

item_parent_id number(8) DEFAULT '0' NOT NULL,

user_id number(8) DEFAULT '0' NOT NULL,

unread number(1) DEFAULT '1' NOT NULL,

time number(11) DEFAULT '1' NOT NULL,

data clob DEFAULT '' ,

CONSTRAINT pk_phpbb_notifications PRIMARY KEY (notification_id)

/

CREATE INDEX phpbb_notifications_unread ON phpbb_notifications (unread)

/

/

CREATE SEQUENCE phpbb_notifications_seq

Table: 'phpbb_user_notifications'

*/

CREATE TABLE phpbb_user_notifications (

item_id number(8) DEFAULT '0' NOT NULL,

user_id number(8) DEFAULT '0' NOT NULL,

CONSTRAINT pk_phpbb_user_notifications PRIMARY KEY (item_type, item_id, user_id, method)

)

/

CREATE TABLE phpbb_notifications (

notification_id INT4 DEFAULT nextval('phpbb_notifications_seq'),

item_id INT4 DEFAULT '0' NOT NULL CHECK (item_id >= 0),

item_parent_id INT4 DEFAULT '0' NOT NULL CHECK (item_parent_id >= 0),

user_id INT4 DEFAULT '0' NOT NULL CHECK (user_id >= 0),

unread INT2 DEFAULT '1' NOT NULL CHECK (unread >= 0),

time INT4 DEFAULT '1' NOT NULL CHECK (time >= 0),

data varchar(4000) DEFAULT '' NOT NULL,

PRIMARY KEY (notification_id)

CREATE INDEX phpbb_notifications_user_id ON phpbb_notifications (user_id);

CREATE INDEX phpbb_notifications_time ON phpbb_notifications (time);

CREATE INDEX phpbb_notifications_unread ON phpbb_notifications (unread);

/*

Table: 'phpbb_poll_options'

Table: 'phpbb_user_notifications'

*/

CREATE TABLE phpbb_user_notifications (

item_id INT4 DEFAULT '0' NOT NULL CHECK (item_id >= 0),

user_id INT4 DEFAULT '0' NOT NULL CHECK (user_id >= 0),

PRIMARY KEY (item_type, item_id, user_id, method)

);

# Table: 'phpbb_notifications'

CREATE TABLE phpbb_notifications (

notification_id INTEGER PRIMARY KEY NOT NULL ,

item_id INTEGER UNSIGNED NOT NULL DEFAULT '0',

item_parent_id INTEGER UNSIGNED NOT NULL DEFAULT '0',

user_id INTEGER UNSIGNED NOT NULL DEFAULT '0',

unread INTEGER UNSIGNED NOT NULL DEFAULT '1',

time INTEGER UNSIGNED NOT NULL DEFAULT '1',

data text(65535) NOT NULL DEFAULT ''

);

CREATE INDEX phpbb_notifications_user_id ON phpbb_notifications (user_id);

CREATE INDEX phpbb_notifications_time ON phpbb_notifications (time);

CREATE INDEX phpbb_notifications_unread ON phpbb_notifications (unread);

# Table: 'phpbb_poll_options'

CREATE TABLE phpbb_poll_options (

# Table: 'phpbb_user_notifications'

CREATE TABLE phpbb_user_notifications (

item_id INTEGER UNSIGNED NOT NULL DEFAULT '0',

user_id INTEGER UNSIGNED NOT NULL DEFAULT '0',

PRIMARY KEY (item_type, item_id, user_id, method)

);

'NOTIFICATION_GROUP_MISCELLANEOUS' => 'Miscellaneous Notifications',

'NOTIFICATION_GROUP_MODERATION' => 'Moderation Notifications',

'NOTIFICATION_GROUP_POSTING' => 'Posting Notifications',

'NOTIFICATION_TYPE' => 'Notification type',

'NOTIFICATION_TYPE_BOOKMARK' => 'Someone replies to a topic you have bookmarked',

'NOTIFICATION_TYPE_IN_MODERATION_QUEUE' => 'A post or topic needs approval',

'PASSWORD_UPDATED' => 'A new password was sent to your registered email address.',

'PERMISSIONS_RESTORED' => 'Successfully restored original permissions.',

'PERMISSIONS_TRANSFERRED' => 'Successfully transferred permissions from <strong>%s</strong>, you are now able to browse the board with this user’s permissions.<br />Please note that admin permissions were not transferred. You are able to revert to your permission set at any time.',

'PM_DISABLED' => 'Private messaging has been disabled on this board.',

'PM_FROM' => 'From',

'PM_FROM_REMOVED_AUTHOR' => 'This message was sent by a user no longer registered.',

$lang_return = $user->lang['RETURN_TOPIC'];

$lang_success = $user->lang['POST_REPORTED_SUCCESS'];

'report_text' => $report_text,

)));

}

$lang_return = $user->lang['RETURN_PM'];

$lang_success = $user->lang['PM_REPORTED_SUCCESS'];

'report_text' => $report_text,

'from_user_id' => $report_data['author_id'],

'report_id' => $report_id,

class phpbb_ext_test_notification_type_test extends phpbb_notification_type_base

{

public static function get_item_id($post)

{

return (int) $post['post_id'];

return $this->_find_users_for_notification(0, $options);

}

{

$this->time = $post['post_time'];

}

public function get_title()

return '';

}

public function get_email_template_variables()

{

return array();

public function test_get_subscription_types()

{

//get_subscription_types

//get_subscription_methods

public function test_subscriptions()

{

$this->assertEquals(array(

array(

'item_id' => 0,

'user_id' => 0,

'method' => '',

$this->assertEquals(array(

array(

'item_id' => 0,

'user_id' => 1,

'method' => '',

),

array(

'item_id' => 0,

'user_id' => 1,

'method' => '',

$this->assertEquals(array(

array(

'item_id' => 0,

'user_id' => 2,

'method' => '',

),

array(

'item_id' => 0,

'user_id' => 2,

'method' => 'email',

),

array(

'item_id' => 0,

'user_id' => 2,

'method' => 'jabber',

),

array(

'item_id' => 1,

'user_id' => 2,

'method' => '',

),

array(

'item_id' => 1,

'user_id' => 2,

'method' => 'email',

),

array(

'item_id' => 1,

'user_id' => 2,

'method' => 'jabber',

),

array(

'item_id' => 2,

'user_id' => 2,

'method' => '',

),

array(

'item_id' => 2,

'user_id' => 2,

'method' => 'email',

),

array(

'item_id' => 2,

'user_id' => 2,

'method' => 'jabber',

), $this->notifications->get_subscriptions(2));

$this->assertEquals(array(

'',

'email',

'jabber',

),

), $this->notifications->get_subscriptions(2, true));

$this->assertEquals(array(

array(

'item_id' => 0,

'user_id' => 2,

'method' => 'email',

),

array(

'item_id' => 0,

'user_id' => 2,

'method' => 'jabber',

),

array(

'item_id' => 1,

'user_id' => 2,

'method' => '',

),

array(

'item_id' => 1,

'user_id' => 2,

'method' => 'jabber',

),

array(

'item_id' => 2,

'user_id' => 2,

'method' => '',

),

array(

'item_id' => 2,

'user_id' => 2,

'method' => 'email',

{

global $db;

// Used to test post notifications later

$db->sql_query('INSERT INTO ' . TOPICS_WATCH_TABLE . ' ' . $db->sql_build_array('INSERT', array(

'count_unread' => true,

)));

'post_id' => '1',

'topic_id' => '1',

'post_time' => 1349413321,

));

'post_id' => '2',

'topic_id' => '2',

'post_time' => 1349413322,

));

'post_id' => '3',

'topic_id' => '2',

'post_time' => 1349413323,

));

'post_id' => '4',

'topic_id' => '2',

'post_time' => 1349413324,

'topic_id' => 2,

'user_id' => 0,

)));

'post_id' => '5',

'topic_id' => '2',

'post_time' => 1349413325,

'forum_name' => 'Your first forum',

));

'post_id' => '6',

'topic_id' => '2',

'post_time' => 1349413326,

));

$expected = array(

'item_parent_id' => 2,

'user_id' => 0,

'unread' => 1,

'data' => array(

'poster_id' => 2,

'topic_title' => 'test-title',

'forum_name' => 'Your first forum',

),

),

'item_parent_id' => 2,

'user_id' => 0,

'unread' => 1,

'data' => array(

'poster_id' => 2,

'topic_title' => 'test-title',

'forum_name' => 'Your first forum',

),

),

);

$this->assertEquals(sizeof($expected), $notifications['unread_count']);

$notifications = $notifications['notifications'];

foreach ($expected as $notification_id => $notification_data)

{

foreach ($notification_data as $key => $value)

{

}

}

// Now test updating -------------------------------

'post_id' => '1',

'topic_id' => '2', // change parent_id

'post_time' => 1349413321,

));

'post_id' => '3',

'topic_id' => '2',

));

'post_id' => '5',

'topic_id' => '2',

'poster_id' => 2,

'topic_title' => 'test-title2', // change topic_title

'post_subject' => 'Re: test-title2', // change post_subject

));

$expected = array(

'item_parent_id' => 2,

'user_id' => 0,

'unread' => 1,

),

2 => array(

'item_id' => 2,

'item_parent_id' => 2,

'user_id' => 0,

'time' => 1349413322,

'data' => array(),

),

'item_parent_id' => 2,

'user_id' => 0,

'unread' => 1,

'data' => array(),

),

5 => array(

'item_id' => 5,

'item_parent_id' => 2,

'user_id' => 0,

'unread' => 1,

'data' => array(

'poster_id' => 2,

'topic_title' => 'test-title2',

'forum_name' => 'Your second forum',

),

),

);

$this->assertEquals(sizeof($expected), $notifications['unread_count']);

$notifications = $notifications['notifications'];

foreach ($expected as $notification_id => $notification_data)

{

foreach ($notification_data as $key => $value)

{

}

}

}