Fixed Ctrl+D by adding RecvParser to every client, including the Mess…

inc/Client.hpp

@@ -1,4 +1,5 @@
 #pragma once
+#include <queue>
 #include <functional>
 #include <cstdint>
 #include <stdexcept>
@@ -7,6 +8,8 @@
 #include <memory>
 #include "CommandDispatcher.hpp"
 #include "User.hpp"
+#include "RecvParser.hpp"
+
 class User;
 class CommandDispatcher;
 /*
@@ -28,7 +31,8 @@ class Client {
 		bool _authenticated = false;
 		bool _registered = false;
 		CommandDispatcher* _test;
-
+		std::queue<std::unique_ptr<Message>> _msg_queue;
+		RecvParser	_parser;
 	public:
 		explicit Client(int fd);
 		~Client();
@@ -41,6 +45,7 @@ class Client {
 		std::function<void(int)>& getHandler(uint32_t eventType);
 		User* getUser(void);
 		CommandDispatcher* getDispatch(void);
+		RecvParser& getParser(void);
 		void authenticate(void);
 		bool isAuthenticated(void) const;
 		bool& accessRegistered(void);

inc/RecvParser.hpp

@@ -7,7 +7,7 @@
 #include <memory>
 #include "Message.hpp"
 
-/**	
+/**
  * @class	RecvParser
  * @brief	A class for parsing data read by recv() into a message queue
  */
@@ -16,6 +16,7 @@ class	RecvParser
 	public:
 		RecvParser(std::queue<std::unique_ptr<Message>> &msg_queue);
 
+		std::queue<std::unique_ptr<Message>> &getQueue(void);
 		void	feed(const char *read_buf, size_t len);
 
 	private:

src/Client.cpp

@@ -1,14 +1,15 @@
 #include "Client.hpp"
 
 
-Client::Client(int fd) : _self(new User()),  _test(new CommandDispatcher()), _fd(fd) {}
+Client::Client(int fd) : _self(new User()),  _test(new CommandDispatcher()), _parser(RecvParser(_msg_queue)), _fd(fd) {}
 
 Client::Client(const Client& other) :
 _IN(other._IN),
 _RDHUP(other._RDHUP),
 _HUP(other._HUP),
 _self(new User(*other._self)),
 _test(other._test),
+_parser(other._parser),
 _fd(other._fd),
 _initialized(other._initialized){}
 
@@ -33,6 +34,10 @@ CommandDispatcher* Client::getDispatch(void) {
 	return _test;
 }
 
+RecvParser& Client::getParser(void) {
+	return _parser;
+}
+
 void Client::setHandler(uint32_t eventType, std::function<void(int)> handler) {
 	switch (eventType) {
 		case EPOLLIN:

src/CommandDispatcher.cpp

@@ -34,8 +34,8 @@ bool	CommandDispatcher::dispatch(const std::unique_ptr<Message> &msg, int fd)
 	{
 		if (auto cmd = _handlers.find(msg->command); cmd != _handlers.end())
 		{
-			if (!irc->checkPassword() &&
-				!irc->getClient(fd).isAuthenticated() &&
+			if (not irc->checkPassword() &&
+				not irc->getClient(fd).isAuthenticated() &&
 				msg->command != "PASS" &&
 				msg->command != "CAP")
 			{
@@ -46,6 +46,8 @@ bool	CommandDispatcher::dispatch(const std::unique_ptr<Message> &msg, int fd)
 				irc->removeClient(fd);
 				return false;
 			}
+			if (msg->command == "QUIT")
+				return cmd->second->execute(*msg, fd), false;
 			cmd->second->execute(*msg, fd);
 			if (msg->command != "QUIT" &&
 				not irc->getClient(fd).getUser()->getNick().empty() &&

src/Handler.cpp

@@ -5,8 +5,9 @@ using namespace std;
 void Handler::clientWrite(int fd) {
 	ssize_t messageLen = 0;
 	vector<char> buf(BUFSIZ);
-	queue<unique_ptr<Message>> msg_queue;
-	RecvParser	parser(msg_queue);
+	Client& client = irc->getClient(fd);
+	RecvParser& parser = client.getParser();
+	std::queue<std::unique_ptr<Message>> &msg_queue = parser.getQueue();
 
 	messageLen = recv(fd, &buf[0], buf.size(), 0);
 	if (messageLen == -1)

src/RecvParser.cpp

@@ -3,6 +3,11 @@
 RecvParser::RecvParser(std::queue<std::unique_ptr<Message>> &msg_queue)
 	: _output(msg_queue){}
 
+std::queue<std::unique_ptr<Message>> &RecvParser::getQueue(void)
+{
+	return _output;
+}
+
 /**
  *	Feed the recv() buffer into std::string buffer
  *	@param	read_buf	The buffer to read