litefeel / writing-on-github

lib/client/base.php

Indentation +200 added lines, -200 removed lines

@@ -9,204 +9,204 @@
  */
 class Writing_On_GitHub_Base_Client {
 
-    const HOST_OPTION_KEY   = 'wogh_host';
-    const TOKEN_OPTION_KEY  = 'wogh_oauth_token';
-    const REPO_OPTION_KEY   = 'wogh_repository';
-    const BRANCH_OPTION_KEY = 'wogh_branch';
-
-    /**
-     * Application container.
-     *
-     * @var Writing_On_GitHub
-     */
-    protected $app;
-
-    /**
-     * Instantiates a new Api object.
-     *
-     * @param Writing_On_GitHub $app Application container.
-     */
-    public function __construct( Writing_On_GitHub $app ) {
-        $this->app = $app;
-    }
-
-    /**
-     * Generic GitHub API interface and response handler
-     *
-     * @param string $method HTTP method.
-     * @param string $endpoint API endpoint.
-     * @param array  $body Request body.
-     *
-     * @return stdClass|WP_Error
-     */
-    protected function call( $method, $endpoint, $body = array() ) {
-        if ( is_wp_error( $error = $this->can_call() ) ) {
-            /*　@var WP_Error $error */
-            return $error;
-        }
-
-        $args = array(
-            'method'  => $method,
-            'headers' => array(
-                'Authorization' => 'token ' . $this->oauth_token(),
-            ),
-        );
-
-        if ( 'GET' !== $method ) {
-            $args['body'] = json_encode( $body );
-        }
-
-        // $tmpbody = isset( $args['body'] ) ? $args['body'] : '';
-        // error_log( "writing-on-github-call $method $endpoint $tmpbody" );
-
-        $response = wp_remote_request( $endpoint, $args );
-        $status   = wp_remote_retrieve_header( $response, 'status' );
-        $body     = json_decode( wp_remote_retrieve_body( $response ) );
-
-        if ( '2' !== substr( $status, 0, 1 ) && '3' !== substr( $status, 0, 1 ) ) {
-            return new WP_Error(
-                strtolower( str_replace( ' ', '_', $status ) ),
-                sprintf(
-                    __( 'Method %s to endpoint %s failed with error: %s', 'writing-on-github' ),
-                    $method,
-                    $endpoint,
-                    ( $body && $body->message ) ? $body->message : 'Unknown error'
-                )
-            );
-        }
-
-        return $body;
-    }
-
-    /**
-     * Validates whether the Api object can make a call.
-     *
-     * @return true|WP_Error
-     */
-    protected function can_call() {
-        if ( ! $this->oauth_token() ) {
-            return new WP_Error(
-                'missing_token',
-                __( 'Writing On GitHub needs an auth token. Please update your settings.', 'writing-on-github' )
-            );
-        }
-
-        $repo = $this->repository();
-
-        if ( ! $repo ) {
-            return new WP_Error(
-                'missing_repository',
-                __( 'Writing On GitHub needs a repository. Please update your settings.', 'writing-on-github' )
-            );
-        }
-
-        $parts = explode( '/', $repo );
-
-        if ( 2 !== count( $parts ) ) {
-            return new WP_Error(
-                'malformed_repository',
-                __( 'Writing On GitHub needs a properly formed repository. Please update your settings.', 'writing-on-github' )
-            );
-        }
-
-        return true;
-    }
-
-    /**
-     * Returns the repository to sync with
-     *
-     * @return string
-     */
-    public function repository() {
-        return (string) get_option( self::REPO_OPTION_KEY );
-    }
-
-    /**
-     * Returns the user's oauth token
-     *
-     * @return string
-     */
-    public function oauth_token() {
-        return (string) get_option( self::TOKEN_OPTION_KEY );
-    }
-
-    /**
-     * Returns the GitHub host to sync with (for GitHub Enterprise support)
-     */
-    public function api_base() {
-        return get_option( self::HOST_OPTION_KEY );
-    }
-
-    public function branch() {
-        $branch = get_option( self::BRANCH_OPTION_KEY );
-        return $branch ? $branch : 'master';
-    }
-
-    /**
-     * API endpoint for the master branch reference
-     */
-    public function reference_endpoint() {
-        $url = $this->api_base() . '/repos/';
-        $url = $url . $this->repository() . '/git/refs/heads/' . $this->branch();
-
-        return $url;
-    }
-
-    /**
-     * Api to get and create commits
-     */
-    public function commit_endpoint() {
-        $url = $this->api_base() . '/repos/';
-        $url = $url . $this->repository() . '/git/commits';
-
-        return $url;
-    }
-
-    /**
-     * Api to compare commits
-     */
-    public function compare_endpoint() {
-        $url = $this->api_base() . '/repos/';
-        $url = $url . $this->repository() . '/compare';
-
-        return $url;
-    }
-
-    /**
-     * Api to get and create trees
-     */
-    public function tree_endpoint() {
-        $url = $this->api_base() . '/repos/';
-        $url = $url . $this->repository() . '/git/trees';
-
-        return $url;
-    }
-
-    /**
-     * Builds the proper blob API endpoint for a given post
-     *
-     * Returns String the relative API call path
-     */
-    public function blob_endpoint() {
-        $url = $this->api_base() . '/repos/';
-        $url = $url . $this->repository() . '/git/blobs';
-
-        return $url;
-    }
-
-    /**
-     * Builds the proper content API endpoint for a given post
-     *
-     * Returns String the relative API call path
-     */
-    public function content_endpoint( $path = false ) {
-        $url = $this->api_base() . '/repos/';
-        $url = $url . $this->repository() . '/contents';
-
-        if ( ! empty($path) ) {
-            $url .= '/' . $path;
-        }
-
-        return $url;
-    }
+	const HOST_OPTION_KEY   = 'wogh_host';
+	const TOKEN_OPTION_KEY  = 'wogh_oauth_token';
+	const REPO_OPTION_KEY   = 'wogh_repository';
+	const BRANCH_OPTION_KEY = 'wogh_branch';
+
+	/**
+	 * Application container.
+	 *
+	 * @var Writing_On_GitHub
+	 */
+	protected $app;
+
+	/**
+	 * Instantiates a new Api object.
+	 *
+	 * @param Writing_On_GitHub $app Application container.
+	 */
+	public function __construct( Writing_On_GitHub $app ) {
+		$this->app = $app;
+	}
+
+	/**
+	 * Generic GitHub API interface and response handler
+	 *
+	 * @param string $method HTTP method.
+	 * @param string $endpoint API endpoint.
+	 * @param array  $body Request body.
+	 *
+	 * @return stdClass|WP_Error
+	 */
+	protected function call( $method, $endpoint, $body = array() ) {
+		if ( is_wp_error( $error = $this->can_call() ) ) {
+			/*　@var WP_Error $error */
+			return $error;
+		}
+
+		$args = array(
+			'method'  => $method,
+			'headers' => array(
+				'Authorization' => 'token ' . $this->oauth_token(),
+			),
+		);
+
+		if ( 'GET' !== $method ) {
+			$args['body'] = json_encode( $body );
+		}
+
+		// $tmpbody = isset( $args['body'] ) ? $args['body'] : '';
+		// error_log( "writing-on-github-call $method $endpoint $tmpbody" );
+
+		$response = wp_remote_request( $endpoint, $args );
+		$status   = wp_remote_retrieve_header( $response, 'status' );
+		$body     = json_decode( wp_remote_retrieve_body( $response ) );
+
+		if ( '2' !== substr( $status, 0, 1 ) && '3' !== substr( $status, 0, 1 ) ) {
+			return new WP_Error(
+				strtolower( str_replace( ' ', '_', $status ) ),
+				sprintf(
+					__( 'Method %s to endpoint %s failed with error: %s', 'writing-on-github' ),
+					$method,
+					$endpoint,
+					( $body && $body->message ) ? $body->message : 'Unknown error'
+				)
+			);
+		}
+
+		return $body;
+	}
+
+	/**
+	 * Validates whether the Api object can make a call.
+	 *
+	 * @return true|WP_Error
+	 */
+	protected function can_call() {
+		if ( ! $this->oauth_token() ) {
+			return new WP_Error(
+				'missing_token',
+				__( 'Writing On GitHub needs an auth token. Please update your settings.', 'writing-on-github' )
+			);
+		}
+
+		$repo = $this->repository();
+
+		if ( ! $repo ) {
+			return new WP_Error(
+				'missing_repository',
+				__( 'Writing On GitHub needs a repository. Please update your settings.', 'writing-on-github' )
+			);
+		}
+
+		$parts = explode( '/', $repo );
+
+		if ( 2 !== count( $parts ) ) {
+			return new WP_Error(
+				'malformed_repository',
+				__( 'Writing On GitHub needs a properly formed repository. Please update your settings.', 'writing-on-github' )
+			);
+		}
+
+		return true;
+	}
+
+	/**
+	 * Returns the repository to sync with
+	 *
+	 * @return string
+	 */
+	public function repository() {
+		return (string) get_option( self::REPO_OPTION_KEY );
+	}
+
+	/**
+	 * Returns the user's oauth token
+	 *
+	 * @return string
+	 */
+	public function oauth_token() {
+		return (string) get_option( self::TOKEN_OPTION_KEY );
+	}
+
+	/**
+	 * Returns the GitHub host to sync with (for GitHub Enterprise support)
+	 */
+	public function api_base() {
+		return get_option( self::HOST_OPTION_KEY );
+	}
+
+	public function branch() {
+		$branch = get_option( self::BRANCH_OPTION_KEY );
+		return $branch ? $branch : 'master';
+	}
+
+	/**
+	 * API endpoint for the master branch reference
+	 */
+	public function reference_endpoint() {
+		$url = $this->api_base() . '/repos/';
+		$url = $url . $this->repository() . '/git/refs/heads/' . $this->branch();
+
+		return $url;
+	}
+
+	/**
+	 * Api to get and create commits
+	 */
+	public function commit_endpoint() {
+		$url = $this->api_base() . '/repos/';
+		$url = $url . $this->repository() . '/git/commits';
+
+		return $url;
+	}
+
+	/**
+	 * Api to compare commits
+	 */
+	public function compare_endpoint() {
+		$url = $this->api_base() . '/repos/';
+		$url = $url . $this->repository() . '/compare';
+
+		return $url;
+	}
+
+	/**
+	 * Api to get and create trees
+	 */
+	public function tree_endpoint() {
+		$url = $this->api_base() . '/repos/';
+		$url = $url . $this->repository() . '/git/trees';
+
+		return $url;
+	}
+
+	/**
+	 * Builds the proper blob API endpoint for a given post
+	 *
+	 * Returns String the relative API call path
+	 */
+	public function blob_endpoint() {
+		$url = $this->api_base() . '/repos/';
+		$url = $url . $this->repository() . '/git/blobs';
+
+		return $url;
+	}
+
+	/**
+	 * Builds the proper content API endpoint for a given post
+	 *
+	 * Returns String the relative API call path
+	 */
+	public function content_endpoint( $path = false ) {
+		$url = $this->api_base() . '/repos/';
+		$url = $url . $this->repository() . '/contents';
+
+		if ( ! empty($path) ) {
+			$url .= '/' . $path;
+		}
+
+		return $url;
+	}
 }

