<?php

namespace KickAi;

use KickAi\Application\Environment as Environment;
use KickAi\Options                 as Options;
use KickAi\Exception               as KickException;

final class Models
{

    const MODEL_EXTENSION       = '.php';

    /**
     *
     */
    protected static $_instance = null;

    /**
     *
     */
    protected static $_comOptions = null;

    /**
     *
     */
    protected static $_collection = array();

    /**
     *
     * @static
     * @return null
     */
    public static function getInstance() {
        if(is_null(self::$_instance)) self::$_instance = new self();
        return self::$_instance;
    }

    /**
     *
     * @param array $options
     * @return void
     */
    public function setOptions(array $options) { self::$_comOptions = (object)$options; }

    /**
     * Get redis component options
     *
     * @return array|null
     */
    public function getOptions() { return self::$_comOptions; }
   
    /**
     *
     * @throws Exception
     * @return void
     */
    public function initialize() {
        if(isset(self::$_comOptions->start) && self::$_comOptions->start == true) {

            if(!isset(self::$_comOptions->models_paths) || !is_array(self::$_comOptions->models_paths)) {
                throw new KickException(
                    "You need to define paths to models as array in order to start model component!"
                );
            }
           
        }
        else self::$_comOptions->start = false;
    }

    /**
     *
     * @throws Exception
     * @param  $model
     * @param  $args
     * @return
     */
    public function __call($model, $args) {

        if(self::$_comOptions->start == false) {
            throw new KickException(
                "It seems that models are disabled from configuration. Access to model is forbidden! In order to use models
                you need to activate it from application configuration file."
            );
        }

        $model_name = strtolower($model);

        if(!array_key_exists($model_name, self::$_collection)) {

            foreach(self::$_comOptions->models_paths as $namespace => $path) {
                $file_path = $path . DIRECTORY_SEPARATOR . $model_name . self::MODEL_EXTENSION;

                if(file_exists($file_path)) {
                    require_once $file_path;
                    $model = $namespace.ucfirst($model_name);
                    self::$_collection[$model_name] = new $model($args);
                }
            }
        }

        return self::$_collection[$model_name];
    }
}

<?php

/** Define controller namespace! */
namespace System\Models;

/** Extend controller with required namespace classes! */
use KickAi\Application    as Application;

class Geo
{

    /**
     * Application container so that we can use it model wide with one instantiation
     *
     * @return Object|Null
     */
    protected static $_app   = null;

    /**
     * Mongodb database connection end-point
     *
     * @var Object|null
     */
    protected static $_mongo = null;

    /**
     * Redis connection endpoint
     *
     * @var Object|Null
     */
    protected static $_redis = null;

    /**
     * Calculated geo data. Remember that this will be populated only if user did not access
     * site in last one hour. Redis key will contain information otherwise.
     *
     * @var Object|null
     */
    protected static $_geoData = null;

    /**
     * Construct mongo and redis application objects.
     *
     * @return void
     */
    public function __construct() {
        self::$_app   = Application::getInstance();
        self::$_mongo = self::$_app->getComponent('mongodb')->getDb();
        self::$_redis = self::$_app->getComponent('redis')->getRedis();
    }

    /**
     * Generate current geolocation route. Remember that hook after_initialize is calculating
     * and triggering this method. You don't need to trigger it.
     *
     * @return void
     */
    public function generate() {
        $ip_int = $this->_ipToInt();
        if(!self::$_redis->get('tmp_geo_'.$ip_int)) {
            $collection = self::$_mongo->selectCollection('ip_location', self::$_mongo);
            $collection_result = $collection->find(
                array( 'ip_from' => array( '$lte' => "$ip_int" ) )
            )->sort(array('ip_from' => -1))->limit(1);

            foreach($collection_result as $res) self::$_geoData = (object)$res;
            self::$_redis->setex('tmp_geo_'.$ip_int, (3600*1), serialize(self::$_geoData)); // Set expiration to one hour!
        }
    }

    /**
     * Get all geo information.
     *
     * #return Object|Null
     */
    public function getGeo() {
        $ip_int = $this->_ipToInt();
        $data   = self::$_redis->get('tmp_geo_'.$ip_int);
        return !is_null($data) ? unserialize($data) : null;
    }

    /**
     *
     * @return string|null
     */
    public function getMongoId() {
        $data = $this->getGeo();
        if(isset($data->_id)) $tmp = (array)$data->_id;
        return isset($tmp) ? $tmp['$id'] : null;
    }

    /**
     *
     * @return null|string
     */
    public function getCountryCode() {
        $data = $this->getGeo();
        return isset($data->ip_country_code) ? ucfirst($data->ip_country_code) : null;
    }

    /**
     *
     * @return null|string
     */
    public function getCountryName() {
        $data = $this->getGeo();
        return isset($data->ip_country_name) ? ucfirst($data->ip_country_name) : null;
    }

    /**
     *
     * @return null|string
     */
    public function getState() {
        $data = $this->getGeo();
        return isset($data->ip_state) ? ucfirst($data->ip_state) : null;
    }

    /**
     *
     * @return null|string
     */
    public function getCity() {
        $data = $this->getGeo();
        return isset($data->ip_city) ? ucfirst($data->ip_city) : null;
    }

    /**
     *
     * @return null
     */
    public function getLatitude() {
        $data = $this->getGeo();
        return isset($data->ip_latitude) ? $data->ip_latitude : null;
    }

    /**
     *
     * @return null
     */
    public function getLongitude() {
        $data = $this->getGeo();
        return isset($data->ip_longitude) ? $data->ip_longitude : null;
    }

    /**
     *
     * @return null
     */
    public function getZip() {
        $data = $this->getGeo();
        return (isset($data->ip_zip) && $data->ip_zip != '-') ? $data->ip_zip : null;
    }

    /**
     *
     * @return null
     */
    public function getTimezone() {
        $data = $this->getGeo();
        return (isset($data->ip_timezone) && $data->ip_timezone != '-') ? $data->ip_timezone : null;
    }

    /**
     *
     * @return
     */
    protected function _ipToInt() {
        $ip = ($_SERVER['REMOTE_ADDR'] == '127.0.0.1') ? '78.2.65.182' : $_SERVER['REMOTE_ADDR'];
        $ip_segments = explode('.', $ip);
        return (($ip_segments[0]*256+$ip_segments[1])*256+$ip_segments[2])*256 + $ip_segments[3];
    }
}