Changeset 8623 in orxonox.OLD for trunk/src/lib/network/network_game_manager.cc

Timestamp:

Jun 20, 2006, 1:39:01 PM (19 years ago)

Author:

bensch

Message:

orxonox/trunk: merged the network branche back here
merged with command:
svn merge -r8230:HEAD ​https://svn.orxonox.net/orxonox/branches/network .
conflicts resolved in favour of the network branche (conflicts were in network)

File:

• trunk/src/lib/network/network_game_manager.cc (modified) (19 diffs)

trunk/src/lib/network/network_game_manager.cc

@@ -23 +23 @@
 #include "state.h"
 #include "class_list.h"
+#include "debug.h"
 
 #include "network_stream.h"
@@ -39 +40 @@
 #include "network_game_manager.h"
 
-#include "debug.h"
-
 
 /* using namespace std is default, this needs to be here */
@@ -59 +58 @@
 
   this->setSynchronized(true);
-
+  
   MessageManager::getInstance()->registerMessageHandler( MSGID_DELETESYNCHRONIZEABLE, delSynchronizeableHandler, NULL );
   MessageManager::getInstance()->registerMessageHandler( MSGID_PREFEREDTEAM, preferedTeamHandler, NULL );
-
+  MessageManager::getInstance()->registerMessageHandler( MSGID_CHATMESSAGE, chatMessageHandler, NULL );
+  
   this->gameState = 0;
   registerVar( new SynchronizeableInt( &gameState, &gameState, "gameState" ) );
@@ -72 +72 @@
 NetworkGameManager::~NetworkGameManager()
 {
+  delete MessageManager::getInstance();
+  
+  PlayerStats::deleteAllPlayerStats();
 }
 
@@ -77 +80 @@
 /**
  * insert new player into game
- * @param userId
- * @return
+ * @param userId 
+ * @return 
  */
 bool NetworkGameManager::signalNewPlayer( int userId )
@@ -85 +88 @@
   assert( State::getGameRules() );
   assert( State::getGameRules()->isA( CL_NETWORK_GAME_RULES ) );
-
+  
   NetworkGameRules & rules = *(dynamic_cast<NetworkGameRules*>(State::getGameRules()));
-
+  
   int team = rules.getTeamForNewUser();
   ClassID playableClassId = rules.getPlayableClassId( userId, team );
   std::string playableModel = rules.getPlayableModelFileName( userId, team, playableClassId );
-
+  
   BaseObject * bo = Factory::fabricate( playableClassId );
-
+  
   assert( bo != NULL );
   assert( bo->isA( CL_PLAYABLE ) );
-
+  
   Playable & playable = *(dynamic_cast<Playable*>(bo));
-
-  playable.loadModel( playableModel );
+  
+  if (  playableModel != "" )
+    playable.loadModel( playableModel );
   playable.setOwner( userId );
   playable.setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
   playable.setSynchronized( true );
-
+  
   PlayerStats * stats = rules.getNewPlayerStats( userId );
-
+  
   stats->setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
   stats->setSynchronized( true );
   stats->setOwner( getHostID() );
-
+  
   stats->setTeamId( team );
   stats->setPlayableClassId( playableClassId );
   stats->setPlayableUniqueId( playable.getUniqueID() );
   stats->setModelFileName( playableModel );
-
+  
   return true;
 }
@@ -121 +125 @@
 /**
  * remove player from game
- * @param userID
- * @return
+ * @param userID 
+ * @return 
  */
 bool NetworkGameManager::signalLeftPlayer(int userID)
@@ -132 +136 @@
     delete PlayerStats::getStats( userID );
   }
-
+  
   return true;
 }
@@ -140 +144 @@
 /**
  * handler for remove synchronizeable messages
- * @param messageId
- * @param data
- * @param dataLength
- * @param someData
- * @param userId
+ * @param messageId 
+ * @param data 
+ * @param dataLength 
+ * @param someData 
+ * @param userId 
  * @return true on successfull handling else handler will be called again
  */
@@ -154 +158 @@
     return true;
   }
-
+  
   int uniqueId = 0;
   int len = Converter::byteArrayToInt( data, &uniqueId );
