Fresh

Author: marickvantuil

composer.json

@@ -1,5 +1,5 @@
 {
-    "name": "stackkit/laravel-google-pubsub-queue",
+    "name": "stackkit/laravel-google-cloud-tasks-queue",
     "license": "MIT",
     "authors": [
         {
@@ -9,7 +9,7 @@
     ],
     "require": {
         "ext-json": "*",
-        "google/cloud-pubsub": "^1.24"
+        "google/cloud-tasks": "^1.6"
     },
     "require-dev": {
         "mockery/mockery": "^1.2",
@@ -18,13 +18,13 @@
     },
     "autoload": {
         "psr-4": {
-            "Stackkit\\LaravelGooglePubSubQueue\\": "src/"
+            "Stackkit\\LaravelGoogleCloudTasksQueue\\": "src/"
         }
     },
     "extra": {
         "laravel": {
             "providers": [
-                "Stackkit\\LaravelGooglePubSubQueue\\LaravelGooglePubSubQueueServiceProvider"
+                "Stackkit\\LaravelGoogleCloudTasksQueue\\CloudTasksServiceProvider"
             ]
         }
     }

src/CloudTasksConnector.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Stackkit\LaravelGoogleCloudTasksQueue;
+
+use Illuminate\Queue\Connectors\ConnectorInterface;
+
+class CloudTasksConnector implements ConnectorInterface
+{
+    public function connect(array $config)
+    {
+        return new CloudTasksQueue();
+    }
+}

src/CloudTasksJob.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Stackkit\LaravelGoogleCloudTasksQueue;
+
+use Illuminate\Queue\Jobs\Job as LaravelJob;
+use Illuminate\Contracts\Queue\Job as JobContract;
+
+class CloudTasksJob extends LaravelJob implements JobContract
+{
+    public function getJobId()
+    {
+        // TODO: Implement getJobId() method.
+    }
+
+    public function getRawBody()
+    {
+        // TODO: Implement getRawBody() method.
+    }
+
+    public function attempts()
+    {
+        // TODO: Implement attempts() method.
+    }
+}

src/CloudTasksQueue.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace Stackkit\LaravelGoogleCloudTasksQueue;
+
+use Illuminate\Contracts\Queue\Queue as QueueContract;
+use Illuminate\Queue\Queue as LaravelQueue;
+
+class CloudTasksQueue extends LaravelQueue implements QueueContract
+{
+    public function size($queue = null)
+    {
+        // TODO: Implement size() method.
+    }
+
+    public function push($job, $data = '', $queue = null)
+    {
+        // TODO: Implement push() method.
+    }
+
+    public function pushRaw($payload, $queue = null, array $options = [])
+    {
+        // TODO: Implement pushRaw() method.
+    }
+
+    public function later($delay, $job, $data = '', $queue = null)
+    {
+        // TODO: Implement later() method.
+    }
+
+    public function pop($queue = null)
+    {
+        // TODO: Implement pop() method.
+    }
+}

src/CloudTasksServiceProvider.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace Stackkit\LaravelGoogleCloudTasksQueue;
+
+use Illuminate\Support\ServiceProvider as LaravelServiceProvider;
+
+class CloudTasksServiceProvider extends LaravelServiceProvider
+{
+    public function boot()
+    {
+        $this->app['queue']->addConnector('cloudtasks', function () {
+            return new CloudTasksConnector;
+        });
+    }
+}