activitypub / includes / rest / class-outbox.php

class-outbox.php in ActivityPub 4.0.2, at includes/rest/class-outbox.php

169 lines 4.5 KB

Raw Download Zip

1	<?php
2	/**
3	* Outbox REST-Class file.
4	*
5	* @package Activitypub
6	*/
7
8	namespace Activitypub\Rest;
9
10	use stdClass;
11	use WP_REST_Server;
12	use WP_REST_Response;
13	use Activitypub\Activity\Activity;
14	use Activitypub\Collection\Users as User_Collection;
15	use Activitypub\Transformer\Factory;
16
17	use function Activitypub\get_context;
18	use function Activitypub\get_rest_url_by_path;
19	use function Activitypub\get_masked_wp_version;
20
21	/**
22	* ActivityPub Outbox REST-Class.
23	*
24	* @author Matthias Pfefferle
25	*
26	* @see https://www.w3.org/TR/activitypub/#outbox
27	*/
28	class Outbox {
29	/**
30	* Initialize the class, registering WordPress hooks.
31	*/
32	public static function init() {
33	self::register_routes();
34	}
35
36	/**
37	* Register routes
38	*/
39	public static function register_routes() {
40	\register_rest_route(
41	ACTIVITYPUB_REST_NAMESPACE,
42	'/(users\|actors)/(?P<user_id>[\w\-\.]+)/outbox',
43	array(
44	array(
45	'methods' => WP_REST_Server::READABLE,
46	'callback' => array( self::class, 'user_outbox_get' ),
47	'args' => self::request_parameters(),
48	'permission_callback' => '__return_true',
49	),
50	)
51	);
52	}
53
54	/**
55	* Renders the user-outbox
56	*
57	* @param \WP_REST_Request $request The request object.
58	* @return WP_REST_Response\|\WP_Error The response object or WP_Error.
59	*/
60	public static function user_outbox_get( $request ) {
61	$user_id = $request->get_param( 'user_id' );
62	$user = User_Collection::get_by_various( $user_id );
63
64	if ( is_wp_error( $user ) ) {
65	return $user;
66	}
67
68	$post_types = \get_option( 'activitypub_support_post_types', array( 'post' ) );
69
70	$page = $request->get_param( 'page', 1 );
71
72	/**
73	* Action triggered prior to the ActivityPub profile being created and sent to the client.
74	*/
75	\do_action( 'activitypub_rest_outbox_pre' );
76
77	$json = new stdClass();
78
79	// phpcs:disable WordPress.NamingConventions.ValidVariableName.UsedPropertyNotSnakeCase
80	$json->{'@context'} = get_context();
81	$json->id = get_rest_url_by_path( sprintf( 'actors/%d/outbox', $user_id ) );
82	$json->generator = 'http://wordpress.org/?v=' . get_masked_wp_version();
83	$json->actor = $user->get_id();
84	$json->type = 'OrderedCollectionPage';
85	$json->partOf = get_rest_url_by_path( sprintf( 'actors/%d/outbox', $user_id ) );
86	$json->totalItems = 0;
87
88	if ( $user_id > 0 ) {
89	$count_posts = \count_user_posts( $user_id, $post_types, true );
90	$json->totalItems = \intval( $count_posts );
91	} else {
92	foreach ( $post_types as $post_type ) {
93	$count_posts = \wp_count_posts( $post_type );
94	$json->totalItems += \intval( $count_posts->publish );
95	}
96	}
97
98	$json->first = \add_query_arg( 'page', 1, $json->partOf );
99	$json->last = \add_query_arg( 'page', \ceil( $json->totalItems / 10 ), $json->partOf );
100
101	if ( $page && ( ( \ceil( $json->totalItems / 10 ) ) > $page ) ) {
102	$json->next = \add_query_arg( 'page', $page + 1, $json->partOf );
103	}
104
105	if ( $page && ( $page > 1 ) ) {
106	$json->prev = \add_query_arg( 'page', $page - 1, $json->partOf );
107	}
108	// phpcs:enable WordPress.NamingConventions.ValidVariableName.UsedPropertyNotSnakeCase
109
110	if ( $page ) {
111	$posts = \get_posts(
112	array(
113	'posts_per_page' => 10,
114	'author' => $user_id > 0 ? $user_id : null,
115	'paged' => $page,
116	'post_type' => $post_types,
117	)
118	);
119
120	foreach ( $posts as $post ) {
121	$transformer = Factory::get_transformer( $post );
122
123	if ( \is_wp_error( $transformer ) ) {
124	continue;
125	}
126
127	$post = $transformer->to_object();
128	$activity = new Activity();
129	$activity->set_type( 'Create' );
130	$activity->set_object( $post );
131	$json->orderedItems[] = $activity->to_array( false ); // phpcs:ignore WordPress.NamingConventions.ValidVariableName.UsedPropertyNotSnakeCase
132	}
133	}
134
135	/**
136	* Filter the ActivityPub outbox array.
137	*
138	* @param array $json The ActivityPub outbox array.
139	*/
140	$json = \apply_filters( 'activitypub_rest_outbox_array', $json );
141
142	/**
143	* Action triggered after the ActivityPub profile has been created and sent to the client
144	*/
145	\do_action( 'activitypub_outbox_post' );
146
147	$rest_response = new WP_REST_Response( $json, 200 );
148	$rest_response->header( 'Content-Type', 'application/activity+json; charset=' . get_option( 'blog_charset' ) );
149
150	return $rest_response;
151	}
152
153	/**
154	* The supported parameters.
155	*
156	* @return array List of parameters.
157	*/
158	public static function request_parameters() {
159	$params = array();
160
161	$params['page'] = array(
162	'type' => 'integer',
163	'default' => 1,
164	);
165
166	return $params;
167	}
168	}
169