[moira.git] / clients / stella / stella.c

/*
 * Command line oriented Moira host tool.
 *
 * kolya@MIT.EDU, January 2000
 *
 * Somewhat based on blanche
 *
 * Copyright (C) 2000 by the Massachusetts Institute of Technology.
 * For copying and distribution information, please see the file
 * <mit-copyright.h>.
 */

#include <mit-copyright.h>
#include <moira.h>
#include <moira_site.h>
#include <mrclient.h>

#include <ctype.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

RCSID("$Header$");

struct owner_type {
  int type;
  char *name;
};

struct mqelem {
  struct mqelem *q_forw;
  struct mqelem *q_back;
  void *q_data;
};

struct string_list {
  char *string;
  struct string_list *next;
};

/* It is important to membercmp that M_USER < M_LIST < M_STRING */
#define M_ANY		0
#define M_USER		1
#define M_LIST		2
#define M_STRING	3
#define M_KERBEROS	4
#define	M_NONE		5

/* argument parsing macro */
#define argis(a, b) (!strcmp(*arg + 1, a) || !strcmp(*arg + 1, b))

/* flags from command line */
int info_flag, update_flag, create_flag, delete_flag, list_map_flag;
int update_map_flag, verbose, noauth;

struct string_list *alias_add_queue, *alias_remove_queue;
struct string_list *map_add_queue, *map_remove_queue;

char *hostname, *whoami;

char *newname, *address, *network, *h_status, *vendor, *model;
char *os, *location, *contact, *adm_cmt, *op_cmt;

struct owner_type *owner;

void usage(char **argv);
int store_host_info(int argc, char **argv, void *hint);
void show_host_info(char **argv);
int show_machine_in_cluster(int argc, char **argv, void *hint);
struct owner_type *parse_member(char *s);
struct string_list *add_to_string_list(struct string_list *old_list, char *s);
int wrap_mr_query(char *handle, int argc, char **argv,
		  int (*callback)(int, char **, void *), void *callarg);
void print_query(char *query_name, int argc, char **argv);

