<?php

class WPBRIGADE_Logger {

	private static $_instances   = array();
	private static $product_data = array();
	private static $_module_id;

	private static $current_uninstall_slug = null;

	// Constructor for the Logger class
	private function __construct( $module_id, $slug = false, $is_init = false ) {
		if ( ! $is_init && ! is_numeric( $module_id ) && ! is_string( $slug ) ) {
			return false;
		}
		self::$_module_id             = $module_id;
		self::$current_uninstall_slug = $slug; // Set current uninstall slug
	}

	// Method to create or retrieve a Logger instance
	public static function instance( $module_id, $slug = false, $is_init = false ) {
		if ( empty( $module_id ) ) {
			return false;
		}
		if ( ! $is_init && true === $slug ) {
			$is_init = true;
		}

		if ( ! isset( self::$_instances[ $slug ] ) ) {
			self::$_instances[ $slug ] = new WPBRIGADE_Logger( $module_id, $slug, $is_init );
		}

		return self::$_instances[ $slug ];
	}

	// Method to initialize the Logger with module data
	public function wpb_init( array $module ) {
		$key                                  = $module['slug'];
		self::$product_data[ $key ]           = array();
		self::$product_data[ $key ]['module'] = $module;
		$this->hooks( $module['slug'] );
	}

	// Method to attach hooks for scheduled events and AJAX
	public function hooks( $slug ) {
		// Initialize custom schedules
		add_action(
			'init',
			function () use ( $slug ) {
				$this->set_logs_schedule( $slug );
			}
		);

		// Daily log plugin execution
		add_action(
			'wpb_data_sync_' . $slug,
			function () use ( $slug ) {
				$this->daily_log_plugin( $slug );
			}
		);

		// Admin footer hook
		add_action(
			'admin_footer',
			function () use ( $slug ) {
				$this->deactivation_model( $slug );
			}
		);

		// AJAX deactivation action
		add_action(
			'wp_ajax_wpb_sdk_' . $slug . '_deactivation',
			function () use ( $slug ) {
				$this->ajax_deactivation( $slug );
			}
		);

		// Plugin activation hook
		register_activation_hook(
			wpb_get_plugin_path( $slug ),
			function () use ( $slug ) {
				$this->log_activation( $slug );
			}
		);

		// Plugin deactivation hook
		register_deactivation_hook(
			wpb_get_plugin_path( $slug ),
			function () use ( $slug ) {
				$this->product_deactivation( $slug );
			}
		);

		// Plugin uninstallation hook
		register_uninstall_hook( wpb_get_plugin_path( $slug ), array( __CLASS__, 'log_uninstallation' ) );
	}

	// Method to set scheduled events for logging
	public function set_logs_schedule( $slug ) {
		// Clean Old Cron jobs
		wp_clear_scheduled_hook( 'wpb_logger_cron_' . $slug );
		wp_clear_scheduled_hook( 'wpb_daily_sync_cron_' . $slug );

		// Calculate future timestamps for scheduling
		$daily_start_time = strtotime( '+1 day' );
		// Schedule daily cron event if not already scheduled
		if ( ! wp_next_scheduled( 'wpb_data_sync_' . $slug ) ) {
			wp_schedule_event( $daily_start_time, 'daily', 'wpb_data_sync_' . $slug );
		}
	}

	public static function reset_logs_schedule( $slug ) {
		// Calculate future timestamps for scheduling
		$daily_start_time = strtotime( '+1 day' );

		// Schedule daily cron event if not already scheduled
		if ( ! wp_next_scheduled( 'wpb_data_sync_' . $slug ) ) {
			wp_schedule_event( $daily_start_time, 'daily', 'wpb_data_sync_' . $slug );
		}
	}

	public static function remove_logs_schedule( $slug ) {
		wp_clear_scheduled_hook( 'wpb_data_sync_' . $slug );
	}

