<?php
/**
 * BuddyBoss Performance Activity Integration.
 *
 * @package BuddyBoss\Performance
 */

namespace BuddyBoss\Performance\Integration;

use BuddyBoss\Performance\Cache;
use BuddyBoss\Performance\Helper;

if ( ! defined( 'ABSPATH' ) ) {
	exit();
}

/**
 * Activity Integration Class.
 *
 * @package BuddyBossApp\Performance
 */
class BB_Activity extends Integration_Abstract {


	/**
	 * Add(Start) Integration
	 *
	 * @return mixed|void
	 */
	public function set_up() {
		$this->register( 'bp-activity' );

		$purge_events = array(
			'bp_activity_add',                    // Any Activity add.
			'bp_activity_after_save',             // Any activity privacy update.
			'bp_activity_delete',                 // Any Activity deleted.
			'bp_activity_delete_comment',         // Any Activity comment deleted.
			'bb_activity_pin_unpin_post',         // Any Activity pin/unpin.
			'bb_activity_close_unclose_comments', // Any Activity closed/unclosed comment.

			// Added moderation support.
			'bp_suspend_activity_suspended',           // Any Activity Suspended.
			'bp_suspend_activity_comment_suspended',   // Any Activity Comment Suspended.
			'bp_suspend_activity_unsuspended',         // Any Activity Unsuspended.
			'bp_suspend_activity_comment_unsuspended', // Any Activity Comment Unsuspended.

			'bp_moderation_after_save',     // Hide activity when member blocked.
			'bb_moderation_after_delete',    // Unhide activity when member unblocked.

			'bb_poll_after_add_poll',     // Add/Update poll
			'bb_poll_after_remove_poll',     // Remove poll
			'bb_poll_after_add_poll_option', // Add poll options
			'bb_poll_after_remove_poll_options', // Remove poll options
			'bb_poll_after_add_poll_vote',   // Add a poll vote
			'bb_poll_after_remove_poll_votes', // Remove poll votes

			'bb_activity_topic_relationship_after_add', // Add a activity topic relationship.
			'bb_activity_topic_relationship_after_update', // Update a activity topic relationship If the same topic is already assigned
			'bb_after_update_activity_topic_relationship', // Update a activity topic relationship.
			'bb_after_delete_activity_topic_relationship', // Delete a activity topic relationship.
			'bb_after_migrate_topic', // Migrate a activity topic relationship.
		);

		$this->purge_event( 'bp-activity', $purge_events );
		$this->purge_event( 'bbapp-deeplinking', $purge_events );

		/**
		 * Support for single items purge
		 *
		 * `bp_groups_posted_update`, `bp_activity_posted_update`, `bp_activity_comment_posted`, `bp_activity_comment_posted_notification_skipped` will manage with `bp_activity_add`
		 * `bp_groups_posted_update` : group activity update added
		 * `bp_activity_posted_update`: activity update added
		 * `bp_activity_comment_posted`: activity comment added
		 * `bp_activity_comment_posted_notification_skipped`: activity comment added without Notification
		 */
		$purge_single_events = array(
			'bp_activity_add'                         => 1, // Any Activity add.
			'bp_activity_delete'                      => 1, // Any Activity deleted.
			'bp_activity_delete_comment'              => 1, // Any Activity comment deleted.
			'updated_activity_meta'                   => 2, // Any Activity meta update.
			'bp_activity_add_user_favorite'           => 1, // if activity added in user favorite list.
			'bp_activity_remove_user_favorite'        => 1, // if activity remove from user favorite list.
			'bb_activity_pin_unpin_post'              => 1, // Any Activity pin/unpin.
			'bb_activity_close_unclose_comments'      => 1, // Any Activity close/unclose comment.

			// Added Moderation Support.
			'bp_suspend_activity_suspended'           => 1, // Any Activity Suspended.
			'bp_suspend_activity_comment_suspended'   => 1, // Any Activity Comment Suspended.
			'bp_suspend_activity_unsuspended'         => 1, // Any Activity Unsuspended.
			'bp_suspend_activity_comment_unsuspended' => 1, // Any Activity Comment Unsuspended.

			'bp_moderation_after_save'                    => 1, // Hide activity when member blocked.
			'bb_moderation_after_delete'                  => 1, // Unhide activity when member unblocked.

			// Add Author Embed Support.
			'profile_update'                              => 1, // User updated on site.
			'deleted_user'                                => 1, // User deleted on site.
			'xprofile_avatar_uploaded'                    => 1, // User avatar photo updated.
			'bp_core_delete_existing_avatar'              => 1, // User avatar photo deleted.

			// When change/update the reaction settings.
			'update_option_bb_all_reactions'              => 3, // When enabled/disabled the reactions.
			'update_option_bb_reaction_mode'              => 3, // When change/update the reaction mode.
			'deleted_post'                                => 2, // When delete the emotion.

			// When create user reaction via reaction API.
			'bb_reaction_after_add_user_item_reaction'    => 2, // When enabled/disabled the reactions.
			'bb_reaction_after_remove_user_item_reaction' => 3, // When enabled/disabled the reactions.

			'bb_poll_after_add_poll'            => 1, // Add/Update poll.
			'bb_poll_after_remove_poll'         => 1, // Remove poll.
			'bb_poll_after_add_poll_option'     => 2, // Add poll options.
			'bb_poll_after_remove_poll_options' => 2, // Remove poll options.
			'bb_poll_after_add_poll_vote'       => 2, // Add a poll vote.
			'bb_poll_after_remove_poll_votes'   => 2, // Remove poll votes.

			'bb_activity_topic_relationship_after_add'    => 3, // Add a activity topic relationship.
			'bb_activity_topic_relationship_after_update' => 3, // Update a activity topic relationship If the same topic is already assigned
			'bb_after_update_activity_topic_relationship' => 3, // Update a activity topic relationship.
			'bb_after_delete_activity_topic_relationship' => 3, // Delete a activity topic relationship.
			'bb_after_migrate_topic'                      => 6, // Migrate a activity topic relationship.

			'updated_option' => 3, // When change/update the activity CPT settings.
		);

		$this->purge_single_events( $purge_single_events );

		$is_component_active = Helper::instance()->get_app_settings( 'cache_component', 'buddyboss-app' );
		$settings            = Helper::instance()->get_app_settings( 'cache_bb_activity_feeds', 'buddyboss-app' );
		$cache_bb_activity   = isset( $is_component_active ) && isset( $settings ) ? ( $is_component_active && $settings ) : false;

		if ( $cache_bb_activity ) {

			// Check if the cache_expiry static method exists and call it, or get the value from an instance.
			$cache_expiry_time = method_exists('BuddyBoss\Performance\Cache', 'cache_expiry') ? Cache::cache_expiry() : Cache::instance()->month_in_seconds;

			$this->cache_endpoint(
				'buddyboss/v1/activity',
				$cache_expiry_time,
				array(
					'unique_id'         => 'id',
				),
				true
			);

			$this->cache_endpoint(
				'buddyboss/v1/activity/<id>',
				$cache_expiry_time,
				array(),
				false
			);
		}
	}

