ryzom/server/src/backup_service/backup_service_mod.cpp

   1 // Ryzom - MMORPG Framework <http://dev.ryzom.com/projects/ryzom/>
   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 #include "nel/net/module.h"
  19 #include "nel/net/module_builder_parts.h"
  20
  21 #include "../server_share/backup_service_itf.h"
  22
  23 #include "backup_service.h"
  24
  25
  26 using namespace std;
  27 using namespace NLMISC;
  28 using namespace NLNET;
  29
  30
  31 namespace BS
  32 {
  33
  34
  35         class CBackupServiceMod:
  36                 public CEmptyModuleServiceBehav<CEmptyModuleCommBehav<CEmptySocketBehav<CModuleBase> > >,
  37                 public CBackupServiceSkel
  38         {
  39         public:
  40
  41                 CBackupServiceMod()
  42                 {
  43                         CBackupServiceSkel::init(this);
  44                 }
  45
  46 //              static const std::string &getInitStringHelp()
  47 //              {
  48 //                      static string help("ring_db(host=<mysql_hostname> user=<user> password=<password> base=<database_name>)");
  49 //                      return help;
  50 //              }
  51 //
  52 //              bool initModule(const TParsedCommandLine &initInfo)
  53 //              {
  54 //                      return CModuleBase::initModule(initInfo);
  55 //
  56 //              }
  57
  58                 void onModuleDown(IModuleProxy *proxy)
  59                 {
  60                         // we must check that this module is not in the listener list
  61                         CBackupService::getInstance()->onModuleDown(proxy);
  62                 }
  63
  64 //              bool onProcessModuleMessage(IModuleProxy *sender, const CMessage &message)
  65 //              {
  66 //                      if (CBackupServiceSkel::onDispatchMessage(sender, message))
  67 //                              return true;
  68 //
  69 //                      nlwarning("CBackupServiceMod: Unknown message '%s' received", message.getName().c_str());
  70 //
  71 //                      return false;
  72 //              }
  73
  74
  75                 /////////////////////////////////////////////////////////////
  76                 //// CBackupServiceSkel interface impl
  77                 /////////////////////////////////////////////////////////////
  78
  79                 // A module ask to save a file in the backup repository
  80                 void saveFile(NLNET::IModuleProxy *sender, const std::string &fileName, const NLNET::TBinBuffer &data)
  81                 {
  82                         CWriteFile*     access = new CWriteFile(fileName, TRequester(sender), 0, data.getBuffer(), data.getBufferSize());
  83
  84                         access->FailureMode = CWriteFile::MajorFailureIfFileUnwritable | CWriteFile::MajorFailureIfFileUnbackupable;
  85                         access->BackupFile = true;
  86                         access->Append = false;
  87
  88                         CBackupService::getInstance()->FileManager.stackFileAccess(access);
  89
  90                 }
  91
  92                 // A module ask to load a file
  93                 void loadFile(NLNET::IModuleProxy *sender, const std::string &fileName, uint32 requestId)
  94                 {
  95                         CLoadFile* access = new CLoadFile(fileName, TRequester(sender), requestId);
  96
  97                         CBackupService::getInstance()->FileManager.stackFileAccess(access);
  98                 }
  99
 100
 101                 /////////////////////////////////////////////////////////////
 102                 //// commands
 103                 /////////////////////////////////////////////////////////////
 104
 105                 NLMISC_COMMAND_HANDLER_TABLE_EXTEND_BEGIN(CBackupServiceMod, CModuleBase)
 106                         NLMISC_COMMAND_HANDLER_ADD(CBackupServiceMod, dump, "dump the module internal state", "no param");
 107 //                      NLMISC_COMMAND_HANDLER_ADD(CMailForumNotifierFwd, simMailNotify, "Simulate a mail notification", "<charId>");
 108                 NLMISC_COMMAND_HANDLER_TABLE_END
 109
 110                 NLMISC_CLASS_COMMAND_DECL(dump)
 111                 {
 112                         // call the base class dump
 113                         NLMISC_CLASS_COMMAND_CALL_BASE(CModuleBase, dump);
 114
 115                         return true;
 116                 }
 117         };
 118
 119         NLNET_REGISTER_MODULE_FACTORY(CBackupServiceMod, "BackupServiceMod");
 120
 121
 122
 123 } // namespace RSMGR
 124
 125 // force module linking
 126 void forceBackupServiceModLink()
 127 {
 128 }