	// Method to log plugin activity on daily scheduled events
	public function daily_log_plugin( $slug ) {
		$sdk_data  = json_decode( get_option( 'wpb_sdk_' . $slug ), true );
		$user_skip = isset( $sdk_data['user_skip'] ) ? $sdk_data['user_skip'] : false;
		$user_skip = $user_skip === '1' ? true : false;
		if ( $user_skip ) {
			$logs_data             = self::get_logs_data( $slug, 'user_skip' );
			$sdk_data['user_skip'] = '0';
			$sdk_data_json         = json_encode( $sdk_data );
			update_option( 'wpb_sdk_' . $slug, $sdk_data_json );
		} else {
			$logs_data = self::get_logs_data( $slug, 'daily' );
		}

		if ( ! empty( $logs_data ) ) {
			$logs_to_send = array_merge(
				$logs_data,
				array(
					'explicit_logs' => array(
						'action' => 'daily',
					),
				)
			);
			self::send( $slug, $logs_to_send );
		}
	}

	// Method to log plugin activation
	public function log_activation( $slug ) {
		$logs_data = self::get_logs_data( $slug, 'activate' );
		if ( ! empty( $logs_data ) ) {
			$logs_to_send = array_merge(
				$logs_data,
				array(
					'explicit_logs' => array(
						'action' => 'activate',
					),
				)
			);
			self::send( $slug, $logs_to_send );
		}
	}

	// Method to add deactivation model HTML to admin footer
	public function deactivation_model( $slug ) {
		if ( function_exists( 'get_current_screen' ) ) {
			$screen = get_current_screen();
			if ( 'plugins.php' === $screen->parent_file ) {
				$plugin_data     = wpb_get_plugin_details( $slug );
				$product_name    = $plugin_data['Name'];
				$product_slug    = $slug;
				$has_pro_version = self::$product_data[ $slug ]['module']['is_premium'] === true;
				include dirname( __DIR__ ) . '/views/wpb-sdk-deactivate-form.php';
			}
		}
	}

	// Method to handle AJAX request for plugin deactivation
	public function ajax_deactivation( $slug ) {
		$path = wpb_get_plugin_path( $slug );

		if ( isset( $_POST['nonce'] ) && empty( $_POST['nonce'] ) ) {
			return;
		}

		$nonce        = sanitize_text_field( wp_unslash( $_POST['nonce'] ) );
		$verify_nonce = wp_verify_nonce( $nonce, 'deactivate-plugin_' . plugin_basename( $path ) );

		if ( ! $verify_nonce ) {
			return;
		}

		$this->log_deactivation( $slug );

		wp_die();
	}

	// Method to handle plugin deactivation
	public function product_deactivation( $slug ) {
		wp_clear_scheduled_hook( 'wpb_data_sync_' . $slug );
	}

	// Method to log plugin deactivation
	public function log_deactivation( $slug ) {
		$reason        = isset( $_POST['reason'] ) ? $_POST['reason'] : '';
		$reason_detail = isset( $_POST['reason_detail'] ) ? $_POST['reason_detail'] : '';
		$logs_data     = self::get_logs_data( $slug, 'deactivate' );
		if ( ! empty( $logs_data ) ) {
			$logs_to_send = array_merge(
				$logs_data,
				array(
					'explicit_logs' => array(
						'action'        => 'deactivate',
						'reason'        => sanitize_text_field( wp_unslash( $reason ) ),
						'reason_detail' => sanitize_text_field( wp_unslash( $reason_detail ) ),
					),
				)
			);
			self::send( $slug, $logs_to_send );
		}
	}

	// Method to log plugin uninstallation
	public static function log_uninstallation() {
		$slug      = self::$current_uninstall_slug;
		$logs_data = self::get_logs_data( $slug, 'uninstall' );
		if ( ! empty( $logs_data ) ) {
			$logs_to_send = array_merge(
				$logs_data,
				array(
					'explicit_logs' => array(
						'action' => 'uninstall',
					),
				)
			);
			self::send( $slug, $logs_to_send );
		}
		// Call Plugin uninstall hook
		do_action( 'wp_wpb_sdk_after_uninstall' );
	}

