<?php

if ( ! class_exists('MUCD_Duplicate') ) {
	require_once WP_ULTIMO_PLUGIN_DIR . '/inc/duplication/option.php';
	require_once WP_ULTIMO_PLUGIN_DIR . '/inc/duplication/files.php';
	require_once WP_ULTIMO_PLUGIN_DIR . '/inc/duplication/data.php';
	require_once WP_ULTIMO_PLUGIN_DIR . '/inc/duplication/log.php';
	require_once WP_ULTIMO_PLUGIN_DIR . '/inc/duplication/functions.php';

	class MUCD_Duplicate {

		public static $log;

		/**
		 * Init static variables
		 *
		 * @since 0.2.0
		 */
		public static function init() {
			self::$log = false;
		}

		/**
		 * Main function of the plugin : duplicates a site
		 *
		 * @since 0.2.0
		 * @param  array $data parameters from form
		 * @return $form_message result messages of the process
		 */
		public static function duplicate_site($data) {

			global $wpdb;
			$form_message = array();
			$wpdb->hide_errors();

			self::init_log($data);

			$email        = $data['email'];
			$domain       = $data['domain'];
			$newdomain    = $data['newdomain'];
			$path         = $data['path'];
			$title        = $data['title'];
			$from_site_id = $data['from_site_id'];
			$keep_users   = $data['keep_users'];
			$copy_file    = $data['copy_files'];
			$public       = $data['public'];
			$network_id   = $data['network_id'];

			self::write_log('Start site duplication : from site ' . $from_site_id);
			self::write_log('Admin email : ' . $email);
			self::write_log('Domain : ' . $newdomain);
			self::write_log('Path : ' . $path);
			self::write_log('Site title : ' . $title);

			$user_id = isset($data['user_id']) && ! empty($data['user_id']) ? $data['user_id'] : self::create_admin($email, $domain);

			if ( is_wp_error($user_id) ) {
				$form_message['error'] = $user_id->get_error_message();
				return $form_message;
			}

			// Create new site
			switch_to_blog(1);
			$to_site_id = wpmu_create_blog($newdomain, $path, $title, $user_id, array('public' => $public), $network_id);
			$wpdb->show_errors();

			if ( is_wp_error($to_site_id) ) {
				$form_message['error'] = $to_site_id->get_error_message();
				return $form_message;
			}

			// User rights adjustments
			if ( ! is_super_admin($user_id) && ! get_user_option('primary_blog', $user_id) ) {
				update_user_option($user_id, 'primary_blog', $to_site_id, true);
			}

			self::bypass_server_limit();

			// Copy Site - File
			if ($copy_file == 'yes') {
				do_action('mucd_before_copy_files', $from_site_id, $to_site_id);
				$result = MUCD_Files::copy_files($from_site_id, $to_site_id);
				do_action('mucd_after_copy_files', $from_site_id, $to_site_id);
			}

			// Copy Site - Data
			do_action('mucd_before_copy_data', $from_site_id, $to_site_id);
			$result = MUCD_Data::copy_data($from_site_id, $to_site_id);
			do_action('mucd_after_copy_data', $from_site_id, $to_site_id);

			// Copy Site - Users
			if ($keep_users == 'yes') {
				do_action('mucd_before_copy_users', $from_site_id, $to_site_id);
				$result = self::copy_users($from_site_id, $to_site_id);
				do_action('mucd_after_copy_users', $from_site_id, $to_site_id);
			}

			update_blog_option($to_site_id, 'mucd_duplicable', 'no');

			$form_message['msg']     = MUCD_NETWORK_PAGE_DUPLICATE_NOTICE_CREATED;
			$form_message['site_id'] = $to_site_id;

			self::write_log('End site duplication : new site ID = ' . $to_site_id);

			wp_cache_flush();
			return $form_message;
		}

		/**
		 * Creates an admin user if no user exists with this email
		 *
		 * @since 0.2.0
		 * @param  string $email the email
		 * @param  string $domain the domain
		 * @return int id of the user
		 */
		public static function create_admin($email, $domain) {
			// Create New site Admin if not exists
			$password = 'N/A';

			$user_id = email_exists($email);

			if ( ! $user_id ) { // Create a new user with a random password
				$password = wp_generate_password(12, false);
				$user_id  = wpmu_create_user($domain, $password, $email);
				if ( false == $user_id ) {
					return new \WP_Error('file_copy', MUCD_NETWORK_PAGE_DUPLICATE_ADMIN_ERROR_CREATE_USER);
				} else {
					wp_new_user_notification($user_id, $password);
				}
			}

			return $user_id;
		}

		/**
		 * Copy users and roles from one site to another
		 *
		 * @since 0.2.0
		 * @param  int $from_site_id duplicated site id
		 * @param  int $to_site_id   new site id
		 */
		public static function copy_users($from_site_id, $to_site_id) {

			global $wpdb;

			// Bugfix Pierre Dargham : relocating this declaration outside of the loop
			// PHP < 5.3
			function user_array_map($a) {
				return $a[0]; }

			if (is_main_site($from_site_id)) {
				$is_from_main_site = true;
				$args              = array('fields' => 'ids');
				$all_sites_ids     = MUCD_Functions::get_sites($args);
				if ( ! empty($all_sites_ids)) {
					$all_sites_ids = array_map('user_array_map', $all_sites_ids);
				}
			} else {
				$is_from_main_site = false;
			}

			// Source Site information
			$from_site_prefix        = $wpdb->get_blog_prefix($from_site_id);                    // prefix
			$from_site_prefix_length = strlen((string) $from_site_prefix);                           // prefix length

			// Destination Site information
			$to_site_prefix        = $wpdb->get_blog_prefix($to_site_id);                        // prefix
			$to_site_prefix_length = strlen((string) $to_site_prefix);

			$users = get_users('blog_id=' . $from_site_id);

			$admin_email = get_blog_option($to_site_id, 'admin_email', 'false');

			switch_to_blog($to_site_id);

			foreach ($users as $user) {
				if ($user->user_email != $admin_email) {
					add_user_to_blog($to_site_id, $user->ID, 'subscriber');

					$all_meta = array_map('user_array_map', get_user_meta($user->ID));

					foreach ($all_meta as $metakey => $metavalue) {
						$prefix = substr($metakey, 0, $from_site_prefix_length);
						if ($prefix == $from_site_prefix) {
							$raw_meta_name = substr($metakey, $from_site_prefix_length);
							if ($is_from_main_site) {
								$parts = explode('_', $raw_meta_name, 2);
								if (count($parts) > 1 && in_array($parts[0], $all_sites_ids)) {
									continue;
								}
							}
							update_user_meta($user->ID, $to_site_prefix . $raw_meta_name, maybe_unserialize($metavalue));
						}
					}
				}
			}

			restore_current_blog();
		}

		/**
		 * Init log object
		 *
		 * @since 0.2.0
		 * @param  array $data data from FORM
		 */
		public static function init_log($data) {
			// INIT LOG AND SAVE OPTION
			if (isset($data['log']) && $data['log'] == 'yes' ) {
				if (isset($data['log-path']) && ! empty($data['log-path'])) {
					$log_name = @date('Y_m_d_His') . '-' . $data['domain'] . '.log';
					if (substr_compare((string) $data['log-path'], '/', -strlen('/')) !== 0) {
						$data['log-path'] = $data['log-path'] . '/';
					}
					self::$log = new MUCD_Log(true, $data['log-path'], $log_name);
				}
			} else {
				self::$log = new MUCD_Log(false);
			}
		}

		/**
		 * Check if log is active
		 *
		 * @since 0.2.0
		 * @return boolean
		 */
		public static function log() {
			return (self::$log !== false && self::$log->can_write() && self::$log->mod() !== false);
		}

		/**
		 * Check if log has error
		 *
		 * @since 0.2.0
		 * @return boolean
		 */
		public static function log_error() {
			return (self::$log !== false && ! (self::$log->can_write()) && self::$log->mod() !== false);
		}

		/**
		 * Writes a message in log file
		 *
		 * @since 0.2.0
		 * @param  string $msg the message
		 */
		public static function write_log($msg) {
			if (self::log() !== false) {
				self::$log->write_log($msg);
			}
		}

		/**
		 * Close the log file
		 *
		 * @since 0.2.0
		 */
		public static function close_log() {
			if (self::log() !== false) {
				self::$log->close_log();
			}
		}

		/**
		 * Get the url of the created log file
		 *
		 * @since 0.2.0
		 * @return  string the url of false if no log file was created
		 */
		public static function log_url() {
			if (self::log() !== false) {
				return self::$log->file_url();
			}
			return false;
		}

		/**
		 * Get log directory
		 *
		 * @since 0.2.0
		 * @return string the path
		 */
		public static function log_dir() {
			return self::$log->dir_path();
		}

		/**
		 * Bypass limit server if possible
		 *
		 * @since 0.2.0
		 */
		public static function bypass_server_limit() {
			@ini_set('memory_limit', '1024M');
			@ini_set('max_execution_time', '0');
		}
	}

	MUCD_Duplicate::init();
}