1 files changed, 125 insertions, 0 deletions
diff --git a/lib/pubsubhubbub/Publisher.php b/lib/pubsubhubbub/Publisher.php
new file mode 100644
index 000000000..df7c1920e
--- /dev/null
+++ b/lib/pubsubhubbub/Publisher.php
@@ -0,0 +1,125 @@
+<?php
+/**
+ * a PHP client library for pubsubhubbub.
+ *
+ * @link    https://github.com/pubsubhubbub/
+ *
+ * @author  Josh Fraser | joshfraser.com | [email protected]
+ * @license Apache License 2.0
+ */
+namespace pubsubhubbub\publisher;
+
+use InvalidArgumentException;
+
+class Publisher
+{
+    /**
+     * @var string
+     */
+    protected $hub_url;
+
+    /**
+     * @var string
+     */
+    protected $last_response;
+
+    /**
+     * Create a new Publisher.
+     *
+     * @param string $hub_url
+     */
+    public function __construct($hub_url)
+    {
+        if (! isset($hub_url)) {
+            throw new InvalidArgumentException('Please specify a hub url');
+        }
+
+        if (! preg_match('|^https?://|i', $hub_url)) {
+            throw new InvalidArgumentException('The specified hub url does not appear to be valid: ' . $hub_url);
+        }
+
+        $this->hub_url = $hub_url;
+    }
+
+    /**
+     * Accepts either a single url or an array of urls.
+     *
+     * @param string|array $topic_urls
+     * @param callable     $http_function
+     *
+     * @return mixed
+     */
+    public function publish_update($topic_urls, $http_function = false)
+    {
+        if (! isset($topic_urls)) {
+            throw new InvalidArgumentException('Please specify a topic url');
+        }
+
+        // check that we're working with an array
+        if (! is_array($topic_urls)) {
+            $topic_urls = [$topic_urls];
+        }
+
+        // set the mode to publish
+        $post_string = 'hub.mode=publish';
+        // loop through each topic url
+        foreach ($topic_urls as $topic_url) {
+
+            // lightweight check that we're actually working w/ a valid url
+            if (! preg_match('|^https?://|i', $topic_url)) {
+                throw new InvalidArgumentException('The specified topic url does not appear to be valid: ' . $topic_url);
+            }
+
+            // append the topic url parameters
+            $post_string .= '&hub.url=' . urlencode($topic_url);
+        }
+
+        // make the http post request and return true/false
+        // easy to over-write to use your own http function
+        if ($http_function) {
+            return $http_function($this->hub_url, $post_string);
+        }
+
+        return $this->http_post($this->hub_url, $post_string);
+    }
+
+    /**
+     * Returns any error message from the latest request.
+     *
+     * @return string
+     */
+    public function last_response()
+    {
+        return $this->last_response;
+    }
+
+    /**
+     * Default http function that uses curl to post to the hub endpoint.
+     *
+     * @param string $url
+     * @param string $post_string
+     *
+     * @return bool
+     */
+    private function http_post($url, $post_string)
+    {
+        // add any additional curl options here
+        $options = [
+            CURLOPT_URL        => $url,
+            CURLOPT_POST       => true,
+            CURLOPT_POSTFIELDS => $post_string,
+            CURLOPT_USERAGENT  => 'PubSubHubbub-Publisher-PHP/1.0',
+        ];
+
+        $ch = curl_init();
+        curl_setopt_array($ch, $options);
+
+        $response = curl_exec($ch);
+        $this->last_response = $response;
+        $info = curl_getinfo($ch);
+
+        curl_close($ch);
+
+        return $info['http_code'] == 204;
+    }
+}