* @var string */ protected $_status; /** * @param int $id * @return Follow_Request $follow_request */ public static function get_from_array( $array ) { $follow_request = self::init_from_array( $array ); if ( ! self::is_valid( $follow_request ) ) { return; } if ( ! $follow_request->get__id() ) { $follow_request->set__id( self::get_follow_request_id_by_uri( $follow_request->get_id() ) ); } return $follow_request; } /** * Retrieve the WordPress post id of the follow request by its id (URI) */ public static function get_follow_request_id_by_uri( $uri ) { global $wpdb; return $wpdb->get_var( $wpdb->prepare( "SELECT ID FROM $wpdb->posts WHERE guid=%s", esc_sql( $uri ) ) ); } /** * Check if the follow request is valid which means it fits to the already stored data. * * @param Follow_Request $follow_request The follow request to be checked. * @return bool Whether the follow request is valid. */ public static function is_valid( $follow_request ) { if ( self::class != get_class( $follow_request ) ) { return false; } if ( 'Follow' != $follow_request->get_type() ) { return false; } $id = self::get_follow_request_id_by_uri( $follow_request->get_id() ); if ( ! $id || is_wp_error( $id ) ) { return false; } if ( self::FOLLOW_REQUEST_POST_TYPE != get_post_type( $id ) ) { return false; } $post = get_post( $id ); $follower = get_post_parent( $id ); if ( $follower->guid != $follow_request->get_actor() ) { return false; } return true; } /** * @param int $id * @return Follow_Request $follow_request */ public static function from_wp_id( $id ) { if ( self::FOLLOW_REQUEST_POST_TYPE != get_post_type( $id ) ) { return; } $post = get_post( $id ); $follow_request = new static(); $follow_request->set_id( $post->guid ); $follow_request->set__id( $post->ID ); $follow_request->set__status( $post->post_status ); $follow_request->set_type( 'Follow' ); return $follow_request; } /** * Get the internal ID of the follower who issues the follow request. */ private function get_follower_id() { return wp_get_post_parent_id( $this->get__id() ); } /** * Save the current Follower-Object. * * @param Follower $follower * * @return Follow_Request|WP_Error The Follow_Request or an WP_Error. */ public static function save( $follower_id, $user_id, $activity_id ) { $meta_input = array( 'activitypub_user_id' => $user_id, ); $args = array( 'guid' => $activity_id, 'post_author' => 0, 'post_type' => self::FOLLOW_REQUEST_POST_TYPE, 'post_status' => 'pending', 'post_parent' => $follower_id, 'meta_input' => $meta_input, 'mime_type' => 'text/plain', ); $post_id = wp_insert_post( $args ); return self::from_wp_id( $post_id ); } /** * Check if the user is allowed to handle this follow request. * * Usually needed for the ajax functions. * @return bool Whether the user is allowed. */ public function can_handle_follow_request() { $target_actor = get_post_meta( $this->get__id(), 'activitypub_user_id' ); if ( get_current_user_id() == $target_actor || current_user_can( 'manage_options' ) ) { return true; } } /** * Get the URL/URI of the Follower that issued the follow request. * * @return string The url/uri of the follower. */ private function get_follower_actor() { $follower_id = wp_get_post_parent_id( $this->get__id() ); $follower = Follower::init_from_cpt( get_post( $follower_id ) ); return $follower->get_id(); } /** * Save the status of the follow request. * * @param string $status The new status of the follow request. */ private function save_follow_request_status( $status ) { wp_update_post( array( 'ID' => $this->get__id(), 'post_status' => $status, ) ); } /** * Reject the follow request. */ public function reject() { $user_id = get_post_meta( $this->get__id(), 'activitypub_user_id', true ); $actor = $this->get_follower_actor(); Followers::remove_follow_relationship( $user_id, $actor ); $this->save_follow_request_status( self::FOLLOW_REQUEST_STATUS_REJECTED ); $this->send_response( 'Reject', $user_id ); $this->delete(); } /** * Approve the follow request. */ public function approve() { $user_id = get_post_meta( $this->get__id(), 'activitypub_user_id', true ); $follower_id = $this->get_follower_id(); Followers::add_follow_relationship( $user_id, $follower_id ); $this->save_follow_request_status( self::FOLLOW_REQUEST_STATUS_APPROVED ); $this->send_response( 'Accept', $user_id, $follower_id ); } /** * Delete the follow request. * * This should only be called after it has been rejected. */ public function delete() { wp_delete_post( $this->get__id() ); } /** * Prepere the sending of the follow request response and hand it over to the sending handler. * * @param string $type The Activity type of the response: 'Accept', or 'Reject'. * @param int|string $user_id The user id of who gets followed. * @param int $follwer_id The internal follower id. */ public function send_response( $type, $user_id = null, $follower_id = null ) { if ( ! $user_id ) { $user_id = get_post_meta( $this->get__id(), 'activitypub_user_id', true ); } if ( ! $follower_id ) { $follower_id = $this->get_follower_id(); } $follower_inbox = get_post_field( 'post_content_filtered', $follower_id ); // Reconstruct the follow_object. $follow_object = array( 'id' => $this->get_id(), 'type' => $this->get_type(), 'actor' => get_post_field( 'guid', $follower_id ), ); do_action( 'activitypub_send_follow_response', $user_id, $follower_inbox, $follow_object, $type ); } }