First commit

Author: kainxspirits

.editorconfig

@@ -0,0 +1,9 @@
+root = true
+
+[*]
+charset = utf-8
+indent_size = 4
+indent_style = space
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true

.gitignore

@@ -0,0 +1,2 @@
+vendor
+composer.lock

.styleci.yml

@@ -0,0 +1 @@
+preset: laravel

.travis.yml

@@ -0,0 +1,11 @@
+language: php
+
+php:
+  - '7.1'
+  - '7.2'
+
+before_script:
+    - travis_retry composer self-update
+    - travis_retry composer update --no-interaction --prefer-source
+
+script: vendor/bin/phpunit --coverage-text

LICENSE

@@ -0,0 +1,9 @@
+MIT License
+
+Copyright (c) 2017 Kendryck Abdou <kainxspirits@users.noreply.github.com>
+
+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.

README.md

@@ -0,0 +1,48 @@
+# Laravel PubSub Queue
+
+[![Travis](https://img.shields.io/travis/kainxspirits/laravel-pubsub-queue.svg)](https://github.com/kainxspirits/laravel-pubsub-queue)
+[![StyleCI](https://styleci.io/repos//shield)](https://styleci.io/repos/)
+
+This package is a Laravel queue driver that use the [Google PubSub](https://github.com/GoogleCloudPlatform/google-cloud-php-pubsub) service.
+
+## Installation
+
+You can easily install this package with [Composer](https://getcomposer.org) by running this command :
+
+```bash
+composer require kainxspirits/laravel-pubsub-queue
+```
+
+If you disabled package discovery, you can still manually register this package by adding the following line to the providers of your `config/app.php` file :
+
+```php
+Kainxspirits\PubSubQueue\PubSubQueueServiceProvider::class,
+```
+
+## Configuration
+
+Add a `pubsub` connection to your `config/queue.php` file. From there, you can use any configuration values from the original pubsub client. Just make sure to use snake_case for the keys name.
+
+You can check [Google Cloud PubSub client](http://googlecloudplatform.github.io/google-cloud-php/#/docs/google-cloud/v0.62.0/pubsub/pubsubclient?method=__construct) for more details about the different options.
+
+```php
+'pubsub' => [
+    'driver' => 'pubsub',
+    'queue' => env('PUBSUB_QUEUE', 'default'),
+    'project_id' => env('PUBSUB_PROJECT_ID', 'your-project-id'),
+    'retries' => 3,
+    'request_timeout' => 60
+],
+```
+
+## Testing
+
+You can run the tests with :
+
+```bash
+vendor/bin/phpunit
+```
+
+## License
+
+This project is licensed under the terms of the MIT license. See [License File](LICENSE) for more information.

VERSION

@@ -0,0 +1 @@
+0.1.0

composer.json

@@ -0,0 +1,49 @@
+{
+    "name": "kainxspirits/laravel-pubsub-queue",
+    "description": "Queue driver for Google Cloud Pub/Sub.",
+    "keywords": [
+        "kainxspirits",
+        "laravel",
+        "queue",
+        "gcp",
+        "google",
+        "pubsub"
+    ],
+    "license": "MIT",
+    "type": "library",
+    "authors": [
+        {
+            "name": "Kendryck",
+            "email": "kainxspirits@users.noreply.github.com"
+        }
+    ],
+    "require": {
+        "php" : ">=7.1",
+        "illuminate/queue": "^5.6",
+        "google/cloud-pubsub": "^1.1"
+    },
+    "require-dev": {
+        "phpunit/phpunit": "^7.1"
+    },
+    "autoload": {
+        "psr-4": {
+            "Kainxspirits\\PubSubQueue\\": "src/"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "Kainxspirits\\PubSubQueue\\Tests\\": "tests/"
+        }
+    },
+    "scripts": {
+        "test": "vendor/bin/phpunit"
+    },
+    "extra": {
+        "laravel": {
+            "providers": [
+                "Kainxspirits\\PubSubQueue\\PubSubQueueServiceProvider"
+            ]
+        }
+    },
+    "minimum-stability": "stable"
+}

phpunit.xml.dist

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit backupGlobals="false"
+         backupStaticAttributes="false"
+         bootstrap="vendor/autoload.php"
+         colors="true"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         processIsolation="false"
+         stopOnFailure="false"
+         verbose="true">
+    <testsuites>
+        <testsuite name="tests">
+            <directory suffix="Tests.php">./tests/</directory>
+        </testsuite>
+    </testsuites>
+    <filter>
+        <whitelist>
+            <directory suffix=".php">src/</directory>
+        </whitelist>
+    </filter>
+</phpunit>

src/Connectors/PubSubConnector.php

@@ -0,0 +1,62 @@
+<?php
+
+namespace Kainxspirits\PubSubQueue\Connectors;
+
+use Google\Cloud\PubSub\PubSubClient;
+use Kainxspirits\PubSubQueue\PubSubQueue;
+use Illuminate\Queue\Connectors\ConnectorInterface;
+
+class PubSubConnector implements ConnectorInterface
+{
+    /**
+     * Default queue name.
+     *
+     * @var string
+     */
+    protected $default_queue = 'default';
+
+    /**
+     * Establish a queue connection.
+     *
+     * @param  array  $config
+     * @return \Illuminate\Contracts\Queue\Queue
+     */
+    public function connect(array $config)
+    {
+        $gcp_config = $this->transformConfig($config);
+
+        return new PubSubQueue(
+            new PubSubClient($gcp_config),
+            $config['queue'] ?? $this->default_queue
+        );
+    }
+
+    /**
+     * Transform the config to key => value array.
+     *
+     * @param  array $config
+     *
+     * @return array
+     */
+    protected function transformConfig($config)
+    {
+        return array_reduce(array_map([$this, 'transformConfigKeys'], $config, array_keys($config)), function ($carry, $item) {
+            $carry[$item[0]] = $item[1];
+
+            return $carry;
+        }, []);
+    }
+
+    /**
+     * Transform the keys of config to camelCase.
+     *
+     * @param  string $item
+     * @param  string $key
+     *
+     * @return array
+     */
+    protected function transformConfigKeys($item, $key)
+    {
+        return [camel_case($key), $item];
+    }
+}