From 5a81b0e272a6e456e8c29ce2e755ac4e1c8b5546 Mon Sep 17 00:00:00 2001
From: Gluzskiy Alexandr <sss@sss.chaoslab.ru>
Date: Mon, 11 Feb 2013 02:12:12 +0200
Subject: started separated proto lib implementation started modules support
 implementation

---
 server/main.cpp | 239 +++-----------------------------------------------------
 1 file changed, 10 insertions(+), 229 deletions(-)

(limited to 'server/main.cpp')

diff --git a/server/main.cpp b/server/main.cpp
index c92244f..eae3b1e 100644
--- a/server/main.cpp
+++ b/server/main.cpp
@@ -1,4 +1,4 @@
-// Copyright © 2010-2012 sss
+// Copyright © 2010-2013 sss
 // 
 // This program is free software; you can redistribute it and/or
 // modify it under the terms of the GNU General Public License
@@ -16,232 +16,10 @@
 
 //based on async_tcp_echo_server.cpp code by Christopher M. Kohlhoff (chris at kohlhoff dot com)
 
-#include <cstdlib>
+#include "headers.h"
 
-#include <signal.h>
-#include <unistd.h>
-#include <stdio.h>
 
-#include <iostream>
-#include <fstream>
-#include <boost/bind.hpp>
-#include <boost/asio.hpp>
-#include <boost/asio/ssl.hpp>
 
