bryanwilhite / songhay.cloud.blobstorage Goto Github PK

internal async Task<IEnumerable<string>> GetYouTubeChannelBlobsAsync(string blobContainerChannelsPath, Func<IListBlobItem, bool> filter)
{
    this.CheckProgramMetadata();

    traceSource?.WriteLine($"{nameof(GetYouTubeChannelBlobsAsync)} getting channel BLOBs...");

    if (filter == null) filter = i => true;

    var blobs = await this._container
        .ListBlobsAsync(useFlatBlobListing: true, pageLimit: 5, rootPath: blobContainerChannelsPath);

    var tasks = blobs.Where(filter).Select(i => (i as ICloudBlob).ToStringFromBlobAsync());

    await Task.WhenAll(tasks);

    traceSource?.WriteLine($"{nameof(GetYouTubeChannelBlobsAsync)} downloaded {tasks.Count()} BLOBs.");

    return tasks.Select(i => i.Result);
}

var blobs = await this._container.ListBlobsAsync(useFlatBlobListing: false, pageLimit: 5, rootPath: blobContainerChannelsPath);

internal async Task<JObject> DownloadBlobAsync(string blobName)
{
    var blob = this._container.GetBlockBlobReference(blobName);
    var json = await blob.ToStringFromBlobAsync();
    return JObject.Parse(json);
}

internal async Task UploadBlobAsync(JObject jObject, string blobName)
{
    var blob = this._container.GetBlockBlobReference(blobName);
    blob.Properties.ContentType = MimeTypes.ApplicationJson;
    traceSource?.TraceVerbose($"Uploading {blobName}...");
    await blob.UploadTextAsync(jObject.ToString());
}

public static CloudStorageAccount ToCloudStorageAccount(this ConfigurationBuilder builder, string basePath, string connectionStringName)
{
    if (builder == null) throw new NullReferenceException("The expected Configuration builder is not here.");
    if (!Directory.Exists(basePath)) throw new DirectoryNotFoundException("The expected configuration base path is not here.");

    builder
        .SetBasePath(basePath)
        .AddJsonFile(AppScalars.conventionalSettingsFile, optional: false, reloadOnChange: true);

    var meta = new ProgramMetadata();
    builder.Build().Bind(nameof(ProgramMetadata), meta);

    if (meta.CloudStorageSet == null) throw new NullReferenceException("The expected cloud storage set is not here.");

    var key = AppScalars.cloudStorageSetName;
    var test = meta.CloudStorageSet.TryGetValue(key, out var set);
    if (!test) throw new NullReferenceException($"The expected cloud storage set, {key}, is not here.");
    if (!set.Any()) throw new NullReferenceException($"The expected cloud storage set items for {key} are not here.");

    test = set.TryGetValue(connectionStringName, out var connectionString);
    if (!test) throw new NullReferenceException($"The expected cloud storage set connection, {connectionStringName}, is not here.");

    var cloudStorageAccount = CloudStorageAccount.Parse(connectionString);
    return cloudStorageAccount;
}