	/**
	 * Collect all data for logging.
	 *
	 * @return array
	 */
	public static function get_logs_data( $slug, $action = '' ) {
		global $wpdb;

		// Get product data
		$module = self::$product_data[ $slug ]['module'];
		// Initialize variables
		$data                  = array();
		$theme_data            = wp_get_theme();
		$curl_version          = '';
		$external_http_blocked = '';
		$users_count           = '';

		$sdk_data = json_decode( get_option( 'wpb_sdk_' . $slug ), true );

		$sdk_communication   = isset( $sdk_data['communication'] ) ? $sdk_data['communication'] : '0';
		$sdk_diagnostic_info = isset( $sdk_data['diagnostic_info'] ) ? $sdk_data['diagnostic_info'] : '0';
		$sdk_extensions      = isset( $sdk_data['extensions'] ) ? $sdk_data['extensions'] : '0';

		$send_wpb_sdk_communication   = $sdk_communication === '1' ? true : false;
		$send_wpb_sdk_diagnostic_info = $sdk_diagnostic_info === '1' ? true : false;
		$send_wpb_sdk_extensions      = $sdk_extensions === '1' ? true : false;

		if ( $action != 'user_skip' ) {
			if ( ! $send_wpb_sdk_communication && ! $send_wpb_sdk_diagnostic_info && ! $send_wpb_sdk_extensions ) {
				self::remove_logs_schedule( $slug );
				return array();
			} else {
				self::reset_logs_schedule( $slug );
			}
		}
		// Get admin user data
		$admin_users = get_users( array( 'role' => 'Administrator' ) );
		$admin       = isset( $admin_users[0] ) ? $admin_users[0]->data : '';
		$admin_meta  = ! empty( $admin ) ? get_user_meta( $admin->ID ) : '';

		// Collect data
		$data['authentication']['public_key'] = $module['public_key'];

		if ( $action == 'user_skip' || $send_wpb_sdk_communication ) {
			// USER INFO
			$data['user_info'] = array(
				'user_email'     => ! empty( $admin ) ? sanitize_email( $admin->user_email ) : '',
				'user_nickname'  => ! empty( $admin ) ? sanitize_text_field( $admin->user_nicename ) : '',
				'user_firstname' => isset( $admin_meta['first_name'][0] ) ? sanitize_text_field( $admin_meta['first_name'][0] ) : '',
				'user_lastname'  => isset( $admin_meta['last_name'][0] ) ? sanitize_text_field( $admin_meta['last_name'][0] ) : '',
			);
		}

		// PRODUCT INFO MUST HAVE
		$data['product_info']                = self::get_product_data( $slug );
		$data['product_info']['sdk_version'] = WP_WPBRIGADE_SDK_VERSION;

		if ( $action == 'user_skip' || $send_wpb_sdk_diagnostic_info ) {
			$data['product_info']['product_settings'] = self::get_product_settings( $slug );
		}

		// SITE INFO MUST HAVE
		$data['site_info'] = array(
			'site_url' => site_url(),
			'home_url' => home_url(),
		);

		if ( $action == 'user_skip' || $send_wpb_sdk_diagnostic_info ) {
			$ip       = self::get_ip();
			$location = self::get_location_details( $ip );

			// Check if get_plugins function exists
			if ( ! function_exists( 'get_plugins' ) ) {
				include ABSPATH . '/wp-admin/includes/plugin.php';
			}

			// Get users count if function exists
			if ( function_exists( 'count_users' ) ) {
				$users_count = count_users();
				$users_count = isset( $users_count['total_users'] ) ? intval( $users_count['total_users'] ) : '';
			}

			// Check external http request blocking
			if ( ! defined( 'WP_HTTP_BLOCK_EXTERNAL' ) || ! WP_HTTP_BLOCK_EXTERNAL ) {
				$external_http_blocked = 'none';
			} else {
				$external_http_blocked = defined( 'WP_ACCESSIBLE_HOSTS' ) ? 'partially (accessible hosts: ' . esc_html( WP_ACCESSIBLE_HOSTS ) . ')' : 'all';
			}

			// Get curl version if function exists
			if ( function_exists( 'curl_init' ) ) {
				$curl         = curl_version();
				$curl_version = '(' . $curl['version'] . ' ' . $curl['ssl_version'] . ')';
			}

			$data['site_info']['site_meta_info']   = array(
				'is_multisite'          => is_multisite(),
				'multisites'            => self::get_multisites(),
				'php_version'           => phpversion(),
				'wp_version'            => get_bloginfo( 'version' ),
				'server'                => isset( $_SERVER['SERVER_SOFTWARE'] ) ? $_SERVER['SERVER_SOFTWARE'] : '',
				'timezoneoffset'        => date( 'P' ),
				'ext/mysqli'            => isset( $wpdb->use_mysqli ) && ! empty( $wpdb->use_mysqli ) ? true : false,
				'mysql_version'         => function_exists( 'mysqli_get_server_info' ) ? mysqli_get_server_info( $wpdb->dbh ) : '',
				'memory_limit'          => ( defined( WP_MEMORY_LIMIT ) ? WP_MEMORY_LIMIT : ini_get( 'memory_limit' ) ) ? ini_get( 'memory_limit' ) : '',
				'external_http_blocked' => $external_http_blocked,
				'wp_locale'             => get_locale(),
				'db_charset'            => defined( 'DB_CHARSET' ) ? DB_CHARSET : '',
				'debug_mode'            => defined( 'WP_DEBUG' ) && WP_DEBUG ? true : false,
				'wp_max_upload'         => size_format( wp_max_upload_size() ),
				'php_time_limit'        => function_exists( 'ini_get' ) ? ini_get( 'max_execution_time' ) : '',
				'php_error_log'         => function_exists( 'ini_get' ) ? ini_get( 'error_log' ) : '',
				'fsockopen'             => function_exists( 'fsockopen' ) ? true : false,
				'open_ssl'              => defined( 'OPENSSL_VERSION_TEXT' ) ? OPENSSL_VERSION_TEXT : '',
				'curl'                  => $curl_version,
				'ip'                    => $ip,
				'user_count'            => $users_count,
				'admin_email'           => sanitize_email( get_bloginfo( 'admin_email' ) ),
				'theme_name'            => sanitize_text_field( $theme_data->Name ),
				'theme_version'         => sanitize_text_field( $theme_data->Version ),
			);
			$data['site_info']['location_details'] = $location !== null ? $location : '';
		}

		// SITE PLUGINS
		if ( $action == 'user_skip' || $send_wpb_sdk_extensions ) {
			$data['site_plugins'] = self::get_all_plugins();
		}

		return $data;
	}


