WP2D_API::get_services() - Code Metrics - gutobenn/wp-to-diaspora - Measure and Improve Code Quality continuously with Scrutinizer

WP2D_API::get_services() A
last analyzed 2017-01-13 12:04 UTC

↳ Parent: WP2D_API
Complexity

Conditions	2
Paths	2
Size

Total Lines	4
Code Lines	3
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
dl	0
loc	4
rs	10
c	0
b	0
f	0
cc	2
eloc	3
nc	2
nop	1
<?php

/**
 * API-like class to deal with HTTP(S) requests to diaspora* using WP_HTTP API.
 *
 * Basic functionality includes:
 * - Logging in to diaspora*
 * - Fetching a user's aspects and connected services
 * - Posting to diaspora*
 *
 * Ideas in this class are based on classes from:
 * https://github.com/Faldrian/WP-diaspora-postwidget/blob/master/wp-diaspora-postwidget/diasphp.php -- Thanks, Faldrian!
 * https://github.com/meitar/diasposter/blob/master/lib/Diaspora_Connection.php -- Thanks, Meitar
 *
 * Which in turn are based on:
 * https://github.com/cocreature/diaspy/blob/master/client.py -- Thanks, Moritz
 *
 * @package WP_To_Diaspora\API
 * @since 1.2.7
 */

// Exit if accessed directly.
defined( 'ABSPATH' ) || exit;

/**
 * API class to talk to diaspora*.
 */
class WP2D_API {
namespace YourVendor;

class YourClass { }

	/**
	 * The provider name to display when posting to diaspora*.
	 *
	 * @var string
	 */
	public $provider = 'WP to diaspora*';

	/**
	 * The last http request error that occurred.
	 *
	 * @var WP_Error
	 */
	private $_last_error;

	/**
	 * Security token to be used for making requests.
	 *
	 * @var string
	 */
	private $_token;

	/**
	 * Save the cookies for the requests.
	 *
	 * @var array
	 */
	private $_cookies;

	/**
	 * The last http request made to diaspora*.
	 * Contains the response and request infos.
	 *
	 * @var object
	 */
	private $_last_request;

	/**
	 * Is this a secure server, use HTTPS instead of HTTP?
	 *
	 * @var boolean
	 */
	private $_is_secure;

	/**
	 * The pod domain to make the http requests to.
	 *
	 * @var string
	 */
	private $_pod;

	/**
	 * Username to use when logging in to diaspora*.
	 *
	 * @var string
	 */
	private $_username;

	/**
	 * Password to use when logging in to diaspora*.
	 *
	 * @var string
	 */
	private $_password;

	/**
	 * Remember the current login state.
	 *
	 * @var boolean
	 */
	private $_is_logged_in = false;

	/**
	 * The list of user's aspects, which get set after ever http request.
	 *
	 * @var array
	 */
	private $_aspects = array();

	/**
	 * The list of user's connected services, which get set after ever http request.
	 *
	 * @var array
	 */
	private $_services = array();

	/**
	 * List of regex expressions used to filter out details from http request responses.
	 *
	 * @var array
	 */
	private $_regexes = array(
		'token'    => '/content="(.*?)" name="csrf-token"|name="csrf-token" content="(.*?)"/',
		'aspects'  => '/"aspects"\:(\[.*?\])/',
		'services' => '/"configured_services"\:(\[.*?\])/',
	);

	/**
	 * The full pod url, with the used protocol.
	 *
	 * @param string $path Path to add to the pod url.
	 * @return string Full pod url.
	 */
	public function get_pod_url( $path = '' ) {
		$path = trim( $path, ' /' );

		// Add a slash to the beginning?
		if ( '' !== $path ) {
			$path = '/' . $path;
		}

		return sprintf( 'http%s://%s%s', ( $this->_is_secure ) ? 's' : '', $this->_pod, $path );
	}

	/**
	 * Constructor to initialise the connection to diaspora*.
	 *
	 * @param string  $pod       The pod domain to connect to.
	 * @param boolean $is_secure Is this a secure server? (Default: true).
	 */
	public function __construct( $pod, $is_secure = true ) {
		// Set class variables.
		$this->_pod       = $pod;
		$this->_is_secure = (bool) $is_secure;
	}

