Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/old/vendor/laminas/laminas-feed/src/PubSubHubbub/Model/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

declare(strict_types=1);

namespace Laminas\Feed\PubSubHubbub\Model;

use DateInterval;
use DateTime;
use Laminas\Feed\PubSubHubbub;

use function array_key_exists;
use function count;
use function is_string;

class Subscription extends AbstractModel implements SubscriptionPersistenceInterface
{
    /**
     * Common DateTime object to assist with unit testing
     *
     * @var DateTime
     */
    protected $now;

    /**
     * Save subscription to RDMBS
     *
     * @return bool
     * @throws PubSubHubbub\Exception\InvalidArgumentException
     */
    public function setSubscription(array $data)
    {
        if (! isset($data['id'])) {
            throw new PubSubHubbub\Exception\InvalidArgumentException(
                'ID must be set before attempting a save'
            );
        }
        $result = $this->db->select(['id' => $data['id']]);
        if (0 < count($result)) {
            /** @psalm-suppress UndefinedInterfaceMethod */
            $data['created_time'] = $result->current()->created_time;
            $now                  = $this->getNow();
            if (
                array_key_exists('lease_seconds', $data)
                && $data['lease_seconds']
            ) {
                $data['expiration_time'] = $now->add(new DateInterval('PT' . $data['lease_seconds'] . 'S'))
                    ->format('Y-m-d H:i:s');
            }
            $this->db->update(
                $data,
                ['id' => $data['id']]
            );
            return false;
        }

        $this->db->insert($data);
        return true;
    }

    /**
     * Get subscription by ID/key
     *
     * @param  string $key
     * @return array
     * @throws PubSubHubbub\Exception\InvalidArgumentException
     */
    public function getSubscription($key)
    {
        if (empty($key) || ! is_string($key)) {
            throw new PubSubHubbub\Exception\InvalidArgumentException(
                'Invalid parameter "key" of "' . $key . '" must be a non-empty string'
            );
        }
        $result = $this->db->select(['id' => $key]);
        if (count($result)) {
            /** @psalm-suppress UndefinedInterfaceMethod */
            return $result->current()->getArrayCopy();
        }
        return false;
    }

    /**
     * Determine if a subscription matching the key exists
     *
     * @param  string $key
     * @return bool
     * @throws PubSubHubbub\Exception\InvalidArgumentException
     */
    public function hasSubscription($key)
    {
        if (empty($key) || ! is_string($key)) {
            throw new PubSubHubbub\Exception\InvalidArgumentException(
                'Invalid parameter "key" of "' . $key . '" must be a non-empty string'
            );
        }
        $result = $this->db->select(['id' => $key]);
        if (count($result)) {
            return true;
        }
        return false;
    }

    /**
     * Delete a subscription
     *
     * @param  string $key
     * @return bool
     */
    public function deleteSubscription($key)
    {
        $result = $this->db->select(['id' => $key]);
        if (count($result)) {
            $this->db->delete(
                ['id' => $key]
            );
            return true;
        }
        return false;
    }

    /**
     * Get a new DateTime or the one injected for testing
     *
     * @return DateTime
     */
    public function getNow()
    {
        if (null === $this->now) {
            return new DateTime();
        }
        return $this->now;
    }

    /**
     * Set a DateTime instance for assisting with unit testing
     *
     * @return $this
     */
    public function setNow(DateTime $now)
    {
        $this->now = $now;
        return $this;
    }
}