# wpforo/1.4.10/wpf-includes/class-subscribes.php wpForo Forum, version 1.4.10. 319 lines. - Page: https://pluginprobe.com/plugins/wpforo/1.4.10/code/wpf-includes/class-subscribes.php - Raw: https://pluginprobe.com/plugins/wpforo/1.4.10/raw/wpf-includes/class-subscribes.php - Modified: 2018-05-29T21:28:12+00:00 Line numbers below start at 1. Link to a line or a range by appending a fragment to the page URL, for example `https://pluginprobe.com/plugins/wpforo/1.4.10/code/wpf-includes/class-subscribes.php#L10-L20`. ```php array() ); function __construct(){ $this->init_defaults(); $this->init_options(); } private function init_defaults(){ $blogname = get_option('blogname', ''); $adminemail = get_option('admin_email'); $this->default = new stdClass; $this->default->options = array ( 'from_name' => $blogname . ' - Forum', 'from_email' => $adminemail, 'admin_emails' => $adminemail, 'new_topic_notify' => 1, 'new_reply_notify' => 0, 'confirmation_email_subject' => "Please confirm subscription to [entry_title]", 'confirmation_email_message' => "Hello [member_name]!
\r\n Thank you for subscribing.
\r\n This is an automated response.
\r\n We are glad to inform you that after confirmation you will get updates from - [entry_title].
\r\n Please click on link below to complete this step.
\r\n [confirm_link]" , 'new_topic_notification_email_subject' => "New Topic" , 'new_topic_notification_email_message' => "Hello [member_name]!
\r\n New topic has been created on your subscribed forum - [forum].\r\n

\r\n [topic_title]\r\n
\r\n [topic_desc]\r\n
\r\n
\r\n If you want to unsubscribe from this forum please use the link below.
\r\n [unsubscribe_link]" , 'new_post_notification_email_subject' => "New Reply" , 'new_post_notification_email_message' => "Hello [member_name]!
\r\n New reply has been posted on your subscribed topic - [topic].\r\n

\r\n [reply_title]\r\n
\r\n [reply_desc]\r\n
\r\n
\r\n If you want to unsubscribe from this topic please use the link below.
\r\n [unsubscribe_link]" , 'report_email_subject' => "Forum Post Report", 'report_email_message' => "Report details:\r\n Reporter: [reporter],
\r\n Message: [message],
\r\n
\r\n [post_url]", 'reset_password_email_message' => "Hello!
\r\n\r\n You asked us to reset your password for your account using the email address [user_login].
\r\n\r\n If this was a mistake, or you didn't ask for a password reset, just ignore this email and nothing will happen.
\r\n\r\n To reset your password, visit the following address:
\r\n\r\n [reset_password_url]
\r\n\r\n Thanks!", //'spam_notification_email_subject' => 'New Banned User', //'spam_notification_email_message' => "Hello [member_name]!
\r\n Please check this user's topics/posts and consider to Delete or Unban.
\r\n User Activity: [profile_activity_url]", 'update' => '1', 'user_mention_notify' => 1, 'user_mention_email_subject' => "You have been mentioned in forum post", 'user_mention_email_message' => "Hi [mentioned-user-name]!
\r\n\r\n You have been mentioned in a post on \"[topic-title]\" by [author-user-name].

