Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 gramps
|
d3271a0405 | ||
|
gramps
|
fab2e09903 | ||
|
gramps
|
31362d1a43 |
@@ -0,0 +1,164 @@
|
|||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Globalization;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Windows.Media;
|
||||||
|
using System.Windows.Media.Imaging;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.ViewModels;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel
|
||||||
|
{
|
||||||
|
internal static System.Windows.Media.Imaging.BitmapSource? LoadBackgroundImage(Scene scene)
|
||||||
|
{
|
||||||
|
var bg = scene.Elements.OfType<Source>().FirstOrDefault(s => s.IsBackground);
|
||||||
|
if (bg != null && !bg.UseDefaultBackground
|
||||||
|
&& !string.IsNullOrWhiteSpace(bg.CustomBackgroundPath)
|
||||||
|
&& System.IO.File.Exists(bg.CustomBackgroundPath))
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var bitmap = new System.Windows.Media.Imaging.BitmapImage();
|
||||||
|
bitmap.BeginInit();
|
||||||
|
bitmap.UriSource = new Uri(bg.CustomBackgroundPath);
|
||||||
|
bitmap.CacheOption = System.Windows.Media.Imaging.BitmapCacheOption.OnLoad;
|
||||||
|
bitmap.EndInit();
|
||||||
|
bitmap.Freeze();
|
||||||
|
return bitmap;
|
||||||
|
}
|
||||||
|
catch { /* fall through to AssetId */ }
|
||||||
|
}
|
||||||
|
if (bg != null && !string.IsNullOrWhiteSpace(bg.AssetId))
|
||||||
|
return ImageCache.Get(bg.AssetId);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
private static BitmapSource CreatePlaceholderSnapshot(string sceneName)
|
||||||
|
{
|
||||||
|
var colors = new Dictionary<string, System.Windows.Media.Brush>(StringComparer.OrdinalIgnoreCase)
|
||||||
|
{
|
||||||
|
["Starting"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(233, 69, 96)),
|
||||||
|
["Live"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(34, 197, 94)),
|
||||||
|
["BRB"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(234, 179, 8)),
|
||||||
|
["Chat"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(59, 130, 246)),
|
||||||
|
["Ending"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(168, 85, 247)),
|
||||||
|
};
|
||||||
|
var brush = colors.TryGetValue(sceneName, out var c) ? c
|
||||||
|
: new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(60, 60, 80));
|
||||||
|
var dv = new System.Windows.Media.DrawingVisual();
|
||||||
|
using (var ctx = dv.RenderOpen())
|
||||||
|
{
|
||||||
|
ctx.DrawRectangle(brush, null, new System.Windows.Rect(0, 0, 320, 180));
|
||||||
|
var ft = new System.Windows.Media.FormattedText(
|
||||||
|
sceneName,
|
||||||
|
System.Globalization.CultureInfo.InvariantCulture,
|
||||||
|
System.Windows.FlowDirection.LeftToRight,
|
||||||
|
new System.Windows.Media.Typeface("Segoe UI"),
|
||||||
|
18,
|
||||||
|
System.Windows.Media.Brushes.White,
|
||||||
|
96);
|
||||||
|
ctx.DrawText(ft, new System.Windows.Point(160 - ft.Width / 2, 90 - ft.Height / 2));
|
||||||
|
}
|
||||||
|
var rtb = new System.Windows.Media.Imaging.RenderTargetBitmap(
|
||||||
|
320, 180, 96, 96, System.Windows.Media.PixelFormats.Pbgra32);
|
||||||
|
rtb.Render(dv);
|
||||||
|
rtb.Freeze();
|
||||||
|
return rtb;
|
||||||
|
}
|
||||||
|
|
||||||
|
// ─── Screen background capture (live desktop/game) ───
|
||||||
|
|
||||||
|
private const string MonitorKeyPrefix = "monitor:";
|
||||||
|
|
||||||
|
/// <summary>Every background-enabled scene has exactly one background, kept at index 0 (bottom layer).
|
||||||
|
/// Returns null for a scene with <see cref="Scene.HasBackground"/> = false.</summary>
|
||||||
|
internal static Source? EnsureBackground(Scene scene)
|
||||||
|
{
|
||||||
|
if (!scene.HasBackground) return null;
|
||||||
|
var background = scene.Elements.OfType<Source>().FirstOrDefault(s => s.IsBackground);
|
||||||
|
if (background != null) return background;
|
||||||
|
|
||||||
|
background = CreateBackground(scene.Name);
|
||||||
|
scene.Elements.Insert(0, background);
|
||||||
|
return background;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>The one Background row for a scene. Live gets the capture flavor
|
||||||
|
/// (Show Desktop / monitor switch / fullscreen-game detect) falling back to
|
||||||
|
/// live-background.jpg; every other screen is a static default-art layer.
|
||||||
|
/// Both are named "Background" — the user never sees capture jargon here.</summary>
|
||||||
|
internal static Source CreateBackground(string sceneName)
|
||||||
|
{
|
||||||
|
var isLive = SceneCatalog.Is(sceneName, SceneCatalog.Live);
|
||||||
|
return new Source
|
||||||
|
{
|
||||||
|
Name = "Background",
|
||||||
|
Type = isLive ? SourceType.DisplayCapture : SourceType.Background,
|
||||||
|
IsBackground = true,
|
||||||
|
IsEnabled = true,
|
||||||
|
X = 0,
|
||||||
|
Y = 0,
|
||||||
|
Width = MasterFrameWidth,
|
||||||
|
Height = MasterFrameHeight,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Heals any loaded layout to the locked Background model: exactly
|
||||||
|
/// one Background per canonical scene, correct flavor for the scene (static
|
||||||
|
/// art everywhere, DisplayCapture on Live only), at index 0, named
|
||||||
|
/// "Background". Duplicates and stale rows are dropped; missing ones seeded;
|
||||||
|
/// non-canonical scenes get HasBackground=false and lose any backgrounds.</summary>
|
||||||
|
internal static void NormalizeBackgrounds(IEnumerable<Scene> scenes)
|
||||||
|
{
|
||||||
|
foreach (var scene in scenes)
|
||||||
|
{
|
||||||
|
if (!SceneCatalog.HasBackground(scene.Name))
|
||||||
|
{
|
||||||
|
scene.HasBackground = false;
|
||||||
|
foreach (var stale in scene.Elements.OfType<Source>().Where(s => s.IsBackground).ToList())
|
||||||
|
scene.Elements.Remove(stale);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
scene.HasBackground = true;
|
||||||
|
var isLive = SceneCatalog.Is(scene.Name, SceneCatalog.Live);
|
||||||
|
var wantedType = isLive ? SourceType.DisplayCapture : SourceType.Background;
|
||||||
|
|
||||||
|
var candidates = scene.Elements.OfType<Source>().Where(s => s.IsBackground).ToList();
|
||||||
|
var keep = candidates.FirstOrDefault(b => b.Type == wantedType) ?? candidates.FirstOrDefault();
|
||||||
|
|
||||||
|
foreach (var extra in candidates.Where(b => !ReferenceEquals(b, keep)))
|
||||||
|
scene.Elements.Remove(extra);
|
||||||
|
|
||||||
|
if (keep == null)
|
||||||
|
{
|
||||||
|
keep = CreateBackground(scene.Name);
|
||||||
|
scene.Elements.Insert(0, keep);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Source.Type's setter derives IsBackground from the enum, so a
|
||||||
|
// flavor correction must re-assert the flag afterwards.
|
||||||
|
if (keep.Type != wantedType)
|
||||||
|
{
|
||||||
|
keep.Type = wantedType;
|
||||||
|
keep.IsBackground = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
keep.Name = "Background";
|
||||||
|
keep.IsEnabled = true;
|
||||||
|
|
||||||
|
var index = scene.Elements.IndexOf(keep);
|
||||||
|
if (index > 0)
|
||||||
|
scene.Elements.Move(index, 0);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Only the Live screen's background is a real-time surface. Every other
|
||||||
|
// lookup below (auto-capture, focus hooks, refresh) must ignore the static
|
||||||
|
// default-art rows so they can never start a desktop capture session.
|
||||||
|
private IEnumerable<Source> AllBackgrounds()
|
||||||
|
=> Scenes.Where(s => SceneCatalog.Is(s.Name, SceneCatalog.Live))
|
||||||
|
.SelectMany(s => s.Elements.OfType<Source>().Where(x => x.IsBackground));
|
||||||
|
}
|
||||||
@@ -146,156 +146,6 @@ public partial class MainViewModel
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
internal static System.Windows.Media.Imaging.BitmapSource? LoadBackgroundImage(Scene scene)
|
|
||||||
{
|
|
||||||
var bg = scene.Elements.OfType<Source>().FirstOrDefault(s => s.IsBackground);
|
|
||||||
if (bg != null && !bg.UseDefaultBackground
|
|
||||||
&& !string.IsNullOrWhiteSpace(bg.CustomBackgroundPath)
|
|
||||||
&& System.IO.File.Exists(bg.CustomBackgroundPath))
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var bitmap = new System.Windows.Media.Imaging.BitmapImage();
|
|
||||||
bitmap.BeginInit();
|
|
||||||
bitmap.UriSource = new Uri(bg.CustomBackgroundPath);
|
|
||||||
bitmap.CacheOption = System.Windows.Media.Imaging.BitmapCacheOption.OnLoad;
|
|
||||||
bitmap.EndInit();
|
|
||||||
bitmap.Freeze();
|
|
||||||
return bitmap;
|
|
||||||
}
|
|
||||||
catch { /* fall through to AssetId */ }
|
|
||||||
}
|
|
||||||
if (bg != null && !string.IsNullOrWhiteSpace(bg.AssetId))
|
|
||||||
return ImageCache.Get(bg.AssetId);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static BitmapSource CreatePlaceholderSnapshot(string sceneName)
|
|
||||||
{
|
|
||||||
var colors = new Dictionary<string, System.Windows.Media.Brush>(StringComparer.OrdinalIgnoreCase)
|
|
||||||
{
|
|
||||||
["Starting"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(233, 69, 96)),
|
|
||||||
["Live"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(34, 197, 94)),
|
|
||||||
["BRB"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(234, 179, 8)),
|
|
||||||
["Chat"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(59, 130, 246)),
|
|
||||||
["Ending"] = new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(168, 85, 247)),
|
|
||||||
};
|
|
||||||
var brush = colors.TryGetValue(sceneName, out var c) ? c
|
|
||||||
: new System.Windows.Media.SolidColorBrush(System.Windows.Media.Color.FromRgb(60, 60, 80));
|
|
||||||
var dv = new System.Windows.Media.DrawingVisual();
|
|
||||||
using (var ctx = dv.RenderOpen())
|
|
||||||
{
|
|
||||||
ctx.DrawRectangle(brush, null, new System.Windows.Rect(0, 0, 320, 180));
|
|
||||||
var ft = new System.Windows.Media.FormattedText(
|
|
||||||
sceneName,
|
|
||||||
System.Globalization.CultureInfo.InvariantCulture,
|
|
||||||
System.Windows.FlowDirection.LeftToRight,
|
|
||||||
new System.Windows.Media.Typeface("Segoe UI"),
|
|
||||||
18,
|
|
||||||
System.Windows.Media.Brushes.White,
|
|
||||||
96);
|
|
||||||
ctx.DrawText(ft, new System.Windows.Point(160 - ft.Width / 2, 90 - ft.Height / 2));
|
|
||||||
}
|
|
||||||
var rtb = new System.Windows.Media.Imaging.RenderTargetBitmap(
|
|
||||||
320, 180, 96, 96, System.Windows.Media.PixelFormats.Pbgra32);
|
|
||||||
rtb.Render(dv);
|
|
||||||
rtb.Freeze();
|
|
||||||
return rtb;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ─── Screen background capture (live desktop/game) ───
|
|
||||||
|
|
||||||
private const string MonitorKeyPrefix = "monitor:";
|
|
||||||
|
|
||||||
/// <summary>Every background-enabled scene has exactly one background, kept at index 0 (bottom layer).
|
|
||||||
/// Returns null for a scene with <see cref="Scene.HasBackground"/> = false.</summary>
|
|
||||||
internal static Source? EnsureBackground(Scene scene)
|
|
||||||
{
|
|
||||||
if (!scene.HasBackground) return null;
|
|
||||||
var background = scene.Elements.OfType<Source>().FirstOrDefault(s => s.IsBackground);
|
|
||||||
if (background != null) return background;
|
|
||||||
|
|
||||||
background = CreateBackground(scene.Name);
|
|
||||||
scene.Elements.Insert(0, background);
|
|
||||||
return background;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>The one Background row for a scene. Live gets the capture flavor
|
|
||||||
/// (Show Desktop / monitor switch / fullscreen-game detect) falling back to
|
|
||||||
/// live-background.jpg; every other screen is a static default-art layer.
|
|
||||||
/// Both are named "Background" — the user never sees capture jargon here.</summary>
|
|
||||||
internal static Source CreateBackground(string sceneName)
|
|
||||||
{
|
|
||||||
var isLive = SceneCatalog.Is(sceneName, SceneCatalog.Live);
|
|
||||||
return new Source
|
|
||||||
{
|
|
||||||
Name = "Background",
|
|
||||||
Type = isLive ? SourceType.DisplayCapture : SourceType.Background,
|
|
||||||
IsBackground = true,
|
|
||||||
IsEnabled = true,
|
|
||||||
X = 0,
|
|
||||||
Y = 0,
|
|
||||||
Width = MasterFrameWidth,
|
|
||||||
Height = MasterFrameHeight,
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>Heals any loaded layout to the locked Background model: exactly
|
|
||||||
/// one Background per canonical scene, correct flavor for the scene (static
|
|
||||||
/// art everywhere, DisplayCapture on Live only), at index 0, named
|
|
||||||
/// "Background". Duplicates and stale rows are dropped; missing ones seeded;
|
|
||||||
/// non-canonical scenes get HasBackground=false and lose any backgrounds.</summary>
|
|
||||||
internal static void NormalizeBackgrounds(IEnumerable<Scene> scenes)
|
|
||||||
{
|
|
||||||
foreach (var scene in scenes)
|
|
||||||
{
|
|
||||||
if (!SceneCatalog.HasBackground(scene.Name))
|
|
||||||
{
|
|
||||||
scene.HasBackground = false;
|
|
||||||
foreach (var stale in scene.Elements.OfType<Source>().Where(s => s.IsBackground).ToList())
|
|
||||||
scene.Elements.Remove(stale);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
scene.HasBackground = true;
|
|
||||||
var isLive = SceneCatalog.Is(scene.Name, SceneCatalog.Live);
|
|
||||||
var wantedType = isLive ? SourceType.DisplayCapture : SourceType.Background;
|
|
||||||
|
|
||||||
var candidates = scene.Elements.OfType<Source>().Where(s => s.IsBackground).ToList();
|
|
||||||
var keep = candidates.FirstOrDefault(b => b.Type == wantedType) ?? candidates.FirstOrDefault();
|
|
||||||
|
|
||||||
foreach (var extra in candidates.Where(b => !ReferenceEquals(b, keep)))
|
|
||||||
scene.Elements.Remove(extra);
|
|
||||||
|
|
||||||
if (keep == null)
|
|
||||||
{
|
|
||||||
keep = CreateBackground(scene.Name);
|
|
||||||
scene.Elements.Insert(0, keep);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Source.Type's setter derives IsBackground from the enum, so a
|
|
||||||
// flavor correction must re-assert the flag afterwards.
|
|
||||||
if (keep.Type != wantedType)
|
|
||||||
{
|
|
||||||
keep.Type = wantedType;
|
|
||||||
keep.IsBackground = true;
|
|
||||||
}
|
|
||||||
|
|
||||||
keep.Name = "Background";
|
|
||||||
keep.IsEnabled = true;
|
|
||||||
|
|
||||||
var index = scene.Elements.IndexOf(keep);
|
|
||||||
if (index > 0)
|
|
||||||
scene.Elements.Move(index, 0);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Only the Live screen's background is a real-time surface. Every other
|
|
||||||
// lookup below (auto-capture, focus hooks, refresh) must ignore the static
|
|
||||||
// default-art rows so they can never start a desktop capture session.
|
|
||||||
private IEnumerable<Source> AllBackgrounds()
|
|
||||||
=> Scenes.Where(s => SceneCatalog.Is(s.Name, SceneCatalog.Live))
|
|
||||||
.SelectMany(s => s.Elements.OfType<Source>().Where(x => x.IsBackground));
|
|
||||||
|
|
||||||
// Full-screen game on its monitor, else null (static bg fallback — no
|
// Full-screen game on its monitor, else null (static bg fallback — no
|
||||||
// infinity mirror). Called at launch (from ReacquireScreenCaptures, before
|
// infinity mirror). Called at launch (from ReacquireScreenCaptures, before
|
||||||
@@ -565,4 +415,4 @@ public partial class MainViewModel
|
|||||||
}
|
}
|
||||||
catch { /* non-critical — the app works without default art */ }
|
catch { /* non-critical — the app works without default art */ }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,475 @@
|
|||||||
|
using System;
|
||||||
|
using System.IO;
|
||||||
|
using System.Threading;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
using System.Windows;
|
||||||
|
using Microsoft.Win32;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.Services;
|
||||||
|
using ytLive.Services.Encoder;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel : ViewModelBase
|
||||||
|
{
|
||||||
|
|
||||||
|
/// <summary>Entry point for the primary Start button (and the start/stop hotkey):
|
||||||
|
/// routes to a record session or the YouTube go-live dialog by the pill state.</summary>
|
||||||
|
private void StartSession()
|
||||||
|
{
|
||||||
|
if (IsLive || IsRecording) return;
|
||||||
|
var streaming = OnAirPillOn;
|
||||||
|
var recording = RecordPillOn;
|
||||||
|
if (!streaming && !recording) return;
|
||||||
|
|
||||||
|
if (!streaming)
|
||||||
|
{
|
||||||
|
BeginRecordOnly();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
BeginGoLive(recording);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Record-only (REC pill on, ON-AIR off): no YouTube dialog — recording
|
||||||
|
/// is local and works signed-out. Generates the auto-named file and starts the
|
||||||
|
/// pipeline immediately.</summary>
|
||||||
|
private async void BeginRecordOnly()
|
||||||
|
{
|
||||||
|
var path = StartRecordFile();
|
||||||
|
if (path == null)
|
||||||
|
{
|
||||||
|
_notifications.Error("Couldn't record", "No record output path could be created.");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
_recordStartTime = DateTime.Now;
|
||||||
|
_liveElapsed = TimeSpan.Zero;
|
||||||
|
_recordLength = TimeSpan.Zero;
|
||||||
|
ResetHealth(StreamStatus.Offline);
|
||||||
|
_audioMixer.StartLive(EncoderOptions.DefaultAudioPipeName);
|
||||||
|
IsRecording = true;
|
||||||
|
await _framePump.StartAsync();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void BeginGoLive(bool alsoRecord)
|
||||||
|
{
|
||||||
|
var dialog = new GoLiveViewModel(() => SignInAsync(), _youtubeAuth.CurrentChannel)
|
||||||
|
{
|
||||||
|
StreamTitle = BroadcastForm.Title,
|
||||||
|
StreamDescription = BroadcastForm.Description,
|
||||||
|
};
|
||||||
|
var window = new ytLive.GoLiveWindow(dialog) { Owner = System.Windows.Application.Current.MainWindow };
|
||||||
|
if (window.ShowDialog() == true)
|
||||||
|
{
|
||||||
|
StreamTitle = dialog.StreamTitle;
|
||||||
|
StreamDescription = dialog.StreamDescription;
|
||||||
|
StreamVisibility = dialog.Visibility; // always "Private" (ship step 7)
|
||||||
|
BroadcastForm.CaptureGoLive(dialog.StreamTitle, dialog.StreamDescription, DateTime.UtcNow);
|
||||||
|
WindowTitle = string.IsNullOrWhiteSpace(dialog.StreamTitle)
|
||||||
|
? "LlamaCasty"
|
||||||
|
: $"{dialog.StreamTitle} — LlamaCasty";
|
||||||
|
StreamStatus = StreamStatus.Streaming;
|
||||||
|
ResetHealth(StreamStatus.Streaming);
|
||||||
|
_audioMixer.StartLive(EncoderOptions.DefaultAudioPipeName);
|
||||||
|
_liveElapsed = TimeSpan.Zero;
|
||||||
|
_recordLength = TimeSpan.Zero;
|
||||||
|
|
||||||
|
var recordStarted = false;
|
||||||
|
if (alsoRecord)
|
||||||
|
{
|
||||||
|
if (StartRecordFile() == null)
|
||||||
|
{
|
||||||
|
_notifications.Error("Couldn't record",
|
||||||
|
"No record output path could be created — streaming continues without recording.");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_recordStartTime = DateTime.Now;
|
||||||
|
recordStarted = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
IsRecording = recordStarted;
|
||||||
|
|
||||||
|
_ = PrepareAndStartLiveAsync();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Creates the record file (auto-named <c>ty-…-0000.mp4</c> in the record
|
||||||
|
/// folder) and returns its path, or null when the folder can't be prepared.</summary>
|
||||||
|
private string? StartRecordFile()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var folder = _recordFolder ?? DefaultRecordFolder();
|
||||||
|
Directory.CreateDirectory(folder);
|
||||||
|
var name = RecordingFile.BuildStartName(DateTime.Now) + ".mp4";
|
||||||
|
var path = Path.Combine(folder, name);
|
||||||
|
_activeRecordPath = path;
|
||||||
|
return path;
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write(ex, "Recording: failed to prepare output path");
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>One-click go-live (TASK 5): ensure the reusable stream, create a
|
||||||
|
/// broadcast bound to it, then start the frame pump. The pump reads the RTMP
|
||||||
|
/// URL once at startup (FramePump.StartAsync), so the stream URL must be set
|
||||||
|
/// before the pump starts — hence the ordering here. Failures surface as an
|
||||||
|
/// error health state, never a crash.</summary>
|
||||||
|
private async Task PrepareAndStartLiveAsync()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var stream = await _youtubeStream.GetOrCreateReusableStreamAsync();
|
||||||
|
if (stream == null)
|
||||||
|
{
|
||||||
|
AppLog.Write("Reusable stream unavailable; check the OAuth session");
|
||||||
|
_notifications.Error("Couldn't go live",
|
||||||
|
"The reusable stream is unavailable — check the YouTube sign-in and try again.");
|
||||||
|
StreamStatus = StreamStatus.Error;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
_reusableStream = stream;
|
||||||
|
_reusableStreamUrl = stream.RtmpUrl;
|
||||||
|
_layoutStore.SaveReusableStream(stream);
|
||||||
|
|
||||||
|
_currentBroadcastId = await _youtubeStream.CreateBroadcast(
|
||||||
|
StreamTitle, StreamDescription, DateTime.UtcNow, stream.Id);
|
||||||
|
if (_currentBroadcastId == null)
|
||||||
|
{
|
||||||
|
AppLog.Write("Broadcast creation failed; check the OAuth session");
|
||||||
|
_notifications.Error("Couldn't go live", "YouTube rejected the broadcast — check the sign-in and try again.");
|
||||||
|
StreamStatus = StreamStatus.Error;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
AppLog.Write($"Broadcast created: {_currentBroadcastId}");
|
||||||
|
OnPropertyChanged(nameof(CurrentBroadcastId));
|
||||||
|
|
||||||
|
if (string.IsNullOrWhiteSpace(StreamTitle) && string.IsNullOrWhiteSpace(StreamDescription))
|
||||||
|
{
|
||||||
|
BroadcastForm.IsDrawerOpen = true;
|
||||||
|
_notifications.Warning("Complete your broadcast details",
|
||||||
|
"Your title and description are empty — fill them in from the Text panel on the right.");
|
||||||
|
}
|
||||||
|
|
||||||
|
// Start chat polling (TASK 9.4): fetch the liveChatId from the broadcast's
|
||||||
|
// contentDetails, then start the poll loop. Chat is non-fatal — if it fails,
|
||||||
|
// the stream continues without on-panel chat.
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var liveChatId = await _youtubeStream.GetBroadcastLiveChatIdAsync(_currentBroadcastId);
|
||||||
|
if (liveChatId != null)
|
||||||
|
{
|
||||||
|
_youtubeChat.Start(liveChatId);
|
||||||
|
AppLog.Write($"Chat polling started: {liveChatId}");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
AppLog.Write("Could not retrieve liveChatId; chat polling disabled");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception chatEx)
|
||||||
|
{
|
||||||
|
AppLog.Write($"Chat start failed (non-fatal): {chatEx.Message}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write($"Go-live preparation failed: {ex.Message}");
|
||||||
|
_notifications.Error("Couldn't go live", ex.Message);
|
||||||
|
StreamStatus = StreamStatus.Error;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
await _framePump.StartAsync(); // never throws; failures log + surface via Failed
|
||||||
|
|
||||||
|
// Health polling (TASK 5 item 3): poll immediately, then every 30s while
|
||||||
|
// live. Report-by-exception — a banner appears only on warning/error.
|
||||||
|
_healthPollTimer.Start();
|
||||||
|
_ = PollHealthAsync();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void OnHealthPollTick(object? sender, EventArgs e) => _ = PollHealthAsync();
|
||||||
|
|
||||||
|
/// <summary>One liveStreams.list poll (TASK 5 item 3): updates the YouTube
|
||||||
|
/// health state + the report-by-exception banner. Never throws — a poll
|
||||||
|
/// failure logs and leaves the last state untouched.</summary>
|
||||||
|
private async Task PollHealthAsync()
|
||||||
|
{
|
||||||
|
if (_reusableStream == null || !IsLive) return;
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var health = await _youtubeStream.GetStreamHealthAsync(_reusableStream.Id);
|
||||||
|
if (health == null)
|
||||||
|
{
|
||||||
|
AppLog.Write("Stream health poll failed; check the OAuth session");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
CurrentHealth.HealthStatus = health.HealthStatus;
|
||||||
|
CurrentHealth.HealthMessage = health.HealthStatus;
|
||||||
|
CurrentHealth.ConfigurationIssues.Clear();
|
||||||
|
CurrentHealth.ConfigurationIssues.AddRange(health.ConfigurationIssues);
|
||||||
|
OnPropertyChanged(nameof(CurrentHealth));
|
||||||
|
ApplyHealthIssue(health.ConfigurationIssues);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write($"Stream health poll failed: {ex.Message}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Report-by-exception: good/ok/noData (or info-only issues) clear the banner;
|
||||||
|
// the first warning/error issue raises it, colored by the worst severity.
|
||||||
|
private void ApplyHealthIssue(List<StreamConfigurationIssue> issues)
|
||||||
|
{
|
||||||
|
var report = StreamHealthReporter.BannerFor(issues);
|
||||||
|
if (report.Text == null)
|
||||||
|
{
|
||||||
|
HealthIssueBanner = null;
|
||||||
|
HealthIssueBackground = "Transparent";
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
HealthIssueBackground = report.IsError ? "#8f1f1f" : "#b8860b";
|
||||||
|
HealthIssueBanner = report.Text;
|
||||||
|
}
|
||||||
|
|
||||||
|
private async void StopStream()
|
||||||
|
{
|
||||||
|
var wasLive = IsLive;
|
||||||
|
var wasRecording = IsRecording;
|
||||||
|
|
||||||
|
StreamStatus = StreamStatus.Offline;
|
||||||
|
IsRecording = false;
|
||||||
|
WindowTitle = "LlamaCasty";
|
||||||
|
ResetHealth(StreamStatus.Offline);
|
||||||
|
// Stop chat polling first (TASK 9.4) — no more messages arriving while
|
||||||
|
// we're tearing down the stream.
|
||||||
|
_youtubeChat.Stop();
|
||||||
|
// Close the audio pipe FIRST so ffmpeg sees EOF on the audio input,
|
||||||
|
// then stop the pump (stdin EOF) — both inputs end and the encoder
|
||||||
|
// finalizes the output. Audio capture itself is always-on (preview
|
||||||
|
// monitoring); only the live/report pipe, the pump, and the session stop here.
|
||||||
|
_audioMixer.StopLive();
|
||||||
|
await _framePump.StopAsync();
|
||||||
|
_currentBroadcastId = null;
|
||||||
|
OnPropertyChanged(nameof(CurrentBroadcastId));
|
||||||
|
|
||||||
|
if (wasRecording) await FinalizeRecordingAsync();
|
||||||
|
|
||||||
|
// Explicit sign-out only (TASK 18): stopping the stream does NOT clear
|
||||||
|
// the session/token — the creator signs out deliberately via the
|
||||||
|
// Logout / Change Account commands.
|
||||||
|
AppLog.Write(wasLive ? "Stream ended" : "Recording ended");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>On stop the auto-named <c>ty-…-0000.mp4</c> file is renamed to carry
|
||||||
|
/// the real recording length (<c>ty-…-hh2mm2.mp4</c>), with a numeric suffix on
|
||||||
|
/// name collisions. Runs only after the pump has fully closed the file.</summary>
|
||||||
|
private async Task FinalizeRecordingAsync()
|
||||||
|
{
|
||||||
|
var startPath = _activeRecordPath;
|
||||||
|
_activeRecordPath = null;
|
||||||
|
if (string.IsNullOrEmpty(startPath)) return;
|
||||||
|
try
|
||||||
|
{
|
||||||
|
while (_framePump.IsRunning) await Task.Delay(50);
|
||||||
|
|
||||||
|
if (!File.Exists(startPath))
|
||||||
|
{
|
||||||
|
AppLog.Write($"Recording: output not found for rename: {startPath}");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
_recordLength = _liveElapsed;
|
||||||
|
var autoStem = RecordingFile.BuildFinalName(_recordStartTime, _recordLength);
|
||||||
|
var dir = Path.GetDirectoryName(startPath)!;
|
||||||
|
|
||||||
|
// Manual rename modal: give the creator a chance to name the recording;
|
||||||
|
// null = keep the auto name (or the default recorded above).
|
||||||
|
string stem = autoStem;
|
||||||
|
var dialog = new RenameRecordingDialog(autoStem);
|
||||||
|
if (dialog.ShowDialog() == true && !string.IsNullOrEmpty(dialog.ResultFileName))
|
||||||
|
stem = dialog.ResultFileName;
|
||||||
|
|
||||||
|
var finalPath = UniquePath(Path.Combine(dir, stem + ".mp4"));
|
||||||
|
File.Move(startPath, finalPath);
|
||||||
|
AppLog.Write($"Recording saved: {finalPath}");
|
||||||
|
_notifications.Info("Recording saved",
|
||||||
|
Path.GetFileName(finalPath) + " — you can rename it in your videos folder at any time.");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write(ex, "Recording: rename-on-stop failed");
|
||||||
|
_notifications.Error("Recording saved",
|
||||||
|
$"The recording was written but couldn't be renamed: {Path.GetFileName(startPath)}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private static string UniquePath(string path)
|
||||||
|
{
|
||||||
|
if (!File.Exists(path)) return path;
|
||||||
|
var dir = Path.GetDirectoryName(path)!;
|
||||||
|
var name = Path.GetFileNameWithoutExtension(path);
|
||||||
|
var ext = Path.GetExtension(path);
|
||||||
|
for (var i = 2; ; i++)
|
||||||
|
{
|
||||||
|
var candidate = Path.Combine(dir, $"{name}-{i}{ext}");
|
||||||
|
if (!File.Exists(candidate)) return candidate;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ChooseRecordFolder()
|
||||||
|
{
|
||||||
|
var dialog = new Microsoft.Win32.OpenFolderDialog
|
||||||
|
{
|
||||||
|
Title = "Choose a folder for local recordings",
|
||||||
|
InitialDirectory = _recordFolder ?? DefaultRecordFolder(),
|
||||||
|
};
|
||||||
|
if (dialog.ShowDialog() == true)
|
||||||
|
{
|
||||||
|
_recordFolder = dialog.FolderName;
|
||||||
|
_layoutStore.SaveRecordFolder(_recordFolder);
|
||||||
|
OnPropertyChanged(nameof(RecordFolderDisplay));
|
||||||
|
_notifications.Info("Record folder set", _recordFolder);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ResetRecordFolder()
|
||||||
|
{
|
||||||
|
_recordFolder = null;
|
||||||
|
_layoutStore.SaveRecordFolder(null);
|
||||||
|
OnPropertyChanged(nameof(RecordFolderDisplay));
|
||||||
|
_notifications.Info("Record folder reset", RecordFolderDisplay);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Falls back to the user's Downloads folder when no preference is set;
|
||||||
|
/// returns MyVideos if Downloads doesn't exist.</summary>
|
||||||
|
internal static string DefaultRecordFolder()
|
||||||
|
{
|
||||||
|
var downloads = Path.Combine(
|
||||||
|
Environment.GetFolderPath(Environment.SpecialFolder.UserProfile), "Downloads");
|
||||||
|
return Directory.Exists(downloads)
|
||||||
|
? downloads
|
||||||
|
: Environment.GetFolderPath(Environment.SpecialFolder.MyVideos);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Full encoder options for the current tier, or null when no RTMP URL is
|
||||||
|
// available — the pump then skips the encoder entirely (TASK 5 fills the seam).
|
||||||
|
private EncoderOptions? BuildEncoderOptions()
|
||||||
|
{
|
||||||
|
var url = _rtmpUrlProvider();
|
||||||
|
var quality = SelectedQuality;
|
||||||
|
return new EncoderOptions
|
||||||
|
{
|
||||||
|
RtmpUrl = url ?? string.Empty,
|
||||||
|
StreamEnabled = OnAirPillOn,
|
||||||
|
RecordEnabled = RecordPillOn,
|
||||||
|
RecordPath = _activeRecordPath,
|
||||||
|
Width = quality.Width,
|
||||||
|
Height = quality.Height,
|
||||||
|
Fps = quality.Fps,
|
||||||
|
BitrateKbps = (int)Math.Round(quality.Bitrate * 1000),
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
private void OnFramePumpFailed(object? sender, string message)
|
||||||
|
{
|
||||||
|
AppLog.Write($"Frame pump failed: {message}");
|
||||||
|
_notifications.Error("The stream pipeline stopped", message);
|
||||||
|
if (IsLive) StreamStatus = StreamStatus.Error;
|
||||||
|
}
|
||||||
|
|
||||||
|
// TASK 4 ship step 6: the encoder's parsed health (bitrate/FPS/dropped/
|
||||||
|
// duration) lands in the bottom bar. The stderr loop raises on a background
|
||||||
|
// thread — marshal to the UI thread like the audio level handlers.
|
||||||
|
private void OnFramePumpHealthUpdated(object? sender, StreamHealth health)
|
||||||
|
{
|
||||||
|
var dispatcher = System.Windows.Application.Current?.Dispatcher;
|
||||||
|
if (dispatcher != null && !dispatcher.CheckAccess())
|
||||||
|
dispatcher.BeginInvoke(() => ApplyHealth(health));
|
||||||
|
else
|
||||||
|
ApplyHealth(health);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ApplyHealth(StreamHealth health)
|
||||||
|
{
|
||||||
|
CurrentHealth.Status = health.Status;
|
||||||
|
CurrentHealth.CurrentBitrate = health.CurrentBitrate;
|
||||||
|
CurrentHealth.FPS = health.FPS;
|
||||||
|
CurrentHealth.DroppedFrames = health.DroppedFrames;
|
||||||
|
CurrentHealth.StreamDuration = health.StreamDuration;
|
||||||
|
CurrentHealth.LastError = health.LastError;
|
||||||
|
CurrentHealth.HealthMessage = health.HealthMessage;
|
||||||
|
OnPropertyChanged(nameof(CurrentHealth));
|
||||||
|
}
|
||||||
|
|
||||||
|
// Keeps the bottom-bar stats honest across sessions: dropped frames and the
|
||||||
|
// elapsed duration must not linger from a previous go-live (bitrate/FPS stay
|
||||||
|
// on the tier's targets — ApplyStreamQuality sets them on pick).
|
||||||
|
private void ResetHealth(StreamStatus status)
|
||||||
|
{
|
||||||
|
CurrentHealth.Status = status;
|
||||||
|
CurrentHealth.DroppedFrames = 0;
|
||||||
|
CurrentHealth.StreamDuration = TimeSpan.Zero;
|
||||||
|
CurrentHealth.LastError = null;
|
||||||
|
CurrentHealth.HealthStatus = null;
|
||||||
|
CurrentHealth.HealthMessage = null;
|
||||||
|
CurrentHealth.ConfigurationIssues.Clear();
|
||||||
|
HealthIssueBanner = null;
|
||||||
|
HealthIssueBackground = "Transparent";
|
||||||
|
OnPropertyChanged(nameof(CurrentHealth));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void UpdateLiveVisuals()
|
||||||
|
{
|
||||||
|
var live = IsLive;
|
||||||
|
TopBarBackground = live ? "#e94560" : "#16213e";
|
||||||
|
PreviewGlowBrush = live ? "#e94560" : "Transparent";
|
||||||
|
PreviewGlowThickness = live ? new Thickness(3) : new Thickness(0);
|
||||||
|
|
||||||
|
if (live)
|
||||||
|
{
|
||||||
|
if (BrandFlashEnabled) StartBrandFlashTimer();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_healthPollTimer.Stop();
|
||||||
|
_brandFlashTimer.Stop();
|
||||||
|
_brandFlashOffTimer.Stop();
|
||||||
|
BrandFlashActive = false;
|
||||||
|
}
|
||||||
|
UpdateSessionTimer();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Runs the elapsed/rec-dot-pulse timer while a session is active —
|
||||||
|
/// live (Streaming) OR recording. Reset the elapsed when a new session starts.</summary>
|
||||||
|
private void UpdateSessionTimer()
|
||||||
|
{
|
||||||
|
var active = IsLive || IsRecording;
|
||||||
|
if (active)
|
||||||
|
{
|
||||||
|
_recDotPulse = 1.0;
|
||||||
|
_liveTimer.Start();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_liveTimer.Stop();
|
||||||
|
LiveElapsedText = "00:00:00";
|
||||||
|
_recDotPulse = 1.0;
|
||||||
|
}
|
||||||
|
OnPropertyChanged(nameof(RecDotOpacity));
|
||||||
|
OnPropertyChanged(nameof(LiveElapsedText));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void OnLiveTimerTick(object? sender, EventArgs e)
|
||||||
|
{
|
||||||
|
_liveElapsed = _liveElapsed.Add(TimeSpan.FromSeconds(1));
|
||||||
|
LiveElapsedText = _liveElapsed.ToString(@"hh\:mm\:ss");
|
||||||
|
_recordLength = _liveElapsed;
|
||||||
|
_recDotPulse = _recDotPulse > 0.5 ? 0.35 : 1.0;
|
||||||
|
OnPropertyChanged(nameof(RecDotOpacity));
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,9 +1,7 @@
|
|||||||
using System.Collections.ObjectModel;
|
using System.Collections.ObjectModel;
|
||||||
using System.IO;
|
|
||||||
using System.Windows;
|
using System.Windows;
|
||||||
using System.Windows.Input;
|
using System.Windows.Input;
|
||||||
using System.Windows.Threading;
|
using System.Windows.Threading;
|
||||||
using Microsoft.Win32;
|
|
||||||
using ytLive.Helpers;
|
using ytLive.Helpers;
|
||||||
using ytLive.Models;
|
using ytLive.Models;
|
||||||
using ytLive.Services;
|
using ytLive.Services;
|
||||||
@@ -327,463 +325,4 @@ public partial class MainViewModel : ViewModelBase
|
|||||||
public ICommand EndStreamCommand { get; }
|
public ICommand EndStreamCommand { get; }
|
||||||
public ICommand ChooseRecordFolderCommand { get; }
|
public ICommand ChooseRecordFolderCommand { get; }
|
||||||
public ICommand ResetRecordFolderCommand { get; }
|
public ICommand ResetRecordFolderCommand { get; }
|
||||||
|
|
||||||
/// <summary>Entry point for the primary Start button (and the start/stop hotkey):
|
|
||||||
/// routes to a record session or the YouTube go-live dialog by the pill state.</summary>
|
|
||||||
private void StartSession()
|
|
||||||
{
|
|
||||||
if (IsLive || IsRecording) return;
|
|
||||||
var streaming = OnAirPillOn;
|
|
||||||
var recording = RecordPillOn;
|
|
||||||
if (!streaming && !recording) return;
|
|
||||||
|
|
||||||
if (!streaming)
|
|
||||||
{
|
|
||||||
BeginRecordOnly();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
BeginGoLive(recording);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>Record-only (REC pill on, ON-AIR off): no YouTube dialog — recording
|
|
||||||
/// is local and works signed-out. Generates the auto-named file and starts the
|
|
||||||
/// pipeline immediately.</summary>
|
|
||||||
private async void BeginRecordOnly()
|
|
||||||
{
|
|
||||||
var path = StartRecordFile();
|
|
||||||
if (path == null)
|
|
||||||
{
|
|
||||||
_notifications.Error("Couldn't record", "No record output path could be created.");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
_recordStartTime = DateTime.Now;
|
|
||||||
_liveElapsed = TimeSpan.Zero;
|
|
||||||
_recordLength = TimeSpan.Zero;
|
|
||||||
ResetHealth(StreamStatus.Offline);
|
|
||||||
_audioMixer.StartLive(EncoderOptions.DefaultAudioPipeName);
|
|
||||||
IsRecording = true;
|
|
||||||
await _framePump.StartAsync();
|
|
||||||
}
|
|
||||||
|
|
||||||
private void BeginGoLive(bool alsoRecord)
|
|
||||||
{
|
|
||||||
var dialog = new GoLiveViewModel(() => SignInAsync(), _youtubeAuth.CurrentChannel)
|
|
||||||
{
|
|
||||||
StreamTitle = BroadcastForm.Title,
|
|
||||||
StreamDescription = BroadcastForm.Description,
|
|
||||||
};
|
|
||||||
var window = new ytLive.GoLiveWindow(dialog) { Owner = System.Windows.Application.Current.MainWindow };
|
|
||||||
if (window.ShowDialog() == true)
|
|
||||||
{
|
|
||||||
StreamTitle = dialog.StreamTitle;
|
|
||||||
StreamDescription = dialog.StreamDescription;
|
|
||||||
StreamVisibility = dialog.Visibility; // always "Private" (ship step 7)
|
|
||||||
BroadcastForm.CaptureGoLive(dialog.StreamTitle, dialog.StreamDescription, DateTime.UtcNow);
|
|
||||||
WindowTitle = string.IsNullOrWhiteSpace(dialog.StreamTitle)
|
|
||||||
? "LlamaCasty"
|
|
||||||
: $"{dialog.StreamTitle} — LlamaCasty";
|
|
||||||
StreamStatus = StreamStatus.Streaming;
|
|
||||||
ResetHealth(StreamStatus.Streaming);
|
|
||||||
_audioMixer.StartLive(EncoderOptions.DefaultAudioPipeName);
|
|
||||||
_liveElapsed = TimeSpan.Zero;
|
|
||||||
_recordLength = TimeSpan.Zero;
|
|
||||||
|
|
||||||
var recordStarted = false;
|
|
||||||
if (alsoRecord)
|
|
||||||
{
|
|
||||||
if (StartRecordFile() == null)
|
|
||||||
{
|
|
||||||
_notifications.Error("Couldn't record",
|
|
||||||
"No record output path could be created — streaming continues without recording.");
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
_recordStartTime = DateTime.Now;
|
|
||||||
recordStarted = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
IsRecording = recordStarted;
|
|
||||||
|
|
||||||
_ = PrepareAndStartLiveAsync();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>Creates the record file (auto-named <c>ty-…-0000.mp4</c> in the record
|
|
||||||
/// folder) and returns its path, or null when the folder can't be prepared.</summary>
|
|
||||||
private string? StartRecordFile()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var folder = _recordFolder ?? DefaultRecordFolder();
|
|
||||||
Directory.CreateDirectory(folder);
|
|
||||||
var name = RecordingFile.BuildStartName(DateTime.Now) + ".mp4";
|
|
||||||
var path = Path.Combine(folder, name);
|
|
||||||
_activeRecordPath = path;
|
|
||||||
return path;
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
AppLog.Write(ex, "Recording: failed to prepare output path");
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>One-click go-live (TASK 5): ensure the reusable stream, create a
|
|
||||||
/// broadcast bound to it, then start the frame pump. The pump reads the RTMP
|
|
||||||
/// URL once at startup (FramePump.StartAsync), so the stream URL must be set
|
|
||||||
/// before the pump starts — hence the ordering here. Failures surface as an
|
|
||||||
/// error health state, never a crash.</summary>
|
|
||||||
private async Task PrepareAndStartLiveAsync()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var stream = await _youtubeStream.GetOrCreateReusableStreamAsync();
|
|
||||||
if (stream == null)
|
|
||||||
{
|
|
||||||
AppLog.Write("Reusable stream unavailable; check the OAuth session");
|
|
||||||
_notifications.Error("Couldn't go live",
|
|
||||||
"The reusable stream is unavailable — check the YouTube sign-in and try again.");
|
|
||||||
StreamStatus = StreamStatus.Error;
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
_reusableStream = stream;
|
|
||||||
_reusableStreamUrl = stream.RtmpUrl;
|
|
||||||
_layoutStore.SaveReusableStream(stream);
|
|
||||||
|
|
||||||
_currentBroadcastId = await _youtubeStream.CreateBroadcast(
|
|
||||||
StreamTitle, StreamDescription, DateTime.UtcNow, stream.Id);
|
|
||||||
if (_currentBroadcastId == null)
|
|
||||||
{
|
|
||||||
AppLog.Write("Broadcast creation failed; check the OAuth session");
|
|
||||||
_notifications.Error("Couldn't go live", "YouTube rejected the broadcast — check the sign-in and try again.");
|
|
||||||
StreamStatus = StreamStatus.Error;
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
AppLog.Write($"Broadcast created: {_currentBroadcastId}");
|
|
||||||
OnPropertyChanged(nameof(CurrentBroadcastId));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(StreamTitle) && string.IsNullOrWhiteSpace(StreamDescription))
|
|
||||||
{
|
|
||||||
BroadcastForm.IsDrawerOpen = true;
|
|
||||||
_notifications.Warning("Complete your broadcast details",
|
|
||||||
"Your title and description are empty — fill them in from the Text panel on the right.");
|
|
||||||
}
|
|
||||||
|
|
||||||
// Start chat polling (TASK 9.4): fetch the liveChatId from the broadcast's
|
|
||||||
// contentDetails, then start the poll loop. Chat is non-fatal — if it fails,
|
|
||||||
// the stream continues without on-panel chat.
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var liveChatId = await _youtubeStream.GetBroadcastLiveChatIdAsync(_currentBroadcastId);
|
|
||||||
if (liveChatId != null)
|
|
||||||
{
|
|
||||||
_youtubeChat.Start(liveChatId);
|
|
||||||
AppLog.Write($"Chat polling started: {liveChatId}");
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
AppLog.Write("Could not retrieve liveChatId; chat polling disabled");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception chatEx)
|
|
||||||
{
|
|
||||||
AppLog.Write($"Chat start failed (non-fatal): {chatEx.Message}");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
AppLog.Write($"Go-live preparation failed: {ex.Message}");
|
|
||||||
_notifications.Error("Couldn't go live", ex.Message);
|
|
||||||
StreamStatus = StreamStatus.Error;
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await _framePump.StartAsync(); // never throws; failures log + surface via Failed
|
|
||||||
|
|
||||||
// Health polling (TASK 5 item 3): poll immediately, then every 30s while
|
|
||||||
// live. Report-by-exception — a banner appears only on warning/error.
|
|
||||||
_healthPollTimer.Start();
|
|
||||||
_ = PollHealthAsync();
|
|
||||||
}
|
|
||||||
|
|
||||||
private void OnHealthPollTick(object? sender, EventArgs e) => _ = PollHealthAsync();
|
|
||||||
|
|
||||||
/// <summary>One liveStreams.list poll (TASK 5 item 3): updates the YouTube
|
|
||||||
/// health state + the report-by-exception banner. Never throws — a poll
|
|
||||||
/// failure logs and leaves the last state untouched.</summary>
|
|
||||||
private async Task PollHealthAsync()
|
|
||||||
{
|
|
||||||
if (_reusableStream == null || !IsLive) return;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var health = await _youtubeStream.GetStreamHealthAsync(_reusableStream.Id);
|
|
||||||
if (health == null)
|
|
||||||
{
|
|
||||||
AppLog.Write("Stream health poll failed; check the OAuth session");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
CurrentHealth.HealthStatus = health.HealthStatus;
|
|
||||||
CurrentHealth.HealthMessage = health.HealthStatus;
|
|
||||||
CurrentHealth.ConfigurationIssues.Clear();
|
|
||||||
CurrentHealth.ConfigurationIssues.AddRange(health.ConfigurationIssues);
|
|
||||||
OnPropertyChanged(nameof(CurrentHealth));
|
|
||||||
ApplyHealthIssue(health.ConfigurationIssues);
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
AppLog.Write($"Stream health poll failed: {ex.Message}");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Report-by-exception: good/ok/noData (or info-only issues) clear the banner;
|
|
||||||
// the first warning/error issue raises it, colored by the worst severity.
|
|
||||||
private void ApplyHealthIssue(List<StreamConfigurationIssue> issues)
|
|
||||||
{
|
|
||||||
var report = StreamHealthReporter.BannerFor(issues);
|
|
||||||
if (report.Text == null)
|
|
||||||
{
|
|
||||||
HealthIssueBanner = null;
|
|
||||||
HealthIssueBackground = "Transparent";
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
HealthIssueBackground = report.IsError ? "#8f1f1f" : "#b8860b";
|
|
||||||
HealthIssueBanner = report.Text;
|
|
||||||
}
|
|
||||||
|
|
||||||
private async void StopStream()
|
|
||||||
{
|
|
||||||
var wasLive = IsLive;
|
|
||||||
var wasRecording = IsRecording;
|
|
||||||
|
|
||||||
StreamStatus = StreamStatus.Offline;
|
|
||||||
IsRecording = false;
|
|
||||||
WindowTitle = "LlamaCasty";
|
|
||||||
ResetHealth(StreamStatus.Offline);
|
|
||||||
// Stop chat polling first (TASK 9.4) — no more messages arriving while
|
|
||||||
// we're tearing down the stream.
|
|
||||||
_youtubeChat.Stop();
|
|
||||||
// Close the audio pipe FIRST so ffmpeg sees EOF on the audio input,
|
|
||||||
// then stop the pump (stdin EOF) — both inputs end and the encoder
|
|
||||||
// finalizes the output. Audio capture itself is always-on (preview
|
|
||||||
// monitoring); only the live/report pipe, the pump, and the session stop here.
|
|
||||||
_audioMixer.StopLive();
|
|
||||||
await _framePump.StopAsync();
|
|
||||||
_currentBroadcastId = null;
|
|
||||||
OnPropertyChanged(nameof(CurrentBroadcastId));
|
|
||||||
|
|
||||||
if (wasRecording) await FinalizeRecordingAsync();
|
|
||||||
|
|
||||||
// Explicit sign-out only (TASK 18): stopping the stream does NOT clear
|
|
||||||
// the session/token — the creator signs out deliberately via the
|
|
||||||
// Logout / Change Account commands.
|
|
||||||
AppLog.Write(wasLive ? "Stream ended" : "Recording ended");
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>On stop the auto-named <c>ty-…-0000.mp4</c> file is renamed to carry
|
|
||||||
/// the real recording length (<c>ty-…-hh2mm2.mp4</c>), with a numeric suffix on
|
|
||||||
/// name collisions. Runs only after the pump has fully closed the file.</summary>
|
|
||||||
private async Task FinalizeRecordingAsync()
|
|
||||||
{
|
|
||||||
var startPath = _activeRecordPath;
|
|
||||||
_activeRecordPath = null;
|
|
||||||
if (string.IsNullOrEmpty(startPath)) return;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
while (_framePump.IsRunning) await Task.Delay(50);
|
|
||||||
|
|
||||||
if (!File.Exists(startPath))
|
|
||||||
{
|
|
||||||
AppLog.Write($"Recording: output not found for rename: {startPath}");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
_recordLength = _liveElapsed;
|
|
||||||
var autoStem = RecordingFile.BuildFinalName(_recordStartTime, _recordLength);
|
|
||||||
var dir = Path.GetDirectoryName(startPath)!;
|
|
||||||
|
|
||||||
// Manual rename modal: give the creator a chance to name the recording;
|
|
||||||
// null = keep the auto name (or the default recorded above).
|
|
||||||
string stem = autoStem;
|
|
||||||
var dialog = new RenameRecordingDialog(autoStem);
|
|
||||||
if (dialog.ShowDialog() == true && !string.IsNullOrEmpty(dialog.ResultFileName))
|
|
||||||
stem = dialog.ResultFileName;
|
|
||||||
|
|
||||||
var finalPath = UniquePath(Path.Combine(dir, stem + ".mp4"));
|
|
||||||
File.Move(startPath, finalPath);
|
|
||||||
AppLog.Write($"Recording saved: {finalPath}");
|
|
||||||
_notifications.Info("Recording saved",
|
|
||||||
Path.GetFileName(finalPath) + " — you can rename it in your videos folder at any time.");
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
AppLog.Write(ex, "Recording: rename-on-stop failed");
|
|
||||||
_notifications.Error("Recording saved",
|
|
||||||
$"The recording was written but couldn't be renamed: {Path.GetFileName(startPath)}");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private static string UniquePath(string path)
|
|
||||||
{
|
|
||||||
if (!File.Exists(path)) return path;
|
|
||||||
var dir = Path.GetDirectoryName(path)!;
|
|
||||||
var name = Path.GetFileNameWithoutExtension(path);
|
|
||||||
var ext = Path.GetExtension(path);
|
|
||||||
for (var i = 2; ; i++)
|
|
||||||
{
|
|
||||||
var candidate = Path.Combine(dir, $"{name}-{i}{ext}");
|
|
||||||
if (!File.Exists(candidate)) return candidate;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void ChooseRecordFolder()
|
|
||||||
{
|
|
||||||
var dialog = new Microsoft.Win32.OpenFolderDialog
|
|
||||||
{
|
|
||||||
Title = "Choose a folder for local recordings",
|
|
||||||
InitialDirectory = _recordFolder ?? DefaultRecordFolder(),
|
|
||||||
};
|
|
||||||
if (dialog.ShowDialog() == true)
|
|
||||||
{
|
|
||||||
_recordFolder = dialog.FolderName;
|
|
||||||
_layoutStore.SaveRecordFolder(_recordFolder);
|
|
||||||
OnPropertyChanged(nameof(RecordFolderDisplay));
|
|
||||||
_notifications.Info("Record folder set", _recordFolder);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void ResetRecordFolder()
|
|
||||||
{
|
|
||||||
_recordFolder = null;
|
|
||||||
_layoutStore.SaveRecordFolder(null);
|
|
||||||
OnPropertyChanged(nameof(RecordFolderDisplay));
|
|
||||||
_notifications.Info("Record folder reset", RecordFolderDisplay);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>Falls back to the user's Downloads folder when no preference is set;
|
|
||||||
/// returns MyVideos if Downloads doesn't exist.</summary>
|
|
||||||
internal static string DefaultRecordFolder()
|
|
||||||
{
|
|
||||||
var downloads = Path.Combine(
|
|
||||||
Environment.GetFolderPath(Environment.SpecialFolder.UserProfile), "Downloads");
|
|
||||||
return Directory.Exists(downloads)
|
|
||||||
? downloads
|
|
||||||
: Environment.GetFolderPath(Environment.SpecialFolder.MyVideos);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Full encoder options for the current tier, or null when no RTMP URL is
|
|
||||||
// available — the pump then skips the encoder entirely (TASK 5 fills the seam).
|
|
||||||
private EncoderOptions? BuildEncoderOptions()
|
|
||||||
{
|
|
||||||
var url = _rtmpUrlProvider();
|
|
||||||
var quality = SelectedQuality;
|
|
||||||
return new EncoderOptions
|
|
||||||
{
|
|
||||||
RtmpUrl = url ?? string.Empty,
|
|
||||||
StreamEnabled = OnAirPillOn,
|
|
||||||
RecordEnabled = RecordPillOn,
|
|
||||||
RecordPath = _activeRecordPath,
|
|
||||||
Width = quality.Width,
|
|
||||||
Height = quality.Height,
|
|
||||||
Fps = quality.Fps,
|
|
||||||
BitrateKbps = (int)Math.Round(quality.Bitrate * 1000),
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
private void OnFramePumpFailed(object? sender, string message)
|
|
||||||
{
|
|
||||||
AppLog.Write($"Frame pump failed: {message}");
|
|
||||||
_notifications.Error("The stream pipeline stopped", message);
|
|
||||||
if (IsLive) StreamStatus = StreamStatus.Error;
|
|
||||||
}
|
|
||||||
|
|
||||||
// TASK 4 ship step 6: the encoder's parsed health (bitrate/FPS/dropped/
|
|
||||||
// duration) lands in the bottom bar. The stderr loop raises on a background
|
|
||||||
// thread — marshal to the UI thread like the audio level handlers.
|
|
||||||
private void OnFramePumpHealthUpdated(object? sender, StreamHealth health)
|
|
||||||
{
|
|
||||||
var dispatcher = System.Windows.Application.Current?.Dispatcher;
|
|
||||||
if (dispatcher != null && !dispatcher.CheckAccess())
|
|
||||||
dispatcher.BeginInvoke(() => ApplyHealth(health));
|
|
||||||
else
|
|
||||||
ApplyHealth(health);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void ApplyHealth(StreamHealth health)
|
|
||||||
{
|
|
||||||
CurrentHealth.Status = health.Status;
|
|
||||||
CurrentHealth.CurrentBitrate = health.CurrentBitrate;
|
|
||||||
CurrentHealth.FPS = health.FPS;
|
|
||||||
CurrentHealth.DroppedFrames = health.DroppedFrames;
|
|
||||||
CurrentHealth.StreamDuration = health.StreamDuration;
|
|
||||||
CurrentHealth.LastError = health.LastError;
|
|
||||||
CurrentHealth.HealthMessage = health.HealthMessage;
|
|
||||||
OnPropertyChanged(nameof(CurrentHealth));
|
|
||||||
}
|
|
||||||
|
|
||||||
// Keeps the bottom-bar stats honest across sessions: dropped frames and the
|
|
||||||
// elapsed duration must not linger from a previous go-live (bitrate/FPS stay
|
|
||||||
// on the tier's targets — ApplyStreamQuality sets them on pick).
|
|
||||||
private void ResetHealth(StreamStatus status)
|
|
||||||
{
|
|
||||||
CurrentHealth.Status = status;
|
|
||||||
CurrentHealth.DroppedFrames = 0;
|
|
||||||
CurrentHealth.StreamDuration = TimeSpan.Zero;
|
|
||||||
CurrentHealth.LastError = null;
|
|
||||||
CurrentHealth.HealthStatus = null;
|
|
||||||
CurrentHealth.HealthMessage = null;
|
|
||||||
CurrentHealth.ConfigurationIssues.Clear();
|
|
||||||
HealthIssueBanner = null;
|
|
||||||
HealthIssueBackground = "Transparent";
|
|
||||||
OnPropertyChanged(nameof(CurrentHealth));
|
|
||||||
}
|
|
||||||
|
|
||||||
private void UpdateLiveVisuals()
|
|
||||||
{
|
|
||||||
var live = IsLive;
|
|
||||||
TopBarBackground = live ? "#e94560" : "#16213e";
|
|
||||||
PreviewGlowBrush = live ? "#e94560" : "Transparent";
|
|
||||||
PreviewGlowThickness = live ? new Thickness(3) : new Thickness(0);
|
|
||||||
|
|
||||||
if (live)
|
|
||||||
{
|
|
||||||
if (BrandFlashEnabled) StartBrandFlashTimer();
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
_healthPollTimer.Stop();
|
|
||||||
_brandFlashTimer.Stop();
|
|
||||||
_brandFlashOffTimer.Stop();
|
|
||||||
BrandFlashActive = false;
|
|
||||||
}
|
|
||||||
UpdateSessionTimer();
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>Runs the elapsed/rec-dot-pulse timer while a session is active —
|
|
||||||
/// live (Streaming) OR recording. Reset the elapsed when a new session starts.</summary>
|
|
||||||
private void UpdateSessionTimer()
|
|
||||||
{
|
|
||||||
var active = IsLive || IsRecording;
|
|
||||||
if (active)
|
|
||||||
{
|
|
||||||
_recDotPulse = 1.0;
|
|
||||||
_liveTimer.Start();
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
_liveTimer.Stop();
|
|
||||||
LiveElapsedText = "00:00:00";
|
|
||||||
_recDotPulse = 1.0;
|
|
||||||
}
|
|
||||||
OnPropertyChanged(nameof(RecDotOpacity));
|
|
||||||
OnPropertyChanged(nameof(LiveElapsedText));
|
|
||||||
}
|
|
||||||
|
|
||||||
private void OnLiveTimerTick(object? sender, EventArgs e)
|
|
||||||
{
|
|
||||||
_liveElapsed = _liveElapsed.Add(TimeSpan.FromSeconds(1));
|
|
||||||
LiveElapsedText = _liveElapsed.ToString(@"hh\:mm\:ss");
|
|
||||||
_recordLength = _liveElapsed;
|
|
||||||
_recDotPulse = _recDotPulse > 0.5 ? 0.35 : 1.0;
|
|
||||||
OnPropertyChanged(nameof(RecDotOpacity));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,183 @@
|
|||||||
|
using System.ComponentModel;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.ViewModels;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
public sealed record DialogEntry(SocialService Service, string Handle, string ProfileUrl, string? FediverseSoftware = null);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// One of the six fixed dialog rows. Row 0 is always YouTube (signed-in account
|
||||||
|
/// or a sign-in prompt); rows 1-5 hold validated entries, an empty slot, or — on
|
||||||
|
/// the free tier — a locked "Premium" slot. Rows are a positional projection of
|
||||||
|
/// the dialog's working list, so deleting an entry makes the ones above advance up.
|
||||||
|
/// </summary>
|
||||||
|
public sealed class SocialSlotViewModel : ViewModelBase
|
||||||
|
{
|
||||||
|
public int Index { get; }
|
||||||
|
public bool IsYoutube => Index == 0;
|
||||||
|
|
||||||
|
private SocialService _service = SocialService.Link;
|
||||||
|
public SocialService Service
|
||||||
|
{
|
||||||
|
get => _service;
|
||||||
|
set { if (SetProperty(ref _service, value)) OnPropertyChanged(nameof(LogoData)); }
|
||||||
|
}
|
||||||
|
|
||||||
|
public string LogoData => Service == SocialService.Fediverse
|
||||||
|
? SocialServiceIcons.LogoDataForFediverse(FediverseSoftware)
|
||||||
|
: SocialServiceIcons.LogoDataFor(Service);
|
||||||
|
public string LockedIconData => SocialServiceIcons.LockedIconData;
|
||||||
|
public string DoNotIconData => SocialServiceIcons.DoNotIconData;
|
||||||
|
|
||||||
|
private bool _isLocked;
|
||||||
|
public bool IsLocked
|
||||||
|
{
|
||||||
|
get => _isLocked;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _isLocked, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(ShowAddButton));
|
||||||
|
OnPropertyChanged(nameof(ShowDoNot));
|
||||||
|
OnPropertyChanged(nameof(DisplayText));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private bool _isFilled;
|
||||||
|
public bool IsFilled
|
||||||
|
{
|
||||||
|
get => _isFilled;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _isFilled, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(ShowEditButton));
|
||||||
|
OnPropertyChanged(nameof(ShowDeleteButton));
|
||||||
|
OnPropertyChanged(nameof(ShowAddButton));
|
||||||
|
OnPropertyChanged(nameof(ShowDoNot));
|
||||||
|
OnPropertyChanged(nameof(DisplayText));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private bool _isSignIn;
|
||||||
|
public bool IsSignIn
|
||||||
|
{
|
||||||
|
get => _isSignIn;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _isSignIn, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(ShowSignInButton));
|
||||||
|
OnPropertyChanged(nameof(ShowDeleteButton));
|
||||||
|
OnPropertyChanged(nameof(ShowLogo));
|
||||||
|
OnPropertyChanged(nameof(DisplayText));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private bool _isEditing;
|
||||||
|
public bool IsEditing
|
||||||
|
{
|
||||||
|
get => _isEditing;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _isEditing, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(ShowEditBox));
|
||||||
|
OnPropertyChanged(nameof(ShowDisplay));
|
||||||
|
OnPropertyChanged(nameof(ShowEditButton));
|
||||||
|
OnPropertyChanged(nameof(ShowDeleteButton));
|
||||||
|
OnPropertyChanged(nameof(ShowAddButton));
|
||||||
|
OnPropertyChanged(nameof(ShowDoNot));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private bool _isValidating;
|
||||||
|
public bool IsValidating
|
||||||
|
{
|
||||||
|
get => _isValidating;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _isValidating, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(ShowBusy));
|
||||||
|
OnPropertyChanged(nameof(ShowDoNot));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private string _handle = string.Empty;
|
||||||
|
public string Handle
|
||||||
|
{
|
||||||
|
get => _handle;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _handle, value))
|
||||||
|
OnPropertyChanged(nameof(DisplayText));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private string? _fediverseSoftware;
|
||||||
|
public string? FediverseSoftware
|
||||||
|
{
|
||||||
|
get => _fediverseSoftware;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _fediverseSoftware, value))
|
||||||
|
OnPropertyChanged(nameof(LogoData));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public string ProfileUrl { get; set; } = string.Empty;
|
||||||
|
|
||||||
|
private string? _error;
|
||||||
|
public string? Error
|
||||||
|
{
|
||||||
|
get => _error;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _error, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(HasError));
|
||||||
|
OnPropertyChanged(nameof(ShowError));
|
||||||
|
OnPropertyChanged(nameof(ShowDoNot));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private string _editText = string.Empty;
|
||||||
|
public string EditText
|
||||||
|
{
|
||||||
|
get => _editText;
|
||||||
|
set => SetProperty(ref _editText, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>The last text submitted for validation (used to skip re-validating
|
||||||
|
/// identical input — e.g. a LostFocus firing as the user clicks Cancel).</summary>
|
||||||
|
public string? LastValidatedInput { get; set; }
|
||||||
|
|
||||||
|
public string DisplayText =>
|
||||||
|
IsYoutube
|
||||||
|
? (IsSignIn ? "Sign in to YouTube" : Handle)
|
||||||
|
: IsLocked ? "Unlock with Premium"
|
||||||
|
: IsFilled ? Handle
|
||||||
|
: "No social yet";
|
||||||
|
|
||||||
|
public bool HasError => !string.IsNullOrEmpty(Error);
|
||||||
|
public bool ShowError => HasError;
|
||||||
|
public bool ShowLogo => IsYoutube ? !IsSignIn : IsFilled;
|
||||||
|
public bool ShowBusy => IsValidating;
|
||||||
|
public bool ShowEditBox => IsEditing;
|
||||||
|
public bool ShowDisplay => !IsEditing && !IsValidating;
|
||||||
|
public bool ShowSignInButton => IsYoutube && IsSignIn && !IsValidating;
|
||||||
|
public bool ShowAddButton => !IsYoutube && !IsLocked && !IsFilled && !IsEditing && !IsValidating;
|
||||||
|
public bool ShowEditButton => !IsYoutube && IsFilled && !IsEditing && !IsValidating;
|
||||||
|
public bool ShowDeleteButton => (IsFilled || IsYoutube) && !IsEditing && !IsValidating;
|
||||||
|
public bool ShowDoNot => !IsYoutube && !IsLocked && (!IsFilled || HasError || IsValidating);
|
||||||
|
|
||||||
|
public SocialSlotViewModel(int index) => Index = index;
|
||||||
|
}
|
||||||
@@ -8,187 +8,6 @@ using ytLive.Services;
|
|||||||
|
|
||||||
namespace ytLive.ViewModels;
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// A validated social entry in the dialog's working copy (non-YouTube slots).
|
|
||||||
/// </summary>
|
|
||||||
public sealed record DialogEntry(SocialService Service, string Handle, string ProfileUrl, string? FediverseSoftware = null);
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// One of the six fixed dialog rows. Row 0 is always YouTube (signed-in account
|
|
||||||
/// or a sign-in prompt); rows 1-5 hold validated entries, an empty slot, or — on
|
|
||||||
/// the free tier — a locked "Premium" slot. Rows are a positional projection of
|
|
||||||
/// the dialog's working list, so deleting an entry makes the ones above advance up.
|
|
||||||
/// </summary>
|
|
||||||
public sealed class SocialSlotViewModel : ViewModelBase
|
|
||||||
{
|
|
||||||
public int Index { get; }
|
|
||||||
public bool IsYoutube => Index == 0;
|
|
||||||
|
|
||||||
private SocialService _service = SocialService.Link;
|
|
||||||
public SocialService Service
|
|
||||||
{
|
|
||||||
get => _service;
|
|
||||||
set { if (SetProperty(ref _service, value)) OnPropertyChanged(nameof(LogoData)); }
|
|
||||||
}
|
|
||||||
|
|
||||||
public string LogoData => Service == SocialService.Fediverse
|
|
||||||
? SocialServiceIcons.LogoDataForFediverse(FediverseSoftware)
|
|
||||||
: SocialServiceIcons.LogoDataFor(Service);
|
|
||||||
public string LockedIconData => SocialServiceIcons.LockedIconData;
|
|
||||||
public string DoNotIconData => SocialServiceIcons.DoNotIconData;
|
|
||||||
|
|
||||||
private bool _isLocked;
|
|
||||||
public bool IsLocked
|
|
||||||
{
|
|
||||||
get => _isLocked;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _isLocked, value))
|
|
||||||
{
|
|
||||||
OnPropertyChanged(nameof(ShowAddButton));
|
|
||||||
OnPropertyChanged(nameof(ShowDoNot));
|
|
||||||
OnPropertyChanged(nameof(DisplayText));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private bool _isFilled;
|
|
||||||
public bool IsFilled
|
|
||||||
{
|
|
||||||
get => _isFilled;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _isFilled, value))
|
|
||||||
{
|
|
||||||
OnPropertyChanged(nameof(ShowEditButton));
|
|
||||||
OnPropertyChanged(nameof(ShowDeleteButton));
|
|
||||||
OnPropertyChanged(nameof(ShowAddButton));
|
|
||||||
OnPropertyChanged(nameof(ShowDoNot));
|
|
||||||
OnPropertyChanged(nameof(DisplayText));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private bool _isSignIn;
|
|
||||||
public bool IsSignIn
|
|
||||||
{
|
|
||||||
get => _isSignIn;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _isSignIn, value))
|
|
||||||
{
|
|
||||||
OnPropertyChanged(nameof(ShowSignInButton));
|
|
||||||
OnPropertyChanged(nameof(ShowDeleteButton));
|
|
||||||
OnPropertyChanged(nameof(ShowLogo));
|
|
||||||
OnPropertyChanged(nameof(DisplayText));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private bool _isEditing;
|
|
||||||
public bool IsEditing
|
|
||||||
{
|
|
||||||
get => _isEditing;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _isEditing, value))
|
|
||||||
{
|
|
||||||
OnPropertyChanged(nameof(ShowEditBox));
|
|
||||||
OnPropertyChanged(nameof(ShowDisplay));
|
|
||||||
OnPropertyChanged(nameof(ShowEditButton));
|
|
||||||
OnPropertyChanged(nameof(ShowDeleteButton));
|
|
||||||
OnPropertyChanged(nameof(ShowAddButton));
|
|
||||||
OnPropertyChanged(nameof(ShowDoNot));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private bool _isValidating;
|
|
||||||
public bool IsValidating
|
|
||||||
{
|
|
||||||
get => _isValidating;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _isValidating, value))
|
|
||||||
{
|
|
||||||
OnPropertyChanged(nameof(ShowBusy));
|
|
||||||
OnPropertyChanged(nameof(ShowDoNot));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private string _handle = string.Empty;
|
|
||||||
public string Handle
|
|
||||||
{
|
|
||||||
get => _handle;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _handle, value))
|
|
||||||
OnPropertyChanged(nameof(DisplayText));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private string? _fediverseSoftware;
|
|
||||||
public string? FediverseSoftware
|
|
||||||
{
|
|
||||||
get => _fediverseSoftware;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _fediverseSoftware, value))
|
|
||||||
OnPropertyChanged(nameof(LogoData));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public string ProfileUrl { get; set; } = string.Empty;
|
|
||||||
|
|
||||||
private string? _error;
|
|
||||||
public string? Error
|
|
||||||
{
|
|
||||||
get => _error;
|
|
||||||
set
|
|
||||||
{
|
|
||||||
if (SetProperty(ref _error, value))
|
|
||||||
{
|
|
||||||
OnPropertyChanged(nameof(HasError));
|
|
||||||
OnPropertyChanged(nameof(ShowError));
|
|
||||||
OnPropertyChanged(nameof(ShowDoNot));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private string _editText = string.Empty;
|
|
||||||
public string EditText
|
|
||||||
{
|
|
||||||
get => _editText;
|
|
||||||
set => SetProperty(ref _editText, value);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>The last text submitted for validation (used to skip re-validating
|
|
||||||
/// identical input — e.g. a LostFocus firing as the user clicks Cancel).</summary>
|
|
||||||
public string? LastValidatedInput { get; set; }
|
|
||||||
|
|
||||||
public string DisplayText =>
|
|
||||||
IsYoutube
|
|
||||||
? (IsSignIn ? "Sign in to YouTube" : Handle)
|
|
||||||
: IsLocked ? "Unlock with Premium"
|
|
||||||
: IsFilled ? Handle
|
|
||||||
: "No social yet";
|
|
||||||
|
|
||||||
public bool HasError => !string.IsNullOrEmpty(Error);
|
|
||||||
public bool ShowError => HasError;
|
|
||||||
public bool ShowLogo => IsYoutube ? !IsSignIn : IsFilled;
|
|
||||||
public bool ShowBusy => IsValidating;
|
|
||||||
public bool ShowEditBox => IsEditing;
|
|
||||||
public bool ShowDisplay => !IsEditing && !IsValidating;
|
|
||||||
public bool ShowSignInButton => IsYoutube && IsSignIn && !IsValidating;
|
|
||||||
public bool ShowAddButton => !IsYoutube && !IsLocked && !IsFilled && !IsEditing && !IsValidating;
|
|
||||||
public bool ShowEditButton => !IsYoutube && IsFilled && !IsEditing && !IsValidating;
|
|
||||||
public bool ShowDeleteButton => (IsFilled || IsYoutube) && !IsEditing && !IsValidating;
|
|
||||||
public bool ShowDoNot => !IsYoutube && !IsLocked && (!IsFilled || HasError || IsValidating);
|
|
||||||
|
|
||||||
public SocialSlotViewModel(int index) => Index = index;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// View model for the Social Media Site Promotion dialog. Owns the working copy
|
/// View model for the Social Media Site Promotion dialog. Owns the working copy
|
||||||
/// of the social bar config: the six fixed slots, the sign-in gate, per-row
|
/// of the social bar config: the six fixed slots, the sign-in gate, per-row
|
||||||
|
|||||||
@@ -67,5 +67,8 @@ source files under 500 lines. One roll-back commit per file; same drill
|
|||||||
(0-warning build, `verify.sh` 246+2, explicit-file scope-check, tracker in same
|
(0-warning build, `verify.sh` 246+2, explicit-file scope-check, tracker in same
|
||||||
commit, tag `refactor-commit-N`, no per-commit push).
|
commit, tag `refactor-commit-N`, no per-commit push).
|
||||||
- [x] **Commit A · `refactor-commit-A`** — **core** → `MainViewModel.cs` 758 → **495**. Moved source add/remove/image block to new **`MainViewModel.Sources.cs`** (234 lines: `AddSource`, `NextSourceName`, `AddImage`, `BuildImageCandidates`, `PickImageBytes`, `AddAsset`, `AddImageSource`, `AddReusedImage`, `RemoveElement`) and WebView2 hosting (`RegisterLoadedWebSources`, `InitWebView2`, `OnWebView2PreviewBitmapChanged`) to new **`MainViewModel.Web.cs`**. Pruned now-dead usings (`Microsoft.Win32`, `NAudio.CoreAudioApi`, `System.Windows.Media.Imaging`, `Collections.ObjectModel/Specialized`). Pending: Streaming, Background, SocialsDialogViewModel, LayoutStore.
|
- [x] **Commit A · `refactor-commit-A`** — **core** → `MainViewModel.cs` 758 → **495**. Moved source add/remove/image block to new **`MainViewModel.Sources.cs`** (234 lines: `AddSource`, `NextSourceName`, `AddImage`, `BuildImageCandidates`, `PickImageBytes`, `AddAsset`, `AddImageSource`, `AddReusedImage`, `RemoveElement`) and WebView2 hosting (`RegisterLoadedWebSources`, `InitWebView2`, `OnWebView2PreviewBitmapChanged`) to new **`MainViewModel.Web.cs`**. Pruned now-dead usings (`Microsoft.Win32`, `NAudio.CoreAudioApi`, `System.Windows.Media.Imaging`, `Collections.ObjectModel/Specialized`). Pending: Streaming, Background, SocialsDialogViewModel, LayoutStore.
|
||||||
|
- [x] **Commit B · `refactor-commit-B`** — **Streaming** → `MainViewModel.Streaming.cs` 789 → **330** + new **`MainViewModel.Streaming.Operations.cs`** (459 lines). Moved the go-live/record/health operation bodies (`StartSession`, `BeginRecordOnly`, `BeginGoLive`, `StartRecordFile`, `PrepareAndStartLiveAsync`, `PollHealthAsync`/`OnHealthPollTick`/`ApplyHealthIssue`, `StopStream`, `FinalizeRecordingAsync`, `UniquePath`, `ChooseRecordFolder`, `ResetRecordFolder`, `DefaultRecordFolder`, `OnFramePumpFailed`, `OnFramePumpHealthUpdated`, `ApplyHealth`, `ResetHealth`, `BuildEncoderOptions`) into the Operations partial; Streaming.cs keeps state + quality/resolution tiers + session timer + command declarations. Pruned dead usings both files. Pending: Background, SocialsDialogViewModel, LayoutStore.
|
||||||
|
- [x] **Commit C · `refactor-commit-C`** — **Background** → `MainViewModel.Background.cs` 567 → **418** + new **`MainViewModel.Background.Model.cs`** (163 lines). Moved the static scene-model helpers (`LoadBackgroundImage`, `CreatePlaceholderSnapshot`, `EnsureBackground`, `CreateBackground`, `NormalizeBackgrounds`, `AllBackgrounds`, `ResolveAutoCaptureKey`, `MonitorKeyPrefix`) into the Model partial; Background.cs keeps capture/live state + operations (`UpdateActiveBackground`, `UpdateBackgroundImage`, `RefreshSnapshotsAsync`, `ReacquireScreenCaptures`, `OnScreenPreviewBitmapChanged`, `OnFullscreenMonitorChanged`, `RefreshBackgroundAutoCapture`, `BrowseBackground`, `ClearBackgroundCaptureAsync`, `RedesignateBackgroundAsync`, `ChangeBackgroundCaptureAsync`, `SetBackgroundCapture`, `DefaultBackgroundAsset`, `HealBackgrounds`, `StampDefaultBackgroundAsset`). Pending: SocialsDialogViewModel, LayoutStore.
|
||||||
|
- [x] **Commit D · `refactor-commit-D`** — **SocialsDialog** → `SocialsDialogViewModel.cs` 515 → **334** + new **`SocialSlotViewModel.cs`** (183 lines). Moved the `DialogEntry` record + the row-level `SocialSlotViewModel` (six-fixed-slot row VM: service/logo/lock/edit/validate state + computed `Show*` flags) into its own file; `SocialsDialogViewModel.cs` keeps the dialog VM (sign-in gate, validation orchestration, commit). `DialogEntry` stays `public` in the same namespace so both files see it. Pending: LayoutStore.
|
||||||
The partial `.cs` files land next to `MainViewModel.cs` in this folder as the split
|
The partial `.cs` files land next to `MainViewModel.cs` in this folder as the split
|
||||||
proceeds; each partial carries its own `using`s and re-declares nothing from core.
|
proceeds; each partial carries its own `using`s and re-declares nothing from core.
|
||||||
Reference in New Issue
Block a user