markTestSkipped( 'The Friends plugin is not loaded.' ); } parent::set_up(); // Manually activate the REST server. global $wp_rest_server; $wp_rest_server = new \Spy_REST_Server(); $this->server = $wp_rest_server; do_action( 'rest_api_init' ); add_filter( 'rest_url', function() { return get_option( 'home' ) . '/wp-json/'; } ); add_filter( 'pre_http_request', array( get_called_class(), 'pre_http_request' ), 10, 3 ); add_filter( 'http_response', array( get_called_class(), 'http_response' ), 10, 3 ); add_filter( 'http_request_host_is_external', array( get_called_class(), 'http_request_host_is_external' ), 10, 2 ); add_filter( 'http_request_args', array( get_called_class(), 'http_request_args' ), 10, 2 ); add_filter( 'pre_get_remote_metadata_by_actor', array( get_called_class(), 'pre_get_remote_metadata_by_actor' ), 10, 2 ); $user_id = $this->factory->user->create( array( 'role' => 'administrator', ) ); wp_set_current_user( $user_id ); $this->friend_name = 'Alex Kirk'; $this->actor = 'https://mastodon.local/users/akirk'; $user_feed = \Friends\User_Feed::get_by_url( $this->actor ); if ( is_wp_error( $user_feed ) ) { $this->friend_id = $this->factory->user->create( array( 'display_name' => $this->friend_name, 'role' => 'friend', ) ); \Friends\User_Feed::save( new \Friends\User( $this->friend_id ), $this->actor, array( 'parser' => 'activitypub', ) ); } else { $this->friend_id = $user_feed->get_friend_user()->ID; } self::$users[ $this->actor ] = array( 'url' => $this->actor, 'name' => $this->friend_name, ); self::$users['https://mastodon.local/@akirk'] = self::$users[ $this->actor ]; _delete_all_posts(); } public function tear_down() { remove_filter( 'pre_http_request', array( get_called_class(), 'pre_http_request' ) ); remove_filter( 'http_response', array( get_called_class(), 'http_response' ) ); remove_filter( 'http_request_host_is_external', array( get_called_class(), 'http_request_host_is_external' ) ); remove_filter( 'http_request_args', array( get_called_class(), 'http_request_args' ) ); remove_filter( 'pre_get_remote_metadata_by_actor', array( get_called_class(), 'pre_get_remote_metadata_by_actor' ) ); } public static function pre_get_remote_metadata_by_actor( $pre, $actor ) { if ( isset( self::$users[ $actor ] ) ) { return self::$users[ $actor ]; } return $pre; } public static function http_request_host_is_external( $in, $host ) { if ( in_array( $host, array( 'mastodon.local' ), true ) ) { return true; } return $in; } public static function http_request_args( $args, $url ) { if ( in_array( parse_url( $url, PHP_URL_HOST ), array( 'mastodon.local' ), true ) ) { $args['reject_unsafe_urls'] = false; } return $args; } public static function pre_http_request( $preempt, $request, $url ) { $p = wp_parse_url( $url ); $cache = __DIR__ . '/fixtures/' . sanitize_title( $p['host'] . '-' . $p['path'] ) . '.response'; if ( file_exists( $cache ) ) { return apply_filters( 'fake_http_response', unserialize( file_get_contents( $cache ) ), $p['scheme'] . '://' . $p['host'], $url, $request ); } $home_url = home_url(); // Pretend the url now is the requested one. update_option( 'home', $p['scheme'] . '://' . $p['host'] ); $rest_prefix = home_url() . '/wp-json'; if ( false === strpos( $url, $rest_prefix ) ) { // Restore the old home_url. update_option( 'home', $home_url ); return $preempt; } $url = substr( $url, strlen( $rest_prefix ) ); $r = new \WP_REST_Request( $request['method'], $url ); if ( ! empty( $request['body'] ) ) { foreach ( $request['body'] as $key => $value ) { $r->set_param( $key, $value ); } } global $wp_rest_server; $response = $wp_rest_server->dispatch( $r ); // Restore the old url. update_option( 'home', $home_url ); return apply_filters( 'fake_http_response', array( 'headers' => array( 'content-type' => 'text/json', ), 'body' => wp_json_encode( $response->data ), 'response' => array( 'code' => $response->status, ), ), $p['scheme'] . '://' . $p['host'], $url, $request ); } public static function http_response( $response, $args, $url ) { $p = wp_parse_url( $url ); $cache = __DIR__ . '/fixtures/' . sanitize_title( $p['host'] . '-' . $p['path'] ) . '.response'; if ( ! file_exists( $cache ) ) { $headers = wp_remote_retrieve_headers( $response ); file_put_contents( $cache, serialize( array( 'headers' => $headers->getAll(), 'body' => wp_remote_retrieve_body( $response ), 'response' => array( 'code' => wp_remote_retrieve_response_code( $response ), ), ) ) ); } return $response; } public function test_incoming_post() { $now = time() - 10; $status_id = 123; $posts = get_posts( array( 'post_type' => \Friends\Friends::CPT, 'author' => $this->friend_id, ) ); $post_count = count( $posts ); // Let's post a new Note through the REST API. $date = gmdate( \DATE_W3C, $now++ ); $id = 'test' . $status_id; $content = 'Test ' . $date . ' ' . rand(); $request = new \WP_REST_Request( 'POST', '/activitypub/1.0/users/' . get_current_user_id() . '/inbox' ); $request->set_param( 'type', 'Create' ); $request->set_param( 'id', $id ); $request->set_param( 'actor', $this->actor ); $request->set_param( 'object', array( 'type' => 'Note', 'id' => $id, 'attributedTo' => $this->actor, 'content' => $content, 'url' => 'https://mastodon.local/users/akirk/statuses/' . ( $status_id++ ), 'published' => $date, ) ); $response = $this->server->dispatch( $request ); $this->assertEquals( 202, $response->get_status() ); $posts = get_posts( array( 'post_type' => \Friends\Friends::CPT, 'author' => $this->friend_id, ) ); $this->assertEquals( $post_count + 1, count( $posts ) ); $this->assertEquals( $content, $posts[0]->post_content ); $this->assertEquals( $this->friend_id, $posts[0]->post_author ); // Do another test post, this time with a URL that has an @-id. $date = gmdate( \DATE_W3C, $now++ ); $id = 'test' . $status_id; $content = 'Test ' . $date . ' ' . rand(); $request = new \WP_REST_Request( 'POST', '/activitypub/1.0/users/' . get_current_user_id() . '/inbox' ); $request->set_param( 'type', 'Create' ); $request->set_param( 'id', $id ); $request->set_param( 'actor', 'https://mastodon.local/@akirk' ); $request->set_param( 'object', array( 'type' => 'Note', 'id' => $id, 'attributedTo' => 'https://mastodon.local/@akirk', 'content' => $content, 'url' => 'https://mastodon.local/users/akirk/statuses/' . ( $status_id++ ), 'published' => $date, ) ); $response = $this->server->dispatch( $request ); $this->assertEquals( 202, $response->get_status() ); $posts = get_posts( array( 'post_type' => \Friends\Friends::CPT, 'author' => $this->friend_id, ) ); $this->assertEquals( $post_count + 2, count( $posts ) ); $this->assertEquals( $content, $posts[0]->post_content ); $this->assertEquals( $this->friend_id, $posts[0]->post_author ); } public function test_incoming_announce() { $now = time() - 10; $status_id = 123; self::$users['https://notiz.blog/author/matthias-pfefferle/'] = array( 'url' => 'https://notiz.blog/author/matthias-pfefferle/', 'name' => 'Matthias Pfefferle', ); $posts = get_posts( array( 'post_type' => \Friends\Friends::CPT, 'author' => $this->friend_id, ) ); $post_count = count( $posts ); $date = gmdate( \DATE_W3C, $now++ ); $id = 'test' . $status_id; $object = 'https://notiz.blog/2022/11/14/the-at-protocol/'; $request = new \WP_REST_Request( 'POST', '/activitypub/1.0/users/' . get_current_user_id() . '/inbox' ); $request->set_param( 'type', 'Announce' ); $request->set_param( 'id', $id ); $request->set_param( 'actor', $this->actor ); $request->set_param( 'published', $date ); $request->set_param( 'object', $object ); $response = $this->server->dispatch( $request ); $this->assertEquals( 202, $response->get_status() ); $p = wp_parse_url( $object ); $cache = __DIR__ . '/fixtures/' . sanitize_title( $p['host'] . '-' . $p['path'] ) . '.response'; $this->assertFileExists( $cache ); $object = json_decode( wp_remote_retrieve_body( unserialize( file_get_contents( $cache ) ) ) ); $posts = get_posts( array( 'post_type' => \Friends\Friends::CPT, 'author' => $this->friend_id, ) ); $this->assertEquals( $post_count + 1, count( $posts ) ); $this->assertStringContainsString( 'Dezentrale Netzwerke', $posts[0]->post_content ); $this->assertEquals( $this->friend_id, $posts[0]->post_author ); } }