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                 quitter->stats->user = NULL; // Unidentify them
 326             }
 327
 328             if (z == ':')
 329                 source--;
 330
 331       #if defined(P10)
 332         } else if (stricmp(cmd, "P") == 0) {
 333             char *rest, *dest;
 334             char *longname;
 335             longname = new char[strlen(s_GameServ) + strlen(servername) + 2];
 336
 337             sprintf(longname, "%S@%s", servername);
 338
 339             dest = strtok(NULL, " ");
 340             rest = strtok(NULL, "");
 341             if (stricmp(dest, gsnum) == 0 || stricmp(dest, longname) == 0)
 342             {
 343                 delete [] longname;
 344                 gameserv(source, rest);
 345             }
 346             else if (stricmp(dest, c_Forest) == 0)
 347             {
 348                 delete [] longname;
 349                 forest(source, rest);
 350             }
 351       #else
 352         } else if (stricmp(cmd, "PRIVMSG") == 0) {
 353             char *rest, *dest;
 354             dest = strtok(NULL, " ");
 355             rest = strtok(NULL, "");
 356             if (strnicmp(dest, s_GameServ, strlen(s_GameServ)) == 0)
 357                 gameserv(source, rest);
 358             else if (stricmp(dest, c_Forest) == 0)
 359                 forest(source, rest);
 360       #endif
 361         } else if (stricmp(cmd, "JOIN") == 0) {
 362             char *channel;
 363             channel = strtok(NULL, " ");
 364             if (stricmp(channel, c_Forest) == 0 && is_playing(source + 1))
 365                 raw(":%S MODE %s +v %s", c_Forest, (source + 1));
 366
 367         #if defined(BAHAMUT)
 368         } else if (stricmp(cmd, "SJOIN") == 0) {
 369             char *channel, *nick, *tmp, *rest;
 370             strtok(NULL, " "); // Ignore the TS
 371 #ifndef HYBRID
 372             strtok(NULL, " "); // Ignore the TS
 373 #endif
 374             channel = strtok(NULL, " ");
 375            rest = strtok(NULL, "");
 376            tmp = strchr(rest, ':');
 377            tmp++;
 378            nick = strtok(tmp, " ");
 379            while (nick != NULL)
 380            {
 381                if (*nick == '@')
 382                    nick++;
 383                if (*nick == '+')
 384                    nick++; // Assume for users set op and voice, they
 385                             // are never passed as +@nick
 386                if (stricmp(channel, c_Forest) == 0 && is_playing(nick))
 387                    raw(":%S MODE %s +v %s", channel, nick);
 388
 389                nick = strtok(NULL, " ");
 390            }
 391 #endif
 392         } else {
 393             #ifdef DEBUGMODE
 394                 log("Unrecognized Message: cmd = %s   source = %s", cmd, source);
 395             #endif
 396         }
 397   }
 398
 399   end:
 400
 401   save_gs_dbase();
 402   save_day();
 403
 404   delete_monsters();
 405   delete_masters();
 406
 407   #ifdef DEBUGMODE
 408       log("<CLOSED>");
 409   #endif
 410
 411   close(sock);
 412   unload_config_file();
 413   return 0;
 414 }
 415
 416 aClient *find(char *nick)
 417 {
 418         return findbynick(nick);
 419 }
 420
 421 aClient *find(const char *nick)
 422 {
 423         return findbynick(nick);
 424 }
 425
 426 #ifdef P10
 427
 428 aClient *findbyrealnick(char *realnick)
 429 {
 430    ListNode <aClient> *newPtr;
 431     newPtr = clients.First();
 432
 433     aClient *client = NULL;
 434
 435     while (newPtr)
 436     {
 437         client = newPtr->getData();
 438             if (stricmp(client->getRealNick(), realnick) == 0)
 439             return client;
 440         client = NULL;
 441         newPtr = newPtr->Next();
 442     }
 443     return client;
 444 }
 445
 446 #else
 447
 448 aClient *findbyrealnick(char *realnick)
 449 {
 450   return findbynick(realnick);
 451 }
 452
 453 #endif
 454
 455 aClient *findbynick(char *nick)
 456 {
 457     ListNode <aClient> *newPtr;
 458     newPtr = clients.First();
 459
 460     aClient *client = NULL;
 461
 462     while (newPtr)
 463     {
 464         client = newPtr->getData();
 465         #ifdef P10
 466             if (strcmp(client->getNick(), nick) == 0)
 467         #else
 468             if (stricmp(client->getNick(), nick) == 0)
 469         #endif
 470             return client;
 471         client = NULL;
 472         newPtr = newPtr->Next();
 473     }
 474     return client;
 475 }
 476
 477 aClient *findIRCplayer(const char *nick)
 478 {
 479     ListNode <aClient> *newPtr;
 480     aClient *p = NULL;
 481
 482     for (newPtr = players.First(); newPtr; newPtr = newPtr->Next())
 483     {
 484         p = newPtr->getData();
 485         #ifdef P10
 486             if (strcmp(p->getNick(), nick) == 0)
 487         #else
 488             if (stricmp(p->getNick(), nick) == 0)
 489         #endif
 490             return p;
 491         p = NULL;
 492     }
 493     return NULL;
 494 }
 495 aClient *findplayer(const char *name)
 496 {
 497     ListNode <aClient> *newPtr;
 498     Player *p = NULL;
 499
 500     for (newPtr = players.First(); newPtr; newPtr = newPtr->Next())
 501     {
 502         p = newPtr->getData()->stats;
 503         if (stricmp(p->name, name) == 0)
 504             return newPtr->getData();
 505         p = NULL;
 506     }
 507     return NULL;
 508 }
 509
 510 aClient *findbynick(const char *nick)
 511 {
 512     ListNode <aClient> *newPtr;
 513     newPtr = clients.First();
 514
 515     aClient *client = NULL;
 516
 517     while (newPtr)
 518     {
 519         client = newPtr->getData();
 520         #ifdef P10
 521             if (strcmp(client->getNick(), nick) == 0)
 522         #else
 523             if (stricmp(client->getNick(), nick) == 0)
 524         #endif
 525             return client;
 526         client = NULL;
 527         newPtr = newPtr->Next();
 528     }
 529     return client;
 530 }
 531
 532 void load_day()
 533 {
 534     ifstream infile;
 535
 536     infile.open(".gsday");
 537
 538     if (infile.fail())
 539     {
 540         #ifdef DEBUGMODE
 541             log("Error opening .gsday");
 542         #endif
 543
 544         generate:
 545         #ifdef DEBUGMODE
 546             log("Generating new day");
 547         #endif
 548         struct tm *tm;
 549         time_t ti;
 550         time(&ti);
 551         tm = localtime(&ti);
 552
 553         day = tm->tm_mday;
 554
 555         save_day();
 556         return;
 557     }
 558
 559     infile >> day;
 560     infile.close();
 561     if (day < 1 || day > 31)
 562         goto generate;
 563 }
 564
 565 void save_day()
 566 {
 567     ofstream outfile;
 568
 569     outfile.open(".gsday");
 570
 571     if (outfile.fail())
 572     {
 573         log("Error creating new file .gsday");
 574         return;
 575     }
 576
 577     outfile << day << endl;
 578
 579     outfile.close();
 580 }
 581
 582 /* daemon() - detach process from user and disappear into the background
 583  * returns -1 on failure, but you can't do much except exit in that case
 584  * since we may already have forked. This is based on the BSD version,
 585  * so the caller is responsible for things like the umask, etc.
 586  */
 587
 588 /* believed to work on all Posix systems */
 589
 590 int daemon(int nochdir, int noclose)
 591 {
 592     pid_t pid;
 593     switch (pid = fork())
 594     {
 595         case 0:  break;
 596         case -1: return -1;
 597         default: _exit(0);          /* exit the original process */
 598     }
 599
 600     if (setsid() < 0)               /* shoudn't fail */
 601       return -1;
 602
 603     /* dyke out this switch if you want to acquire a control tty in */
 604     /* the future -- not normally advisable for daemons */
 605
 606     switch (pid = fork())
 607     {
 608         case 0:  break;
 609         case -1: return -1;
 610         default:
 611                 ofstream outfile;
 612                 outfile.open(pidfile);
 613                 if (outfile.fail())
 614                     cerr << "Unable to open " << pidfile << endl;
 615                 outfile << pid << endl;
 616                 outfile.close();
 617
 618         _exit(0);
 619     }
 620
 621     if (!nochdir)
 622       chdir("/");
 623
 624     if (!noclose)
 625     {
 626         closeall(0);
 627         open("/dev/null",O_RDWR);
 628         dup(0); dup(0);
 629     }
 630
 631     return 0;
 632 }
 633
 634
 635 /* closeall() -- close all FDs >= a specified value */
 636
 637 void closeall(int fd)
 638 {
 639     int fdlimit = sysconf(_SC_OPEN_MAX);
 640
 641     while (fd < fdlimit)
 642       close(fd++);
 643 }
 644
 645 void prettyIntro()
 646 {
 647 cout << endl;
 648 cout << "  GGGG     AAA   MM    MM EEEEEEE  SSSSS  EEEEEEE RRRRRR  VV     VV " << endl;
 649 cout << " GG  GG   AAAAA  MMM  MMM EE      SS      EE      RR   RR VV     VV " << endl;
 650 cout << "GG       AA   AA MM MM MM EEEEE    SSSSS  EEEEE   RRRRRR   VV   VV  " << endl;
 651 cout << "GG   GGG AAAAAAA MM    MM EE           SS EE      RR  RR    VV VV   " << endl;
 652 cout << "G     G  AA   AA MM    MM EEEEEEE  SSSSS  EEEEEEE RR   RR    VVV" << endl;
 653 cout << " GGGGG                                                        V\n\n" << endl;
 654 cout << "Version: " << VERSION << endl;
 655 }