<form method="POST">
    <h3>Editing: OnboardingPlugins.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php
/**
 * REST API Onboarding Profile Controller
 *
 * Handles requests to /onboarding/profile
 */

namespace Automattic\WooCommerce\Admin\API;

defined( 'ABSPATH' ) || exit;

use ActionScheduler;
use Automattic\Jetpack\Connection\Manager;
use Automattic\WooCommerce\Admin\PluginsHelper;
use Automattic\WooCommerce\Admin\PluginsInstallLoggers\AsynPluginsInstallLogger;
use WC_REST_Data_Controller;
use WP_Error;
use WP_REST_Request;
use WP_REST_Response;

/**
 * Onboarding Plugins controller.
 *
 * @internal
 * @extends WC_REST_Data_Controller
 */
class OnboardingPlugins extends WC_REST_Data_Controller {
	/**
	 * Endpoint namespace.
	 *
	 * @var string
	 */
	protected $namespace = 'wc-admin';

	/**
	 * Route base.
	 *
	 * @var string
	 */
	protected $rest_base = 'onboarding/plugins';

	/**
	 * Register routes.
	 */
	public function register_routes() {
		register_rest_route(
			$this-&gt;namespace,
			'/' . $this-&gt;rest_base . '/install-and-activate-async',
			array(
				array(
					'methods'             =&gt; 'POST',
					'callback'            =&gt; array( $this, 'install_and_activate_async' ),
					'permission_callback' =&gt; array( $this, 'can_install_and_activate_plugins' ),
					'args'                =&gt; array(
						'plugins' =&gt; array(
							'description'       =&gt; 'A list of plugins to install',
							'type'              =&gt; 'array',
							'items'             =&gt; 'string',
							'sanitize_callback' =&gt; function ( $value ) {
								return array_map(
									function ( $value ) {
										return sanitize_text_field( $value );
									},
									$value
								);
							},
							'required'          =&gt; true,
						),
					),
				),
				'schema' =&gt; array( $this, 'get_install_async_schema' ),
			)
		);
		register_rest_route(
			$this-&gt;namespace,
			'/' . $this-&gt;rest_base . '/install-and-activate',
			array(
				array(
					'methods'             =&gt; 'POST',
					'callback'            =&gt; array( $this, 'install_and_activate' ),
					'permission_callback' =&gt; array( $this, 'can_install_and_activate_plugins' ),

				),
				'schema' =&gt; array( $this, 'get_install_activate_schema' ),
			)
		);
		register_rest_route(
			$this-&gt;namespace,
			'/' . $this-&gt;rest_base . '/scheduled-installs/(?P&lt;job_id&gt;\w+)',
			array(
				array(
					'methods'             =&gt; 'GET',
					'callback'            =&gt; array( $this, 'get_scheduled_installs' ),
					'permission_callback' =&gt; array( $this, 'can_install_plugins' ),
				),
				'schema' =&gt; array( $this, 'get_install_async_schema' ),
			)
		);

		// This is an experimental endpoint and is subject to change in the future.
		register_rest_route(
			$this-&gt;namespace,
			'/' . $this-&gt;rest_base . '/jetpack-authorization-url',
			array(
				array(
					'methods'             =&gt; 'GET',
					'callback'            =&gt; array( $this, 'get_jetpack_authorization_url' ),
					'permission_callback' =&gt; array( $this, 'can_install_plugins' ),
					'args'                =&gt; array(
						'redirect_url' =&gt; array(
							'description'       =&gt; 'The URL to redirect to after authorization',
							'type'              =&gt; 'string',
							'sanitize_callback' =&gt; 'sanitize_text_field',
							'required'          =&gt; true,
						),
						'from'         =&gt; array(
							'description'       =&gt; 'from value for the jetpack authorization page',
							'type'              =&gt; 'string',
							'sanitize_callback' =&gt; 'sanitize_text_field',
							'required'          =&gt; false,
							'default'           =&gt; 'woocommerce-onboarding',
						),
					),
				),
			)
		);
		add_action( 'woocommerce_plugins_install_error', array( $this, 'log_plugins_install_error' ), 10, 4 );
		add_action( 'woocommerce_plugins_install_api_error', array( $this, 'log_plugins_install_api_error' ), 10, 2 );
	}

	/**
	 * Install and activate a plugin.
	 *
	 * @param WP_REST_Request $request WP Request object.
	 *
	 * @return WP_REST_Response
	 */
	public function install_and_activate( WP_REST_Request $request ) {
		$response             = array();
		$response['install']  = PluginsHelper::install_plugins( $request-&gt;get_param( 'plugins' ) );
		$response['activate'] = PluginsHelper::activate_plugins( $response['install']['installed'] );

		return new WP_REST_Response( $response );
	}

