]> andersk Git - moira.git/blob - clients/stella/stella.c
Fix typo.
[moira.git] / clients / stella / stella.c
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 #define M_ANY           0
43 #define M_USER          1
44 #define M_LIST          2
45 #define M_KERBEROS      3
46 #define M_NONE          4
47
48 /* argument parsing macro */
49 #define argis(a, b) (!strcmp(*arg + 1, a) || !strcmp(*arg + 1, b))
50
51 /* flags from command line */
52 int info_flag, update_flag, create_flag, delete_flag, list_map_flag;
53 int update_map_flag, verbose, noauth;
54
55 struct string_list *alias_add_queue, *alias_remove_queue;
56 struct string_list *map_add_queue, *map_remove_queue;
57
58 char *hostname, *whoami;
59
60 char *newname, *address, *network, *h_status, *vendor, *model;
61 char *os, *location, *contact, *adm_cmt, *op_cmt;
62
63 struct owner_type *owner;
64
65 void usage(char **argv);
66 int store_host_info(int argc, char **argv, void *hint);
67 void show_host_info(char **argv);
68 int show_machine_in_cluster(int argc, char **argv, void *hint);
69 struct owner_type *parse_member(char *s);
70 struct string_list *add_to_string_list(struct string_list *old_list, char *s);
71 int wrap_mr_query(char *handle, int argc, char **argv,
72                   int (*callback)(int, char **, void *), void *callarg);
73 void print_query(char *query_name, int argc, char **argv);
74
75 int main(int argc, char **argv)
76 {
77   int status, success;
78   char **arg = argv;
79   char *server = NULL;
80
81   /* clear all flags & lists */
82   info_flag = update_flag = create_flag = list_map_flag = update_map_flag = 0;
83   verbose = noauth = 0;
84   newname = address = network = h_status = vendor = model = NULL;
85   os = location = contact = adm_cmt = op_cmt = NULL;
86   owner = NULL;
87   alias_add_queue = alias_remove_queue = NULL;
88   map_add_queue = map_remove_queue = NULL;
89   whoami = argv[0];
90
91   success = 1;
92
93   /* parse args, building addlist, dellist, & synclist */
94   while (++arg - argv < argc)
95     {
96       if (**arg == '-')
97         {
98           if (argis("i", "info"))
99             info_flag++;
100           else if (argis("C", "create"))
101             create_flag++;
102           else if (argis("D", "delete"))
103             delete_flag++;
104           else if (argis("R", "rename")) {
105             if (arg - argv < argc - 1) {
106               arg++;
107               update_flag++;
108               newname = *arg;
109             } else
110               usage(argv);
111           }
112           else if (argis("A", "address")) {
113             if (arg - argv < argc - 1) {
114               arg++;
115               update_flag++;
116               address = *arg;
117             } else
118               usage(argv);
119           }
120           else if (argis("O", "owner")) {
121             if (arg - argv < argc - 1) {
122               arg++;
123               update_flag++;
124               owner = parse_member(*arg);
125             } else
126               usage(argv);
127           }
128           else if (argis("N", "network")) {
129             if (arg - argv < argc - 1) {
130               arg++;
131               update_flag++;
132               network = *arg;
133             } else
134               usage(argv);
135           }
136           else if (argis("S", "status")) {
137             if (arg - argv < argc - 1) {
138               int i;
139               int len;
140
141               arg++;
142               update_flag++;
143               h_status = *arg;
144
145               len = strlen(h_status);
146               for(i = 0; i < len; 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       else
317         argv[9] = "unique";
318       if (adm_cmt)
319         argv[12] = adm_cmt;
320       if (op_cmt)
321         argv[13] = op_cmt;
322
323       if (owner)
324         {
325           argv[11] = owner->name;
326           switch (owner->type)
327             {
328             case M_ANY:
329             case M_USER:
330               argv[10] = "USER";
331               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
332               if (owner->type != M_ANY || status != MR_USER)
333                 break;
334
335             case M_LIST:
336               argv[10] = "LIST";
337               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
338               break;
339
340             case M_KERBEROS:
341               argv[10] = "KERBEROS";
342               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
343               break;
344
345             case M_NONE:
346               argv[10] = "NONE";
347               status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
348               break;
349             }
350         }
351       else
352         {
353           argv[10] = "NONE";
354           argv[11] = "NONE";
355
356           status = wrap_mr_query("add_host", 14, argv, NULL, NULL);
357         }
358
359       if (status)
360         {
361           com_err(whoami, status, "while creating host.");
362           exit(1);
363         }
364
365     }
366   else if (update_flag)
367     {
368       char *old_argv[30];
369       char *argv[16];
370       char *args[5];
371
372       args[0] = canonicalize_hostname(strdup(hostname));
373       args[1] = args[2] = args[3] = "*";
374
375       status = wrap_mr_query("get_host", 4, args, store_host_info, old_argv);
376       if (status)
377         {
378           com_err(whoami, status, "while getting list information");
379           exit(1);
380         }
381
382       argv[1] = old_argv[0];
383       argv[2] = old_argv[1];
384       argv[3] = old_argv[2];
385       argv[4] = old_argv[3];
386       argv[5] = old_argv[4];
387       argv[6] = old_argv[5];
388       argv[7] = old_argv[6];
389       argv[8] = old_argv[7];
390       argv[9] = old_argv[9];
391       argv[10] = old_argv[10];
392       argv[11] = old_argv[11];
393       argv[12] = old_argv[12];
394       argv[13] = old_argv[13];
395       argv[14] = old_argv[14];
396
397       argv[0] = canonicalize_hostname(strdup(hostname));
398       if (newname)
399         argv[1] = canonicalize_hostname(strdup(newname));
400       if (vendor)
401         argv[2] = vendor;
402       if (model)
403         argv[3] = model;
404       if (os)
405         argv[4] = os;
406       if (location)
407         argv[5] = location;
408       if (contact)
409         argv[6] = contact;
410       if (h_status)
411         argv[8] = h_status;
412       if (network)
413         argv[9] = network;
414       if (address)
415         argv[10] = address;
416       if (adm_cmt)
417         argv[13] = adm_cmt;
418       if (op_cmt)
419         argv[14] = op_cmt;
420
421       if (owner)
422         {
423           argv[12] = owner->name;
424           switch (owner->type)
425             {
426             case M_ANY:
427             case M_USER:
428               argv[11] = "USER";
429               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
430               if (owner->type != M_ANY || status != MR_USER)
431                 break;
432
433             case M_LIST:
434               argv[11] = "LIST";
435               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
436               break;
437
438             case M_KERBEROS:
439               argv[11] = "KERBEROS";
440               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
441               break;
442
443             case M_NONE:
444               argv[11] = "NONE";
445               status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
446               break;
447             }
448         }
449       else
450         status = wrap_mr_query("update_host", 15, argv, NULL, NULL);
451
452       if (status)
453         com_err(whoami, status, "while updating host.");
454       else if (newname)
455         hostname = newname;
456     }
457
458   /* create aliases if necessary */
459   if (alias_add_queue) {
460     struct string_list *q = alias_add_queue;
461
462     while(q) {
463       char *alias = q->string;
464       char *args[2];
465
466       args[0] = partial_canonicalize_hostname(strdup(alias));
467       args[1] = canonicalize_hostname(strdup(hostname));
468       status = wrap_mr_query("add_hostalias", 2, args, NULL, NULL);
469       if (status) {
470         com_err(whoami, status, "while adding host alias");
471         exit(1);
472       }
473
474       q = q->next;
475     }
476   }
477
478   /* delete aliases if necessary */
479   if (alias_remove_queue) {
480     struct string_list *q = alias_remove_queue;
481
482     while(q) {
483       char *alias = q->string;
484       char *args[2];
485
486       args[0] = partial_canonicalize_hostname(strdup(alias));
487       args[1] = canonicalize_hostname(strdup(hostname));
488       status = wrap_mr_query("delete_hostalias", 2, args, NULL, NULL);
489       if (status) {
490         com_err(whoami, status, "while deleting host alias");
491         exit(1);
492       }
493
494       q = q->next;
495     }
496   }
497
498   /* create cluster mappings */
499   if (map_add_queue) {
500     struct string_list *q = map_add_queue;
501
502     while(q) {
503       char *clustername = q->string;
504       char *args[2];
505
506       args[0] = canonicalize_hostname(strdup(hostname));
507       args[1] = clustername;
508       status = wrap_mr_query("add_machine_to_cluster", 2, args, NULL, NULL);
509       if (status) {
510         com_err(whoami, status, "while adding cluster mapping");
511         exit(1);
512       }
513
514       q = q->next;
515     }
516   }
517
518   /* delete cluster mappings */
519   if (map_remove_queue) {
520     struct string_list *q = map_remove_queue;
521
522     while(q) {
523       char *clustername = q->string;
524       char *args[2];
525
526       args[0] = canonicalize_hostname(strdup(hostname));
527       args[1] = clustername;
528       status = wrap_mr_query("delete_machine_from_cluster", 2, args,
529                              NULL, NULL);
530       if (status) {
531         com_err(whoami, status, "while deleting cluster mapping");
532         exit(1);
533       }
534
535       q = q->next;
536     }
537   }
538
539   /* display list info if requested to */
540   if (info_flag) {
541     struct mqelem *elem = NULL;
542     char *args[5];
543     char *argv[30];
544
545     args[0] = canonicalize_hostname(strdup(hostname));
546     args[1] = args[2] = args[3] = "*";
547     status = wrap_mr_query("get_host", 4, args, store_host_info, argv);
548     if (status) {
549       com_err(whoami, status, "while getting host information");
550       exit(1);
551     }
552     show_host_info(argv);
553   }
554
555   /* list cluster mappings if needed */
556   if (list_map_flag) {
557     char *args[3];
558
559     args[0] = canonicalize_hostname(strdup(hostname));
560     args[1] = "*";
561     status = wrap_mr_query("get_machine_to_cluster_map", 2, args,
562                       show_machine_in_cluster, NULL);
563     if (status)
564       if (status != MR_NO_MATCH) {
565         com_err(whoami, status, "while getting cluster mappings");
566         exit(1);
567       }
568   }
569
570   if (delete_flag) {
571     char *argv[1];
572
573     argv[0] = canonicalize_hostname(strdup(hostname));
574     status = wrap_mr_query("delete_host", 1, argv, NULL, NULL);
575     if (status) {
576       com_err(whoami, status, "while deleting host");
577       exit(1);
578     }
579   }
580
581   /* We're done! */
582   mr_disconnect();
583   exit(success ? 0 : 1);
584 }
585
586 void usage(char **argv)
587 {
588 #define USAGE_OPTIONS_FORMAT "  %-39s%s\n"
589   fprintf(stderr, "Usage: %s hostname [options]\n", argv[0]);
590   fprintf(stderr, "Options are\n");
591   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-C   | -create",
592           "-O   | -owner owner");
593   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-D   | -delete",
594           "-S   | -status status");
595   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-R   | -rename newname",
596           "-V   | -vendor vendor");
597   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-a   | -addalias alias",
598           "-M   | -model model");
599   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-d   | -deletealias alias",
600           "-L   | -location location");
601   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-i   | -info",
602           "-o   | -os os");
603   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-oc  | -opcmt op_cmt",
604           "-c   | -contact contact");
605   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-ac  | -admcmt adm_cmt",
606           "-A   | -address address");
607   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-am  | -addmap cluster",
608           "-N   | -network network");
609   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-dm  | -deletemap cluster",
610           "-lm  | -listmap");
611   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-db  | -database host[:port]",
612           "-n   | -noauth");
613   fprintf(stderr, USAGE_OPTIONS_FORMAT, "-v   | -verbose",
614           "");
615   exit(1);
616 }
617
618 /* Show alias information */
619
620 static int show_has_aliases;
621
622 int show_alias_info(int argc, char **argv, void *hint)
623 {
624   if(!show_has_aliases++)
625     printf("Aliases:  %s", argv[0]);
626   else
627     printf(", %s", argv[0]);
628
629   return MR_CONT;
630 }
631
632 static char *states[] = {
633   "Reserved (0)",
634   "Active (1)",
635   "None (2)",
636   "Deleted (3)"
637 };
638
639 static char *MacState(int state)
640 {
641   static char buf[BUFSIZ];
642
643   if (state < 0 || state > 3)
644     {
645       sprintf(buf, "Unknown (%d)", state);
646       return buf;
647     }
648   return states[state];
649 }
650
651 /* Retrieve information about a host */
652
653 int store_host_info(int argc, char **argv, void *hint)
654 {
655   int i;
656   char **nargv = hint;
657
658   for(i=0; i<argc; i++)
659     nargv[i] = strdup(argv[i]);
660
661   return MR_CONT;
662 }
663
664 void show_host_info(char **argv)
665 {
666   char tbuf[256];
667   char *args[3];
668   struct mqelem *elem = NULL;
669   int stat;
670
671   printf("Machine:  %s\n", argv[M_NAME]);
672   args[0] = "*";
673   args[1] = argv[M_NAME];
674   show_has_aliases = 0;
675   stat = wrap_mr_query("get_hostalias", 2, args, show_alias_info, &elem);
676   printf("\n");
677   if (stat) {
678     if (stat != MR_NO_MATCH)
679       com_err(whoami, stat, "while getting aliases");
680   } else {
681     printf("\n");
682   }
683   sprintf(tbuf, "%s %s", argv[M_OWNER_TYPE],
684           strcmp(argv[M_OWNER_TYPE], "NONE") ? argv[M_OWNER_NAME] : "");
685   printf("Address:  %-16s    Network:    %-16s\n",
686           argv[M_ADDR], argv[M_SUBNET]);
687   printf("Owner:    %-16s    Use data:   %s\n", tbuf, argv[M_INUSE]);
688   printf("Status:   %-16s    Changed:    %s\n",
689           MacState(atoi(argv[M_STAT])), argv[M_STAT_CHNG]);
690   printf("\n");
691
692   printf("Vendor:   %-16s    Model:      %-20s  OS:  %s\n",
693           argv[M_VENDOR], argv[M_MODEL], argv[M_OS]);
694   printf("Location: %-16s    Contact:    %-20s  Opt: %s\n",
695           argv[M_LOC], argv[M_CONTACT], argv[M_USE]);
696   printf("\nAdm cmt: %s\n", argv[M_ACOMMENT]);
697   printf("Op cmt:  %s\n", argv[M_OCOMMENT]);
698   printf("\n");
699   printf("Created  by %s on %s\n", argv[M_CREATOR], argv[M_CREATED]);
700   printf("Last mod by %s at %s with %s.\n", argv[M_MODBY], argv[M_MODTIME], argv[M_MODWITH]);
701 }
702
703 int show_machine_in_cluster(int argc, char **argv, void *hint)
704 {
705   printf("Machine: %-30s Cluster: %-30s\n", argv[0], argv[1]);
706
707   return MR_CONT;
708 }
709
710 /* Parse a line of input, fetching a member.  NULL is returned if a member
711  * is not found.  ';' is a comment character.
712  */
713
714 struct owner_type *parse_member(char *s)
715 {
716   struct owner_type *m;
717   char *p, *lastchar;
718
719   while (*s && isspace(*s))
720     s++;
721   lastchar = p = s;
722   while (*p && *p != '\n' && *p != ';')
723     {
724       if (isprint(*p) && !isspace(*p))
725         lastchar = p++;
726       else
727         p++;
728     }
729   lastchar++;
730   *lastchar = '\0';
731   if (p == s || strlen(s) == 0)
732     return NULL;
733
734   if (!(m = malloc(sizeof(struct owner_type))))
735     return NULL;
736
737   if ((p = strchr(s, ':')))
738     {
739       *p = '\0';
740       m->name = ++p;
741       if (!strcasecmp("user", s))
742         m->type = M_USER;
743       else if (!strcasecmp("list", s))
744         m->type = M_LIST;
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 }
This page took 0.099296 seconds and 5 git commands to generate.