Tribes2/T2-CPP
1
0
Fork 0
mirror of https://github.com/Ragora/T2-CPP.git synced 2026-01-19 18:14:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Functional experimental version

Browse source
This commit is contained in:
Robert MacGregor 2014-09-02 14:21:43 -04:00
parent 18cccdeb7f
commit f5b0ff6a07
3 changed files with 80 additions and 58 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
Mod Sources/TSExtension/TSExtension/include/DXConCmds.h
View file

@ -36,6 +36,9 @@ const char* conTCPObjectConnect(Linker::SimObject *obj, S32 argc, const char *ar
bool conTCPObjectSend(Linker::SimObject *obj, S32 argc, const char *argv[]);
bool conTCPObjectDisconnect(Linker::SimObject *obj, S32 argc, const char *argv[]);
// HTTPObject Commands ------------------------------
bool conHTTPObjectDoNothing(Linker::SimObject *obj, S32 argc, const char *argv[]);
// General Commands ---------------------------------
const char* conSprintf(Linker::SimObject *obj, S32 argc, const char* argv[]);
bool conTSExtensionUpdate(Linker::SimObject *obj, S32 argc, const char *argv[]);

116
Mod Sources/TSExtension/TSExtension/source/DXTCPObjects.cpp
View file

@ -5,6 +5,8 @@
#include <WinDNS.h>
#define TCPOBJECT_MAXCOUNT 256
#define TCPOBJECT_BUFFERSIZE 256
#define TCPOBJECT_SENDQUEUELENGTH 64 // Number of elements
static unsigned int TSEXTENSION_RUNNINGTCPOBJECTCOUNT = 0;
static DX::TCPObject *TSEXTENSION_RUNNINGTCPOBJECTS[TCPOBJECT_MAXCOUNT];
@ -27,7 +29,10 @@ typedef struct
unsigned int buffer_length;
char *buffer;
bool send_retry;
unsigned int send_queue_count;
char *send_queue[TCPOBJECT_SENDQUEUELENGTH];
bool is_connected;
SOCKET socket;
} ConnectionInformation;
@ -62,33 +67,17 @@ inline bool TCPObject_Disconnect(unsigned int identifier)
return true;
}
#define TCPOBJECT_BUFFERSIZE 256
enum TCPObjectEvent
{
TCPObjectEvent_FailedDNSLookup = 1,
TCPObjectEvent_FailedConnection = 2,
TCPObjectEvent_FailedConnectionNoPort = 3,
TCPObjectEvent_FailedSocketCreation = 4,
TCPObjectEvent_FailedRecv = 5,
TCPObjectEvent_NULL = 6, // Should be the first Good Identifier
TCPObjectEvent_GoodDNSLookup = 7,
TCPObjectEvent_GoodConnection = 8,
TCPObjectEvent_ReceivedData = 9,
};
const char* conTCPObjectConnect(Linker::SimObject *obj, S32 argc, const char *argv[])
{
DX::TCPObject *operand = new DX::TCPObject((unsigned int)obj);
DX::TCPObject *search_object = TCPObject_Find(operand->identifier);
if (search_object)
DX::TCPObject *operand = TCPObject_Find(atoi(argv[1]));
if (operand)
{
TCPObject_Disconnect(operand->identifier);
delete operand;
operand = search_object;
TCPObject_Disconnect(search_object->identifier);
return false;
}
operand = new DX::TCPObject((unsigned int)obj);
// Copy the hostname over
char *desired_hostname = (char*)malloc(strlen(argv[2]) + 1);
memcpy(desired_hostname, argv[2], strlen(argv[2]) + 1);
@ -98,8 +87,8 @@ const char* conTCPObjectConnect(Linker::SimObject *obj, S32 argc, const char *ar
connection->target_hostname = desired_hostname;
connection->buffer = 0x00;
connection->buffer_length = 0;
connection->send_retry = false;
connection->socket = 10;
connection->is_connected = false;
connection->socket = 0;
// Hack: Store the Ptr to our connection information struct in the old unused state value
operand->state = (unsigned int)connection;
@ -169,44 +158,51 @@ const char* conTCPObjectConnect(Linker::SimObject *obj, S32 argc, const char *ar
return "FAILED_SOCKET_CREATION";
}
// Stick us in the TCPObject array
TSEXTENSION_RUNNINGTCPOBJECTS[TSEXTENSION_RUNNINGTCPOBJECTCOUNT] = operand;
TSEXTENSION_RUNNINGTCPOBJECTCOUNT++;
// Attempt the Connection
if(connect(connection->socket, (SOCKADDR*)&target_host, sizeof(target_host)) != 0)
if(connect(connection->socket, (SOCKADDR*)&target_host, sizeof(target_host)) == SOCKET_ERROR)
{
Con::errorf(0, "Failed to connect!");
operand->TSCall("onConnectFailed", 0);
return "CANNOT_CONNECT";
}
else
{
// Set Blocking Mode
u_long imode = 1;
ioctlsocket(connection->socket, FIONBIO, &imode);
// Connected
connection->is_connected = true;
// Notify TS
operand->TSCall("onConnected", 0);
}
// Set Blocking Mode
u_long imode = 1;
ioctlsocket(connection->socket, FIONBIO, &imode);
// Stick us in the TCPObject array
TSEXTENSION_RUNNINGTCPOBJECTS[TSEXTENSION_RUNNINGTCPOBJECTCOUNT] = operand;
TSEXTENSION_RUNNINGTCPOBJECTCOUNT++;
return "unknown_error";
}
bool conTCPObjectSend(Linker::SimObject *obj, S32 argc, const char *argv[])
{
Con::errorf(0, "Should Send? - SimID %s", argv[1]);
if (!TCPObject_Find(atoi(argv[1])))
return false;
Con::errorf(0, "Queued Data");
DX::TCPObject operand((unsigned int)obj);
Con::errorf(0, "Should Send? - SimID %u", operand.identifier);
//if (!TCPObject_Find(operand.identifier))
// return false;
Con::errorf(0, "Sending");
ConnectionInformation *connection = (ConnectionInformation*)operand.state;
// Pause the thread as we're doing an recv in the main thread
if (!connection->is_connected)
Con::errorf(0, "Attempted to send before connected.");
if (send(connection->socket, argv[2], strlen(argv[2]), 0) == SOCKET_ERROR)
{
Con::errorf(0, "Failed to send: %u (Socket: %u, SimID: %u)", WSAGetLastError(), connection->socket, operand.identifier);
return false;
Con::errorf(0, "Unable to send data!");
}
return true;
@ -214,8 +210,7 @@ bool conTCPObjectSend(Linker::SimObject *obj, S32 argc, const char *argv[])
bool conTCPObjectDisconnect(Linker::SimObject *obj, S32 argc, const char *argv[])
{
DX::TCPObject operand((unsigned int)obj);
return TCPObject_Disconnect(operand.identifier);
return TCPObject_Disconnect(atoi(argv[1]));
}
bool conTSExtensionUpdate(Linker::SimObject *obj, S32 argc, const char *argv[])
@ -233,10 +228,6 @@ bool conTSExtensionUpdate(Linker::SimObject *obj, S32 argc, const char *argv[])
DX::TCPObject *current_connection = TSEXTENSION_RUNNINGTCPOBJECTS[iteration];
ConnectionInformation *connection_information = (ConnectionInformation*)current_connection->state;
// TODO: Kill the TCPObject
if (connection_information->socket == 0)
continue;
unsigned int data_length = recv(connection_information->socket, character_buffer, TCPOBJECT_BUFFERSIZE, 0);
int currentError = WSAGetLastError();
@ -256,13 +247,25 @@ bool conTSExtensionUpdate(Linker::SimObject *obj, S32 argc, const char *argv[])
if (connection_information->buffer[split_iteration] == '\n' || split_iteration == connection_information->buffer_length - 1)
{
unsigned int desired_length = (split_iteration - current_start);
char *current_line = (char*)malloc(desired_length + 1);
memset(current_line, 0x00, desired_length + 1);
memcpy(current_line, &connection_information->buffer[current_start], desired_length);
connection_information->buffer[connection_information->buffer_length - 1] = 0x00;
current_start = split_iteration + 1;
current_connection->TSCall("onLine", 1, current_line);
free(current_line);
if (desired_length == data_length)
current_connection->TSCall("onLine", 1, connection_information->buffer);
else
{
char *current_line = (char*)malloc(desired_length + 1);
memset(current_line, 0x00, desired_length + 1);
memcpy(current_line, &connection_information->buffer[current_start], desired_length);
current_line[desired_length + 1] = 0x00;
// Is it some newline?
if (strlen(current_line) == 1 && current_line[0] == 0xD) // Carriage Return
current_line[0] = 0x20; // Space
current_start = split_iteration + 1;
current_connection->TSCall("onLine", 1, current_line);
free(current_line);
}
}
closesocket(connection_information->socket);
@ -306,3 +309,8 @@ bool conTSExtensionUpdate(Linker::SimObject *obj, S32 argc, const char *argv[])
return true;
}
bool conHTTPObjectDoNothing(Linker::SimObject *obj, S32 argc, const char *argv[])
{
return true;
}

17
Mod Sources/TSExtension/TSExtension/source/dllmain.cpp
View file

@ -27,6 +27,10 @@ extern "C"
{
__declspec(dllexport) void ModInitialize(void)
{
// Init WSA
WSADATA wsadata;
WSAStartup(0x0202, &wsadata);
Con::addMethodB("Player", "isjumping", &conPlayerGetJumpingState,"Returns whether or not the player is jumping", 2, 2);
Con::addMethodB("Player", "isjetting", &conPlayerGetJettingState,"Returns whether or not the player is jetting", 2, 2);
Con::addMethodB("GameConnection", "setheat", &conGameConnectionSetHeatLevel,"Sets the heat level", 3, 3);
@ -39,9 +43,16 @@ extern "C"
Con::addMethodB("Projectile", "makeNerf", &conProjectileMakeNerf,"Makes the Projectile deal no damage", 2, 2);
// TCPObject
Con::addMethodS("TCPObject", "altConnect", &conTCPObjectConnect, "Connects to a remote server", 3, 3);
Con::addMethodB("TCPObject", "altSend", &conTCPObjectSend, "Sends data to the remote server", 3, 3);
Con::addMethodB("TCPObject", "altDisconnect", &conTCPObjectDisconnect, "Disconnects from the remote server", 2, 2);
Con::addMethodS("TCPObject", "connect", &conTCPObjectConnect, "Connects to a remote server", 3, 3);
Con::addMethodB("TCPObject", "send", &conTCPObjectSend, "Sends data to the remote server", 3, 3);
Con::addMethodB("TCPObject", "disconnect", &conTCPObjectDisconnect, "Disconnects from the remote server", 2, 2);
// HTTPObject
Con::addMethodB("HTTPObject", "get", &conHTTPObjectDoNothing, "Disconnects from the remote server", 6, 6);
Con::addMethodB("HTTPObject", "post", &conHTTPObjectDoNothing, "Disconnects from the remote server", 6, 6);
Con::addMethodB("HTTPObject", "send", &conHTTPObjectDoNothing, "Disconnects from the remote server", 6, 6);
Con::addMethodB("HTTPObject", "connect", &conHTTPObjectDoNothing, "Disconnects from the remote server", 6, 6);
Con::addMethodB("HTTPObject", "listen", &conHTTPObjectDoNothing, "Disconnects from the remote server", 6, 6);
// General
Con::addMethodS(NULL, "sprintf", &conSprintf,"Formats a string. See the C sprintf.", 2, 20);