admin.php

<?php
/**
 * Admin code used by GES.
 *
 * @since 3.7.0
 */

/**
 * Adds "Group Email Options" panel under "Settings" in the admin/network admin.
 *
 * @since 2.1b
 */
function ass_admin_menu() {
	$admin_cap = bpges_admin_menu_cap();

	// Catch manual migration requests.
	if ( current_user_can( $admin_cap ) && ! empty( $_GET['page'] ) && 'ass_admin_options' === $_GET['page'] ) {
		if ( ! empty( $_GET['action'] ) && 'migrate_39' === $_GET['action'] ) {
			check_admin_referer( 'bpges_migrate_39' );

			$status = bpges_39_migration_status();

			if ( ! $status['subscription_table_created'] ) {
				bpges_install_subscription_table();
			} elseif ( ! $status['queued_items_table_created'] ) {
				bpges_install_queued_items_table();
			} elseif( ! $status['subscriptions_migrated'] ) {
				bpges_39_launch_legacy_subscription_migration();
			} elseif ( ! $status['queued_items_migrated'] ) {
				bpges_39_launch_legacy_digest_queue_migration();
			}

			wp_safe_redirect( bpges_get_admin_panel_url() );
			die;
		}
	}

	// BP 1.6+ deprecated the "BuddyPress" top-level menu item.
	if ( function_exists( 'bp_version' ) ) {
		// GES is network-activated, so show under Network Settings.
		if ( is_multisite() && is_plugin_active_for_network( plugin_basename( dirname( __FILE__ ) ) . '/bp-activity-subscription.php' ) ) {
			$settings_page = 'settings.php';
			$admin_cap     = 'manage_network_options';

		// Everything else.
		} else {
			$settings_page = 'options-general.php';
		}

		$title = __( 'BP Group Email Options', 'buddypress-group-email-subscription' );

	// BP 1.5 - Keep using the top-level "BuddyPress" menu item.
	} else {
		$settings_page = 'bp-general-settings';
		$title = __( 'Group Email Options', 'buddypress-group-email-subscription' );
	}

	add_submenu_page(
		$settings_page,
		$title,
		$title,
		$admin_cap,
		'ass_admin_options',
		'ass_admin_options'
	);
}
add_action( 'admin_menu', 'ass_admin_menu' );
add_action( 'network_admin_menu', 'ass_admin_menu' );

/**
 * Gets the capability for managing BPGES admin options.
 *
 * @since 3.9.3
 *
 * @return string
 */
function bpges_admin_menu_cap() {
	if ( is_multisite() && is_plugin_active_for_network( plugin_basename( dirname( __FILE__ ) ) . '/bp-activity-subscription.php' ) ) {
		$admin_cap = 'manage_network_options';
	} else {
		$admin_cap = 'manage_options';
	}

	/**
	 * Filters the capability for managing BPGES admin options.
	 *
	 * @since 3.9.3
	 *
	 * @param string $admin_cap
	 */
	return apply_filters( 'bpges_admin_menu_cap', $admin_cap );
}

/**
 * Gets the URL for the BPGES options panel.
 *
 * @since 3.9.0
 */
function bpges_get_admin_panel_url() {
	// GES is network-activated, so show under Network Settings.
	if ( is_multisite() && is_plugin_active_for_network( plugin_basename( dirname( __FILE__ ) ) . '/bp-activity-subscription.php' ) ) {
		$url = bp_get_admin_url( 'settings.php' );

	// Everything else.
	} else {
		$url = admin_url( 'options-general.php' );
	}

	return add_query_arg( 'page', 'ass_admin_options', $url );
}

/**
 * Checks whether an installation is from before BPGES 3.9 and needs migration.
 *
 * This is very rough!
 *
 * @since 3.9.1
 *
 * @return bool
 */
function bpges_is_legacy_installation() {
	global $wpdb, $bp;

	$is_legacy = $wpdb->get_var( "SELECT COUNT(*) FROM {$bp->groups->table_name_groupmeta} WHERE meta_key = 'ass_subscribed_users'" );

	return (bool) $is_legacy;
}

