]> jfr.im git - irc/gameservirc.git/blob - gameserv/tcpclient.cpp
updated the TODO
[irc/gameservirc.git] / gameserv / tcpclient.cpp
1 /*
2 * This file is provided for use with the unix-socket-faq. It is public
3 * domain, and may be copied freely. There is no copyright on it. The
4 * original work was by Vic Metcalfe (vic@brutus.tlug.org), and any
5 * modifications made to that work were made with the understanding that
6 * the finished work would be in the public domain.
7 *
8 * If you have found a bug, please pass it on to me at the above address
9 * acknowledging that there will be no copyright on your work.
10 *
11 * The most recent version of this file, and the unix-socket-faq can be
12 * found at http://www.interlog.com/~vic/sock-faq/.
13 */
14
15 #include "sockhelp.h"
16 #include "options.h"
17 #include "list.h"
18 #include "aClient.h"
19 #include "extern.h"
20 #include "flags.h"
21 #include <stdio.h>
22 #include <unistd.h>
23 #include <string.h>
24 #include <fstream>
25 #include <stdlib.h>
26 #include <fcntl.h>
27 #include <signal.h>
28 //#include <sys/types.h>
29 //#include <sys/wait.h>
30 //#include <errno.h>
31
32
33
34 using std::ofstream;
35 using std::ifstream;
36 using std::cerr;
37 using std::endl;
38
39 char *PACKAGE = "GameServ";
40 char *VERSION = "1.2.1 +devel";
41
42 int sock;
43 int day;
44
45 List<aClient> clients[U_TABLE_SIZE];
46
47 void save_day();
48 void load_day();
49 void prettyIntro();
50 void check_idles();
51
52 // Make this a daemon
53 int daemon(int nochdir, int noclose);
54
55 // Close all file descriptors from >= fd
56 void closeall(int fd);
57
58 int main(int argc, char *argv[])
59 {
60 char buffer[1024], buf[1024];
61 int connected;
62 long lastidlecheck;
63 char *cmd, *source = NULL, *conf = "gameserv.conf";
64 srand(time(NULL));
65
66 /*
67 * This needs to be fixed to work for any number of arguments in any
68 * order
69 *
70 */
71 if (argc > 1)
72 {
73 if ( argc > 2 || stricmp(argv[1], "--help") == 0)
74 {
75 cout << "Usage: gameserv [options] [configfile]" << endl;
76 cout << "Options:" << endl;
77 cout << "--help Displays this help dialogue" << endl;
78 return 1;
79 }
80 conf = new char[strlen(argv[1])];
81 strcpy(conf, argv[1]);
82 }
83
84 prettyIntro();
85
86 if (load_config_file(conf))
87 {
88 cout << "Config file loaded ok...\n"
89 << "Turning into a daemon" << endl;
90 }
91 else
92 exit(2);
93
94 // Turn into a daemon
95 if (daemon(1,0) < 0)
96 {
97 perror("Could not turn into a daemon");
98 exit(3);
99 }
100 init_masters();
101 load_gs_dbase();
102
103 if (load_monsters() == false)
104 goto end;
105
106 shuttingdown = false;
107
108 char ignoreservers[32][256];
109 char *currentserver;
110 currentserver = strtok(ignoreserverslist, " ");
111 for (int server = 0; server < 32 && currentserver != NULL; server++)
112 {
113 strncpy(ignoreservers[server], currentserver, 255);
114 log("Placing %s on the server ignore list", currentserver);
115 currentserver = strtok(NULL, " ");
116 }
117
118 strcpy(boss.name, "Red Dragon");
119 strcpy(boss.weapon, "Breath of Unholy Fire");
120 boss.strength = 6667;
121 boss.gold = 2000000000;
122 boss.exp = 2000000000;
123 strcpy(boss.death, "You finally snuff out the deadly murderous "\
124 "dragon's dark flames. You have freed the land of its terror "\
125 "filled reign from above!");
126
127
128 // This loop will retry the connection 3 times
129 for (int retry = 0; retry < 3 && !shuttingdown; retry++)
130 {
131 connected = 1;
132 load_day();
133
134
135 long int loadtime = time(NULL);
136 long int currentTime;
137 long int oldTime = loadtime;
138
139 lastidlecheck = loadtime;
140
141 #ifdef DEBUGMODE
142 log("Setting primary Idle Check timestamp: %ld", lastidlecheck);
143 #endif
144 bool loaded = false;
145
146 ignore_pipe();
147 sock = make_connection(remoteport, SOCK_STREAM, remoteserver);
148 if (sock == -1) {
149 fprintf(stderr,"make_connection failed.\n");
150 unload_config_file();
151 return -1;
152 }
153 log("%S socket connected.");
154
155 #ifdef UNREAL
156 raw("PROTOCTL NICKv2 VHP");
157 raw("PASS :%s", remotepass);
158 raw("SERVER %s 1 :%s", servername, servername);
159 raw("NICK %S 1 %d %S %s %s %d +wghraAxNt %s :%s v%s", time(NULL), gshost,
160 servername, time(NULL), gshost, PACKAGE, VERSION);
161 raw(":%S JOIN %s", c_Forest);
162 raw(":%S MODE %s +tn", c_Forest);
163 #elif defined(BAHAMUT)
164 raw("PASS %s :TS", remotepass);
165 raw("SERVER %s 1 :%s", servername, servername);
166 raw("NICK %S 1 %d +w %s %s %s 0 :GameServ", time(NULL), gsident, gshost,
167 servername);
168 raw(":%s SJOIN %d %d %s +nt :@%S", servername, time(NULL), time(NULL), c_Forest);
169 #elif defined(HYBRID)
170 raw("PASS %s :TS", remotepass);
171 raw("SERVER %s 1 :%s", servername, servername);
172 raw("NICK %S 1 %d +w %s %s %s :GameServ", time(NULL), gsident, gshost,
173 servername);
174 raw(":%s SJOIN %ld %s +nt :@%S", servername, time(NULL), c_Forest);
175 #elif defined(P10)
176 // Server numeric is: [] <-- must be unique
177 raw("PASS :%s", remotepass);
178 raw("SERVER %s 1 %d %d P10 []AAF :%s", servername, time(NULL), time(NULL), servername);
179 raw("[] N %S 1 %d %s %s DAqAoB %s :%S", time(NULL), gsident, gshost, gsnum);
180 raw("[] B %s %d +tn %s:o", c_Forest, time(NULL) - 864000, gsnum);
181 #endif
182
183 #if defined(P10)
184 raw("%s T %s :%s", gsnum, c_Forest, c_ForestTopic);
185 raw("[] EB"); // End burst
186 #else
187 #ifndef HYBRID
188 raw(":%S MODE %s +o %S", c_Forest);
189 #endif
190 raw(":%S TOPIC %s :%s", c_Forest, c_ForestTopic);
191 #endif
192
193 sock_gets(sock,buffer,sizeof(buffer)-1); /* -1 added thanks to
194 David Duchene <dave@ltd.com> for pointing out the possible
195 buffer overflow resulting from the linefeed added below. */
196
197
198 #ifdef DEBUGMODE
199 log("Server: %s",buffer);
200 #endif
201
202 while (connected) {
203 if (sock_gets(sock,buffer,sizeof(buffer)) == -1) {
204 connected = 0;
205 }
206 strcpy(buf, buffer);
207
208 #if !defined(P10)
209 if (buffer[0] == ':')
210 {
211 source = strtok(buf, " ");
212 cmd = strtok(NULL, " ");
213 }
214 else
215 cmd = strtok(buf, " ");
216 #else
217 source = strtok(buf, " ");
218 cmd = strtok(NULL, " ");
219 #endif
220
221 #ifdef DEBUGMODE
222 log("Server: %s", buffer);
223 #endif
224
225 // Wait N seconds then we're loaded.
226 if (!loaded)
227 {
228 if (time(NULL) >= welcomedelay + loadtime)
229 {
230 loaded = true;
231 retry = 0; // Start the reconnection cycle over
232 }
233 }
234 else
235 {
236 long TIME = time(NULL);
237 if (TIME - lastidlecheck >= idlecheckperiod)
238 {
239 check_idles();
240 lastidlecheck = TIME;
241 }
242 }
243
244 // Save the player data every updateperiod seconds
245 currentTime = time(NULL);
246 if (currentTime - oldTime >= updateperiod)
247 {
248 oldTime = currentTime;
249 log("Saving to %s", playerdata);
250 save_gs_dbase();
251 }
252
253
254 #if !defined(P10)
255 if (stricmp(cmd, "PING") == 0) {
256 char *timestamp;
257 timestamp = strtok(NULL, "");
258 raw("PONG %s", timestamp);
259 #else
260 if (stricmp(cmd, "G") == 0) {
261 char *timestamp;
262 timestamp = strtok(NULL, " ");
263 raw("[] Z [] %s 0 %s", timestamp + 1, timestamp);
264 #endif
265 #ifdef P10
266 } else if (stricmp(cmd, "EB") == 0) {
267 raw("[] EA");
268 #endif
269 } else if (stricmp(cmd, "VERSION") == 0) {
270 char *server;
271 server = strtok(NULL, " ");
272 server++;
273 raw(":%s 351 %s %s_%s. %s", servername, source+1, PACKAGE, VERSION, servername);
274 #if !defined(P10)
275 } else if (strncmp(cmd, "NICK", 4) == 0) {
276 if (buffer[0] == ':')
277 {
278 aClient *tempPtr;
279 if ((tempPtr = find((source + 1))))
280 {
281 char *nick;
282 unsigned long oldhv, newhv;
283 nick = strtok(NULL, " ");
284 oldhv = iHASH((unsigned char *) tempPtr->getNick());
285 newhv = iHASH((unsigned char *) nick);
286 tempPtr->setNick(nick);
287 clients[oldhv].remove(tempPtr);
288 clients[newhv].insertAtBack(tempPtr);
289 }
290 }
291 else
292 {
293 char *nick;
294 #else
295 } else if (stricmp(cmd, "N") == 0 && strlen(source) == 2) {
296 {
297 char *nick, *realnick;
298 realnick = strtok(NULL, " ");
299
300 for (int x = 0; x < 5; x++)
301 nick = strtok(NULL, " ");
302
303 if (nick[0] == '+')
304 {
305 #ifdef DEBUGMODE
306 log ("aClient has modes");
307 #endif
308
309 // Searching for the +r mode (extra parameter)
310 for (unsigned int count = 1; count < strlen(nick); count++)
311 {
312 if (nick[count] == 'r')
313 {
314 nick = strtok(NULL, " ");
315 break;
316 }
317 }
318 nick = strtok(NULL, " ");
319 }
320 #endif
321 aClient *newuser, *temp;
322
323 nick = strtok(NULL, " ");
324
325 #ifdef P10
326 newuser = new aClient(nick, realnick);
327 #else
328 newuser = new aClient(nick);
329 #endif
330
331
332 if (loaded)
333 #ifdef P10
334 notice(s_GameServ, nick, welcomemsg, realnick);
335 #else
336 notice(s_GameServ, nick, welcomemsg, nick);
337 #endif
338 #ifdef P10
339 unsigned long hv = sHASH((unsigned char *) nick)
340 #else
341 unsigned long hv = iHASH((unsigned char *) nick);
342 #endif
343
344 temp = clients[hv].insertAtBack(newuser);
345
346 #ifdef HYBRID
347 char *nickserver;
348 strtok(NULL, " ");
349 strtok(NULL, " ");
350 nickserver = strtok(NULL, " ");
351 if (nickserver[0] == '+')
352 strtok(NULL, " ");
353 strtok(NULL, " ");
354
355 nickserver = strtok(NULL, " ");
356 for (int x = 0; x < 32; x++)
357 {
358 if (stricmp(ignoreservers[x], nickserver) == 0)
359 {
360 setIgnore(temp);
361 break;
362 }
363 }
364 #endif
365 delete newuser;
366 }
367 #if defined(P10)
368 } else if (stricmp(cmd, "Q") == 0) {
369 // unsigned long hv = sHASH((unsigned char *) source);
370 #else
371 } else if (stricmp(cmd, "QUIT") == 0) {
372 // unsigned long hv = iHASH((unsigned char *) source);
373 #endif
374 aClient *quitter;
375 char z = source[0];
376
377 if (z == ':')
378 source++;
379
380 if (!(quitter = find(source)))
381 {
382 log("Fatal Error: could not find %s in the "\
383 "clients list", source);
384 goto end;
385 }
386
387 logout(quitter);
388
389 if (z == ':')
390 source--;
391
392 /* Attempting to use the logout() function
393 if ((quitter = find(source)))
394 clients[hv].remove(quitter);
395 if ((quitter = findIRCplayer(source)))
396 {
397 if (player_fight(quitter))
398 {
399 // Stop the fight on the other client
400 aClient *otherplayer = quitter->stats->battle;
401 otherplayer->stats->battle = NULL;
402 notice(s_GameServ, otherplayer->getNick(), "%s "\
403 "has quit IRC. The fight stops here.",
404 quitter->stats->name);
405 }
406 quitter->stats->battle = NULL;
407 quitter->stats->fight = NULL;
408 quitter->stats->master = NULL;
409
410 quitter->setNick("Not Playing");
411 #ifdef P10
412 quitter->setRealNick("Not Playing");
413 #endif
414 quitter->stats->client = NULL; // Unidentify them
415 }
416 */
417
418 #if defined(P10)
419 } else if (stricmp(cmd, "P") == 0) {
420 char *rest, *dest;
421 char *longname;
422 longname = new char[strlen(s_GameServ) + strlen(servername) + 2];
423
424 sprintf(longname, "%S@%s", servername);
425
426 dest = strtok(NULL, " ");
427 rest = strtok(NULL, "");
428 if (stricmp(dest, gsnum) == 0 || stricmp(dest, longname) == 0)
429 {
430 delete [] longname;
431 gameserv(source, rest);
432 }
433 else if (stricmp(dest, c_Forest) == 0 && listenonc_forest)
434 {
435 delete [] longname;
436 forest(source, rest);
437 }
438 #else
439 } else if (stricmp(cmd, "PRIVMSG") == 0) {
440 char *rest, *dest;
441 dest = strtok(NULL, " ");
442 rest = strtok(NULL, "");
443 if (strnicmp(dest, s_GameServ, strlen(s_GameServ)) == 0)
444 gameserv(source, rest);
445 else if (stricmp(dest, c_Forest) == 0)
446 forest(source, rest);
447 #endif
448 #if defined(P10)
449 } else if (stricmp(cmd, "J") == 0) {
450 #else
451 } else if (stricmp(cmd, "JOIN") == 0) {
452 #endif
453 char *channel;
454 aClient *joiner;
455 channel = strtok(NULL, " ");
456
457 char z = source[0];
458
459 if (z == ':')
460 source++;
461
462 joiner = find(source);
463
464 if (stricmp(channel, c_Forest) == 0 && is_playing(joiner))
465 {
466 #ifdef DEBUGMODE
467 log("Player %s (IRC: %s) joined %s",
468 joiner->stats->name,
469 #ifdef P10
470 joiner->getRealNick(),
471 #else
472 joiner->getNick(),
473 #endif
474 c_Forest);
475 #endif
476 raw(":%S MODE %s +v %s", c_Forest, (source));
477 }
478
479 if (z == ':')
480 source--;
481
482 #if defined(BAHAMUT)
483 } else if (stricmp(cmd, "SJOIN") == 0) {
484 char *channel, *nick, *tmp, *rest;
485 strtok(NULL, " "); // Ignore the TS
486 #ifndef HYBRID
487 strtok(NULL, " "); // Ignore the TS
488 #endif
489 channel = strtok(NULL, " ");
490 rest = strtok(NULL, "");
491 tmp = strchr(rest, ':');
492 tmp++;
493 nick = strtok(tmp, " ");
494 while (nick != NULL)
495 {
496 if (*nick == '@')
497 nick++;
498 if (*nick == '+')
499 nick++; // Assume for users set op and voice, they
500 // are never passed as +@nick
501 if (stricmp(channel, c_Forest) == 0 && is_playing(nick))
502 raw(":%S MODE %s +v %s", channel, nick);
503
504 nick = strtok(NULL, " ");
505 }
506 #endif
507 } else {
508 #ifdef DEBUGMODE
509 log("Unrecognized Message: cmd = %s source = %s", cmd, source);
510 #endif
511 }
512 }
513
514 } // for loop for connection retry
515
516 end:
517
518 save_gs_dbase();
519 save_day();
520
521 delete_monsters();
522 delete_masters();
523
524 #ifdef DEBUGMODE
525 log("<CLOSED>");
526 #endif
527
528 close(sock);
529 unload_config_file();
530 return 0;
531 }
532
533 aClient *find(char *nick)
534 {
535 return findbynick(nick);
536 }
537
538 aClient *find(const char *nick)
539 {
540 return findbynick(nick);
541 }
542
543 #ifdef P10
544
545 aClient *findbyrealnick(char *realnick)
546 {
547 ListNode <aClient> *newPtr;
548 unsigned long hv = sHASH((unsigned char *) realnick);
549 newPtr = clients[hv].First();
550
551 aClient *client = NULL;
552
553 while (newPtr)
554 {
555 client = newPtr->getData();
556 if (stricmp(client->getRealNick(), realnick) == 0)
557 return client;
558 client = NULL;
559 newPtr = newPtr->Next();
560 }
561 return client;
562 }
563
564 #else
565
566 aClient *findbyrealnick(char *realnick)
567 {
568 return findbynick(realnick);
569 }
570
571 #endif
572
573 aClient *findbynick(char *nick)
574 {
575 ListNode <aClient> *newPtr;
576 #ifdef P10
577 unsigned long hv = sHASH((unsigned char *) nick);
578 #else
579 unsigned long hv = iHASH((unsigned char *) nick);
580 #endif
581
582 newPtr = clients[hv].First();
583
584 aClient *client = NULL;
585
586 while (newPtr)
587 {
588 client = newPtr->getData();
589 #ifdef P10
590 if (strcmp(client->getNick(), nick) == 0)
591 #else
592 if (stricmp(client->getNick(), nick) == 0)
593 #endif
594 return client;
595 client = NULL;
596 newPtr = newPtr->Next();
597 }
598 return client;
599 }
600
601 aClient *findIRCplayer(const char *nick)
602 {
603 ListNode <aClient> *newPtr;
604 aClient *p = NULL;
605
606 p = find(nick);
607
608 if (!is_playing(p))
609 return NULL;
610
611 unsigned long hv = iHASH((unsigned char *) p->stats->name);
612
613 for (newPtr = players[hv].First(); newPtr; newPtr = newPtr->Next())
614 {
615 p = newPtr->getData();
616 #ifdef P10
617 if (strcmp(p->getNick(), nick) == 0)
618 #else
619 if (stricmp(p->getNick(), nick) == 0)
620 #endif
621 return p;
622 p = NULL;
623 }
624 return NULL;
625 }
626
627 aClient *findplayer(const char *name)
628 {
629 ListNode <aClient> *newPtr;
630 Player *p = NULL;
631 unsigned long hv = iHASH((unsigned char *) name);
632 for (newPtr = players[hv].First(); newPtr; newPtr = newPtr->Next())
633 {
634 p = newPtr->getData()->stats;
635 if (stricmp(p->name, name) == 0)
636 return newPtr->getData();
637 p = NULL;
638 }
639 return NULL;
640 }
641
642 void check_idles()
643 {
644 ListNode <aClient> *newPtr;
645 Player *p = NULL;
646
647 for (int x = 0; x < U_TABLE_SIZE; x++)
648 {
649 for (newPtr = players[x].First(); newPtr; newPtr = newPtr->Next())
650 {
651 p = newPtr->getData()->stats;
652 if (timedOut(p))
653 {
654 timeOutEvent(p);
655 }
656 }
657 }
658 }
659
660 aClient *findbynick(const char *nick)
661 {
662 ListNode <aClient> *newPtr;
663 #ifdef P10
664 unsigned long hv = sHASH((unsigned char *) nick);
665 #else
666 unsigned long hv = iHASH((unsigned char *) nick);
667 #endif
668
669 newPtr = clients[hv].First();
670
671 aClient *client = NULL;
672
673 while (newPtr)
674 {
675 client = newPtr->getData();
676 #ifdef P10
677 if (strcmp(client->getNick(), nick) == 0)
678 #else
679 if (stricmp(client->getNick(), nick) == 0)
680 #endif
681 return client;
682 client = NULL;
683 newPtr = newPtr->Next();
684 }
685 return client;
686 }
687
688 void load_day()
689 {
690 ifstream infile;
691
692 infile.open(".gsday");
693
694 if (infile.fail())
695 {
696 #ifdef DEBUGMODE
697 log("Error opening .gsday");
698 #endif
699
700 generate:
701 #ifdef DEBUGMODE
702 log("Generating new day");
703 #endif
704 struct tm *tm;
705 time_t ti;
706 time(&ti);
707 tm = localtime(&ti);
708
709 day = tm->tm_mday;
710
711 save_day();
712 return;
713 }
714
715 infile >> day;
716 infile.close();
717 if (day < 1 || day > 31)
718 goto generate;
719 }
720
721 void save_day()
722 {
723 ofstream outfile;
724
725 outfile.open(".gsday");
726
727 if (outfile.fail())
728 {
729 log("Error creating new file .gsday");
730 return;
731 }
732
733 outfile << day << endl;
734
735 outfile.close();
736 }
737
738 /* daemon() - detach process from user and disappear into the background
739 * returns -1 on failure, but you can't do much except exit in that case
740 * since we may already have forked. This is based on the BSD version,
741 * so the caller is responsible for things like the umask, etc.
742 */
743
744 /* believed to work on all Posix systems */
745
746 int daemon(int nochdir, int noclose)
747 {
748 pid_t pid;
749 switch (pid = fork())
750 {
751 case 0: break;
752 case -1: return -1;
753 default: _exit(0); /* exit the original process */
754 }
755
756 if (setsid() < 0) /* shoudn't fail */
757 return -1;
758
759 /* dyke out this switch if you want to acquire a control tty in */
760 /* the future -- not normally advisable for daemons */
761
762 switch (pid = fork())
763 {
764 case 0: break;
765 case -1: return -1;
766 default:
767 ofstream outfile;
768 outfile.open(pidfile);
769 if (outfile.fail())
770 cerr << "Unable to open " << pidfile << endl;
771 outfile << pid << endl;
772 outfile.close();
773
774 _exit(0);
775 }
776
777 if (!nochdir)
778 chdir("/");
779
780 if (!noclose)
781 {
782 closeall(0);
783 open("/dev/null",O_RDWR);
784 dup(0); dup(0);
785 }
786
787 return 0;
788 }
789
790
791 /* closeall() -- close all FDs >= a specified value */
792
793 void closeall(int fd)
794 {
795 int fdlimit = sysconf(_SC_OPEN_MAX);
796
797 while (fd < fdlimit)
798 close(fd++);
799 }
800
801 void prettyIntro()
802 {
803 cout << endl;
804 cout << " GGGG AAA MM MM EEEEEEE SSSSS EEEEEEE RRRRRR VV VV " << endl;
805 cout << " GG GG AAAAA MMM MMM EE SS EE RR RR VV VV " << endl;
806 cout << "GG AA AA MM MM MM EEEEE SSSSS EEEEE RRRRRR VV VV " << endl;
807 cout << "GG GGG AAAAAAA MM MM EE SS EE RR RR VV VV " << endl;
808 cout << "G G AA AA MM MM EEEEEEE SSSSS EEEEEEE RR RR VVV" << endl;
809 cout << " GGGGG V\n\n" << endl;
810 cout << "Version: " << VERSION << endl;
811 }