[lcd4linux @ 2004-02-18 14:45:42 by nicowallmeier]

Imon/Telmon plugin ported

3 files changed, 435 insertions, 1 deletions

diff --git a/Makefile.am b/Makefile.am
index b76b57f..d5aad06 100644
--- a/Makefile.am
+++ b/Makefile.am
@@ -46,6 +46,7 @@ plugin_netdev.c             \
 plugin_ppp.c                \
 plugin_dvb.c                \
 plugin_i2c_sensors.c        \
+plugin_imon.c               \
 plugin_xmms.c               
 
 #liblcd4linux_la_DEPENDENCIES = @DRIVERS@
diff --git a/plugin.c b/plugin.c
index 4591b6c..7e1c36b 100644
--- a/plugin.c
+++ b/plugin.c
@@ -1,4 +1,4 @@
-/* $Id: plugin.c,v 1.18 2004/02/10 07:42:35 reinelt Exp $
+/* $Id: plugin.c,v 1.19 2004/02/18 14:45:42 nicowallmeier Exp $
  *
  * plugin handler for the Evaluator
  *
@@ -22,6 +22,9 @@
  *
  *
  * $Log: plugin.c,v $
+ * Revision 1.19  2004/02/18 14:45:42  nicowallmeier
+ * Imon/Telmon plugin ported
+ *
  * Revision 1.18  2004/02/10 07:42:35  reinelt
  * cut off all old-style files which are no longer used with NextGeneration
  *
@@ -145,6 +148,7 @@ int plugin_init_ppp (void);
 int plugin_init_dvb (void);
 int plugin_init_i2c_sensors (void);
 int plugin_init_xmms (void);
+int plugin_init_imon(void);
 
 
 int plugin_init (void)
@@ -162,6 +166,7 @@ int plugin_init (void)
   plugin_init_dvb();
   plugin_init_i2c_sensors();
   plugin_init_xmms();
+  plugin_init_imon();
   
   return 0;
 }
diff --git a/plugin_imon.c b/plugin_imon.c
new file mode 100755
index 0000000..fc49a96
--- /dev/null
+++ b/plugin_imon.c
@@ -0,0 +1,428 @@
+/* $Id: plugin_imon.c,v 1.1 2004/02/18 14:45:43 nicowallmeier Exp $

+ *

+ * imond/telmond data processing

+ *

+ * Copyright 2003 Nico Wallmeier <nico.wallmeier@post.rwth-aachen.de>

+ *

+ * 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.

+ *

+ *

+ * $Log: plugin_imon.c,v $
+ * Revision 1.1  2004/02/18 14:45:43  nicowallmeier
+ * Imon/Telmon plugin ported
+ *

+ */

+ 

+#include "config.h"

+#include "debug.h"

+#include "plugin.h"

+#include "cfg.h"

+#include "hash.h"

+

+#include <stdio.h>

+#include <string.h>

+#include <unistd.h>

+#include <stdlib.h>

+#include <sys/types.h>

+#include <sys/fcntl.h>

+#include <sys/ioctl.h>

+#include <sys/time.h>

+#include <linux/errno.h>

+#include <sys/stat.h>

+#include <string.h>

+#include <time.h>

+

+#include <netdb.h>

+#include <netinet/in.h>

+#include <netinet/tcp.h>

+#include <arpa/inet.h>                          /* decl of inet_addr()      */

+#include <sys/socket.h>

+

+static HASH TELMON = { 0, };

+static HASH IMON = { 0, };

+

+static char thost[256];

+static int tport;

+static char phoneb[256];

+

+static char ihost[256];

+static char ipass[256];

+static int iport;

+

+static int fd=0;

+static int err=0;

+

+/*----------------------------------------------------------------------------

+ *  service_connect (host_name, port)       - connect to tcp-service

+ *----------------------------------------------------------------------------

+ */

+static int service_connect (char * host_name, int port){

+    struct sockaddr_in  addr;

+    struct hostent *    host_p;

+    int                 fd;

+    int                 opt = 1;

+

+    (void) memset ((char *) &addr, 0, sizeof (addr));

+

+    if ((addr.sin_addr.s_addr = inet_addr ((char *) host_name)) == INADDR_NONE)

+    {

+        host_p = gethostbyname (host_name);

+

+        if (! host_p)

+        {

+            error ("%s: host not found\n", host_name);

+            return (-1);

+        }

+

+        (void) memcpy ((char *) (&addr.sin_addr), host_p->h_addr,

+                        host_p->h_length);

+    }

+

+    addr.sin_family  = AF_INET;

+    addr.sin_port    = htons ((unsigned short) port);

+

+    if ((fd = socket (AF_INET, SOCK_STREAM, 0)) < 0)

+    {                                           /* open socket              */

+        perror ("socket");

+        return (-1);

+    }

+    

+    (void) setsockopt (fd, IPPROTO_TCP, TCP_NODELAY,

+                       (char *) &opt, sizeof (opt));

+

+    if (connect (fd, (struct sockaddr *) &addr, sizeof (addr)) != 0)

+    {

+        (void) close (fd);

+        perror (host_name);

+        return (-1);

+    }

+

+    return (fd);

+} /* service_connect (char * host_name, int port) */

