array( 'url' => 'https://example.org/users/username', 'inbox' => 'https://example.org/users/username/inbox', 'name' => 'username', ), 'jon@example.com' => array( 'url' => 'https://example.com/author/jon', 'inbox' => 'https://example.com/author/jon/inbox', 'name' => 'jon', ), ); public function test_dispatch_activity() { $followers = array( 'https://example.com/author/jon', 'https://example.org/users/username' ); \update_user_meta( 1, 'activitypub_followers', $followers ); $post = \wp_insert_post( array( 'post_author' => 1, 'post_content' => 'hello', ) ); $pre_http_request = new MockAction(); add_filter( 'pre_http_request', array( $pre_http_request, 'filter' ), 10, 3 ); $activitypub_post = new \Activitypub\Model\Post( $post ); \Activitypub\Activity_Dispatcher::send_post_activity( $activitypub_post ); $this->assertNotEmpty( $activitypub_post->get_content() ); $this->assertSame( 2, $pre_http_request->get_call_count() ); $all_args = $pre_http_request->get_args(); $first_call_args = array_shift( $all_args ); $this->assertEquals( 'https://example.com/author/jon/inbox', $first_call_args[2] ); $second_call_args = array_shift( $all_args ); $this->assertEquals( 'https://example.org/users/username/inbox', $second_call_args[2] ); remove_filter( 'pre_http_request', array( $pre_http_request, 'filter' ), 10 ); } public function test_dispatch_mentions() { $post = \wp_insert_post( array( 'post_author' => 1, 'post_content' => '@alex hello', ) ); self::$users['https://example.com/alex'] = array( 'url' => 'https://example.com/alex', 'inbox' => 'https://example.com/alex/inbox', 'name' => 'alex', ); add_filter( 'activitypub_extract_mentions', function( $mentions ) { $mentions[] = 'https://example.com/alex'; return $mentions; }, 10 ); $pre_http_request = new MockAction(); add_filter( 'pre_http_request', array( $pre_http_request, 'filter' ), 10, 3 ); $activitypub_post = new \Activitypub\Model\Post( $post ); \Activitypub\Activity_Dispatcher::send_post_activity( $activitypub_post ); $this->assertNotEmpty( $activitypub_post->get_content() ); $this->assertSame( 1, $pre_http_request->get_call_count() ); $all_args = $pre_http_request->get_args(); $first_call_args = $all_args[0]; $this->assertEquals( 'https://example.com/alex/inbox', $first_call_args[2] ); $body = json_decode( $first_call_args[1]['body'], true ); $this->assertArrayHasKey( 'id', $body ); remove_all_filters( 'activitypub_from_post_object' ); remove_filter( 'pre_http_request', array( $pre_http_request, 'filter' ), 10 ); } public function set_up() { parent::set_up(); add_filter( 'pre_get_remote_metadata_by_actor', array( get_called_class(), 'pre_get_remote_metadata_by_actor' ), 10, 2 ); _delete_all_posts(); } public function tear_down() { remove_filter( 'pre_get_remote_metadata_by_actor', array( get_called_class(), 'pre_get_remote_metadata_by_actor' ) ); parent::tear_down(); } public static function pre_get_remote_metadata_by_actor( $pre, $actor ) { if ( isset( self::$users[ $actor ] ) ) { return self::$users[ $actor ]; } foreach ( self::$users as $username => $data ) { if ( $data['url'] === $actor ) { return $data; } } return $pre; } public static function http_request_host_is_external( $in, $host ) { if ( in_array( $host, array( 'example.com', 'example.org' ), true ) ) { return true; } return $in; } public static function http_request_args( $args, $url ) { if ( in_array( wp_parse_url( $url, PHP_URL_HOST ), array( 'example.com', 'example.org' ), true ) ) { $args['reject_unsafe_urls'] = false; } return $args; } public static function pre_http_request( $preempt, $request, $url ) { return array( 'headers' => array( 'content-type' => 'text/json', ), 'body' => '', 'response' => array( 'code' => 202, ), ); } public static function http_response( $response, $args, $url ) { return $response; } }