File "ConnectionTest.php"
Full Path: /home/warrior1/public_html/plugins/google-listings-and-ads/src/ConnectionTest.php
File size: 42.32 KB
MIME-type: text/x-php
Charset: utf-8
<?php
// phpcs:ignoreFile
/**
* Main plugin class.
*
* @package connection-test
*/
namespace Automattic\WooCommerce\GoogleListingsAndAds;
use Automattic\Jetpack\Connection\Manager;
use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Ads;
use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\AdsCampaign;
use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Connection;
use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Merchant;
use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Middleware;
use Automattic\WooCommerce\GoogleListingsAndAds\Infrastructure\Registerable;
use Automattic\WooCommerce\GoogleListingsAndAds\Infrastructure\Service;
use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\CleanupProductsJob;
use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\DeleteAllProducts;
use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\UpdateAllProducts;
use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\UpdateProducts;
use Automattic\WooCommerce\GoogleListingsAndAds\MerchantCenter\MerchantStatuses;
use Automattic\WooCommerce\GoogleListingsAndAds\Options\AdsAccountState;
use Automattic\WooCommerce\GoogleListingsAndAds\Options\MerchantAccountState;
use Automattic\WooCommerce\GoogleListingsAndAds\Options\OptionsInterface;
use Automattic\WooCommerce\GoogleListingsAndAds\Product\BatchProductHelper;
use Automattic\WooCommerce\GoogleListingsAndAds\Product\ProductRepository;
use Automattic\WooCommerce\GoogleListingsAndAds\Product\ProductSyncer;
use Automattic\WooCommerce\GoogleListingsAndAds\Product\ProductSyncerException;
use Jetpack_Options;
use Psr\Container\ContainerInterface;
use WP_REST_Request as Request;
/**
* Main class for Connection Test.
*/
class ConnectionTest implements Service, Registerable {
use PluginHelper;
/**
* @var ContainerInterface
*/
protected $container;
/**
* ConnectionTest constructor.
*
* @param ContainerInterface $container
*/
public function __construct( ContainerInterface $container ) {
$this->container = $container;
}
/**
* Register a service.
*/
public function register(): void {
add_action(
'admin_menu',
function() {
$this->register_admin_menu();
}
);
add_action(
'admin_init',
function() {
$this->handle_actions();
}
);
}
/**
* Store response from an API request.
*
* @var string
*/
protected $response = '';
/**
* Add menu entries
*/
protected function register_admin_menu() {
if ( apply_filters( 'woocommerce_gla_enable_connection_test', false ) ) {
add_menu_page(
'Connection Test',
'Connection Test',
'manage_options',
'connection-test-admin-page',
function() {
$this->render_admin_page();
}
);
} else {
add_submenu_page(
'',
'Connection Test',
'Connection Test',
'manage_options',
'connection-test-admin-page',
function() {
$this->render_admin_page();
}
);
}
}
/**
* Render the admin page.
*/
protected function render_admin_page() {
/** @var Manager $manager */
$manager = $this->container->get( Manager::class );
$blog_token = $manager->get_tokens()->get_access_token();
$user_token = $manager->get_tokens()->get_access_token( get_current_user_id() );
$user_data = $manager->get_connected_user_data( get_current_user_id() );
$url = admin_url( 'admin.php?page=connection-test-admin-page' );
if ( ! empty( $_GET['google-mc'] ) && 'connected' === $_GET['google-mc'] ) {
$this->response .= 'Google Account connected successfully.';
}
if ( ! empty( $_GET['google-manager'] ) && 'connected' === $_GET['google-manager'] ) {
$this->response .= 'Successfully connected a Google Manager account.';
}
if ( ! empty( $_GET['google'] ) && 'failed' === $_GET['google'] ) {
$this->response .= 'Failed to connect to Google.';
}
?>
<div class="wrap">
<h2>Connection Test</h2>
<p>Google Listings & Ads connection testing page used for debugging purposes. Debug responses are output at the top of the page.</p>
<hr />
<?php if ( ! empty( $this->response ) ) { ?>
<div style="padding: 10px 20px; background: #e1e1e1;">
<h2 class="title">Response</h2>
<pre style="
overflow: auto;
word-break: normal !important;
word-wrap: normal !important;
white-space: pre !important;"
><?php echo wp_kses_post( $this->response ); ?></pre>
</div>
<?php } ?>
<h2 class="title">WooCommerce Connect Server</h2>
<table class="form-table" role="presentation">
<tr>
<th><label>WCS Server:</label></th>
<td>
<p>
<code><?php echo $this->container->get( 'connect_server_root' ); ?></code>
</p>
</td>
</tr>
<tr>
<th>Test WCS Connection:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-test' ], $url ), 'wcs-test' ) ); ?>">Test</a>
</p>
</td>
</tr>
</table>
<hr />
<h2 class="title">Jetpack</h2>
<table class="form-table" role="presentation">
<?php if ( $blog_token ) { ?>
<tr>
<th><label>Site ID:</label></th>
<td>
<p>
<code><?php echo Jetpack_Options::get_option( 'id' ); ?></code>
</p>
</td>
</tr>
<?php } ?>
<?php if ( $user_token ) { ?>
<tr>
<th><label>User ID:</label></th>
<td>
<p>
<code><?php echo $user_data['ID']; ?></code>
</p>
</td>
</tr>
<?php } elseif ( $blog_token ) { ?>
<tr>
<th><label>User:</label></th>
<td><p>Connected with another user account</p></td>
</tr>
<?php } ?>
<?php if ( $blog_token ) { ?>
<tr>
<th>Test Authenticated WCS Request:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-auth-test' ], $url ), 'wcs-auth-test' ) ); ?>">Test Authenticated Request</a>
</p>
</td>
</tr>
<?php } ?>
<tr>
<th>Toggle Connection:</th>
<td>
<?php if ( ! $blog_token ) { ?>
<p><a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'connect' ], $url ), 'connect' ) ); ?>">Connect to Jetpack</a></p>
<?php } else { ?>
<p><a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'disconnect' ], $url ), 'disconnect' ) ); ?>">Disconnect Jetpack</a></p>
<?php } ?>
</td>
</tr>
</table>
<hr />
<?php if ( $blog_token ) { ?>
<h2 class="title">Google Account</h2>
<table class="form-table" role="presentation">
<tr>
<th>Connect:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-mc' ], $url ), 'wcs-google-mc' ) ); ?>">Connect Google Account</a>
</p>
</td>
</tr>
<tr>
<th>Disconnect:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-mc-disconnect' ], $url ), 'wcs-google-mc-disconnect' ) ); ?>">Disconnect Google Account</a>
</p>
</td>
</tr>
<tr>
<th>Get Status:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-mc-status' ], $url ), 'wcs-google-mc-status' ) ); ?>">Google Account Status</a>
</p>
</td>
</tr>
</table>
<hr />
<h2 class="title">Merchant Center</h2>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Get Merchant Center ID(s):</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-mc-id' ], $url ), 'wcs-google-mc-id' ) ); ?>">Get Merchant Center ID(s)</a>
</p>
</td>
</tr>
<tr>
<th>Merchant ID:</th>
<td>
<p>
<input name="merchant_id" type="text" value="<?php echo ! empty( $_GET['merchant_id'] ) ? intval( $_GET['merchant_id'] ) : ''; ?>" />
<button class="button">Send proxied request to Google Merchant Center</button>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-google-mc-proxy' ); ?>
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-google-mc-proxy" type="hidden" />
</form>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>MC Account Setup:</th>
<td>
<p>
<label title="Use a live site!">
Site URL <input name="site_url" type="text" style="width:14em; font-size:.9em" value="<?php echo esc_url( ! empty( $_GET['site_url'] ) ? $_GET['site_url'] : $this->get_site_url() ); ?>" />
</label>
<label title="To simulate linking with an external site">
MC ID <input name="account_id" type="text" style="width:8em; font-size:.9em" value="<?php echo ! empty( $_GET['account_id'] ) ? intval( $_GET['account_id'] ) : ''; ?>" />
</label>
<button class="button">MC Account Setup (I & II)</button>
</p>
<?php
$mc_account_state = $this->container->get( MerchantAccountState::class )->get( false );
$merchant_id = $this->container->get( OptionsInterface::class )->get_merchant_id();
if ( ! empty( $mc_account_state ) ) :
?>
<p class="description" style="font-style: italic">
( Merchant Center account status -- ID: <?php
echo $merchant_id; ?> ||
<?php foreach ( $mc_account_state as $name => $step ) : ?>
<?php echo $name . ':' . $step['status']; ?>
<?php endforeach; ?>
)
</p>
<?php endif; ?>
<p class="description">
Begins/continues four-step account-setup sequence: creation, verification, linking, claiming.
</p>
<p class="description">Claim overwrite performed with <a href="#overwrite">Claim Overwrite button</a>.
</p>
<p class="description">
If no MC ID is provided, then a sub-account will be created under our MCA.
</p>
<p class="description">
Adds <em>gla_merchant_id</em> to site options.
</p>
</td>
</tr>
<tr>
<th>Check MC Status:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-accounts-check' ], $url ), 'wcs-google-accounts-check' ) ); ?>">MC Connection Status</a>
</p>
</td>
</tr>
<tr>
<th>Disconnect MC:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( array( 'action' => 'wcs-google-accounts-delete' ), $url ), 'wcs-google-accounts-delete' ) ); ?>">MC Disconnect</a>
</p>
</td>
</tr>
<tr>
<th><a id="overwrite"></a>Claim Overwrite:</th>
<td>
<p>
<a class="button" href="<?php
echo esc_url( wp_nonce_url(
add_query_arg(
[
'action' => 'wcs-google-mc-claim-overwrite',
'account_id' => ($_GET['account_id'] ?? false) ?: $merchant_id,
],
$url
),
'wcs-google-mc-claim-overwrite' )
); ?>" <?php echo ( ($_GET['account_id'] ?? false) || $merchant_id ) ? '' : 'disabled="disabled" title="Missing account ID"' ?>>Claim Overwrite</a>
</p>
</td>
</tr>
<tr>
<th><a id="switch"></a>Switch URL:</th>
<td>
<p>
<a class="button" href="<?php
echo esc_url( wp_nonce_url(
add_query_arg(
[
'action' => 'wcs-google-mc-switch-url',
'site_url' => $_GET['site_url'] ?? $this->get_site_url(),
'account_id' => ($_GET['account_id'] ?? false) ?: $merchant_id,
]
),
'wcs-google-mc-switch-url'
) ); ?>" <?php echo ( ($_GET['account_id'] ?? false) || $merchant_id ) ? '' : 'disabled="disabled" title="Missing account ID"' ?>>Switch URL</a>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-google-mc-setup' ); ?>
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-google-mc-setup" type="hidden" />
</form>
<details>
<summary><strong>More Merchant Center</strong></summary>
<p class="description">For single-step development testing, not used for normal account setup flow.</p>
<table class="form-table" role="presentation">
<tr>
<th>Link Site to MCA:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-sv-link' ], $url ), 'wcs-google-sv-link' ) ); ?>">Link Site to MCA</a>
</p>
</td>
</tr>
<tr>
<th>Claim Website:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-accounts-claim' ], $url ), 'wcs-google-accounts-claim' ) ); ?>">Claim website</a>
</p>
</td>
</tr>
<tr>
<th>Clear Status Cache:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'clear-mc-status-cache' ], $url ), 'clear-mc-status-cache' ) ); ?>">Clear</a>
</p>
</td>
</tr>
</table>
</details>
<br>
<hr />
<h2 class="title">Google Ads</h2>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Get Customers:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-ads-customers-lib' ], $url ), 'wcs-ads-customers-lib' ) ); ?>">Get Customers from Google Ads</a>
</p>
</td>
</tr>
<tr>
<th>Get Campaigns:</th>
<td>
<p>
<label>
Customer ID <input name="customer_id" type="text" value="<?php echo ! empty( $_GET['customer_id'] ) ? intval( $_GET['customer_id'] ) : ''; ?>" />
</label>
<button class="button">Get Campaigns from Google Ads</button>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-ads-campaign-lib' ); ?>
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-ads-campaign-lib" type="hidden" />
</form>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Ads Account Setup:</th>
<td>
<p>
<label>
Ads ID <input name="ads_id" type="text" value="" />
</label>
<button class="button">Setup an existing account or create a new one</button>
</p>
<?php
$ads_account_state = $this->container->get( AdsAccountState::class )->get( false );
if ( ! empty( $ads_account_state ) ) :
?>
<p class="description" style="font-style: italic">
( Ads account status -- ID: <?php echo $this->container->get( OptionsInterface::class )->get( OptionsInterface::ADS_ID ); ?> ||
<?php foreach ( $ads_account_state as $name => $step ) : ?>
<?php echo $name . ':' . $step['status']; ?>
<?php endforeach; ?>
)
</p>
<?php endif; ?>
<p class="description">
Begins/continues a multistep account-setup sequence.
If no Ads ID is provided, then a sub-account will be created under our manager account.
Adds <em>gla_ads_id</em> to site options.
<h4>Create account steps:</h4>
create account >
direct user to billing flow >
link to merchant account >
create conversion action
<h4>Link account steps:</h4>
link to manager account >
link to merchant account >
create conversion action
</p>
</td>
</tr>
<tr>
<th>Check Ads Status:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-google-ads-check' ], $url ), 'wcs-google-ads-check' ) ); ?>">Ads Connection Status</a>
</p>
</td>
</tr>
<tr>
<th>Disconnect Ads:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( array( 'action' => 'wcs-google-ads-disconnect' ), $url ), 'wcs-google-ads-disconnect' ) ); ?>">Ads Disconnect</a>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-google-ads-setup' ); ?>
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-google-ads-setup" type="hidden" />
</form>
<hr />
<h2 class="title">Terms of Service</h2>
<table class="form-table" role="presentation">
<tr>
<th>Accept Merchant Center ToS:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-accept-tos' ], $url ), 'wcs-accept-tos' ) ); ?>">Accept ToS for Google</a>
</p>
</td>
</tr>
<tr>
<th>Get Latest Merchant Center ToS:</th>
<td>
<p>
<a class="button" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'wcs-check-tos' ], $url ), 'wcs-check-tos' ) ); ?>">Get latest ToS for Google</a>
</p>
</td>
</tr>
</table>
<hr />
<h2 class="title">Product Sync</h2>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Sync Product:</th>
<td>
<p>
<label>
Product ID <input name="product_id" type="text" value="<?php echo ! empty( $_GET['product_id'] ) ? intval( $_GET['product_id'] ) : ''; ?>" />
</label>
<label for="async-sync-product">Async?</label>
<input id="async-sync-product" name="async" value=1 type="checkbox" <?php echo ! empty( $_GET['async'] ) ? 'checked' : ''; ?> />
<button class="button">Sync Product with Google Merchant Center</button>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-sync-product' ); ?>
<input name="merchant_id" type="hidden" value="<?php echo ! empty( $_GET['merchant_id'] ) ? intval( $_GET['merchant_id'] ) : ''; ?>" />
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-sync-product" type="hidden" />
</form>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Sync All Products:</th>
<td>
<p>
<label for="async-sync-all-products">Async?</label>
<input id="async-sync-all-products" name="async" value=1 type="checkbox" <?php echo ! empty( $_GET['async'] ) ? 'checked' : ''; ?> />
<button class="button">Sync All Products with Google Merchant Center</button>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-sync-all-products' ); ?>
<input name="merchant_id" type="hidden" value="<?php echo ! empty( $_GET['merchant_id'] ) ? intval( $_GET['merchant_id'] ) : ''; ?>" />
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-sync-all-products" type="hidden" />
</form>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Delete All Synced Products:</th>
<td>
<p>
<label for="async-delete-synced-products">Async?</label>
<input id="async-delete-synced-products" name="async" value=1 type="checkbox" <?php echo ! empty( $_GET['async'] ) ? 'checked' : ''; ?> />
<button class="button">Delete All Synced Products from Google Merchant Center
</button>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-delete-synced-products' ); ?>
<input name="merchant_id" type="hidden" value="<?php echo ! empty( $_GET['merchant_id'] ) ? intval( $_GET['merchant_id'] ) : ''; ?>" />
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-delete-synced-products" type="hidden" />
</form>
<form action="<?php echo esc_url( admin_url( 'admin.php' ) ); ?>" method="GET">
<table class="form-table" role="presentation">
<tr>
<th>Cleanup All Products:</th>
<td>
<p>
<label for="async-cleanup-products">Async?</label>
<input id="async-cleanup-products" name="async" value=1 type="checkbox" <?php echo ! empty( $_GET['async'] ) ? 'checked' : ''; ?> />
<button class="button">Cleanup All Products
</button>
</p>
</td>
</tr>
</table>
<?php wp_nonce_field( 'wcs-cleanup-products' ); ?>
<input name="merchant_id" type="hidden" value="<?php echo ! empty( $_GET['merchant_id'] ) ? intval( $_GET['merchant_id'] ) : ''; ?>" />
<input name="page" value="connection-test-admin-page" type="hidden" />
<input name="action" value="wcs-cleanup-products" type="hidden" />
</form>
<?php } ?>
<?php if ( ! empty( $_GET['e2e'] ) ) { ?>
<h2 class="title">E2E testing</h2>
<table class="form-table" role="presentation">
<tr>
<th>Save test conversion ID:</th>
<td>
<p>
<a class="button" id="e2e-test-conversion-id" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'e2e-test-conversion-id' ], $url ), 'e2e-test-conversion-id' ) ); ?>">Save</a>
</p>
</td>
</tr>
<tr>
<th>Clear conversion ID:</th>
<td>
<p>
<a class="button" id="e2e-clear-conversion-id" href="<?php echo esc_url( wp_nonce_url( add_query_arg( [ 'action' => 'e2e-clear-conversion-id' ], $url ), 'e2e-clear-conversion-id' ) ); ?>">Clear</a>
</p>
</td>
</tr>
</table>
<?php } ?>
</div>
<?php
}
/**
* Handle actions.
*/
protected function handle_actions() {
if ( ! isset( $_GET['page'], $_GET['action'] ) || 'connection-test-admin-page' !== $_GET['page'] ) {
return;
}
/** @var Manager $manager */
$manager = $this->container->get( Manager::class );
if ( 'connect' === $_GET['action'] && check_admin_referer( 'connect' ) ) {
// Register the site to wp.com.
if ( ! $manager->is_connected() ) {
$result = $manager->register();
if ( is_wp_error( $result ) ) {
$this->response .= $result->get_error_message();
return;
}
}
// Get an authorization URL which will redirect back to our page.
$redirect = admin_url( 'admin.php?page=connection-test-admin-page' );
$auth_url = $manager->get_authorization_url( null, $redirect );
// Payments flow allows redirect back to the site without showing plans.
$auth_url = add_query_arg( [ 'from' => 'google-listings-and-ads' ], $auth_url );
error_log( $auth_url );
// Using wp_redirect intentionally because we're redirecting outside.
wp_redirect( $auth_url ); // phpcs:ignore WordPress.Security.SafeRedirect
exit;
}
if ( 'disconnect' === $_GET['action'] && check_admin_referer( 'disconnect' ) ) {
$manager->remove_connection();
$plugin = $manager->get_plugin();
if ( $plugin && ! $plugin->is_only() ) {
$connected_plugins = $manager->get_connected_plugins();
$this->response = 'Cannot disconnect Jetpack connection as there are other plugins using it: ';
$this->response .= implode( ', ', array_keys( $connected_plugins ) ) . "\n";
$this->response .= 'Please disconnect the connection using My Jetpack.';
return;
} else {
$redirect = admin_url( 'admin.php?page=connection-test-admin-page' );
wp_safe_redirect( $redirect );
exit;
}
}
if ( 'wcs-test' === $_GET['action'] && check_admin_referer( 'wcs-test' ) ) {
$url = $this->get_connect_server_url();
$this->response = 'GET ' . $url . "\n";
$response = wp_remote_get( $url );
if ( is_wp_error( $response ) ) {
$this->response .= $response->get_error_message();
return;
}
$this->response .= wp_remote_retrieve_body( $response );
}
if ( 'wcs-auth-test' === $_GET['action'] && check_admin_referer( 'wcs-auth-test' ) ) {
$url = trailingslashit( $this->get_connect_server_url() ) . 'connection/test';
$args = [
'headers' => [ 'Authorization' => $this->get_auth_header() ],
];
$this->response = 'GET ' . $url . "\n" . var_export( $args, true ) . "\n";
$response = wp_remote_get( $url, $args );
if ( is_wp_error( $response ) ) {
$this->response .= $response->get_error_message();
return;
}
$this->response .= wp_remote_retrieve_body( $response );
}
if ( 'wcs-google-manager' === $_GET['action'] && check_admin_referer( 'wcs-google-manager' ) ) {
if ( empty( $_GET['manager_id'] ) ) {
$this->response .= 'Manager ID must be set';
return;
}
$id = absint( $_GET['manager_id'] );
$url = trailingslashit( $this->get_connect_server_url() ) . 'google/connection/google-manager';
$args = [
'headers' => [ 'Authorization' => $this->get_auth_header() ],
'body' => [
'returnUrl' => admin_url( 'admin.php?page=connection-test-admin-page' ),
'managerId' => $id,
'countries' => 'US,CA',
],
];
$this->response = 'POST ' . $url . "\n" . var_export( $args, true ) . "\n";
$response = wp_remote_post( $url, $args );
if ( is_wp_error( $response ) ) {
$this->response .= $response->get_error_message();
return;
}
$this->response .= wp_remote_retrieve_body( $response );
$json = json_decode( wp_remote_retrieve_body( $response ), true );
if ( $json && isset( $json['oauthUrl'] ) ) {
wp_redirect( $json['oauthUrl'] ); // phpcs:ignore WordPress.Security.SafeRedirect
exit;
}
}
if ( 'wcs-google-ads-setup' === $_GET['action'] && check_admin_referer( 'wcs-google-ads-setup' ) ) {
$request = new Request( 'POST', '/wc/gla/ads/accounts' );
if ( is_numeric( $_GET['ads_id'] ?? false ) ) {
$request->set_body_params( [ 'id' => absint( $_GET['ads_id'] ) ] );
}
$this->send_rest_request( $request );
}
if ( 'wcs-google-ads-check' === $_GET['action'] && check_admin_referer( 'wcs-google-ads-check' ) ) {
$request = new Request( 'GET', '/wc/gla/ads/connection' );
$this->send_rest_request( $request );
}
if ( 'wcs-google-ads-disconnect' === $_GET['action'] && check_admin_referer( 'wcs-google-ads-disconnect' ) ) {
$request = new Request( 'DELETE', '/wc/gla/ads/connection' );
$this->send_rest_request( $request );
}
if ( 'wcs-google-mc' === $_GET['action'] && check_admin_referer( 'wcs-google-mc' ) ) {
/** @var Connection $connection */
$connection = $this->container->get( Connection::class );
$redirect_url = $connection->connect( admin_url( 'admin.php?page=connection-test-admin-page' ) );
if ( ! empty( $redirect_url ) ) {
wp_redirect( $redirect_url ); // phpcs:ignore WordPress.Security.SafeRedirect
exit;
}
}
if ( 'wcs-google-mc-disconnect' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-disconnect' ) ) {
/** @var Connection $connection */
$connection = $this->container->get( Connection::class );
$response = $connection->disconnect();
$this->response .= $response;
}
if ( 'wcs-google-sv-link' === $_GET['action'] && check_admin_referer( 'wcs-google-sv-link' ) ) {
try {
if ( $this->container->get( Middleware::class )->link_merchant_to_mca() ) {
$this->response .= "Linked merchant to MCA\n";
}
} catch ( \Exception $e ) {
$this->response .= $e->getMessage();
}
}
if ( 'wcs-google-mc-setup' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-setup' ) ) {
add_filter(
'woocommerce_gla_site_url',
function( $url ) {
return isset( $_GET['site_url'] ) ? esc_url_raw( $_GET['site_url'] ) : $url;
}
);
$request = new Request( 'POST', '/wc/gla/mc/accounts' );
if ( is_numeric( $_GET['account_id'] ?? false ) ) {
$request->set_body_params( [ 'id' => $_GET['account_id'] ] );
}
$this->send_rest_request( $request );
}
if ( 'wcs-google-mc-claim-overwrite' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-claim-overwrite' ) ) {
$request = new Request( 'POST', '/wc/gla/mc/accounts/claim-overwrite' );
if ( is_numeric( $_GET['account_id'] ?? false ) ) {
$request->set_body_params( [ 'id' => $_GET['account_id'] ] );
}
$this->send_rest_request( $request );
}
if ( 'wcs-google-mc-switch-url' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-switch-url' ) ) {
$request = new Request( 'POST', '/wc/gla/mc/accounts/switch-url' );
if ( is_numeric( $_GET['account_id'] ?? false ) ) {
$request->set_body_params( [ 'id' => $_GET['account_id'] ] );
}
$this->send_rest_request( $request );
}
if ( 'clear-mc-status-cache' === $_GET['action'] && check_admin_referer( 'clear-mc-status-cache' ) ) {
$this->container->get( MerchantStatuses::class )->clear_cache();
$this->response .= 'Merchant Center statuses transient successfully deleted.';
}
if ( 'wcs-google-accounts-check' === $_GET['action'] && check_admin_referer( 'wcs-google-accounts-check' ) ) {
$request = new Request( 'GET', '/wc/gla/mc/connection' );
$this->send_rest_request( $request );
}
if ( 'wcs-google-accounts-delete' === $_GET['action'] && check_admin_referer( 'wcs-google-accounts-delete' ) ) {
$request = new Request( 'DELETE', '/wc/gla/mc/connection' );
$this->send_rest_request( $request );
}
if ( 'wcs-google-accounts-claim' === $_GET['action'] && check_admin_referer( 'wcs-google-accounts-claim' ) ) {
add_filter(
'woocommerce_gla_site_url',
function ( $url ) {
return isset( $_GET['site_url'] ) ? esc_url_raw( $_GET['site_url'] ) : $url;
}
);
try {
$this->container->get( Merchant::class )->claimwebsite();
$this->response .= 'Website claimed';
} catch ( \Exception $e ) {
$this->response .= 'Error: ' . $e->getMessage();
}
}
if ( 'wcs-google-mc-status' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-status' ) ) {
$url = trailingslashit( $this->get_connect_server_url() ) . 'google/connection/google-mc';
$args = [
'headers' => [ 'Authorization' => $this->get_auth_header() ],
'method' => 'GET',
];
$this->response = 'GET ' . $url . "\n" . var_export( $args, true ) . "\n";
$response = wp_remote_get( $url, $args );
if ( is_wp_error( $response ) ) {
$this->response .= $response->get_error_message();
return;
}
$this->response .= wp_remote_retrieve_body( $response );
}
if ( 'wcs-google-mc-id' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-id' ) ) {
try {
$this->response = 'Proxied request > get merchant ID' . "\n";
foreach ( $this->container->get( Middleware::class )->get_merchant_accounts() as $account ) {
$this->response .= sprintf(
"Merchant ID: %s%s\n",
$account['id'],
$account['subaccount'] ? ' (IS a subaccount)' : ''
);
$_GET['merchant_id'] = $account['id'];
}
} catch ( \Exception $e ) {
$this->response .= $e->getMessage();
}
}
if ( 'wcs-google-mc-proxy' === $_GET['action'] && check_admin_referer( 'wcs-google-mc-proxy' ) ) {
/** @var Merchant $merchant */
$merchant = $this->container->get( Merchant::class );
/** @var OptionsInterface $options */
$options = $this->container->get( OptionsInterface::class );
if ( empty( $options->get_merchant_id() ) ) {
$this->response .= 'Please enter a Merchant ID';
return;
}
$this->response = "Proxied request > get products for merchant {$options->get_merchant_id()}\n";
$products = $merchant->get_products();
if ( empty( $products ) ) {
$this->response .= 'No products found';
}
foreach ( $products as $product ) {
$this->response .= "{$product->getId()} {$product->getTitle()}\n";
}
}
if ( 'wcs-ads-customers-lib' === $_GET['action'] && check_admin_referer( 'wcs-ads-customers-lib' ) ) {
try {
$accounts = $this->container->get( Ads::class )->get_ads_accounts();
$this->response .= 'Total accounts: ' . count( $accounts ) . "\n";
foreach ( $accounts as $account ) {
$this->response .= sprintf( "%d : %s\n", $account['id'], $account['name'] );
$_GET['customer_id'] = $account['id'];
}
} catch ( \Exception $e ) {
$this->response .= 'Error: ' . $e->getMessage();
}
}
if ( 'wcs-ads-campaign-lib' === $_GET['action'] && check_admin_referer( 'wcs-ads-campaign-lib' ) ) {
try {
/** @var AdsCampaign $ads_campaign */
$ads_campaign = $this->container->get( AdsCampaign::class );
/** @var OptionsInterface $options */
$options = $this->container->get( OptionsInterface::class );
$this->response = "Proxied request > get ad campaigns {$options->get_ads_id()}\n";
$campaigns = $ads_campaign->get_campaigns();
if ( empty( $campaigns ) ) {
$this->response .= 'No campaigns found';
} else {
$this->response .= 'Total campaigns: ' . count( $campaigns ) . "\n";
foreach ( $campaigns as $campaign ) {
$this->response .= print_r( $campaign, true ) . "\n";
}
}
} catch ( \Exception $e ) {
$this->response .= 'Error: ' . $e->getMessage();
}
}
if ( 'wcs-accept-tos' === $_GET['action'] && check_admin_referer( 'wcs-accept-tos' ) ) {
$result = $this->container->get( Middleware::class )->mark_tos_accepted( 'google-mc', 'john.doe@example.com' );
$this->response .= sprintf(
'Attempting to accept Tos. Successful? %s<br>Response body: %s',
$result->accepted() ? 'Yes' : 'No',
$result->message()
);
}
if ( 'wcs-check-tos' === $_GET['action'] && check_admin_referer( 'wcs-check-tos' ) ) {
$accepted = $this->container->get( Middleware::class )->check_tos_accepted( 'google-mc' );
$this->response .= sprintf(
'Tos Accepted? %s<br>Response body: %s',
$accepted->accepted() ? 'Yes' : 'No',
$accepted->message()
);
}
if ( 'wcs-sync-product' === $_GET['action'] && check_admin_referer( 'wcs-sync-product' ) ) {
if ( empty( $_GET['product_id'] ) ) {
$this->response .= 'Please enter a Product ID';
return;
}
$id = absint( $_GET['product_id'] );
$product = wc_get_product( $id );
if ( $product instanceof \WC_Product ) {
if ( empty( $_GET['async'] ) ) {
/** @var ProductSyncer $product_syncer */
$product_syncer = $this->container->get( ProductSyncer::class );
try {
$result = $product_syncer->update( [ $product ] );
$this->response .= sprintf( '%s products successfully submitted to Google.', count( $result->get_products() ) ) . "\n";
if ( ! empty( $result->get_errors() ) ) {
$this->response .= sprintf( 'There were %s errors:', count( $result->get_errors() ) ) . "\n";
foreach ( $result->get_errors() as $invalid_product ) {
$this->response .= sprintf( "%s:\n%s", $invalid_product->get_wc_product_id(), implode( "\n", $invalid_product->get_errors() ) ) . "\n";
}
}
} catch ( ProductSyncerException $exception ) {
$this->response = 'Error submitting product to Google: ' . $exception->getMessage();
}
} else {
// schedule a job
/** @var UpdateProducts $update_job */
$update_job = $this->container->get( UpdateProducts::class );
$update_job->schedule( [ [ $product->get_id() ] ] );
$this->response = 'Successfully scheduled a job to sync the product ' . $product->get_id();
}
} else {
$this->response = 'Invalid product ID provided: ' . $id;
}
}
if ( 'wcs-sync-all-products' === $_GET['action'] && check_admin_referer( 'wcs-sync-all-products' ) ) {
if ( empty( $_GET['async'] ) ) {
/** @var ProductSyncer $product_syncer */
$product_syncer = $this->container->get( ProductSyncer::class );
/** @var ProductRepository $product_repository */
$product_repository = $this->container->get( ProductRepository::class );
try {
$products = $product_repository->find_sync_ready_products()->get();
$result = $product_syncer->update( $products );
$this->response .= sprintf( '%s products successfully submitted to Google.', count( $result->get_products() ) ) . "\n";
if ( ! empty( $result->get_errors() ) ) {
$this->response .= sprintf( 'There were %s errors:', count( $result->get_errors() ) ) . "\n";
foreach ( $result->get_errors() as $invalid_product ) {
$this->response .= sprintf( "%s:\n%s", $invalid_product->get_wc_product_id(), implode( "\n", $invalid_product->get_errors() ) ) . "\n";
}
}
} catch ( ProductSyncerException $exception ) {
$this->response = 'Error submitting products to Google: ' . $exception->getMessage();
}
} else {
// schedule a job
/** @var UpdateAllProducts $update_job */
$update_job = $this->container->get( UpdateAllProducts::class );
$update_job->schedule();
$this->response = 'Successfully scheduled a job to sync all products!';
}
}
if ( 'wcs-delete-synced-products' === $_GET['action'] && check_admin_referer( 'wcs-delete-synced-products' ) ) {
if ( empty( $_GET['async'] ) ) {
/** @var ProductSyncer $product_syncer */
$product_syncer = $this->container->get( ProductSyncer::class );
/** @var ProductRepository $product_repository */
$product_repository = $this->container->get( ProductRepository::class );
try {
$products = $product_repository->find_synced_products();
$result = $product_syncer->delete( $products );
$this->response .= sprintf( '%s synced products deleted from Google.', count( $result->get_products() ) ) . "\n";
if ( ! empty( $result->get_errors() ) ) {
$this->response .= sprintf( 'There were %s errors:', count( $result->get_errors() ) ) . "\n";
foreach ( $result->get_errors() as $invalid_product ) {
$this->response .= sprintf( "%s:\n%s", $invalid_product->get_wc_product_id(), implode( "\n", $invalid_product->get_errors() ) ) . "\n";
}
}
} catch ( ProductSyncerException $exception ) {
$this->response = 'Error deleting products from Google: ' . $exception->getMessage();
}
} else {
// schedule a job
/** @var DeleteAllProducts $delete_job */
$delete_job = $this->container->get( DeleteAllProducts::class );
$delete_job->schedule();
$this->response = 'Successfully scheduled a job to delete all synced products!';
}
}
if ( 'wcs-cleanup-products' === $_GET['action'] && check_admin_referer( 'wcs-cleanup-products' ) ) {
if ( empty( $_GET['async'] ) ) {
/** @var ProductSyncer $product_syncer */
$product_syncer = $this->container->get( ProductSyncer::class );
/** @var ProductRepository $product_repository */
$product_repository = $this->container->get( ProductRepository::class );
/** @var BatchProductHelper $batch_product_helper */
$batch_product_helper = $this->container->get( BatchProductHelper::class );
try {
$products = $product_repository->find_synced_products();
$stale_entries = $batch_product_helper->generate_stale_products_request_entries( $products );
$result = $product_syncer->delete_by_batch_requests( $stale_entries );
$this->response .= sprintf( '%s products cleaned up.', count( $result->get_products() ) ) . "\n";
if ( ! empty( $result->get_errors() ) ) {
$this->response .= sprintf( 'There were %s errors:', count( $result->get_errors() ) ) . "\n";
foreach ( $result->get_errors() as $invalid_product ) {
$this->response .= sprintf( "%s:\n%s", $invalid_product->get_wc_product_id(), implode( "\n", $invalid_product->get_errors() ) ) . "\n";
}
}
} catch ( ProductSyncerException $exception ) {
$this->response = 'Error cleaning up products: ' . $exception->getMessage();
}
} else {
// schedule a job
/** @var CleanupProductsJob $delete_job */
$delete_job = $this->container->get( CleanupProductsJob::class );
$delete_job->schedule();
$this->response = 'Successfully scheduled a job to cleanup all products!';
}
}
if ( 'e2e-test-conversion-id' === $_GET['action'] && check_admin_referer( 'e2e-test-conversion-id' ) ) {
/** @var OptionsInterface $options */
$options = $this->container->get( OptionsInterface::class );
$options->update(
OptionsInterface::ADS_CONVERSION_ACTION,
[
'conversion_id' => 'AW-123456',
'conversion_label' => 'aB_cdEFgh',
]
);
$this->response .= 'Saved test conversion ID.';
}
if ( 'e2e-clear-conversion-id' === $_GET['action'] && check_admin_referer( 'e2e-clear-conversion-id' ) ) {
/** @var OptionsInterface $options */
$options = $this->container->get( OptionsInterface::class );
$options->delete( OptionsInterface::ADS_CONVERSION_ACTION );
$this->response .= 'Cleared conversion ID.';
}
}
/**
* Retrieve an authorization header containing a Jetpack token.
*
* @return string Authorization header.
*/
private function get_auth_header(): string {
/** @var Manager $manager */
$manager = $this->container->get( Manager::class );
$token = $manager->get_tokens()->get_access_token();
[ $token_key, $token_secret ] = explode( '.', $token->secret );
$token_key = sprintf( '%s:%d:%d', $token_key, defined( 'JETPACK__API_VERSION' ) ? JETPACK__API_VERSION : 1, $token->external_user_id );
$time_diff = (int) Jetpack_Options::get_option( 'time_diff' );
$timestamp = time() + $time_diff;
$nonce = wp_generate_password( 10, false );
$normalized_request_string = join( "\n", [ $token_key, $timestamp, $nonce ] ) . "\n";
$signature = base64_encode( hash_hmac( 'sha1', $normalized_request_string, $token_secret, true ) );
$auth = [
'token' => $token_key,
'timestamp' => $timestamp,
'nonce' => $nonce,
'signature' => $signature,
];
$header_pieces = [];
foreach ( $auth as $key => $value ) {
$header_pieces[] = sprintf( '%s="%s"', $key, $value );
}
return 'X_JP_Auth ' . join( ' ', $header_pieces );
}
/**
* Send a REST API request and add the response to our buffer.
*/
private function send_rest_request( Request $request ) {
$response = rest_do_request( $request );
$server = rest_get_server();
$data = $server->response_to_data( $response, false );
$json = wp_json_encode( $data, JSON_PRETTY_PRINT );
$this->response .= 'Request: ' . $request->get_method() . ' ' . $request->get_route() . PHP_EOL;
$this->response .= 'Status: ' . $response->get_status() . PHP_EOL;
$this->response .= 'Response: ' . $json;
}
}