-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathProgram.cs
71 lines (61 loc) · 2.67 KB
/
Program.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
using System;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;
using Microsoft.Azure.Storage;
using Microsoft.Azure.Storage.Blob;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
[assembly: InternalsVisibleTo("PhotoArchiver.Tests")]
namespace PhotoArchiver
{
class Program
{
static async Task Main(string[] args)
{
// configure
var configuration = new ConfigurationBuilder()
.AddJsonFile("appsettings.json", optional: true)
.AddCommandLine(args)
.Build();
// set up services
using var serviceProvider = new ServiceCollection()
.AddLogging(builder => builder
.AddConsole(options =>
{
options.IncludeScopes = false;
})
.SetMinimumLevel(Microsoft.Extensions.Logging.LogLevel.Information)
.AddConfiguration(configuration)
)
.AddSingleton(sp => CloudStorageAccount.Parse(sp.GetService<IOptions<StorageOptions>>().Value.ConnectionString))
.AddSingleton(sp => sp.GetService<CloudStorageAccount>().CreateCloudBlobClient())
.Configure<Options>(configuration)
.Configure<StorageOptions>(configuration.GetSection("Storage"))
.AddSingleton<Archiver>()
.BuildServiceProvider();
// initialize
var archiver = serviceProvider.GetRequiredService<Archiver>();
var options = serviceProvider.GetRequiredService<IOptions<Options>>();
var client = serviceProvider.GetRequiredService<CloudBlobClient>();
var logger = serviceProvider.GetRequiredService<ILogger<Program>>();
logger.LogTrace("Ensure container exists...");
if (await client.GetContainerReference(options.Value.Container).CreateIfNotExistsAsync())
{
logger.LogInformation("Container created.");
}
// start
var result = await archiver.ArchiveAsync(options.Value.Path);
// summarize results
var succeeded = result.Results.Where(r => r.Result.IsSuccessful());
var failed = result.Results.Where(r => !r.Result.IsSuccessful());
Console.WriteLine($"{succeeded.Count()} succeeded, {failed.Count()} failed");
foreach (var f in failed)
{
Console.WriteLine(String.Join('\t', f.Result, f.File.Name));
}
}
}
}