int main(int argc, char **argv)
{
  int status, success;
  char **arg = argv;
  char *server = NULL, *p;

  /* clear all flags & lists */
  info_flag = update_flag = create_flag = list_map_flag = update_map_flag = 0;
  verbose = noauth = 0;
  newname = address = network = h_status = vendor = model = NULL;
  os = location = contact = adm_cmt = op_cmt = NULL;
  owner = NULL;
  alias_add_queue = alias_remove_queue = NULL;
  map_add_queue = map_remove_queue = NULL;
  whoami = argv[0];

  success = 1;

  /* parse args, building addlist, dellist, & synclist */
  while (++arg - argv < argc)
    {
      if (**arg == '-')
	{
	  if (argis("i", "info"))
	    info_flag++;
	  else if (argis("C", "create"))
	    create_flag++;
	  else if (argis("D", "delete"))
	    delete_flag++;
	  else if (argis("R", "rename")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      newname = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("A", "address")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      address = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("O", "owner")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      owner = parse_member(*arg);
	    } else
	      usage(argv);
	  }
	  else if (argis("N", "network")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      network = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("S", "status")) {
	    if (arg - argv < argc - 1) {
	      int i;

	      arg++;
	      update_flag++;
	      h_status = *arg;

	      for(i=0; i<strlen(h_status); i++) {
		if(!isdigit(h_status[i])) {
		  printf("Error: status code %s is not numeric.\n", h_status);
		  exit(1);
		}
	      }
	    } else
	      usage(argv);
	  }
	  else if (argis("V", "vendor")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      vendor = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("M", "model")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      model = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("o", "os")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      os = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("L", "location")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      location = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("c", "contact")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      contact = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("ac", "admcmt")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      adm_cmt = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("oc", "opcmt")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      update_flag++;
	      op_cmt = *arg;
	    } else
	      usage(argv);
	  }
	  else if (argis("a", "aliasadd")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      alias_add_queue=add_to_string_list(alias_add_queue, *arg);
	    } else
	      usage(argv);
	  }
	  else if (argis("d", "aliasdelete")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      alias_remove_queue=add_to_string_list(alias_remove_queue, *arg);
	    } else
	      usage(argv);
	  }
	  else if (argis("am", "addmap")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      map_add_queue=add_to_string_list(map_add_queue, *arg);
	    } else
	      usage(argv);
	    update_map_flag++;
	  }
	  else if (argis("dm", "deletemap")) {
	    if (arg - argv < argc - 1) {
	      arg++;
	      map_remove_queue=add_to_string_list(map_remove_queue, *arg);
	    } else
	      usage(argv);
	    update_map_flag++;
	  }
	  else if (argis("lm", "listmap"))
	    list_map_flag++;
	  else if (argis("n", "noauth"))
	    noauth++;
	  else if (argis("v", "verbose"))
	    verbose++;
	  else if (argis("db", "database"))
	    {
	      if (arg - argv < argc - 1)
		{
		  ++arg;
		  server = *arg;
		}
	      else
		usage(argv);
	    }
	  else
	    usage(argv);
	}
      else if (hostname == NULL)
	hostname = *arg;
      else
	usage(argv);
    }
  if (hostname == NULL)
    usage(argv);

  /* default to info_flag if nothing else was specified */
  if(!(info_flag   || update_flag   || create_flag     || \
       delete_flag || list_map_flag || update_map_flag )) {
    info_flag++;
  }

  /* fire up Moira */
  status = mrcl_connect(server, "stella", 2, !noauth);
  if (status == MRCL_AUTH_ERROR)
    {
      com_err(whoami, 0, "Try the -noauth flag if you don't "
	      "need authentication.");
    }
  if (status)
    exit(2);

  /* create if needed */
  if (create_flag)
    {
      char *argv[30];
      int cnt;

      for (cnt = 0; cnt < 15; cnt++) {
	argv[cnt] = "";
      }

      argv[0] = canonicalize_hostname(strdup(hostname));

      if (vendor)
	argv[1] = vendor;
      if (model)
	argv[2] = model;
      if (os)
	argv[3] = os;
      if (location)
	argv[4] = location;
      if (contact)
	argv[5] = contact;
      /* The use field always gets set to "0" */
      argv[6] = "0";
      if (h_status)
	argv[7] = h_status;
      else
	argv[7] = "1";
      if (network)
	argv[8] = network;
      if (address)
	argv[9] = address;
      if (adm_cmt)
	argv[12] = adm_cmt;
      if (op_cmt)
	argv[13] = op_cmt;

      if (owner)
	{
	  argv[11] = owner->name;
	  switch (owner->type)
	    {
	    case M_ANY:
	    case M_USER:
	      argv[10] = "USER";
	      status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
	      if (owner->type != M_ANY || status != MR_USER)
		break;

	    case M_LIST:
	      argv[10] = "LIST";
	      status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
	      break;

	    case M_KERBEROS:
	      argv[10] = "KERBEROS";
	      status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
	      break;

	    case M_NONE:
	      argv[10] = "NONE";
	      status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
	      break;
	    }
	}
      else
	{
	  argv[10] = "NONE";
	  argv[11] = "NONE";

	  status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
	}

      if (status)
	{
	  com_err(whoami, status, "while creating host.");
	  exit(1);
	}

    }
  else if (update_flag)
    {
      char *old_argv[30];
      char *argv[16];
      char *args[5];
      int cnt;

      args[0] = canonicalize_hostname(strdup(hostname));
      args[1] = args[2] = args[3] = "*";

      status = wrap_mr_query("get_host", 4, args, store_host_info, old_argv);
      if (status)
	{
	  com_err(whoami, status, "while getting list information");
	  exit(1);
	}

      argv[1] = old_argv[0];
      argv[2] = old_argv[1];
      argv[3] = old_argv[2];
      argv[4] = old_argv[3];
      argv[5] = old_argv[4];
      argv[6] = old_argv[5];
      argv[7] = old_argv[6];
      argv[8] = old_argv[7];
      argv[9] = old_argv[9];
      argv[10] = old_argv[10];
      argv[11] = old_argv[11];
      argv[12] = old_argv[12];
      argv[13] = old_argv[13];
      argv[14] = old_argv[14];

      argv[0] = canonicalize_hostname(strdup(hostname));
      if (newname)
	argv[1] = newname;
      if (vendor)
	argv[2] = vendor;
      if (model)
	argv[3] = model;
      if (os)
	argv[4] = os;
      if (location)
	argv[5] = location;
      if (contact)
	argv[6] = contact;
      if (h_status)
	argv[8] = h_status;
      if (network)
	argv[9] = network;
      if (address)
	argv[10] = address;
      if (adm_cmt)
	argv[13] = adm_cmt;
      if (op_cmt)
	argv[14] = op_cmt;

      if (owner)
	{
	  argv[12] = owner->name;
	  switch (owner->type)
	    {
	    case M_ANY:
	    case M_USER:
	      argv[11] = "USER";
	      status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
	      if (owner->type != M_ANY || status != MR_USER)
		break;

	    case M_LIST:
	      argv[11] = "LIST";
	      status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
	      break;

	    case M_KERBEROS:
	      argv[11] = "KERBEROS";
	      status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
	      break;

	    case M_NONE:
	      argv[11] = "NONE";
	      status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
	      break;
	    }
	}
      else
	status = wrap_mr_query("update_host", 15, argv, NULL, NULL);

      if (status)
	com_err(whoami, status, "while updating host.");
      else if (newname)
	hostname = newname;
    }

  /* create aliases if necessary */
  if (alias_add_queue) {
    struct string_list *q = alias_add_queue;

    while(q) {
      char *alias = q->string;
      char *args[2];

      args[0] = canonicalize_hostname(strdup(alias));
      args[1] = canonicalize_hostname(strdup(hostname));
      status = wrap_mr_query("add_hostalias", 2, args, NULL, NULL);
      if (status) {
	com_err(whoami, status, "while adding host alias");
	exit(1);
      }

      q = q->next;
    }
  }

  /* delete aliases if necessary */
  if (alias_remove_queue) {
    struct string_list *q = alias_remove_queue;

    while(q) {
      char *alias = q->string;
      char *args[2];

      args[0] = canonicalize_hostname(strdup(alias));
      args[1] = canonicalize_hostname(strdup(hostname));
      status = wrap_mr_query("delete_hostalias", 2, args, NULL, NULL);
      if (status) {
	com_err(whoami, status, "while deleting host alias");
	exit(1);
      }

      q = q->next;
    }
  }

  /* create cluster mappings */
  if (map_add_queue) {
    struct string_list *q = map_add_queue;

    while(q) {
      char *clustername = q->string;
      char *args[2];

      args[0] = canonicalize_hostname(strdup(hostname));
      args[1] = clustername;
      status = wrap_mr_query("add_machine_to_cluster", 2, args, NULL, NULL);
      if (status) {
	com_err(whoami, status, "while adding cluster mapping");
	exit(1);
      }

      q = q->next;
    }
  }

  /* delete cluster mappings */
  if (map_remove_queue) {
    struct string_list *q = map_remove_queue;

    while(q) {
      char *clustername = q->string;
      char *args[2];

      args[0] = canonicalize_hostname(strdup(hostname));
      args[1] = clustername;
      status = wrap_mr_query("delete_machine_from_cluster", 2, args,
			     NULL, NULL);
      if (status) {
	com_err(whoami, status, "while deleting cluster mapping");
	exit(1);
      }

      q = q->next;
    }
  }

  /* display list info if requested to */
  if (info_flag) {
    struct mqelem *elem = NULL;
    char *args[5];
    char *argv[30];

    args[0] = canonicalize_hostname(strdup(hostname));
    args[1] = args[2] = args[3] = "*";
    status = wrap_mr_query("get_host", 4, args, store_host_info, argv);
    if (status) {
      com_err(whoami, status, "while getting host information");
      exit(1);
    }
    show_host_info(argv);
  }

  /* list cluster mappings if needed */
  if (list_map_flag) {
    char *args[3];

    args[0] = canonicalize_hostname(strdup(hostname));
    args[1] = "*";
    status = wrap_mr_query("get_machine_to_cluster_map", 2, args,
		      show_machine_in_cluster, NULL);
    if (status)
      if (status != MR_NO_MATCH) {
        com_err(whoami, status, "while getting cluster mappings");
        exit(1);
      }
  }

  if (delete_flag) {
    char *argv[1];

    argv[0] = canonicalize_hostname(strdup(hostname));
    status = wrap_mr_query("delete_host", 1, argv, NULL, NULL);
    if (status) {
      com_err(whoami, status, "while deleting host");
      exit(1);
    }
  }

  /* We're done! */
  mr_disconnect();
  exit(success ? 0 : 1);
}

