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
138
139
140
|
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.Where(c => c.StartDateTime >= DateTime.Now).ToList());
app.MapGet("tz", () => TimeZoneInfo.Local.Id);
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 required string Title { get; set; }
public required string Scene { get; set; }
public required DateTime StartDateTime { get; set; }
public required string TicketUrl { get; set; }
public required string Type { get; set; }
public required string MovieVersion { get; set; }
public required string MovieMainVersion { get; set; }
public required string[] Tags { get; set; }
}
class DataWorker(IServiceScopeFactory serviceScopeFactory) : BackgroundService
{
protected override async Task ExecuteAsync(CancellationToken stoppingToken) {
const int interval = 1000 * 60 * 60;
while (!stoppingToken.IsCancellationRequested) {
try {
await Work(stoppingToken);
await Task.Delay(interval, stoppingToken);
} catch (Exception e) {
Console.WriteLine(e);
}
}
}
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) {
File.Copy("data/main.db", $"data/main-{Random.Shared.Next(10000)}.db");
db.Shows.RemoveRange(db.Shows);
await db.SaveChangesAsync(ct);
}
var count = await db.Shows.CountAsync(ct);
foreach (var show in shows?.Shows ?? []) {
if (string.IsNullOrWhiteSpace(show.TicketSaleUrl)) continue;
var existing = await db.Shows.AnyAsync(s => s.Title == show.MovieTitle && s.StartDateTime == show.ShowStart, ct);
if (existing) continue;
logger.LogInformation("Adding show {Title} at {StartDateTime}", show.MovieTitle, show.ShowStart);
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 required List<VegaShow> Shows { get; set; }
}
class VegaShow
{
[JsonPropertyName("screenName")]
public required string ScreenName { get; set; }
[JsonPropertyName("ticketSaleUrl")]
public required string TicketSaleUrl { get; set; }
[JsonPropertyName("showType")]
public required string ShowType { get; set; }
[JsonPropertyName("showStart")]
public required DateTime ShowStart { get; set; }
[JsonPropertyName("movieVersionId")]
public required string MovieVersionId { get; set; }
[JsonPropertyName("movieMainVersionId")]
public required string MovieMainVersionId { get; set; }
[JsonPropertyName("movieTitle")]
public required string MovieTitle { get; set; }
[JsonPropertyName("versionTags")]
public required VersionTag[] VersionTags { get; set; }
}
public class VersionTag
{
[JsonPropertyName("tag")]
public required string Tag { get; set; }
}
}
|