-
+  
   if ( len != dataLength )
   {
@@ -163 +167 @@
     return true;
   }
-
+  
   const std::list<BaseObject*> * list = ClassList::getList( CL_SYNCHRONIZEABLE );
-
+  
   for ( std::list<BaseObject*>::const_iterator it = list->begin(); it != list->end(); it++ )
   {
@@ -175 +179 @@
         return true;
       }
-
+      
       delete dynamic_cast<Synchronizeable*>(*it);
       return true;
     }
   }
-
+  
   return true;
 }
@@ -191 +195 @@
 {
   byte buf[INTSIZE];
-
+  
   assert( Converter::intToByteArray( uniqueId, buf, INTSIZE ) == INTSIZE );
 
@@ -201 +205 @@
 /**
  * handler for MSGID_PREFEREDTEAM message
- * @param messageId
- * @param data
- * @param dataLength
- * @param someData
- * @param userId
- * @return
+ * @param messageId 
+ * @param data 
+ * @param dataLength 
+ * @param someData 
+ * @param userId 
+ * @return 
  */
 bool NetworkGameManager::preferedTeamHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
 {
   assert( NetworkGameManager::getInstance()->isServer() );
-
+  
   int teamId = 0;
   int len = Converter::byteArrayToInt( data, &teamId );
-
+  
   if ( len != dataLength )
   {
@@ -220 +224 @@
     return true;
   }
-
+  
   NetworkGameManager::getInstance()->setPreferedTeam( userId, teamId );
-
+  
   return true;
 }
@@ -230 +234 @@
   if ( !PlayerStats::getStats( userId ) )
     return;
-
+  
   PlayerStats & stats = *(PlayerStats::getStats( userId ));
-
+  
   stats.setPreferedTeamId( teamId );
 }
@@ -238 +242 @@
 /**
  * set prefered team for this host
- * @param teamId
+ * @param teamId 
  */
 void NetworkGameManager::prefereTeam( int teamId )
@@ -247 +251 @@
   {
     byte buf[INTSIZE];
-
+    
     assert( Converter::intToByteArray( teamId, buf, INTSIZE) == INTSIZE );
-
+    
     MessageManager::getInstance()->sendMessage( MSGID_PREFEREDTEAM, buf, INTSIZE, RT_USER, 0, MP_HIGHBANDWIDTH );
   }
@@ -278 +282 @@
 
 
-
+bool NetworkGameManager::chatMessageHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
+{
+  assert( State::getGameRules() );
+  assert( State::getGameRules()->isA( CL_NETWORK_GAME_RULES ) );
+  
+  NetworkGameRules & rules = *(dynamic_cast<NetworkGameRules*>(State::getGameRules()));
+  
+  if ( dataLength < 2*INTSIZE )
+  {
+    PRINTF(2)("got too small chatmessage from client %d\n", userId);
+    
+    return true;
+  }
+  
+  int messageType = 0;
+  Converter::byteArrayToInt( data, &messageType );
+  std::string message;
+  Converter::byteArrayToString( data+INTSIZE, message, dataLength-INTSIZE );
+  
+  rules.handleChatMessage( userId, message, messageType );
+
+  return true;
+}
+
+/**
+ * send chat message
+ * @param message message text
+ * @param messageType some int
+ * @param userId user to send message to -1 = ALL
+ */
+void NetworkGameManager::sendChatMessage( const std::string & message, int messageType, int userId )
+{
+  byte * buf = new byte[message.length()+2*INTSIZE];
+
+  assert( Converter::intToByteArray( messageType, buf, INTSIZE ) == INTSIZE );
+  assert( Converter::stringToByteArray(message, buf+INTSIZE, message.length()+INTSIZE) == message.length()+INTSIZE );
+  
+  if ( userId == -1 )
+    MessageManager::getInstance()->sendMessage( MSGID_CHATMESSAGE, buf, message.length()+2*INTSIZE, RT_ALL_ME, 0, MP_HIGHBANDWIDTH );
+  else
+    MessageManager::getInstance()->sendMessage( MSGID_CHATMESSAGE, buf, message.length()+2*INTSIZE, RT_USER, userId, MP_HIGHBANDWIDTH );
+  
+  delete [] buf;
+}
+
+
+