lib/client/persist.php

Indentation +60 added lines, -60 removed lines

@@ -9,75 +9,75 @@
  */
 class Writing_On_GitHub_Persist_Client extends Writing_On_GitHub_Base_Client {
 
-    /**
-     * Get the data for the current user.
-     *
-     * @return array
-     */
-    protected function export_user() {
-        $user_id = get_current_user_id();
-        $user = get_userdata( $user_id );
+	/**
+	 * Get the data for the current user.
+	 *
+	 * @return array
+	 */
+	protected function export_user() {
+		$user_id = get_current_user_id();
+		$user = get_userdata( $user_id );
 
-        if ( $user ) {
-            return array(
-                'name'  => $user->display_name,
-                'email' => $user->user_email,
-            );
-        }
+		if ( $user ) {
+			return array(
+				'name'  => $user->display_name,
+				'email' => $user->user_email,
+			);
+		}
 
-        return false;
-    }
+		return false;
+	}
 
-    /**
-     * Delete the file.
-     *
-     * @return array
-     */
-    public function delete_file( $path, $sha, $message ) {
-        $body = new stdClass();
-        $body->message = $message;
-        $body->sha = $sha;
-        $body->branch = $this->branch();
+	/**
+	 * Delete the file.
+	 *
+	 * @return array
+	 */
+	public function delete_file( $path, $sha, $message ) {
+		$body = new stdClass();
+		$body->message = $message;
+		$body->sha = $sha;
+		$body->branch = $this->branch();
 
-        if ( $author = $this->export_user() ) {
-            $body->author = $author;
-        }
+		if ( $author = $this->export_user() ) {
+			$body->author = $author;
+		}
 
-        return $this->call( 'DELETE', $this->content_endpoint( $path ), $body );
-    }
+		return $this->call( 'DELETE', $this->content_endpoint( $path ), $body );
+	}
 
-    /**
-     * Create the file.
-     *
-     * @return array
-     */
-    public function create_file( $blob, $message ) {
-        $body = $blob->to_body();
-        $body->message = $message;
-        $body->branch = $this->branch();
-        unset($body->sha);
+	/**
+	 * Create the file.
+	 *
+	 * @return array
+	 */
+	public function create_file( $blob, $message ) {
+		$body = $blob->to_body();
+		$body->message = $message;
+		$body->branch = $this->branch();
+		unset($body->sha);
 
-        if ( $author = $this->export_user() ) {
-            $body->author = $author;
-        }
+		if ( $author = $this->export_user() ) {
+			$body->author = $author;
+		}
 
-        return $this->call( 'PUT', $this->content_endpoint( $blob->path() ), $body );
-    }
+		return $this->call( 'PUT', $this->content_endpoint( $blob->path() ), $body );
+	}
 
-    /**
-     * Update the file.
-     *
-     * @return array
-     */
-    public function update_file( $blob, $message ) {
-        $body = $blob->to_body();
-        $body->message = $message;
-        $body->branch = $this->branch();
+	/**
+	 * Update the file.
+	 *
+	 * @return array
+	 */
+	public function update_file( $blob, $message ) {
+		$body = $blob->to_body();
+		$body->message = $message;
+		$body->branch = $this->branch();
 
-        if ( $author = $this->export_user() ) {
-            $body->author = $author;
-        }
+		if ( $author = $this->export_user() ) {
+			$body->author = $author;
+		}
 
-        return $this->call( 'PUT', $this->content_endpoint( $blob->path() ), $body );
-    }
+		return $this->call( 'PUT', $this->content_endpoint( $blob->path() ), $body );
+	}
 }

lib/response.php

Indentation +70 added lines, -70 removed lines

@@ -9,87 +9,87 @@
  */
 class Writing_On_GitHub_Response {
 
-    /**
-     * Application container.
-     *
-     * @var Writing_On_GitHub
-     */
-    protected $app;
+	/**
+	 * Application container.
+	 *
+	 * @var Writing_On_GitHub
+	 */
+	protected $app;
 
-    /**
-     * Writing_On_GitHub_Response constructor.
-     *
-     * @param Writing_On_GitHub $app Application container.
-     */
-    public function __construct( Writing_On_GitHub $app ) {
-        $this->app = $app;
-    }
+	/**
+	 * Writing_On_GitHub_Response constructor.
+	 *
+	 * @param Writing_On_GitHub $app Application container.
+	 */
+	public function __construct( Writing_On_GitHub $app ) {
+		$this->app = $app;
+	}
 
-    /**
-     * Writes to the log and returns the error response.
-     *
-     * @param WP_Error $error Error to respond with.
-     *
-     * @return false
-     */
-    public function error( WP_Error $error ) {
-        global $wp_version;
+	/**
+	 * Writes to the log and returns the error response.
+	 *
+	 * @param WP_Error $error Error to respond with.
+	 *
+	 * @return false
+	 */
+	public function error( WP_Error $error ) {
+		global $wp_version;
 
-        $this->log( $error );
+		$this->log( $error );
 
-        if ( defined( 'DOING_AJAX' ) && DOING_AJAX && defined( 'WOGH_AJAX' ) && WOGH_AJAX ) {
-            /**
-             * WordPress 4.1.0 introduced allowing WP_Error objects to be
-             * passed directly into `wp_send_json_error`. This shims in
-             * compatibility for older versions. We're currently supporting 3.9+.
-             */
-            if ( version_compare( $wp_version, '4.1.0', '<' ) ) {
-                $result = array();
+		if ( defined( 'DOING_AJAX' ) && DOING_AJAX && defined( 'WOGH_AJAX' ) && WOGH_AJAX ) {
+			/**
+			 * WordPress 4.1.0 introduced allowing WP_Error objects to be
+			 * passed directly into `wp_send_json_error`. This shims in
+			 * compatibility for older versions. We're currently supporting 3.9+.
+			 */
+			if ( version_compare( $wp_version, '4.1.0', '<' ) ) {
+				$result = array();
 
-                foreach ( $error->errors as $code => $messages ) {
-                    foreach ( $messages as $message ) {
-                        $result[] = array( 'code' => $code, 'message' => $message );
-                    }
-                }
+				foreach ( $error->errors as $code => $messages ) {
+					foreach ( $messages as $message ) {
+						$result[] = array( 'code' => $code, 'message' => $message );
+					}
+				}
 
-                $error = $result;
-            }
+				$error = $result;
+			}
 
-            wp_send_json_error( $error );
-        }
+			wp_send_json_error( $error );
+		}
 
-        return false;
-    }
+		return false;
+	}
 
-    /**
-     * Writes to the log and returns the success response.
-     *
-     * @param string $success Success message to respond with.
-     *
-     * @return true
-     */
-    public function success( $success ) {
-        $this->log( $success );
+	/**
+	 * Writes to the log and returns the success response.
+	 *
+	 * @param string $success Success message to respond with.
+	 *
+	 * @return true
+	 */
+	public function success( $success ) {
+		$this->log( $success );
 
-        if ( defined( 'DOING_AJAX' ) && DOING_AJAX && defined( 'WOGH_AJAX' ) && WOGH_AJAX ) {
-            wp_send_json_success( $success );
-        }
+		if ( defined( 'DOING_AJAX' ) && DOING_AJAX && defined( 'WOGH_AJAX' ) && WOGH_AJAX ) {
+			wp_send_json_success( $success );
+		}
 
-        return true;
-    }
+		return true;
+	}
 
-    /**
-     * Writes a log message.
-     *
-     * Can extract a message from WP_Error object.
-     *
-     * @param string|WP_Error $msg Message to log.
-     */
-    protected function log( $msg ) {
-        if ( is_wp_error( $msg ) ) {
-            $msg = $msg->get_error_message();
-        }
+	/**
+	 * Writes a log message.
+	 *
+	 * Can extract a message from WP_Error object.
+	 *
+	 * @param string|WP_Error $msg Message to log.
+	 */
+	protected function log( $msg ) {
+		if ( is_wp_error( $msg ) ) {
+			$msg = $msg->get_error_message();
+		}
 
-        Writing_On_GitHub::write_log( $msg );
-    }
+		Writing_On_GitHub::write_log( $msg );
+	}
 }

