StorageMethods.csx

#r "System.Runtime"

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO;
using Microsoft.WindowsAzure;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Blob;
using Microsoft.WindowsAzure.Storage.Queue;
using System.Diagnostics;
using System.Configuration;

public const string receiptBlobName = "receipts";
public const string imageDirectoryName = "images";
public static CloudBlobClient blobClient { get; set; }
public static CloudBlobContainer blobContainer { get; set; }
public static CloudStorageAccount storageAccount { get { return CloudStorageAccount.Parse(ConfigurationManager.AppSettings["contosofinancestorage"]); } }

static string GetImage(string fileName)
{
    // Create the blob client.
    blobClient = storageAccount.CreateCloudBlobClient();

    // Retrieve a reference to a container.
    blobContainer = blobClient.GetContainerReference(imageDirectoryName);

    // Create the container if it doesn't already exist.
    blobContainer.CreateIfNotExists(BlobContainerPublicAccessType.Blob);

    CloudBlockBlob blockBlob = blobContainer.GetBlockBlobReference(fileName);
    string filePath = Path.Combine(Path.GetTempPath(), fileName);
    if (!File.Exists(filePath))
        blockBlob.DownloadToFile(filePath, FileMode.OpenOrCreate);
    return filePath;

}


/// <summary>
/// Upload the generated receipt Pdf to Blob storage.
/// </summary>
/// <param name="file">Byte array containig the Pdf file contents to be uploaded.</param>
/// <param name="fileName">The desired filename of the uploaded file.</param>
/// <returns></returns>
public static string UploadPdfToBlob(byte[] file, string fileName, TraceWriter log)
{
    log.Info("Hit Upload");
    // Create the blob client.
    blobClient = storageAccount.CreateCloudBlobClient();

    // Retrieve a reference to a container.
    blobContainer = blobClient.GetContainerReference(receiptBlobName);

    // Create the container if it doesn't already exist - private.
    blobContainer.CreateIfNotExists(BlobContainerPublicAccessType.Off);

    string fileUri = string.Empty;

    CloudBlockBlob blockBlob = blobContainer.GetBlockBlobReference(fileName);

    using (var stream = new MemoryStream(file))
    {
        // Upload the in-memory Pdf file to blob storage.
        blockBlob.UploadFromStream(stream);
    }

    // Get a SAS URL to use to read the doc from.
    SharedAccessBlobPolicy readPolicy = new SharedAccessBlobPolicy()
    {
        SharedAccessExpiryTime = DateTime.UtcNow.AddYears(7),
        Permissions = SharedAccessBlobPermissions.Read
    };

    fileUri = blockBlob.Uri.ToString() + blockBlob.GetSharedAccessSignature(readPolicy);
    log.Info($"Using fileUri {fileUri}");
    return fileUri;
}

/// <summary>
/// Grabs the next pending queue message containing the next order
/// whose receipt we need to generate.
/// </summary>
/// <returns></returns>
public async Task<int> GetOrderIdFromQueue()
{
    int orderId = 0;

    // Create the queue client.
    CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

    // Retrieve a reference to a queue.
    CloudQueue queue = queueClient.GetQueueReference("receiptgenerator");

    // Create the queue if it doesn't already exist.
    if (await queue.CreateIfNotExistsAsync())
    {
        Console.WriteLine("Queue '{0}' Created", queue.Name);
    }
    else
    {
        Console.WriteLine("Queue '{0}' Exists", queue.Name);
    }

    // Get the next message.
    CloudQueueMessage retrievedMessage = await queue.GetMessageAsync();

    if (retrievedMessage != null)
    {
        Trace.TraceInformation("Retrieved Queue Message: " + retrievedMessage.AsString);
        // Process the message in less than 30 seconds, and then delete the message.
        await queue.DeleteMessageAsync(retrievedMessage);
        int.TryParse(retrievedMessage.AsString, out orderId);
    }

    return orderId;
}