From 181cec4348da40331b3e8ab365732c025ec149b2 Mon Sep 17 00:00:00 2001 From: Reinhard Tartler Date: Wed, 27 Apr 2011 19:24:15 +0200 Subject: Import upstream version 0.11.0~svn1143 --- plugin_asterisk.c | 303 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 303 insertions(+) create mode 100644 plugin_asterisk.c (limited to 'plugin_asterisk.c') diff --git a/plugin_asterisk.c b/plugin_asterisk.c new file mode 100644 index 0000000..79b03b7 --- /dev/null +++ b/plugin_asterisk.c @@ -0,0 +1,303 @@ +/* $Id: plugin_asterisk.c 1036 2009-07-18 03:10:52Z michael $ + * $URL: https://ssl.bulix.org/svn/lcd4linux/trunk/plugin_asterisk.c $ + * + * plugin for asterisk + * + * Copyright (C) 2003 Michael Reinelt + * Copyright (C) 2004, 2005, 2006, 2007 The LCD4Linux Team + * + * This file is part of LCD4Linux. + * + * LCD4Linux is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2, or (at your option) + * any later version. + * + * LCD4Linux is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * + */ + +/* + * exported functions: + * + * int plugin_init_sample (void) + * adds various functions + * + */ + + +/* define the include files you need */ +#include "config.h" +#include +#include +#include +#include +#include +#include "debug.h" +#include "plugin.h" + +#ifdef WITH_DMALLOC +#include +#endif + +struct Line { + char Channel[25]; /* Zap Channel */ + char EndPoint[25]; + unsigned char active; +}; + +static char *rtrim(char *string, char junk) +{ + char *original = string + strlen(string); + while (*--original == junk); + *(original + 1) = '\0'; + + return string; +} + +static void zapstatus(RESULT * result, RESULT * arg1) +{ + FILE *infile; + int skipline = 0; // Skip the first in the file, it throws off the detection + char line[100], *SipLoc, Channel[25], Location[25], State[9], Application[25], EndPoint[8], Ret[50]; + int i = 0, ChannelInt = 0, ZapLine = 0; + struct Line Lines[32]; // Setup 32 lines, ZAP 1-32 (memory is cheap) + + ZapLine = R2N(arg1); + + // Set all the lines status's default to inactive + for (i = 0; i < 32; i++) { + strcpy(Lines[i].Channel, "ZAP/"); + Lines[i].Channel[4] = (char) (i + 49); + Lines[i].Channel[5] = '\0'; + Lines[i].active = 0; + } + + system("touch /tmp/asterisk.state"); // Touch the file in it's naughty place + system("chmod 744 /tmp/asterisk.state"); + system("asterisk -rx \"show channels\" > /tmp/asterisk.state"); // Crappy CLI way to do it + + infile = fopen("/tmp/asterisk.state", "r"); + + for (i = 0; i < 100; i++) { + line[i] = ' '; + } + line[99] = '\0'; + + while (fgets(line, 100, infile) != NULL) { + if (strstr(line, "Zap") != NULL) { + for (i = 0; i < (int) strlen(line); i++) { + if (i < 20) { + Channel[i] = line[i]; + } else if (i < 42) { + Location[i - 21] = line[i]; + } else if (i < 50) { + State[i - 42] = line[i]; + } else { + Application[i - 50] = line[i]; + } + } + strncpy(Channel, Channel, 7); + Channel[7] = '\0'; + strcpy(Location, rtrim(Location, ' ')); + State[4] = '\0'; + memcpy(EndPoint, Application + 13, 7); + EndPoint[7] = '\0'; + + if (strstr(Application, "Bridged Call") != NULL) { + // Subtract 48 from the character value to get the int + // value. Subtract one more because arrays start at 0. + ChannelInt = (int) (Channel[4]) - 49; + strcpy(Lines[ChannelInt].Channel, Channel); + strncpy(Lines[ChannelInt].EndPoint, EndPoint, 8); + Lines[ChannelInt].active = 1; + } else { + SipLoc = strstr(Application, "SIP"); + if (SipLoc != NULL) { + strncpy(EndPoint, SipLoc, 7); + } else { + EndPoint[0] = '\0'; + } + ChannelInt = (int) (Channel[4]) - 49; + strcpy(Lines[ChannelInt].Channel, Channel); + Lines[ChannelInt].active = 1; + } + } else { + if (strlen(line) > 54 && skipline > 1) { + for (i = 55; i < 88; i++) { + if (i < 80) { + Channel[i - 55] = line[i]; + } else { + EndPoint[i - 80] = line[i]; + } + } + strncpy(Channel, rtrim(Channel, ' '), 5); + strncpy(EndPoint, rtrim(EndPoint, ' '), 7); + + ChannelInt = (int) (Channel[4]) - 49; + strcpy(Lines[ChannelInt].Channel, Channel); + strcpy(Lines[ChannelInt].EndPoint, EndPoint); + Lines[ChannelInt].active = 1; + } + } + skipline += 1; + } + fclose(infile); + + ZapLine -= 1; + if (ZapLine < 0 || ZapLine > 31) { + memset(Ret, ' ', 50); + Ret[0] = '\0'; + strcat(Ret, "Invalid ZAP #"); + SetResult(&result, R_STRING, &Ret); + } else if (Lines[ZapLine].active == 1) { + memset(Ret, ' ', 50); + Ret[0] = '\0'; + strcat(Ret, Lines[ZapLine].Channel); + strcat(Ret, " -> "); + strncat(Ret, Lines[ZapLine].EndPoint, 8); + SetResult(&result, R_STRING, &Ret); + } else { + memset(Ret, ' ', 50); + Ret[0] = '\0'; + strcat(Ret, Lines[ZapLine].Channel); + strcat(Ret, ": inactive"); + SetResult(&result, R_STRING, &Ret); + } + return; +} + +static void corecalls(RESULT * result) +{ + FILE *infile; + char line[100]; + int calls; + + system("asterisk -rx 'core show channels' > /tmp/asterisk.calls"); + + infile = fopen("/tmp/asterisk.state", "r"); + line[0] = '\0'; + while (fgets(line, 100, infile) != NULL) { + if (strstr(line, "active calls") != NULL) { + break; + } + } + fclose(infile); + + if (line[0] != '\0') { + sscanf(line, "%d active calls", &calls); + } else { + calls = 0; + } + + SetResult(&result, R_NUMBER, &calls); + return; +} + +int sipinfo(int type) +{ + FILE *infile; + char line[100]; + int peers, online; + + system("asterisk -rx 'sip show peers' > /tmp/asterisk.sip"); + + infile = fopen("/tmp/asterisk.sip", "r"); + line[0] = '\0'; + while (fgets(line, 100, infile) != NULL) { + } // Get the last line + fclose(infile); + + if (line[0] != '\0') { + sscanf(line, "%d sip peers [Monitored: %d online,", &peers, &online); + } else { + peers = 0; + online = 0; + } + + return (type == 1) ? peers : online; +} + +static void sippeers(RESULT * result) +{ + int peers; + peers = sipinfo(1); + SetResult(&result, R_NUMBER, &peers); + return; +} + +static void siponline(RESULT * result) +{ + int online; + online = sipinfo(2); + SetResult(&result, R_NUMBER, &online); + return; +} + +static void uptime(RESULT * result) +{ + FILE *infile; + char line[100], *tok; + int fields[5], toknum = 0, num, s = 0; + + fields[0] = fields[1] = fields[2] = fields[3] = fields[4] = 0; + + system("asterisk -rx 'core show uptime' > /tmp/asterisk.uptime"); + + infile = fopen("/tmp/asterisk.uptime", "r"); + line[0] = '\0'; + while (fgets(line, 100, infile) != NULL) { + if (strstr(line, "System uptime") != NULL) { + break; + } + } + fclose(infile); + + if (line[0] != '\0') { + for (tok = strtok(line, " "); tok != NULL; tok = strtok(NULL, " ")) { + toknum++; + if (toknum == 3 || toknum == 5 || toknum == 7 || toknum == 9 || toknum == 11) { + sscanf(tok, "%d", &num); + } else if (toknum == 4 || toknum == 6 || toknum == 8 || toknum == 10 || toknum == 12) { + if (strstr(tok, "weeks") != NULL || (strstr(tok, "week") != NULL)) { + fields[4] = num; + } else if (strstr(tok, "days") != NULL || (strstr(tok, "day") != NULL)) { + fields[3] = num; + } else if (strstr(tok, "hours") != NULL || (strstr(tok, "hour") != NULL)) { + fields[2] = num; + } else if (strstr(tok, "minutes") != NULL || (strstr(tok, "minute") != NULL)) { + fields[1] = num; + } else { + fields[0] = num; + } + } + } + s = (fields[4] * 604800) + (fields[3] * 86400) + (fields[2] * 3600) + (fields[1] * 60) + fields[0]; + } + + SetResult(&result, R_NUMBER, &s); + return; +} + +int plugin_init_asterisk(void) +{ + AddFunction("asterisk::zapstatus", 1, zapstatus); + AddFunction("asterisk::corecalls", 0, corecalls); + AddFunction("asterisk::sippeers", 0, sippeers); + AddFunction("asterisk::siponline", 0, siponline); + AddFunction("asterisk::uptime", 0, uptime); + return 0; +} + +void plugin_exit_asterisk(void) +{ + /* free any allocated memory */ + /* close filedescriptors */ +} -- cgit v1.2.3