initial commit

matthewgoslett · matthewgoslett · commit a7c47a0f9be7 · 2016-09-04T10:37:05.000+02:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,7 @@
+.idea
+composer.lock
+vendor
+bin
+coverage
+coverage.xml
+gcloud-test-key.json
diff --git a/.travis.yml b/.travis.yml
@@ -0,0 +1,11 @@
+language: php
+
+php:
+  - 5.6
+  - 7.0
+  - 7.1
+  - hhvm
+  - nightly
+
+before_script:
+  - composer install
diff --git a/Dockerfile b/Dockerfile
@@ -0,0 +1,36 @@
+FROM php:7.0-fpm
+MAINTAINER Superbalist <tech+docker@superbalist.com>
+
+RUN mkdir /opt/php-pubsub
+WORKDIR /opt/php-pubsub
+
+# Packages
+RUN apt-get update \
+    && DEBIAN_FRONTEND=noninteractive apt-get install -y \
+        git \
+        zlib1g-dev \
+        unzip \
+    && rm -r /var/lib/apt/lists/*
+
+# PHP Extensions
+RUN docker-php-ext-install -j$(nproc) zip
+
+# Composer
+ENV COMPOSER_HOME /composer
+ENV PATH /composer/vendor/bin:$PATH
+ENV COMPOSER_ALLOW_SUPERUSER 1
+RUN curl -o /tmp/composer-setup.php https://getcomposer.org/installer \
+    && curl -o /tmp/composer-setup.sig https://composer.github.io/installer.sig \
+    && php -r "if (hash('SHA384', file_get_contents('/tmp/composer-setup.php')) !== trim(file_get_contents('/tmp/composer-setup.sig'))) { unlink('/tmp/composer-setup.php'); echo 'Invalid installer' . PHP_EOL; exit(1); }" \
+    && php /tmp/composer-setup.php --no-ansi --install-dir=/usr/local/bin --filename=composer --version=1.1.0 && rm -rf /tmp/composer-setup.php
+
+# Install Composer Application Dependencies
+COPY composer.json /opt/php-pubsub/
+RUN composer install --no-autoloader --no-scripts --no-interaction
+
+COPY src /opt/php/pubsub/
+COPY examples /opt/php/pubsub
+
+RUN composer dump-autoload --no-interaction
+
+CMD ["/bin/bash"]
diff --git a/LICENSE b/LICENSE
@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2016 Superbalist.com a division of Takealot Online (Pty) Ltd
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
diff --git a/Makefile b/Makefile
@@ -0,0 +1,13 @@
+.PHONY: tests
+
+up:
+	@docker-compose rm -f
+	@docker-compose pull
+	@sed -e "s/HOSTIP/$$(docker-machine ip)/g" docker-compose.yml | docker-compose --file - up --build -d
+	@docker-compose run php-pubsub-google-cloud /bin/bash
+
+down:
+	@docker-compose stop -t 1
+
+tests:
+	@./vendor/bin/phpunit --configuration phpunit.xml
diff --git a/README.md b/README.md
@@ -0,0 +1,57 @@
+# php-pubsub-google-cloud
+
+A Google Cloud adapter for the [php-pubsub](https://github.com/Superbalist/php-pubsub) package.
+
+[![Author](http://img.shields.io/badge/author-@superbalist-blue.svg?style=flat-square)](https://twitter.com/superbalist)
+[![Build Status](https://img.shields.io/travis/Superbalist/php-pubsub-google-cloud/master.svg?style=flat-square)](https://travis-ci.org/Superbalist/php-pubsub-google-cloud)
+[![Software License](https://img.shields.io/badge/license-MIT-brightgreen.svg?style=flat-square)](LICENSE)
+[![Packagist Version](https://img.shields.io/packagist/v/superbalist/php-pubsub-google-cloud.svg?style=flat-square)](https://packagist.org/packages/superbalist/php-pubsub-google-cloud)
+[![Total Downloads](https://img.shields.io/packagist/dt/superbalist/php-pubsub-google-cloud.svg?style=flat-square)](https://packagist.org/packages/superbalist/php-pubsub-google-cloud)
+
+
+## Installation
+
+```bash
+composer require superbalist/php-pubsub-google-cloud
+```
+
+## Usage
+
+```php
+putenv('GOOGLE_APPLICATION_CREDENTIALS=' . __DIR__ . '/../your-gcloud-key.json');
+
+$client = new \Google\Cloud\PubSub\PubSubClient([
+    'projectId' => 'your-project-id-here',
+]);
+
+$adapter = new \Superbalist\PubSub\GoogleCloud\GoogleCloudPubSubAdapter($client);
+
+// consume messages
+// note: this is a blocking call
+$adapter->subscribe('my_channel', function ($message) {
+    var_dump($message);
+});
+
+// publish messages
+$adapter->publish('my_channel', 'HELLO WORLD');
+$adapter->publish('my_channel', json_encode(['hello' => 'world']));
+$adapter->publish('my_channel', 1);
+$adapter->publish('my_channel', false);
+```
+
+## Examples
+
+The library comes with [examples](examples) for the adapter and a [Dockerfile](Dockerfile) for
+running the example scripts.
+
+Run `make up`.
+
+You will start at a `bash` prompt in the `/opt/php-pubsub` directory.
+
+If you need another shell to publish a message to a blocking consumer, you can run `docker-compose run php-pubsub-google-cloud /bin/bash`
+
+To run the examples:
+```bash
+$ php examples/GoogleCloudConsumerExample.php
+$ php examples/GoogleCloudPublishExample.php (in a separate shell)
+```
diff --git a/changelog.md b/changelog.md
@@ -0,0 +1,5 @@
+# Changelog
+
+## 1.0.0 - 2016-09-05
+
+* Initial release
diff --git a/composer.json b/composer.json
@@ -0,0 +1,31 @@
+{
+  "name": "superbalist/php-pubsub-google-cloud",
+  "description": "A Google Cloud adapter for the php-pubsub package",
+  "license": "MIT",
+  "authors": [
+    {
+      "name": "Superbalist.com a division of Takealot Online (Pty) Ltd",
+      "email": "info@superbalist.com"
+    }
+  ],
+  "require": {
+    "php": ">=5.6.0",
+    "superbalist/php-pubsub": "^1.0",
+    "google/cloud": "^0.7.0"
+  },
+  "autoload": {
+    "psr-4": {
+      "Superbalist\\PubSub\\GoogleCloud\\": "src/",
+      "Tests\\": "tests/"
+    }
+  },
+  "extra": {
+    "branch-alias": {
+      "dev-master": "1.0-dev"
+    }
+  },
+  "require-dev": {
+    "phpunit/phpunit": "^5.5",
+    "mockery/mockery": "^0.9.5"
+  }
+}
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -0,0 +1,7 @@
+version: '2'
+services:
+  php-pubsub-google-cloud:
+    build: .
+    volumes:
+      - ./src:/opt/php-pubsub/src
+      - ./examples:/opt/php-pubsub/examples
diff --git a/examples/GoogleCloudConsumerExample.php b/examples/GoogleCloudConsumerExample.php
@@ -0,0 +1,15 @@
+<?php
+
+include __DIR__ . '/../vendor/autoload.php';
+
+putenv('GOOGLE_APPLICATION_CREDENTIALS=' . __DIR__ . '/../your-gcloud-key.json');
+
+$client = new \Google\Cloud\PubSub\PubSubClient([
+    'projectId' => 'your-project-id-here',
+]);
+
+$adapter = new \Superbalist\PubSub\GoogleCloud\GoogleCloudPubSubAdapter($client);
+
+$adapter->subscribe('my_channel', function ($message) {
+    var_dump($message);
+});
diff --git a/examples/GoogleCloudPublishExample.php b/examples/GoogleCloudPublishExample.php
@@ -0,0 +1,15 @@
+<?php
+
+include __DIR__ . '/../vendor/autoload.php';
+
+putenv('GOOGLE_APPLICATION_CREDENTIALS=' . __DIR__ . '/../your-gcloud-key.json');
+
+$client = new \Google\Cloud\PubSub\PubSubClient([
+    'projectId' => 'your-project-id-here',
+]);
+
+$adapter = new \Superbalist\PubSub\GoogleCloud\GoogleCloudPubSubAdapter($client);
+
+$adapter->publish('my_channel', 'Hello World');
+$adapter->publish('my_channel', ['lorem' => 'ipsum']);
+$adapter->publish('my_channel', '{"blah": "bleh"}');
diff --git a/phpunit.php b/phpunit.php
@@ -0,0 +1,3 @@
+<?php
+
+include __DIR__ . '/vendor/autoload.php';
diff --git a/phpunit.xml b/phpunit.xml
@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit backupGlobals="false"
+         backupStaticAttributes="false"
+         bootstrap="./phpunit.php"
+         colors="true"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         processIsolation="false"
+         stopOnFailure="false"
+         syntaxCheck="true"
+         verbose="true"
+>
+    <testsuites>
+        <testsuite name="php-pubsub-google-cloud/tests">
+            <directory suffix=".php">./tests/</directory>
+        </testsuite>
+    </testsuites>
+    <filter>
+        <whitelist>
+            <directory suffix=".php">./src/</directory>
+        </whitelist>
+    </filter>
+    <logging>
+        <log type="coverage-text" target="php://stdout" showUncoveredFiles="true"/>
+        <log type="coverage-html" target="coverage" showUncoveredFiles="true"/>
+        <log type="coverage-clover" target="coverage.xml" showUncoveredFiles="true"/>
+    </logging>
+</phpunit>
diff --git a/src/GoogleCloudPubSubAdapter.php b/src/GoogleCloudPubSubAdapter.php
@@ -0,0 +1,122 @@
+<?php
+
+namespace Superbalist\PubSub\GoogleCloud;
+
+use Google\Cloud\PubSub\PubSubClient;
+use Superbalist\PubSub\PubSubAdapterInterface;
+use Superbalist\PubSub\Utils;
+
+class GoogleCloudPubSubAdapter implements PubSubAdapterInterface
+{
+    /**
+     * @var PubSubClient
+     */
+    protected $client;
+
+    /**
+     * @param PubSubClient $client
+     */
+    public function __construct(PubSubClient $client)
+    {
+        $this->client = $client;
+    }
+
+    /**
+     * Return the Google PubSubClient.
+     *
+     * @return PubSubClient
+     */
+    public function getClient()
+    {
+        return $this->client;
+    }
+
+    /**
+     * Subscribe a handler to a channel.
+     *
+     * @param string $channel
+     * @param callable $handler
+     */
+    public function subscribe($channel, callable $handler)
+    {
+        $subscription = $this->getSubscriptionForChannel($channel);
+
+        $isSubscriptionLoopActive = true;
+
+        while ($isSubscriptionLoopActive) {
+            $ackIds = [];
+            $payloads = [];
+
+            $messages = $subscription->pull();
+
+            foreach ($messages as $message) {
+                $ackIds[] = $message['ackId'];
+
+                // the cloud library base64 encodes messages
+                $payload = base64_decode($message['message']['data']);
+                $payload = Utils::unserializeMessagePayload($payload);
+
+                if ($payload === 'unsubscribe') {
+                    $isSubscriptionLoopActive = false;
+                } else {
+                    $payloads[] = $payload;
+                }
+            }
+
+            if (!empty($ackIds)) {
+                $subscription->acknowledgeBatch($ackIds);
+            }
+
+            foreach ($payloads as $payload) {
+                call_user_func($handler, $payload);
+            }
+        }
+    }
+
+    /**
+     * Publish a message to a channel.
+     *
+     * @param string $channel
+     * @param mixed $message
+     */
+    public function publish($channel, $message)
+    {
+        $topic = $this->getTopicForChannel($channel);
+        $topic->publish(['data' => Utils::serializeMessage($message)]);
+    }
+
+    /**
+     * Return a `Topic` instance from a channel name.
+     *
+     * If the topic doesn't exist, the topic is first created.
+     *
+     * @param string $channel
+     * @return \Google\Cloud\PubSub\Topic
+     */
+    protected function getTopicForChannel($channel)
+    {
+        $topic = $this->client->topic($channel);
+        if (!$topic->exists()) {
+            $topic->create();
+        }
+        return $topic;
+    }
+
+    /**
+     * Return a `Subscription` instance from a channel name.
+     *
+     * If the subscription doesn't exist, the subscription is first created.
+     *
+     * @param string $channel
+     * @return \Google\Cloud\PubSub\Subscription
+     */
+    protected function getSubscriptionForChannel($channel)
+    {
+        $topic = $this->getTopicForChannel($channel);
+        $subscription = $topic->subscription($channel);
+        if (!$subscription->exists()) {
+            $subscription->create();
+        }
+        return $subscription;
+    }
+}
diff --git a/tests/GoogleCloudPubSubAdapterTest.php b/tests/GoogleCloudPubSubAdapterTest.php
