New database and column names for Moira2.

[moira.git] / update / update_server.c

/*
 *	$Source$
 *	$Header$
 */
/*  (c) Copyright 1988 by the Massachusetts Institute of Technology. */
/*  For copying and distribution information, please see the file */
/*  <mit-copyright.h>. */

#ifndef lint
static char *rcsid_dispatch_c = "$Header$";
#endif	lint

#include <mit-copyright.h>
#include <stdio.h>
#include <gdb.h>
#include <errno.h>
#include <strings.h>
#include <pwd.h>
#include <moira.h>
#include <sys/file.h>
#include <sys/ioctl.h>
#include "update.h"

extern int auth_001(), inst_001();
extern int xfer_002(), exec_002();

extern int sync_proc(), quit();
extern char *config_lookup();

extern void gdb_debug();
extern int exit(), abort(), errno;
extern STRING instructions;

CONNECTION conn;
int code;
char *whoami;

int have_authorization = 0;
int have_file = 0;
int have_instructions = 0;
int done = 0;
int uid = 0;

#define send_int(n) \
     (_send_int=(n),send_object(conn,(char *)&_send_int,INTEGER_T))
int _send_int;

struct _dt {
     char *str;
     int (*proc)();
} dispatch_table[] = {
     { "INST_001", inst_001 },
     { "AUTH_001", auth_001 },
     { "XFER_002", xfer_002 },
     { "EXEC_002", exec_002 },
     { "quit", quit },
     { (char *)NULL, abort }
};

/* general scratch space -- useful for building error messages et al... */
char buf[BUFSIZ];


main(argc, argv)
     int argc;
     char **argv;
{
     STRING str;
     struct _dt *d;
     char *p;
     int n;

#ifdef DEBUG
     gdb_debug(GDB_NOFORK);
#endif /* DEBUG */

     whoami = rindex(argv[0], '/');
     if (whoami)
	 whoami++;
     else
	 whoami = argv[0];

     /* interpret arguments here */
     if (argc != 1) {
	  fprintf(stderr, "Usage:  %s\n", whoami);
	  exit(1);
     }

#ifndef DEBUG
     if (!config_lookup("nofork")) {
	 if (fork())
	   exit(0);
	 n = open("/dev/tty", O_RDWR|FNDELAY);
	 if (n > 0) {
	     (void) ioctl(n, TIOCNOTTY, (char *)NULL);
	     (void) close(n);
	 }
     } else
       gdb_debug(GDB_NOFORK);
#endif

     umask(0022);
     initialize_sms_error_table();
     initialize_krb_error_table();
     mr_update_initialize();

     /* wait for connection */
     gdb_init();
     /* If the config file contains a line "port portname", the daemon
      * will listen on the named port rather than SERVICE_NAME "sms_update"
      */
     if ((p = config_lookup("port")) == NULL)
       p = SERVICE_NAME;
     conn = create_forking_server(p, 0);

     /* If the config file contains a line "user username", the
      * daemon will run with that user's UID.
      */
     if (p = config_lookup("user")) {
	 struct passwd *pw;
	 pw = getpwnam(p);
	 if (pw == 0) {
	     com_err(whoami, errno, "Unable to find user %s\n", p);
	     exit(1);
	 }
	 uid = pw->pw_uid;
     }

     /* If the config file contains a line "chroot /dir/name", the
      * daemon will run chrooted to that directory.
      */
     if (p = config_lookup("chroot")) {
	 if (chroot(p) < 0) {
	     com_err(whoami, errno, "unable to chroot to %s", p);
	     exit(1);
	 }
     }

     if (!conn) {
	 com_err(whoami, errno, "can't get connection");
	 exit(1);
     }
     if (connection_status(conn) == CON_STOPPED) {
	 com_err(whoami, connection_errno(conn), ": can't get connection");
	 exit(1);
     }

     mr_log_info("got connection");
     /* got a connection; loop forever */
     while (1) {
	  register char *cp;
	  code = receive_object(conn, (char *)&str, STRING_T);
	  if (code) {
	      com_err(whoami, connection_errno(conn), "receiving command");
	      sever_connection(conn);
	      exit(1);
	  }
	  cp = index(STRING_DATA(str), ' ');
	  if (cp)
	       *cp = '\0';
	  for (d = dispatch_table; d->str; d++) {
	      if (!strcmp(d->str, STRING_DATA(str))) {
		  if (cp)
		      *cp = ' ';
#ifdef	DEBUG
		  printf("got request: %s\n", STRING_DATA(str));
#endif	/* DEBUG */
		  (void)(d->proc)(STRING_DATA(str));
		  goto ok;
	      }
	  }
	  sprintf(buf, "unknown request received: %s\n", STRING_DATA(str));
	  mr_log_error(buf);
	  code = send_int(MR_UNKNOWN_PROC);
	  if (code) {
	      com_err(whoami, connection_errno(conn), "sending UNKNOWN_PROC");
	  }
     ok:
	  string_free(&str);
     }
}

int
send_ok()
{
     static int zero = 0;
     return((code = send_object(conn, (char *)&zero, INTEGER_T)));
}


initialize()
{
     /* keep have_authorization around */
     have_file = 0;
     have_instructions = 0;
     done = 0;
     if (STRING_DATA(instructions) != (char *)NULL)
	  string_free(&instructions);
}


/*
 * quit request:
 *
 * syntax:
 * >>> quit
 * <<< (int)0
 * any arguments are ignored
 *
 * function:
 *	closes connection from MR
 */
int
quit(str)
     char *str;
{
#ifdef lint
     str = (char *)NULL;
#endif /* lint */
     (void) send_ok();
     sever_connection(conn);
     mr_log_info("Closing connection.");
     exit(0);
}


/*
 * lose(msg)
 *
 * put <msg> to log as error, break connection, and exit
 */

lose(msg)
    char *msg;
{
    com_err(whoami, code, msg);
    if (conn)
	sever_connection(conn);
    exit(1);
}

/*
 * report_error(msg)
 *
 * send back (external) <code>; if error, punt big with <lose(msg)>
 */

report_error(msg)
    char *msg;
{
    code = send_object(conn, (char *)&code, INTEGER_T);
    if (code) {
	code = connection_errno(conn);
	lose(msg);
    }
}

/*
 * reject_call(c)
 *
 * set (external) <code> to <c> and call <report_error>
 */

reject_call(c)
    int c;
{
    code = c;
    report_error("call rejected");
}