1 files changed, 80 insertions, 0 deletions
diff --git a/IPC.cpp b/IPC.cpp
new file mode 100644
index 0000000..215a15c
--- /dev/null
+++ b/IPC.cpp
@@ -0,0 +1,80 @@
+#include "IPC.h"
+
+#include <cstring>
+#include <sys/socket.h>
+#include <iostream>
+#include <unistd.h>
+
+using std::cout, std::endl;
+
+static const char* path = "/tmp/YATwm.sock";
+
+IPCModule::IPCModule(CommandsModule& commandsModule, Config& cfg, Globals& globals)
+	:commandsModule(commandsModule),
+	 cfg(cfg),
+	 globals(globals)
+{
+	sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
+	address.sun_family = AF_UNIX;
+	strcpy(address.sun_path, path);
+	unlink(address.sun_path);
+	len = strlen(address.sun_path) + sizeof(address.sun_family);
+
+	if(bind(sockfd, (sockaddr*)&address, len) == -1)
+	{
+		cout << "ERROR" << endl;
+	}
+	cout << "SOCKETED" << endl;
+}
+
+void IPCModule::doListen()
+{
+	if(listen(sockfd, 1) != 0)
+	{
+		cout << "ERROR 2" << endl;
+		return;
+	}
+	if(first)
+	{
+		first = false;
+		return;
+	}
+	cout << "DOLISTEN" << endl;
+	unsigned int socklen = 0;
+	sockaddr_un remote;
+	int newsock = accept(sockfd, (sockaddr*)&remote, &socklen);
+	cout << "LISTENING" << endl;
+	char buffer[256];
+	memset(buffer, 0, 256);
+	read(newsock, buffer, 256);
+	std::string command(buffer);
+	while(command[command.size() - 1] == 0 || command[command.size() - 1] == '\n')
+		command = command.substr(0, command.size() - 1);
+	//cout << '"' << command << '"' << endl;
+	try
+	{
+		commandsModule.runCommand(command);
+	}
+	catch(Err e)
+	{
+		cout << e.code << " " << e.message << endl;
+	}
+	char* message = "RAN COMMAND";
+	send(newsock, message, strlen(message), 0);
+	cout << "RAN COMMAND" << endl;
+	shutdown(newsock, SHUT_RDWR);
+	close(newsock);
+}
+
+void IPCModule::quitIPC()
+{
+	close(sockfd);
+	cout << path << endl;
+}
+
+int IPCModule::getFD()
+{
+	if(sockfd > 0)
+		return sockfd;
+	return -1;
+}