void usage(char **argv)
{
  fprintf(stderr, "Usage: %s hostname [options]\n", argv[0]);
  fprintf(stderr, "Options are\n");
  fprintf(stderr, "  %-39s%-39s\n", "-C   | -create",
	  "-O   | -owner owner");
  fprintf(stderr, "  %-39s%-39s\n", "-D   | -delete",
	  "-S   | -status status");
  fprintf(stderr, "  %-39s%-39s\n", "-R   | -rename newname",
	  "-V   | -vendor vendor");
  fprintf(stderr, "  %-39s%-39s\n", "-a   | -addalias alias",
	  "-M   | -model model");
  fprintf(stderr, "  %-39s%-39s\n", "-d   | -deletealias alias",
	  "-L   | -location location");
  fprintf(stderr, "  %-39s%-39s\n", "-i   | -info",
	  "-o   | -os os");
  fprintf(stderr, "  %-39s%-39s\n", "-oc  | -opcmt op_cmt",
	  "-c   | -contact contact");
  fprintf(stderr, "  %-39s%-39s\n", "-ac  | -admcmt adm_cmt",
	  "-A   | -address address");
  fprintf(stderr, "  %-39s%-39s\n", "-am  | -addmap cluster",
	  "-N   | -network network");
  fprintf(stderr, "  %-39s%-39s\n", "-dm  | -deletemap cluster",
	  "-lm  | -listmap");
  fprintf(stderr, "  %-39s%-39s\n", "-db  | -database host[:port]",
	  "-n   | -noauth");
  fprintf(stderr, "  %-39s%-39s\n", "-v   | -verbose",
	  "");
  exit(1);
}

/* Show alias information */

static int show_has_aliases;

int show_alias_info(int argc, char **argv, void *hint)
{
  if(!show_has_aliases++)
    printf("Aliases:  %s", argv[0]);
  else
    printf(", %s", argv[0]);

  return MR_CONT;
}

static char *states[] = {
  "Reserved (0)",
  "Active (1)",
  "None (2)",
  "Deleted (3)"
};

static char *MacState(int state)
{
  static char buf[BUFSIZ];

  if (state < 0 || state > 3)
    {
      sprintf(buf, "Unknown (%d)", state);
      return buf;
    }
  return states[state];
}

/* Retrieve information about a host */

int store_host_info(int argc, char **argv, void *hint)
{
  int i;
  char **nargv = hint;

  for(i=0; i<argc; i++)
    nargv[i] = strdup(argv[i]);

  return MR_CONT;
}

