Ticket #3395: 3395.diff

includes/extend/akismet.php

@@ -68 +68 @@
                 // Update post meta
                 add_action( 'wp_insert_post', array( $this, 'update_post_meta' ), 10, 2 );
 
+                // Cleanup
+                add_action( 'akismet_scheduled_delete', array( $this, 'delete_old_spam' ) );
+                add_action( 'akismet_scheduled_delete', array( $this, 'delete_old_spam_meta' ) );
+                add_action( 'akismet_scheduled_delete', array( $this, 'delete_orphaned_spam_meta' ) );
+                /**
+                 * The above will need to be scheduled with something like:
+                 * if ( ! wp_next_scheduled( 'akismet_scheduled_delete' ) ) {
+                 *      wp_schedule_event( time(), 'daily', 'akismet_scheduled_delete' );
+                 * }
+                 */
+                 
+
                 // Admin
                 if ( is_admin() ) {
                         add_action( 'add_meta_boxes', array( $this, 'add_metaboxes' ) );
@@ -811 +823 @@
 
                 <?php
         }
+
+        /**
+         * Delete old spam topics and replies from the queue after a few days (determined by `_bbp_akismet_delete_spam_interval` filter)
+         *
+         * @since 2.7.0 bbPress
+         */
+        public function delete_old_spam() {
+                global $wpdb;
+
+                /**
+                 * Determines how many posts will be deleted in each batch.
+                 *
+                 * @param int The default, as defined by AKISMET_DELETE_LIMIT (also used in AK WP plugin).
+                 */
+                $delete_limit = apply_filters( '_bbp_akismet_delete_spam_limit', defined( 'AKISMET_DELETE_LIMIT' ) ? AKISMET_DELETE_LIMIT : 10000 );
+                $delete_limit = max( 1, intval( $delete_limit ) );
+
+                /**
+                 * Determines how many days a piece of spam will be left in the Spam queue before being deleted.
+                 *
+                 * @param int The default number of days.
+                 */
+                $delete_interval = apply_filters( '_bbp_akismet_delete_spam_interval', 15 );
+                $delete_interval = max( 1, intval( $delete_interval ) );
+
+                while ( $spam_ids = $wpdb->get_col( $wpdb->prepare( "SELECT id FROM {$wpdb->posts} WHERE post_type IN ('topic', 'reply') AND post_status = 'spam' AND DATE_SUB(NOW(), INTERVAL %d DAY) > post_date_gmt LIMIT %d", $delete_interval, $delete_limit ) ) ) {
+                        if ( empty( $spam_ids ) )
+                                return;
+
+                        $wpdb->queries = array();
+
+                        foreach ( $spam_ids as $spam_id ) {
+                                // Maybe we should run the bbp_delete_topic or bbp_delete_reply actions too?
+                                do_action( '_bbp_akismet_batch_delete_count', __FUNCTION__ );
+                        }
+
+                        // Prepared as strings since id is an unsigned BIGINT, and using %d will constrain the value to the maximum signed BIGINT.
+                        $format_string = implode( ", ", array_fill( 0, count( $spam_ids ), '%s' ) );
+
+                        $wpdb->query( $wpdb->prepare( "DELETE FROM {$wpdb->posts} WHERE post_id IN ( " . $format_string . " )", $spam_ids ) );
+                        $wpdb->query( $wpdb->prepare( "DELETE FROM {$wpdb->postmeta} WHERE post_id IN ( " . $format_string . " )", $spam_ids ) );
+
+                        clean_post_cache( $spam_ids );
+                        do_action( '_bbp_akismet_delete_spam_batch', count( $spam_ids ) );
+                }
+
+                if ( apply_filters( '_bbp_akismet_optimize_table', ( mt_rand(1, 5000) == 11), $wpdb->posts ) ) // lucky number
+                        $wpdb->query("OPTIMIZE TABLE {$wpdb->posts}");
+        }
+
+        /**
+         * Delete the `_bbp_akismet_as_submitted` meta keys after a while, since they are large and not useful in the long term.
+         *
+         * @since 2.7.0 bbPress
+         */
+        public function delete_old_spam_meta() {
+                global $wpdb;
+
+                $interval = apply_filters( '_bbp_akismet_delete_spam_meta_interval', 15 );
+
+                # enforce a minimum of 1 day
+                $interval = absint( $interval );
+                if ( $interval < 1 )
+                        $interval = 1;
+
+                // akismet_as_submitted meta values are large, so expire them
+                // after $interval days regardless of the spam status
+                while ( $spam_ids = $wpdb->get_col( $wpdb->prepare( "SELECT m.post_id FROM {$wpdb->postmeta} as m INNER JOIN {$wpdb->posts} as p ON m.post_id = p.id WHERE m.meta_key = '_bbp_akismet_as_submitted' AND DATE_SUB(NOW(), INTERVAL %d DAY) > p.post_date_gmt LIMIT 10000", $interval ) ) ) {
+                        if ( empty( $spam_ids ) )
+                                return;
+
+                        $wpdb->queries = array();
+
+                        foreach ( $spam_ids as $spam_id ) {
+                                delete_post_meta( $spam_id, '_bbp_akismet_as_submitted' );
+                                do_action( '_bbp_akismet_batch_delete_count', __FUNCTION__ );
+                        }
+
+                        do_action( '_bbp_akismet_delete_spam_meta_batch', count( $spam_ids ) );
+                }
+
+                if ( apply_filters( '_bbp_akismet_optimize_table', ( mt_rand(1, 5000) == 11), $wpdb->postmeta ) ) // lucky number
+                        $wpdb->query("OPTIMIZE TABLE {$wpdb->postmeta}");
+        }
+
+        /**
+         * Clear out posts meta that no longer have corresponding posts in the database
+         *
+         * @since 2.7.0 bbPress
+         */
+        public function delete_orphaned_spam_meta() {
+                global $wpdb;
+
+                $last_meta_id = 0;
+                $start_time = isset( $_SERVER['REQUEST_TIME_FLOAT'] ) ? $_SERVER['REQUEST_TIME_FLOAT'] : microtime( true );
+                $max_exec_time = max( ini_get('max_execution_time') - 5, 3 );
+
+                while ( $spam_meta_results = $wpdb->get_results( $wpdb->prepare( "SELECT m.meta_id, m.post_id, m.meta_key FROM {$wpdb->postmeta} as m LEFT JOIN {$wpdb->posts} as p ON m.post_id = p.id WHERE p.id IS NULL AND m.meta_id > %d ORDER BY m.meta_id LIMIT 1000", $last_meta_id ) ) ) {
+                        if ( empty( $spam_meta_results ) )
+                                return;
+
+                        $wpdb->queries = array();
+
+                        $spam_meta_deleted = 0;
+
+                        foreach ( $spam_meta_results as $spam_meta ) {
+                                if ( 'akismet_' == substr( $spam_meta->meta_key, 0, 8 ) ) {
+                                        delete_post_meta( $spam_meta->post_id, $spam_meta->meta_key );
+                                        do_action( '_bbp_akismet_batch_delete_count', __FUNCTION__ );
+                                        $spam_meta_deleted++;
+                                }
+
+                                $last_meta_id = $spam_meta->meta_id;
+                        }
+
+                        do_action( '_bbp_akismet_delete_spam_meta_batch', $spam_meta_deleted );
+
+                        // If we're getting close to max_execution_time, quit for this round.
+                        if ( microtime(true) - $start_time > $max_exec_time )
+                                return;
+                }
+
+                if ( apply_filters( '_bbp_akismet_optimize_table', ( mt_rand(1, 5000) == 11), $wpdb->postmeta ) ) // lucky number
+                        $wpdb->query("OPTIMIZE TABLE {$wpdb->postmeta}");
+        }
 }
 endif;