| @@ -1,10 +1,11 @@ | ||
| 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; | |
| 7 | 8 | use Activitypub\Webfinger; |
| 8 | 9 | use Activitypub\Activity\Activity; |
| 9 | 10 | use Activitypub\Collection\Followers; |
| 10 | 11 | use Activitypub\Collection\Users; |
| @@ -14,9 +15,9 @@ | ||
| 14 | 15 | * |
| 15 | 16 | * @return array the activitypub context |
| 16 | 17 | */ |
| 17 | 18 | function get_context() { |
| 18 | - $context = Activity::CONTEXT; | |
| 19 | + $context = Activity::JSON_LD_CONTEXT; | |
| 19 | 20 | |
| 20 | 21 | return \apply_filters( 'activitypub_json_context', $context ); |
| 21 | 22 | } |
| 22 | 23 | |
| @@ -51,8 +52,19 @@ | ||
| 51 | 52 | $pre = apply_filters( 'pre_get_remote_metadata_by_actor', false, $actor ); |
| 52 | 53 | if ( $pre ) { |
| 53 | 54 | return $pre; |
| 54 | 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 | + | |
| 55 | 67 | if ( preg_match( '/^@?' . ACTIVITYPUB_USERNAME_REGEXP . '$/i', $actor ) ) { |
| 56 | 68 | $actor = Webfinger::resolve( $actor ); |
| 57 | 69 | } |
| 58 | 70 | |
| @@ -133,9 +145,9 @@ | ||
| 133 | 145 | function url_to_authorid( $url ) { |
| 134 | 146 | global $wp_rewrite; |
| 135 | 147 | |
| 136 | 148 | // check if url hase the same host |
| 137 | - 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 ) ) { | |
| 138 | 150 | return 0; |
| 139 | 151 | } |
| 140 | 152 | |
| 141 | 153 | // first, check to see if there is a 'author=N' to match against |
| @@ -311,8 +323,14 @@ | ||
| 311 | 323 | return false; |
| 312 | 324 | } |
| 313 | 325 | } |
| 314 | 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 | + | |
| 315 | 333 | // One can trigger an ActivityPub request by adding ?activitypub to the URL. |
| 316 | 334 | // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.VariableRedeclaration |
| 317 | 335 | global $wp_query; |
| 318 | 336 | if ( isset( $wp_query->query_vars['activitypub'] ) ) { |
| @@ -377,9 +395,9 @@ | ||
| 377 | 395 | $return = true; |
| 378 | 396 | break; |
| 379 | 397 | } |
| 380 | 398 | |
| 381 | - if ( ! \user_can( $user_id, 'publish_posts' ) ) { | |
| 399 | + if ( ! \user_can( $user_id, 'activitypub' ) ) { | |
| 382 | 400 | $return = true; |
| 383 | 401 | break; |
| 384 | 402 | } |
| 385 | 403 | |
| @@ -637,9 +655,9 @@ | ||
| 637 | 655 | } |
| 638 | 656 | |
| 639 | 657 | $users = \get_users( |
| 640 | 658 | array( |
| 641 | - 'capability__in' => array( 'publish_posts' ), | |
| 659 | + 'capability__in' => array( 'activitypub' ), | |
| 642 | 660 | ) |
| 643 | 661 | ); |
| 644 | 662 | |
| 645 | 663 | if ( is_array( $users ) ) { |
| @@ -663,24 +681,9 @@ | ||
| 663 | 681 | * |
| 664 | 682 | * @return int|boolean Comment ID, or false on failure. |
| 665 | 683 | */ |
| 666 | 684 | function object_id_to_comment( $id ) { |
| 667 | - $comment_query = new WP_Comment_Query( | |
| 668 | - array( | |
| 669 | - 'meta_key' => 'source_id', // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_key | |
| 670 | - 'meta_value' => $id, // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_value | |
| 671 | - ) | |
| 672 | - ); | |
| 673 | - | |
| 674 | - if ( ! $comment_query->comments ) { | |
| 675 | - return false; | |
| 676 | - } | |
| 677 | - | |
| 678 | - if ( count( $comment_query->comments ) > 1 ) { | |
| 679 | - return false; | |
| 680 | - } | |
| 681 | - | |
| 682 | - return $comment_query->comments[0]; | |
| 685 | + return Comment::object_id_to_comment( $id ); | |
| 683 | 686 | } |
| 684 | 687 | |
| 685 | 688 | /** |
| 686 | 689 | * Verify if URL is a local comment, |
| @@ -691,52 +694,9 @@ | ||
| 691 | 694 | * |
| 692 | 695 | * @return int comment_ID or null if not found |
| 693 | 696 | */ |
| 694 | 697 | function url_to_commentid( $url ) { |
| 695 | - if ( ! $url || ! filter_var( $url, FILTER_VALIDATE_URL ) ) { | |
| 696 | - return null; | |
| 697 | - } | |
| 698 | - | |
| 699 | - // check for local comment | |
| 700 | - if ( \wp_parse_url( \site_url(), \PHP_URL_HOST ) === \wp_parse_url( $url, \PHP_URL_HOST ) ) { | |
| 701 | - $query = \wp_parse_url( $url, PHP_URL_QUERY ); | |
| 702 | - | |
| 703 | - if ( $query ) { | |
| 704 | - parse_str( $query, $params ); | |
| 705 | - | |
| 706 | - if ( ! empty( $params['c'] ) ) { | |
| 707 | - $comment = \get_comment( $params['c'] ); | |
| 708 | - | |
| 709 | - if ( $comment ) { | |
| 710 | - return $comment->comment_ID; | |
| 711 | - } | |
| 712 | - } | |
| 713 | - } | |
| 714 | - } | |
| 715 | - | |
| 716 | - $args = array( | |
| 717 | - // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_query | |
| 718 | - 'meta_query' => array( | |
| 719 | - 'relation' => 'OR', | |
| 720 | - array( | |
| 721 | - 'key' => 'source_url', | |
| 722 | - 'value' => $url, | |
| 723 | - ), | |
| 724 | - array( | |
| 725 | - 'key' => 'source_id', | |
| 726 | - 'value' => $url, | |
| 727 | - ), | |
| 728 | - ), | |
| 729 | - ); | |
| 730 | - | |
| 731 | - $query = new \WP_Comment_Query(); | |
| 732 | - $comments = $query->query( $args ); | |
| 733 | - | |
| 734 | - if ( $comments && is_array( $comments ) ) { | |
| 735 | - return $comments[0]->comment_ID; | |
| 736 | - } | |
| 737 | - | |
| 738 | - return null; | |
| 698 | + return Comment::url_to_commentid( $url ); | |
| 739 | 699 | } |
| 740 | 700 | |
| 741 | 701 | /** |
| 742 | 702 | * Get the URI of an ActivityPub object |
| @@ -772,5 +732,314 @@ | ||
| 772 | 732 | break; |
| 773 | 733 | } |
| 774 | 734 | |
| 775 | 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 | |
| 908 | + ); | |
| 909 | + | |
| 910 | + return array_filter( $enclosures ); | |
| 911 | +} | |
| 912 | + | |
| 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(); | |
| 930 | + } | |
| 931 | + | |
| 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 ); | |
| 776 | 1045 | } |