/*
 *  SCLI.C
 *
 *  DNET (c)Copyright 1988, Matthew Dillon, All Rights Reserved.
 *
 *  SHELL SERVER.   THIS REQUIRES MY PIPE DEVICE TO WORK!!!!!!!!!!
 *
 *  Port #8196
 *
 *  Only one connection accepted at a time in this baby.
 *  HUGE CLUDGE!!!
 *
 *  DNET_LEVEL must be 9 or higher.
 */

#include "defs.h"

char Buf[4096];

int
brk()
{
    return(0);
}

void
#ifdef LATTICE
_main(str)
#else
_main(len,str)
#endif
char *str;
{
    struct MsgPort *port;
    PROC    *proc = (PROC *)FindTask(NULL);
    void    *chan;
    long    mask, rmask;
    long    namei = (long)proc;
    APTR    oldwptr;
    /*short   mycis = 0, mycos = 0;*/

    onbreak(brk);

    if (strncmp(str, "__dnet", 6) != 0) {
	Version("SCli", VERSION, SCLI_VERSION);
	_exit(0);
    }

    port = DListen(PORT_AMIGASHELL);
    WaitPort(&proc->pr_MsgPort);
    ReplyMsg(GetMsg(&proc->pr_MsgPort));
    if (!port)
	_exit(1);
    mask = SIGBREAKF_CTRL_C|(1 << port->mp_SigBit);
    oldwptr = proc->pr_WindowPtr;
    proc->pr_WindowPtr = (APTR)-1;

    /* REMOVED
    proc->pr_ConsoleTask = DeviceProc("dpipe:");
    if (!proc->pr_CIS) {
	mycis = 1;
	proc->pr_CIS = Open("nil:", 1006);
    }
    if (!proc->pr_COS) {
	mycos = 1;
	proc->pr_COS = Open("nil:", 1006);
    }
    */
    for (;;) {
	rmask = Wait(mask);
	if (rmask & SIGBREAKF_CTRL_C)
	    break;
	if (chan = DAccept(port)) {
	    long fh;
	    long mask;
	    long fhmask, smask;
	    short sig;
	    char pname[16];
	    char buf[64];

	    if (GetEnvVal(DNET_LEVEL) < 9) {
		DWrite(chan, "env:DNET_LEVEL must be >= 9\n", 18);
		DClose(chan);
		continue;
	    }

	    sprintf(pname, "%08lx", namei++);
	    sprintf(buf, "newshell <nil: >nil: dpipe:%s/St FROM s:remote-startup", pname);
	    DExec(chan, buf);
	    sig = AllocSignal(-1);
	    fhmask = 1 << sig;
	    smask = 1 << ((struct MsgPort *)chan)->mp_SigBit;
	    sprintf(buf, "dpipe:%s/Mctns%ld", pname, sig);
	    fh = (long)Open(buf, 1006);
	    if (fh) {
		char notdone = 1;
		DWrite(chan, "Amiga CLI running\n", 20);
		while (notdone) {
		    char buf[256];
		    int n;
		    mask = Wait(fhmask | smask | SIGBREAKF_CTRL_C);
		    while ((n = Read(fh, buf, 256)) > 0) {
			DWrite(chan, buf, n);
		    }
		    if (n < 0)
			notdone = 0;
		    while ((n = DNRead(chan, buf, 256)) > 0) {
			/* REMOVED
			DWrite(chan, buf, n);
			*/
			Write(fh, buf, n);
		    }
		    if (n == -2) {
			short pv;
			char pa;
			DGetIoctl(chan, &pv, &pa);
		    } else if (n < 0)
			notdone = 0;
		}
		Write(fh, "ENDCLI\n", 7);
		Write(fh, "ENDCLI\n", 7);
		Close(fh);
	    }
	    DClose(chan);
	    FreeSignal(sig);
	    puts("DONE");
	}
    }
    proc->pr_WindowPtr = oldwptr;

    /* REMOVED
    if (mycos) {
	Close(proc->pr_COS);
	proc->pr_COS = NULL;
    }
    if (mycis) {
	Close(proc->pr_CIS);
	proc->pr_CIS = NULL;
    }
    */
    DUnListen(port);
}