开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 查看源码
WSCKCOMM.C
资源名称：mercwsrc.zip　[点击查看]
上传用户：kesirui
上传日期：2007-01-07
资源大小：263k
文件大小：74k
源码类别：

Internet/网络编程

开发平台：

WINDOWS

WSCKCOMM.C：源码内容
  1. /***************************************************************************
  2.  *  Original Diku Mud copyright (C) 1990, 1991 by Sebastian Hammer,        *
  3.  *  Michael Seifert, Hans Henrik St{rfeldt, Tom Madsen, and Katja Nyboe.   *
  4.  *                                                                         *
  5.  *  Merc Diku Mud improvments copyright (C) 1992, 1993 by Michael          *
  6.  *  Chastain, Michael Quan, and Mitchell Tse.                              *
  7.  *                                                                         *
  8.  *  Envy Diku Mud improvements copyright (C) 1994 by Michael Quan, David   *
  9.  *  Love, Guilherme 'Willie' Arnold, and Mitchell Tse.                     *
  10.  *                                                                         *
  11.  *  Windows sockets port by Slash.                                         *
  12.  *                                                                         *
  13.  *  In order to use any part of this Envy Diku Mud, you must comply with   *
  14.  *  the original Diku license in 'license.doc', the Merc license in        *
  15.  *  'license.txt', as well as the Envy license in 'license.nvy'.           *
  16.  *  In particular, you may not remove either of these copyright notices.   *
  17.  *                                                                         *
  18.  *  Thanks to abaddon for proof-reading our comm.c and pointing out bugs.  *
  19.  *  Any remaining bugs are, of course, our work, not his.  :)              *
  20.  *                                                                         *
  21.  *  Much time and thought has gone into this software and you are          *
  22.  *  benefitting.  We hope that you share your changes too.  What goes      *
  23.  *  around, comes around.                                                  *
  24.  ***************************************************************************/
  25. #include <time.h>
  26. #include <stdio.h>
  27. #include <stdlib.h>
  29. //#include "telnet.h"
  31. #include "merc.h"
  32. #include "merc-win.rh"
  34. #include <windows.h>
  36. // Yes, we want mobprogram support
  37. #define MOBPROGS
  39. // Yes, we want support for Merc 2.2 for Windows additions
  40. #define MERCW32
  42. #define STDERR_FILE "stderr.txt" /* For what Unix writes to standard error */
  44. /*
  45.  * Definitions for the TELNET protocol.
  46.  */
  47. #define IAC 255 /* interpret as command: */
  48. #define WONT 252 /* I won't use option */
  49. #define WILL 251 /* I will use option */
  50. #define GA 249    /* you may reverse the line */
  52. /* telnet options */
  53. #define TELOPT_ECHO 1 /* echo */
  55. struct host_and_name_lookup {
  56.     // These are used by WSAAsyncGetHostByAddr()
  57.     char       hostdata[MAXGETHOSTSTRUCT];
  58.     HANDLE     hRequestHandle;
  59.     struct     in_addr sin_addr;
  61.     // These are used by the identd stuff
  62.     char       username[64];
  63.     SOCKET     sAuth;
  64.     struct sockaddr_in authsock;    // Address of the authentication
  65.     struct sockaddr_in us;          // Address of our socket to this player
  66.     struct sockaddr_in them;        // Address of our socket to this player
  67. };
  69. /* Local #defines for Win32 */
  70. //#define MAKEWORD(a, b)      ((WORD)(((BYTE)(a)) | (((WORD)((BYTE)(b))) << 8)))
  72. #define WM_NET_ACCEPT      (WM_USER+500)
  73. #define WM_NET_READWRITE   (WM_USER+501)
  74. #define WM_NET_GETHOST     (WM_USER+502)
  75. #define WM_NET_AUTHCONNECT (WM_USER+503)
  77. /*
  78.  * Global variables.
  79.  */
  80. DESCRIPTOR_DATA *   descriptor_free; /* Free list for descriptors */
  81. DESCRIPTOR_DATA *   descriptor_list; /* All open descriptors */
  82. DESCRIPTOR_DATA *   d_next; /* Next descriptor in loop */
  83. FILE *     fpReserve; /* Reserved file handle */
  84. bool     god; /* All new chars are gods! */
  85. bool     merc_down; /* Shutdown */
  86. bool     wizlock; /* Game is wizlocked */
  87. int                 numlock = 0;        /* Game is numlocked at <level> (ENVY) */
  88. char     str_boot_time[MAX_INPUT_LENGTH];
  89. time_t     current_time; /* Time of this pulse */
  91. /* Windows version variables */
  92. SOCKET control;
  93. int nPlayers = 0;
  94. int nOldPlayers = 0;
  95. FILE *fpStderr;
  96. BOOL fWantsMessageBox = TRUE; // if TRUE, bring up message box on bugs, else log
  98. /*
  99.  * Other local functions (OS-independent).
  100.  */
  101. bool check_parse_name args( ( char *name ) );
  102. bool check_reconnect args( ( DESCRIPTOR_DATA *d, char *name,
  103.     bool fConn ) );
  104. bool check_playing args( ( DESCRIPTOR_DATA *d, char *name ) );
  105. int main args( ( int argc, char **argv ) );
  106. void nanny args( ( DESCRIPTOR_DATA *d, char *argument ) );
  107. bool process_output args( ( DESCRIPTOR_DATA *d, bool fPrompt ) );
  108. void read_from_buffer args( ( DESCRIPTOR_DATA *d ) );
  109. void stop_idling args( ( CHAR_DATA *ch ) );
  110. //void    bust_a_prompt           args( ( CHAR_DATA *ch ) );
  111. void    bust_a_prompt           args( ( DESCRIPTOR_DATA *d ) );
  113. // @@@ My junk
  114. //char      UserMessage[512];
  115. //BOOL      fUserReady;
  116. const char echo_off_str [] = { IAC, WILL, TELOPT_ECHO, '' };
  117. const char echo_on_str [] = { IAC, WONT, TELOPT_ECHO, '' };
  118. const char  go_ahead_str [] = { IAC, GA, '' };
  119. bool write_to_descriptor args( ( int desc, char *txt, int length ) );
  120. bool BlastedTrumpet(SOCKET sSocket);
  121. LRESULT SocketAccept (WPARAM /*wParam*/, LPARAM lParam);
  122. LRESULT SocketReadWrite (WPARAM wParam, LPARAM lParam);
  123. LRESULT SocketGetHost(WPARAM wParam, LPARAM lParam);
  124. LRESULT SocketAuthConnect(WPARAM wParam, LPARAM lParam);
  125. SOCKET init_socket( int port );
  126. bool read_from_descriptor( DESCRIPTOR_DATA *d );
  128. void send_to_char args( ( const char *txt, CHAR_DATA *ch ) )
  129. {
  130.     if ( txt == NULL || ch->desc == NULL )
  131.         return;
  132.     free_string( ch->desc->showstr_head );
  133. #if 0 // @@@ The next line is from sands, it seems wrong
  134.     ch->desc->showstr_head = str_dup( txt );
  135. #else
  136.     ch->desc->showstr_head = alloc_mem( strlen( txt ) + 1 );
  137.     strcpy( ch->desc->showstr_head, txt );
  138. #endif
  139.     ch->desc->showstr_point = ch->desc->showstr_head;
  140.     show_string( ch->desc, "" );
  141. }
  143. void gettimeofday( struct timeval *tp, void *tzp )
  144. {
  145.     tp->tv_sec  = time( NULL );
  146.     tp->tv_usec = 0;
  147. }
  149. #if 0 // @@@
  150. bool read_from_descriptor( DESCRIPTOR_DATA *d )
  151. {
  152.     int iStart;
  154.     /* Hold horses if pending command already. */
  155.     if ( d->incomm[0] != '' )
  156. return TRUE;
  158.     /* Check for overflow. */
  159.     iStart = strlen(d->inbuf);
  160.     if ( iStart >= sizeof(d->inbuf) - 10 )
  161.     {
  162. sprintf( log_buf, "%s input overflow!", d->host );
  163. log_string( log_buf );
  164. write_to_descriptor( d->descriptor,
  165.     "nr*** PUT A LID ON IT!!! ***nr", 0 );
  166. return FALSE;
  167.     }
  169. #if 0
  170.     /* Snarf input. */
  171.     for ( ; ; )
  172.     {
  173. int c;
  174. c = getc( stdin );
  175. if ( c == '' || c == EOF )
  176.     break;
  177. putc( c, stdout );
  178. if ( c == 'r' )
  179.     putc( 'n', stdout );
  180. d->inbuf[iStart++] = c;
  181. if ( iStart > sizeof(d->inbuf) - 10 )
  182.     break;
  183.     }
  184. #else
  185.     if (fUserReady)
  186.        {
  187.        int nLen = strlen(UserMessage);
  188.        fUserReady = FALSE;
  189.        if (iStart + nLen <= sizeof d->inbuf - 10)
  190.           {
  191.           memcpy(d->inbuf + iStart, UserMessage, nLen);
  192.           iStart += nLen;
  193.           d->inbuf[iStart++] = 'r';
  194.           }
  195.        }
  196. #endif
  198.     d->inbuf[iStart] = '';
  199.     return TRUE;
  200. }
  201. #endif
  204. /*
  205.  * Transfer one line from input buffer to input line.
  206.  */
  207. void read_from_buffer( DESCRIPTOR_DATA *d )
  208. {
  209.     int i, j, k;
  211.     /*
  212.      * Hold horses if pending command already.
  213.      */
  214.     if ( d->incomm[0] != '' )
  215. return;
  217.     /*
  218.      * Look for at least one new line.
  219.      */
  220.     for ( i = 0; d->inbuf[i] != 'n' && d->inbuf[i] != 'r'; i++ )
  221.     {
  222. if ( d->inbuf[i] == '' )
  223.     return;
  224.     }
  226.     /*
  227.      * Canonical input processing.
  228.      */
  229.     for ( i = 0, k = 0; d->inbuf[i] != 'n' && d->inbuf[i] != 'r'; i++ )
  230.     {
  231. if ( k >= MAX_INPUT_LENGTH - 2 )
  232. {
  233.     write_to_descriptor( d->descriptor, "Line too long.nr", 0 );
  235.     /* skip the rest of the line */
  236.     for ( ; d->inbuf[i] != ''; i++ )
  237.     {
  238. if ( d->inbuf[i] == 'n' || d->inbuf[i] == 'r' )
  239.     break;
  240.     }
  241.     d->inbuf[i]   = 'n';
  242.     d->inbuf[i+1] = '';
  243.     break;
  244. }
  246. if ( d->inbuf[i] == 'b' && k > 0 )
  247.     --k;
  248. else if ( isascii(d->inbuf[i]) && isprint(d->inbuf[i]) )
  249.     d->incomm[k++] = d->inbuf[i];
  250.     }
  252.     /*
  253.      * Finish off the line.
  254.      */
  255.     if ( k == 0 )
  256. d->incomm[k++] = ' ';
  257.     d->incomm[k] = '';
  259.     /*
  260.      * Deal with bozos with #repeat 1000 ...
  261.      */
  262.     if ( k > 1 || d->incomm[0] == '!' )
  263.     {
  264.      if ( d->incomm[0] != '!' && strcmp( d->incomm, d->inlast ) )
  265. {
  266.     d->repeat = 0;
  267. }
  268. else
  269. {
  270.     if ( ++d->repeat >= 20 )
  271.     {
  272. sprintf( log_buf, "%s input spamming!", d->host );
  273. log_string( log_buf );
  274. write_to_descriptor( d->descriptor,
  275.     "nr*** PUT A LID ON IT!!! ***nr", 0 );
  276. strcpy( d->incomm, "quit" );
  277.     }
  278. }
  279.     }
  281.     /*
  282.      * Do '!' substitution.
  283.      */
  284.     if ( d->incomm[0] == '!' )
  285. strcpy( d->incomm, d->inlast );
  286.     else
  287. strcpy( d->inlast, d->incomm );
  289.     /*
  290.      * Shift the input buffer.
  291.      */
  292.     while ( d->inbuf[i] == 'n' || d->inbuf[i] == 'r' )
  293. i++;
  294.     for ( j = 0; ( d->inbuf[j] = d->inbuf[i+j] ) != ''; j++ )
  295. ;
  296.     return;
  297. }
  299. void CloseMerc(void)
  300. {
  301. }
  303. HINSTANCE hInst;
  304. HWND      hQryDlgBox;                         // handle of modeless dialog box
  305. HWND      hWndMain;
  306. HWND      hWndOutput;
  307. //char      UserMessage[512];
  308. //bool      fUserReady;
  310. LRESULT CALLBACK _export MercWndProc(HWND hWnd, UINT message,
  311.                              WPARAM wParam, LPARAM lParam)
  312. {
  313.     switch (message)
  314.     {
  315.         case WM_MOVE:
  316.             // Move the dialog box on top of our main window every
  317.             // time the main window moves.
  318.             if (IsWindow(hQryDlgBox))
  319.                 SendMessage(hQryDlgBox, message, wParam, lParam);
  320.             break;
  322.         case WM_SETFOCUS:
  323.             // Always set the input focus to the dialog box.
  324.             if (IsWindow(hQryDlgBox))
  325.                 SendMessage(hQryDlgBox, message, wParam, lParam);
  326.             break;
  328.         case WM_CLOSE:
  329.             // Tell windows to destroy our window.
  330.             DestroyWindow(hWnd);
  331.             break;
  333.         case WM_QUERYENDSESSION:
  334.             // If we return TRUE we are saying it's ok with us to end the
  335. // windows session.
  336.             return((long) TRUE);  // we agree to end session.
  338.         case WM_ENDSESSION:
  339.             // If wParam is not zero, it meany every application said ok
  340.             // to WM_QUERYENDSESSION messages, so we are really ending.
  341.             if (wParam)           // if all apps aggreed to end session.
  342.                 CloseMerc();     // This is the end. We will not get a
  343.                                    // WM_DESTROY message on end session.
  344.             break;
  346.         case WM_DESTROY:
  347.             // This is the end if we were closed by a DestroyWindow call.
  349.             CloseMerc();
  350. PostQuitMessage(0);
  351.             break;
  353.         default:
  354.             return(DefWindowProc(hWnd, message, wParam, lParam));
  355.     }
  357.     return(0L);
  358. }
  360. BOOL CALLBACK _export MercDlgProc(HWND hDlg, UINT message,
  361.                            WPARAM wParam, LPARAM lParam)
  362. {
  363.     static RECT   wrect;
  365.     int           x, y, w, h, i;
  366.     long          rc;
  367. //    char         *cp, *cpd, tmp[30], sdrives[30];
  368. //    HANDLE        hCursor;
  369.     HWND hWndInput;
  371.     switch (message)
  372.     {
  373.         case WM_INITDIALOG:
  374.             // Save the handle of this proc for use by main window proc.
  375.             hQryDlgBox = hDlg;
  377.             // Save the handle to the output window
  378.             hWndOutput = GetDlgItem(hDlg, 102);
  379. //            SendMessage(hWndOutput, WM_SETFONT,
  380. //               (WPARAM) GetStockObject(SYSTEM_FIXED_FONT), 0);
  381.             SetFocus(GetDlgItem(hDlg, 101));
  383.             // Get position of dialog box window.
  384.             GetWindowRect(hDlg, (LPRECT) &wrect);
  385.             w = wrect.right - wrect.left;
  386.             h = wrect.bottom - wrect.top;
  388.             // Move main application window to same position.
  389.             SetWindowPos(hWndMain, hDlg,
  390.                          wrect.left, wrect.top, w, h,
  391.                          0);
  393.             // Tell Winsock we are listening for accepted sockets
  394.             WSAAsyncSelect(control, hDlg, WM_NET_ACCEPT, FD_ACCEPT);
  395.             break;
  397.         case WM_MOVE:
  398.             // Always keep this dialog box on top of main window.
  399.             GetWindowRect(hWndMain, (LPRECT) &wrect);
  400.             x = wrect.left;
  401.             y = wrect.top;
  402.             w = wrect.right - wrect.left;
  403.             h = wrect.bottom - wrect.top;
  404.             MoveWindow(hDlg, x, y, w, h, 1);
  405.             break;
  407.         case WM_SYSCOMMAND:
  408.             // Pass WM_SYSCOMMAND messages on to main window so both
  409.             // main window and dialog box get iconized, minimized etc.
  410.             // in parallel.
  411.             SendMessage(hWndMain, message, wParam, lParam);
  412.             break;
  414.         case WM_COMMAND:
  415.             switch (LOWORD(wParam))
  416.             {
  417. #if 0 // @@@
  418.                 case IDOK:
  419.                     hWndInput = GetDlgItem(hDlg, 101);
  420.                     SendMessage(hWndInput, WM_GETTEXT, sizeof UserMessage, (LPARAM) UserMessage);
  421.                     SendMessage(hWndInput, WM_SETTEXT, 0, (LPARAM) "");
  422.                     SetFocus(hWndInput);
  423.                     fUserReady = TRUE;
  424.                     break;
  425. #endif
  426.                 case IDCANCEL:                  // Cancel button
  427.                     // Tell main application window we want to quit.
  428.                     SendMessage(hWndMain, WM_CLOSE, 0, 0L);
  429.                     break;
  431.                 default:
  432.                     break;
  433.             }
  434.             break;
  436.         case WM_CLOSE:
  437.             // Unlock dialog resource we locked above.
  439.             // Zero handle to this dialog window.
  440.             hQryDlgBox = 0;
  442.             // Tell main window to close.
  443.             PostMessage(hWndMain, WM_CLOSE, 0, 0L);
  445.             // Destroy ourseleves.
  446.             DestroyWindow(hDlg);
  447.             break;
  449.         case WM_NET_ACCEPT:
  450.            SocketAccept(wParam, lParam);
  451.            break;
  453.         case WM_NET_READWRITE:
  454.            SocketReadWrite(wParam, lParam);
  455.            break;
  457.         case WM_NET_GETHOST:
  458.            SocketGetHost(wParam, lParam);
  459.            break;
  461.         case WM_NET_AUTHCONNECT:
  462.            SocketAuthConnect(wParam, lParam);
  463.            break;
  465.         default:
  466.             return FALSE;
  467.     }
  469.     return(TRUE);
  470. }
  472. void InitMerc22(HINSTANCE hInstance, int cmdShow)
  473. {
  474.     WNDCLASS wcMercClass;
  476.     // Define the window class for this application.
  477.     wcMercClass.lpszClassName = "Merc22";
  478.     wcMercClass.hInstance     = hInstance;
  479.     wcMercClass.lpfnWndProc   = MercWndProc;
  480.     wcMercClass.hCursor       = LoadCursor(NULL, IDC_ARROW);
  481. //    wcMercClass.hIcon         = LoadIcon(hInstance, SetUpData.szAppName);
  482.     wcMercClass.hIcon         = 0;
  483.     wcMercClass.lpszMenuName  = (LPSTR) NULL;
  484.     wcMercClass.hbrBackground = GetStockObject(WHITE_BRUSH);
  485.     wcMercClass.style         = CS_HREDRAW | CS_VREDRAW;
  486.     wcMercClass.cbClsExtra    = 0;
  487.     wcMercClass.cbWndExtra    = 0;
  489.     // Register the class
  490.     if (RegisterClass(&wcMercClass) == 0)
  491.        {
  492.        MessageBox(0, "Could not create Window", "@@@", MB_ICONHAND|MB_OK);
  493.        exit(1);
  494.        }
  496.     hInst = hInstance;       // save for use by window procs
  498.     // Create applications main window.
  499.     hWndMain = CreateWindow(
  500.                   "Merc22",
  501.                   "Welcome to Merc22/Win32",
  502.                     WS_BORDER |
  503.                     WS_CAPTION |
  504.                     WS_SYSMENU |
  505.                     WS_MINIMIZEBOX,
  506.                   10,
  507.                   19,
  508.                   256,
  509.                   123,
  510.                   NULL,
  511.                   NULL,
  512.                   hInstance,
  513.                   NULL
  514.                   );
  516.     CreateDialog(hInst, MAKEINTRESOURCE(1), hWndMain, (DLGPROC) MercDlgProc);
  517.     ShowWindow(hWndMain, cmdShow);
  518.     UpdateWindow(hWndMain);
  519. }
  521. /*int SpinTheMessageLoop()
  522. {
  523.    MSG msg;
  524.    if (PeekMessage(&msg, NULL, NULL, NULL, PM_REMOVE))
  525.       {
  526.       if (msg.message == WM_QUIT)
  527.          return FALSE;
  529.       if (!IsDialogMessage(hQryDlgBox, &msg))
  530.          {
  531.          TranslateMessage(&msg);
  532.          DispatchMessage(&msg);
  533.          }
  534.       }
  536.    return TRUE;
  537. }*/
  539. WPARAM game_loop_win32(HINSTANCE hInstance, HINSTANCE hPrevInstance, int nCmdShow)
  540. {
  541. //    static DESCRIPTOR_DATA dcon;
  542.     DESCRIPTOR_DATA *d;
  543.     MSG   msg;
  544.     DWORD dwTick = 0;
  545.     int   fBackground;
  546. extern char * help_greeting;
  547. //   HDC hDC;
  548.     char szBuffer[128];
  550.    extern int nAllocString;
  551.    extern int sAllocString;
  552.    extern int nAllocPerm;
  553.    extern int sAllocPerm;
  554.    static int nOldNString = -1;
  555.    static int nOldSString = -1;
  556.    static int nOldNPerm = -1;
  557.    static int nOldSPerm = -1;
  559.     /* Main loop */
  561. //    // Go init this application.
  562. //    InitMerc22(hInstance, nCmdShow);
  564.     // Get and dispatch messages for this applicaton.
  565.     fBackground = FALSE;
  566.     for ( ;; )
  567.         {
  568.         // Always give Windows messages priority over Merc execution
  569.         if (PeekMessage(&msg, NULL, NULL, NULL, PM_REMOVE))
  570.             {
  571.             if (msg.message == WM_QUIT)
  572.                break;
  574.             if (!IsDialogMessage(hQryDlgBox, &msg))
  575.                {
  576.                TranslateMessage(&msg);
  577.                DispatchMessage(&msg);
  578.                }
  579.             }
  580.        else if (!fBackground)
  581.           {
  582.           fBackground++;
  584.     time( &current_time );
  586. /*
  587.  * Autonomous game motion.
  588.  * (Synchronize to a clock.
  589.  * Busy wait (blargh).)
  590.  */
  591.     if (GetTickCount() - dwTick >= 1000 / PULSE_PER_SECOND)
  592.        {
  593.        dwTick = GetTickCount();
  594. /*
  595.  * Process input.
  596.  */
  597. for ( d = descriptor_list; d != NULL; d = d_next )
  598.    {
  599.        // Give Windows a change to run other programs
  600. //       if (!SpinTheMessageLoop())
  601. //          goto merc_done;
  603.    d_next = d->next;
  604.    d->fcommand = FALSE;
  606.    if ( d->character != NULL )
  607.         d->character->timer = 0;
  609. #if 0
  610.        // Did the user break connection?
  611.    if ( !read_from_descriptor( d ) )
  612.       {
  613.     if ( d->character != NULL )
  614. save_char_obj( d->character );
  615.     d->outtop = 0;
  616.     close_socket( d );
  617.     continue;
  618.     }
  619. #endif
  620.     if ( d->character != NULL && d->character->wait > 0 )
  621.         {
  622.     --d->character->wait;
  623.     continue;
  624.         }
  626.     read_from_buffer( d );
  627.     if ( d->incomm[0] != '' )
  628.     {
  629. d->fcommand = TRUE;
  630. stop_idling( d->character );
  632. if ( d->connected == CON_PLAYING )
  633.     if ( d->showstr_point )
  634.         show_string( d, d->incomm );
  635.     else
  636.         interpret( d->character, d->incomm );
  637. else
  638.     nanny( d, d->incomm );
  640. d->incomm[0] = '';
  641.     }
  642.    }
  644.        update_handler( );
  646.        // Update the screen
  647.        if (nAllocString != nOldNString || sAllocString != nOldSString)
  648.           {
  649.           nOldNString = nAllocString;
  650.           nOldSString = sAllocString;
  651.           wsprintf( szBuffer, "Strings %5d strings of %7d bytes",
  652.              nAllocString, sAllocString);
  653.           SetDlgItemText(hQryDlgBox, 103, szBuffer);
  654.           }
  656.        if (nAllocPerm != nOldNPerm || sAllocPerm != nOldSPerm)
  657.           {
  658.           wsprintf( szBuffer, "Perms   %5d blocks  of %7d bytes",
  659.             nAllocPerm, sAllocPerm );
  660.           nOldNPerm = nAllocPerm;
  661.           nOldSPerm = sAllocPerm;
  662.           SetDlgItemText(hQryDlgBox, 104, szBuffer);
  663.           }
  665.        if (nPlayers != nOldPlayers)
  666.           {
  667.           wsprintf( szBuffer, "%d", nPlayers);
  668.           nOldPlayers = nPlayers;
  669.           SetDlgItemText(hQryDlgBox, 101, szBuffer);
  670.           }
  671. /*
  672.  * Output.
  673.  */
  674. for ( d = descriptor_list; d != NULL; d = d_next )
  675. {
  676.        // Give Windows a change to run other programs
  677. //       if (!SpinTheMessageLoop())
  678. //          goto merc_done;
  680.     d_next = d->next;
  682.     if ( ( d->fcommand || d->outtop > 0 ) )
  683.     {
  684. if ( !process_output( d, TRUE ) && WSAGetLastError() != WSAEWOULDBLOCK)
  685. {
  686.     if ( d->character != NULL )
  687. save_char_obj( d->character );
  688.     d->outtop = 0;
  689.     close_socket( d );
  690. }
  691.     }
  692. }
  695. #if 0
  696. now_time = last_time;
  697. for ( ; ; )
  698. {
  699.     int delta;
  701.     {
  702. if ( dcon.character != NULL )
  703.     dcon.character->timer = 0;
  704. if ( !read_from_descriptor( &dcon ) )
  705. {
  706.     if ( dcon.character != NULL )
  707. save_char_obj( d->character );
  708.     dcon.outtop = 0;
  709.     close_socket( &dcon );
  710. }
  711. #if defined(MSDOS)
  712. break;
  713. #endif
  714.     }
  716.     gettimeofday( &now_time, NULL );
  717.     delta = ( now_time.tv_sec  - last_time.tv_sec  ) * 1000 * 1000
  718.   + ( now_time.tv_usec - last_time.tv_usec );
  719.     if ( delta >= 1000000 / PULSE_PER_SECOND )
  720. break;
  721. }
  722. last_time    = now_time;
  723. current_time = (time_t) last_time.tv_sec;
  724. #endif
  725.        }
  726.    fBackground--;
  727.           }
  728.        }
  729. merc_done:
  731.     return(msg.wParam);
  732. }
  734. //int main( int argc, char **argv )
  735. int PASCAL WinMain(HINSTANCE hInstance, HINSTANCE hPrev, LPSTR lpszCmdLine, int nCmdShow)
  736. {
  737.     extern char * help_greeting;
  738.     struct timeval now_time;
  739.     int port;
  741. //#if defined(unix)
  742. //    int control;
  743. //#endif
  744. #ifdef WIN32
  745.    WORD wVersionRequested = MAKEWORD( 1, 1 );
  747.    WSADATA wsaData;
  748.    int err;
  749. #endif
  751.     /*
  752.      * Memory debugging if needed.
  753.      */
  754. #if defined(MALLOC_DEBUG)
  755.     malloc_debug( 2 );
  756. #endif
  758.     /*
  759.      * Init time.
  760.      */
  761.     gettimeofday( &now_time, NULL );
  762.     current_time = (time_t) now_time.tv_sec;
  763.     strcpy( str_boot_time, ctime( &current_time ) );
  765. #if 0
  766.     /*
  767.      * Reserve one channel for our use.
  768.      */
  769.     if ( ( fpReserve = fopen( NULL_FILE, "r" ) ) == NULL )
  770.     {
  771. perror( NULL_FILE );
  772. return 1;
  773.     }
  774. #endif
  776. #if 0 // @@@
  777.     /*
  778.      * Get the port number.
  779.      */
  780.     port = 1234;
  781.     if ( lpszCmdLine[0] )
  782.     {
  783. if ( !is_number( lpszCmdLine ) )
  784. {
  785. //     fprintf( stderr, "Usage: Merc22sv [port #]n" );
  786.        MessageBox(0, "Usage: Merc22sv [port #]", "Merc22", MB_ICONHAND|MB_OK);
  787.     return 1;
  788. }
  789. #if 0
  790. else if ( ( port = atoi( lpszCmdLine ) ) <= 1024 )
  791. {
  792.     fprintf( stderr, "Port number must be above 1024.n" );
  793.     return 1;
  794. }
  795. #endif
  796.     }
  797. #else
  798.     port = GetProfileInt("MercW32", "PortNum", 23); // %%%
  799. #endif
  801. #ifdef WIN32
  802.    err = WSAStartup( wVersionRequested, &wsaData );
  803.    if ( err != 0 ) {
  804.       MessageBox(0, "No useable WINSOCK.DLL, not loading sockets", "Serv",
  805.          MB_ICONHAND|MB_OK);
  807.       return INVALID_SOCKET;
  808.       }
  810.    /* Confirm that the Windows Sockets DLL supports 1.1.*/
  811.    /* Note that if the DLL supports versions greater    */
  812.    /* than 1.1 in addition to 1.1, it will still return */
  813.    /* 1.1 in wVersion since that is the version we      */
  814.    /* requested.                                        */
  816.    if ( LOBYTE( wsaData.wVersion ) != 1 ||
  817.          HIBYTE( wsaData.wVersion ) != 1 ) {
  818.       /* Tell the user that we couldn't find a useable */
  819.       /* winsock.dll.                                  */
  820.       WSACleanup( );
  821.       MessageBox(0, "Windows sockets version not 1.1, not loading sockets", "Serv",
  822.          MB_ICONHAND|MB_OK);
  824.       return INVALID_SOCKET;
  825.       }
  827.    /* Make sure that the version requested is >= 1.1.   */
  828.    /* The low byte is the major version and the high    */
  829.    /* byte is the minor version.                        */
  831.    if ( LOBYTE( wVersionRequested ) < 1 ||
  832.         ( LOBYTE( wVersionRequested ) == 1 &&
  833.           HIBYTE( wVersionRequested ) < 1 )) {
  834.       MessageBox(0, "Windows sockets version not 1.1, not loading sockets", "Serv",
  835.          MB_ICONHAND|MB_OK);
  837.        return INVALID_SOCKET;
  838.    }
  840.    /* Since we only support 1.1, set both wVersion and  */
  841.    /* wHighVersion to 1.1.                              */
  843. //   wsaData.wVersion = MAKEWORD( 1, 1 );
  844. //   wsaData.wHighVersion = MAKEWORD( 1, 1 );
  845. #endif
  847.     // Go init this application.
  848.     fpStderr = fopen( STDERR_FILE, "a" );
  849.     InitMerc22(hInstance, nCmdShow);
  851.     // Load the areas
  852.     log_string( "Loading areas" );
  853.     UpdateWindow(hWndOutput);
  854.     boot_db( );
  856.     // Validate enough of zones loaded to run Merc
  857.     if (help_greeting == 0)
  858.        log_string( "Error: areas.lst did not include help.are.  Game will crash when players log in" );
  859. #ifdef MERCW32
  860.     if (get_obj_index(OBJ_VNUM_ERROR) == 0)
  861.        {
  862.        log_string( "Error: Object #4 missing (check limbo.are).  MercW32 needs object #4");
  863.        log_string( "  to prevent crashes when players with invalid equipment log in.");
  864.        log_string( "  check LIMBO.ARE");
  865.        }
  866. #endif
  867.     if (get_obj_index(OBJ_VNUM_MONEY_ONE) == 0 || get_obj_index(OBJ_VNUM_MONEY_SOME) == 0)
  868.        log_string( "Error: Money objects #2 #3 did not load.  Check LIMBO.ARE");
  869.     if (get_obj_index(OBJ_VNUM_CORPSE_NPC) == 0 || get_obj_index(OBJ_VNUM_CORPSE_PC) == 0)
  870.        log_string( "Error: Corpse templates did not load.  Check LIMBO.ARE");
  871.     if (get_obj_index(OBJ_VNUM_SEVERED_HEAD) == 0 || get_obj_index(OBJ_VNUM_TORN_HEART) == 0 ||
  872.         get_obj_index(OBJ_VNUM_SLICED_ARM) == 0 || get_obj_index(OBJ_VNUM_SLICED_LEG) == 0 ||
  873.         get_obj_index(OBJ_VNUM_FINAL_TURD) == 0)
  874.        log_string( "Error: Severed body parts did not load.  Check LIMBO.ARE");
  875.     if (get_obj_index(OBJ_VNUM_MUSHROOM) == 0 || get_obj_index(OBJ_VNUM_LIGHT_BALL) == 0 ||
  876.         get_obj_index(OBJ_VNUM_SPRING) == 0)
  877.        log_string( "Error: Spell objects did not load.  Check LIMBO.ARE #20 #21 #22");
  878.     if (get_obj_index(OBJ_VNUM_SCHOOL_MACE) == 0 || get_obj_index(OBJ_VNUM_SCHOOL_DAGGER) == 0 ||
  879.         get_obj_index(OBJ_VNUM_SCHOOL_SWORD) == 0 || get_obj_index(OBJ_VNUM_SCHOOL_VEST) == 0 ||
  880.         get_obj_index(OBJ_VNUM_SCHOOL_SHIELD) == 0 || get_obj_index(OBJ_VNUM_SCHOOL_BANNER) == 0)
  881.        log_string( "Error: New player equipment did not load.  Check SCHOOL.ARE");
  882.     if (get_room_index(ROOM_VNUM_LIMBO) == 0)
  883.        log_string( "Error: The Void did not load.  Check LIMBO.ARE");
  884.     if (get_room_index(ROOM_VNUM_CHAT) == 0)
  885.        log_string( "Error:  Immortal chat-room did not load.  Check HITOWER.ARE");
  886.     if (get_room_index(ROOM_VNUM_TEMPLE) == 0 || get_room_index(ROOM_VNUM_ALTAR) == 0)
  887.        log_string( "Error: Midgaard temple and Alter necessary for game.  Check MIDGAARD.ARE");
  888.     if (get_room_index(ROOM_VNUM_SCHOOL) == 0)
  889.        log_string( "Error: New player initial room did not load.  Check SCHOOL.ARE" );
  891.     // #define MOB_VNUM_CITYGUARD    3060
  892.     // #define MOB_VNUM_VAMPIRE    3404
  893.     // #define MOB_VNUM_WALKING_DEAD 20
  895.     // Initialize sockets
  896.     log_string( "Initializing sockets" );
  897.     UpdateWindow(hWndOutput);
  898.     control = init_socket( port );
  900.     // Tell Winsock we are listening for accepted sockets
  901.     WSAAsyncSelect(control, hQryDlgBox, WM_NET_ACCEPT, FD_ACCEPT);
  903.     sprintf( log_buf, "Merc is ready to rock on port %d.", port );
  904.     log_string( log_buf );
  905.     game_loop_win32(hInstance, hPrev, nCmdShow);
  906.     closesocket( control );
  908.     /*
  909.      * That's all, folks.
  910.      */
  911.     log_string( "Normal termination of game." );
  912.     fclose(fpStderr);
  914. #ifdef WIN32
  915.     WSACleanup( );
  916. #endif
  918.     return 0;
  919. }
  921. // @@@ Orig junk
  923. /*
  924.  * The primary output interface for formatted output.
  925.  */
  926. void act( const char *format, CHAR_DATA *ch, const void *arg1,
  927.  const void *arg2, int type )
  928. {
  929.     static char * const he_she [] = { "it",  "he",  "she" };
  930.     static char * const him_her [] = { "it",  "him", "her" };
  931.     static char * const his_her [] = { "its", "his", "her" };
  933.     char buf[MAX_STRING_LENGTH];
  934.     char fname[MAX_INPUT_LENGTH];
  935.     CHAR_DATA *to;
  936.     CHAR_DATA *vch = (CHAR_DATA *) arg2;
  937.     OBJ_DATA *obj1 = (OBJ_DATA  *) arg1;
  938.     OBJ_DATA *obj2 = (OBJ_DATA  *) arg2;
  939.     const char *str;
  940.     const char *i;
  941.     char *point;
  943.     /*
  944.      * Discard null and zero-length messages.
  945.      */
  946.     if ( format == NULL || format[0] == '' )
  947. return;
  949.     to = ch->in_room->people;
  950.     if ( type == TO_VICT )
  951.     {
  952. if ( vch == NULL )
  953. {
  954.     bug( "Act: null vch with TO_VICT.", 0 );
  955.     return;
  956. }
  957. to = vch->in_room->people;
  958.     }
  959.     
  960.     for ( ; to != NULL; to = to->next_in_room )
  961.     {
  962. if ( ( to->desc == NULL 
  963.     && ( IS_NPC( to ) && !(to->pIndexData->progtypes & ACT_PROG ) ) )
  964.     || !IS_AWAKE(to) )
  965.     continue;
  967. if ( type == TO_CHAR && to != ch )
  968.     continue;
  969. if ( type == TO_VICT && ( to != vch || to == ch ) )
  970.     continue;
  971. if ( type == TO_ROOM && to == ch )
  972.     continue;
  973. if ( type == TO_NOTVICT && (to == ch || to == vch) )
  974.     continue;
  976. point = buf;
  977. str = format;
  978. while ( *str != '' )
  979. {
  980.     if ( *str != '$' )
  981.     {
  982. *point++ = *str++;
  983. continue;
  984.     }
  985.     ++str;
  987.     if ( arg2 == NULL && *str >= 'A' && *str <= 'Z' )
  988.     {
  989. bug( "Act: missing arg2 for code %d.", *str );
  990. i = " <@@@> ";
  991.     }
  992.     else
  993.     {
  994. switch ( *str )
  995. {
  996. default:  bug( "Act: bad code %d.", *str );
  997.   i = " <@@@> "; break;
  998. /* Thx alex for 't' idea */
  999. case 't': i = (char *) arg1; break;
  1000. case 'T': i = (char *) arg2;           break;
  1001. case 'n': i = PERS( ch,  to  ); break;
  1002. case 'N': i = PERS( vch, to  ); break;
  1003. case 'e': i = he_she  [URANGE(0, ch  ->sex, 2)]; break;
  1004. case 'E': i = he_she  [URANGE(0, vch ->sex, 2)]; break;
  1005. case 'm': i = him_her [URANGE(0, ch  ->sex, 2)]; break;
  1006. case 'M': i = him_her [URANGE(0, vch ->sex, 2)]; break;
  1007. case 's': i = his_her [URANGE(0, ch  ->sex, 2)]; break;
  1008. case 'S': i = his_her [URANGE(0, vch ->sex, 2)]; break;
  1010. case 'p':
  1011.     i = can_see_obj( to, obj1 )
  1012.     ? obj1->short_descr
  1013.     : "something";
  1014.     break;
  1016. case 'P':
  1017.     i = can_see_obj( to, obj2 )
  1018.     ? obj2->short_descr
  1019.     : "something";
  1020.     break;
  1022. case 'd':
  1023.     if ( arg2 == NULL || ((char *) arg2)[0] == '' )
  1024.     {
  1025. i = "door";
  1026.     }
  1027.     else
  1028.     {
  1029. one_argument( (char *) arg2, fname );
  1030. i = fname;
  1031.     }
  1032.     break;
  1033. }
  1034.     }
  1036.     ++str;
  1037.     while ( ( *point = *i ) != '' )
  1038. ++point, ++i;
  1039. }
  1041. *point++ = 'n';
  1042. *point++ = 'r';
  1043.    // @@@ Following line added by Slash, to prevent bugs where stuff in the
  1044.    // buffers fires mobprogs.  Particularly bad when a player enters the game
  1045.    // and gets the greet_prog over and over.
  1046.    *point = '';
  1047. buf[0]   = UPPER(buf[0]);
  1048. if (to->desc)
  1049.   write_to_buffer( to->desc, buf, point - buf );
  1050. #ifdef MOBPROGS
  1051. if (MOBtrigger)
  1052.   mprog_act_trigger( buf, to, ch, obj1, vch );
  1053.                                             /* Added by Kahn */
  1054. #endif
  1055.     }
  1057. #ifdef MOBPROGS
  1058.     MOBtrigger = TRUE;
  1059. #endif
  1060.     return;
  1061. }
  1063. /*
  1064.  * Append onto an output buffer.
  1065.  */
  1066. void write_to_buffer( DESCRIPTOR_DATA *d, const char *txt, int length )
  1067. {
  1068.     /* @@@ ECS */
  1069.     if (d == 0)
  1070.        return;
  1071.        
  1072.     /*
  1073.      * Find length in case caller didn't.
  1074.      */
  1075.     if ( length <= 0 )
  1076. length = strlen(txt);
  1077.    // @@@
  1078. //   else if (length < strlen(txt))
  1079. //      MessageBox(0, "Length Error", "Merc22Sv", MB_ICONHAND|MB_OK);
  1081.     /*
  1082.      * Initial nr if needed.
  1083.      */
  1084.     if ( d->outtop == 0 && !d->fcommand )
  1085.     {
  1086. d->outbuf[0] = 'n';
  1087. d->outbuf[1] = 'r';
  1088. d->outtop = 2;
  1089.     }
  1091.     /*
  1092.      * Expand the buffer as needed.
  1093.      */
  1094.     while ( d->outtop + length >= d->outsize )
  1095.     {
  1096. char *outbuf;
  1098. outbuf      = alloc_mem( 2 * d->outsize );
  1099. #if 1 // @@@ Deal with too large a memory increment...
  1100.    if (!outbuf)
  1101.       {
  1102.       length = d->outsize - d->outtop - 1;
  1103.       break;
  1104.       }
  1105. #endif
  1106.    strncpy( outbuf, d->outbuf, d->outtop );
  1107. free_mem( d->outbuf, d->outsize );
  1108. d->outbuf   = outbuf;
  1109. d->outsize *= 2;
  1110.     }
  1112.     /*
  1113.      * Copy.
  1114.      */
  1115. //@@@ Ack!    strcpy( d->outbuf + d->outtop, txt );
  1116. #if 1
  1117.     if (length > 0)
  1118.        {
  1119. #endif
  1120.     memcpy(d->outbuf + d->outtop, txt, length);
  1121.     d->outtop += length;
  1122. #if 1
  1123.        }
  1124. #endif
  1126. #ifdef WIN32
  1127.     // Tell Winsock to wake us when the socket becomes ready
  1128.     if (!BlastedTrumpet(d->descriptor))
  1129.        {
  1130.  if ( d->character != NULL )
  1131.     save_char_obj( d->character );
  1132.  d->outtop = 0;
  1133.  close_socket( d );
  1134.        }
  1135. #endif
  1137.     return;
  1138. }
  1140. void close_socket( DESCRIPTOR_DATA *dclose )
  1141. {
  1142.     CHAR_DATA *ch;
  1144.     if ( dclose->outtop > 0 )
  1145. process_output( dclose, FALSE );
  1147.     if ( dclose->snoop_by != NULL )
  1148.     {
  1149. write_to_buffer( dclose->snoop_by,
  1150.     "Your victim has left the game.nr", 0 );
  1151.     }
  1153.     {
  1154. DESCRIPTOR_DATA *d;
  1156. for ( d = descriptor_list; d != NULL; d = d->next )
  1157. {
  1158.     if ( d->snoop_by == dclose )
  1159. d->snoop_by = NULL;
  1160. }
  1161.     }
  1163.     if ( ( ch = dclose->character ) != NULL )
  1164.     {
  1165. sprintf( log_buf, "Closing link to %s.", ch->name );
  1166. log_string( log_buf );
  1167. if ( dclose->connected == CON_PLAYING )
  1168. {
  1169.     act( "$n has lost $s link.", ch, NULL, NULL, TO_ROOM );
  1170.     ch->desc = NULL;
  1171. }
  1172. else
  1173. {
  1174.     free_char( dclose->character );
  1175. }
  1176.     }
  1178.     if ( d_next == dclose )
  1179. d_next = d_next->next;
  1181.     if ( dclose == descriptor_list )
  1182.     {
  1183. descriptor_list = descriptor_list->next;
  1184.     }
  1185.     else
  1186.     {
  1187. DESCRIPTOR_DATA *d;
  1189. for ( d = descriptor_list; d && d->next != dclose; d = d->next )
  1190.     ;
  1191. if ( d != NULL )
  1192.     d->next = dclose->next;
  1193. else
  1194.     bug( "Close_socket: dclose not found.", 0 );
  1195.     }
  1197.     closesocket( dclose->descriptor );
  1198.     free_string( dclose->host );
  1199.     dclose->next = descriptor_free;
  1200.     descriptor_free = dclose;
  1201.     nPlayers--;
  1202.     
  1203.     return;
  1204. }
  1206. // Write_to_descriptor bypasses the whole buffered output system.  Blech!
  1207. bool write_to_descriptor( int desc, char *txt, int length )
  1208. {
  1209.    int iStart;
  1210.    int nWrite;
  1211.    int nBlock;
  1213.    if ( length <= 0 )
  1214.       length = strlen(txt);
  1216.    for ( iStart = 0; iStart < length; iStart += nWrite )
  1217.       {
  1218.       nBlock = UMIN( length - iStart, 4096 );
  1219.       // @@@ Should check WSAEWOULDBLOCK, and we don't want MessageBox...
  1220.       if ( ( nWrite = send( desc, txt + iStart, nBlock, 0 ) ) == SOCKET_ERROR ||
  1221.          nWrite != nBlock)
  1222.          {
  1223.         log_string( "Write_to_descriptor" );
  1224.          return FALSE;
  1225.          }
  1226.       }
  1228. #ifdef WIN32
  1229.     // Tell Winsock to wake us when the socket becomes ready
  1230.     BlastedTrumpet(desc);
  1231. #endif
  1233.     return TRUE;
  1234. }
  1238. /*
  1239.  * Deal with sockets that haven't logged in yet.
  1240.  */
  1241. void nanny( DESCRIPTOR_DATA *d, char *argument )
  1242. {
  1243.     char buf[MAX_STRING_LENGTH];
  1244.     CHAR_DATA *ch;
  1245.     NOTE_DATA *pnote;
  1246.     char *pwdnew;
  1247.     char *p;
  1248.     int iClass;
  1249.     int iRace;
  1250.     int lines;
  1251.     int notes;
  1252.     bool fOld;
  1254.     while ( isspace(*argument) )
  1255. argument++;
  1257.     ch = d->character;
  1259.     switch ( d->connected )
  1260.     {
  1262.     default:
  1263. bug( "Nanny: bad d->connected %d.", d->connected );
  1264. close_socket( d );
  1265. return;
  1267.     case CON_GET_NAME:
  1268. if ( argument[0] == '' )
  1269. {
  1270.     close_socket( d );
  1271.     return;
  1272. }
  1274. argument[0] = UPPER(argument[0]);
  1275. if ( !check_parse_name( argument ) )
  1276. {
  1277.     write_to_buffer( d, "Illegal name, try another.nrName: ", 0 );
  1278.     return;
  1279. }
  1281. fOld = load_char_obj( d, argument );
  1282. ch   = d->character;
  1284. if ( IS_SET(ch->act, PLR_DENY) )
  1285. {
  1286.     sprintf( log_buf, "Denying access to %s@%s.", argument, d->host );
  1287.     log_string( log_buf );
  1288.     write_to_buffer( d, "You are denied access.nr", 0 );
  1289.     close_socket( d );
  1290.     return;
  1291. }
  1293. if ( check_reconnect( d, argument, FALSE ) )
  1294. {
  1295.     fOld = TRUE;
  1296. }
  1297. else
  1298. {
  1299.     if ( wizlock && !IS_HERO( ch ) && !ch->wizbit )
  1300.     {
  1301. write_to_buffer( d, "The game is wizlocked.nr", 0 );
  1302. close_socket( d );
  1303. return;
  1304.     }
  1305. }
  1307. if ( fOld )
  1308. {
  1309.     /* Old player */
  1310.     write_to_buffer( d, "Password: ", 0 );
  1311.     write_to_buffer( d, echo_off_str, 0 );
  1312.     d->connected = CON_GET_OLD_PASSWORD;
  1313.     return;
  1314. }
  1315. else
  1316. {
  1317.     /* New player */
  1318.     /* New characters with same name fix by Salem's Lot */
  1319.     if ( check_playing( d, ch->name ) )
  1320.         return;
  1321.     sprintf( buf, "Did I get that right, %s (Y/N)? ", argument );
  1322.     write_to_buffer( d, buf, 0 );
  1323.     d->connected = CON_CONFIRM_NEW_NAME;
  1324.     return;
  1325. }
  1326. //@@@ break;
  1328.     case CON_GET_OLD_PASSWORD:
  1329. #if defined(unix)
  1330. write_to_buffer( d, "nr", 2 );
  1331. #endif
  1333. if ( strcmp( crypt( argument, ch->pcdata->pwd ), ch->pcdata->pwd ) )
  1334. {
  1335.     write_to_buffer( d, "Wrong password.nr", 0 );
  1336.     close_socket( d );
  1337.     return;
  1338. }
  1340. write_to_buffer( d, echo_on_str, 0 );
  1342. if ( check_reconnect( d, ch->name, TRUE ) )
  1343.     return;
  1345. if ( check_playing( d, ch->name ) )
  1346.     return;
  1347.     
  1348. sprintf( log_buf, "%s@%s has connected.", ch->name, d->host );
  1349. log_string( log_buf );
  1350. lines = ch->pcdata->pagelen;
  1351. ch->pcdata->pagelen = 20;
  1352. if ( IS_HERO(ch) )
  1353.     do_help( ch, "imotd" );
  1354. do_help( ch, "motd" );
  1355. ch->pcdata->pagelen = lines;
  1356. d->connected = CON_READ_MOTD;
  1357. break;
  1359.     case CON_CONFIRM_NEW_NAME:
  1360. switch ( *argument )
  1361. {
  1362. case 'y': case 'Y':
  1363.     sprintf( buf, "New character.nrGive me a password for %s: %s",
  1364. ch->name, echo_off_str );
  1365.     write_to_buffer( d, buf, 0 );
  1366.     d->connected = CON_GET_NEW_PASSWORD;
  1367.     break;
  1369. case 'n': case 'N':
  1370.     write_to_buffer( d, "Ok, what IS it, then? ", 0 );
  1371.     free_char( d->character );
  1372.     d->character = NULL;
  1373.     d->connected = CON_GET_NAME;
  1374.     break;
  1376. default:
  1377.     write_to_buffer( d, "Please type Yes or No? ", 0 );
  1378.     break;
  1379. }
  1380. break;
  1382.     case CON_GET_NEW_PASSWORD:
  1383. #if defined(unix)
  1384. write_to_buffer( d, "nr", 2 );
  1385. #endif
  1387. if ( strlen(argument) < 3 )
  1388. {
  1389.     write_to_buffer( d,
  1390. "Password must be at least three characters long.nrPassword: ",
  1391. 0 );
  1392.     return;
  1393. }
  1395. pwdnew = crypt( argument, ch->name );
  1396. for ( p = pwdnew; *p != ''; p++ )
  1397. {
  1398.     if ( *p == '~' )
  1399.     {
  1400. write_to_buffer( d,
  1401.     "New password not acceptable, try again.nrPassword: ",
  1402.     0 );
  1403. return;
  1404.     }
  1405. }
  1407. free_string( ch->pcdata->pwd );
  1408. ch->pcdata->pwd = str_dup( pwdnew );
  1409. write_to_buffer( d, "Please retype password: ", 0 );
  1410. d->connected = CON_CONFIRM_NEW_PASSWORD;
  1411. break;
  1413.     case CON_CONFIRM_NEW_PASSWORD:
  1414. #if defined(unix)
  1415. write_to_buffer( d, "nr", 2 );
  1416. #endif
  1418. if ( strcmp( crypt( argument, ch->pcdata->pwd ), ch->pcdata->pwd ) )
  1419. {
  1420.     write_to_buffer( d, "Passwords don't match.nrRetype password: ",
  1421. 0 );
  1422.     d->connected = CON_GET_NEW_PASSWORD;
  1423.     return;
  1424. }
  1426. write_to_buffer( d, echo_on_str, 0 );
  1427. write_to_buffer( d, "What is your sex (M/F/N)? ", 0 );
  1428. d->connected = CON_GET_NEW_SEX;
  1429. break;
  1431.     case CON_GET_NEW_SEX:
  1432. switch ( argument[0] )
  1433. {
  1434. case 'm': case 'M': ch->sex = SEX_MALE;    break;
  1435. case 'f': case 'F': ch->sex = SEX_FEMALE;  break;
  1436. case 'n': case 'N': ch->sex = SEX_NEUTRAL; break;
  1437. default:
  1438.     write_to_buffer( d, "That's not a sex.nrWhat IS your sex? ", 0 );
  1439.     return;
  1440. }
  1442. #ifdef RACES
  1443. strcpy( buf, "Select a race [" );
  1444. for ( iRace = 0; iRace < MAX_RACE; iRace++ )
  1445. {
  1446.     if ( iRace > 0 )
  1447. strcat( buf, " " );
  1448.     strcat( buf, race_table[iRace].who_name );
  1449. }
  1450. strcat( buf, "]: " );
  1451. write_to_buffer( d, buf, 0 );
  1452. d->connected = CON_GET_NEW_RACE;
  1453. break;
  1455.     case CON_GET_NEW_RACE:
  1456. for ( iRace = 0; iRace < MAX_RACE; iRace++ )
  1457. {
  1458.     if ( !str_cmp( argument, race_table[iRace].who_name ) )
  1459.     {
  1460. ch->race = iRace;
  1461. break;
  1462.     }
  1463. }
  1465. if ( iRace == MAX_RACE )
  1466. {
  1467.     write_to_buffer( d,
  1468. "That's not a race.nrWhat IS your race? ", 0 );
  1469.     return;
  1470. }
  1471. #endif
  1472. strcpy( buf, "Select a class [" );
  1473. for ( iClass = 0; iClass < MAX_CLASS; iClass++ )
  1474. {
  1475.     if ( iClass > 0 )
  1476. strcat( buf, " " );
  1477.     strcat( buf, class_table[iClass].who_name );
  1478. }
  1479. strcat( buf, "]: " );
  1480. write_to_buffer( d, buf, 0 );
  1482. d->connected = CON_GET_NEW_CLASS;
  1483. break;
  1485.     case CON_GET_NEW_CLASS:
  1486. for ( iClass = 0; iClass < MAX_CLASS; iClass++ )
  1487. {
  1488.     if ( !str_cmp( argument, class_table[iClass].who_name ) )
  1489.     {
  1490. ch->class = iClass;
  1491. break;
  1492.     }
  1493. }
  1495. if ( iClass == MAX_CLASS )
  1496. {
  1497.     write_to_buffer( d,
  1498. "That's not a class.nrWhat IS your class? ", 0 );
  1499.     return;
  1500. }
  1502. sprintf( log_buf, "%s@%s new player.", ch->name, d->host );
  1503. log_string( log_buf );
  1504. write_to_buffer( d, "nr", 2 );
  1505. ch->pcdata->pagelen = 20;
  1506. ch->prompt = "<%hhp %mm %vmv> ";
  1507. do_help( ch, "motd" );
  1508. d->connected = CON_READ_MOTD;
  1509. break;
  1511.     case CON_READ_MOTD:
  1512. ch->next = char_list;
  1513. char_list = ch;
  1514. d->connected = CON_PLAYING;
  1516. send_to_char(
  1517.     "nrWelcome to Merc Diku Mud.  May your visit here be ... Mercenary.nr",
  1518.     ch );
  1520. if ( ch->level == 0 )
  1521. {
  1522.     OBJ_DATA *obj;
  1524.     switch ( class_table[ch->class].attr_prime )
  1525.     {
  1526.     case APPLY_STR: ch->pcdata->perm_str = 16; break;
  1527.     case APPLY_INT: ch->pcdata->perm_int = 16; break;
  1528.     case APPLY_WIS: ch->pcdata->perm_wis = 16; break;
  1529.     case APPLY_DEX: ch->pcdata->perm_dex = 16; break;
  1530.     case APPLY_CON: ch->pcdata->perm_con = 16; break;
  1531.     }
  1533. #ifdef RACES
  1534.        ch->pcdata->perm_str += race_table[ch->race].mod_str;
  1535.        ch->pcdata->perm_int += race_table[ch->race].mod_int;
  1536.        ch->pcdata->perm_wis += race_table[ch->race].mod_wis;
  1537.        ch->pcdata->perm_dex += race_table[ch->race].mod_dex;
  1538.        ch->pcdata->perm_con += race_table[ch->race].mod_con;
  1539. #endif
  1541.     ch->level = 1;
  1542.     ch->exp = 1000;
  1543.     ch->hit = ch->max_hit;
  1544.     ch->mana = ch->max_mana;
  1545.     ch->move = ch->max_move;
  1546. #ifdef RACES
  1547.        ch->affected_by = race_table[ch->race].bitvector;
  1548. #else
  1549.        ch->affected_by = 0;
  1550. #endif
  1551.     sprintf( buf, "the %s",
  1552. title_table [ch->class] [ch->level]
  1553. [ch->sex == SEX_FEMALE ? 1 : 0] );
  1554.     set_title( ch, buf );
  1556.     obj = create_object( get_obj_index(OBJ_VNUM_SCHOOL_BANNER), 0 );
  1557.     obj_to_char( obj, ch );
  1558.     equip_char( ch, obj, WEAR_LIGHT );
  1560.     obj = create_object( get_obj_index(OBJ_VNUM_SCHOOL_VEST), 0 );
  1561.     obj_to_char( obj, ch );
  1562.     equip_char( ch, obj, WEAR_BODY );
  1564.     obj = create_object( get_obj_index(OBJ_VNUM_SCHOOL_SHIELD), 0 );
  1565.     obj_to_char( obj, ch );
  1566.     equip_char( ch, obj, WEAR_SHIELD );
  1568.     obj = create_object( get_obj_index(class_table[ch->class].weapon),
  1569. 0 );
  1570.     obj_to_char( obj, ch );
  1571.     equip_char( ch, obj, WEAR_WIELD );
  1573.     char_to_room( ch, get_room_index( ROOM_VNUM_SCHOOL ) );
  1574. }
  1575. else if ( ch->in_room != NULL )
  1576. {
  1577.     char_to_room( ch, ch->in_room );
  1578. }
  1579. else if ( IS_IMMORTAL(ch) )
  1580. {
  1581.     char_to_room( ch, get_room_index( ROOM_VNUM_CHAT ) );
  1582. }
  1583. else
  1584. {
  1585. #ifdef RACES
  1586.     char_to_room( ch, get_room_index( race_table[ch->race].city_temple ) );
  1587. #else
  1588.     char_to_room( ch, get_room_index( ROOM_VNUM_TEMPLE ) );
  1589. #endif
  1590. }
  1592. act( "$n has entered the game.", ch, NULL, NULL, TO_ROOM );
  1593. do_look( ch, "auto" );
  1594. /* check for new notes */
  1595. notes = 0;
  1597. for ( pnote = note_list; pnote != NULL; pnote = pnote->next )
  1598.     if ( is_note_to( ch, pnote ) && str_cmp( ch->name, pnote->sender )
  1599. && pnote->date_stamp > ch->last_note )
  1600.         notes++;
  1602. if ( notes == 1 )
  1603.     send_to_char( "nrYou have one new note waiting.nr", ch );
  1604. else
  1605.     if ( notes > 1 )
  1606.     {
  1607. sprintf( buf, "nrYou have %d new notes waiting.nr",
  1608. notes );
  1609. send_to_char( buf, ch );
  1610.     }
  1612. break;
  1613.     }
  1615.     return;
  1616. }
  1620. /*
  1621.  * Parse a name for acceptability.
  1622.  */
  1623. bool check_parse_name( char *name )
  1624. {
  1625.     /*
  1626.      * Reserved words.
  1627.      */
  1628.     if ( is_name( name, "all auto immortal self someone" ) )
  1629. return FALSE;
  1631.     /*
  1632.      * Length restrictions.
  1633.      */
  1634.     if ( strlen(name) <  3 )
  1635. return FALSE;
  1637. #if defined(MSDOS)
  1638.     if ( strlen(name) >  8 )
  1639. return FALSE;
  1640. #endif
  1642. #if defined(macintosh) || defined(unix)
  1643.     if ( strlen(name) > 12 )
  1644. return FALSE;
  1645. #endif
  1647.     /*
  1648.      * Alphanumerics only.
  1649.      * Lock out IllIll twits.
  1650.      */
  1651.     {
  1652. char *pc;
  1653. bool fIll;
  1655. fIll = TRUE;
  1656. for ( pc = name; *pc != ''; pc++ )
  1657. {
  1658.     if ( !isalpha(*pc) )
  1659. return FALSE;
  1660.     if ( LOWER(*pc) != 'i' && LOWER(*pc) != 'l' )
  1661. fIll = FALSE;
  1662. }
  1664. if ( fIll )
  1665.     return FALSE;
  1666.     }
  1668.     /*
  1669.      * Prevent players from naming themselves after mobs.
  1670.      */
  1671.     {
  1672. extern MOB_INDEX_DATA *mob_index_hash[MAX_KEY_HASH];
  1673. MOB_INDEX_DATA *pMobIndex;
  1674. int iHash;
  1676. for ( iHash = 0; iHash < MAX_KEY_HASH; iHash++ )
  1677. {
  1678.     for ( pMobIndex  = mob_index_hash[iHash];
  1679.   pMobIndex != NULL;
  1680.   pMobIndex  = pMobIndex->next )
  1681.     {
  1682. if ( is_name( name, pMobIndex->player_name ) )
  1683.     return FALSE;
  1684.     }
  1685. }
  1686.     }
  1688.     return TRUE;
  1689. }
  1693. /*
  1694.  * Look for link-dead player to reconnect.
  1695.  */
  1696. bool check_reconnect( DESCRIPTOR_DATA *d, char *name, bool fConn )
  1697. {
  1698.     CHAR_DATA *ch;
  1699.     OBJ_DATA *obj;
  1701.     for ( ch = char_list; ch != NULL; ch = ch->next )
  1702.     {
  1703. if ( !IS_NPC(ch)
  1704. && ( !fConn || ch->desc == NULL )
  1705. &&   !str_cmp( d->character->name, ch->name ) )
  1706. {
  1707.     if ( fConn == FALSE )
  1708.     {
  1709. free_string( d->character->pcdata->pwd );
  1710. d->character->pcdata->pwd = str_dup( ch->pcdata->pwd );
  1711.     }
  1712.     else
  1713.     {
  1714. free_char( d->character );
  1715. d->character = ch;
  1716. ch->desc  = d;
  1717. ch->timer  = 0;
  1718. send_to_char( "Reconnecting.nr", ch );
  1719. act( "$n has reconnected.", ch, NULL, NULL, TO_ROOM );
  1720. sprintf( log_buf, "%s@%s reconnected.", ch->name, d->host );
  1721. log_string( log_buf );
  1722. d->connected = CON_PLAYING;
  1724. /*
  1725.  * Contributed by Gene Choi
  1726.  */
  1727. if ( ( obj = get_eq_char( ch, WEAR_LIGHT ) ) != NULL
  1728.     && obj->item_type == ITEM_LIGHT
  1729.     && obj->value[2] != 0
  1730.     && ch->in_room != NULL )
  1731.     ++ch->in_room->light;
  1732.     }
  1733.     return TRUE;
  1734. }
  1735.     }
  1737.     return FALSE;
  1738. }
  1742. /*
  1743.  * Check if already playing.
  1744.  */
  1745. bool check_playing( DESCRIPTOR_DATA *d, char *name )
  1746. {
  1747.     DESCRIPTOR_DATA *dold;
  1749.     for ( dold = descriptor_list; dold; dold = dold->next )
  1750.     {
  1751. if ( dold != d
  1752. &&   dold->character != NULL
  1753. &&   dold->connected != CON_GET_NAME
  1754. &&   dold->connected != CON_GET_OLD_PASSWORD
  1755. &&   !str_cmp( name, dold->original
  1756.          ? dold->original->name : dold->character->name ) )
  1757. {
  1758.     write_to_buffer( d, "Already playing.nrName: ", 0 );
  1759.     d->connected = CON_GET_NAME;
  1760.     if ( d->character != NULL )
  1761.     {
  1762. free_char( d->character );
  1763. d->character = NULL;
  1764.     }
  1765.     return TRUE;
  1766. }
  1767.     }
  1769.     return FALSE;
  1770. }
  1774. void stop_idling( CHAR_DATA *ch )
  1775. {
  1776.     if ( ch == NULL
  1777.     ||   ch->desc == NULL
  1778.     ||   ch->desc->connected != CON_PLAYING
  1779.     ||   ch->was_in_room == NULL
  1780.     ||   ch->in_room != get_room_index( ROOM_VNUM_LIMBO ) )
  1781. return;
  1783.     ch->timer = 0;
  1784.     char_from_room( ch );
  1785.     char_to_room( ch, ch->was_in_room );
  1786.     ch->was_in_room = NULL;
  1787.     act( "$n has returned from the void.", ch, NULL, NULL, TO_ROOM );
  1788.     return;
  1789. }
  1791. /*
  1792.  * Low level output function.
  1793.  */
  1794. bool process_output( DESCRIPTOR_DATA *d, bool fPrompt )
  1795. {
  1796.     extern bool merc_down;
  1798.     /*
  1799.      * Bust a prompt.
  1800.      */
  1801.     if ( fPrompt && !merc_down && d->connected == CON_PLAYING )
  1802.         if ( d->showstr_point )
  1803.     write_to_buffer( d,
  1804.   "[Please type (c)ontinue, (r)efresh, (b)ack, (h)elp, (q)uit, or RETURN]:  ",
  1805.     0 );
  1806. else
  1807. {
  1808.     CHAR_DATA *ch;
  1810.     ch = d->original ? d->original : d->character;
  1811.     if ( IS_SET(ch->act, PLR_BLANK) )
  1812.         write_to_buffer( d, "nr", 2 );
  1814.     if ( IS_SET(ch->act, PLR_PROMPT) )
  1815. //         bust_a_prompt( ch );
  1816.         bust_a_prompt( d );
  1818.     if ( IS_SET(ch->act, PLR_TELNET_GA) )
  1819.         write_to_buffer( d, go_ahead_str, 0 );
  1820. }
  1822.     /*
  1823.      * Short-circuit if nothing to write.
  1824.      */
  1825.     if ( d->outtop == 0 )
  1826. return TRUE;
  1828.     /*
  1829.      * Snoop-o-rama.
  1830.      */
  1831.     if ( d->snoop_by != NULL )
  1832.     {
  1833. write_to_buffer( d->snoop_by, "% ", 2 );
  1834. write_to_buffer( d->snoop_by, d->outbuf, d->outtop );
  1835.     }
  1837. #if 0
  1838.     /*
  1839.      * OS-dependent output.
  1840.      */
  1841.     if ( !write_to_descriptor( d->descriptor, d->outbuf, d->outtop ) )
  1842.     {
  1843. d->outtop = 0;
  1844. return FALSE;
  1845.     }
  1846.     else
  1847.     {
  1848. d->outtop = 0;
  1849. return TRUE;
  1850.     }
  1851. #endif
  1852.    // Wake up Winsock, if necessary
  1853.     if (!BlastedTrumpet(d->descriptor))
  1854.        {
  1855.  if ( d->character != NULL )
  1856.     save_char_obj( d->character );
  1857.  d->outtop = 0;
  1858.  close_socket( d );
  1859.        return FALSE;
  1860.        }
  1861.    return TRUE;
  1862. }
  1864. /*
  1865.  * Bust a prompt (player settable prompt)
  1866.  * coded by Morgenes for Aldara Mud
  1867.  */
  1868. //void bust_a_prompt( CHAR_DATA *ch )
  1869. void bust_a_prompt( DESCRIPTOR_DATA *d )
  1870. {
  1871.    char buf[MAX_STRING_LENGTH];
  1872.    char buf2[MAX_STRING_LENGTH];
  1873.    const char *str;
  1874.    const char *i;
  1875.    char *point;
  1876.    CHAR_DATA *ch;
  1877.    CHAR_DATA *victim;
  1879.    ch = d->character;
  1881.    if( ch->prompt == NULL || ch->prompt[0] == '' )
  1882.    {
  1883.       send_to_char( "nrnr", ch );
  1884.       return;
  1885.    }
  1887.    point = buf;
  1888.  //  str = ch->prompt;
  1889.    str = d->original != NULL ? d->original->prompt :  /* VERY VERY NEW */
  1890.          d->character->prompt;
  1891.    while( *str != '' )
  1892.    {
  1893.       if( *str != '%' )
  1894.       {
  1895.          *point++ = *str++;
  1896.          continue;
  1897.       }
  1898.       ++str;
  1899.       switch( *str )
  1900.       {
  1901.          default :
  1902.             i = " "; break;
  1903.          case 'h' :
  1904.             sprintf( buf2, "%d", ch->hit );
  1905.             i = buf2; break;
  1906.          case 'H' :
  1907.             sprintf( buf2, "%d", ch->max_hit );
  1908.             i = buf2; break;
  1909.          case 'm' :
  1910.             sprintf( buf2, "%d", ch->mana );
  1911.             i = buf2; break;
  1912.          case 'M' :
  1913.             sprintf( buf2, "%d", ch->max_mana );
  1914.             i = buf2; break;
  1915.          case 'v' :
  1916.             sprintf( buf2, "%d", ch->move );
  1917.             i = buf2; break;
  1918.          case 'V' :
  1919.             sprintf( buf2, "%d", ch->max_move );
  1920.             i = buf2; break;
  1921.          case 'x' :
  1922.             sprintf( buf2, "%d", ch->exp );
  1923.             i = buf2; break;
  1924.          case 'g' :
  1925.             sprintf( buf2, "%d", ch->gold);
  1926.             i = buf2; break;
  1927.          case 'a' :
  1928.             if( ch->level < 5 )
  1929.                sprintf( buf2, "%d", ch->alignment );
  1930.             else
  1931.                sprintf( buf2, "%s", IS_GOOD(ch) ? "good" : IS_EVIL(ch) ?
  1932.                 "evil" : "neutral" );
  1933.             i = buf2; break;
  1934.          case 'r' :
  1935.             if( ch->in_room != NULL )
  1936.                sprintf( buf2, "%s", ch->in_room->name );
  1937.             else
  1938.                sprintf( buf2, " " );
  1939.             i = buf2; break;
  1940.          case 'R' :
  1941.             if( IS_IMMORTAL( ch ) && ch->in_room != NULL )
  1942.                sprintf( buf2, "%d", ch->in_room->vnum );
  1943.             else
  1944.                sprintf( buf2, " " );
  1945.             i = buf2; break;
  1946.          case 'z' :
  1947.             if( IS_IMMORTAL( ch ) && ch->in_room != NULL )
  1948.                sprintf( buf2, "%s", ch->in_room->area->name );
  1949.             else
  1950.                sprintf( buf2, " " );
  1951.             i = buf2; break;
  1952.          case '%' :
  1953.             sprintf( buf2, "%%" );
  1954.             i = buf2; break;
  1955.       }
  1956.       ++str;
  1957.       while( (*point = *i) != '' )
  1958.          ++point, ++i;
  1959.    }
  1960.    
  1961.         /* battle prompt */
  1962.         if ((victim = ch->fighting) != NULL)
  1964.           {
  1965.             int percent;
  1966.             char wound[100];
  1967.             char buf[MAX_STRING_LENGTH];
  1968.  
  1969.             write_to_buffer( d, "nr", 0);
  1970.                 if (victim->max_hit > 0)
  1971.                 percent = victim->hit * 100 / victim->max_hit;
  1972.             else
  1973.                 percent = -1;
  1974.  
  1975.             if (percent >= 100)
  1976.                 sprintf(wound,"is in excellent condition.");
  1977.             else if (percent >= 90)
  1978.                 sprintf(wound,"has a few scratches.");
  1979.             else if (percent >= 75)
  1980.                 sprintf(wound,"has some small wounds and bruises.");
  1981.             else if (percent >= 50)
  1982.                 sprintf(wound,"has quite a few wounds.");
  1983.             else if (percent >= 30)
  1984.                 sprintf(wound,"has some big nasty wounds and scratches.");
  1985.             else if (percent >= 15)
  1986.                 sprintf(wound,"looks pretty hurt.");
  1987.             else if (percent >= 0)
  1988.                 sprintf(wound,"is in awful condition.");
  1989.             else
  1990.                 sprintf(wound,"is bleeding to death.");
  1991.  
  1992.             sprintf(buf,"%s %s nr",
  1993.                     IS_NPC(victim) ? victim->short_descr : victim->name,wound);
  1994.             buf[0] = UPPER(buf[0]);
  1995.             write_to_buffer( d, buf, 0);
  1996.           }
  1998.    write_to_buffer( ch->desc, buf, point - buf );
  1999.    return;
  2000. }
  2002. /* The heart of the pager.  Thanks to N'Atas-Ha, ThePrincedom
  2003.    for porting this SillyMud code for MERC 2.0 and laying down the groundwork.
  2004.    Thanks to Blackstar, hopper.cs.uiowa.edu 4000 for which
  2005.    the improvements to the pager was modeled from.  - Kahn */
  2007. void show_string(struct descriptor_data *d, char *input)
  2008. {
  2009.   char buffer[ MAX_STRING_LENGTH ];
  2010.   char buf[ MAX_INPUT_LENGTH ];
  2011.   register char *scan, *chk;
  2012.   int lines /*= 0*/, toggle=1;
  2014.   one_argument(input, buf);
  2016.   switch( UPPER( buf[0] ) )
  2017.   {
  2018.   case '':
  2019.   case 'C': /* show next page of text */
  2020.     lines = 0;
  2021.     break;
  2023.   case 'R': /* refresh current page of text */
  2024.     lines = - 1 - (d->character->pcdata->pagelen);
  2025.     break;
  2027.   case 'B': /* scroll back a page of text */
  2028.     lines = -(2*d->character->pcdata->pagelen);
  2029.     break;
  2031.   case 'H': /* Show some help */
  2032.     write_to_buffer( d,
  2033.         "C, or Return = continue, R = redraw this page,nr", 0 );
  2034.     write_to_buffer( d,
  2035.         "B = back one page, H = this help, Q or other keys = exit.nrnr",
  2036.     0 );
  2037.     lines = - 1 - (d->character->pcdata->pagelen);
  2038.     break;
  2040.   default: /*otherwise, stop the text viewing */
  2041.     // @@@ Sands had some changes here that lead to double freeing
  2042.     if ( d->showstr_head )
  2043.     {
  2044.       free_string( d->showstr_head );
  2045. //      d->showstr_head = str_dup( "" );
  2046.       d->showstr_head = 0;
  2047.     }
  2048. //    free_string( d->showstr_point );
  2049. //    d->showstr_point = str_dup( "" );
  2050.     d->showstr_point = 0;
  2051.     return;
  2053.   }
  2055.   /* do any backing up necessary */
  2056.   if (lines < 0)
  2057.   {
  2058.     for ( scan = d->showstr_point; scan > d->showstr_head; scan-- )
  2059.          if ( ( *scan == 'n' ) || ( *scan == 'r' ) )
  2060.  {
  2061.      toggle = -toggle;
  2062.      if ( toggle < 0 )
  2063.          if ( !( ++lines ) )
  2064.      break;
  2065.  }
  2066.     d->showstr_point = scan;
  2067.   }
  2069.   /* show a chunk */
  2070.   lines  = 0;
  2071.   toggle = 1;
  2072.   for ( scan = buffer; ; scan++, d->showstr_point++ )
  2073.        if ( ( ( *scan = *d->showstr_point ) == 'n' || *scan == 'r' )
  2074.    && ( toggle = -toggle ) < 0 )
  2075.    lines++;
  2076.        else
  2077.    if ( !*scan || ( d->character && !IS_NPC( d->character )
  2078.   && lines >= d->character->pcdata->pagelen) )
  2079.    {
  2081.        *scan = '';
  2082.        write_to_buffer( d, buffer, strlen( buffer ) );
  2084.      /* See if this is the end (or near the end) of the string */
  2085.        for ( chk = d->showstr_point; isspace( *chk ); chk++ );
  2086.        if ( !*chk )
  2087.        {
  2088.    if ( d->showstr_head )
  2089.    {
  2090.       free_string( d->showstr_head );
  2091.       d->showstr_head  = 0;
  2092.    }
  2093.    d->showstr_point = 0;
  2094.        }
  2095.        return;
  2096.    }
  2098. //@@@  return;
  2099. }
  2101. SOCKET init_socket( int port )
  2102. {
  2103.    // Assume there aren't any sockets
  2104. //@@@   fSockets = FALSE;
  2105.     static struct sockaddr_in sa_zero;
  2106.     struct sockaddr_in sa;
  2107.     SOCKET newsock;
  2108.     int x = 1;
  2110. #if 0
  2111.    WORD wVersionRequested = MAKEWORD( 1, 1 );
  2113.    WSADATA wsaData;
  2114.    int err = WSAStartup( wVersionRequested, &wsaData );
  2115.    if ( err != 0 ) {
  2116.       MessageBox(0, "No useable WINSOCK.DLL, not loading sockets", "Serv",
  2117.          MB_ICONHAND|MB_OK);
  2119.       return INVALID_SOCKET;
  2120.       }
  2122.    /* Confirm that the Windows Sockets DLL supports 1.1.*/
  2123.    /* Note that if the DLL supports versions greater    */
  2124.    /* than 1.1 in addition to 1.1, it will still return */
  2125.    /* 1.1 in wVersion since that is the version we      */
  2126.    /* requested.                                        */
  2128.    if ( LOBYTE( wsaData.wVersion ) != 1 ||
  2129.          HIBYTE( wsaData.wVersion ) != 1 ) {
  2130.       /* Tell the user that we couldn't find a useable */
  2131.       /* winsock.dll.                                  */
  2132.       WSACleanup( );
  2133.       MessageBox(0, "Windows sockets version not 1.1, not loading sockets", "Serv",
  2134.          MB_ICONHAND|MB_OK);
  2136.       return INVALID_SOCKET;
  2137.       }
  2139.    /* Make sure that the version requested is >= 1.1.   */
  2140.    /* The low byte is the major version and the high    */
  2141.    /* byte is the minor version.                        */
  2143.    if ( LOBYTE( wVersionRequested ) < 1 ||
  2144.         ( LOBYTE( wVersionRequested ) == 1 &&
  2145.           HIBYTE( wVersionRequested ) < 1 )) {
  2146.       MessageBox(0, "Windows sockets version not 1.1, not loading sockets", "Serv",
  2147.          MB_ICONHAND|MB_OK);
  2149.        return INVALID_SOCKET;
  2150.    }
  2152.    /* Since we only support 1.1, set both wVersion and  */
  2153.    /* wHighVersion to 1.1.                              */
  2155.    wsaData.wVersion = MAKEWORD( 1, 1 );
  2156.    wsaData.wHighVersion = MAKEWORD( 1, 1 );
  2157. #endif
  2158. //   fSockets = TRUE;
  2161.     if ( ( newsock = socket( PF_INET, SOCK_STREAM, 0 ) ) == INVALID_SOCKET )
  2162.        {
  2163.     MessageBox(0, "Init_socket: socket", __FILE__, MB_OK);
  2164.     return INVALID_SOCKET;
  2165.        }
  2167.     if ( setsockopt( newsock, SOL_SOCKET, SO_REUSEADDR, (char *) &x, sizeof(x) )
  2168.              == SOCKET_ERROR )
  2169.        {
  2170.     MessageBox(0, "Init_socket: SO_REUSEADDR", __FILE__, MB_OK);
  2171.        closesocket(newsock);
  2172.        return INVALID_SOCKET;
  2173.        }
  2175. #if 0
  2176.     {
  2177.    struct linger ld;
  2179. ld.l_onoff  = 1;
  2180. ld.l_linger = 1000;
  2182. if ( setsockopt( fd, SOL_SOCKET, SO_DONTLINGER, (char *) &ld, sizeof(ld) ) < 0 )
  2183. {
  2184.     MessageBox(0, 0, "Init_socket: SO_DONTLINGER", __FILE__, MB_OK );
  2185.     closesocket( fd );
  2186.     return INVALID_SOCKET;
  2187. }
  2188.     }
  2189. #endif
  2191.     sa     = sa_zero;
  2192.     sa.sin_family   = AF_INET;
  2193.     sa.sin_port     = htons( port );
  2195.     if ( bind( newsock, (struct sockaddr *) &sa, sizeof(sa) ) == SOCKET_ERROR )
  2196.     {
  2197. MessageBox(0, "Init_socket: bind", __FILE__, MB_OK );
  2198. closesocket( newsock );
  2199. return INVALID_SOCKET;
  2200.     }
  2202.     if ( listen( newsock, 3 ) == SOCKET_ERROR )
  2203.     {
  2204. MessageBox(0, "Init_socket: listen", __FILE__, MB_OK );
  2205. closesocket( newsock );
  2206. return INVALID_SOCKET;
  2207.     }
  2209.     return newsock;
  2210. }
  2212. LRESULT SocketAccept (WPARAM wParam, LPARAM lParam)
  2213. {
  2214.     static DESCRIPTOR_DATA d_zero;
  2215.       SOCKET sSocket;
  2216.    SOCKADDR_IN saPeer;
  2217.    int iAddrSize;
  2218. //    int iError;
  2219. char     buf[512];
  2220.          DESCRIPTOR_DATA *dnew;
  2222. switch(WSAGETSELECTEVENT(lParam))
  2223. {
  2224.       default:
  2225.          MessageBeep(-1);
  2226.          break;
  2228. case FD_ACCEPT:
  2229.    {
  2230. // LPSOCKADDR_IN lpsaHostAddr;
  2231. //         LPHOSTENT    lpheHostEnt;
  2233. //       struct sockaddr_in isa;
  2234. //       int i = sizeof(isa);
  2235. //        getsockname(s, &isa, &i);
  2236.          struct sockaddr_in sock;
  2237.          int size = sizeof(sock);
  2239. //         MessageBeep(-1);
  2241. /* Get a pending accept */
  2242. iAddrSize = sizeof(SOCKADDR_IN);
  2243. sSocket = accept( control, (LPSOCKADDR) &saPeer, (LPINT) &iAddrSize );
  2244. if ( sSocket == INVALID_SOCKET )
  2245.    {
  2246. //            MessageBox(0, "Couldn't accept() connection.", "Serv",
  2247. //               MB_ICONHAND|MB_OK);
  2248.             log_string("Couldn't accept() connection");
  2249. return FALSE;
  2250.    }
  2252.          // Cons a new descriptor.
  2253.          if ( descriptor_free )
  2254.             {
  2255.             dnew = descriptor_free;
  2256.             descriptor_free = descriptor_free->next;
  2257.             dnew->descriptor = sSocket;
  2258.             }
  2259.          else
  2260.           dnew = alloc_perm( sizeof(*dnew) );
  2262.          *dnew = d_zero;
  2263.          dnew->descriptor = sSocket;
  2264.          dnew->connected = CON_GET_NAME;
  2265.          dnew->showstr_head  = NULL;
  2266.          dnew->showstr_point = NULL;
  2267.          dnew->outsize = 2000;
  2268.          dnew->outbuf = alloc_mem( dnew->outsize );
  2269.          dnew->host_and_name = alloc_mem( sizeof *dnew->host_and_name );
  2270.          strcpy(dnew->host_and_name->username, "<waiting>");
  2272.          if ( getpeername( sSocket, (struct sockaddr *) &sock, &size ) == SOCKET_ERROR )
  2273.             {
  2274. #if 1
  2275.             wsprintf(buf, "new_descriptor(): getpeername() == %d",
  2276.                WSAGetLastError());
  2277.             log_string( buf );
  2278. #else
  2279.             log_string("New_descriptor: getpeername");
  2280. #endif
  2281.           dnew->host = str_dup( "(unknown)" );
  2282.             }
  2283.          else
  2284.             {
  2285.             int ulen = sizeof dnew->host_and_name->us;
  2287.             // Get the caller's machine in quad format
  2288.             u_long addr = ntohl( sock.sin_addr.s_addr );
  2289.             struct hostent *from;
  2290.             wsprintf( buf, "%d.%d.%d.%d",
  2291.                ( addr >> 24 ) & 0xFF, ( addr >> 16 ) & 0xFF,
  2292.                ( addr >>  8 ) & 0xFF, ( addr       ) & 0xFF);
  2293.             wsprintf( log_buf, "Sock.sinaddr:  %s", buf );
  2294.             log_string( log_buf );
  2296.             // Request the name of the caller's machine from DNS
  2297.             dnew->host = str_dup( buf );
  2298.             dnew->host_and_name->sin_addr = sock.sin_addr;
  2299.             dnew->host_and_name->hRequestHandle = WSAAsyncGetHostByAddr( hQryDlgBox,
  2300.                WM_NET_GETHOST, (LPSTR) &dnew->host_and_name->sin_addr, sizeof dnew->host_and_name->sin_addr,
  2301.                PF_INET, dnew->host_and_name->hostdata, sizeof dnew->host_and_name->hostdata);
  2303.             // Look up the local name for this socket
  2304.             if (getsockname(sSocket, (struct sockaddr *)&dnew->host_and_name->us, &ulen) ==
  2305.                                                                  SOCKET_ERROR)
  2306.                {
  2307.                wsprintf(dnew->host_and_name->username, "(getsockname)#%d", WSAGetLastError());
  2308.                goto failure;
  2309.                }
  2311.             // Create a socket to connect to the user's ident port
  2312.             if ((dnew->host_and_name->sAuth = socket(PF_INET, SOCK_STREAM, AF_UNSPEC)) ==
  2313.                                                                INVALID_SOCKET)
  2314.                {
  2315.                wsprintf(dnew->host_and_name->username, "(socket)#%d", WSAGetLastError());
  2316.                goto failure;
  2317.                }
  2319.             // Save the address of their side of the socket
  2320.             dnew->host_and_name->them = sock;
  2322.             // htons convers a u_short from host to network byte order. 113 is
  2323.             //  the auth socket
  2324.             dnew->host_and_name->authsock.sin_port = htons(113);
  2325.             // Use Internet protocol
  2326.             dnew->host_and_name->authsock.sin_family = AF_INET;
  2327.             // Look up the other end of our socket
  2328.             dnew->host_and_name->authsock.sin_addr = sock.sin_addr;
  2330.             WSAAsyncSelect(dnew->host_and_name->sAuth, hQryDlgBox, WM_NET_AUTHCONNECT,
  2331.                FD_CONNECT|FD_READ|FD_WRITE);
  2332.             if (connect(dnew->host_and_name->sAuth, (struct sockaddr *)&dnew->host_and_name->authsock,
  2333.                                        sizeof(dnew->host_and_name->authsock)) == SOCKET_ERROR)
  2334.                {
  2335.                int nError = WSAGetLastError();
  2336.                if (nError != WSAEWOULDBLOCK)
  2337.                   {
  2338.                   wsprintf(dnew->host_and_name->username, "(connect)#%d", nError);
  2339.                   goto failure;
  2340.                   }
  2341.                }
  2343.             }
  2344. failure:
  2346.          // Init descriptor data.
  2347.          dnew->next = descriptor_list;
  2348.          descriptor_list = dnew;
  2349.          nPlayers++;
  2351. // OK now get messages from this socket
  2352.          BlastedTrumpet(sSocket);
  2354.          // Send the greeting.
  2355.          {
  2356.        extern char * help_greeting;
  2357.        if ( help_greeting[0] == '.' )
  2358.           write_to_buffer( dnew, help_greeting+1, 0 );
  2359.        else
  2360.         write_to_buffer( dnew, help_greeting  , 0 );
  2361.          }
  2362.    } // FD_ACCEPT
  2363. }
  2365.    return FALSE;
  2366. }
  2368. LRESULT SocketReadWrite (WPARAM wParam, LPARAM lParam)
  2369. {
  2370. SOCKET sSocket = (SOCKET) wParam;
  2371. // SOCKADDR_IN saPeer;
  2372. // int iAddrSize;
  2373. // int iError;
  2374. //   char     szBuffer[64];
  2375. //   int      len;
  2377. switch(WSAGETSELECTEVENT(lParam))
  2378.      {
  2379.       default:
  2380.          MessageBeep(-1);
  2381.          break;
  2383. case FD_READ: // WinSock has something for us
  2384.    {
  2385.       // Find the descriptor for this FD_READ
  2386.          DESCRIPTOR_DATA *d;
  2387.          for (d = descriptor_list; d; d = d_next )
  2388.             {
  2389.             d_next = d->next;
  2391.             if (d->descriptor == sSocket)
  2392.                {
  2393.                d->fcommand = FALSE;
  2395.                if ( d->character != NULL )
  2396.                   d->character->timer = 0;
  2398.                if ( !read_from_descriptor( d ) )
  2399.              {
  2400. //@@@Dunno what this does?                  FD_CLR( d->descriptor, &out_set );
  2401.                   if ( d->character != NULL )
  2402.              save_char_obj( d->character );
  2403.                   d->outtop = 0;
  2404.                   close_socket( d );
  2405. //@@@                  continue;
  2406.                   }
  2408.                break;
  2409.                }
  2410.             }
  2411.    } // FD_READ
  2412.          break;
  2414. case FD_WRITE: // WinSock ready to send data on this socket
  2415.    {
  2416. #if 0
  2417.          if (!BlastedTrumpet(sSocket))
  2418.             return FALSE;
  2419. #endif
  2420. #if 0
  2421.          send(sSocket, szMessage, strlen(szMessage), 0);
  2422. #else
  2423.          // Output.
  2424.          DESCRIPTOR_DATA *d;
  2425.          for (d = descriptor_list; d != NULL; d = d_next )
  2426.             {
  2427.             d_next = d->next;
  2428.             if (d->descriptor == sSocket)
  2429.                if ( d->fcommand || d->outtop > 0 )
  2430.                   {
  2431. #if 0
  2432.                   if ( !process_output( d, TRUE ) && WSAGetLastError() != WSAEWOULDBLOCK )
  2433.                      {
  2434.                      if ( d->character != NULL )
  2435.                         save_char_obj( d->character );
  2436.                      d->outtop = 0;
  2437.                      close_socket( d );
  2438.                      }
  2439. #endif
  2440.                   int iStart, nWrite;
  2441.                   for ( iStart = 0; iStart < d->outtop; iStart += nWrite )
  2442.                      {
  2443.                      int nBlock = UMIN( d->outtop - iStart, 4096 );
  2444.                      if ( ( nWrite = send( d->descriptor, d->outbuf + iStart, nBlock, 0 ) ) == SOCKET_ERROR)
  2445.                         {
  2446.                         if (WSAGetLastError() != WSAEWOULDBLOCK)
  2447.                            {
  2448.                            log_string( "Write_to_descriptor" );
  2449.                            if ( d->character != NULL )
  2450.                               save_char_obj( d->character );
  2451.                            close_socket( d );
  2452.                            }
  2454.                         break;
  2455.                         }
  2456.                      }
  2458.                   // @@@ It would be better at this point to resend if we got
  2459.                   // EWOULDBLOCK, but we throw all data away...
  2460.                   d->outtop = 0;
  2461.                   }
  2462.             }
  2463. #endif
  2464.          } // FD_WRITE
  2465.          break;
  2467. case FD_CLOSE: // Hey, it closed on us...
  2468. //          MessageBox(0, "Closing", "Serv", MB_ICONINFORMATION|MB_OK);
  2469. //          log_string("Closing");
  2470.           break;
  2472. }
  2474.    return FALSE;
  2475. }
  2477. bool BlastedTrumpet(SOCKET sSocket)
  2478. {
  2479. if ( WSAAsyncSelect( sSocket, hQryDlgBox, WM_NET_READWRITE,
  2480.       FD_READ|FD_WRITE|FD_CLOSE) == SOCKET_ERROR)
  2481.     {
  2482. // MessageBox(0, "Couldn't select() on client socket.", "Serv",
  2483. //         MB_ICONHAND|MB_OK);
  2484. log_string("Couldn't select() on client socket.");
  2485.       return FALSE;
  2486. }
  2488.    return TRUE;
  2489. }
  2491. bool read_from_descriptor( DESCRIPTOR_DATA *d )
  2492. {
  2493.     int iStart;
  2495.     /* Hold horses if pending command already. */
  2496.     if ( d->incomm[0] != '' )
  2497.        {
  2498.        if (!BlastedTrumpet(d->descriptor))
  2499.           {
  2500.      if ( d->character != NULL )
  2501.         save_char_obj( d->character );
  2502.      d->outtop = 0;
  2503.      close_socket( d );
  2504.           }
  2505. //       BlastedTrumpet(d->descriptor);
  2506.        return TRUE;
  2507.        }
  2509.     /* Check for overflow. */
  2510.     iStart = strlen(d->inbuf);
  2511.     if ( iStart >= sizeof(d->inbuf) - 10 )
  2512.     {
  2513. wsprintf( log_buf, "%s input overflow!", d->host );
  2514. log_string( log_buf );
  2515.    BlastedTrumpet(d->descriptor);
  2516. //@@@ MessageBox(0, "input overflow!", "Serv", MB_ICONHAND|MB_OK);
  2517. write_to_descriptor( d->descriptor,
  2518.     "nr*** PUT A LID ON IT!!! ***nr", 0 );
  2519. return FALSE;
  2520.     }
  2522.     /* Snarf input. */
  2523.     for ( ; ; )
  2524.     {
  2525. int nRead;
  2527. nRead = recv( d->descriptor, d->inbuf + iStart,
  2528.     sizeof(d->inbuf) - 10 - iStart, 0 );
  2529. if ( nRead > 0 )
  2530. {
  2531.     iStart += nRead;
  2532.     if ( d->inbuf[iStart-1] == 'n' || d->inbuf[iStart-1] == 'r' )
  2533. break;
  2534. }
  2535. else if ( nRead == 0 )
  2536. {
  2537. //     log_string( "EOF encountered on read." );
  2538.     return FALSE;
  2539. }
  2540. else if ( WSAGetLastError() == WSAEWOULDBLOCK )
  2541.     break;
  2542. else
  2543. {
  2544. //     perror( "Read_from_descriptor" );
  2545. //  MessageBox(0, "Read_from_descriptor", "Serv", MB_ICONHAND|MB_OK);
  2546.        log_string("read_from_descriptor() got error");
  2547.     return FALSE;
  2548. }
  2549.     }
  2551.     d->inbuf[iStart] = '';
  2552.     return TRUE;
  2553. }
  2555. /*
  2556.  * Writes a string to the log.
  2557.  */
  2558. void log_string( const char *str )
  2559. {
  2560.    char *strtime;
  2562.    if (IsWindow(hWndOutput))
  2563.       SendMessage(hWndOutput, LB_ADDSTRING, 0, (LPARAM)(LPCSTR) str);
  2565.    strtime                    = ctime( &current_time );
  2566.    strtime[strlen(strtime)-1] = '';
  2567.    fprintf( fpStderr, "%s :: %sn", strtime, str );
  2568. }
  2570. LRESULT SocketGetHost(WPARAM wParam, LPARAM lParam)
  2571. {
  2572.    DESCRIPTOR_DATA *des = descriptor_list;
  2573.    WORD wError;
  2575. //   MessageBeep(-1);
  2577.    while (des && des->host_and_name->hRequestHandle != (HANDLE) wParam)
  2578.       des = des->next;
  2580.    if (!des)
  2581.       {
  2582.       log_string("Got Host info for unknown descriptor");
  2583.       return FALSE;
  2584.       }
  2586.    wError = WSAGETASYNCERROR(lParam);
  2587.    if (wError)
  2588.       {
  2589.       char szBuf[512];
  2590.       char *p = "(Unknown Error)";
  2592.       if (wError == WSAHOST_NOT_FOUND)
  2593.          p = "(Authoritative Answer:  Host Not Found)";
  2594.       else if (wError == WSATRY_AGAIN)
  2595.          p = "(Host not found, or Server Failure)";
  2596.       else if (wError == WSANO_RECOVERY)
  2597.          p = "(Former, Refused, or Not Implemented)";
  2598.       else if (wError == WSANO_DATA)
  2599.          p = "(Valid name, no data record)";
  2600.       else if (wError == WSANO_DATA)
  2601.          p = "(No Address)";
  2603.       wsprintf(szBuf, "%s %s", des->host, p);
  2604.       free_string( des->host );
  2605.       des->host = str_dup( szBuf );
  2606.       }
  2607.    else
  2608.       {
  2609.       free_string( des->host );
  2610.       des->host = str_dup( ((struct hostent FAR *)(des->host_and_name->hostdata))->h_name );
  2611.       }
  2613.    return TRUE;
  2614. }
  2616. LRESULT SocketAuthConnect(WPARAM wParam, LPARAM lParam)
  2617. {
  2618.    char szIdentRequest[32];
  2619.    char szIdentReply[256];
  2620.    char szUserID[32];
  2621.    u_short port1, port2;
  2622.    char *p;
  2624.    DESCRIPTOR_DATA *des = descriptor_list;
  2625.    while (des && des->host_and_name->sAuth != (SOCKET) wParam)
  2626.       des = des->next;
  2628.    if (!des)
  2629.       {
  2630.       log_string("Ident message info for unknown descriptor");
  2631.       return FALSE;
  2632.       }
  2634. switch(WSAGETSELECTEVENT(lParam))
  2635.       {
  2636.       default:
  2637.          MessageBeep(-1);
  2638.          break;
  2640.       case FD_CONNECT:
  2641. //         log_string("FD_CONNECT to IDENTD port");
  2642. //         break;
  2643. //
  2644. //      case FD_WRITE:
  2646.          // Failure?
  2647.          if (WSAGETSELECTERROR(lParam))
  2648.             {
  2649.             wsprintf(des->host_and_name->username, "(FD_CONNECT)#%d", WSAGetLastError());
  2650.             closesocket((SOCKET) wParam);
  2651.             return FALSE;
  2652.             }
  2654.          // Create a string of the form <port>, <port>rn
  2655.          wsprintf(szIdentRequest, "%u , %urn",
  2656.                ntohs(des->host_and_name->them.sin_port),
  2657.                ntohs(des->host_and_name->us.sin_port));
  2659.          send((SOCKET) wParam, szIdentRequest, strlen(szIdentRequest), 0);
  2660.          // @@@ Should check return value
  2661.          break;
  2663.       case FD_READ:
  2664.          // Read the response from the IDENT port
  2665.          recv((SOCKET) wParam, szIdentReply, sizeof szIdentReply, 0);
  2666.          // @@@ Should check return value
  2668.          // Extract the user name provided by IDENT
  2669.          sscanf(szIdentReply, "%hd , %hd : USERID : %*[^:]: %10s",
  2670.             &port1, &port2, szUserID);
  2671.          log_string(szIdentReply); // @@@
  2673.          // Remove any trailing newline from the user name
  2674.          for (p = szUserID; *p && *p != 'n' && *p != 'r'; p++)
  2675.             ;
  2677.          *p = '';
  2679.          // Save the user name in the descriptor
  2680.          strcpy(des->host_and_name->username, szUserID);
  2682.          // Close this socket
  2683.          closesocket((SOCKET) wParam);
  2685.          break;
  2686.       }
  2688.    return TRUE;
  2689. }
  2690. /*
  2691.  * Write to all characters.
  2692.  */
  2693. void send_to_all_char( const char *text )
  2694. {
  2695.     DESCRIPTOR_DATA *d;
  2697.     if ( !text )
  2698.         return;
  2699.     for ( d = descriptor_list; d; d = d->next )
  2700.         if ( d->connected == CON_PLAYING )
  2701.     send_to_char( text, d->character );
  2703.     return;
  2704. }
  2706. /*
  2707.  * Reports a bug.
  2708.  */
  2709. void bug( const char *str, int param )
  2710. {
  2711.     extern FILE * fpArea;
  2712.     extern char strArea[ MAX_INPUT_LENGTH   ];
  2714.     FILE *fp;
  2715.     char  buf [ MAX_STRING_LENGTH ];
  2716.     char  buf2[ MAX_STRING_LENGTH ];
  2718.     if ( fpArea )
  2719.     {
  2720. int iLine;
  2721. int iChar;
  2723. if ( fpArea == stdin )
  2724. {
  2725.     iLine = 0;
  2726. }
  2727. else
  2728. {
  2729.     iChar = ftell( fpArea );
  2730.     fseek( fpArea, 0, 0 );
  2731.     for ( iLine = 0; ftell( fpArea ) < iChar; iLine++ )
  2732.     {
  2733. while ( getc( fpArea ) != 'n' )
  2734.     ;
  2735.     }
  2736.     fseek( fpArea, iChar, 0 );
  2737. }
  2739. sprintf( buf2, "[*****] FILE: %s LINE: %d", strArea, iLine );
  2740. log_string( buf2 );
  2742. if ( ( fp = fopen( "shutdown.txt", "a" ) ) )
  2743. {
  2744.     fprintf( fp, "[*****] %sn", buf2 );
  2745.     fclose( fp );
  2746. }
  2747.     }
  2748.    else
  2749.       buf2[0] = 0;
  2751.     strcpy( buf, "[*****] BUG: " );
  2752.     sprintf( buf + strlen( buf ), str, param );
  2753.     log_string( buf );
  2755.     fclose( fpReserve );
  2756.     if ( ( fp = fopen( BUG_FILE, "a" ) ) )
  2757.     {
  2758. fprintf( fp, "%sn", buf );
  2759. fclose( fp );
  2760.     }
  2761.     fpReserve = fopen( NULL_FILE, "r" );
  2763.     if (fWantsMessageBox)
  2764.        MessageBox(0, buf, buf2, MB_ICONHAND|MB_OK);
  2766.     return;
  2767. }
  2769. // This was moved out of act_wiz so that I can use the host_and_name member
  2770. void do_users( CHAR_DATA *ch, char *argument )
  2771. {
  2772.     char buf[MAX_STRING_LENGTH];
  2773.     char buf2[MAX_STRING_LENGTH];
  2774.     DESCRIPTOR_DATA *d;
  2775.     int count;
  2777.     count = 0;
  2778.     buf[0] = '';
  2779.     buf2[0]     = '';
  2780.     for ( d = descriptor_list; d != NULL; d = d->next )
  2781.     {
  2782. if ( d->character != NULL && can_see( ch, d->character ) )
  2783. {
  2784.     count++;
  2785.     sprintf( buf + strlen(buf), "[%3d %2d] %s (%s@%s)nr",
  2786. d->descriptor,
  2787. d->connected,
  2788. d->original  ? d->original->name  :
  2789. d->character ? d->character->name : "(none)",
  2790. d->host_and_name->username, d->host
  2791. );
  2792. }
  2793.     }
  2795.     sprintf( buf2, "%d user%snr", count, count == 1 ? "" : "s" );
  2796.     strcat( buf, buf2 );
  2797.     send_to_char( buf, ch );
  2798.     return;
  2799. }