diff options
Diffstat (limited to 'Stars45/NetBrokerClient.cpp')
-rw-r--r-- | Stars45/NetBrokerClient.cpp | 502 |
1 files changed, 263 insertions, 239 deletions
diff --git a/Stars45/NetBrokerClient.cpp b/Stars45/NetBrokerClient.cpp index a29a686..21de24d 100644 --- a/Stars45/NetBrokerClient.cpp +++ b/Stars45/NetBrokerClient.cpp @@ -1,239 +1,263 @@ -/* Project Starshatter 4.5
- Destroyer Studios LLC
- Copyright (C) 1997-2004. All Rights Reserved.
-
- SUBSYSTEM: Stars.exe
- FILE: NetBrokerClient.cpp
- AUTHOR: John DiCamillo
-
-
- OVERVIEW
- ========
- Client for Starshatter.com GameNet Broker
-*/
-
-
-#include "MemDebug.h"
-#include "NetBrokerClient.h"
-
-#include "HttpClient.h"
-#include "HttpServlet.h"
-#include "NetLayer.h"
-
-#include "Game.h"
-
-extern const char* versionInfo;
-const char* HOSTNAME = "www.starshatter.com";
-const WORD HTTPPORT = 80;
-
-bool NetBrokerClient::broker_available = false;
-bool NetBrokerClient::broker_found = false;
-
-// +--------------------------------------------------------------------+
-
-bool
-NetBrokerClient::GameOn(const char* name,
-const char* type,
-const char* addr,
-WORD port,
-const char* password)
-{
- bool result = false;
-
- if (!broker_available)
- return result;
-
- Text msg;
- char buffer[8];
- NetAddr broker(HOSTNAME, HTTPPORT);
-
- if (broker.IPAddr() == 0)
- return result;
-
- sprintf_s(buffer, "%d", port);
-
- msg = "GET http://";
- msg += HOSTNAME;
- msg += "/GameNet/GameOn.php?name=";
- msg += HttpRequest::EncodeParam(name);
- msg += "&addr=";
- msg += HttpRequest::EncodeParam(addr);
- msg += "&game=";
- msg += HttpRequest::EncodeParam(type);
- msg += "&vers=";
- msg += HttpRequest::EncodeParam(versionInfo);
- msg += "&port=";
- msg += buffer;
- msg += "&pass=";
- msg += HttpRequest::EncodeParam(password);
- msg += " HTTP/1.1\n\n";
-
- HttpClient client(broker);
- HttpRequest request(msg);
- request.SetHeader("Host", HOSTNAME);
-
- HttpResponse* response = client.DoRequest(request);
-
- if (response && response->Status() == 200) {
- broker_found = true;
- result = true;
- }
- else {
- ::Print("NetBrokerClient unable to contact GameNet!\n");
-
- if (response) {
- ::Print(" Response Status: %d\n", response->Status());
- ::Print(" Response Content: %s\n", response->Content().data());
- }
- else {
- ::Print(" No response.\n");
- }
-
- if (!broker_found)
- broker_available = false;
- }
-
- delete response;
- return result;
-}
-
-bool
-NetBrokerClient::GameList(const char* type, List<NetServerInfo>& server_list)
-{
- bool result = false;
-
- if (!broker_available)
- return result;
-
- Text msg;
- NetAddr broker(HOSTNAME, HTTPPORT);
-
- if (broker.IPAddr() == 0)
- return result;
-
- msg = "GET http://";
- msg += HOSTNAME;
- msg += "/GameNet/GameList.php?game=";
- msg += HttpRequest::EncodeParam(type);
- msg += "&vers=";
- msg += HttpRequest::EncodeParam(versionInfo);
- msg += " HTTP/1.1\n\n";
-
- HttpClient client(broker);
- HttpRequest request(msg);
- request.SetHeader("Host", HOSTNAME);
-
- HttpResponse* response = client.DoRequest(request);
-
- if (response && response->Status() == 200) {
- result = true;
-
- Text name;
- Text type;
- Text addr;
- int port;
- Text pass;
- Text vers;
- char buff[1024];
-
- const char* p = response->Content();
-
- // skip size
- while (*p && strncmp(p, "name:", 5))
- p++;
-
- while (*p) {
- if (!strncmp(p, "name:", 5)) {
- p += 5;
- ZeroMemory(buff, sizeof(buff));
- char* d = buff;
- while (*p && *p != '\n') *d++ = *p++;
- if (*p) p++;
-
- name = buff;
- }
- else if (!strncmp(p, "addr:", 5)) {
- p += 5;
- ZeroMemory(buff, sizeof(buff));
- char* d = buff;
- while (*p && *p != '\n') *d++ = *p++;
- if (*p) p++;
-
- addr = buff;
- }
- else if (!strncmp(p, "port:", 5)) {
- p += 5;
- ZeroMemory(buff, sizeof(buff));
- char* d = buff;
- while (*p && *p != '\n') *d++ = *p++;
- if (*p) p++;
-
- sscanf_s(buff, "%d", &port);
- }
- else if (!strncmp(p, "pass:", 5)) {
- p += 5;
- ZeroMemory(buff, sizeof(buff));
- char* d = buff;
- while (*p && *p != '\n') *d++ = *p++;
- if (*p) p++;
-
- pass = buff;
- }
- else if (!strncmp(p, "game:", 5)) {
- p += 5;
- ZeroMemory(buff, sizeof(buff));
- char* d = buff;
- while (*p && *p != '\n') *d++ = *p++;
- if (*p) p++;
-
- type = buff;
- type.setSensitive(false);
-
- if (type.contains("lan"))
- type = "LAN";
- else
- type = "Public";
- }
- else if (!strncmp(p, "vers:", 5)) {
- p += 5;
- ZeroMemory(buff, sizeof(buff));
- char* d = buff;
- while (*p && *p != '\n') *d++ = *p++;
- if (*p) p++;
-
- vers = buff;
- }
- else if (!strncmp(p, "time:", 5)) {
- while (*p && *p != '\n') p++;
- if (*p) p++;
- }
-
- else if (!strncmp(p, "###", 3)) {
- NetServerInfo* server = new(__FILE__,__LINE__) NetServerInfo;
- server->name = name;
- server->hostname = addr;
- server->type = type;
- server->addr = NetAddr(addr, port);
- server->port = port;
- server->password = pass;
- server->version = vers;
- server->save = false;
-
- server_list.append(server);
-
- while (*p && strncmp(p, "name:", 5))
- p++;
- }
- else {
- while (*p && *p != '\n') p++;
- if (*p) p++;
- }
- }
- }
- else if (!broker_found) {
- broker_available = false;
- }
-
- delete response;
- return result;
-}
+/* Starshatter OpenSource Distribution + Copyright (c) 1997-2004, Destroyer Studios LLC. + All Rights Reserved. + + Redistribution and use in source and binary forms, with or without + modification, are permitted provided that the following conditions are met: + + * Redistributions of source code must retain the above copyright notice, + this list of conditions and the following disclaimer. + * Redistributions in binary form must reproduce the above copyright notice, + this list of conditions and the following disclaimer in the documentation + and/or other materials provided with the distribution. + * Neither the name "Destroyer Studios" nor the names of its contributors + may be used to endorse or promote products derived from this software + without specific prior written permission. + + THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" + AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE + LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR + CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN + CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE + POSSIBILITY OF SUCH DAMAGE. + + SUBSYSTEM: Stars.exe + FILE: NetBrokerClient.cpp + AUTHOR: John DiCamillo + + + OVERVIEW + ======== + Client for Starshatter.com GameNet Broker +*/ + + +#include "MemDebug.h" +#include "NetBrokerClient.h" + +#include "HttpClient.h" +#include "HttpServlet.h" +#include "NetLayer.h" + +#include "Game.h" + +extern const char* versionInfo; +const char* HOSTNAME = "www.starshatter.com"; +const WORD HTTPPORT = 80; + +bool NetBrokerClient::broker_available = false; +bool NetBrokerClient::broker_found = false; + +// +--------------------------------------------------------------------+ + +bool +NetBrokerClient::GameOn(const char* name, +const char* type, +const char* addr, +WORD port, +const char* password) +{ + bool result = false; + + if (!broker_available) + return result; + + Text msg; + char buffer[8]; + NetAddr broker(HOSTNAME, HTTPPORT); + + if (broker.IPAddr() == 0) + return result; + + sprintf_s(buffer, "%d", port); + + msg = "GET http://"; + msg += HOSTNAME; + msg += "/GameNet/GameOn.php?name="; + msg += HttpRequest::EncodeParam(name); + msg += "&addr="; + msg += HttpRequest::EncodeParam(addr); + msg += "&game="; + msg += HttpRequest::EncodeParam(type); + msg += "&vers="; + msg += HttpRequest::EncodeParam(versionInfo); + msg += "&port="; + msg += buffer; + msg += "&pass="; + msg += HttpRequest::EncodeParam(password); + msg += " HTTP/1.1\n\n"; + + HttpClient client(broker); + HttpRequest request(msg); + request.SetHeader("Host", HOSTNAME); + + HttpResponse* response = client.DoRequest(request); + + if (response && response->Status() == 200) { + broker_found = true; + result = true; + } + else { + ::Print("NetBrokerClient unable to contact GameNet!\n"); + + if (response) { + ::Print(" Response Status: %d\n", response->Status()); + ::Print(" Response Content: %s\n", response->Content().data()); + } + else { + ::Print(" No response.\n"); + } + + if (!broker_found) + broker_available = false; + } + + delete response; + return result; +} + +bool +NetBrokerClient::GameList(const char* type, List<NetServerInfo>& server_list) +{ + bool result = false; + + if (!broker_available) + return result; + + Text msg; + NetAddr broker(HOSTNAME, HTTPPORT); + + if (broker.IPAddr() == 0) + return result; + + msg = "GET http://"; + msg += HOSTNAME; + msg += "/GameNet/GameList.php?game="; + msg += HttpRequest::EncodeParam(type); + msg += "&vers="; + msg += HttpRequest::EncodeParam(versionInfo); + msg += " HTTP/1.1\n\n"; + + HttpClient client(broker); + HttpRequest request(msg); + request.SetHeader("Host", HOSTNAME); + + HttpResponse* response = client.DoRequest(request); + + if (response && response->Status() == 200) { + result = true; + + Text name; + Text type; + Text addr; + int port; + Text pass; + Text vers; + char buff[1024]; + + const char* p = response->Content(); + + // skip size + while (*p && strncmp(p, "name:", 5)) + p++; + + while (*p) { + if (!strncmp(p, "name:", 5)) { + p += 5; + ZeroMemory(buff, sizeof(buff)); + char* d = buff; + while (*p && *p != '\n') *d++ = *p++; + if (*p) p++; + + name = buff; + } + else if (!strncmp(p, "addr:", 5)) { + p += 5; + ZeroMemory(buff, sizeof(buff)); + char* d = buff; + while (*p && *p != '\n') *d++ = *p++; + if (*p) p++; + + addr = buff; + } + else if (!strncmp(p, "port:", 5)) { + p += 5; + ZeroMemory(buff, sizeof(buff)); + char* d = buff; + while (*p && *p != '\n') *d++ = *p++; + if (*p) p++; + + sscanf_s(buff, "%d", &port); + } + else if (!strncmp(p, "pass:", 5)) { + p += 5; + ZeroMemory(buff, sizeof(buff)); + char* d = buff; + while (*p && *p != '\n') *d++ = *p++; + if (*p) p++; + + pass = buff; + } + else if (!strncmp(p, "game:", 5)) { + p += 5; + ZeroMemory(buff, sizeof(buff)); + char* d = buff; + while (*p && *p != '\n') *d++ = *p++; + if (*p) p++; + + type = buff; + type.setSensitive(false); + + if (type.contains("lan")) + type = "LAN"; + else + type = "Public"; + } + else if (!strncmp(p, "vers:", 5)) { + p += 5; + ZeroMemory(buff, sizeof(buff)); + char* d = buff; + while (*p && *p != '\n') *d++ = *p++; + if (*p) p++; + + vers = buff; + } + else if (!strncmp(p, "time:", 5)) { + while (*p && *p != '\n') p++; + if (*p) p++; + } + + else if (!strncmp(p, "###", 3)) { + NetServerInfo* server = new(__FILE__,__LINE__) NetServerInfo; + server->name = name; + server->hostname = addr; + server->type = type; + server->addr = NetAddr(addr, port); + server->port = port; + server->password = pass; + server->version = vers; + server->save = false; + + server_list.append(server); + + while (*p && strncmp(p, "name:", 5)) + p++; + } + else { + while (*p && *p != '\n') p++; + if (*p) p++; + } + } + } + else if (!broker_found) { + broker_available = false; + } + + delete response; + return result; +} |