deb-mbse/mbcico/mbtelind.c

/*****************************************************************************
 *
 * $Id$
 * Purpose ...............: Fidonet telnet input proxy daemon
 *
 *****************************************************************************
 * Copyright (C) 1997-2003
 *   
 * Michiel Broek		FIDO:	2:280/2802
 * Beekmansbos 10
 * 1971 BV IJmuiden
 * the Netherlands
 *
 * This file is part of MBSE BBS.
 *
 * This BBS 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, or (at your option) any
 * later version.
 *
 * MBSE BBS 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 MBSE BBS; see the file COPYING.  If not, write to the Free
 * Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
 *****************************************************************************/


/*
  Simple proxy daemon for ifcico to work with SIO/VMODEM.
  ========================================================
  Written by:  Vadim Zaliva, lord@crocodile.kiev.ua, 2:463/80

  This software is provided ``as is'' without express or implied warranty.
  Feel free to distribute it.
  
  Feel free to contact me with improovments request
  and bug reports.
  
  Some parts of this code are taken from
  1. serge terekhov, 2:5000/13@fidonet path for ifmail
  2. Vadim Kurland, vadim@gu.kiev.ua transl daemon.
  Thanks them.
 */

#include "../config.h"
#include "../lib/libs.h"
#include "../lib/structs.h"
#include "../lib/users.h"
#include "../lib/records.h"
#include "../lib/common.h"
#include "../lib/clcomm.h"
#include "../lib/dbcfg.h"
#include "../lib/mberrors.h"
#include "mbtelind.h"


/*
 * Timeout, less then 10 minutes because we need to keep the connection
 * with mbtask alive.
 */
#define MBT_TIMEOUT 500
#define	MBT_BUFLEN  8192


char		*envptr = NULL;
time_t		t_start, t_end;
static int      tellen;



void die(int onsig)
{
    signal(onsig, SIG_IGN);

    if (onsig) {
	if (onsig <= NSIG)
	    WriteError("Terminated on signal %d (%s)", onsig, SigName[onsig]);
	else
	    Syslog('+', "Terminated with error %d", onsig);
    }

    t_end = time(NULL);
    Syslog(' ', "MBTELIND finished in %s", t_elapsed(t_start, t_end));
    if (envptr)
	free(envptr);
    ExitClient(onsig);
}



int main(int ac, char **av)
{
    struct sockaddr_in	peeraddr;
    int			addrlen = sizeof(struct sockaddr_in);
    char		*remote_name = NULL;
    char		*remote_port = NULL;
    int			s; /* socket to remote*/
    int			i;
    struct hostent	*hp;
    struct servent	*sp;
    struct sockaddr_in	server;
    char		*tmp = NULL;
    struct passwd	*pw;

    /*
     * The next trick is to supply a fake environment variable
     * MBSE_ROOT in case we are started from inetd or mgetty,
     * this will setup the variable so InitConfig() will work.
     * The /etc/passwd must point to the correct homedirectory.
     */
     pw = getpwuid(getuid());
	if (getenv("MBSE_ROOT") == NULL) {
	envptr = xstrcpy((char *)"MBSE_ROOT=");
	envptr = xstrcat(envptr, pw->pw_dir);
	putenv(envptr);
    }

    InitConfig();
    t_start = time(NULL);

    InitClient(pw->pw_name, (char *)"mbtelind", CFG.location, CFG.logfile, 
	    CFG.util_loglevel, CFG.error_log, CFG.mgrlog, CFG.debuglog);

    Syslog(' ', " ");
    Syslog(' ', "MBTELIND v%s", VERSION);

    /*
     * Catch all signals we can, and ignore the rest.
     */
    for (i = 0; i < NSIG; i++) {
	if ((i == SIGINT) || (i == SIGBUS) || (i == SIGILL) || (i == SIGSEGV) || (i == SIGTERM) || (i == SIGKILL)) {
	    signal(i, (void (*))die);
	} else {
	    signal(i, SIG_IGN);
	}
    }

    remote_name = xstrcpy((char *)"localhost");
    remote_port = xstrcpy((char *)"fido");

    if (getpeername(0,(struct sockaddr*)&peeraddr,&addrlen) == 0) {
	tmp = strdup(inet_ntoa(peeraddr.sin_addr));
	Syslog('+', "Incoming TCP connection from %s", tmp ? tmp : "Unknown");
	Syslog('+', "Rerouting to %s:%s", remote_name, remote_port);
    }

    if (tmp) 
	free(tmp);
    
    if ((sp = getservbyname(remote_port, "tcp")) == NULL) {
	WriteError("Can't find service: %s", remote_port);
	free(remote_name);
	free(remote_port);
	die(MBERR_INIT_ERROR);
    }

    if ((s = socket(AF_INET,SOCK_STREAM,0)) == -1) {
	WriteError("Can't create Internet domain socket");
	free(remote_name);
	free(remote_port);
	die(MBERR_INIT_ERROR);
    }

    if ((hp = gethostbyname(remote_name)) == NULL) {
	WriteError("%s - Unknown host", remote_name);
	free(remote_name);
	free(remote_port);
	die(MBERR_INIT_ERROR);
    }
  
    memset(&server,0,sizeof(server));
    memcpy((char *)&server.sin_addr,hp->h_addr,hp->h_length);
    
    server.sin_family=hp->h_addrtype;
    server.sin_port  = sp->s_port;
    
    if (connect(s,(struct sockaddr *)&server,sizeof(server)) == -1) {
	WriteError("Can't connect %s", remote_name);
	free(remote_name);
	free(remote_port);
	die(MBERR_INIT_ERROR);
    }

    telnet_init();

    tmp = calloc(81, sizeof(char ));
    sprintf(tmp, "mbtelind v%s\r\n", VERSION);
    telnet_write(tmp, strlen(tmp));
    free(tmp);

    com_gw(s);
    
    free(remote_name);
    free(remote_port);
    close(s);
    die(0);
    return 0;
}