void show_host_info(char **argv)
{
  char tbuf[256];
  char *args[3];
  struct mqelem *elem = NULL;
  int stat;

  printf("Machine:  %s\n", argv[M_NAME]);
  args[0] = "*";
  args[1] = argv[M_NAME];
  show_has_aliases = 0;
  stat = wrap_mr_query("get_hostalias", 2, args, show_alias_info, &elem);
  printf("\n");
  if (stat) {
    if (stat != MR_NO_MATCH)
      com_err(whoami, stat, "while getting aliases");
  } else {
    printf("\n");
  }
  sprintf(tbuf, "%s %s", argv[M_OWNER_TYPE],
          strcmp(argv[M_OWNER_TYPE], "NONE") ? argv[M_OWNER_NAME] : "");
  printf("Address:  %-16s    Network:    %-16s\n",
          argv[M_ADDR], argv[M_SUBNET]);
  printf("Owner:    %-16s    Use data:   %s\n", tbuf, argv[M_INUSE]);
  printf("Status:   %-16s    Changed:    %s\n",
          MacState(atoi(argv[M_STAT])), argv[M_STAT_CHNG]);
  printf("\n");

  printf("Vendor:   %-16s    Model:      %-20s  OS:  %s\n",
          argv[M_VENDOR], argv[M_MODEL], argv[M_OS]);
  printf("Location: %-16s    Contact:    %-20s  Opt: %s\n",
          argv[M_LOC], argv[M_CONTACT], argv[M_USE]);
  printf("\nAdm cmt: %s\n", argv[M_ACOMMENT]);
  printf("Op cmt:  %s\n", argv[M_OCOMMENT]);
  printf("\n");
  printf("Created  by %s on %s\n", argv[M_CREATOR], argv[M_CREATED]);
  printf("Last mod by %s at %s with %s.\n", argv[M_MODBY], argv[M_MODTIME], argv[M_MODWITH]);
}

int show_machine_in_cluster(int argc, char **argv, void *hint)
{
  printf("Machine: %-30s Cluster: %-30s\n", argv[0], argv[1]);

  return MR_CONT;
}

/* Parse a line of input, fetching a member.  NULL is returned if a member
 * is not found.  ';' is a comment character.
 */

struct owner_type *parse_member(char *s)
{
  struct owner_type *m;
  char *p, *lastchar;

  while (*s && isspace(*s))
    s++;
  lastchar = p = s;
  while (*p && *p != '\n' && *p != ';')
    {
      if (isprint(*p) && !isspace(*p))
	lastchar = p++;
      else
	p++;
    }
  lastchar++;
  *lastchar = '\0';
  if (p == s || strlen(s) == 0)
    return NULL;

  if (!(m = malloc(sizeof(struct owner_type))))
    return NULL;

  if ((p = strchr(s, ':')))
    {
      *p = '\0';
      m->name = ++p;
      if (!strcasecmp("user", s))
	m->type = M_USER;
      else if (!strcasecmp("list", s))
	m->type = M_LIST;
      else if (!strcasecmp("string", s))
	m->type = M_STRING;
      else if (!strcasecmp("kerberos", s))
	m->type = M_KERBEROS;
      else if (!strcasecmp("none", s))
	m->type = M_NONE;
      else
	{
	  m->type = M_ANY;
	  *(--p) = ':';
	  m->name = s;
	}
      m->name = strdup(m->name);
    }
  else
    {
      m->name = strdup(s);
      m->type = strcasecmp(s, "none") ? M_ANY : M_NONE;
    }
  return m;
}

struct string_list *add_to_string_list(struct string_list *old_list, char *s) {
  struct string_list *new_list;

  new_list = (struct string_list *)malloc(sizeof(struct string_list *));
  new_list->next = old_list;
  new_list->string = s;

  return new_list;
}

int wrap_mr_query(char *handle, int argc, char **argv,
                  int (*callback)(int, char **, void *), void *callarg) {
  if (verbose)
    print_query(handle, argc, argv);

  return mr_query(handle, argc, argv, callback, callarg);
}

void print_query(char *query_name, int argc, char **argv) {
  int cnt;

  printf("qy %s", query_name);
  for(cnt=0; cnt<argc; cnt++)
    printf(" <%s>", argv[cnt]);
  printf("\n");
}
Commit	Line	Data
80e8aa14	1	/*
	2	* Command line oriented Moira host tool.
	3	*
	4	* kolya@MIT.EDU, January 2000
	5	*
	6	* Somewhat based on blanche
	7	*
	8	* Copyright (C) 2000 by the Massachusetts Institute of Technology.
	9	* For copying and distribution information, please see the file
	10	* <mit-copyright.h>.
	11	*/
	12
	13	#include <mit-copyright.h>
	14	#include <moira.h>
	15	#include <moira_site.h>
	16	#include <mrclient.h>
	17
	18	#include <ctype.h>
	19	#include <errno.h>
	20	#include <stdio.h>
	21	#include <stdlib.h>
	22	#include <string.h>
	23
	24	RCSID("$Header$");
	25
	26	struct owner_type {
	27	int type;
	28	char *name;
	29	};
	30
	31	struct mqelem {
	32	struct mqelem *q_forw;
	33	struct mqelem *q_back;
	34	void *q_data;
	35	};
	36
	37	struct string_list {
	38	char *string;
	39	struct string_list *next;
	40	};
	41
	42	/* It is important to membercmp that M_USER < M_LIST < M_STRING */
	43	#define M_ANY 0
	44	#define M_USER 1
	45	#define M_LIST 2
	46	#define M_STRING 3
	47	#define M_KERBEROS 4
	48	#define M_NONE 5
	49
	50	/* argument parsing macro */
	51	#define argis(a, b) (!strcmp(arg + 1, a) \|\| !strcmp(arg + 1, b))
	52
	53	/* flags from command line */
	54	int info_flag, update_flag, create_flag, delete_flag, list_map_flag;
	55	int update_map_flag, verbose, noauth;
	56
	57	struct string_list alias_add_queue, alias_remove_queue;
	58	struct string_list map_add_queue, map_remove_queue;
	59
	60	char hostname, whoami;
	61
	62	char newname, address, network, h_status, vendor, model;
	63	char os, location, contact, adm_cmt, *op_cmt;
	64
