xwords/xwords4/linux/cursesmain.c

/* -*-mode: C; fill-column: 78; c-basic-offset: 4; -*- */
/* 
 * Copyright 2000 by Eric House (fixin@peak.org).  All rights reserved.
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */
#ifdef PLATFORM_NCURSES

#include <ncurses.h>
#include <signal.h>
#include <assert.h>
#include <ctype.h>

#include <netdb.h>		/* gethostbyname */
#include <errno.h>
//#include <net/netinet.h>

#include <sys/poll.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netinet/in.h>

#include "linuxmain.h"
#include "cursesmain.h"
#include "cursesask.h"
#include "cursesletterask.h"
#include "model.h"
#include "draw.h"
#include "board.h"
#include "engine.h"
/* #include "compipe.h" */
#include "xwproto.h"
#include "xwstream.h"
#include "xwstate.h"
#include "server.h"
#include "memstream.h"
#include "util.h"

#define MENU_WINDOW_HEIGHT 5	/* three lines plus borders */
#define INFINITE_TIMEOUT -1

CursesAppGlobals globals;	/* must be global b/c of SIGWINCH_handler */

static void changeFocus( CursesAppGlobals* globals );

#ifdef MEM_DEBUG
# define MEMPOOL params->util->mpool,
#else
# define MEMPOOL
#endif

/* extern int errno; */

static void
cursesUserError( CursesAppGlobals* globals, char* format, ... )
{
    char buf[512];
    va_list ap;

    va_start( ap, format );

    vsprintf( buf, format, ap );

    (void)cursesask( globals, buf, 1, "OK" );

    va_end(ap);
} /* cursesUserError */

static void
curses_util_listenPortChange( XW_UtilCtxt* uc, XP_U16 newPort )
{
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    XP_LOGF( "listenPortChange  called: not sure what to do" );

    /* if this isn't true, need to tear down and rebind socket */
    XP_ASSERT( newPort == globals->cGlobals.params->defaultListenPort );
} /* curses_util_listenPortChange */

static XP_S16 
curses_util_userPickTile( XW_UtilCtxt* uc, PickInfo* pi, XP_U16 playerNum,
                          XP_UCHAR4* texts, XP_U16 nTiles )
{
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    char query[128];
    XP_S16 index;
    char* playerName = globals->cGlobals.params->gi.players[playerNum].name;

    sprintf( query, "Pick tile for %s! (Tab or type letter to select\n"
             "then hit <cr>.)", playerName );

    index = curses_askLetter( globals, query, texts, nTiles );
    return index;
} /* util_userPickTile */

static void
curses_util_userError( XW_UtilCtxt* uc, UtilErrID id )
{
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    XP_UCHAR* message = linux_getErrString( id );

    cursesUserError( globals, message );
} /* curses_util_userError */

static XP_Bool
curses_util_userQuery( XW_UtilCtxt* uc, UtilQueryID id, XWStreamCtxt* stream )
{
    CursesAppGlobals* globals;
    char* question;
    char* answers[3];
    short numAnswers = 0;
    XP_Bool freeMe = XP_FALSE;
    XP_Bool result;
    XP_U16 okIndex = 1;

    switch( id ) {
    case QUERY_COMMIT_TURN:
        question = strFromStream( stream );
        freeMe = XP_TRUE;
        answers[numAnswers++] = "Cancel";
        answers[numAnswers++] = "Ok";
        break;
    case QUERY_COMMIT_TRADE:
        question = "Commit trade?";
        answers[numAnswers++] = "Cancel";
        answers[numAnswers++] = "Ok";
        break;
    case QUERY_ROBOT_MOVE:
    case QUERY_ROBOT_TRADE:
        question = strFromStream( stream );
        freeMe = XP_TRUE;
        answers[numAnswers++] = "Ok";
        okIndex = 0;
        break;
        
    default:
        XP_ASSERT( 0 );
        return 0;
    }
    globals = (CursesAppGlobals*)uc->closure;
    result = cursesask( globals, question, numAnswers, 
                        answers[0], answers[1], answers[2] ) == okIndex;

    if ( freeMe ) {
        free( question );
    }

    return result;
} /* curses_util_userQuery */

static void
curses_util_trayHiddenChange( XW_UtilCtxt* uc, XW_TrayVisState state )
{
    /* nothing to do if we don't have a scrollbar */
} /* curses_util_trayHiddenChange */

