feat(Subscription): add Google Cloud PubSub destination

closes #418

Author: jenschude

src/Core/Model/Subscription/AzureServiceBusDestination.php

@@ -14,6 +14,10 @@
  * @method AzureServiceBusDestination setType(string $type = null)
  * @method string getConnectionString()
  * @method AzureServiceBusDestination setConnectionString(string $connectionString = null)
+ * @method string getUri()
+ * @method AzureServiceBusDestination setUri(string $uri = null)
+ * @method string getAccessKey()
+ * @method AzureServiceBusDestination setAccessKey(string $accessKey = null)
  */
 class AzureServiceBusDestination extends Destination
 {
@@ -22,13 +26,13 @@ public function fieldDefinitions()
         return [
             'type' => [static::TYPE => 'string'],
             'connectionString' => [static::TYPE => 'string'],
+            'uri' => [static::TYPE => 'string'],
+            'accessKey' => [static::TYPE => 'string'],
         ];
     }
 
     /**
      * @param $connectionString
-     * @param $accessKey
-     * @param $accessSecret
      * @param Context|null $context
      * @return AzureServiceBusDestination
      */
@@ -38,4 +42,18 @@ public static function ofQueueURLAccessKeyAndSecret($connectionString, Context $
             ->setType('AzureServiceBus')
             ->setConnectionString($connectionString);
     }
+
+    /**
+     * @param $uri
+     * @param $accessKey
+     * @param Context|null $context
+     * @return AzureServiceBusDestination
+     */
+    public static function ofUriAndAccessKey($uri, $accessKey, Context $context = null)
+    {
+        return static::of($context)
+            ->setType('AzureServiceBus')
+            ->setUri($uri)
+            ->setAccessKey($accessKey);
+    }
 }

src/Core/Model/Subscription/Destination.php

@@ -17,6 +17,9 @@ class Destination extends JsonObject
 {
     const DESTINATION_SQS = 'SQS';
     const DESTINATION_IRON_MQ = 'IronMQ';
+    const DESTINATION_SNS = 'SNS';
+    const DESTINATION_AZURE_SERVICE_BUS = 'AzureServiceBus';
+    const DESTINATION_GOOGLE_CLOUD_PUB_SUB = 'GoogleCloudPubSub';
 
     public function fieldDefinitions()
     {
@@ -30,6 +33,9 @@ protected static function destinationType($typeId)
         $types = [
             static::DESTINATION_SQS => SQSDestination::class,
             static::DESTINATION_IRON_MQ => IronMQDestination::class,
+            static::DESTINATION_SNS => SNSDestination::class,
+            static::DESTINATION_AZURE_SERVICE_BUS => AzureServiceBusDestination::class,
+            static::DESTINATION_GOOGLE_CLOUD_PUB_SUB => GoogleCloudPubSubDestination::class,
         ];
         return isset($types[$typeId]) ? $types[$typeId] : Destination::class;
     }

src/Core/Model/Subscription/GoogleCloudPubSubDestination.php

@@ -0,0 +1,40 @@
+<?php
+/**
+ */
+
+namespace Commercetools\Core\Model\Subscription;
+
+use Commercetools\Core\Model\Common\Context;
+
+/**
+ * @package Commercetools\Core\Model\Subscription
+ *
+ * @method string getType()
+ * @method GoogleCloudPubSubDestination setType(string $type = null)
+ * @method string getProjectId()
+ * @method GoogleCloudPubSubDestination setProjectId(string $projectId = null)
+ * @method string getTopic()
+ * @method GoogleCloudPubSubDestination setTopic(string $topic = null)
+ */
+class GoogleCloudPubSubDestination extends Destination
+{
+    public function fieldDefinitions()
+    {
+        return [
+            'type' => [static::TYPE => 'string'],
+            'projectId' => [static::TYPE => 'string'],
+            'topic' => [static::TYPE => 'string'],
+        ];
+    }
+
+    /**
+     * @param string $projectId
+     * @param string $topic
+     * @param Context $context
+     * @return GoogleCloudPubSubDestination
+     */
+    public static function ofProjectIdAndTopic($projectId, $topic, Context $context = null)
+    {
+        return static::of($context)->setType('GoogleCloudPubSub')->setProjectId($projectId)->setTopic($topic);
+    }
+}