TRUSTS: require sqlite

[irc/quakenet/newserv.git] / server / server.c

/* server.c
 * 
 * This module is responsible for tracking the active server tree.
 */

#include "../parser/parser.h"
#include "../irc/irc_config.h"
#include "../irc/irc.h"
#include "../lib/base64.h"
#include "../lib/sstring.h"
#include "../core/error.h"
#include "../core/hooks.h"
#include "../core/config.h"
#include "../lib/version.h"
#include "server.h"

#include <stdio.h>
#include <string.h>

MODULE_VERSION("");

int findserver(const char *name);
void completelink(int servernum);

server serverlist[MAXSERVERS];
long myhub;

const flag smodeflags[] = {
   { 'h', SMODE_HUB },
   { '6', SMODE_IPV6 },
   { 's', SMODE_SERVICE },
   { 'n', SMODE_OPERNAME },
   { '\0', 0 } };

void _init() {
  /* Initialise the server tree */
  memset(serverlist,0,MAXSERVERS*sizeof(server));
  
  myhub=-1;
  
  serverlist[numerictolong(mynumeric->content,2)].parent=-1;
  serverlist[numerictolong(mynumeric->content,2)].name=getsstring(myserver->content,HOSTLEN);
  serverlist[numerictolong(mynumeric->content,2)].description=getcopyconfigitem("irc","serverdescription","newserv",100);
  serverlist[numerictolong(mynumeric->content,2)].maxusernum=MAXLOCALUSER;
  serverlist[numerictolong(mynumeric->content,2)].ts=getnettime();
  serverlist[numerictolong(mynumeric->content,2)].linkstate=LS_LINKED;
  /* remember to update the mode line in irc/irc.c */
  serverlist[numerictolong(mynumeric->content,2)].flags=SMODE_SERVICE|SMODE_IPV6|SMODE_HUB|SMODE_OPERNAME;
  
  /* Register the protocol messages we handle */
  registerserverhandler("SERVER",&handleservermsg,8);
  registerserverhandler("S",&handleservermsg,8);
  registerserverhandler("SQ",&handlesquitmsg,3);
  registerserverhandler("EB",&handleeobmsg,0);
  
  /* And the events we hook */
  registerhook(HOOK_IRC_DISCON,&handledisconnect);
}

void _fini() {
  int i;

  /* Deregister everything */
  deregisterserverhandler("SERVER",&handleservermsg);
  deregisterserverhandler("S",&handleservermsg);
  deregisterserverhandler("SQ",&handlesquitmsg);
  deregisterserverhandler("EB",&handleeobmsg);
  deregisterhook(HOOK_IRC_DISCON,&handledisconnect);
  
  for (i=0;i<MAXSERVERS;i++) {
    freesstring(serverlist[i].name);
    freesstring(serverlist[i].description);
  }
}

int handleservermsg(void *source, int cargc, char **cargv) {
  long servernum;
  
  servernum=numerictolong(cargv[5],2);
  
  if (serverlist[servernum].name!=NULL) {
    Error("server",ERR_ERROR,"New server %ld already exists in servertable.",servernum);
    return CMD_ERROR;
  }
 
  serverlist[servernum].name=getsstring(cargv[0],HOSTLEN);
  serverlist[servernum].description=getsstring(cargv[cargc-1],REALLEN);
  serverlist[servernum].maxusernum=numerictolong(cargv[5]+2,3);
  serverlist[servernum].ts=strtoull(cargv[3], NULL, 10);
  serverlist[servernum].marker=0;
  setflags(&serverlist[servernum].flags,SMODE_ALL,cargv[6],smodeflags,REJECT_NONE);

  if (!strncmp((char *)source,"INIT",4)) {
    /* This is the initial server */
    myhub=servernum;
    serverlist[servernum].parent=numerictolong(mynumeric->content,2);
    triggerhook(HOOK_IRC_SENDBURSTSERVERS,NULL);
    triggerhook(HOOK_IRC_SENDBURSTNICKS,NULL);
    triggerhook(HOOK_IRC_SENDBURSTBURSTS,NULL);
    irc_send("%s EB",mynumeric->content);
    triggerhook(HOOK_IRC_CONNECTED,NULL);
  } else {
    serverlist[servernum].parent=numerictolong(source,2);
  }    

  /* Set up the initial server state -- this MUST be one of the "linking" states */
  if (cargv[4][0]=='J') {
    serverlist[servernum].linkstate=LS_LINKING;
    Error("server",ERR_DEBUG,"Creating server %s in LS_LINKING state.",serverlist[servernum].name->content);
  } else {
    serverlist[servernum].linkstate=LS_PLINKING;
    Error("server",ERR_DEBUG,"Creating server %s in LS_PLINKING state.",serverlist[servernum].name->content);
  }

  triggerhook(HOOK_SERVER_NEWSERVER,(void *)servernum);  
  return CMD_OK;
}