static void
cursesShowFinalScores( CursesAppGlobals* globals )
{
    XWStreamCtxt* stream;
    XP_UCHAR* text;

    stream = mem_stream_make( MPPARM(globals->cGlobals.params->util->mpool)
                              globals->cGlobals.params->vtMgr,
                              globals, CHANNEL_NONE, NULL );
    server_writeFinalScores( globals->cGlobals.game.server, stream );

    text = strFromStream( stream );

    (void)cursesask( globals, text, 1, "Ok" );

    free( text );
} /* cursesShowFinalScores */

static void
curses_util_notifyGameOver( XW_UtilCtxt* uc )
{
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    board_draw( globals->cGlobals.game.board );

    /* game belongs in cGlobals... */
    if ( globals->cGlobals.params->printHistory ) {    
        catGameHistory( &globals->cGlobals );
    }

    if ( globals->cGlobals.params->quitAfter ) {
        globals->timeToExit = XP_TRUE;
    } else if ( globals->cGlobals.params->undoWhenDone ) {
        server_handleUndo( globals->cGlobals.game.server );
    } else {
        cursesShowFinalScores( globals );
    }
} /* curses_util_notifyGameOver */

static XP_Bool
curses_util_hiliteCell( XW_UtilCtxt* uc, XP_U16 col, XP_U16 row )
{
    return XP_TRUE;
} /* curses_util_hiliteCell */

static XP_Bool
curses_util_engineProgressCallback( XW_UtilCtxt* uc )
{
    return XP_TRUE;
} /* curses_util_engineProgressCallback */

static void
curses_util_setTimer( XW_UtilCtxt* uc, XWTimerReason why )
{
    XP_ASSERT( 0 );		/* no pen-down events..... */
} /* curses_util_setTimer */

static void
curses_util_requestTime( XW_UtilCtxt* uc ) 
{
    /* I've created a pipe whose read-only end is plugged into the array of
       fds that my event loop polls so that I can write to it to simulate
       post-event on a more familiar system.  It works, so no complaints! */
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    (void)write( globals->timepipe[1], "!", 1 );
} /* curses_util_requestTime */

static void
initCurses( CursesAppGlobals* globals )
{
    WINDOW* mainWin;
    WINDOW* menuWin;
    WINDOW* boardWin;

    int x, y;

    /* ncurses man page says most apps want this sequence  */
    mainWin = initscr(); 
    cbreak(); 
    noecho();
    nonl();
    intrflush(stdscr, FALSE);
    keypad(stdscr, TRUE);

    getmaxyx(mainWin, y, x);
    globals->statusLine = y - MENU_WINDOW_HEIGHT - 1;
    menuWin = newwin( MENU_WINDOW_HEIGHT, x, y-MENU_WINDOW_HEIGHT, 0 );
    nodelay(menuWin, 1);		/* don't block on getch */
    boardWin = newwin( MAX_ROWS+1, x, 0, 0 );

/*     leaveok( boardWin, 1 ); */
/*     leaveok( menuWin, 1 ); */

    globals->menuWin = menuWin;
    globals->boardWin = boardWin;
    globals->mainWin = mainWin;
} /* initCurses */

#if 0
static void
showStatus( CursesAppGlobals* globals )
{
    char* str;

    switch ( globals->state ) {
    case XW_SERVER_WAITING_CLIENT_SIGNON:
	str = "Waiting for client[s] to connnect";
	break;
    case XW_SERVER_READY_TO_PLAY:
	str = "It's somebody's move";
	break;
    default:
	str = "unknown state";
    }

    
    standout();
    mvaddstr( globals->statusLine, 0, str );
/*     clrtoeol();     */
    standend();

    refresh();
} /* showStatus */
#endif

typedef XP_Bool (*CursesMenuHandler)(CursesAppGlobals* globals);
typedef struct MenuList {
    CursesMenuHandler handler;
    char* desc;
    char* keyDesc;
    char key;
} MenuList;
static XP_Bool
handleQuit( CursesAppGlobals* globals )
{
    globals->timeToExit = XP_TRUE;
    return XP_TRUE;
} /* handleQuit */

static XP_Bool
handleTab( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board, 
                                       XP_FOCUSCHANGE_KEY );
    changeFocus( globals );
    return XP_TRUE;
} /* handleTab */