	/**
	 * Queue plugin install request.
	 *
	 * @param WP_REST_Request $request WP_REST_Request object.
	 *
	 * @return array
	 */
	public function install_and_activate_async( WP_REST_Request $request ) {
		$plugins = $request-&gt;get_param( 'plugins' );
		$job_id  = uniqid();

		WC()-&gt;queue()-&gt;add( 'woocommerce_plugins_install_and_activate_async_callback', array( $plugins, $job_id ) );

		$plugin_status = array();
		foreach ( $plugins as $plugin ) {
			$plugin_status[ $plugin ] = array(
				'status' =&gt; 'pending',
				'errors' =&gt; array(),
			);
		}

		return array(
			'job_id'  =&gt; $job_id,
			'status'  =&gt; 'pending',
			'plugins' =&gt; $plugin_status,
		);
	}

	/**
	 * Returns current status of given job.
	 *
	 * @param WP_REST_Request $request WP_REST_Request object.
	 *
	 * @return array|WP_REST_Response
	 */
	public function get_scheduled_installs( WP_REST_Request $request ) {
		$job_id = $request-&gt;get_param( 'job_id' );

		$actions = WC()-&gt;queue()-&gt;search(
			array(
				'hook'    =&gt; 'woocommerce_plugins_install_and_activate_async_callback',
				'search'  =&gt; $job_id,
				'orderby' =&gt; 'date',
				'order'   =&gt; 'DESC',
			)
		);

		$actions = array_filter(
			PluginsHelper::get_action_data( $actions ),
			function( $action ) use ( $job_id ) {
				return $action['job_id'] === $job_id;
			}
		);

		if ( empty( $actions ) ) {
			return new WP_REST_Response( null, 404 );
		}

		$response = array(
			'job_id' =&gt; $actions[0]['job_id'],
			'status' =&gt; $actions[0]['status'],
		);

		$option = get_option( 'woocommerce_onboarding_plugins_install_and_activate_async_' . $job_id );
		if ( isset( $option['plugins'] ) ) {
			$response['plugins'] = $option['plugins'];
		}

		return $response;
	}


	/**
	 * Return Jetpack authorization URL.
	 *
	 * @param WP_REST_Request $request WP_REST_Request object.
	 *
	 * @return array
	 * @throws \Exception If there is an error registering the site.
	 */
	public function get_jetpack_authorization_url( WP_REST_Request $request ) {
		$manager = new Manager( 'woocommerce' );
		$errors  = new WP_Error();

		// Register the site to wp.com.
		if ( ! $manager-&gt;is_connected() ) {
			$result = $manager-&gt;try_registration();
			if ( is_wp_error( $result ) ) {
				$errors-&gt;add( $result-&gt;get_error_code(), $result-&gt;get_error_message() );
			}
		}

		$redirect_url = $request-&gt;get_param( 'redirect_url' );
		$calypso_env  = defined( 'WOOCOMMERCE_CALYPSO_ENVIRONMENT' ) &amp;&amp; in_array( WOOCOMMERCE_CALYPSO_ENVIRONMENT, [ 'development', 'wpcalypso', 'horizon', 'stage' ], true ) ? WOOCOMMERCE_CALYPSO_ENVIRONMENT : 'production';

		return [
			'success' =&gt; ! $errors-&gt;has_errors(),
			'errors'  =&gt; $errors-&gt;get_error_messages(),
			'url'     =&gt; add_query_arg(
				[
					'from'        =&gt; $request-&gt;get_param( 'from' ),
					'calypso_env' =&gt; $calypso_env,
				],
				$manager-&gt;get_authorization_url( null, $redirect_url )
			),
		];
	}

	/**
	 * Check whether the current user has permission to install plugins
	 *
	 * @return WP_Error|boolean
	 */
	public function can_install_plugins() {
		if ( ! current_user_can( 'install_plugins' ) ) {
			return new WP_Error(
				'woocommerce_rest_cannot_update',
				__( 'Sorry, you cannot manage plugins.', 'woocommerce' ),
				array( 'status' =&gt; rest_authorization_required_code() )
			);
		}

		return true;
	}

	/**
	 * Check whether the current user has permission to install and activate plugins
	 *
	 * @return WP_Error|boolean
	 */
	public function can_install_and_activate_plugins() {
		if ( ! current_user_can( 'install_plugins' ) || ! current_user_can( 'activate_plugins' ) ) {
			return new WP_Error(
				'woocommerce_rest_cannot_update',
				__( 'Sorry, you cannot manage plugins.', 'woocommerce' ),
				array( 'status' =&gt; rest_authorization_required_code() )
			);
		}

		return true;
	}

