← All changes | classes/client/client.php +67 -8 1.6.0 → 1.7.7 View file →

		@@ -4,9 +4,13 @@
4	4
5	5	use ImageOptimization\Classes\Exceptions\Client_Exception;
6	6	use ImageOptimization\Classes\File_Utils;
7	7	use ImageOptimization\Classes\Image\Image;
	8	+use ImageOptimization\Classes\Logger;
	9	+use ImageOptimization\Modules\Connect\Module as Connect_Module;
	10	+use ImageOptimization\Modules\Optimization\Classes\Optimize_Image;
8	11	use ImageOptimization\Modules\Stats\Classes\Optimization_Stats;
	12	+use Throwable;
9	13	use WP_Error;
10	14
11	15	use ImageOptimization\Plugin;
12	16
		@@ -18,9 +22,13 @@
18	22	* Class Client
19	23	*/
20	24	class Client {
21	25	const BASE_URL = 'https://my.elementor.com/api/v2/image-optimizer/';
22		- const STATUS_CHECK = 'status/check';
	26	+ const BASE_URL_FEEDBACK = 'https://feedback-api.prod.apps.elementor.red/apps/api/v1/';
	27	+ const SITE_INFO = 'site/info';
	28	+ const SITE_INFO_TRANSIENT = 'image_optimizer_site_info';
	29	+ const SITE_INFO_TRANSIENT_ERROR = 'image_optimizer_site_info_error';
	30	+ const ERROR_CACHE_DURATION = MINUTE_IN_SECONDS * 5;
23	31
24	32	private bool $refreshed = false;
25	33
26	34	public static ?Client $instance = null;
		@@ -32,8 +40,9 @@
32	40	public static function get_instance(): ?Client {
33	41	if ( ! self::$instance ) {
34	42	self::$instance = new self();
35	43	}
	44	+
36	45	return self::$instance;
37	46	}
38	47
39	48	public static function get_site_info( $endpoint = null ): array {
		@@ -48,9 +57,9 @@
48	57	'local_id' => get_current_user_id(),
49	58
50	59	];
51	60
52		- if ( $endpoint !== self::STATUS_CHECK ) {
	61	+ if ( Optimize_Image::IMAGE_OPTIMIZE_ENDPOINT === $endpoint ) {
53	62	// Media library stats
54	63	$data['media_data'] = base64_encode( wp_json_encode( self::get_request_stats() ) ); // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_encode
55	64	}
56	65
		@@ -56,8 +65,43 @@
56	65
57	66	return $data;
58	67	}
59	68
	69	+ /**
	70	+ * Get site info
	71	+ * @return mixed|WP_Error|null
	72	+ */
	73	+ public static function get_subscription_info() {
	74	+ $cached_info = get_transient( self::SITE_INFO_TRANSIENT );
	75	+
	76	+ if ( $cached_info ) {
	77	+ return $cached_info;
	78	+ }
	79	+
	80	+ $cached_error = get_transient( self::SITE_INFO_TRANSIENT_ERROR );
	81	+
	82	+ if ( $cached_error ) {
	83	+ Logger::debug( 'Status check skipped due to recent error: ' . $cached_error );
	84	+ return null;
	85	+ }
	86	+
	87	+ try {
	88	+ $info = self::get_instance()->make_request( 'POST', self::SITE_INFO );
	89	+ } catch ( Throwable $t ) {
	90	+ $error_message = $t->getMessage();
	91	+
	92	+ Logger::error( 'Cannot get site info response from service: ' . $error_message );
	93	+
	94	+ set_transient( self::SITE_INFO_TRANSIENT_ERROR, $error_message, self::ERROR_CACHE_DURATION );
	95	+
	96	+ return null;
	97	+ }
	98	+
	99	+ set_transient( self::SITE_INFO_TRANSIENT, $info, DAY_IN_SECONDS );
	100	+
	101	+ return $info;
	102	+ }
	103	+
60	104	private static function get_request_stats(): array {
61	105	$optimization_stats = Optimization_Stats::get_image_stats();
62	106	$image_sizes = [];
63	107
		@@ -101,9 +145,9 @@
101	145	$response = $this->request(
102	146	$method,
103	147	$endpoint,
104	148	[
105		- 'timeout' => 100,
	149	+ 'timeout' => 50,
106	150	'headers' => $headers,
107	151	'body' => $body,
108	152	]
109	153	);
		@@ -110,11 +154,19 @@
110	154
111	155	return ( new Client_Response( $response ) )->handle();
112	156	}
113	157
	158	+ public static function get_feedback_base_url() {
	159	+ return apply_filters( 'image_optimizer_feedback_base_url', self::BASE_URL_FEEDBACK );
	160	+ }
	161	+
114	162	private static function get_remote_url( $endpoint ): string {
115	163	$base_url = apply_filters( 'image_optimizer_client_get_base_url', self::BASE_URL );
116	164
	165	+ if ( strpos( $endpoint, 'feedback/' ) !== false ) {
	166	+ return self::get_feedback_base_url() . $endpoint;
	167	+ }
	168	+
117	169	return $base_url . $endpoint;
118	170	}
119	171
120	172	protected function is_connected(): bool {
		@@ -121,9 +173,8 @@
121	173	return Plugin::instance()->modules_manager->get_modules( 'connect-manager' )->connect_instance->is_connected();
122	174	}
123	175
124	176	protected function generate_authentication_headers( $endpoint ): array {
125		-
126	177	$connect_instance = Plugin::instance()->modules_manager->get_modules( 'connect-manager' )->connect_instance;
127	178
128	179	if ( ! $connect_instance->get_is_connect_on_fly() ) {
129	180	$headers = [
		@@ -193,9 +244,15 @@
193	244	return $this->request( $method, $endpoint, $args );
194	245	}
195	246	}
196	247
197		- if ( 200 !== $response_code ) {
	248	+ // If there is mismatch then trigger the mismatch flow explicitly.
	249	+ if ( ! $this->refreshed && ! empty( $body->message ) && ( false !== strpos( $body->message, 'site url mismatch' ) ) ) {
	250	+ Connect_Module::get_connect()->data()->set_home_url( 'https://wrongurl' );
	251	+ return new WP_Error( 401, 'site url mismatch' );
	252	+ }
	253	+
	254	+ if ( ! in_array( $response_code, [ 200, 201 ], true ) ) {
198	255	// In case $as_array = true.
199	256	$message = $body->message ?? wp_remote_retrieve_response_message( $response );
200	257	$message = is_array( $message ) ? join( ', ', $message ) : $message;
201	258	$code = isset( $body->code ) ? (int) $body->code : $response_code;
		@@ -225,8 +282,9 @@
225	282	* @throws Client_Exception
226	283	*/
227	284	private function get_upload_request_body( array $body, $file, string $boundary, string $file_name = '' ): string {
228	285	$payload = '';
	286	+
229	287	// add all body fields as standard POST fields:
230	288	foreach ( $body as $name => $value ) {
231	289	$payload .= '--' . $boundary;
232	290	$payload .= "\r\n";
		@@ -245,9 +303,9 @@
245	303	if (
246	304	! in_array( $image_mime, Image::get_supported_mime_types(), true ) &&
247	305	( 'application/octet-stream' === $image_mime && 'avif' !== File_Utils::get_extension( $file ) )
248	306	) {
249		- throw new Client_Exception( "Unsupported mime type `$image_mime`" );
	307	+ throw new Client_Exception( esc_html( "Unsupported mime type `$image_mime`" ) );
250	308	}
251	309
252	310	if ( empty( $file_name ) ) {
253	311	$file_name = basename( $file );
		@@ -270,15 +328,16 @@
270	328	* @return string
271	329	*/
272	330	private function get_file_payload( string $filename, string $file_type, string $file_path, string $boundary ): string {
273	331	$name = $filename ?? basename( $file_path );
274		- $mine_type = 'image' === $file_type ? image_type_to_mime_type( exif_imagetype( $file_path ) ) : $file_type;
	332	+ $mime_type = 'image' === $file_type ? image_type_to_mime_type( exif_imagetype( $file_path ) ) : $file_type;
275	333	$payload = '';
	334	+
276	335	// Upload the file
277	336	$payload .= '--' . $boundary;
278	337	$payload .= "\r\n";
279	338	$payload .= 'Content-Disposition: form-data; name="' . esc_attr( $name ) . '"; filename="' . esc_attr( $name ) . '"' . "\r\n";
280		- $payload .= 'Content-Type: ' . $mine_type . "\r\n";
	339	+ $payload .= 'Content-Type: ' . $mime_type . "\r\n";
281	340	$payload .= "\r\n";
282	341	$payload .= file_get_contents( $file_path );
283	342	$payload .= "\r\n";
284	343