← All changes | includes/functions.php +387 -42 1.3.0 → 2.6.0 View file →

		@@ -1,10 +1,12 @@
1	1	<?php
2	2	namespace Activitypub;
3	3
	4	+use WP_Query;
4	5	use WP_Error;
5		-use WP_Comment_Query;
6	6	use Activitypub\Http;
	7	+use Activitypub\Comment;
	8	+use Activitypub\Webfinger;
7	9	use Activitypub\Activity\Activity;
8	10	use Activitypub\Collection\Followers;
9	11	use Activitypub\Collection\Users;
10	12
		@@ -13,9 +15,9 @@
13	15	*
14	16	* @return array the activitypub context
15	17	*/
16	18	function get_context() {
17		- $context = Activity::CONTEXT;
	19	+ $context = Activity::JSON_LD_CONTEXT;
18	20
19	21	return \apply_filters( 'activitypub_json_context', $context );
20	22	}
21	23
		@@ -50,8 +52,19 @@
50	52	$pre = apply_filters( 'pre_get_remote_metadata_by_actor', false, $actor );
51	53	if ( $pre ) {
52	54	return $pre;
53	55	}
	56	+
	57	+ if ( is_array( $actor ) ) {
	58	+ if ( array_key_exists( 'id', $actor ) ) {
	59	+ $actor = $actor['id'];
	60	+ } elseif ( array_key_exists( 'url', $actor ) ) {
	61	+ $actor = $actor['url'];
	62	+ } else {
	63	+ return new WP_Error( 'activitypub_no_valid_actor_identifier', \__( 'The "actor" identifier is not valid', 'activitypub' ), array( 'status' => 404, 'actor' => $actor ) );
	64	+ }
	65	+ }
	66	+
54	67	if ( preg_match( '/^@?' . ACTIVITYPUB_USERNAME_REGEXP . '$/i', $actor ) ) {
55	68	$actor = Webfinger::resolve( $actor );
56	69	}
57	70
		@@ -132,9 +145,9 @@
