X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fmodules%2Fm_jumpserver.cpp;h=44c6fc0d9fb20cfbd11c5a23015faac793c73f36;hb=0c78ad71d32e4062827f2ebac927bdbf43c091ba;hp=5a823b44cdc17f7b687ee16412ae61cdfb05e452;hpb=bab14f0dd2345c9d7dcbc47c918563709e1ac094;p=user%2Fhenk%2Fcode%2Finspircd.git diff --git a/src/modules/m_jumpserver.cpp b/src/modules/m_jumpserver.cpp index 5a823b44c..44c6fc0d9 100644 --- a/src/modules/m_jumpserver.cpp +++ b/src/modules/m_jumpserver.cpp @@ -1 +1,182 @@ -/* +------------------------------------+ * | Inspire Internet Relay Chat Daemon | * +------------------------------------+ * * InspIRCd: (C) 2002-2007 InspIRCd Development Team * See: http://www.inspircd.org/wiki/index.php/Credits * * This program is free but copyrighted software; see * the file COPYING for details. * * --------------------------------------------------- */ #include "inspircd.h" #include "users.h" #include "channels.h" #include "modules.h" /* $ModDesc: Provides support for unreal-style SAPART command */ /** Handle /SAPART */ class cmd_jumpserver : public command_t { public: bool redirect_all_immediately; bool redirect_new_users; bool direction; std::string redirect_to; std::string reason; int port; cmd_jumpserver (InspIRCd* Instance) : command_t(Instance, "JUMPSERVER", 'o', 0) { this->source = "m_jumpserver.so"; syntax = "[ <+/-a> :]"; redirect_to.clear(); reason.clear(); port = 0; redirect_all_immediately = redirect_new_users = false; } CmdResult Handle (const char** parameters, int pcnt, userrec *user) { int n_done = 0; reason = (pcnt < 4) ? "Please use this server/port instead" : parameters[3]; redirect_all_immediately = false; redirect_new_users = true; direction = true; std::string n_done_s; /* No parameters: jumpserver disabled */ if (!pcnt) { if (port) user->WriteServ("NOTICE %s :*** Disabled jumpserver (previously set to '%s:%d')", user->nick, redirect_to.c_str(), port); else user->WriteServ("NOTICE %s :*** jumpserver was not enabled.", user->nick); port = 0; redirect_to.clear(); return CMD_LOCALONLY; } port = 0; redirect_to.clear(); for (const char* n = parameters[2]; *n; n++) { switch (*n) { case '+': direction = true; break; case '-': direction = false; break; case 'a': redirect_all_immediately = direction; break; case 'n': redirect_new_users = direction; break; } } if (redirect_all_immediately) { /* Redirect everyone but the oper sending the command */ for (std::vector::const_iterator i = ServerInstance->local_users.begin(); i != ServerInstance->local_users.end(); i++) { userrec* t = *i; if (!IS_OPER(t)) { t->WriteServ("010 %s %s %s :Please use this Server/Port instead", user->nick, parameters[0], parameters[1]); userrec::QuitUser(ServerInstance, t, reason); n_done++; } } if (n_done) { n_done_s = ConvToStr(n_done); } } if (redirect_new_users) { redirect_to = parameters[0]; port = atoi(parameters[1]); } user->WriteServ("NOTICE %s :*** Set jumpserver to server '%s' port '%s', flags '+%s%s'%s%s%s: %s", user->nick, parameters[0], parameters[1], redirect_all_immediately ? "a" : "", redirect_new_users ? "n" : "", n_done ? " (" : "", n_done ? n_done_s.c_str() : "", n_done ? " user(s) redirected)" : "", reason.c_str()); return CMD_LOCALONLY; } }; class ModuleJumpServer : public Module { cmd_jumpserver* js; public: ModuleJumpServer(InspIRCd* Me) : Module(Me) { js = new cmd_jumpserver(ServerInstance); ServerInstance->AddCommand(js); } virtual ~ModuleJumpServer() { } virtual int OnUserRegister(userrec* user) { if (js->port && js->redirect_new_users) { user->WriteServ("010 %s %s %d :Please use this Server/Port instead", user->nick, js->redirect_to.c_str(), js->port); userrec::QuitUser(ServerInstance, user, js->reason); return 0; } return 0; } virtual void Implements(char* List) { List[I_OnUserRegister] = 1; } virtual Version GetVersion() { return Version(1,1,0,1,VF_VENDOR,API_VERSION); } }; MODULE_INIT(ModuleJumpServer) \ No newline at end of file +/* + * InspIRCd -- Internet Relay Chat Daemon + * + * Copyright (C) 2007-2008 Craig Edwards + * Copyright (C) 2007 Dennis Friis + * Copyright (C) 2007 Robin Burchell + * + * This file is part of InspIRCd. InspIRCd 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, version 2. + * + * 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, see . + */ + + +#include "inspircd.h" + +/* $ModDesc: Provides support for the RPL_REDIR numeric and the /JUMPSERVER command. */ + +/** Handle /JUMPSERVER + */ +class CommandJumpserver : public Command +{ + public: + bool redirect_new_users; + std::string redirect_to; + std::string reason; + int port; + + CommandJumpserver(Module* Creator) : Command(Creator, "JUMPSERVER", 0, 4) + { + flags_needed = 'o'; syntax = "[ <+/-an> ]"; + port = 0; + redirect_new_users = false; + } + + CmdResult Handle (const std::vector ¶meters, User *user) + { + int n_done = 0; + reason = (parameters.size() < 4) ? "Please use this server/port instead" : parameters[3]; + bool redirect_all_immediately = false; + redirect_new_users = true; + bool direction = true; + std::string n_done_s; + + /* No parameters: jumpserver disabled */ + if (!parameters.size()) + { + if (port) + user->WriteServ("NOTICE %s :*** Disabled jumpserver (previously set to '%s:%d')", user->nick.c_str(), redirect_to.c_str(), port); + else + user->WriteServ("NOTICE %s :*** Jumpserver was not enabled.", user->nick.c_str()); + + port = 0; + redirect_to.clear(); + return CMD_SUCCESS; + } + + port = 0; + redirect_to.clear(); + + if (parameters.size() >= 3) + { + for (std::string::const_iterator n = parameters[2].begin(); n != parameters[2].end(); ++n) + { + switch (*n) + { + case '+': + direction = true; + break; + case '-': + direction = false; + break; + case 'a': + redirect_all_immediately = direction; + break; + case 'n': + redirect_new_users = direction; + break; + default: + user->WriteServ("NOTICE %s :*** Invalid JUMPSERVER flag: %c", user->nick.c_str(), *n); + return CMD_FAILURE; + break; + } + } + + if (!atoi(parameters[1].c_str())) + { + user->WriteServ("NOTICE %s :*** Invalid port number", user->nick.c_str()); + return CMD_FAILURE; + } + + if (redirect_all_immediately) + { + /* Redirect everyone but the oper sending the command */ + for (LocalUserList::const_iterator i = ServerInstance->Users->local_users.begin(); i != ServerInstance->Users->local_users.end(); ++i) + { + User* t = *i; + if (!IS_OPER(t)) + { + t->WriteNumeric(10, "%s %s %s :Please use this Server/Port instead", t->nick.c_str(), parameters[0].c_str(), parameters[1].c_str()); + ServerInstance->Users->QuitUser(t, reason); + n_done++; + } + } + if (n_done) + { + n_done_s = ConvToStr(n_done); + } + } + + if (redirect_new_users) + { + redirect_to = parameters[0]; + port = atoi(parameters[1].c_str()); + } + + user->WriteServ("NOTICE %s :*** Set jumpserver to server '%s' port '%s', flags '+%s%s'%s%s%s: %s", user->nick.c_str(), parameters[0].c_str(), parameters[1].c_str(), + redirect_all_immediately ? "a" : "", + redirect_new_users ? "n" : "", + n_done ? " (" : "", + n_done ? n_done_s.c_str() : "", + n_done ? " user(s) redirected)" : "", + reason.c_str()); + } + + return CMD_SUCCESS; + } +}; + + +class ModuleJumpServer : public Module +{ + CommandJumpserver js; + public: + ModuleJumpServer() : js(this) + { + } + + void init() + { + ServerInstance->Modules->AddService(js); + Implementation eventlist[] = { I_OnUserRegister, I_OnRehash }; + ServerInstance->Modules->Attach(eventlist, this, sizeof(eventlist)/sizeof(Implementation)); + } + + virtual ~ModuleJumpServer() + { + } + + virtual ModResult OnUserRegister(LocalUser* user) + { + if (js.port && js.redirect_new_users) + { + user->WriteNumeric(10, "%s %s %d :Please use this Server/Port instead", + user->nick.c_str(), js.redirect_to.c_str(), js.port); + ServerInstance->Users->QuitUser(user, js.reason); + return MOD_RES_DENY; + } + return MOD_RES_PASSTHRU; + } + + virtual void OnRehash(User* user) + { + // Emergency way to unlock + if (!user) js.redirect_new_users = false; + } + + virtual Version GetVersion() + { + return Version("Provides support for the RPL_REDIR numeric and the /JUMPSERVER command.", VF_VENDOR); + } + +}; + +MODULE_INIT(ModuleJumpServer)