void Write_NoFormat(int sock, const char *text)
{
- if ((sock < 0) || (!text))
+ if ((sock < 0) || (!text) || (sock > MAX_DESCRIPTORS))
return;
char tb[MAXBUF];
{
if (Config->GetIOHook(fd_ref_table[sock]->port))
{
- Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ try
+ {
+ Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
}
else
{
void Write(int sock,char *text, ...)
{
- if (sock < 0)
+ if ((sock < 0) || (sock > MAX_DESCRIPTORS))
return;
if (!text)
{
{
if (Config->GetIOHook(fd_ref_table[sock]->port))
{
- Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ try
+ {
+ Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
}
else
{
void WriteServ_NoFormat(int sock, const char* text)
{
- if ((sock < 0) || (!text))
+ if ((sock < 0) || (!text) || (sock > MAX_DESCRIPTORS))
return;
char tb[MAXBUF];
int bytes = snprintf(tb,MAXBUF,":%s %s\r\n",Config->ServerName,text);
{
if (Config->GetIOHook(fd_ref_table[sock]->port))
{
- Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ try
+ {
+ Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
}
else
{
void WriteServ(int sock, char* text, ...)
{
- if (sock < 0)
+ if ((sock < 0) || (sock > MAX_DESCRIPTORS))
return;
if (!text)
{
{
if (Config->GetIOHook(fd_ref_table[sock]->port))
{
- Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ try
+ {
+ Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
}
else
{
void WriteFrom_NoFormat(int sock, userrec *user, const char* text)
{
- if ((sock < 0) || (!text) || (!user))
+ if ((sock < 0) || (!text) || (!user) || (sock > MAX_DESCRIPTORS))
return;
char tb[MAXBUF];
int bytes = snprintf(tb,MAXBUF,":%s %s\r\n",user->GetFullHost(),text);
{
if (Config->GetIOHook(fd_ref_table[sock]->port))
{
- Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ try
+ {
+ Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
}
else
{
void WriteFrom(int sock, userrec *user,char* text, ...)
{
- if (sock < 0)
+ if ((sock < 0) || (sock > MAX_DESCRIPTORS))
return;
if ((!text) || (!user))
{
{
if (Config->GetIOHook(fd_ref_table[sock]->port))
{
- Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ try
+ {
+ Config->GetIOHook(fd_ref_table[sock]->port)->OnRawSocketWrite(sock,tb,bytes);
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
}
else
{
/* write formatted text from a source user to all users on a channel except
* for the sender (for privmsg etc) */
-void ChanExceptSender(chanrec* Ptr, userrec* user, char* text, ...)
+void ChanExceptSender(chanrec* Ptr, userrec* user, char status, char* text, ...)
{
if ((!Ptr) || (!user) || (!text))
{
vsnprintf(textbuffer, MAXBUF, text, argsPtr);
va_end(argsPtr);
- std::map<char*,char*> *ulist= Ptr->GetUsers();
+ std::map<char*,char*> *ulist;
+ switch (status)
+ {
+ case '@':
+ ulist = Ptr->GetOppedUsers();
+ break;
+ case '%':
+ ulist = Ptr->GetHalfoppedUsers();
+ break;
+ case '+':
+ ulist = Ptr->GetVoicedUsers();
+ break;
+ default:
+ ulist = Ptr->GetUsers();
+ break;
+ }
+ log(DEBUG,"%d users to write to",ulist->size());
for (std::map<char*,char*>::iterator i = ulist->begin(); i != ulist->end(); i++)
{
char* o = i->second;
}
}
-void ChanExceptSender_NoFormat(chanrec* Ptr, userrec* user, const char* text)
+void ChanExceptSender_NoFormat(chanrec* Ptr, userrec* user, char status, const char* text)
{
if ((!Ptr) || (!user) || (!text))
{
log(DEFAULT,"*** BUG *** ChanExceptSender was given an invalid parameter");
return;
}
- std::map<char*,char*> *ulist= Ptr->GetUsers();
+ std::map<char*,char*> *ulist;
+ switch (status)
+ {
+ case '@':
+ ulist = Ptr->GetOppedUsers();
+ break;
+ case '%':
+ ulist = Ptr->GetHalfoppedUsers();
+ break;
+ case '+':
+ ulist = Ptr->GetVoicedUsers();
+ break;
+ default:
+ ulist = Ptr->GetUsers();
+ break;
+ }
for (std::map<char*,char*>::iterator i = ulist->begin(); i != ulist->end(); i++)
{
char* o = i->second;
return iter->second;
}
+userrec* Find(const char* nick)
+{
+ if (!nick)
+ return NULL;
+ user_hash::iterator iter = clientlist.find(nick);
+
+ if (iter == clientlist.end())
+ return NULL;
+
+ return iter->second;
+}
+
/* find a channel record by channel name and return a pointer to it */
chanrec* FindChan(const char* chan)
int usercount_opers(void)
{
- return all_opers.size();
+ int c = 0;
+ for (user_hash::const_iterator i = clientlist.begin(); i != clientlist.end(); i++)
+ if (*i->second->oper) c++;
+ return c;
}
int usercount_unknown(void)
// only one write operation
if (Config->GetIOHook(user->port))
{
- Config->GetIOHook(user->port)->OnRawSocketWrite(user->fd,(char*)WholeMOTD.c_str(),WholeMOTD.length());
+ try
+ {
+ Config->GetIOHook(user->port)->OnRawSocketWrite(user->fd,(char*)WholeMOTD.c_str(),WholeMOTD.length());
+ }
+ catch (ModuleException& modexcept)
+ {
+ log(DEBUG,"Module exception cought: %s",modexcept.GetReason()); \
+ }
+
}
else
{
output.insert(pos, mode);
return 1;
}
+
+bool IsValidChannelName(const char *chname)
+{
+ char *c;
+
+ /* check for no name - don't check for !*chname, as if it is empty, it won't be '#'! */
+ if (!chname || *chname != '#')
+ {
+ return false;
+ }
+
+ c = (char *)chname + 1;
+ while (*c)
+ {
+ switch (*c)
+ {
+ case ' ':
+ case ',':
+ case 7:
+ return false;
+ }
+
+ c++;
+ }
+
+ /* too long a name - note funky pointer arithmetic here. */
+ if ((c - chname) > CHANMAX)
+ {
+ return false;
+ }
+
+ return true;
+}