int handleeobmsg(void *source, int cargc, char **argv) {
  long servernum;
  
  servernum=numerictolong(source,2);
  completelink(servernum);
  
  if (servernum==myhub) {
    /* Send EA */
    irc_send("%s EA",mynumeric->content);  
    Error("server",ERR_INFO,"Acknowledging end of burst");
    triggerhook(HOOK_SERVER_END_OF_BURST, NULL);
  }
  
  return CMD_OK;
}

int handlesquitmsg(void *source, int cargc, char **cargv) {
  long servernum=findserver(cargv[0]);
  if (servernum<0) {
    Error("server",ERR_WARNING,"Received SQUIT for unknown server %s\n",cargv[0]);
    return CMD_ERROR;
  }
  if (servernum==myhub) {
    Error("server",ERR_WARNING,"Rejected by our hub: %s",cargv[cargc-1]);
    irc_disconnected(0);
    return CMD_OK;
  }
  deleteserver(servernum);
  
  return CMD_OK;
}

void handledisconnect(int hooknum, void *arg) {
  if (myhub>=0) {
    deleteserver(myhub);
    myhub=-1;
  }
}

void completelink(int servernum) {
  int i;
  
  if (serverlist[servernum].name==NULL) {
    Error("server",ERR_WARNING,"Tried to complete link for server %d which doesn't exist.",servernum);
    return;
  }
  
  /* Complete the link for all children in the PLINKING state. */
  for (i=0;i<MAXSERVERS;i++) {
    if (serverlist[i].parent==servernum && serverlist[i].linkstate==LS_PLINKING) {
      completelink(i);
    }
  }
  
  /* This server is now fully linked. */
  serverlist[servernum].linkstate=LS_LINKED;
  triggerhook(HOOK_SERVER_LINKED, (void *)(long)servernum);
  Error("server",ERR_DEBUG,"Setting link state on %s to LS_LINKED",serverlist[servernum].name->content);
}  

void deleteserver(long servernum) {
  int i;
  
  if (serverlist[servernum].name==NULL) {
    Error("server",ERR_WARNING,"Tried to remove server %ld which doesn't exist.",servernum);
    return;
  }
  
  /* Delete all it's children first */
  for (i=0;i<MAXSERVERS;i++) {
    if (serverlist[i].parent==servernum && serverlist[i].name!=NULL) {
      deleteserver(i);
    }
  }
  
  /* Set state to SQUITting, then trigger hook */
  Error("server",ERR_DEBUG,"Setting link state on %s to LS_SQUIT",serverlist[servernum].name->content);
  serverlist[servernum].linkstate=LS_SQUIT;

  /* Until hooks have priorities we need something like this */
  triggerhook(HOOK_SERVER_PRE_LOSTSERVER,(void *)servernum);
  triggerhook(HOOK_SERVER_LOSTSERVER,(void *)servernum);
  
  /* Now delete the actual server */
  freesstring(serverlist[servernum].name);
  freesstring(serverlist[servernum].description);
  memset(&(serverlist[servernum]),0,sizeof(server)); /* sets state back to LS_INVALID */
}

int findserver(const char *name) {
  int i;
  
  for(i=0;i<MAXSERVERS;i++)
    if (serverlist[i].name!=NULL && !strncmp(serverlist[i].name->content,name,serverlist[i].name->length))
      return i;
      
  return -1;
}

unsigned int nextservermarker(void) {
  int i;
  static unsigned int servermarker=0;

  servermarker++;
  if (!servermarker) {
    /* If we wrapped to zero, zap the marker on all hosts */
    for (i=0;i<MAXSERVERS;i++)
      serverlist[i].marker=0;
    servermarker++;
  }

  return servermarker;
}