// $Id: accept.c,v 1.119 2008/08/03 14:21:59 lynx Exp $ // vim:syntax=lpc:ts=8
//
// this file contains the glue between LDMUD and psyced to
// connect the socket ports to appropriately named objects.
//
#include "/local/config.h"

#ifdef Dmaster
# undef DEBUG
# define DEBUG Dmaster
#endif

#include NET_PATH "include/net.h"
#include NET_PATH "include/services.h"
#include DRIVER_PATH "include/driver.h"
#include CONFIG_PATH "config.h"

#include DRIVER_PATH "sys/tls.h"

#ifndef ERR_TLS_NOT_DETECTED
# define ERR_TLS_NOT_DETECTED -31337
# ifdef SPYC_PATH
#  echo Warning: TLS autodetect is not enabled in driver.
# endif
#endif

volatile int shutdown_in_progress = 0;

// not part of the master/driver API.. this is called from the library
void notify_shutdown_first(int progress) {
        P3(("%O notify_shutdown_first(%O)\n", ME, progress))
        shutdown_in_progress = progress;
}

#ifndef UID2NICK
# ifdef _userid_nick_mapping
#  define UID2NICK(uid) ([ _userid_nick_mapping ])[uid]
# endif
#endif

/*
 * This function is called every time a TCP connection is established.
 * It dispatches the ports to the protocol implementations.
 * input_to() can't be called from here.
 *
 * uid is only passed if USE_AUTHLOCAL is built into the driver.
 */
object connect(int uid, int port, string service) {
    int peerport;
    mixed arg, t;

    // now that's a bit of preprocessor magic you don't need to understand..  ;)
    D2( if (uid) D("master:connected on port "+ query_mud_port() +" by uid "
		   + uid +"\n");
	else) {
	    D3(D("master:connected on port "+query_mud_port()
		   +" by "+query_ip_name()+"\n");)
    }
#ifndef H_DEFAULT_PROMPT
    set_prompt("");
#endif

    if (shutdown_in_progress) {
        PT(("shutdown_in_progress(%O): putting connection from %O on hold\n",
            shutdown_in_progress, query_ip_name(ME)))
        // put the connection on hold to avoid further reconnects
        return clone_object(NET_PATH "utility/onhold");
    }

    // we dont want the telnet machine most of the time
    // but disabling and re-enabling it for telnet doesn't work
    switch(port || query_mud_port()) {

#if HAS_PORT(PSYCS_PORT, PSYC_PATH)
    case PSYCS_PORT:	// inofficial & temporary
# if __EFUN_DEFINED__(tls_want_peer_certificate)
        tls_want_peer_certificate(ME);
# endif
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			   query_mud_port(), tls_error(t) ));
#endif // fall thru
#if HAS_PORT(PSYC_PORT, PSYC_PATH)
    case PSYC_PORT:
#endif
#if HAS_PORT(PSYC_PORT, PSYC_PATH) || HAS_PORT(PSYCS_PORT, PSYC_PATH)
# ifdef DRIVER_HAS_CALL_BY_REFERENCE
	arg = ME;
	query_ip_number(&arg);
	// this assumes network byte order provided by driver
	peerport = pointerp(arg) ? (arg[2]*256 + arg[3]) : 0;
	if (peerport < 0) peerport = 65536 + peerport;
	// no support for non-AF_INET nets yet
	if (peerport == PSYC_SERVICE) peerport = 0;
# else
	// as long as the object names don't collide, this is okay too
	peerport = 65536 + random(9999999);
# endif
# ifdef DRIVER_HAS_RENAMED_CLONES
	unless (service) service = "psyc";
	t = "S:"+ service + ":"+ query_ip_number();
	// tcp peerports cannot be connected to, so we use minus
	if (peerport) t += ":-"+peerport;
# else
	t = clone_object(PSYC_PATH "server");
# endif
	// the psyc backend distinguishes listen ports from peers using minus
	D3(D(S("%O -> load(%O, %O)\n", t, query_ip_number(), -peerport));)
	return t -> load(query_ip_number(), -peerport);
#endif

#if HAS_PORT(SPYCS_PORT, SPYC_PATH)
    case SPYCS_PORT:	// inofficial & temporary
# if __EFUN_DEFINED__(tls_want_peer_certificate)
        tls_want_peer_certificate(ME);
