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_profile_delete( $user_id ) { $user = get_userdata( $user_id ); if ( $user->has_cap( 'publish_posts' ) ) { $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 ) ); } } }