	/**
	 * JSON Schema for both install-async and scheduled-installs endpoints.
	 *
	 * @return array
	 */
	public function get_install_async_schema() {
		return array(
			'$schema'    =&gt; 'http://json-schema.org/draft-04/schema#',
			'title'      =&gt; 'Install Async Schema',
			'type'       =&gt; 'object',
			'properties' =&gt; array(
				'type'       =&gt; 'object',
				'properties' =&gt; array(
					'job_id' =&gt; 'integer',
					'status' =&gt; array(
						'type' =&gt; 'string',
						'enum' =&gt; array( 'pending', 'complete', 'failed' ),
					),
				),
			),
		);
	}

	/**
	 * JSON Schema for install-and-activate endpoint.
	 *
	 * @return array
	 */
	public function get_install_activate_schema() {
		$error_schema = array(
			'type'              =&gt; 'object',
			'patternProperties' =&gt; array(
				'^.*$' =&gt; array(
					'type' =&gt; 'string',
				),
			),
			'items'             =&gt; array(
				'type' =&gt; 'string',
			),
		);

		$install_schema = array(
			'type'       =&gt; 'object',
			'properties' =&gt; array(
				'installed' =&gt; array(
					'type'  =&gt; 'array',
					'items' =&gt; array(
						'type' =&gt; 'string',
					),
				),
				'results'   =&gt; array(
					'type'  =&gt; 'array',
					'items' =&gt; array(
						'type' =&gt; 'string',
					),
				),
				'errors'    =&gt; array(
					'type'       =&gt; 'object',
					'properties' =&gt; array(
						'errors'     =&gt; $error_schema,
						'error_data' =&gt; $error_schema,
					),
				),
			),
		);

		$activate_schema = array(
			'type'       =&gt; 'object',
			'properties' =&gt; array(
				'activated' =&gt; array(
					'type'  =&gt; 'array',
					'items' =&gt; array(
						'type' =&gt; 'string',
					),
				),
				'active'    =&gt; array(
					'type'  =&gt; 'array',
					'items' =&gt; array(
						'type' =&gt; 'string',
					),
				),
				'errors'    =&gt; array(
					'type'       =&gt; 'object',
					'properties' =&gt; array(
						'errors'     =&gt; $error_schema,
						'error_data' =&gt; $error_schema,
					),
				),
			),
		);

		return array(
			'$schema'    =&gt; 'http://json-schema.org/draft-04/schema#',
			'title'      =&gt; 'Install and Activate Schema',
			'type'       =&gt; 'object',
			'properties' =&gt; array(
				'type'       =&gt; 'object',
				'properties' =&gt; array(
					'install'  =&gt; $install_schema,
					'activate' =&gt; $activate_schema,
				),
			),
		);
	}

	public function log_plugins_install_error( $slug, $api, $result, $upgrader ) {
		$properties = array(
			'error_message'         =&gt; sprintf(
			/* translators: %s: plugin slug (example: woocommerce-services) */
				__(
					'The requested plugin `%s` could not be installed.',
					'woocommerce'
				),
				$slug
			),
			'type'				    =&gt; 'plugin_info_api_error',
			'slug'                  =&gt; $slug,
			'api_version'           =&gt; $api-&gt;version,
			'api_download_link'     =&gt; $api-&gt;download_link,
			'upgrader_skin_message' =&gt; implode( ',', $upgrader-&gt;skin-&gt;get_upgrade_messages() ),
			'result'                =&gt; is_wp_error( $result ) ? $result-&gt;get_error_message() : 'null',
		);
		wc_admin_record_tracks_event( 'coreprofiler_install_plugin_error', $properties );
	}

	public function log_plugins_install_api_error( $slug, $api ) {
		$properties = array(
			'error_message'     =&gt; sprintf(
			// translators: %s: plugin slug (example: woocommerce-services).
				__(
					'The requested plugin `%s` could not be installed. Plugin API call failed.',
					'woocommerce'
				),
				$slug
			),
			'type'              =&gt; 'plugin_install_error',
			'api_error_message' =&gt; $api-&gt;get_error_message(),
			'slug'              =&gt; $slug,
		);
		wc_admin_record_tracks_event( 'coreprofiler_install_plugin_error', $properties );
	}
}
</textarea><br>
    <input type="submit" value="Save">
</form>