- fix audio plugin and make that a real interface

- that fixes a duplicate statis audiomanager (1x pacman, 1x audio plugin) on windows
- display won/lost dialog upon gameend

1 files changed, 66 insertions, 29 deletions

diff --git a/pacman-c++/client/mainwidget.cpp b/pacman-c++/client/mainwidget.cpp
index f2e3f46..99b0f5b 100644
--- a/pacman-c++/client/mainwidget.cpp
+++ b/pacman-c++/client/mainwidget.cpp
@@ -22,13 +22,14 @@ MainWidget::MainWidget(QWidget *parent)
   m_ambientPlayer = new GaplessAudioPlayer(Sound::Ambient, 100, this);
 
   m_recvTimer = new QTimer(this);
-  m_recvTimer->setInterval(Constants::tick / 2);
-  connect(m_recvTimer, SIGNAL(timeout()), this, SLOT(tick()));
+  m_recvTimer->setInterval(Constants::Networking::recv_interval);
+  connect(m_recvTimer, SIGNAL(timeout()), this, SLOT(readServerUpdates()));
 }
 
 MainWidget::~MainWidget()
 {
   doDisconnect();
+  deleteGUI();
   if (m_host != NULL)
   {
     enet_host_destroy(m_host);
@@ -38,6 +39,10 @@ MainWidget::~MainWidget()
 
 void MainWidget::doConnect(QString srv, unsigned int port)
 {
+  /* preload sound - this eliminates some loading gap on slower computers */
+  AudioManager::self()->setSource(Sound::Intro);
+  deleteGUI();
+
   Color::Color color = connectToServer(srv, port);
   if (color == Color::none)
   {
@@ -48,7 +53,7 @@ void MainWidget::doConnect(QString srv, unsigned int port)
   /* create our scene */
   m_scene = new SceneHolder(this);
   m_scene->setColor(color);
-  m_scene->showWaitingForPlayers(true);
+  m_scene->showWaitingForPlayers();
   createGui();
 
   m_recvTimer->start();
@@ -77,13 +82,26 @@ void MainWidget::deleteLayout(QLayout *layout)
   delete layout;
 }
 
+void MainWidget::deleteGUI()
+{
+  deleteLayout(layout());
+  m_playerScoreLayouts.clear();
+}
+
 void MainWidget::doDisconnect()
 {
+  if (!connected())
+    return;
+  closeENetPeer();
+  onDisconnect();
+}
+
+void MainWidget::onDisconnect()
+{
   stopGame();
   m_recvTimer->stop();
-  closeENetPeer();
-  deleteLayout(layout());
-  m_playerScoreLayouts.clear();
+  m_scene->clear();
+  m_scene->showWonLost(didIWinLoose());
   emit connected(false);
 }
 
@@ -157,6 +175,23 @@ void MainWidget::updateScore(const ProtoBuf::MapUpdate& packet)
   }
 }
 
+bool MainWidget::didIWinLoose()
+{
+  QGridLayout *score = m_playerScoreLayouts.at(0);
+  QLabel *allPointsLbl = dynamic_cast<QLabel *>(score->itemAtPosition(1, 1)->widget());
+  unsigned long myscore = allPointsLbl->text().toULong();
+
+  for(unsigned i = 1; i < m_maxplayers; ++i)
+  {
+    QGridLayout *score = m_playerScoreLayouts.at(i);
+    QLabel *allPointsLbl = dynamic_cast<QLabel *>(score->itemAtPosition(1, 1)->widget());
+    unsigned long other = allPointsLbl->text().toULong();
+    if (other > myscore)
+      return false;
+  }
+  return true;
+}
+
 Transmission::field_t MainWidget::translateKey(int key)
 {
   switch(key)
@@ -182,7 +217,7 @@ Transmission::field_t MainWidget::translateKey(int key)
   }
 }
 
-void MainWidget::tick()
+void MainWidget::readServerUpdates()
 {
   ENetEvent event;
   while (enet_host_service(m_host, &event, 1) > 0)
@@ -191,10 +226,10 @@ void MainWidget::tick()
     {
     case ENET_EVENT_TYPE_DISCONNECT:
       m_peer = NULL;
-      doDisconnect();
+      onDisconnect();
       break;
     case ENET_EVENT_TYPE_RECEIVE:
-      tick(&event);
+      processServerUpdates(&event);
       enet_packet_destroy(event.packet);
       break;
     default:
@@ -203,18 +238,22 @@ void MainWidget::tick()
   }
 }
 
