citadel/citserver.c

   1 /*
   2  * $Id$
   3  *
   4  * Main source module for the Citadel server
   5  *
   6  */
   7
   8 #include "sysdep.h"
   9 #include <stdlib.h>
  10 #include <unistd.h>
  11 #include <stdio.h>
  12 #include <fcntl.h>
  13 #include <signal.h>
  14 #include <sys/types.h>
  15 #include <sys/stat.h>
  16
  17
  18 #if TIME_WITH_SYS_TIME
  19 # include <sys/time.h>
  20 # include <time.h>
  21 #else
  22 # if HAVE_SYS_TIME_H
  23 #  include <sys/time.h>
  24 # else
  25 #  include <time.h>
  26 # endif
  27 #endif
  28
  29 #if HAVE_BACKTRACE
  30 #include <execinfo.h>
  31 #endif
  32
  33 #include <ctype.h>
  34 #include <string.h>
  35 #include <dirent.h>
  36 #include <errno.h>
  37 #include <limits.h>
  38 #include <netdb.h>
  39 #include <sys/types.h>
  40 #include <sys/socket.h>
  41 #include <netinet/in.h>
  42 #include <arpa/inet.h>
  43 #include <libcitadel.h>
  44 #include "citadel.h"
  45 #include "server.h"
  46 #include "sysdep_decls.h"
  47 #include "threads.h"
  48 #include "citserver.h"
  49 #include "config.h"
  50 #include "database.h"
  51 #include "housekeeping.h"
  52 #include "user_ops.h"
  53 #include "msgbase.h"
  54 #include "support.h"
  55 #include "locate_host.h"
  56 #include "room_ops.h"
  57 #include "file_ops.h"
  58 #include "policy.h"
  59 #include "control.h"
  60 #include "euidindex.h"
  61 #include "svn_revision.h"
  62
  63 #ifndef HAVE_SNPRINTF
  64 #include "snprintf.h"
  65 #endif
  66
  67 #include "ctdl_module.h"
  68
  69
  70 struct CitContext *ContextList = NULL;
  71 struct CitContext* next_session = NULL;
  72 char *unique_session_numbers;
  73 int ScheduledShutdown = 0;
  74 time_t server_startup_time;
  75 int panic_fd;
  76
  77 /**
  78  * \brief print the actual stack frame.
  79  */
  80 void cit_backtrace(void)
  81 {
  82 #ifdef HAVE_BACKTRACE
  83         void *stack_frames[50];
  84         size_t size, i;
  85         char **strings;
  86
  87
  88         size = backtrace(stack_frames, sizeof(stack_frames) / sizeof(void*));
  89         strings = backtrace_symbols(stack_frames, size);
  90         for (i = 0; i < size; i++) {
  91                 if (strings != NULL)
  92                         CtdlLogPrintf(1, "%s\n", strings[i]);
  93                 else
  94                         CtdlLogPrintf(1, "%p\n", stack_frames[i]);
  95         }
  96         free(strings);
  97 #endif
  98 }
  99
 100 /**
 101  * \brief print the actual stack frame.
 102  */
 103 void cit_panic_backtrace(int SigNum)
 104 {
 105 #ifdef HAVE_BACKTRACE
 106         void *stack_frames[10];
 107         size_t size, i;
 108         char **strings;
 109
 110         printf("caught signal 11\n");
 111         size = backtrace(stack_frames, sizeof(stack_frames) / sizeof(void*));
 112         strings = backtrace_symbols(stack_frames, size);
 113         for (i = 0; i < size; i++) {
 114                 if (strings != NULL)
 115                         CtdlLogPrintf(1, "%s\n", strings[i]);
 116                 else
 117                         CtdlLogPrintf(1, "%p\n", stack_frames[i]);
 118         }
 119         free(strings);
 120 #endif
 121         exit(-1);
 122 }
 123
 124 /*
 125  * Various things that need to be initialized at startup
 126  */
 127 void master_startup(void) {
 128         struct timeval tv;
 129         unsigned int seed;
 130         FILE *urandom;
 131         struct ctdlroom qrbuf;
 132
 133         CtdlLogPrintf(CTDL_DEBUG, "master_startup() started\n");
 134         time(&server_startup_time);
 135
 136         CtdlLogPrintf(CTDL_INFO, "Opening databases\n");
 137         open_databases();
 138
 139         ctdl_thread_internal_init_tsd();
 140
 141         CtdlThreadAllocTSD();
 142
 143         check_ref_counts();
 144
 145         CtdlLogPrintf(CTDL_INFO, "Creating base rooms (if necessary)\n");
 146         create_room(config.c_baseroom,  0, "", 0, 1, 0, VIEW_BBS);
 147         create_room(AIDEROOM,           3, "", 0, 1, 0, VIEW_BBS);
 148         create_room(SYSCONFIGROOM,      3, "", 0, 1, 0, VIEW_BBS);
 149         create_room(config.c_twitroom,  0, "", 0, 1, 0, VIEW_BBS);
 150
 151         /* The "Local System Configuration" room doesn't need to be visible */
 152         if (lgetroom(&qrbuf, SYSCONFIGROOM) == 0) {
 153                 qrbuf.QRflags2 |= QR2_SYSTEM;
 154                 lputroom(&qrbuf);
 155         }
 156
 157         /* Aide needs to be public postable, else we're not RFC conformant. */
 158         if (lgetroom(&qrbuf, AIDEROOM) == 0) {
 159                 qrbuf.QRflags2 |= QR2_SMTP_PUBLIC;
 160                 lputroom(&qrbuf);
 161         }
 162
 163         CtdlLogPrintf(CTDL_INFO, "Seeding the pseudo-random number generator...\n");
 164         urandom = fopen("/dev/urandom", "r");
 165         if (urandom != NULL) {
 166                 fread(&seed, sizeof seed, 1, urandom);
 167                 fclose(urandom);
 168         }
 169         else {
 170                 gettimeofday(&tv, NULL);
 171                 seed = tv.tv_usec;
 172         }
 173         srand(seed);
 174         srandom(seed);
 175
 176         CtdlLogPrintf(CTDL_INFO, "Initializing ipgm secret\n");
 177         get_config();
 178         config.c_ipgm_secret = rand();
 179         put_config();
 180
 181         CtdlLogPrintf(CTDL_DEBUG, "master_startup() finished\n");
 182 }
 183
 184
 185 /*
 186  * Cleanup routine to be called when the server is shutting down.
 187  */
 188 void master_cleanup(int exitcode) {
 189         struct CleanupFunctionHook *fcn;
 190         static int already_cleaning_up = 0;
 191
 192         if (already_cleaning_up) while(1) sleep(1);
 193         already_cleaning_up = 1;
 194
 195         /* Run any cleanup routines registered by loadable modules */
 196         for (fcn = CleanupHookTable; fcn != NULL; fcn = fcn->next) {
 197                 (*fcn->h_function_pointer)();
 198         }
 199
 200         /* Close the AdjRefCount queue file */
 201         AdjRefCount(-1, 0);
 202
 203         /* Do system-dependent stuff */
 204         sysdep_master_cleanup();
 205
 206         /* Close databases */
 207         CtdlLogPrintf(CTDL_INFO, "Closing databases\n");
 208         close_databases();
 209
 210 #ifdef DEBUG_MEMORY_LEAKS
 211         dump_heap();
 212 #endif
 213
 214         /* If the operator requested a halt but not an exit, halt here. */
 215         if (shutdown_and_halt) {
 216                 CtdlLogPrintf(CTDL_NOTICE, "citserver: Halting server without exiting.\n");
 217                 fflush(stdout); fflush(stderr);
 218                 while(1) {
 219                         sleep(32767);
 220                 }
 221         }
 222
 223         release_control();
 224
 225         /* Now go away. */
 226         CtdlLogPrintf(CTDL_NOTICE, "citserver: Exiting with status %d\n", exitcode);
 227         fflush(stdout); fflush(stderr);
 228
 229         if (restart_server != 0)
 230                 exit(1);
 231         if ((running_as_daemon != 0) && (exitcode == 0))
 232                 exitcode = CTDLEXIT_SHUTDOWN;
 233         exit(exitcode);
 234 }
 235
 236
 237
 238 /*
 239  * Terminate a session.
 240  */
 241 void RemoveContext (struct CitContext *con)
 242 {
 243         if (con==NULL) {
 244                 CtdlLogPrintf(CTDL_ERR,
 245                         "WARNING: RemoveContext() called with NULL!\n");
 246                 return;
 247         }
 248         CtdlLogPrintf(CTDL_DEBUG, "RemoveContext() session %d\n", con->cs_pid);
 249
 250         /* Run any cleanup routines registered by loadable modules.
 251          * Note: We have to "become_session()" because the cleanup functions
 252          *       might make references to "CC" assuming it's the right one.
 253          */
 254         become_session(con);
 255         logout();
 256         PerformSessionHooks(EVT_STOP);
 257         become_session(NULL);
 258
 259         CtdlLogPrintf(CTDL_NOTICE, "[%3d] Session ended.\n", con->cs_pid);
 260
 261         /* If the client is still connected, blow 'em away. */
 262         CtdlLogPrintf(CTDL_DEBUG, "Closing socket %d\n", con->client_socket);
 263         close(con->client_socket);
 264
 265         CtdlLogPrintf(CTDL_DEBUG, "Done with RemoveContext()\n");
 266 }
 267
 268
 269
 270
 271
 272 /*
 273  * cmd_info()  -  tell the client about this server
 274  */
 275 void cmd_info(void) {
 276         cprintf("%d Server info:\n", LISTING_FOLLOWS);
 277         cprintf("%d\n", CC->cs_pid);
 278         cprintf("%s\n", config.c_nodename);
 279         cprintf("%s\n", config.c_humannode);
 280         cprintf("%s\n", config.c_fqdn);
 281         cprintf("%s\n", CITADEL);
 282         cprintf("%d\n", REV_LEVEL);
 283         cprintf("%s\n", config.c_site_location);
 284         cprintf("%s\n", config.c_sysadm);
 285         cprintf("%d\n", SERVER_TYPE);
 286         cprintf("%s\n", config.c_moreprompt);
 287         cprintf("1\n"); /* 1 = yes, this system supports floors */
 288         cprintf("1\n"); /* 1 = we support the extended paging options */
 289         cprintf("%s\n", CC->cs_nonce);
 290         cprintf("1\n"); /* 1 = yes, this system supports the QNOP command */
 291
 292 #ifdef HAVE_LDAP
 293         cprintf("1\n"); /* 1 = yes, this server is LDAP-enabled */
 294 #else
 295         cprintf("0\n"); /* 1 = no, this server is not LDAP-enabled */
 296 #endif
 297
 298         if (config.c_auth_mode == AUTHMODE_NATIVE) {
 299                 cprintf("%d\n", config.c_disable_newu);
 300         }
 301         else {
 302                 cprintf("1\n"); /* "create new user" does not work with non-native auth modes */
 303         }
 304
 305         cprintf("%s\n", config.c_default_cal_zone);
 306
 307         /* Output load averages */
 308         cprintf("%f\n", CtdlThreadLoadAvg);
 309         cprintf("%f\n", CtdlThreadWorkerAvg);
 310         cprintf("%d\n", CtdlThreadGetCount());
 311
 312         cprintf("1\n");         /* yes, Sieve mail filtering is supported */
 313         cprintf("%d\n", config.c_enable_fulltext);
 314         cprintf("%s\n", svn_revision());
 315
 316         if (config.c_auth_mode == AUTHMODE_NATIVE) {
 317                 cprintf("1\n"); /* OpenID is enabled when using native auth */
 318         }
 319         else {
 320                 cprintf("0\n"); /* OpenID is disabled when using non-native auth */
 321         }
 322
 323         cprintf("000\n");
 324 }
 325
 326
 327 /*
 328  * returns an asterisk if there are any instant messages waiting,
 329  * space otherwise.
 330  */
 331 char CtdlCheckExpress(void) {
 332         if (CC->FirstExpressMessage == NULL) {
 333                 return(' ');
 334         }
 335         else {
 336                 return('*');
 337         }
 338 }
 339
 340 void cmd_time(void)
 341 {
 342    time_t tv;
 343    struct tm tmp;
 344
 345    tv = time(NULL);
 346    localtime_r(&tv, &tmp);
 347
 348    /* timezone and daylight global variables are not portable. */
 349 #ifdef HAVE_STRUCT_TM_TM_GMTOFF
 350    cprintf("%d %ld|%ld|%d\n", CIT_OK, (long)tv, tmp.tm_gmtoff, tmp.tm_isdst);
 351 #else
 352    cprintf("%d %ld|%ld|%d\n", CIT_OK, (long)tv, timezone, tmp.tm_isdst);
 353 #endif
 354 }
 355
 356
 357 /*
 358  * Check originating host against the public_clients file.  This determines
 359  * whether the client is allowed to change the hostname for this session
 360  * (for example, to show the location of the user rather than the location
 361  * of the client).
 362  */
 363 int is_public_client(void)
 364 {
 365         char buf[1024];
 366         char addrbuf[1024];
 367         FILE *fp;
 368         int i;
 369         char *public_clientspos;
 370         char *public_clientsend;
 371         char *paddr = NULL;
 372         struct stat statbuf;
 373         static time_t pc_timestamp = 0;
 374         static char public_clients[SIZ];
 375         static char public_clients_file[SIZ];
 376
 377 #define LOCALHOSTSTR "127.0.0.1"
 378
 379         snprintf(public_clients_file,
 380                          sizeof public_clients_file,
 381                          "%s/public_clients",
 382                          ctdl_etc_dir);
 383
 384         /*
 385          * Check the time stamp on the public_clients file.  If it's been
 386          * updated since the last time we were here (or if this is the first
 387          * time we've been through the loop), read its contents and learn
 388          * the IP addresses of the listed hosts.
 389          */
 390         if (stat(public_clients_file, &statbuf) != 0) {
 391                 /* No public_clients file exists, so bail out */
 392                 CtdlLogPrintf(CTDL_WARNING, "Warning: '%s' does not exist\n",
 393                                 public_clients_file);
 394                 return(0);
 395         }
 396
 397         if (statbuf.st_mtime > pc_timestamp) {
 398                 begin_critical_section(S_PUBLIC_CLIENTS);
 399                 CtdlLogPrintf(CTDL_INFO, "Loading %s\n", public_clients_file);
 400
 401                 public_clientspos = &public_clients[0];
 402                 public_clientsend = public_clientspos + SIZ;
 403                 safestrncpy(public_clientspos, LOCALHOSTSTR, sizeof public_clients);
 404                 public_clientspos += sizeof(LOCALHOSTSTR) - 1;
 405
 406                 if (hostname_to_dotted_quad(addrbuf, config.c_fqdn) == 0) {
 407                         *(public_clientspos++) = '|';
 408                         paddr = &addrbuf[0];
 409                         while (!IsEmptyStr (paddr) &&
 410                                (public_clientspos < public_clientsend))
 411                                 *(public_clientspos++) = *(paddr++);
 412                 }
 413
 414                 fp = fopen(public_clients_file, "r");
 415                 if (fp != NULL)
 416                         while ((fgets(buf, sizeof buf, fp)!=NULL) &&
 417                                (public_clientspos < public_clientsend)){
 418                                 char *ptr;
 419                                 ptr = buf;
 420                                 while (!IsEmptyStr(ptr)) {
 421                                         if (*ptr == '#') {
 422                                                 *ptr = 0;
 423                                                 break;
 424                                         }
 425                                 else ptr++;
 426                                 }
 427                                 ptr--;
 428                                 while (ptr>buf && isspace(*ptr)) {
 429                                         *(ptr--) = 0;
 430                                 }
 431                                 if (hostname_to_dotted_quad(addrbuf, buf) == 0) {
 432                                         *(public_clientspos++) = '|';
 433                                         paddr = addrbuf;
 434                                         while (!IsEmptyStr(paddr) &&
 435                                                (public_clientspos < public_clientsend)){
 436                                                 *(public_clientspos++) = *(paddr++);
 437                                         }
 438                                 }
 439                         }
 440                 fclose(fp);
 441                 pc_timestamp = time(NULL);
 442                 end_critical_section(S_PUBLIC_CLIENTS);
 443         }
 444
 445         CtdlLogPrintf(CTDL_DEBUG, "Checking whether %s is a local or public client\n",
 446                 CC->cs_addr);
 447         for (i=0; i<num_parms(public_clients); ++i) {
 448                 extract_token(addrbuf, public_clients, i, '|', sizeof addrbuf);
 449                 if (!strcasecmp(CC->cs_addr, addrbuf)) {
 450                         CtdlLogPrintf(CTDL_DEBUG, "... yes it is.\n");
 451                         return(1);
 452                 }
 453         }
 454
 455         /* No hits.  This is not a public client. */
 456         CtdlLogPrintf(CTDL_DEBUG, "... no it isn't.\n");
 457         return(0);
 458 }
 459
 460
 461 /*
 462  * the client is identifying itself to the server
 463  */
 464 void cmd_iden(char *argbuf)
 465 {
 466         int dev_code;
 467         int cli_code;
 468         int rev_level;
 469         char desc[128];
 470         char from_host[128];
 471         struct in_addr addr;
 472         int do_lookup = 0;
 473
 474         if (num_parms(argbuf)<4) {
 475                 cprintf("%d usage error\n", ERROR + ILLEGAL_VALUE);
 476                 return;
 477         }
 478
 479         dev_code = extract_int(argbuf,0);
 480         cli_code = extract_int(argbuf,1);
 481         rev_level = extract_int(argbuf,2);
 482         extract_token(desc, argbuf, 3, '|', sizeof desc);
 483
 484         safestrncpy(from_host, config.c_fqdn, sizeof from_host);
 485         from_host[sizeof from_host - 1] = 0;
 486         if (num_parms(argbuf)>=5) extract_token(from_host, argbuf, 4, '|', sizeof from_host);
 487
 488         CC->cs_clientdev = dev_code;
 489         CC->cs_clienttyp = cli_code;
 490         CC->cs_clientver = rev_level;
 491         safestrncpy(CC->cs_clientname, desc, sizeof CC->cs_clientname);
 492         CC->cs_clientname[31] = 0;
 493
 494         if (!IsEmptyStr(from_host)) {
 495                 if (CC->is_local_socket) do_lookup = 1;
 496                 else if (is_public_client()) do_lookup = 1;
 497         }
 498
 499         if (do_lookup) {
 500                 CtdlLogPrintf(CTDL_DEBUG, "Looking up hostname '%s'\n", from_host);
 501                 if ((addr.s_addr = inet_addr(from_host)) != -1) {
 502                         locate_host(CC->cs_host, sizeof CC->cs_host,
 503                                 CC->cs_addr, sizeof CC->cs_addr,
 504                                 &addr);
 505                 }
 506                 else {
 507                         safestrncpy(CC->cs_host, from_host, sizeof CC->cs_host);
 508                         CC->cs_host[sizeof CC->cs_host - 1] = 0;
 509                 }
 510         }
 511
 512         CtdlLogPrintf(CTDL_NOTICE, "Client %d/%d/%01d.%02d (%s) from %s\n",
 513                 dev_code,
 514                 cli_code,
 515                 (rev_level / 100),
 516                 (rev_level % 100),
 517                 desc,
 518                 CC->cs_host);
 519         cprintf("%d Ok\n",CIT_OK);
 520 }
 521
 522
 523 /*
 524  * display system messages or help
 525  */
 526 void cmd_mesg(char *mname)
 527 {
 528         FILE *mfp;
 529         char targ[256];
 530         char buf[256];
 531         char buf2[256];
 532         char *dirs[2];
 533         DIR *dp;
 534         struct dirent *d;
 535
 536         extract_token(buf, mname, 0, '|', sizeof buf);
 537
 538         dirs[0] = strdup(ctdl_message_dir);
 539         dirs[1] = strdup(ctdl_hlp_dir);
 540
 541         snprintf(buf2, sizeof buf2, "%s.%d.%d",
 542                 buf, CC->cs_clientdev, CC->cs_clienttyp);
 543
 544         /* If the client requested "?" then produce a listing */
 545         if (!strcmp(buf, "?")) {
 546                 cprintf("%d %s\n", LISTING_FOLLOWS, buf);
 547                 dp = opendir(dirs[1]);
 548                 if (dp != NULL) {
 549                         while (d = readdir(dp), d != NULL) {
 550                                 if (d->d_name[0] != '.') {
 551                                         cprintf(" %s\n", d->d_name);
 552                                 }
 553                         }
 554                         closedir(dp);
 555                 }
 556                 cprintf("000\n");
 557                 free(dirs[0]);
 558                 free(dirs[1]);
 559                 return;
 560         }
 561
 562         /* Otherwise, look for the requested file by name. */
 563         else {
 564                 mesg_locate(targ, sizeof targ, buf2, 2, (const char **)dirs);
 565                 if (IsEmptyStr(targ)) {
 566                         snprintf(buf2, sizeof buf2, "%s.%d",
 567                                                         buf, CC->cs_clientdev);
 568                         mesg_locate(targ, sizeof targ, buf2, 2,
 569                                                         (const char **)dirs);
 570                         if (IsEmptyStr(targ)) {
 571                                 mesg_locate(targ, sizeof targ, buf, 2,
 572                                                         (const char **)dirs);
 573                         }
 574                 }
 575         }
 576
 577         free(dirs[0]);
 578         free(dirs[1]);
 579
 580         if (IsEmptyStr(targ)) {
 581                 cprintf("%d '%s' not found.  (Searching in %s and %s)\n",
 582                         ERROR + FILE_NOT_FOUND,
 583                         mname,
 584                         ctdl_message_dir,
 585                         ctdl_hlp_dir
 586                 );
 587                 return;
 588         }
 589
 590         mfp = fopen(targ, "r");
 591         if (mfp==NULL) {
 592                 cprintf("%d Cannot open '%s': %s\n",
 593                         ERROR + INTERNAL_ERROR, targ, strerror(errno));
 594                 return;
 595         }
 596         cprintf("%d %s\n", LISTING_FOLLOWS,buf);
 597
 598         while (fgets(buf, (sizeof buf - 1), mfp) != NULL) {
 599                 buf[strlen(buf)-1] = 0;
 600                 do_help_subst(buf);
 601                 cprintf("%s\n",buf);
 602         }
 603
 604         fclose(mfp);
 605         cprintf("000\n");
 606 }
 607
 608
 609 /*
 610  * enter system messages or help
 611  */
 612 void cmd_emsg(char *mname)
 613 {
 614         FILE *mfp;
 615         char targ[256];
 616         char buf[256];
 617         char *dirs[2];
 618         int a;
 619
 620         unbuffer_output();
 621
 622         if (CtdlAccessCheck(ac_aide)) return;
 623
 624         extract_token(buf, mname, 0, '|', sizeof buf);
 625         for (a=0; !IsEmptyStr(&buf[a]); ++a) {          /* security measure */
 626                 if (buf[a] == '/') buf[a] = '.';
 627         }
 628
 629         dirs[0] = strdup(ctdl_message_dir);
 630         dirs[1] = strdup(ctdl_hlp_dir);
 631
 632         mesg_locate(targ, sizeof targ, buf, 2, (const char**)dirs);
 633         free(dirs[0]);
 634         free(dirs[1]);
 635
 636         if (IsEmptyStr(targ)) {
 637                 snprintf(targ, sizeof targ,
 638                                  "%s/%s",
 639                                  ctdl_hlp_dir, buf);
 640         }
 641
 642         mfp = fopen(targ,"w");
 643         if (mfp==NULL) {
 644                 cprintf("%d Cannot open '%s': %s\n",
 645                         ERROR + INTERNAL_ERROR, targ, strerror(errno));
 646                 return;
 647         }
 648         cprintf("%d %s\n", SEND_LISTING, targ);
 649
 650         while (client_getln(buf, sizeof buf) >=0 && strcmp(buf, "000")) {
 651                 fprintf(mfp, "%s\n", buf);
 652         }
 653
 654         fclose(mfp);
 655 }
 656
 657
 658 /* Don't show the names of private rooms unless the viewing
 659  * user also knows the rooms.
 660  */
 661 void GenerateRoomDisplay(char *real_room,
 662                         struct CitContext *viewed,
 663                         struct CitContext *viewer) {
 664
 665         int ra;
 666
 667         strcpy(real_room, viewed->room.QRname);
 668         if (viewed->room.QRflags & QR_MAILBOX) {
 669                 strcpy(real_room, &real_room[11]);
 670         }
 671         if (viewed->room.QRflags & QR_PRIVATE) {
 672                 CtdlRoomAccess(&viewed->room, &viewer->user, &ra, NULL);
 673                 if ( (ra & UA_KNOWN) == 0) {
 674                         strcpy(real_room, "<private room>");
 675                 }
 676         }
 677
 678         if (viewed->cs_flags & CS_CHAT) {
 679                 while (strlen(real_room) < 14) {
 680                         strcat(real_room, " ");
 681                 }
 682                 strcpy(&real_room[14], "<chat>");
 683         }
 684
 685 }
 686
 687 /*
 688  * Convenience function.
 689  */
 690 int CtdlAccessCheck(int required_level) {
 691
 692         if (CC->internal_pgm) return(0);
 693         if (required_level >= ac_internal) {
 694                 cprintf("%d This is not a user-level command.\n",
 695                         ERROR + HIGHER_ACCESS_REQUIRED);
 696                 return(-1);
 697         }
 698
 699         if ((required_level >= ac_logged_in) && (CC->logged_in == 0)) {
 700                 cprintf("%d Not logged in.\n", ERROR + NOT_LOGGED_IN);
 701                 return(-1);
 702         }
 703
 704         if (CC->user.axlevel >= 6) return(0);
 705         if (required_level >= ac_aide) {
 706                 cprintf("%d This command requires Aide access.\n",
 707                         ERROR + HIGHER_ACCESS_REQUIRED);
 708                 return(-1);
 709         }
 710
 711         if (is_room_aide()) return(0);
 712         if (required_level >= ac_room_aide) {
 713                 cprintf("%d This command requires Aide or Room Aide access.\n",
 714                         ERROR + HIGHER_ACCESS_REQUIRED);
 715                 return(-1);
 716         }
 717
 718         /* shhh ... succeed quietly */
 719         return(0);
 720 }
 721
 722
 723
 724 /*
 725  * Terminate another running session
 726  */
 727 void cmd_term(char *cmdbuf)
 728 {
 729         int session_num;
 730         struct CitContext *ccptr;
 731         int found_it = 0;
 732         int allowed = 0;
 733
 734         session_num = extract_int(cmdbuf, 0);
 735         if (session_num == CC->cs_pid) {
 736                 cprintf("%d You can't kill your own session.\n", ERROR + ILLEGAL_VALUE);
 737                 return;
 738         }
 739
 740         CtdlLogPrintf(CTDL_DEBUG, "Locating session to kill\n");
 741         begin_critical_section(S_SESSION_TABLE);
 742         for (ccptr = ContextList; ccptr != NULL; ccptr = ccptr->next) {
 743                 if (session_num == ccptr->cs_pid) {
 744                         found_it = 1;
 745                         if ((ccptr->user.usernum == CC->user.usernum)
 746                            || (CC->user.axlevel >= 6)) {
 747                                 allowed = 1;
 748                                 ccptr->kill_me = 1;
 749                         }
 750                         else {
 751                                 allowed = 0;
 752                         }
 753                 }
 754         }
 755         end_critical_section(S_SESSION_TABLE);
 756
 757         if (found_it) {
 758                 if (allowed) {
 759                         cprintf("%d Session terminated.\n", CIT_OK);
 760                 }
 761                 else {
 762                         cprintf("%d You are not allowed to do that.\n",
 763                                 ERROR + HIGHER_ACCESS_REQUIRED);
 764                 }
 765         }
 766         else {
 767                 cprintf("%d No such session.\n", ERROR + ILLEGAL_VALUE);
 768         }
 769 }
 770
 771
 772
 773
 774
 775 /*
 776  * get the paginator prompt
 777  */
 778 void cmd_more(void) {
 779         cprintf("%d %s\n", CIT_OK, config.c_moreprompt);
 780 }
 781
 782 /*
 783  * echo
 784  */
 785 void cmd_echo(char *etext)
 786 {
 787         cprintf("%d %s\n", CIT_OK, etext);
 788 }
 789
 790
 791
 792 /*
 793  * identify as internal program
 794  */
 795 void cmd_ipgm(char *argbuf)
 796 {
 797         int secret;
 798
 799         secret = extract_int(argbuf, 0);
 800
 801         /* For security reasons, we do NOT allow this command to run
 802          * over the network.  Local sockets only.
 803          */
 804         if (!CC->is_local_socket) {
 805                 sleep(5);
 806                 cprintf("%d Authentication failed.\n",
 807                         ERROR + PASSWORD_REQUIRED);
 808         }
 809         else if (secret == config.c_ipgm_secret) {
 810                 CC->internal_pgm = 1;
 811                 strcpy(CC->curr_user, "<internal program>");
 812                 CC->cs_flags = CC->cs_flags|CS_STEALTH;
 813                 cprintf("%d Authenticated as an internal program.\n", CIT_OK);
 814         }
 815         else {
 816                 sleep(5);
 817                 cprintf("%d Authentication failed.\n",
 818                         ERROR + PASSWORD_REQUIRED);
 819                 CtdlLogPrintf(CTDL_ERR, "Warning: ipgm authentication failed.\n");
 820                 CC->kill_me = 1;
 821         }
 822 }
 823
 824
 825 /*
 826  * Shut down the server
 827  */
 828 void cmd_down(char *argbuf) {
 829         char *Reply ="%d Shutting down server.  Goodbye.\n";
 830
 831         if (CtdlAccessCheck(ac_aide)) return;
 832
 833         if (!IsEmptyStr(argbuf))
 834         {
 835                 int state = CIT_OK;
 836                 restart_server = extract_int(argbuf, 0);
 837
 838                 if (restart_server > 0)
 839                 {
 840                         Reply = "%d citserver will now shut down and automatically restart.\n";
 841                 }
 842                 if ((restart_server > 0) && !running_as_daemon)
 843                 {
 844                         CtdlLogPrintf(CTDL_ERR, "The user requested restart, but not running as daemon! Geronimooooooo!\n");
 845                         Reply = "%d Warning: citserver is not running in daemon mode and is therefore unlikely to restart automatically.\n";
 846                         state = ERROR;
 847                 }
 848                 cprintf(Reply, state);
 849         }
 850         else
 851         {
 852                 cprintf(Reply, CIT_OK + SERVER_SHUTTING_DOWN);
 853         }
 854         CtdlThreadStopAll();
 855 }
 856
 857 /*
 858  * Halt the server without exiting the server process.
 859  */
 860 void cmd_halt(void) {
 861
 862         if (CtdlAccessCheck(ac_aide)) return;
 863
 864         cprintf("%d Halting server.  Goodbye.\n", CIT_OK);
 865         CtdlThreadStopAll();
 866         shutdown_and_halt = 1;
 867 }
 868
 869 /*
 870  * Schedule or cancel a server shutdown
 871  */
 872 void cmd_scdn(char *argbuf)
 873 {
 874         int new_state;
 875         int state = CIT_OK;
 876         char *Reply = "%d %d\n";
 877
 878         if (CtdlAccessCheck(ac_aide)) return;
 879
 880         new_state = extract_int(argbuf, 0);
 881         if ((new_state == 2) || (new_state == 3))
 882         {
 883                 restart_server = 1;
 884                 if (!running_as_daemon)
 885                 {
 886                         CtdlLogPrintf(CTDL_ERR, "The user requested restart, but not running as deamon! Geronimooooooo!\n");
 887                         Reply = "%d %d Warning, not running in deamon mode. maybe we will come up again, but don't lean on it.\n";
 888                         state = ERROR;
 889                 }
 890
 891                 restart_server = extract_int(argbuf, 0);
 892                 new_state -= 2;
 893         }
 894         if ((new_state == 0) || (new_state == 1)) {
 895                 ScheduledShutdown = new_state;
 896         }
 897         cprintf(Reply, state, ScheduledShutdown);
 898 }
 899
 900
 901 /*
 902  * Set or unset asynchronous protocol mode
 903  */
 904 void cmd_asyn(char *argbuf)
 905 {
 906         int new_state;
 907
 908         new_state = extract_int(argbuf, 0);
 909         if ((new_state == 0) || (new_state == 1)) {
 910                 CC->is_async = new_state;
 911         }
 912         cprintf("%d %d\n", CIT_OK, CC->is_async);
 913 }
 914
 915
 916 /*
 917  * Generate a "nonce" for APOP-style authentication.
 918  *
 919  * RFC 1725 et al specify a PID to be placed in front of the nonce.
 920  * Quoth BTX: That would be stupid.
 921  */
 922 void generate_nonce(struct CitContext *con) {
 923         struct timeval tv;
 924
 925         memset(con->cs_nonce, NONCE_SIZE, 0);
 926         gettimeofday(&tv, NULL);
 927         memset(con->cs_nonce, NONCE_SIZE, 0);
 928         snprintf(con->cs_nonce, NONCE_SIZE, "<%d%ld@%s>",
 929                 rand(), (long)tv.tv_usec, config.c_fqdn);
 930 }
 931
 932
 933
 934
 935 /*
 936  * Back-end function for starting a session
 937  */
 938 void begin_session(struct CitContext *con)
 939 {
 940         socklen_t len;
 941         struct sockaddr_in sin;
 942
 943         /*
 944          * Initialize some variables specific to our context.
 945          */
 946         con->logged_in = 0;
 947         con->internal_pgm = 0;
 948         con->download_fp = NULL;
 949         con->upload_fp = NULL;
 950         con->FirstExpressMessage = NULL;
 951         time(&con->lastcmd);
 952         time(&con->lastidle);
 953         strcpy(con->lastcmdname, "    ");
 954         strcpy(con->cs_clientname, "(unknown)");
 955         strcpy(con->curr_user, NLI);
 956         *con->net_node = '\0';
 957         *con->fake_username = '\0';
 958         *con->fake_hostname = '\0';
 959         *con->fake_roomname = '\0';
 960         generate_nonce(con);
 961         safestrncpy(con->cs_host, config.c_fqdn, sizeof con->cs_host);
 962         safestrncpy(con->cs_addr, "", sizeof con->cs_addr);
 963         con->cs_host[sizeof con->cs_host - 1] = 0;
 964         len = sizeof sin;
 965         if (!CC->is_local_socket) {
 966                 if (!getpeername(con->client_socket, (struct sockaddr *) &sin, &len)) {
 967                         locate_host(con->cs_host, sizeof con->cs_host,
 968                                 con->cs_addr, sizeof con->cs_addr,
 969                                 &sin.sin_addr
 970                         );
 971                 }
 972         }
 973         else {
 974                 strcpy(con->cs_host, "");
 975         }
 976         con->cs_flags = 0;
 977         con->upload_type = UPL_FILE;
 978         con->dl_is_net = 0;
 979
 980         con->nologin = 0;
 981         if (((config.c_maxsessions > 0)&&(num_sessions > config.c_maxsessions)) || CtdlWantSingleUser()) {
 982                 con->nologin = 1;
 983         }
 984
 985         if (!CC->is_local_socket) {
 986                 CtdlLogPrintf(CTDL_NOTICE, "Session started from %s [%s].\n", con->cs_host, con->cs_addr);
 987         }
 988         else {
 989                 CtdlLogPrintf(CTDL_NOTICE, "Session started via local socket.\n");
 990         }
 991
 992         /* Run any session startup routines registered by loadable modules */
 993         PerformSessionHooks(EVT_START);
 994 }
 995
 996
 997 void citproto_begin_session() {
 998         if (CC->nologin==1) {
 999                 cprintf("%d %s: Too many users are already online (maximum is %d)\n",
1000                         ERROR + MAX_SESSIONS_EXCEEDED,
1001                         config.c_nodename, config.c_maxsessions
1002                 );
1003                 CC->kill_me = 1;
1004         }
1005         else {
1006                 cprintf("%d %s Citadel server ready.\n",
1007                         CIT_OK, config.c_nodename);
1008         }
1009 }
1010
1011
1012
1013
1014 /*
1015  * This loop recognizes all server commands.
1016  */
1017 void do_command_loop(void) {
1018         char cmdbuf[SIZ];
1019         const char *old_name = NULL;
1020
1021         old_name = CtdlThreadName("do_command_loop");
1022
1023         time(&CC->lastcmd);
1024         memset(cmdbuf, 0, sizeof cmdbuf); /* Clear it, just in case */
1025         if (client_getln(cmdbuf, sizeof cmdbuf) < 1) {
1026                 CtdlLogPrintf(CTDL_ERR, "Client disconnected: ending session.\n");
1027                 CC->kill_me = 1;
1028                 CtdlThreadName(old_name);
1029                 return;
1030         }
1031
1032         /* Log the server command, but don't show passwords... */
1033         if ( (strncasecmp(cmdbuf, "PASS", 4))
1034            && (strncasecmp(cmdbuf, "SETP", 4)) ) {
1035                 CtdlLogPrintf(CTDL_INFO, "%s\n", cmdbuf);
1036         }
1037         else {
1038                 CtdlLogPrintf(CTDL_INFO, "<password command sent>\n");
1039         }
1040
1041         buffer_output();
1042
1043         /*
1044          * Let other clients see the last command we executed, and
1045          * update the idle time, but not NOOP, QNOP, PEXP, GEXP, RWHO, or TIME.
1046          */
1047         if ( (strncasecmp(cmdbuf, "NOOP", 4))
1048            && (strncasecmp(cmdbuf, "QNOP", 4))
1049            && (strncasecmp(cmdbuf, "PEXP", 4))
1050            && (strncasecmp(cmdbuf, "GEXP", 4))
1051            && (strncasecmp(cmdbuf, "RWHO", 4))
1052            && (strncasecmp(cmdbuf, "TIME", 4)) ) {
1053                 strcpy(CC->lastcmdname, "    ");
1054                 safestrncpy(CC->lastcmdname, cmdbuf, sizeof(CC->lastcmdname));
1055                 time(&CC->lastidle);
1056         }
1057
1058         CtdlThreadName(cmdbuf);
1059
1060         if ((strncasecmp(cmdbuf, "ENT0", 4))
1061            && (strncasecmp(cmdbuf, "MESG", 4))
1062            && (strncasecmp(cmdbuf, "MSGS", 4)))
1063         {
1064            CC->cs_flags &= ~CS_POSTING;
1065         }
1066
1067         if (!strncasecmp(cmdbuf, "NOOP", 4)) {
1068                 cprintf("%d%cok\n", CIT_OK, CtdlCheckExpress() );
1069         }
1070
1071         else if (!strncasecmp(cmdbuf, "XYZZY", 5)) {
1072                 cprintf("%d Nothing happens.\n", CIT_OK);
1073         }
1074
1075         else if (!strncasecmp(cmdbuf, "QNOP", 4)) {
1076                 /* do nothing, this command returns no response */
1077         }
1078
1079         else if (!strncasecmp(cmdbuf,"QUIT",4)) {
1080                 cprintf("%d Goodbye.\n", CIT_OK);
1081                 CC->kill_me = 1;
1082         }
1083
1084         else if (!strncasecmp(cmdbuf,"ASYN",4)) {
1085                 cmd_asyn(&cmdbuf[5]);
1086         }
1087
1088         else if (!strncasecmp(cmdbuf,"LOUT",4)) {
1089                 if (CC->logged_in) logout();
1090                 cprintf("%d logged out.\n", CIT_OK);
1091         }
1092
1093         else if (!strncasecmp(cmdbuf,"USER",4)) {
1094                 cmd_user(&cmdbuf[5]);
1095         }
1096
1097         else if (!strncasecmp(cmdbuf,"PASS",4)) {
1098                 cmd_pass(&cmdbuf[5]);
1099         }
1100
1101         else if (!strncasecmp(cmdbuf,"NEWU",4)) {
1102                 cmd_newu(&cmdbuf[5]);
1103         }
1104
1105         else if (!strncasecmp(cmdbuf,"CREU",4)) {
1106                 cmd_creu(&cmdbuf[5]);
1107         }
1108
1109         else if (!strncasecmp(cmdbuf,"SETP",4)) {
1110                 cmd_setp(&cmdbuf[5]);
1111         }
1112
1113         else if (!strncasecmp(cmdbuf,"LRMS",4)) {
1114                 cmd_lrms(&cmdbuf[5]);
1115         }
1116
1117         else if (!strncasecmp(cmdbuf,"LKRA",4)) {
1118                 cmd_lkra(&cmdbuf[5]);
1119         }
1120
1121         else if (!strncasecmp(cmdbuf,"LKRN",4)) {
1122                 cmd_lkrn(&cmdbuf[5]);
1123         }
1124
1125         else if (!strncasecmp(cmdbuf,"LKRO",4)) {
1126                 cmd_lkro(&cmdbuf[5]);
1127         }
1128
1129         else if (!strncasecmp(cmdbuf,"LZRM",4)) {
1130                 cmd_lzrm(&cmdbuf[5]);
1131         }
1132
1133         else if (!strncasecmp(cmdbuf,"LPRM",4)) {
1134                 cmd_lprm(&cmdbuf[5]);
1135         }
1136
1137         else if (!strncasecmp(cmdbuf,"GETU",4)) {
1138                 cmd_getu();
1139         }
1140
1141         else if (!strncasecmp(cmdbuf,"SETU",4)) {
1142                 cmd_setu(&cmdbuf[5]);
1143         }
1144
1145         else if (!strncasecmp(cmdbuf,"GOTO",4)) {
1146                 cmd_goto(&cmdbuf[5]);
1147         }
1148
1149         else if (!strncasecmp(cmdbuf,"MSGS",4)) {
1150                 cmd_msgs(&cmdbuf[5]);
1151         }
1152
1153         else if (!strncasecmp(cmdbuf,"WHOK",4)) {
1154                 cmd_whok();
1155         }
1156
1157         else if (!strncasecmp(cmdbuf,"RDIR",4)) {
1158                 cmd_rdir();
1159         }
1160
1161         else if (!strncasecmp(cmdbuf,"EUID",4)) {
1162                 cmd_euid(&cmdbuf[5]);
1163         }
1164
1165         else if (!strncasecmp(cmdbuf,"MSG0",4)) {
1166                 cmd_msg0(&cmdbuf[5]);
1167         }
1168
1169         else if (!strncasecmp(cmdbuf,"MSG2",4)) {
1170                 cmd_msg2(&cmdbuf[5]);
1171         }
1172
1173         else if (!strncasecmp(cmdbuf,"MSG3",4)) {
1174                 cmd_msg3(&cmdbuf[5]);
1175         }
1176
1177         else if (!strncasecmp(cmdbuf,"MSG4",4)) {
1178                 cmd_msg4(&cmdbuf[5]);
1179         }
1180
1181         else if (!strncasecmp(cmdbuf,"MSGP",4)) {
1182                 cmd_msgp(&cmdbuf[5]);
1183         }
1184
1185         else if (!strncasecmp(cmdbuf,"OPNA",4)) {
1186                 cmd_opna(&cmdbuf[5]);
1187         }
1188
1189         else if (!strncasecmp(cmdbuf,"DLAT",4)) {
1190                 cmd_dlat(&cmdbuf[5]);
1191         }
1192
1193         else if (!strncasecmp(cmdbuf,"INFO",4)) {
1194                 cmd_info();
1195         }
1196
1197         else if (!strncasecmp(cmdbuf,"SLRP",4)) {
1198                 cmd_slrp(&cmdbuf[5]);
1199         }
1200
1201         else if (!strncasecmp(cmdbuf,"INVT",4)) {
1202                 cmd_invt_kick(&cmdbuf[5],1);
1203         }
1204
1205         else if (!strncasecmp(cmdbuf,"KICK",4)) {
1206                 cmd_invt_kick(&cmdbuf[5],0);
1207         }
1208
1209         else if (!strncasecmp(cmdbuf,"GETR",4)) {
1210                 cmd_getr();
1211         }
1212
1213         else if (!strncasecmp(cmdbuf,"SETR",4)) {
1214                 cmd_setr(&cmdbuf[5]);
1215         }
1216
1217         else if (!strncasecmp(cmdbuf,"GETA",4)) {
1218                 cmd_geta();
1219         }
1220
1221         else if (!strncasecmp(cmdbuf,"SETA",4)) {
1222                 cmd_seta(&cmdbuf[5]);
1223         }
1224
1225         else if (!strncasecmp(cmdbuf,"ENT0",4)) {
1226                 cmd_ent0(&cmdbuf[5]);
1227         }
1228
1229         else if (!strncasecmp(cmdbuf,"RINF",4)) {
1230                 cmd_rinf();
1231         }
1232
1233         else if (!strncasecmp(cmdbuf,"DELE",4)) {
1234                 cmd_dele(&cmdbuf[5]);
1235         }
1236
1237         else if (!strncasecmp(cmdbuf,"KILL",4)) {
1238                 cmd_kill(&cmdbuf[5]);
1239         }
1240
1241         else if (!strncasecmp(cmdbuf,"CRE8",4)) {
1242                 cmd_cre8(&cmdbuf[5]);
1243         }
1244
1245         else if (!strncasecmp(cmdbuf,"MOVE",4)) {
1246                 cmd_move(&cmdbuf[5]);
1247         }
1248
1249         else if (!strncasecmp(cmdbuf,"FORG",4)) {
1250                 cmd_forg();
1251         }
1252
1253         else if (!strncasecmp(cmdbuf,"MESG",4)) {
1254                 cmd_mesg(&cmdbuf[5]);
1255         }
1256
1257         else if (!strncasecmp(cmdbuf,"EMSG",4)) {
1258                 cmd_emsg(&cmdbuf[5]);
1259         }
1260
1261         else if (!strncasecmp(cmdbuf,"GNUR",4)) {
1262                 cmd_gnur();
1263         }
1264
1265         else if (!strncasecmp(cmdbuf,"VALI",4)) {
1266                 cmd_vali(&cmdbuf[5]);
1267         }
1268
1269         else if (!strncasecmp(cmdbuf,"EINF",4)) {
1270                 cmd_einf(&cmdbuf[5]);
1271         }
1272
1273         else if (!strncasecmp(cmdbuf,"LIST",4)) {
1274                 cmd_list(&cmdbuf[5]);
1275         }
1276
1277         else if (!strncasecmp(cmdbuf,"CHEK",4)) {
1278                 cmd_chek();
1279         }
1280
1281         else if (!strncasecmp(cmdbuf,"DELF",4)) {
1282                 cmd_delf(&cmdbuf[5]);
1283         }
1284
1285         else if (!strncasecmp(cmdbuf,"MOVF",4)) {
1286                 cmd_movf(&cmdbuf[5]);
1287         }
1288
1289         else if (!strncasecmp(cmdbuf,"OPEN",4)) {
1290                 cmd_open(&cmdbuf[5]);
1291         }
1292
1293         else if (!strncasecmp(cmdbuf,"CLOS",4)) {
1294                 cmd_clos();
1295         }
1296
1297         else if (!strncasecmp(cmdbuf,"UOPN",4)) {
1298                 cmd_uopn(&cmdbuf[5]);
1299         }
1300
1301         else if (!strncasecmp(cmdbuf,"UCLS",4)) {
1302                 cmd_ucls(&cmdbuf[5]);
1303         }
1304
1305         else if (!strncasecmp(cmdbuf,"READ",4)) {
1306                 cmd_read(&cmdbuf[5]);
1307         }
1308
1309         else if (!strncasecmp(cmdbuf,"WRIT",4)) {
1310                 cmd_writ(&cmdbuf[5]);
1311         }
1312
1313         else if (!strncasecmp(cmdbuf,"QUSR",4)) {
1314                 cmd_qusr(&cmdbuf[5]);
1315         }
1316
1317         else if (!strncasecmp(cmdbuf,"ECHO",4)) {
1318                 cmd_echo(&cmdbuf[5]);
1319         }
1320
1321         else if (!strncasecmp(cmdbuf,"OIMG",4)) {
1322                 cmd_oimg(&cmdbuf[5]);
1323         }
1324
1325         else if (!strncasecmp(cmdbuf,"MORE",4)) {
1326                 cmd_more();
1327         }
1328
1329         else if (!strncasecmp(cmdbuf,"NDOP",4)) {
1330                 cmd_ndop(&cmdbuf[5]);
1331         }
1332
1333         else if (!strncasecmp(cmdbuf,"NUOP",4)) {
1334                 cmd_nuop(&cmdbuf[5]);
1335         }
1336
1337         else if (!strncasecmp(cmdbuf,"LFLR",4)) {
1338                 cmd_lflr();
1339         }
1340
1341         else if (!strncasecmp(cmdbuf,"CFLR",4)) {
1342                 cmd_cflr(&cmdbuf[5]);
1343         }
1344
1345         else if (!strncasecmp(cmdbuf,"KFLR",4)) {
1346                 cmd_kflr(&cmdbuf[5]);
1347         }
1348
1349         else if (!strncasecmp(cmdbuf,"EFLR",4)) {
1350                 cmd_eflr(&cmdbuf[5]);
1351         }
1352
1353         else if (!strncasecmp(cmdbuf,"IDEN",4)) {
1354                 cmd_iden(&cmdbuf[5]);
1355         }
1356
1357         else if (!strncasecmp(cmdbuf,"IPGM",4)) {
1358                 cmd_ipgm(&cmdbuf[5]);
1359         }
1360
1361         else if (!strncasecmp(cmdbuf,"TERM",4)) {
1362                 cmd_term(&cmdbuf[5]);
1363         }
1364
1365         else if (!strncasecmp(cmdbuf,"DOWN",4)) {
1366                 cmd_down(&cmdbuf[5]);
1367         }
1368
1369         else if (!strncasecmp(cmdbuf,"HALT",4)) {
1370                 cmd_halt();
1371         }
1372
1373         else if (!strncasecmp(cmdbuf,"SCDN",4)) {
1374                 cmd_scdn(&cmdbuf[5]);
1375         }
1376
1377         else if (!strncasecmp(cmdbuf, "UIMG", 4)) {
1378                 cmd_uimg(&cmdbuf[5]);
1379         }
1380
1381         else if (!strncasecmp(cmdbuf, "TIME", 4)) {
1382                 cmd_time();
1383         }
1384
1385         else if (!strncasecmp(cmdbuf, "AGUP", 4)) {
1386                 cmd_agup(&cmdbuf[5]);
1387         }
1388
1389         else if (!strncasecmp(cmdbuf, "ASUP", 4)) {
1390                 cmd_asup(&cmdbuf[5]);
1391         }
1392
1393         else if (!strncasecmp(cmdbuf, "GPEX", 4)) {
1394                 cmd_gpex(&cmdbuf[5]);
1395         }
1396
1397         else if (!strncasecmp(cmdbuf, "SPEX", 4)) {
1398                 cmd_spex(&cmdbuf[5]);
1399         }
1400
1401         else if (!strncasecmp(cmdbuf, "CONF", 4)) {
1402                 cmd_conf(&cmdbuf[5]);
1403         }
1404
1405         else if (!strncasecmp(cmdbuf, "SEEN", 4)) {
1406                 cmd_seen(&cmdbuf[5]);
1407         }
1408
1409         else if (!strncasecmp(cmdbuf, "GTSN", 4)) {
1410                 cmd_gtsn(&cmdbuf[5]);
1411         }
1412
1413         else if (!strncasecmp(cmdbuf, "VIEW", 4)) {
1414                 cmd_view(&cmdbuf[5]);
1415         }
1416
1417         else if (!strncasecmp(cmdbuf, "ISME", 4)) {
1418                 cmd_isme(&cmdbuf[5]);
1419         }
1420
1421         else if (!strncasecmp(cmdbuf, "RENU", 4)) {
1422                 cmd_renu(&cmdbuf[5]);
1423         }
1424
1425         else if (!DLoader_Exec_Cmd(cmdbuf)) {
1426                 cprintf("%d Unrecognized or unsupported command.\n", ERROR + CMD_NOT_SUPPORTED);
1427         }
1428
1429         unbuffer_output();
1430
1431         /* Run any after-each-command routines registered by modules */
1432         PerformSessionHooks(EVT_CMD);
1433         CtdlThreadName(old_name);
1434 }
1435
1436
1437 /*
1438  * This loop performs all asynchronous functions.
1439  */
1440 void do_async_loop(void) {
1441         PerformSessionHooks(EVT_ASYNC);
1442 }