DevelopmentHelpers.Storage.Core 9.0.0

DevelopmentHelpers.Storage.Core

This library allows easier access to Azure Storage and Azure FileShare as well as Local directory structure. With few command you can upload or download entire structure to local or Azure storage.

Code Example Following example shows how to use Azure Storage Classes

Create IStorage -- IStorage interface has two implementation local & Azure:use any dependency injection container

IStorage storage =  new AzureStorage(config,logger); 
IStorage storage = new FileSystemStorage(config,logger);

Create IAzureFileStorage to use FileShare use dependency injection container

services.AddAzureStorage(configuration);
IAzureFileStorage fileStorage =  new AzureFileStorage(AzureFileStorageConfiguration,logger);

Use methods available on the interface

UploadDirectoryAsync(DirectoryInfo directory, string container); 

To Add in the Web Application add the configuration in appsettings.json file

 
 "DevelopmentHelpers" : 
 {
       "AzureConfiguration": {
       "AccountName": "Account-Name",
       "AccountKey": "Account-Key",
       "UseHttps": "True"
       },
       "AzureFileStorageConfiguration": {
       "ConnectionString": "Connection-String",
       "ShareName": "Share-Name"
       }
 }

Add the services in program.cs file

services.AddAzureStorage(Configuration);  

To Use in a constructor

private readonly IStorage _storage;
private readonly IAzureFileStorage _fileStorage;
public IndexModel(IStorage storage,IAzureFileStorage fileStorage)
{
      _storage = storage; AzureStorage azureStorage = new(new Models.AzureConfiguration
      {
      AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
      AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
      UseHttps = true
      }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());            
      string tempDirectoryPath = Path.Combine(_localDirectoryPath, sourceContainerName);
      if (Directory.Exists(tempDirectoryPath))
      {
      Directory.Delete(tempDirectoryPath, true);
      }  
      if (!await azureStorage.ContainerExistsAsync(sourceContainerName))
      {
      var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath);
      _ = await az
   _fileStorage= fileStorage;
}

To Sync Containers between storage accounts

      ureStorage.UploadDirectoryAsync(tempPath, sourceContainerName);
       }
       AzureStorageSyncHelper syncHelper = new(azureStorage, azureStorage);
       var (Success, _) = await syncHelper.SyncContainersAsync(sourceContainerName, targetContainerName, false, _localDirectoryPath);

To Get files exist in Target Container but not in local directory use

   AzureStorage azureStorage = new(new Models.AzureConfiguration
   {
   AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
   AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
   UseHttps = true
   }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());
   IDirectoryToContainerSyncHelper directorySyncHelper = new DirectoryToContainerSyncHelper(azureStorage);
   var response = await directorySyncHelper.GetBlobUrlListExistInTargetButNotInSourceAsync(sourceDirectoryPath, targetContainerName);
   Assert.IsNotNull(response.blobUrls);

To Get blobs exist in Target but not in Source use, create target storage and source storage separately if needed, sample uses same storage account

   AzureStorage azureStorage = new(new Models.AzureConfiguration
   {
   AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
   AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
   UseHttps = true
   }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());       
   IContainerToContainerSyncHelper syncHelper = new ContainerToContainerSyncHelper(azureStorage, azureStorage);        
   var (BlobUrls, Message) = await syncHelper.GetBlobUrlListExistInTargetButNotInSourceAsync(sourceContainerName, targetContainerName);

Motivation

I needed a consistent and easy to use library in .net Standard which I can use it with any project, and be able to download and upload complete directories.

Tests

using System.Collections.Generic;
using System.Drawing;
using System.IO;
using System.Threading.Tasks;
using FileHelper = DevelopmentHelpers.Storage.Core.Tests.Helpers.FileHelper;

namespace DevelopmentHelpers.Storage.Core.Tests
{


    [TestClass]
    public class AzureStorageCoreTest
    {

