From 7d4fcb78e2e42738e1bcef4da00ad17909c3817b Mon Sep 17 00:00:00 2001 From: nicowallmeier <> Date: Wed, 18 Feb 2004 14:45:43 +0000 Subject: [lcd4linux @ 2004-02-18 14:45:42 by nicowallmeier] Imon/Telmon plugin ported --- plugin_imon.c | 428 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 428 insertions(+) create mode 100755 plugin_imon.c (limited to 'plugin_imon.c') 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 + * + * 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 +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include +#include +#include /* decl of inet_addr() */ +#include + +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 -- cgit v1.2.3