	/**
	 * Initialise the connection to diaspora*. The pod and protocol can be changed by passing new parameters.
	 * Check if we can connect to the pod to retrieve the token.
	 *
	 * @param string  $pod       Pod domain to connect to, if it should be changed.
	 * @param boolean $is_secure Is this a secure server? (Default: true).
	 * @return boolean True if we could get the token, else false.
	 */
	public function init( $pod = null, $is_secure = true ) {
		// If we are changing pod, we need to fetch a new token.
		$force_new_token = false;

		// When initialising a connection, clear the last error.
		// This is important when multiple init tries happen.
		$this->_last_error = null;

		// Change the pod we are connecting to?
		if ( isset( $pod ) && ( $this->_pod !== $pod || $this->_is_secure !== $is_secure ) ) {
			$this->_pod       = $pod;
			$this->_is_secure = (bool) $is_secure;
			$force_new_token  = true;
		}

		// Get and save the token.
		if ( null === $this->_fetch_token( $force_new_token ) ) {
			$error = ( $this->has_last_error() ) ? ' ' . $this->get_last_error() : '';
			$this->_error( 'wp2d_api_init_failed',
				sprintf(
					_x( 'Failed to initialise connection to pod "%s".', 'Placeholder is the full pod URL.', 'wp-to-diaspora' ),
					$this->get_pod_url()
				) . $error,
				array( 'help_tab' => 'troubleshooting' )
			);

			return false;
		}
		return true;
	}

	/**
	 * Check if there is an API error around.
	 *
	 * @return boolean If there is an API error around.
	 */
	public function has_last_error() {
		return is_wp_error( $this->_last_error );
	}

	/**
	 * Get the last API error object.
	 *
	 * @param boolean $clear If the error should be cleared after returning it.
	 * @return WP_Error|null The last API error object or null.
	 */
	public function get_last_error_object( $clear = true ) {
		$last_error = $this->_last_error;
		$clear && $this->_last_error = null;
		return $last_error;
	}

	/**
	 * Get the last API error message.
	 *
	 * @param boolean $clear If the error should be cleared after returning it.
	 * @return string The last API error message.
	 */
	public function get_last_error( $clear = false ) {
		$last_error = ( $this->has_last_error() ) ? $this->_last_error->get_error_message() : '';
		$clear && $this->_last_error = null;
		return $last_error;
	}

	/**
	 * Fetch the secure token from Diaspora and save it for future use.
	 *
	 * @param boolean $force Force to fetch a new token.
	 * @return string The fetched token.
	 */
	private function _fetch_token( $force = false ) {
		if ( ! isset( $this->_token ) || (bool) $force ) {
			// Go directly to the sign in page, as it would redirect to there anyway.
			// Since _request function automatically saves the new token, just call it with no data.
			$this->_request( '/users/sign_in' );
		}
		return $this->_token;
	}

	/**
	 * Check if the API has been initialised. Otherwise set the last error.
	 *
	 * @return boolean Has the connection been initialised?
	 */
	private function _check_init() {
		if ( is_null( $this->_token ) ) {
			$this->_error( 'wp2d_api_connection_not_initialised', __( 'Connection not initialised.', 'wp-to-diaspora' ) );
			return false;
		}
		return true;
	}

	/**
	 * Check if we're logged in. Otherwise set the last error.
	 *
	 * @return boolean Are we logged in already?
	 */
	private function _check_login() {
		if ( ! $this->_check_init() ) {
			return false;
		}
		if ( ! $this->is_logged_in() ) {
			$this->_error( 'wp2d_api_not_logged_in', __( 'Not logged in.', 'wp-to-diaspora' ) );
			return false;
		}
		return true;
	}

	/**
	 * Check if we are logged in.
	 *
	 * @return boolean Are we logged in already?
	 */
	public function is_logged_in() {
		return $this->_is_logged_in;
	}

