<?php

/**

 * Zend Framework

 *

 * LICENSE

 *

 * This source file is subject to the new BSD license that is bundled

 * with this package in the file LICENSE.txt.

 * It is also available through the world-wide-web at this URL:

 * http://framework.zend.com/license/new-bsd

 * If you did not receive a copy of the license and are unable to

 * obtain it through the world-wide-web, please send an email

 * to license@zend.com so we can send you a copy immediately.

 *

 * @category   Zend

 * @package    Zend_Feed_Pubsubhubbub

 * @subpackage Callback

 * @license    http://framework.zend.com/license/new-bsd     New BSD License

 */

/**

 * @see Zend_Feed_Pubsubhubbub_CallbackInterface

 */

require_once 'Zend/Feed/Pubsubhubbub/CallbackInterface.php';

/**

 * @see Zend_Feed_Pubsubhubbub_HttpResponse

 */

require_once 'Zend/Feed/Pubsubhubbub/HttpResponse.php';

/**

 * @category   Zend

 * @package    Zend_Feed_Pubsubhubbub

 * @subpackage Callback

 * @license    http://framework.zend.com/license/new-bsd     New BSD License

 */

abstract class Zend_Feed_Pubsubhubbub_CallbackAbstract

    implements Zend_Feed_Pubsubhubbub_CallbackInterface