static XP_Bool
handleRet( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board, 
                                       XP_RETURN_KEY );
    return XP_TRUE;
} /* handleRet */

static XP_Bool
handleHint( CursesAppGlobals* globals )
{
    XP_Bool redo;
    globals->doDraw = board_requestHint( globals->cGlobals.game.board, 0, &redo );
    return XP_TRUE;
} /* handleHint */

static XP_Bool
handleCommit( CursesAppGlobals* globals )
{
    globals->doDraw = board_commitTurn( globals->cGlobals.game.board );
    return XP_TRUE;
} /* handleCommit */

static XP_Bool
handleJuggle( CursesAppGlobals* globals )
{
    globals->doDraw = board_juggleTray( globals->cGlobals.game.board );
    return XP_TRUE;
} /* handleJuggle */

static XP_Bool
handleHide( CursesAppGlobals* globals )
{
    XW_TrayVisState curState = 
        board_getTrayVisState( globals->cGlobals.game.board );

    if ( curState == TRAY_REVEALED ) {
        globals->doDraw = board_hideTray( globals->cGlobals.game.board );
    } else {
        globals->doDraw = board_showTray( globals->cGlobals.game.board );
    }

    return XP_TRUE;
} /* handleJuggle */

static XP_Bool
handleFlip( CursesAppGlobals* globals )
{
    globals->doDraw = board_flip( globals->cGlobals.game.board );
    return XP_TRUE;
} /* handleFlip */

static XP_Bool
handleToggleValues( CursesAppGlobals* globals )
{
    globals->doDraw = board_toggle_showValues( globals->cGlobals.game.board );
    return XP_TRUE;
} /* handleToggleValues */

static XP_Bool
handleBackspace( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board,
                                       XP_CURSOR_KEY_DEL );
    return XP_TRUE;
} /* handleBackspace */

static XP_Bool
handleUndo( CursesAppGlobals* globals )
{
    globals->doDraw = server_handleUndo( globals->cGlobals.game.server );
    return XP_TRUE;
} /* handleUndo */

static XP_Bool
handleReplace( CursesAppGlobals* globals )
{
    globals->doDraw = board_replaceTiles( globals->cGlobals.game.board );
    return XP_TRUE;
} /* handleReplace */

MenuList sharedMenuList[] = {
    { handleQuit, "Quit", "Q", 'Q' },
    { handleTab, "Change focus", "<tab>", '\t' },
    { handleRet, "Click/tap", "<ret>", '\r' },
    { handleHint, "Hint", "?", '?' },
    { handleCommit, "Commit move", "C", 'C' },
    { handleFlip, "Flip", "F", 'F' },
    { handleToggleValues, "Show values", "V", 'V' },

    { handleBackspace, "Remove from board", "<del>", 8 },
    { handleUndo, "Undo prev", "U", 'U' },
    { handleReplace, "uNdo cur", "N", 'N' },

    { NULL, NULL, NULL, '\0'}
};

static XP_Bool
handleLeft( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board, 
                                       XP_CURSOR_KEY_LEFT );
    return XP_TRUE;
} /* handleLeft */

static XP_Bool
handleDivLeft( CursesAppGlobals* globals )
{
    globals->doDraw = board_moveDivider( globals->cGlobals.game.board, 
                                         XP_FALSE );
    return XP_TRUE;
} /* handleDivLeft */

static XP_Bool
handleDivRight( CursesAppGlobals* globals )
{
    globals->doDraw = board_moveDivider( globals->cGlobals.game.board, 
                                         XP_TRUE );
    return XP_TRUE;
} /* handleDivRight */

static XP_Bool
handleRight( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board, 
                                       XP_CURSOR_KEY_RIGHT );
    return XP_TRUE;
} /* handleRight */

static XP_Bool
handleUp( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board, 
                                       XP_CURSOR_KEY_UP );
    return XP_TRUE;
} /* handleUp */

static XP_Bool
handleDown( CursesAppGlobals* globals )
{
    globals->doDraw = board_handleKey( globals->cGlobals.game.board, 
                                       XP_CURSOR_KEY_DOWN );
    return XP_TRUE;
} /* handleDown */

MenuList boardMenuList[] = {
    { handleLeft, "Left", "H", 'H' },
    { handleRight, "Right", "L", 'L' },
    { handleUp, "Up", "J", 'J' },
    { handleDown, "Down", "K", 'K' },

    { NULL, NULL, NULL, '\0'}
};

