NewsClient hinzugefügt

Include/KSGNetwork.h

@@ -298,7 +298,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -384,7 +384,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -421,7 +421,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // Gibt die Id des Accounts zurück, in den sich der Client eingeloggt hat.
@@ -644,7 +644,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -734,7 +734,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Wartet auf eine Nachricht vom Chatserver und gibt diese zurück.
         virtual ChatServerNachricht *getNextMessage() = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
@@ -822,7 +822,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -908,7 +908,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -956,7 +956,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -1022,7 +1022,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -1111,7 +1111,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück
@@ -1362,7 +1362,7 @@ namespace KSGClient
         // Trennt die Verbindung zum Server
         //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
         //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
-        virtual bool trenne() = 0;
+        virtual bool trenne( bool abmelden ) = 0;
         // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
         virtual bool istVerbunden() const = 0;
         // gibt den Letzten Fehlertext zuück

KSGNetwork/KSGNetwork.vcxproj

@@ -152,12 +152,14 @@
     <ClInclude Include="Keys.h" />
     <ClInclude Include="Main.cpp" />
     <ClInclude Include="MainClient.h" />
+    <ClInclude Include="NewsClient.h" />
     <ClInclude Include="PatchClient.h" />
   </ItemGroup>
   <ItemGroup>
     <ClCompile Include="ErhaltungClient.cpp" />
     <ClCompile Include="Keys.cpp" />
     <ClCompile Include="MainClient.cpp" />
+    <ClCompile Include="NewsClient.cpp" />
     <ClCompile Include="PatchClient.cpp" />
   </ItemGroup>
   <Import Project="$(VCTargetsPath)\Microsoft.Cpp.targets" />

KSGNetwork/KSGNetwork.vcxproj.filters

@@ -33,6 +33,9 @@
     <ClInclude Include="PatchClient.h">
       <Filter>Headerdateien</Filter>
     </ClInclude>
+    <ClInclude Include="NewsClient.h">
+      <Filter>Headerdateien</Filter>
+    </ClInclude>
   </ItemGroup>
   <ItemGroup>
     <ClCompile Include="MainClient.cpp">
@@ -47,5 +50,8 @@
     <ClCompile Include="PatchClient.cpp">
       <Filter>Quelldateien</Filter>
     </ClCompile>
+    <ClCompile Include="NewsClient.cpp">
+      <Filter>Quelldateien</Filter>
+    </ClCompile>
   </ItemGroup>
 </Project>

KSGNetwork/MainClient.cpp

@@ -3,6 +3,7 @@
 #include "Keys.h"
 #include "ErhaltungClient.h"
 #include "PatchClient.h"
+#include "NewsClient.h"
 
 using namespace KSGClient;
 
@@ -260,7 +261,52 @@ PatchServerClient *MainClient::createPatchServerClient()
 //  Gibt bei misserfolg 0 zurück
 NewsServerClient *MainClient::createNewsServerClient()
 {
-
+    cs.lock();
+    bool connected = k != 0;
+    if( !connected )
+        connect();
+    if( !k )
+    {
+        err = "no connection to Main Server";
+        cs.unlock();
+        return 0;
+    }
+    k->sendeEncrypted( "\6\x9", 2 );
+    char byte = 0;
+    k->getNachrichtEncrypted( &byte, 1 );
+    if( byte == 2 )
+    {
+        unsigned char lsIp[ 4 ];
+        k->getNachrichtEncrypted( (char *)lsIp, 4 );
+        unsigned short lsPort = 0;
+        k->getNachrichtEncrypted( (char*)&lsPort, 2 );
+        Framework::Text ipT;
+        ipT += (int)lsIp[ 0 ];
+        ipT += ".";
+        ipT += (int)lsIp[ 1 ];
+        ipT += ".";
+        ipT += (int)lsIp[ 2 ];
+        ipT += ".";
+        ipT += (int)lsIp[ 3 ];
+        if( !connected )
+            disconnect();
+        cs.unlock();
+        return new NewsClient( cId, lsPort, ipT, key, keyLen );
+    }
+    else if( byte == 3 )
+    {
+        k->getNachrichtEncrypted( &byte, 1 );
+        char *f = new char[ byte + 1 ];
+        f[ byte ] = 0;
+        k->getNachrichtEncrypted( f, byte );
+        err = "error while requesting NewsServer server returned: ";
+        err += f;
+        delete[]f;
+    }
+    if( !connected )
+        disconnect();
+    cs.unlock();
+    return 0;
 }
 
 // Erzeugt einen Register Server Client

