using System.Security.Cryptography.X509Certificates; using System.Text.RegularExpressions; using RestSharp; using TwitchLib.Api; using TwitchLib.Api.Helix.Models.Users.GetUsers; using TwitchLib.Client; using TwitchLib.Client.Events; using TwitchLib.Client.Models; using TwitchLib.Communication.Clients; using TwitchLib.Communication.Models; using vassago.Behavior; using vassago.Models; namespace vassago.TwitchInterface; public class TwitchInterface { internal const string PROTOCOL = "twitch"; private bool eventsSignedUp = false; private ChattingContext _db; private static SemaphoreSlim twitchChannelSetup = new SemaphoreSlim(1, 1); private Channel protocolAsChannel; TwitchClient client; TwitchAPI api; public TwitchInterface() { _db = new ChattingContext(); } private async Task SetupTwitchChannel() { await twitchChannelSetup.WaitAsync(); try { protocolAsChannel = _db.Channels.FirstOrDefault(c => c.ParentChannel == null && c.Protocol == PROTOCOL); if (protocolAsChannel == null) { protocolAsChannel = new Channel() { DisplayName = "twitch (itself)", MeannessFilterLevel = Enumerations.MeannessFilterLevel.Medium, LewdnessFilterLevel = Enumerations.LewdnessFilterLevel.G, MaxTextChars = 500, MaxAttachmentBytes = 0, LinksAllowed = false, ReactionsPossible = false, ExternalId = null, Protocol = PROTOCOL, SubChannels = new List() }; protocolAsChannel.SendMessage = (t) => { throw new InvalidOperationException($"twitch itself cannot accept text"); }; protocolAsChannel.SendFile = (f, t) => { throw new InvalidOperationException($"twitch itself cannot send file"); }; _db.Channels.Add(protocolAsChannel); _db.SaveChanges(); } } finally { twitchChannelSetup.Release(); } } ///https://www.twitchapps.com/tmi/ public async Task Init(TwitchConfig tc) { await SetupTwitchChannel(); WebSocketClient customClient = new WebSocketClient(new ClientOptions { MessagesAllowedInPeriod = 750, ThrottlingPeriod = TimeSpan.FromSeconds(30) } ); client = new TwitchClient(customClient); client.Initialize(new ConnectionCredentials(tc.username, tc.oauth, capabilities: new Capabilities())); client.OnLog += Client_OnLog; client.OnJoinedChannel += Client_OnJoinedChannel; client.OnMessageReceived += Client_OnMessageReceivedAsync; client.OnWhisperReceived += Client_OnWhisperReceivedAsync; client.OnConnected += Client_OnConnected; Console.WriteLine("twitch client 1 connecting..."); client.Connect(); Console.WriteLine("twitch client 1 connected"); // Console.WriteLine("twitch API client connecting..."); // api = new TwitchAPI(); // Console.WriteLine("can I just use the same creds as the other client?"); // api.Settings.ClientId = tc.username; // api.Settings.AccessToken = tc.oauth; // try{ // var neckbreads = await api.Helix.Moderation.GetModeratorsAsync("silvermeddlists"); // Console.WriteLine($"{neckbreads?.Data?.Count()} shabby beards that need to be given up on"); // } // catch(Exception e){ // Console.Error.WriteLine(e); // } // Console.WriteLine("k."); } private async void Client_OnWhisperReceivedAsync(object sender, OnWhisperReceivedArgs e) { Console.WriteLine($"whisper#{e.WhisperMessage.Username}[{DateTime.Now}][{e.WhisperMessage.DisplayName} [id={e.WhisperMessage.Username}]][msg id: {e.WhisperMessage.MessageId}] {e.WhisperMessage.Message}"); var old = _db.Messages.FirstOrDefault(m => m.ExternalId == e.WhisperMessage.MessageId && m.Protocol == PROTOCOL); if (old != null) { Console.WriteLine($"[whisperreceived]: {e.WhisperMessage.MessageId}? already seent it. Internal id: {old.Id}"); return; } var m = UpsertMessage(e.WhisperMessage); m.Channel.ChannelType = vassago.Models.Enumerations.ChannelType.DM; m.MentionsMe = Regex.IsMatch(e.WhisperMessage.Message?.ToLower(), $"\\b@{e.WhisperMessage.BotUsername.ToLower()}\\b"); await _db.SaveChangesAsync(); await Behaver.Instance.ActOn(m); await _db.SaveChangesAsync(); } private async void Client_OnMessageReceivedAsync(object sender, OnMessageReceivedArgs e) { Console.WriteLine($"#{e.ChatMessage.Channel}[{DateTime.Now}][{e.ChatMessage.DisplayName} [id={e.ChatMessage.Username}]][msg id: {e.ChatMessage.Id}] {e.ChatMessage.Message}"); var old = _db.Messages.FirstOrDefault(m => m.ExternalId == e.ChatMessage.Id && m.Protocol == PROTOCOL); if (old != null) { Console.WriteLine($"[messagereceived]: {e.ChatMessage.Id}? already seent it"); return; } Console.WriteLine($"[messagereceived]: {e.ChatMessage.Id}? new to me."); var m = UpsertMessage(e.ChatMessage); m.MentionsMe = Regex.IsMatch(e.ChatMessage.Message?.ToLower(), $"@{e.ChatMessage.BotUsername.ToLower()}\\b") || e.ChatMessage.ChatReply?.ParentUserLogin == e.ChatMessage.BotUsername; await _db.SaveChangesAsync(); await Behaver.Instance.ActOn(m); await _db.SaveChangesAsync(); } private async void Client_OnConnected(object sender, OnConnectedArgs e) { var selfAccount = UpsertAccount(e.BotUsername, protocolAsChannel.Id); await _db.SaveChangesAsync(); Behaver.Instance.MarkSelf(selfAccount); Console.WriteLine($"Connected to {e.AutoJoinChannel}"); } private void Client_OnJoinedChannel(object sender, OnJoinedChannelArgs e) { client.SendMessage(e.Channel, "beep boop"); } private void Client_OnLog(object sender, OnLogArgs e) { Console.WriteLine($"{e.DateTime.ToString()}: {e.BotUsername} - {e.Data}"); } private Account UpsertAccount(string username, Guid inChannel) { var acc = _db.Accounts.FirstOrDefault(ui => ui.ExternalId == username && ui.SeenInChannel.Id == inChannel); if (acc == null) { acc = new Account(); _db.Accounts.Add(acc); } acc.Username = username; acc.ExternalId = username; //acc.IsBot = acc.Protocol = PROTOCOL; acc.IsUser = _db.Users.FirstOrDefault(u => u.Accounts.Any(a => a.ExternalId == acc.ExternalId && a.Protocol == acc.Protocol)); if (acc.IsUser == null) { acc.IsUser = new vassago.Models.User() { Accounts = new List() { acc } }; _db.Users.Add(acc.IsUser); } return acc; } private Channel UpsertChannel(string channelName) { Channel c = _db.Channels.FirstOrDefault(ci => ci.ExternalId == channelName && ci.Protocol == PROTOCOL); if (c == null) { c = new Channel(); _db.Channels.Add(c); } c.DisplayName = channelName; c.ExternalId = channelName; c.ChannelType = vassago.Models.Enumerations.ChannelType.Normal; c.Messages = c.Messages ?? new List(); c.Protocol = PROTOCOL; c.ParentChannel = protocolAsChannel; c.SubChannels = c.SubChannels ?? new List(); c.SendMessage = (t) => { return Task.Run(() => { client.SendMessage(channelName, t); }); }; c.SendFile = (f, t) => { throw new InvalidOperationException($"twitch cannot send files"); }; return c; } private Channel UpsertDMChannel(string whisperWith) { Channel c = _db.Channels.FirstOrDefault(ci => ci.ExternalId == $"w_{whisperWith}" && ci.Protocol == PROTOCOL); if (c == null) { c = new Channel(); _db.Channels.Add(c); } c.DisplayName = $"Whisper: {whisperWith}"; c.ExternalId = $"w_{whisperWith}"; c.ChannelType = vassago.Models.Enumerations.ChannelType.DM; c.Messages = c.Messages ?? new List(); c.Protocol = PROTOCOL; c.ParentChannel = protocolAsChannel; c.SubChannels = c.SubChannels ?? new List(); c.SendMessage = (t) => { return Task.Run(() => { try { client.SendWhisper(whisperWith, t); } catch(Exception e) { Console.Error.WriteLine(e); } }); }; c.SendFile = (f, t) => { throw new InvalidOperationException($"twitch cannot send files"); }; return c; } private Message UpsertMessage(ChatMessage chatMessage) { var m = _db.Messages.FirstOrDefault(mi => mi.ExternalId == chatMessage.Id); if (m == null) { m = new Message(); m.Protocol = PROTOCOL; _db.Messages.Add(m); m.Timestamp = (DateTimeOffset)DateTime.SpecifyKind(DateTime.UtcNow, DateTimeKind.Utc); } m.Content = chatMessage.Message; m.ExternalId = chatMessage.Id; m.Channel = UpsertChannel(chatMessage.Channel); m.Author = UpsertAccount(chatMessage.Username, m.Channel.Id); m.Author.SeenInChannel = m.Channel; m.Reply = (t) => { return Task.Run(() => { client.SendReply(chatMessage.Channel, chatMessage.Id, t); }); }; m.React = (e) => { throw new InvalidOperationException($"twitch cannot react"); }; return m; } private Message UpsertMessage(WhisperMessage whisperMessage) { var m = _db.Messages.FirstOrDefault(mi => mi.ExternalId == whisperMessage.MessageId); if (m == null) { m = new Message(); m.Protocol = PROTOCOL; _db.Messages.Add(m); m.Timestamp = (DateTimeOffset)DateTime.SpecifyKind(DateTime.UtcNow, DateTimeKind.Utc); } m.Content = whisperMessage.Message; m.ExternalId = whisperMessage.MessageId; m.Channel = UpsertDMChannel(whisperMessage.Username); m.Channel.ChannelType = vassago.Models.Enumerations.ChannelType.DM; m.Author = UpsertAccount(whisperMessage.Username, m.Channel.Id); m.Author.SeenInChannel = m.Channel; m.Reply = (t) => { return Task.Run(() => { client.SendWhisper(whisperMessage.Username, t); }); }; m.React = (e) => { throw new InvalidOperationException($"twitch cannot react"); }; return m; } public string AttemptJoin(string channelTarget) { client.JoinChannel(channelTarget); return $"attempt join {channelTarget} - o7"; } internal void AttemptLeave(string channelTarget) { client.SendMessage(channelTarget, "o7"); client.LeaveChannel(channelTarget); } }