Outbox: Process first batch right away (#1334)

Helps with cutting down the number of events the need processing.

Author: obenland

CHANGELOG.md

@@ -11,6 +11,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 * Setting to adjust the number of days Outbox items are kept before being purged.
 
+### Changed
+
+* Outbox now precesses the first batch of followers right away to avoid delays in processing new Activities.
+
 ### Fixed
 
 * The Outbox purging routine no longer is limited to deleting 5 items at a time.

includes/class-dispatcher.php

@@ -90,15 +90,11 @@ public static function process_outbox( $id ) {
 		self::send_to_interactees( $activity, $actor->get__id(), $outbox_item );
 
 		if ( self::should_send_to_followers( $activity, $actor, $outbox_item ) ) {
-			\wp_schedule_single_event(
-				\time(),
-				'activitypub_async_batch',
-				array(
-					self::$callback,
-					$outbox_item->ID,
-					self::$batch_size,
-					\get_post_meta( $outbox_item->ID, '_activitypub_outbox_offset', true ) ?: 0, // phpcs:ignore
-				)
+			Scheduler::async_batch(
+				self::$callback,
+				$outbox_item->ID,
+				self::$batch_size,
+				\get_post_meta( $outbox_item->ID, '_activitypub_outbox_offset', true ) ?: 0 // phpcs:ignore
 			);
 		} else {
 			// No followers to process for this update. We're done.

readme.txt

@@ -134,6 +134,7 @@ For reasons of data protection, it is not possible to see the followers of other
 * Added: Allow Activities on URLs instead of requiring Activity-Objects. This is useful especially for sending Announces and Likes.
 * Added: Undo API for Outbox items.
 * Added: Setting to adjust the number of days Outbox items are kept before being purged.
+* Changed: Outbox now precesses the first batch of followers right away to avoid delays in processing new Activities.
 * Fixed: The Outbox purging routine no longer is limited to deleting 5 items at a time.
 * Fixed an issue where the outbox could not send object types other than `Base_Object` (introduced in 5.0.0).
 

tests/includes/class-test-dispatcher.php

@@ -93,17 +93,7 @@ public function test_process_outbox() {
 
 		Dispatcher::process_outbox( $outbox_item->ID );
 
-		$this->assertNotFalse(
-			wp_next_scheduled(
-				'activitypub_async_batch',
-				array(
-					Dispatcher::$callback,
-					$outbox_item->ID,
-					Dispatcher::$batch_size,
-					0,
-				)
-			)
-		);
+		$this->assertEquals( 'publish', \get_post( $outbox_item->ID )->post_status );
 
 		remove_filter( 'activitypub_send_activity_to_followers', $test_callback );
 	}