# endif
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			   query_mud_port(), tls_error(t) ));
#endif // fall thru
#if HAS_PORT(SPYC_PORT, SPYC_PATH)
    case SPYC_PORT:
#endif
#if HAS_PORT(SPYC_PORT, SPYC_PATH) || HAS_PORT(SPYCS_PORT, SPYC_PATH)
# ifdef DRIVER_HAS_CALL_BY_REFERENCE
	arg = ME;
	query_ip_number(&arg);
	// this assumes network byte order provided by driver
	peerport = pointerp(arg) ? (arg[2]*256 + arg[3]) : 0;
	if (peerport < 0) peerport = 65536 + peerport;
	// no support for non-AF_INET nets yet
	if (peerport == PSYC_SERVICE) peerport = 0;
# else
	// as long as the object names don't collide, this is okay too
	peerport = 65536 + random(9999999);
# endif
# ifdef DRIVER_HAS_RENAMED_CLONES
	t = "S:spyc:"+query_ip_number();
	// tcp peerports cannot be connected to, so we use minus
	if (peerport) t += ":-"+peerport;
# else
	t = clone_object(SPYC_PATH "server");
# endif
	// the psyc backend distinguishes listen ports from peers using minus
	D3(D(S("%O -> load(%O, %O)\n", t, query_ip_number(), -peerport));)
	return t -> load(query_ip_number(), -peerport);
#endif

#if HAS_PORT(POP3S_PORT, POP3_PATH)
    case POP3S_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			   query_mud_port(), tls_error(t) ));
	return clone_object(POP3_PATH "server");
#endif
#if HAS_PORT(POP3_PORT, POP3_PATH)
    case POP3_PORT:
	return clone_object(POP3_PATH "server");
#endif

#if HAS_PORT(SMTPS_PORT, NNTP_PATH)
    case SMTPS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			   query_mud_port(), tls_error(t) ));
	return clone_object(SMTP_PATH "server");
#endif
#if HAS_PORT(SMTP_PORT, SMTP_PATH)
    case SMTP_PORT:
	return clone_object(SMTP_PATH "server");
#endif

// heldensagas little http app
#if HAS_PORT(SHT_PORT, SHT_PATH)
    case SHT_PORT:
	return clone_object(SHT_PATH "server");
#endif

#if HAS_PORT(NNTPS_PORT, NNTP_PATH)
    case NNTPS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			   query_mud_port(), tls_error(t) ));
	return clone_object(NNTP_PATH "server");
#endif
#if HAS_PORT(NNTP_PORT, NNTP_PATH)
    case NNTP_PORT:
	return clone_object(NNTP_PATH "server");
#endif

#if HAS_PORT(JABBERS_PORT, JABBER_PATH)
    case JABBERS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			     query_mud_port(), tls_error(t) ));
	return clone_object(JABBER_PATH "server");
#endif
#if HAS_PORT(JABBER_PORT, JABBER_PATH)
    case JABBER_PORT:
# if __EFUN_DEFINED__(enable_telnet)
	enable_telnet(0);   // are you sure!???
# endif
	return clone_object(JABBER_PATH "server");
#endif

#if HAS_PORT(JABBER_S2S_PORT, JABBER_PATH)
    case JABBER_S2S_PORT:
# ifdef DRIVER_HAS_CALL_BY_REFERENCE
	arg = ME;
	query_ip_number(&arg);
	// this assumes network byte order provided by driver
	peerport = pointerp(arg) ? (arg[2]*256 + arg[3]) : 0;
	if (peerport < 0) peerport = 65536 + peerport;
	if (peerport == JABBER_S2S_SERVICE) peerport = 0;
# else
	// as long as the object names don't collide, this is okay too
	peerport = 65536 + random(9999999);
# endif
# if __EFUN_DEFINED__(enable_telnet)
	enable_telnet(0);
# endif
	t = "S:xmpp:"+query_ip_number();
	// it's just an object name, but let's be consequent minus peerport
	if (peerport) t += ":-"+peerport;
# ifdef _flag_log_sockets_XMPP
	SIMUL_EFUN_FILE -> log_file("RAW_XMPP", "\n\n%O: %O -> load(%O, %O)",
				ME, t,
#  ifdef _flag_log_hosts
                                query_ip_number(),
#  else
                                "?",
#  endif
                                -peerport);