lib/cli.php

Indentation +146 added lines, -146 removed lines

@@ -9,150 +9,150 @@
  */
 class Writing_On_GitHub_CLI extends WP_CLI_Command {
 
-    /**
-     * Application container.
-     *
-     * @var Writing_On_GitHub
-     */
-    protected $app;
-
-    /**
-     * Grab the Application container on instantiation.
-     */
-    public function __construct() {
-        $this->app = Writing_On_GitHub::$instance;
-    }
-
-    /**
-     * Exports an individual post
-     * all your posts to GitHub
-     *
-     * ## OPTIONS
-     *
-     * <post_id|all>
-     * : The post ID to export or 'all' for full site
-     *
-     * <user_id>
-     * : The user ID you'd like to save the commit as
-     *
-     * ## EXAMPLES
-     *
-     *     wp wogh export all 1
-     *     wp wogh export 1 1
-     *
-     * @synopsis <post_id|all> <user_id>
-     *
-     * @param array $args Command arguments.
-     */
-    public function export( $args ) {
-        list( $post_id, $user_id ) = $args;
-
-        if ( ! is_numeric( $user_id ) ) {
-            WP_CLI::error( __( 'Invalid user ID', 'writing-on-github' ) );
-        }
-
-        $this->app->export()->set_user( $user_id );
-
-        if ( 'all' === $post_id ) {
-            WP_CLI::line( __( 'Starting full export to GitHub.', 'writing-on-github' ) );
-            $this->app->controller()->export_all();
-        } elseif ( is_numeric( $post_id ) ) {
-            WP_CLI::line(
-                sprintf(
-                    __( 'Exporting post ID to GitHub: %d', 'writing-on-github' ),
-                    $post_id
-                )
-            );
-            $this->app->controller()->export_post( (int) $post_id );
-        } else {
-            WP_CLI::error( __( 'Invalid post ID', 'writing-on-github' ) );
-        }
-    }
-
-    /**
-     * Imports the post in your GitHub repo
-     * into your WordPress blog
-     *
-     * ## OPTIONS
-     *
-     * <user_id>
-     * : The user ID you'd like to save the commit as
-     *
-     * ## EXAMPLES
-     *
-     *     wp wogh import 1
-     *
-     * @synopsis <user_id>
-     *
-     * @param array $args Command arguments.
-     */
-    public function import( $args ) {
-        list( $user_id ) = $args;
-
-        if ( ! is_numeric( $user_id ) ) {
-            WP_CLI::error( __( 'Invalid user ID', 'writing-on-github' ) );
-        }
-
-        update_option( '_wogh_export_user_id', (int) $user_id );
-
-        WP_CLI::line( __( 'Starting import from GitHub.', 'writing-on-github' ) );
-
-        $this->app->controller()->import_master();
-    }
-
-    /**
-     * Fetches the provided sha or the repository's
-     * master branch and caches it.
-     *
-     * ## OPTIONS
-     *
-     * <user_id>
-     * : The user ID you'd like to save the commit as
-     *
-     * ## EXAMPLES
-     *
-     *     wp wogh prime --branch=master
-     *     wp wogh prime --sha=<commit_sha>
-     *
-     * @synopsis [--sha=<commit_sha>] [--branch]
-     *
-     * @param array $args Command arguments.
-     * @param array $assoc_args Command associated arguments.
-     */
-    public function prime( $args, $assoc_args ) {
-        if ( isset( $assoc_args['branch'] ) ) {
-            WP_CLI::line( __( 'Starting branch import.', 'writing-on-github' ) );
-
-            $commit = $this->app->api()->fetch()->master();
-
-            if ( is_wp_error( $commit ) ) {
-                WP_CLI::error(
-                    sprintf(
-                        __( 'Failed to import and cache branch with error: %s', 'writing-on-github' ),
-                        $commit->get_error_message()
-                    )
-                );
-            } else {
-                WP_CLI::success(
-                    sprintf(
-                        __( 'Successfully imported and cached commit %s from branch.', 'writing-on-github' ),
-                        $commit->sha()
-                    )
-                );
-            }
-        } else if ( isset( $assoc_args['sha'] ) ) {
-            WP_CLI::line( 'Starting sha import.' );
-
-            $commit = $this->app->api()->fetch()->commit( $assoc_args['sha'] );
-
-            WP_CLI::success(
-                sprintf(
-                    __( 'Successfully imported and cached commit %s.', 'writing-on-github' ),
-                    $commit->sha()
-                )
-            );
-        } else {
-            WP_CLI::error( 'Invalid fetch.' );
-        }
-    }
+	/**
+	 * Application container.
+	 *
+	 * @var Writing_On_GitHub
+	 */
+	protected $app;
+
+	/**
+	 * Grab the Application container on instantiation.
+	 */
+	public function __construct() {
+		$this->app = Writing_On_GitHub::$instance;
+	}
+
+	/**
+	 * Exports an individual post
+	 * all your posts to GitHub
+	 *
+	 * ## OPTIONS
+	 *
+	 * <post_id|all>
+	 * : The post ID to export or 'all' for full site
+	 *
+	 * <user_id>
+	 * : The user ID you'd like to save the commit as
+	 *
+	 * ## EXAMPLES
+	 *
+	 *     wp wogh export all 1
+	 *     wp wogh export 1 1
+	 *
+	 * @synopsis <post_id|all> <user_id>
+	 *
+	 * @param array $args Command arguments.
+	 */
+	public function export( $args ) {
+		list( $post_id, $user_id ) = $args;
+
+		if ( ! is_numeric( $user_id ) ) {
+			WP_CLI::error( __( 'Invalid user ID', 'writing-on-github' ) );
+		}
+
+		$this->app->export()->set_user( $user_id );
+
+		if ( 'all' === $post_id ) {
+			WP_CLI::line( __( 'Starting full export to GitHub.', 'writing-on-github' ) );
+			$this->app->controller()->export_all();
+		} elseif ( is_numeric( $post_id ) ) {
+			WP_CLI::line(
+				sprintf(
+					__( 'Exporting post ID to GitHub: %d', 'writing-on-github' ),
+					$post_id
+				)
+			);
+			$this->app->controller()->export_post( (int) $post_id );
+		} else {
+			WP_CLI::error( __( 'Invalid post ID', 'writing-on-github' ) );
+		}
+	}
+
+	/**
+	 * Imports the post in your GitHub repo
+	 * into your WordPress blog
+	 *
+	 * ## OPTIONS
+	 *
+	 * <user_id>
+	 * : The user ID you'd like to save the commit as
+	 *
+	 * ## EXAMPLES
+	 *
+	 *     wp wogh import 1
+	 *
+	 * @synopsis <user_id>
+	 *
+	 * @param array $args Command arguments.
+	 */
+	public function import( $args ) {
+		list( $user_id ) = $args;
+
+		if ( ! is_numeric( $user_id ) ) {
+			WP_CLI::error( __( 'Invalid user ID', 'writing-on-github' ) );
+		}
+
+		update_option( '_wogh_export_user_id', (int) $user_id );
+
+		WP_CLI::line( __( 'Starting import from GitHub.', 'writing-on-github' ) );
+
+		$this->app->controller()->import_master();
+	}
+
+	/**
+	 * Fetches the provided sha or the repository's
+	 * master branch and caches it.
+	 *
+	 * ## OPTIONS
+	 *
+	 * <user_id>
+	 * : The user ID you'd like to save the commit as
+	 *
+	 * ## EXAMPLES
+	 *
+	 *     wp wogh prime --branch=master
+	 *     wp wogh prime --sha=<commit_sha>
+	 *
+	 * @synopsis [--sha=<commit_sha>] [--branch]
+	 *
+	 * @param array $args Command arguments.
+	 * @param array $assoc_args Command associated arguments.
+	 */
+	public function prime( $args, $assoc_args ) {
+		if ( isset( $assoc_args['branch'] ) ) {
+			WP_CLI::line( __( 'Starting branch import.', 'writing-on-github' ) );
+
+			$commit = $this->app->api()->fetch()->master();
+
+			if ( is_wp_error( $commit ) ) {
+				WP_CLI::error(
+					sprintf(
+						__( 'Failed to import and cache branch with error: %s', 'writing-on-github' ),
+						$commit->get_error_message()
+					)
+				);
+			} else {
+				WP_CLI::success(
+					sprintf(
+						__( 'Successfully imported and cached commit %s from branch.', 'writing-on-github' ),
+						$commit->sha()
+					)
+				);
+			}
+		} else if ( isset( $assoc_args['sha'] ) ) {
+			WP_CLI::line( 'Starting sha import.' );
+
+			$commit = $this->app->api()->fetch()->commit( $assoc_args['sha'] );
+
+			WP_CLI::success(
+				sprintf(
+					__( 'Successfully imported and cached commit %s.', 'writing-on-github' ),
+					$commit->sha()
+				)
+			);
+		} else {
+			WP_CLI::error( 'Invalid fetch.' );
+		}
+	}
 }

