From c76b0c2ff8d35bf8cbefea0c45887e04d253ee01 Mon Sep 17 00:00:00 2001 From: markster Date: Wed, 7 Aug 2002 17:59:33 +0000 Subject: Version 0.2.0 from FTP git-svn-id: http://svn.digium.com/svn/asterisk/trunk@501 f38db490-d61c-443f-a65b-d21fe96a405b --- utils/astman.c | 653 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 653 insertions(+) create mode 100755 utils/astman.c (limited to 'utils/astman.c') diff --git a/utils/astman.c b/utils/astman.c new file mode 100755 index 000000000..f1d0faf65 --- /dev/null +++ b/utils/astman.c @@ -0,0 +1,653 @@ +/* + * ASTerisk MANager + * Copyright (C) 2002, Linux Support Services, Inc. + * + * Distributed under the terms of the GNU General Public License + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include + +#define MAX_HEADERS 80 +#define MAX_LEN 256 + +static struct mansession { + struct sockaddr_in sin; + int fd; + char inbuf[MAX_LEN]; + int inlen; +} session; + +struct message { + int hdrcount; + char headers[MAX_HEADERS][MAX_LEN]; +} message; + +static struct ast_chan { + char name[80]; + char exten[20]; + char context[20]; + char priority[20]; + char callerid[40]; + char state[10]; + struct ast_chan *next; +} *chans; + +static struct ast_chan *find_chan(char *name) +{ + struct ast_chan *prev = NULL, *chan = chans; + while(chan) { + if (!strcmp(name, chan->name)) + return chan; + prev = chan; + chan = chan->next; + } + chan = malloc(sizeof(struct ast_chan)); + if (chan) { + memset(chan, 0, sizeof(struct ast_chan)); + strncpy(chan->name, name, sizeof(chan->name) - 1); + if (prev) + prev->next = chan; + else + chans = chan; + } + return chan; +} + +static void del_chan(char *name) +{ + struct ast_chan *prev = NULL, *chan = chans; + while(chan) { + if (!strcmp(name, chan->name)) { + if (prev) + prev->next = chan->next; + else + chans = chan->next; + return; + } + prev = chan; + chan = chan->next; + } +} + +static void fdprintf(int fd, char *fmt, ...) +{ + char stuff[4096]; + va_list ap; + va_start(ap, fmt); + vsnprintf(stuff, sizeof(stuff), fmt, ap); + va_end(ap); + write(fd, stuff, strlen(stuff)); +} + +static char *get_header(struct message *m, char *var) +{ + char cmp[80]; + int x; + snprintf(cmp, sizeof(cmp), "%s: ", var); + for (x=0;xhdrcount;x++) + if (!strncasecmp(cmp, m->headers[x], strlen(cmp))) + return m->headers[x] + strlen(cmp); + return ""; +} + +static int event_newstate(struct mansession *s, struct message *m) +{ + struct ast_chan *chan; + chan = find_chan(get_header(m, "Channel")); + strncpy(chan->state, get_header(m, "State"), sizeof(chan->state) - 1); + return 0; +} + +static int event_newexten(struct mansession *s, struct message *m) +{ + struct ast_chan *chan; + chan = find_chan(get_header(m, "Channel")); + strncpy(chan->exten, get_header(m, "Extension"), sizeof(chan->exten) - 1); + strncpy(chan->context, get_header(m, "Context"), sizeof(chan->context) - 1); + strncpy(chan->priority, get_header(m, "Priority"), sizeof(chan->priority) - 1); + return 0; +} + +static int event_newchannel(struct mansession *s, struct message *m) +{ + struct ast_chan *chan; + chan = find_chan(get_header(m, "Channel")); + strncpy(chan->state, get_header(m, "State"), sizeof(chan->state) - 1); + strncpy(chan->callerid, get_header(m, "Callerid"), sizeof(chan->callerid) - 1); + return 0; +} + +static int event_status(struct mansession *s, struct message *m) +{ + struct ast_chan *chan; + chan = find_chan(get_header(m, "Channel")); + strncpy(chan->state, get_header(m, "State"), sizeof(chan->state) - 1); + strncpy(chan->callerid, get_header(m, "Callerid"), sizeof(chan->callerid) - 1); + strncpy(chan->exten, get_header(m, "Extension"), sizeof(chan->exten) - 1); + strncpy(chan->context, get_header(m, "Context"), sizeof(chan->context) - 1); + strncpy(chan->priority, get_header(m, "Priority"), sizeof(chan->priority) - 1); + return 0; +} + +static int event_hangup(struct mansession *s, struct message *m) +{ + del_chan(get_header(m, "Channel")); + return 0; +} + +static int event_ignore(struct mansession *s, struct message *m) +{ + return 0; +} + +static int event_rename(struct mansession *s, struct message *m) +{ + struct ast_chan *chan; + chan = find_chan(get_header(m, "Oldname")); + strncpy(chan->name, get_header(m, "Newname"), sizeof(chan->name) - 1); + return 0; +} +static struct event { + char *event; + int (*func)(struct mansession *s, struct message *m); +} events[] = { + { "Newstate", event_newstate }, + { "Newchannel", event_newchannel }, + { "Newexten", event_newexten }, + { "Hangup", event_hangup }, + { "Rename", event_rename }, + { "Status", event_status }, + { "Link", event_ignore }, + { "Unlink", event_ignore }, +}; + +static int process_message(struct mansession *s, struct message *m) +{ + int x; + char event[80]; + strncpy(event, get_header(m, "Event"), sizeof(event)); + if (!strlen(event)) { + fprintf(stderr, "Missing event in request"); + return 0; + } + for (x=0;x= sizeof(events) / sizeof(events[0])) + fprintf(stderr, "Ignoring unknown event '%s'", event); +#if 0 + for (x=0;xhdrcount;x++) { + printf("Header: %s\n", m->headers[x]); + } +#endif + return 0; +} + +static void rebuild_channels(newtComponent c) +{ + void *prev = NULL; + struct ast_chan *chan; + char tmpn[42]; + char tmp[256]; + int x=0; + prev = newtListboxGetCurrent(c); + newtListboxClear(c); + chan = chans; + while(chan) { + snprintf(tmpn, sizeof(tmpn), "%s (%s)", chan->name, chan->callerid); + if (strlen(chan->exten)) + snprintf(tmp, sizeof(tmp), "%-30s %8s -> %s@%s:%s", + tmpn, chan->state, + chan->exten, chan->context, chan->priority); + else + snprintf(tmp, sizeof(tmp), "%-30s %8s", + tmpn, chan->state); + newtListboxAppendEntry(c, tmp, chan); + x++; + chan = chan->next; + } + if (!x) + newtListboxAppendEntry(c, " << No Active Channels >> ", NULL); + newtListboxSetCurrentByKey(c, prev); +} + +static int has_input(struct mansession *s) +{ + int x; + for (x=1;xinlen;x++) + if ((s->inbuf[x] == '\n') && (s->inbuf[x-1] == '\r')) + return 1; + return 0; +} + +static int get_input(struct mansession *s, char *output) +{ + /* output must have at least sizeof(s->inbuf) space */ + int res; + int x; + struct timeval tv = {0, 0}; + fd_set fds; + for (x=1;xinlen;x++) { + if ((s->inbuf[x] == '\n') && (s->inbuf[x-1] == '\r')) { + /* Copy output data up to and including \r\n */ + memcpy(output, s->inbuf, x + 1); + /* Add trailing \0 */ + output[x+1] = '\0'; + /* Move remaining data back to the front */ + memmove(s->inbuf, s->inbuf + x + 1, s->inlen - x); + s->inlen -= (x + 1); + return 1; + } + } + if (s->inlen >= sizeof(s->inbuf) - 1) { + fprintf(stderr, "Dumping long line with no return from %s: %s\n", inet_ntoa(s->sin.sin_addr), s->inbuf); + s->inlen = 0; + } + FD_ZERO(&fds); + FD_SET(s->fd, &fds); + res = select(s->fd + 1, &fds, NULL, NULL, &tv); + if (res < 0) { + fprintf(stderr, "Select returned error: %s\n", strerror(errno)); + } else if (res > 0) { + res = read(s->fd, s->inbuf + s->inlen, sizeof(s->inbuf) - 1 - s->inlen); + if (res < 1) + return -1; + s->inlen += res; + s->inbuf[s->inlen] = '\0'; + } else { + return 2; + } + return 0; +} + +static int input_check(struct mansession *s, struct message **mout) +{ + static struct message m; + int res; + + if (mout) + *mout = NULL; + + for(;;) { + res = get_input(s, m.headers[m.hdrcount]); + if (res == 1) { +#if 0 + fprintf(stderr, "Got header: %s", m.headers[m.hdrcount]); + fgetc(stdin); +#endif + /* Strip trailing \r\n */ + if (strlen(m.headers[m.hdrcount]) < 2) + continue; + m.headers[m.hdrcount][strlen(m.headers[m.hdrcount]) - 2] = '\0'; + if (!strlen(m.headers[m.hdrcount])) { + if (mout && strlen(get_header(&m, "Response"))) { + *mout = &m; + return 0; + } + if (process_message(s, &m)) + break; + memset(&m, 0, sizeof(&m)); + } else if (m.hdrcount < MAX_HEADERS - 1) + m.hdrcount++; + } else if (res < 0) { + return -1; + } else if (res == 2) + return 0; + } + return -1; +} + +static struct message *wait_for_response(int timeout) +{ + struct message *m; + struct timeval tv; + int res; + fd_set fds; + for (;;) { + tv.tv_sec = timeout / 1000; + tv.tv_usec = (timeout % 1000) * 1000; + FD_SET(session.fd, &fds); + res = select(session.fd + 1, &fds, NULL, NULL, &tv); + if (res < 1) + break; + if (input_check(&session, &m) < 0) { + return NULL; + } + if (m) + return m; + } + return NULL; +} + +static int manager_action(char *action, char *fmt, ...) +{ + struct mansession *s; + char tmp[4096]; + va_list ap; + + s = &session; + fdprintf(s->fd, "Action: %s\r\n", action); + va_start(ap, fmt); + vsnprintf(tmp, sizeof(tmp), fmt, ap); + va_end(ap); + write(s->fd, tmp, strlen(tmp)); + fdprintf(s->fd, "\r\n"); + return 0; +} + +static int show_message(char *title, char *msg) +{ + newtComponent form; + newtComponent label; + newtComponent ok; + struct newtExitStruct es; + + newtCenteredWindow(60,7, title); + + label = newtLabel(4,1,msg); + ok = newtButton(27, 3, "OK"); + form = newtForm(NULL, NULL, 0); + newtFormAddComponents(form, label, ok, NULL); + newtFormRun(form, &es); + newtPopWindow(); + newtFormDestroy(form); + return 0; +} + +static newtComponent showform; +static int show_doing(char *title, char *tmp) +{ + struct newtExitStruct es; + newtComponent label; + showform = newtForm(NULL, NULL, 0); + newtCenteredWindow(70,4, title); + label = newtLabel(3,1,tmp); + newtFormAddComponents(showform,label, NULL); + newtFormSetTimer(showform, 200); + newtFormRun(showform, &es); + return 0; +} + +static int hide_doing() +{ + newtPopWindow(); + newtFormDestroy(showform); + return 0; +} + +static void try_status() +{ + struct message *m; + manager_action("Status", ""); + m = wait_for_response(10000); + if (!m) { + show_message("Status Failed", "Timeout waiting for response"); + } else if (strcasecmp(get_header(m, "Response"), "Success")) { + show_message("Status Failed Failed", get_header(m, "Message")); + } +} + + +static void try_hangup(newtComponent c) +{ + struct ast_chan *chan; + struct message *m; + + chan = newtListboxGetCurrent(c); + if (chan) { + manager_action("Hangup", "Channel: %s\r\n", chan->name); + m = wait_for_response(10000); + if (!m) { + show_message("Hangup Failed", "Timeout waiting for response"); + } else if (strcasecmp(get_header(m, "Response"), "Success")) { + show_message("Hangup Failed", get_header(m, "Message")); + } + } + +} + +static int get_user_input(char *msg, char *buf, int buflen) +{ + newtComponent form; + newtComponent ok; + newtComponent cancel; + newtComponent inpfield; + char *input; + int res = -1; + struct newtExitStruct es; + + newtCenteredWindow(60,7, msg); + + inpfield = newtEntry(5, 2, "", 50, &input, 0); + ok = newtButton(22, 3, "OK"); + cancel = newtButton(32, 3, "Cancel"); + form = newtForm(NULL, NULL, 0); + newtFormAddComponents(form, inpfield, ok, cancel, NULL); + newtFormRun(form, &es); + strncpy(buf, input, buflen - 1); + if (es.u.co == ok) + res = 0; + else + res = -1; + newtPopWindow(); + newtFormDestroy(form); + return res; +} + +static void try_redirect(newtComponent c) +{ + struct ast_chan *chan; + char dest[256]; + struct message *m; + char channame[256]; + char tmp[80]; + char *context; + + chan = newtListboxGetCurrent(c); + if (chan) { + strncpy(channame, chan->name, sizeof(channame) - 1); + snprintf(tmp, sizeof(tmp), "Enter new extension for %s", channame); + if (get_user_input(tmp, dest, sizeof(dest))) + return; + if ((context = strchr(dest, '@'))) { + *context = '\0'; + context++; + manager_action("Redirect", "Channel: %s\r\nContext: %s\r\nExten: %s\r\nPriority: 1\r\n", chan->name,context,dest); + } else { + manager_action("Redirect", "Channel: %s\r\nExten: %s\r\nPriority: 1\r\n", chan->name, dest); + } + m = wait_for_response(10000); + if (!m) { + show_message("Hangup Failed", "Timeout waiting for response"); + } else if (strcasecmp(get_header(m, "Response"), "Success")) { + show_message("Hangup Failed", get_header(m, "Message")); + } + } + +} + +static int manage_calls(char *host) +{ + newtComponent form; + newtComponent quit; + newtComponent hangup; + newtComponent redirect; + newtComponent channels; + struct newtExitStruct es; + char tmp[80]; + + /* If there's one thing you learn from this code, it is this... + Never, ever fly Air France. Their customer service is absolutely + the worst. I've never heard the words "That's not my problem" as + many times as I have from their staff -- It should, without doubt + be their corporate motto if it isn't already. Don't bother giving + them business because you're just a pain in their side and they + will be sure to let you know the first time you speak to them. + + If you ever want to make me happy just tell me that you, too, will + never fly Air France again either (in spite of their excellent + cuisine). */ + snprintf(tmp, sizeof(tmp), "Asterisk Manager at %s", host); + newtCenteredWindow(74, 20, tmp); + form = newtForm(NULL, NULL, 0); + newtFormWatchFd(form, session.fd, NEWT_FD_READ); + newtFormSetTimer(form, 100); + quit = newtButton(62, 16, "Quit"); + redirect = newtButton(35, 16, "Redirect"); + hangup = newtButton(50, 16, "Hangup"); + channels = newtListbox(1,1,14, NEWT_FLAG_SCROLL); + newtFormAddComponents(form, channels, redirect, hangup, quit, NULL); + newtListboxSetWidth(channels, 72); + + show_doing("Getting Status", "Retrieving system status..."); + try_status(); + hide_doing(); + + for(;;) { + newtFormRun(form, &es); + if (has_input(&session) || (es.reason == NEWT_EXIT_FDREADY)) { + if (input_check(&session, NULL)) { + show_message("Disconnected", "Disconnected from remote host"); + break; + } + } else if (es.reason == NEWT_EXIT_COMPONENT) { + if (es.u.co == quit) + break; + if (es.u.co == hangup) { + try_hangup(channels); + } else if (es.u.co == redirect) { + try_redirect(channels); + } + } + rebuild_channels(channels); + } + newtFormDestroy(form); + return 0; +} + +static int login(char *hostname) +{ + newtComponent form; + newtComponent cancel; + newtComponent login; + newtComponent username; + newtComponent password; + newtComponent label; + newtComponent ulabel; + newtComponent plabel; + char *user; + char *pass; + struct message *m; + struct newtExitStruct es; + char tmp[55]; + struct hostent *hp; + int res = -1; + + session.fd = socket(AF_INET, SOCK_STREAM, 0); + if (session.fd < 0) { + snprintf(tmp, sizeof(tmp), "socket() failed: %s\n", strerror(errno)); + show_message("Socket failed", tmp); + return -1; + } + + snprintf(tmp, sizeof(tmp), "Looking up %s\n", hostname); + show_doing("Connecting....", tmp); + + + hp = gethostbyname(hostname); + if (!hp) { + snprintf(tmp, sizeof(tmp), "No such address: %s\n", hostname); + show_message("Host lookup failed", tmp); + return -1; + } + hide_doing(); + snprintf(tmp, sizeof(tmp), "Connecting to %s", hostname); + show_doing("Connecting...", tmp); + + session.sin.sin_family = AF_INET; + session.sin.sin_port = htons(DEFAULT_MANAGER_PORT); + memcpy(&session.sin.sin_addr, hp->h_addr, sizeof(session.sin.sin_addr)); + + if (connect(session.fd, &session.sin, sizeof(session.sin))) { + snprintf(tmp, sizeof(tmp), "%s failed: %s\n", hostname, strerror(errno)); + show_message("Connect Failed", tmp); + return -1; + } + + hide_doing(); + + login = newtButton(5, 6, "Login"); + cancel = newtButton(25, 6, "Cancel"); + newtCenteredWindow(40, 10, "Asterisk Manager Login"); + snprintf(tmp, sizeof(tmp), "Host: %s", hostname); + label = newtLabel(4,1, tmp); + + ulabel = newtLabel(4,2,"Username:"); + plabel = newtLabel(4,3,"Password:"); + + username = newtEntry(14, 2, "", 20, &user, 0); + password = newtEntry(14, 3, "", 20, &pass, NEWT_FLAG_HIDDEN); + + form = newtForm(NULL, NULL, 0); + newtFormAddComponents(form, username, password, login, cancel, label, ulabel, plabel,NULL); + newtFormRun(form, &es); + if (es.reason == NEWT_EXIT_COMPONENT) { + if (es.u.co == login) { + snprintf(tmp, sizeof(tmp), "Logging in '%s'...", user); + show_doing("Logging in", tmp); + manager_action("Login", + "Username: %s\r\n" + "Secret: %s\r\n", + user, pass); + m = wait_for_response(10000); + hide_doing(); + if (m) { + if (!strcasecmp(get_header(m, "Response"), "Success")) { + res = 0; + } else { + show_message("Login Failed", get_header(m, "Message")); + } + } + } + } + newtFormDestroy(form); + return res; +} + +int main(int argc, char *argv[]) +{ + if (argc < 2) { + fprintf(stderr, "Usage: astman \n"); + exit(1); + } + newtInit(); + newtCls(); + newtDrawRootText(0, 0, "Asterisk Manager (C)2002, Linux Support Services, Inc."); + newtPushHelpLine("Welcome to the Asterisk Manager!"); + if (login(argv[1])) { + newtFinished(); + exit(1); + } + manage_calls(argv[1]); + newtFinished(); + return 0; +} -- cgit v1.2.3