X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fhttp%2Fhttpthread.cpp;h=ceaad4ff136fe078ec9e0e1a723499d2309626e3;hb=dec33c63afafabf83c3039e916725cac6faef9b3;hp=dd4bd9b731a685f2d0696bc1c3ee1144462e4a87;hpb=d8ccfe2b3944adf07d35534459cdda19d15217c8;p=fms.git

diff --git a/src/http/httpthread.cpp b/src/http/httpthread.cpp
index dd4bd9b..ceaad4f 100644
--- a/src/http/httpthread.cpp
+++ b/src/http/httpthread.cpp
@@ -1,7 +1,11 @@
 #include "../../include/http/httpthread.h"
+#include "../../include/http/fmshttprequesthandlerfactory.h"
 #include "../../include/option.h"
 #include "../../include/stringfunctions.h"
-#include "../../include/http/pages/homepage.h"
+
+#include <Poco/Net/ServerSocket.h>
+#include <Poco/Net/HTTPServer.h>
+#include <Poco/Net/HTTPServerParams.h>
 
 #include <iostream>
 
@@ -11,33 +15,34 @@
 
 HTTPThread::HTTPThread()
 {
-
-	int port;
+	m_listenport=8080;
 	std::string portstr;
 	Option::Instance()->Get("HTTPListenPort",portstr);
-	StringFunctions::Convert(portstr,port);
-
-	m_pagehandlers.push_back(new HomePage());
-
-	m_ctx=0;
-	m_ctx=shttpd_init(NULL,"listen_ports",portstr.c_str(),NULL);
-	shttpd_listen(m_ctx,port,false);
-
-	shttpd_register_uri(m_ctx,"*",HTTPThread::PageCallback,this);
-
-}
-
-HTTPThread::~HTTPThread()
-{
-	shttpd_fini(m_ctx);
-
-	for(std::vector<IPageHandler *>::iterator i=m_pagehandlers.begin(); i!=m_pagehandlers.end(); i++)
-	{
-		delete (*i);
-	}
-
+	StringFunctions::Convert(portstr,m_listenport);
+
+	// push back page handlers
+	/*
+	m_pagehandlers.push_back(new ShowCaptchaPage());
+	m_pagehandlers.push_back(new OptionsPage(templatestr));
+	m_pagehandlers.push_back(new LocalIdentitiesPage(templatestr));
+	m_pagehandlers.push_back(new CreateIdentityPage(templatestr));
+	m_pagehandlers.push_back(new AnnounceIdentityPage(templatestr));
+	m_pagehandlers.push_back(new AddPeerPage(templatestr));
+	m_pagehandlers.push_back(new PeerTrustPage(templatestr));
+	m_pagehandlers.push_back(new ControlBoardPage(templatestr));
+	m_pagehandlers.push_back(new PeerDetailsPage(templatestr));
+	m_pagehandlers.push_back(new PeerMaintenancePage(templatestr));
+	m_pagehandlers.push_back(new ExecQueryPage(templatestr));
+	m_pagehandlers.push_back(new BoardsPage(templatestr));
+	m_pagehandlers.push_back(new InsertedFilesPage(templatestr));
+	m_pagehandlers.push_back(new ConfirmPage(templatestr));
+	// homepage must be last - catch all page handler
+	m_pagehandlers.push_back(new HomePage(templatestr));
+	*/
+	
 }
 
+/*
 void HTTPThread::PageCallback(shttpd_arg *arg)
 {
 
@@ -56,16 +61,26 @@ void HTTPThread::PageCallback(shttpd_arg *arg)
 	}
 
 }
-
-void HTTPThread::Run()
+*/
+void HTTPThread::run()
 {
-	m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"HTTPThread::run thread started.");
+	m_log->debug("HTTPThread::run thread started.");
+
+	Poco::Net::ServerSocket sock(m_listenport);
+	Poco::Net::HTTPServerParams* pParams = new Poco::Net::HTTPServerParams;
+	pParams->setMaxQueued(10);
+	pParams->setMaxThreads(5);
+	Poco::Net::HTTPServer srv(new FMSHTTPRequestHandlerFactory,sock,pParams);
+
+	srv.start();
 
 	do
 	{
-		shttpd_poll(m_ctx,1000);
+		Poco::Thread::sleep(1000);
 	}while(!IsCancelled());
 
-	m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"HTTPThread::run thread exiting.");
+	srv.stop();
+
+	m_log->debug("HTTPThread::run thread exiting.");
 
 }