Throwing exception if blob name is passed as null (#41099)

Author: ibrahimrabab

sdk/storage/azure-storage-blob-cryptography/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "java",
   "TagPrefix": "java/storage/azure-storage-blob-cryptography",
-  "Tag": "java/storage/azure-storage-blob-cryptography_961671aec4"
+  "Tag": "java/storage/azure-storage-blob-cryptography_8b89809d96"
 }

sdk/storage/azure-storage-blob-cryptography/src/test/java/com/azure/storage/blob/specialized/cryptography/EncryptedFlux.java

@@ -99,9 +99,10 @@ ByteBuffer limit() is exclusive, which is why we add one to a limit if that byte
     EncryptedFlux(int testCase, AsyncKeyEncryptionKey key, BlobCryptographyTestBase base) throws InvalidKeyException {
         this.testCase = testCase;
         this.plainText = base.getRandomData(DOWNLOAD_SIZE - 2); // This will yield two bytes of padding... for fun.
+        String blobName = base.generateBlobName();
 
         EncryptedBlob encryptedBlob = new EncryptedBlobAsyncClient(null, "https://random.blob.core.windows.net",
-            BlobServiceVersion.getLatest(), null, null, null, null, null, null, key, "keyWrapAlgorithm", null,
+            BlobServiceVersion.getLatest(), null, null, blobName, null, null, null, key, "keyWrapAlgorithm", null,
             EncryptionVersion.V1, false)
             .encryptBlob(just(this.plainText)).block();
         this.cipherText = FluxUtil.collectBytesInByteBufferStream(encryptedBlob.getCiphertextFlux())

sdk/storage/azure-storage-blob/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "java",
   "TagPrefix": "java/storage/azure-storage-blob",
-  "Tag": "java/storage/azure-storage-blob_e9a4d152f3"
+  "Tag": "java/storage/azure-storage-blob_b29c63bb55"
 }

sdk/storage/azure-storage-blob/src/main/java/com/azure/storage/blob/specialized/BlobAsyncClientBase.java

@@ -230,6 +230,9 @@ protected BlobAsyncClientBase(HttpPipeline pipeline, String url, BlobServiceVers
             throw LOGGER.logExceptionAsError(
                 new IllegalArgumentException("'snapshot' and 'versionId' cannot be used at the same time."));
         }
+        if (blobName == null) {
+            throw LOGGER.logExceptionAsError(new NullPointerException("'blobName' can not be set to null."));
+        }
         this.azureBlobStorage = new AzureBlobStorageImplBuilder()
             .pipeline(pipeline)
             .url(url)

sdk/storage/azure-storage-blob/src/test/java/com/azure/storage/blob/ContainerApiTests.java

@@ -90,6 +90,11 @@ public void setup() {
         tagValue = testResourceNamer.randomName(prefix, 20);
     }
 
+    @Test
+    public void blobNameNull() {
+        assertThrows(NullPointerException.class, () -> cc.getBlobClient(null));
+    }
+
     @Test
     public void createAllNull() {
         // Overwrite the existing cc, which has already been created

sdk/storage/azure-storage-blob/src/test/java/com/azure/storage/blob/ContainerAsyncApiTests.java

@@ -85,6 +85,11 @@ public void setup() {
         tagValue = testResourceNamer.randomName(prefix, 20);
     }
 
+    @Test
+    public void blobNameNull() {
+        assertThrows(NullPointerException.class, () -> cc.getBlobClient(null));
+    }
+
     @Test
     public void createAllNull() {
         // Overwrite the existing cc, which has already been created