	/**
	 * Log in to diaspora*.
	 *
	 * @param string  $username Username used for login.
	 * @param string  $password Password used for login.
	 * @param boolean $force    Force a new login even if we are already logged in.
	 * @return boolean Did the login succeed?
	 */
	public function login( $username, $password, $force = false ) {
		// Has the connection been initialised?
		if ( ! $this->_check_init() ) {
			$this->logout();
			return false;
		}

		// Username and password both need to be set.
		$username = ( isset( $username ) && '' !== $username ) ? $username : null;
		$password = ( isset( $password ) && '' !== $password ) ? $password : null;
		if ( ! isset( $username, $password ) ) {
			$this->logout();
			return false;
		}

		// If we are already logged in and not forcing a relogin, return.
		if ( ! $force && $this->is_logged_in() &&
			$username === $this->_username &&
			$password === $this->_password ) {
			return true;
		}

		// Set the newly passed username and password.
		$this->_username = $username;
		$this->_password = $password;

		// Set up the login parameters.
		$params = array(
			'user[username]'     => $this->_username,
			'user[password]'     => $this->_password,
			'authenticity_token' => $this->_fetch_token(),
		);

		$args = array(
			'method' => 'POST',
			'body'   => $params,
		);

		// Try to sign in.
		$this->_request( '/users/sign_in', $args );

		// Can we load the bookmarklet to make sure we're logged in?
		$response = $this->_request( '/bookmarklet' );

		// If the request isn't successful, we are not logged in correctly.
		if ( is_wp_error( $response ) || 200 !== $response->code ) {
			// Login failed.
			$this->_error( 'wp2d_api_login_failed', __( 'Login failed. Check your login details.', 'wp-to-diaspora' ), array( 'help_tab' => 'troubleshooting' ) );
			$this->logout();
			return false;
		}

		// Login succeeded.
		$this->_is_logged_in = true;
		return true;
	}

	/**
	 * Perform a logout, resetting all login info.
	 *
	 * @since 1.6.0
	 */
	public function logout() {
		$this->_is_logged_in = false;
		$this->_username = null;
		$this->_password = null;
		$this->_aspects = array();
		$this->_services = array();
	}

	/**
	 * Perform a deinitialisation, resetting all class variables.
	 *
	 * @since 1.7.0
	 */
	public function deinit() {
		$this->logout();
		$this->_last_error = null;
		$this->_token = null;
		$this->_cookies = array();
		$this->_last_request = null;
	}

	/**
	 * Post to diaspora*.
	 *
	 * @param string       $text       The text to post.
	 * @param array|string $aspects    The aspects to post to. Array or comma seperated ids.
	 * @param array        $extra_data Any extra data to be added to the post call.
	 * @return boolean|object Return the response data of the new diaspora* post if successfully posted, else false.
	 */
	public function post( $text, $aspects = 'public', $extra_data = array() ) {
		// Are we logged in?
		if ( ! $this->_check_login() ) {
			return false;
		}

		// Put the aspects into a clean array.
		$aspects = array_filter( WP2D_Helpers::str_to_arr( $aspects ) );

		// If no aspects have been selected or the public one is also included, choose public only.
		if ( empty( $aspects ) || in_array( 'public', $aspects ) ) {
			$aspects = 'public';
		}

		// Prepare post data.
		$post_data = array(
			'aspect_ids'     => $aspects,
			'status_message' => array(
				'text' => $text,
				'provider_display_name' => $this->provider,
			),
		);

		// Add any extra data to the post.
		if ( ! empty( $extra_data ) ) {
				$post_data += $extra_data;
		}

		// Check if we can use the new wp_json_encode function.
		$post_data = ( function_exists( 'wp_json_encode' ) )
			? wp_json_encode( $post_data )
			: json_encode( $post_data );

		$args = array(
			'method'  => 'POST',
			'body'    => $post_data,
			'headers' => array(
				'Accept'       => 'application/json',
				'Content-Type' => 'application/json',
				'X-CSRF-Token' => $this->_fetch_token(),
			),
		);

		// Submit the post.
		$response = $this->_request( '/status_messages', $args );

		if ( is_wp_error( $response ) ) {
			$this->_error( 'wp2d_api_post_failed', $response->get_error_message() );
			return false;
		}

		$diaspost = json_decode( $response->body );
		if ( 201 !== $response->code ) {
			$this->_error( 'wp2d_api_post_failed', ( isset( $diaspost->error ) ) ? $diaspost->error : _x( 'Unknown error occurred.', 'When an unknown error occurred in the WP2D_API object.', 'wp-to-diaspora' ) );
			return false;
		}

		// Add additional info to our diaspora post object.
		$diaspost->permalink = $this->get_pod_url( '/posts/' . $diaspost->guid );

		return $diaspost;
	}

