DevelopmentHelpers.Storage.Core 6.0.5

DevelopmentHelpers.Storage.Core

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

Code Example

Following example shows how to use Azure Storage Classes

1. Create IStorage -- IStorage interface has two implementation local & Azure: use any dependency injection container IStorage storage = new AzureStorage(config,logger); or IStorage storage = new FileSystemStorage(config,logger);

2. Create IAzureFileStorage to use FileShare use dependency injection container services.AddAzureStorage(configuration); where configuration is IConfiguration or IAzureFileStorage fileStorage = new AzureFileStorage(AzureFileStorageConfiguration,logger);

3. Use methods available on the interface: e.g: UploadDirectoryAsync(DirectoryInfo directory, string container);

4. To Add in the Web Application

   1. Create Appsettings
      "DevelopmentHelpers": { "AzureConfiguration": { "AccountName": "Account-Name", "AccountKey": "Account-Key", "UseHttps": "True" }, "AzureFileStorageConfiguration": { "ConnectionString": "Connection-String", "ShareName": "Share-Name" } }
   2. Add in the Startup file //Add Azure Storage and make sure required values exists in app settings services.AddAzureStorage(Configuration);
   3. To Use it private readonly IStorage _storage; private readonly IAzureFileStorage _fileStorage; public IndexModel(IStorage storage,IAzureFileStorage fileStorage) { _storage = storage; _fileStorage= fileStorage; }
   4. Added Capability to sync containers, this is useful if you want to sync containers between region
      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); } AzureStorageSyncHelper syncHelper = new(azureStorage, azureStorage); var (Success, _) = await syncHelper.SyncContainersAsync(sourceContainerName, targetContainerName, false, _localDirectoryPath);

5. 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);

6. 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.

API Reference

Tests

Describe and show how to run the tests with code examples. Tests are as follows: AzureTest

/*************************** AzureStorageTest ************************* using Azure.Storage.Blobs.Models; using DevelopmentHelpers.Storage.Core.Helpers; using DevelopmentHelpers.Storage.Core.Implementations.Azure; using DevelopmentHelpers.Storage.Core.Interfaces; using DevelopmentHelpers.Storage.Core.Models; using DevelopmentHelpers.Storage.Core.Tests.Helpers; using Microsoft.Extensions.Logging; using Microsoft.VisualStudio.TestPlatform.Utilities.Helpers; using Microsoft.VisualStudio.TestTools.UnitTesting; using System; 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);
        var 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]
    //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");
    }

}

}

*****************End FileSystemStorage Test/

License

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.