\r\n\r\n Post URL: [post-url]" ); } private function init_options(){ $this->options = get_wpf_option('wpforo_subscribe_options', $this->default->options); } function get_confirm_key(){ return substr(md5(rand().time()), 0, 32); } function add( $args = array() ){ if( empty($args) && empty($_REQUEST['sbscrb']) ) return FALSE; if( empty($args) && !empty($_REQUEST['sbscrb']) ) $args = $_REQUEST['sbscrb']; if( !isset($args['active']) || !$args['active'] ) $args['active'] = 0; extract( $args ); if( !isset($itemid) || !( (isset($userid) && $userid) || (isset($user_email) && $user_email) ) || !isset($type) || !$type ) return FALSE; if( empty($confirmkey) ) $confirmkey = $this->get_confirm_key(); if(WPF()->db->insert( WPF()->tables->subscribes, array( 'itemid' => wpforo_bigintval($itemid), 'type' => sanitize_text_field($type), 'confirmkey' => sanitize_text_field($confirmkey), 'userid' => wpforo_bigintval($userid), 'active' => $active, 'user_name' => ( isset($user_name) && $user_name ? $user_name : ''), 'user_email' => ( isset($user_email) && $user_email ? $user_email : '') ), array( '%d', '%s', '%s', '%d', '%d', '%s', '%s' ) )){ if( isset($active) && $active == 1 ){ WPF()->notice->add('You have been successfully subscribed', 'success'); }else{ WPF()->notice->add('Success! Thank you. Please check your email and click confirmation link below to complete this step.', 'success'); } return $confirmkey; } WPF()->notice->add('Can\'t subscribe to this item', 'error'); return FALSE; } function edit( $confirmkey = '' ){ if( !$confirmkey && isset($_REQUEST['key']) && $_REQUEST['key'] ) $confirmkey = $_REQUEST['key']; if( !$confirmkey ){ WPF()->notice->add('Invalid request!', 'error'); return FALSE; } if( WPF()->db->update( WPF()->tables->subscribes, array( 'active' => 1 ), array( 'confirmkey' => sanitize_text_field($confirmkey) ), array( '%d' ), array( '%s' ) ) ){ if( $sbs = $this->get_subscribe($confirmkey) ) WPF()->member->edit_is_email_confirmed($sbs['userid'], 1); WPF()->notice->add('You have been successfully subscribed', 'success'); return TRUE; } WPF()->notice->add('Your subscription for this item could not be confirmed', 'error'); return FALSE; } public function reset($data = array(), $all = '', $user = null){ if(!$user && !WPF()->current_userid && !WPF()->current_user_email) return false; if (!$user) $user = ( WPF()->current_userid ? WPF()->current_userid : WPF()->current_user_email ); $data = array_filter( (array) $data ); $args = array( 'itemid' => 0, 'type' => '', 'userid' => 0, 'active' => ( wpforo_feature('subscribe_conf') ? 0 : 1 ), 'user_name' => '', 'user_email' => '' ); if( is_numeric($user) ){ $args['userid'] = $user; $where = WPF()->db->prepare("`userid` = %d", $user); }else{ $args['user_email'] = $user; $args['user_name'] = WPF()->current_user_display_name; $where = WPF()->db->prepare("`user_email` = %s", $user); } if( $this->is_email_confirmed($user) ) $args['active'] = 1; $types = array('forum', 'forum-topic'); if( !$all ) array_push($types, 'forums', 'forums-topics'); $sql = "DELETE FROM `".WPF()->tables->subscribes."` WHERE `type` IN('".implode("','", $types)."') AND " . $where; if(!$all && $data){ $forumids = array_keys($data); $sql .= " AND `itemid` NOT IN(".implode(',', $forumids).")"; } WPF()->db->query($sql); if(!$all && $data){ foreach ($data as $forumid => $type){ $sql = "SELECT `subid` FROM `".WPF()->tables->subscribes."` WHERE `type` IN('forum', 'forum-topic') AND `itemid` = %d AND " . $where; $sql = WPF()->db->prepare($sql, $forumid); if( $subid = WPF()->db->get_var($sql) ){ WPF()->db->update( WPF()->tables->subscribes, array('type' => sanitize_text_field($type), 'active' => $args['active']), array('subid' => $subid), array('%s', '%d'), array('%d') ); }else{ $args['itemid'] = intval($forumid); $args['type'] = sanitize_text_field($type); $this->add($args); } } } if ($all){ $sql = "SELECT `subid` FROM `".WPF()->tables->subscribes."` WHERE `type` IN('forums', 'forums-topics') AND `itemid` = 0 AND " . $where; if( $subid = WPF()->db->get_var($sql) ){ WPF()->db->update( WPF()->tables->subscribes, array('type' => sanitize_text_field($all), 'active' => $args['active']), array('subid' => $subid), array('%s', '%d'), array('%d') ); }else{ $args['itemid'] = 0; $args['type'] = sanitize_text_field($all); $this->add($args); } } return true; } function delete( $confirmkey = '' ){ if( !$confirmkey && isset($_REQUEST['confirmkey']) && $_REQUEST['confirmkey'] ) $confirmkey = $_REQUEST['confirmkey']; if( !$confirmkey ){ WPF()->notice->add('Invalid request!', 'error'); return FALSE; } if( WPF()->db->delete( WPF()->tables->subscribes, array( 'confirmkey' => sanitize_text_field($confirmkey) ), array( '%s' ) ) ){ WPF()->notice->add('You have been successfully unsubscribed', 'success'); return TRUE; } WPF()->notice->add('Could not be unsubscribe from this item', 'error'); return FALSE; } function get_subscribe( $args = array() ){ $cache = WPF()->cache->on('memory_cashe'); if( is_string($args) ) $args = array("confirmkey" => sanitize_text_field($args)); if( empty($args) && !empty($_REQUEST['sbscrb']) ) $args = $_REQUEST['sbscrb']; if( empty($args) ) return FALSE; extract( $args, EXTR_OVERWRITE ); if( (!isset($itemid) || !$itemid || !( (isset($userid) && $userid) || (isset($user_email) && $user_email) ) || !isset($type) || !$type) && (!isset($confirmkey) || !$confirmkey) ) return FALSE; if( isset($confirmkey) && $confirmkey){ $where = " `confirmkey` = '".esc_sql(sanitize_text_field($confirmkey))."'"; }elseif( isset($itemid) && $itemid && isset($userid) && $userid && isset($type) && $type ){ $where = " `itemid` = ".wpforo_bigintval($itemid)." AND `userid` = ".wpforo_bigintval($userid)." AND `type` = '".esc_sql(sanitize_text_field($type))."'"; }elseif( isset($itemid) && $itemid && isset($user_email) && $user_email && isset($type) && $type ){ $where = " `itemid` = ".wpforo_bigintval($itemid)." AND `user_email` = '".esc_sql($user_email)."' AND `type` = '".esc_sql(sanitize_text_field($type))."'"; }else{ return FALSE; } $UID = ( $userid ? $userid : $user_email ); if( $cache && isset(self::$cache['subscribe'][$itemid][$UID][$type]) ){ return self::$cache['subscribe'][$itemid][$UID][$type]; } $sql = "SELECT * FROM `".WPF()->tables->subscribes."` WHERE " . $where; $subscribe = WPF()->db->get_row($sql, ARRAY_A); if($cache && !empty($subscribe)){ self::$cache['subscribe'][$itemid][$UID][$type] = $subscribe; } return $subscribe; } function get_subscribes( $args = array(), &$items_count = 0 ){ $default = array( 'itemid' => NULL, 'type' => array(), // topic | forum 'userid' => NULL, // 'active' => 1, 'orderby' => 'subid', // order by `field` 'order' => 'DESC', // ASC DESC 'offset' => NULL, // OFFSET 'row_count' => NULL, // ROW COUNT ); $args = wpforo_parse_args( $args, $default ); extract($args); $sql = "SELECT * FROM `".WPF()->tables->subscribes."`"; $wheres = array(); if( $type ) $wheres[] = " `type` IN( '" . implode("','", array_map('esc_sql', (array) $type ) ) . "')"; if( !is_null($active) ) $wheres[] = " `active` = " . intval($active); if( !is_null($itemid) ) $wheres[] = " `itemid` = " . wpforo_bigintval($itemid); if( !is_null($userid) ) $wheres[] = " `userid` = " . wpforo_bigintval($userid); if(!empty($wheres)) $sql .= " WHERE " . implode( " AND ", $wheres ); $item_count_sql = preg_replace('#SELECT.+?FROM#isu', 'SELECT count(*) FROM', $sql); if( $item_count_sql ) $items_count = WPF()->db->get_var($item_count_sql); $sql .= " ORDER BY `$orderby` " . $order; if( !is_null($row_count) ){ if( !is_null($offset) ){ $sql .= esc_sql(" LIMIT $offset,$row_count"); }else{ $sql .= esc_sql(" LIMIT $row_count"); } } return WPF()->db->get_results($sql, ARRAY_A); } function get_confirm_link($args){ if(is_string($args)) return wpforo_home_url( "?wpforo=sbscrbconfirm&key=" . sanitize_text_field($args) ); if($args['type'] == 'forum'){ $url = WPF()->forum->get_forum_url($args['itemid']) . '/'; }elseif($args['type'] == 'topic'){ $url = WPF()->topic->get_topic_url($args['itemid']) . '/'; }else{ $url = wpforo_home_url(); } return wpforo_home_url( $url . "?wpforo=sbscrbconfirm&key=" . sanitize_text_field($args['confirmkey']) ); } function get_unsubscribe_link($confirmkey){ return wpforo_home_url( "?wpforo=unsbscrb&key=" . sanitize_text_field($confirmkey) ); } public function is_email_confirmed($user = null){ if(!$user && !WPF()->current_userid && !WPF()->current_user_email) return false; if (!$user) $user = ( WPF()->current_userid ? WPF()->current_userid : WPF()->current_user_email ); $sql = ( is_numeric($user) ? "`userid` = %d" : "`user_email` = %s" ); $where = WPF()->db->prepare($sql, $user); if( WPF()->current_userid === $user && wpfval(WPF()->current_user, 'is_email_confirmed') ){ $has_confirmed = WPF()->current_user['is_email_confirmed']; }elseif( is_numeric($user) ){ $has_confirmed = WPF()->member->get_is_email_confirmed(WPF()->current_userid); }else{ $has_confirmed = WPF()->db->get_var( "SELECT `subid` FROM `".WPF()->tables->subscribes."` WHERE `active` = 1 AND " . $where ); } return (bool) $has_confirmed; } } ```