lib/api.php

Indentation +48 added lines, -48 removed lines

@@ -9,59 +9,59 @@
  */
 class Writing_On_GitHub_Api {
 
-    /**
-     * Application container.
-     *
-     * @var Writing_On_GitHub
-     */
-    protected $app;
+	/**
+	 * Application container.
+	 *
+	 * @var Writing_On_GitHub
+	 */
+	protected $app;
 
-    /**
-     * GitHub fetch client.
-     *
-     * @var Writing_On_GitHub_Fetch_Client
-     */
-    protected $fetch;
+	/**
+	 * GitHub fetch client.
+	 *
+	 * @var Writing_On_GitHub_Fetch_Client
+	 */
+	protected $fetch;
 
-    /**
-     * Github persist client.
-     *
-     * @var Writing_On_GitHub_Persist_Client
-     */
-    protected $persist;
+	/**
+	 * Github persist client.
+	 *
+	 * @var Writing_On_GitHub_Persist_Client
+	 */
+	protected $persist;
 
-    /**
-     * Instantiates a new Api object.
-     *
-     * @param Writing_On_GitHub $app Application container.
-     */
-    public function __construct( Writing_On_GitHub $app ) {
-        $this->app = $app;
-    }
+	/**
+	 * Instantiates a new Api object.
+	 *
+	 * @param Writing_On_GitHub $app Application container.
+	 */
+	public function __construct( Writing_On_GitHub $app ) {
+		$this->app = $app;
+	}
 
-    /**
-     * Lazy-load fetch client.
-     *
-     * @return Writing_On_GitHub_Fetch_Client
-     */
-    public function fetch() {
-        if ( ! $this->fetch ) {
-            $this->fetch = new Writing_On_GitHub_Fetch_Client( $this->app );
-        }
+	/**
+	 * Lazy-load fetch client.
+	 *
+	 * @return Writing_On_GitHub_Fetch_Client
+	 */
+	public function fetch() {
+		if ( ! $this->fetch ) {
+			$this->fetch = new Writing_On_GitHub_Fetch_Client( $this->app );
+		}
 
-        return $this->fetch;
-    }
+		return $this->fetch;
+	}
 
-    /**
-     * Lazy-load persist client.
-     *
-     * @return Writing_On_GitHub_Persist_Client
-     */
-    public function persist() {
-        if ( ! $this->persist ) {
-            $this->persist = new Writing_On_GitHub_Persist_Client( $this->app );
-        }
+	/**
+	 * Lazy-load persist client.
+	 *
+	 * @return Writing_On_GitHub_Persist_Client
+	 */
+	public function persist() {
+		if ( ! $this->persist ) {
+			$this->persist = new Writing_On_GitHub_Persist_Client( $this->app );
+		}
 
-        return $this->persist;
-    }
+		return $this->persist;
+	}
 }

lib/fileinfo.php

Indentation +8 added lines, -8 removed lines

@@ -6,13 +6,13 @@
  */
 class Writing_On_GitHub_File_Info {
 
-    public function __construct( stdClass $data ) {
-        $this->sha          = $data->sha;
-        $this->path         = $data->path;
-        $this->status       = $data->status;
-    }
+	public function __construct( stdClass $data ) {
+		$this->sha          = $data->sha;
+		$this->path         = $data->path;
+		$this->status       = $data->status;
+	}
 
-    public $sha;
-    public $path;
-    public $status;  // added removed modified
+	public $sha;
+	public $path;
+	public $status;  // added removed modified
 }

lib/semaphore.php

Indentation +51 added lines, -51 removed lines

@@ -9,55 +9,55 @@
  */
 class Writing_On_GitHub_Semaphore {
 
-    /**
-     * Sempahore's option key.
-     */
-    const KEY = 'wogh_semaphore_lock';
-
-    /**
-     * Option key when semaphore is locked.
-     */
-    const VALUE_LOCKED = 'yes';
-
-    /**
-     * Option key when semaphore is unlocked.
-     */
-    const VALUE_UNLOCKED = 'no';
-
-    /**
-     * Clean up the old values on instantiation.
-     */
-    public function __construct() {
-        delete_option( self::KEY );
-    }
-
-    /**
-     * Checks if the Semaphore is open.
-     *
-     * Fails to report it's open if the the Api class can't make a call
-     * or the push lock has been enabled.
-     *
-     * @return bool
-     */
-    public function is_open() {
-        if ( self::VALUE_LOCKED === get_transient( self::KEY ) ) {
-            return false;
-        }
-
-        return true;
-    }
-
-    /**
-     * Enables the push lock.
-     */
-    public function lock() {
-        set_transient( self::KEY, self::VALUE_LOCKED, MINUTE_IN_SECONDS );
-    }
-
-    /**
-     * Disables the push lock.
-     */
-    public function unlock() {
-        set_transient( self::KEY, self::VALUE_UNLOCKED, MINUTE_IN_SECONDS );
-    }
+	/**
+	 * Sempahore's option key.
+	 */
+	const KEY = 'wogh_semaphore_lock';
+
+	/**
+	 * Option key when semaphore is locked.
+	 */
+	const VALUE_LOCKED = 'yes';
+
+	/**
+	 * Option key when semaphore is unlocked.
+	 */
+	const VALUE_UNLOCKED = 'no';
+
+	/**
+	 * Clean up the old values on instantiation.
+	 */
+	public function __construct() {
+		delete_option( self::KEY );
+	}
+
+	/**
+	 * Checks if the Semaphore is open.
+	 *
+	 * Fails to report it's open if the the Api class can't make a call
+	 * or the push lock has been enabled.
+	 *
+	 * @return bool
+	 */
+	public function is_open() {
+		if ( self::VALUE_LOCKED === get_transient( self::KEY ) ) {
+			return false;
+		}
+
+		return true;
+	}
+
+	/**
+	 * Enables the push lock.
+	 */
+	public function lock() {
+		set_transient( self::KEY, self::VALUE_LOCKED, MINUTE_IN_SECONDS );
+	}
+
+	/**
+	 * Disables the push lock.
+	 */
+	public function unlock() {
+		set_transient( self::KEY, self::VALUE_UNLOCKED, MINUTE_IN_SECONDS );
+	}
 }

lib/database.php

Indentation +508 added lines, -508 removed lines

