-
Notifications
You must be signed in to change notification settings - Fork 0
/
Program.cs
50 lines (36 loc) · 1.21 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
using BBQueue.Models;
using Microsoft.EntityFrameworkCore;
namespace BBQueue;
public class Program
{
public static void Main(string[] args)
{
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddDbContext<VotesContext>(opt =>
{
opt.UseNpgsql(builder.Configuration.GetConnectionString("Database"));
});
builder.Services.AddSingleton<Queue>();
builder.Services.AddHostedService<Worker>();
var app = builder.Build();
using (var serviceScope = app.Services.CreateScope())
{
var context = serviceScope.ServiceProvider.GetRequiredService<VotesContext>();
if(context.Database.GetPendingMigrations().Any())
{
context.Database.Migrate();
}
}
app.MapPost("/api/votes", async (Vote vote, VotesContext context, Queue q) =>
{
var cont = await context.Contestants.FindAsync(vote.ContestantId);
if (cont is null)
{
return Results.NotFound();
}
q.Publish(vote.ContestantId.ToString());
return Results.Accepted();
});
app.Run();
}
}