<?php
/**
 * Class: Abstract Active Record
 *
 * Abstract ActiveRecord model is the generic model for any kind
 * of adapter.
 *
 * @package mwp-al-ext
 * @since 1.0.0
 */

namespace WSAL\MainWPExtension\Models;

use \WSAL\MainWPExtension\Helpers\DataHelper as DataHelper;

// Exit if accessed directly.
if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

/**
 * Abstract ActiveRecord model is the generic model for any kind
 * of adapter.
 *
 * @package mwp-al-ext
 */
abstract class ActiveRecord {

	const STATE_UNKNOWN = 'unknown';
	const STATE_CREATED = 'created';
	const STATE_UPDATED = 'updated';
	const STATE_DELETED = 'deleted';
	const STATE_LOADED  = 'loaded';

	/**
	 * Data connector
	 *
	 * @var \WSAL\MainWPExtension\Connector\ConnectorFactory
	 */
	protected $connector;

	/**
	 * Record ID.
	 *
	 * @var boolean
	 */
	protected $id = false;

	/**
	 * Adapter Name.
	 *
	 * @var null
	 */
	protected $adapterName = null;

	/**
	 * Use Default Adapter.
	 *
	 * @var boolean
	 */
	protected $useDefaultAdapter = false;

	/**
	 * Record State.
	 *
	 * @var string
	 */
	protected $_state = self::STATE_UNKNOWN;

	/**
	 * Cache.
	 *
	 * @var array
	 */
	protected static $_cache = array();

	/**
	 * Returns this records' fields.
	 *
	 * @return array
	 */
	public function GetFields() {
		if ( ! isset( $this->_column_cache ) ) {
			$this->_column_cache = array();
			foreach ( array_keys( get_object_vars( $this ) ) as $col ) {
				if ( trim( $col ) && '_' != $col[0] ) {
					$this->_column_cache[] = $col;
				}
			}
		}
		return $this->_column_cache;
	}

	/**
	 * Sets the id.
	 *
	 * @param integer $id - ID.
	 */
	public function setId( $id ) {
		$this->id = $id;
	}

	/**
	 * Gets the id.
	 *
	 * @return integer $id.
	 */
	public function getId() {
		return $this->id;
	}

	/**
	 * Method: Constructor.
	 *
	 * @param array $data - Active data.
	 * @throws Exception - Requires adapterName.
	 */
	public function __construct( $data = null ) {
		if ( ! $this->adapterName ) {
			throw new Exception( 'Class "' . __CLASS__ . '" requires "adapterName" to be set.' );
		}
		if ( ! is_null( $data ) ) {
			$this->LoadData( $data );
			$this->_state = self::STATE_LOADED;
		}
	}

	/**
	 * Gets the connector.
	 *
	 * @return \WSAL\MainWPExtension\Connector\ConnectorInterface
	 */
	protected function getConnector() {
		if ( ! empty( $this->connector ) ) {
			return $this->connector;
		}
		if ( $this->useDefaultAdapter ) {
			$this->connector = \WSAL\MainWPExtension\Connector\ConnectorFactory::GetDefaultConnector();
		} else {
			$this->connector = \WSAL\MainWPExtension\Connector\ConnectorFactory::GetConnector();
		}
		return $this->connector;
	}

	/**
	 * Gets an adapter for the specified model
	 * based on the adapter name.
	 *
	 * @see \WSAL\MainWPExtension\Connector\ConnectorInterface::getAdapter()
	 */
	public function getAdapter() {
		return $this->getConnector()->getAdapter( $this->adapterName );
	}

	/**
	 * Load record from DB.
	 *
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::Load()
	 * @param string $cond (Optional) Load condition.
	 * @param array  $args (Optional) Load condition arguments.
	 */
	public function Load( $cond = '%d', $args = array( 1 ) ) {
		$this->_state = self::STATE_UNKNOWN;

		$data = $this->getAdapter()->Load( $cond, $args );
		if ( ! is_null( $data ) ) {
			$this->LoadData( $data );
			$this->_state = self::STATE_LOADED;
		}
	}

	/**
	 * Load object data from variable.
	 *
	 * @param array|object $data Data array or object.
	 * @throws Exception - Unsupported type.
	 */
	public function LoadData( $data ) {
		$copy = get_class( $this );
		$copy = new $copy();
		foreach ( (array) $data as $key => $val ) {
			if ( isset( $copy->$key ) ) {
				switch ( true ) {
					case $this->is_ip_address( $val ):
						$this->$key = (string) $val;
						break;
					case is_array( $copy->$key ):
					case is_object( $copy->$key ):
						$json_decoded_val = DataHelper::JsonDecode( $val );
						$this->$key       = ( null == $json_decoded_val ) ? $val : $json_decoded_val;
						break;
					case is_int( $copy->$key ):
						$this->$key = (int) $val;
						break;
					case is_float( $copy->$key ):
						$this->$key = (float) $val;
						break;
					case is_bool( $copy->$key ):
						$this->$key = (bool) $val;
						break;
					case is_string( $copy->$key ):
						$this->$key = (string) $val;
						break;
					default:
						throw new Exception( 'Unsupported type "' . gettype( $copy->$key ) . '"' );
				}
			}
		}
		return $this;
	}

