using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Net; using c3stream.DataModels; using c3stream.Pages; using LinqToDB.Common; using LinqToDB.Data; using Microsoft.AspNetCore.Hosting; using Microsoft.AspNetCore.Http; using Microsoft.Extensions.Hosting; namespace c3stream { public static class c3stream { public const string DataPath = "data"; public const string DbFile = "c3stream.sqlite"; public const string CachePath = "/mnt/storage/archive/Video/congress/"; public const string CacheUrl = "https://c3stream-mirror.zotan.services/"; public static object Lock = new(); public static string DbPath = Path.Combine(DataPath, DbFile); public static readonly List Conferences = new() { new ConferenceObject("rc3", true), new ConferenceObject("36c3"), new ConferenceObject("camp2019"), new ConferenceObject("gpn19"), new ConferenceObject("35c3"), new ConferenceObject("34c3"), new ConferenceObject("33c3"), new ConferenceObject("32c3"), new ConferenceObject("31c3"), new ConferenceObject("30c3") }; public static void Main(string[] args) { if (!Directory.Exists(DataPath)) Directory.CreateDirectory(DataPath); if (!File.Exists(DbPath)) File.Copy(Path.Combine(DataPath, "database.init.sqlite"), DbPath); DataConnection.DefaultSettings = new Database.Settings(); foreach (var conference in Conferences) UpdateConference(conference); if (args.Length != 0) { if (args[0] == "logo") foreach (var conference in Conferences) { Console.WriteLine($"wget {conference.LogoUri} -O {Path.Combine(CachePath, conference.Acronym, "logo.png")}"); } else if (Conferences.All(p => p.Acronym != args[0])) Console.WriteLine("No matching conference found."); else foreach (var talk in Conferences.First(p => p.Acronym == args[0]).Talks) Console.WriteLine($"youtube-dl -f \"best[ext = mp4]\" {talk.FrontendLink} -o \"{Path.Combine(CachePath, args[0], talk.Slug)}.mp4\""); } else { CreateHostBuilder(args).Build().Run(); } } //TODO: move this to the database as well public static void UpdateConference(ConferenceObject conference) { using var wc = new WebClient(); var jsonpath = Path.Combine(DataPath, conference.Acronym + "_index.json"); var json = ""; if (!File.Exists(jsonpath)) { json = wc.DownloadString($"https://api.media.ccc.de/public/conferences/{conference.Acronym}"); File.WriteAllText(jsonpath, json); } else if (conference.Ongoing) { json = wc.DownloadString($"https://api.media.ccc.de/public/conferences/{conference.Acronym}"); } else { json = File.ReadAllText(jsonpath); } var parsed = Conference.FromJson(json); lock (Lock) { conference.Talks.Clear(); conference.LogoUri = parsed.LogoUrl.AbsoluteUri; conference.Talks.AddRange(parsed.Events); conference.Talks.ForEach(p => p.Guid = p.Guid.Trim()); } } public static string UpdateCookie(HttpRequest request, HttpResponse response, string redirectUri) { var cookie = ""; //if new bookmark is in uri if (request.Query.ContainsKey("bookmark") && Guid.TryParseExact(request.Query["bookmark"], "D", out _)) { response.Cookies.Append("bookmark", request.Query["bookmark"], new CookieOptions {Expires = DateTimeOffset.MaxValue}); cookie = request.Query["bookmark"]; } //if no cookie exists or cookie is invalid else if (!request.Cookies.ContainsKey("bookmark") || !Guid.TryParseExact(request.Cookies["bookmark"], "D", out _)) { var guid = Guid.NewGuid().ToString(); response.Cookies.Append("bookmark", guid, new CookieOptions {Expires = DateTimeOffset.MaxValue}); cookie = guid; } else { cookie = request.Cookies["bookmark"]; } if (request.Query.ContainsKey("bookmark")) { response.Redirect(redirectUri); } return cookie; } public static Event GetEventByGuid(string guid) { return Conferences.SelectMany(c => c.Talks.Where(talk => talk.Guid.ToString() == guid)).FirstOrDefault(); } public static ConferenceObject GetConferenceByEventGuid(string guid) { return Conferences.FirstOrDefault(c => c.Talks.Any(t => t.Guid.ToString() == guid)); } public static IHostBuilder CreateHostBuilder(string[] args) => Host.CreateDefaultBuilder(args).ConfigureWebHostDefaults(webBuilder => { webBuilder.UseStartup(); }); public class ConferenceObject { public string Acronym; public bool Ongoing; public string LogoUri; public List Talks = new(); public ConferenceObject(string acronym, bool ongoing = false) { Acronym = acronym; Ongoing = ongoing; } } } }