Salastil/KfChatDotNet
1
0
Fork 0
mirror of https://github.com/barelyprofessional/KfChatDotNet.git synced 2026-05-02 04:22:04 -04:00
Code Issues Packages Projects Releases Wiki Activity

YouTube PubSub

Browse Source
This commit is contained in:
barelyprofessional
2025-12-19 00:49:18 -06:00
parent 72a162b67a
commit a88045c63d
5 changed files with 137 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
KfChatDotNetBot/Services/BotServices.cs
View File

@@ -39,6 +39,7 @@ public class BotServices
private PeerTube? _peerTubeStatusCheck;
private Owncast? _owncastStatusCheck;
private ShuffleDotUs? _shuffleDotUs;
private YouTubePubSub? _youTubePubSub;
public OpenRouter? OpenRouter;
private Task? _websocketWatchdog;
@@ -130,6 +131,20 @@ public class BotServices
_shuffleDotUs.OnLatestBetUpdated += ShuffleOnLatestBetUpdated;
await _shuffleDotUs.StartWsClient();
}
private async Task BuildYouTubePubSub()
{
var settings = await SettingsProvider.GetMultipleValuesAsync([BuiltIn.Keys.YouTubePubSubEnabled]);
if (!settings[BuiltIn.Keys.YouTubePubSubEnabled].ToBoolean())
{
_logger.Debug("YouTube PubSub is disabled");
return;
}
_youTubePubSub = new YouTubePubSub(_cancellationToken);
_youTubePubSub.OnNewVideo += YouTubePubSubOnNewVideo;
await _youTubePubSub.Connect();
_logger.Info("Built YouTube PubSub");
}
private async Task BuildDiscord()
{
@@ -393,7 +408,8 @@ public class BotServices
var settings = await SettingsProvider.GetMultipleValuesAsync([
BuiltIn.Keys.KickEnabled, BuiltIn.Keys.HowlggEnabled, BuiltIn.Keys.ChipsggEnabled,
BuiltIn.Keys.ClashggEnabled, BuiltIn.Keys.BetBoltEnabled, BuiltIn.Keys.YeetEnabled,
BuiltIn.Keys.RainbetEnabled, BuiltIn.Keys.PartiEnabled, BuiltIn.Keys.JackpotEnabled
BuiltIn.Keys.RainbetEnabled, BuiltIn.Keys.PartiEnabled, BuiltIn.Keys.JackpotEnabled,
BuiltIn.Keys.YouTubePubSubEnabled
]);
try
{
@@ -508,6 +524,15 @@ public class BotServices
_shuffleDotUs = null!;
await BuildShuffleDotUs();
}
if (settings[BuiltIn.Keys.YouTubePubSubEnabled].ToBoolean() && _youTubePubSub != null &&
!_youTubePubSub.IsConnected())
{
_logger.Error("YouTube PubSub died, recreating it");
_youTubePubSub.Dispose();
_youTubePubSub = null;
await BuildYouTubePubSub();
}
}
catch (Exception e)
{
@@ -1253,4 +1278,31 @@ public class BotServices
};
await SettingsProvider.SetValueAsJsonObjectAsync(BuiltIn.Keys.BossmanLastSighting, sighting);
}
private void YouTubePubSubOnNewVideo(object sender, YouTubePubSubNotificationModel data)
{
var video = YouTubeApi.GetVideoDetails(data.Id).Result;
if (video == null)
{
_logger.Error($"Caught a null when getting video details for {data.Id} which we were just notified about");
return;
}
if (video.Snippet.LiveBroadcastContent == "live")
{
_chatBot.SendChatMessageAsync($"@{video.Snippet.ChannelTitle} has gone live! {data.Title} {data.Url}", true).Wait(_cancellationToken);
}
else if (video.Snippet.LiveBroadcastContent == "upcoming")
{
_chatBot.SendChatMessageAsync($"@{video.Snippet.ChannelTitle} has scheduled a live stream! {data.Title} {data.Url}", true).Wait(_cancellationToken);
}
else if (video.Snippet.LiveBroadcastContent == "none")
{
_chatBot.SendChatMessageAsync($"@{video.Snippet.ChannelTitle} has uploaded a new video! {data.Title} {data.Url}", true).Wait(_cancellationToken);
}
else
{
_logger.Error($"YouTube live broadcast content '{video.Snippet.LiveBroadcastContent}' was unhandled for {data.Id}");
}
}
}