        static IStorage _storage;
        static StringHelper _stringHelper;
        private static string _localDirectoryPath;
        static DirectoryHelper _dirHelper;

        [ClassInitialize]
        public static void AzureStorageTestInit(TestContext context)
        {
            _storage = new AzureStorage(ConfigHelper.Instance.AzureConfiguration, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());
            _stringHelper = new StringHelper();
            _dirHelper = new DirectoryHelper();
            _localDirectoryPath = Path.Combine("C:\\temp", "AzureStorageCoreTest");
            if (Directory.Exists(_localDirectoryPath))
            {
                Directory.Delete(_localDirectoryPath, true);
            }
            Directory.CreateDirectory(_localDirectoryPath);
            Console.WriteLine("AzureStorageTestInit " + context.TestName);
        }
        [TestMethod]
        public void ValidateTest()
        {
            Assert.IsTrue(_storage.Validate());
        }
        [TestMethod]
        public void CreateContainerAndDeleteContainerTest()
        {
            string testContainerName = $"{Guid.NewGuid():N}";
            var response = _storage.CreateContainerAsync(testContainerName, false).Result;
            Assert.IsNotNull(response);
            response = _storage.CreateContainerAsync(testContainerName, false).Result;
            Assert.IsNull(response);//because container already exists 
            Assert.IsTrue(_storage.DeleteAsync(testContainerName).Result);
        }
        [TestMethod]
        [DataRow(5, 1024)]
        [DataRow(3, 36870637)]
        public void AzureUploadFileStreamTest(int count, long size)
        {

            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            FileHelper fileHelper = new(tempDirectoryPath);
            for (int i = 0; i < count; i++)
            {
                string fileName = $"{Guid.NewGuid()}.txt";
                fileHelper.CreateFile(size, fileName);
                FileInfo fileInfo = new(Path.Combine(tempDirectoryPath, fileName));
                FileStream fileStream = fileInfo.OpenRead();
                MemoryStream memoryStream = new();
                fileStream.CopyTo(memoryStream);
                Assert.IsNotNull(_storage.UploadFileStreamAsync(memoryStream, MimeTypes.txt, containerName, fileInfo.Name).Result);
                var blobUri = _storage.GetUri(containerName, fileName);
                Assert.IsNotNull(blobUri);
            }
        }

        [TestMethod]
        [DataRow(1, 1024)]
        [DataRow(1, 36870637)]
        public void AzureUploadFileInfoTest(int count, long size)
        {

            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            FileHelper fileHelper = new(tempDirectoryPath);
            for (int i = 0; i < count; i++)
            {
                string fileName = $"{Guid.NewGuid()}.txt";
                fileHelper.CreateFile(size, fileName);
                FileInfo fileInfo = new(Path.Combine(tempDirectoryPath, fileName));
                Assert.IsNotNull(_storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName).Result);
                var blobUri = _storage.GetUri(containerName, fileName);
                Assert.IsNotNull(blobUri);

                bool exists =  _storage.BlobExistsAsync(blobUri).Result;
                Assert.IsTrue(exists);
            }
        }