	/******************************** Activity Events ********************************/
	/**
	 * Any Activity add
	 *
	 * @param array $r Arguments array.
	 */
	public function event_bp_activity_add( $r ) {
		if ( ! empty( $r['id'] ) ) {
			$this->purge_item_cache_by_item_id( $r['id'] );
		}
		if ( 'activity_comment' === $r['type'] && ! empty( $r['item_id'] ) ) {
			$this->purge_item_cache_by_item_id( $r['item_id'] );
		}
	}

	/**
	 * Any Activity deleted
	 *
	 * @param array $args Arguments array.
	 */
	public function event_bp_activity_delete( $args ) {
		if ( ! empty( $r['id'] ) ) {
			$this->purge_item_cache_by_item_id( $args['id'] );
		}
	}

	/**
	 * Any Activity comment deleted
	 *
	 * @param int $activity_id Activity id.
	 */
	public function event_bp_activity_delete_comment( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Any Activity meta update
	 *
	 * @param int $meta_id     Activity Meta id.
	 * @param int $activity_id Activity id.
	 */
	public function event_updated_activity_meta( $meta_id, $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Activity added in user favorite list
	 *
	 * @param int $activity_id Activity id.
	 */
	public function event_bp_activity_add_user_favorite( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Activity remove from user favorite list
	 *
	 * @param int $activity_id Activity id.
	 */
	public function event_bp_activity_remove_user_favorite( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Pin/Unpin Activity.
	 *
	 * @param int $activity_id Activity id.
	 */
	public function event_bb_activity_pin_unpin_post( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/******************************* Moderation Support ******************************/
	/**
	 * Suspended Activity ID.
	 *
	 * @param int $activity_id Activity ID.
	 */
	public function event_bp_suspend_activity_suspended( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Suspended Activity Comment ID.
	 *
	 * @param int $activity_id Activity ID.
	 */
	public function event_bp_suspend_activity_comment_suspended( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Unsuspended Activity ID.
	 *
	 * @param int $activity_id Activity ID.
	 */
	public function event_bp_suspend_activity_unsuspended( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Unsuspended Activity Comment ID.
	 *
	 * @param int $activity_id Activity ID.
	 */
	public function event_bp_suspend_activity_comment_unsuspended( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Update cache for activity when member blocked.
	 *
	 * @param BP_Moderation $bp_moderation Current instance of moderation item. Passed by reference.
	 */
	public function event_bp_moderation_after_save( $bp_moderation ) {
		if ( empty( $bp_moderation->item_id ) || empty( $bp_moderation->item_type ) || 'user' !== $bp_moderation->item_type ) {
			return;
		}

		$activity_ids = $this->get_activity_ids_by_userid( $bp_moderation->item_id );

		if ( ! empty( $activity_ids ) ) {
			$this->purge_item_cache_by_item_ids( $activity_ids );
		}
	}

	/**
	 * Update cache for activity when member unblocked.
	 *
	 * @param BP_Moderation $bp_moderation Current instance of moderation item. Passed by reference.
	 */
	public function event_bb_moderation_after_delete( $bp_moderation ) {
		if ( empty( $bp_moderation->item_id ) || empty( $bp_moderation->item_type ) || 'user' !== $bp_moderation->item_type ) {
			return;
		}

		$activity_ids = $this->get_activity_ids_by_userid( $bp_moderation->item_id );

		if ( ! empty( $activity_ids ) ) {
			$this->purge_item_cache_by_item_ids( $activity_ids );
		}
	}

	/****************************** Author Embed Support *****************************/
	/**
	 * User updated on site
	 *
	 * @param int $user_id User ID.
	 */
	public function event_profile_update( $user_id ) {
		$activity_ids = $this->get_activity_ids_by_userid( $user_id );

		if ( ! empty( $activity_ids ) ) {
			$this->purge_item_cache_by_item_ids( $activity_ids );
		}
	}

	/**
	 * User deleted on site
	 *
	 * @param int $user_id User ID.
	 */
	public function event_deleted_user( $user_id ) {
		$activity_ids = $this->get_activity_ids_by_userid( $user_id );

		if ( ! empty( $activity_ids ) ) {
			$this->purge_item_cache_by_item_ids( $activity_ids );
		}
	}

	/**
	 * User avatar photo updated
	 *
	 * @param int $user_id User ID.
	 */
	public function event_xprofile_avatar_uploaded( $user_id ) {
		$activity_ids = $this->get_activity_ids_by_userid( $user_id );

		if ( ! empty( $activity_ids ) ) {
			$this->purge_item_cache_by_item_ids( $activity_ids );
		}
	}

	/**
	 * User avatar photo deleted
	 *
	 * @param array $args Arguments array.
	 */
	public function event_bp_core_delete_existing_avatar( $args ) {
		$user_id = ! empty( $args['item_id'] ) ? absint( $args['item_id'] ) : 0;

		if ( ! empty( $user_id ) ) {
			if ( isset( $args['object'] ) && 'user' === $args['object'] ) {
				$activity_ids = $this->get_activity_ids_by_userid( $user_id );

				if ( ! empty( $activity_ids ) ) {
					$this->purge_item_cache_by_item_ids( $activity_ids );
				}
			}
		}
	}

	/**
	 * When enabled/disabled reaction.
	 *
	 * @param string $option    Name of the updated option.
	 * @param mixed  $old_value The old option value.
	 * @param mixed  $value     The new option value.
	 */
	public function event_update_option_bb_all_reactions( $old_value, $value, $option ) {
		Cache::instance()->purge_by_component( 'bp-activity' );
		Cache::instance()->purge_by_component( 'bbapp-deeplinking' );
	}

	/**
	 * When reaction mode changed.
	 *
	 * @param string $option    Name of the updated option.
	 * @param mixed  $old_value The old option value.
	 * @param mixed  $value     The new option value.
	 */
	public function event_update_option_bb_reaction_mode( $old_value, $value, $option ) {
		Cache::instance()->purge_by_component( 'bp-activity' );
		Cache::instance()->purge_by_component( 'bbapp-deeplinking' );
	}

	/**
	 * When emotion deleted.
	 *
	 * @param int     $postid Post ID.
	 * @param object $post   Post object.
	 */
	public function event_deleted_post( $postid, $post ) {
		if (
			! empty( $post ) &&
			! empty( $post->post_type ) &&
			'bb_reaction' === $post->post_type
		) {
			Cache::instance()->purge_by_component( 'bp-activity' );
			Cache::instance()->purge_by_component( 'bbapp-deeplinking' );
		}
	}

	/**
	 * When created user reaction via reaction API.
	 *
	 * @param int   $user_reaction_id User reaction id.
	 * @param array $r                Array of parsed arguments.
	 */
	public function event_bb_reaction_after_add_user_item_reaction( $user_reaction_id, $r ) {
		if (
			! empty( $r ) &&
			! empty( $r['item_id'] )
		) {
			$this->purge_item_cache_by_item_id( $r['item_id'] );
		}
	}

	/**
	 * When deleted user reaction via reaction API.
	 *
	 * @param int       $user_reaction_id User reaction id.
	 * @param int|false $deleted          The number of rows deleted, or false on error.
	 * @param object    $get              Reaction data.
	 */
	public function event_bb_reaction_after_remove_user_item_reaction( $user_reaction_id, $deleted, $get ) {
		if (
			! empty( $get ) &&
			! empty( $get->item_id )
		) {
			$this->purge_item_cache_by_item_id( $get->item_id );
		}
	}

	/*********************************** Functions ***********************************/
	/**
	 * Get Activities ids from user name.
	 *
	 * @param int $user_id User ID.
	 *
	 * @return array
	 */
	private function get_activity_ids_by_userid( $user_id ) {
		global $wpdb;
		$bp = buddypress();
		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
		$sql = $wpdb->prepare( "SELECT id FROM {$bp->activity->table_name} WHERE user_id = %d", $user_id );

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
		return $wpdb->get_col( $sql );
	}

	/**
	 * Purge item cache by item id.
	 *
	 * @param $activity_id
	 */
	private function purge_item_cache_by_item_id( $activity_id ) {
		Cache::instance()->purge_by_group( 'bp-activity_' . $activity_id );
		Cache::instance()->purge_by_group( 'bbapp-deeplinking_' . untrailingslashit( bp_activity_get_permalink( $activity_id ) ) );
	}

	/**
	 * Purge item cache by item ids.
	 *
	 * @param array $ids Array of ids.
	 *
	 * @return void
	 */
	private function purge_item_cache_by_item_ids( $ids ) {
		if ( empty( $ids ) ) {
			return;
		}

		Cache::instance()->purge_by_group_names( $ids, array( 'bp-activity_' ), array( $this, 'prepare_activity_deeplink' ) );
	}

	/**
	 * Prepare activity deeplink.
	 *
	 * @param int $activity_id Activity ID.
	 *
	 * @return string
	 */
	public function prepare_activity_deeplink( $activity_id ) {
		return 'bbapp-deeplinking_' . untrailingslashit( bp_activity_get_permalink( $activity_id ) );
	}

	/**
	 * Close/Unclose Activity Comments.
	 *
	 * @param int $activity_id Activity id.
	 */
	public function event_bb_activity_close_unclose_comments( $activity_id ) {
		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Update poll.
	 *
	 * @param int $poll_id Poll id.
	 */
	public function event_bb_poll_after_add_poll( $poll_id ) {
		$activity_id = $this->get_activity_id_by_poll_id( $poll_id );

		if ( empty( $activity_id ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Remove poll.
	 *
	 * @param int $poll_id Poll id.
	 */
	public function event_bb_poll_after_remove_poll( $poll_id ) {
		$activity_id = $this->get_activity_id_by_poll_id( $poll_id );

		if ( empty( $activity_id ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Add/Update a poll option.
	 *
	 * @param int   $option_id Option id.
	 * @param array $args      Arguments array.
	 */
	public function event_bb_poll_after_add_poll_option( $option_id, $args ) {
		if ( empty( $args['poll_id'] ) ) {
			return;
		}

		$activity_id = $this->get_activity_id_by_poll_id( $args['poll_id'] );

		if ( empty( $activity_id ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Remove a poll option.
	 *
	 * @param int   $option_id Option id.
	 * @param array $args      Arguments array.
	 */
	public function event_bb_poll_after_remove_poll_options( $option_id, $args ) {
		if ( empty( $args['poll_id'] ) ) {
			return;
		}

		$activity_id = $this->get_activity_id_by_poll_id( $args['poll_id'] );

		if ( empty( $activity_id ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Add/Update a poll vote.
	 *
	 * @param int   $vote_id Vote id.
	 * @param array $args    Arguments array.
	 */
	public function event_bb_poll_after_add_poll_vote( $vote_id, $args ) {
		if ( empty( $args['poll_id'] ) ) {
			return;
		}

		$activity_id = $this->get_activity_id_by_poll_id( $args['poll_id'] );

		if ( empty( $activity_id ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Remove a poll vote.
	 *
	 * @param int   $vote_id Vote id.
	 * @param array $args    Arguments array.
	 */
	public function event_bb_poll_after_remove_poll_votes( $vote_id, $args ) {
		if ( empty( $args['poll_id'] ) ) {
			return;
		}

		$activity_id = $this->get_activity_id_by_poll_id( $args['poll_id'] );

		if ( empty( $activity_id ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $activity_id );
	}

	/**
	 * Get Activity id based on poll ID.
	 *
	 * @param int $poll_id Poll ID.
	 *
	 * @return string
	 */
	private function get_activity_id_by_poll_id( $poll_id ) {
		global $wpdb;
		$bp = buddypress();

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
		return $wpdb->get_var( $wpdb->prepare( "SELECT activity_id FROM {$bp->activity->table_name_meta} WHERE meta_key = %s AND meta_value = %d", "bb_poll_id", $poll_id ) );
	}

	/**
	 * When activity CPT settings updated.
	 *
	 * @param string $option    Name of the updated option.
	 * @param mixed  $old_value The old option value.
	 * @param mixed  $value     The new option value.
	 */
	public function event_updated_option( $option, $old_value, $value ) {
		// Check if the option name contains 'bp-feed-custom-post-type' and if the option value has changed.
		if ( false !== strpos( $option, 'bp-feed-custom-post-type' ) && $old_value !== $value ) {
			Cache::instance()->purge_by_component( 'bp-activity' );
		}
	}

	/**
	 * When a activity topic relationship is added.
	 *
	 * @param int   $updated Topic relationship id.
	 * @param array $data    Data array.
	 * @param array $r Arguments array.
	 */
	public function event_bb_activity_topic_relationship_after_add( $updated, $data, $r ) {
		if ( empty( $data['activity_id'] ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $data['activity_id'] );
	}

	/**
	 * When a activity topic relationship is updated if the same topic is already assigned.
	 *
	 * @param int   $updated Topic relationship id.
	 * @param array $data    Data array.
	 * @param array $r Arguments array.
	 */
	public function event_bb_activity_topic_relationship_after_update( $updated, $data, $r ) {
		if ( empty( $data['activity_id'] ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $data['activity_id'] );
	}

	/**
	 * When a activity topic relationship is updated.
	 *
	 * @param int   $updated Topic relationship id.
	 * @param array $data    Data array.
	 * @param array $r       Arguments array.
	 */
	public function event_bb_after_update_activity_topic_relationship( $updated, $data, $r ) {
		if ( empty( $data['activity_id'] ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $data['activity_id'] );
	}

	/**
	 * When a activity topic relationship is deleted.
	 *
	 * @param int   $deleted Topic relationship id.
	 * @param array $data    Data array.
	 * @param array $r       Arguments array.
	 */
	public function event_bb_after_delete_activity_topic_relationship( $deleted, $data, $r ) {
		if ( empty( $data['activity_id'] ) ) {
			return;
		}

		$this->purge_item_cache_by_item_id( $data['activity_id'] );
	}

	/**
	 * When a activity topic relationship is migrated.
	 *
	 * @param object $topic        The topic object.
	 * @param int    $old_topic_id The ID of the old topic.
	 * @param int    $new_topic_id The ID of the new topic.
	 * @param int    $item_id      The ID of the item.
	 * @param string $item_type    The type of item.
	 * @param array  $migrated_activity_ids The IDs of the activities.
	 */
	public function event_bb_after_migrate_topic( $topic, $old_topic_id, $new_topic_id, $item_id, $item_type, $migrated_activity_ids ) {
		if ( empty( $migrated_activity_ids ) ) {
			return;
		}

		$this->purge_item_cache_by_item_ids( $migrated_activity_ids );
	}
}