	/**
	 * Retrieve plugin settings related to the product.
	 *
	 * @return array
	 */
	private static function get_product_settings( $slug ) {
		$product_data   = self::$product_data[ $slug ]['module'];
		$plugin_options = array();

		// Pull settings data from db.
		foreach ( $product_data['settings'] as $option_name => $default_value ) {
			$get_option       = get_option( $option_name );
			$plugin_options[] = array(
				'option' => $option_name,
				'value'  => ! empty( $get_option ) ? wp_json_encode( $get_option ) : $default_value,
			);
		}

		return $plugin_options;
	}

	/**
	 * Collect multisite data.
	 *
	 * @return array|false
	 */
	private static function get_multisites() {
		if ( ! is_multisite() ) {
			return false;
		}

		$sites_info = array();
		$sites      = get_sites();

		foreach ( $sites as $site ) {
			$sites_info[ $site->blog_id ] = array(
				'name'   => get_blog_details( $site->blog_id )->blogname,
				'domain' => $site->domain,
				'path'   => $site->path,
			);
		}

		return $sites_info;
	}

	/**
	 * Get user IP information.
	 *
	 * @return string|null
	 */
	private static function get_ip() {
		$fields = array(
			'HTTP_CF_CONNECTING_IP',
			'HTTP_CLIENT_IP',
			'HTTP_X_FORWARDED_FOR',
			'HTTP_X_FORWARDED',
			'HTTP_FORWARDED_FOR',
			'HTTP_FORWARDED',
			'REMOTE_ADDR',
		);

		foreach ( $fields as $ip_field ) {
			if ( ! empty( $_SERVER[ $ip_field ] ) ) {
				return $_SERVER[ $ip_field ];
			}
		}

		return null;
	}

