From 024e1557b704600583b415e7da7e97a4bd4d70ce Mon Sep 17 00:00:00 2001 From: Jeremy Dormitzer Date: Mon, 24 Sep 2018 17:36:30 -0400 Subject: [PATCH] Implement inbox forwarding --- inc/deliver.php | 26 ++++++++++++--- inc/inbox.php | 86 ++++++++++++++++++++++++++++++++++++++++++------- 2 files changed, 97 insertions(+), 15 deletions(-) diff --git a/inc/deliver.php b/inc/deliver.php index 91c6d32..48e598b 100644 --- a/inc/deliver.php +++ b/inc/deliver.php @@ -3,6 +3,10 @@ namespace deliver; require_once plugin_dir_path( __FILE__ ) . 'activities.php'; +// TODO look at inReplyTo, object, target, and tag objects +// and deliver to their audience as well. Recurse through these +// objects up to some limit + function deliver_activity( $activity ) { $recipients = array(); foreach ( array( 'to', 'bto', 'cc', 'bcc', 'audience' ) as $field ) { @@ -66,8 +70,15 @@ function get_recipient_urls( $object, $depth, $acc ) { return $recipients; case Link: if ( array_key_exists( 'href', $object ) ) { - $link_target = wp_remote_retrieve_body( wp_remote_get( $object['href'] ) ); - return get_recipient_urls( $link_target, $depth + 1, $acc ); + $response = wp_remote_get( $object['href'] ); + if ( is_wp_error( $response ) ) { + return array(); + } + $link_target = wp_remote_retrieve_body( $response ); + if ( empty( $link_target ) ) { + return array(); + } + return get_recipient_urls( json_decode( $link_target, true ), $depth + 1, $acc ); } else { return array(); } @@ -92,8 +103,15 @@ function get_recipient_urls( $object, $depth, $acc ) { return $recipients; } else { if ( filter_var( $object, FILTER_VALIDATE_URL ) ) { - $response_body = wp_remote_retrieve_body( wp_remote_get ( $object ) ); - return get_recipient_urls( $response_body, $depth + 1, $acc ); + $response = wp_remote_get( $object ); + if ( is_wp_error( $response ) ) { + return array(); + } + $response_body = wp_remote_retrieve_body( $response ); + if ( empty( $response_body ) ) { + return $array(); + } + return get_recipient_urls( json_decode( $response_body, true ), $depth + 1, $acc ); } else { return array(); } diff --git a/inc/inbox.php b/inc/inbox.php index ab09937..71572ec 100644 --- a/inc/inbox.php +++ b/inc/inbox.php @@ -10,6 +10,8 @@ When an Activity is received (i.e. POSTed) to an Actor's inbox, the server must: namespace inbox; require_once plugin_dir_path( __FILE__ ) . '/activities.php'; +require_once plugin_dir_path( __FILE__ ) . '/objects.php'; +require_once plugin_dir_path( __FILE__ ) . '/deliver.php'; require_once plugin_dir_path( __FILE__ ) . '/activities/create.php'; require_once plugin_dir_path( __FILE__ ) . '/activities/update.php'; require_once plugin_dir_path( __FILE__ ) . '/activities/delete.php'; @@ -51,18 +53,10 @@ function handle_activity( $actor_slug, $activity ) { $activity = \activities\reject\handle_inbox( $actor_slug, $activity ); break; case 'Add': - return new \WP_Error( - 'not_implemented', - __( 'The Add activity has not been implemented', 'pterotype' ), - array( 'status' => 501 ) - ); + // TODO not yet implemented break; case 'Remove': - return new \WP_Error( - 'not_implemented', - __( 'The Remove activity has not been implemented', 'pterotype' ), - array( 'status' => 501 ) - ); + // TODO not yet implemented break; case 'Announce': $activity = \activities\announce\handle_inbox( $actor_slug, $activity ); @@ -78,7 +72,77 @@ function handle_activity( $actor_slug, $activity ) { } function forward_activity( $activity ) { - // TODO + if ( !array_key_exists( 'id', $activity ) ) { + return; + } + $seen_before = \activities\get_activity_id( $activity['id'] ); + if ( $seen_before ) { + return; + } + if ( !references_local_object( $activity, 0 ) ) { + return; + } + $collections = array_intersect_key( + $activity, + array_flip( array( 'to', 'cc', 'audience' ) ) + ); + if ( count( $collections ) === 0 ) { + return; + } + \deliver\deliver_activity( $activity ); +} + +function references_local_object( $object, $depth ) { + if ( $depth === 12 ) { + return false; + } + if ( \objects\is_local_object( $object ) ) { + return true; + } + $fields = array_intersect_key( + $object, + array_flip( array( 'inReplyTo', 'object', 'target', 'tag' ) ) + ); + if ( count( $fields ) === 0 ) { + return false; + } + $result = false; + foreach ( $fields as $field_value ) { + if ( $result ) { + return $result; + } + // $field_value is either a url, a Link, or an object + if ( is_array( $field_value ) ) { + if ( array_key_exists( 'id', $field_value ) ) { + return \objects\is_local_object( $field_value ); + } else if ( array_key_exists( 'href', $field_value ) ) { + $response = wp_remote_get( $field_value['href'] ); + if ( is_wp_error( $response ) ) { + return false; + } + $body = wp_remote_retrieve_body( $response ); + if ( empty( $body ) ) { + return false; + } + $body_array = json_decode( $body, true ); + return $body_array && references_local_object( $body_array, $depth + 1 ); + } else { + return false; + } + } else { + $response = wp_remote_get( $field_value ); + if ( is_wp_error( $response ) ) { + continue; + } + $body = wp_remote_retrieve_body( $response ); + if ( empty( $body ) ) { + continue; + } + $body_array = json_decode( $body, true ); + $result = $body_array && references_local_object( $body_array, $depth + 1 ); + } + } + return false; } function persist_activity( $actory_slug, $activity ) {