/* Initalization and related routines. * * (C) 2003-2014 Anope Team * Contact us at team@anope.org * * Please read COPYING and README for further details. * * Based on the original code of Epona by Lara. * Based on the original code of Services by Andy Church. * * */ #include "services.h" #include "pseudo.h" int servernum = 0; extern void moduleAddMsgs(void); extern void moduleAddIRCDMsgs(void); /*************************************************************************/ void introduce_user(const char *user) { /* Watch out for infinite loops... */ #define LTSIZE 20 static int lasttimes[LTSIZE]; if (lasttimes[0] >= time(NULL) - 3) fatal("introduce_user() loop detected"); memmove(lasttimes, lasttimes + 1, sizeof(lasttimes) - sizeof(int)); lasttimes[LTSIZE - 1] = time(NULL); #undef LTSIZE /* Introduce OperServ first because on some IRCd's send * we send data from OperServ before introduction completes. * Patch fixing ratbox RESV support provided by Jobe. */ if (!user || stricmp(user, s_OperServ) == 0) { anope_cmd_nick(s_OperServ, desc_OperServ, ircd->operservmode); } /* NickServ */ if (!user || stricmp(user, s_NickServ) == 0) { anope_cmd_nick(s_NickServ, desc_NickServ, ircd->nickservmode); } /* ChanServ */ if (!user || stricmp(user, s_ChanServ) == 0) { anope_cmd_nick(s_ChanServ, desc_ChanServ, ircd->chanservmode); } if (s_HostServ && ircd->vhost && (!user || stricmp(user, s_HostServ) == 0)) { anope_cmd_nick(s_HostServ, desc_HostServ, ircd->hostservmode); } if (!user || stricmp(user, s_MemoServ) == 0) { anope_cmd_nick(s_MemoServ, desc_MemoServ, ircd->memoservmode); } if (s_BotServ && (!user || stricmp(user, s_BotServ) == 0)) { anope_cmd_nick(s_BotServ, desc_BotServ, ircd->botservmode); } if (!user || stricmp(user, s_HelpServ) == 0) { anope_cmd_nick(s_HelpServ, desc_HelpServ, ircd->helpservmode); } if (s_DevNull && (!user || stricmp(user, s_DevNull) == 0)) { anope_cmd_nick(s_DevNull, desc_DevNull, ircd->devnullmode); } if (!user || stricmp(user, s_GlobalNoticer) == 0) { anope_cmd_nick(s_GlobalNoticer, desc_GlobalNoticer, ircd->globalmode); } /* We make aliases go online */ if (s_NickServAlias && (!user || stricmp(user, s_NickServAlias) == 0)) { anope_cmd_nick(s_NickServAlias, desc_NickServAlias, ircd->nickservaliasmode); } if (s_ChanServAlias && (!user || stricmp(user, s_ChanServAlias) == 0)) { anope_cmd_nick(s_ChanServAlias, desc_ChanServAlias, ircd->chanservaliasmode); } if (s_MemoServAlias && (!user || stricmp(user, s_MemoServAlias) == 0)) { anope_cmd_nick(s_MemoServAlias, desc_MemoServAlias, ircd->memoservaliasmode); } if (s_BotServAlias && (!user || stricmp(user, s_BotServAlias) == 0)) { anope_cmd_nick(s_BotServAlias, desc_BotServAlias, ircd->botservaliasmode); } if (s_HelpServAlias && (!user || stricmp(user, s_HelpServAlias) == 0)) { anope_cmd_nick(s_HelpServAlias, desc_HelpServAlias, ircd->helpservaliasmode); } if (s_OperServAlias && (!user || stricmp(user, s_OperServAlias) == 0)) { anope_cmd_nick(s_OperServAlias, desc_OperServAlias, ircd->operservaliasmode); } if (s_DevNullAlias && (!user || stricmp(user, s_DevNullAlias) == 0)) { anope_cmd_nick(s_DevNullAlias, desc_DevNullAlias, ircd->devnullvaliasmode); } if (s_HostServAlias && ircd->vhost && (!user || stricmp(user, s_HostServAlias) == 0)) { anope_cmd_nick(s_HostServAlias, desc_HostServAlias, ircd->hostservaliasmode); } if (s_GlobalNoticerAlias && (!user || stricmp(user, s_GlobalNoticerAlias) == 0)) { anope_cmd_nick(s_GlobalNoticerAlias, desc_GlobalNoticerAlias, ircd->globalaliasmode); } /* We make the bots go online */ if (s_BotServ) { BotInfo *bi; int i; for (i = 0; i < 256; i++) for (bi = botlists[i]; bi; bi = bi->next) { if (!user || !stricmp(user, bi->nick)) anope_cmd_bot_nick(bi->nick, bi->user, bi->host, bi->real, ircd->botserv_bot_mode); } } } /*************************************************************************/ /* Set GID if necessary. Return 0 if successful (or if RUNGROUP not * defined), else print an error message to logfile and return -1. */ static int set_group(void) { #if defined(RUNGROUP) && defined(HAVE_SETGRENT) struct group *gr; setgrent(); while ((gr = getgrent()) != NULL) { if (strcmp(gr->gr_name, RUNGROUP) == 0) break; } endgrent(); if (gr) { setgid(gr->gr_gid); return 0; } else { alog("Unknown group `%s'\n", RUNGROUP); return -1; } #else return 0; #endif } /*************************************************************************/ /* Parse command-line options for the "-dir" option only. Return 0 if all * went well or -1 for a syntax error. */ /* XXX this could fail if we have "-some-option-taking-an-argument -dir" */ static int parse_dir_options(int ac, char **av) { int i; char *s; for (i = 1; i < ac; i++) { s = av[i]; if (*s == '-') { s++; if (strcmp(s, "dir") == 0) { if (++i >= ac) { fprintf(stderr, "-dir requires a parameter\n"); return -1; } services_dir = av[i]; } else if (strcmp(s, "log") == 0) { if (++i >= ac) { fprintf(stderr, "-log requires a parameter\n"); return -1; } log_filename = av[i]; } else if (strcmp(s, "version") == 0) { fprintf(stdout, "Anope-%s %s -- %s\n", version_number, version_flags, version_build); exit(EXIT_SUCCESS); } } } return 0; } /*************************************************************************/ /* Parse command-line options. Return 0 if all went well, -1 for an error * with an option, or 1 for -help. */ static int parse_options(int ac, char **av) { int i; char *s, *t; for (i = 1; i < ac; i++) { s = av[i]; if (*s == '-') { s++; if (strcmp(s, "remote") == 0) { if (++i >= ac) { fprintf(stderr, "-remote requires hostname[:port]\n"); return -1; } s = av[i]; t = strchr(s, ':'); if (t) { int portnum; *t++ = 0; portnum = atoi(t); if ((portnum > 0) && (portnum < 65535)) RemotePort = portnum; else { fprintf(stderr, "-remote: Port numbers must be in the range 1..65535. Using default.\n"); return -1; } } RemoteServer = s; } else if (strcmp(s, "local") == 0) { if (++i >= ac) { fprintf(stderr, "-local requires hostname or [hostname]:[port]\n"); return -1; } s = av[i]; t = strchr(s, ':'); if (t) { int portnum; *t++ = 0; portnum = atoi(t); if ((portnum >= 0) && (portnum < 65535)) LocalPort = portnum; else { fprintf(stderr, "-local: Port numbers must be in the range 1..65535 or 0. Using default.\n"); return -1; } } LocalHost = s; } else if (strcmp(s, "name") == 0) { if (++i >= ac) { fprintf(stderr, "-name requires a parameter\n"); return -1; } ServerName = av[i]; } else if (strcmp(s, "desc") == 0) { if (++i >= ac) { fprintf(stderr, "-desc requires a parameter\n"); return -1; } ServerDesc = av[i]; } else if (strcmp(s, "user") == 0) { if (++i >= ac) { fprintf(stderr, "-user requires a parameter\n"); return -1; } ServiceUser = av[i]; } else if (strcmp(s, "host") == 0) { if (++i >= ac) { fprintf(stderr, "-host requires a parameter\n"); return -1; } ServiceHost = av[i]; } else if (strcmp(s, "dir") == 0) { /* Handled by parse_dir_options() */ i++; /* Skip parameter */ } else if (strcmp(s, "log") == 0) { /* Handled by parse_dir_options(), too */ i++; /* Skip parameter */ } else if (strcmp(s, "update") == 0) { if (++i >= ac) { fprintf(stderr, "-update requires a parameter\n"); return -1; } s = av[i]; if (atoi(s) <= 0) { fprintf(stderr, "-update: number of seconds must be positive"); return -1; } else UpdateTimeout = atol(s); } else if (strcmp(s, "expire") == 0) { if (++i >= ac) { fprintf(stderr, "-expire requires a parameter\n"); return -1; } s = av[i]; if (atoi(s) <= 0) { fprintf(stderr, "-expire: number of seconds must be positive\n"); return -1; } else ExpireTimeout = atol(s); } else if (strcmp(s, "debug") == 0) { debug++; } else if (strcmp(s, "readonly") == 0) { readonly = 1; skeleton = 0; } else if (strcmp(s, "skeleton") == 0) { readonly = 0; skeleton = 1; } else if (strcmp(s, "nofork") == 0) { nofork = 1; } else if (strcmp(s, "logchan") == 0) { if (!LogChannel) { fprintf(stderr, "-logchan: LogChannel must be defined in services.conf\n"); } else { /* LogChannel */ logchan = 1; } } else if (strcmp(s, "forceload") == 0) { forceload = 1; } else if (strcmp(s, "nothird") == 0) { nothird = 1; } else if (strcmp(s, "protocoldebug") == 0) { protocoldebug = 1; } else if (strcmp(s, "support") == 0) { nofork = 1; debug++; nothird = 1; } else if (!strcmp(s, "noexpire")) { noexpire = 1; } else if (!strcmp(s, "help")) { fprintf(stdout, "Anope-%s %s -- %s\n", version_number, version_flags, version_build); fprintf(stdout, "Anope IRC Services (http://www.anope.org)\n"); fprintf(stdout, "Usage ./services [options] ...\n"); fprintf(stdout, "-remote -remote hostname[:port]\n"); fprintf(stdout, "-local -local hostname[:port]\n"); fprintf(stdout, "-name -name servername\n"); fprintf(stdout, "-desc -desc serverdesc\n"); fprintf(stdout, "-user -user serviceuser\n"); fprintf(stdout, "-host -host servicehost\n"); fprintf(stdout, "-update -update updatetime(secs)\n"); fprintf(stdout, "-expire -expire expiretime(secs)\n"); fprintf(stdout, "-debug -debug\n"); fprintf(stdout, "-protocoldebug -protocoldebug\n"); fprintf(stdout, "-nofork -nofork\n"); fprintf(stdout, "-logchan -logchan channelname\n"); fprintf(stdout, "-skeleton -skeleton\n"); fprintf(stdout, "-forceload -forceload\n"); fprintf(stdout, "-nothird -nothird\n"); fprintf(stdout, "-support -support\n"); fprintf(stdout, "-readonly -readonly\n"); fprintf(stdout, "-noexpire -noexpire\n"); fprintf(stdout, "-version -version\n"); fprintf(stdout, "-help -help\n"); fprintf(stdout, "-log -log logfilename\n"); fprintf(stdout, "-dir -dir servicesdirectory\n\n"); fprintf(stdout, "Further support is available from http://www.anope.org\n"); fprintf(stdout, "Or visit US on IRC at irc.anope.org #anope\n"); exit(EXIT_SUCCESS); } else { fprintf(stderr, "Unknown option -%s\n", s); return -1; } } else { fprintf(stderr, "Non-option arguments not allowed\n"); return -1; } } return 0; } /*************************************************************************/ /* Remove our PID file. Done at exit. */ static void remove_pidfile(void) { remove(PIDFilename); } /*************************************************************************/ /* Create our PID file and write the PID to it. */ static void write_pidfile(void) { FILE *pidfile; pidfile = fopen(PIDFilename, "w"); if (pidfile) { fprintf(pidfile, "%d\n", (int) getpid()); fclose(pidfile); atexit(remove_pidfile); } else { log_perror("Warning: cannot write to PID file %s", PIDFilename); } } /*************************************************************************/ /* Overall initialization routines. Return 0 on success, -1 on failure. */ int openlog_failed = 0, openlog_errno = 0; int init_primary(int ac, char **av) { int started_from_term = isatty(0) && isatty(1) && isatty(2); /* Set file creation mask and group ID. */ #if defined(DEFUMASK) && HAVE_UMASK umask(DEFUMASK); #endif if (set_group() < 0) return -1; /* Parse command line for -dir and -version options. */ parse_dir_options(ac, av); /* Chdir to Services data directory. */ if (chdir(services_dir) < 0) { fprintf(stderr, "chdir(%s): %s\n", services_dir, strerror(errno)); return -1; } /* Open logfile, and complain if we didn't. */ if (open_log() < 0) { openlog_errno = errno; if (started_from_term) { fprintf(stderr, "Warning: unable to open log file %s: %s\n", log_filename, strerror(errno)); } else { openlog_failed = 1; } } /* Read configuration file; exit if there are problems. */ if (!read_config(0)) { return -1; } /* Add IRCD Protocol Module; exit if there are errors */ if (protocol_module_init()) { return -1; } /* Add Encryption Module; exit if there are errors */ if (encryption_module_init()) { return -1; } return 0; } int init_secondary(int ac, char **av) { int i; int started_from_term = isatty(0) && isatty(1) && isatty(2); /* Add Core MSG handles */ moduleAddMsgs(); /* Parse all remaining command-line options. */ parse_options(ac, av); /* Parse the defcon mode string if needed */ if (DefConLevel && !ircd->delay_cl_intro) { if (!defconParseModeString(DefConChanModes)) { fprintf(stderr, "services.conf: The given DefConChanModes mode string was incorrect (see log for exact errors)\n"); return -1; } } #ifndef _WIN32 if (!nofork) { if ((i = fork()) < 0) { perror("fork()"); return -1; } else if (i != 0) { exit(0); } if (started_from_term) { close(0); close(1); close(2); } if (setpgid(0, 0) < 0) { perror("setpgid()"); return -1; } } #else /* Initialize winsocks -- codemastr */ { WSADATA wsa; if (WSAStartup(MAKEWORD(1, 1), &wsa)) { alog("Failed to initialized WinSock library"); return -1; } } if (!SupportedWindowsVersion()) { char *winver = GetWindowsVersion(); alog("%s is not a supported version of Windows", winver); free(winver); return -1; } if (!nofork) { alog("Launching Anope into the background"); FreeConsole(); } #endif /* Write our PID to the PID file. */ write_pidfile(); /* Announce ourselves to the logfile. */ if (debug || readonly || skeleton) { alog("Anope %s (ircd protocol: %s) starting up (options:%s%s%s)", version_number, version_protocol, debug ? " debug" : "", readonly ? " readonly" : "", skeleton ? " skeleton" : ""); } else { alog("Anope %s (ircd protocol: %s) starting up", version_number, version_protocol); } start_time = time(NULL); /* If in read-only mode, close the logfile again. */ if (readonly) close_log(); /* Set signal handlers. Catch certain signals to let us do things or * panic as necessary, and ignore all others. */ #ifndef _WIN32 #if defined(NSIG) for (i = 1; i <= NSIG - 1; i++) { #else for (i = 1; i <= 31; i++) { #endif signal(i, SIG_IGN); } #else /* work around to bug #527 */ signal(SIGILL, SIG_IGN); signal(SIGBREAK, SIG_IGN); signal(SIGABRT, SIG_IGN); #endif signal(SIGINT, sighandler); signal(SIGTERM, sighandler); #ifndef _WIN32 signal(SIGQUIT, sighandler); #endif if (!DumpCore) { signal(SIGSEGV, sighandler); #ifndef _WIN32 signal(SIGBUS, sighandler); signal(SIGTRAP, sighandler); #endif } else { signal(SIGSEGV, SIG_DFL); #ifndef _WIN32 signal(SIGBUS, sighandler); signal(SIGTRAP, sighandler); #endif } #ifndef _WIN32 signal(SIGQUIT, sighandler); signal(SIGHUP, sighandler); signal(SIGUSR2, sighandler); #endif #ifdef SIGIOT signal(SIGIOT, sighandler); #endif signal(SIGFPE, sighandler); #ifndef _WIN32 signal(SIGUSR1, sighandler); /* This is our "out-of-memory" panic switch */ #endif /* Initialize multi-language support */ lang_init(); if (debug) alog("debug: Loaded languages"); /* Initialize subservices */ ns_init(); cs_init(); ms_init(); bs_init(); os_init(); hostserv_init(); helpserv_init(); #ifdef USE_RDB if (!rdb_init()) { if (UseRDB) { UseRDB = 0; alog("Error: Disabling UseRDB due to errors with SQL"); } } else { if (MysqlSecure && UseRDB) { UseRDB = 0; alog("Error: MySQL password are encrypted using method in MysqlSecure disabling UseRDB"); } } #endif /* load any custom modules */ modules_init(); /* Initialize random number generator */ rand_init(); add_entropy_userkeys(); /* Load up databases */ #ifdef USE_RDB if (UseRDB) rdb_load_dbases(); /* Need a better way to handle this -dane */ if (!UseRDB) { #endif if (!skeleton) { load_ns_dbase(); if (debug) alog("debug: Loaded %s database (1/%d)", s_NickServ, (PreNickDBName ? 8 : 7)); if (s_HostServ) { load_hs_dbase(); if (debug) alog("debug: Loaded %s database (2/%d)", s_HostServ, (PreNickDBName ? 8 : 7)); } else if (debug) { alog("debug: HostServ database (2/%d) not loaded because HostServ is disabled", (PreNickDBName ? 8 : 7)); } if (s_BotServ) { load_bs_dbase(); if (debug) alog("debug: Loaded %s database (3/%d)", s_BotServ, (PreNickDBName ? 8 : 7)); } else if (debug) { alog("debug: BotServ database (3/%d) not loaded because BotServ is disabled", (PreNickDBName ? 8 : 7)); } load_cs_dbase(); if (debug) alog("debug: Loaded %s database (4/%d)", s_ChanServ, (PreNickDBName ? 8 : 7)); } load_os_dbase(); if (debug) alog("debug: Loaded %s database (5/%d)", s_OperServ, (PreNickDBName ? 8 : 7)); load_news(); if (debug) alog("debug: Loaded news database (6/%d)", (PreNickDBName ? 8 : 7)); load_exceptions(); if (debug) alog("debug: Loaded exception database (7/%d)", (PreNickDBName ? 8 : 7)); if (PreNickDBName) { load_ns_req_db(); if (debug) alog("debug: Loaded PreNick database (8/8)"); } #ifdef USE_RDB } #endif alog("Databases loaded"); /* Save the databases back to file/mysql to reflect any changes */ #ifdef USE_RDB if (!UseRDB) { /* Only save if we are not using remote databases * to avoid floods. As a side effects our nice * FFF databases won't get overwritten if the * mysql db is broken (empty etc.) */ #endif alog("Info: Reflecting database records."); save_databases(); #ifdef USE_RDB } else { alog("Info: Not reflecting database records."); } #endif send_event(EVENT_CONNECT, 1, EVENT_START); /* Connect to the remote server */ servsock = conn(RemoteServer, RemotePort, LocalHost, LocalPort); if (servsock < 0 && RemoteServer2) { servsock = conn(RemoteServer2, RemotePort2, LocalHost, LocalPort); if (servsock < 0 && RemoteServer3) { servsock = conn(RemoteServer3, RemotePort3, LocalHost, LocalPort); if (servsock < 0) { fatal_perror("Can't connect to server"); } else { servernum = 3; alog("Connected to Server %d (%s:%d)", servernum, RemoteServer3, RemotePort3); } } else { if (servsock < 0) { fatal_perror("Can't connect to server"); } servernum = 2; alog("Connected to Server %d (%s:%d)", servernum, RemoteServer2, RemotePort2); } } else { if (servsock < 0) { fatal_perror("Can't connect to server"); } servernum = 1; alog("Connected to Server %d (%s:%d)", servernum, RemoteServer, RemotePort); } anope_cmd_connect(servernum); send_event(EVENT_CONNECT, 1, EVENT_STOP); sgets2(inbuf, sizeof(inbuf), servsock); if (strnicmp(inbuf, "ERROR", 5) == 0) { /* Close server socket first to stop wallops, since the other * server doesn't want to listen to us anyway */ disconn(servsock); servsock = -1; fatal("Remote server returned: %s", inbuf); } /* Announce a logfile error if there was one */ if (openlog_failed) { anope_cmd_global(NULL, "Warning: couldn't open logfile: %s", strerror(openlog_errno)); } if (!ircd->delay_cl_intro) init_tertiary(); /* Success! */ return 0; } /*************************************************************************/ void init_tertiary() { /* Begin our burst..*/ anope_cmd_bob(); /* Bring in our pseudo-clients */ introduce_user(NULL); /* And hybrid needs Global joined in the logchan */ if (logchan && ircd->join2msg) { /* XXX might desync */ anope_cmd_join(s_GlobalNoticer, LogChannel, time(NULL)); } /* End our burst.. */ anope_cmd_eob(); /** * Load our delayed modeles - modules that are planing on making clients need to wait till now * where as modules wanting to modify our ircd connection messages need to load eariler :| **/ modules_delayed_init(); } /*************************************************************************/