KSGNetwork/NewsClient.cpp

@@ -0,0 +1,273 @@
+#include "NewsClient.h"
+#include <Klient.h>
+#include "Keys.h"
+#include <Datei.h>
+#include <Globals.h>
+
+using namespace KSGClient;
+
+// Inhalt der NewsClient Klasse
+
+// Konstruktor
+NewsClient::NewsClient( int klientId, unsigned short port, char *ip, char *key, unsigned char keyLen )
+{
+    ref = 1;
+    this->ip = ip;
+    this->port = port;
+    cId = klientId;
+    k = 0;
+    this->key = new char[ keyLen ];
+    memcpy( this->key, key, keyLen );
+    this->keyLen = keyLen;
+}
+
+// Destruktor
+NewsClient::~NewsClient()
+{
+    if( k )
+        k->release();
+    delete[] key;
+}
+
+// verbindet ich mit dem News Server
+//  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+bool NewsClient::verbinde()
+{
+    cs.lock();
+    if( k )
+    {
+        cs.unlock();
+        return 1;
+    }
+    k = new Network::Klient();
+    int l = 0;
+    char *key;
+    Keys::getServerKey( &key, l, Keys::NEWS, Keys::SENDEN );
+    k->setSendeKey( key, l );
+    delete[] key;
+    Keys::getServerKey( &key, l, Keys::NEWS, Keys::EMPFANGEN );
+    k->setEmpfangKey( key, l );
+    delete[] key;
+    if( k->verbinde( port, ip ) )
+    {
+        if( k->sendeEncrypted( "\1", 1 ) )
+        {
+            k->sendeEncrypted( (char*)&cId, 4 );
+            char serverReturn = 0;
+            k->getNachrichtEncrypted( &serverReturn, 1 );
+            if( serverReturn == 3 )
+            {
+                char byte = 0;
+                k->getNachrichtEncrypted( &byte, 1 );
+                char *f = new char[ byte + 1 ];
+                f[ byte ] = 0;
+                k->getNachrichtEncrypted( f, byte );
+                err = "error while identifying client News Server returned: ";
+                err += f;
+                delete[]f;
+                trenne( 0 );
+                cs.unlock();
+                return 0;
+            }
+            k->setSendeKey( (char*)key, keyLen );
+            k->setEmpfangKey( (char*)key, keyLen );
+        }
+        else
+        {
+            err = "network error while sending to Patch Server";
+            k = k->release();
+            cs.unlock();
+            return 0;
+        }
+    }
+    else
+    {
+        err = "network error while connecting to Patch Server";
+        k = k->release();
+        cs.unlock();
+        return 0;
+    }
+    cs.unlock();
+    return 1;
+}
+
+// Lädt eine KSG-Script Seite herunter uns speichert sie unter data/tmp/news/{name}
+//  name: Der Name der Seite
+//  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+bool NewsClient::ladeSeite( char *name )
+{
+    cs.lock();
+    if( !k )
+    {
+        err = "Der Client ist nicht verbunden.";
+        cs.unlock();
+        return 0;
+    }
+    k->sendeEncrypted( "\5", 1 );
+    char ret = 0;
+    k->getNachrichtEncrypted( &ret, 1 );
+    if( ret == 1 )
+    {
+        char län = (char)textLength( name );
+        k->sendeEncrypted( &län, 1 );
+        k->sendeEncrypted( name, län );
+        k->getNachrichtEncrypted( &ret, 1 );
+        if( ret == 1 )
+        {
+            Text *pfad = new Text( "data/tmp/news/" );
+            pfad->append( name );
+            if( DateiExistiert( pfad->getThis() ) )
+                DateiRemove( pfad->getThis() );
+            pfad->append( "/" );
+            int dAnz = 0;
+            k->getNachrichtEncrypted( (char*)&dAnz, 4 );
+            for( int i = 0; i < dAnz; i++ )
+            {
+                char nLän = 0;
+                k->getNachrichtEncrypted( &nLän, 1 );
+                char *dName = new char[ nLän + 1 ];
+                dName[ nLän ] = 0;
+                k->getNachrichtEncrypted( dName, nLän );
+                Text *pf = new Text( pfad->getText() );
+                pf->append( dName );
+                delete[] dName;
+                Datei *d = new Datei();
+                d->setDatei( pf );
+                d->erstellen();
+                d->open( Datei::Style::schreiben );
+                __int64 dGr = 0;
+                k->getNachrichtEncrypted( (char*)&dGr, 8 );
+                char buffer[ 2048 ];
+                while( dGr > 0 )
+                {
+                    int län = dGr > 2048 ? 2048 : (int)dGr;
+                    k->getNachricht( buffer, län );
+                    d->schreibe( buffer, län );
+                    dGr -= län;
+                }
+                d->close();
+                d->release();
+            }
+            pfad->release();
+        }
+    }
+    if( ret == 3 )
+    {
+        k->getNachrichtEncrypted( &ret, 1 );
+        if( ret )
+        {
+            char *tmp = new char[ ret ];
+            k->getNachrichtEncrypted( tmp, ret );
+            err = tmp;
+            delete[] tmp;
+        }
+        else
+            err = "unbekannter Fehler";
+        cs.unlock();
+        return 0;
+    }
+    cs.unlock();
+    return 1;
+}
+
+// Erhält die Verbindung aufrecht
+//  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+//  Sollte während einer bestehenden Verbindung etwa einmal alle 60 Sekunden aufgerufen werden, da sonst der Router die Verbindung automatisch trennt
+bool NewsClient::keepAlive()
+{
+    if( !k )
+        return 0;
+    char res = 0;
+    if( !cs.tryLock() )
+        return 1;
+    Framework::logLine( ( char* )"Verbindungstest zum News Server..." );
+    bool ok = k->sendeEncrypted( "\x6", 1 );
+    ok &= k->getNachrichtEncrypted( &res, 1 );
+    cs.unlock();
+    if( res != 1 || !ok )
+    {
+        Framework::logLine( ( char* )"Verbindungsabbruch." );
+        trenne( 0 );
+    }
+    else
+        Framework::logLine( ( char* )"Verbindung besteht." );
+    return res == 1;
+}
+
+// Trennt die Verbindung zum Server
+//  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+//  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
+bool NewsClient::trenne( bool abmelden )
+{
+    cs.lock();
+    verbinde();
+    if( !k )
+    {
+        cs.unlock();
+        return 1;
+    }
+    if( abmelden )
+    {
+        k->sendeEncrypted( "\4", 1 );
+        char ret = 0;
+        k->getNachrichtEncrypted( &ret, 1 );
+        if( ret == 3 )
+        { // error
+            k->getNachrichtEncrypted( &ret, 1 );
+            char *msg = new char[ ret + 1 ];
+            msg[ ret ] = 0;
+            if( ret )
+                k->getNachrichtEncrypted( msg, ret );
+            err = "error while unregister Client News Server returned: ";
+            err += msg;
+            delete[] msg;
+        }
+    }
+    k->sendeEncrypted( "\3", 1 );
+    char ret = 0;
+    k->getNachrichtEncrypted( &ret, 1 );
+    if( ret == 3 )
+    { // error
+        k->getNachrichtEncrypted( &ret, 1 );
+        char *msg = new char[ ret + 1 ];
+        msg[ ret ] = 0;
+        if( ret )
+            k->getNachrichtEncrypted( msg, ret );
+        err = "error while trenne News Server returned: ";
+        err += msg;
+        delete[] msg;
+    }
+    k->trenne();
+    k = k->release();
+    cs.unlock();
+    return 1;
+}
+
+// Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
+bool NewsClient::istVerbunden() const
+{
+    return k != 0;
+}
+
+// gibt den Letzten Fehlertext zuück
+//  sollte erst aufgerufen werden, nachdem eine andere aufgerufene Methode fehlgeschlagen ist
+char *NewsClient::getLetzterFehler() const
+{
+    return err;
+}
+
+// Erhöht den Reference Counter um 1 un gibt this zurück
+NewsServerClient *NewsClient::getThis()
+{
+    ref++;
+    return this;
+}
+
+// Verringert den Reference Counter um 1 und gibt 0 zurück.
+//  Falls der Reference Counter nach dem Aufruf auf 0 ist löscht sich das Objekt selbst 
+NewsServerClient *NewsClient::release()
+{
+    if( !--ref )
+        delete this;
+    return 0;
+}