# endif
	P3(("%O -> load(%O, %O)\n", t, query_ip_number(), -peerport))
	return t -> load(query_ip_number(), -peerport);
#endif
#if 0 //__EFUN_DEFINED__(enable_binary)
    // work in progress
    case 8888:
        enable_binary();
        enable_telnet(0);
        return clone_object(NET_PATH "socks/protocol");
    case 1935:
        enable_binary();
        enable_telnet(0);
        return clone_object(NET_PATH "rtmp/protocol");
#endif
#if HAS_PORT(IRCS_PORT, IRC_PATH)
    case IRCS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			     query_mud_port(), tls_error(t) ));
	return clone_object(IRC_PATH "server");
#endif
#if HAS_PORT(IRC_PORT, IRC_PATH)
    case IRC_PORT:
# if 0 // __EFUN_DEFINED__(enable_telnet)
	enable_telnet(0);	// shouldn't harm.. but it does!!!
# endif
	return clone_object(IRC_PATH "server");
#endif

#if HAS_PORT(APPLET_PORT, APPLET_PATH)
    case APPLET_PORT:
# if __EFUN_DEFINED__(enable_telnet)
	// enable_telnet(0);
# endif
	return clone_object(APPLET_PATH "server");
#endif

#if HAS_PORT(TELNETS_PORT, TELNET_PATH)
    case TELNETS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			     query_mud_port(), tls_error(t) ));
	// we could do the UID2NICK thing here, too, but why should we?
	// what do you need tls for on a localhost tcp link?
        return clone_object(TELNET_PATH "server");
#endif
#if HAS_PORT(TELNET_PORT, TELNET_PATH)
    case TELNET_PORT:
//	set_prompt("> ");
	// we can't do the usual autodetect here, as telnet users
	// don't send first and rather expect the server to prompt
	// the correct way to do this: implement telnet nego for tls. bah!
        t = clone_object(TELNET_PATH "server");
# ifdef UID2NICK
        if (uid && (arg = UID2NICK(uid))) { t -> sName(arg); }
# endif
	return t;
#endif

#if HAS_PORT(HTTPS_PORT, HTTP_PATH)
    case HTTPS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0) {
		D1( if (t != ERR_TLS_NOT_DETECTED) PP(( "TLS(%O) on %O: %O\n",
					t, query_mud_port(), tls_error(t) )); )
#if !HAS_PORT(HTTP_PORT, HTTP_PATH)
		// if we have no http port, it may be intentional
                return (object)0;
#endif
	}
	D2( else if (t > 0) PP(( "Setting up TLS connection in the background.\n" )); )
	D2( else PP(( "Oh yeah, I'm initializing an https session!\n" )); )
	return clone_object(HTTP_PATH "server");
#endif
	/* don't fall thru. allow for https: to be available without http: */
#if HAS_PORT(HTTP_PORT, HTTP_PATH)
    case HTTP_PORT:
	return clone_object(HTTP_PATH "server");
#endif

#if HAS_PORT(MUDS_PORT, MUD_PATH)
    case MUDS_PORT:
	t = tls_init_connection(this_object());
	if (t < 0 && t != ERR_TLS_NOT_DETECTED) PP(( "TLS on %O: %O\n",
			     query_mud_port(), tls_error(t) ));
	return clone_object(MUD_PATH "login");
#endif
#if HAS_PORT(MUD_PORT, MUD_PATH)
    default:
	// if you want to multiplex psyced with an LPMUD game
//	set_prompt("> ");
	return clone_object(MUD_PATH "login");
#endif
    }
    
    PP(("Received connection on port %O which isn't configured.\n",
	query_mud_port()));
    return (object)0;
}