132	145	function url_to_authorid( $url ) {
133	146	global $wp_rewrite;
134	147
135	148	// check if url hase the same host
136		- if ( \wp_parse_url( \site_url(), \PHP_URL_HOST ) !== \wp_parse_url( $url, \PHP_URL_HOST ) ) {
	149	+ if ( \wp_parse_url( \home_url(), \PHP_URL_HOST ) !== \wp_parse_url( $url, \PHP_URL_HOST ) ) {
137	150	return 0;
138	151	}
139	152
140	153	// first, check to see if there is a 'author=N' to match against
		@@ -168,8 +181,29 @@
168	181	return 0;
169	182	}
170	183
171	184	/**
	185	+ * Verify if url is a wp_ap_comment,
	186	+ * Or if it is a previously received remote comment
	187	+ *
	188	+ * @return int comment_id
	189	+ */
	190	+function is_comment() {
	191	+ $comment_id = get_query_var( 'c', null );
	192	+
	193	+ if ( ! is_null( $comment_id ) ) {
	194	+ $comment = \get_comment( $comment_id );
	195	+
	196	+ // Only return local origin comments
	197	+ if ( $comment && $comment->user_id ) {
	198	+ return $comment_id;
	199	+ }
	200	+ }
	201	+
	202	+ return false;
	203	+}
	204	+
	205	+/**
172	206	* Check for Tombstone Objects
173	207	*
174	208	* @see https://www.w3.org/TR/activitypub/#delete-activity-outbox
175	209	*
		@@ -289,8 +323,14 @@
289	323	return false;
290	324	}
291	325	}
292	326
	327	+ // Check if header already sent.
	328	+ if ( ! \headers_sent() && ACTIVITYPUB_SEND_VARY_HEADER ) {
	329	+ // Send Vary header for Accept header.
	330	+ \header( 'Vary: Accept' );
	331	+ }
	332	+
293	333	// One can trigger an ActivityPub request by adding ?activitypub to the URL.
294	334	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.VariableRedeclaration
295	335	global $wp_query;
296	336	if ( isset( $wp_query->query_vars['activitypub'] ) ) {
		@@ -355,9 +395,9 @@
355	395	$return = true;
356	396	break;
357	397	}
358	398
359		- if ( ! \user_can( $user_id, 'publish_posts' ) ) {
	399	+ if ( ! \user_can( $user_id, 'activitypub' ) ) {
360	400	$return = true;
361	401	break;
362	402	}
363	403
		@@ -578,9 +618,9 @@
578	618	if ( false === $count ) {
579	619	global $wpdb;
580	620	$query = "SELECT COUNT( DISTINCT post_author ) FROM {$wpdb->posts} WHERE post_type = 'post' AND post_status = 'publish' AND post_date <= DATE_SUB( NOW(), INTERVAL %d MONTH )";
581	621	$query = $wpdb->prepare( $query, $duration );
582		- $count = $wpdb->get_var( $query ); // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery
	622	+ $count = $wpdb->get_var( $query ); // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
583	623
584	624	set_transient( $transient_key, $count, DAY_IN_SECONDS );
585	625	}
586	626
		@@ -615,9 +655,9 @@
615	655	}
616	656
617	657	$users = \get_users(
618	658	array(
619		- 'capability__in' => array( 'publish_posts' ),
	659	+ 'capability__in' => array( 'activitypub' ),
620	660	)
621	661	);
622	662
623	663	if ( is_array( $users ) ) {
		@@ -641,24 +681,9 @@
641	681	*
642	682	* @return int|boolean Comment ID, or false on failure.
643	683	*/
644	684	function object_id_to_comment( $id ) {
645		- $comment_query = new WP_Comment_Query(
646		- array(
647		- 'meta_key' => 'source_id', // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_key
648		- 'meta_value' => $id, // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_value
649		- )
650		- );
651		-
652		- if ( ! $comment_query->comments ) {
653		- return false;
654		- }
655		-
656		- if ( count( $comment_query->comments ) > 1 ) {
657		- return false;
658		- }
659		-
660		- return $comment_query->comments[0];
	685	+ return Comment::object_id_to_comment( $id );
661	686	}
662	687
663	688	/**
664	689	* Verify if URL is a local comment,
		@@ -669,32 +694,352 @@
669	694	*
670	695	* @return int comment_ID or null if not found
671	696	*/
672	697	function url_to_commentid( $url ) {
673		- if ( ! $url || ! filter_var( $url, FILTER_VALIDATE_URL ) ) {
674		- return null;
	698	+ return Comment::url_to_commentid( $url );
	699	+}
	700	+
	701	+/**
	702	+ * Get the URI of an ActivityPub object
	703	+ *
	704	+ * @param array $object The ActivityPub object
	705	+ *
	706	+ * @return string The URI of the ActivityPub object
	707	+ */
	708	+function object_to_uri( $object ) {
	709	+ // check if it is already simple
	710	+ if ( ! $object || is_string( $object ) ) {
	711	+ return $object;
675	712	}
676	713
677		- $args = array(
678		- // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_query
679		- 'meta_query' => array(
680		- 'relation' => 'OR',
681		- array(
682		- 'key' => 'source_url',
683		- 'value' => $url,
684		- ),
685		- array(
686		- 'key' => 'source_id',
687		- 'value' => $url,
688		- ),
689		- ),
	714	+ // check if it is a list, then take first item
	715	+ // this plugin does not support collections
	716	+ if ( array_is_list( $object ) ) {
	717	+ $object = $object[0];
	718	+ }
	719	+
	720	+ // check if it is simplified now
	721	+ if ( is_string( $object ) ) {
	722	+ return $object;
	723	+ }
	724	+
	725	+ // return part of Object that makes most sense
	726	+ switch ( $object['type'] ) {
	727	+ case 'Link':
	728	+ $object = $object['href'];
	729	+ break;
	730	+ default:
	731	+ $object = $object['id'];
	732	+ break;
	733	+ }
	734	+
	735	+ return $object;
	736	+}
	737	+
	738	+/**
	739	+ * Check if a comment should be federated.
	740	+ *
	741	+ * We consider a comment should be federated if it is authored by a user that is
	742	+ * not disabled for federation and if it is a reply directly to the post or to a
	743	+ * federated comment.
	744	+ *
	745	+ * @param mixed $comment Comment object or ID.
	746	+ *
	747	+ * @return boolean True if the comment should be federated, false otherwise.
	748	+ */
	749	+function should_comment_be_federated( $comment ) {
	750	+ return Comment::should_be_federated( $comment );
	751	+}
	752	+
	753	+/**
	754	+ * Check if a comment was federated.
	755	+ *
	756	+ * This function checks if a comment was federated via ActivityPub.
	757	+ *
	758	+ * @param mixed $comment Comment object or ID.
	759	+ *
	760	+ * @return boolean True if the comment was federated, false otherwise.
	761	+ */
	762	+function was_comment_sent( $comment ) {
	763	+ return Comment::was_sent( $comment );
	764	+}
	765	+
	766	+/**
	767	+ * Check if a comment is federated.
	768	+ *
	769	+ * We consider a comment federated if comment was received via ActivityPub.
	770	+ *
	771	+ * Use this function to check if it is comment that was received via ActivityPub.
	772	+ *
	773	+ * @param mixed $comment Comment object or ID.
	774	+ *
	775	+ * @return boolean True if the comment is federated, false otherwise.
	776	+ */
	777	+function was_comment_received( $comment ) {
	778	+ return Comment::was_received( $comment );
	779	+}
	780	+
	781	+/**
	782	+ * Check if a comment is local only.
	783	+ *
	784	+ * This function checks if a comment is local only and was not sent or received via ActivityPub.
	785	+ *
	786	+ * @param mixed $comment Comment object or ID.
	787	+ *
	788	+ * @return boolean True if the comment is local only, false otherwise.
	789	+ */
	790	+function is_local_comment( $comment ) {
	791	+ return Comment::is_local( $comment );
	792	+}
	793	+
	794	+/**
	795	+ * Mark a WordPress object as federated.
	796	+ *
	797	+ * @param WP_Comment|WP_Post|mixed $wp_object
	798	+ *
	799	+ * @return void
	800	+ */
	801	+function set_wp_object_state( $wp_object, $state ) {
	802	+ $meta_key = 'activitypub_status';
	803	+
	804	+ if ( $wp_object instanceof \WP_Post ) {
	805	+ \update_post_meta( $wp_object->ID, $meta_key, $state );
	806	+ } elseif ( $wp_object instanceof \WP_Comment ) {
	807	+ \update_comment_meta( $wp_object->comment_ID, $meta_key, $state );
	808	+ } else {
	809	+ \apply_filters( 'activitypub_mark_wp_object_as_federated', $wp_object );
	810	+ }
	811	+}
	812	+
	813	+/**
	814	+ * Get the federation state of a WordPress object.
	815	+ *
	816	+ * @param WP_Comment|WP_Post|mixed $wp_object
	817	+ *
	818	+ * @return string|false The state of the object or false if not found.
	819	+ */
	820	+function get_wp_object_state( $wp_object ) {
	821	+ $meta_key = 'activitypub_status';
	822	+
	823	+ if ( $wp_object instanceof \WP_Post ) {
	824	+ return \get_post_meta( $wp_object->ID, $meta_key, true );
	825	+ } elseif ( $wp_object instanceof \WP_Comment ) {
	826	+ return \get_comment_meta( $wp_object->comment_ID, $meta_key, true );
	827	+ } else {
	828	+ return \apply_filters( 'activitypub_get_wp_object_state', false, $wp_object );
	829	+ }
	830	+}
	831	+
	832	+/**
	833	+ * Get the description of a post type.
	834	+ *
	835	+ * Set some default descriptions for the default post types.
	836	+ *
	837	+ * @param WP_Post_Type $post_type The post type object.
	838	+ *
	839	+ * @return string The description of the post type.
	840	+ */
	841	+function get_post_type_description( $post_type ) {
	842	+ $description = '';
	843	+
	844	+ switch ( $post_type->name ) {
	845	+ case 'post':
	846	+ $description = '';
	847	+ break;
	848	+ case 'page':
	849	+ $description = '';
	850	+ break;
	851	+ case 'attachment':
	852	+ $description = ' - ' . __( 'The attachments that you have uploaded to a post (images, videos, documents or other files).', 'activitypub' );
	853	+ break;
	854	+ default:
	855	+ if ( ! empty( $post_type->description ) ) {
	856	+ $description = ' - ' . $post_type->description;
	857	+ }
	858	+ }
	859	+
	860	+ return apply_filters( 'activitypub_post_type_description', $description, $post_type->name, $post_type );
	861	+}
	862	+
	863	+/**
	864	+ * Get the masked WordPress version to only show the major and minor version.
	865	+ *
	866	+ * @return string The masked version.
	867	+ */
	868	+function get_masked_wp_version() {
	869	+ // only show the major and minor version
	870	+ $version = get_bloginfo( 'version' );
	871	+ // strip the RC or beta part
	872	+ $version = preg_replace( '/-.*$/', '', $version );
	873	+ $version = explode( '.', $version );
	874	+ $version = array_slice( $version, 0, 2 );
	875	+
	876	+ return implode( '.', $version );
	877	+}
	878	+
	879	+/**
	880	+ * Get the enclosures of a post.
	881	+ *
	882	+ * @param int $post_id The post ID.
	883	+ *
	884	+ * @return array The enclosures.
	885	+ */
	886	+function get_enclosures( $post_id ) {
	887	+ $enclosures = get_post_meta( $post_id, 'enclosure' );
	888	+
	889	+ if ( ! $enclosures ) {
	890	+ return array();
	891	+ }
	892	+
	893	+ $enclosures = array_map(
	894	+ function ( $enclosure ) {
	895	+ $attributes = explode( "\n", $enclosure );
	896	+
	897	+ if ( ! isset( $attributes[0] ) || ! \wp_http_validate_url( $attributes[0] ) ) {
	898	+ return false;
	899	+ }
	900	+
	901	+ return array(
	902	+ 'url' => $attributes[0],
	903	+ 'length' => isset( $attributes[1] ) ? trim( $attributes[1] ) : null,
	904	+ 'mediaType' => isset( $attributes[2] ) ? trim( $attributes[2] ) : null,
	905	+ );
	906	+ },
	907	+ $enclosures
690	908	);
691	909
692		- $query = new \WP_Comment_Query();
693		- $comments = $query->query( $args );
	910	+ return array_filter( $enclosures );
	911	+}
694	912
695		- if ( $comments && is_array( $comments ) ) {
696		- return $comments[0]->comment_ID;
	913	+/**
	914	+ * Retrieves the IDs of the ancestors of a comment.
	915	+ *
	916	+ * Adaption of `get_post_ancestors` from WordPress core.
	917	+ *
	918	+ * @see https://developer.wordpress.org/reference/functions/get_post_ancestors/
	919	+ *
	920	+ * @param int|WP_Comment $comment Comment ID or comment object.
	921	+ *
	922	+ * @return WP_Comment[] Array of ancestor comments or empty array if there are none.
	923	+ */
	924	+function get_comment_ancestors( $comment ) {
	925	+ $comment = \get_comment( $comment );
	926	+
	927	+ // phpcs:ignore Universal.Operators.StrictComparisons.LooseEqual
	928	+ if ( ! $comment || empty( $comment->comment_parent ) || $comment->comment_parent == $comment->comment_ID ) {
	929	+ return array();
697	930	}
698	931
699		- return null;
	932	+ $ancestors = array();
	933	+
	934	+ $id = (int) $comment->comment_parent;
	935	+ $ancestors[] = $id;
	936	+
	937	+ // phpcs:ignore Generic.CodeAnalysis.AssignmentInCondition.FoundInWhileCondition
	938	+ while ( $id > 0 ) {
	939	+ $ancestor = \get_comment( $id );
	940	+ $parent_id = (int) $ancestor->comment_parent;
	941	+
	942	+ // Loop detection: If the ancestor has been seen before, break.
	943	+ if ( empty( $parent_id ) || ( $parent_id === (int) $comment->comment_ID ) || in_array( $parent_id, $ancestors, true ) ) {
	944	+ break;
	945	+ }
	946	+
	947	+ $id = $parent_id;
	948	+ $ancestors[] = $id;
	949	+ }
	950	+
	951	+ return $ancestors;
	952	+}
	953	+
	954	+/**
	955	+ * Change the display of large numbers on the site.
	956	+ *
	957	+ * @author Jeremy Herve
	958	+ *
	959	+ * @see https://wordpress.org/support/topic/abbreviate-numbers-with-k/
	960	+ *
	961	+ * @param string $formatted Converted number in string format.
	962	+ * @param float $number The number to convert based on locale.
	963	+ * @param int $decimals Precision of the number of decimal places.
	964	+ *
	965	+ * @return string Converted number in string format.
	966	+ */
	967	+function custom_large_numbers( $formatted, $number, $decimals ) {
	968	+ global $wp_locale;
	969	+
	970	+ $decimals = 0;
	971	+ $decimal_point = '.';
	972	+ $thousands_sep = ',';
	973	+
	974	+ if ( isset( $wp_locale ) ) {
	975	+ $decimals = (int) $wp_locale->number_format['decimal_point'];
	976	+ $decimal_point = $wp_locale->number_format['decimal_point'];
	977	+ $thousands_sep = $wp_locale->number_format['thousands_sep'];
	978	+ }
	979	+
	980	+ if ( $number < 1000 ) { // any number less than a Thousand.
	981	+ return \number_format( $number, $decimals, $decimal_point, $thousands_sep );
	982	+ } elseif ( $number < 1000000 ) { // any number less than a million
	983	+ return \number_format( $number / 1000, $decimals, $decimal_point, $thousands_sep ) . 'K';
	984	+ } elseif ( $number < 1000000000 ) { // any number less than a billion
	985	+ return \number_format( $number / 1000000, $decimals, $decimal_point, $thousands_sep ) . 'M';
	986	+ } else { // at least a billion
	987	+ return \number_format( $number / 1000000000, $decimals, $decimal_point, $thousands_sep ) . 'B';
	988	+ }
	989	+
	990	+ // Default fallback. We should not get here.
	991	+ return $formatted;
	992	+}
	993	+
	994	+/**
	995	+ * Normalize a URL.
	996	+ *
	997	+ * @param string $url The URL.
	998	+ *
	999	+ * @return string The normalized URL.
	1000	+ */
	1001	+function normalize_url( $url ) {
	1002	+ $url = \untrailingslashit( $url );
	1003	+ $url = \str_replace( 'https://', '', $url );
	1004	+ $url = \str_replace( 'http://', '', $url );
	1005	+ $url = \str_replace( 'www.', '', $url );
	1006	+
	1007	+ return $url;
	1008	+}
	1009	+
	1010	+/**
	1011	+ * Normalize a host.
	1012	+ *
	1013	+ * @param string $host The host.
	1014	+ *
	1015	+ * @return string The normalized host.
	1016	+ */
	1017	+function normalize_host( $host ) {
	1018	+ return \str_replace( 'www.', '', $host );
	1019	+}
	1020	+
	1021	+/**
	1022	+ * Get the Extra Fields of an Actor
	1023	+ *
	1024	+ * @param int $user_id The User-ID.
	1025	+ *
	1026	+ * @return array The extra fields.
	1027	+ */
	1028	+function get_actor_extra_fields( $user_id ) {
	1029	+ $extra_fields = new WP_Query(
	1030	+ array(
	1031	+ 'post_type' => 'ap_extrafield',
	1032	+ 'nopaging' => true,
	1033	+ 'status' => 'publish',
	1034	+ 'author' => $user_id,
	1035	+ )
	1036	+ );
	1037	+
	1038	+ if ( $extra_fields->have_posts() ) {
	1039	+ $extra_fields = $extra_fields->posts;
	1040	+ } else {
	1041	+ $extra_fields = array();
	1042	+ }
	1043	+
	1044	+ return apply_filters( 'activitypub_get_actor_extra_fields', $extra_fields, $user_id );
700	1045	}