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 ); } }