#ifdef DRIVER_HAS_RENAMED_CLONES
// named clones		-lynx
object compile_object(string file) {
	P3((">> compile_object(%O)\n", file))
	string path, name;
	object rob;

# ifdef PSYC_PATH
	if (abbrev("S:psyc:", file)) {
		rob = clone_object(PSYC_PATH "server");
		D2(if (rob) PP(("NAMED CLONE: %O => %s\n", rob, file));)
		return rob;
	}
	if (abbrev("psyc:", file)) {
#  ifdef USE_SPYC
#  echo Using SPYC by default! Yeeha!
		rob = clone_object(SPYC_PATH "active");
#  else
		rob = clone_object(PSYC_PATH "active");
#  endif
		D2(if (rob) PP(("NAMED CLONE: %O => %s\n", rob, file));)
		return rob;
	}
# endif
# ifdef SPYC_PATH
	if (abbrev("S:spyc:", file)) {
		rob = clone_object(SPYC_PATH "server");
		D2(if (rob) PP(("NAMED CLONE: %O => %s\n", rob, file));)
		return rob;
	}
	if (abbrev("spyc:", file)) {
		rob = clone_object(SPYC_PATH "active");
		D2(if (rob) PP(("NAMED CLONE: %O => %s\n", rob, file));)
		return rob;
	}
# endif
# ifdef HTTP_PATH
        // match both http:/ and https:/ objects  ;D
	if (abbrev("http", file)) {
		rob = clone_object(HTTP_PATH "fetch");
		// driver has the habit of removing double slash in object name
		file = replace(file, ":/", "://");
		if (rob) rob->fetch(file[..<3]);
		return rob;
	}
	if (abbrev("xmlrpc:", file)) {
	    rob = clone_object(HTTP_PATH "xmlrpc");
	    if (rob) rob->fetch("http://" + file[7..<3]);
	    return rob;
	}
# endif
	if (sscanf(file, "place/%s.c", name) && name != "") {
#ifdef SANDBOX
		string t;
#endif
		unless (name = SIMUL_EFUN_FILE->legal_name(name, 1))
		    return (object)0;

		string username;
		if (sscanf(file, "place/~%s#updates", username)) {
		    object p;
		    unless ((p = SIMUL_EFUN_FILE->summon_person(username, NET_PATH "user")) && p->vQuery("password")) {
			P3(("PLACE %O NOT CLONED: %O isn't a registered user\n", name, username));
			return (object)0;
		    }

		    if (rob = clone_object(NET_PATH "place/userthreads")) {
			PP(("PLACE CLONED: %O becomes %O\n", rob, file));
			rob->sName(name);
			return rob;
		    } else {
			P3(("ERROR: could not clone place %O\n", name));
			return (object)0;
		    }
		}

#ifdef SANDBOX
		if (file_size(t = USER_PATH + name + ".c") != -1) {
		    rob = t -> sName(name);
		    D2(if (rob) PP(("USER PLACE loaded: %O becomes %O\n", rob, file));)
		} else {
#endif

#ifdef _flag_disable_places_arbitrary
		    P2(("WARN: cloned places disabled by #define %O\n", file))
		    return (object)0;
#else
#ifdef _path_archetype_place_default
		    rob = clone_object(_path_archetype_place_default);
#else
		    rob = clone_object(NET_PATH "place/default");
#endif
		    rob -> sName(name);
		    D2(if (rob) PP(("PLACE CLONED: %O becomes %O\n", rob, file));)
#endif
#ifdef SANDBOX
		}
#endif
		return rob;
	}
	if (sscanf(file, "%s#%s.c", path, name) && name != "") {
		unless (name = SIMUL_EFUN_FILE->legal_name(name))
		    return (object)0;
		rob = clone_object(path);
		rob -> sName(name);
		D2(if (rob) PP(("NAMED CLONE: %O becomes %s of %s\n",
				rob, name, path));)
		return rob;
	}
	if (sscanf(file, "%s/text.c", path) && path != "") {
		rob = clone_object(NET_PATH "text");
		rob -> sPath(path);
		D2(if (rob) PP(("DB CLONED: %O becomes %s/text\n", rob, path));)
		return rob;
	}
# ifdef JABBER_PATH
	if (abbrev("S:xmpp:", file)) {
		rob = clone_object(JABBER_PATH "gateway");
		D2(if (rob) PP(("NAMED CLONE: %O => %s\n", rob, file));)
		return rob;
	}
	if (abbrev("C:xmpp:", file)) {
		rob = clone_object(JABBER_PATH "active");
		D2(if (rob) PP(("NAMED CLONE: %O => %s\n", rob, file));)
		return rob;
	}
# endif
	P3(("WARN: could not create %O\n", file))
	return (object)0;
}
#endif