@@ -9,512 +9,512 @@
  */
 class Writing_On_GitHub_Database {
 
-    /**
-     * Application container.
-     *
-     * @var Writing_On_GitHub
-     */
-    protected $app;
-
-    /**
-     * Currently whitelisted post types.
-     *
-     * @var array
-     */
-    protected $whitelisted_post_types = array( 'post', 'page' );
-
-    /**
-     * Currently whitelisted post statuses.
-     *
-     * @var array
-     */
-    protected $whitelisted_post_statuses = array( 'publish' );
-
-    /**
-     * Instantiates a new Database object.
-     *
-     * @param Writing_On_GitHub $app Application container.
-     */
-    public function __construct( Writing_On_GitHub $app ) {
-        $this->app = $app;
-    }
-
-    /**
-     * Queries the database for all of the supported posts.
-     *
-     * @param  bool $force
-     *
-     * @return Writing_On_GitHub_Post[]|WP_Error
-     */
-    public function fetch_all_supported( $force = false ) {
-        $args  = array(
-            'post_type'   => $this->get_whitelisted_post_types(),
-            'post_status' => $this->get_whitelisted_post_statuses(),
-            'nopaging'    => true,
-            'fields'      => 'ids',
-        );
-
-        $query = new WP_Query( apply_filters( 'wogh_pre_fetch_all_supported', $args ) );
-
-        $post_ids = $query->get_posts();
-
-        if ( ! $post_ids ) {
-            return new WP_Error(
-                'no_results',
-                __( 'Querying for supported posts returned no results.', 'writing-on-github' )
-            );
-        }
-
-        /* @var Writing_On_GitHub_Post[] $results */
-        $results = array();
-        foreach ( $post_ids as $post_id ) {
-            // Do not export posts that have already been exported
-            if ( $force || ! get_post_meta( $post_id, '_wogh_sha', true ) ||
-                 ! get_post_meta( $post_id, '_wogh_github_path', true ) ) {
-
-                $results[] = new Writing_On_GitHub_Post( $post_id, $this->app->api() );
-            }
-        }
-
-        return $results;
-    }
-
-    /**
-     * Queries a post and returns it if it's supported.
-     *
-     * @param int $post_id Post ID to fetch.
-     *
-     * @return WP_Error|Writing_On_GitHub_Post
-     */
-    public function fetch_by_id( $post_id ) {
-        $post = new Writing_On_GitHub_Post( $post_id, $this->app->api() );
-
-        if ( ! $this->is_post_supported( $post ) ) {
-            return new WP_Error(
-                'unsupported_post',
-                sprintf(
-                    __(
-                        'Post ID %s is not supported by WOGH. See wiki to find out how to add support.',
-                        'writing-on-github'
-                    ),
-                    $post_id
-                )
-            );
-        }
-
-        return $post;
-    }
-
-    /**
-     * Save an post to database
-     * and associates their author as well as their latest
-     *
-     * @param  Writing_On_GitHub_Post $post [description]
-     * @return WP_Error|true
-     */
-    public function save_post( Writing_On_GitHub_Post $post ) {
-        $args = apply_filters( 'wogh_pre_import_args', $this->post_args( $post ), $post );
-
-        remove_filter( 'content_save_pre', 'wp_filter_post_kses' );
-        $post_id = $post->is_new() ?
-            wp_insert_post( $args, true ) :
-            wp_update_post( $args, true );
-        add_filter( 'content_save_pre', 'wp_filter_post_kses' );
-
-        if ( is_wp_error( $post_id ) ) {
-            /* @var WP_Error $post_id */
-            return $post_id;
-        }
-
-        if ( $post->is_new() ) {
-            $author = false;
-            $meta = $post->get_meta();
-            if ( ! empty( $meta ) && ! empty( $meta['author'] ) ) {
-                $author = $meta['author'];
-            }
-            $user    = $this->fetch_commit_user( $author );
-            $user_id = is_wp_error( $user ) ? 0 : $user->ID;
-            $this->set_post_author( $post_id, $user_id );
-        }
-
-        $post->set_post( get_post( $post_id ) );
-
-        $meta = apply_filters( 'wogh_pre_import_meta', $post->get_meta(), $post );
-
-        update_post_meta( $post_id, '_wogh_sha', $meta['_wogh_sha'] );
-
-        // unset( $meta['tags'] );
-        // unset( $meta['categories'] );
-        // unset( $meta['author'] );
-        // unset( $meta['post_date'] );
-        // unset( $meta['post_excerpt'] );
-        // unset( $meta['permalink'] );
-        // unset( $meta['link'] );
-
-        // foreach ( $meta as $key => $value ) {
-        //  update_post_meta( $post_id, $key, $value );
-        // }
-        return true;
-    }
-
-    protected function post_args( $post ) {
-        $args = $post->get_args();
-        $meta = $post->get_meta();
-
-        // prevent backslash loss
-        $args['post_content'] = addslashes( $args['post_content'] );
-
-        // update tags
-        if ( ! empty( $meta['tags'] ) ) {
-            $args['tags_input'] = $meta['tags'];
-        }
-
-        // update categories
-        if ( ! empty( $meta['categories'] ) ) {
-            $categories = $meta['categories'];
-            if ( ! is_array( $categories ) ) {
-                $categories = array( $categories );
-            }
-            $terms = get_terms( array(
-                'taxonomy' => 'category',
-                'fields' => 'id=>name',
-                'hide_empty' => 0,
-                'name' => $categories
-                )
-            );
-            $map = array();
-            foreach ( $categories as $name ) {
-                $map[$name] = 1;
-            }
-
-            $ids = array();
-            if ( ! empty( $terms ) ) {
-                foreach ( $terms as $id => $name ) {
-                    $ids[] = $id;
-                    unset( $map[$name] );
-                }
-            }
-
-            // create new terms
-            if ( ! empty( $map ) ) {
-                foreach ( $map as $name => $value ) {
-                    $term = wp_insert_term( $name, 'category', array( 'parent' => 0 ) );
-                    // array('term_id' => $term_id, 'term_taxonomy_id' => $tt_id);
-                    $ids[] = $term['term_id'];
-                }
-            }
-
-            $args['post_category'] = $ids;
-        }
-
-        return $args;
-    }
-
-    private function get_post_id_by_filename( $filename, $pattern  ) {
-        preg_match( $pattern , $filename, $matches );
-        $title = $matches[4];
-
-        $query = new WP_Query( array(
-            'name'     => $title,
-            'posts_per_page' => 1,
-            'post_type' => $this->get_whitelisted_post_types(),
-            'fields'         => 'ids',
-        ) );
-
-        $post_id = $query->get_posts();
-        $post_id = array_pop( $post_id );
-        return $post_id;
-    }
-
-    /**
-     * Deletes a post from the database based on its GitHub path.
-     *
-     * @param string $path Path of Post to delete.
-     *
-     * @return string|WP_Error
-     */
-    public function delete_post_by_path( $path ) {
-        $query = new WP_Query( array(
-            'meta_key'       => '_wogh_github_path',
-            'meta_value'     => $path,
-            'meta_compare'   => '=',
-            'posts_per_page' => 1,
-            'fields'         => 'ids',
-        ) );
-
-        $post_id = $query->get_posts();
-        $post_id = array_pop( $post_id );
-
-        if ( ! $post_id ) {
-            $parts     = explode( '/', $path );
-            $filename  = array_pop( $parts );
-            $directory = $parts ? array_shift( $parts ) : '';
-
-            if ( false !== strpos( $directory, 'post' ) ) {
-                $post_id = get_post_id_by_filename( $filename, '/([0-9]{4})-([0-9]{2})-([0-9]{2})-(.*)\.md/' );
-            }
-
-            if ( ! $post_id ) {
-                $post_id = get_post_id_by_filename( $filename, '/(.*)\.md/' );
-            }
-        }
-
-        if ( ! $post_id ) {
-            return new WP_Error(
-                'path_not_found',
-                sprintf(
-                    __( 'Post not found for path %s.', 'writing-on-github' ),
-                    $path
-                )
-            );
-        }
-
-        $result = wp_delete_post( $post_id );
-
-        // If deleting fails...
-        if ( false === $result ) {
-            $post = get_post( $post_id );
-
-            // ...and the post both exists and isn't in the trash...
-            if ( $post && 'trash' !== $post->post_status ) {
-                // ... then something went wrong.
-                return new WP_Error(
-                    'db_error',
-                    sprintf(
-                        __( 'Failed to delete post ID %d.', 'writing-on-github' ),
-                        $post_id
-                    )
-                );
-            }
-        }
-
-        return sprintf(
-            __( 'Successfully deleted post ID %d.', 'writing-on-github' ),
-            $post_id
-        );
-    }
-
-    public function delete_post( $post_id ) {
-        $result = wp_delete_post( $post_id );
-
-        // If deleting fails...
-        if ( false === $result ) {
-            $post = get_post( $post_id );
-
-            // ...and the post both exists and isn't in the trash...
-            if ( $post && 'trash' !== $post->post_status ) {
-                // ... then something went wrong.
-                return new WP_Error(
-                    'db_error',
-                    sprintf(
-                        __( 'Failed to delete post ID %d.', 'writing-on-github' ),
-                        $post_id
-                    )
-                );
-            }
-        }
-
-        return sprintf(
-            __( 'Successfully deleted post ID %d.', 'writing-on-github' ),
-            $post_id
-        );
-    }
-
-    /**
-     * Returns the list of post type permitted.
-     *
-     * @return array
-     */
-    protected function get_whitelisted_post_types() {
-        return apply_filters( 'wogh_whitelisted_post_types', $this->whitelisted_post_types );
-    }
-
-    /**
-     * Returns the list of post status permitted.
-     *
-     * @return array
-     */
-    protected function get_whitelisted_post_statuses() {
-        return apply_filters( 'wogh_whitelisted_post_statuses', $this->whitelisted_post_statuses );
-    }
-
-    /**
-     * Formats a whitelist array for a query.
-     *
-     * @param array $whitelist Whitelisted posts to format into query.
-     *
-     * @return string Whitelist formatted for query
-     */
-    protected function format_for_query( $whitelist ) {
-        foreach ( $whitelist as $key => $value ) {
-            $whitelist[ $key ] = "'$value'";
-        }
-
-        return implode( ', ', $whitelist );
-    }
-
-    /**
-     * Verifies that both the post's status & type
-     * are currently whitelisted
-     *
-     * @param  Writing_On_GitHub_Post $post Post to verify.
-     *
-     * @return boolean                          True if supported, false if not.
-     */
-    protected function is_post_supported( Writing_On_GitHub_Post $post ) {
-        if ( wp_is_post_revision( $post->id ) ) {
-            return false;
-        }
-
-        // We need to allow trashed posts to be queried, but they are not whitelisted for export.
-        if ( ! in_array( $post->status(), $this->get_whitelisted_post_statuses() ) && 'trash' !== $post->status() ) {
-            return false;
-        }
-
-        if ( ! in_array( $post->type(), $this->get_whitelisted_post_types() ) ) {
-            return false;
-        }
-
-        if ( $post->has_password() ) {
-            return false;
-        }
-
-        return apply_filters( 'wogh_is_post_supported', true, $post );
-    }
-
-    /**
-     * Retrieves the commit user for a provided display name
-     *
-     * Searches for a user with provided display name or returns
-     * the default user saved in the database.
-     *
-     * @param string $display_name User display name to search for.
-     *
-     * @return WP_Error|WP_User
-     */
-    protected function fetch_commit_user( $display_name ) {
-        // If we can't find a user and a default hasn't been set,
-        // we're just going to set the revision author to 0.
-        $user = false;
-
-        if ( ! empty( $display_name ) ) {
-            $search_string = esc_attr( $display_name );
-            $query = new WP_User_Query( array(
-                'search'         => "{$search_string}",
-                'search_columns' => array(
-                    'display_name',
-                    'user_nicename',
-                    'user_login',
-                )
-            ) );
-            $users = $query->get_results();
-            $user = empty($users) ? false : $users[0];
-        }
-
-        if ( ! $user ) {
-            // Use the default user.
-            $user = get_user_by( 'id', (int) get_option( 'wogh_default_user' ) );
-        }
-
-        if ( ! $user ) {
-            return new WP_Error(
-                'user_not_found',
-                sprintf(
-                    __( 'Commit user not found for email %s', 'writing-on-github' ),
-                    $email
-                )
-            );
-        }
-
-        return $user;
-    }
-
-    // /**
-    //  * Sets the author latest revision
-    //  * of the provided post ID to the provided user.
-    //  *
-    //  * @param int $post_id Post ID to update revision author.
-    //  * @param int $user_id User ID for revision author.
-    //  *
-    //  * @return string|WP_Error
-    //  */
-    // protected function set_revision_author( $post_id, $user_id ) {
-    //  $revision = wp_get_post_revisions( $post_id );
-
-    //  if ( ! $revision ) {
-    //      $new_revision = wp_save_post_revision( $post_id );
-
-    //      if ( ! $new_revision || is_wp_error( $new_revision ) ) {
-    //          return new WP_Error( 'db_error', 'There was a problem saving a new revision.' );
-    //      }
-
-    //      // `wp_save_post_revision` returns the ID, whereas `get_post_revision` returns the whole object
-    //      // in order to be consistent, let's make sure we have the whole object before continuing.
-    //      $revision = get_post( $new_revision );
-
-    //      if ( ! $revision ) {
-    //          return new WP_Error( 'db_error', 'There was a problem retrieving the newly recreated revision.' );
-    //      }
-    //  } else {
-    //      $revision = array_shift( $revision );
-    //  }
-
-    //  return $this->set_post_author( $revision->ID, $user_id );
-    // }
-
-    /**
-     * Updates the user ID for the provided post ID.
-     *
-     * Bypassing triggering any hooks, including creating new revisions.
-     *
-     * @param int $post_id Post ID to update.
-     * @param int $user_id User ID to update to.
-     *
-     * @return string|WP_Error
-     */
-    protected function set_post_author( $post_id, $user_id ) {
-        global $wpdb;
-
-        $result = $wpdb->update(
-            $wpdb->posts,
-            array(
-                'post_author' => (int) $user_id,
-            ),
-            array(
-                'ID' => (int) $post_id,
-            ),
-            array( '%d' ),
-            array( '%d' )
-        );
-
-        if ( false === $result ) {
-            return new WP_Error( 'db_error', $wpdb->last_error );
-        }
-
-        if ( 0 === $result ) {
-            return sprintf(
-                __( 'No change for post ID %d.', 'writing-on-github' ),
-                $post_id
-            );
-        }
-
-        clean_post_cache( $post_id );
-
-        return sprintf(
-            __( 'Successfully updated post ID %d.', 'writing-on-github' ),
-            $post_id
-        );
-    }
-
-    // *
-    //  * Update the provided post's blob sha.
-    //  *
-    //  * @param Writing_On_GitHub_Post $post Post to update.
-    //  * @param string                     $sha Sha to update to.
-    //  *
-    //  * @return bool|int
-
-    // public function set_post_sha( $post, $sha ) {
-    //  return update_post_meta( $post->id, '_wogh_sha', $sha );
-    // }
+	/**
+	 * Application container.
+	 *
+	 * @var Writing_On_GitHub
+	 */
+	protected $app;
+
+	/**
+	 * Currently whitelisted post types.
+	 *
+	 * @var array
+	 */
+	protected $whitelisted_post_types = array( 'post', 'page' );
+
+	/**
+	 * Currently whitelisted post statuses.
+	 *
+	 * @var array
+	 */
+	protected $whitelisted_post_statuses = array( 'publish' );
+
+	/**
+	 * Instantiates a new Database object.
+	 *
+	 * @param Writing_On_GitHub $app Application container.
+	 */
+	public function __construct( Writing_On_GitHub $app ) {
+		$this->app = $app;
+	}
+
+	/**
+	 * Queries the database for all of the supported posts.
+	 *
+	 * @param  bool $force
+	 *
+	 * @return Writing_On_GitHub_Post[]|WP_Error
+	 */
+	public function fetch_all_supported( $force = false ) {
+		$args  = array(
+			'post_type'   => $this->get_whitelisted_post_types(),
+			'post_status' => $this->get_whitelisted_post_statuses(),
+			'nopaging'    => true,
+			'fields'      => 'ids',
+		);
+
+		$query = new WP_Query( apply_filters( 'wogh_pre_fetch_all_supported', $args ) );
+
+		$post_ids = $query->get_posts();
+
+		if ( ! $post_ids ) {
+			return new WP_Error(
+				'no_results',
+				__( 'Querying for supported posts returned no results.', 'writing-on-github' )
+			);
+		}
+
+		/* @var Writing_On_GitHub_Post[] $results */
+		$results = array();
+		foreach ( $post_ids as $post_id ) {
+			// Do not export posts that have already been exported
+			if ( $force || ! get_post_meta( $post_id, '_wogh_sha', true ) ||
+				 ! get_post_meta( $post_id, '_wogh_github_path', true ) ) {
+
+				$results[] = new Writing_On_GitHub_Post( $post_id, $this->app->api() );
+			}
+		}
+
+		return $results;
+	}
+
+	/**
+	 * Queries a post and returns it if it's supported.
+	 *
+	 * @param int $post_id Post ID to fetch.
+	 *
+	 * @return WP_Error|Writing_On_GitHub_Post
+	 */
+	public function fetch_by_id( $post_id ) {
+		$post = new Writing_On_GitHub_Post( $post_id, $this->app->api() );
+
+		if ( ! $this->is_post_supported( $post ) ) {
+			return new WP_Error(
+				'unsupported_post',
+				sprintf(
+					__(
+						'Post ID %s is not supported by WOGH. See wiki to find out how to add support.',
+						'writing-on-github'
+					),
+					$post_id
+				)
+			);
+		}
+
+		return $post;
+	}
+
+	/**
+	 * Save an post to database
+	 * and associates their author as well as their latest
+	 *
+	 * @param  Writing_On_GitHub_Post $post [description]
+	 * @return WP_Error|true
+	 */
+	public function save_post( Writing_On_GitHub_Post $post ) {
+		$args = apply_filters( 'wogh_pre_import_args', $this->post_args( $post ), $post );
+
+		remove_filter( 'content_save_pre', 'wp_filter_post_kses' );
+		$post_id = $post->is_new() ?
+			wp_insert_post( $args, true ) :
+			wp_update_post( $args, true );
+		add_filter( 'content_save_pre', 'wp_filter_post_kses' );
+
+		if ( is_wp_error( $post_id ) ) {
+			/* @var WP_Error $post_id */
+			return $post_id;
+		}
+
+		if ( $post->is_new() ) {
+			$author = false;
+			$meta = $post->get_meta();
+			if ( ! empty( $meta ) && ! empty( $meta['author'] ) ) {
+				$author = $meta['author'];
+			}
+			$user    = $this->fetch_commit_user( $author );
+			$user_id = is_wp_error( $user ) ? 0 : $user->ID;
+			$this->set_post_author( $post_id, $user_id );
+		}
+
+		$post->set_post( get_post( $post_id ) );
+
+		$meta = apply_filters( 'wogh_pre_import_meta', $post->get_meta(), $post );
+
+		update_post_meta( $post_id, '_wogh_sha', $meta['_wogh_sha'] );
+
+		// unset( $meta['tags'] );
+		// unset( $meta['categories'] );
+		// unset( $meta['author'] );
+		// unset( $meta['post_date'] );
+		// unset( $meta['post_excerpt'] );
+		// unset( $meta['permalink'] );
+		// unset( $meta['link'] );
+
+		// foreach ( $meta as $key => $value ) {
+		//  update_post_meta( $post_id, $key, $value );
+		// }
+		return true;
+	}
+
+	protected function post_args( $post ) {
+		$args = $post->get_args();
+		$meta = $post->get_meta();
+
+		// prevent backslash loss
+		$args['post_content'] = addslashes( $args['post_content'] );
+
+		// update tags
+		if ( ! empty( $meta['tags'] ) ) {
+			$args['tags_input'] = $meta['tags'];
+		}
+
+		// update categories
+		if ( ! empty( $meta['categories'] ) ) {
+			$categories = $meta['categories'];
+			if ( ! is_array( $categories ) ) {
+				$categories = array( $categories );
+			}
+			$terms = get_terms( array(
+				'taxonomy' => 'category',
+				'fields' => 'id=>name',
+				'hide_empty' => 0,
+				'name' => $categories
+				)
+			);
+			$map = array();
+			foreach ( $categories as $name ) {
+				$map[$name] = 1;
+			}
+
+			$ids = array();
+			if ( ! empty( $terms ) ) {
+				foreach ( $terms as $id => $name ) {
+					$ids[] = $id;
+					unset( $map[$name] );
+				}
+			}
+
+			// create new terms
+			if ( ! empty( $map ) ) {
+				foreach ( $map as $name => $value ) {
+					$term = wp_insert_term( $name, 'category', array( 'parent' => 0 ) );
+					// array('term_id' => $term_id, 'term_taxonomy_id' => $tt_id);
+					$ids[] = $term['term_id'];
+				}
+			}
+
+			$args['post_category'] = $ids;
+		}
+
+		return $args;
+	}
+
+	private function get_post_id_by_filename( $filename, $pattern  ) {
+		preg_match( $pattern , $filename, $matches );
+		$title = $matches[4];
+
+		$query = new WP_Query( array(
+			'name'     => $title,
+			'posts_per_page' => 1,
+			'post_type' => $this->get_whitelisted_post_types(),
+			'fields'         => 'ids',
+		) );
+
+		$post_id = $query->get_posts();
+		$post_id = array_pop( $post_id );
+		return $post_id;
+	}
+
+	/**
+	 * Deletes a post from the database based on its GitHub path.
+	 *
+	 * @param string $path Path of Post to delete.
+	 *
+	 * @return string|WP_Error
+	 */
+	public function delete_post_by_path( $path ) {
+		$query = new WP_Query( array(
+			'meta_key'       => '_wogh_github_path',
+			'meta_value'     => $path,
+			'meta_compare'   => '=',
+			'posts_per_page' => 1,
+			'fields'         => 'ids',
+		) );
+
+		$post_id = $query->get_posts();
+		$post_id = array_pop( $post_id );
+
+		if ( ! $post_id ) {
+			$parts     = explode( '/', $path );
+			$filename  = array_pop( $parts );
+			$directory = $parts ? array_shift( $parts ) : '';
+
+			if ( false !== strpos( $directory, 'post' ) ) {
+				$post_id = get_post_id_by_filename( $filename, '/([0-9]{4})-([0-9]{2})-([0-9]{2})-(.*)\.md/' );
+			}
+
+			if ( ! $post_id ) {
+				$post_id = get_post_id_by_filename( $filename, '/(.*)\.md/' );
+			}
+		}
+
+		if ( ! $post_id ) {
+			return new WP_Error(
+				'path_not_found',
+				sprintf(
+					__( 'Post not found for path %s.', 'writing-on-github' ),
+					$path
+				)
+			);
+		}
+
+		$result = wp_delete_post( $post_id );
+
+		// If deleting fails...
+		if ( false === $result ) {
+			$post = get_post( $post_id );
+
+			// ...and the post both exists and isn't in the trash...
+			if ( $post && 'trash' !== $post->post_status ) {
+				// ... then something went wrong.
+				return new WP_Error(
+					'db_error',
+					sprintf(
+						__( 'Failed to delete post ID %d.', 'writing-on-github' ),
+						$post_id
+					)
+				);
+			}
+		}
+
+		return sprintf(
+			__( 'Successfully deleted post ID %d.', 'writing-on-github' ),
+			$post_id
+		);
+	}
+
+	public function delete_post( $post_id ) {
+		$result = wp_delete_post( $post_id );
+
+		// If deleting fails...
+		if ( false === $result ) {
+			$post = get_post( $post_id );
+
+			// ...and the post both exists and isn't in the trash...
+			if ( $post && 'trash' !== $post->post_status ) {
+				// ... then something went wrong.
+				return new WP_Error(
+					'db_error',
+					sprintf(
+						__( 'Failed to delete post ID %d.', 'writing-on-github' ),
+						$post_id
+					)
+				);
+			}
+		}
+
+		return sprintf(
+			__( 'Successfully deleted post ID %d.', 'writing-on-github' ),
+			$post_id
+		);
+	}
+
+	/**
+	 * Returns the list of post type permitted.
+	 *
+	 * @return array
+	 */
+	protected function get_whitelisted_post_types() {
+		return apply_filters( 'wogh_whitelisted_post_types', $this->whitelisted_post_types );
+	}
+
+	/**
+	 * Returns the list of post status permitted.
+	 *
+	 * @return array
+	 */
+	protected function get_whitelisted_post_statuses() {
+		return apply_filters( 'wogh_whitelisted_post_statuses', $this->whitelisted_post_statuses );
+	}
+
+	/**
+	 * Formats a whitelist array for a query.
+	 *
+	 * @param array $whitelist Whitelisted posts to format into query.
+	 *
+	 * @return string Whitelist formatted for query
+	 */
+	protected function format_for_query( $whitelist ) {
+		foreach ( $whitelist as $key => $value ) {
+			$whitelist[ $key ] = "'$value'";
+		}
+
+		return implode( ', ', $whitelist );
+	}
+
+	/**
+	 * Verifies that both the post's status & type
+	 * are currently whitelisted
+	 *
+	 * @param  Writing_On_GitHub_Post $post Post to verify.
+	 *
+	 * @return boolean                          True if supported, false if not.
+	 */
+	protected function is_post_supported( Writing_On_GitHub_Post $post ) {
+		if ( wp_is_post_revision( $post->id ) ) {
+			return false;
+		}
+
+		// We need to allow trashed posts to be queried, but they are not whitelisted for export.
+		if ( ! in_array( $post->status(), $this->get_whitelisted_post_statuses() ) && 'trash' !== $post->status() ) {
+			return false;
+		}
+
+		if ( ! in_array( $post->type(), $this->get_whitelisted_post_types() ) ) {
+			return false;
+		}
+
+		if ( $post->has_password() ) {
+			return false;
+		}
+
+		return apply_filters( 'wogh_is_post_supported', true, $post );
+	}
+
+	/**
+	 * Retrieves the commit user for a provided display name
+	 *
+	 * Searches for a user with provided display name or returns
+	 * the default user saved in the database.
+	 *
+	 * @param string $display_name User display name to search for.
+	 *
+	 * @return WP_Error|WP_User
+	 */
+	protected function fetch_commit_user( $display_name ) {
+		// If we can't find a user and a default hasn't been set,
+		// we're just going to set the revision author to 0.
+		$user = false;
+
+		if ( ! empty( $display_name ) ) {
+			$search_string = esc_attr( $display_name );
+			$query = new WP_User_Query( array(
+				'search'         => "{$search_string}",
+				'search_columns' => array(
+					'display_name',
+					'user_nicename',
+					'user_login',
+				)
+			) );
+			$users = $query->get_results();
+			$user = empty($users) ? false : $users[0];
+		}
+
+		if ( ! $user ) {
+			// Use the default user.
+			$user = get_user_by( 'id', (int) get_option( 'wogh_default_user' ) );
+		}
+
+		if ( ! $user ) {
+			return new WP_Error(
+				'user_not_found',
+				sprintf(
+					__( 'Commit user not found for email %s', 'writing-on-github' ),
+					$email
+				)
+			);
+		}
+
+		return $user;
+	}
+
+	// /**
+	//  * Sets the author latest revision
+	//  * of the provided post ID to the provided user.
+	//  *
+	//  * @param int $post_id Post ID to update revision author.
+	//  * @param int $user_id User ID for revision author.
+	//  *
+	//  * @return string|WP_Error
+	//  */
+	// protected function set_revision_author( $post_id, $user_id ) {
+	//  $revision = wp_get_post_revisions( $post_id );
+
+	//  if ( ! $revision ) {
+	//      $new_revision = wp_save_post_revision( $post_id );
+
+	//      if ( ! $new_revision || is_wp_error( $new_revision ) ) {
+	//          return new WP_Error( 'db_error', 'There was a problem saving a new revision.' );
+	//      }
+
+	//      // `wp_save_post_revision` returns the ID, whereas `get_post_revision` returns the whole object
+	//      // in order to be consistent, let's make sure we have the whole object before continuing.
+	//      $revision = get_post( $new_revision );
+
+	//      if ( ! $revision ) {
+	//          return new WP_Error( 'db_error', 'There was a problem retrieving the newly recreated revision.' );
+	//      }
+	//  } else {
+	//      $revision = array_shift( $revision );
+	//  }
+
+	//  return $this->set_post_author( $revision->ID, $user_id );
+	// }
+
+	/**
+	 * Updates the user ID for the provided post ID.
+	 *
+	 * Bypassing triggering any hooks, including creating new revisions.
+	 *
+	 * @param int $post_id Post ID to update.
+	 * @param int $user_id User ID to update to.
+	 *
+	 * @return string|WP_Error
+	 */
+	protected function set_post_author( $post_id, $user_id ) {
+		global $wpdb;
+
+		$result = $wpdb->update(
+			$wpdb->posts,
+			array(
+				'post_author' => (int) $user_id,
+			),
+			array(
+				'ID' => (int) $post_id,
+			),
+			array( '%d' ),
+			array( '%d' )
+		);
+
+		if ( false === $result ) {
+			return new WP_Error( 'db_error', $wpdb->last_error );
+		}
+
+		if ( 0 === $result ) {
+			return sprintf(
+				__( 'No change for post ID %d.', 'writing-on-github' ),
+				$post_id
+			);
+		}
+
+		clean_post_cache( $post_id );
+
+		return sprintf(
+			__( 'Successfully updated post ID %d.', 'writing-on-github' ),
+			$post_id
+		);
+	}
+
+	// *
+	//  * Update the provided post's blob sha.
+	//  *
+	//  * @param Writing_On_GitHub_Post $post Post to update.
+	//  * @param string                     $sha Sha to update to.
+	//  *
+	//  * @return bool|int
+
+	// public function set_post_sha( $post, $sha ) {
+	//  return update_post_meta( $post->id, '_wogh_sha', $sha );
+	// }
 }