        [TestMethod] 
        public void CheckBlobExists()
        {
            bool exists = _storage.BlobExistsAsync("https://thisisdummybloburl.azurewebsites.net").Result;
            Assert.IsFalse(exists); 
        }
        [TestMethod]
        [DataRow(1, 0)]
        [DataRow(1, 1024)]
        [DataRow(1, 4194304)] //4mb
        [DataRow(1, 36870637)]
        [DataRow(1, 536870637)]
        // [DataRow(1, 1073741824)] //1 GB 
        // [DataRow(1, 2147483648)]// 2 GB
        //  [DataRow(1, 5368709120)]// 5 gb
        //  [DataRow(1, 10737418240)]// 10 GB
        public void AzureUploadFileInChunksTest(int count, long size)
        {
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            FileHelper fileHelper = new(tempDirectoryPath);
            for (int i = 0; i < count; i++)
            {
                string fileName = $"{Guid.NewGuid()}.txt";
                fileHelper.CreateFile(size, fileName);
                string completeFilePath = Path.Combine(tempDirectoryPath, fileName);
                var uri = _storage.UploadInChunks(completeFilePath, containerName, fileName, MimeTypes.txt).Result;
                Assert.IsNotNull(uri);
            }
        }
        [TestMethod]
        [DataRow(1, 1024)]
        [DataRow(1, 4194304)] //4mb
        [DataRow(1, 36870637)]
        [DataRow(1, 536870637)]
        //[DataRow(1, 1073741824)] //1 GB 
        //[DataRow(1, 2147483648)]// 2 GB
        //[DataRow(1, 5368709120)]// 5 gb
        //[DataRow(1, 10737418240)]// 10 GB
        public void AzureDownloadFileTest(int count, long size)
        {

            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            string downloadDirectoryPath = Path.Combine(_localDirectoryPath, $"{Guid.NewGuid():N}");
            Directory.CreateDirectory(downloadDirectoryPath);
            FileHelper fileHelper = new(tempDirectoryPath);
            for (int i = 0; i < count; i++)
            {
                string fileName = $"{Guid.NewGuid()}.txt";
                fileHelper.CreateFile(size, fileName);
                FileInfo fileInfo = new(Path.Combine(tempDirectoryPath, fileName));
                Assert.IsNotNull(_storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName).Result);
                var blobUri = _storage.GetUri(containerName, fileName);
                Assert.IsNotNull(blobUri);
                //Download
                var file = _storage.DownloadToFileAsync(blobUri, downloadDirectoryPath).Result;
                Assert.IsNotNull(file);
            }
        }



        [TestMethod]
        public void AzureDownloadFileTest()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            Directory.CreateDirectory(tempDirectoryPath);
            string testfile = Path.Combine(tempDirectoryPath, $"{Guid.NewGuid()}.txt");
            _stringHelper.CreatetestFile(testfile);
            FileInfo fileInfo = new(testfile);
            var url = _storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName).Result;
            var file = _storage.DownloadToFileAsync(url, tempDirectoryPath).Result;
            Assert.IsNotNull(file);
        }


        [TestMethod]
        public void AzureDownloadToStreamAsyncTest()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            Directory.CreateDirectory(tempDirectoryPath);
            string testfile = Path.Combine(tempDirectoryPath, $"{Guid.NewGuid()}.txt");
            _stringHelper.CreatetestFile(testfile);
            FileInfo fileInfo = new(testfile);
            var url = _storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName).Result;
            var file = _storage.DownloadToStreamAsync(url, tempDirectoryPath);
            Assert.IsNotNull(file);
        }


        [TestMethod]
        public void GetStorageContainerTest()
        {
            string tempDirectory = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, tempDirectory);
            _dirHelper.CreateTempDirectory(tempDirectoryPath);
            StorageContainer storageContainer = _storage.GetStorageContainerAsync(tempDirectory).Result;
            Assert.IsNotNull(storageContainer);
        }

        [TestMethod]
        public void DownloadContainerTest()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            _dirHelper.CreateTempDirectory(tempDirectoryPath);
            //Upload the directory 
            var created = _storage.UploadDirectoryAsync(tempDirectoryPath, containerName).Result;
            Assert.IsNotNull(created);
            string downloadDirectory = $"{Guid.NewGuid():N}";
            string downloadDirectoryPath = Path.Combine(_localDirectoryPath, downloadDirectory);
            _ = _storage.DownloadContainer(containerName, downloadDirectoryPath).Result;

            bool areIdentical = DirectoryHelper.CompareDirectories(tempDirectoryPath, downloadDirectoryPath);
            Assert.IsTrue(areIdentical);
        }
        [TestMethod]
        public void AzureUploadDirectoryAndZipAsyncTest()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath);
            DirectoryInfo info = new(tempPath);
            var created = _storage.UploadDirectoryAsync(info, containerName).Result;
            Assert.IsNotNull(created);
            string zipFolder = "Zip";
            string zipFolderPath = Path.Combine(_localDirectoryPath, zipFolder);
            if (!Directory.Exists(zipFolderPath))
                Directory.CreateDirectory(zipFolderPath);
            var zipFile = _storage.CreateZipFromContainerAsync(info.Name, zipFolderPath, $"{containerName}.zip")
                .Result;
            Assert.IsNotNull(zipFile);
        }
        [TestMethod]
        public void AzureUploadDirectoryAsyncTest()
        {
            AzureStorage azureStorage = new(new Models.AzureConfiguration
            {
                AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
                AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
                UseHttps = true
            }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath);
            var created = azureStorage.UploadDirectoryAsync(tempPath, containerName).Result;
            Assert.IsNotNull(created);


        }

        [TestMethod]
        public void AzureDownloadStorageContainerTest()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath);
            DirectoryInfo info = new(tempPath);
            var created = _storage.UploadDirectoryAsync(info, containerName).Result;
            Assert.IsNotNull(created);

            var storageContainer = _storage.GetStorageContainerAsync(containerName).Result;
            Assert.IsNotNull(storageContainer);

        }


        [TestMethod]
        public void AzureSystemUploadFileAsyncInfoTest()
        {
            //Test File 
            string fileName = $"{Guid.NewGuid()}.txt";
            string testFile = Path.Combine(Path.GetTempPath(), fileName);
            _stringHelper.CreatetestFile(testFile);
            FileInfo fileInfo = new(testFile);
            //Container 
            string containerName = $"{Guid.NewGuid():N}";
            var url = _storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName).Result;
            Assert.IsNotNull(url);
            Assert.IsNotNull(_storage.GetUri(containerName, fileName));
            var file = _storage.DownloadToFileAsync(url, _localDirectoryPath).Result;
            Assert.IsNotNull(file);
            var stream = _storage.DownloadToStreamAsync(url, _localDirectoryPath).Result;
            var tempFilePath = Path.Combine(_localDirectoryPath, "test.txt");
            if (File.Exists(tempFilePath))
                File.Delete(tempFilePath);
            using (FileStream fileStream = new(tempFilePath, FileMode.Create, FileAccess.Write))
            {
                byte[] bytes = new byte[stream.Length];
                stream.Read(bytes, 0, (int)stream.Length);
                fileStream.Write(bytes, 0, bytes.Length);
                stream.Close();
            }
            Assert.IsNotNull(stream);
        }

        [TestMethod]
        [DataRow("/help/new/add/")]
        public async Task AzureBlobUploadToNewContainerAsyncInfoTest(string prefix)
        {
            //Test File 
            string fileName = $"{Guid.NewGuid()}.txt";
            string testFile = Path.Combine(Path.GetTempPath(), fileName);
            _stringHelper.CreatetestFile(testFile);
            FileInfo fileInfo = new(testFile);
            //Container 
            string containerName = $"{Guid.NewGuid():N}";
            containerName= containerName.ToLower();
          
            var blobUrl = await _storage.UploadFileAsync($"{prefix}{fileName}",fileInfo.FullName, MimeTypes.txt, containerName);
            Assert.IsNotNull(blobUrl);
            Assert.IsNotNull(_storage.GetUri(containerName, fileName));

            var downloadedFile = await _storage.DownloadToFileAsync(blobUrl, _localDirectoryPath);
            Assert.IsNotNull(downloadedFile);


            BlobContainerClient blobContainerClient = _storage.Account.GetBlobContainerClient(containerName);
            BlobClient blobClient = blobContainerClient.GetBlobClient(blobUrl);


            var blobNameWithPrefix = blobClient.Name.Replace(blobContainerClient.Uri.AbsoluteUri, "");


            string newContainerName = $"{containerName.ToLower()}new";
            var newBlobUrl = await _storage.UploadFileAsync($"{blobNameWithPrefix}", downloadedFile, MimeTypes.txt, newContainerName);
            Assert.IsNotNull(newBlobUrl);
            BlobContainerClient blobContainerClientNew = _storage.Account.GetBlobContainerClient(newContainerName);
            BlobClient blobClientNew = blobContainerClientNew.GetBlobClient(newBlobUrl);

            var blobNameWithPrefixNew = blobClientNew.Name.Replace(blobContainerClientNew.Uri.AbsoluteUri, "");

            await _storage.DeleteAsync(containerName);
            await _storage.DeleteAsync(newContainerName);
            Assert.IsTrue(blobNameWithPrefixNew.Equals(blobNameWithPrefix)); 
        }
        [TestMethod]
        [DataRow("/help/new/add/")]
        [DataRow("")]
        public async Task AzureBlobUploadInchunksToNewContainerAsyncInfoTest(string prefix)
        {
            AzureStorage azureStorage = _storage as AzureStorage;
            //Test File 
            string fileName = $"{Guid.NewGuid()}.txt";
            string testFile = Path.Combine(Path.GetTempPath(), fileName);
            _stringHelper.CreatetestFile(testFile);
            FileInfo fileInfo = new(testFile);
            //Container 
            string containerName = $"{Guid.NewGuid():N}";
            containerName = containerName.ToLower();
            var blobUrl = await _storage.UploadInChunks(fileInfo.FullName, containerName, $"{prefix}{fileName}",  MimeTypes.txt);
            Assert.IsNotNull(blobUrl);
            Assert.IsNotNull(_storage.GetUri(containerName, fileName));
            var downloadedFile = await _storage.DownloadToFileAsync(blobUrl, _localDirectoryPath);
            Assert.IsNotNull(downloadedFile);
            var blobNameWithPrefix = azureStorage.GetBlobNameWithPrefix(blobUrl, containerName);              string newContainerName = $"{containerName.ToLower()}new"; 
            string newBlobUrl = await _storage.UploadInChunks(downloadedFile, newContainerName,blobNameWithPrefix, MimeTypes.txt);
            Assert.IsNotNull(newBlobUrl); 
            var blobNameWithPrefixNew = azureStorage.GetBlobNameWithPrefix(newBlobUrl, newContainerName);           
            await _storage.DeleteAsync(containerName);
            await _storage.DeleteAsync(newContainerName);
            Assert.IsTrue(blobNameWithPrefixNew.Equals(blobNameWithPrefix));
        }
        [TestMethod]
        public void CreateLargeFileZipTest()
        {
            //Create local Temp Directory where Container will be downloaded
            string zipFolder = "LargeFolder";
            string zipFolderPath = Path.Combine(_localDirectoryPath, zipFolder);
            if (Directory.Exists(zipFolderPath))
                Directory.Delete(zipFolderPath, true);
            //Create and upload temp directory to Azure Container
            string tempContainer = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, tempContainer);
            var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath, 1);
            DirectoryInfo info = new DirectoryInfo(tempPath);
            var uploaded = _storage.UploadDirectoryAsync(info, tempContainer).Result;
            Assert.IsNotNull(uploaded);
            var zipFile = _storage.CreateZipFromContainerAsync(tempContainer, zipFolderPath, $"{tempContainer}.zip")
                .Result;
            Assert.IsNotNull(zipFile);
        }

        [TestMethod]
        public void AzureGetContainerTest()
        {

            var blobContainerList = _storage.GetContainersAsync().Result;
            Assert.IsInstanceOfType(blobContainerList, typeof(List<BlobContainerItem>));
            Assert.IsTrue(true);
        }
        //
        [TestMethod]
        [DataRow(5, 1024)]
        public void ListBlobsAsyncTest(int count, long size)
        {

            string containerName = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, containerName);
            FileHelper fileHelper = new(tempDirectoryPath);
            for (int i = 0; i < count; i++)
            {
                string fileName = $"{Guid.NewGuid()}.txt";
                fileHelper.CreateFile(size, fileName);
            }
            DirectoryInfo infos = new(tempDirectoryPath);
            foreach (var fileInfo in infos.GetFiles())
            {
                var url = _storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName).Result;
                Assert.IsNotNull(url);
            }

            var blobItems = _storage.ListBlobsAsync(containerName).Result;
            Assert.IsInstanceOfType(blobItems, typeof(List<BlobItem>));
            //Delete the container 
            _storage.DeleteAsync(containerName);
            Assert.IsTrue(true);
        }
        [TestMethod]
        public void LocalGetContainerTest()
        {
            //Create local Temp Directory where Container will be downloaded
            string localTempDirectoryDownload = "localTempDirectoryDownload";
            string localTempDirectoryDownloadPath = Path.Combine(_localDirectoryPath, localTempDirectoryDownload);
            if (Directory.Exists(localTempDirectoryDownloadPath))
                Directory.Delete(localTempDirectoryDownloadPath);
            //Create and upload temp directory to Azure Container
            string tempContainer = $"{Guid.NewGuid():N}";
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, tempContainer);
            var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath);
            DirectoryInfo info = new(tempPath);
            var created = _storage.UploadDirectoryAsync(info, tempContainer).Result;
            Assert.IsNotNull(created);
            var storageContainer = _storage.GetStorageContainerAsync(tempContainer).Result;
            Assert.IsNotNull(storageContainer);
            //Save Container to Local Directory
            var localSavedPath = _storage.SaveStorageContainerAsync(storageContainer, localTempDirectoryDownloadPath).Result;
            Assert.IsNotNull(localSavedPath);
        }


        [TestMethod] 
        public async Task AzureUploadFileNameWithSpacesAndDownloadTestAsync()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string TestFileDirectory = Path.Combine(Environment.CurrentDirectory, "TestFiles");
            string downloadFileDirectory = Path.Combine(_localDirectoryPath, "DownloadedFiles");
            if (!Directory.Exists(downloadFileDirectory))
                Directory.CreateDirectory(downloadFileDirectory);
            DirectoryInfo directoryInfo = new(TestFileDirectory);
            foreach(FileInfo fileInfo in directoryInfo.GetFiles())
            {
                var blobUri = await _storage.UploadFileAsync(fileInfo, MimeTypes.txt, containerName); 
                Assert.IsNotNull(blobUri);
                var downloadedFile = await _storage.DownloadToFileAsync(blobUri, downloadFileDirectory);
                Assert.IsNotNull(downloadedFile);
            } 

        }
        [TestMethod]
        public async Task AzureUploadDirectoryWithSpacesAndDownloadTestAsync()
        {
            string containerName = $"{Guid.NewGuid():N}";
            string TestDirectory = Path.Combine(Environment.CurrentDirectory, "TestFiles");
            string downloadDirectory = Path.Combine(_localDirectoryPath, "DownloadedDirectory");
            var uploadedDirectory = await _storage.UploadDirectoryAsync(TestDirectory, containerName);
            Assert.IsNotNull(uploadedDirectory);
            var downloadedDirectory = await _storage.DownloadContainer(containerName, downloadDirectory);
            Assert.IsNotNull(downloadedDirectory);

            StorageContainer storageContainer = await _storage.GetStorageContainerAsync(containerName);
            Assert.IsNotNull(storageContainer);

        }
        [TestMethod]
        [DataTestMethod]
        [DataRow("source","target")]
        public async Task SyncContainersTestWhenTargetDoesnotExistAsync(string sourceContainerName, string targetContainerName)
        {
            AzureStorage azureStorage = new(new Models.AzureConfiguration
            {
                AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
                AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
                UseHttps = true
            }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());
            
            string tempDirectoryPath = Path.Combine(_localDirectoryPath, sourceContainerName);
            if (Directory.Exists(tempDirectoryPath))
            {
                Directory.Delete(tempDirectoryPath, true);
            }
          

            if (!await azureStorage.ContainerExistsAsync(sourceContainerName))
            {
                var tempPath = _dirHelper.CreateTempDirectory(tempDirectoryPath);
                _ = await azureStorage.UploadDirectoryAsync(tempPath, sourceContainerName);
            }

            ContainerToContainerSyncHelper syncHelper = new(azureStorage, azureStorage);
            var (Success, _) = await syncHelper.SyncSourceToTargetContainersAsync(sourceContainerName, targetContainerName, false, _localDirectoryPath);
            Assert.IsTrue(Success);



        }
      
        [TestMethod]
        [DataTestMethod]
        public async Task SyncContainersTestWhenTargetExistAsync()
        {
            string sourceContainerName = $"{Guid.NewGuid():N}";
            string targetContainerName = $"{Guid.NewGuid():N}";
            AzureStorage azureStorage = new(new Models.AzureConfiguration
            {
                AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
                AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
                UseHttps = true
            }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());

            string sourceDirectoryPath = Path.Combine(_localDirectoryPath, sourceContainerName);
            if (Directory.Exists(sourceDirectoryPath))
            {
                Directory.Delete(sourceDirectoryPath, true);
            }
            string targetDirectoryPath = Path.Combine(_localDirectoryPath, targetContainerName);
            if (Directory.Exists(targetDirectoryPath))
            {
                Directory.Delete(targetDirectoryPath, true);
            }
            if (!await azureStorage.ContainerExistsAsync(sourceContainerName))
            {
                sourceDirectoryPath = _dirHelper.CreateDirectoryWithTempData(sourceDirectoryPath);
                _ = await azureStorage.UploadDirectoryAsync(sourceDirectoryPath, sourceContainerName);
                _ = await azureStorage.UploadDirectoryAsync(sourceDirectoryPath, targetContainerName);

                //add some files so containers do not match
                for (int i = 0; i < 3; i++)
                {
                    string fileName = $"deleteme_{i}.txt";
                    FileHelper fileHelper = new(targetDirectoryPath);
                    fileHelper.CreateFile(1024, fileName);
                    FileInfo fileInfo = new(Path.Combine(targetDirectoryPath, fileName));
                    await azureStorage.UploadFileAsync(fileInfo, MimeTypes.txt, targetContainerName);
                }

            }
            ContainerToContainerSyncHelper syncHelper = new(azureStorage, azureStorage);
            var (Success, Message) = await syncHelper.SyncSourceToTargetContainersAsync(sourceContainerName, targetContainerName, false, _localDirectoryPath);
            Assert.IsNotNull(Message);
            Assert.IsTrue(Success);

        }

        [TestMethod]
        [DataTestMethod]
        public async Task GetBlobsRequireDeletionFromTargetContainerAsync()
        {
            string sourceContainerName = $"{Guid.NewGuid():N}";
            string targetContainerName = $"{Guid.NewGuid():N}";
            AzureStorage azureStorage = new(new Models.AzureConfiguration
            {
                AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
                AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
                UseHttps = true
            }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());

            string sourceDirectoryPath = Path.Combine(_localDirectoryPath, sourceContainerName);
            if (Directory.Exists(sourceDirectoryPath))
            {
                Directory.Delete(sourceDirectoryPath, true);
            }
            string targetDirectoryPath = Path.Combine(_localDirectoryPath, targetContainerName);
            if (Directory.Exists(targetDirectoryPath))
            {
                Directory.Delete(targetDirectoryPath, true);
            }
            if (!await azureStorage.ContainerExistsAsync(sourceContainerName))
            {
                sourceDirectoryPath = _dirHelper.CreateDirectoryWithTempData(sourceDirectoryPath);
                _ = await azureStorage.UploadDirectoryAsync(sourceDirectoryPath, sourceContainerName);
                _ = await azureStorage.UploadDirectoryAsync(sourceDirectoryPath, targetContainerName);

                //add some files so containers do not match
                for (int i = 0; i < 3; i++)
                {
                    string fileName = $"deleteme_{i}.txt";
                    FileHelper fileHelper = new(targetDirectoryPath);
                    fileHelper.CreateFile(1024, fileName);
                    FileInfo fileInfo = new(Path.Combine(targetDirectoryPath, fileName));
                    await azureStorage.UploadFileAsync(fileInfo, MimeTypes.txt, targetContainerName);
                }

            }

            IContainerToContainerSyncHelper syncHelper = new ContainerToContainerSyncHelper(azureStorage, azureStorage);
            var (BlobUrls, Message) = await syncHelper.GetBlobUrlListExistInTargetButNotInSourceAsync(sourceContainerName, targetContainerName);
            Assert.IsNotNull(BlobUrls);
            Assert.IsTrue(BlobUrls.Count == 3);


        }
        [TestMethod]
        [DataTestMethod]
        public async Task GetFilesRequireDeletionFromTargetContainerAsync()
        {
            string sourceContainerName = $"{Guid.NewGuid():N}";
            string targetContainerName = $"{Guid.NewGuid():N}";
            AzureStorage azureStorage = new(new Models.AzureConfiguration
            {
                AccountKey = ConfigHelper.Instance.AzureConfiguration.AccountKey,
                AccountName = ConfigHelper.Instance.AzureConfiguration.AccountName,
                UseHttps = true
            }, ConfigHelper.Instance.LoggerFactory.CreateLogger<AzureStorage>());

            string sourceDirectoryPath = Path.Combine(_localDirectoryPath, sourceContainerName);
            if (Directory.Exists(sourceDirectoryPath))
            {
                Directory.Delete(sourceDirectoryPath, true);
            }
            string targetDirectoryPath = Path.Combine(_localDirectoryPath, targetContainerName);
            if (Directory.Exists(targetDirectoryPath))
            {
                Directory.Delete(targetDirectoryPath, true);
            }
            if (!await azureStorage.ContainerExistsAsync(sourceContainerName))
            {
                sourceDirectoryPath = _dirHelper.CreateDirectoryWithTempData(sourceDirectoryPath); 
                _ = await azureStorage.UploadDirectoryAsync(sourceDirectoryPath, targetContainerName);
                //add some files so containers do not match
                for (int i = 0; i < 3; i++)
                {
                    string fileName = $"deleteme_{i}.txt";
                    FileHelper fileHelper = new(targetDirectoryPath);
                    fileHelper.CreateFile(1024, fileName);
                    FileInfo fileInfo = new(Path.Combine(targetDirectoryPath, fileName));
                    await azureStorage.UploadFileAsync(fileInfo, MimeTypes.txt, targetContainerName);
                }

            } 

            IDirectoryToContainerSyncHelper directorySyncHelper = new DirectoryToContainerSyncHelper(azureStorage);
            var response = await directorySyncHelper.GetBlobUrlListExistInTargetButNotInSourceAsync(sourceDirectoryPath, targetContainerName);
            Assert.IsNotNull(response.blobUrls);
            Assert.IsTrue(response.blobUrls.Count == 3);

        }

        [ClassCleanup]
        public static void ClassCleanup()
        {
            var containers = _storage.GetContainersAsync().Result;
            foreach (BlobContainerItem container in containers)
            {
                var deleted = _storage.DeleteAsync(container.Name).Result;
                Assert.IsTrue(deleted);
            }
            //Delete temp directory
            if (Directory.Exists(_localDirectoryPath))
                Directory.Delete(_localDirectoryPath, true);
            Console.WriteLine("AzureStorageTestInit Cleanup");
        }


        [AssemblyCleanup]
        public static void AssemblyCleanup()
        {
            Console.WriteLine("Assembly Cleanup");
        }

    }
}