<?php

/*

//https://github.com/KiboOst/php-LinkyAPI

*/

class Linky{

    public $_version = '0.12';

    public function getData_perhour($date)
    {
        //start from date - 2days to date + 1 day...
        $endDate = DateTime::createFromFormat('d/m/Y', $date)->add(new DateInterval('P1D'));
        $endDate = $endDate->format('d/m/Y');
        $startDate = DateTime::createFromFormat('d/m/Y', $date);
        $startDate->sub(new DateInterval('P2D'));
        $startDate = $startDate->format('d/m/Y');

        $resource_id = 'urlCdcHeure';
        $result = $this->getData($resource_id, $startDate, $endDate);

        if (!isset($result['graphe']['data'])) {
            $this->_data['hours'][$date] = null;
            return false;
        }

        //format this correctly:
        $returnData = array();
        $startHour = new DateTime('23:30');

        $data = $result['graphe']['data'];
        $end = count($data);
        for($i=$end-1; $i>=$end-48; $i--)
        {
            $valeur = $data[$i]['valeur'].'kW';

            $thisHour = clone $startHour;
            $thisHour = $thisHour->format('H:i');

            $returnData[$thisHour] = $valeur;
            $startHour->modify('-30 min');
        }

        $returnData = array_reverse($returnData);
        $this->_data['hours'][$date] = $returnData;
        return array($date=>$returnData);
    }

    public function getData_perday($startDate, $endDate)
    {
        //max 31days:
        $date1 = DateTime::createFromFormat('d/m/Y', $startDate);
        $date2 = DateTime::createFromFormat('d/m/Y', $endDate);
        $nbr_ts = $date2->getTimestamp() - $date1->getTimestamp();
        $nbr_days = $nbr_ts/86400;
        if ($nbr_days > 31) return array('etat'=>null, 'error' => 'Max number of days can not exceed 31 days');

        $resource_id = 'urlCdcJour';
        $result = $this->getData($resource_id, $startDate, $endDate);

        if (!isset($result['graphe']['data'])) {
            $this->_data['days'] = null;
            return false;
        }

        //format this correctly:
        $returnData = array();

        $data = $result['graphe']['data'];
        foreach ($data as $day)
        {
            $valeur = $day['valeur'];
            if ($valeur == -2) $valeur = null;
            else $valeur .= 'kWh';

            $date = $date1;
            $date = $date1->format("d/m/Y");
            $returnData[$date] = $valeur;
            $date1->modify('+1 day');
        }

        $this->_data['days'] = $returnData;
        return $returnData;
    }

    public function getData_permonth($startDate, $endDate)
    {
        $resource_id = 'urlCdcMois';
        $result = $this->getData($resource_id, $startDate, $endDate);

        if (!isset($result['graphe']['data'])) {
            $this->_data['months'] = null;
            return false;
        }

        //format this correctly:
        $fromMonth = DateTime::createFromFormat('d/m/Y', $startDate);
        $returnData = array();

        $data = $result['graphe']['data'];
        foreach ($data as $month)
        {
            $valeur = $month['valeur'];
            if ($valeur == -2) $valeur = null;
            else $valeur .= 'kW';

            $thisMonth = $fromMonth;
            $thisMonth = $thisMonth->format('M Y');

            $returnData[$thisMonth] = $valeur;
            $fromMonth->modify('+1 month');
        }

        $this->_data['months'] = $returnData;
        return $returnData;
    }

    public function getData_peryear()
    {
        $resource_id = 'urlCdcAn';
        $result = $this->getData($resource_id, null, null);

        if (!isset($result['graphe']['data'])) {
            $this->_data['years'] = null;
            return false;
        }

        //format this correctly:
        $fromYear = new DateTime();
        $returnData = array();

        $data = $result['graphe']['data'];
        $c = count($data)-1;
        $fromYear->modify('- '.$c.' year');
        foreach ($data as $year)
        {
            $valeur = $year['valeur'];
            if ($valeur == -2) $valeur = null;
            else $valeur .= 'kW';

            $thisYear = $fromYear;
            $thisYear = $thisYear->format('Y');

            $returnData[$thisYear] = $valeur;
            $fromYear->modify('+1 year');
        }

        $this->_data['years'] = $returnData;
        return $returnData;
    }


    //INTERNAL FUNCTIONS==================================================
    public function getAll()
    {
        //____Initialize datas:
        $timezone = 'Europe/Paris';
        $today = new DateTime('NOW', new DateTimeZone($timezone));
        $today->sub(new DateInterval('P1D')); //Enedis last data are yesterday

        //____Get per hour for yesterday:
        $yesterday = $today->format('d/m/Y');
        $this->getData_perhour($yesterday);

        //____Get per day
        $var = clone $today;
        $fromMonth = $var->sub(new DateInterval('P30D'));
        $fromMonth = $fromMonth->format('d/m/Y');
        $this->getData_perday($fromMonth, $yesterday);

        //____Get per month
        $var = clone $today;
        $fromYear = $var->sub(new DateInterval('P1Y'));
        $fromYear = $fromYear->format('01/'.'m/Y');
        $this->getData_permonth($fromYear, $yesterday);

        //____Get per year
        $this->getData_peryear();
    }



