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