	/**
	 * Collect plugins information: Active/Inactive plugins.
	 *
	 * @return array
	 */
	private static function get_all_plugins() {
		$all_plugins       = array_keys( get_plugins() );
		$active_plugins    = get_option( 'active_plugins', array() );
		$in_active_plugins = array();

		foreach ( $all_plugins as $plugin ) {
			if ( ! in_array( $plugin, $active_plugins ) ) {
				// add in-active plugins in list.
				$in_active_plugins[] = $plugin;
			}
		}

		return array(
			'active'   => $active_plugins,
			'inactive' => $in_active_plugins,
		);
	}

	/**
	 * Get location details based on IP.
	 *
	 * @param string|null $ip
	 * @return array
	 */
	private static function get_location_details( $ip ) {
		$location_details = array();
		try {
			$ch = curl_init();

			curl_setopt( $ch, CURLOPT_URL, "https://api.iplocation.net/?ip={$ip}" );

			curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );

			$execute = curl_exec( $ch );

			curl_close( $ch );

			$result = json_decode( $execute );

			if ( $result && $result->response_code === '200' ) {
				if ( $result->country_name !== '-' && $result->country_code2 !== '-' ) {
					$location_details['response_code']        = $result->response_code;
					$location_details['message']              = 'Success';
					$location_details['data']['country_name'] = $result->country_name;
					$location_details['data']['country_code'] = $result->country_code2;
				} else {
					$missing_info = array();
					if ( $result->country_name === '-' ) {
						$missing_info[] = 'country_name';
					}
					if ( $result->country_code2 === '-' ) {
						$missing_info[] = 'country_code';
					}
					$location_details['response_code'] = '400';
					$location_details['message']       = 'Error: Missing information for ' . implode( ', ', $missing_info ) . ' for the IP Address: ' . $ip;
				}
			} else {
				$location_details['response_code'] = '400';
				$location_details['message']       = 'Error: Invalid response code or data for the IP Address: ' . $ip;
			}

			return $location_details;
		} catch ( \Exception $e ) {
			$location_details['response_code'] = '400';
			$location_details['message']       = 'Error: ' . $e->getMessage();
			return $location_details;
		}
	}

	/**
	 * Get product data.
	 *
	 * @param string $slug
	 * @return array
	 */
	private static function get_product_data( $slug ) {
		$plugin_data     = wpb_get_plugin_details( $slug );
		$data            = array();
		$data['name']    = isset( $plugin_data['Name'] ) ? $plugin_data['Name'] : $plugin_data['Title'];
		$data['slug']    = $slug;
		$data['id']      = self::$_module_id;
		$data['type']    = 'Plugin';
		$data['path']    = wpb_get_plugin_path( $slug );
		$data['version'] = $plugin_data['Version'];
		return $data;
	}


	/**
	 * Send log data to the API.
	 *
	 * @param array $payload The log data payload.
	 */
	private static function send( $slug, $payload ) {
		// Add timestamp to the payload
		$payload['sent_at'] = current_time( 'mysql', 1 );

		// Determine the log status
		$logStatus             = 'new';
		$payload['log_status'] = $logStatus;

		self::sendDataToAPI( $slug, $payload );
	}


	/**
	 * Send data to the API endpoint.
	 *
	 * @param array $data The data to be sent.
	 */
	private static function sendDataToAPI( $slug, $data ) {
		$token = self::$product_data[ $slug ]['module']['public_key'];

		$response = wp_remote_post(
			WPBRIGADE_SDK_API_ENDPOINT . '/logger',
			array(
				'method'  => 'POST',
				'body'    => $data,
				'headers' => array(
					'Authorization' => 'Bearer ' . $token, // Add the token in the request headers
				),
			)
		);
	}
}