← All changes | includes/handler/class-create.php +144 -37 2.1.0 → 8.0.2 View file →

		@@ -1,70 +1,177 @@
1	1	<?php
	2	+/**
	3	+ * Create handler file.
	4	+ *
	5	+ * @package Activitypub
	6	+ */
	7	+
2	8	namespace Activitypub\Handler;
3	9
4		-use WP_Error;
5	10	use Activitypub\Collection\Interactions;
	11	+use Activitypub\Collection\Posts;
	12	+use Activitypub\Tombstone;
6	13
7		-use function Activitypub\is_activity_public;
	14	+use function Activitypub\get_activity_visibility;
	15	+use function Activitypub\is_activity_reply;
	16	+use function Activitypub\is_quote_activity;
	17	+use function Activitypub\is_self_ping;
8	18	use function Activitypub\object_id_to_comment;
9	19
10	20	/**
11		- * Handle Create requests
	21	+ * Handle Create requests.
12	22	*/
13	23	class Create {
14	24	/**
15		- * Initialize the class, registering WordPress hooks
	25	+ * Initialize the class, registering WordPress hooks.
16	26	*/
17	27	public static function init() {
18		- \add_action(
19		- 'activitypub_inbox_create',
20		- array( self::class, 'handle_create' ),
21		- 10,
22		- 3
23		- );
	28	+ \add_action( 'activitypub_handled_inbox_create', array( self::class, 'handle_create' ), 10, 3 );
	29	+ \add_filter( 'activitypub_validate_object', array( self::class, 'validate_object' ), 10, 3 );
	30	+ \add_action( 'post_activitypub_add_to_outbox', array( self::class, 'maybe_unbury' ), 10, 2 );
24	31	}
25	32
26	33	/**
27		- * Handles "Create" requests
	34	+ * Handles "Create" requests.
28	35	*
29		- * @param array $array The activity-object
30		- * @param int $user_id The id of the local blog-user
31		- * @param Activitypub\Activity $object The activity object
	36	+ * @param array $activity The activity-object.
	37	+ * @param int|int[] $user_ids The id(s) of the local blog-user(s).
	38	+ * @param \Activitypub\Activity\Activity $activity_object Optional. The activity object. Default null.
	39	+ */
	40	+ public static function handle_create( $activity, $user_ids, $activity_object = null ) {
	41	+ // Check for private and/or direct messages.
	42	+ if ( ACTIVITYPUB_CONTENT_VISIBILITY_PRIVATE === get_activity_visibility( $activity ) ) {
	43	+ $result = false;
	44	+ } elseif ( is_activity_reply( $activity ) || is_quote_activity( $activity ) ) { // Check for replies and quotes.
	45	+ $result = self::create_interaction( $activity, $user_ids, $activity_object );
	46	+ } else { // Handle non-interaction objects.
	47	+ $result = self::create_post( $activity, $user_ids, $activity_object );
	48	+ }
	49	+
	50	+ if ( false === $result ) {
	51	+ return;
	52	+ }
	53	+
	54	+ $success = ! \is_wp_error( $result );
	55	+
	56	+ /**
	57	+ * Fires after an ActivityPub Create activity has been handled.
	58	+ *
	59	+ * @param array $activity The ActivityPub activity data.
	60	+ * @param int[] $user_ids The local user IDs.
	61	+ * @param bool $success True on success, false otherwise.
	62	+ * @param \WP_Comment|\WP_Post|\WP_Error $result The WP_Comment object of the created comment, or null if creation failed.
	63	+ */
	64	+ \do_action( 'activitypub_handled_create', $activity, (array) $user_ids, $success, $result );
	65	+ }
	66	+
	67	+ /**
	68	+ * Handle interactions like replies.
32	69	*
33		- * @return void
	70	+ * @param array $activity The activity-object.
	71	+ * @param int[] $user_ids The ids of the local blog-users.
	72	+ * @param \Activitypub\Activity\Activity $activity_object Optional. The activity object. Default null.
	73	+ *
	74	+ * @return \WP_Comment|\WP_Error|false The created comment, WP_Error on failure, false if already exists or not processed.
34	75	*/
35		- public static function handle_create( $array, $user_id, $object = null ) {
36		- if ( ACTIVITYPUB_DISABLE_INCOMING_INTERACTIONS ) {
37		- return;
	76	+ public static function create_interaction( $activity, $user_ids, $activity_object = null ) {
	77	+ $existing_comment = object_id_to_comment( $activity['object']['id'] );
	78	+
	79	+ // If comment exists, call update action.
	80	+ if ( $existing_comment ) {
	81	+ Update::handle_update( $activity, (array) $user_ids, $activity_object );
	82	+
	83	+ return false;
38	84	}
39	85
40		- if (
41		- ! isset( $array['object'] ) ||
42		- ! isset( $array['object']['id'] )
43		- ) {
44		- return;
	86	+ if ( is_self_ping( $activity['object']['id'] ) ) {
	87	+ return false;
45	88	}
46	89
47		- // check if Activity is public or not
48		- if ( ! is_activity_public( $array ) ) {
49		- // @todo maybe send email
50		- return;
	90	+ $result = Interactions::add_comment( $activity );
	91	+
	92	+ if ( ! $result || \is_wp_error( $result ) ) {
	93	+ return $result;
51	94	}
52	95
53		- $check_dupe = object_id_to_comment( $array['object']['id'] );
	96	+ return \get_comment( $result );
	97	+ }
54	98
55		- // if comment exists, call update action
56		- if ( $check_dupe ) {
57		- \do_action( 'activitypub_inbox_update', $array, $user_id, $object );
	99	+ /**
	100	+ * Handle non-interaction posts like posts.
	101	+ *
	102	+ * @param array $activity The activity-object.
	103	+ * @param int[] $user_ids The ids of the local blog-users.
	104	+ * @param \Activitypub\Activity\Activity $activity_object Optional. The activity object. Default null.
	105	+ *
	106	+ * @return \WP_Post|\WP_Error|false The post on success, WP_Error on failure, false if already exists.
	107	+ */
	108	+ public static function create_post( $activity, $user_ids, $activity_object = null ) {
	109	+ if ( ! \get_option( 'activitypub_create_posts', false ) ) {
	110	+ return false;
	111	+ }
	112	+
	113	+ $existing_post = Posts::get_by_guid( $activity['object']['id'] );
	114	+
	115	+ // If post exists, call update action.
	116	+ if ( $existing_post instanceof \WP_Post ) {
	117	+ Update::handle_update( $activity, (array) $user_ids, $activity_object );
	118	+
	119	+ return false;
	120	+ }
	121	+
	122	+ return Posts::add( $activity, $user_ids );
	123	+ }
	124	+
	125	+ /**
	126	+ * Validate the object.
	127	+ *
	128	+ * @param bool $valid The validation state.
	129	+ * @param string $param The object parameter.
	130	+ * @param \WP_REST_Request $request The request object.
	131	+ *
	132	+ * @return bool The validation state: true if valid, false if not.
	133	+ */
	134	+ public static function validate_object( $valid, $param, $request ) {
	135	+ $activity = $request->get_json_params();
	136	+
	137	+ if ( empty( $activity['type'] ) ) {
	138	+ return false;
	139	+ }
	140	+
	141	+ if ( 'Create' !== $activity['type'] ) {
	142	+ return $valid;
	143	+ }
	144	+
	145	+ if ( ! isset( $activity['object'] ) || ! \is_array( $activity['object'] ) ) {
	146	+ return false;
	147	+ }
	148	+
	149	+ if ( ! isset( $activity['object']['id'], $activity['object']['content'] ) ) {
	150	+ return false;
	151	+ }
	152	+
	153	+ return $valid;
	154	+ }
	155	+
	156	+ /**
	157	+ * Remove a URL from the tombstone registry when a Create or Update activity is sent.
	158	+ *
	159	+ * This handles the case where a post was soft-deleted (visibility changed to local/private)
	160	+ * and then later changed back to public. The Create/Update activity indicates the post is being
	161	+ * re-federated, so we remove it from the tombstone registry.
	162	+ *
	163	+ * @param int $outbox_id The ID of the outbox activity.
	164	+ * @param \Activitypub\Activity\Activity $activity The Activity object.
	165	+ */
	166	+ public static function maybe_unbury( $outbox_id, $activity ) {
	167	+ if ( ! in_array( $activity->get_type(), array( 'Create', 'Update' ), true ) ) {
58	168	return;
59	169	}
60	170
61		- $state = Interactions::add_comment( $array );
62		- $reaction = null;
	171	+ $object = $activity->get_object();
63	172
64		- if ( $state && ! \is_wp_error( $reaction ) ) {
65		- $reaction = \get_comment( $state );
	173	+ if ( $object ) {
	174	+ Tombstone::remove( $object->get_id(), $object->get_url() );
66	175	}
67		-
68		- \do_action( 'activitypub_handled_create', $array, $user_id, $state, $reaction );
69	176	}
70	177	}