source code copied from azure-storage-php for v1.3.0-queue release

Author: vinjiang

ChangeLog.md

@@ -1,3 +1,7 @@
+2019.04 - version 1.3.0
+* Added support for OAuth authentication.
+* Resolved some issues on Linux platform.
+
 2019.03 - version 1.2.0
 * Documentation refinement.
 

README.md

@@ -100,6 +100,10 @@ QueueEndpoint=[myQueueEndpoint];SharedAccessSignature=[sasToken]
 ```php
 $queueClient = QueueRestProxy::createQueueService($connectionString);
 ```
+Or for AAD authentication:
+```php
+$queueClient = QueueRestProxy::createQueueServiceWithTokenCredential($token, $connectionString);
+```
 ### Using Middlewares
 To specify the middlewares, user have to create an array with middlewares
 and put it in the `$requestOptions` with key 'middlewares'. The sequence of

composer.json

@@ -1,6 +1,6 @@
 {
     "name": "microsoft/azure-storage-queue",
-    "version": "1.2.0",
+    "version": "1.3.0",
     "description": "This project provides a set of PHP client libraries that make it easy to access Microsoft Azure Storage Queue APIs.",
     "keywords": [ "php", "azure", "storage", "sdk", "queue" ],
     "license": "MIT",
@@ -12,7 +12,7 @@
     ],
     "require": {
         "php": ">=5.6.0",
-		"microsoft/azure-storage-common": "~1.3.0"
+		"microsoft/azure-storage-common": "~1.4"
     },
     "autoload": {
         "psr-4": {

src/Queue/Internal/QueueResources.php

@@ -41,8 +41,8 @@ class QueueResources extends Resources
 {
     // @codingStandardsIgnoreStart
 
-    const QUEUE_SDK_VERSION = '1.2.0';
-    const STORAGE_API_LATEST_VERSION = '2016-05-31';
+    const QUEUE_SDK_VERSION = '1.3.0';
+    const STORAGE_API_LATEST_VERSION = '2017-11-09';
 
     // Error messages
     const INVALID_RECEIVE_MODE_MSG = 'The receive message option is in neither RECEIVE_AND_DELETE nor PEEK_LOCK mode.';

src/Queue/QueueRestProxy.php

@@ -26,6 +26,7 @@
 
 use MicrosoftAzure\Storage\Common\Internal\Authentication\SharedAccessSignatureAuthScheme;
 use MicrosoftAzure\Storage\Common\Internal\Authentication\SharedKeyAuthScheme;
+use MicrosoftAzure\Storage\Common\Internal\Authentication\TokenAuthScheme;
 use MicrosoftAzure\Storage\Common\Internal\Http\HttpFormatter;
 use MicrosoftAzure\Storage\Common\Internal\Middlewares\CommonRequestMiddleware;
 use MicrosoftAzure\Storage\Common\Internal\Serialization\XmlSerializer;
@@ -132,6 +133,66 @@ public static function createQueueService(
         return $queueWrapper;
     }
 
+    /**
+     * Builds a queue service object, it accepts the following
+     * options:
+     *
+     * - http: (array) the underlying guzzle options. refer to
+     *   http://docs.guzzlephp.org/en/latest/request-options.html for detailed available options
+     * - middlewares: (mixed) the middleware should be either an instance of a sub-class that
+     *   implements {@see MicrosoftAzure\Storage\Common\Middlewares\IMiddleware}, or a
+     *   `callable` that follows the Guzzle middleware implementation convention
+     *
+     * Please refer to
+     * https://docs.microsoft.com/en-us/azure/storage/common/storage-auth-aad
+     * for authenticate access to Azure blobs and queues using Azure Active Directory.
+     *
+     * @param string $token            The bearer token passed as reference.
+     * @param string $connectionString The configuration connection string.
+     * @param array  $options          Array of options to pass to the service
+     *
+     * @return QueueRestProxy
+     */
+    public static function createQueueServiceWithTokenCredential(
+        &$token,
+        $connectionString,
+        array $options = []
+    ) {
+        $settings = StorageServiceSettings::createFromConnectionStringForTokenCredential(
+            $connectionString
+        );
+
+        $primaryUri = Utilities::tryAddUrlScheme(
+            $settings->getQueueEndpointUri()
+        );
+
+        $secondaryUri = Utilities::tryAddUrlScheme(
+            $settings->getQueueSecondaryEndpointUri()
+        );
+
+        $queueWrapper = new QueueRestProxy(
+            $primaryUri,
+            $secondaryUri,
+            $settings->getName(),
+            $options
+        );
+
+        // Getting authentication scheme
+        $authScheme = new TokenAuthScheme(
+            $token
+        );
+
+        // Adding common request middleware
+        $commonRequestMiddleware = new CommonRequestMiddleware(
+            $authScheme,
+            Resources::STORAGE_API_LATEST_VERSION,
+            Resources::QUEUE_SDK_VERSION
+        );
+        $queueWrapper->pushMiddleware($commonRequestMiddleware);
+
+        return $queueWrapper;
+    }
+
     /**
      * Lists all queues in the storage account.
      *