source: Daodan/MSVC/Flatline_Client.c@ 585

Last change on this file since 585 was 585, checked in by gumby, 14 years ago

Getting there. Throws still rarely crash and classes aren't synced.
File size: 5.7 KB
Line 
1#include "Flatline.h"
2#include "Flatline_Client.h"
3
4int client_slot = 0;
5RGBA green = {0, 0xFF, 0, 0};
6RGBA red = {0, 0, 0xFF, 0};
7RGBA grey = {0x80,0x80,0x80,0x80};
8
9
10int FLcEventHandler( int eventIndex, int args[] )
11{
12 switch(eventIndex)
13 {
14 case(EV_DISCONNECT):
15 FLrPlayerDisconnect( args[0] );
16 break;
17 case(EV_KILLED):
18 ONrCharacter_SetHitPoints( PlayerList[args[0]]->Chr, 0);
19 case(EV_DOOR_OPEN):
20 OBJrDoor_ForceOpen( args[0] );
21 break;
22 case(EV_CONSOLE_USE):
23 OBJrConsole_OnActivate( OBJrConsole_GetByID(args[0]), PlayerList[args[1]]->Chr );
24 break;
25 default:
26 break;
27 }
28 return 0;
29}
30
31
32bool FLrClient_Run(flatline_packet* packet)
33{
34
35 char data[1400];
36 uint16_t len;
37 int j;
38 int sent_bytes;
39 client_connected = 0;
40
41
42 //starts the connection
43 DDrConsole_PrintF("Connecting to server %s on socket %i", inet_ntoa(address.sin_addr), client_sock);
44 sent_bytes = NetUDPSocket_Send(client_sock, (sockaddr*)&address, (char*)packet, 255);
45 if(sent_bytes == SOCKET_ERROR) {
46 NetCatchError();
47 }
48 //loops once per second waiting for a reply.
49 for(j = 0; j < CONNECTION_TIMEOUT; j++) {
50 while(NetUDPSocket_Recieve(client_sock, (sockaddr_storage *) &client_address, data, &len)){
51 packet = (flatline_packet*)data;
52 if(packet->id == CONNECT_REPLY) {
53 if(packet->connect_reply.goodtogo){
54
55 client_connected = 1;
56
57 client_slot = ((connect_reply*)packet->data)->player_slot;
58
59 PlayerList[client_slot] = Players+client_slot;
60 PlayerList[client_slot]->Chr = ONgGameState->PlayerCharacter;
61
62 DDrConsole_PrintColored("Connection successful!",0,green, grey);
63
64 sprintf_s( PlayerList[client_slot]->name, 32, "%s", player_name );
65
66 //disable local input.
67 DDrPatch_NOOP(0x004FA929, 5 + 6 + 5);
68
69 //Disable local turning
70 //DDrPatch_NOOP(0x004F7EA8, 2);
71 //DDrPatch_Byte( 0x004F7EB1 , 0xE9);
72 //DDrPatch_MakeJump( 0x004F7EB1, 0x004F8030 );
73
74
75 DDrPatch_Byte(0x04ED6FB, 0xEB);
76
77 //DDrConsole_PrintF("Slot %i", ((connect_reply*)packet)->player_slot);
78 //DDrPatch_NOOP(0x43B23,0x10);
79 //DDrPatch_NOOP(0x4EC248,(0x5A-0x48));
80 //DDrPatch_NOOP(0x4EC861, 6);
81 break;
82 }
83 else {
84 DDrConsole_PrintF("Connection rejected: %s", ((connect_reply*)packet->data)->message);
85 return false;
86 break;
87 }
88 }
89 }
90 if(client_connected) break;
91 DDrConsole_PrintF("Connection timing out in %i seconds...", CONNECTION_TIMEOUT - j);
92 Sleep(1000);
93 }
94 //the client timed out without recieving an error message.
95 if(!client_connected) {
96 DDrConsole_PrintColored("Connection timed out.",0,red, grey);
97 return false;
98 }
99
100 return true;
101}
102
103
104void FLrClient_GetPackets()
105{
106 flatline_packet packet;
107 uint16_t len;
108 //#define SPAM_INPUT
109#ifdef SPAM_INPUT
110 struct timeval lasttime;
111 struct timeval thistime;
112 gettimeofday(&lasttime, 0);
113#endif
114
115
116 while(NetUDPSocket_Recieve(client_sock, (sockaddr_storage *) &client_address, &packet, &len)) {
117 //packet = (flatline_packet*)data;
118 //DDrConsole_PrintF("Data recieved, length %i, type %i", len, ((flatline_packet*)data)->id);
119 switch(packet.id) {
120 case MESSAGE:
121 COrMessage_Print(packet.data, "chat", 0);
122 break;
123 case CHANGE_NAME:
124 if(PlayerList[(char)packet.data[0]])
125 {
126 char message_buffer[1024];
127 sprintf(message_buffer,"%s changed their name to %s", PlayerList[(char)packet.data[0]]->name, packet.data + 1);
128 COrMessage_Print(message_buffer, "name_change", 0);
129
130 sprintf_s(PlayerList[packet.data[0]]->name, 32, "%s", packet.data + 1);
131
132 }
133 break;
134 case CONNECT_SEND:
135 ;if(1) {
136 flatline_packet connect_recv;
137 memcpy(&connect_recv.connect_reply.message,"This isn't a server!", sizeof("This isn't a server!"));
138 NetUDPSocket_Send(client_sock, (sockaddr *) &address, (char*)&connect_recv, sizeof(bool) + FLATLINE_HEADER + sizeof("This isn't a server!"));
139 }
140 case CONNECT_REPLY:
141 break; //extra packet or something.
142 case NEW_PLAYER:
143 ;if(1) { //haxhaxhax
144 CharacterObject* Char = &(packet.new_player.Character);
145 uint32_t chr_index = 0;
146 Character* PC;
147 DDrConsole_PrintF("%i | %i", packet.new_player.Playernumber ,client_slot);
148 //Char->OSD.Options = 0;
149 if(packet.new_player.Playernumber == client_slot) {
150 PlayerList[packet.new_player.Playernumber] = &Players[0];
151 PC = (ONgGameState->PlayerCharacter);
152 Players[0].Chr = PC;
153
154 }
155 else {
156 ONrGameState_NewCharacter(Char, NULL, NULL, &chr_index);
157 ONgGameState->CharacterStorage[chr_index].charType = 0;
158 PlayerList[packet.new_player.Playernumber] = &Players[chr_index];
159 Players[chr_index].Chr = &(ONgGameState->CharacterStorage[chr_index]);
160 Players[chr_index].Chr->Flags &= 0xFFBFFFFF;
161 Players[chr_index].spawnnumber = chr_index;
162 DDrConsole_PrintF("Spawning player %s, class %s, slot %i", ((new_player*)(packet.data))->Character.OSD.Name, ((new_player*)(packet.data))->Character.OSD.Class,chr_index) ;
163 sprintf_s(Players[chr_index].name, 32, "%s", ((new_player*)(packet.data))->Character.OSD.Name);
164 }
165 //Players[((new_player*)(packet.data))->Playernumber].spawnnumber = ONrGameState_NewCharacter(&(((new_player*)(packet.data))->Character), NULL, NULL, 0);
166 break;
167 }
168
169 case FLATLINE_EVENT:
170 FLcEventHandler( packet.flatline_event.event_index, packet.flatline_event.intArray );
171 break;
172 case PK_PING:
173 packet.id = PK_PONG;
174 NetUDPSocket_Send(client_sock, (sockaddr *) &address, (char*)&packet, FLATLINE_HEADER + 4);
175 break;
176 case PK_PLAYER_DATA:
177 FLcReadPlayerData( &packet, len );
178 break;
179 default:
180 DDrConsole_PrintF("Warning, recieved badly formed packet!");
181 break;
182 }
183 }
184}
185
Note: See TracBrowser for help on using the repository browser.