wordpress-activitypub/includes/class-scheduler.php

170 lines
4 KiB
PHP
Raw Normal View History

<?php
namespace Activitypub;
2023-07-03 11:20:44 +02:00
use Activitypub\Collection\Users;
use Activitypub\Collection\Followers;
2023-07-03 19:52:54 +02:00
use Activitypub\Transformer\Post;
/**
* ActivityPub Scheduler Class
*
* @author Matthias Pfefferle
*/
class Scheduler {
/**
* Initialize the class, registering WordPress hooks
*/
public static function init() {
\add_action( 'transition_post_status', array( self::class, 'schedule_post_activity' ), 33, 3 );
\add_action( 'activitypub_update_followers', array( self::class, 'update_followers' ) );
\add_action( 'activitypub_cleanup_followers', array( self::class, 'cleanup_followers' ) );
\add_action( 'admin_init', array( self::class, 'schedule_migration' ) );
}
2023-05-10 14:55:10 +02:00
/**
* Schedule all ActivityPub schedules.
*
* @return void
*/
public static function register_schedules() {
if ( ! \wp_next_scheduled( 'activitypub_update_followers' ) ) {
\wp_schedule_event( time(), 'hourly', 'activitypub_update_followers' );
}
if ( ! \wp_next_scheduled( 'activitypub_cleanup_followers' ) ) {
\wp_schedule_event( time(), 'daily', 'activitypub_cleanup_followers' );
}
}
2023-05-10 14:55:10 +02:00
/**
* Unscedule all ActivityPub schedules.
*
* @return void
*/
public static function deregister_schedules() {
wp_unschedule_hook( 'activitypub_update_followers' );
wp_unschedule_hook( 'activitypub_cleanup_followers' );
}
/**
* Schedule Activities.
*
* @param string $new_status New post status.
* @param string $old_status Old post status.
* @param WP_Post $post Post object.
*/
public static function schedule_post_activity( $new_status, $old_status, $post ) {
// Do not send activities if post is password protected.
if ( \post_password_required( $post ) ) {
return;
}
// Check if post-type supports ActivityPub.
$post_types = \get_post_types_by_support( 'activitypub' );
if ( ! \in_array( $post->post_type, $post_types, true ) ) {
return;
}
2023-06-29 19:10:49 +02:00
$type = false;
2023-06-14 15:02:45 +02:00
if ( 'publish' === $new_status && 'publish' !== $old_status ) {
2023-06-29 19:10:49 +02:00
$type = 'Create';
} elseif ( 'publish' === $new_status ) {
2023-06-29 19:10:49 +02:00
$type = 'Update';
2023-06-14 15:02:45 +02:00
} elseif ( 'trash' === $new_status ) {
2023-06-29 19:10:49 +02:00
$type = 'Delete';
2023-06-14 15:02:45 +02:00
}
2023-06-29 19:10:49 +02:00
if ( ! $type ) {
2023-06-21 15:45:03 +02:00
return;
}
2023-06-21 15:45:03 +02:00
2023-06-30 16:08:28 +02:00
\wp_schedule_single_event(
\time(),
'activitypub_send_activity',
2023-07-03 17:59:42 +02:00
array( $post, $type )
2023-06-30 16:08:28 +02:00
);
\wp_schedule_single_event(
\time(),
sprintf(
'activitypub_send_%s_activity',
\strtolower( $type )
),
2023-07-03 17:59:42 +02:00
array( $post )
2023-06-30 16:08:28 +02:00
);
}
/**
* Update followers
*
* @return void
*/
public static function update_followers() {
$number = 5;
if ( defined( 'DISABLE_WP_CRON' ) && DISABLE_WP_CRON ) {
$number = 50;
}
$followers = Followers::get_outdated_followers( $number );
foreach ( $followers as $follower ) {
$meta = get_remote_metadata_by_actor( $follower->get_url(), false );
if ( empty( $meta ) || ! is_array( $meta ) || is_wp_error( $meta ) ) {
2023-07-06 14:42:18 +02:00
Followers::add_error( $follower->get__id(), $meta );
} else {
2023-07-06 14:42:18 +02:00
$follower->from_array( $meta );
$follower->update();
}
}
}
/**
* Cleanup followers
*
* @return void
*/
public static function cleanup_followers() {
$number = 5;
if ( defined( 'DISABLE_WP_CRON' ) && DISABLE_WP_CRON ) {
$number = 50;
}
$followers = Followers::get_faulty_followers( $number );
foreach ( $followers as $follower ) {
$meta = get_remote_metadata_by_actor( $follower->get_url(), false );
2023-05-10 17:21:59 +02:00
if ( is_tombstone( $meta ) ) {
$follower->delete();
} elseif ( empty( $meta ) || ! is_array( $meta ) || is_wp_error( $meta ) ) {
2023-07-28 10:28:55 +02:00
if ( $follower->count_errors() >= 5 ) {
$follower->delete();
} else {
2023-07-06 14:42:18 +02:00
Followers::add_error( $follower->get__id(), $meta );
}
} else {
$follower->reset_errors();
}
}
}
/**
* Schedule migration if DB-Version is not up to date.
*
* @return void
*/
public static function schedule_migration() {
if ( ! \wp_next_scheduled( 'activitypub_schedule_migration' ) && ! Migration::is_latest_version() ) {
\wp_schedule_single_event( \time(), 'activitypub_schedule_migration' );
}
}
}