1 files changed, 104 insertions, 23 deletions

diff --git a/pacman-c++/server.cpp b/pacman-c++/server.cpp
index 07e4c72..1c3caf9 100644
--- a/pacman-c++/server.cpp
+++ b/pacman-c++/server.cpp
@@ -11,7 +11,7 @@
 
 Server::Server(QWidget *parent)
   : SceneHolder(parent), m_bindaddress(QHostAddress::Any),
-  m_port(Constants::Networking::port), m_numbots(0)
+  m_port(Constants::Networking::port), m_rounds(3), m_numbots(0), m_curRound(0)
 {
   /* determine max players by using order array */
   for(m_maxplayers = 0; Color::order[m_maxplayers] != Color::none; ++m_maxplayers);
@@ -26,34 +26,25 @@ bool Server::run()
 
   qDebug() << "[Server] Running server...";
   qDebug() << "[Server] Max players:" << m_maxplayers;
+  qDebug() << "[Server] Number of rounds:" << m_rounds;
   qDebug() << "[Server] Number of bots:" << m_numbots;
   if (!waitForClientConnections())
     return false;
 
-  qDebug() << "[Server] Creating map...";
-  Transmission::map_t map =  Util::createDemoMap();
-  Util::placeActors(map, m_maxplayers, Color::order);
-  Util::fillPoints(map);
+  initRoundMap(true);
 
-  /* save positions of blocks for later usage */
-  for (unsigned int x = 0; x < Constants::map_size.width; ++x)
-  {
-    for (unsigned int y = 0; y < Constants::map_size.height; ++y)
-    {
-      Transmission::field_t &cur = map[x][y];
-      if (cur & Transmission::block)
-        m_blocks.append(QPoint(x, y));
-    }
-  }
+  m_tickTimer = new QTimer(this);
+  connect(m_tickTimer, SIGNAL(timeout()), this, SLOT(tick()));
+  m_tickTimer->start(Constants::tick);
 
-  updateMap(map);
-  sendUpdate(map, true);
-  Util::deleteMap(map);
-  map = NULL;
+  /* finish round every 3 sec
+  QTimer *timer2 = new QTimer(this);
+  connect(timer2, SIGNAL(timeout()), this, SLOT(onRoundFinished()));
+  timer2->start(3000);
+  // */
+
+  connect(this, SIGNAL(allPointsRemoved()), SLOT(onRoundFinished()));
 
-  QTimer *timer = new QTimer(this);
-  connect(timer, SIGNAL(timeout()), this, SLOT(tick()));
-  timer->start(Constants::tick);
   return true;
 }
 
@@ -108,7 +99,6 @@ invalid_direction:
 
     // <t3h g4m3 10gic>
     // TODO: support actors eating each other
-    // TODO: old item - REMOVE THAT?
     GameEntity *oldItem = visualMap[mapPosition.x()][mapPosition.y()];
 
     /* check if there's an item at new location of actor */
@@ -500,6 +490,81 @@ void Server::keyPressUpdate()
   }
 }
 
+void Server::onRoundFinished()
+{
+  foreach(Actor *actor, m_actors) {
+    actor->finishRound();
+  }
+
+  initRoundMap();
+  ++m_curRound;
+
+  if(m_curRound >= m_rounds) {
+    // end of game
+    m_tickTimer->stop();
+  }
+}
+
+void Server::initRoundMap(bool firstPacket)
+{
+  disconnect(this, SIGNAL(allPointsRemoved()), this, SLOT(onRoundFinished()));
+  if (!firstPacket) {
+    // clear old map
+    for (unsigned int i=0; i<visualMap.size(); ++i) {
+      for (unsigned int j=0; j<visualMap[0].size(); ++j) {
+        GameEntity *e = visualMap[i][j];
+        if (e != NULL) {
+          if (qgraphicsitem_cast<Actor *>(e) == NULL) {
+            removeItem(e);
+            delete e;
+          }
+        }
+        visualMap[i][j] = 0;
+      }
+    }
+  }
+
+  // create new map
+  Transmission::map_t map =  Util::createDemoMap();
+  // add content
+  Util::placeActors(map, m_maxplayers, Color::order);
+  /*
+  if (!firstPacket) {
+    for (unsigned int i=0; i<Constants::map_size.width; ++i) {
+      for (unsigned int j=0; j<Constants::map_size.height; ++j) {
+        if (map[i][j] & Transmission::pacman) {
+          Color::Color color = static_cast<Color::Color>(map[i][j] & Transmission::color_mask);
+          Actor *actor = m_actors.value(color, NULL);
+          qDebug() << "setting actor to " << i << j << mapPositionToCoord(i, j);
+          actor->setPos(mapPositionToCoord(i, j));
+        }
+      }
+    }
+  }
+  */
+
+  Util::fillPoints(map);
+
+  /* save positions of blocks for later usage */
+  m_blocks.clear();
+  for (unsigned int x = 0; x < Constants::map_size.width; ++x)
+  {
+    for (unsigned int y = 0; y < Constants::map_size.height; ++y)
+    {
+      Transmission::field_t &cur = map[x][y];
+      if (cur & Transmission::block)
+        m_blocks.append(QPoint(x, y));
+    }
+  }
+
+  updateMap(map);
+  sendUpdate(map, firstPacket);
+  Util::deleteMap(map);
+  map = NULL;
+
+  connect(this, SIGNAL(allPointsRemoved()), this, SLOT(onRoundFinished()));
+}
+
 bool Server::parseCommandline()
 {
   AnyOption opt;
@@ -535,6 +600,10 @@ bool Server::parseCommandline()
   out << "  --nocolorblocks" << endl
       << "  Disable random colorized blocks" << endl
       << endl;
+  opt.setOption("rounds", 'r');
+  out << "  -r, --rounds [1..n]" << endl
+      << "  Number of rounds to play" << endl
+      << endl;
   opt.setFlag("nocolorblocks");
   out << "  -h, --help" << endl
       << "  Prints this help message" << endl;
@@ -603,6 +672,18 @@ bool Server::parseCommandline()
     m_numbots = numbots;
   }
 
+  if (opt.getValue("rounds") != NULL)
+  {
+    bool ok;
+    unsigned int rounds = QString(opt.getValue("rounds")).toUInt(&ok);
+    if (!ok || rounds == 0)
+    {
+      qCritical() << "Invalid number of rounds: " << opt.getValue("rounds") << endl;
+      return false;
+    }
+    m_rounds = rounds;
+  }
+
   this->setProperty("coloredblocks", !opt.getFlag("nocolorblocks"));
 
   return true;