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 <stdio.h>
  21 #include <unistd.h>
  22 #include <string.h>
  23 #include <fstream>
  24 #include <stdlib.h>
  25 #include <fcntl.h>
  26 #include <signal.h>
  27 //#include <sys/types.h>
  28 //#include <sys/wait.h>
  29 //#include <errno.h>
  30
  31
  32
  33 using std::ofstream;
  34 using std::ifstream;
  35 using std::cerr;
  36 using std::endl;
  37
  38 char *PACKAGE = "GameServ";
  39 char *VERSION = "1.2.0 +devel";
  40
  41 int sock;
  42 int day;
  43
  44 List<aClient> clients;
  45
  46 void save_day();
  47 void load_day();
  48 void prettyIntro();
  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   int connected = 1;
  60   char *cmd, *source = NULL, *conf = "gameserv.conf";
  61   srand(time(NULL));
  62
  63   /*
  64    * This needs to be fixed to work for any number of arguments in any
  65    * order
  66    *
  67    */
  68   if (argc > 1)
  69   {
  70         if ( argc > 2 || stricmp(argv[1], "--help") == 0)
  71         {
  72             cout << "Usage: gameserv [options] [configfile]" << endl;
  73             cout << "Options:" << endl;
  74             cout << "--help                        Displays this help dialogue" << endl;
  75             return 1;
  76         }
  77         conf = new char[strlen(argv[1])];
  78         strcpy(conf, argv[1]);
  79   }
  80
  81   prettyIntro();
  82
  83   if (load_config_file(conf))
  84   {
  85         cout << "Config file loaded ok...\n"
  86              << "Turning into a daemon" << endl;
  87   }
  88   else
  89         exit(2);
  90
  91     // Turn into a daemon
  92     if (daemon(1,0) < 0)
  93     {
  94         perror("Could not turn into a daemon");
  95         exit(2);
  96     }
  97
  98   ignore_pipe();
  99   sock = make_connection(remoteport, SOCK_STREAM, remoteserver);
 100   if (sock == -1) {
 101     fprintf(stderr,"make_connection failed.\n");
 102     unload_config_file();
 103     return -1;
 104   }
 105
 106 #ifdef UNREAL
 107         raw("PROTOCTL NICKv2 VHP");
 108         raw("PASS :%s", remotepass);
 109         raw("SERVER %s 1 :%s", servername, servername);
 110         raw("NICK %S 1 %d %S %s %s %d +owghraAxNt %s :%s v%s", time(NULL), gshost,
 111                 servername, time(NULL), gshost, PACKAGE, VERSION);
 112         raw(":%S JOIN %s", c_Forest);
 113         raw(":%S MODE %s +mtn", c_Forest);
 114 #elif defined(BAHAMUT)
 115         raw("PASS %s :TS", remotepass);
 116         raw("SERVER %s 1 :%s", servername, servername);
 117         raw("NICK %S 1 %d +o %s %s %s 0 :GameServ", time(NULL), gsident, gshost,
 118                 servername);
 119         raw(":%s SJOIN %d %d %s +mnt :@%S", servername, time(NULL), time(NULL), c_Forest);
 120 #elif defined(HYBRID)
 121         raw("PASS %s :TS", remotepass);
 122         raw("SERVER %s 1 :%s", servername, servername);
 123         raw("NICK %S 1 %d +o %s %s %s :GameServ", time(NULL), gsident, gshost,
 124                 servername);
 125         // Sending a timestamp of 1 to force ops.
 126         raw(":%s SJOIN 1 %s +ntm :@%S", servername, c_Forest);
 127 #elif defined(P10)
 128         // Server numeric is: []  <-- must be unique
 129         raw("PASS :%s", remotepass);
 130         raw("SERVER %s 1 %d %d P10 []AAF :%s", servername, time(NULL), time(NULL), servername);
 131         raw("[] N %S 1 %d %s %s DAqAoB %s :%S", time(NULL), gsident, gshost, gsnum);
 132         raw("[] B %s %d +tnm %s:o", c_Forest, time(NULL) - 864000, gsnum);
 133 #endif
 134
 135 #if defined(P10)
 136         raw("%s T %s :%s", gsnum, c_Forest, c_ForestTopic);
 137         raw("[] EB");  // End burst
 138 #else
 139 #ifndef HYBRID
 140         raw(":%S MODE %s +o %S", c_Forest);
 141 #endif
 142         raw(":%S TOPIC %s :%s", c_Forest, c_ForestTopic);
 143 #endif
 144
 145   sock_gets(sock,buffer,sizeof(buffer)-1); /* -1 added thanks to
 146     David Duchene <dave@ltd.com> for pointing out the possible
 147     buffer overflow resulting from the linefeed added below. */
 148
 149
 150   #ifdef DEBUGMODE
 151       log("Server: %s",buffer);
 152   #endif
 153
 154   strcpy(boss.name, "Red Dragon");
 155   strcpy(boss.weapon, "Breath of Unholy Fire");
 156   boss.strength = 6667;
 157   boss.gold = 2000000000;
 158   boss.exp = 2000000000;
 159   strcpy(boss.death, "You finally snuff out the deadly murderous "\
 160     "dragon's dark flames. You have freed the land of its terror "\
 161     "filled reign from above!");
 162
 163   init_masters();
 164   load_gs_dbase();
 165   load_day();
 166   long int loadtime = time(NULL);
 167   long int currentTime;
 168   long int oldTime = loadtime;
 169   bool loaded = false;
 170
 171   if (load_monsters() == false)
 172         goto end;
 173
 174   while (connected) {
 175       if (sock_gets(sock,buffer,sizeof(buffer)) == -1) {
 176         connected = 0;
 177       }
 178         strcpy(buf, buffer);
 179
 180       #if !defined(P10)
 181         if (buffer[0] == ':')
 182         {
 183             source = strtok(buf, " ");
 184             cmd = strtok(NULL, " ");
 185         }
 186         else
 187             cmd = strtok(buf, " ");
 188       #else
 189             source = strtok(buf, " ");
 190             cmd = strtok(NULL, " ");
 191       #endif
 192
 193         #ifdef DEBUGMODE
 194             log("Server: %s", buffer);
 195         #endif
 196
 197         // Wait N seconds then we're loaded.
 198         if (!loaded)
 199         {
 200             if (time(NULL) >= welcomedelay + loadtime)
 201                 loaded = true;
 202         }
 203
 204         // Save the player data every updateperiod seconds
 205         currentTime = time(NULL);
 206         if (currentTime - oldTime >= updateperiod)
 207         {
 208             oldTime = currentTime;
 209             save_gs_dbase();
 210         }
 211
 212
 213       #if !defined(P10)
 214         if (stricmp(cmd, "PING") == 0) {
 215             char *timestamp;
 216             timestamp = strtok(NULL, "");
 217             raw("PONG %s", timestamp);
 218       #else
 219         if (stricmp(cmd, "G") == 0) {
 220             char *timestamp;
 221             timestamp = strtok(NULL, " ");
 222             raw("[] Z [] %s 0 %s", timestamp + 1, timestamp);
 223       #endif
 224         #ifdef P10
 225         } else if (stricmp(cmd, "EB") == 0) {
 226             raw("[] EA");
 227         #endif
 228         } else if (stricmp(cmd, "VERSION") == 0) {
 229             char *server;
 230             server = strtok(NULL, " ");
 231             server++;
 232             raw(":%s 351 %s %s_%s. %s", servername, source+1, PACKAGE, VERSION, servername);
 233       #if !defined(P10)
 234         } else if (strncmp(cmd, "NICK", 4) == 0) {
 235             if (buffer[0] == ':')
 236             {
 237                 aClient *tempPtr;
 238                 if ((tempPtr = find((source + 1))))
 239                 {
 240                     char *nick;
 241                     nick = strtok(NULL, " ");
 242                     tempPtr->setNick(nick);
 243                 }
 244             }
 245             else
 246             {
 247                 char *nick;
 248       #else
 249        } else if (stricmp(cmd, "N") == 0 && strlen(source) == 2) {
 250             {
 251                 char *nick, *realnick;
 252                 realnick = strtok(NULL, " ");
 253
 254                 for (int x = 0; x < 5; x++)
 255                       nick = strtok(NULL, " ");
 256
 257                 if (nick[0] == '+')
 258                 {
 259                     #ifdef DEBUGMODE
 260                     log ("aClient has modes");
 261                     #endif
 262
 263                     // Searching for the +r mode (extra parameter)
 264                     for (unsigned int count = 1; count < strlen(nick); count++)
 265                     {
 266                         if (nick[count] == 'r')
 267                         {
 268                             nick = strtok(NULL, " ");
 269                             break;
 270                         }
 271                     }
 272                     nick = strtok(NULL, " ");
 273                 }
 274       #endif
 275                 aClient *newuser;
 276
 277                 nick = strtok(NULL, " ");
 278
 279                 #ifdef P10
 280                     newuser = new aClient(nick, realnick);
 281                 #else
 282                     newuser = new aClient(nick);
 283                 #endif
 284
 285
 286                 if (loaded)
 287                 #ifdef P10
 288                     notice(s_GameServ, nick, welcomemsg, realnick);
 289                 #else
 290                     notice(s_GameServ, nick, welcomemsg, nick);
 291                 #endif
 292
 293                 clients.insertAtBack(newuser);
 294                 delete newuser;
 295             }
 296       #if defined(P10)
 297         } else if (stricmp(cmd, "Q") == 0) {
 298       #else
 299         } else if (stricmp(cmd, "QUIT") == 0) {
 300       #endif
 301             aClient *quitter;
 302             char z = source[0];
 303
 304             if (z == ':')
 305                 source++;
 306
 307             if ((quitter = find(source)))
 308                 clients.remove(quitter);
 309             if ((quitter = findIRCplayer(source)))
 310             {
 311                 if (player_fight(quitter))
 312                 {
 313                     // Stop the fight on the other client
 314                     aClient *otherplayer = quitter->stats->battle;
 315                     otherplayer->stats->battle = NULL;
 316                     notice(s_GameServ, otherplayer->getNick(), "%s "\
 317                            "has quit IRC. The fight stops here.",
 318                            quitter->stats->name);
 319                 }
 320                 quitter->stats->battle = NULL;
 321                 quitter->stats->fight = NULL;
 322                 quitter->stats->master = NULL;
 323
 324                 quitter->setNick("!NULL!");
 325                 #ifdef P10
 326                     quitter->setRealNick("!NULL!");
 327                 #endif
 328                 quitter->stats->user = NULL; // Unidentify them
 329             }
 330
 331             if (z == ':')
 332                 source--;
 333
 334       #if defined(P10)
 335         } else if (stricmp(cmd, "P") == 0) {
 336             char *rest, *dest;
 337             char *longname;
 338             longname = new char[strlen(s_GameServ) + strlen(servername) + 2];
 339
 340             sprintf(longname, "%S@%s", servername);
 341
 342             dest = strtok(NULL, " ");
 343             rest = strtok(NULL, "");
 344             if (stricmp(dest, gsnum) == 0 || stricmp(dest, longname) == 0)
 345             {
 346                 delete [] longname;
 347                 gameserv(source, rest);
 348             }
 349             else if (stricmp(dest, c_Forest) == 0)
 350             {
 351                 delete [] longname;
 352                 forest(source, rest);
 353             }
 354       #else
 355         } else if (stricmp(cmd, "PRIVMSG") == 0) {
 356             char *rest, *dest;
 357             dest = strtok(NULL, " ");
 358             rest = strtok(NULL, "");
 359             if (strnicmp(dest, s_GameServ, strlen(s_GameServ)) == 0)
 360                 gameserv(source, rest);
 361             else if (stricmp(dest, c_Forest) == 0)
 362                 forest(source, rest);
 363       #endif
 364         } else if (stricmp(cmd, "JOIN") == 0) {
 365             char *channel;
 366             channel = strtok(NULL, " ");
 367             if (stricmp(channel, c_Forest) == 0 && is_playing(source + 1))
 368                 raw(":%S MODE %s +v %s", c_Forest, (source + 1));
 369
 370         #if defined(BAHAMUT)
 371         } else if (stricmp(cmd, "SJOIN") == 0) {
 372             char *channel, *nick, *tmp, *rest;
 373             strtok(NULL, " "); // Ignore the TS
 374 #ifndef HYBRID
 375             strtok(NULL, " "); // Ignore the TS
 376 #endif
 377             channel = strtok(NULL, " ");
 378            rest = strtok(NULL, "");
 379            tmp = strchr(rest, ':');
 380            tmp++;
 381            nick = strtok(tmp, " ");
 382            while (nick != NULL)
 383            {
 384                if (*nick == '@')
 385                    nick++;
 386                if (*nick == '+')
 387                    nick++; // Assume for users set op and voice, they
 388                             // are never passed as +@nick
 389                if (stricmp(channel, c_Forest) == 0 && is_playing(nick))
 390                    raw(":%S MODE %s +v %s", channel, nick);
 391
 392                nick = strtok(NULL, " ");
 393            }
 394 #endif
 395         } else {
 396             #ifdef DEBUGMODE
 397                 log("Unrecognized Message: cmd = %s   source = %s", cmd, source);
 398             #endif
 399         }
 400   }
 401
 402   end:
 403
 404   save_gs_dbase();
 405   save_day();
 406
 407   delete_monsters();
 408   delete_masters();
 409
 410   #ifdef DEBUGMODE
 411       log("<CLOSED>");
 412   #endif
 413
 414   close(sock);
 415   unload_config_file();
 416   return 0;
 417 }
 418
 419 aClient *find(char *nick)
 420 {
 421         return findbynick(nick);
 422 }
 423
 424 aClient *find(const char *nick)
 425 {
 426         return findbynick(nick);
 427 }
 428
 429 #ifdef P10
 430
 431 aClient *findbyrealnick(char *realnick)
 432 {
 433    ListNode <aClient> *newPtr;
 434     newPtr = clients.First();
 435
 436     aClient *client = NULL;
 437
 438     while (newPtr)
 439     {
 440         client = newPtr->getData();
 441             if (stricmp(client->getRealNick(), realnick) == 0)
 442             return client;
 443         client = NULL;
 444         newPtr = newPtr->Next();
 445     }
 446     return client;
 447 }
 448
 449 #else
 450
 451 aClient *findbyrealnick(char *realnick)
 452 {
 453   return findbynick(realnick);
 454 }
 455
 456 #endif
 457
 458 aClient *findbynick(char *nick)
 459 {
 460     ListNode <aClient> *newPtr;
 461     newPtr = clients.First();
 462
 463     aClient *client = NULL;
 464
 465     while (newPtr)
 466     {
 467         client = newPtr->getData();
 468         #ifdef P10
 469             if (strcmp(client->getNick(), nick) == 0)
 470         #else
 471             if (stricmp(client->getNick(), nick) == 0)
 472         #endif
 473             return client;
 474         client = NULL;
 475         newPtr = newPtr->Next();
 476     }
 477     return client;
 478 }
 479
 480 aClient *findIRCplayer(const char *nick)
 481 {
 482     ListNode <aClient> *newPtr;
 483     aClient *p = NULL;
 484
 485     for (newPtr = players.First(); newPtr; newPtr = newPtr->Next())
 486     {
 487         p = newPtr->getData();
 488         #ifdef P10
 489             if (strcmp(p->getNick(), nick) == 0)
 490         #else
 491             if (stricmp(p->getNick(), nick) == 0)
 492         #endif
 493             return p;
 494         p = NULL;
 495     }
 496     return NULL;
 497 }
 498 aClient *findplayer(const char *name)
 499 {
 500     ListNode <aClient> *newPtr;
 501     Player *p = NULL;
 502
 503     for (newPtr = players.First(); newPtr; newPtr = newPtr->Next())
 504     {
 505         p = newPtr->getData()->stats;
 506         if (stricmp(p->name, name) == 0)
 507             return newPtr->getData();
 508         p = NULL;
 509     }
 510     return NULL;
 511 }
 512
 513 aClient *findbynick(const char *nick)
 514 {
 515     ListNode <aClient> *newPtr;
 516     newPtr = clients.First();
 517
 518     aClient *client = NULL;
 519
 520     while (newPtr)
 521     {
 522         client = newPtr->getData();
 523         #ifdef P10
 524             if (strcmp(client->getNick(), nick) == 0)
 525         #else
 526             if (stricmp(client->getNick(), nick) == 0)
 527         #endif
 528             return client;
 529         client = NULL;
 530         newPtr = newPtr->Next();
 531     }
 532     return client;
 533 }
 534
 535 void load_day()
 536 {
 537     ifstream infile;
 538
 539     infile.open(".gsday");
 540
 541     if (infile.fail())
 542     {
 543         #ifdef DEBUGMODE
 544             log("Error opening .gsday");
 545         #endif
 546
 547         generate:
 548         #ifdef DEBUGMODE
 549             log("Generating new day");
 550         #endif
 551         struct tm *tm;
 552         time_t ti;
 553         time(&ti);
 554         tm = localtime(&ti);
 555
 556         day = tm->tm_mday;
 557
 558         save_day();
 559         return;
 560     }
 561
 562     infile >> day;
 563     infile.close();
 564     if (day < 1 || day > 31)
 565         goto generate;
 566 }
 567
 568 void save_day()
 569 {
 570     ofstream outfile;
 571
 572     outfile.open(".gsday");
 573
 574     if (outfile.fail())
 575     {
 576         log("Error creating new file .gsday");
 577         return;
 578     }
 579
 580     outfile << day << endl;
 581
 582     outfile.close();
 583 }
 584
 585 /* daemon() - detach process from user and disappear into the background
 586  * returns -1 on failure, but you can't do much except exit in that case
 587  * since we may already have forked. This is based on the BSD version,
 588  * so the caller is responsible for things like the umask, etc.
 589  */
 590
 591 /* believed to work on all Posix systems */
 592
 593 int daemon(int nochdir, int noclose)
 594 {
 595     pid_t pid;
 596     switch (pid = fork())
 597     {
 598         case 0:  break;
 599         case -1: return -1;
 600         default: _exit(0);          /* exit the original process */
 601     }
 602
 603     if (setsid() < 0)               /* shoudn't fail */
 604       return -1;
 605
 606     /* dyke out this switch if you want to acquire a control tty in */
 607     /* the future -- not normally advisable for daemons */
 608
 609     switch (pid = fork())
 610     {
 611         case 0:  break;
 612         case -1: return -1;
 613         default:
 614                 ofstream outfile;
 615                 outfile.open(pidfile);
 616                 if (outfile.fail())
 617                     cerr << "Unable to open " << pidfile << endl;
 618                 outfile << pid << endl;
 619                 outfile.close();
 620
 621         _exit(0);
 622     }
 623
 624     if (!nochdir)
 625       chdir("/");
 626
 627     if (!noclose)
 628     {
 629         closeall(0);
 630         open("/dev/null",O_RDWR);
 631         dup(0); dup(0);
 632     }
 633
 634     return 0;
 635 }
 636
 637
 638 /* closeall() -- close all FDs >= a specified value */
 639
 640 void closeall(int fd)
 641 {
 642     int fdlimit = sysconf(_SC_OPEN_MAX);
 643
 644     while (fd < fdlimit)
 645       close(fd++);
 646 }
 647
 648 void prettyIntro()
 649 {
 650 cout << endl;
 651 cout << "  GGGG     AAA   MM    MM EEEEEEE  SSSSS  EEEEEEE RRRRRR  VV     VV " << endl;
 652 cout << " GG  GG   AAAAA  MMM  MMM EE      SS      EE      RR   RR VV     VV " << endl;
 653 cout << "GG       AA   AA MM MM MM EEEEE    SSSSS  EEEEE   RRRRRR   VV   VV  " << endl;
 654 cout << "GG   GGG AAAAAAA MM    MM EE           SS EE      RR  RR    VV VV   " << endl;
 655 cout << "G     G  AA   AA MM    MM EEEEEEE  SSSSS  EEEEEEE RR   RR    VVV" << endl;
 656 cout << " GGGGG                                                        V\n\n" << endl;
 657 cout << "Version: " << VERSION << endl;
 658 }