Add/User Delete activities

includes/class-activity-dispatcher.php

@@ -7,7 +7,7 @@
 use Activitypub\Collection\Users;
 use Activitypub\Collection\Followers;
 use Activitypub\Transformer\Factory;
-use Activitypub\Transformer\Post;
+use Activitypub\Application;
 use Activitypub\Transformer\Comment;
 
 use function Activitypub\is_single_user;
@@ -33,6 +33,7 @@ public static function init() {
 		\add_action( 'activitypub_send_activity', array( self::class, 'send_activity' ), 10, 2 );
 		\add_action( 'activitypub_send_activity', array( self::class, 'send_activity_or_announce' ), 10, 2 );
 		\add_action( 'activitypub_send_update_profile_activity', array( self::class, 'send_profile_update' ), 10, 1 );
+		\add_action( 'activitypub_send_server_activity', array( self::class, 'send_server_activity' ), 10, 2 );
 	}
 
 	/**
@@ -174,8 +175,21 @@ private static function send_activity_to_followers( $activity, $user_id, $wp_obj
 		foreach ( $inboxes as $inbox ) {
 			safe_remote_post( $inbox, $json, $user_id );
 		}
+	}
 
-		set_wp_object_state( $wp_object, 'federated' );
+	/**
+	 * Send an Activity to all known (shared_)inboxes.
+	 *
+	 * @param Activity $activity The ActivityPub Activity.
+	 *
+	 * @return void
+	 */
+	public static function send_server_activity( $activity, $user_id = Users::APPLICATION_USER_ID ) {
+		$json = $activity->to_json();
+		$inboxes = Application::known_inboxes();
+		foreach ( $inboxes as $inbox ) {
+			safe_remote_post( $inbox, $json, $user_id );
+		}
 	}
 
 	/**

includes/class-application.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace Activitypub;
+
+use Activitypub\Collection\Followers;
+use Activitypub\Collection\Users;
+
+use function Activitypub\is_user_disabled;
+
+/**
+ * ActivityPub Application Class
+ *
+ * @author Django Doucet
+ */
+class Application {
+
+	public static function known_inboxes() {
+		$authors = get_users(
+			array(
+				'capability' => 'publish_posts',
+			)
+		);
+		$follower_inboxes_all = [];
+		foreach ( $authors as $user ) {
+			$follower_inboxes = Followers::get_inboxes( $user->ID );
+			$follower_inboxes_all = array_merge( $follower_inboxes, $follower_inboxes_all );
+		}
+		if ( ! is_user_disabled( Users::BLOG_USER_ID ) ) {
+			$follower_inboxes = Followers::get_inboxes( Users::BLOG_USER_ID );
+			$follower_inboxes_all = array_merge( $follower_inboxes, $follower_inboxes_all );
+		}
+		return array_unique( array_filter( $follower_inboxes_all ) );
+	}
+}

includes/class-scheduler.php

@@ -5,9 +5,11 @@
 use Activitypub\Transformer\Post;
 use Activitypub\Collection\Users;
 use Activitypub\Collection\Followers;
+use Activitypub\Activity\Activity;
 
-use function Activitypub\was_comment_sent;
+use function Activitypub\get_private_key_for;
 use function Activitypub\is_user_type_disabled;
+use function Activitypub\was_comment_sent;
 use function Activitypub\should_comment_be_federated;
 use function Activitypub\get_remote_metadata_by_actor;
 
@@ -63,6 +65,7 @@ function ( $comment_id ) {
 		// Follower Cleanups
 		\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' ) );
 
 		// profile updates for blog options
 		if ( ! is_user_type_disabled( 'blog' ) ) {
@@ -75,6 +78,8 @@ function ( $comment_id ) {
 
 		// profile updates for user options
 		if ( ! is_user_type_disabled( 'user' ) ) {
+			\add_action( 'delete_user', array( self::class, 'schedule_profile_delete' ), 10, 3 );
+			\add_action( 'deleted_user', array( self::class, 'schedule_user_delete' ), 10, 3 );
 			\add_action( 'wp_update_user', array( self::class, 'user_update' ) );
 			\add_action( 'updated_user_meta', array( self::class, 'user_meta_update' ), 10, 3 );
 			// @todo figure out a feasible way of updating the header image since it's not unique to any user.
@@ -330,4 +335,38 @@ public static function schedule_profile_update( $user_id ) {
 			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' ) ) {
+			$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_delete( $user_id ) {
+		$user = get_userdata( $user_id );
+		if ( $user->has_cap( 'publish_posts' ) ) {
+			delete_option( 'activitypub_temp_sig_' . $user_id );
+		}
+	}
 }

includes/class-signature.php

@@ -186,7 +186,11 @@ protected static function check_legacy_key_pair_for( $user_id ) {
 	 */
 	public static function generate_signature( $user_id, $http_method, $url, $date, $digest = null ) {
 		$user = Users::get_by_id( $user_id );
-		$key  = self::get_private_key_for( $user->get__id() );
+		if ( ! is_wp_error( $user ) ) {
+			$key = self::get_private_key_for( $user->get__id() );
+		} else {
+			$key = get_option( 'activitypub_temp_sig_' . $user_id, true );
+		}
 
 		$url_parts = \wp_parse_url( $url );