1 files changed, 166 insertions, 0 deletions
diff --git a/server/webserver.cpp b/server/webserver.cpp
new file mode 100644
index 0000000..ce8acda
--- /dev/null
+++ b/server/webserver.cpp
@@ -0,0 +1,166 @@
+/*
+ * webserver.cpp
+ *
+ *  Created on: 06.08.2012
+ *      Author: savop
+ */
+
+#include "../include/webserver.h"
+#include "../upnp.h"
+#include <sstream>
+
+namespace upnp {
+
+cWebserver::cWebserver(std::string address)
+: mListenerAddress(address)
+, mListenerPort(7649)
+, mWebserverThread(*this)
+{
+  SetWebserverRootDir(string(), string(), string());
+  SetServiceUrl("services/", string());
+}
+
+cWebserver::~cWebserver(){
+
+}
+
+bool cWebserver::Start(){
+  return mWebserverThread.Start();
+}
+
+void cWebserver::Stop(){
+  try {
+    mApplication.shutdown();
+  } catch (const std::exception& e){
+    esyslog("UPnP\tError while stopping web server: %s", e.what());
+  }
+}
+
+bool cWebserver::Initialise(){
+
+  try {
+    // Map static contents
+    stringstream ss1, ss2;
+
+    mApplication.listen(mListenerAddress.c_str(), mListenerPort);
+
+    mApplication.mapUrl("^/$", "index");
+
+    mApplication.mapUrl("^/index.html", "index");
+
+    ss1.clear(); ss1.str(string());
+    ss1 << "^/" << mServiceUrl << "([^/.]+).xml$";
+
+    mApplication.mapUrl(ss1.str(), "$1");
+
+    // Map static contents
+    ss1.clear(); ss1.str(string());
+    ss1 << "^/" << mStaticContentUrl << "(.*)";
+
+    ss2.clear(); ss2.str(string());
+    ss2 << mWebserverRootDir << "$1";
+
+    mApplication.mapUrl(ss1.str(), ss2.str(), "static@tntnet");
+
+    // Map static contents
+    ss1.clear(); ss1.str(string());
+    ss1 << "^/" << mServiceUrl << "([^/.]+)";
+
+    ss2.clear(); ss2.str(string());
+    ss2 << mServiceUrl << "$1";
+
+    mApplication.mapUrl(ss1.str(), ss2.str(), "serviceRedirect");
+
+    isyslog("UPnP\tUsing %s for static content delivery.", mWebserverRootDir.c_str());
+
+  } catch (const std::exception& e){
+    esyslog("UPnP\tError while initialising web server: %s", e.what());
+    return false;
+  }
+
+  return true;
+}
+
+void cWebserver::SetListenerPort(uint16_t port){
+  if(mWebserverThread.Active()) return;
+
+  mListenerPort = port ? port : 7649;
+}
+
+void cWebserver::SetWebserverRootDir(std::string rootDirectory, std::string staticContentUrl, std::string presentationUrl){
+  if(mWebserverThread.Active()) return;
+
+  if(rootDirectory.empty())
+    mWebserverRootDir = std::string(cPluginUpnp::ConfigDirectory(PLUGIN_NAME_I18N)) + "/httpdocs/";
+  else
+    mWebserverRootDir = rootDirectory;
+
+  if(staticContentUrl.empty())
+    mStaticContentUrl = "http/";
+  else
+    mStaticContentUrl = staticContentUrl;
+
+  if(presentationUrl.empty())
+    mPresentationUrl = "index.html";
+  else
+    mPresentationUrl = presentationUrl;
+}
+
+void cWebserver::SetServiceUrl(std::string descriptionUrl, std::string controlUrl){
+  if(mWebserverThread.Active()) return;
+
+  if(descriptionUrl.empty())
+    mServiceUrl = "services/";
+  else
+    mServiceUrl = descriptionUrl;
+
+  if(controlUrl.empty()){
+    stringstream s;
+    s << "http://" << UpnpGetServerIpAddress() << ":" << UpnpGetServerPort() << "/" << mServiceUrl;
+
+    mControlUrl = s.str();
+  } else {
+    mControlUrl = controlUrl;
+  }
+}
+
+const std::string cWebserver::GetBaseUrl() const {
+  stringstream s;
+  s << "http://" << mListenerAddress << ":" << mListenerPort << "/";
+
+  return s.str();
+}
+
+const std::string cWebserver::GetServiceUrl() const {
+  return mServiceUrl;
+}
+
+const std::string cWebserver::GetControlUrl() const {
+  return mControlUrl;
+}
+
+const std::string cWebserver::GetPresentationUrl() const {
+  return mPresentationUrl;
+}
+
+const std::string cWebserver::GetStaticContentUrl() const {
+  return mStaticContentUrl;
+}
+
+cWebserver::cWSThread::cWSThread(cWebserver& webServer)
+: mWebserver(webServer)
+{
+
+}
+
+void cWebserver::cWSThread::Action(){
+  try {
+    mWebserver.mApplication.run();
+  } catch (const std::exception& e){
+    esyslog("UPnP\tError while starting web server: %s", e.what());
+  }
+}
+
+}  // namespace upnp
+
+