-using boost::asio::ip::tcp;
-typedef boost::asio::ssl::stream<boost::asio::ip::tcp::socket> ssl_socket;
-
-class session
-{
-public:
-  session(boost::asio::io_service& io_service,
-      boost::asio::ssl::context& context)
-    : socket_(io_service, context)  {
-  }
-
-  ssl_socket::lowest_layer_type& socket()
-  {
-    return socket_.lowest_layer();
-  }
-  
-  void handle_handshake(const boost::system::error_code& error)
-  {
-    if (!error)
-    {
-      socket_.async_read_some(boost::asio::buffer(data_, max_length),
-          boost::bind(&session::handle_read, this,
-            boost::asio::placeholders::error,
-            boost::asio::placeholders::bytes_transferred));
-    }
-    else
-    {
-      delete this;
-    }
-  }
-  
-  void start()
-  {
-    socket_.async_handshake(boost::asio::ssl::stream_base::server,
-        boost::bind(&session::handle_handshake, this,
-          boost::asio::placeholders::error));
-  }
-
-private:
-  void handle_read(const boost::system::error_code& error,
-      size_t bytes_transferred)
-  {
-    if (!error)
-    {
-//		std::cout<<"recieved: "<<data_<<"\n";
-		if(strstr(data_, "restart vbox"))
-		{
-			FILE *f = popen("/sbin/runscript /etc/init.d/vbox_headles restart --nodeps","r");
-			if(f != NULL)
-			{
-				char buf[128];
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				int s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-		}
-		else if(strstr(data_, "reboot now"))
-		{
-			FILE *f = popen("reboot","r");
-			if(f != NULL)
-			{
-				char buf[128];
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				int s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-		}
-		else if(strstr(data_, "halt now"))
-		{
-			FILE *f = popen("halt","r");
-			if(f != NULL)
-			{
-				char buf[128];
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				int s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-		}
-		else if(strstr(data_, "restart cups"))
-		{
-			FILE *f = popen("/sbin/runscript /etc/init.d/cupsd restart --nodeps","r");
-			if(f != NULL)
-			{
-				char buf[128];
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				int s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-		}
-		else if(strstr(data_, "restart ppp"))
-		{
-			FILE *f = popen("/sbin/runscript /etc/init.d/net.ppp0 stop --nodeps","r");
-			char buf[128];
-			int s = 0;
-			if(f != NULL)
-			{
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-			sleep(3);
-			f = popen("killall pppd","r");
-			if(f == NULL)
-			{
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-			sleep(1);
-			f = popen("/sbin/runscript /etc/init.d/net.ppp0 start --nodeps","r");
-			if(f == NULL)
-			{
-				while(fgets(buf, 128, f) != NULL)
-					; //TODO: do something with output
-				s = pclose(f); // TODO: handle exit status
-			}
-			else
-				; //TODO: handle fail
-		}
-/*      boost::asio::async_write(socket_,
-          boost::asio::buffer(data_, bytes_transferred),
-          boost::bind(&session::handle_write, this,
-            boost::asio::placeholders::error)); */
-    }
-    delete this;
-  }
-
-/*  void handle_write(const boost::system::error_code& error)
-  {
-    if (!error)
-    {
-      socket_.async_read_some(boost::asio::buffer(data_, max_length),
-          boost::bind(&session::handle_read, this,
-            boost::asio::placeholders::error,
-            boost::asio::placeholders::bytes_transferred));
-    }
-    else
-    {
-      delete this;
-    }
-  }*/
-
-  ssl_socket socket_;
-  enum { max_length = 32 };
-  char data_[max_length];
-};
-
-class server
-{
-public:
-/*  server(boost::asio::io_service& io_service, short port)
-    : io_service_(io_service),
-      acceptor_(io_service, tcp::endpoint(boost::asio::ip::address_v4::from_string("192.168.0.1"), port)),
-	  context_(boost::asio::ssl::context::sslv23) */
-  server(boost::asio::io_service& io_service, short port)
-    : io_service_(io_service),
-      acceptor_(io_service, tcp::endpoint(boost::asio::ip::address_v4(), port)),
-	  context_(boost::asio::ssl::context::sslv23)
-  {
-   context_.set_options(
-        boost::asio::ssl::context::default_workarounds
-        | boost::asio::ssl::context::no_sslv2);
-    context_.set_password_callback(boost::bind(&server::get_password, this));
-    context_.use_certificate_chain_file("/etc/restarter_server/serv.crt");
-    context_.use_rsa_private_key_file("/etc/restarter_server/serv.key", boost::asio::ssl::context::pem);
-	context_.load_verify_file("/etc/restarter_server/ca.crt");
-	context_.set_verify_mode(boost::asio::ssl::verify_peer | boost::asio::ssl::verify_client_once);
-    start_accept();
-  }
-
-private:
-  void start_accept()
-  {
-    session* new_session = new session(io_service_, context_);
-    acceptor_.async_accept(new_session->socket(),
-        boost::bind(&server::handle_accept, this, new_session,
-          boost::asio::placeholders::error)); 
-  }
-  std::string get_password() const
-  {
-    return "";
-  }
-
-  void handle_accept(session* new_session,
-      const boost::system::error_code& error)
-  {
-    if (!error)
-    {
-      new_session->start();
-    }
-    else
-    {
-      delete new_session;
-    }
-
-    start_accept();
-  }
-
-  boost::asio::io_service& io_service_;
-  boost::asio::ip::tcp::acceptor acceptor_;
-  boost::asio::ssl::context context_;
-};
 
 extern "C" void handle_term(int i)
 {
@@ -249,13 +27,14 @@ extern "C" void handle_term(int i)
     exit(1);
 }
 
+
 int main(int argc, char* argv[])
 {
-	if(geteuid())
+/*	if(geteuid()) //temporary disabled for debug
 	{
 	    std::cout<<"Program must be runned with root privilegies\n";
 	    exit(EXIT_FAILURE);
-	}
+	} */
 	{
 		std::ifstream in_pid;
 		in_pid.open("/var/run/restarter_server.pid");
@@ -275,7 +54,7 @@ int main(int argc, char* argv[])
 			}
 		}
 	}
-	pid_t pid;
+/*	pid_t pid; //temporary disabled for debug
 	pid = fork();
 	if(pid < 0)
 	{
@@ -292,9 +71,11 @@ int main(int argc, char* argv[])
 		out<<pid<<"\n";
 		out.close();
 		exit(EXIT_SUCCESS);
-	}
+	} */
 	signal (SIGTERM, handle_term);
 	
+	load_modules();
+	
   try
   {
 
@@ -310,4 +91,4 @@ int main(int argc, char* argv[])
   }
 
   return 0;
-}
\ No newline at end of file
+}
-- 
cgit v1.2.3