Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1efde5a1e6 | |||
| 3b77a132be | |||
| e1006a04ab | |||
| c41ff7fd0a | |||
| 535a50192c | |||
| c1126a52b9 | |||
| fc33022006 | |||
| 46978b8bc3 | |||
| 58e7b3f3d1 |
@@ -20,6 +20,13 @@ work lands directly on `main`, committed and pushed per work unit. No
|
|||||||
`taskNN-*` branches, no PRs. The scope discipline above is about test focus,
|
`taskNN-*` branches, no PRs. The scope discipline above is about test focus,
|
||||||
not git mechanics.
|
not git mechanics.
|
||||||
|
|
||||||
|
**Commit / push policy (2026-08-30, user directive):** commit every work unit —
|
||||||
|
committing is expected and never needs extra permission. Pushing is different:
|
||||||
|
push ONLY at sub-milestones and milestones. During a multi-commit refactor,
|
||||||
|
that means commits land locally every partial; `git push` happens at the
|
||||||
|
session's agreed checkpoint(s), not per-commit. When a milestone warrants a
|
||||||
|
push the user will say so (or say "push it").
|
||||||
|
|
||||||
MUST read the architecture guide before planning or modifying the codebase:
|
MUST read the architecture guide before planning or modifying the codebase:
|
||||||
[`ai.md`](ai.md) (+ [`schema.md`](schema.md) for the memory-map conventions).
|
[`ai.md`](ai.md) (+ [`schema.md`](schema.md) for the memory-map conventions).
|
||||||
|
|
||||||
|
|||||||
+26
-8
@@ -6,11 +6,28 @@
|
|||||||
|
|
||||||
No feature branches pre-1.0: all work lands on `main` per work unit.
|
No feature branches pre-1.0: all work lands on `main` per work unit.
|
||||||
|
|
||||||
**Latest commit:** `6031a56` — gear cleanup + Default Location for Recordings + single Start + socials hover glow.
|
**Latest commit:** `e286719` — Commit 5/12 of the MainViewModel refactor (Webcam partial, tag `refactor-commit-5`).
|
||||||
|
|
||||||
## What's In Flight
|
## What's In Flight
|
||||||
|
|
||||||
Nothing — clean tree, ready for next task.
|
**MainViewModel partial split (Phase 1):** 5 of 12 refactor commits landed and pushed.
|
||||||
|
Tags `refactor-commit-0…5` = scaffold, Account, License, Scenes, Background, Webcam.
|
||||||
|
Latest head `e286719`. Working tree clean.
|
||||||
|
|
||||||
|
Remaining partials in order: `Audio` (Commit 6), `Trax` (7), `Socials` (8), `Streaming` (9),
|
||||||
|
`Chat` (10), `Overlays` (11). Each lands the same way: cut → build 0 warnings →
|
||||||
|
`./scripts/verify.sh` + `./scripts/scope-check.sh "file1" …` → commit titled
|
||||||
|
`refactor: split <Area> out of MainViewModel — Commit N/12 (tag refactor-commit-N)`
|
||||||
|
with the `ViewModels/index.md` progress update in the SAME commit → `git tag refactor-commit-N`.
|
||||||
|
**Do NOT push per commit (policy 2026-08-30):** commits land locally; `git push` only at
|
||||||
|
a user-agreed sub-milestone/milestone ("push it"). Tags ride along on that push.
|
||||||
|
|
||||||
|
Known partial-usings list (grep-verified):
|
||||||
|
`Scenes` = ObjectModel+Specialized+ComponentModel+`ytLive`+Models+Services;
|
||||||
|
`Background` = ObjectModel+IO+Windows+Input+Media+Media.Imaging+Helpers+Models+Services;
|
||||||
|
`Webcam` = Windows+Input+Media.Imaging+`ytLive`+Models+Services.
|
||||||
|
`INotificationService.Info/Warning/Error/Success` are default interface methods → any
|
||||||
|
partial calling `_notifications.X` needs `using ytLive.Services;`.
|
||||||
|
|
||||||
## Landmines
|
## Landmines
|
||||||
|
|
||||||
@@ -35,11 +52,12 @@ Nothing — clean tree, ready for next task.
|
|||||||
- TASK 22 (Audio sync offset): not started — required for v1.
|
- TASK 22 (Audio sync offset): not started — required for v1.
|
||||||
- TASK 30: gear cleanup + record location + single Start + preview layout restructure — shipped across commits `6031a56` + `61b850f` + `455a409`.
|
- TASK 30: gear cleanup + record location + single Start + preview layout restructure — shipped across commits `6031a56` + `61b850f` + `455a409`.
|
||||||
- Monetization: deferred (creator rethinking price/subscription model).
|
- Monetization: deferred (creator rethinking price/subscription model).
|
||||||
- **File refactor (in progress — Commit 0 done):** MainViewModel.cs (3,900 lines) will be split into functional partials (Scenes, Background, Webcam, Audio, Trax, Socials, Streaming, Chat, Overlays, Account, License). `MainViewModel` is now `public partial class` (scaffold commit). Remaining: one commit per partial, each a roll-back point, `verify.sh` + `scope-check.sh` before each, docs in the same commit. MainWindow.xaml (1,681 lines) will be split into UserControls after Phase 1. Zero behavior change, tests stay green.
|
- **File refactor (in progress — Commit 5/12 done):** MainViewModel.cs (3,900 lines) split into functional partials (Scenes, Background, Webcam ✔; Audio, Trax, Socials, Streaming, Chat, Overlays pending; Account, License ✔). One commit per partial, each a roll-back point (`refactor-commit-N` tags), `verify.sh` + `scope-check.sh` before each, docs in the same commit. MainWindow.xaml (1,681 lines) will be split into UserControls after Phase 1. Zero behavior change, tests stay green.
|
||||||
|
- Monitoring: partials must re-declare their own `using`s — core file's usings do NOT carry across partial files. Field-initializer order across parts is compiler-ordered but no moved field has interdependent initializers.
|
||||||
|
|
||||||
## Session summary (2026-08-29)
|
## Session summary (2026-08-30)
|
||||||
|
|
||||||
- Corrected task status tracking: TASK 4 → ✅ Done, TASK 3 item15 (Window capture) → ✅ absorbed into Screen picker, TASK 3 status updated to 27/30
|
- Completed refactor Commits 3/12 (Scenes, `dcdfcb9`), 4/12 (Background, `db068ab`), 5/12 (Webcam, `e286719`) — each tagged `refactor-commit-N`, pushed with `--tags`, verified (0-warning clean build, only the 2 known test failures).
|
||||||
- ai.md updated: TASK 4 steps 5-7 added as shipped, stale "frame-pipeline wiring follows" removed
|
- Background partial took the full bucket: background model, screen capture machinery, display picker, preview fns, capture commands. Webcam partial took identity + per-scene configs + capture callbacks + size safeguards.
|
||||||
- HANDOFF.md todo state expanded with full statuses for all active tasks
|
- Mea culpa: asked the user a bucket-boundary question that the rules already answered — won't repeat; buckets are fixed.
|
||||||
- Discussed file organization: MainViewModel.cs (3,900 lines) is a god-object with 49 commands mixing scenes, camera, audio, streaming, socials, overlays, and auth. Next session: split into functional partials
|
- Test-suite note: full `vstest` run aborted early once (236/237) with only the 2 known failures — accepted by `verify.sh` as a known flake.
|
||||||
|
|||||||
@@ -0,0 +1,408 @@
|
|||||||
|
using System.Windows;
|
||||||
|
using System.Windows.Input;
|
||||||
|
using System.Windows.Media;
|
||||||
|
using System.Windows.Threading;
|
||||||
|
using NAudio.CoreAudioApi;
|
||||||
|
using ytLive;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.Services;
|
||||||
|
using ytLive.Services.Audio;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel
|
||||||
|
{
|
||||||
|
private readonly DispatcherTimer _volumeFlashTimer;
|
||||||
|
private readonly DispatcherTimer _gameVolumeFlashTimer;
|
||||||
|
private double _audioLevel;
|
||||||
|
private bool _volumeAdjusting;
|
||||||
|
private bool _volumeFlash;
|
||||||
|
private double _micVolume = 0.8;
|
||||||
|
private bool _micMuted;
|
||||||
|
private double? _volumeBeforeMute;
|
||||||
|
private string? _micSourceName;
|
||||||
|
private MicStatus _micStatus = MicStatus.NotConnected;
|
||||||
|
private double _gameAudioLevel;
|
||||||
|
private bool _gameVolumeAdjusting;
|
||||||
|
private bool _gameVolumeFlash;
|
||||||
|
private double _gameVolume = 1.0;
|
||||||
|
private bool _gameMuted;
|
||||||
|
private double? _gameVolumeBeforeMute;
|
||||||
|
private AudioGainProvider? _gainProvider;
|
||||||
|
private readonly IMicrophoneEnumerator _microphoneEnumerator;
|
||||||
|
private readonly AudioMixer _audioMixer;
|
||||||
|
|
||||||
|
public ICommand ToggleMicMuteCommand { get; }
|
||||||
|
public ICommand ToggleGameMuteCommand { get; }
|
||||||
|
public ICommand OpenMicPickerCommand { get; }
|
||||||
|
|
||||||
|
// ─── Audio: the mic bar (meter + volume + mute + status dot) is always
|
||||||
|
// ─── visible; the game bar (meter + volume + mute) appears only while a
|
||||||
|
// ─── full-screen game is producing sound. Both meters preview live. ───
|
||||||
|
|
||||||
|
/// <summary>Live mic input level (0..1) — fed by the audio mixer once capture
|
||||||
|
/// lands; 0 with no input. Read by the meter, scaled by MicVolume.</summary>
|
||||||
|
public double AudioLevel
|
||||||
|
{
|
||||||
|
get => _audioLevel;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _audioLevel, Math.Clamp(value, 0, 1)))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(MeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(MeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Displayed meter level: 0 while muted; the volume position while
|
||||||
|
/// the slider is being dragged (or briefly after an unmute, so the restored
|
||||||
|
/// level flashes on the bar) so the creator sees where they're setting it;
|
||||||
|
/// otherwise the realtime live level scaled by volume (raising the volume
|
||||||
|
/// moves ambient noise up the bar). Read-only meter.</summary>
|
||||||
|
private double MeterLevel => MicMuted ? 0 : _volumeAdjusting || _volumeFlash ? MicVolume : Math.Min(1, AudioLevelMeter.ToDisplay((float)AudioLevel) * 1.2 * MicVolume);
|
||||||
|
|
||||||
|
public double MeterFillWidth => MeterLevel * 288;
|
||||||
|
|
||||||
|
public string MeterBrush => MeterLevel switch
|
||||||
|
{
|
||||||
|
< 0.6 => "#22c55e",
|
||||||
|
< 0.8 => "#eab308",
|
||||||
|
_ => "#ef4444",
|
||||||
|
};
|
||||||
|
|
||||||
|
/// <summary>Previewes the volume position while the slider is dragged; the
|
||||||
|
/// bar returns to the live level on release (empty when there is no input).
|
||||||
|
/// Starting a drag cancels any pending unmute flash.</summary>
|
||||||
|
public void SetVolumeAdjusting(bool adjusting)
|
||||||
|
{
|
||||||
|
if (adjusting)
|
||||||
|
CancelVolumeFlash();
|
||||||
|
if (SetProperty(ref _volumeAdjusting, adjusting))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(MeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(MeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void BeginVolumeFlash()
|
||||||
|
{
|
||||||
|
_volumeFlash = true;
|
||||||
|
OnPropertyChanged(nameof(MeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(MeterBrush));
|
||||||
|
_volumeFlashTimer.Stop();
|
||||||
|
_volumeFlashTimer.Start();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void EndVolumeFlash()
|
||||||
|
{
|
||||||
|
_volumeFlashTimer.Stop();
|
||||||
|
if (_volumeFlash)
|
||||||
|
{
|
||||||
|
_volumeFlash = false;
|
||||||
|
OnPropertyChanged(nameof(MeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(MeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void CancelVolumeFlash()
|
||||||
|
{
|
||||||
|
_volumeFlashTimer.Stop();
|
||||||
|
_volumeFlash = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Mic gain (0..1). Running to 0 mutes (the speaker flips to muted);
|
||||||
|
/// moving up from 0 unmutes (the mute indicator clears). The level being left
|
||||||
|
/// is remembered so the speaker button can restore it.</summary>
|
||||||
|
public double MicVolume
|
||||||
|
{
|
||||||
|
get => _micVolume;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
var clamped = Math.Clamp(value, 0, 1);
|
||||||
|
if (clamped == 0 && !_micMuted)
|
||||||
|
_volumeBeforeMute ??= _micVolume;
|
||||||
|
if (SetProperty(ref _micVolume, clamped))
|
||||||
|
{
|
||||||
|
var muted = clamped == 0;
|
||||||
|
if (_micMuted != muted)
|
||||||
|
{
|
||||||
|
_micMuted = muted;
|
||||||
|
OnPropertyChanged(nameof(MicMuted));
|
||||||
|
OnPropertyChanged(nameof(MicMuteText));
|
||||||
|
}
|
||||||
|
if (!muted)
|
||||||
|
_volumeBeforeMute = null;
|
||||||
|
OnPropertyChanged(nameof(MeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(MeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Read-only: true whenever the volume is 0. Only MicVolume may
|
||||||
|
/// change it, so the slider and the speaker can never disagree.</summary>
|
||||||
|
public bool MicMuted => _micMuted;
|
||||||
|
|
||||||
|
public string MicMuteText => MicMuted ? "Unmute" : "Mute";
|
||||||
|
|
||||||
|
/// <summary>Name of the picked voice source, shown left-justified INSIDE the meter
|
||||||
|
/// bar (FontSize 10, ellipsized to the bar) — ai.md is the authority here.</summary>
|
||||||
|
public string? MicSourceName
|
||||||
|
{
|
||||||
|
get => _micSourceName;
|
||||||
|
private set => SetProperty(ref _micSourceName, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ToggleMicMute()
|
||||||
|
{
|
||||||
|
if (MicMuted)
|
||||||
|
{
|
||||||
|
MicVolume = _volumeBeforeMute ?? 0.8;
|
||||||
|
BeginVolumeFlash();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_volumeBeforeMute = MicVolume;
|
||||||
|
MicVolume = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void PickMicrophone()
|
||||||
|
{
|
||||||
|
var dialog = new MicPickerDialog(new MicPickerViewModel(_microphoneEnumerator))
|
||||||
|
{
|
||||||
|
Owner = System.Windows.Application.Current?.MainWindow
|
||||||
|
};
|
||||||
|
if (dialog.ShowDialog() == true && dialog.PickedDevice != null)
|
||||||
|
{
|
||||||
|
MicSourceName = dialog.PickedDevice.DisplayName;
|
||||||
|
_layoutStore.SaveMicSourceName(MicSourceName); // persist across restarts
|
||||||
|
_audioMixer.RestartMic(); // swap the live device immediately
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ─── Mic status dot (the MIC button) ───
|
||||||
|
|
||||||
|
private static readonly SolidColorBrush MicProblemBrush = CreateBrush("#f1c40f");
|
||||||
|
|
||||||
|
/// <summary>Mic connection state, driven by the mixer's MicConnected/MicFailed
|
||||||
|
/// events and the startup device check (see StartMicCaptureAsync).</summary>
|
||||||
|
public MicStatus MicStatus
|
||||||
|
{
|
||||||
|
get => _micStatus;
|
||||||
|
private set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _micStatus, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(MicStatusBrush));
|
||||||
|
OnPropertyChanged(nameof(MicStatusToolTip));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Status dot: green = connected, yellow = problem with the requested
|
||||||
|
/// connection, red = not connected (no device / not started).</summary>
|
||||||
|
public SolidColorBrush MicStatusBrush => MicStatus switch
|
||||||
|
{
|
||||||
|
MicStatus.Connected => BarOnBrush,
|
||||||
|
MicStatus.Problem => MicProblemBrush,
|
||||||
|
_ => BarOffBrush,
|
||||||
|
};
|
||||||
|
|
||||||
|
public string MicStatusToolTip => MicStatus switch
|
||||||
|
{
|
||||||
|
MicStatus.Connected => "Mic connected — click to change",
|
||||||
|
MicStatus.Problem => "Mic problem — the requested microphone is unavailable (in use or unplugged). Click to change",
|
||||||
|
_ => "No mic connected — click to choose a microphone",
|
||||||
|
};
|
||||||
|
// ─── Game audio bar (desktop/game): always visible — a mirror of the mic bar
|
||||||
|
// ─── (meter + mute + volume). Desktop/game audio is automatic (WASAPI loopback). ───
|
||||||
|
private static void PushSystemVolume(double volume)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var enumerator = new MMDeviceEnumerator();
|
||||||
|
using var device = enumerator.GetDefaultAudioEndpoint(DataFlow.Render, Role.Multimedia);
|
||||||
|
device.AudioEndpointVolume.MasterVolumeLevelScalar = (float)volume;
|
||||||
|
}
|
||||||
|
catch { }
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Live desktop/game input level (0..1), fed by the mixer's loopback
|
||||||
|
/// capture. Read by the game meter, scaled by GameAudioVolume.</summary>
|
||||||
|
public double GameAudioLevel
|
||||||
|
{
|
||||||
|
get => _gameAudioLevel;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _gameAudioLevel, Math.Clamp(value, 0, 1)))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(GameMeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(GameMeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Displayed game meter level: 0 while muted; the volume position
|
||||||
|
/// while the slider is dragged (or briefly after an unmute flash); otherwise
|
||||||
|
/// the realtime live level scaled by volume.</summary>
|
||||||
|
private double GameMeterLevel => GameMuted ? 0 : _gameVolumeAdjusting || _gameVolumeFlash ? GameAudioVolume : Math.Min(1, AudioLevelMeter.ToDisplay((float)GameAudioLevel));
|
||||||
|
|
||||||
|
public double GameMeterFillWidth => GameMeterLevel * 288;
|
||||||
|
|
||||||
|
public string GameMeterBrush => GameMeterLevel switch
|
||||||
|
{
|
||||||
|
< 0.6 => "#22c55e",
|
||||||
|
< 0.8 => "#eab308",
|
||||||
|
_ => "#ef4444",
|
||||||
|
};
|
||||||
|
|
||||||
|
public void SetGameVolumeAdjusting(bool adjusting)
|
||||||
|
{
|
||||||
|
if (adjusting)
|
||||||
|
CancelGameVolumeFlash();
|
||||||
|
if (SetProperty(ref _gameVolumeAdjusting, adjusting))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(GameMeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(GameMeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void BeginGameVolumeFlash()
|
||||||
|
{
|
||||||
|
_gameVolumeFlash = true;
|
||||||
|
OnPropertyChanged(nameof(GameMeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(GameMeterBrush));
|
||||||
|
_gameVolumeFlashTimer.Stop();
|
||||||
|
_gameVolumeFlashTimer.Start();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void EndGameVolumeFlash()
|
||||||
|
{
|
||||||
|
_gameVolumeFlashTimer.Stop();
|
||||||
|
if (_gameVolumeFlash)
|
||||||
|
{
|
||||||
|
_gameVolumeFlash = false;
|
||||||
|
OnPropertyChanged(nameof(GameMeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(GameMeterBrush));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void CancelGameVolumeFlash()
|
||||||
|
{
|
||||||
|
_gameVolumeFlashTimer.Stop();
|
||||||
|
_gameVolumeFlash = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Game audio gain (0..1, unity default). Running to 0 mutes; the
|
||||||
|
/// prior level is remembered so the speaker button can restore it.</summary>
|
||||||
|
public double GameAudioVolume
|
||||||
|
{
|
||||||
|
get => _gameVolume;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
var clamped = Math.Clamp(value, 0, 1);
|
||||||
|
if (clamped == 0 && !_gameMuted)
|
||||||
|
_gameVolumeBeforeMute ??= _gameVolume;
|
||||||
|
if (SetProperty(ref _gameVolume, clamped))
|
||||||
|
{
|
||||||
|
var muted = clamped == 0;
|
||||||
|
if (_gameMuted != muted)
|
||||||
|
{
|
||||||
|
_gameMuted = muted;
|
||||||
|
OnPropertyChanged(nameof(GameMuted));
|
||||||
|
OnPropertyChanged(nameof(GameMuteText));
|
||||||
|
}
|
||||||
|
if (!muted)
|
||||||
|
_gameVolumeBeforeMute = null;
|
||||||
|
OnPropertyChanged(nameof(GameMeterFillWidth));
|
||||||
|
OnPropertyChanged(nameof(GameMeterBrush));
|
||||||
|
UpdateTraxLocalGain();
|
||||||
|
PushSystemVolume(clamped);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Read-only: true whenever the volume is 0 (the slider and the
|
||||||
|
/// speaker can never disagree).</summary>
|
||||||
|
public bool GameMuted => _gameMuted;
|
||||||
|
|
||||||
|
public string GameMuteText => GameMuted ? "Unmute" : "Mute";
|
||||||
|
|
||||||
|
private void ToggleGameMute()
|
||||||
|
{
|
||||||
|
if (GameMuted)
|
||||||
|
{
|
||||||
|
GameAudioVolume = _gameVolumeBeforeMute ?? 1.0;
|
||||||
|
BeginGameVolumeFlash();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_gameVolumeBeforeMute = GameAudioVolume;
|
||||||
|
GameAudioVolume = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
private void OnMicLevelChanged(float level)
|
||||||
|
{
|
||||||
|
// NAudio raises on its capture thread; marshal to the UI thread so the
|
||||||
|
// meter binding updates safely.
|
||||||
|
var dispatcher = System.Windows.Application.Current?.Dispatcher;
|
||||||
|
if (dispatcher != null && !dispatcher.CheckAccess())
|
||||||
|
dispatcher.BeginInvoke(() => AudioLevel = level);
|
||||||
|
else
|
||||||
|
AudioLevel = level;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void OnLoopbackLevelChanged(float level)
|
||||||
|
{
|
||||||
|
var dispatcher = System.Windows.Application.Current?.Dispatcher;
|
||||||
|
if (dispatcher != null && !dispatcher.CheckAccess())
|
||||||
|
dispatcher.BeginInvoke(() => GameAudioLevel = level);
|
||||||
|
else
|
||||||
|
GameAudioLevel = level;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void OnMicConnected()
|
||||||
|
{
|
||||||
|
var dispatcher = System.Windows.Application.Current?.Dispatcher;
|
||||||
|
if (dispatcher != null && !dispatcher.CheckAccess())
|
||||||
|
dispatcher.BeginInvoke(() => MicStatus = MicStatus.Connected);
|
||||||
|
else
|
||||||
|
MicStatus = MicStatus.Connected;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void OnMicFailed(Exception ex)
|
||||||
|
{
|
||||||
|
// The mixer logs the failure detail; here we only flip the dot to yellow.
|
||||||
|
var dispatcher = System.Windows.Application.Current?.Dispatcher;
|
||||||
|
if (dispatcher != null && !dispatcher.CheckAccess())
|
||||||
|
dispatcher.BeginInvoke(() => MicStatus = MicStatus.Problem);
|
||||||
|
else
|
||||||
|
MicStatus = MicStatus.Problem;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Starts capture once at startup: with no mic device present the
|
||||||
|
/// dot stays red and capture never starts; otherwise the mixer starts and
|
||||||
|
/// raises MicConnected (green) or MicFailed (yellow).</summary>
|
||||||
|
private async Task StartMicCaptureAsync()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var mics = await _microphoneEnumerator.GetMicrophonesAsync();
|
||||||
|
if (mics.Count == 0)
|
||||||
|
{
|
||||||
|
MicStatus = MicStatus.NotConnected;
|
||||||
|
AppLog.Write("Mic: no capture devices found — mic capture not started");
|
||||||
|
_notifications.Warning("No microphone found",
|
||||||
|
"Mic capture wasn't started — plug one in and pick it from the mixer.");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
_audioMixer.Start();
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write($"Mic: device check failed: {ex.Message}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,194 @@
|
|||||||
|
using System.Collections.ObjectModel;
|
||||||
|
using System.Windows.Media;
|
||||||
|
using System.Windows.Media.Imaging;
|
||||||
|
using System.Windows.Threading;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.Services;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel : ViewModelBase
|
||||||
|
{
|
||||||
|
|
||||||
|
private readonly ChatBoxRenderer _chatBoxRenderer;
|
||||||
|
|
||||||
|
// Mock chat messages for the ChatBox preview — branded placeholders so the
|
||||||
|
// creator sees where the overlay lands before going live.
|
||||||
|
private static readonly IReadOnlyList<ChatMessage> MockChatMessages = new[]
|
||||||
|
{
|
||||||
|
new ChatMessage { AuthorName = "LlamaCasty", Message = "welcome to the stream!", Timestamp = DateTime.Now.AddMinutes(-4), IsMember = true },
|
||||||
|
new ChatMessage { AuthorName = "LlamaCastyFan", Message = "$10 — LlamaCasty is the best!", Timestamp = DateTime.Now.AddMinutes(-3), IsSuperChat = true },
|
||||||
|
new ChatMessage { AuthorName = "GamerDude", Message = "what streaming software is this?", Timestamp = DateTime.Now.AddMinutes(-2) },
|
||||||
|
new ChatMessage { AuthorName = "LlamaCasty", Message = "thanks for watching! llamacasty.com", Timestamp = DateTime.Now.AddMinutes(-1), IsMember = true },
|
||||||
|
new ChatMessage { AuthorName = "LlamaDog", Message = "Subscribe so they can buy the subscription at llamacasty.com!", Timestamp = DateTime.Now, IsMember = true },
|
||||||
|
};
|
||||||
|
// Chat fade timer: clears chat overlay after N seconds of inactivity.
|
||||||
|
private System.Windows.Threading.DispatcherTimer? _chatFadeTimer;
|
||||||
|
|
||||||
|
public ObservableCollection<ChatMessage> ChatMessages { get; } = new();
|
||||||
|
|
||||||
|
/// <summary>The Add → YouTube Chat menu item: enabled only while no chat layer exists
|
||||||
|
/// anywhere — one chat overlay per layout.</summary>
|
||||||
|
public bool CanAddYouTubeChat
|
||||||
|
=> StagedScene != null
|
||||||
|
&& !Scenes.Any(s => s.Elements.OfType<Source>().Any(e => e.Type == SourceType.ChatBox));
|
||||||
|
|
||||||
|
public bool ShowChatInactiveMessage => !IsLive;
|
||||||
|
|
||||||
|
private void OnChatMessageReceived(ChatMessage message)
|
||||||
|
{
|
||||||
|
System.Windows.Application.Current.Dispatcher.Invoke(() =>
|
||||||
|
{
|
||||||
|
ChatMessages.Add(message);
|
||||||
|
if (ChatMessages.Count > 500)
|
||||||
|
ChatMessages.RemoveAt(0);
|
||||||
|
|
||||||
|
// Reset chat fade timer on every message
|
||||||
|
ResetChatFadeTimer();
|
||||||
|
|
||||||
|
StopMockChatPreview();
|
||||||
|
|
||||||
|
// Switch ChatBox previews from mock to real messages
|
||||||
|
if (StagedScene != null)
|
||||||
|
foreach (var chatBox in StagedScene.Elements.OfType<Source>().Where(s => s.Type == SourceType.ChatBox))
|
||||||
|
UpdateChatBoxPreview(chatBox);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ResetChatFadeTimer()
|
||||||
|
{
|
||||||
|
_chatFadeTimer?.Stop();
|
||||||
|
var chatBoxes = Scenes.SelectMany(s => s.Elements).OfType<Source>()
|
||||||
|
.Where(s => s.Type == SourceType.ChatBox && s.ChatFadeSeconds > 0).ToList();
|
||||||
|
if (chatBoxes.Count == 0) return;
|
||||||
|
|
||||||
|
var delay = chatBoxes.Min(s => s.ChatFadeSeconds);
|
||||||
|
_chatFadeTimer = new System.Windows.Threading.DispatcherTimer
|
||||||
|
{ Interval = TimeSpan.FromSeconds(delay) };
|
||||||
|
_chatFadeTimer.Tick += (_, _) =>
|
||||||
|
{
|
||||||
|
_chatFadeTimer?.Stop();
|
||||||
|
_chatFadeTimer = null;
|
||||||
|
ChatMessages.Clear();
|
||||||
|
foreach (var chatBox in Scenes.SelectMany(s => s.Elements).OfType<Source>()
|
||||||
|
.Where(s => s.Type == SourceType.ChatBox))
|
||||||
|
UpdateChatBoxPreview(chatBox);
|
||||||
|
StartMockChatPreview();
|
||||||
|
};
|
||||||
|
_chatFadeTimer.Start();
|
||||||
|
}
|
||||||
|
|
||||||
|
private VideoFrame? RenderChatBox(Source chatBox)
|
||||||
|
{
|
||||||
|
if (ChatMessages.Count == 0) return null;
|
||||||
|
|
||||||
|
var width = (int)Math.Max(1, chatBox.Width);
|
||||||
|
var height = (int)Math.Max(1, chatBox.Height);
|
||||||
|
|
||||||
|
return _chatBoxRenderer.Render(
|
||||||
|
ChatMessages,
|
||||||
|
width,
|
||||||
|
height,
|
||||||
|
chatBox.ChatFontSize,
|
||||||
|
chatBox.ChatFontFamily,
|
||||||
|
chatBox.ChatFontColor,
|
||||||
|
chatBox.ChatBackgroundColor,
|
||||||
|
chatBox.ChatMaxMessages,
|
||||||
|
chatBox.ChatShowTimestamps,
|
||||||
|
chatBox.ChatShowBadges,
|
||||||
|
chatBox.ChatMemberColor,
|
||||||
|
chatBox.ChatSuperChatColor);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Renders the ChatBox preview: real messages when connected, mock when not.
|
||||||
|
/// </summary>
|
||||||
|
private void UpdateChatBoxPreview(Source chatBox, IReadOnlyList<ChatMessage>? messages = null)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
messages ??= ChatMessages.Count > 0 ? (IReadOnlyList<ChatMessage>)ChatMessages : MockChatMessages;
|
||||||
|
var width = (int)Math.Max(32, chatBox.Width);
|
||||||
|
var height = (int)Math.Max(32, chatBox.Height);
|
||||||
|
|
||||||
|
var frame = _chatBoxRenderer.Render(
|
||||||
|
messages,
|
||||||
|
width,
|
||||||
|
height,
|
||||||
|
chatBox.ChatFontSize,
|
||||||
|
chatBox.ChatFontFamily,
|
||||||
|
chatBox.ChatFontColor,
|
||||||
|
chatBox.ChatBackgroundColor,
|
||||||
|
chatBox.ChatMaxMessages,
|
||||||
|
chatBox.ChatShowTimestamps,
|
||||||
|
chatBox.ChatShowBadges,
|
||||||
|
chatBox.ChatMemberColor,
|
||||||
|
chatBox.ChatSuperChatColor);
|
||||||
|
|
||||||
|
var bitmap = new WriteableBitmap(width, height, 96, 96, System.Windows.Media.PixelFormats.Bgra32, null);
|
||||||
|
bitmap.WritePixels(new System.Windows.Int32Rect(0, 0, width, height), frame.BgraPixels, frame.Stride, 0);
|
||||||
|
chatBox.VideoImageSource = bitmap;
|
||||||
|
}
|
||||||
|
catch (Exception ex) { AppLog.Write($"UpdateChatBoxPreview failed: {ex.Message}"); }
|
||||||
|
}
|
||||||
|
|
||||||
|
private CancellationTokenSource? _mockChatCts;
|
||||||
|
|
||||||
|
private async Task RunMockChatPreviewAsync(Source chatBox, CancellationToken ct)
|
||||||
|
{
|
||||||
|
var n = 0;
|
||||||
|
while (!ct.IsCancellationRequested)
|
||||||
|
{
|
||||||
|
UpdateChatBoxPreview(chatBox, MockChatMessages.Take(n + 1).ToList());
|
||||||
|
await Task.Delay(1000, ct);
|
||||||
|
n++;
|
||||||
|
if (n == MockChatMessages.Count)
|
||||||
|
{
|
||||||
|
await Task.Delay(3000, ct);
|
||||||
|
n = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void StartMockChatPreview()
|
||||||
|
{
|
||||||
|
StopMockChatPreview();
|
||||||
|
_mockChatCts = new CancellationTokenSource();
|
||||||
|
var ct = _mockChatCts.Token;
|
||||||
|
foreach (var chatBox in Scenes.SelectMany(s => s.Elements).OfType<Source>()
|
||||||
|
.Where(s => s.Type == SourceType.ChatBox && s.ChatPreviewEnabled))
|
||||||
|
_ = RunMockChatPreviewAsync(chatBox, ct);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void StopMockChatPreview()
|
||||||
|
{
|
||||||
|
_mockChatCts?.Cancel();
|
||||||
|
_mockChatCts?.Dispose();
|
||||||
|
_mockChatCts = null;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Render previews + wire property-change subscriptions for all ChatBox
|
||||||
|
/// sources across every scene. Called after layout load so existing ChatBox
|
||||||
|
/// sources show mock content and respond to config changes.
|
||||||
|
/// </summary>
|
||||||
|
private void UpdateActiveChatBoxPreviews()
|
||||||
|
{
|
||||||
|
foreach (var scene in Scenes)
|
||||||
|
foreach (var chatBox in scene.Elements.OfType<Source>().Where(s => s.Type == SourceType.ChatBox))
|
||||||
|
{
|
||||||
|
chatBox.PropertyChanged += (_, e) =>
|
||||||
|
{
|
||||||
|
if (e.PropertyName is nameof(Source.ChatFontSize) or nameof(Source.ChatFontColor)
|
||||||
|
or nameof(Source.ChatBackgroundColor) or nameof(Source.ChatBackgroundOpacity)
|
||||||
|
or nameof(Source.ChatMaxMessages) or nameof(Source.ChatShowTimestamps)
|
||||||
|
or nameof(Source.ChatShowBadges) or nameof(Source.ChatMemberColor)
|
||||||
|
or nameof(Source.ChatSuperChatColor) or nameof(Source.ChatFontFamily)
|
||||||
|
or nameof(Source.ChatFadeSeconds) or nameof(Source.Width) or nameof(Source.Height))
|
||||||
|
UpdateChatBoxPreview(chatBox);
|
||||||
|
};
|
||||||
|
UpdateChatBoxPreview(chatBox);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,193 @@
|
|||||||
|
using System.Diagnostics;
|
||||||
|
using System.IO;
|
||||||
|
using System.Windows.Input;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel : ViewModelBase
|
||||||
|
{
|
||||||
|
|
||||||
|
private bool _isSettingsOpen;
|
||||||
|
private bool _isBugOpen;
|
||||||
|
private bool _isFeatureOpen;
|
||||||
|
private bool _isAboutOpen;
|
||||||
|
private bool _isLicensesOpen;
|
||||||
|
private string _overlayTitle = string.Empty;
|
||||||
|
private string _bugReportText = string.Empty;
|
||||||
|
private string _bugReportEmail = string.Empty;
|
||||||
|
private string _featureRequestText = string.Empty;
|
||||||
|
private string _featureRequestEmail = string.Empty;
|
||||||
|
|
||||||
|
private const string SupportEmail = "gramps@llamachile.shop";
|
||||||
|
// The creator-hub link targets (About overlay) — public so the hub's
|
||||||
|
// integration test can assert they point at real destinations.
|
||||||
|
public const string ChannelUrl = "https://youtube.com/@llamachileshop";
|
||||||
|
public const string MastodonUrl = "https://mastodon.llamachile.tube/@gramps";
|
||||||
|
public const string PremiumUrl = "https://buy.polar.sh/polar_cl_ueMy8AyAClO0o0yo19IroZwKTbD587gzUsjEW3bFapw";
|
||||||
|
public const string CoffeeUrl = "https://buymeacoffee.com/llamachiley";
|
||||||
|
public static string AppVersionLabel => $"Version {typeof(MainViewModel).Assembly.GetName().Version?.ToString(3)}";
|
||||||
|
|
||||||
|
/// <summary>The About hub's Unlock Premium button lights up only once the
|
||||||
|
/// billing URL is set (Polar — polar.sh, pending TASK 10 implementation).</summary>
|
||||||
|
public bool IsPremiumAvailable => PremiumUrl.Length > 0;
|
||||||
|
|
||||||
|
/// <summary>Full in-app licensing/legal text, loaded on demand from the
|
||||||
|
/// shipped THIRD-PARTY-NOTICES.txt (never opens the OS viewer).</summary>
|
||||||
|
public string LicensesText { get; private set; } = string.Empty;
|
||||||
|
|
||||||
|
// Overlay panels
|
||||||
|
public bool IsSettingsOpen
|
||||||
|
{
|
||||||
|
get => _isSettingsOpen;
|
||||||
|
private set => SetPanel(ref _isSettingsOpen, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool IsBugOpen
|
||||||
|
{
|
||||||
|
get => _isBugOpen;
|
||||||
|
private set => SetPanel(ref _isBugOpen, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool IsFeatureOpen
|
||||||
|
{
|
||||||
|
get => _isFeatureOpen;
|
||||||
|
private set => SetPanel(ref _isFeatureOpen, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool IsAboutOpen
|
||||||
|
{
|
||||||
|
get => _isAboutOpen;
|
||||||
|
private set => SetPanel(ref _isAboutOpen, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>About hub sub-view: the full licensing/legal texts panel
|
||||||
|
/// (in-app scrolling — no Notepad, no browser tab).</summary>
|
||||||
|
public bool IsLicensesOpen
|
||||||
|
{
|
||||||
|
get => _isLicensesOpen;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _isLicensesOpen, value))
|
||||||
|
OnPropertyChanged(nameof(IsHubVisible));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool IsAnyOverlayOpen => IsSettingsOpen || IsBugOpen || IsFeatureOpen || IsAboutOpen;
|
||||||
|
|
||||||
|
public string OverlayTitle
|
||||||
|
{
|
||||||
|
get => _overlayTitle;
|
||||||
|
private set => SetProperty(ref _overlayTitle, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string BugReportText
|
||||||
|
{
|
||||||
|
get => _bugReportText;
|
||||||
|
set => SetProperty(ref _bugReportText, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string BugReportEmail
|
||||||
|
{
|
||||||
|
get => _bugReportEmail;
|
||||||
|
set => SetProperty(ref _bugReportEmail, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string FeatureRequestText
|
||||||
|
{
|
||||||
|
get => _featureRequestText;
|
||||||
|
set => SetProperty(ref _featureRequestText, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string FeatureRequestEmail
|
||||||
|
{
|
||||||
|
get => _featureRequestEmail;
|
||||||
|
set => SetProperty(ref _featureRequestEmail, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public ICommand OpenSettingsCommand { get; }
|
||||||
|
public ICommand OpenBugCommand { get; }
|
||||||
|
public ICommand OpenFeatureCommand { get; }
|
||||||
|
public ICommand OpenAboutCommand { get; }
|
||||||
|
public ICommand CloseOverlayCommand { get; }
|
||||||
|
public ICommand SubmitBugCommand { get; }
|
||||||
|
public ICommand SubmitFeatureCommand { get; }
|
||||||
|
public ICommand OpenChannelCommand { get; }
|
||||||
|
public ICommand OpenMastodonCommand { get; }
|
||||||
|
public ICommand OpenCoffeeCommand { get; }
|
||||||
|
public ICommand OpenPremiumCommand { get; }
|
||||||
|
public ICommand OpenLicensesCommand { get; }
|
||||||
|
|
||||||
|
private void SetPanel(ref bool field, bool value, [System.Runtime.CompilerServices.CallerMemberName] string? propertyName = null)
|
||||||
|
{
|
||||||
|
if (SetProperty(ref field, value, propertyName))
|
||||||
|
OnPropertyChanged(nameof(IsAnyOverlayOpen));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ShowOverlay(string? panel = null, string title = "")
|
||||||
|
{
|
||||||
|
IsSettingsOpen = panel == nameof(IsSettingsOpen);
|
||||||
|
IsBugOpen = panel == nameof(IsBugOpen);
|
||||||
|
IsFeatureOpen = panel == nameof(IsFeatureOpen);
|
||||||
|
IsAboutOpen = panel == nameof(IsAboutOpen);
|
||||||
|
OverlayTitle = title;
|
||||||
|
if (panel != nameof(IsAboutOpen))
|
||||||
|
IsLicensesOpen = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Shows the in-app licensing panel, loading the full texts from
|
||||||
|
/// the shipped THIRD-PARTY-NOTICES.txt on first open (never the OS viewer).
|
||||||
|
/// Falls back to a "not found" note if the file is missing so the panel
|
||||||
|
/// never hangs on nothing.</summary>
|
||||||
|
private void ShowLicenses()
|
||||||
|
{
|
||||||
|
if (string.IsNullOrEmpty(LicensesText))
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var path = Path.Combine(AppContext.BaseDirectory, "THIRD-PARTY-NOTICES.txt");
|
||||||
|
LicensesText = File.Exists(path)
|
||||||
|
? File.ReadAllText(path)
|
||||||
|
: "THIRD-PARTY-NOTICES.txt not found next to the executable.";
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LicensesText = $"Could not read THIRD-PARTY-NOTICES.txt: {ex.Message}";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
IsLicensesOpen = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void SubmitBug()
|
||||||
|
{
|
||||||
|
var body = string.Join(Environment.NewLine,
|
||||||
|
BugReportText.Trim(),
|
||||||
|
string.Empty,
|
||||||
|
$"LlamaCasty {AppVersionLabel}",
|
||||||
|
string.IsNullOrWhiteSpace(BugReportEmail) ? string.Empty : $"Reply-to: {BugReportEmail.Trim()}");
|
||||||
|
ComposeEmail("[LlamaCasty Bug Report]", body);
|
||||||
|
ShowOverlay();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void SubmitFeature()
|
||||||
|
{
|
||||||
|
var body = string.Join(Environment.NewLine,
|
||||||
|
FeatureRequestText.Trim(),
|
||||||
|
string.Empty,
|
||||||
|
$"LlamaCasty {AppVersionLabel}",
|
||||||
|
string.IsNullOrWhiteSpace(FeatureRequestEmail) ? string.Empty : $"Reply-to: {FeatureRequestEmail.Trim()}");
|
||||||
|
ComposeEmail("[LlamaCasty Feature Request]", body);
|
||||||
|
ShowOverlay();
|
||||||
|
}
|
||||||
|
|
||||||
|
private static void ComposeEmail(string subject, string body)
|
||||||
|
{
|
||||||
|
var uri = $"mailto:{SupportEmail}?subject={Uri.EscapeDataString(subject)}&body={Uri.EscapeDataString(body)}";
|
||||||
|
OpenUrl(uri);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static void OpenUrl(string url)
|
||||||
|
{
|
||||||
|
Process.Start(new ProcessStartInfo(url) { UseShellExecute = true });
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,161 @@
|
|||||||
|
using System.Windows;
|
||||||
|
using System.Windows.Input;
|
||||||
|
using System.Windows.Media;
|
||||||
|
using ytLive;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.Services;
|
||||||
|
using ytLive.Services.Compositor;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel
|
||||||
|
{
|
||||||
|
private SocialsConfig? _socials;
|
||||||
|
private VideoFrame? _socialBarFrame;
|
||||||
|
private readonly ISocialValidator _socialValidator = new HttpSocialValidator();
|
||||||
|
|
||||||
|
public ICommand OpenSocialDialogCommand { get; }
|
||||||
|
|
||||||
|
// ─── Social bar (global resource, shown on every scene) ───
|
||||||
|
|
||||||
|
/// <summary>True when the global socials config has at least one validated entry.</summary>
|
||||||
|
public bool HasSocials => _socials != null && _socials.Entries.Count > 0;
|
||||||
|
|
||||||
|
/// <summary>The bar is on the stream when it's enabled and has entries.</summary>
|
||||||
|
public bool SocialBarVisible => (_socials?.BarEnabled ?? false) && HasSocials;
|
||||||
|
|
||||||
|
/// <summary>Footer indicator dot: green when the bar is on the stream, red otherwise.</summary>
|
||||||
|
public SolidColorBrush SocialBarDotBrush => SocialBarVisible ? BarOnBrush : BarOffBrush;
|
||||||
|
|
||||||
|
/// <summary>Green glow on the bar while it's on the stream.</summary>
|
||||||
|
public SolidColorBrush SocialBarGlowBrush => BarOnBrush;
|
||||||
|
|
||||||
|
/// <summary>The global socials config (entries + bar settings), or null.</summary>
|
||||||
|
public SocialsConfig? Socials => _socials;
|
||||||
|
|
||||||
|
/// <summary>Canvas.Top for the social bar: 0 = top, 1040 = bottom (40px from the 1080 edge).</summary>
|
||||||
|
public double SocialBarTop => _socials?.BarPosition == SocialBarPosition.Top ? 0 : 1040;
|
||||||
|
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Resolves a missing nodeinfo software name (mastodon, peertube, ...) for every
|
||||||
|
/// fediverse entry that doesn't have one, so the bar shows the instance's real
|
||||||
|
/// logo instead of the generic fediverse glyph. Best-effort: a failed resolution
|
||||||
|
/// leaves the glyph untouched. Returns handle → software for what was resolved —
|
||||||
|
/// the caller applies + persists (the app hops to the dispatcher; a test applies
|
||||||
|
/// directly).
|
||||||
|
/// </summary>
|
||||||
|
public static async Task<Dictionary<string, string>> HealFediverseSoftwareAsync(
|
||||||
|
SocialsConfig socials,
|
||||||
|
ISocialValidator validator,
|
||||||
|
Action<string>? log = null)
|
||||||
|
{
|
||||||
|
var resolved = new Dictionary<string, string>();
|
||||||
|
if (socials == null || validator == null) return resolved;
|
||||||
|
foreach (var entry in socials.Entries)
|
||||||
|
{
|
||||||
|
if (entry.Service != SocialService.Fediverse
|
||||||
|
|| !string.IsNullOrWhiteSpace(entry.FediverseSoftware))
|
||||||
|
continue;
|
||||||
|
if (!SocialServiceIcons.TryParseFediverse(entry.Handle, out _, out var domain))
|
||||||
|
continue;
|
||||||
|
var software = await validator.ResolveFediverseSoftwareAsync(
|
||||||
|
domain, System.Threading.CancellationToken.None);
|
||||||
|
if (string.IsNullOrWhiteSpace(software)) continue;
|
||||||
|
resolved[entry.Handle] = software;
|
||||||
|
log?.Invoke($"Socials heal: {entry.Handle} → {software}");
|
||||||
|
}
|
||||||
|
return resolved;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Runs the heal off the UI thread and applies + saves any result.</summary>
|
||||||
|
private void HealFediverseSoftwareInBackground()
|
||||||
|
{
|
||||||
|
var socials = _socials;
|
||||||
|
if (socials == null) return;
|
||||||
|
_ = Task.Run(async () =>
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var resolved = await HealFediverseSoftwareAsync(
|
||||||
|
socials, _socialValidator, m => AppLog.Write(m));
|
||||||
|
if (resolved.Count == 0) return;
|
||||||
|
await Application.Current.Dispatcher.InvokeAsync(() =>
|
||||||
|
{
|
||||||
|
var current = _socials;
|
||||||
|
if (current == null) return;
|
||||||
|
var applied = false;
|
||||||
|
foreach (var entry in current.Entries)
|
||||||
|
{
|
||||||
|
if (!resolved.TryGetValue(entry.Handle, out var software)) continue;
|
||||||
|
if (entry.FediverseSoftware == software) continue;
|
||||||
|
entry.FediverseSoftware = software;
|
||||||
|
applied = true;
|
||||||
|
}
|
||||||
|
if (applied) NotifySocialsChanged(); // re-renders the bar + saves
|
||||||
|
});
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write($"Socials heal failed: {ex.Message}");
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Re-rasterizes the social bar strip the output compositor overlays. UI thread
|
||||||
|
/// only (WPF rendering); the resulting frame is immutable, so the frame pump may
|
||||||
|
/// read it from its own thread. Null when the bar is off or empty.
|
||||||
|
/// </summary>
|
||||||
|
private void RenderSocialBarFrame()
|
||||||
|
{
|
||||||
|
_socialBarFrame = _socials != null && _socials.BarEnabled
|
||||||
|
? SocialBarRenderer.Render(_socials.Entries)
|
||||||
|
: null;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Opens the Social Media Site Promotion dialog (6 slots, sign-in gate,
|
||||||
|
/// validation). On save the working copy replaces <see cref="_socials"/>.
|
||||||
|
/// </summary>
|
||||||
|
private void OpenSocialDialog()
|
||||||
|
{
|
||||||
|
var dialog = new SocialsDialogViewModel(
|
||||||
|
_socialValidator,
|
||||||
|
SignInAsync,
|
||||||
|
SignOutYouTubeAsync,
|
||||||
|
_youtubeAuth.CurrentChannel,
|
||||||
|
_socials);
|
||||||
|
var window = new ytLive.SocialsDialog(dialog) { Owner = Application.Current.MainWindow };
|
||||||
|
if (window.ShowDialog() == true)
|
||||||
|
{
|
||||||
|
_socials = dialog.BuildSocialsConfig();
|
||||||
|
NotifySocialsChanged();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void NotifySocialsChanged()
|
||||||
|
{
|
||||||
|
RenderSocialBarFrame();
|
||||||
|
OnPropertyChanged(nameof(HasSocials));
|
||||||
|
OnPropertyChanged(nameof(SocialBarVisible));
|
||||||
|
OnPropertyChanged(nameof(SocialBarDotBrush));
|
||||||
|
ScheduleSave();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Sets the bar's edge; called by the preview click-toggle.</summary>
|
||||||
|
public void SetSocialBarPosition(SocialBarPosition position)
|
||||||
|
{
|
||||||
|
if (_socials == null || _socials.BarPosition == position) return;
|
||||||
|
_socials.BarPosition = position;
|
||||||
|
OnPropertyChanged(nameof(SocialBarTop));
|
||||||
|
ScheduleSave();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Preview click flips the bar top ⇄ bottom (KISS — no drag math).</summary>
|
||||||
|
public void ToggleSocialBarPosition()
|
||||||
|
=> SetSocialBarPosition(_socials?.BarPosition == SocialBarPosition.Top
|
||||||
|
? SocialBarPosition.Bottom
|
||||||
|
: SocialBarPosition.Top);
|
||||||
|
}
|
||||||
@@ -0,0 +1,789 @@
|
|||||||
|
using System.Collections.ObjectModel;
|
||||||
|
using System.IO;
|
||||||
|
using System.Windows;
|
||||||
|
using System.Windows.Input;
|
||||||
|
using System.Windows.Threading;
|
||||||
|
using Microsoft.Win32;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.Services;
|
||||||
|
using ytLive.Services.Encoder;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel : ViewModelBase
|
||||||
|
{
|
||||||
|
|
||||||
|
private readonly DispatcherTimer _liveTimer;
|
||||||
|
private readonly DispatcherTimer _healthPollTimer;
|
||||||
|
|
||||||
|
private StreamStatus _streamStatus = StreamStatus.Offline;
|
||||||
|
private StreamHealth _currentHealth = new();
|
||||||
|
private string _streamTitle = string.Empty;
|
||||||
|
private string _streamDescription = string.Empty;
|
||||||
|
private string _streamVisibility = "Private";
|
||||||
|
private string? _currentBroadcastId;
|
||||||
|
private string? _reusableStreamUrl;
|
||||||
|
private ReusableStream? _reusableStream;
|
||||||
|
private string? _healthIssueBanner;
|
||||||
|
private string _healthIssueBackground = "Transparent";
|
||||||
|
private string _windowTitle = "LlamaCasty";
|
||||||
|
private string _topBarBackground = "#16213e";
|
||||||
|
private string _previewGlowBrush = "Transparent";
|
||||||
|
private Thickness _previewGlowThickness = new(0);
|
||||||
|
private string _liveElapsedText = "00:00:00";
|
||||||
|
private double _recDotPulse = 1.0;
|
||||||
|
private TimeSpan _liveElapsed;
|
||||||
|
|
||||||
|
// ─── Recording (TASK 18): independent REC / ON-AIR pills. The pills are
|
||||||
|
// ─── intent; IsRecording / IsLive are reality. ON-AIR needs a sign-in.
|
||||||
|
private bool _recordPillOn;
|
||||||
|
private bool _onAirPillOn;
|
||||||
|
private bool _isRecording;
|
||||||
|
private string? _recordFolder;
|
||||||
|
|
||||||
|
/// <summary>Resolved record folder — the configured choice, or Downloads (0th case).</summary>
|
||||||
|
public string RecordFolderDisplay => _recordFolder ?? DefaultRecordFolder();
|
||||||
|
|
||||||
|
private string? _activeRecordPath;
|
||||||
|
private DateTime _recordStartTime;
|
||||||
|
private TimeSpan _recordLength;
|
||||||
|
|
||||||
|
private readonly FramePump _framePump;
|
||||||
|
|
||||||
|
public StreamStatus StreamStatus
|
||||||
|
{
|
||||||
|
get => _streamStatus;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _streamStatus, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(IsOffline));
|
||||||
|
OnPropertyChanged(nameof(IsLive));
|
||||||
|
OnPropertyChanged(nameof(IsEditMode));
|
||||||
|
OnPropertyChanged(nameof(RecDotBrush));
|
||||||
|
OnPropertyChanged(nameof(RecTextBrush));
|
||||||
|
OnPropertyChanged(nameof(RecDotOpacity));
|
||||||
|
OnPropertyChanged(nameof(OnAirBrush));
|
||||||
|
OnPropertyChanged(nameof(IsLivePrivate));
|
||||||
|
OnPropertyChanged(nameof(ShowPrimaryStartButton));
|
||||||
|
OnPropertyChanged(nameof(ShowLogInButton));
|
||||||
|
OnPropertyChanged(nameof(ShowEndStreamButton));
|
||||||
|
OnPropertyChanged(nameof(EndButtonText));
|
||||||
|
OnPropertyChanged(nameof(AccountStatusLightToolTip));
|
||||||
|
OnPropertyChanged(nameof(ShowChatInactiveMessage));
|
||||||
|
OnPropertyChanged(nameof(ShowPreviewPlaceholder));
|
||||||
|
UpdateLiveVisuals();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool IsOffline => StreamStatus == StreamStatus.Offline;
|
||||||
|
public bool IsLive => StreamStatus == StreamStatus.Streaming;
|
||||||
|
public bool IsLivePrivate => IsLive && string.Equals(StreamVisibility, "Private", StringComparison.OrdinalIgnoreCase);
|
||||||
|
public string RecDotBrush => !IsRecording ? "#555555" : "#e94560";
|
||||||
|
public string RecTextBrush => (IsLive || IsRecording) ? "#ffffff" : "#888888";
|
||||||
|
public double RecDotOpacity => IsRecording ? _recDotPulse : 0.55;
|
||||||
|
public string OnAirBrush => !IsLive ? "#555555" : IsLivePrivate ? "#22c55e" : "#e94560";
|
||||||
|
|
||||||
|
// ─── REC / ON-AIR pills (TASK 18) ───
|
||||||
|
public bool RecordPillOn
|
||||||
|
{
|
||||||
|
get => _recordPillOn;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (!SetProperty(ref _recordPillOn, value)) return;
|
||||||
|
OnPropertyChanged(nameof(ShowPrimaryStartButton));
|
||||||
|
OnPropertyChanged(nameof(CanStartSession));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool OnAirPillOn
|
||||||
|
{
|
||||||
|
get => _onAirPillOn;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (value && !CanToggleOnAir) return; // needs a sign-in
|
||||||
|
if (!SetProperty(ref _onAirPillOn, value)) return;
|
||||||
|
OnPropertyChanged(nameof(ShowPrimaryStartButton));
|
||||||
|
OnPropertyChanged(nameof(CanStartSession));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>The ON-AIR pill (and thus live streaming) needs a YouTube sign-in.</summary>
|
||||||
|
public bool CanToggleOnAir => IsConnected;
|
||||||
|
|
||||||
|
/// <summary>Whether the session is actively recording — the REC status light
|
||||||
|
/// turns green only when this is true (the pill is intent, this is reality).</summary>
|
||||||
|
public bool IsRecording
|
||||||
|
{
|
||||||
|
get => _isRecording;
|
||||||
|
private set
|
||||||
|
{
|
||||||
|
if (!SetProperty(ref _isRecording, value)) return;
|
||||||
|
OnPropertyChanged(nameof(RecDotBrush));
|
||||||
|
OnPropertyChanged(nameof(RecTextBrush));
|
||||||
|
OnPropertyChanged(nameof(RecDotOpacity));
|
||||||
|
OnPropertyChanged(nameof(IsEditMode));
|
||||||
|
OnPropertyChanged(nameof(ShowEndStreamButton));
|
||||||
|
OnPropertyChanged(nameof(ShowPrimaryStartButton));
|
||||||
|
OnPropertyChanged(nameof(EndButtonText));
|
||||||
|
UpdateSessionTimer();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>The primary button shows when there's something to start, but never
|
||||||
|
/// while a session is running — once recording/live the ONLY control is the End
|
||||||
|
/// button.</summary>
|
||||||
|
public bool ShowPrimaryStartButton =>
|
||||||
|
IsOffline && !IsRecording && !IsLive
|
||||||
|
&& (IsConnected || (RecordPillOn && !OnAirPillOn));
|
||||||
|
|
||||||
|
/// <summary>Either output selected makes the button actionable.</summary>
|
||||||
|
public bool CanStartSession => RecordPillOn || OnAirPillOn;
|
||||||
|
|
||||||
|
/// <summary>The End button shows while recording OR live.</summary>
|
||||||
|
public bool ShowEndStreamButton => IsLive || IsRecording;
|
||||||
|
|
||||||
|
/// <summary>The one button whose label changes: while recording it reads
|
||||||
|
/// "Stop Recording", while live "End Stream".</summary>
|
||||||
|
public string EndButtonText => IsRecording && !IsLive ? "Stop Recording" : "End Stream";
|
||||||
|
|
||||||
|
public bool ShowLogInButton => !IsConnected && IsOffline && !IsRecording;
|
||||||
|
|
||||||
|
public StreamHealth CurrentHealth
|
||||||
|
{
|
||||||
|
get => _currentHealth;
|
||||||
|
set => SetProperty(ref _currentHealth, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Report-by-exception YouTube health (TASK 5 item 3): non-null only
|
||||||
|
/// while a warning/error configuration issue exists — the banner's text.
|
||||||
|
/// good/ok/noData keep it null so nothing renders.</summary>
|
||||||
|
public string? HealthIssueBanner
|
||||||
|
{
|
||||||
|
get => _healthIssueBanner;
|
||||||
|
private set => SetProperty(ref _healthIssueBanner, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Banner background: app red (#8f1f1f) for an error issue, amber
|
||||||
|
/// (#b8860b) for a warning. Transparent when no banner is shown.</summary>
|
||||||
|
public string HealthIssueBackground
|
||||||
|
{
|
||||||
|
get => _healthIssueBackground;
|
||||||
|
private set => SetProperty(ref _healthIssueBackground, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string StreamTitle
|
||||||
|
{
|
||||||
|
get => _streamTitle;
|
||||||
|
set => SetProperty(ref _streamTitle, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string StreamDescription
|
||||||
|
{
|
||||||
|
get => _streamDescription;
|
||||||
|
set => SetProperty(ref _streamDescription, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string StreamVisibility
|
||||||
|
{
|
||||||
|
get => _streamVisibility;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _streamVisibility, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(RecDotBrush));
|
||||||
|
OnPropertyChanged(nameof(RecTextBrush));
|
||||||
|
OnPropertyChanged(nameof(OnAirBrush));
|
||||||
|
OnPropertyChanged(nameof(IsLivePrivate));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public string WindowTitle
|
||||||
|
{
|
||||||
|
get => _windowTitle;
|
||||||
|
set => SetProperty(ref _windowTitle, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string TopBarBackground
|
||||||
|
{
|
||||||
|
get => _topBarBackground;
|
||||||
|
set => SetProperty(ref _topBarBackground, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string PreviewGlowBrush
|
||||||
|
{
|
||||||
|
get => _previewGlowBrush;
|
||||||
|
set => SetProperty(ref _previewGlowBrush, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Thickness PreviewGlowThickness
|
||||||
|
{
|
||||||
|
get => _previewGlowThickness;
|
||||||
|
set => SetProperty(ref _previewGlowThickness, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public string LiveElapsedText
|
||||||
|
{
|
||||||
|
get => _liveElapsedText;
|
||||||
|
set => SetProperty(ref _liveElapsedText, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
// ─── Broadcast metadata pull-out (the "Text" tab on the Live screen) ───
|
||||||
|
|
||||||
|
/// <summary>The broadcast id of the current/last session; null until Go Live
|
||||||
|
/// succeeds. Gates the pull-out's Update button (nothing remote to patch).</summary>
|
||||||
|
public string? CurrentBroadcastId => _currentBroadcastId;
|
||||||
|
|
||||||
|
public Services.LiveBroadcastFormViewModel BroadcastForm { get; }
|
||||||
|
|
||||||
|
// ─── Resolution quality dropdown (bottom bar) ───
|
||||||
|
// Tiers offered to the creator before going live. First = default. The
|
||||||
|
// dropdown is disabled while live because YouTube stream resolution is
|
||||||
|
// immutable after stream creation (see TASKS.md compliance notes).
|
||||||
|
|
||||||
|
// The composition master frame. Every tier is an output rect + target
|
||||||
|
// resolution over this frame (see ai.md "Resolution tiers"): 16:9 tiers
|
||||||
|
// use the full frame; the vertical tier uses a centered 9:16 window and
|
||||||
|
// the preview dims the cropped strips (semi-crop).
|
||||||
|
private const double MasterFrameWidth = 1920;
|
||||||
|
private const double MasterFrameHeight = 1080;
|
||||||
|
|
||||||
|
public QualityOption[] QualityOptions { get; } =
|
||||||
|
{
|
||||||
|
new("1080p60", 60, 8.0, 1920, 1080),
|
||||||
|
new("1080p30", 30, 8.0, 1920, 1080),
|
||||||
|
new("720p60", 60, 6.0, 1280, 720),
|
||||||
|
new("720p30", 30, 6.0, 1280, 720),
|
||||||
|
new("Vertical 1080p60", 60, 8.0, 1080, 1920),
|
||||||
|
};
|
||||||
|
|
||||||
|
public string ResolutionHelp { get; } =
|
||||||
|
"Pick the highest resolution your upload bandwidth can comfortably sustain. " +
|
||||||
|
"Find your upload speed on your ISP plan or with a speed test (e.g. fast.com), " +
|
||||||
|
"then choose a tier your upload comfortably exceeds. 1080p60 is the default.";
|
||||||
|
|
||||||
|
private QualityOption _selectedQuality;
|
||||||
|
public QualityOption SelectedQuality
|
||||||
|
{
|
||||||
|
get => _selectedQuality;
|
||||||
|
set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _selectedQuality, value))
|
||||||
|
ApplyStreamQuality(value);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Output frame of the selected tier over the 1920x1080 master. The strips
|
||||||
|
// outside it are dimmed in the preview so the cropped area stays visible.
|
||||||
|
public double OutputRectX { get; private set; }
|
||||||
|
public double OutputRectY { get; private set; }
|
||||||
|
public double OutputRectWidth { get; private set; }
|
||||||
|
public double OutputRectHeight { get; private set; }
|
||||||
|
public bool IsOutputCropped { get; private set; }
|
||||||
|
public string ResolutionBadgeText { get; private set; } = string.Empty;
|
||||||
|
public ObservableCollection<Rect> DimRects { get; } = new();
|
||||||
|
|
||||||
|
private void ApplyStreamQuality(QualityOption quality)
|
||||||
|
{
|
||||||
|
var health = CurrentHealth;
|
||||||
|
health.CurrentBitrate = quality.Bitrate;
|
||||||
|
health.FPS = quality.Fps;
|
||||||
|
OnPropertyChanged(nameof(CurrentHealth));
|
||||||
|
|
||||||
|
var scale = Math.Min(MasterFrameWidth / quality.Width, MasterFrameHeight / quality.Height);
|
||||||
|
var rectW = quality.Width * scale;
|
||||||
|
var rectH = quality.Height * scale;
|
||||||
|
var rectX = (MasterFrameWidth - rectW) / 2;
|
||||||
|
var rectY = (MasterFrameHeight - rectH) / 2;
|
||||||
|
|
||||||
|
OutputRectX = rectX;
|
||||||
|
OutputRectY = rectY;
|
||||||
|
OutputRectWidth = rectW;
|
||||||
|
OutputRectHeight = rectH;
|
||||||
|
|
||||||
|
DimRects.Clear();
|
||||||
|
if (rectX > 0) DimRects.Add(new Rect(0, 0, rectX, MasterFrameHeight));
|
||||||
|
if (rectX + rectW < MasterFrameWidth)
|
||||||
|
DimRects.Add(new Rect(rectX + rectW, 0, MasterFrameWidth - rectX - rectW, MasterFrameHeight));
|
||||||
|
if (rectY > 0) DimRects.Add(new Rect(0, 0, MasterFrameWidth, rectY));
|
||||||
|
if (rectY + rectH < MasterFrameHeight)
|
||||||
|
DimRects.Add(new Rect(0, rectY + rectH, MasterFrameWidth, MasterFrameHeight - rectY - rectH));
|
||||||
|
|
||||||
|
IsOutputCropped = DimRects.Count > 0;
|
||||||
|
ResolutionBadgeText = $"{quality.Label} · {quality.Width}×{quality.Height}";
|
||||||
|
|
||||||
|
OnPropertyChanged(nameof(OutputRectX));
|
||||||
|
OnPropertyChanged(nameof(OutputRectY));
|
||||||
|
OnPropertyChanged(nameof(OutputRectWidth));
|
||||||
|
OnPropertyChanged(nameof(OutputRectHeight));
|
||||||
|
OnPropertyChanged(nameof(IsOutputCropped));
|
||||||
|
OnPropertyChanged(nameof(ResolutionBadgeText));
|
||||||
|
}
|
||||||
|
|
||||||
|
public ICommand StartStreamCommand { get; }
|
||||||
|
public ICommand EndStreamCommand { get; }
|
||||||
|
public ICommand ChooseRecordFolderCommand { 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,132 @@
|
|||||||
|
using System.IO;
|
||||||
|
using System.Windows.Media;
|
||||||
|
using Microsoft.Win32;
|
||||||
|
using ytLive.Helpers;
|
||||||
|
using ytLive.Models;
|
||||||
|
using ytLive.Services.Audio;
|
||||||
|
|
||||||
|
namespace ytLive.ViewModels;
|
||||||
|
|
||||||
|
public partial class MainViewModel
|
||||||
|
{
|
||||||
|
// TRAX (TASK 9): free background music at a fixed quiet volume, playing to
|
||||||
|
// the default device so it rides the loopback into the stream. The dot is
|
||||||
|
// red (no track) / yellow (loaded, stopped) / green (playing).
|
||||||
|
private readonly MusicPlayer _musicPlayer = new();
|
||||||
|
private Music? _music;
|
||||||
|
private bool _musicPlaying;
|
||||||
|
|
||||||
|
private static readonly SolidColorBrush TraxIdleBrush = CreateBrush("#555");
|
||||||
|
/// <summary>True while the TRAX background track is playing.</summary>
|
||||||
|
public bool IsMusicPlaying
|
||||||
|
{
|
||||||
|
get => _musicPlaying;
|
||||||
|
private set
|
||||||
|
{
|
||||||
|
if (SetProperty(ref _musicPlaying, value))
|
||||||
|
{
|
||||||
|
OnPropertyChanged(nameof(TraxDotBrush));
|
||||||
|
OnPropertyChanged(nameof(TraxToolTip));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private string? _traxError;
|
||||||
|
|
||||||
|
/// <summary>Error message from the last TRAX load/playback failure; null = no error.</summary>
|
||||||
|
public string? TraxError
|
||||||
|
{
|
||||||
|
get => _traxError;
|
||||||
|
private set => SetProperty(ref _traxError, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>TRAX status dot: green = playing, gray = idle or no track.</summary>
|
||||||
|
public SolidColorBrush TraxDotBrush => _musicPlayer.IsPlaying
|
||||||
|
? BarOnBrush
|
||||||
|
: TraxIdleBrush;
|
||||||
|
|
||||||
|
public string TraxToolTip => _musicPlayer.TrackName != null
|
||||||
|
? $"TRAX: {_musicPlayer.TrackName} — left-click {(IsMusicPlaying ? "pauses" : "plays")}, right-click chooses a track"
|
||||||
|
: "No track — left-click or right-click to choose background music";
|
||||||
|
|
||||||
|
/// <summary>Left-click on TRAX: no track → pick one; otherwise toggle play/pause.</summary>
|
||||||
|
public void TraxLeftClick()
|
||||||
|
{
|
||||||
|
if (_music == null || string.IsNullOrWhiteSpace(_music.TrackPath))
|
||||||
|
PickTraxTrack();
|
||||||
|
else if (IsMusicPlaying)
|
||||||
|
PauseTrax();
|
||||||
|
else
|
||||||
|
PlayTrax();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Right-click on TRAX: always open the track picker (never the OS viewer).</summary>
|
||||||
|
public void TraxRightClick() => PickTraxTrack();
|
||||||
|
|
||||||
|
private void PickTraxTrack()
|
||||||
|
{
|
||||||
|
var dialog = new OpenFileDialog
|
||||||
|
{
|
||||||
|
Title = "Choose background music",
|
||||||
|
Filter = "Music (*.mp3;*.wav;*.m4a;*.aac;*.flac;*.ogg)|*.mp3;*.wav;*.m4a;*.aac;*.flac;*.ogg|All files (*.*)|*.*",
|
||||||
|
};
|
||||||
|
if (dialog.ShowDialog() != true)
|
||||||
|
return;
|
||||||
|
|
||||||
|
_music = new Music { TrackPath = dialog.FileName, IsEnabled = true };
|
||||||
|
LoadTrax(play: true);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void LoadTrax(bool play)
|
||||||
|
{
|
||||||
|
if (_music == null || string.IsNullOrWhiteSpace(_music.TrackPath))
|
||||||
|
return;
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
_musicPlayer.Load(_music.TrackPath);
|
||||||
|
UpdateTraxLocalGain();
|
||||||
|
_music.IsEnabled = true;
|
||||||
|
TraxError = null;
|
||||||
|
if (play)
|
||||||
|
_musicPlayer.Play();
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
AppLog.Write($"TRAX: failed to load '{_music.TrackPath}': {ex.Message}");
|
||||||
|
TraxError = $"Failed to load: {Path.GetFileName(_music.TrackPath)} — {ex.Message}";
|
||||||
|
}
|
||||||
|
RefreshTraxUi();
|
||||||
|
ScheduleSave();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void PlayTrax() => _musicPlayer.Play();
|
||||||
|
|
||||||
|
private void PauseTrax() => _musicPlayer.Pause();
|
||||||
|
|
||||||
|
private void OnTraxPlaybackEnded(Exception? ex)
|
||||||
|
{
|
||||||
|
if (ex != null)
|
||||||
|
{
|
||||||
|
AppLog.Write($"TRAX: playback error: {ex.Message}");
|
||||||
|
TraxError = $"Playback error: {ex.Message}";
|
||||||
|
}
|
||||||
|
RefreshTraxUi();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void RefreshTraxUi()
|
||||||
|
{
|
||||||
|
IsMusicPlaying = _musicPlayer.IsPlaying;
|
||||||
|
OnPropertyChanged(nameof(TraxDotBrush));
|
||||||
|
OnPropertyChanged(nameof(TraxToolTip));
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>Mirrors the desktop/game audio bar's volume and mute onto the
|
||||||
|
/// music so the creator hears the controls work in the headphones (the
|
||||||
|
/// track rides the loopback channel, so it must duck the same way locally).
|
||||||
|
/// Called whenever the game volume/mute change and on TRAX load.</summary>
|
||||||
|
private void UpdateTraxLocalGain()
|
||||||
|
{
|
||||||
|
_musicPlayer.LocalGain = GameMuted ? 0f : 1f;
|
||||||
|
}
|
||||||
|
}
|
||||||
File diff suppressed because it is too large
Load Diff
+32
-47
File diff suppressed because one or more lines are too long
Reference in New Issue
Block a user