{

    /**

     * An instance of Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface used

     * to background save any verification tokens associated with a subscription

     * or other.

     *

     * @var Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface

     */

    protected $_storage = null;

    /**

     * An instance of a class handling Http Responses. This is implemented in

     * Zend_Feed_Pubsubhubbub_HttpResponse which shares an unenforced interface with

     * (i.e. not inherited from) Zend_Controller_Response_Http.

     *

     * @var Zend_Feed_Pubsubhubbub_HttpResponse|Zend_Controller_Response_Http

     */

    protected $_httpResponse = null;

    /**

     * The number of Subscribers for which any updates are on behalf of.

     *

     * @var int

     */

    protected $_subscriberCount = 1;

    /**

     * Constructor; accepts an array or Zend_Config instance to preset

     * options for the Subscriber without calling all supported setter

     * methods in turn.

     *

     */

    public function __construct($config = null)

    {

        if ($config !== null) {

            $this->setConfig($config);

        }

    }

    /**

     * Process any injected configuration options

     *

     * @return Zend_Feed_Pubsubhubbub_CallbackAbstract

     */

    public function setConfig($config)

    {

        if ($config instanceof Zend_Config) {

            $config = $config->toArray();

        } elseif (!is_array($config)) {

            require_once 'Zend/Feed/Pubsubhubbub/Exception.php';

            throw new Zend_Feed_Pubsubhubbub_Exception('Array or Zend_Config object'

            . 'expected, got ' . gettype($config));

        }

        if (array_key_exists('storage', $config)) {

            $this->setStorage($config['storage']);

        }

        return $this;

    }

    /**

     * Send the response, including all headers.

     * If you wish to handle this via Zend_Controller, use the getter methods

     * to retrieve any data needed to be set on your HTTP Response object, or

     * simply give this object the HTTP Response instance to work with for you!

     *

     * @return void

     */

    public function sendResponse()

    {

        $this->getHttpResponse()->sendResponse();

    }

    /**

     * Sets an instance of Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface used

     * to background save any verification tokens associated with a subscription

     * or other.

     *

     * @param  Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface $storage

     * @return Zend_Feed_Pubsubhubbub_CallbackAbstract

     */

    public function setStorage(Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface $storage)

    {

        $this->_storage = $storage;

        return $this;

    }

    /**

     * Gets an instance of Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface used

     * to background save any verification tokens associated with a subscription

     * or other.

     *

     * @return Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface

     */

    public function getStorage()

    {

        if ($this->_storage === null) {

            require_once 'Zend/Feed/Pubsubhubbub/Exception.php';

            throw new Zend_Feed_Pubsubhubbub_Exception('No storage object has been'

                . ' set that subclasses Zend_Feed_Pubsubhubbub_Model_SubscriptionInterface');

        }

        return $this->_storage;

    }

    /**

     * An instance of a class handling Http Responses. This is implemented in

     * Zend_Feed_Pubsubhubbub_HttpResponse which shares an unenforced interface with

     * (i.e. not inherited from) Zend_Controller_Response_Http.

     *

     * @param  Zend_Feed_Pubsubhubbub_HttpResponse|Zend_Controller_Response_Http $httpResponse

     * @return Zend_Feed_Pubsubhubbub_CallbackAbstract

     */

    public function setHttpResponse($httpResponse)

    {

        if (!is_object($httpResponse)

            || (!$httpResponse instanceof Zend_Feed_Pubsubhubbub_HttpResponse

                && !$httpResponse instanceof Zend_Controller_Response_Http)

        ) {

            require_once 'Zend/Feed/Pubsubhubbub/Exception.php';

            throw new Zend_Feed_Pubsubhubbub_Exception('HTTP Response object must'

                . ' implement one of Zend_Feed_Pubsubhubbub_HttpResponse or'

                . ' Zend_Controller_Response_Http');

        }

        $this->_httpResponse = $httpResponse;

        return $this;

    }

    /**

     * An instance of a class handling Http Responses. This is implemented in

     * Zend_Feed_Pubsubhubbub_HttpResponse which shares an unenforced interface with

     * (i.e. not inherited from) Zend_Controller_Response_Http.

     *

     * @return Zend_Feed_Pubsubhubbub_HttpResponse|Zend_Controller_Response_Http

     */

    public function getHttpResponse()

    {

        if ($this->_httpResponse === null) {

            $this->_httpResponse = new Zend_Feed_Pubsubhubbub_HttpResponse;

        }

        return $this->_httpResponse;

    }

    /**

     * Sets the number of Subscribers for which any updates are on behalf of.

     * In other words, is this class serving one or more subscribers? How many?

     * Defaults to 1 if left unchanged.

     *

     * @param  string|int $count

     * @return Zend_Feed_Pubsubhubbub_CallbackAbstract

     */

    public function setSubscriberCount($count)

    {

        $count = intval($count);

        if ($count <= 0) {

            require_once 'Zend/Feed/Pubsubhubbub/Exception.php';

            throw new Zend_Feed_Pubsubhubbub_Exception('Subscriber count must be'

                . ' greater than zero');

        }

        $this->_subscriberCount = $count;

        return $this;

    }

    /**

     * Gets the number of Subscribers for which any updates are on behalf of.

     * In other words, is this class serving one or more subscribers? How many?

     *

     * @return int

     */

    public function getSubscriberCount()

    {

        return $this->_subscriberCount;

    }

    /**

     * Attempt to detect the callback URL (specifically the path forward)

     */

    protected function _detectCallbackUrl()

    {

        $callbackUrl = '';

        if (isset($_SERVER['HTTP_X_ORIGINAL_URL'])) {

            $callbackUrl = $_SERVER['HTTP_X_ORIGINAL_URL'];

        } elseif (isset($_SERVER['HTTP_X_REWRITE_URL'])) {

            $callbackUrl = $_SERVER['HTTP_X_REWRITE_URL'];

        } elseif (isset($_SERVER['REQUEST_URI'])) {

            $callbackUrl = $_SERVER['REQUEST_URI'];

            $scheme = 'http';

            if ($_SERVER['HTTPS'] == 'on') {

                $scheme = 'https';

            }

            $schemeAndHttpHost = $scheme . '://' . $this->_getHttpHost();

            if (strpos($callbackUrl, $schemeAndHttpHost) === 0) {

                $callbackUrl = substr($callbackUrl, strlen($schemeAndHttpHost));

            }

        } elseif (isset($_SERVER['ORIG_PATH_INFO'])) {

            $callbackUrl= $_SERVER['ORIG_PATH_INFO'];

            if (!empty($_SERVER['QUERY_STRING'])) {

                $callbackUrl .= '?' . $_SERVER['QUERY_STRING'];

            }

        }

        return $callbackUrl;

    }

    /**

     * Get the HTTP host

     *

     * @return string

     */

    protected function _getHttpHost()

    {

        if (!empty($_SERVER['HTTP_HOST'])) {

            return $_SERVER['HTTP_HOST'];

        }

        $scheme = 'http';

        if ($_SERVER['HTTPS'] == 'on') {

            $scheme = 'https';

        }

        $name = $_SERVER['SERVER_NAME'];

        $port = $_SERVER['SERVER_PORT'];

        if (($scheme == 'http' && $port == 80)

            || ($scheme == 'https' && $port == 443)

        ) {

            return $name;

        } else {

            return $name . ':' . $port;

        }

    }

    /**

     * Retrieve a Header value from either $_SERVER or Apache

     *

     */

    protected function _getHeader($header)

    {

        $temp = strtoupper(str_replace('-', '_', $header));

        if (!empty($_SERVER[$temp])) {

            return $_SERVER[$temp];

        }

        $temp = 'HTTP_' . strtoupper(str_replace('-', '_', $header));

        if (!empty($_SERVER[$temp])) {

            return $_SERVER[$temp];

        }

        if (function_exists('apache_request_headers')) {

            $headers = apache_request_headers();

            if (!empty($headers[$header])) {

                return $headers[$header];

            }

        }

        return false;

    }

    /**

     * Return the raw body of the request

     *

     * @return string|false Raw body, or false if not present

     */

    protected function _getRawBody()

    {

        $body = file_get_contents('php://input');

        if (strlen(trim($body)) == 0 && isset($GLOBALS['HTTP_RAW_POST_DATA'])) {

            $body = $GLOBALS['HTTP_RAW_POST_DATA'];

        }

        if (strlen(trim($body)) > 0) {

            return $body;

        }

        return false;

    }

}