JAQB\Session

Complexity

Total Complexity

9

Size/Duplication

Total Lines	132
Duplicated Lines	13.64 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	registerHandler()	0	4	1
A	__construct()	0	4	1
A	install()	8	8	1
A	read()	0	8	1
A	write()	0	15	1
A	destroy()	0	7	1
A	gc()	10	10	1
A	open()	0	4	1
A	close()	0	4	1

<?php

/**
 * @author Jared King <j@jaredtking.com>
 *
 * @link http://jaredtking.com
 *
 * @copyright 2015 Jared King
 * @license MIT
 */
namespace JAQB;

use PDOStatement;
use Pimple\Container;
use SessionHandlerInterface;

class Session implements SessionHandlerInterface
{
    const TABLENAME = 'Sessions';

    /**
     * @var \Pimple\Container
     */
    private $app;

    /**
     * Starts the session using this handler.
     *
     * @param Session $handler
     *
     * @return bool
     */
    public static function registerHandler(Session $handler)
    {
        return session_set_save_handler($handler, true);
    }

    /**
     * Creates a new session handler.
     *
     * @param \Pimple\Container $app
     */
    public function __construct(Container $app)
    {
        $this->app = $app;
    }

    /**
     * Installs schema for handling sessions in a database.
     *
     * @return bool success
     */
    public function install()
    {
        $sql = 'CREATE TABLE IF NOT EXISTS `'.self::TABLENAME.'` (`id` varchar(32) NOT NULL, PRIMARY KEY (`id`), `session_data` longtext NULL, `access` int(10) NULL);';

        return $this->app['db']
            ->raw($sql)
            ->execute() instanceof PDOStatement;
    }

    /**
     * Reads a session.
     *
     * @param int $id session ID
     *
     * @return string data
     */
    public function read($id)
    {
        return $this->app['db']
            ->select('session_data')
            ->from(self::TABLENAME)
            ->where('id', $id)
            ->scalar();
    }

    /**
     * Writes a session.
     *
     * @param int    $id   session ID
     * @param string $data session data
     *
     * @return bool success
     */
    public function write($id, $data)
    {
        $this->app['db']
            ->delete(self::TABLENAME)
            ->where('id', $id)
            ->execute();

        return $this->app['db']
            ->insert([
                'id' => $id,
                'access' => time(),
                'session_data' => $data, ])
            ->into(self::TABLENAME)
            ->execute() instanceof PDOStatement;
    }

    /**
     * Destroys a session.
     *
     * @param int $id session ID
     *
     * @return bool success
     */
    public function destroy($id)
    {
        return $this->app['db']
            ->delete(self::TABLENAME)
            ->where('id', $id)
            ->execute() instanceof PDOStatement;
    }

    /**
     * Performs garbage collection on sessions.
     *
     * @param int $max maximum number of seconds a session can live
     *
     * @return bool success
     */
    public function gc($max)
    {
        // delete sessions older than max TTL
        $ttl = time() - $max;

        return $this->app['db']
            ->delete(self::TABLENAME)
            ->where('access', $ttl, '<')
            ->execute() instanceof PDOStatement;
    }

    /**
     * These functions are all noops for various reasons...
     * open() and close() have no practical meaning in terms of database connections.
     */
    public function open($path, $name)
    {
        return true;
    }

    public function close()
    {
        return true;
    }
}