/* $Header$
*
- * Command line oriented SMS List tool.
+ * Command line oriented Moira List tool.
*
* by Mark Rosenstein, September 1988.
*
* Copyright 1989 by the Massachusetts Institute of Technology.
+ *
+ * (c) Copyright 1988 by the Massachusetts Institute of Technology.
+ * For copying and distribution information, please see the file
+ * <mit-copyright.h>.
*/
+/* ### Aren't there a lot of sq abstraction barrier violations here?
+ Do we need to improve the support for queue operations? */
+
#include <mit-copyright.h>
#include <stdio.h>
#include <ctype.h>
-#include <sms.h>
-#include <sms_app.h>
+#include <moira.h>
+#include <moira_site.h>
#ifndef LINT
-static char smslist_rcsid[] = "$Header$";
+static char blanche_rcsid[] = "$Header$";
#endif
char *name;
};
-/* member types */
+/* 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
+
+/* argument parsing macro */
+#define argis(a,b) ((strcmp(*arg+1, a) == 0) || (strcmp(*arg+1, b) == 0))
/* flags from command line */
-int infoflg, verbose, syncflg, memberflg, debugflg;
+int infoflg, verbose, syncflg, memberflg, recursflg, debugflg, noauth;
+int showusers, showstrings, showkerberos, showlists;
/* various member lists */
struct save_queue *addlist, *dellist, *memberlist, *synclist;
extern int errno;
int show_list_info(), show_list_count(), get_list_members(), scream();
+int show_list_members();
struct member *parse_member();
{
int status;
char **arg = argv;
- char *membervec[3];
+ char *membervec[3], *motd;
struct member *memberstruct;
+ char *server = NULL;
/* clear all flags & lists */
- infoflg = verbose = syncflg = memberflg = debugflg = 0;
+ infoflg = verbose = syncflg = memberflg = debugflg = recursflg = 0;
+ noauth = showusers = showstrings = showkerberos = showlists = 0;
listname = NULL;
addlist = sq_create();
dellist = sq_create();
/* parse args, building addlist, dellist, & synclist */
while (++arg - argv < argc) {
if (**arg == '-')
- switch((*arg)[1]) {
- case 'm':
- memberflg++;
- break;
- case 'D':
- debugflg++;
- break;
- case 'i':
+ {
+ if (argis("m", "members"))
+ memberflg++;
+ else if (argis("u", "users"))
+ showusers++;
+ else if (argis("s", "strings"))
+ showstrings++;
+ else if (argis("l", "lists"))
+ showlists++;
+ else if (argis("k", "kerberos"))
+ showkerberos++;
+ else if (argis("D", "debug"))
+ debugflg++;
+ else if (argis("i","info"))
infoflg++;
- break;
- case 'v':
+ else if (argis("n","noauth"))
+ noauth++;
+ else if (argis("v","verbose"))
verbose++;
- break;
- case 'a':
- if (arg - argv < argc - 1) {
- ++arg;
- if (memberstruct = parse_member(*arg))
- sq_save_data(addlist, memberstruct);
- } else
- usage(argv);
- break;
- case 'd':
- if (arg - argv < argc - 1) {
- ++arg;
- if (memberstruct = parse_member(*arg))
- sq_save_data(dellist, memberstruct);
- } else
+ else if (argis("r","recursive"))
+ recursflg++;
+ else if (argis("S","server"))
+ if (arg - argv < argc - 1) {
+ ++arg;
+ server = *arg;
+ } else
+ usage(argv);
+ else if (argis("a","add"))
+ if (arg - argv < argc - 1) {
+ ++arg;
+ if (memberstruct = parse_member(*arg))
+ sq_save_data(addlist, memberstruct);
+ } else
+ usage(argv);
+ else if (argis("al","addlist"))
+ if (arg - argv < argc - 1) {
+ ++arg;
+ get_members_from_file(*arg, addlist);
+ } else
+ usage(argv);
+ else if (argis("d","delete"))
+ if (arg - argv < argc - 1) {
+ ++arg;
+ if (memberstruct = parse_member(*arg))
+ sq_save_data(dellist, memberstruct);
+ } else
+ usage(argv);
+ else if (argis("dl","deletelist"))
+ if (arg - argv < argc - 1) {
+ ++arg;
+ get_members_from_file(*arg, dellist);
+ } else
+ usage(argv);
+ else if (argis("f","file"))
+ if (arg - argv < argc - 1) {
+ syncflg++;
+ ++arg;
+ get_members_from_file(*arg, synclist);
+ } else
+ usage(argv);
+ else
usage(argv);
- break;
- case 'f':
- if (arg - argv < argc - 1) {
- FILE *in;
- char buf[BUFSIZ];
-
- syncflg++;
- ++arg;
- if (!strcmp(*arg, "-"))
- in = stdin;
- else {
- in = fopen(*arg, "r");
- if (!in) {
- com_err(whoami, errno, " while opening %s for input",
- *arg);
- exit(2);
- }
- }
- while (fgets(buf, BUFSIZ, in))
- if (memberstruct = parse_member(buf))
- sq_save_data(synclist, memberstruct);
- if (!feof(in))
- com_err(whoami, errno, " while reading from %s", *arg);
- } else
- usage(argv);
- break;
- default:
- usage(argv);
- }
+ }
else if (listname == NULL)
listname = *arg;
else
addlist->q_next != addlist || dellist->q_next != dellist))
memberflg++;
- /* fire up SMS */
- if (status = sms_connect()) {
- com_err(whoami, status, " unable to connect to SMS");
+ /* If none of {users,strings,lists,kerberos} specified, turn them all on */
+ if (!(showusers || showstrings || showlists || showkerberos))
+ showusers = showstrings = showlists = showkerberos = 1;
+
+ /* fire up Moira */
+ if (status = mr_connect(server)) {
+ com_err(whoami, status, "unable to connect to the Moira server");
+ exit(2);
+ }
+ if ( status = mr_motd(&motd) ) {
+ com_err(whoami, status, "unable to check server status");
exit(2);
}
- if (status = sms_auth("blanche")) {
- com_err(whoami, status, " unable to authenticate to SMS");
+ if (motd) {
+ fprintf(stderr, "The Moira server is currently unavailable:\n%s\n", motd);
+ mr_disconnect();
exit(2);
}
+ if (!noauth && (status = mr_auth("blanche"))) {
+ if (status == MR_USER_AUTH)
+ com_err(whoami, status, "");
+ else {
+ com_err(whoami, status, "unable to authenticate to Moira");
+ com_err(whoami, 0,
+ " Try the -noauth flag if you don't need authentication");
+ exit(2);
+ }
+ }
+
/* display list info if requested to */
if (infoflg) {
- status = sms_query("get_list_info", 1, &listname, show_list_info,NULL);
+ status = mr_query("get_list_info", 1, &listname, show_list_info,NULL);
if (status)
- com_err(whoami, status, " while getting list information");
+ com_err(whoami, status, "while getting list information");
if (verbose && !memberflg) {
- status = sms_query("count_members_of_list", 1, &listname,
+ status = mr_query("count_members_of_list", 1, &listname,
show_list_count, NULL);
if (status)
- com_err(whoami, status, " while getting list count");
+ com_err(whoami, status, "while getting list count");
}
}
* lastly, reset memberlist so we can use it again later
*/
if (syncflg) {
- status = sms_query("get_members_of_list", 1, &listname,
- get_list_members, memberlist);
+ status = mr_query("get_members_of_list", 1, &listname,
+ get_list_members, (char *)memberlist);
if (status)
- com_err(whoami, status, " while getting members of list");
+ com_err(whoami, status, "getting members of list %s", listname);
while (sq_get_data(synclist, &memberstruct)) {
struct save_queue *q;
int removed = 0;
for (q = memberlist->q_next; q != memberlist; q = q->q_next) {
- if (membermatch(q->q_data, memberstruct)) {
+ if (membercmp(q->q_data, memberstruct) == 0) {
q->q_prev->q_next = q->q_next;
q->q_next->q_prev = q->q_prev;
removed++;
while (sq_get_data(addlist, &memberstruct)) {
membervec[0] = listname;
membervec[2] = memberstruct->name;
+ if (verbose) {
+ printf("Adding member ");
+ show_list_member(memberstruct);
+ }
switch (memberstruct->type) {
case M_ANY:
case M_USER:
membervec[1] = "USER";
- status = sms_query("add_member_to_list", 3, membervec, scream, NULL);
- if (status == SMS_SUCCESS)
+ status = mr_query("add_member_to_list", 3, membervec, scream, NULL);
+ if (status == MR_SUCCESS)
break;
- else if (status != SMS_USER || memberstruct->type != M_ANY) {
- com_err(whoami, status, " while adding member %s to %s",
+ else if (status != MR_USER || memberstruct->type != M_ANY) {
+ com_err(whoami, status, "while adding member %s to %s",
memberstruct->name, listname);
break;
}
case M_LIST:
membervec[1] = "LIST";
- status = sms_query("add_member_to_list", 3, membervec,
+ status = mr_query("add_member_to_list", 3, membervec,
scream, NULL);
- if (status == SMS_SUCCESS)
+ if (status == MR_SUCCESS)
break;
- else if (status != SMS_LIST || memberstruct->type != M_ANY) {
- com_err(whoami, status, " while adding member %s to %s",
+ else if (status != MR_LIST || memberstruct->type != M_ANY) {
+ com_err(whoami, status, "while adding member %s to %s",
memberstruct->name, listname);
break;
}
case M_STRING:
membervec[1] = "STRING";
- status = sms_query("add_member_to_list", 3, membervec,
+ status = mr_query("add_member_to_list", 3, membervec,
scream, NULL);
- if (status != SMS_SUCCESS)
- com_err(whoami, status, " while adding member %s to %s",
+ if (status != MR_SUCCESS)
+ com_err(whoami, status, "while adding member %s to %s",
+ memberstruct->name, listname);
+ break;
+ case M_KERBEROS:
+ membervec[1] = "KERBEROS";
+ status = mr_query("add_member_to_list", 3, membervec,
+ scream, NULL);
+ if (status != MR_SUCCESS)
+ com_err(whoami, status, "while adding member %s to %s",
memberstruct->name, listname);
}
}
while (sq_get_data(dellist, &memberstruct)) {
membervec[0] = listname;
membervec[2] = memberstruct->name;
+ if (verbose) {
+ printf("Deleting member ");
+ show_list_member(memberstruct);
+ }
switch (memberstruct->type) {
case M_ANY:
case M_USER:
membervec[1] = "USER";
- status = sms_query("delete_member_from_list", 3, membervec,
+ status = mr_query("delete_member_from_list", 3, membervec,
scream, NULL);
- if (status == SMS_SUCCESS)
+ if (status == MR_SUCCESS)
break;
- else if ((status != SMS_USER && status != SMS_NO_MATCH) ||
+ else if ((status != MR_USER && status != MR_NO_MATCH) ||
memberstruct->type != M_ANY) {
- com_err(whoami, status, " while deleteing member %s from %s",
+ com_err(whoami, status, "while deleting member %s from %s",
memberstruct->name, listname);
break;
}
case M_LIST:
membervec[1] = "LIST";
- status = sms_query("delete_member_from_list", 3, membervec,
+ status = mr_query("delete_member_from_list", 3, membervec,
scream, NULL);
- if (status == SMS_SUCCESS)
+ if (status == MR_SUCCESS)
break;
- else if ((status != SMS_LIST && status != SMS_NO_MATCH) ||
+ else if ((status != MR_LIST && status != MR_NO_MATCH) ||
memberstruct->type != M_ANY) {
- com_err(whoami, status, " while deleteing member %s from %s",
+ com_err(whoami, status, "while deleting member %s from %s",
memberstruct->name, listname);
break;
}
case M_STRING:
membervec[1] = "STRING";
- status = sms_query("delete_member_from_list", 3, membervec,
+ status = mr_query("delete_member_from_list", 3, membervec,
scream, NULL);
- if (status == SMS_STRING && memberstruct->type == M_ANY)
- com_err(whoami, 0, "Unable to find member %s to delete from %s",
+ if (status == MR_STRING && memberstruct->type == M_ANY)
+ com_err(whoami, 0, " Unable to find member %s to delete from %s",
memberstruct->name, listname);
- else if (status != SMS_SUCCESS)
- com_err(whoami, status, " while deleteing member %s from %s",
+ else if (status != MR_SUCCESS)
+ com_err(whoami, status, "while deleting member %s from %s",
+ memberstruct->name, listname);
+ break;
+ case M_KERBEROS:
+ membervec[1] = "KERBEROS";
+ status = mr_query("delete_member_from_list", 3, membervec,
+ scream, NULL);
+ if (status != MR_SUCCESS)
+ com_err(whoami, status, "while deleting member %s from %s",
memberstruct->name, listname);
}
}
/* Display the members of the list now, if requested */
if (memberflg) {
- status = sms_query("get_members_of_list", 1, &listname,
- get_list_members, memberlist);
- if (status)
- com_err(whoami, status, " while getting members of list");
- while (sq_get_data(memberlist, &memberstruct)) {
- if (verbose) {
- char *s;
- switch (memberstruct->type) {
- case M_USER:
- s = "USER";
- break;
- case M_LIST:
- s = "LIST";
- break;
- case M_STRING:
- s = "STRING";
- break;
- }
- printf("%s: %s\n", s, memberstruct->name);
- } else {
- if (memberstruct->type == M_LIST)
- printf("LIST:%s\n", memberstruct->name);
- else if (memberstruct->type == M_STRING &&
- !index(memberstruct->name, '@'))
- printf("STRING:%s\n", memberstruct->name);
- else
- printf("%s\n", memberstruct->name);
- }
+ if (recursflg)
+ recursive_display_list_members();
+ else {
+ status = mr_query("get_members_of_list", 1, &listname,
+ get_list_members, (char *)memberlist);
+ if (status)
+ com_err(whoami, status, "while getting members of list %s",
+ listname);
+ while (sq_get_data(memberlist, &memberstruct))
+ show_list_member(memberstruct);
}
}
/* We're done! */
- sms_disconnect();
+ mr_disconnect();
exit(0);
}
usage(argv)
char **argv;
{
- printf("Usage: %s [-i] [-v] [-m] listname [-a member] [-d member] [-f file]\n",
- argv[0]);
+ fprintf(stderr, "Usage: %s [options] listname [options]\n",argv[0]);
+ fprintf(stderr, "Options are\n");
+ fprintf(stderr, " -v | -verbose\n");
+ fprintf(stderr, " -m | -members\n");
+ fprintf(stderr, " -u | -users\n");
+ fprintf(stderr, " -l | -lists\n");
+ fprintf(stderr, " -s | -strings\n");
+ fprintf(stderr, " -k | -kerberos\n");
+ fprintf(stderr, " -i | -info\n");
+ fprintf(stderr, " -r | -recursive\n");
+ fprintf(stderr, " -a | -add member\n");
+ fprintf(stderr, " -d | -delete member\n");
+ fprintf(stderr, " -al | -addlist filename\n");
+ fprintf(stderr, " -dl | -deletelist filename\n");
+ fprintf(stderr, " -f | -file filename\n");
+ fprintf(stderr, " -n | -noauth\n");
+ fprintf(stderr, " -S | -server host[:port]\n");
+ fprintf(stderr, " -D | -debug\n");
exit(1);
}
+/* Display the members stored in the queue */
+
+show_list_member(memberstruct)
+struct member *memberstruct;
+{
+ char *s = "";
+
+ switch (memberstruct->type) {
+ case M_USER:
+ if (!showusers)
+ return;
+ s = "USER";
+ break;
+ case M_LIST:
+ if (!showlists)
+ return;
+ s = "LIST";
+ break;
+ case M_STRING:
+ if (!showstrings)
+ return;
+ s = "STRING";
+ break;
+ case M_KERBEROS:
+ if (!showkerberos)
+ return;
+ s = "KERBEROS";
+ break;
+ case M_ANY:
+ printf("%s\n", memberstruct->name);
+ return;
+ }
+
+ if (verbose)
+ printf("%s:%s\n", s, memberstruct->name);
+ else {
+ if (memberstruct->type == M_LIST)
+ printf("LIST:%s\n", memberstruct->name);
+ else if (memberstruct->type == M_KERBEROS)
+ printf("KERBEROS:%s\n", memberstruct->name);
+ else if (memberstruct->type == M_STRING &&
+ !index(memberstruct->name, '@'))
+ printf("STRING:%s\n", memberstruct->name);
+ else
+ printf("%s\n", memberstruct->name);
+ }
+}
+
+
+/* Show the retrieved information about a list */
+
show_list_info(argc, argv, hint)
int argc;
char **argv;
atoi(argv[1]) ? "active" : "inactive",
atoi(argv[2]) ? "public" : "private",
atoi(argv[3]) ? "hidden" : "visible");
- printf("%s is %sa maillist, and is %sa group", argv[0],
+ printf("%s is %sa maillist and is %sa group", argv[0],
atoi(argv[4]) ? "" : "not ",
atoi(argv[5]) ? "" : "not ");
if (atoi(argv[5]))
printf("\n");
printf("Owner: %s %s\n", argv[7], argv[8]);
printf("Last modified by %s with %s on %s\n", argv[11], argv[12], argv[10]);
- return(SMS_CONT);
+ return(MR_CONT);
}
+/* Show the retrieve list member count */
+
show_list_count(argc, argv, hint)
int argc;
char **argv;
}
+/* Recursively find all of the members of listname, and then display them */
+
+recursive_display_list_members()
+{
+ int status, count, savecount;
+ struct save_queue *lists, *members;
+ struct member *m, *m1, *data;
+
+ lists = sq_create();
+ members = sq_create();
+ m = (struct member *) malloc(sizeof(struct member));
+ m->type = M_LIST;
+ m->name = listname;
+ sq_save_data(lists, m);
+
+ while (sq_get_data(lists, &m)) {
+ sq_destroy(memberlist);
+ memberlist = sq_create();
+ if (debugflg)
+ fprintf(stderr, "Fetching members of %s\n", m->name);
+ status = mr_query("get_members_of_list", 1, &(m->name),
+ get_list_members, (char *)memberlist);
+ if (status)
+ com_err(whoami, status, "while getting members of list %s", m->name);
+ while (sq_get_data(memberlist, &m1)) {
+ if (m1->type == M_LIST)
+ unique_add_member(lists, m1);
+ else
+ unique_add_member(members, m1);
+ }
+ }
+ savecount = count = sq_count_elts(members);
+ data = (struct member *) malloc(count * sizeof(struct member));
+ count = 0;
+ while (sq_get_data(members, &m))
+ bcopy(m, &data[count++], sizeof(struct member));
+ qsort(data, count, sizeof(struct member), membercmp);
+ for (count = 0; count < savecount; count++) {
+ show_list_member(&data[count]);
+ }
+}
+
+
+/* add a struct member to a queue if that member isn't already there. */
+
+unique_add_member(q, m)
+struct save_queue *q;
+struct member *m;
+{
+ struct save_queue *qp;
+
+ for (qp = q->q_next; qp != q; qp = qp->q_next) {
+ if (!membercmp(qp->q_data, m))
+ return;
+ }
+ sq_save_data(q, m);
+}
+
+
+/* Collect the retrieved members of the list */
+
get_list_members(argc, argv, q)
int argc;
char **argv;
case 'S':
m->type = M_STRING;
break;
+ case 'K':
+ m->type = M_KERBEROS;
+ break;
}
m->name = strsave(argv[1]);
sq_save_data(q, m);
- return(SMS_CONT);
+ return(MR_CONT);
}
+/* Called only if a query returns a value that we weren't expecting */
+
scream()
{
fprintf(stderr, "Programmer botch\n");
}
+/* Open file, parse members from file, and put them on the specified queue */
+get_members_from_file(filename, queue)
+char *filename;
+struct save_queue *queue;
+{
+ FILE *in;
+ char buf[BUFSIZ];
+ struct member *memberstruct;
+
+ if (!strcmp(filename, "-"))
+ in = stdin;
+ else {
+ in = fopen(filename, "r");
+ if (!in) {
+ com_err(whoami, errno, "while opening %s for input", filename);
+ exit(2);
+ }
+ }
+
+ while (fgets(buf, BUFSIZ, in))
+ if (memberstruct = parse_member(buf))
+ sq_save_data(queue, memberstruct);
+ if (!feof(in))
+ com_err(whoami, errno, "while reading from %s", filename);
+}
+
+
+/* Parse a line of input, fetching a member. NULL is returned if a member
+ * is not found. ';' is a comment character.
+ */
+
struct member *parse_member(s)
register char *s;
{
register struct member *m;
- char *p;
+ char *p, *lastchar;
while (*s && isspace(*s))
s++;
- p = s;
- while (*p && isprint(*p) && !isspace(*p) && *p != ';')
- p++;
- *p = 0;
+ 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);
m->type = M_LIST;
else if (!strcasecmp("string", s))
m->type = M_STRING;
+ else if (!strcasecmp("kerberos", s))
+ m->type = M_KERBEROS;
else {
m->type = M_STRING;
*(--p) = ':';
return(m);
}
m->name = strsave(s);
- if (index(s, '@') || index(s, '!') || index(s, '%'))
+ if (index(s, '@') || index(s, '!') || index(s, '%') || index(s, ' '))
m->type = M_STRING;
else
m->type = M_ANY;
}
-int membermatch(m1, m2)
-struct member *m1, *m2;
+ /*
+ * This routine two compares members by the following rules:
+ * 1. A USER is less than a LIST
+ * 2. A LIST is less than a STRING
+ * 3. If two members are of the same type, the one alphabetically first
+ * is less than the other
+ * It returs < 0 if the first member is less, 0 if they are identical, and
+ * > 0 if the second member is less (the first member is greater).
+ */
+
+int membercmp(m1, m2)
+ struct member *m1, *m2;
{
- if (strcmp(m1->name, m2->name))
- return(0);
- if (m1->type == M_ANY || m2->type == M_ANY)
- return(1);
- if (m1->type == m2->type)
- return(1);
+ if (m1->type == M_ANY || m2->type == M_ANY || (m1->type == m2->type))
+ return(strcmp(m1->name, m2->name));
else
- return(0);
+ return(m1->type - m2->type);
+}
+
+
+sq_count_elts(q)
+struct save_queue *q;
+{
+ char *foo;
+ int count;
+
+ count = 0;
+ while (sq_get_data(q, &foo))
+ count++;
+ return(count);
}
andersk / moira.git / blobdiff