/* * This file is part of the OLC On-Line Consulting System. * It contains procedures for exectuting olc commands. * * Win Treese * Dan Morgan * Bill Saphir * MIT Project Athena * * Ken Raeburn * MIT Information Systems * * Tom Coppeto * Chris VanHaren * Lucien Van Elsen * MIT Project Athena * * Copyright (C) 1988,1990 by the Massachusetts Institute of Technology. * For copying and distribution information, see the file "mit-copyright.h". * * $Source: /afs/sipb.mit.edu/project/sipb-athena/repository/src/olc/clients/parser/p_messages.c,v $ * $Id: p_messages.c,v 1.12 1996/06/02 07:55:47 ghudson Exp $ * $Author: ghudson $ */ #ifndef lint #ifndef SABER static char rcsid[] ="$Header: /afs/sipb.mit.edu/project/sipb-athena/repository/src/olc/clients/parser/p_messages.c,v 1.12 1996/06/02 07:55:47 ghudson Exp $"; #endif #endif #include #include #include /* * Function: do_olc_replay() prints the log of the conversation up to * this point. * Arguments: arguments: Argument array from the parser. * arguments[1] may be a username or ">". * arguments[2] may be a filename to save the log in if * arguments[1] is ">". * The two different arguments may not be used at the * same time. (I call this a bug) * Returns: An error code. * Notes: * If the command has the form "replay > filename", save the * conversation in "filename" for the user. If the first argument is * a username, replay the conversation of that user. Otherwise, * read the log from the daemon and display it. */ ERRCODE do_olc_replay(arguments) char **arguments; { REQUEST Request; int status; int stati = 0; char queues[NAME_SIZE]; char users[NAME_SIZE]; char topics[NAME_SIZE]; char file[NAME_SIZE]; int savefile = FALSE; int i, mask; queues[0] = '\0'; users[0] = '\0'; topics[0] = '\0'; if(fill_request(&Request) != SUCCESS) return(ERROR); make_temp_name(file); savefile = FALSE; for (arguments++; *arguments != (char *)NULL; arguments++) { if ((string_equiv(*arguments, "-file",max(2,strlen(*arguments)))) || string_eq(*arguments,">")) { arguments++; unlink(file); if (*arguments == (char *)NULL) { file[0] = '\0'; get_prompted_input("Enter a file name: ",file,NAME_SIZE,0); if(file[0] == '\0') return(ERROR); } else (void) strcpy(file, *arguments); savefile = TRUE; continue; } if(string_equiv(*arguments,"-queue",max(strlen(*arguments),2))) { ++arguments; if(*arguments == (char *) NULL) { fprintf(stderr, "You must specify a queue after the -queue option.\n"); return(ERROR); } for(i=0; *arguments != (char *) NULL; arguments++) { if(strlen(*arguments) >= (NAME_SIZE -i)) fprintf(stderr,"Too many queues specified. Continuing...\n"); else { strcat(queues," "); strncat(queues,*arguments,NAME_SIZE-1); break; } if(*(arguments+1) && (*(arguments+1)[0] == '-')) break; if(arguments[1] == (char *) NULL) break; } continue; } if(string_equiv(*arguments,"-status",max(strlen(*arguments),2))) { ++arguments; if(*arguments != (char *) NULL) for(i=0; *arguments != (char *) NULL; arguments++) { OGetStatusCode(*arguments, &mask); if(mask == -1) { printf("Invalid status label specified. Choose one of...\n"); t_pp_stati(); return(ERROR); } else stati |= mask; if((*(arguments+1)) && (*(arguments+1)[0] == '-')) break; if(arguments[1] == (char *) NULL) break; } continue; } if(string_equiv(*arguments,"-user",max(strlen(*arguments),2))) { ++arguments; if(*arguments == (char *) NULL) { fprintf(stderr, "You must specify something after the -user option.\n"); return(ERROR); } strncpy(users,*arguments,NAME_SIZE-1); continue; } if(string_equiv(*arguments,"-topic",max(strlen(*arguments),2))) { ++arguments; if(*arguments == (char *) NULL) { fprintf(stderr, "You must specify a topic after the -topic option.\n"); return(ERROR); } for(i=0; *arguments != (char *) NULL; arguments++) { if(strlen(*arguments) >= (NAME_SIZE -i)) fprintf(stderr, "Too many topics specified. Continuing...\n"); else { strncpy(topics, *arguments, NAME_SIZE-1); break; } if((*(arguments+1)) && (*(arguments+1)[0] == '-')) break; if(arguments[1] == (char *) NULL) break; } continue; } arguments = handle_argument(arguments, &Request, &status); if(status) return(ERROR); if(arguments == (char **) NULL) /* error */ { if(OLC) printf("Usage is: \treplay [-file ]\n"); else { printf("Usage is: \treplay [ ] "); printf("[-file ]\n"); printf("\t\t[-instance ]\n"); } return(ERROR); } if(*arguments == (char *) NULL) /* end of list */ break; } status = t_replay(&Request, queues, topics, users, stati, file, !savefile); if((savefile == FALSE) || (status != SUCCESS)) (void) unlink(file); return(status); } /* * Function: do_olc_show() shows the new part of the log. * Arguments: arguments: The argument array from the parser. * Returns: An error code. * Notes: */ ERRCODE do_olc_show(arguments) char **arguments; { REQUEST Request; char file[NAME_SIZE]; int savefile; int status; int connected = 0; int noflush = 0; if(fill_request(&Request) != SUCCESS) return(ERROR); savefile = FALSE; make_temp_name(file); for (arguments++; *arguments != (char *)NULL; arguments++) { if ((string_equiv(*arguments, "-file",max(strlen(*arguments),2))) || string_eq(*arguments,">")) { arguments++; unlink(file); if (*arguments == (char *)NULL) { file[0] = '\0'; get_prompted_input("Enter a filename: ",file,NAME_SIZE,0); if(file[0] == '\0') return(ERROR); } else (void) strcpy(file, *arguments); savefile = TRUE; } else if (string_equiv(*arguments, "-connected", max(strlen(*arguments),2))) { connected = TRUE; continue; } else if (string_equiv(*arguments, "-noflush", max(strlen(*arguments),2))) { noflush = TRUE; continue; } else { arguments = handle_argument(arguments, &Request, &status); if(status) return(ERROR); } if(arguments == (char **) NULL) /* error */ { if(OLC) { printf("Usage is: \tshow [-file ] [-connected]"); printf(" [-noflush]\n"); } else { printf("Usage is: \tshow [ ] "); printf("[-file ]\n"); printf("\t\t[-connected] [-noflush] "); printf("[-instance ]\n"); } return(ERROR); } if(*arguments == (char *) NULL) /* end of list */ break; } status = t_show_message(&Request,file, !savefile, connected, noflush); if((savefile == FALSE) || (status != SUCCESS)) (void) unlink(file); return(status); }