/**
 * Function to create the back end admin form.
 */
function ass_admin_options() {
	//print_r($_POST); die();

	if ( !empty( $_POST ) ) {
		if ( ass_update_dashboard_settings() ) {
			?>

			<div id="message" class="updated">
				<p><?php _e( 'Settings saved.', 'buddypress-group-email-subscription' ) ?></p>
			</div>

			<?php
		}
	}

	$is_legacy_installation = bpges_is_legacy_installation();

	if ( $is_legacy_installation ) {
		$status = bpges_39_migration_status();

		$table_class   = 'bpges-migration-step-success';
		$table_message = __( 'Complete!', 'buddypress-group-email-subscription' );
		if ( ! $status['subscription_table_created'] || ! $status['queued_items_table_created'] ) {
			$table_class   = 'bpges-migration-step-failure';
			$table_message = '';
		}

		$subs_class   = 'bpges-migration-step-success';
		$subs_message = __( 'Complete!', 'buddypress-group-email-subscription' );
		if ( $status['subscription_migration_in_progress'] ) {
			$subs_class   = 'bpges-migration-step-in-progress';
			$subs_message = __( 'In Progress', 'buddypress-group-email-subscription' );
		} elseif ( ! $status['subscriptions_migrated'] ) {
			$subs_class   = 'bpges-migration-step-failure';
			$subs_message = '';
		}

		$queued_class   = 'bpges-migration-step-success';
		$queued_message = __( 'Complete!', 'buddypress-group-email-subscription' );
		if ( $status['queued_items_migration_in_progress'] ) {
			$queued_class   = 'bpges-migration-step-in-progress';
			$queued_message = __( 'In Progress', 'buddypress-group-email-subscription' );
		} elseif ( ! $status['queued_items_migrated'] ) {
			$queued_class   = 'bpges-migration-step-failure';
			$queued_message = '';
		}
	}

	//set the first time defaults
	if ( !$ass_digest_time = bp_get_option( 'ass_digest_time' ) )
		$ass_digest_time = array( 'hours' => '05', 'minutes' => '00' );

	if ( !$ass_weekly_digest = bp_get_option( 'ass_weekly_digest' ) )
//		$ass_weekly_digest = 5; // friday
		$ass_weekly_digest = 0; // sunday

	$next = date( "r", wp_next_scheduled( 'ass_digest_event' ) );
	?>
	<div class="wrap">
		<h2><?php _e('Group Email Subscription Settings', 'buddypress-group-email-subscription'); ?></h2>

		<?php if ( $is_legacy_installation ) : ?>
			<div class="bpges-migration-tools">
				<h3><?php esc_html_e( 'Migration Status', 'buddypress-group-email-subscription' ); ?></h3>
				<p><?php esc_html_e( 'BuddyPress Group Email Subscription version 3.9 includes a number of important database migration routines.', 'buddypress-group-email-subscription' ); ?></p>

				<ol>
					<li class="bpges-migration-step <?php echo esc_attr( $table_class ); ?>"><?php esc_html_e( 'Create database tables', 'buddypress-group-email-subscription' ); ?> <?php if ( $table_message ) : ?><em> - <?php echo esc_html( $table_message ); ?></em><?php endif; ?></li>
					<li class="bpges-migration-step <?php echo esc_attr( $subs_class ); ?>"><?php esc_html_e( 'Migrate subscriptions', 'buddypress-group-email-subscription' ); ?> <?php if ( $subs_message ) : ?><em> - <?php echo esc_html( $subs_message ); ?></em><?php endif; ?></li>
					<li class="bpges-migration-step <?php echo esc_attr( $queued_class ); ?>"><?php esc_html_e( 'Migrate queued items', 'buddypress-group-email-subscription' ); ?> <?php if ( $queued_message ) : ?><em> - <?php echo esc_html( $queued_message ); ?></em><?php endif; ?></li>
				</ol>

				<?php
				$fix_link = bpges_get_admin_panel_url();
				$fix_link = add_query_arg( 'action', 'migrate_39', $fix_link );
				$fix_link = wp_nonce_url( $fix_link, 'bpges_migrate_39' );
				?>

				<?php if ( ! $status['subscription_migration_in_progress'] && ! $status['queued_items_migration_in_progress'] ) : ?>
					<p><?php esc_html_e( 'If you need to re-run or restart the migration process, you can do so with the following link:', 'buddypress-group-email-subscription' ); ?> <a href="<?php echo esc_url( $fix_link ); ?>">Manually trigger the migration process.</a></p>
				<?php else : ?>
					<p><?php esc_html_e( 'Some migrations are currently in progress. Please reload this page in a few moments.', 'buddypress-group-email-subscription' ); ?></p>
				<?php endif; ?>

				<p><a href="https://github.com/boonebgorges/buddypress-group-email-subscription/wiki/Migrating-to-3.9.0"><?php esc_html_e( 'Learn more about the 3.9 migration process.', 'buddypress-group-email-subscription' ); ?></a></p>

				<style type="text/css">
					.bpges-migration-step:before {
						font-family: "dashicons";
						font-size: 2em;
						margin-left: 8px;
						vertical-align: middle;
					}
					.bpges-migration-step-success:before {
						color: green;
						content: "\f147";
					}
					.bpges-migration-step-failure:before {
						color: red;
						content: "\f158";
					}
					.bpges-migration-step-in-progress:before {
						content: "\f469";
					}
				</style>
			</div>
		<?php endif; ?>

		<form id="ass-admin-settings-form" method="post" action="admin.php?page=ass_admin_options">
		<?php wp_nonce_field( 'ass_admin_settings' ); ?>

		<h3><?php _e( 'Digests & Summaries', 'buddypress-group-email-subscription' ) ?></h3>

		<p><b><a href="<?php bloginfo('url') ?>?sum=1" target="_blank"><?php _e('View queued digest items</a></b> (in new window)<br>As admin, you can see what is currently in the email queue by adding ?sum=1 to your url. This will not fire the digest, it will just show you what is waiting to be sent.', 'buddypress-group-email-subscription') ?><br>
		</p>

		<p>
			<label for="ass_digest_time"><?php _e( '<strong>Daily Digests</strong> should be sent at this time:', 'buddypress-group-email-subscription' ) ?> </label>
			<select name="ass_digest_time[hours]" id="ass_digest_time[hours]">
				<?php for( $i = 0; $i <= 23; $i++ ) : ?>
					<?php if ( $i < 10 ) $i = '0' . $i ?>
					<option value="<?php echo $i?>" <?php if ( $i == $ass_digest_time['hours'] ) : ?>selected="selected"<?php endif; ?>><?php echo $i ?></option>
				<?php endfor; ?>
			</select>

			<select name="ass_digest_time[minutes]" id="ass_digest_time[minutes]">
				<?php for( $i = 0; $i <= 55; $i += 5 ) : ?>
					<?php if ( $i < 10 ) $i = '0' . $i ?>
					<option value="<?php echo $i?>" <?php if ( $i == $ass_digest_time['minutes'] ) : ?>selected="selected"<?php endif; ?>><?php echo $i ?></option>
				<?php endfor; ?>
			</select>
		</p>

		<p>
			<label for="ass_weekly_digest"><?php _e( '<strong>Weekly Summaries</strong> should be sent on:', 'buddypress-group-email-subscription' ) ?> </label>
			<select name="ass_weekly_digest" id="ass_weekly_digest">
				<?php /* disabling "no weekly digest" option for now because it will complicate the individual settings pages */ ?>
				<?php /* <option value="No weekly digest" <?php if ( 'No weekly digest' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'No weekly digest', 'buddypress-group-email-subscription' ) ?></option> */ ?>
				<option value="1" <?php if ( '1' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Monday' ) ?></option>
				<option value="2" <?php if ( '2' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Tuesday' ) ?></option>
				<option value="3" <?php if ( '3' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Wednesday' ) ?></option>
				<option value="4" <?php if ( '4' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Thursday' ) ?></option>
				<option value="5" <?php if ( '5' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Friday' ) ?></option>
				<option value="6" <?php if ( '6' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Saturday' ) ?></option>
				<option value="0" <?php if ( '0' == $ass_weekly_digest ) : ?>selected="selected"<?php endif; ?>><?php _e( 'Sunday' ) ?></option>
			</select>
			<!-- (the summary will be sent one hour after the daily digests) -->
		</p>

		<p><i><?php $weekday = array( __("Sunday"), __("Monday"), __("Tuesday"), __("Wednesday"), __("Thursday"), __("Friday"), __("Saturday") ); echo sprintf( __( 'The server timezone is %s (%s); the current server time is %s (%s); and the day is %s.', 'buddypress-group-email-subscription' ), date( 'T' ), date( 'e' ), date( 'g:ia' ), date( 'H:i' ), $weekday[date( 'w' )] ) ?></i>
		<br>
		<br>

		<h3><?php _e( 'Global Unsubscribe Link', 'buddypress-group-email-subscription' ); ?></h3>
		<p><?php _e( 'Add a link in the emails and on the notifications settings page allowing users to unsubscribe from all their groups at once:', 'buddypress-group-email-subscription' ); ?>
		<?php $global_unsubscribe_link = bp_get_option( 'ass-global-unsubscribe-link' ); ?>
		<input<?php checked( $global_unsubscribe_link, 'yes' ); ?> type="radio" name="ass-global-unsubscribe-link" value="yes"> <?php _e( 'yes', 'buddypress-group-email-subscription' ); ?> &nbsp;
		<input<?php checked( $global_unsubscribe_link, '' ); ?> type="radio" name="ass-global-unsubscribe-link" value=""> <?php _e( 'no', 'buddypress-group-email-subscription' ); ?>
		<br />
		<br />


		<h3><?php _e('Group Admin Abilities', 'buddypress-group-email-subscription'); ?></h3>
		<p><?php _e('Allow group admins and mods to change members\' email subscription settings: ', 'buddypress-group-email-subscription'); ?>
		<?php $admins_can_edit_status = bp_get_option('ass-admin-can-edit-email'); ?>
		<input type="radio" name="ass-admin-can-edit-email" value="yes" <?php if ( $admins_can_edit_status == 'yes' || !$admins_can_edit_status ) echo 'checked="checked"'; ?>> <?php _e('yes', 'buddypress-group-email-subscription') ?> &nbsp;
		<input type="radio" name="ass-admin-can-edit-email" value="no" <?php if ( $admins_can_edit_status == 'no' ) echo 'checked="checked"'; ?>> <?php _e('no', 'buddypress-group-email-subscription') ?>

		<p><?php _e('Allow group admins to override subscription settings and send an email to everyone in their group: ', 'buddypress-group-email-subscription'); ?>
		<?php $admins_can_send_email = bp_get_option('ass-admin-can-send-email'); ?>
		<input type="radio" name="ass-admin-can-send-email" value="yes" <?php if ( $admins_can_send_email == 'yes' || !$admins_can_send_email ) echo 'checked="checked"'; ?>> <?php _e('yes', 'buddypress-group-email-subscription') ?> &nbsp;
		<input type="radio" name="ass-admin-can-send-email" value="no" <?php if ( $admins_can_send_email == 'no' ) echo 'checked="checked"'; ?>> <?php _e('no', 'buddypress-group-email-subscription') ?>

		<br>
		<br>
		<h3><?php _e('Spam Prevention', 'buddypress-group-email-subscription'); ?></h3>
			<p><?php _e('To help protect against spam, you may wish to require a user to have been a member of the site for a certain amount of days before any group updates are emailed to the other group members. This is disabled by default.', 'buddypress-group-email-subscription'); ?> </p>
			<?php _e('Member must be registered for', 'buddypress-group-email-subscription'); ?><input type="text" size="1" name="ass_registered_req" value="<?php echo bp_get_option( 'ass_registered_req' ); ?>" style="text-align:center"/><?php _e('days', 'buddypress-group-email-subscription'); ?></p>


			<p class="submit">
				<input type="submit" value="<?php _e('Save Settings', 'buddypress-group-email-subscription') ?>" id="bp-admin-ass-submit" name="bp-admin-ass-submit" class="button-primary">
			</p>

		</form>

		<hr>
		<form action="https://www.paypal.com/cgi-bin/webscr" method="post" target="_blank">
		<?php echo sprintf( __('If you enjoy using this plugin %s please rate it %s.', 'buddypress-group-email-subscription'), '<a href="http://wordpress.org/extend/plugins/buddypress-group-email-subscription/" target="_blank">', '</a>'); ?><br>
		<?php _e('Please make a donation to the team to support ongoing development.', 'buddypress-group-email-subscription'); ?><br>
		<input type="hidden" name="cmd" value="_s-xclick">
		<input type="hidden" name="hosted_button_id" value="PXD76LU2VQ5AS">
		<input type="image" src="https://www.paypal.com/en_US/i/btn/btn_donate_SM.gif" border="0" name="submit" alt="PayPal - The safer, easier way to pay online!">
		<img alt="" border="0" src="https://www.paypal.com/en_US/i/scr/pixel.gif" width="1" height="1" />

	</div>
	<?php
}

/**
 * Save the back-end admin settings.
 */
function ass_update_dashboard_settings() {
	if ( !check_admin_referer( 'ass_admin_settings' ) )
		return;

	if ( !is_super_admin() )
		return;

	/* The daily digest time has been changed */
	if ( $_POST['ass_digest_time'] )
		ass_set_daily_digest_time( $_POST['ass_digest_time']['hours'], $_POST['ass_digest_time']['minutes'] );

	/* The weekly digest day has been changed */
	if ( $_POST['ass_weekly_digest'] )
		ass_set_weekly_digest_time( $_POST['ass_weekly_digest'] );

	if ( $_POST['ass-global-unsubscribe-link'] != bp_get_option( 'ass-global-unsubscribe-link' ) )
		bp_update_option( 'ass-global-unsubscribe-link', $_POST['ass-global-unsubscribe-link'] );

	if ( $_POST['ass-admin-can-edit-email'] != bp_get_option( 'ass-admin-can-edit-email' ) )
		bp_update_option( 'ass-admin-can-edit-email', $_POST['ass-admin-can-edit-email'] );

	if ( $_POST['ass-admin-can-send-email'] != bp_get_option( 'ass-admin-can-send-email' ) )
		bp_update_option( 'ass-admin-can-send-email', $_POST['ass-admin-can-send-email'] );

	if ( $_POST['ass_registered_req'] != bp_get_option( 'ass_registered_req' ) )
		bp_update_option( 'ass_registered_req', $_POST['ass_registered_req'] );

	return true;
	//echo '<pre>'; print_r( $_POST ); echo '</pre>';
}

/**
 * Manage each group member's email subscription settings from the "Groups"
 * dashboard page.
 *
 * Only works in BP 1.8+.
 *
 * @uses ass_manage_members_email_status()
 */
function ass_groups_admin_manage_member_row( $user_id, $group ) {
	ass_manage_members_email_status( $user_id, $group );
}
add_action( 'bp_groups_admin_manage_member_row', 'ass_groups_admin_manage_member_row', 10, 2 );

/**
 * Install GES emails during email installation routine for BuddyPress.
 *
 * @since 3.7.0
 *
 * @param bool $post_exists_check Should we check to see if our email post types exist before installing?
 *                                Default: true.
 */
function ass_install_emails( $post_exists_check = true ) {
	if ( ! function_exists( 'ass_set_email_type' ) ) {
		require_once( __DIR__ . '/bp-activity-subscription-functions.php' );
	}

	// No need to check if our post types exist.
	if ( ! $post_exists_check ) {
		ass_set_email_type( 'bp-ges-single', false );
		ass_set_email_type( 'bp-ges-digest', false );
		ass_set_email_type( 'bp-ges-notice', false );
		ass_set_email_type( 'bp-ges-welcome', false );

	// Only create email post types if they do not exist.
	} else {
		switch_to_blog( bp_get_root_blog_id() );

		$ges_types = array( 'bp-ges-single', 'bp-ges-digest', 'bp-ges-notice', 'bp-ges-welcome' );

		// Try to fetch email posts with our taxonomy.
		$emails = get_posts( array(
			'fields'           => 'ids',
			'post_status'      => 'publish',
			'post_type'        => bp_get_email_post_type(),
			'posts_per_page'   => 4,
			'suppress_filters' => false,
			'tax_query' => array(
				'relation' => 'OR',
				array(
					'taxonomy' => bp_get_email_tax_type(),
					'field'    => 'slug',
					'terms'    => $ges_types,
				),
			),
		) );

		// See if our taxonomies are attached to our email posts.
		$found = array();
		foreach ( $emails as $post_id ) {
			$tax   = wp_get_object_terms( $post_id, bp_get_email_tax_type(), array( 'fields' => 'slugs' ) );
			$found = array_merge( $found, (array) $tax );
		}

		restore_current_blog();

		// Find out if we need to create any posts.
		$to_create = array_diff( $ges_types, $found );
		if ( empty( $to_create ) ) {
			return;
		}

		// Create posts with our email types.
		if ( ! function_exists( 'ass_set_email_type' ) ) {
			require_once( dirname( __FILE__ ) . '/bp-activity-subscription-functions.php' );
		}
		foreach ( $to_create as $email_type ) {
			ass_set_email_type( $email_type, false );
		}
	}
}
add_action( 'bp_core_install_emails', 'ass_install_emails' );

/**
 * Show admin notice when editing a BP email in the admin dashboard.
 *
 * @since 3.7.0
 */
function ass_bp_email_admin_notice() {
	// Bail if not using BP 2.5 or if not editing a BP email.
	if ( ! function_exists( 'bp_get_email_post_type' ) ) {
		return;
	}
	if ( get_current_screen()->post_type !== bp_get_email_post_type() ) {
		return;
	}

	// Output notice; hidden by default.
	echo '<div id="bp-ges-notice" class="updated" style="display:none;">';
	printf( '<p>%s</p>',
		sprintf(
			__( 'This email is handled by the Group Email Subscription plugin and uses customized tokens.  <a target="_blank" href="%s">Learn more about GES tokens on our wiki</a>.', 'buddypress-group-email-subscription' ),
			esc_url( 'https://github.com/boonebgorges/buddypress-group-email-subscription/wiki/Email-Tokens#tokens' )
		)
	);
	echo '</div>';

	// Inline JS.
	$inline_js = <<<EOD

jQuery( function( $ ) {
	$( '#bp-email-typechecklist input:checked' ).each( function() {
		// If current email is used by GES, show our notice.
		if ( $(this).val().lastIndexOf( 'bp-ges-', 0 ) === 0 ) {
			$( '#bp-ges-notice' ).show();
			return false;
		}
	} );
} );

EOD;

	echo "<script type=\"text/javascript\">{$inline_js}</script>";
}
add_action( 'admin_head-post.php', 'ass_bp_email_admin_notice' );

/**
 * Utility function to check for 3.9 migration status.
 *
 * @since 3.9.0
 *
 * @return array
 */
function bpges_39_migration_status() {
	global $wpdb;

	$retval = array(
		'subscription_table_created' => (bool) bp_get_option( '_ges_39_subscriptions_table_created' ),
		'queued_items_table_created' => (bool) bp_get_option( '_ges_39_queued_items_table_created' ),
		'subscriptions_migrated'     => (bool) bp_get_option( '_ges_39_subscriptions_migrated' ),
		'queued_items_migrated'      => (bool) bp_get_option( '_ges_39_digest_queue_migrated' ),

		'subscription_migration_in_progress' => (bool) bp_get_option( '_ges_39_subscription_migration_in_progress' ),
		'queued_items_migration_in_progress' => (bool) bp_get_option( '_ges_39_digest_queue_migration_in_progress' ),
	);

	return $retval;
}

/**
 * Show admin notices related to BPGES 3.9 migration.
 *
 * @since 3.9.0
 */
function bpges_39_migration_admin_notice() {
	if ( ! current_user_can( bpges_admin_menu_cap() ) ) {
		return;
	}

	// Don't show on BPGES settings panel.
	if ( isset( $_GET['page'] ) && 'ass_admin_options' === $_GET['page'] ) {
		return;
	}

	$status = bpges_39_migration_status();

	if ( $status['subscription_table_created'] && $status['queued_items_table_created'] && $status['subscriptions_migrated'] && $status['queued_items_migrated'] ) {
		return;
	}

	$is_legacy_installation = bpges_is_legacy_installation();
	if ( ! $is_legacy_installation ) {
		return;
	}

	// Output notice; hidden by default.
	echo '<div id="bp-ges-notice" class="error"><p>';
	esc_html_e( 'Some BuddyPress Group Email Subscription migration tasks have not successfully completed.', 'buddypress-group-email-subscription' );
	printf(
		' <a href="%s">%s</a>',
		bpges_get_admin_panel_url(),
		esc_html__( 'Visit the BPGES settings page to fix this problem.', 'buddypress-group-email-subscription' )
	);
	echo '</p></div>';
}
add_action( 'admin_head', 'bpges_39_migration_admin_notice' );

/**
 * Install/update subscription database table.
 *
 * @since 3.9.0
 */
function bpges_install_subscription_table() {
	global $wpdb;

	require_once( ABSPATH . 'wp-admin/includes/upgrade.php' );

	$sql             = array();
	$charset_collate = $wpdb->get_charset_collate();
	$bp_prefix       = bp_core_get_table_prefix();

	$sql[] = "CREATE TABLE {$bp_prefix}bpges_subscriptions (
				id bigint(20) NOT NULL AUTO_INCREMENT PRIMARY KEY,
				user_id bigint(20) NOT NULL,
				group_id bigint(20) NOT NULL,
				type varchar(75) NOT NULL,
				KEY user_id (user_id),
				KEY group_id (group_id),
				KEY user_type (user_id,type)
			) {$charset_collate};";

	dbDelta( $sql );

	if ( $wpdb->get_var( $wpdb->prepare( "SHOW TABLES LIKE %s", "{$bp_prefix}bpges_subscriptions" ) ) ) {
		bp_add_option( '_ges_39_subscriptions_table_created', 1 );
	}
}

/**
 * Install/update queued items database table.
 *
 * @since 3.9.0
 */
function bpges_install_queued_items_table() {
	global $wpdb;

	require_once( ABSPATH . 'wp-admin/includes/upgrade.php' );

	$sql             = array();
	$charset_collate = $wpdb->get_charset_collate();
	$bp_prefix       = bp_core_get_table_prefix();

	$sql[] = "CREATE TABLE {$bp_prefix}bpges_queued_items (
				id bigint(20) NOT NULL AUTO_INCREMENT PRIMARY KEY,
				user_id bigint(20) NOT NULL,
				group_id bigint(20) NOT NULL,
				activity_id bigint(20) NOT NULL,
				type varchar(75) NOT NULL,
				date_recorded datetime NOT NULL default '0000-00-00 00:00:00',
				KEY user_id (user_id),
				KEY group_id (group_id),
				KEY activity_id (activity_id),
				KEY user_group_type_date (user_id,type,date_recorded),
				UNIQUE KEY user_group_activity_type (user_id,group_id,activity_id,type)
			) {$charset_collate};";

	dbDelta( $sql );

	if ( $wpdb->get_var( $wpdb->prepare( "SHOW TABLES LIKE %s", "{$bp_prefix}bpges_queued_items" ) ) ) {
		bp_add_option( '_ges_39_queued_items_table_created', 1 );
	}
}

/**
 * Migrates the legacy subscriptions for a single group.
 *
 * @since 3.9.2
 *
 * @param int $group_id
 */
function bpges_39_migrate_group_subscriptions( $group_id ) {
	$group_subscriptions = groups_get_groupmeta( $group_id, 'ass_subscribed_users', true );

	if ( is_array( $group_subscriptions ) ) {
		foreach ( $group_subscriptions as $user_id => $type ) {
			$query = new BPGES_Subscription_Query( array(
				'user_id'  => $user_id,
				'group_id' => $group_id,
			) );

			$existing = $query->get_results();
			if ( $existing ) {
				// Nothing to migrate.
				groups_update_groupmeta( $group_id, '_ges_subscriptions_migrated', 1 );
				continue;
			}

			$subscription = new BPGES_Subscription();
			$subscription->user_id = $user_id;
			$subscription->group_id = $group_id;
			$subscription->type = $type;
			$subscription->save();
		}
	}

	groups_update_groupmeta( $group_id, '_ges_subscriptions_migrated', 1 );
}
/**

 * Migrates the legacy queued items for a single user.
 *
 * @since 3.9.2
 *
 * @param int $user_id
 */
function bpges_39_migrate_user_queued_items( $user_id ) {
	$user_queues = bp_get_user_meta( $user_id, 'ass_digest_items', true );
	foreach ( $user_queues as $digest_type => $user_groups ) {
		foreach ( $user_groups as $group_id => $activity_ids ) {
			$query = new BPGES_Subscription_Query( array(
				'user_id'  => $user_id,
				'group_id' => $group_id,
			) );

			$existing = $query->get_results();
			if ( ! $existing ) {
				// Nothing to migrate.
				bp_update_user_meta( $user_id, '_ges_digest_queue_migrated', 1 );
				continue;
			}

			$subscription = reset( $existing );

			$to_queue = array();
			foreach ( $activity_ids as $activity_id ) {
				// Don't migrate deleted, stale, or other invalid items.
				if ( ! bp_ges_activity_is_valid_for_digest( $activity_id, $digest_type, $user_id ) ) {
					continue;
				}

				$to_queue[] = array(
					'user_id'       => $user_id,
					'group_id'      => $group_id,
					'activity_id'   => $activity_id,
					'type'          => $digest_type,
					'date_recorded' => date( 'Y-m-d H:i:s' ),
				);
			}

			if ( $to_queue ) {
				BPGES_Queued_Item::bulk_insert( $to_queue );
			}
		}
	}

	// Delete the legacy queue, to avoid double-processing.
	bp_update_user_meta( $user_id, '_ges_digest_queue_migrated', 1 );
}

/**
 * Launch the migration of legacy subscriptions.
 *
 * @since 3.9.0
 */
function bpges_39_launch_legacy_subscription_migration() {
	global $wpdb;

	if ( ! class_exists( 'WP_Background_Process' ) ) {
		require_once( dirname( __FILE__ ) . '/lib/wp-background-processing/wp-background-processing.php' );
	}

	if ( ! class_exists( 'BPGES_Async_Request' ) ) {
		require( dirname( __FILE__ ) . '/classes/class-bpges-async-request.php' );
	}

	if ( ! class_exists( 'BPGES_Async_Request_Subscription_Migrate' ) ) {
		require( dirname( __FILE__ ) . '/classes/class-bpges-async-request-subscription-migrate.php' );
	}

	$process = new BPGES_Async_Request_Subscription_Migrate();
	$process->dispatch();
}

/**
 * Launch the migration of legacy digest queues.
 *
 * @since 3.9.0
 */
function bpges_39_launch_legacy_digest_queue_migration() {
	global $wpdb;

	if ( ! class_exists( 'WP_Background_Process' ) ) {
		require_once( dirname( __FILE__ ) . '/lib/wp-background-processing/wp-background-processing.php' );
	}

	if ( ! class_exists( 'BPGES_Async_Request' ) ) {
		require( dirname( __FILE__ ) . '/classes/class-bpges-async-request.php' );
	}

	if ( ! class_exists( 'BPGES_Async_Request_Digest_Queue_Migrate' ) ) {
		require( dirname( __FILE__ ) . '/classes/class-bpges-async-request-digest-queue-migrate.php' );
	}

	$process = new BPGES_Async_Request_Digest_Queue_Migrate();
	$process->dispatch();
}