Handler::open() - Code Metrics - Inspection of "Updates and fixes" - XOOPS/XoopsCore - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#489)

by Richard

created 2016-05-04 02:46 UTC

Handler::open() A

↳ Parent: Handler

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Metric	Value
dl	0
loc	4
rs	10
ccs	0
cts	2
cp	0
cc	1
eloc	2
nc	1
nop	2
crap	2

<?php
/*
 You may not change or alter any portion of this comment or credits
 of supporting developers from this source code or any supporting source code
 which is considered copyrighted (c) material of the original comment or credit authors.

 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
*/

namespace Xoops\Core\Session;

use Xoops\Core\Database\Connection;

/**
 * Handler for database session storage
 *
 * @category  Xoops\Core\Session
 * @package   Handler
 * @author    Kazumi Ono (AKA onokazu) http://www.myweb.ne.jp/, http://jp.xoops.org/
 * @author    Taiwen Jiang <[email protected]>
 * @author    Richard Griffith <[email protected]>
 * @copyright 2000-2015 XOOPS Project (http://xoops.org)
 * @license   GNU GPL 2 or later (http://www.gnu.org/licenses/gpl-2.0.html)
 * @link      http://xoops.org
 */
class Handler implements \SessionHandlerInterface
{
    /**
     * @var \Xoops\Core\Database\Connection
     */
    private $db;

    /**
     * @var string $sessionTable
     */
    private $sessionTable = 'system_session';

    /**
     * Constructor
     */
    public function __construct()
    {
        $this->db = \Xoops::getInstance()->db();
    }

    /**
     * Open a session
     *
     * @param string $save_path not used
     * @param string $name      not used
     *
     * @return bool
     */
    public function open($save_path, $name)
    {
        return true;
    }

    /**
     * Close a session
     *
     * @return bool
     */
    public function close()
    {
        return true;
    }

    /**
     * Read a session from the database
     *
     * @param string $session_id Id of the session
     *
     * @return string Session data
     */
    public function read($session_id)
    {
        $qb = $this->db->createXoopsQueryBuilder();
        $eb = $qb->expr();
        $qb ->select('s.session_data')
            ->fromPrefix($this->sessionTable, 's')
            ->where($eb->eq('s.session_id', ':sessid'))
            ->andWhere($eb->gt('s.expires_at', ':expires'))
            ->setParameter(':sessid', $session_id, \PDO::PARAM_STR)
            ->setParameter(':expires', time(), \PDO::PARAM_INT);

        $session_data = '';
        if ($result = $qb->execute()) {
            if ($row = $result->fetch(\PDO::FETCH_NUM)) {
                list ($session_data) = $row;
            }
        }

        // if system is not configured for garbage collect, force it anyway
        //if ((ini_get('session.gc_probability') == 0) && (rand(1, 100) <= 5)) {
        //    $this->gc(0);
        //}

        return $session_data;
    }

    /**
     * Write a session to the database
     *
     * @param string $session_id   id of session
     * @param string $session_data data to store
     *
     * @return bool
     **/
    public function write($session_id, $session_data)
// Bad
class Router
{
    public function generate($path)
    {
        return $_SERVER['HOST'].$path;
    }
}

// Better
class Router
{
    private $host;

    public function __construct($host)
    {
        $this->host = $host;
    }

    public function generate($path)
    {
        return $this->host.$path;
    }
}

class Controller
{
    public function myAction(Request $request)
    {
        // Instead of
        $page = isset($_GET['page']) ? intval($_GET['page']) : 1;

        // Better (assuming you use the Symfony2 request)
        $page = $request->query->get('page', 1);
    }
}
    {
        $expires =  (isset($_SESSION['SESSION_MANAGER_EXPIRES']))
            ? (int)($_SESSION['SESSION_MANAGER_EXPIRES'])
            : time() + (session_cache_expire() * 60);
        $oldIsolation = $this->db->getTransactionIsolation();
        $this->db->setTransactionIsolation(Connection::TRANSACTION_REPEATABLE_READ);
        $this->db->beginTransaction();
        $qb = $this->db->createXoopsQueryBuilder();
        $eb = $qb->expr();
        $qb ->updatePrefix($this->sessionTable)
            ->set('expires_at', ':expires')
            ->set('session_data', ':sessdata')
            ->where($eb->eq('session_id', ':sessid'))
            ->setParameter(':sessid', $session_id, \PDO::PARAM_STR)
            ->setParameter(':expires', $expires, \PDO::PARAM_INT)
            ->setParameter(':sessdata', $session_data, \PDO::PARAM_STR);
        $this->db->setForce(true);
        $result = $qb->execute();
        if ($result<=0) {
            $qb = $this->db->createXoopsQueryBuilder();
            $qb ->insertPrefix($this->sessionTable)
                ->values(array(
                    'session_id'   => ':sessid',
                    'expires_at'   => ':expires',
                    'session_data' => ':sessdata',
                    ))
                ->setParameter(':sessid', $session_id, \PDO::PARAM_STR)
                ->setParameter(':expires', $expires, \PDO::PARAM_INT)
                ->setParameter(':sessdata', $session_data, \PDO::PARAM_STR);
            $this->db->setForce(true);
            $result = $qb->execute();
        }
        $this->db->commit();
        $this->db->setTransactionIsolation($oldIsolation);

        return (boolean) ($result>0);
    }

