From 3a2fb425383b2e6563d1ba38845fd1ffe8514eb8 Mon Sep 17 00:00:00 2001
From: Juhani Haverinen <juhani.haverinen@gmail.com>
Date: Tue, 5 Sep 2017 13:11:08 +0300
Subject: [PATCH] Have thread be spawned for non-trivial messages

---
 line_handling.py | 46 ++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 40 insertions(+), 6 deletions(-)

diff --git a/line_handling.py b/line_handling.py
index d650360..63b98e1 100644
--- a/line_handling.py
+++ b/line_handling.py
@@ -1,5 +1,9 @@
+import threading
+
 import constants
 
+import botcmd
+
 class API:
 	def __init__(self, serverthread_object):
 		# We need to access the internal functions of the ServerThread object in order to send lines etc.
@@ -115,10 +119,40 @@ def parse_line(line):
 
 	return prefix, command, arguments
 
-def handle_line(line, *, irc):
-	try:
-		prefix, command, arguments = parse_line(line)
-	except LineParsingError:
-		irc.error("Cannot parse line" + line.decode(encoding = 'utf-8', errors = 'replace'))
+class LineHandlerThread(threading.Thread):
+	def __init__(self, line, *, irc):
+		self.line = line
+		self.irc = irc
 
-	# TODO: handle line
+		threading.Thread.__init__(self)
+
+	def run(self):
+		try:
+			prefix, command, arguments = parse_line(self.line)
+		except LineParsingError:
+			irc.error("Cannot parse line" + self.line.decode(encoding = 'utf-8', errors = 'replace'))
+
+		if command.upper() == b'PRIVMSG':
+			# PRIVMSG should have two parameters: recipient and the message
+			assert len(arguments) == 2
+			recipients, message = arguments
+
+			# Prefix contains the nick of the sender, delimited from user and host by '!'
+			nick = prefix.split(b'!')[0]
+
+			# Recipients are in a comma-separate list
+			for recipient in recipients.split(b','):
+				# 'channel' is bit of a misnomer. This is where we'll send the response to
+				# Usually it's the channel, but in queries it's not
+				channel = recipient if recipient[0] == ord('#') else nick
+
+				# Delegate rest to botcmd.handle_message
+				botcmd.handle_message(prefix = prefix, message = message, nick = nick, channel = channel, irc = self.irc)
+
+		else:
+			# Delegate to botcmd.handle_nonmessage
+			botcmd.handle_nonmessage(prefix = prefix, command = command, arguments = arguments, irc = self.irc)
+
+def handle_line(line, *, irc):
+	# Spawn a thread to handle the line
+	LineHandlerThread(line, irc = irc).start()