File indexing completed on 2025-01-19 05:21:05

 <?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
  * @copyright  Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com)
  * @license    http://framework.zend.com/license/new-bsd     New BSD License
  * @version    $Id$
  */
 
 /**
  * @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
  * @copyright  Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com)
  * @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.
      *
      * @param array|Zend_Config|null $config Options array or Zend_Config instance
      */
     public function __construct($config = null)
     {
         if ($config !== null) {
             $this->setConfig($config);
         }
     }
 
     /**
      * Process any injected configuration options
      *
      * @param  array|Zend_Config $config Options array or Zend_Config instance
      * @throws Zend_Feed_Pubsubhubbub_Exception
      * @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.
      *
      * @throws Zend_Feed_Pubsubhubbub_Exception
      * @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
      * @throws Zend_Feed_Pubsubhubbub_Exception
      * @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
      * @throws Zend_Feed_Pubsubhubbub_Exception
      * @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
      *
      * @param  string $header
      * @return bool
      */
     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;
     }
 }