aboutsummaryrefslogtreecommitdiffstats
path: root/plugin_asterisk.c
diff options
context:
space:
mode:
Diffstat (limited to 'plugin_asterisk.c')
-rw-r--r--plugin_asterisk.c303
1 files changed, 303 insertions, 0 deletions
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 <michael@reinelt.co.at>
+ * Copyright (C) 2004, 2005, 2006, 2007 The LCD4Linux Team <lcd4linux-devel@users.sourceforge.net>
+ *
+ * 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 <string.h>
+#include <stdlib.h>
+#include <string.h>
+#include <ctype.h>
+#include <stdio.h>
+#include "debug.h"
+#include "plugin.h"
+
+#ifdef WITH_DMALLOC
+#include <dmalloc.h>
+#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 */
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-09 16:52:03 +0000