steven4547466
commented
1 year ago This looks good and has the ability to send the chatter's ID as well in the future for moderation purposes it seems. I was unaware this existed when I made my original change.
However, I will say, this does use YouTube's private API, which can change with no warning and no documentation, and that the innertube api key can and will expire eventually which means the process will need to be restarted to scrape a new one, but that's not too big of a deal.
Regardless, at this point in time I have tested this and it does work, though I will suggest a minor change, now that it's possible.
Change getAuthorAndContents to
async function getAuthorAndContents(message) {
if (!message) return null
let id = message.author.channelId
let author = message.author.name || "User"
let text = message.message[0].text || "Not Found"
return { id, author, text }
}and add id to the C# side by editing the ChatMessage class:
public class ChatMessage
{
public string id { get; set; }
public string author { get; set; }
public string text { get; set; }
public ChatMessage(string id, string author, string text)
{
this.author = author;
this.text = text;
this.id = id;
}
public ChatMessage() { }
public override string ToString()
{
return $"Author: {author} ({id}) | Message: {text}";
}
}while not used now, this allows for moderation tools in the future.
While you're in there, you may as well drop the need for it to be an array as well, which on the js side is simply changing the body to JSON.stringify(authorAndContents), the C# side would need to look like this:
while (listener.IsListening)
{
HttpListenerContext ctx = listener.GetContext();
HttpListenerRequest req = ctx.Request;
HttpListenerResponse resp = ctx.Response;
ChatMessage chatMessage = JsonConvert.DeserializeObject<ChatMessage>(new StreamReader(req.InputStream).ReadToEnd());
string message = chatMessage.text;
string author = chatMessage.author;
if (string.IsNullOrWhiteSpace(message))
{
continue;
}
Debug.Log("recieved: " + chatMessage);
if (message.ToLower().StartsWith("topic:"))
{
string topicMessage = message.Substring("topic:".Length).Trim();
// Check if the topicMessage contains any word from the wordBlacklist
bool containsBlacklistedWord = wordBlacklist.Any(blackWord => topicMessage.ToLower().Contains(blackWord.ToLower()));
bool haveAlreadyDoneTopic = alreadyTakenTopics.Contains(topicMessage);
// Check if the message after "topic:" is not empty or only spaces
if (!string.IsNullOrWhiteSpace(topicMessage) && !haveAlreadyDoneTopic && !containsBlacklistedWord)
{
// Add new message text to message texts
topicSuggestions.Add(topicMessage + "\n" + author);
Debug.Log(topicMessage + "\n" + author);
// Limit the size of messageTexts
if (topicSuggestions.Count > maxListSize)
{
// Remove oldest message text
topicSuggestions.RemoveAt(0);
}
}
}
else if (message.ToLower().StartsWith("vote:"))
{
string voteMessage = message.Substring("vote:".Length).Trim();
// Check if the message after "topic:" is not empty or only spaces
if (!string.IsNullOrWhiteSpace(voteMessage))
{
// Add new message text to message texts
voteSuggestions.Add(voteMessage);
}
}
resp.OutputStream.Write(responseBuffer, 0, responseBuffer.Length);
resp.Close();
}
Da532
codingMASTER398
I've tried to make a stream read the live chat myself once before, and how I did it was with an old, but extremely handy NPM module,
youtube-chat. It's able to reliably read incoming chat messages in the same way that the current system does, but much cleaner and created by a couple smarter folks that weren't on crack.The stream I used it on worked for ~5 months without missing a single chat message using this. It doesn't need any API keys, either. I honestly have no clue how it works but seeing as it stumbled its way onwards through 5 months & reliably picks up every message from high-activity streams I've demoed it on, it would be safe to assume that it's a whole lot better than cobbled together puppeteer code written by Code Bullet at 3AM.
This PR does exactly what it says, and replaces any and all puppeteer bloatware with an easier to understand module that just does everything for us. It's in the same format as the Unity stream expects, too.
Handy dandy demo showing it working on Alan Becker's 24/7 stream