<?php

namespace WPPilot;

defined( 'ABSPATH' ) || exit;

/**
 * Runs on plugin activation. Creates the required database tables and sets
 * default options. Safe to call multiple times (idempotent).
 */
class Activator {

	private const DB_VERSION = '2';

	public static function activate(): void {
		self::create_tables();
		self::backfill_connected_user();
		// Only a first install takes the owner to WPPilot's page: a reactivation
		// (a plugin update re-activates the plugin) must not.
		$first_install = '' === (string) get_option( 'wppilot_db_version', '' );
		self::set_defaults();
		update_option( 'wppilot_db_version', self::DB_VERSION );
		if ( $first_install ) {
			update_option( 'wppilot_activation_redirect', '1', false );
		}
	}

	public static function maybe_redirect_after_activation(): void {
		if ( ! get_option( 'wppilot_activation_redirect', false ) ) {
			return;
		}

		// An update, AJAX, cron, REST or CLI request never takes the redirect:
		// a redirect answering one of those breaks it (an update's next step, an
		// AJAX caller). The next ordinary admin page does.
		if ( ! self::may_redirect_now() ) {
			return;
		}

		delete_option( 'wppilot_activation_redirect' );

		if ( isset( $_GET['activate-multi'] ) || is_network_admin() || ! current_user_can( 'manage_options' ) ) {
			return;
		}

		wp_safe_redirect( admin_url( 'admin.php?page=wppilot' ) );
		exit;
	}

	/** Whether this request is an ordinary admin page view, where a redirect is harmless. */
	public static function may_redirect_now(): bool {
		if ( ( function_exists( 'wp_doing_ajax' ) && wp_doing_ajax() ) || ( function_exists( 'wp_doing_cron' ) && wp_doing_cron() ) ) {
			return false;
		}
		if ( ( defined( 'REST_REQUEST' ) && REST_REQUEST ) || ( defined( 'WP_CLI' ) && WP_CLI ) || ( defined( 'IFRAME_REQUEST' ) && IFRAME_REQUEST ) ) {
			return false;
		}
		global $pagenow;
		return ! in_array( (string) $pagenow, array( 'update.php', 'update-core.php', 'admin-ajax.php', 'admin-post.php', 'async-upload.php' ), true );
	}

	/**
	 * Apply database changes required after a plugin update.
	 *
	 * The option read is intentionally the only work performed when the current
	 * schema version is already installed.
	 */
	public static function maybe_upgrade(): void {
		$version = get_option( 'wppilot_db_version', '' );
		if ( self::DB_VERSION === (string) $version ) {
			return;
		}

		self::create_tables();
		self::backfill_connected_user();
		update_option( 'wppilot_db_version', self::DB_VERSION );
	}

	private static function create_tables(): void {
		global $wpdb;
		$charset = $wpdb->get_charset_collate();

		$connection_table = $wpdb->prefix . 'wppilot_connection';
		$log_table        = $wpdb->prefix . 'wppilot_log';

		require_once ABSPATH . 'wp-admin/includes/upgrade.php';

		dbDelta(
			"CREATE TABLE {$connection_table} (
				id bigint(20) unsigned NOT NULL AUTO_INCREMENT,
				site_id varchar(36) NOT NULL DEFAULT '',
				site_url varchar(255) NOT NULL DEFAULT '',
				secret varchar(128) NOT NULL DEFAULT '',
				callback_token_hash varchar(64) NOT NULL DEFAULT '',
				connected_user_id bigint(20) unsigned NOT NULL DEFAULT 0,
				jwt_token text NOT NULL,
				jwt_expires_at datetime DEFAULT NULL,
				connected tinyint(1) NOT NULL DEFAULT 0,
				created_at datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
				updated_at datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
				PRIMARY KEY (id)
			) {$charset};"
		);

		dbDelta(
			"CREATE TABLE {$log_table} (
				id bigint(20) unsigned NOT NULL AUTO_INCREMENT,
				level varchar(10) NOT NULL DEFAULT 'info',
				message text NOT NULL,
				context text DEFAULT NULL,
				created_at datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
				PRIMARY KEY (id),
				KEY level_idx (level),
				KEY created_at_idx (created_at)
			) {$charset};"
		);
	}

	private static function backfill_connected_user(): void {
		global $wpdb;

		$connection_table = $wpdb->prefix . 'wppilot_connection';
		$connection_id    = $wpdb->get_var(
			"SELECT id FROM {$connection_table}
			WHERE connected = 1 AND connected_user_id = 0
			ORDER BY id ASC
			LIMIT 1"
		);

		if ( null === $connection_id ) {
			return;
		}

		$administrators = get_users(
			array(
				'role'    => 'administrator',
				'orderby' => 'ID',
				'order'   => 'ASC',
				'number'  => 1,
				'fields'  => array( 'ID' ),
			)
		);
		if ( empty( $administrators ) ) {
			return;
		}

		$wpdb->update(
			$connection_table,
			array( 'connected_user_id' => (int) $administrators[0]->ID ),
			array( 'id' => (int) $connection_id ),
			array( '%d' ),
			array( '%d' )
		);
	}

	private static function set_defaults(): void {
		add_option( 'wppilot_connected', '0' );
		add_option( 'wppilot_log_level', 'info' );
	}
}