	/**
	 * Delete a post or comment from diaspora*.
	 *
	 * @since 1.6.0
	 *
	 * @param string $what What to delete, 'post' or 'comment'.
	 * @param string $id The ID of the post or comment to delete.
	 * @return boolean If the deletion was successful.
	 */
	public function delete( $what, $id ) {
		// Are we logged in?
		if ( ! $this->_check_login() ) {
			return false;
		}

		// For now, only deleting posts and comments is allowed.
		if ( ! in_array( $what, array( 'post', 'comment' ) ) ) {
			$this->_error( 'wp2d_api_delete_failed', __( 'You can only delete posts and comments.', 'wp-to-diaspora' ) );
			return false;
		}

		$args = array(
			'method'  => 'DELETE',
			'headers' => array(
				'Accept'       => 'application/json',
				'Content-Type' => 'application/json',
				'X-CSRF-Token' => $this->_fetch_token(),
			),
		);

		// Try to delete the post or comment.
		$response = $this->_request( '/' . $what . 's/' . $id, $args );

		$error_message = '';
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

		if ( is_wp_error( $response ) ) {
			$error_message = $response->get_error_message();
		} else {
			switch ( $response->code ) {
				case 204:
					return true;
				case 404:
					$error_message = ( 'post' === $what )
						? __( 'The post you tried to delete does not exist.', 'wp-to-diaspora' )
						: __( 'The comment you tried to delete does not exist.', 'wp-to-diaspora' );
					break;

				// Due to diaspora* returning a proper 403 when trying to delete a foreign comment
				// but returning a 500 when trying to delete a foreign post, this needs some special attention.
				case 403:
					if ( 'comment' === $what ) {
						$error_message = __( 'The comment you tried to delete does not belong to you.', 'wp-to-diaspora' );
						break;
					}
					// Fall through...
				case 500:
					if ( 'post' === $what ) {
						$error_message = __( 'The post you tried to delete does not belong to you.', 'wp-to-diaspora' );
						break;
					}
					// Fall through...
				default:
					$error_message = _x( 'Unknown error occurred.', 'When an unknown error occurred in the WP2D_API object.', 'wp-to-diaspora' );
					break;
			}
		}

		$this->_error( 'wp2d_api_delete_' . $what . '_failed', $error_message );
		return false;
	}

	/**
	 * Get the list of aspects.
	 *
	 * @param boolean $force Force to fetch new aspects.
	 * @return array Array of aspect objects.
	 */
	public function get_aspects( $force = false ) {
		$this->_aspects = $this->_get_aspects_services( 'aspects', $this->_aspects, $force );
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
		return ( is_array( $this->_aspects ) ) ? $this->_aspects : false;
	}

	/**
	 * Get the list of connected services.
	 *
	 * @param boolean $force Force to fetch new connected services.
	 * @return array Array of service objects.
	 */
	public function get_services( $force = false ) {
		$this->_services = $this->_get_aspects_services( 'services', $this->_services, $force );
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
		return ( is_array( $this->_services ) ) ? $this->_services : false;
	}

	/**
	 * Get the list of aspects or connected services.
	 *
	 * @param string  $type  Type of list to get.
	 * @param array   $list  The current list of items.
	 * @param boolean $force Force to fetch new list.
	 * @return boolean Was the list fetched successfully?
	 */
	private function _get_aspects_services( $type, $list, $force ) {
		if ( ! $this->_check_login() ) {
			return false;
		}

		// Fetch the new list if the current list is empty or a reload is forced.
		if ( empty( $list ) || (bool) $force ) {
			$response = $this->_request( '/bookmarklet' );

			if ( is_wp_error( $response ) || 200 !== $response->code ) {
				switch ( $type ) {
					case 'aspects':
						$this->_error( 'wp2d_api_getting_aspects_failed', __( 'Error loading aspects.', 'wp-to-diaspora' ) );
						break;
					case 'services':
						$this->_error( 'wp2d_api_getting_services_failed', __( 'Error loading services.', 'wp-to-diaspora' ) );
						break;
					default:
						$this->_error( 'wp2d_api_getting_aspects_services_failed', _x( 'Unknown error occurred.', 'When an unknown error occurred in the WP2D_API object.', 'wp-to-diaspora' ) );
						break;
				}
				return false;
			}

			// Load the aspects or services.
			if ( is_array( $raw_list = json_decode( $this->_parse_regex( $type, $response->body ) ) ) ) {
				// In case this fetch is forced, empty the list.
				$list = array();

				switch ( $type ) {
					case 'aspects':
						// Add the 'public' aspect, as it's global and not user specific.
						$list['public'] = __( 'Public', 'wp-to-diaspora' );

						// Add all user specific aspects.
						foreach ( $raw_list as $aspect ) {
							$list[ $aspect->id ] = $aspect->name;
						}
						break;
					case 'services':
						foreach ( $raw_list as $service ) {
							$list[ $service ] = ucfirst( $service );
						}
						break;
				}
			}
		}
		return $list;
	}