-void MainWidget::tick(ENetEvent *event)
+void MainWidget::processServerUpdates(ENetEvent *event)
 {
   QSharedPointer<QByteArray> data = Util::receivePacket(event->packet);
-  bool worked = m_updatepacket.ParseFromArray(data->data(), data->size());
-  Q_ASSERT(worked);
-  Q_UNUSED(worked);
+  if (!m_updatepacket.ParseFromArray(data->data(), data->size()))
+  {
+    qWarning() << "Invalid update packet from server";
+    return;
+  }
 
   /* eating order data set indicates a new round */
   if (m_updatepacket.eating_order_size() > 0)
   {
     Q_ASSERT(m_scene != NULL);
-    m_scene->reset();
+
+    /* stop game */
+    stopGame();
 
     /* fetch eating order */
     QList<Color::Color> order;
@@ -222,16 +261,13 @@ void MainWidget::tick(ENetEvent *event)
       order.append(static_cast<Color::Color>(m_updatepacket.eating_order(i) & Transmission::color_mask));
     m_scene->setEatingOrder(order);
 
-    /* stop game */
-    stopGame();
-
     /* and restart game */
     QTimer *timer = new QTimer(this);
     timer->setSingleShot(true);
     timer->setInterval(Sound::length[Sound::Intro] + Constants::tick);
     connect(timer, SIGNAL(timeout()), this, SLOT(startGame()));
     timer->start();
-    AudioManager::self()->audioPlayer()->play(Sound::Intro);
+    AudioManager::self()->play(Sound::Intro);
   }
 
   Transmission::map_t map = Util::createUninitialisedMap();
@@ -250,10 +286,7 @@ void MainWidget::tick(ENetEvent *event)
   updateScore(m_updatepacket);
 
   if (m_updatepacket.eating_order_size() > 0)
-  {
-    m_scene->showWaitingForPlayers(false);
     m_scene->showEatingText();
-  }
 }
 
 void MainWidget::keyPressEvent(QKeyEvent* event)
@@ -273,11 +306,13 @@ void MainWidget::keyPressEvent(QKeyEvent* event)
 
 void MainWidget::sendKeyUpdate()
 {
+  if (!connected())
+    return;
   if (m_currentKey == Transmission::direction_none)
     return;
   qDebug() << "[SendKey] key=" << m_currentKey;
-  ProtoBuf::KeyPressUpdate packet;
-  packet.set_newkey(m_currentKey);
+  ProtoBuf::ClientUpdate packet;
+  packet.set_new_direction(m_currentKey);
   Util::sendPacket(packet, m_peer, m_host);
 }
 
@@ -294,7 +329,7 @@ void MainWidget::keyReleaseEvent(QKeyEvent* event)
 void MainWidget::startGame()
 {
   disconnect(AudioManager::self()->audioPlayer(), NULL, this, SLOT(startGame()));
-  m_scene->showEatingText(false);
+  m_scene->hideOverlayText();
   m_running = true;
   sendKeyUpdate();
   m_ambientPlayer->play();
@@ -304,6 +339,7 @@ void MainWidget::stopGame()
 {
   m_running = false;
   m_ambientPlayer->pause();
+  m_scene->reset();
 }
 
 void MainWidget::setAmbientMuted(bool muted)
@@ -348,11 +384,12 @@ Color::Color MainWidget::connectToServer(QString srv, unsigned int port)
       QSharedPointer<QByteArray> data = Util::receivePacket(event.packet);
       enet_packet_destroy(event.packet);
       ProtoBuf::Init packet;
-      worked = packet.ParseFromArray(data->data(), data->size());
-      Q_ASSERT(worked);
-      Q_UNUSED(worked);
-      m_maxplayers = packet.maxplayers();
-      return static_cast<Color::Color>(packet.color() & Transmission::color_mask);
+      if (packet.ParseFromArray(data->data(), data->size()))
+      {
+        m_maxplayers = packet.maxplayers();
+        return static_cast<Color::Color>(packet.color() & Transmission::color_mask);
+      }
+      qWarning() << "Invalid initialize packet from server";
     }
   }
   enet_peer_reset(m_peer);