wvdial/wvdialmon.cc

   1 // copyright: (C) 2000 by SuSE GmbH
   2 // author: arvin@suse.de
   3 // WvStreamsified by Patrick Patterson (ppatters@nit.ca)
   4
   5 #include <stdio.h>
   6 #include <stdlib.h>
   7 #include <unistd.h>
   8 #include <stdlib.h>
   9 #include <errno.h>
  10 #include <string.h>
  11 #include <regex.h>
  12 #include <netdb.h>
  13 #include <net/route.h>
  14 #include <sys/socket.h>
  15 #include <sys/types.h>
  16 #include <sys/stat.h>
  17 #include <fcntl.h>
  18
  19 #include "wvdialmon.h"
  20
  21
  22
  23 WvDialMon::WvDialMon()
  24     : log( "WvDial", WvLog::Debug ),
  25       err( log.split( WvLog::Error ) ),
  26       buffer("")
  27 {
  28     // executename = WvString( "" );
  29     connectmsg = WvString( "Connected... Press Ctrl-C to disconnect\n" );
  30
  31     // usleep_time = 1000;
  32     do_check_dfr = 0;
  33     do_check_dns = 0;
  34
  35     route_fd = (FILE *) 0;
  36
  37     buffer.setsize(100);
  38
  39     regcomp( &rx_status, "status *= *", REG_EXTENDED );
  40     regcomp( &rx_quote, "\\\"[^\\\"]+\\\"", REG_EXTENDED );
  41     regcomp( &rx_namesrv, "nameserver *[0-9]+.[0-9]+.[0-9]+.[0-9]+", REG_EXTENDED );
  42
  43     reset();
  44 }
  45
  46
  47
  48 WvDialMon::~WvDialMon()
  49 {
  50     regfree( &rx_status );
  51     regfree( &rx_quote );
  52     regfree( &rx_namesrv );
  53 }
  54
  55
  56 void WvDialMon::setdnstests (WvString dnstest1, WvString dnstest2)
  57 {
  58     WvDialMon::dnstest1 = dnstest1;
  59     WvDialMon::dnstest2 = dnstest2;
  60 }
  61
  62
  63 void WvDialMon::reset()
  64 {
  65     _auth_failed = 0;
  66 }
  67
  68 const int WvDialMon::auth_failed()
  69 {
  70     return _auth_failed;
  71 }
  72
  73
  74 int WvDialMon::get_quotedtext(char *dest, const char *line)
  75 {
  76     regmatch_t rm[1];
  77
  78     if( regexec( &rx_quote, line, 1, &rm[0], 0 ) == REG_NOMATCH )
  79     {
  80         err("***** no quoted text found in `%s' *****\n", line );
  81         return 0;
  82     }
  83
  84     int s = rm[0].rm_so, e = rm[0].rm_eo;
  85     strncpy (dest, &line[s], e-s);
  86     dest[e-s] = '\0';
  87
  88     return 1;
  89 }
  90
  91 char *WvDialMon::analyse_line(const char *line)
  92 {
  93     regmatch_t rm[1];
  94
  95     if (line == NULL )
  96         return NULL;
  97
  98     // PAP stuff
  99     //
 100     if (strstr(line, "AuthReq") != NULL)
 101         log("Authentication (PAP) started\n");
 102
 103     if (strstr(line, "AuthAck") != NULL)
 104         log("Authentication (PAP) successful\n");
 105
 106     if (strstr(line, "AuthNak") != NULL) {
 107         log("Authentication (PAP) failed");
 108
 109         char buf[strlen(line)];
 110         if( get_quotedtext( buf, line ) )
 111             log(" (Message: %s )\n", buf);
 112
 113         _auth_failed = 1;
 114     }
 115
 116
 117     // CHAP stuff
 118     //
 119     if (strstr(line, "CHAP Challenge") != NULL)
 120         log("Authentication (CHAP) started\n");
 121
 122     if (strstr(line, "CHAP Success") != NULL)
 123         log("Authentication (CHAP) successful\n");
 124
 125     if (strstr(line, "CHAP Failure") != NULL) {
 126         log("Authentication (CHAP) failed");
 127
 128         char buf[strlen(line)];
 129         if( get_quotedtext( buf, line ) )
 130             log(" (Message: %s )\n", buf);
 131
 132         _auth_failed = 1;
 133     }
 134
 135
 136     // IP stuff
 137     //
 138     if (!strncmp(line, "local  IP address", 17)     ||
 139         !strncmp(line, "remote IP address", 17)     ||
 140         !strncmp(line, "primary   DNS address", 20) ||
 141         !strncmp(line, "secondary DNS address", 20)   )
 142     {
 143         log("%s\n",line);
 144     }
 145
 146     // Script stuff
 147     //
 148     if (strncmp(line, "Script", 6) == 0)
 149     {
 150         if (strstr(line, "/etc/ppp/ip-up") != NULL && strstr(line, "finished") != NULL)
 151         {
 152             if( regexec( &rx_status, line, 1, &rm[0], 0 ) == 0 )
 153             {
 154                 const char *p = &line[ rm[0].rm_eo ];
 155
 156                 // err("***** status is `%s' *****\n", p2 );
 157
 158                 if (strcmp( p, "0x0") == 0)
 159                 {
 160
 161                     log("Script /etc/ppp/ip-up run successful\n");
 162
 163                     if( do_check_dfr )
 164                     {
 165                         if( check_dfr() )
 166                             log( "Default route Ok.\n" );
 167                         else
 168                             log( "Default route failure.\n" );
 169                     }
 170
 171                     if( do_check_dns )
 172                     {
 173                         if( check_dns() )
 174                             log( "Nameserver (DNS) Ok.\n" );
 175                         else
 176                             log( "Nameserver (DNS) failure, the connection may not work.\n" );
 177                     }
 178
 179                     log( "%s\n", connectmsg );
 180
 181                     //    execute whatever the user wants to
 182                     //
 183                     //            if( executename.len() > 0 ) {
 184                     //
 185                     //              fflush(stdout);
 186                     //              fflush(stderr);
 187                     //
 188                     //              pid_t pid = fork();
 189                     //
 190                     //              if( pid == (pid_t) 0 ) { // we are the child
 191                     //
 192                     //                int devnullr = open("/dev/null",O_RDONLY,0);
 193                     //                dup2(devnullr, fileno(stdin));
 194                     //                close(devnullr);
 195                     //
 196                     //                int devnullw = open("/dev/null",O_WRONLY,0);
 197                     //                dup2(devnullw, fileno(stdout));
 198                     //                dup2(devnullw, fileno(stderr));
 199                     //                close(devnullw);
 200                     //                fflush(stdout);
 201                     //                fflush(stderr);
 202                     //
 203                     //                for( int tty = 3; tty < 256; tty++ )
 204                     //                  close(tty);
 205                     //
 206                     //                usleep( usleep_time );
 207                     //
 208                     //                // executename = Netscape -remote "reload()", macht probleme
 209                     //                // wenn mehrere netscapes auf dem xserver laufen (dann
 210                     //                // empfängt zufällig einer die message)
 211                     //
 212                     //                const char *new_argv[4];
 213                     //                new_argv[0] = "sh";
 214                     //                new_argv[1] = "-c";
 215                     //                new_argv[2] = executename;
 216                     //                new_argv[3] = NULL;
 217                     //
 218                     //                execv( "/bin/sh", (char *const *) new_argv );
 219                     //
 220                     //                fprintf( stderr, "exec failed: %s\n", strerror(errno) );
 221                     //              }
 222                     //
 223                     //      if( pid < (pid_t) 0 ) // the fork failed
 224                     //        fprintf( stderr, "error: can't fork child process\n" );
 225                     //      else
 226                     //        output( "Started `", executename, "' successfully\n" );
 227                     //
 228                     //    }
 229
 230                 }
 231                 else
 232                 {
 233                     log("Script /etc/ppp/ip-up failed (return value: %s )\n", p);
 234                 }
 235
 236             }
 237             else
 238             {
 239                 // fprintf( stderr, "***** no status found *****\n" );
 240             }
 241
 242         }
 243
 244         if (strstr(line, "/etc/ppp/ip-down") != NULL && strstr(line, "started") != NULL)
 245             log("Script /etc/ppp/ip-down started\n");
 246     }
 247
 248
 249     // TermReq stuff
 250     //
 251     if (strstr(line, "LCP TermReq") != NULL)
 252     {
 253         log("Terminate Request");
 254
 255         char buf[strlen(line)];
 256         if( get_quotedtext( buf, line ) )
 257             log(" (Message: %s )\n", buf);
 258     }
 259
 260
 261     // connect time stuff
 262     //
 263     if (strncmp(line, "Connect time", 12) == 0)
 264         log("%s\n",line);
 265
 266
 267     // interface stuff
 268     //
 269     if (strncmp(line, "Using interface", 15) == 0)
 270         log("%s\n", line);
 271
 272     // terminate stuff
 273     //
 274     if( strncmp(line,"Terminating", 11 ) == 0 )
 275         log("%s\n",line);
 276
 277
 278     return buffer.edit();
 279 }
 280
 281
 282
 283 /********* taken from pppd ************/
 284
 285 #define KVERSION(j,n,p) ((j)*1000000 + (n)*1000 + (p))
 286
 287 #define SET_SA_FAMILY(addr, family)                     \
 288         memset ((char *) &(addr), '\0', sizeof(addr));  \
 289     addr.sa_family = (family);
 290
 291 #define SIN_ADDR(x)     (((struct sockaddr_in *) (&(x)))->sin_addr.s_addr)
 292
 293 #define ROUTE_MAX_COLS  12
 294
 295 /********************************************************************
 296  *
 297  * close_route_table - close the interface to the route table
 298  */
 299
 300 void WvDialMon::close_route_table ()
 301 {
 302     if (route_fd != (FILE *) 0)
 303     {
 304         fclose (route_fd);
 305         route_fd = (FILE *) 0;
 306     }
 307 }
 308
 309 /********************************************************************
 310  *
 311  * open_route_table - open the interface to the route table
 312  */
 313
 314 static char route_delims[] = " \t\n";
 315
 316 int WvDialMon::open_route_table ()
 317 {
 318     char path[] = "/proc/net/route";
 319
 320     close_route_table();
 321
 322     route_fd = fopen (path, "r");
 323     if (route_fd == NULL) {
 324         log( "can't read %s\n", path );
 325         return 0;
 326     }
 327
 328     route_dev_col = 0;          /* default to usual columns */
 329     route_dest_col = 1;
 330     route_gw_col = 2;
 331     route_flags_col = 3;
 332     route_mask_col = 7;
 333     route_num_cols = 8;
 334
 335     /* parse header line */
 336     if (fgets(route_buffer, sizeof(route_buffer), route_fd) != 0)
 337     {
 338         char *p = route_buffer, *q;
 339         int col;
 340         for (col = 0; col < ROUTE_MAX_COLS; ++col)
 341         {
 342             int used = 1;
 343             if ((q = strtok(p, route_delims)) == 0)
 344                 break;
 345             if (strcasecmp(q, "iface") == 0)
 346                 route_dev_col = col;
 347             else if (strcasecmp(q, "destination") == 0)
 348                 route_dest_col = col;
 349             else if (strcasecmp(q, "gateway") == 0)
 350                 route_gw_col = col;
 351             else if (strcasecmp(q, "flags") == 0)
 352                 route_flags_col = col;
 353             else if (strcasecmp(q, "mask") == 0)
 354                 route_mask_col = col;
 355             else
 356                 used = 0;
 357             if (used && col >= route_num_cols)
 358                 route_num_cols = col + 1;
 359             p = NULL;
 360         }
 361     }
 362
 363     return 1;
 364 }
 365
 366 /********************************************************************
 367  *
 368  * read_route_table - read the next entry from the route table
 369  */
 370
 371 int WvDialMon::read_route_table(struct rtentry *rt)
 372 {
 373     char *cols[ROUTE_MAX_COLS], *p;
 374     int col;
 375
 376     memset (rt, '\0', sizeof (struct rtentry));
 377
 378     if (fgets (route_buffer, sizeof (route_buffer), route_fd) == (char *) 0)
 379         return 0;
 380
 381     p = route_buffer;
 382     for (col = 0; col < route_num_cols; ++col) {
 383         cols[col] = strtok(p, route_delims);
 384         if (cols[col] == NULL)
 385             return 0;           /* didn't get enough columns */
 386         p = NULL;
 387     }
 388
 389     SET_SA_FAMILY (rt->rt_dst,     AF_INET);
 390     SET_SA_FAMILY (rt->rt_gateway, AF_INET);
 391
 392     SIN_ADDR(rt->rt_dst) = strtoul(cols[route_dest_col], NULL, 16);
 393     SIN_ADDR(rt->rt_gateway) = strtoul(cols[route_gw_col], NULL, 16);
 394     SIN_ADDR(rt->rt_genmask) = strtoul(cols[route_mask_col], NULL, 16);
 395
 396     rt->rt_flags = (short) strtoul(cols[route_flags_col], NULL, 16);
 397     rt->rt_dev   = cols[route_dev_col];
 398
 399     return 1;
 400 }
 401
 402 /********************************************************************
 403  *
 404  * defaultroute_exists - determine if there is a default route
 405  */
 406
 407 int WvDialMon::defaultroute_exists (struct rtentry *rt)
 408 {
 409     int result = 0;
 410
 411     if (!open_route_table())
 412         return 0;
 413
 414     while (read_route_table(rt) != 0)
 415     {
 416         if ((rt->rt_flags & RTF_UP) == 0)
 417             continue;
 418
 419         if (kernel_version > KVERSION(2,1,0) && SIN_ADDR(rt->rt_genmask) != 0)
 420             continue;
 421         if (SIN_ADDR(rt->rt_dst) == 0L)
 422         {
 423             result = 1;
 424             break;
 425         }
 426     }
 427
 428     close_route_table();
 429     return result;
 430 }
 431
 432 int WvDialMon::check_dfr()
 433 {
 434     struct rtentry def_rt;
 435
 436     if( !defaultroute_exists( &def_rt ) )
 437         return 0;
 438
 439     // FIXME: check if the gateway is set correct
 440     //
 441     return 1;
 442 }
 443
 444 int WvDialMon::check_dns_name( const char *name )
 445 {
 446     struct hostent *hp;
 447     hp = gethostbyname( name );
 448     if( hp == NULL )
 449     {
 450         log( "warning, can't find address for `%s`\n", name );
 451         return 0;
 452     }
 453
 454     // err("***** official name for `%s' is `%s' *****\n", name, hp->h_name );
 455     //
 456     return 1;
 457 }
 458
 459 int WvDialMon::check_dns()
 460 {
 461   char name[] = "/etc/resolv.conf";
 462
 463     FILE *fin = fopen( name, "r" );
 464     if( fin == NULL ) {
 465         log( "warning, can't read `%s`\n", name );
 466         return 0;
 467     }
 468
 469     const int size = 100;
 470     char line[size];
 471
 472     regmatch_t rm[1];
 473     int found_namesrv = 0;
 474
 475     while( fgets( line, size, fin ) != NULL )
 476     {
 477         if( line[0] == '\n' || line[0] == '#' )
 478             continue;
 479
 480         if( line[ strlen(line)-1 ] == '\n' )
 481             line[ strlen(line)-1 ] = '\0';
 482
 483         if( regexec( &rx_namesrv, line, 1, &rm[0], 0 ) == 0 )
 484         {
 485             found_namesrv = 1;
 486             break;
 487         }
 488
 489     }
 490
 491     fclose( fin );
 492
 493     if( !found_namesrv )
 494     {
 495         log( "warning, no nameserver found `%s`\n",name);
 496         return 0;
 497     }
 498
 499     if (!check_dns_name ((const char* ) dnstest1) || !check_dns_name ((const char* ) dnstest2))
 500     {
 501         log( "warning, address lookup does not work\n" );
 502         return 0;
 503     }
 504
 505     return 1;
 506 }
 507