	/**
	 * Save this active record
	 *
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::Save()
	 * @return integer|boolean Either the number of modified/inserted rows or false on failure.
	 */
	public function Save() {
		$this->_state = self::STATE_UNKNOWN;

		// Use today's date if not set up.
		if ( is_null( $this->created_on ) ) {
			$this->created_on = $this->GetMicrotime();
		}
		$update_id = $this->getId();
		$result    = $this->getAdapter()->Save( $this );

		if ( false !== $result ) {
			$this->_state = ( ! empty( $update_id ) ) ? self::STATE_UPDATED : self::STATE_CREATED;
		}
		return $result;
	}

	/**
	 * Deletes this active record.
	 *
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::Delete()
	 * @return int|boolean Either the amount of deleted rows or False on error.
	 */
	public function Delete() {
		$this->_state = self::STATE_UNKNOWN;
		$result       = $this->getAdapter()->Delete( $this );
		if ( false !== $result ) {
			$this->_state = self::STATE_DELETED;
		}
		return $result;
	}

	/**
	 * Count records that matching a condition.
	 *
	 * @param string $cond - Condition.
	 * @param array  $args - Arguments.
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::Count()
	 * @return int count
	 */
	public function Count( $cond = '%d', $args = array( 1 ) ) {
		$result = $this->getAdapter()->Count( $cond, $args );
		return $result;
	}

	/**
	 * Check state loaded.
	 *
	 * @return bool
	 */
	public function IsLoaded() {
		return self::STATE_LOADED == $this->_state;
	}

	/**
	 * Check state saved.
	 *
	 * @return bool
	 */
	public function IsSaved() {
		return self::STATE_CREATED == $this->_state
			|| self::STATE_UPDATED == $this->_state;
	}

	/**
	 * Check state created.
	 *
	 * @return bool
	 */
	public function IsCreated() {
		return self::STATE_CREATED == $this->_state;
	}

	/**
	 * Check state updated.
	 *
	 * @return bool
	 */
	public function IsUpdated() {
		return self::STATE_UPDATED == $this->_state;
	}

	/**
	 * Check if the Record structure is created.
	 *
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::IsInstalled()
	 * @return bool
	 */
	public function IsInstalled() {
		return $this->getAdapter()->IsInstalled();
	}

	/**
	 * Install the Record structure.
	 *
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::Install()
	 */
	public function Install() {
		return $this->getAdapter()->Install();
	}

	/**
	 * Check state deleted.
	 *
	 * @return bool
	 */
	public function IsDeleted() {
		return self::STATE_DELETED == $this->_state;
	}

	/**
	 * Load ActiveRecord from DB or cache.
	 *
	 * @param string $target ActiveRecord class name.
	 * @param string $query Load condition.
	 * @param array  $args Arguments used in condition.
	 * @return \WSAL\MainWPExtension\Models\ActiveRecord
	 */
	protected static function CacheLoad( $target, $query, $args ) {
		$index = $target . '::' . vsprintf( $query, $args );
		if ( ! isset( self::$_cache[ $index ] ) ) {
			self::$_cache[ $index ] = new $target();
			self::$_cache[ $index ]->Load( $query, $args );
		}
		return self::$_cache[ $index ];
	}

	/**
	 * Remove ActiveRecord cache.
	 *
	 * @param string $target ActiveRecord class name.
	 * @param string $query Load condition.
	 * @param array  $args Arguments used in condition.
	 */
	protected static function CacheRemove( $target, $query, $args ) {
		$index = $target . '::' . sprintf( $query, $args );
		if ( ! isset( self::$_cache[ $index ] ) ) {
			unset( self::$_cache[ $index ] );
		}
	}

	/**
	 * Clear the cache.
	 */
	protected static function CacheClear() {
		self::$_cache = array();
	}

	/**
	 * Function used in WSAL reporting extension.
	 *
	 * @see \WSAL\MainWPExtension\Adapters\MySQL\ActiveRecord::GetReporting()
	 * @param int       $_site_id - Site ID.
	 * @param int       $_user_id - User ID.
	 * @param string    $_role_name - User role.
	 * @param int       $_alert_code - Alert code.
	 * @param timestamp $_start_timestamp - From created_on.
	 * @param timestamp $_end_timestamp - To created_on.
	 * @return array - Report results.
	 */
	public function GetReporting( $_site_id, $_user_id, $_role_name, $_alert_code, $_start_timestamp, $_end_timestamp ) {
		return $this->getAdapter()->GetReporting( $_site_id, $_user_id, $_role_name, $_alert_code, $_start_timestamp, $_end_timestamp );
	}

	/**
	 * Check if the float is IPv4 instead.
	 *
	 * @see \WSAL\MainWPExtension\Models\ActiveRecord::LoadData()
	 * @param float $ip_address - Number to check.
	 * @return bool result validation
	 */
	private function is_ip_address( $ip_address ) {
		if ( filter_var( $ip_address, FILTER_VALIDATE_IP ) !== false ) {
			return true;
		}
		return false;
	}
}