    /**
     * Destroy a session
     *
     * @param string $session_id Id of session
     *
     * @return bool
     */
    public function destroy($session_id)
    {
        $qb = $this->db->createXoopsQueryBuilder();
        $eb = $qb->expr();
        $qb ->deletePrefix($this->sessionTable)
            ->where($eb->eq('session_id', ':sessid'))
            ->setParameter(':sessid', $session_id, \PDO::PARAM_STR);
        $this->db->setForce(true);
        $result = $qb->execute();
        return (boolean) ($result>0);
    }

    /**
     * Garbage Collector
     *
     * @param string $maxlifetime Time in seconds until a session expires
     *
     * @return bool
     */
    public function gc($maxlifetime)
    {
        $mintime = time();
        $qb = $this->db->createXoopsQueryBuilder();
        $eb = $qb->expr();
        $qb ->deletePrefix($this->sessionTable)
            ->where($eb->lt('expires_at', ':expires'))
            ->setParameter(':expires', $mintime, \PDO::PARAM_INT);
        $this->db->setForce(true);
        $result = $qb->execute();
        return (boolean) ($result>0);
    }
}


1		<?php
2		/*
3		You may not change or alter any portion of this comment or credits
4		of supporting developers from this source code or any supporting source code
5		which is considered copyrighted (c) material of the original comment or credit authors.
6
7		This program is distributed in the hope that it will be useful,
8		but WITHOUT ANY WARRANTY; without even the implied warranty of
9		MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
10		*/
11
12		namespace Xoops\Core\Session;
13
14		use Xoops\Core\Database\Connection;
15
16		/**
17		* Handler for database session storage
18		*
19		* @category Xoops\Core\Session
20		* @package Handler
21		* @author Kazumi Ono (AKA onokazu) http://www.myweb.ne.jp/, http://jp.xoops.org/
22		* @author Taiwen Jiang <[email protected]>
23		* @author Richard Griffith <[email protected]>
24		* @copyright 2000-2015 XOOPS Project (http://xoops.org)
25		* @license GNU GPL 2 or later (http://www.gnu.org/licenses/gpl-2.0.html)
26		* @link http://xoops.org
27		*/
28		class Handler implements \SessionHandlerInterface
29		{
30		/**
31		* @var \Xoops\Core\Database\Connection
32		*/
33		private $db;
34
35		/**
36		* @var string $sessionTable
37		*/
38		private $sessionTable = 'system_session';
39
40		/**
41		* Constructor
42		*/
43		public function __construct()
44		{
45		$this->db = \Xoops::getInstance()->db();
46		}
47
48		/**
49		* Open a session
50		*
51		* @param string $save_path not used
52		* @param string $name not used
53		*
54		* @return bool
55		*/
56		public function open($save_path, $name)
57		{
58		return true;
59		}
60
61		/**
62		* Close a session
63		*
64		* @return bool
65		*/
66		public function close()
67		{
68		return true;
69		}
70
71		/**
72		* Read a session from the database
73		*
74		* @param string $session_id Id of the session
75		*
76		* @return string Session data
77		*/
78		public function read($session_id)
79		{
80		$qb = $this->db->createXoopsQueryBuilder();
81		$eb = $qb->expr();
82		$qb ->select('s.session_data')
83		->fromPrefix($this->sessionTable, 's')
84		->where($eb->eq('s.session_id', ':sessid'))
85		->andWhere($eb->gt('s.expires_at', ':expires'))
86		->setParameter(':sessid', $session_id, \PDO::PARAM_STR)
87		->setParameter(':expires', time(), \PDO::PARAM_INT);
88
89		$session_data = '';
90		if ($result = $qb->execute()) {
91		if ($row = $result->fetch(\PDO::FETCH_NUM)) {
92		list ($session_data) = $row;
93		}
94		}
95
96		// if system is not configured for garbage collect, force it anyway
97		//if ((ini_get('session.gc_probability') == 0) && (rand(1, 100) <= 5)) {
98		// $this->gc(0);
99		//}
100
101		return $session_data;
102		}
103
104		/**
105		* Write a session to the database
106		*
107		* @param string $session_id id of session
108		* @param string $session_data data to store
109		*
110		* @return bool
111		**/
112		public function write($session_id, $session_data)
		0 ignored issues – show Coding Style introduced 2015-12-12 03:50 UTC by Report Bug Copy Issue Report `write` uses the super-global variable `$_SESSION` which is generally not recommended. Instead of super-globals, we recommend to explicitly inject the dependencies of your class. This makes your code less dependent on global state and it becomes generally more testable: // Bad class Router { public function generate($path) { return $_SERVER['HOST'].$path; } } // Better class Router { private $host; public function __construct($host) { $this->host = $host; } public function generate($path) { return $this->host.$path; } } class Controller { public function myAction(Request $request) { // Instead of $page = isset($_GET['page']) ? intval($_GET['page']) : 1; // Better (assuming you use the Symfony2 request) $page = $request->query->get('page', 1); } } Loading history...
113		{
114		$expires = (isset($_SESSION['SESSION_MANAGER_EXPIRES']))
115		? (int)($_SESSION['SESSION_MANAGER_EXPIRES'])
116		: time() + (session_cache_expire() * 60);
117		$oldIsolation = $this->db->getTransactionIsolation();
118		$this->db->setTransactionIsolation(Connection::TRANSACTION_REPEATABLE_READ);
119		$this->db->beginTransaction();
120		$qb = $this->db->createXoopsQueryBuilder();
121		$eb = $qb->expr();
122		$qb ->updatePrefix($this->sessionTable)
123		->set('expires_at', ':expires')
124		->set('session_data', ':sessdata')
125		->where($eb->eq('session_id', ':sessid'))
126		->setParameter(':sessid', $session_id, \PDO::PARAM_STR)
127		->setParameter(':expires', $expires, \PDO::PARAM_INT)
128		->setParameter(':sessdata', $session_data, \PDO::PARAM_STR);
129		$this->db->setForce(true);
130		$result = $qb->execute();
131		if ($result<=0) {
132		$qb = $this->db->createXoopsQueryBuilder();
133		$qb ->insertPrefix($this->sessionTable)
134		->values(array(
135		'session_id' => ':sessid',
136		'expires_at' => ':expires',
137		'session_data' => ':sessdata',
138		))
139		->setParameter(':sessid', $session_id, \PDO::PARAM_STR)
140		->setParameter(':expires', $expires, \PDO::PARAM_INT)
141		->setParameter(':sessdata', $session_data, \PDO::PARAM_STR);
142		$this->db->setForce(true);
143		$result = $qb->execute();
144		}
145		$this->db->commit();
146		$this->db->setTransactionIsolation($oldIsolation);
147
148		return (boolean) ($result>0);
149		}
150
151		/**
152		* Destroy a session
153		*
154		* @param string $session_id Id of session
155		*
156		* @return bool
157		*/
158	View Code Duplication	public function destroy($session_id)
159		{
160		$qb = $this->db->createXoopsQueryBuilder();
161		$eb = $qb->expr();
162		$qb ->deletePrefix($this->sessionTable)
163		->where($eb->eq('session_id', ':sessid'))
164		->setParameter(':sessid', $session_id, \PDO::PARAM_STR);
165		$this->db->setForce(true);
166		$result = $qb->execute();
167		return (boolean) ($result>0);
168		}
169
170		/**
171		* Garbage Collector
172		*
173		* @param string $maxlifetime Time in seconds until a session expires
174		*
175		* @return bool
176		*/
177	View Code Duplication	public function gc($maxlifetime)
178		{
179		$mintime = time();
180		$qb = $this->db->createXoopsQueryBuilder();
181		$eb = $qb->expr();
182		$qb ->deletePrefix($this->sessionTable)
183		->where($eb->lt('expires_at', ':expires'))
184		->setParameter(':expires', $mintime, \PDO::PARAM_INT);
185		$this->db->setForce(true);
186		$result = $qb->execute();
187		return (boolean) ($result>0);
188		}
189		}
190

XOOPS / XoopsCore

Pull Request — master (#489)

Handler::open() A

Complexity

Size

Duplication

Code Coverage

Duplication Side-by-Side

Filter issues like