+

+/*----------------------------------------------------------------------------

+ *  send_command (int fd, char * str)       - send command to imond

+ *----------------------------------------------------------------------------

+ */

+static void

+send_command (int fd, char * str)

+{

+    char    buf[256];

+    int     len = strlen (str);

+

+    sprintf (buf, "%s\r\n", str);

+    write (fd, buf, len + 2);

+

+    return;

+} /* send_command (int fd, char * str) */

+

+

+/*----------------------------------------------------------------------------

+ *  get_answer (int fd)                     - get answer from imond

+ *----------------------------------------------------------------------------

+ */

+static char *

+get_answer (int fd)

+{

+    static char buf[8192];

+    int         len;

+

+    len = read (fd, buf, 8192);

+

+    if (len <= 0)

+    {

+        return ((char *) NULL);

+    }

+

+    while (len > 1 && (buf[len - 1] == '\n' || buf[len - 1] == '\r'))

+    {

+        buf[len - 1] = '\0';

+        len--;

+    }

+

+    if (! strncmp (buf, "OK ", 3))                      /* OK xxxx          */

+    {

+        return (buf + 3);

+    }

+    else if (len > 2 && ! strcmp (buf + len - 2, "OK"))

+    {

+        *(buf + len - 2) = '\0';

+        return (buf);

+    }

+    else if (len == 2 && ! strcmp (buf + len - 2, "OK"))

+    {

+        return (buf);

+    }

+

+    return ((char *) NULL);                             /* ERR xxxx         */

+} /* get_answer (int fd) */

+

+/*----------------------------------------------------------------------------

+ *  get_value (char * cmd)         - send command, get value

+ *----------------------------------------------------------------------------

+ */

+static char *

+get_value (char * cmd)

+{

+    char *  answer;

+

+    send_command (fd, cmd);

+

+    answer = get_answer (fd);

+

+    if (answer)

+    {

+        return (answer);

+    }

+

+    return ("");

+} /* get_value (char * cmd, int arg) */

+

+static void phonebook(char *number){

+  FILE *  fp;

+  char line[256];

+  

+  fp = fopen (phoneb, "r");

+  

+  if (! fp) return;

+  

+  while (fgets (line, 128, fp)){

+  	if (*line == '#') continue;

+  	if (!strncmp(line,number,strlen(number))){

+  	  char *komma=strchr(line,',');

+  	  char *beginn=strchr(line,'=');

+  	  if (!beginn) return;

+  	  while (strrchr(line,'\r')) strrchr(line,'\r')[0]='\0';

+  	  while (strrchr(line,'\n')) strrchr(line,'\n')[0]='\0';

+  	  if (komma) komma[0]='\0';

+  	  strcpy(number,beginn+1);

+  	  break;

+  	}  	

+  }

+  

+  fclose(fp);

+}

+

+

+static int parse_telmon(){

+ static int telmond_fd=-2;

+ static char oldanswer[128];

+ int age;

+   

+ // reread every 1 sec only

+ age=hash_age(&TELMON, NULL, NULL);

+ if (age>0 && age<=1000) return 0;

+

+ if (telmond_fd != -1){

+  char    telbuf[128];

+

+  telmond_fd = service_connect (thost, tport);

+  if (telmond_fd >= 0){

+   int l = read (telmond_fd, telbuf, 127);

+   if ((l > 0) && (strcmp(telbuf,oldanswer))){

+	char date[11]; 

+	char time[11];

+	char number[256];

+	char msn[256];

+	sscanf(telbuf,"%s %s %s %s",date,time,number,msn);

+	hash_set (&TELMON, "time", time);

+	date[4]='\0';

+	date[7]='\0';

+	snprintf(time, sizeof(time), "%s.%s.%s",date+8,date+5,date);

+	hash_set (&TELMON, "number", number);

+	hash_set (&TELMON, "msn", msn);

+	hash_set (&TELMON, "date", time);

+	phonebook(number);

+	phonebook(msn);

+	hash_set (&TELMON, "name", number);

+	hash_set (&TELMON, "msnname", msn);

+   }

+   close (telmond_fd);

+   strcpy(oldanswer,telbuf);

+  }

+ }

+ return 0;

+}

+

+static void my_telmon (RESULT *result, RESULT *arg1){

+ char *val=NULL;

+ if (parse_telmon()<0) {

+  SetResult(&result, R_STRING, ""); 

+  return;

+ }

+  

+ val=hash_get(&TELMON, R2S(arg1));

+ if (val==NULL) val="";

+ SetResult(&result, R_STRING, val); 

+}

+