void com_gw(int in)
{
    fd_set		    fds;
    int			    n, fdsbits;
    static struct timeval   tout = { MBT_TIMEOUT, 0 };
    unsigned char	    buf[MBT_BUFLEN];

    alarm(0);
    fdsbits = in + 1;

    while (TRUE) {
        FD_ZERO(&    fds);
        FD_SET (in, &fds);
        FD_SET (0 , &fds);
        FD_SET (1 , &fds);
	
        tout.tv_sec  = MBT_TIMEOUT;
        tout.tv_usec = 0;
        if ((n = select(fdsbits, &fds, NULL, NULL, &tout)) > 0) {
            if (FD_ISSET(in, &fds)) {
                if ((n = read(in, buf, sizeof buf)) > 0) {
                    if (telnet_write(buf, n) < 0) {
			goto bad;
		    }
                } else {
		    goto bad;
		}
            }
            if (FD_ISSET(0, &fds)) {
                if ((n = telnet_read(buf, sizeof buf)) > 0) {
                    if (write(in, buf, n) < 0) goto bad;
                } else {
		    goto bad;
		}
            }
        } else {
	    goto bad;
	}
	Nopper();
    }
bad: ;
}



/* --- This is an artwork of serge terekhov, 2:5000/13@fidonet :) --- */

void telnet_answer(int tag, int opt)
{
    char    buf[3];
    char    *r = (char *)"???";
	
    switch (tag) {
	case WILL:
	    r = (char *)"WILL";
	    break;
	case WONT:
	    r = (char *)"WONT";
	    break;
	case DO:
	    r = (char *)"DO";
	    break;
	case DONT:
	    r = (char *)"DONT";
	    break;
    }
    Syslog('s', "Telnet: send %s %d", r, opt);

    buf[0] = IAC;
    buf[1] = tag;
    buf[2] = opt;
    if (write (1, buf, 3) != 3)
	WriteError("$answer cant send");
}



int telnet_init(void)
{
    Syslog('s', "telnet_init()");
    tellen = 0;
    telnet_answer(DO, TOPT_SUPP);
    telnet_answer(WILL, TOPT_SUPP);
    telnet_answer(DO, TOPT_BIN);
    telnet_answer(WILL, TOPT_BIN);
    telnet_answer(DO, TOPT_ECHO);
    telnet_answer(WILL, TOPT_ECHO);
    return 1;
}



/*
 * Read function for mbtelnetd
 */
int telnet_read(char *buf, int len)
{
    int		n = 0, m;
    char	*q, *p;
    static char	telbuf[4];

    while ((n == 0) && (n = read (0, buf + tellen, MBT_BUFLEN - tellen)) > 0) {

	if (n < 0) {
	    return n;
	}

	if (tellen) {
	    memcpy(buf, telbuf, tellen);
	    n += tellen;
	    tellen = 0;
	}

	if (memchr (buf, IAC, n)) {
	    for (p = q = buf; n--; )
		if ((m = (unsigned char)*q++) != IAC)
		    *p++ = m;
		else {
		    if (n < 2) {
			memcpy (telbuf, q - 1, tellen = n + 1);
			break;
		    }
		    --n;
		    switch (m = (unsigned char)*q++) {
			case WILL:  m = (unsigned char)*q++; --n;
				    Syslog('s', "Telnet: recv WILL %d", m);
				    if (m != TOPT_BIN && m != TOPT_SUPP && m != TOPT_ECHO)
					telnet_answer(DONT, m);
				    break;
			case WONT:  m = *q++; 
				    --n;
				    Syslog('s', "Telnet: recv WONT %d", m);
				    break;
			case DO:    m = (unsigned char)*q++; 
				    --n;
				    Syslog('s', "Telnet: recv DO %d", m);
				    if (m != TOPT_BIN && m != TOPT_SUPP && m != TOPT_ECHO)
					telnet_answer(WONT, m);
				    break;
			case DONT:  m = (unsigned char)*q++; 
				    --n;
				    Syslog('s', "Telnet: recv DONT %d", m);
				    break;
			case IAC:   *p++ = IAC;
				    break;
			default:    Syslog('s', "Telnet: recv IAC %d, not good", m);
				    break;
		    }
		}
	    n = p - buf;
	}
    }

    return n;
}



/*
 * Telnet output filter, IAC characters are escaped.
 */
int telnet_write(char *buf, int len)
{
    char    *q;
    int	    k, l;
    
    l = len;
    while ((len > 0) && (q = memchr(buf, IAC, len))) {
	k = (q - buf) + 1;
	if ((write(1, buf, k) != k) || (write(1, q, 1) != 1)) {
	    return -1;
	}
	buf += k;
	len -= k;
    }

    if ((len > 0) && write(1, buf, len) != len) {
	return -1;
    }
    return l;
}