From c2624f71e1260881610dc6109f0b3ad61ae4f31a Mon Sep 17 00:00:00 2001 From: brain Date: Sun, 29 May 2005 18:14:13 +0000 Subject: [PATCH] Added m_watch.cpp (provides /WATCH for notify) and fixes to allow it to work git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@1556 e03df62e-2008-0410-955e-edbf42e46eb7 --- src/commands.cpp | 5 + src/inspircd.cpp | 1 + src/modules/m_watch.cpp | 300 ++++++++++++++++++++++++++++++++++++++++ 3 files changed, 306 insertions(+) create mode 100644 src/modules/m_watch.cpp diff --git a/src/commands.cpp b/src/commands.cpp index 26cfa0da6..3a9399f7c 100644 --- a/src/commands.cpp +++ b/src/commands.cpp @@ -2286,6 +2286,11 @@ void handle_n(char token,char* params,serverrec* source,serverrec* reply, char* if (!user->nick) return; strlcpy(user->nick, newnick,NICKMAX); log(DEBUG,"new nick set: %s",user->nick); + if (user->registered == 7) + { + FOREACH_MOD OnUserPostNick(user,oldnick); + } + } } diff --git a/src/inspircd.cpp b/src/inspircd.cpp index 37c98bb1b..c780b8bf1 100644 --- a/src/inspircd.cpp +++ b/src/inspircd.cpp @@ -1607,6 +1607,7 @@ void FullConnectUser(userrec* user) // fix by brain: these should be AFTER the N token, so other servers know what the HELL we're on about... :) FOREACH_MOD OnUserConnect(user); + FOREACH_MOD OnGlobalConnect(user); WriteOpers("*** Client connecting on port %lu: %s!%s@%s [%s]",(unsigned long)user->port,user->nick,user->ident,user->host,user->ip); } diff --git a/src/modules/m_watch.cpp b/src/modules/m_watch.cpp new file mode 100644 index 000000000..f613acda3 --- /dev/null +++ b/src/modules/m_watch.cpp @@ -0,0 +1,300 @@ +/* +------------------------------------+ + * | Inspire Internet Relay Chat Daemon | + * +------------------------------------+ + * + * Inspire is copyright (C) 2002-2004 ChatSpike-Dev. + * E-mail: + * + * + * + * Written by Craig Edwards, Craig McLure, and others. + * This program is free but copyrighted software; see + * the file COPYING for details. + * + * --------------------------------------------------- + */ + +using namespace std; + +#include +#include +#include +#include "users.h" +#include "channels.h" +#include "modules.h" +#include "helperfuncs.h" +#include "hashcomp.h" + +/* $ModDesc: Provides support for the /watch command */ + +Server *Srv; + +class watchentry +{ + public: + userrec* watcher; + std::string target; +}; + +typedef std::vector watchlist; +watchlist watches; + +void handle_watch(char **parameters, int pcnt, userrec *user) +{ + if (!pcnt) + { + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + userrec* targ = Srv->FindNick(q->target); + if (targ) + { + WriteServ(user->fd,"604 %s %s %s %s %lu :is online",user->nick,targ->nick,targ->ident,targ->dhost,targ->age); + } + } + } + WriteServ(user->fd,"607 %s :End of WATCH list",user->nick); + } + else if (pcnt > 0) + { + for (int x = 0; x < pcnt; x++) + { + char *nick = parameters[x]; + if (!strcasecmp(nick,"C")) + { + // watch clear + bool done = false; + while (!done) + { + done = true; + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + done = false; + watches.erase(q); + break; + } + } + } + } + if (!strcasecmp(nick,"L")) + { + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + userrec* targ = Srv->FindNick(q->target); + if (targ) + { + WriteServ(user->fd,"604 %s %s %s %s %lu :is online",user->nick,targ->nick,targ->ident,targ->dhost,targ->age); + } + } + } + WriteServ(user->fd,"607 %s :End of WATCH list",user->nick); + } + if (!strcasecmp(nick,"S")) + { + std::string list = ""; + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + list = list + " " + q->target; + } + } + char* l = (char*)list.c_str(); + if (*l == ' ') + l++; + WriteServ(user->fd,"606 %s :%s",user->nick,l); + WriteServ(user->fd,"607 %s :End of WATCH S",user->nick); + } + if (nick[0] == '-') + { + // removing an item from the list + nick++; + irc::string n1 = nick; + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + irc::string n2 = q->target.c_str(); + userrec* a = Srv->FindNick(q->target); + if (a) + { + WriteServ(user->fd,"602 %s %s %s %s %lu :stopped watching",user->nick,a->nick,a->ident,a->dhost,a->age); + } + else + { + WriteServ(user->fd,"602 %s %s * * 0 :stopped watching",user->nick,q->target.c_str()); + } + if (n1 == n2) + { + watches.erase(q); + break; + } + } + } + } + else if (nick[0] == '+') + { + nick++; + irc::string n1 = nick; + bool exists = false; + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + irc::string n2 = q->target.c_str(); + if (n1 == n2) + { + // already on watch list + exists = true; + } + } + } + if (!exists) + { + watchentry w; + w.watcher = user; + w.target = nick; + watches.push_back(w); + log(DEBUG,"*** Added %s to watchlist of %s",nick,user->nick); + } + userrec* a = Srv->FindNick(nick); + if (a) + { + WriteServ(user->fd,"604 %s %s %s %s %lu :is online",user->nick,a->nick,a->ident,a->dhost,a->age); + } + else + { + WriteServ(user->fd,"605 %s %s * * 0 :is offline",user->nick,nick); + } + } + } + } + return; +} + + +class Modulewatch : public Module +{ + + public: + + Modulewatch() + { + Srv = new Server; + Srv->AddCommand("WATCH",handle_watch,0,0,"m_watch.so"); + } + + virtual void OnUserQuit(userrec* user) + { + log(DEBUG,"*** WATCH: On global quit: user %s",user->nick); + irc::string n2 = user->nick; + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + irc::string n1 = q->target.c_str(); + if (n1 == n2) + { + log(DEBUG,"*** WATCH: On global quit: user %s is in notify of %s",user->nick,q->watcher->nick); + WriteServ(q->watcher->fd,"601 %s %s %s %s %lu :went offline",q->watcher->nick,user->nick,user->ident,user->dhost,time(NULL)); + } + } + bool done = false; + while (!done) + { + done = true; + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + if (q->watcher == user) + { + done = false; + watches.erase(q); + break; + } + } + } + } + + virtual void OnGlobalConnect(userrec* user) + { + irc::string n2 = user->nick; + log(DEBUG,"*** WATCH: On global connect: user %s",user->nick); + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + irc::string n1 = q->target.c_str(); + if (n1 == n2) + { + log(DEBUG,"*** WATCH: On global connect: user %s is in notify of %s",user->nick,q->watcher->nick); + WriteServ(q->watcher->fd,"600 %s %s %s %s %lu :arrived online",q->watcher->nick,user->nick,user->ident,user->dhost,user->age); + } + } + } + + virtual void OnUserPostNick(userrec* user, std::string oldnick) + { + irc::string n2 = oldnick.c_str(); + irc::string n3 = user->nick; + log(DEBUG,"*** WATCH: On global nickchange: old nick: %s new nick: %s",oldnick.c_str(),user->nick); + for (watchlist::iterator q = watches.begin(); q != watches.end(); q++) + { + irc::string n1 = q->target.c_str(); + // changed from a nick on the watchlist to one that isnt + if (n1 == n2) + { + log(DEBUG,"*** WATCH: On global nickchange: old nick %s was on notify list of %s",oldnick.c_str(),q->watcher->nick); + WriteServ(q->watcher->fd,"601 %s %s %s %s %lu :went offline",q->watcher->nick,oldnick.c_str(),user->ident,user->dhost,time(NULL)); + } + else if (n1 == n3) + { + // changed from a nick not on notify to one that is + log(DEBUG,"*** WATCH: On global nickchange: new nick %s is on notify list of %s",user->nick,q->watcher->nick); + WriteServ(q->watcher->fd,"600 %s %s %s %s %lu :arrived online",q->watcher->nick,user->nick,user->ident,user->dhost,user->age); + } + } + } + + virtual void On005Numeric(std::string &output) + { + // we don't really have a limit... + output = output + " WATCH=999"; + } + + virtual ~Modulewatch() + { + delete Srv; + } + + virtual Version GetVersion() + { + return Version(1,0,0,1,VF_VENDOR); + } +}; + + +class ModulewatchFactory : public ModuleFactory +{ + public: + ModulewatchFactory() + { + } + + ~ModulewatchFactory() + { + } + + virtual Module * CreateModule() + { + return new Modulewatch; + } + +}; + + +extern "C" void * init_module( void ) +{ + return new ModulewatchFactory; +} + -- 2.39.5