1324 lines
57 KiB
C#
1324 lines
57 KiB
C#
using System.IO;
|
|
using System.Security.Cryptography;
|
|
using Microsoft.Data.Sqlite;
|
|
using ytLive.Models;
|
|
|
|
namespace ytLive.Services;
|
|
|
|
public class LayoutStore : IDisposable
|
|
{
|
|
public static LayoutStore? Instance { get; private set; }
|
|
|
|
private readonly SqliteConnection _connection;
|
|
public string ActivePath { get; }
|
|
|
|
/// <summary>The app-wide webcam identity loaded with the last Load() (null = never picked).</summary>
|
|
public Webcam? Webcam { get; private set; }
|
|
|
|
/// <summary>The app-wide social bar config loaded with the last Load() (null = never defined).</summary>
|
|
public SocialsConfig? Socials { get; private set; }
|
|
|
|
/// <summary>The app-wide background music (TASK 9 TRAX) loaded with the last
|
|
/// Load() (null = no track chosen).</summary>
|
|
public Music? Music { get; private set; }
|
|
|
|
public LayoutStore(string path)
|
|
{
|
|
ActivePath = path;
|
|
Directory.CreateDirectory(Path.GetDirectoryName(path)!);
|
|
_connection = new SqliteConnection($"Data Source={path}");
|
|
_connection.Open();
|
|
using (var pragma = _connection.CreateCommand())
|
|
{
|
|
pragma.CommandText = "PRAGMA foreign_keys = ON;";
|
|
pragma.ExecuteNonQuery();
|
|
}
|
|
EnsureSchema();
|
|
Instance = this;
|
|
}
|
|
|
|
private void EnsureSchema()
|
|
{
|
|
string[] statements =
|
|
{
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Scene (
|
|
Id TEXT PRIMARY KEY,
|
|
Name TEXT NOT NULL,
|
|
IsHidden INTEGER NOT NULL DEFAULT 0,
|
|
IsChatScene INTEGER NOT NULL DEFAULT 0,
|
|
HasBackground INTEGER NOT NULL DEFAULT 1,
|
|
SortOrder INTEGER NOT NULL DEFAULT 0
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Asset (
|
|
Id TEXT PRIMARY KEY,
|
|
Hash TEXT NOT NULL UNIQUE,
|
|
Data BLOB NOT NULL,
|
|
PixelWidth INTEGER NOT NULL DEFAULT 0,
|
|
PixelHeight INTEGER NOT NULL DEFAULT 0
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Source (
|
|
Id TEXT PRIMARY KEY,
|
|
SceneId TEXT NOT NULL REFERENCES Scene(Id) ON DELETE CASCADE,
|
|
AssetId TEXT REFERENCES Asset(Id),
|
|
Type TEXT NOT NULL,
|
|
Name TEXT NOT NULL,
|
|
IsEnabled INTEGER NOT NULL DEFAULT 1,
|
|
X REAL NOT NULL DEFAULT 0,
|
|
Y REAL NOT NULL DEFAULT 0,
|
|
Width REAL NOT NULL DEFAULT 0,
|
|
Height REAL NOT NULL DEFAULT 0,
|
|
Opacity REAL NOT NULL DEFAULT 1,
|
|
MonitorIndex INTEGER,
|
|
DeviceId TEXT,
|
|
ClipShape TEXT NOT NULL DEFAULT 'Traditional',
|
|
IsMirrored INTEGER NOT NULL DEFAULT 0,
|
|
IsBackground INTEGER NOT NULL DEFAULT 0,
|
|
CaptureKey TEXT,
|
|
SortOrder INTEGER NOT NULL DEFAULT 0
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Webcam (
|
|
Id TEXT PRIMARY KEY,
|
|
DeviceId TEXT NOT NULL UNIQUE,
|
|
Name TEXT NOT NULL
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS WebcamSceneConfig (
|
|
SceneId TEXT NOT NULL REFERENCES Scene(Id) ON DELETE CASCADE,
|
|
WebcamId TEXT NOT NULL REFERENCES Webcam(Id) ON DELETE CASCADE,
|
|
IsVisible INTEGER NOT NULL DEFAULT 1,
|
|
X REAL NOT NULL DEFAULT 0,
|
|
Y REAL NOT NULL DEFAULT 0,
|
|
Width REAL NOT NULL DEFAULT 0,
|
|
Height REAL NOT NULL DEFAULT 0,
|
|
Opacity REAL NOT NULL DEFAULT 1,
|
|
ClipShape TEXT NOT NULL DEFAULT 'Traditional',
|
|
IsMirrored INTEGER NOT NULL DEFAULT 0,
|
|
RectWidth REAL,
|
|
RectHeight REAL,
|
|
BorderColor TEXT,
|
|
BorderOpacity REAL NOT NULL DEFAULT 1,
|
|
BorderWidth INTEGER NOT NULL DEFAULT 0,
|
|
BorderAnimation TEXT NOT NULL DEFAULT 'None',
|
|
SortOrder INTEGER NOT NULL DEFAULT 0,
|
|
PRIMARY KEY (SceneId, WebcamId)
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Socials (
|
|
Id TEXT PRIMARY KEY,
|
|
BarPosition TEXT NOT NULL DEFAULT 'Bottom',
|
|
BarJustify TEXT NOT NULL DEFAULT 'Center'
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS SocialEntry (
|
|
Id TEXT PRIMARY KEY,
|
|
SocialsId TEXT NOT NULL REFERENCES Socials(Id) ON DELETE CASCADE,
|
|
Service TEXT NOT NULL,
|
|
Handle TEXT NOT NULL,
|
|
ProfileUrl TEXT NOT NULL,
|
|
SortOrder INTEGER NOT NULL DEFAULT 0
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Music (
|
|
Id TEXT PRIMARY KEY,
|
|
TrackPath TEXT NOT NULL,
|
|
IsEnabled INTEGER NOT NULL DEFAULT 0
|
|
);
|
|
""",
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS Settings (
|
|
Key TEXT PRIMARY KEY,
|
|
Value TEXT NOT NULL
|
|
);
|
|
""",
|
|
};
|
|
foreach (var sql in statements)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = sql;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
MigrateSourceTable();
|
|
MigrateWebcamConfigTable();
|
|
MigrateSceneTable();
|
|
MigrateSceneSocialBarColumn();
|
|
MigrateSocialsTable();
|
|
MigrateSocialEntryTable();
|
|
if (GetUserVersion() < 3)
|
|
MigrateToV3();
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA user_version = 9;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
|
|
private int GetUserVersion()
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "PRAGMA user_version;";
|
|
return Convert.ToInt32(cmd.ExecuteScalar());
|
|
}
|
|
|
|
// v1 → v2: Source gains ClipShape + IsMirrored (webcam clip/mirror prefs).
|
|
// CREATE TABLE IF NOT EXISTS doesn't touch existing tables, so pre-v2 DBs
|
|
// get the columns here instead.
|
|
private void MigrateSourceTable()
|
|
{
|
|
var columns = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA table_info(Source);";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
columns.Add(reader.GetString(1));
|
|
}
|
|
|
|
if (!columns.Contains("ClipShape"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ClipShape TEXT NOT NULL DEFAULT 'Traditional';";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
if (!columns.Contains("IsMirrored"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN IsMirrored INTEGER NOT NULL DEFAULT 0;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
if (columns.Contains("IsBackdrop"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source RENAME COLUMN IsBackdrop TO IsBackground;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
else if (!columns.Contains("IsBackground"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN IsBackground INTEGER NOT NULL DEFAULT 0;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
if (!columns.Contains("CaptureKey"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN CaptureKey TEXT;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
// TASK 3.18: ChatBox overlay source
|
|
if (!columns.Contains("ChatFontSize"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatFontSize REAL NOT NULL DEFAULT 16;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatFontColor"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatFontColor TEXT NOT NULL DEFAULT '#FFFFFF';";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatBackgroundColor"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatBackgroundColor TEXT NOT NULL DEFAULT '#80000000';";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatMaxMessages"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatMaxMessages INTEGER NOT NULL DEFAULT 5;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatShowTimestamps"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatShowTimestamps INTEGER NOT NULL DEFAULT 1;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatShowBadges"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatShowBadges INTEGER NOT NULL DEFAULT 1;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatMemberColor"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatMemberColor TEXT NOT NULL DEFAULT '#e94560';";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ChatSuperChatColor"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ChatSuperChatColor TEXT NOT NULL DEFAULT '#eab308';";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
if (!columns.Contains("ShowDesktop"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Source ADD COLUMN ShowDesktop INTEGER NOT NULL DEFAULT 0;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
// Rename legacy "Backdrop" display name to "Background" in existing rows
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "UPDATE Source SET Name = 'Background' WHERE Name = 'Backdrop';";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
|
|
// v3 → v4: WebcamSceneConfig gains RectWidth/RectHeight (the pre-Round rect,
|
|
// so a reloaded Round webcam restores its aspect on toggle-back).
|
|
private void MigrateWebcamConfigTable()
|
|
{
|
|
var columns = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA table_info(WebcamSceneConfig);";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
columns.Add(reader.GetString(1));
|
|
}
|
|
|
|
if (!columns.Contains("RectWidth"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE WebcamSceneConfig ADD COLUMN RectWidth REAL;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
if (!columns.Contains("RectHeight"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE WebcamSceneConfig ADD COLUMN RectHeight REAL;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
|
|
// v2 → v3: the webcam leaves the Source table. Any webcam Source rows become
|
|
// one Webcam identity (first row — one camera app-wide) + a WebcamSceneConfig
|
|
// per scene that had one, then the webcam rows are deleted. No backfill:
|
|
// scenes without the webcam stay webcam-free.
|
|
private void MigrateToV3()
|
|
{
|
|
var rows = new List<(string Id, string SceneId, string Name, double X, double Y, double W, double H, double Opacity, string DeviceId, string ClipShape, bool IsMirrored)>();
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = """
|
|
SELECT Id, SceneId, Name, X, Y, Width, Height, Opacity, DeviceId, ClipShape, IsMirrored
|
|
FROM Source WHERE Type = 'Webcam' ORDER BY SortOrder;
|
|
""";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
rows.Add((
|
|
reader.GetString(0),
|
|
reader.GetString(1),
|
|
reader.GetString(2),
|
|
reader.GetDouble(3),
|
|
reader.GetDouble(4),
|
|
reader.GetDouble(5),
|
|
reader.GetDouble(6),
|
|
reader.GetDouble(7),
|
|
reader.IsDBNull(8) ? string.Empty : reader.GetString(8),
|
|
reader.GetString(9),
|
|
reader.GetInt32(10) != 0));
|
|
}
|
|
}
|
|
if (rows.Count == 0) return;
|
|
|
|
using var tx = _connection.BeginTransaction();
|
|
var webcamId = Guid.NewGuid().ToString();
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "INSERT INTO Webcam (Id, DeviceId, Name) VALUES ($id, $device, $name);";
|
|
cmd.Transaction = tx;
|
|
cmd.Parameters.AddWithValue("$id", webcamId);
|
|
cmd.Parameters.AddWithValue("$device", rows[0].DeviceId);
|
|
cmd.Parameters.AddWithValue("$name", rows[0].Name);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
foreach (var row in rows)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = """
|
|
INSERT INTO WebcamSceneConfig
|
|
(SceneId, WebcamId, IsVisible, X, Y, Width, Height, Opacity,
|
|
ClipShape, IsMirrored, BorderColor, BorderOpacity, BorderWidth, BorderAnimation, SortOrder)
|
|
VALUES ($sceneId, $webcamId, 1, $x, $y, $w, $h, $opacity,
|
|
$clip, $mirrored, NULL, 1, 0, 'None', 0);
|
|
""";
|
|
cmd.Transaction = tx;
|
|
cmd.Parameters.AddWithValue("$sceneId", row.SceneId);
|
|
cmd.Parameters.AddWithValue("$webcamId", webcamId);
|
|
cmd.Parameters.AddWithValue("$x", row.X);
|
|
cmd.Parameters.AddWithValue("$y", row.Y);
|
|
cmd.Parameters.AddWithValue("$w", row.W);
|
|
cmd.Parameters.AddWithValue("$h", row.H);
|
|
cmd.Parameters.AddWithValue("$opacity", row.Opacity);
|
|
cmd.Parameters.AddWithValue("$clip", row.ClipShape);
|
|
cmd.Parameters.AddWithValue("$mirrored", row.IsMirrored ? 1 : 0);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Source WHERE Type = 'Webcam';";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
tx.Commit();
|
|
}
|
|
|
|
// v5 → v6: Scene gains HasBackground. Added columns default to true; the
|
|
// ONE-TIME backfill (runs only when the column is first added) turns every
|
|
// non-Live canonical scene off and drops their background sources — the fix for
|
|
// DBs saved before the Live-only policy. MainViewModel.NormalizeBackgrounds
|
|
// re-runs the same normalization on every load for DBs that miss the backfill.
|
|
private void MigrateSceneTable()
|
|
{
|
|
var columns = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA table_info(Scene);";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
columns.Add(reader.GetString(1));
|
|
}
|
|
|
|
if (columns.Contains("HasBackdrop"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Scene RENAME COLUMN HasBackdrop TO HasBackground;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
else if (columns.Contains("HasBackground"))
|
|
{
|
|
return;
|
|
}
|
|
|
|
if (!columns.Contains("HasBackground"))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "ALTER TABLE Scene ADD COLUMN HasBackground INTEGER NOT NULL DEFAULT 1;";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
const string noBackground = "('starting', 'brb', 'chat', 'ending')";
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = $"UPDATE Scene SET HasBackground = 0 WHERE LOWER(TRIM(Name)) IN {noBackground};";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = $"""
|
|
DELETE FROM Source
|
|
WHERE IsBackground = 1 AND SceneId IN
|
|
(SELECT Id FROM Scene WHERE LOWER(TRIM(Name)) IN {noBackground});
|
|
""";
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
|
|
// v6 → v7: Scene gains HasSocialBar (the per-scene social-bar toggle).
|
|
// Defaults to 0 (off) — the creator adds it explicitly via the footer [+].
|
|
private void MigrateSceneSocialBarColumn()
|
|
{
|
|
var columns = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA table_info(Scene);";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
columns.Add(reader.GetString(1));
|
|
}
|
|
|
|
if (columns.Contains("HasSocialBar")) return;
|
|
|
|
using var alter = _connection.CreateCommand();
|
|
alter.CommandText = "ALTER TABLE Scene ADD COLUMN HasSocialBar INTEGER NOT NULL DEFAULT 0;";
|
|
alter.ExecuteNonQuery();
|
|
}
|
|
|
|
// v7 → v8: Socials gains BarEnabled (the dialog's show/hide switch). The old
|
|
// BarJustify column stays for back-compat but is no longer read or written.
|
|
private void MigrateSocialsTable()
|
|
{
|
|
var columns = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA table_info(Socials);";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
columns.Add(reader.GetString(1));
|
|
}
|
|
|
|
if (columns.Contains("BarEnabled")) return;
|
|
|
|
using var alter = _connection.CreateCommand();
|
|
alter.CommandText = "ALTER TABLE Socials ADD COLUMN BarEnabled INTEGER NOT NULL DEFAULT 1;";
|
|
alter.ExecuteNonQuery();
|
|
}
|
|
|
|
// v8 → v9: SocialEntry gains Software (the fediverse instance's nodeinfo
|
|
// software name) so a reloaded entry still shows the right service logo.
|
|
private void MigrateSocialEntryTable()
|
|
{
|
|
var columns = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "PRAGMA table_info(SocialEntry);";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
columns.Add(reader.GetString(1));
|
|
}
|
|
|
|
if (columns.Contains("Software")) return;
|
|
|
|
using var alter = _connection.CreateCommand();
|
|
alter.CommandText = "ALTER TABLE SocialEntry ADD COLUMN Software TEXT;";
|
|
alter.ExecuteNonQuery();
|
|
}
|
|
|
|
public List<Scene> Load()
|
|
{
|
|
Webcam = null;
|
|
Socials = null;
|
|
Music = null;
|
|
var scenes = new List<Scene>();
|
|
var sourcesByScene = new Dictionary<string, List<Source>>();
|
|
var configsByScene = new Dictionary<string, List<WebcamSceneConfig>>();
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "SELECT Id, Name, IsHidden, IsChatScene, HasBackground, HasSocialBar FROM Scene ORDER BY SortOrder";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
scenes.Add(new Scene
|
|
{
|
|
Id = reader.GetString(0),
|
|
Name = reader.GetString(1),
|
|
IsHidden = reader.GetInt32(2) != 0,
|
|
IsChatScene = reader.GetInt32(3) != 0,
|
|
HasBackground = reader.GetInt32(4) != 0,
|
|
HasSocialBar = reader.FieldCount > 5 && !reader.IsDBNull(5) && reader.GetInt32(5) != 0,
|
|
});
|
|
}
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "SELECT Id, DeviceId, Name FROM Webcam;";
|
|
using var reader = cmd.ExecuteReader();
|
|
if (reader.Read())
|
|
{
|
|
Webcam = new Webcam
|
|
{
|
|
Id = reader.GetString(0),
|
|
DeviceId = reader.GetString(1),
|
|
Name = reader.GetString(2),
|
|
};
|
|
}
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "SELECT Id, BarPosition, BarEnabled FROM Socials LIMIT 1;";
|
|
using var reader = cmd.ExecuteReader();
|
|
if (reader.Read())
|
|
{
|
|
Socials = new SocialsConfig
|
|
{
|
|
BarPosition = Enum.TryParse<SocialBarPosition>(reader.GetString(1), out var pos) ? pos : SocialBarPosition.Bottom,
|
|
BarEnabled = reader.FieldCount > 2 && !reader.IsDBNull(2) && reader.GetInt32(2) != 0,
|
|
};
|
|
var socialsId = reader.GetString(0);
|
|
|
|
using var entryCmd = _connection.CreateCommand();
|
|
entryCmd.CommandText = "SELECT Service, Handle, ProfileUrl, Software FROM SocialEntry WHERE SocialsId = $id ORDER BY SortOrder;";
|
|
entryCmd.Parameters.AddWithValue("$id", socialsId);
|
|
using var entryReader = entryCmd.ExecuteReader();
|
|
while (entryReader.Read())
|
|
{
|
|
Socials.Entries.Add(new SocialEntry
|
|
{
|
|
Service = Enum.TryParse<SocialService>(entryReader.GetString(0), out var svc) ? svc : SocialService.Link,
|
|
Handle = entryReader.GetString(1),
|
|
ProfileUrl = entryReader.GetString(2),
|
|
FediverseSoftware = entryReader.FieldCount > 3 && !entryReader.IsDBNull(3) ? entryReader.GetString(3) : null,
|
|
});
|
|
}
|
|
}
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "SELECT TrackPath, IsEnabled FROM Music LIMIT 1;";
|
|
using var reader = cmd.ExecuteReader();
|
|
if (reader.Read())
|
|
{
|
|
Music = new Music
|
|
{
|
|
TrackPath = reader.GetString(0),
|
|
IsEnabled = reader.GetInt32(1) != 0,
|
|
};
|
|
}
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = """
|
|
SELECT Id, SceneId, AssetId, Type, Name, IsEnabled,
|
|
X, Y, Width, Height, Opacity, MonitorIndex, ClipShape, IsMirrored,
|
|
IsBackground, CaptureKey, ShowDesktop,
|
|
ChatFontSize, ChatFontColor, ChatBackgroundColor, ChatMaxMessages,
|
|
ChatShowTimestamps, ChatShowBadges, ChatMemberColor, ChatSuperChatColor
|
|
FROM Source ORDER BY SortOrder
|
|
""";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
var sceneId = reader.GetString(1);
|
|
var type = Enum.Parse<SourceType>(reader.GetString(3));
|
|
var source = new Source
|
|
{
|
|
Id = reader.GetString(0),
|
|
AssetId = reader.IsDBNull(2) ? null : reader.GetString(2),
|
|
Type = type,
|
|
Name = reader.GetString(4),
|
|
IsEnabled = reader.GetInt32(5) != 0,
|
|
X = reader.GetDouble(6),
|
|
Y = reader.GetDouble(7),
|
|
Width = reader.GetDouble(8),
|
|
Height = reader.GetDouble(9),
|
|
Opacity = reader.GetDouble(10),
|
|
MonitorIndex = reader.IsDBNull(11) ? null : reader.GetInt32(11),
|
|
ClipShape = Enum.TryParse<ClipShape>(reader.GetString(12), out var clip) ? clip : ClipShape.Traditional,
|
|
IsMirrored = reader.GetInt32(13) != 0,
|
|
// Rows saved before the Type setter derived the flag carry
|
|
// IsBackground=0; derive from Type, keeping the persisted bit
|
|
// for legacy DisplayCapture backdrops.
|
|
IsBackground = type == SourceType.Background || reader.GetInt32(14) != 0,
|
|
CaptureKey = reader.IsDBNull(15) ? null : reader.GetString(15),
|
|
ShowDesktop = reader.GetInt32(16) != 0,
|
|
ChatFontSize = reader.IsDBNull(17) ? 16 : reader.GetDouble(17),
|
|
ChatFontColor = reader.IsDBNull(18) ? "#FFFFFF" : reader.GetString(18),
|
|
ChatBackgroundColor = reader.IsDBNull(19) ? "#80000000" : reader.GetString(19),
|
|
ChatMaxMessages = reader.IsDBNull(20) ? 5 : reader.GetInt32(20),
|
|
ChatShowTimestamps = reader.IsDBNull(21) ? true : reader.GetInt32(21) != 0,
|
|
ChatShowBadges = reader.IsDBNull(22) ? true : reader.GetInt32(22) != 0,
|
|
ChatMemberColor = reader.IsDBNull(23) ? "#e94560" : reader.GetString(23),
|
|
ChatSuperChatColor = reader.IsDBNull(24) ? "#eab308" : reader.GetString(24),
|
|
};
|
|
if (!sourcesByScene.TryGetValue(sceneId, out var list))
|
|
sourcesByScene[sceneId] = list = new List<Source>();
|
|
list.Add(source);
|
|
}
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = """
|
|
SELECT SceneId, WebcamId, IsVisible, X, Y, Width, Height, Opacity,
|
|
ClipShape, IsMirrored, BorderColor, BorderOpacity, BorderWidth, BorderAnimation,
|
|
RectWidth, RectHeight
|
|
FROM WebcamSceneConfig ORDER BY SortOrder
|
|
""";
|
|
using var reader = cmd.ExecuteReader();
|
|
while (reader.Read())
|
|
{
|
|
var sceneId = reader.GetString(0);
|
|
var config = new WebcamSceneConfig
|
|
{
|
|
WebcamId = reader.GetString(1),
|
|
Name = Webcam?.Name ?? "Webcam",
|
|
IsVisible = reader.GetInt32(2) != 0,
|
|
X = reader.GetDouble(3),
|
|
Y = reader.GetDouble(4),
|
|
Width = reader.GetDouble(5),
|
|
Height = reader.GetDouble(6),
|
|
Opacity = reader.GetDouble(7),
|
|
ClipShape = Enum.TryParse<ClipShape>(reader.GetString(8), out var clip) ? clip : ClipShape.Traditional,
|
|
IsMirrored = reader.GetInt32(9) != 0,
|
|
BorderColor = reader.IsDBNull(10) ? string.Empty : reader.GetString(10),
|
|
BorderOpacity = reader.IsDBNull(11) ? 1.0 : reader.GetDouble(11),
|
|
BorderWidth = reader.IsDBNull(12) ? 0 : reader.GetInt32(12),
|
|
BorderAnimation = Enum.TryParse<BorderAnimation>(reader.GetString(13), out var anim) ? anim : BorderAnimation.None,
|
|
RectWidth = reader.IsDBNull(14) ? null : reader.GetDouble(14),
|
|
RectHeight = reader.IsDBNull(15) ? null : reader.GetDouble(15),
|
|
};
|
|
if (!configsByScene.TryGetValue(sceneId, out var list))
|
|
configsByScene[sceneId] = list = new List<WebcamSceneConfig>();
|
|
list.Add(config);
|
|
}
|
|
}
|
|
|
|
foreach (var scene in scenes)
|
|
{
|
|
if (sourcesByScene.TryGetValue(scene.Id, out var sources))
|
|
foreach (var source in sources)
|
|
scene.Elements.Add(source);
|
|
if (configsByScene.TryGetValue(scene.Id, out var configs))
|
|
foreach (var config in configs)
|
|
scene.Elements.Add(config);
|
|
|
|
var bg = scene.Elements.OfType<Source>().FirstOrDefault(s => s.IsBackground);
|
|
if (bg != null)
|
|
{
|
|
// Load from source-keyed settings (new) or scene-keyed (legacy migration)
|
|
var path = GetSetting($"BackgroundPath_{bg.Id}");
|
|
if (string.IsNullOrWhiteSpace(path))
|
|
path = GetSetting($"BackgroundPath_{scene.Id}");
|
|
if (!string.IsNullOrWhiteSpace(path))
|
|
bg.CustomBackgroundPath = path;
|
|
|
|
var useDefault = GetSetting($"BackgroundUseDefault_{bg.Id}");
|
|
if (string.IsNullOrWhiteSpace(useDefault))
|
|
useDefault = GetSetting($"BackgroundUseDefault_{scene.Id}");
|
|
if (useDefault == "0")
|
|
bg.UseDefaultBackground = false;
|
|
}
|
|
}
|
|
|
|
return scenes;
|
|
}
|
|
|
|
/// <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 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 void Save(IEnumerable<Scene> scenes, Webcam? webcam, SocialsConfig? socials, Music? music = null)
|
|
{
|
|
using var tx = _connection.BeginTransaction();
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM WebcamSceneConfig;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Source;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Webcam;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM SocialEntry;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Socials;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Music;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Scene;";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = """
|
|
INSERT INTO Scene (Id, Name, IsHidden, IsChatScene, HasBackground, HasSocialBar, SortOrder)
|
|
VALUES ($id, $name, $isHidden, $isChat, $hasBackground, $hasSocialBar, $sort)
|
|
""";
|
|
cmd.Transaction = tx;
|
|
var idP = cmd.Parameters.Add("$id", SqliteType.Text);
|
|
var nameP = cmd.Parameters.Add("$name", SqliteType.Text);
|
|
var hiddenP = cmd.Parameters.Add("$isHidden", SqliteType.Integer);
|
|
var chatP = cmd.Parameters.Add("$isChat", SqliteType.Integer);
|
|
var backgroundP = cmd.Parameters.Add("$hasBackground", SqliteType.Integer);
|
|
var socialBarP = cmd.Parameters.Add("$hasSocialBar", SqliteType.Integer);
|
|
var sortP = cmd.Parameters.Add("$sort", SqliteType.Integer);
|
|
|
|
var sort = 0;
|
|
foreach (var scene in scenes)
|
|
{
|
|
idP.Value = scene.Id;
|
|
nameP.Value = scene.Name;
|
|
hiddenP.Value = scene.IsHidden ? 1 : 0;
|
|
chatP.Value = scene.IsChatScene ? 1 : 0;
|
|
backgroundP.Value = scene.HasBackground ? 1 : 0;
|
|
socialBarP.Value = scene.HasSocialBar ? 1 : 0;
|
|
sortP.Value = sort++;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = """
|
|
INSERT INTO Source (Id, SceneId, AssetId, Type, Name, IsEnabled,
|
|
X, Y, Width, Height, Opacity, MonitorIndex,
|
|
ClipShape, IsMirrored, IsBackground, CaptureKey, ShowDesktop, SortOrder,
|
|
ChatFontSize, ChatFontColor, ChatBackgroundColor, ChatMaxMessages,
|
|
ChatShowTimestamps, ChatShowBadges, ChatMemberColor, ChatSuperChatColor)
|
|
VALUES ($id, $sceneId, $assetId, $type, $name, $isEnabled,
|
|
$x, $y, $w, $h, $opacity, $monitor,
|
|
$clip, $mirrored, $isBackground, $captureKey, $showDesktop, $sort,
|
|
$chatFontSize, $chatFontColor, $chatBgColor, $chatMaxMsgs,
|
|
$chatTimestamps, $chatBadges, $chatMemberColor, $chatSuperChatColor)
|
|
""";
|
|
cmd.Transaction = tx;
|
|
var idP = cmd.Parameters.Add("$id", SqliteType.Text);
|
|
var sceneIdP = cmd.Parameters.Add("$sceneId", SqliteType.Text);
|
|
var assetIdP = cmd.Parameters.Add("$assetId", SqliteType.Text);
|
|
var typeP = cmd.Parameters.Add("$type", SqliteType.Text);
|
|
var nameP = cmd.Parameters.Add("$name", SqliteType.Text);
|
|
var enabledP = cmd.Parameters.Add("$isEnabled", SqliteType.Integer);
|
|
var xP = cmd.Parameters.Add("$x", SqliteType.Real);
|
|
var yP = cmd.Parameters.Add("$y", SqliteType.Real);
|
|
var wP = cmd.Parameters.Add("$w", SqliteType.Real);
|
|
var hP = cmd.Parameters.Add("$h", SqliteType.Real);
|
|
var opacityP = cmd.Parameters.Add("$opacity", SqliteType.Real);
|
|
var monitorP = cmd.Parameters.Add("$monitor", SqliteType.Integer);
|
|
var clipP = cmd.Parameters.Add("$clip", SqliteType.Text);
|
|
var mirroredP = cmd.Parameters.Add("$mirrored", SqliteType.Integer);
|
|
var isBackgroundP = cmd.Parameters.Add("$isBackground", SqliteType.Integer);
|
|
var captureKeyP = cmd.Parameters.Add("$captureKey", SqliteType.Text);
|
|
var showDesktopP = cmd.Parameters.Add("$showDesktop", SqliteType.Integer);
|
|
var sortP = cmd.Parameters.Add("$sort", SqliteType.Integer);
|
|
var chatFontSizeP = cmd.Parameters.Add("$chatFontSize", SqliteType.Real);
|
|
var chatFontColorP = cmd.Parameters.Add("$chatFontColor", SqliteType.Text);
|
|
var chatBgColorP = cmd.Parameters.Add("$chatBgColor", SqliteType.Text);
|
|
var chatMaxMsgsP = cmd.Parameters.Add("$chatMaxMsgs", SqliteType.Integer);
|
|
var chatTimestampsP = cmd.Parameters.Add("$chatTimestamps", SqliteType.Integer);
|
|
var chatBadgesP = cmd.Parameters.Add("$chatBadges", SqliteType.Integer);
|
|
var chatMemberColorP = cmd.Parameters.Add("$chatMemberColor", SqliteType.Text);
|
|
var chatSuperChatColorP = cmd.Parameters.Add("$chatSuperChatColor", SqliteType.Text);
|
|
|
|
foreach (var scene in scenes)
|
|
{
|
|
var sort = 0;
|
|
foreach (var element in scene.Elements)
|
|
{
|
|
if (element is not Source source) continue;
|
|
idP.Value = source.Id;
|
|
sceneIdP.Value = scene.Id;
|
|
assetIdP.Value = (object?)source.AssetId ?? DBNull.Value;
|
|
typeP.Value = source.Type.ToString();
|
|
nameP.Value = source.Name;
|
|
enabledP.Value = source.IsEnabled ? 1 : 0;
|
|
xP.Value = source.X;
|
|
yP.Value = source.Y;
|
|
wP.Value = source.Width;
|
|
hP.Value = source.Height;
|
|
opacityP.Value = source.Opacity;
|
|
monitorP.Value = (object?)source.MonitorIndex ?? DBNull.Value;
|
|
clipP.Value = source.ClipShape.ToString();
|
|
mirroredP.Value = source.IsMirrored ? 1 : 0;
|
|
isBackgroundP.Value = source.IsBackground ? 1 : 0;
|
|
captureKeyP.Value = (object?)source.CaptureKey ?? DBNull.Value;
|
|
showDesktopP.Value = source.ShowDesktop ? 1 : 0;
|
|
sortP.Value = sort++;
|
|
chatFontSizeP.Value = source.ChatFontSize;
|
|
chatFontColorP.Value = source.ChatFontColor;
|
|
chatBgColorP.Value = source.ChatBackgroundColor;
|
|
chatMaxMsgsP.Value = source.ChatMaxMessages;
|
|
chatTimestampsP.Value = source.ChatShowTimestamps ? 1 : 0;
|
|
chatBadgesP.Value = source.ChatShowBadges ? 1 : 0;
|
|
chatMemberColorP.Value = source.ChatMemberColor;
|
|
chatSuperChatColorP.Value = source.ChatSuperChatColor;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
}
|
|
|
|
if (webcam != null)
|
|
{
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "INSERT INTO Webcam (Id, DeviceId, Name) VALUES ($id, $device, $name);";
|
|
cmd.Transaction = tx;
|
|
cmd.Parameters.AddWithValue("$id", webcam.Id);
|
|
cmd.Parameters.AddWithValue("$device", webcam.DeviceId);
|
|
cmd.Parameters.AddWithValue("$name", webcam.Name);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = """
|
|
INSERT INTO WebcamSceneConfig
|
|
(SceneId, WebcamId, IsVisible, X, Y, Width, Height, Opacity,
|
|
ClipShape, IsMirrored, BorderColor, BorderOpacity, BorderWidth, BorderAnimation,
|
|
RectWidth, RectHeight, SortOrder)
|
|
VALUES ($sceneId, $webcamId, $isVisible, $x, $y, $w, $h, $opacity,
|
|
$clip, $mirrored, $borderColor, $borderOpacity, $borderWidth, $borderAnimation,
|
|
$rectWidth, $rectHeight, $sort)
|
|
""";
|
|
cmd.Transaction = tx;
|
|
var sceneIdP = cmd.Parameters.Add("$sceneId", SqliteType.Text);
|
|
var webcamIdP = cmd.Parameters.Add("$webcamId", SqliteType.Text);
|
|
var visibleP = cmd.Parameters.Add("$isVisible", SqliteType.Integer);
|
|
var xP = cmd.Parameters.Add("$x", SqliteType.Real);
|
|
var yP = cmd.Parameters.Add("$y", SqliteType.Real);
|
|
var wP = cmd.Parameters.Add("$w", SqliteType.Real);
|
|
var hP = cmd.Parameters.Add("$h", SqliteType.Real);
|
|
var opacityP = cmd.Parameters.Add("$opacity", SqliteType.Real);
|
|
var clipP = cmd.Parameters.Add("$clip", SqliteType.Text);
|
|
var mirroredP = cmd.Parameters.Add("$mirrored", SqliteType.Integer);
|
|
var colorP = cmd.Parameters.Add("$borderColor", SqliteType.Text);
|
|
var borderOpacityP = cmd.Parameters.Add("$borderOpacity", SqliteType.Real);
|
|
var borderWidthP = cmd.Parameters.Add("$borderWidth", SqliteType.Integer);
|
|
var animationP = cmd.Parameters.Add("$borderAnimation", SqliteType.Text);
|
|
var rectWidthP = cmd.Parameters.Add("$rectWidth", SqliteType.Real);
|
|
var rectHeightP = cmd.Parameters.Add("$rectHeight", SqliteType.Real);
|
|
var sortP = cmd.Parameters.Add("$sort", SqliteType.Integer);
|
|
|
|
foreach (var scene in scenes)
|
|
{
|
|
var sort = 0;
|
|
foreach (var config in scene.Elements.OfType<WebcamSceneConfig>())
|
|
{
|
|
sceneIdP.Value = scene.Id;
|
|
webcamIdP.Value = config.WebcamId;
|
|
visibleP.Value = config.IsVisible ? 1 : 0;
|
|
xP.Value = config.X;
|
|
yP.Value = config.Y;
|
|
wP.Value = config.Width;
|
|
hP.Value = config.Height;
|
|
opacityP.Value = config.Opacity;
|
|
clipP.Value = config.ClipShape.ToString();
|
|
mirroredP.Value = config.IsMirrored ? 1 : 0;
|
|
colorP.Value = (object?)(string.IsNullOrEmpty(config.BorderColor) ? null : config.BorderColor) ?? DBNull.Value;
|
|
borderOpacityP.Value = config.BorderOpacity;
|
|
borderWidthP.Value = config.BorderWidth;
|
|
animationP.Value = config.BorderAnimation.ToString();
|
|
rectWidthP.Value = (object?)config.RectWidth ?? DBNull.Value;
|
|
rectHeightP.Value = (object?)config.RectHeight ?? DBNull.Value;
|
|
sortP.Value = sort++;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (socials != null && socials.Entries.Count > 0)
|
|
{
|
|
var socialsId = Guid.NewGuid().ToString();
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "INSERT INTO Socials (Id, BarPosition, BarEnabled) VALUES ($id, $pos, $enabled);";
|
|
cmd.Transaction = tx;
|
|
cmd.Parameters.AddWithValue("$id", socialsId);
|
|
cmd.Parameters.AddWithValue("$pos", socials.BarPosition.ToString());
|
|
cmd.Parameters.AddWithValue("$enabled", socials.BarEnabled ? 1 : 0);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
using var entryCmd = _connection.CreateCommand();
|
|
entryCmd.CommandText = """
|
|
INSERT INTO SocialEntry (Id, SocialsId, Service, Handle, ProfileUrl, Software, SortOrder)
|
|
VALUES ($id, $socialsId, $service, $handle, $url, $software, $sort)
|
|
""";
|
|
entryCmd.Transaction = tx;
|
|
var eId = entryCmd.Parameters.Add("$id", SqliteType.Text);
|
|
var eSocialsId = entryCmd.Parameters.Add("$socialsId", SqliteType.Text);
|
|
var eService = entryCmd.Parameters.Add("$service", SqliteType.Text);
|
|
var eHandle = entryCmd.Parameters.Add("$handle", SqliteType.Text);
|
|
var eUrl = entryCmd.Parameters.Add("$url", SqliteType.Text);
|
|
var eSoftware = entryCmd.Parameters.Add("$software", SqliteType.Text);
|
|
var eSort = entryCmd.Parameters.Add("$sort", SqliteType.Integer);
|
|
|
|
var entrySort = 0;
|
|
foreach (var entry in socials.Entries)
|
|
{
|
|
eId.Value = Guid.NewGuid().ToString();
|
|
eSocialsId.Value = socialsId;
|
|
eService.Value = entry.Service.ToString();
|
|
eHandle.Value = entry.Handle;
|
|
eUrl.Value = entry.ProfileUrl;
|
|
eSoftware.Value = (object?)entry.FediverseSoftware ?? DBNull.Value;
|
|
eSort.Value = entrySort++;
|
|
entryCmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
|
|
if (music != null && !string.IsNullOrWhiteSpace(music.TrackPath))
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "INSERT INTO Music (Id, TrackPath, IsEnabled) VALUES ($id, $path, $enabled);";
|
|
cmd.Transaction = tx;
|
|
cmd.Parameters.AddWithValue("$id", Guid.NewGuid().ToString());
|
|
cmd.Parameters.AddWithValue("$path", music.TrackPath);
|
|
cmd.Parameters.AddWithValue("$enabled", music.IsEnabled ? 1 : 0);
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
using (var cmd = _connection.CreateCommand())
|
|
{
|
|
cmd.CommandText = "DELETE FROM Asset WHERE Id NOT IN (SELECT AssetId FROM Source WHERE AssetId IS NOT NULL);";
|
|
cmd.Transaction = tx;
|
|
cmd.ExecuteNonQuery();
|
|
}
|
|
|
|
// Save custom background paths and use-default flags per background source
|
|
foreach (var scene in scenes)
|
|
{
|
|
var bg = scene.Elements.OfType<Source>().FirstOrDefault(s => s.IsBackground);
|
|
if (bg == null) continue;
|
|
|
|
var pathKey = $"BackgroundPath_{bg.Id}";
|
|
if (!string.IsNullOrWhiteSpace(bg.CustomBackgroundPath))
|
|
UpsertSetting(pathKey, bg.CustomBackgroundPath);
|
|
else
|
|
{
|
|
using var del = _connection.CreateCommand();
|
|
del.CommandText = "DELETE FROM Settings WHERE Key = $key;";
|
|
del.Parameters.AddWithValue("$key", pathKey);
|
|
del.ExecuteNonQuery();
|
|
}
|
|
|
|
var defaultKey = $"BackgroundUseDefault_{bg.Id}";
|
|
UpsertSetting(defaultKey, bg.UseDefaultBackground ? "1" : "0");
|
|
}
|
|
|
|
// Purge background settings left behind by deleted/duplicated rows
|
|
// (TASK 25 heal drops extras; their keys must not accumulate).
|
|
using (var purge = _connection.CreateCommand())
|
|
{
|
|
purge.Transaction = tx;
|
|
purge.CommandText =
|
|
@"DELETE FROM Settings
|
|
WHERE (Key LIKE 'BackgroundUseDefault\_%' ESCAPE '\'
|
|
OR Key LIKE 'BackgroundPath\_%' ESCAPE '\')
|
|
AND SUBSTR(Key, INSTR(Key, '_') + 1) NOT IN (SELECT Id FROM Source);";
|
|
purge.ExecuteNonQuery();
|
|
}
|
|
|
|
tx.Commit();
|
|
}
|
|
|
|
public byte[]? GetAssetBytes(string assetId)
|
|
{
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = "SELECT Data FROM Asset WHERE Id = $id";
|
|
cmd.Parameters.AddWithValue("$id", assetId);
|
|
return cmd.ExecuteScalar() as byte[];
|
|
}
|
|
|
|
public string UpsertAsset(byte[] data, int pixelWidth, int pixelHeight)
|
|
{
|
|
var hash = Convert.ToHexString(SHA256.HashData(data));
|
|
var id = Guid.NewGuid().ToString();
|
|
|
|
using var cmd = _connection.CreateCommand();
|
|
cmd.CommandText = """
|
|
INSERT INTO Asset (Id, Hash, Data, PixelWidth, PixelHeight)
|
|
VALUES ($id, $hash, $data, $w, $h)
|
|
ON CONFLICT(Hash) DO NOTHING;
|
|
""";
|
|
cmd.Parameters.AddWithValue("$id", id);
|
|
cmd.Parameters.AddWithValue("$hash", hash);
|
|
cmd.Parameters.AddWithValue("$data", data);
|
|
cmd.Parameters.AddWithValue("$w", pixelWidth);
|
|
cmd.Parameters.AddWithValue("$h", pixelHeight);
|
|
cmd.ExecuteNonQuery();
|
|
|
|
cmd.CommandText = "SELECT Id FROM Asset WHERE Hash = $hash;";
|
|
return (string)cmd.ExecuteScalar()!;
|
|
}
|
|
|
|
// ─── License (TASK 10 — Polar billing) ───
|
|
|
|
/// <summary>The saved license key, or null if never entered.</summary>
|
|
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();
|
|
}
|
|
|
|
public void Dispose()
|
|
{
|
|
_connection.Dispose();
|
|
}
|
|
}
|