MenuList scoreMenuList[] = {
    { handleUp, "Up", "J", 'J' },
    { handleDown, "Down", "K", 'K' },

    { NULL, NULL, NULL, '\0'}
};

MenuList trayMenuList[] = {
    { handleLeft, "Left", "H", 'H' },
    { handleRight, "Right", "L", 'L' },
    { handleDivLeft, "Div left", "{", '{' },
    { handleDivRight, "Div right", "}", '}' },
    { handleJuggle, "Juggle", "J", 'J' },
    { handleHide, "[un]hIde", "I", 'I' },

    { NULL, NULL, NULL, '\0'}
};

static void
figureMaxes( MenuList* mList, short maxLines, short* maxKeyP, short* maxCmdP )
{
    short i;

    *maxKeyP = *maxCmdP = 0;

    for ( i = 0; i < maxLines && mList->handler != NULL; ++i ) {
        short keyLen = strlen(mList->keyDesc);
        short cmdLen = strlen(mList->desc);
        *maxKeyP = XP_MAX( *maxKeyP, keyLen );
        *maxCmdP= XP_MAX( *maxCmdP, cmdLen );
        ++mList;
    }
} /* figureMaxes */

static void
drawMenuFromList( CursesAppGlobals* globals, MenuList* menuList )
{
    short i;
    short maxKey = 0, maxCmd = 0;
    short line = 0, col;
    short nLines;
    int winMaxY, winMaxX;
    WINDOW* win = globals->menuWin;
    XP_Bool done = XP_FALSE;

    getmaxyx( win, winMaxY, winMaxX );

    nLines = globals->nLinesMenu;
    if ( nLines == 0 ) {
        nLines = 1;
    }

    for ( ; !done; ++nLines ) {
        MenuList* entry = sharedMenuList;
        XP_Bool isShared = XP_TRUE;

        wclear( win );

        maxKey = maxCmd = 0;
        for ( line = 0, col = -2, i = 0; ; ++entry, ++line ) {
            char* key;

            if ( entry->handler == NULL ) {
                if ( !isShared ) {
                    done = XP_TRUE;
                    break;
                } else {
                    isShared = XP_FALSE;
                    entry = menuList;
                    XP_ASSERT( !!entry->handler );
                }
            }

            if ( line % nLines == 0 ) {
                line = 0;
                col += maxKey + maxCmd + 2;
                figureMaxes( entry, nLines, &maxKey, &maxCmd );
                if ( (col + maxCmd + strlen(entry->keyDesc)) >= winMaxX ) {
                    break;
                }
            }

            key = entry->keyDesc;

            wstandout( win );
            mvwaddstr( win, line, col+maxKey-strlen(key), key );
            wstandend( win );
            mvwaddstr( win, line, col+maxKey+1, entry->desc );
        }
    }

    globals->nLinesMenu = nLines - 1;

    wrefresh( win );
} /* drawMenuFromList */

static void 
SIGWINCH_handler( int signal )
{
    int x, y;

    assert( signal == SIGWINCH );

    endwin(); 

/*     (*globals.drawMenu)( &globals );  */

    getmaxyx( stdscr, y, x );
    wresize( globals.mainWin, y-MENU_WINDOW_HEIGHT, x );

    board_draw( globals.cGlobals.game.board );
} /* SIGWINCH_handler */

static void
cursesListenOnSocket( CursesAppGlobals* globals, int newSock, 
                      XWStreamCtxt* stream )
{
    XP_ASSERT( globals->fdCount+1 < FD_MAX );

    XP_WARNF( "setting fd[%d] to %d", globals->fdCount, newSock );
    globals->fdArray[globals->fdCount].fd = newSock;
    globals->fdArray[globals->fdCount].events = POLLIN;

    globals->streams[globals->fdCount] = stream;

    ++globals->fdCount;
    XP_LOGF( "listenOnSocket: there are now %d sources to poll",
             globals->fdCount );
} /* cursesListenOnSocket */


/* 
 * Ok, so this doesn't block yet.... 
 */
