projects/stargazer/plugins/configuration/sgconfig/configproto.cpp

   1 /*
   2  *    This program is free software; you can redistribute it and/or modify
   3  *    it under the terms of the GNU General Public License as published by
   4  *    the Free Software Foundation; either version 2 of the License, or
   5  *    (at your option) any later version.
   6  *
   7  *    This program is distributed in the hope that it will be useful,
   8  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
   9  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  10  *    GNU General Public License for more details.
  11  *
  12  *    You should have received a copy of the GNU General Public License
  13  *    along with this program; if not, write to the Free Software
  14  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  15  */
  16
  17 /*
  18  *    Date: 27.10.2002
  19  */
  20
  21 /*
  22  *    Author : Boris Mikhailenko <stg34@stargazer.dp.ua>
  23  */
  24
  25  /*
  26  $Revision: 1.22 $
  27  $Date: 2010/10/04 20:24:14 $
  28  $Author: faust $
  29  */
  30
  31 #include "configproto.h"
  32
  33 #include "parser.h"
  34 #include "parser_auth_by.h"
  35 #include "parser_user_info.h"
  36
  37 #include "stg/users.h"
  38 #include "stg/admins.h"
  39 #include "stg/tariffs.h"
  40 #include "stg/logger.h"
  41
  42 #include <unistd.h>
  43
  44 //-----------------------------------------------------------------------------
  45 void ParseXMLStart(void *data, const char *el, const char **attr)
  46 {
  47 CONFIGPROTO * cp = static_cast<CONFIGPROTO *>(data);
  48
  49 if (cp->currParser)
  50     {
  51     cp->currParser->SetAnswerList(&cp->answerList);
  52     cp->currParser->SetCurrAdmin(*cp->currAdmin);
  53     cp->currParser->ParseStart(data, el, attr);
  54     }
  55 else
  56     {
  57     for (size_t i = 0; i < cp->dataParser.size(); i++)
  58         {
  59         cp->dataParser[i]->SetAnswerList(&cp->answerList);
  60         cp->dataParser[i]->SetCurrAdmin(*cp->currAdmin);
  61         cp->dataParser[i]->Reset();
  62         if (cp->dataParser[i]->ParseStart(data, el, attr) == 0)
  63             {
  64             cp->currParser = cp->dataParser[i];
  65             break;
  66             }
  67         else
  68             {
  69             cp->dataParser[i]->Reset();
  70             }
  71         }
  72     }
  73 }
  74 //-----------------------------------------------------------------------------
  75 void ParseXMLEnd(void *data, const char *el)
  76 {
  77 CONFIGPROTO * cp = static_cast<CONFIGPROTO *>(data);
  78 if (cp->currParser)
  79     {
  80     if (cp->currParser->ParseEnd(data, el) == 0)
  81         {
  82         cp->currParser = NULL;
  83         }
  84     }
  85 else
  86     {
  87     for (size_t i = 0; i < cp->dataParser.size(); i++)
  88         {
  89         if (cp->dataParser[i]->ParseEnd(data, el) == 0)
  90             {
  91             break;
  92             }
  93         }
  94     }
  95 }
  96 //-----------------------------------------------------------------------------
  97 CONFIGPROTO::CONFIGPROTO(PLUGIN_LOGGER & l)
  98     : adminIP(0),
  99       port(0),
 100       nonstop(true),
 101       state(0),
 102       currAdmin(NULL),
 103       logger(l),
 104       listenSocket(-1),
 105       admins(NULL),
 106       currParser(NULL)
 107 {
 108 dataParser.push_back(new PARSER_GET_SERVER_INFO);
 109
 110 dataParser.push_back(new PARSER_GET_USERS);
 111 dataParser.push_back(new PARSER_GET_USER);
 112 dataParser.push_back(new PARSER_CHG_USER);
 113 dataParser.push_back(new PARSER_ADD_USER);
 114 dataParser.push_back(new PARSER_DEL_USER);
 115 dataParser.push_back(new PARSER_CHECK_USER);
 116 dataParser.push_back(new PARSER_SEND_MESSAGE);
 117 dataParser.push_back(new PARSER_AUTH_BY);
 118 dataParser.push_back(new PARSER_USER_INFO);
 119
 120 dataParser.push_back(new PARSER_GET_TARIFFS);
 121 dataParser.push_back(new PARSER_ADD_TARIFF);
 122 dataParser.push_back(new PARSER_DEL_TARIFF);
 123 dataParser.push_back(new PARSER_CHG_TARIFF);
 124
 125 dataParser.push_back(new PARSER_GET_ADMINS);
 126 dataParser.push_back(new PARSER_CHG_ADMIN);
 127 dataParser.push_back(new PARSER_DEL_ADMIN);
 128 dataParser.push_back(new PARSER_ADD_ADMIN);
 129
 130 xmlParser = XML_ParserCreate(NULL);
 131
 132 if (!xmlParser)
 133     {
 134     logger("Couldn't allocate memory for parser.");
 135     exit(1);
 136     }
 137
 138 }
 139 //-----------------------------------------------------------------------------
 140 CONFIGPROTO::~CONFIGPROTO()
 141 {
 142 for (size_t i = 0; i < dataParser.size(); ++i)
 143     delete dataParser[i];
 144 XML_ParserFree(xmlParser);
 145 }
 146 //-----------------------------------------------------------------------------
 147 int CONFIGPROTO::ParseCommand()
 148 {
 149 std::list<std::string>::iterator n;
 150 int done = 0;
 151 char str[9];
 152
 153 if (requestList.empty())
 154     return 0;
 155
 156 n = requestList.begin();
 157
 158 strncpy(str, (*n).c_str(), 8);
 159 str[8] = 0;
 160
 161 XML_ParserReset(xmlParser, NULL);
 162 XML_SetElementHandler(xmlParser, ParseXMLStart, ParseXMLEnd);
 163 XML_SetUserData(xmlParser, this);
 164
 165 while(nonstop)
 166     {
 167     strncpy(str, (*n).c_str(), 8);
 168     str[8] = 0;
 169     size_t len = strlen(str);
 170
 171     ++n;
 172     if (n == requestList.end())
 173         done = 1;
 174     --n;
 175
 176     if (XML_Parse(xmlParser, (*n).c_str(), static_cast<int>(len), done) == XML_STATUS_ERROR)
 177         {
 178         logger("Invalid configuration request");
 179         printfd(__FILE__, "Parse error at line %d:\n%s\n",
 180            XML_GetCurrentLineNumber(xmlParser),
 181            XML_ErrorString(XML_GetErrorCode(xmlParser)));
 182         if (currParser)
 183             {
 184             printfd(__FILE__, "Parser reset\n");
 185             currParser->Reset();
 186             currParser = NULL;
 187             }
 188
 189         return -1;
 190         }
 191
 192     if (done)
 193         return 0;
 194
 195     ++n;
 196     }
 197
 198 return 0;
 199 }
 200 //-----------------------------------------------------------------------------
 201 void CONFIGPROTO::SetAdmins(ADMINS * a)
 202 {
 203 admins = a;
 204 for (size_t i = 0; i < dataParser.size(); i++)
 205     dataParser[i]->SetAdmins(a);
 206 }
 207 //-----------------------------------------------------------------------------
 208 void CONFIGPROTO::SetUsers(USERS * u)
 209 {
 210 for (size_t i = 0; i < dataParser.size(); i++)
 211     dataParser[i]->SetUsers(u);
 212 }
 213 //-----------------------------------------------------------------------------
 214 void CONFIGPROTO::SetTariffs(TARIFFS * t)
 215 {
 216 for (size_t i = 0; i < dataParser.size(); i++)
 217     dataParser[i]->SetTariffs(t);
 218 }
 219 //-----------------------------------------------------------------------------
 220 void CONFIGPROTO::SetStore(STORE * s)
 221 {
 222 for (size_t i = 0; i < dataParser.size(); i++)
 223     dataParser[i]->SetStore(s);
 224 }
 225 //-----------------------------------------------------------------------------
 226 void CONFIGPROTO::SetStgSettings(const SETTINGS * s)
 227 {
 228 for (size_t i = 0; i < dataParser.size(); i++)
 229     dataParser[i]->SetStgSettings(s);
 230 }
 231 //-----------------------------------------------------------------------------