315 lines
8.5 KiB
PHP
315 lines
8.5 KiB
PHP
<?php
|
|
|
|
namespace Activitypub;
|
|
|
|
use Activitypub\Collection\Users;
|
|
use Activitypub\Collection\Followers;
|
|
use Activitypub\Transformer\Post;
|
|
use Activitypub\Activity\Activity;
|
|
|
|
use function Activitypub\get_private_key_for;
|
|
use function Activitypub\is_user_type_disabled;
|
|
|
|
/**
|
|
* 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' ) );
|
|
|
|
\add_action( 'activitypub_delete_remote_actor_comments', array( self::class, 'schedule_delete_remote_actor_comments' ), 10, 3 );
|
|
\add_action( 'activitypub_delete_remote_actor_comment', array( self::class, 'schedule_delete_comments' ), 10, 1 );
|
|
|
|
// profile updates for blog options
|
|
if ( ! is_user_type_disabled( 'blog' ) ) {
|
|
\add_action( 'update_option_site_icon', array( self::class, 'blog_user_update' ) );
|
|
\add_action( 'update_option_blogdescription', array( self::class, 'blog_user_update' ) );
|
|
\add_action( 'update_option_blogname', array( self::class, 'blog_user_update' ) );
|
|
\add_filter( 'pre_set_theme_mod_custom_logo', array( self::class, 'blog_user_update' ) );
|
|
\add_filter( 'pre_set_theme_mod_header_image', array( self::class, 'blog_user_update' ) );
|
|
}
|
|
|
|
// profile updates for user options
|
|
if ( ! is_user_type_disabled( 'user' ) ) {
|
|
\add_action( 'updated_user_meta', array( self::class, 'user_update' ), 10, 3 );
|
|
// @todo figure out a feasible way of updating the header image since it's not unique to any user.
|
|
|
|
\add_action( 'delete_user', array( self::class, 'schedule_user_delete' ), 10, 3 );
|
|
\add_action( 'deleted_user', array( self::class, 'schedule_user_deleted' ), 10, 3 );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 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' );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 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;
|
|
}
|
|
|
|
$type = false;
|
|
|
|
if ( 'publish' === $new_status && 'publish' !== $old_status ) {
|
|
$type = 'Create';
|
|
} elseif ( 'publish' === $new_status ) {
|
|
$type = 'Update';
|
|
} elseif ( 'trash' === $new_status ) {
|
|
$type = 'Delete';
|
|
}
|
|
|
|
if ( ! $type ) {
|
|
return;
|
|
}
|
|
|
|
\wp_schedule_single_event(
|
|
\time(),
|
|
'activitypub_send_activity',
|
|
array( $post, $type )
|
|
);
|
|
|
|
\wp_schedule_single_event(
|
|
\time(),
|
|
sprintf(
|
|
'activitypub_send_%s_activity',
|
|
\strtolower( $type )
|
|
),
|
|
array( $post )
|
|
);
|
|
}
|
|
|
|
/**
|
|
* 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 ) ) {
|
|
Followers::add_error( $follower->get__id(), $meta );
|
|
} else {
|
|
$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 );
|
|
|
|
if ( is_tombstone( $meta ) ) {
|
|
$follower->delete();
|
|
} elseif ( empty( $meta ) || ! is_array( $meta ) || is_wp_error( $meta ) ) {
|
|
if ( $follower->count_errors() >= 5 ) {
|
|
$follower->delete();
|
|
} else {
|
|
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' );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Send a profile update when relevant user meta is updated.
|
|
*
|
|
* @param int $meta_id Meta ID being updated.
|
|
* @param int $user_id User ID being updated.
|
|
* @param string $meta_key Meta key being updated.
|
|
* @return void
|
|
*/
|
|
public static function user_update( $meta_id, $user_id, $meta_key ) {
|
|
// don't bother if the user can't publish
|
|
if ( ! \user_can( $user_id, 'publish_posts' ) ) {
|
|
return;
|
|
}
|
|
// the user meta fields that affect a profile.
|
|
$fields = array(
|
|
'activitypub_user_description',
|
|
'description',
|
|
'user_url',
|
|
'display_name',
|
|
);
|
|
if ( in_array( $meta_key, $fields, true ) ) {
|
|
self::schedule_profile_update( $user_id );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Theme mods only have a dynamic filter so we fudge it like this.
|
|
* @param mixed $value
|
|
* @return mixed
|
|
*/
|
|
public static function blog_user_update( $value = null ) {
|
|
self::schedule_profile_update( 0 );
|
|
return $value;
|
|
}
|
|
|
|
/**
|
|
* Send a profile update to all followers. Gets hooked into all relevant options/meta etc.
|
|
* @param int $user_id The user ID to update (Could be 0 for Blog-User).
|
|
*/
|
|
public static function schedule_profile_update( $user_id ) {
|
|
\wp_schedule_single_event(
|
|
\time(),
|
|
'activitypub_send_update_profile_activity',
|
|
array( $user_id )
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Send an Actor Delete activity.
|
|
* @param int $user_id The user ID to Delete.
|
|
*/
|
|
public static function schedule_user_delete( $user_id ) {
|
|
$user = get_userdata( $user_id );
|
|
if ( $user->has_cap( 'publish_posts' ) ) {
|
|
$temp_private_key = get_private_key_for( $user->ID );
|
|
add_option( 'activitypub_temp_sig_' . $user->ID, $temp_private_key );
|
|
|
|
$author_url = \get_author_posts_url( $user->ID );
|
|
|
|
$activity = new Activity();
|
|
$activity->set_id( $author_url . '#delete' );
|
|
$activity->set_type( 'Delete' );
|
|
$activity->set_actor( $author_url );
|
|
$activity->set_object( $author_url );
|
|
$activity->set_to( [ 'https://www.w3.org/ns/activitystreams#Public' ] );
|
|
|
|
\wp_schedule_single_event(
|
|
\time(),
|
|
'activitypub_send_server_activity',
|
|
array( $activity, $user_id )
|
|
);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Delete actor related options.
|
|
* @param int $user_id The deleted user ID.
|
|
*/
|
|
public static function schedule_user_deleted( $user_id ) {
|
|
$user = get_userdata( $user_id );
|
|
error_log( 'schedule_user_delete: ' . print_r( $user, true ) );
|
|
if ( $user->has_cap( 'publish_posts' ) ) {
|
|
delete_option( 'activitypub_temp_sig_' . $user_id );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Delete actor related comments.
|
|
* @param string $comment_author_url The deleted actor ID.
|
|
*/
|
|
public static function schedule_delete_remote_actor_comments( $actor ) {
|
|
$args = array(
|
|
'user_id' => 0,
|
|
'author_url' => $actor,
|
|
'meta_query' => array(
|
|
array(
|
|
'key' => 'protocol',
|
|
'value' => 'activitypub',
|
|
'compare' => '=',
|
|
),
|
|
),
|
|
);
|
|
$remote_comments_query = new WP_Comment_Query( $args );
|
|
foreach ( $remote_comments_query->comments as $comment ) {
|
|
\wp_schedule_single_event(
|
|
\time(),
|
|
'activitypub_delete_remote_actor_comment',
|
|
array( $comment->comment_ID )
|
|
);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Delete comments.
|
|
* @param string $comment_id The ID of the comment to delete.
|
|
*/
|
|
public static function schedule_delete_comments( $comment_id ) {
|
|
wp_delete_comment( $comment_id );
|
|
}
|
|
}
|