static XP_Bool
blocking_gotEvent( CursesAppGlobals* globals, int* ch )
{
    XP_Bool result = XP_FALSE;
    int numEvents;
    short fdIndex;
    XP_Bool redraw = XP_FALSE;

    numEvents = poll( globals->fdArray, globals->fdCount, INFINITE_TIMEOUT );

    if ( numEvents > 0 ) {
	
        /* stdin first */
        if ( (globals->fdArray[FD_STDIN].revents & POLLIN) != 0 ) {
            int evtCh = fgetc(stdin);
            *ch = evtCh;
            result = XP_TRUE;
            --numEvents;
        }
        if ( (globals->fdArray[FD_STDIN].revents & ~POLLIN ) ) {
	    XP_LOGF( "some other events set on stdin" );
        }

        if ( (globals->fdArray[FD_TIMEEVT].revents & POLLIN) != 0 ) {
            char ch;
            /* 	    XP_DEBUGF( "curses got a USER EVENT\n" ); */
            (void)read(globals->fdArray[FD_TIMEEVT].fd, &ch, 1 );
        }

        fdIndex = FD_FIRSTSOCKET;

        if ( numEvents > 0 && 
             (globals->fdArray[fdIndex].revents & POLLIN) != 0 ) {
            int flen, nBytes;
            XP_U8 buf[256];
            struct sockaddr_in addr_sock;

            --numEvents;

            flen = sizeof(addr_sock);
            nBytes = recvfrom( globals->fdArray[fdIndex].fd,
                               buf, sizeof(buf), 0,
                               (struct sockaddr *)&addr_sock, &flen );

            if ( nBytes == -1 ) {
                XP_WARNF( "recvfrom: errno=%d\n", errno );
            } else {
                XWStreamCtxt* inboundS;
                XP_Bool redraw = XP_FALSE;

                XP_STATUSF( "recvfrom=>%d", nBytes );
                inboundS = stream_from_msgbuf( &globals->cGlobals, 
                                               buf, nBytes );
                if ( !!inboundS ) {
                    CommsAddrRec addrRec;
                
                    XP_MEMSET( &addrRec, 0, sizeof(addrRec) );
                    addrRec.conType = COMMS_CONN_IP;
            
                    addrRec.u.ip.ipAddr = ntohl(addr_sock.sin_addr.s_addr);
                    XP_LOGF( "captured incomming ip address: 0x%lx",
                             addrRec.u.ip.ipAddr );

                    if ( comms_checkIncommingStream(globals->cGlobals.game.comms,
                                                    inboundS, 
                                                    &addrRec ) ) {
                        XP_LOGF( "comms read port: %d", 
                                 addrRec.u.ip.port );
                        redraw = server_receiveMessage( globals->cGlobals.game.server, 
                                                        inboundS );
                    }
                    stream_destroy( inboundS );
                }
                
                /* if there's something to draw resulting from the message, we
                   need to give the main loop time to reflect that on the
                   screen before giving the server another shot.  So just call
                   the idle proc. */
                if ( redraw ) {
                    curses_util_requestTime(globals->cGlobals.params->util);
                }
            }

            ++fdIndex;
        }

        redraw = server_do( globals->cGlobals.game.server ) || redraw;
        if ( redraw ) {
            /* messages change a lot */
            board_invalAll( globals->cGlobals.game.board );
            board_draw( globals->cGlobals.game.board );
        }
    }
    return result;
} /* blocking_gotEvent */

static void
changeFocus( CursesAppGlobals* globals )
{
    BoardObjectType focussed = 
        board_getFocusOwner( globals->cGlobals.game.board );
    if ( focussed == OBJ_TRAY ) {
        globals->menuList = trayMenuList;
        drawMenuFromList( globals, trayMenuList );
    } else if ( focussed == OBJ_BOARD ) {
        globals->menuList = boardMenuList;
        drawMenuFromList( globals, boardMenuList );
    } else if ( focussed == OBJ_SCORE ) {
        globals->menuList = scoreMenuList;
        drawMenuFromList( globals, scoreMenuList );
    } else {
        XP_ASSERT(0);
    }
} /* changeFocus */

#if 0
static void
initClientSocket( CursesAppGlobals* globals, char* serverName )
{
    struct hostent* hostinfo;
    hostinfo = gethostbyname( serverName );
    if ( !hostinfo ) {
	userError( globals, "unable to get host info for %s\n", serverName );
    } else {
	char* hostName = inet_ntoa( *(struct in_addr*)hostinfo->h_addr );
	XP_LOGF( "gethostbyname returned %s", hostName );
	globals->csInfo.client.serverAddr = inet_addr(hostName);
	XP_LOGF( "inet_addr returned %lu", 
		 globals->csInfo.client.serverAddr );
    }
} /* initClientSocket */
#endif