+void init(){

+ if (fd!=0) return;

+ 

+ fd=service_connect(ihost,iport);

+

+ if (fd<0){

+  err++;

+ } else if ((ipass!=NULL) && (*ipass!='\0')) { // Passwort senden

+  char buf[40];

+  snprintf(buf,sizeof(buf),"pass %s",ipass);

+  send_command(fd,buf);

+  get_answer(fd); 

+ }

+}

+

+static int parse_imon(char *cmd){

+ // reread every half sec only

+ int age=hash_age(&IMON, cmd, NULL);

+ if (age>0 && age<=500) return 0;

+

+ init(); // establish connection

+

+ if (err) return -1;

+ 

+ hash_set (&IMON, cmd , get_value(cmd));

+ 

+ return 0;

+}

+

+static void my_imon_version (RESULT *result){

+ char *val;

+ // read only ones

+ int age=hash_age(&IMON, "version", NULL);

+ if (age<0){

+  char *s;

+  init();

+  if (err){

+   SetResult(&result, R_STRING, ""); 

+   return;

+  }

+  s=get_value("version");

+  for (;;){ // interne Versionsnummer killen

+   if (s[0]==' '){

+    s=s+1;

+    break;

+   }

+   s=s+1;		

+  }

+  hash_set (&IMON, "version", s);

+ }

+	

+ val=hash_get(&IMON, "version");

+ if (val==NULL) val="";

+ SetResult(&result, R_STRING, val); 

+}

+

+static int parse_imon_rates(char *channel){

+ char buf[128],in[25],out[25];

+ char *s;

+ int age;

+  

+ snprintf(buf,sizeof(buf),"rate %s in",channel);

+ 

+ // reread every half sec only

+ age=hash_age(&IMON, buf, NULL);

+ if (age>0 && age<=500) return 0;

+

+ init(); // establish connection

+

+ if (err) return -1;

+

+ snprintf(buf, sizeof(buf), "rate %s", channel);

+ s=get_value(buf);

+ 

+ if (sscanf(s,"%s %s",in, out)!=2) return -1;

+

+ snprintf(buf, sizeof(buf), "rate %s in", channel);

+ hash_set (&IMON, buf , in);

+ snprintf(buf, sizeof(buf), "rate %s out", channel);

+ hash_set (&IMON, buf , out);

+ 

+ return 0;

+}

+

+

+static void my_imon_rates (RESULT *result, RESULT *arg1, RESULT *arg2){

+ char *val;

+ char buf[128];

+ 

+ if (parse_imon_rates(R2S(arg1))<0) {

+  SetResult(&result, R_STRING, ""); 

+  return;

+ }

+ 

+ snprintf(buf,sizeof(buf),"rate %s %s",R2S(arg1),R2S(arg2));

+

+ val=hash_get(&IMON, buf);

+ if (val==NULL) val="";

+ SetResult(&result, R_STRING, val); 

+}

+

+static void my_imon (RESULT *result, RESULT *arg1){

+ char *val=NULL,*cmd=R2S(arg1);

+ 

+ if (parse_imon(cmd)<0) {

+  SetResult(&result, R_STRING, ""); 

+  return;

+ }

+  

+ val=hash_get(&IMON, cmd);

+ if (val==NULL) val="";

+ SetResult(&result, R_STRING, val); 

+}

+

+int plugin_init_imon (void){

+ char telmon='\1',imon='\1';	

+

+ char *s=cfg_get ("Telmon", "Host","127.0.0.1");

+ if (*s=='\0') {

+  error ("[Telmon] no 'Host' entry in %s", cfg_source());

+  telmon='\0';

+ } 

+ strcpy(thost,s);

+  

+ if ((telmon=='\01') && (cfg_number("Telmon", "Port",5001,1,65536,&tport)<0)){

+  error ("[Telmon] no valid port definition");

+  telmon='\0';	

+ }

+ 

+ s=cfg_get ("Telmon", "Phonebook","/etc/phonebook");

+ strcpy(phoneb,s);

+ 

+ s=cfg_get ("Imon", "Host", "127.0.0.1");

+ if (*s=='\0') {

+  error ("[Imon] no 'Host' entry in %s", cfg_source());

+  imon='\0';

+ }

+ strcpy(ihost,s); 

+ 

+ if ((imon=='\01') && (cfg_number("Imon", "Port",5000,1,65536,&iport)<0)){

+  error ("[Imon] no valid port definition");

+  imon='\0';	

+ }

+ 

+ s=cfg_get ("Imon", "Pass", "");

+ strcpy(ipass,s);

+	

+ if (telmon=='\1') AddFunction ("telmon", 1, my_telmon);

+ if (imon=='\1'){

+  AddFunction ("imon", 1, my_imon);

+  AddFunction ("version", 0, my_imon_version);

+  AddFunction ("rates", 2, my_imon_rates);

+ }

+

+ return 0;

+}
\ No newline at end of file