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