KSGNetwork/NewsClient.h

@@ -0,0 +1,54 @@
+#pragma once
+
+#include "../Include/KSGNetwork.h"
+#include <Critical.h>
+
+namespace KSGClient
+{
+    // Wird verwendet um News Oberflächen abzufragen (KSG Script Seiten)
+    class NewsClient : public NewsServerClient
+    {
+    private:
+        int ref;
+        Framework::Text ip;
+        unsigned short port;
+        int cId;
+        Network::Klient *k;
+        char *key;
+        unsigned char keyLen;
+        Framework::Critical cs;
+        Framework::Text err;
+
+    public:
+        // Konstruktor
+        NewsClient( int klientId, unsigned short port, char *ip, char *key, unsigned char keyLen );
+        // Destruktor
+        ~NewsClient();
+        // verbindet ich mit dem News Server
+        //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+        bool verbinde() override;
+        // Lädt eine KSG-Script Seite herunter uns speichert sie unter data/tmp/news/{name}
+        //  name: Der Name der Seite
+        //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+        bool ladeSeite( char *name ) override;
+        // Erhält die Verbindung aufrecht
+        //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+        //  Sollte während einer bestehenden Verbindung etwa einmal alle 60 Sekunden aufgerufen werden, da sonst der Router die Verbindung automatisch trennt
+        bool keepAlive() override;
+        // Trennt die Verbindung zum Server
+        //  Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
+        //  Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
+        bool trenne( bool abmelden ) override;
+        // Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
+        bool istVerbunden() const override;
+        // gibt den Letzten Fehlertext zuück
+        //  sollte erst aufgerufen werden, nachdem eine andere aufgerufene Methode fehlgeschlagen ist
+        char *getLetzterFehler() const override;
+        // Erhöht den Reference Counter um 1 un gibt this zurück
+        NewsServerClient *getThis() override;
+        // Verringert den Reference Counter um 1 und gibt 0 zurück.
+        //  Falls der Reference Counter nach dem Aufruf auf 0 ist löscht sich das Objekt selbst 
+        NewsServerClient *release() override;
+    };
+
+};

KSGNetwork/PatchClient.cpp

@@ -70,7 +70,7 @@ bool PatchClient::verbinde()
                 char *f = new char[ byte + 1 ];
                 f[ byte ] = 0;
                 k->getNachrichtEncrypted( f, byte );
-                err = "error while identifyin client Patch Server returned: ";
+                err = "error while identifying client Patch Server returned: ";
                 err += f;
                 delete[]f;
                 trenne( 0 );