How to use BlobContainer class of PetImages.Storage package

Best Coyote code snippet using PetImages.Storage.BlobContainer

ImageController.cs

Source:ImageController.cs

...15    public class ImageController : ControllerBase16    {17        private readonly ICosmosContainer AccountContainer;18        private readonly ICosmosContainer ImageContainer;19        private readonly IBlobContainer BlobContainer;20        private readonly IMessagingClient MessagingClient;21        public ImageController(ICosmosContainer accountContainer, ICosmosContainer imageContainer,22            IBlobContainer blobContainer, IMessagingClient messagingClient)23        {24            this.AccountContainer = accountContainer;25            this.ImageContainer = imageContainer;26            this.BlobContainer = blobContainer;27            this.MessagingClient = messagingClient;28        }29        /// <summary>30        /// Scenario 2 - Buggy CreateImageAsync version.31        /// </summary>32        [HttpPost]33        public async Task<ActionResult<Image>> CreateImageAsync(string accountName, Image image)34        {35            if (!await StorageHelper.DoesItemExist<AccountItem>(this.AccountContainer, partitionKey: accountName, id: accountName))36            {37                return this.NotFound();38            }39            var imageItem = image.ToItem();40            // We upload the image to Azure Storage, before adding an entry to Cosmos DB41            // so that it is guaranteed to be there when user does a GET request.42            // Note: we're calling CreateOrUpdateBlobAsync because Azure Storage doesn't43            // have a create-only API.44            await this.BlobContainer.CreateContainerIfNotExistsAsync(accountName);45            await this.BlobContainer.CreateOrUpdateBlobAsync(accountName, image.Name, image.Content);46            try47            {48                imageItem = await this.ImageContainer.CreateItem(imageItem);49            }50            catch (DatabaseItemAlreadyExistsException)51            {52                return this.Conflict();53            }54            catch (DatabaseException)55            {56                // We handle an exception thrown by Cosmos DB layer, perhaps due to some57                // intermittent failure, by cleaning up the image to not waste resources.58                await this.BlobContainer.DeleteBlobIfExistsAsync(accountName, image.Name);59                return this.StatusCode(503);60            }61            return this.Ok(imageItem.ToImage());62        }63        /// <summary>64        /// Scenario 2 - Fixed CreateImageAsync version.65        /// </summary>66        [HttpPost]67        public async Task<ActionResult<Image>> CreateImageAsyncFixed(string accountName, Image image)68        {69            if (!await StorageHelper.DoesItemExist<AccountItem>(this.AccountContainer, partitionKey: accountName, id: accountName))70            {71                return this.NotFound();72            }73            var imageItem = image.ToItem();74            await this.BlobContainer.CreateContainerIfNotExistsAsync(accountName);75            await this.BlobContainer.CreateOrUpdateBlobAsync(accountName, image.Name, image.Content);76            try77            {78                imageItem = await this.ImageContainer.CreateItem(imageItem);79            }80            catch (DatabaseItemAlreadyExistsException)81            {82                return this.Conflict();83            }84            // We don't delete the blob in the controller; orphaned blobs (i.e., blobs with no corresponding85            // Cosmos DB entry) are cleaned up asynchronously by a background "garbage collector" worker86            // (not shown in this sample).87            return this.Ok(imageItem.ToImage());88        }89        [HttpGet]90        public async Task<ActionResult<byte[]>> GetImageContentsAsync(string accountName, string imageName)91        {92            if (!await StorageHelper.DoesItemExist<AccountItem>(this.AccountContainer, partitionKey: accountName, id: accountName))93            {94                return this.NotFound();95            }96            ImageItem imageItem;97            try98            {99                imageItem = await this.ImageContainer.GetItem<ImageItem>(partitionKey: imageName, id: imageName);100            }101            catch (DatabaseItemDoesNotExistException)102            {103                return this.NotFound();104            }105            if (!await this.BlobContainer.ExistsBlobAsync(accountName, imageItem.StorageName))106            {107                return this.NotFound();108            }109            return this.Ok(await this.BlobContainer.GetBlobAsync(accountName, imageItem.StorageName));110        }111        [HttpGet]112        public async Task<ActionResult<byte[]>> GetImageThumbnailAsync(string accountName, string imageName)113        {114            if (!await StorageHelper.DoesItemExist<AccountItem>(this.AccountContainer, partitionKey: accountName, id: accountName))115            {116                return this.NotFound();117            }118            ImageItem imageItem;119            try120            {121                imageItem = await this.ImageContainer.GetItem<ImageItem>(partitionKey: imageName, id: imageName);122            }123            catch (DatabaseItemDoesNotExistException)124            {125                return this.NotFound();126            }127            var containerName = accountName + Constants.ThumbnailContainerNameSuffix;128            var blobName = imageItem.StorageName + Constants.ThumbnailSuffix;129            if (!await this.BlobContainer.ExistsBlobAsync(containerName, blobName))130            {131                return this.NotFound();132            }133            return this.Ok(await this.BlobContainer.GetBlobAsync(containerName, blobName));134        }135        /// <summary>136        /// Scenario 3 - Buggy CreateOrUpdateImageAsync version.137        /// </summary>138        [HttpPut]139        public async Task<ActionResult<Image>> CreateOrUpdateImageAsync(string accountName, Image image)140        {141            if (!await StorageHelper.DoesItemExist<AccountItem>(this.AccountContainer, partitionKey: accountName, id: accountName))142            {143                return this.NotFound();144            }145            var imageItem = image.ToItem();146            await this.BlobContainer.CreateContainerIfNotExistsAsync(accountName);147            await this.BlobContainer.CreateOrUpdateBlobAsync(accountName, image.Name, image.Content);148            imageItem = await this.ImageContainer.UpsertItem(imageItem);149            await this.MessagingClient.SubmitMessage(new GenerateThumbnailMessage()150            {151                AccountName = accountName,152                ImageStorageName = image.Name153            });154            return this.Ok(imageItem.ToImage());155        }156        /// <summary>157        /// Scenario 3 - Fixed CreateOrUpdateImageAsync version.158        /// </summary>159        [HttpPut]160        public async Task<ActionResult<Image>> CreateOrUpdateImageAsyncFixed(string accountName, Image image)161        {162            if (!await StorageHelper.DoesItemExist<AccountItem>(this.AccountContainer, partitionKey: accountName, id: accountName))163            {164                return this.NotFound();165            }166            var imageItem = image.ToItem();167            var uniqueId = Guid.NewGuid().ToString();168            imageItem.StorageName = uniqueId;169            await this.BlobContainer.CreateContainerIfNotExistsAsync(accountName);170            await this.BlobContainer.CreateOrUpdateBlobAsync(accountName, imageItem.StorageName, image.Content);171            imageItem = await this.ImageContainer.UpsertItem(imageItem);172            await this.MessagingClient.SubmitMessage(new GenerateThumbnailMessage()173            {174                AccountName = accountName,175                ImageStorageName = imageItem.StorageName176            });177            return this.Ok(imageItem.ToImage());178        }179    }180}...

TestPetImagesClient.cs

Source:TestPetImagesClient.cs

...14    public class TestPetImagesClient : IPetImagesClient15    {16        private readonly ICosmosContainer AccountContainer;17        private readonly ICosmosContainer ImageContainer;18        private readonly IBlobContainer BlobContainer;19        private readonly IMessagingClient MessagingClient;20        public TestPetImagesClient(ICosmosContainer accountContainer)21        {22            this.AccountContainer = accountContainer;23        }24        public TestPetImagesClient(ICosmosContainer accountContainer, ICosmosContainer imageContainer, IBlobContainer blobContainer)25        {26            this.AccountContainer = accountContainer;27            this.ImageContainer = imageContainer;28            this.BlobContainer = blobContainer;29        }30        public TestPetImagesClient(ICosmosContainer accountContainer, ICosmosContainer imageContainer,31            IBlobContainer blobContainer, IMessagingClient messagingClient)32        {33            this.AccountContainer = accountContainer;34            this.ImageContainer = imageContainer;35            this.BlobContainer = blobContainer;36            this.MessagingClient = messagingClient;37        }38        public async Task<ServiceResponse<Account>> CreateAccountAsync(Account account)39        {40            var accountCopy = TestHelper.Clone(account);41            return await Task.Run(async () =>42            {43                var controller = new AccountController(this.AccountContainer);44                var actionResult = await InvokeControllerAction(async () => await controller.CreateAccountAsync(accountCopy));45                return ExtractServiceResponse<Account>(actionResult.Result);46            });47        }48        public async Task<ServiceResponse<Image>> CreateImageAsync(string accountName, Image image)49        {50            var imageCopy = TestHelper.Clone(image);51            return await Task.Run(async () =>52            {53                var controller = new ImageController(this.AccountContainer, this.ImageContainer, this.BlobContainer, this.MessagingClient);54                var actionResult = await InvokeControllerAction(async () => await controller.CreateImageAsync(accountName, imageCopy));55                return ExtractServiceResponse<Image>(actionResult.Result);56            });57        }58        public async Task<ServiceResponse<Image>> CreateOrUpdateImageAsync(string accountName, Image image)59        {60            var imageCopy = TestHelper.Clone(image);61            return await Task.Run(async () =>62            {63                var controller = new ImageController(this.AccountContainer, this.ImageContainer, this.BlobContainer, this.MessagingClient);64                var actionResult = await InvokeControllerAction(async () => await controller.CreateOrUpdateImageAsync(accountName, imageCopy));65                return ExtractServiceResponse<Image>(actionResult.Result);66            });67        }68        public async Task<ServiceResponse<byte[]>> GetImageAsync(string accountName, string imageName)69        {70            return await Task.Run(async () =>71            {72                var controller = new ImageController(this.AccountContainer, this.ImageContainer, this.BlobContainer, this.MessagingClient);73                var actionResult = await InvokeControllerAction(async () => await controller.GetImageContentsAsync(accountName, imageName));74                return ExtractServiceResponse<byte[]>(actionResult.Result);75            });76        }77        public async Task<ServiceResponse<byte[]>> GetImageThumbnailAsync(string accountName, string imageName)78        {79            return await Task.Run(async () =>80            {81                var controller = new ImageController(this.AccountContainer, this.ImageContainer, this.BlobContainer, this.MessagingClient);82                var actionResult = await InvokeControllerAction(async () => await controller.GetImageThumbnailAsync(accountName, imageName));83                return ExtractServiceResponse<byte[]>(actionResult.Result);84            });85        }86        /// <summary>87        /// Simulate middleware by wrapping invocation of controller in exception handling88        /// code which runs in middleware in production.89        /// </summary>90        private static async Task<ActionResult<T>> InvokeControllerAction<T>(Func<Task<ActionResult<T>>> lambda)91        {92            try93            {94                return await lambda();95            }...

GenerateThumbnailWorker.cs

Source:GenerateThumbnailWorker.cs

...6namespace PetImages.Worker7{8    public class GenerateThumbnailWorker : IWorker9    {10        private readonly IBlobContainer BlobContainer;11        public GenerateThumbnailWorker(12            IBlobContainer imageBlobContainer)13        {14            this.BlobContainer = imageBlobContainer;15        }16        public async Task ProcessMessage(Message message)17        {18            var thumbnailMessage = (GenerateThumbnailMessage)message;19            var accountName = thumbnailMessage.AccountName;20            var imageStorageName = thumbnailMessage.ImageStorageName;21            var imageContents = await this.BlobContainer.GetBlobAsync(accountName, imageStorageName);22            var thumbnail = GenerateThumbnail(imageContents);23            var containerName = accountName + Constants.ThumbnailContainerNameSuffix;24            var blobName = imageStorageName + Constants.ThumbnailSuffix;25            await this.BlobContainer.CreateContainerIfNotExistsAsync(containerName);26            await this.BlobContainer.CreateOrUpdateBlobAsync(containerName, blobName, thumbnail);27        }28        /// <summary>29        /// Dummy implementation of GenerateThumbnail that returns the same bytes as the image.30        /// </summary>31        private static byte[] GenerateThumbnail(byte[] imageContents) => imageContents;32    }33}...

BlobContainer

Using AI Code Generation

1using PetImages.Storage;2using System;3using System.Threading.Tasks;4{5    {6        static void Main(string[] args)7        {8            Console.WriteLine("Hello World!");9            Console.ReadLine();10        }11    }12}13using PetImages.Storage;14using System;15using System.Threading.Tasks;16{17    {18        static void Main(string[] args)19        {20            Console.WriteLine("Hello World!");21            Console.ReadLine();22        }23    }24}25using PetImages.Storage;26using System;27using System.Threading.Tasks;28{29    {30        static void Main(string[] args)31        {32            Console.WriteLine("Hello World!");33            Console.ReadLine();34        }35    }36}37using PetImages.Storage;38using System;39using System.Threading.Tasks;40{41    {42        static void Main(string[] args)43        {44            Console.WriteLine("Hello World!");45            Console.ReadLine();46        }47    }48}49using PetImages.Storage;50using System;51using System.Threading.Tasks;52{53    {54        static void Main(string[] args)55        {56            Console.WriteLine("Hello World!");57            Console.ReadLine();58        }59    }60}61using PetImages.Storage;62using System;63using System.Threading.Tasks;64{65    {66        static void Main(string[] args)67        {68            Console.WriteLine("Hello World!");69            Console.ReadLine();70        }71    }72}73using PetImages.Storage;74using System;75using System.Threading.Tasks;76{77    {78        static void Main(string[] args)79        {80            Console.WriteLine("Hello World!");81            Console.ReadLine();82        }83    }84}85using PetImages.Storage;86using System;

BlobContainer

Using AI Code Generation

1using PetImages.Storage;2var blobContainer = new BlobContainer("myConnectionString", "myContainerName");3using PetImages.Storage;4var blobContainer = new BlobContainer("myConnectionString", "myContainerName");5using PetImages.Storage;6var blobContainer = new BlobContainer("myConnectionString", "myContainerName");7using PetImages.Storage;8var blobContainer = new BlobContainer("myConnectionString", "myContainerName");9using PetImages.Storage;10var blobContainer = new BlobContainer("myConnectionString", "myContainerName");11using PetImages.Storage;12var blobContainer = new BlobContainer("myConnectionString", "myContainerName");13using PetImages.Storage;14var blobContainer = new BlobContainer("myConnectionString", "myContainerName");15using PetImages.Storage;16var blobContainer = new BlobContainer("myConnectionString", "myContainerName");17using PetImages.Storage;18var blobContainer = new BlobContainer("myConnectionString", "myContainerName");19using PetImages.Storage;20var blobContainer = new BlobContainer("myConnectionString", "myContainerName");21using PetImages.Storage;22var blobContainer = new BlobContainer("myConnectionString", "myContainerName");23using PetImages.Storage;24var blobContainer = new BlobContainer("myConnectionString", "myContainerName");

BlobContainer

Using AI Code Generation

1var container = new BlobContainer("connectionString", "containerName");2var container = new BlobContainer("connectionString", "containerName");3var container = new BlobContainer("connectionString", "containerName");4var container = new BlobContainer("connectionString", "containerName");5var container = new BlobContainer("connectionString", "containerName");6var container = new BlobContainer("connectionString", "containerName");7var container = new BlobContainer("connectionString", "containerName");8var container = new BlobContainer("connectionString", "containerName");9var container = new BlobContainer("connectionString", "containerName");10var container = new BlobContainer("connectionString", "containerName");11var container = new BlobContainer("connectionString", "containerName");12var container = new BlobContainer("connectionString", "containerName");13var container = new BlobContainer("connectionString", "containerName");14var container = new BlobContainer("connectionString", "containerName");15var container = new BlobContainer("connectionString", "containerName");

BlobContainer

Using AI Code Generation

1using PetImages.Storage;2{3    {4        public BlobContainer()5        {6            var container = new BlobContainer();7        }8    }9}10using PetImages.Storage;11{12    {13        public BlobContainer()14        {15            var container = new BlobContainer();16        }17    }18}19using PetImages.Storage;20{21    {22        public BlobContainer()23        {24            var container = new PetImages.Storage.BlobContainer();25        }26    }27}28using PetImages.Storage;29{30    {31        public BlobContainer()32        {33            var container = new PetImages.Storage.BlobContainer();34        }35    }36}

BlobContainer

Using AI Code Generation

1using PetImages.Storage;2{3    {4        public BlobContainer(string connectionString)5        {6        }7    }8}9using PetImages.Storage;10{11    {12        public BlobContainer(string connectionString)13        {14        }15    }16}17using PetImages.Storage;18{19    {20        public BlobContainer(string connectionString)21        {22        }23    }24}25using PetImages.Storage;26{27    {28        public BlobContainer(string connectionString)29        {30        }31    }32}33using PetImages.Storage;34{35    {36        public BlobContainer(string connectionString)37        {38        }39    }40}41using PetImages.Storage;42{43    {44        public BlobContainer(string connectionString)45        {46        }47    }48}49using PetImages.Storage;50{51    {52        public BlobContainer(string connectionString)53        {54        }55    }56}57using PetImages.Storage;58{59    {60        public BlobContainer(string connectionString)61        {62        }63    }64}65using PetImages.Storage;66{

BlobContainer

Using AI Code Generation

1using PetImages.Storage;2using PetImages.Storage.Models;3{4    {5        public async Task UploadImage(Image image)6        {7        }8    }9}10using PetImages.Storage;11using PetImages.Storage.Models;12{13    {14        public async Task UploadImage(Image image)15        {16        }17    }18}19using PetImages.Storage;20using PetImages.Storage.Models;21{22    {23        public async Task UploadImage(Image image)24        {25        }26    }27}

BlobContainer

Using AI Code Generation

1public void Foo()2{3    var blobContainer = new BlobContainer("foo", "bar");4    blobContainer.Upload("file1.txt", "content1");5    blobContainer.Upload("file2.txt", "content2");6}7public void Foo()8{9    var blobContainer = new BlobContainer("foo", "bar");10    blobContainer.Upload("file1.txt", "content1");11    blobContainer.Upload("file2.txt", "content2");12}13public void Foo()14{15    var blobContainer = new BlobContainer("foo", "bar");16    blobContainer.Upload("file1.txt", "content1");17    blobContainer.Upload("file2.txt", "content2");18}19public void Foo()20{21    var blobContainer = new BlobContainer("foo", "bar");22    blobContainer.Upload("file1.txt", "content1");23    blobContainer.Upload("file2.txt", "content2");24}25public void Foo()26{27    var blobContainer = new BlobContainer("foo", "bar");28    blobContainer.Upload("file1.txt", "content1");29    blobContainer.Upload("file2.txt", "content2");30}31public void Foo()32{33    var blobContainer = new BlobContainer("foo", "bar");34    blobContainer.Upload("file1.txt", "content1");35    blobContainer.Upload("file2.txt", "content2");36}37public void Foo()38{39    var blobContainer = new BlobContainer("foo", "bar");40    blobContainer.Upload("file1.txt", "content1");41    blobContainer.Upload("file2.txt", "content2");42}43public void Foo()44{45    var blobContainer = new BlobContainer("foo", "bar");46    blobContainer.Upload("file1.txt", "content1");

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.