lib/client/fetch.php

Indentation +114 added lines, -114 removed lines

@@ -9,118 +9,118 @@
  */
 class Writing_On_GitHub_Fetch_Client extends Writing_On_GitHub_Base_Client {
 
-    /**
-     * Compare a commit by sha with master from the GitHub API
-     *
-     * @param string $sha Sha for commit to retrieve.
-     *
-     * @return Writing_On_GitHub_File_Info[]|WP_Error
-     */
-    public function compare( $sha ) {
-        // https://api.github.com/repos/litefeel/testwpsync/compare/861f87e8851b8debb78db548269d29f8da4d94ac...master
-        $endpoint = $this->compare_endpoint();
-        $branch = $this->branch();
-        $data = $this->call( 'GET', "$endpoint/$sha...$branch" );
-
-        if ( is_wp_error( $data ) ) {
-            return $data;
-        }
-
-        $files = array();
-        foreach ($data->files as $file) {
-            $file->path = $file->filename;
-            $files[] = new Writing_On_GitHub_File_Info($file);
-        }
-
-        return $files;
-    }
-
-    /**
-     * Calls the content API to get the post's contents and metadata
-     *
-     * Returns Object the response from the API
-     *
-     * @param Writing_On_GitHub_Post $post Post to retrieve remote contents for.
-     *
-     * @return mixed
-     */
-    public function remote_contents( $post ) {
-        return $this->call( 'GET', $this->content_endpoint( $post->github_path() ) );
-    }
-
-
-
-    public function exists( $path ) {
-        $result = $this->call( 'GET', $this->content_endpoint( $path ) );
-        if ( is_wp_error( $result ) ) {
-            return false;
-        }
-        return true;
-    }
-
-    /**
-     * Retrieves a tree by sha recursively from the GitHub API
-     *
-     * @param string $sha Commit sha to retrieve tree from.
-     *
-     * @return Writing_On_GitHub_File_Info[]|WP_Error
-     */
-    public function tree_recursive( $sha = '_default' ) {
-
-        if ( '_default' === $sha ) {
-            $sha = $this->branch();
-        }
-
-        $data = $this->call( 'GET', $this->tree_endpoint() . '/' . $sha . '?recursive=1' );
-
-        if ( is_wp_error( $data ) ) {
-            return $data;
-        }
-
-        $files = array();
-
-        foreach ( $data->tree as $index => $thing ) {
-            // We need to remove the trees because
-            // the recursive tree includes both
-            // the subtrees as well the subtrees' blobs.
-            if ( 'blob' === $thing->type ) {
-                $thing->status = '';
-                $files[] = new Writing_On_GitHub_File_Info( $thing );
-            }
-        }
-
-        return $files;
-    }
-
-    /**
-     * Retrieves the blob data for a given sha
-     *
-     * @param Writing_On_GitHub_File_Info $fileinfo
-     *
-     * @return Writing_On_GitHub_Blob|WP_Error
-     */
-    public function blob( Writing_On_GitHub_File_Info $fileinfo ) {
-        $data = $this->call( 'GET', $this->blob_endpoint() . '/' . $fileinfo->sha );
-
-        if ( is_wp_error( $data ) ) {
-            return $data;
-        }
-
-        $data->path = $fileinfo->path;
-        return new Writing_On_GitHub_Blob( $data );
-    }
-
-    /**
-     * Get blob by path
-     * @param  string $path
-     * @return Writing_On_GitHub_Blob|WP_Error
-     */
-    public function blob_by_path( $path ) {
-        $result = $this->call( 'GET', $this->content_endpoint( $path ) );
-        if ( is_wp_error( $result ) ) {
-            return $result;
-        }
-
-        return new Writing_On_GitHub_Blob( $result );
-    }
+	/**
+	 * Compare a commit by sha with master from the GitHub API
+	 *
+	 * @param string $sha Sha for commit to retrieve.
+	 *
+	 * @return Writing_On_GitHub_File_Info[]|WP_Error
+	 */
+	public function compare( $sha ) {
+		// https://api.github.com/repos/litefeel/testwpsync/compare/861f87e8851b8debb78db548269d29f8da4d94ac...master
+		$endpoint = $this->compare_endpoint();
+		$branch = $this->branch();
+		$data = $this->call( 'GET', "$endpoint/$sha...$branch" );
+
+		if ( is_wp_error( $data ) ) {
+			return $data;
+		}
+
+		$files = array();
+		foreach ($data->files as $file) {
+			$file->path = $file->filename;
+			$files[] = new Writing_On_GitHub_File_Info($file);
+		}
+
+		return $files;
+	}
+
+	/**
+	 * Calls the content API to get the post's contents and metadata
+	 *
+	 * Returns Object the response from the API
+	 *
+	 * @param Writing_On_GitHub_Post $post Post to retrieve remote contents for.
+	 *
+	 * @return mixed
+	 */
+	public function remote_contents( $post ) {
+		return $this->call( 'GET', $this->content_endpoint( $post->github_path() ) );
+	}
+
+
+
+	public function exists( $path ) {
+		$result = $this->call( 'GET', $this->content_endpoint( $path ) );
+		if ( is_wp_error( $result ) ) {
+			return false;
+		}
+		return true;
+	}
+
+	/**
+	 * Retrieves a tree by sha recursively from the GitHub API
+	 *
+	 * @param string $sha Commit sha to retrieve tree from.
+	 *
+	 * @return Writing_On_GitHub_File_Info[]|WP_Error
+	 */
+	public function tree_recursive( $sha = '_default' ) {
+
+		if ( '_default' === $sha ) {
+			$sha = $this->branch();
+		}
+
+		$data = $this->call( 'GET', $this->tree_endpoint() . '/' . $sha . '?recursive=1' );
+
+		if ( is_wp_error( $data ) ) {
+			return $data;
+		}
+
+		$files = array();
+
+		foreach ( $data->tree as $index => $thing ) {
+			// We need to remove the trees because
+			// the recursive tree includes both
+			// the subtrees as well the subtrees' blobs.
+			if ( 'blob' === $thing->type ) {
+				$thing->status = '';
+				$files[] = new Writing_On_GitHub_File_Info( $thing );
+			}
+		}
+
+		return $files;
+	}
+
+	/**
+	 * Retrieves the blob data for a given sha
+	 *
+	 * @param Writing_On_GitHub_File_Info $fileinfo
+	 *
+	 * @return Writing_On_GitHub_Blob|WP_Error
+	 */
+	public function blob( Writing_On_GitHub_File_Info $fileinfo ) {
+		$data = $this->call( 'GET', $this->blob_endpoint() . '/' . $fileinfo->sha );
+
+		if ( is_wp_error( $data ) ) {
+			return $data;
+		}
+
+		$data->path = $fileinfo->path;
+		return new Writing_On_GitHub_Blob( $data );
+	}
+
+	/**
+	 * Get blob by path
+	 * @param  string $path
+	 * @return Writing_On_GitHub_Blob|WP_Error
+	 */
+	public function blob_by_path( $path ) {
+		$result = $this->call( 'GET', $this->content_endpoint( $path ) );
+		if ( is_wp_error( $result ) ) {
+			return $result;
+		}
+
+		return new Writing_On_GitHub_Blob( $result );
+	}
 }