65	struct owner_type *owner;
66
67	void usage(char **argv);
68	int store_host_info(int argc, char *argv, void hint);
69	void show_host_info(char **argv);
70	int show_machine_in_cluster(int argc, char *argv, void hint);
71	struct owner_type parse_member(char s);
72	struct string_list add_to_string_list(struct string_list old_list, char *s);
73	int wrap_mr_query(char handle, int argc, char *argv,
74	int (callback)(int, char , void ), void *callarg);
75	void print_query(char query_name, int argc, char *argv);
76
77	int main(int argc, char **argv)
78	{
79	int status, success;
80	char **arg = argv;
81	char server = NULL, p;
82
83	/* clear all flags & lists */
84	info_flag = update_flag = create_flag = list_map_flag = update_map_flag = 0;
85	verbose = noauth = 0;
86	newname = address = network = h_status = vendor = model = NULL;
87	os = location = contact = adm_cmt = op_cmt = NULL;
88	owner = NULL;
89	alias_add_queue = alias_remove_queue = NULL;
90	map_add_queue = map_remove_queue = NULL;
91	whoami = argv[0];
92
93	success = 1;
94
95	/* parse args, building addlist, dellist, & synclist */
96	while (++arg - argv < argc)
97	{
98	if (**arg == '-')
99	{
100	if (argis("i", "info"))
101	info_flag++;
102	else if (argis("C", "create"))
103	create_flag++;
104	else if (argis("D", "delete"))
105	delete_flag++;
106	else if (argis("R", "rename")) {
107	if (arg - argv < argc - 1) {
108	arg++;
109	update_flag++;
110	newname = *arg;
111	} else
112	usage(argv);
113	}
114	else if (argis("A", "address")) {
115	if (arg - argv < argc - 1) {
116	arg++;
117	update_flag++;
118	address = *arg;
119	} else
120	usage(argv);
121	}
122	else if (argis("O", "owner")) {
123	if (arg - argv < argc - 1) {
124	arg++;
125	update_flag++;
126	owner = parse_member(*arg);
127	} else
128	usage(argv);
129	}
130	else if (argis("N", "network")) {
131	if (arg - argv < argc - 1) {
132	arg++;
133	update_flag++;
134	network = *arg;
135	} else
136	usage(argv);
137	}
138	else if (argis("S", "status")) {
139	if (arg - argv < argc - 1) {
140	int i;
141
142	arg++;
143	update_flag++;
144	h_status = *arg;
145
146	for(i=0; i<strlen(h_status); i++) {
147	if(!isdigit(h_status[i])) {
148	printf("Error: status code %s is not numeric.\n", h_status);
149	exit(1);
150	}
151	}
152	} else
153	usage(argv);
154	}
155	else if (argis("V", "vendor")) {
156	if (arg - argv < argc - 1) {
157	arg++;
158	update_flag++;
159	vendor = *arg;
160	} else
161	usage(argv);
162	}
163	else if (argis("M", "model")) {
164	if (arg - argv < argc - 1) {
165	arg++;
166	update_flag++;
167	model = *arg;
168	} else
169	usage(argv);
170	}
171	else if (argis("o", "os")) {
172	if (arg - argv < argc - 1) {
173	arg++;
174	update_flag++;
175	os = *arg;
176	} else
177	usage(argv);
178	}
179	else if (argis("L", "location")) {
180	if (arg - argv < argc - 1) {
181	arg++;
182	update_flag++;
183	location = *arg;
184	} else
185	usage(argv);
186	}
187	else if (argis("c", "contact")) {
188	if (arg - argv < argc - 1) {
189	arg++;
190	update_flag++;
191	contact = *arg;
192	} else
193	usage(argv);
194	}
195	else if (argis("ac", "admcmt")) {
196	if (arg - argv < argc - 1) {
197	arg++;
198	update_flag++;
199	adm_cmt = *arg;
200	} else
201	usage(argv);
202	}
203	else if (argis("oc", "opcmt")) {
204	if (arg - argv < argc - 1) {
205	arg++;
206	update_flag++;
207	op_cmt = *arg;
208	} else
209	usage(argv);
210	}
211	else if (argis("a", "aliasadd")) {
212	if (arg - argv < argc - 1) {
213	arg++;
214	alias_add_queue=add_to_string_list(alias_add_queue, *arg);
215	} else
216	usage(argv);
217	}
218	else if (argis("d", "aliasdelete")) {
219	if (arg - argv < argc - 1) {
220	arg++;
221	alias_remove_queue=add_to_string_list(alias_remove_queue, *arg);
222	} else
223	usage(argv);
224	}
225	else if (argis("am", "addmap")) {
226	if (arg - argv < argc - 1) {
227	arg++;
228	map_add_queue=add_to_string_list(map_add_queue, *arg);
229	} else
230	usage(argv);
231	update_map_flag++;
232	}
233	else if (argis("dm", "deletemap")) {
234	if (arg - argv < argc - 1) {
235	arg++;
236	map_remove_queue=add_to_string_list(map_remove_queue, *arg);
237	} else
238	usage(argv);
239	update_map_flag++;
240	}
241	else if (argis("lm", "listmap"))
242	list_map_flag++;
243	else if (argis("n", "noauth"))
244	noauth++;
245	else if (argis("v", "verbose"))
246	verbose++;
247	else if (argis("db", "database"))
248	{
249	if (arg - argv < argc - 1)
250	{
251	++arg;
252	server = *arg;
253	}
254	else
255	usage(argv);
256	}
257	else
258	usage(argv);
259	}
260	else if (hostname == NULL)
261	hostname = *arg;
262	else
263	usage(argv);
264	}
265	if (hostname == NULL)
266	usage(argv);
267
268	/* default to info_flag if nothing else was specified */
269	if(!(info_flag \|\| update_flag \|\| create_flag \|\| \
270	delete_flag \|\| list_map_flag \|\| update_map_flag )) {
271	info_flag++;
272	}
273
274	/* fire up Moira */
275	status = mrcl_connect(server, "stella", 2, !noauth);
276	if (status == MRCL_AUTH_ERROR)
277	{
278	com_err(whoami, 0, "Try the -noauth flag if you don't "
279	"need authentication.");
280	}
281	if (status)
282	exit(2);
283
284	/* create if needed */
285	if (create_flag)
286	{
287	char *argv[30];
288	int cnt;
289
290	for (cnt = 0; cnt < 15; cnt++) {
291	argv[cnt] = "";
292	}
293
294	argv[0] = canonicalize_hostname(strdup(hostname));
295
296	if (vendor)
297	argv[1] = vendor;
298	if (model)
299	argv[2] = model;
300	if (os)
301	argv[3] = os;
302	if (location)
303	argv[4] = location;
304	if (contact)
305	argv[5] = contact;
306	/* The use field always gets set to "0" */
307	argv[6] = "0";
308	if (h_status)
309	argv[7] = h_status;
310	else
311	argv[7] = "1";
312	if (network)
313	argv[8] = network;
314	if (address)
315	argv[9] = address;
316	if (adm_cmt)
317	argv[12] = adm_cmt;
318	if (op_cmt)
319	argv[13] = op_cmt;
320
321	if (owner)
322	{
323	argv[11] = owner->name;
324	switch (owner->type)
325	{
326	case M_ANY:
327	case M_USER:
328	argv[10] = "USER";
329	status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
330	if (owner->type != M_ANY \|\| status != MR_USER)
331	break;
332
333	case M_LIST:
334	argv[10] = "LIST";
335	status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
336	break;
337
338	case M_KERBEROS:
339	argv[10] = "KERBEROS";
340	status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
341	break;
342
343	case M_NONE:
344	argv[10] = "NONE";
345	status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
346	break;
347	}
348	}
349	else
350	{
351	argv[10] = "NONE";
352	argv[11] = "NONE";
353
354	status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
355	}
356
357	if (status)
358	{
359	com_err(whoami, status, "while creating host.");
360	exit(1);
361	}
362
363	}
364	else if (update_flag)
365	{
366	char *old_argv[30];
367	char *argv[16];
368	char *args[5];
369	int cnt;
370
371	args[0] = canonicalize_hostname(strdup(hostname));
372	args[1] = args[2] = args[3] = "*";
373
374	status = wrap_mr_query("get_host", 4, args, store_host_info, old_argv);
375	if (status)
376	{
377	com_err(whoami, status, "while getting list information");
378	exit(1);
379	}
380
381	argv[1] = old_argv[0];
382	argv[2] = old_argv[1];
383	argv[3] = old_argv[2];
384	argv[4] = old_argv[3];
385	argv[5] = old_argv[4];
386	argv[6] = old_argv[5];
387	argv[7] = old_argv[6];
388	argv[8] = old_argv[7];
389	argv[9] = old_argv[9];
390	argv[10] = old_argv[10];
391	argv[11] = old_argv[11];
392	argv[12] = old_argv[12];
393	argv[13] = old_argv[13];
394	argv[14] = old_argv[14];
395
396	argv[0] = canonicalize_hostname(strdup(hostname));
397	if (newname)
398	argv[1] = newname;
399	if (vendor)
400	argv[2] = vendor;
401	if (model)
402	argv[3] = model;
403	if (os)
404	argv[4] = os;
405	if (location)
406	argv[5] = location;
407	if (contact)
408	argv[6] = contact;
409	if (h_status)
410	argv[8] = h_status;
411	if (network)
412	argv[9] = network;
413	if (address)
414	argv[10] = address;
415	if (adm_cmt)
416	argv[13] = adm_cmt;
417	if (op_cmt)
418	argv[14] = op_cmt;
419
420	if (owner)
421	{
422	argv[12] = owner->name;
423	switch (owner->type)
424	{
425	case M_ANY:
426	case M_USER:
427	argv[11] = "USER";
428	status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
429	if (owner->type != M_ANY \|\| status != MR_USER)
430	break;
431
432	case M_LIST:
433	argv[11] = "LIST";
434	status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
435	break;
436
437	case M_KERBEROS:
438	argv[11] = "KERBEROS";
439	status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
440	break;
441
442	case M_NONE:
443	argv[11] = "NONE";
444	status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
445	break;
446	}
447	}
448	else
449	status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
450
451	if (status)
452	com_err(whoami, status, "while updating host.");
453	else if (newname)
454	hostname = newname;
455	}
456
457	/* create aliases if necessary */
458	if (alias_add_queue) {
459	struct string_list *q = alias_add_queue;
460
461	while(q) {
462	char *alias = q->string;
463	char *args[2];
464
465	args[0] = canonicalize_hostname(strdup(alias));
466	args[1] = canonicalize_hostname(strdup(hostname));
467	status = wrap_mr_query("add_hostalias", 2, args, NULL, NULL);
468	if (status) {
469	com_err(whoami, status, "while adding host alias");
470	exit(1);
471	}
472
473	q = q->next;
474	}
475	}
476
477	/* delete aliases if necessary */
478	if (alias_remove_queue) {
479	struct string_list *q = alias_remove_queue;
480
481	while(q) {
482	char *alias = q->string;
483	char *args[2];
484
485	args[0] = canonicalize_hostname(strdup(alias));
486	args[1] = canonicalize_hostname(strdup(hostname));
487	status = wrap_mr_query("delete_hostalias", 2, args, NULL, NULL);
488	if (status) {
489	com_err(whoami, status, "while deleting host alias");
490	exit(1);
491	}
492
493	q = q->next;
494	}
495	}
496
497	/* create cluster mappings */
498	if (map_add_queue) {
499	struct string_list *q = map_add_queue;
500
501	while(q) {
502	char *clustername = q->string;
503	char *args[2];
504
505	args[0] = canonicalize_hostname(strdup(hostname));
506	args[1] = clustername;
507	status = wrap_mr_query("add_machine_to_cluster", 2, args, NULL, NULL);
508	if (status) {
509	com_err(whoami, status, "while adding cluster mapping");
510	exit(1);
511	}
512
513	q = q->next;
514	}
515	}
516
517	/* delete cluster mappings */
518	if (map_remove_queue) {
519	struct string_list *q = map_remove_queue;
520
521	while(q) {
522	char *clustername = q->string;
523	char *args[2];
524
525	args[0] = canonicalize_hostname(strdup(hostname));
526	args[1] = clustername;
527	status = wrap_mr_query("delete_machine_from_cluster", 2, args,
528	NULL, NULL);
529	if (status) {
530	com_err(whoami, status, "while deleting cluster mapping");
531	exit(1);
532	}
533
534	q = q->next;
535	}
536	}
537
538	/* display list info if requested to */
539	if (info_flag) {
540	struct mqelem *elem = NULL;
541	char *args[5];
542	char *argv[30];
543
544	args[0] = canonicalize_hostname(strdup(hostname));
545	args[1] = args[2] = args[3] = "*";
546	status = wrap_mr_query("get_host", 4, args, store_host_info, argv);
547	if (status) {
548	com_err(whoami, status, "while getting host information");
549	exit(1);
550	}
551	show_host_info(argv);
552	}
553
554	/* list cluster mappings if needed */
555	if (list_map_flag) {
556	char *args[3];
557
558	args[0] = canonicalize_hostname(strdup(hostname));
559	args[1] = "*";
560	status = wrap_mr_query("get_machine_to_cluster_map", 2, args,
561	show_machine_in_cluster, NULL);
562	if (status)
563	if (status != MR_NO_MATCH) {
564	com_err(whoami, status, "while getting cluster mappings");
565	exit(1);
566	}
567	}
568
569	if (delete_flag) {
570	char *argv[1];
571
572	argv[0] = canonicalize_hostname(strdup(hostname));
573	status = wrap_mr_query("delete_host", 1, argv, NULL, NULL);
574	if (status) {
575	com_err(whoami, status, "while deleting host");
576	exit(1);
577	}
578	}
579
580	/* We're done! */
581	mr_disconnect();
582	exit(success ? 0 : 1);
583	}
584
585	void usage(char **argv)
586	{
587	fprintf(stderr, "Usage: %s hostname [options]\n", argv[0]);
588	fprintf(stderr, "Options are\n");
589	fprintf(stderr, " %-39s%-39s\n", "-C \| -create",
590	"-O \| -owner owner");
591	fprintf(stderr, " %-39s%-39s\n", "-D \| -delete",
592	"-S \| -status status");
593	fprintf(stderr, " %-39s%-39s\n", "-R \| -rename newname",
594	"-V \| -vendor vendor");
595	fprintf(stderr, " %-39s%-39s\n", "-a \| -addalias alias",
596	"-M \| -model model");
597	fprintf(stderr, " %-39s%-39s\n", "-d \| -deletealias alias",
598	"-L \| -location location");
599	fprintf(stderr, " %-39s%-39s\n", "-i \| -info",
600	"-o \| -os os");
601	fprintf(stderr, " %-39s%-39s\n", "-oc \| -opcmt op_cmt",
602	"-c \| -contact contact");
603	fprintf(stderr, " %-39s%-39s\n", "-ac \| -admcmt adm_cmt",
604	"-A \| -address address");
605	fprintf(stderr, " %-39s%-39s\n", "-am \| -addmap cluster",
606	"-N \| -network network");
607	fprintf(stderr, " %-39s%-39s\n", "-dm \| -deletemap cluster",
608	"-lm \| -listmap");
609	fprintf(stderr, " %-39s%-39s\n", "-db \| -database host[:port]",
610	"-n \| -noauth");
611	fprintf(stderr, " %-39s%-39s\n", "-v \| -verbose",
612	"");
613	exit(1);
614	}
615
616	/* Show alias information */
617
618	static int show_has_aliases;
619
620	int show_alias_info(int argc, char *argv, void hint)
621	{
622	if(!show_has_aliases++)
623	printf("Aliases: %s", argv[0]);
624	else
625	printf(", %s", argv[0]);
626
627	return MR_CONT;
628	}
629
630	static char *states[] = {
631	"Reserved (0)",
632	"Active (1)",
633	"None (2)",
634	"Deleted (3)"
635	};
636
637	static char *MacState(int state)
638	{
639	static char buf[BUFSIZ];
640
641	if (state < 0 \|\| state > 3)
642	{
643	sprintf(buf, "Unknown (%d)", state);
644	return buf;
645	}
646	return states[state];
647	}
648
649	/* Retrieve information about a host */
650
651	int store_host_info(int argc, char *argv, void hint)
652	{
653	int i;
654	char **nargv = hint;
655
656	for(i=0; i<argc; i++)
657	nargv[i] = strdup(argv[i]);
658
659	return MR_CONT;
660	}
661
662	void show_host_info(char **argv)
663	{
664	char tbuf[256];
665	char *args[3];
666	struct mqelem *elem = NULL;
667	int stat;
668
669	printf("Machine: %s\n", argv[M_NAME]);
670	args[0] = "*";
671	args[1] = argv[M_NAME];
672	show_has_aliases = 0;
673	stat = wrap_mr_query("get_hostalias", 2, args, show_alias_info, &elem);
674	printf("\n");
675	if (stat) {
676	if (stat != MR_NO_MATCH)
677	com_err(whoami, stat, "while getting aliases");
678	} else {
679	printf("\n");
680	}
681	sprintf(tbuf, "%s %s", argv[M_OWNER_TYPE],
682	strcmp(argv[M_OWNER_TYPE], "NONE") ? argv[M_OWNER_NAME] : "");
683	printf("Address: %-16s Network: %-16s\n",
684	argv[M_ADDR], argv[M_SUBNET]);
685	printf("Owner: %-16s Use data: %s\n", tbuf, argv[M_INUSE]);
686	printf("Status: %-16s Changed: %s\n",
687	MacState(atoi(argv[M_STAT])), argv[M_STAT_CHNG]);
688	printf("\n");
689
690	printf("Vendor: %-16s Model: %-20s OS: %s\n",
691	argv[M_VENDOR], argv[M_MODEL], argv[M_OS]);
692	printf("Location: %-16s Contact: %-20s Opt: %s\n",
693	argv[M_LOC], argv[M_CONTACT], argv[M_USE]);
694	printf("\nAdm cmt: %s\n", argv[M_ACOMMENT]);
695	printf("Op cmt: %s\n", argv[M_OCOMMENT]);
696	printf("\n");
697	printf("Created by %s on %s\n", argv[M_CREATOR], argv[M_CREATED]);
698	printf("Last mod by %s at %s with %s.\n", argv[M_MODBY], argv[M_MODTIME], argv[M_MODWITH]);
699	}
700
701	int show_machine_in_cluster(int argc, char *argv, void hint)
702	{
703	printf("Machine: %-30s Cluster: %-30s\n", argv[0], argv[1]);
704
705	return MR_CONT;
706	}
707
708	/* Parse a line of input, fetching a member. NULL is returned if a member
709	* is not found. ';' is a comment character.
710	*/
711
712	struct owner_type parse_member(char s)
713	{
714	struct owner_type *m;
715	char p, lastchar;
716
717	while (s && isspace(s))
718	s++;
719	lastchar = p = s;
720	while (p && p != '\n' && *p != ';')
721	{
722	if (isprint(p) && !isspace(p))
723	lastchar = p++;
724	else
725	p++;
726	}
727	lastchar++;
728	*lastchar = '\0';
729	if (p == s \|\| strlen(s) == 0)
730	return NULL;
731
732	if (!(m = malloc(sizeof(struct owner_type))))
733	return NULL;
734
735	if ((p = strchr(s, ':')))
736	{
737	*p = '\0';
738	m->name = ++p;
739	if (!strcasecmp("user", s))
740	m->type = M_USER;
741	else if (!strcasecmp("list", s))
742	m->type = M_LIST;
743	else if (!strcasecmp("string", s))
744	m->type = M_STRING;
745	else if (!strcasecmp("kerberos", s))
746	m->type = M_KERBEROS;
747	else if (!strcasecmp("none", s))
748	m->type = M_NONE;
749	else
750	{
751	m->type = M_ANY;
752	*(--p) = ':';
753	m->name = s;
754	}
755	m->name = strdup(m->name);
756	}
757	else
758	{
759	m->name = strdup(s);
760	m->type = strcasecmp(s, "none") ? M_ANY : M_NONE;
761	}
762	return m;
763	}
764
765	struct string_list add_to_string_list(struct string_list old_list, char *s) {
766	struct string_list *new_list;
767
768	new_list = (struct string_list )malloc(sizeof(struct string_list ));
769	new_list->next = old_list;
770	new_list->string = s;
771
772	return new_list;
773	}
774
775	int wrap_mr_query(char handle, int argc, char *argv,
776	int (callback)(int, char , void ), void *callarg) {
777	if (verbose)
778	print_query(handle, argc, argv);
779
780	return mr_query(handle, argc, argv, callback, callarg);
781	}
782
783	void print_query(char query_name, int argc, char *argv) {
784	int cnt;
785
786	printf("qy %s", query_name);
787	for(cnt=0; cnt<argc; cnt++)
788	printf(" <%s>", argv[cnt]);
789	printf("\n");
790	}