SessionToken.php

Go to the documentation of this file.

<?php

namespace Combu;

class SessionToken extends DataClass {

    const TABLE_NAME = "SessionToken";

    public $Token = "";
    public $IdApp = 0;
    public $IPAddress = "";
    public $Created = "";
    public $RSA_PrivateKey = "";
    public $RSA_PublicKey = "";
    public $AES_Key = "";
    public $AES_IV = "";
    public $IdAccount = 0;
    public $ClientVersion = "";
    public $Updated = "";

    public function __construct($src = null, $stripSlashes = false) {
        global $Database;
        if (!$src) {
            return;
        }
        if (is_array($src)) {
            // Load by array
            $this->_loadByRow($src, $stripSlashes);
        } else {
            // Load by Id
            $this->_loadFilter(self::GetTableName(__CLASS__), sprintf("Token = '%s'", $Database->Escape($src)));
        }
    }

    public static function Load ($idAccount = 0, $fromDate = NULL, $toDate = NULL, $idApp = 0, $ipAddress = NULL, $limit = NULL, $offset = NULL, &$count = NULL) {
        global $Database;
        $where = "";
        if ($idAccount > 0) {
            $where .= ($where ? " AND " : "") . sprintf("(IdAccount = %d)", $idAccount);
        }
        if ($fromDate) {
            $where .= ($where ? " AND " : "") . sprintf("(Created >= %s)", $Database->EscapeDate($fromDate));
        }
        if ($toDate) {
            $where .= ($where ? " AND " : "") . sprintf("(Created <= %s)", $Database->EscapeDate($toDate));
        }
        if ($idApp > 0) {
            $where .= ($where ? " AND " : "") . sprintf("(IdApp = %d)", $idApp);
        }
        if (!empty($ipAddress)) {
            $where .= ($where ? " AND " : "") . sprintf("(IPAddress = '%s')", $Database->Escape($ipAddress));
        }
        return self::_load(self::GetTableName(__CLASS__), __CLASS__, $where, "Created DESC", $limit, $offset, $count);
    }

    public function Save() {
        global $Database;
        $now = Utils::GetCurrentDateTimeFormat();
        if (!$this->Created) {
            $this->Created = $now;
        }
        $this->Updated = $now;
        $query = sprintf("REPLACE INTO %s (Token, IdApp, IPAddress, Created, RSA_PrivateKey, RSA_PublicKey, AES_Key, AES_IV, IdAccount, ClientVersion, Updated) VALUES ('%s', %d, '%s', '%s', '%s', '%s', '%s', '%s', %d, '%s', '%s')",
                self::GetTableName(__CLASS__),
                $Database->Escape($this->Token),
                $this->IdApp,
                $Database->Escape($this->IPAddress),
                $this->Created,
                $Database->Escape($this->RSA_PrivateKey),
                $Database->Escape($this->RSA_PublicKey),
                $Database->Escape($this->AES_Key),
                $Database->Escape($this->AES_IV),
                $this->IdAccount,
                $Database->Escape($this->ClientVersion),
                $this->Updated);
        if ($Database->Query($query)) {
            return TRUE;
        }
        return FALSE;
    }
    
    function UpdateLastAction () {
        global $Database;
        $this->Updated = Utils::GetCurrentDateTimeFormat();
        $query = sprintf("UPDATE %s SET Updated = '%s' WHERE Token = '%s'",
                self::GetTableName(__CLASS__),
                $this->Updated,
                $Database->Escape($this->Token));
        if ($Database->Query($query)) {
            return TRUE;
        }
        return FALSE;
    }
    
    public static function ClearSessions($idAccount, $deleteAll = FALSE) {
        global $Database, $WS_TOKEN;
        $where = sprintf("IdAccount = %d", $idAccount);
        if ($WS_TOKEN) {
            $where .= sprintf(" AND Token <> '%s'", $Database->Escape($WS_TOKEN));
        }
        if (!$deleteAll) {
            // Get all sessions from 24 hours ago and earlier
            $date = Utils::GetCurrentDateTime();
            $date = $date->sub(new \DateInterval("P1D"));
            $where .= sprintf(" AND LastActionDate <= '%s'", $date->format("Y-m-d H:i:s"));
        }
        $recs = self::_load(self::GetTableName(__CLASS__), __CLASS__, $where);
        foreach ($recs as $rec) {
            $rec->Delete();
        }
    }
    
    public static function GetLastSession($idAccount) {
        global $AppId;
        $where = sprintf("(IdAccount = %d)", $idAccount);
        if ($AppId->IsValid()) {
            $where .= sprintf(" AND (IdApp = %d)", $AppId->Id);
        }
        $records = self::_load(self::GetTableName(__CLASS__), __CLASS__, $where, "Updated DESC", 1);
        if (count($records) > 0) {
            return $records[0];
        }
        return NULL;
    }
    
    public static function SetSession($idAccount, $token) {
        global $Database;
        $query = sprintf("UPDATE %s SET IdAccount = %d, Updated = '%s' WHERE Token = '%s'",
                self::GetTableName(__CLASS__),
                $idAccount,
                Utils::GetCurrentDateTimeFormat(),
                $Database->Escape($token));
        if ($Database->Query($query)) {
            return TRUE;
        }
        return FALSE;
    }
    
    public static function UnsetSession($idAccount, $token) {
        global $Database;
        $query = sprintf("UPDATE %s SET IdAccount = 0, Updated = '%s' WHERE IdAccount = %d AND Token = '%s'",
                self::GetTableName(__CLASS__),
                Utils::GetCurrentDateTimeFormat(),
                $idAccount,
                $Database->Escape($token));
        if ($Database->Query($query)) {
            return TRUE;
        }
        return FALSE;
    }

    public function Delete() {
        global $Database;
        if (!empty($this->Token)) {
            return $this->_Delete(self::GetTableName(__CLASS__), sprintf("Token = '%s'", $Database->Escape($this->Token)));
        }
        return FALSE;
    }
    
    public static function Prune() {
        self::TruncateClass(__CLASS__);
    }
}