Merge branch 'tmj-dev' into milek-dev

messaging.cpp

@@ -13,18 +13,24 @@ http://mozilla.org/MPL/2.0/.
 #include "Globals.h"
 #include "application.h"
 #include "simulation.h"
+#include "simulationtime.h"
+#include "event.h"
+#include "DynObj.h"
+#include "Driver.h"
 #include "mtable.h"
 #include "Logs.h"
 
 #ifdef _WIN32
 extern "C"
 {
-    GLFWAPI HWND glfwGetWin32Window( GLFWwindow* window ); //m7todo: potrzebne do directsound
+    GLFWAPI HWND glfwGetWin32Window( GLFWwindow* window );
 }
 #endif
 
 namespace multiplayer {
 
+std::uint32_t const EU07_MESSAGEHEADER { MAKE_ID4( 'E','U','0','7' ) };
+
 void
 Navigate(std::string const &ClassName, UINT Msg, WPARAM wParam, LPARAM lParam) {
 #ifdef _WIN32
@@ -36,12 +42,171 @@ Navigate(std::string const &ClassName, UINT Msg, WPARAM wParam, LPARAM lParam) {
 #endif
 }
 
+void
+OnCommandGet(multiplayer::DaneRozkaz *pRozkaz)
+{ // odebranie komunikatu z serwera
+    if (pRozkaz->iSygn == EU07_MESSAGEHEADER )
+        switch (pRozkaz->iComm)
+        {
+        case 0: // odesłanie identyfikatora wersji
+			CommLog( Now() + " " + std::to_string(pRozkaz->iComm) + " version" + " rcvd");
+            WyslijString(Global.asVersion, 0); // przedsatwienie się
+            break;
+        case 1: // odesłanie identyfikatora wersji
+			CommLog( Now() + " " + std::to_string(pRozkaz->iComm) + " scenery" + " rcvd");
+            WyslijString(Global.SceneryFile, 1); // nazwa scenerii
+            break;
+        case 2: {
+            // event
+            CommLog( Now() + " " + std::to_string( pRozkaz->iComm ) + " " +
+                std::string( pRozkaz->cString + 1, (unsigned)( pRozkaz->cString[ 0 ] ) ) + " rcvd" );
+
+            if( Global.iMultiplayer ) {
+                auto *event = simulation::Events.FindEvent( std::string( pRozkaz->cString + 1, (unsigned)( pRozkaz->cString[ 0 ] ) ) );
+                if( event != nullptr ) {
+                    if( ( event->Type == tp_Multiple )
+                     || ( event->Type == tp_Lights )
+                     || ( event->evJoined != 0 ) ) {
+                        // tylko jawne albo niejawne Multiple
+                        simulation::Events.AddToQuery( event, nullptr ); // drugi parametr to dynamic wywołujący - tu brak
+                    }
+                }
+            }
+            break;
+        }
+        case 3: // rozkaz dla AI
+            if (Global.iMultiplayer)
+            {
+                int i = int(pRozkaz->cString[8]); // długość pierwszego łańcucha (z przodu dwa floaty)
+                CommLog(
+                    Now() + " " + to_string(pRozkaz->iComm) + " " +
+                    std::string(pRozkaz->cString + 11 + i, (unsigned)(pRozkaz->cString[10 + i])) +
+                    " rcvd");
+                // nazwa pojazdu jest druga
+                auto *vehicle = simulation::Vehicles.find( { pRozkaz->cString + 11 + i, (unsigned)pRozkaz->cString[ 10 + i ] } );
+                if( ( vehicle != nullptr )
+                 && ( vehicle->Mechanik != nullptr ) ) {
+                    vehicle->Mechanik->PutCommand(
+                        { pRozkaz->cString + 9, static_cast<std::size_t>(i) },
+                        pRozkaz->fPar[0], pRozkaz->fPar[1],
+                        nullptr,
+                        stopExt ); // floaty są z przodu
+                    WriteLog("AI command: " + std::string(pRozkaz->cString + 9, i));
+                }
+            }
+            break;
+        case 4: // badanie zajętości toru
+        {
+            CommLog(Now() + " " + to_string(pRozkaz->iComm) + " " +
+                    std::string(pRozkaz->cString + 1, (unsigned)(pRozkaz->cString[0])) + " rcvd");
+
+            auto *track = simulation::Paths.find( std::string( pRozkaz->cString + 1, (unsigned)( pRozkaz->cString[ 0 ] ) ) );
+            if( ( track != nullptr )
+             && ( track->IsEmpty() ) ) {
+                WyslijWolny( track->name() );
+            }
+        }
+        break;
+        case 5: // ustawienie parametrów
+        {
+            CommLog(Now() + " " + to_string(pRozkaz->iComm) + " params " + to_string(*pRozkaz->iPar) + " rcvd");
+            if (*pRozkaz->iPar == 0) // sprawdzenie czasu
+                if (*pRozkaz->iPar & 1) // ustawienie czasu
+                {
+                    double t = pRozkaz->fPar[1];
+                    simulation::Time.data().wDay = std::floor(t); // niby nie powinno być dnia, ale...
+                    if (Global.fMoveLight >= 0)
+                        Global.fMoveLight = t; // trzeba by deklinację Słońca przeliczyć
+                    simulation::Time.data().wHour = std::floor(24 * t) - 24.0 * simulation::Time.data().wDay;
+                    simulation::Time.data().wMinute = std::floor(60 * 24 * t) - 60.0 * (24.0 * simulation::Time.data().wDay + simulation::Time.data().wHour);
+                    simulation::Time.data().wSecond = std::floor( 60 * 60 * 24 * t ) - 60.0 * ( 60.0 * ( 24.0 * simulation::Time.data().wDay + simulation::Time.data().wHour ) + simulation::Time.data().wMinute );
+                }
+            if (*pRozkaz->iPar & 2)
+            { // ustawienie flag zapauzowania
+                Global.iPause = pRozkaz->fPar[2]; // zakładamy, że wysyłający wie, co robi
+            }
+        }
+        break;
+        case 6: // pobranie parametrów ruchu pojazdu
+            if (Global.iMultiplayer) {
+                // Ra 2014-12: to ma działać również dla pojazdów bez obsady
+                CommLog(
+                    Now() + " "
+                  + to_string( pRozkaz->iComm ) + " "
+                  + std::string{ pRozkaz->cString + 1, (unsigned)( pRozkaz->cString[ 0 ] ) }
+                  + " rcvd" );
+                if (pRozkaz->cString[0]) {
+                    // jeśli długość nazwy jest niezerowa szukamy pierwszego pojazdu o takiej nazwie i odsyłamy parametry ramką #7
+                    auto *vehicle = (
+                        pRozkaz->cString[ 1 ] == '*' ?
+                            simulation::Vehicles.find( Global.asHumanCtrlVehicle ) :
+                            simulation::Vehicles.find( std::string{ pRozkaz->cString + 1, (unsigned)pRozkaz->cString[ 0 ] } ) );
+                    if( vehicle != nullptr ) {
+                        WyslijNamiary( vehicle ); // wysłanie informacji o pojeździe
+                    }
+                }
+                else {
+                    // dla pustego wysyłamy ramki 6 z nazwami pojazdów AI (jeśli potrzebne wszystkie, to rozpoznać np. "*")
+                    simulation::Vehicles.DynamicList();
+                }
+            }
+            break;
+        case 8: // ponowne wysłanie informacji o zajętych odcinkach toru
+			CommLog(Now() + " " + to_string(pRozkaz->iComm) + " all busy track" + " rcvd");
+            simulation::Paths.TrackBusyList();
+            break;
+        case 9: // ponowne wysłanie informacji o zajętych odcinkach izolowanych
+			CommLog(Now() + " " + to_string(pRozkaz->iComm) + " all busy isolated" + " rcvd");
+            simulation::Paths.IsolatedBusyList();
+            break;
+        case 10: // badanie zajętości jednego odcinka izolowanego
+            CommLog(Now() + " " + to_string(pRozkaz->iComm) + " " +
+                    std::string(pRozkaz->cString + 1, (unsigned)(pRozkaz->cString[0])) + " rcvd");
+            simulation::Paths.IsolatedBusy( std::string( pRozkaz->cString + 1, (unsigned)( pRozkaz->cString[ 0 ] ) ) );
+            break;
+        case 11: // ustawienie parametrów ruchu pojazdu
+            //    Ground.IsolatedBusy(AnsiString(pRozkaz->cString+1,(unsigned)(pRozkaz->cString[0])));
+            break;
+		case 12: // skrocona ramka parametrow pojazdow AI (wszystkich!!)
+			CommLog(Now() + " " + to_string(pRozkaz->iComm) + " obsadzone" + " rcvd");
+            WyslijObsadzone();
+			//    Ground.IsolatedBusy(AnsiString(pRozkaz->cString+1,(unsigned)(pRozkaz->cString[0])));
+			break;
+		case 13: // ramka uszkodzenia i innych stanow pojazdu, np. wylaczenie CA, wlaczenie recznego itd.
+            CommLog(Now() + " " + to_string(pRozkaz->iComm) + " " +
+                    std::string(pRozkaz->cString + 1, (unsigned)(pRozkaz->cString[0])) +
+                    " rcvd");
+            if( pRozkaz->cString[ 1 ] ) // jeśli długość nazwy jest niezerowa
+            { // szukamy pierwszego pojazdu o takiej nazwie i odsyłamy parametry ramką #13
+                auto *lookup = (
+                    pRozkaz->cString[ 2 ] == '*' ?
+                        simulation::Vehicles.find( Global.asHumanCtrlVehicle ) : // nazwa pojazdu użytkownika
+                        simulation::Vehicles.find( std::string( pRozkaz->cString + 2, (unsigned)pRozkaz->cString[ 1 ] ) ) ); // nazwa pojazdu
+                if( lookup == nullptr ) { break; } // nothing found, nothing to do
+                auto *d { lookup };
+                while( d != nullptr ) {
+                    d->Damage( pRozkaz->cString[ 0 ] );
+                    d = d->Next(); // pozostałe też
+                }
+                d = lookup->Prev();
+                while( d != nullptr ) {
+                    d->Damage( pRozkaz->cString[ 0 ] );
+                    d = d->Prev(); // w drugą stronę też
+                }
+                WyslijUszkodzenia( lookup->asName, lookup->MoverParameters->EngDmgFlag ); // zwrot informacji o pojeździe
+            }
+			break;
+        default:
+            break;
+		}
+}
+
 void
 WyslijEvent(const std::string &e, const std::string &d)
 { // Ra: jeszcze do wyczyszczenia
 #ifdef _WIN32
     DaneRozkaz r;
-    r.iSygn = MAKE_ID4( 'E', 'U', '0', '7' );
+    r.iSygn = EU07_MESSAGEHEADER;
     r.iComm = 2; // 2 - event
     size_t i = e.length(), j = d.length();
     r.cString[0] = char(i);
@@ -49,7 +214,7 @@ WyslijEvent(const std::string &e, const std::string &d)
     r.cString[i + 2] = char(j); // licznik po zerze kończącym
     strcpy(r.cString + 3 + i, d.c_str()); // zakończony zerem
     COPYDATASTRUCT cData;
-    cData.dwData = MAKE_ID4( 'E', 'U', '0', '7' ); // sygnatura
+    cData.dwData = EU07_MESSAGEHEADER; // sygnatura
     cData.cbData = (DWORD)(12 + i + j); // 8+dwa liczniki i dwa zera kończące
     cData.lpData = &r;
     Navigate( "TEU07SRK", WM_COPYDATA, (WPARAM)glfwGetWin32Window( Application.window() ), (LPARAM)&cData );
@@ -61,15 +226,15 @@ void
 WyslijUszkodzenia(const std::string &t, char fl)
 { // wysłanie informacji w postaci pojedynczego tekstu
 #ifdef _WIN32
-	DaneRozkaz r;
-    r.iSygn = MAKE_ID4( 'E', 'U', '0', '7' );
+    DaneRozkaz r;
+    r.iSygn = EU07_MESSAGEHEADER;
 	r.iComm = 13; // numer komunikatu
 	size_t i = t.length();
 	r.cString[0] = char(fl);
 	r.cString[1] = char(i);
 	strcpy(r.cString + 2, t.c_str()); // z zerem kończącym
 	COPYDATASTRUCT cData;
-    cData.dwData = MAKE_ID4( 'E', 'U', '0', '7' ); // sygnatura
+    cData.dwData = EU07_MESSAGEHEADER; // sygnatura
 	cData.cbData = (DWORD)(11 + i); // 8+licznik i zero kończące
 	cData.lpData = &r;
     Navigate( "TEU07SRK", WM_COPYDATA, (WPARAM)glfwGetWin32Window( Application.window() ), (LPARAM)&cData );
@@ -82,13 +247,13 @@ WyslijString(const std::string &t, int n)
 { // wysłanie informacji w postaci pojedynczego tekstu
 #ifdef _WIN32
     DaneRozkaz r;
-    r.iSygn = MAKE_ID4( 'E', 'U', '0', '7' );
+    r.iSygn = EU07_MESSAGEHEADER;
     r.iComm = n; // numer komunikatu
     size_t i = t.length();
     r.cString[0] = char(i);
     strcpy(r.cString + 1, t.c_str()); // z zerem kończącym
     COPYDATASTRUCT cData;
-    cData.dwData = MAKE_ID4( 'E', 'U', '0', '7' ); // sygnatura
+    cData.dwData = EU07_MESSAGEHEADER; // sygnatura
     cData.cbData = (DWORD)(10 + i); // 8+licznik i zero kończące
     cData.lpData = &r;
     Navigate( "TEU07SRK", WM_COPYDATA, (WPARAM)glfwGetWin32Window( Application.window() ), (LPARAM)&cData );
@@ -107,7 +272,7 @@ WyslijNamiary(TDynamicObject const *Vehicle)
 { // wysłanie informacji o pojeździe - (float), długość ramki będzie zwiększana w miarę potrzeby
 #ifdef _WIN32
     DaneRozkaz r;
-    r.iSygn = MAKE_ID4( 'E', 'U', '0', '7' );
+    r.iSygn = EU07_MESSAGEHEADER;
     r.iComm = 7; // 7 - dane pojazdu
 	int i = 32;
 	size_t j = Vehicle->asName.length();
@@ -170,7 +335,7 @@ WyslijNamiary(TDynamicObject const *Vehicle)
     r.cString[i] = char(j); // na końcu nazwa, żeby jakoś zidentyfikować
     strcpy(r.cString + i + 1, Vehicle->asName.c_str()); // zakończony zerem
     COPYDATASTRUCT cData;
-    cData.dwData = MAKE_ID4( 'E', 'U', '0', '7' ); // sygnatura
+    cData.dwData = EU07_MESSAGEHEADER; // sygnatura
     cData.cbData = (DWORD)(10 + i + j); // 8+licznik i zero kończące
     cData.lpData = &r;
     // WriteLog("Ramka gotowa");
@@ -184,8 +349,8 @@ void
 WyslijObsadzone()
 {   // wysłanie informacji o pojeździe
 #ifdef _WIN32
-	DaneRozkaz2 r;
-    r.iSygn = MAKE_ID4( 'E', 'U', '0', '7' );
+    DaneRozkaz2 r;
+    r.iSygn = EU07_MESSAGEHEADER;
 	r.iComm = 12;   // kod 12
 	for (int i=0; i<1984; ++i) r.cString[i] = 0;
 
@@ -219,7 +384,7 @@ WyslijObsadzone()
 	}
 
 	COPYDATASTRUCT cData;
-    cData.dwData = MAKE_ID4( 'E', 'U', '0', '7' );     // sygnatura
+    cData.dwData = EU07_MESSAGEHEADER;     // sygnatura
 	cData.cbData = 8 + 1984; // 8+licznik i zero kończące
 	cData.lpData = &r;
 	// WriteLog("Ramka gotowa");
@@ -233,7 +398,7 @@ WyslijParam(int nr, int fl)
 { // wysłanie parametrów symulacji w ramce (nr) z flagami (fl)
 #ifdef _WIN32
     DaneRozkaz r;
-    r.iSygn = MAKE_ID4( 'E', 'U', '0', '7' );
+    r.iSygn = EU07_MESSAGEHEADER;
     r.iComm = nr; // zwykle 5
     r.iPar[0] = fl; // flagi istotności kolejnych parametrów
     int i = 0; // domyślnie brak danych
@@ -246,7 +411,7 @@ WyslijParam(int nr, int fl)
         break;
     }
     COPYDATASTRUCT cData;
-    cData.dwData = MAKE_ID4( 'E', 'U', '0', '7' ); // sygnatura
+    cData.dwData = EU07_MESSAGEHEADER; // sygnatura
     cData.cbData = 12 + i; // 12+rozmiar danych
     cData.lpData = &r;
     Navigate( "TEU07SRK", WM_COPYDATA, (WPARAM)glfwGetWin32Window( Application.window() ), (LPARAM)&cData );