source: Daodan/MSVC/Flatline_Server.c@ 587

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

stuff
File size: 11.8 KB
Line 
1#include "Flatline.h"
2#include "Flatline_Server.h"
3#include <Windows.h>
4
5//I hereby apologize for the uglyness of the below code.
6//It was never intended to be "final" code, much less shared with anyone
7
8int total_players = 0;
9uint16_t max_connections = MAX_CONNECTIONS;
10
11player_info* FLrServer_AddPlayer(int ip, char* name, bool is_server, bool is_bot) {
12 flatline_packet new_char = {0};
13 CharacterObject* Char;
14 uint32_t player_slot = 0;
15 int playerlist_slot = 0;
16
17 if(is_server || total_players < max_connections) {
18
19 int i = 0;
20 int k = 0;
21
22 //Skip for the host
23 if(!is_server)
24 {
25 char* zero = strchr(name, 0);
26 playerlist_slot = FLr_FindEmptyListSlot();
27
28 total_players++;
29
30 //checks to see if a name exists or not
31 //then appends [#] on the end of it if it does
32 //May be buggy, come back to this.
33 if(zero - name > 28) zero = name + 28;
34 for(i = 0; i < max_connections; i++) {
35 if(PlayerList[i] != 0 && !strcmp(name, PlayerList[i]->name)) {
36 k++;
37 sprintf(zero, "[%i]", k);
38 i = 0;
39 }
40 }
41 }
42
43 new_char.new_player.Playernumber = playerlist_slot;
44
45 //Set up a new Character structure to be spawned as the new player.
46 //Can this code be surrounded with if(!is_server){}?
47 Char = &new_char.new_player.Character;
48 memset(Char, 0, sizeof(CharacterObject));
49 Char->Header.Type = 'CHAR';
50 sprintf(Char->OSD.Name,"%s",name);
51 sprintf(Char->OSD.Class, "%s", "konoko_generic");
52 if(is_bot) {
53 Char->OSD.MeleeID = 22;
54 Char->OSD.JobID = 1;
55 Char->OSD.MinimalAlertLevel = 4;
56 Char->OSD.InvestigatingAlertLevel = 4;
57 Char->OSD.InitialAlertLevel = 4;
58 Char->OSD.StartJobAlertLevel = 4;
59 }
60 else if( !is_server )
61 {
62 Char->Header.Position.X = PlayerList[0]->Chr->Position.X;
63 Char->Header.Position.Y = PlayerList[0]->Chr->Position.Y;
64 Char->Header.Position.Z = PlayerList[0]->Chr->Position.Z;
65 }
66
67 //TMrInstance_GetDataPtr('ONCC', "striker_easy_1", PlayerList[playerlist_slot]->Chr->ONCC);
68
69 new_char.id = NEW_PLAYER;
70 if(!is_server) {
71 ONrGameState_NewCharacter(Char, NULL, NULL, &(player_slot));
72 //move this to a set up characters function...
73 if(!is_bot) ONgGameState->CharacterStorage[player_slot].charType = 0;
74
75 PlayerList[playerlist_slot] = Players+player_slot;
76 PlayerList[playerlist_slot]->spawnnumber = player_slot;
77 PlayerList[playerlist_slot]->Chr = &(ONgGameState->CharacterStorage)[player_slot];
78 //PlayerList[playerlist_slot]->Chr->Flags = chr_dontaim | chr_unkillable; //&= 0xFFBFFFFF; //WTF
79 if(!is_bot) PlayerList[playerlist_slot]->Chr->Flags &= 0xFFBFFFFF; //WTF, magic number.
80 sprintf_s(PlayerList[playerlist_slot]->Chr->Name, 32, "%s", name);
81 sprintf_s(PlayerList[playerlist_slot]->name, 32, "%s", name);
82 UDPServer_SendToAll( (char*)&new_char, sizeof(new_player) + FLATLINE_HEADER );
83
84 }
85 else {
86 PlayerList[0] = Players;
87 PlayerList[0]->Chr = (Character *)(((GameState * )(ONgGameState))->CharacterStorage);
88 }
89
90 //add player to list
91
92 PlayerList[playerlist_slot]->ip = ip;
93 PlayerList[playerlist_slot]->list_slot = playerlist_slot;
94 sprintf_s(PlayerList[playerlist_slot]->name, 32, "%s", name);
95
96 MultiplayerStatus.PleaseUpdateAllPlayers = 1;
97
98 return &Players[player_slot];
99 }
100 return (player_info*)(-1);
101}
102
103void FLrServer_Initialize(){
104 FLrServer_AddPlayer(inet_addr("127.0.0.1"), "host", 1, 0);
105}
106
107//UDPServer_SendToAll
108//Sends a packet to all the clients currently connected.
109//Returns the number of players sent to.
110int UDPServer_SendToAll(void* packet, int size) {
111 int j;
112 int players = 0;
113 sockaddr_in address;
114 memset(&address, 0, sizeof(sockaddr_in));
115 address.sin_family = AF_INET;
116 address.sin_addr.s_addr = htonl(INADDR_ANY);
117 address.sin_port = htons(27777);
118 for(j = 0; j < max_connections; j++) {
119 if (PlayerList[j] != 0 && PlayerList[j]->ip && (PlayerList[j]->ip != inet_addr("127.0.0.1"))) {
120 int sent_bytes;
121 address.sin_addr.s_addr = htonl(PlayerList[j]->ip);//*((struct in_addr*)(int*)&(Players[j].ip));
122 sent_bytes = NetUDPServer_Send((sockaddr *) &address, (char*)packet, size);
123 if(sent_bytes == SOCKET_ERROR) NetCatchError();
124 else players++;
125 }
126 }
127 return players;
128}
129
130//FLsPublic_Event
131//Sends an event (door opening, player disconnecting, etc) to all players
132//Always make sure you send a pointer to this, even if it is just one arg. ;).
133//If it is void the double door in State crashes. Probably stack corruption,
134//I'm not sure exactly why.
135//So we return 0 to stop that.
136int FLsPublic_Event( const unsigned int eventIndex, const int * args )
137{
138 int numArgs = FLrEvent_GetNumArgs( eventIndex );
139 int ret;
140 flatline_packet eventPacket = {0};
141 eventPacket.id = FLATLINE_EVENT;
142 eventPacket.flatline_event.event_index = eventIndex;
143 ret = memcpy( eventPacket.flatline_event.intArray, args, sizeof(int) * numArgs );
144 ret = UDPServer_SendToAll( &eventPacket, sizeof(int) * (numArgs + 1) + FLATLINE_HEADER );
145 return 0;
146}
147
148void FLsPingAll()
149{
150 flatline_packet ping;
151 ping.id = PK_PING;
152 lastPingTime = ping.ping = GetTickCount();
153 UDPServer_SendToAll(&ping, FLATLINE_HEADER + 4);
154}
155
156void FLsUpdateName( int index, char* name )
157{
158 flatline_packet message;
159 int message_size;
160
161 char message_buffer[1024];
162 sprintf(message_buffer,"%s changed their name to %s", PlayerList[index]->name, name);
163 COrMessage_Print(message_buffer, "name_change", 0);
164
165 sprintf_s(PlayerList[index]->name, 32, "%s", name);
166 sprintf_s(PlayerList[index]->Chr->Name, 32, "%s", name);
167
168 message.id = CHANGE_NAME;
169 message.data[0] = index;
170 message_size = sprintf(message.data + 1, "%s", name);
171
172 UDPServer_SendToAll(&message, message_size + 2 + FLATLINE_HEADER);
173}
174void FLsSend_BINACHAR( short j, sockaddr* socket )
175{
176
177 ActiveCharacter* AC = ONrGetActiveCharacter( PlayerList[j]->Chr);
178 flatline_packet new_char = {0};
179 CharacterObject* Char = &new_char.new_player.Character;
180
181 new_char.id = NEW_PLAYER;
182 new_char.new_player.Playernumber = j;
183
184// memset(Char, 0, sizeof(CharacterObject));
185 Char->Header.Type = 'CHAR';
186 Char->OSD.Options = chr_dontaim;
187
188 sprintf(Char->OSD.Name,"%s",PlayerList[j]->name);
189
190 sprintf(Char->OSD.Class, "%s", TMrInstance_GetInstanceName(PlayerList[j]->Chr->ONCC));
191
192 if(AC)
193 {
194 Char->Header.Position = AC->PhyContext->Position;
195 }
196 else
197 {
198 Char->Header.Position.X = 0;
199 Char->Header.Position.Y = 0;
200 Char->Header.Position.Z = 0;
201 }
202
203 NetTCPServer_Send(socket, (char*)&new_char, sizeof(new_player) + FLATLINE_HEADER );
204}
205bool FLrServer_PacketCallback(char* data, int datalen, int from)
206{
207 int i, j;
208 bool found_player = 0;
209 flatline_packet * packet = (flatline_packet*)data;
210 static int recieved = 0;
211 sockaddr_in sender;
212 sender.sin_family = AF_INET;
213 sender.sin_port = htons(27777);
214 sender.sin_addr = *((struct in_addr*)(int*)&from);
215
216
217 //packet->data[datalen] = '\0';
218
219 //DDrConsole_PrintF("Packet \r%d recieved from %i", ++recieved, from);
220
221
222
223 //if data[0] != CONNECT_SEND, search in playerlist for ip address
224
225
226
227
228 switch(packet->id) {
229 flatline_packet connect_recv;
230 player_info * playah;
231 //rewrite this when we get TCP support.
232 //rewrite this before we get TCP support*
233 //the way of seeing if there is room for players sucks.
234 case CONNECT_SEND:
235 ;
236
237 connect_recv.id = CONNECT_REPLY;
238
239 //if(Players[i].ip == sender.sin_addr.S_un.S_addr) break; //needs to send an error message
240 sender.sin_addr.S_un.S_addr = htonl(sender.sin_addr.S_un.S_addr);
241 playah = FLrServer_AddPlayer(from,packet->connect_send.name, 0, 0);
242 DDrConsole_PrintF("%s connected from %s", packet->connect_send.name, inet_ntoa(sender.sin_addr ) );
243 if(!((int)playah > -5 && (int)playah <= 0)) {
244
245 connect_recv.connect_reply.goodtogo = 1;
246 connect_recv.connect_reply.player_slot = playah->list_slot;
247 //DDrConsole_PrintF("Slot: %i", playah->list_slot);
248
249 //sending this several times to make sure it gets through. Really need to make up some form of packet tracking.
250 NetUDPServer_Send((sockaddr *) &sender, (char*)&connect_recv, sizeof(connect_reply) + FLATLINE_HEADER);
251 NetUDPServer_Send((sockaddr *) &sender, (char*)&connect_recv, sizeof(connect_reply) + FLATLINE_HEADER);
252 NetUDPServer_Send((sockaddr *) &sender, (char*)&connect_recv, sizeof(connect_reply) + FLATLINE_HEADER);
253 NetUDPServer_Send((sockaddr *) &sender, (char*)&connect_recv, sizeof(connect_reply) + FLATLINE_HEADER);
254 NetUDPServer_Send((sockaddr *) &sender, (char*)&connect_recv, sizeof(connect_reply) + FLATLINE_HEADER);
255 Sleep(100);
256
257
258
259 for(j = 0; j < max_connections; j++) {
260 if(PlayerList[j] != 0) {
261 FLsSend_BINACHAR( j, (sockaddr *)&sender);
262 }
263
264 }
265 }
266 else {
267 //fix the error messages...
268 DDrConsole_PrintF("Server is full. :(");
269 connect_recv.connect_reply.goodtogo = 0;
270 sender.sin_addr.S_un.S_addr = htonl(sender.sin_addr.S_un.S_addr);
271 memcpy(&connect_recv.connect_reply.message,"Server is full.", sizeof("Server is full."));
272 NetTCPServer_Send((sockaddr *) &sender, (char*)&connect_recv, sizeof(bool)*2 + FLATLINE_HEADER + sizeof("Server is full."));
273
274 }
275
276
277 break;
278 case CONNECT_REPLY:
279 break; //do nothing...a server shouldn't recieve this type of packet.
280 case MESSAGE:
281 for(i = 0; i < MAX_PLAYERS; i++) {
282 //DDrConsole_PrintF("%i : %i | %s : %s", from, Players[i].ip, inet_ntoa(*(struct in_addr*)&from), inet_ntoa(*(struct in_addr*)&(Players[i].ip)));
283 if(Players[i].ip == sender.sin_addr.S_un.S_addr) {
284 found_player = 1;
285 break;
286 }
287 }
288 if(found_player == 0) break;
289 else {
290 char message_buffer[512] = {0};
291 flatline_packet message;
292 int message_size;
293 data[datalen] = 0;
294
295 DDrConsole_PrintF("%s: %s", Players[i].name, packet->data);
296 sprintf(message_buffer, "%s: %s", Players[i].name, packet->data);
297
298 message.id = MESSAGE;
299 message_size = sprintf(message.data, "%s", message_buffer);
300 COrMessage_Print(message_buffer, "chat", 0);
301 UDPServer_SendToAll(&message, message_size + 1 + FLATLINE_HEADER);
302 break;
303 }
304 case CHANGE_NAME:
305 for(i = 0; i < MAX_PLAYERS; i++) {
306 if(PlayerList[i] && PlayerList[i]->ip == sender.sin_addr.S_un.S_addr) {
307 found_player = 1;
308 break;
309 }
310 }
311 if(found_player == 0) break;
312 else {
313 bool name_exists = 0;
314 for(j = 0; j < MAX_PLAYERS; j++) {
315 if(PlayerList[j] && !strcmp(packet->data, PlayerList[j]->name)) {
316 name_exists = 1;
317 break;
318 }
319 }
320 if(!name_exists) {
321 FLsUpdateName( i, packet->data );
322 }
323 break;
324 }
325 case PLAYER_INPUT:
326
327 for(i = 0; i < max_connections; i++) {
328 if(PlayerList[i] != 0 && PlayerList[i]->ip == sender.sin_addr.S_un.S_addr) {
329 found_player = 1;
330 break;
331 }
332 }
333
334 if(found_player == 0) break;
335 else {
336 input_struct * packet_input = &packet->input_struct;
337
338
339 PlayerList[i]->InputFromClient.Actions1 = packet_input->Actions1;
340 PlayerList[i]->InputFromClient.Actions2 = packet_input->Actions2;
341 PlayerList[i]->InputFromClient.MouseDeltaX = packet_input->MouseDeltaX;
342 PlayerList[i]->InputFromClient.MouseDeltaY = packet_input->MouseDeltaY;
343 PlayerList[i]->FacingFromClient = packet_input->DesiredFacing;
344 //PlayerList[i]->LastInputTime = packet_input->Time;
345
346 break;
347 }
348 case PK_PONG:
349 for(i = 0; i < max_connections; i++) {
350 if(PlayerList[i] != 0 && PlayerList[i]->ip == sender.sin_addr.S_un.S_addr) {
351 found_player = 1;
352 break;
353 }
354 }
355
356 if(found_player == 0) break;
357 if(packet->ping != lastPingTime)
358 {
359 PlayerList[i]->Ping = 999;
360 }
361 else
362 {
363 PlayerList[i]->Ping = GetTickCount() - packet->ping;
364 }
365 break;
366 case PK_MISSING_PLAYER:
367 if(packet->integer < MAX_PLAYERS)
368 {
369 FLsSend_BINACHAR( packet->integer, &sender);
370 }
371 break;
372 default:
373 DDrConsole_PrintF("Warning, recieved badly formed packet!");
374 break;
375 }
376 return true;
377}
Note: See TracBrowser for help on using the repository browser.