	/**
	 * Send an http(s) request via WP_HTTP API.
	 *
	 * @see WP_Http::request()
	 *
	 * @param string $url  The URL to request.
	 * @param array  $args Arguments to be posted with the request.
	 * @return object An object containing details about this request.
	 */
	private function _request( $url, $args = array() ) {
		// Prefix the full pod URL if necessary.
		if ( 0 === strpos( $url, '/' ) ) {
			$url = $this->get_pod_url( $url );
		}

		// Disable redirections so we can verify HTTP response codes.
		$defaults = array(
			'redirection' => 0,
			'sslverify'   => true,
			'timeout'     => 60,
			'method'      => 'GET',
		);

		// If the certificate bundle has been downloaded manually, use that instead.
		// NOTE: This should actually never be necessary, it's a fallback!
		if ( file_exists( WP2D_DIR . '/cacert.pem' ) ) {
			$defaults['sslcertificates'] = WP2D_DIR . '/cacert.pem';
		}

		// Set the correct cookie.
		if ( ! empty( $this->_cookies ) ) {
			$defaults['cookies'] = $this->_cookies;
		}

		$args = wp_parse_args( $args, $defaults );

		// Get the response from the WP_HTTP request.
		$response = wp_remote_request( $url, $args );

		if ( is_wp_error( $response ) ) {
			$this->_last_error = $response;
			return $response;
		}

		// Get the headers and the html response.
		$headers = wp_remote_retrieve_headers( $response );
		$body    = wp_remote_retrieve_body( $response );

		// Remember this request.
		$this->_last_request = new stdClass();
		$this->_last_request->response = $response;
		$this->_last_request->headers  = $headers;
		$this->_last_request->body     = $body;
		$this->_last_request->message  = wp_remote_retrieve_response_message( $response );
		$this->_last_request->code     = wp_remote_retrieve_response_code( $response );

		// Save the new token.
		if ( $token = $this->_parse_regex( 'token', $body ) ) {
			$this->_token = $token;
		}

		// Save the latest cookies.
		if ( isset( $response['cookies'] ) ) {
			$this->_cookies = $response['cookies'];
		}

		// Return the last request details.
		return $this->_last_request;
	}

	/**
	 * Helper method to set the last occurred error.
	 *
	 * @see WP_Error::__construct()
	 * @since 1.6.0
	 *
	 * @param  string|int $code    Error code.
	 * @param  string     $message Error message.
	 * @param  mixed      $data    Error data.
	 */
	private function _error( $code, $message, $data = '' ) {
		// Always add the code and message of the last request.
		$data = array_merge( array_filter( (array) $data ), array(
			'code'    => ( isset( $this->_last_request->code ) ) ? $this->_last_request->code : null,
			'message' => ( isset( $this->_last_request->message ) ) ? $this->_last_request->message : null,
		) );
		$this->_last_error = new WP_Error( $code, $message, $data );
	}

	/**
	 * Parse the regex and return the found string.
	 *
	 * @param string $regex   Shorthand of a saved regex or a custom regex.
	 * @param string $content Text to parse the regex with.
	 * @return string The found string, or an empty string.
	 */
	private function _parse_regex( $regex, $content ) {
		// Use a shorthand regex if available.
		if ( array_key_exists( $regex, $this->_regexes ) ) {
			$regex = $this->_regexes[ $regex ];
		}

		preg_match( $regex, $content, $matches );
		return trim( array_pop( $matches ) );
	}
}

gutobenn / wp-to-diaspora

WP2D_API::get_services() A last analyzed 2017-01-13 12:04 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

WP2D_API::get_services() A
last analyzed 2017-01-13 12:04 UTC
