enwikipedia-acc / waca

includes/DataObjects/AntiSpoofCache.php

<?php
/******************************************************************************
 * Wikipedia Account Creation Assistance tool                                 *
 *                                                                            *
 * All code in this file is released into the public domain by the ACC        *
 * Development Team. Please see team.json for a list of contributors.         *
 ******************************************************************************/

namespace Waca\DataObjects;

use DateTimeImmutable;
use Exception;
use Waca\DataObject;
use Waca\PdoDatabase;

/**
 * AntiSpoofCache data object
 */
class AntiSpoofCache extends DataObject
{
    /** @var string */
    protected $username;
    /** @var string */
    protected $data;
    /** @var string */
    protected $timestamp;

    /**
     * @param   string    $username
     * @param PdoDatabase $database
     *
     * @return AntiSpoofCache|false
     */
    public static function getByUsername($username, PdoDatabase $database)

This method seems to be duplicated in your project.

    {
        $statement = $database->prepare(<<<SQL
SELECT *
FROM antispoofcache
WHERE username = :id AND timestamp > date_sub(now(), INTERVAL 3 HOUR)
LIMIT 1
SQL
        );
        $statement->bindValue(":id", $username);

        $statement->execute();

        $resultObject = $statement->fetchObject(get_called_class());

        if ($resultObject != false) {
            $resultObject->setDatabase($database);
        }

        return $resultObject;
    }

    /**
     * @return string
     */
    public function getUsername()
    {
        return $this->username;
    }

    /**
     * @param string $username
     */
    public function setUsername($username)
    {
        $this->username = $username;
    }

    /**
     * @return string
     */
    public function getData()
    {
        return $this->data;
    }

    /**
     * @param string $data
     */
    public function setData($data)
    {
        $this->data = $data;
    }

    /**
     * @return DateTimeImmutable
     */
    public function getTimestamp()
    {
        return new DateTimeImmutable($this->timestamp);
    }

    /**
     * @throws Exception
     */
    public function save()
    {
        if ($this->isNew()) {
            // insert
            // clear old data first
            $this->dbObject->exec("DELETE FROM antispoofcache WHERE timestamp < date_sub(now(), INTERVAL 3 HOUR);");

            $statement = $this->dbObject->prepare("INSERT INTO antispoofcache (username, data) VALUES (:username, :data);");
            $statement->bindValue(":username", $this->username);
            $statement->bindValue(":data", $this->data);

            if ($statement->execute()) {
                $this->id = (int)$this->dbObject->lastInsertId();
            }
            else {
                throw new Exception($statement->errorInfo());
            }
        }
    }
}