static VTableMgr*
curses_util_getVTManager(XW_UtilCtxt* uc)
{
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    return globals->cGlobals.params->vtMgr;
} /* linux_util_getVTManager */

static XP_Bool
curses_util_askPassword( XW_UtilCtxt* uc, const XP_UCHAR* name, 
                         XP_UCHAR* buf, XP_U16* len )
{
    XP_WARNF( "curses_util_askPassword not implemented" );
    return XP_FALSE;
} /* curses_util_askPassword */

static void
curses_util_yOffsetChange( XW_UtilCtxt* uc, XP_U16 oldOffset, XP_U16 newOffset )
{
    if ( oldOffset != newOffset ) {
	XP_WARNF( "curses_util_yOffsetChange(%d,%d) not implemented",
		  oldOffset, newOffset );    
    }
} /* curses_util_yOffsetChange */

static XP_Bool
curses_util_warnIllegalWord( XW_UtilCtxt* uc, BadWordInfo* bwi, XP_U16 player,
                             XP_Bool turnLost )
{
    XP_WARNF( "curses_util_warnIllegalWord not implemented" );
    return XP_FALSE;
} /* curses_util_warnIllegalWord */

static void
cursesSendOnClose( XWStreamCtxt* stream, void* closure )
{
    XP_S16 result;
    CursesAppGlobals* globals = (CursesAppGlobals*)closure;

    XP_LOGF( "cursesSendOnClose called" );
    result = comms_send( globals->cGlobals.game.comms, COMMS_CONN_IP, stream );
} /* cursesSendOnClose */

static XWStreamCtxt* 
curses_util_makeStreamFromAddr(XW_UtilCtxt* uc, XP_PlayerAddr channelNo )
{
    CursesAppGlobals* globals = (CursesAppGlobals*)uc->closure;
    LaunchParams* params = globals->cGlobals.params;

    XWStreamCtxt* stream = mem_stream_make( MPPARM(uc->mpool) 
                                            params->vtMgr,
                                            uc->closure, channelNo, 
                                            cursesSendOnClose );
    return stream;
} /* curses_util_makeStreamFromAddr */

static void
setupCursesUtilCallbacks( CursesAppGlobals* globals, XW_UtilCtxt* util )
{
    util->vtable->m_util_userError = curses_util_userError;

    util->vtable->m_util_getVTManager = curses_util_getVTManager;
    util->vtable->m_util_askPassword = curses_util_askPassword;
    util->vtable->m_util_yOffsetChange = curses_util_yOffsetChange;
    util->vtable->m_util_warnIllegalWord = curses_util_warnIllegalWord;
    util->vtable->m_util_makeStreamFromAddr = curses_util_makeStreamFromAddr;

    util->vtable->m_util_userQuery = curses_util_userQuery;
    util->vtable->m_util_userPickTile = curses_util_userPickTile;
    util->vtable->m_util_trayHiddenChange = curses_util_trayHiddenChange;
    util->vtable->m_util_notifyGameOver = curses_util_notifyGameOver;
    util->vtable->m_util_hiliteCell = curses_util_hiliteCell;
    util->vtable->m_util_engineProgressCallback = 
	curses_util_engineProgressCallback;
    util->vtable->m_util_setTimer = curses_util_setTimer;
    util->vtable->m_util_requestTime = curses_util_requestTime;

    util->vtable->m_util_listenPortChange = curses_util_listenPortChange;

    util->closure = globals;
} /* setupCursesUtilCallbacks */

static void
sendOnClose( XWStreamCtxt* stream, void* closure )
{
    CursesAppGlobals* globals = closure;
    XP_LOGF( "curses sendOnClose called" );
    XP_ASSERT( !!globals->cGlobals.game.comms );
    comms_send( globals->cGlobals.game.comms, COMMS_CONN_IP, stream );
} /* sendOnClose */

static XP_Bool
handleKeyEvent( CursesAppGlobals* globals, MenuList* list, char ch )
{
    while ( list->handler != NULL ) {
        if ( list->key == ch ) {
            if ( (*list->handler)(globals) ) {
                return XP_TRUE;
            }
        }
        ++list;
    }
    return XP_FALSE;
} /* handleKeyEvent */