    //______________________calling functions
    protected function _request($method, $url, $postdata=null) //standard function handling all get/post request with curl | return string
    {
        if (!isset($this->_curlHdl))
        {
            $this->_curlHdl = curl_init();
            curl_setopt($this->_curlHdl, CURLOPT_COOKIEJAR, $this->_cookFile);
            curl_setopt($this->_curlHdl, CURLOPT_COOKIEFILE, $this->_cookFile);

            curl_setopt($this->_curlHdl, CURLOPT_SSL_VERIFYHOST, false);
            curl_setopt($this->_curlHdl, CURLOPT_SSL_VERIFYPEER, false);

            curl_setopt($this->_curlHdl, CURLOPT_HEADER, true);
            curl_setopt($this->_curlHdl, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($this->_curlHdl, CURLOPT_FOLLOWLOCATION, true);

            curl_setopt($this->_curlHdl, CURLOPT_USERAGENT, 'User-Agent: Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:57.0) Gecko/20100101 Firefox/57.0');
        }

        $url = filter_var($url, FILTER_SANITIZE_URL);
        //echo 'url: ', $url, "<br>";
        curl_setopt($this->_curlHdl, CURLOPT_URL, $url);

        if ($method == 'POST')
        {
            curl_setopt($this->_curlHdl, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($this->_curlHdl, CURLOPT_POST, true);
        }
        else
        {
            curl_setopt($this->_curlHdl, CURLOPT_POST, false);
        }

        if ( isset($postdata) )
        {
            curl_setopt($this->_curlHdl, CURLOPT_CUSTOMREQUEST, 'POST');
            curl_setopt($this->_curlHdl, CURLOPT_POSTFIELDS, $postdata);
        }

        $response = curl_exec($this->_curlHdl);

        //$info   = curl_getinfo($this->_curlHdl);
        //echo "<pre>cURL info".json_encode($info, JSON_PRETTY_PRINT)."</pre><br>";

        $this->error = null;
        if ($response === false) $this->error = curl_error($this->_curlHdl);

        if ($this->_isAuth == true)
        {
            $header_size = curl_getinfo($this->_curlHdl, CURLINFO_HEADER_SIZE);
            $header = substr($response, 0, $header_size);
            $response = substr($response, $header_size);
        }
        return $response;
    }


    //______________________Internal cooking
    protected function getData($resource_id, $startDate, $endDate)
    {
        $p_p_id = 'lincspartdisplaycdc_WAR_lincspartcdcportlet';

        $url = $this->_APIBaseUrl.$this->_APIDataUrl;
        $url .= '?p_p_id='.$p_p_id;
        $url .= '&p_p_lifecycle=2';
        $url .= '&p_p_mode=view';
        $url .= '&p_p_resource_id='.$resource_id;
        $url .= '&p_p_cacheability=cacheLevelPage';
        $url .= '&p_p_col_id=column-1';
        $url .= '&p_p_col_count=2';

        $postdata = null;
        if ($startDate)
        {
            $postdata = http_build_query(
                                        array(
                                            '_'.$p_p_id.'_dateDebut' => $startDate,
                                            '_'.$p_p_id.'_dateFin' => $endDate
                                            )
                                        );
        }

        $response = $this->_request('GET', $url, $postdata);
        $jsonArray = json_decode($response, true);
        return $jsonArray;
    }

    public $error = null;
    public $_isAuth = false;

    public $_data = array();

    //authentication:
    protected $_login;
    protected $_password;

    protected $_cookFile = '';

    protected $_loginBaseUrl = 'https://espace-client-connexion.enedis.fr';
    protected $_APIBaseUrl = 'https://espace-client-particuliers.enedis.fr/group/espace-particuliers';
    protected $_APILoginUrl = '/auth/UI/Login';
    protected $_APIHomeUrl = '/home';
    protected $_APIDataUrl = '/suivi-de-consommation';

    protected $_curlHdl = null;

    protected function auth()
    {
        $postdata = http_build_query(
                                    array(
                                        'IDToken1' => $this->_login,
                                        'IDToken2' => $this->_password,
                                        'SunQueryParamsString' => base64_encode('realm=particuliers'),
                                        'encoded' => 'true',
                                        'gx_charset' => 'UTF-8'
                                        )
                                    );

        $url = $this->_loginBaseUrl.$this->_APILoginUrl;
        $response = $this->_request('POST', $url, $postdata);

        //connected ?
        preg_match_all('/^Set-Cookie:\s*([^;]*)/mi', $response, $matches);
        $cookies = array();
        foreach($matches[1] as $item)
        {
            parse_str($item, $cookie);
            $cookies = array_merge($cookies, $cookie);
        }
        if (!array_key_exists('iPlanetDirectoryPro', $cookies))
        {
            $this->error = 'Sorry, could not connect. Check your credentials.';
            return false;
        }

        $this->_isAuth = true;

        $url = 'https://espace-client-particuliers.enedis.fr/group/espace-particuliers/accueil';
        $response = $this->_request('GET', $url);

        return true;
    }

    function __construct($login, $password, $getAll=false)
    {
        $this->_login = $login;
        $this->_password = $password;

        if ($this->auth() == false)
        {
            return $this->error;
        }

        if ($getAll)
        {
            $this->getAll();
        }
    }

//Linky end
}

?>