src/client/remoteplayer.cpp

   1 #include "remoteplayer.h"
   2 #include "network.h"
   3 #include "../middleman.h"
   4 #include "../logic/chessboard.h"
   5
   6 #include <fstream>
   7 #include <sstream>
   8
   9 RemotePlayer::RemotePlayer()
  10     : mNetwork(Network::createNewNetwork())
  11     , mMiddleman(0)
  12     , mDisabled(true)
  13     , mConnected(false)
  14     , mThread(0)
  15     , mCollectUsers(false)
  16 {
  17 }
  18
  19 RemotePlayer::~RemotePlayer()
  20 {
  21     disconnect();
  22     delete mNetwork;
  23 }
  24
  25 void RemotePlayer::init(Middleman* middleman)
  26 {
  27     mMiddleman = middleman;
  28     //~ mDisabled = !parseConfigFile();
  29     mDisabled = true;
  30 }
  31
  32
  33 bool RemotePlayer::connect()
  34 {
  35     if (mDisabled)
  36     {
  37         log("Re-parsing configs begin");
  38         mDisabled = !parseConfigFile();
  39         log("Re-parsing configs end");
  40     }
  41
  42     log("Connect begin");
  43     if (!mDisabled
  44         && mNetwork->connect(mNInfo.address.c_str(), mNInfo.port.c_str()))
  45     {
  46         log("Connect successful");
  47         mNetwork->startBuffering();
  48
  49         mConnected = true;
  50         mThread = new boost::thread(boost::bind(
  51             &RemotePlayer::handleIncomingMessages, this));
  52
  53         // Send nickname.
  54         log("Nickname send begin");
  55         mNetwork->send(mNInfo.nick);
  56         log("Nickname send end");
  57
  58         return true;
  59     }
  60     log("Connect failed");
  61     mDisabled = true;
  62     return false;
  63 }
  64
  65 void RemotePlayer::disconnect()
  66 {
  67     log("Disconnect begin");
  68     mConnected = false;
  69     if (mThread)
  70     {
  71         mThread->join();
  72         delete mThread;
  73     }
  74     log("Disconnect end");
  75 }
  76
  77 void RemotePlayer::move(int fromX, int fromY, int toX, int toY, unsigned int promoteTo)
  78 {
  79     if (!mDisabled)
  80     {
  81         log("Move begin");
  82         std::ostringstream message;
  83         message << "TPE_3M ";
  84         message << fromX << " " << fromY << " " << toX << " " << toY << " " << promoteTo;
  85         mNetwork->sendln(message.str());
  86         log("Move end");
  87     }
  88 }
  89
  90
  91 void RemotePlayer::sendUndo(unsigned int steps)
  92 {
  93     log("Undo begin");
  94     std::ostringstream message;
  95     message << "TPE_3U ";
  96     message << steps;
  97     mNetwork->sendln(message.str());
  98     log("Undo end[" + message.str() + "]");
  99 }
 100
 101 void RemotePlayer::setControl(bool white, bool black)
 102 {
 103     // This holds no meaning in network play.
 104     // Or at least so it seems.
 105     // In reality, we are going to use this method to define who controls
 106     // what and where.
 107 }
 108
 109 void RemotePlayer::sendChallenge(const std::string& name)
 110 {
 111     log("Challenge send begin[" + name + "]");
 112     mNetwork->send("MSG_B" + name);
 113     log("Challenge send end");
 114 }
 115
 116 void RemotePlayer::respondToChallenge(bool accept)
 117 {
 118     log("Response begin");
 119     if (accept)
 120     {
 121         mNetwork->sendln("MSG_C");
 122         log("Response true");
 123     }
 124     else
 125     {
 126         mNetwork->sendln("MSG_D");
 127         log("Response false");
 128     }
 129 }
 130
 131 void RemotePlayer::handleIncomingMessages()
 132 {
 133     while (mConnected)
 134     {
 135         while (mNetwork->hasLines())
 136         {
 137             std::string line = mNetwork->popLine();
 138
 139             if (line != "MSG_A")
 140             {
 141                 log("Received[" + line + "]");
 142             }
 143
 144             if (line.substr(0, 6) == "TPE_3M")
 145             {
 146                 log("Receive move begin");
 147                 std::stringstream move;
 148                 move << line.substr(7);
 149                 std::size_t fromX, fromY, toX, toY, promoteTo;
 150                 move >> fromX;
 151                 move >> fromY;
 152                 move >> toX;
 153                 move >> toY;
 154                 move >> promoteTo;
 155
 156                 std::ostringstream response;
 157                 response << "TPE_3R ";
 158                 response << mMiddleman->move(fromX, fromY, toX, toY, promoteTo);
 159                 mNetwork->sendln(response.str());
 160                 log("Receive move end");
 161             }
 162             else if (line.substr(0, 6) == "TPE_3U")
 163             {
 164                 log("Receive undo begin");
 165                 std::stringstream undo;
 166                 undo << line.substr(7);
 167                 unsigned int steps;
 168                 undo >> steps;
 169                 mMiddleman->undo(steps);
 170                 log("Receive undo end");
 171             }
 172             else if (line.substr(0, 5) == "MSG_E")
 173             {
 174                 log("Receive challenge begin[" + line.substr(5) + "]");
 175                 mMiddleman->promptChallenge(line.substr(5));
 176                 log("Receive challenge end");
 177             }
 178             else if (line == "MSG_U")
 179             {
 180                 log("Receive userlist begin");
 181                 mCollectUsers = true;
 182                 mUsers.clear();
 183             }
 184             else if (line == "MSG_UEND")
 185             {
 186                 mCollectUsers = false;
 187                 mMiddleman->updateUsers(mUsers);
 188                 log("Receive userlist end");
 189             }
 190             else if (mCollectUsers)
 191             {
 192                 log("Add user[" + line + "]");
 193                 mUsers.push_back(line);
 194             }
 195         }
 196         boost::this_thread::sleep(boost::posix_time::millisec(10));
 197     }
 198 }
 199
 200 void RemotePlayer::log(const std::string& message)
 201 {
 202     std::cout << "@Remote: " << message << std::endl;
 203 }
 204
 205
 206 bool RemotePlayer::parseConfigFile()
 207 {
 208     log("parsing begin");
 209     std::ifstream inputFile("../data/remote.cfg");
 210     if (!inputFile.is_open())
 211     {
 212         log("parsing end, Fail(couldn't open config file)");
 213         return false;
 214     }
 215
 216     std::string line;
 217     while (std::getline(inputFile, line))
 218     {
 219         removeInvalidChars(line);
 220         std::size_t separator;
 221
 222         if (!line.empty()
 223             && (separator = line.find('=')) != std::string::npos)
 224         {
 225             std::string key = line.substr(0, separator);
 226             std::string value = line.substr(separator + 1);
 227
 228             if (!updateNetworkInfo(key, value))
 229             {
 230                 log("parsing end, Fail(wrong key)");
 231                 return false;
 232             }
 233         }
 234     }
 235
 236     log("parsing end, success");
 237     return true;
 238 }
 239
 240
 241 bool RemotePlayer::updateNetworkInfo(const std::string& key,
 242                                      const std::string& value)
 243 {
 244     if (key == "name")
 245     {
 246         mNInfo.nick = value;
 247         return true;
 248     }
 249     if (key == "address")
 250     {
 251         mNInfo.address = value;
 252         return true;
 253     }
 254     if (key == "port")
 255     {
 256         std::stringstream ss(value);
 257         unsigned int num;
 258         if ((ss >> num).fail())
 259         {
 260             return false;
 261         }
 262
 263         mNInfo.port = value;
 264         return true;
 265     }
 266
 267     return false;
 268 }
 269
 270 void RemotePlayer::removeInvalidChars(std::string& line)
 271 {
 272     std::size_t found;
 273     while ((found = line.find_first_not_of("abcdefghijklmnopqrstuvwxyz"
 274         "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789[]=-_#.")) != std::string::npos) {
 275         line.erase(found, 1);
 276     }
 277 }
 278
 279