Adding plugin buddypress

wp-content/plugins/buddypress/bp-activity/bp-activity-classes.php

+<?php
+
+Class BP_Activity_Activity {
+	var $id;
+	var $item_id;
+	var $secondary_item_id;
+	var $user_id;
+	var $primary_link;
+	var $component;
+	var $type;
+	var $action;
+	var $content;
+	var $date_recorded;
+	var $hide_sitewide = false;
+
+	function bp_activity_activity( $id = false ) {
+		global $bp;
+
+		if ( $id ) {
+			$this->id = $id;
+			$this->populate();
+		}
+	}
+
+	function populate() {
+		global $wpdb, $bp;
+
+		$row = $wpdb->get_row( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE id = %d", $this->id ) );
+		if ( $row ) {
+			$this->id = $row->id;
+			$this->item_id = $row->item_id;
+			$this->secondary_item_id = $row->secondary_item_id;
+			$this->user_id = $row->user_id;
+			$this->primary_link = $row->primary_link;
+			$this->component = $row->component;
+			$this->type = $row->type;
+			$this->action = $row->action;
+			$this->content = $row->content;
+			$this->date_recorded = $row->date_recorded;
+			$this->hide_sitewide = $row->hide_sitewide;
+			$this->mptt_left = $row->mptt_left;
+			$this->mptt_right = $row->mptt_right;
+		}
+	}
+
+	function save() {
+		global $wpdb, $bp, $current_user;
+
+		do_action( 'bp_activity_before_save', &$this );
+
+		$this->id = apply_filters( 'bp_activity_id_before_save', $this->id, &$this );
+		$this->item_id = apply_filters( 'bp_activity_item_id_before_save', $this->item_id, &$this );
+		$this->secondary_item_id = apply_filters( 'bp_activity_secondary_item_id_before_save', $this->secondary_item_id, &$this );
+		$this->user_id = apply_filters( 'bp_activity_user_id_before_save', $this->user_id, &$this );
+		$this->primary_link = apply_filters( 'bp_activity_primary_link_before_save', $this->primary_link, &$this );
+		$this->component = apply_filters( 'bp_activity_component_before_save', $this->component, &$this );
+		$this->type = apply_filters( 'bp_activity_type_before_save', $this->type, &$this );
+		$this->action = apply_filters( 'bp_activity_action_before_save', $this->action, &$this );
+		$this->content = apply_filters( 'bp_activity_content_before_save', $this->content, &$this );
+		$this->date_recorded = apply_filters( 'bp_activity_date_recorded_before_save', $this->date_recorded, &$this );
+		$this->hide_sitewide = apply_filters( 'bp_activity_hide_sitewide_before_save', $this->hide_sitewide, &$this );
+		$this->mptt_left = apply_filters( 'bp_activity_mptt_left_before_save', $this->mptt_left, &$this );
+		$this->mptt_right = apply_filters( 'bp_activity_mptt_right_before_save', $this->mptt_right, &$this );
+
+		if ( !$this->component || !$this->type )
+			return false;
+
+		if ( !$this->primary_link )
+			$this->primary_link = $bp->loggedin_user->domain;
+
+		/* If we have an existing ID, update the activity item, otherwise insert it. */
+		if ( $this->id )
+			$q = $wpdb->prepare( "UPDATE {$bp->activity->table_name} SET user_id = %d, component = %s, type = %s, action = %s, content = %s, primary_link = %s, date_recorded = %s, item_id = %s, secondary_item_id = %s, hide_sitewide = %d WHERE id = %d", $this->user_id, $this->component, $this->type, $this->action, $this->content, $this->primary_link, $this->date_recorded, $this->item_id, $this->secondary_item_id, $this->hide_sitewide, $this->id );
+		else
+			$q = $wpdb->prepare( "INSERT INTO {$bp->activity->table_name} ( user_id, component, type, action, content, primary_link, date_recorded, item_id, secondary_item_id, hide_sitewide ) VALUES ( %d, %s, %s, %s, %s, %s, %s, %s, %s, %d )", $this->user_id, $this->component, $this->type, $this->action, $this->content, $this->primary_link, $this->date_recorded, $this->item_id, $this->secondary_item_id, $this->hide_sitewide );
+
+		if ( !$wpdb->query( $q ) )
+			return false;
+
+		if ( empty( $this->id ) )
+			$this->id = $wpdb->insert_id;
+
+		do_action( 'bp_activity_after_save', &$this );
+		return true;
+	}
+
+	/* Static Functions */
+
+	function get( $max = false, $page = 1, $per_page = 25, $sort = 'DESC', $search_terms = false, $filter = false, $display_comments = false, $show_hidden = false ) {
+		global $wpdb, $bp;
+
+		/* Select conditions */
+		$select_sql = "SELECT a.*, u.user_email, u.user_nicename, u.user_login, u.display_name";
+
+		$from_sql = " FROM {$bp->activity->table_name} a LEFT JOIN {$wpdb->users} u ON a.user_id = u.ID";
+
+		/* Where conditions */
+		$where_conditions = array();
+
+		/* Searching */
+		if ( $search_terms ) {
+			$search_terms = $wpdb->escape( $search_terms );
+			$where_conditions['search_sql'] = "a.content LIKE '%%" . like_escape( $search_terms ) . "%%'";
+		}
+
+		/* Filtering */
+		if ( $filter && $filter_sql = BP_Activity_Activity::get_filter_sql( $filter ) )
+			$where_conditions['filter_sql'] = $filter_sql;
+
+		/* Sorting */
+		if ( $sort != 'ASC' && $sort != 'DESC' )
+			$sort = 'DESC';
+
+		/* Hide Hidden Items? */
+		if ( !$show_hidden )
+			$where_conditions['hidden_sql'] = "a.hide_sitewide = 0";
+
+		/* Alter the query based on whether we want to show activity item comments in the stream like normal comments or threaded below the activity */
+		if ( !$display_comments || 'threaded' == $display_comments ) {
+			$where_conditions[] = "a.type != 'activity_comment'";
+		}
+
+		$where_sql = 'WHERE ' . join( ' AND ', $where_conditions );
+
+		if ( $per_page && $page ) {
+			$pag_sql = $wpdb->prepare( "LIMIT %d, %d", intval( ( $page - 1 ) * $per_page ), intval( $per_page ) );
+			$activities = $wpdb->get_results( $wpdb->prepare( "{$select_sql} {$from_sql} {$where_sql} ORDER BY a.date_recorded {$sort} {$pag_sql}" ) );
+		} else
+			$activities = $wpdb->get_results( $wpdb->prepare( "{$select_sql} {$from_sql} {$where_sql} ORDER BY a.date_recorded {$sort} {$pag_sql}" ) );
+
+		$total_activities = $wpdb->get_var( $wpdb->prepare( "SELECT count(a.id) FROM {$bp->activity->table_name} a {$where_sql} ORDER BY a.date_recorded {$sort}" ) );
+
+		/* Get the fullnames of users so we don't have to query in the loop */
+		if ( function_exists( 'xprofile_install' ) && $activities ) {
+			foreach ( (array)$activities as $activity ) {
+				if ( (int)$activity->user_id )
+					$activity_user_ids[] = $activity->user_id;
+			}
+
+			$activity_user_ids = implode( ',', array_unique( (array)$activity_user_ids ) );
+			if ( !empty( $activity_user_ids ) ) {
+				if ( $names = $wpdb->get_results( $wpdb->prepare( "SELECT user_id, value AS user_fullname FROM {$bp->profile->table_name_data} WHERE field_id = 1 AND user_id IN ({$activity_user_ids})" ) ) ) {
+					foreach ( (array)$names as $name )
+						$tmp_names[$name->user_id] = $name->user_fullname;
+
+					foreach ( (array)$activities as $i => $activity ) {
+						if ( !empty( $tmp_names[$activity->user_id] ) )
+							$activities[$i]->user_fullname = $tmp_names[$activity->user_id];
+					}
+
+					unset( $names );
+					unset( $tmp_names );
+				}
+			}
+		}
+
+		if ( $activities && $display_comments )
+			$activities = BP_Activity_Activity::append_comments( &$activities );
+
+		/* If $max is set, only return up to the max results */
+		if ( !empty( $max ) ) {
+			if ( (int)$total_activities > (int)$max )
+				$total_activities = $max;
+		}
+
+		return array( 'activities' => $activities, 'total' => (int)$total_activities );
+	}
+
+	function get_specific( $activity_ids, $max = false, $page = 1, $per_page = 25, $sort = 'DESC', $display_comments = false ) {
+		global $wpdb, $bp;
+
+		if ( is_array( $activity_ids ) )
+			$activity_ids = implode( ',', $activity_ids );
+
+		$activity_ids = $wpdb->escape( $activity_ids );
+
+		if ( empty( $activity_ids ) )
+			return false;
+
+		if ( $per_page && $page )
+			$pag_sql = $wpdb->prepare( "LIMIT %d, %d", intval( ( $page - 1 ) * $per_page ), intval( $per_page ) );
+
+		if ( $sort != 'ASC' && $sort != 'DESC' )
+			$sort = 'DESC';
+
+		$activities = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$bp->activity->table_name} WHERE id IN ({$activity_ids}) ORDER BY date_recorded {$sort} $pag_sql" ) );
+		$total_activities = $wpdb->get_var( $wpdb->prepare( "SELECT count(id) FROM {$bp->activity->table_name} WHERE id IN ({$activity_ids})" ) );
+
+		if ( $display_comments )
+			$activities = BP_Activity_Activity::append_comments( $activities );
+
+		/* If $max is set, only return up to the max results */
+		if ( !empty( $max ) ) {
+			if ( (int)$total_activities > (int)$max )
+				$total_activities = $max;
+		}
+
+		return array( 'activities' => $activities, 'total' => (int)$total_activities );
+	}
+
+	function get_id( $user_id, $component, $type, $item_id, $secondary_item_id, $action, $content, $date_recorded ) {
+		global $bp, $wpdb;
+
+		$where_args = false;
+
+		if ( !empty( $user_id ) )
+			$where_args[] = $wpdb->prepare( "user_id = %d", $user_id );
+
+		if ( !empty( $component ) )
+			$where_args[] = $wpdb->prepare( "component = %s", $component );
+
+		if ( !empty( $type ) )
+			$where_args[] = $wpdb->prepare( "type = %s", $type );
+
+		if ( !empty( $item_id ) )
+			$where_args[] = $wpdb->prepare( "item_id = %s", $item_id );
+
+		if ( !empty( $secondary_item_id ) )
+			$where_args[] = $wpdb->prepare( "secondary_item_id = %s", $secondary_item_id );
+
+		if ( !empty( $action ) )
+			$where_args[] = $wpdb->prepare( "action = %s", $action );
+
+		if ( !empty( $content ) )
+			$where_args[] = $wpdb->prepare( "content = %s", $content );
+
+		if ( !empty( $date_recorded ) )
+			$where_args[] = $wpdb->prepare( "date_recorded = %s", $date_recorded );
+
+		if ( !empty( $where_args ) )
+			$where_sql = 'WHERE ' . join( ' AND ', $where_args );
+		else
+			return false;
+
+		return $wpdb->get_var( "SELECT id FROM {$bp->activity->table_name} {$where_sql}" );
+	}
+
+	function delete( $args ) {
+		global $wpdb, $bp;
+
+		extract( $args );
+
+		$defaults = array(
+			'id' => false,
+			'action' => false,
+			'content' => false,
+			'component' => false,
+			'type' => false,
+			'primary_link' => false,
+			'user_id' => false,
+			'item_id' => false,
+			'secondary_item_id' => false,
+			'date_recorded' => false,
+			'hide_sitewide' => false
+		);
+
+		$where_args = false;
+
+		if ( !empty( $id ) )
+			$where_args[] = $wpdb->prepare( "id = %d", $id );
+
+		if ( !empty( $user_id ) )
+			$where_args[] = $wpdb->prepare( "user_id = %d", $user_id );
+
+		if ( !empty( $action ) )
+			$where_args[] = $wpdb->prepare( "action = %s", $action );
+
+		if ( !empty( $content ) )
+			$where_args[] = $wpdb->prepare( "content = %s", $content );
+
+		if ( !empty( $component ) )
+			$where_args[] = $wpdb->prepare( "component = %s", $component );
+
+		if ( !empty( $type ) )
+			$where_args[] = $wpdb->prepare( "type = %s", $type );
+
+		if ( !empty( $primary_link ) )
+			$where_args[] = $wpdb->prepare( "primary_link = %s", $primary_link );
+
+		if ( !empty( $item_id ) )
+			$where_args[] = $wpdb->prepare( "item_id = %s", $item_id );
+
+		if ( !empty( $secondary_item_id ) )
+			$where_args[] = $wpdb->prepare( "secondary_item_id = %s", $secondary_item_id );
+
+		if ( !empty( $date_recorded ) )
+			$where_args[] = $wpdb->prepare( "date_recorded = %s", $date_recorded );
+
+		if ( !empty( $hide_sitewide ) )
+			$where_args[] = $wpdb->prepare( "hide_sitewide = %d", $hide_sitewide );
+
+		if ( !empty( $where_args ) )
+			$where_sql = 'WHERE ' . join( ' AND ', $where_args );
+		else
+			return false;
+
+		/* Fetch the activity IDs so we can delete any comments for this activity item */
+		$activity_ids = $wpdb->get_col( $wpdb->prepare( "SELECT id FROM {$bp->activity->table_name} {$where_sql}" ) );
+
+		if ( !$wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} {$where_sql}" ) ) )
+			return false;
+
+		if ( $activity_ids ) {
+			BP_Activity_Activity::delete_activity_item_comments( $activity_ids );
+			BP_Activity_Activity::delete_activity_meta_entries( $activity_ids );
+
+			return $activity_ids;
+		}
+
+		return $activity_ids;
+	}
+
+	function delete_activity_item_comments( $activity_ids ) {
+		global $bp, $wpdb;
+
+		if ( is_array($activity_ids) )
+			$activity_ids = implode( ',', $activity_ids );
+
+		$activity_ids = $wpdb->escape( $activity_ids );
+
+		return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name} WHERE type = 'activity_comment' AND item_id IN ({$activity_ids})" ) );
+	}
+
+	function delete_activity_meta_entries( $activity_ids ) {
+		global $bp, $wpdb;
+
+		if ( is_array($activity_ids) )
+			$activity_ids = implode( ',', $activity_ids );
+
+		$activity_ids = $wpdb->escape( $activity_ids );
+
+		return $wpdb->query( $wpdb->prepare( "DELETE FROM {$bp->activity->table_name_meta} WHERE activity_id IN ({$activity_ids})" ) );
+	}
+
+	function append_comments( $activities ) {
+		global $bp, $wpdb;
+
+		/* Now fetch the activity comments and parse them into the correct position in the activities array. */
+		foreach( (array)$activities as $activity ) {
+			if ( 'activity_comment' != $activity->type && $activity->mptt_left && $activity->mptt_right )
+				$activity_comments[$activity->id] = BP_Activity_Activity::get_activity_comments( $activity->id, $activity->mptt_left, $activity->mptt_right );
+		}
+
+		/* Merge the comments with the activity items */
+		foreach( (array)$activities as $key => $activity )
+			$activities[$key]->children = $activity_comments[$activity->id];
+
+		return $activities;
+	}
+
+	function get_activity_comments( $activity_id, $left, $right ) {
+		global $wpdb, $bp;
+
+		if ( !$comments = wp_cache_get( 'bp_activity_comments_' . $activity_id ) ) {
+			/* Select the user's fullname with the query so we don't have to fetch it for each comment */
+			if ( function_exists( 'xprofile_install' ) ) {
+				$fullname_select = ", pd.value as user_fullname";
+				$fullname_from = ", {$bp->profile->table_name_data} pd ";
+				$fullname_where = "AND pd.user_id = a.user_id AND pd.field_id = 1";
+			}
+
+			/* Retrieve all descendants of the $root node */
+			$descendants = $wpdb->get_results( $wpdb->prepare( "SELECT a.*, u.user_email, u.user_nicename, u.user_login, u.display_name{$fullname_select} FROM {$bp->activity->table_name} a, {$wpdb->users} u{$fullname_from} WHERE u.ID = a.user_id {$fullname_where} AND a.type = 'activity_comment' AND a.item_id = %d AND a.mptt_left BETWEEN %d AND %d ORDER BY a.date_recorded ASC", $activity_id, $left, $right ) );
+
+			/* Loop descendants and build an assoc array */
+			foreach ( (array)$descendants as $d ) {
+			    $d->children = array();
+
+				/* If we have a reference on the parent */
+			    if ( isset( $ref[ $d->secondary_item_id ] ) ) {
+			        $ref[ $d->secondary_item_id ]->children[ $d->id ] = $d;
+			        $ref[ $d->id ] =& $ref[ $d->secondary_item_id ]->children[ $d->id ];
+
+				/* If we don't have a reference on the parent, put in the root level */
+			    } else {
+			        $comments[ $d->id ] = $d;
+			        $ref[ $d->id ] =& $comments[ $d->id ];
+			    }
+			}
+			wp_cache_set( 'bp_activity_comments_' . $activity_id, $comments, 'bp' );
+		}
+
+		return $comments;
+	}
+
+	function rebuild_activity_comment_tree( $parent_id, $left = 1 ) {
+		global $wpdb, $bp;
+
+		/* The right value of this node is the left value + 1 */
+		$right = $left + 1;
+
+		/* Get all descendants of this node */
+		$descendants = BP_Activity_Activity::get_child_comments( $parent_id );
+
+		/* Loop the descendants and recalculate the left and right values */
+		foreach ( (array)$descendants as $descendant )
+			$right = BP_Activity_Activity::rebuild_activity_comment_tree( $descendant->id, $right );
+
+		/* We've got the left value, and now that we've processed the children of this node we also know the right value */
+		if ( 1 == $left )
+			$wpdb->query( $wpdb->prepare( "UPDATE {$bp->activity->table_name} SET mptt_left = %d, mptt_right = %d WHERE id = %d", $left, $right, $parent_id ) );
+		else
+			$wpdb->query( $wpdb->prepare( "UPDATE {$bp->activity->table_name} SET mptt_left = %d, mptt_right = %d WHERE type = 'activity_comment' AND id = %d", $left, $right, $parent_id ) );
+
+		/* Return the right value of this node + 1 */
+		return $right + 1;
+	}
+
+	function get_child_comments( $parent_id ) {
+		global $bp, $wpdb;
+
+		return $wpdb->get_results( $wpdb->prepare( "SELECT id FROM {$bp->activity->table_name} WHERE type = 'activity_comment' AND secondary_item_id = %d", $parent_id ) );
+	}
+
+	function get_recorded_components() {
+		global $wpdb, $bp;
+
+		return $wpdb->get_col( $wpdb->prepare( "SELECT DISTINCT component FROM {$bp->activity->table_name} ORDER BY component ASC" ) );
+	}