dcb3637cca
LayoutStore.cs 1402 -> 47-line shell + 5 partials, grouped by functionality (line count is a consequence, not the goal): - LayoutStore.Migrations.cs: all DB schema migration (EnsureSchema, GetUserVersion, MigrateSourceTable/WebcamConfigTable/ToV3/SceneTable/SceneSocialBarColumn/ SocialsTable/SocialEntryTable) - LayoutStore.Load.cs: Load() scene/source read-back - LayoutStore.Save.cs: Save() full scene tree write - LayoutStore.Settings.cs: key/value settings + mic/record-folder/reusable-stream + license/transition/broadcast/hotkey/window-state GetSetting/UpsertSetting - LayoutStore.Assets.cs: GetAssetBytes/UpsertAsset blob IO - LayoutStore.cs: shell — Instance, fields, ctor, Dispose Converted to public partial class LayoutStore : IDisposable. Pruned per-file dead usings. Phase 3 DOWN: no production .cs exceeds 500 lines. Zero behavior change; build 0 warnings; 246 pass, only the 2 known failures. Docs: ViewModels/index.md Phase 3 tracker updated in same commit.
293 lines
12 KiB
C#
293 lines
12 KiB
C#
using Microsoft.Data.Sqlite;
|
|
using ytLive.Models;
|
|
|
|
namespace ytLive.Services;
|
|
|
|
public partial class LayoutStore : IDisposable
|
|
{
|
|
/// <summary>The last picked mic source name, or null if never chosen. Restored
|
|
/// at startup so the sound bar reconnects to the same, already-vetted device.</summary>
|
|
public string? LoadMicSourceName()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'MicSourceName';";
|
|
var value = cmd.ExecuteScalar() as string;
|
|
return string.IsNullOrWhiteSpace(value) ? null : value;
|
|
}
|
|
|
|
public void SaveMicSourceName(string? name)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = 'MicSourceName';";
|
|
cmd.ExecuteNonQuery();
|
|
if (string.IsNullOrWhiteSpace(name))
|
|
return;
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ('MicSourceName', $name);";
|
|
insert.Parameters.AddWithValue("$name", name);
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
|
|
/// <summary>The user's chosen record output folder (TASK 18), or null to use the
|
|
/// default <c>%APPDATA%\ytLlive\recordings</c>. Restored at startup.</summary>
|
|
public string? LoadRecordFolder()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'RecordFolder';";
|
|
var value = cmd.ExecuteScalar() as string;
|
|
return string.IsNullOrWhiteSpace(value) ? null : value;
|
|
}
|
|
|
|
public void SaveRecordFolder(string? folder)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = 'RecordFolder';";
|
|
cmd.ExecuteNonQuery();
|
|
if (string.IsNullOrWhiteSpace(folder))
|
|
return;
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ('RecordFolder', $folder);";
|
|
insert.Parameters.AddWithValue("$folder", folder);
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
|
|
/// <summary>The cached reusable stream (TASK 5), or null if never created.
|
|
/// Survives restarts so the pump has its RTMP URL the moment go-live starts
|
|
/// instead of waiting on the YouTube round-trip.</summary>
|
|
public ReusableStream? LoadReusableStream()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'ReusableStream';";
|
|
var value = cmd.ExecuteScalar() as string;
|
|
if (string.IsNullOrWhiteSpace(value)) return null;
|
|
|
|
var parts = value.Split('\u001F');
|
|
return parts.Length == 3
|
|
? new ReusableStream(parts[0], parts[1], parts[2])
|
|
: null;
|
|
}
|
|
|
|
public void SaveReusableStream(ReusableStream? stream)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = 'ReusableStream';";
|
|
cmd.ExecuteNonQuery();
|
|
if (stream == null) return;
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ('ReusableStream', $value);";
|
|
insert.Parameters.AddWithValue("$value", $"{stream.Id}\u001F{stream.IngestionAddress}\u001F{stream.StreamName}");
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
|
|
public string? LoadLicenseKey()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'LicenseKey';";
|
|
var value = cmd.ExecuteScalar() as string;
|
|
return string.IsNullOrWhiteSpace(value) ? null : value;
|
|
}
|
|
|
|
public void SaveLicenseKey(string? key)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = 'LicenseKey';";
|
|
cmd.ExecuteNonQuery();
|
|
if (string.IsNullOrWhiteSpace(key)) return;
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ('LicenseKey', $value);";
|
|
insert.Parameters.AddWithValue("$value", key);
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
|
|
/// <summary>When the license was last validated online (ISO 8601), or null if never.</summary>
|
|
public DateTime? LoadLicenseValidatedAt()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'LicenseValidatedAt';";
|
|
var value = cmd.ExecuteScalar() as string;
|
|
if (string.IsNullOrWhiteSpace(value)) return null;
|
|
return DateTime.TryParse(value, out var dt) ? dt : null;
|
|
}
|
|
|
|
public void SaveLicenseValidatedAt(DateTime? dt)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = 'LicenseValidatedAt';";
|
|
cmd.ExecuteNonQuery();
|
|
if (dt == null) return;
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ('LicenseValidatedAt', $value);";
|
|
insert.Parameters.AddWithValue("$value", dt.Value.ToString("o"));
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
|
|
/// <summary>Cached premium state (1 = premium, 0 = free). Used for offline
|
|
/// grace period — the app checks online at startup but uses this cached
|
|
/// value when offline.</summary>
|
|
public bool LoadIsPremium()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'IsPremium';";
|
|
var value = cmd.ExecuteScalar() as string;
|
|
return value == "1";
|
|
}
|
|
|
|
public void SaveIsPremium(bool isPremium)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = 'IsPremium';";
|
|
cmd.ExecuteNonQuery();
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ('IsPremium', $value);";
|
|
insert.Parameters.AddWithValue("$value", isPremium ? "1" : "0");
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
|
|
public (string TransitionType, double DurationMs) LoadTransitionSettings()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = 'TransitionType';";
|
|
var type = cmd.ExecuteScalar() as string;
|
|
|
|
using var cmd2 = _connection.CreateCommand();
|
|
cmd2.CommandText = "SELECT Value FROM Settings WHERE Key = 'TransitionDurationMs';";
|
|
var dur = cmd2.ExecuteScalar() as string;
|
|
|
|
return (type ?? "Fade", dur != null && double.TryParse(dur, out var d) ? d : 300);
|
|
}
|
|
|
|
public void SaveTransitionSettings(string transitionType, double durationMs)
|
|
{
|
|
UpsertSetting("TransitionType", transitionType);
|
|
UpsertSetting("TransitionDurationMs", durationMs.ToString("F0"));
|
|
}
|
|
|
|
// ─── Broadcast metadata (broadcast pull-out) + window geometry ───
|
|
|
|
public Models.BroadcastMetadata LoadBroadcastMetadata()
|
|
{
|
|
return new Models.BroadcastMetadata
|
|
{
|
|
Title = GetSetting("Broadcast.Title") ?? string.Empty,
|
|
Description = GetSetting("Broadcast.Description") ?? string.Empty,
|
|
TagsCsv = GetSetting("Broadcast.TagsCsv") ?? string.Empty,
|
|
Visibility = GetSetting("Broadcast.Visibility") ?? "private",
|
|
MadeForKids = GetSetting("Broadcast.MadeForKids") == "1",
|
|
ScheduledStartTime = DateTime.TryParse(GetSetting("Broadcast.ScheduledStartTime"), out var t) ? t : null,
|
|
};
|
|
}
|
|
|
|
public void SaveBroadcastMetadata(Models.BroadcastMetadata meta)
|
|
{
|
|
UpsertSetting("Broadcast.Title", meta.Title);
|
|
UpsertSetting("Broadcast.Description", meta.Description);
|
|
UpsertSetting("Broadcast.TagsCsv", meta.TagsCsv);
|
|
UpsertSetting("Broadcast.Visibility", meta.Visibility);
|
|
UpsertSetting("Broadcast.MadeForKids", meta.MadeForKids ? "1" : "0");
|
|
UpsertSetting("Broadcast.ScheduledStartTime",
|
|
meta.ScheduledStartTime?.ToString("o") ?? string.Empty);
|
|
}
|
|
|
|
// ─── Hotkey bindings (TASK 20 step 2) ───
|
|
|
|
/// <summary>
|
|
/// Load saved hotkey bindings. Returns only entries that have been explicitly
|
|
/// saved — missing HotkeyIds are unbound (not in the returned dictionary).
|
|
/// Caller fills in defaults for any missing entries as needed.
|
|
/// </summary>
|
|
public Dictionary<HotkeyId, HotkeyChord> LoadHotkeyBindings()
|
|
{
|
|
var result = new Dictionary<HotkeyId, HotkeyChord>();
|
|
foreach (HotkeyId id in Enum.GetValues(typeof(HotkeyId)))
|
|
{
|
|
var raw = GetSetting($"Hotkey.{id}");
|
|
if (raw == null) continue; // not saved = unbound
|
|
if (raw == "none") continue; // explicitly unbound
|
|
try
|
|
{
|
|
result[id] = HotkeyChord.ParseStorage(raw);
|
|
}
|
|
catch (FormatException)
|
|
{
|
|
// corrupt entry — skip, will fall back to default
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Save hotkey bindings. Null entries in the dictionary mean "unbound" (stored
|
|
/// as "none"). Only the provided entries are saved; previously saved entries
|
|
/// for HotkeyIds not in the dictionary are deleted.
|
|
/// </summary>
|
|
public void SaveHotkeyBindings(Dictionary<HotkeyId, HotkeyChord?> bindings)
|
|
{
|
|
// Delete all existing hotkey settings first
|
|
foreach (HotkeyId id in Enum.GetValues(typeof(HotkeyId)))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = $key;";
|
|
cmd.Parameters.AddWithValue("$key", $"Hotkey.{id}");
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
// Save the new bindings
|
|
foreach (var (id, chord) in bindings)
|
|
{
|
|
var value = chord?.ToString() ?? "none";
|
|
UpsertSetting($"Hotkey.{id}", value);
|
|
}
|
|
}
|
|
|
|
public (double Left, double Top, double Width, double Height, string State)? LoadWindowState()
|
|
{
|
|
var left = GetSetting("Window.Left");
|
|
var top = GetSetting("Window.Top");
|
|
var width = GetSetting("Window.Width");
|
|
var height = GetSetting("Window.Height");
|
|
var state = GetSetting("Window.State");
|
|
if (left == null || top == null || width == null || height == null) return null;
|
|
if (!double.TryParse(left, out var l) || !double.TryParse(top, out var t) ||
|
|
!double.TryParse(width, out var w) || !double.TryParse(height, out var h))
|
|
return null;
|
|
return (l, t, w, h, state ?? "Normal");
|
|
}
|
|
|
|
public void SaveWindowState(double left, double top, double width, double height, string state)
|
|
{
|
|
UpsertSetting("Window.Left", left.ToString("F0"));
|
|
UpsertSetting("Window.Top", top.ToString("F0"));
|
|
UpsertSetting("Window.Width", width.ToString("F0"));
|
|
UpsertSetting("Window.Height", height.ToString("F0"));
|
|
UpsertSetting("Window.State", state);
|
|
}
|
|
|
|
private string? GetSetting(string key)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Value FROM Settings WHERE Key = $key;";
|
|
cmd.Parameters.AddWithValue("$key", key);
|
|
return cmd.ExecuteScalar() as string;
|
|
}
|
|
|
|
private void UpsertSetting(string key, string value)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "DELETE FROM Settings WHERE Key = $key;";
|
|
cmd.Parameters.AddWithValue("$key", key);
|
|
cmd.ExecuteNonQuery();
|
|
|
|
using var insert = _connection.CreateCommand();
|
|
insert.CommandText = "INSERT INTO Settings (Key, Value) VALUES ($key, $value);";
|
|
insert.Parameters.AddWithValue("$key", key);
|
|
insert.Parameters.AddWithValue("$value", value);
|
|
insert.ExecuteNonQuery();
|
|
}
|
|
}
|