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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
using System.Text.Json.Serialization;
using Microsoft.EntityFrameworkCore;
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddHttpClient();
builder.Services.AddDbContext<Database>(o => o.UseSqlite("Data Source=data/main.db"));
builder.Services.AddHostedService<DataWorker>();
var app = builder.Build();
try {
using var scope = app.Services.CreateScope();
scope.ServiceProvider.GetRequiredService<Database>().Database.EnsureCreated();
} catch (Exception e) {
Console.WriteLine(e);
}
app.MapStaticAssets();
app.MapGet("shows", (Database db) => db.Shows);
app.MapGet("/", () => Results.Redirect("/index.html"));
app.Run();
class Database(DbContextOptions<Database> options) : DbContext(options)
{
public DbSet<Show> Shows { get; set; }
protected override void OnModelCreating(ModelBuilder modelBuilder) {
modelBuilder.Entity<Show>().HasIndex(p => new {
p.Title,
p.StartDateTime
})
.IsUnique();
base.OnModelCreating(modelBuilder);
}
}
class Show
{
public int Id { get; set; }
public string Title { get; set; }
public string Scene { get; set; }
public DateTimeOffset StartDateTime { get; set; }
public string TicketUrl { get; set; }
public string Type { get; set; }
public string MovieVersion { get; set; }
public string MovieMainVersion { get; set; }
public string[] Tags { get; set; }
}
class DataWorker(IServiceScopeFactory serviceScopeFactory) : BackgroundService
{
protected override async Task ExecuteAsync(CancellationToken stoppingToken) {
const int hour = 3600 * 60;
while (!stoppingToken.IsCancellationRequested) {
await Work(stoppingToken);
await Task.Delay(hour, stoppingToken);
}
}
async Task Work(CancellationToken ct) {
using var scope = serviceScopeFactory.CreateScope();
var db = scope.ServiceProvider.GetRequiredService<Database>();
var http = scope.ServiceProvider.GetRequiredService<HttpClient>();
var logger = scope.ServiceProvider.GetRequiredService<ILogger<DataWorker>>();
var refreshData = Environment.GetEnvironmentVariable("VEGADATA_REFRESH_DATA") == "1";
logger.LogInformation("Syncing data. refresh:{refreshData}", refreshData);
var shows = await http.GetFromJsonAsync<ShowsResponse>("https://www.vegascene.no/api/program", ct);
var addedCount = 0;
if (refreshData) {
db.Shows.RemoveRange(db.Shows);
await db.SaveChangesAsync(ct);
File.Copy("data/main.db", $"data/main-{DateTime.UnixEpoch}.db");
}
var count = await db.Shows.CountAsync(ct);
foreach (var show in shows?.Shows ?? []) {
var existing = await db.Shows.AnyAsync(s =>
s.Title == show.MovieTitle && s.StartDateTime == show.ShowStart, ct);
if (existing) continue;
db.Shows.Add(new Show() {
Title = show.MovieTitle,
Scene = show.ScreenName,
StartDateTime = show.ShowStart,
MovieMainVersion = show.MovieMainVersionId,
MovieVersion = show.MovieVersionId,
TicketUrl = show.TicketSaleUrl,
Type = show.ShowType,
Tags = show.VersionTags.Select(t => t.Tag).ToArray()
});
addedCount++;
}
await db.SaveChangesAsync(ct);
logger.LogInformation("Synced data, old count:{count}, new count:{addedCount}", count, addedCount);
}
class ShowsResponse
{
public List<VegaShow> Shows { get; set; }
}
class VegaShow
{
[JsonPropertyName("screenName")]
public string ScreenName { get; set; }
[JsonPropertyName("ticketSaleUrl")]
public string TicketSaleUrl { get; set; }
[JsonPropertyName("showType")]
public string ShowType { get; set; }
[JsonPropertyName("showStart")]
public DateTimeOffset ShowStart { get; set; }
[JsonPropertyName("movieVersionId")]
public string MovieVersionId { get; set; }
[JsonPropertyName("movieMainVersionId")]
public string MovieMainVersionId { get; set; }
[JsonPropertyName("movieTitle")]
public string MovieTitle { get; set; }
[JsonPropertyName("versionTags")]
public VersionTag[] VersionTags { get; set; }
}
public class VersionTag
{
[JsonPropertyName("tag")]
public string Tag { get; set; }
[JsonPropertyName("type")]
public string Type { get; set; }
}
}
|
