nelns/admin_service/connection_web.cpp

   1 // NeLNS - MMORPG Framework <http://dev.ryzom.com/projects/nel/>
   2 // Copyright (C) 2010  Winch Gate Property Limited
   3 //
   4 // This program is free software: you can redistribute it and/or modify
   5 // it under the terms of the GNU Affero General Public License as
   6 // published by the Free Software Foundation, either version 3 of the
   7 // License, or (at your option) any later version.
   8 //
   9 // This program is distributed in the hope that it will be useful,
  10 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12 // GNU Affero General Public License for more details.
  13 //
  14 // You should have received a copy of the GNU Affero General Public License
  15 // along with this program.  If not, see <http://www.gnu.org/licenses/>.
  16
  17 #include "nel/misc/types_nl.h"
  18
  19 #include <stdio.h>
  20 #include <ctype.h>
  21 #include <math.h>
  22
  23 #include <vector>
  24 #include <map>
  25
  26 #include "nel/misc/debug.h"
  27 #include "nel/misc/config_file.h"
  28 #include "nel/misc/displayer.h"
  29 #include "nel/misc/log.h"
  30
  31 #include "nel/net/buf_server.h"
  32 #include "nel/net/service.h"
  33
  34 #include "admin_service.h"
  35
  36 //
  37 // Namespaces
  38 //
  39
  40 using namespace std;
  41 using namespace NLMISC;
  42 using namespace NLNET;
  43
  44
  45 //
  46 // Variables
  47 //
  48
  49 CBufServer *WebServer = 0;
  50
  51
  52 //
  53 // Callbacks
  54 //
  55
  56 void cbGetRequest (CMemStream &msgin, TSockId host)
  57 {
  58         string rawvarpath;
  59         msgin.serial (rawvarpath);
  60         addRequest (rawvarpath, host);
  61 }
  62
  63 typedef void (*WebCallback)(CMemStream &msgin, TSockId host);
  64
  65 WebCallback WebCallbackArray[] =
  66 {
  67         cbGetRequest,
  68 };
  69
  70 //
  71 // Functions
  72 //
  73
  74 void sendString (TSockId from, const string &str)
  75 {
  76         nlinfo ("REQUEST: Send '%s' to php '%s'", str.c_str (), from->asString ().c_str());
  77
  78         if(from == 0)
  79                 return;
  80
  81         CMemStream msgout;
  82         uint32 fake = 0;
  83         msgout.serial(fake);
  84         msgout.serial (const_cast<string&>(str));
  85         WebServer->send (msgout, from);
  86 }
  87
  88 void connectionWebInit ()
  89 {
  90         nlassert(WebServer == 0);
  91
  92         WebServer = new CBufServer ();
  93         nlassert(WebServer != 0);
  94
  95         uint16 port = (uint16) IService::getInstance ()->ConfigFile.getVar ("WebPort").asInt();
  96         WebServer->init (port);
  97
  98         nlinfo ("Set the server connection for web to port %hu", port);
  99 }
 100
 101 void connectionWebUpdate ()
 102 {
 103         nlassert(WebServer != 0);
 104
 105         try
 106         {
 107                 WebServer->update ();
 108
 109                 while (WebServer->dataAvailable ())
 110                 {
 111                         // create a string mem stream to easily communicate with web server
 112                         NLMISC::CMemStream msgin (true);
 113                         TSockId host;
 114                         sint8 messageType = 0;
 115
 116                         try
 117                         {
 118                                 WebServer->receive (msgin, &host);
 119                                 uint32 fake = 0;
 120                                 msgin.serial(fake);
 121
 122                                 msgin.serial (messageType);
 123                         }
 124                         catch (Exception &e)
 125                         {
 126                                 nlwarning ("Error during receive: '%s'", e.what ());
 127                         }
 128
 129                         if(messageType>=0 && messageType<(sint8)(sizeof(WebCallbackArray)/sizeof(WebCallbackArray[0])))
 130                         {
 131                                 WebCallbackArray[messageType](msgin, host);
 132                         }
 133                         else
 134                         {
 135                                 nlwarning ("Received an unknown message type %d from web server", messageType);
 136                         }
 137                 }
 138         }
 139         catch (Exception &e)
 140         {
 141                 nlwarning ("Error during update: '%s'", e.what ());
 142         }
 143 }
 144
 145 void connectionWebRelease ()
 146 {
 147         nlassert(WebServer != 0);
 148
 149         delete WebServer;
 150         WebServer = 0;
 151 }