static XP_Bool
passKeyToBoard( CursesAppGlobals* globals, char ch )
{
    XP_Bool handled = ch >= 'a' && ch <= 'z';
    if ( handled ) {
        ch += 'A' - 'a';
        globals->doDraw = board_handleKey( globals->cGlobals.game.board, ch );
    }
    XP_LOGF( "passKeyToBoard: handled=%d on %x (%c)", handled, ch, ch );
    return handled;
} /* passKeyToBoard */

void
cursesmain( XP_Bool isServer, LaunchParams* params )
{
    int piperesult;
    int sock;
    DictionaryCtxt* dict;
    CommsAddrRec addr;

    memset( &globals, 0, sizeof(globals) );

    globals.amServer = isServer;
    globals.cGlobals.params = params;

    globals.cp.showBoardArrow = XP_TRUE;
    globals.cp.showRobotScores = params->showRobotScores;

    dict = params->dict;

    setupCursesUtilCallbacks( &globals, params->util );

    globals.cGlobals.defaultServerName = params->info.clientInfo.serverName;

    cursesListenOnSocket( &globals, 0, NULL ); /* stdin */

    piperesult = pipe( globals.timepipe );
    XP_ASSERT( piperesult == 0 );

    cursesListenOnSocket( &globals, globals.timepipe[0], NULL ); /* reader pipe */

    sock = initListenerSocket( params->defaultListenPort );
    cursesListenOnSocket( &globals, sock, NULL );	

    signal( SIGWINCH, SIGWINCH_handler );
    initCurses( &globals );

    globals.draw = (CursesDrawCtx*)cursesDrawCtxtMake( globals.boardWin );
    
    game_makeNewGame( MEMPOOL &globals.cGlobals.game, &params->gi,
                      params->util, (DrawCtx*)globals.draw,
                      &globals.cp, linux_udp_send, &globals );

    addr.conType = COMMS_CONN_IP;
    addr.u.ip.ipAddr = 0;       /* ??? */
    addr.u.ip.port = params->defaultSendPort;
    comms_setAddr( globals.cGlobals.game.comms, 
                   &addr, params->defaultListenPort );

	model_setDictionary( globals.cGlobals.game.model, params->dict );

    board_setPos( globals.cGlobals.game.board, 1, 1, XP_FALSE );
    board_setScale( globals.cGlobals.game.board, 1, 1 );
    board_setScoreboardLoc( globals.cGlobals.game.board, 20, 1, 50, 
                            5, /*4 players + rem*/ XP_FALSE );

    board_setTrayLoc( globals.cGlobals.game.board, 25, 8, 3, 4, 1 );
    /* no divider -- yet */
    /*     board_setTrayVisible( globals.board, XP_TRUE, XP_FALSE ); */

    board_invalAll( globals.cGlobals.game.board );

    /* send any events that need to get off before the event loop begins */
    if ( !isServer ) {
        if ( 1 /* stream_open( params->info.clientInfo.stream )  */) {
            server_initClientConnection( globals.cGlobals.game.server, 
                                         mem_stream_make( MEMPOOL
                                                          params->vtMgr,
                                                          &globals,
                                                          (XP_PlayerAddr)0,
                                                          sendOnClose ) );
#if 0
            cursesListenOnSocket( 
                                 &globals, NULL,	/* replaces below */
                                 /* 		linux_getStreamSocket( params->info.clientInfo.stream ), */
                                 params->info.clientInfo.stream );
#endif
        } else {
            cursesUserError( &globals, "Unable to open connection to server");
            exit( 0 );
        }
    }

    server_do( globals.cGlobals.game.server );

    globals.menuList = boardMenuList;
    drawMenuFromList( &globals, boardMenuList );
    board_draw( globals.cGlobals.game.board );

    while ( !globals.timeToExit ) {
        int ch;
        if ( blocking_gotEvent( &globals, &ch )
             && (handleKeyEvent( &globals, globals.menuList, ch )
                 || handleKeyEvent( &globals, sharedMenuList, ch )
                 || passKeyToBoard( &globals, ch ) ) ) {
            if ( globals.doDraw ) {
                board_draw( globals.cGlobals.game.board );
                globals.doDraw = XP_FALSE;
            }
        }
    }
    
    endwin();
} /* cursesmain */
#endif /* PLATFORM_NCURSES */