bin/fexsrv

   1 #!/usr/bin/perl -T
   2
   3 # fexsrv : web server for F*EX service
   4 #
   5 # Author: Ulli Horlacher <framstag@rus.uni-stuttgart.de>
   6 #
   7
   8 use 5.008;
   9 use Socket;
  10 use IO::Handle;
  11 use Fcntl qw':flock :seek';
  12 use warnings;
  13
  14 BEGIN {
  15   # stunnel workaround
  16   $SIG{CHLD} = "DEFAULT";
  17   $ENV{PERLINIT} = q{
  18     unshift @INC,(getpwuid($<))[7].'/perl';
  19     # web error handler
  20     $SIG{__DIE__} = $SIG{__WARN__} = sub {
  21       my $info = '';
  22       my $url = $ENV{REQUEST_URL}||'';
  23       my @d = localtime time;
  24       my $time = sprintf('%d-%02d-%02d %02d:%02d:%02d',
  25                  $d[5]+1900,$d[4]+1,$d[3],$d[2],$d[1],$d[0]);
  26       if ($admin) {
  27         my $mailto = "mailto:$admin?subject=fex%20bug";
  28         $info = "<h3>send this error to <a href=\"$mailto\">$admin</a></h3>";
  29       }
  30       $_ = join("\n",@_);
  31       chomp;
  32       s/&/&amp;/g;
  33       s/</&lt;/g;
  34       $_ = join("\n",
  35         "<html><body>",
  36         "<h1>INTERNAL ERROR in $0</h1>",
  37         "<pre>\n$_\n</pre>\n<p>",
  38         "$url\n<p>",
  39         "$time\n<p>",
  40         "$info\n<p>",
  41         "</body></html>"
  42       );
  43       $length = length;
  44       unless ($HTTP_HEADER) {
  45         print "HTTP/1.0 200 ERROR\r\n";
  46         print "Content-Type: text/html\r\n";
  47         print "Content-Length: $length\r\n";
  48         print "\r\n";
  49       }
  50       print;
  51       exit 99;
  52     }
  53   };
  54   eval $ENV{PERLINIT};
  55 }
  56
  57 # use BSD::Resource;
  58 # setrlimit(RLIMIT_CPU,999,999) or die "$0: $!\n";
  59
  60 # SSL remote address provided by stunnel
  61 if (@ARGV and $ARGV[0] eq 'stunnel' and $ENV{REMOTE_HOST} =~ /(.+)/) {
  62   $ssl_ra = $1;
  63 }
  64
  65 # KEEP_ALIVE <== callback from CGI
  66 if ($ENV{KEEP_ALIVE}) {
  67   $keep_alive = $ENV{KEEP_ALIVE};
  68 } else {
  69   %ENV = ( PERLINIT => $ENV{PERLINIT} );   # clean environment
  70 }
  71
  72 $ENV{HOME} = (getpwuid($<))[7] or die "no HOME";
  73
  74 # fexsrv MUST be run with full path!
  75 if ($0 =~ m:^(/.+)/bin/fexsrv:) {
  76   $FEXHOME = $1;
  77   $FEXHOME =~ s:/+:/:g;
  78   $FEXHOME =~ s:/$::;
  79   $ENV{FEXHOME} = $FEXHOME;
  80 }
  81
  82 foreach my $lib (
  83   $FEXHOME,
  84   '/usr/local/fex',
  85   '/usr/local/share/fex',
  86   '/usr/share/fex',
  87 ) {
  88   $ENV{FEXLIB} = $FEXLIB = $lib       and last if -f "$lib/fex.pp";
  89   $ENV{FEXLIB} = $FEXLIB = "$lib/lib" and last if -f "$lib/lib/fex.pp";
  90 }
  91
  92 # import from fex.pp
  93 our ($hostname,$debug,$timeout,$max_error,$max_error_handler);
  94 our ($spooldir,@logdir,$docdir,$xkeydir,$lockdir);
  95 our ($force_https,$default_locale,$bs,$MB,$adlm);
  96 our (@locales);
  97
  98 # load common code (local config: $FEXHOME/lib/fex.ph)
  99 require "$FEXLIB/fex.pp" or die "cannot load $FEXLIB/fex.pp - $!\n";
 100
 101 chdir $spooldir or http_die("$0: $spooldir - $!\n");
 102
 103 our $log = 'fexsrv.log';
 104 our $error = 'F*EX ERROR';
 105 our $htmlsource;
 106 our $hid = ''; # header ID
 107 our @log;
 108
 109 $0 = untaint($0);
 110
 111 $ENV{GATEWAY_INTERFACE} = 'CGI/1.1f';
 112 $ENV{SERVER_NAME} = $hostname;
 113 $ENV{REQUEST_METHOD} = '';
 114 $ENV{QUERY_STRING} = '';
 115 $ENV{HTTP_COOKIE} = '';
 116 $ENV{PATH_INFO} = '';
 117 $ENV{RANDOM} = randstring(8);
 118 $ENV{FEATURES} = join(',',qw(
 119   SID CHECKRECIPIENT GROUPS QUOTA FILEID MULTIPOST XKEY FILEQUERY FILESTREAM
 120   JUP NOSTORE AXEL FEXMAIL FILELINK
 121 ));
 122
 123 $port = 0;
 124
 125 # continue session?
 126 if ($keep_alive) {
 127   if ($ENV{HTTP_HOST} =~ /(.+):(.+)/) {
 128     $hostname = $1;
 129     $port = $2;
 130   } else {
 131     $hostname = $ENV{HTTP_HOST};
 132     if ($ENV{PROTO} eq 'https') { $port = 443 }
 133     else                        { $port = 80 }
 134   }
 135   $ra = $ENV{REMOTE_ADDR};
 136   $rh = $ENV{REMOTE_HOST};
 137 }
 138
 139 # new session
 140 else {
 141   my $iaddr;
 142
 143   # HTTPS connect
 144   if ($ssl_ra) {
 145     $ENV{PROTO} = 'https';
 146     $ENV{REMOTE_ADDR} = $ra = $ssl_ra;
 147     if ($ssl_ra =~ /\w:\w/) {
 148       # ($rh) = `host $ssl_ra 2>/dev/null` =~ /name pointer (.+)\.$/;
 149       $^W = 0; eval 'use Socket6'; $^W = 1;
 150       http_error(503) if $@;
 151       $iaddr = inet_pton(AF_INET6,$ssl_ra) and
 152       $rh = gethostbyaddr($iaddr,AF_INET6);
 153     } else {
 154       $rh = gethostbyaddr(inet_aton($ra),AF_INET);
 155     }
 156     $rh ||= '-';
 157     $port = 443;
 158     # print {$log} "X-SSL-Remote-Host: $ssl_ra\n";
 159   }
 160
 161   # HTTP connect
 162   else {
 163     $ENV{PROTO} = 'http';
 164     my $sa = getpeername(STDIN) or die "no network stream on STDIN\n";
 165     if (sockaddr_family($sa) == AF_INET) {
 166       ($ENV{REMOTE_PORT},$iaddr) = sockaddr_in($sa);
 167       $ENV{REMOTE_ADDR} = $ra = inet_ntoa($iaddr);
 168       $rh = gethostbyaddr($iaddr,AF_INET);
 169       ($port) = sockaddr_in(getsockname(STDIN));
 170     } elsif (sockaddr_family($sa) == AF_INET6) {
 171       $^W = 0; eval 'use Socket6'; $^W = 1;
 172       http_error(503) if $@;
 173       ($ENV{REMOTE_PORT},$iaddr) = unpack_sockaddr_in6($sa);
 174       $ENV{REMOTE_ADDR} = $ra = inet_ntop(AF_INET6,$iaddr);
 175       $rh = gethostbyaddr($iaddr,AF_INET6);
 176       ($port) = unpack_sockaddr_in6(getsockname(STDIN));
 177     } else {
 178       die "unknown IP version\n";
 179     }
 180     $port = 80 unless $port;
 181   }
 182
 183   $ENV{REMOTE_HOST} = $rh || '';
 184
 185   $ENV{HTTP_HOST} = ($port == 80 or $port == 443)
 186                   ? $hostname : "$hostname:$port";
 187
 188   $ENV{PORT} = $port;
 189 }
 190
 191 if ($reverse_proxy_ip and $reverse_proxy_ip eq $ra) {
 192   $ENV{FEATURES} =~ s/SID,//;
 193 }
 194
 195 if (@anonymous_upload and ipin($ra,@anonymous_upload)) {
 196   $ENV{FEATURES} .= ',ANONYMOUS';
 197 }
 198
 199 $| = 1;
 200
 201 $SIG{CHLD} = "DEFAULT"; # stunnel workaround
 202
 203 $SIG{ALRM} = sub {
 204   # printf {$log} "\nTIMEOUT %s %s\n",isodate(time),$connect;
 205   if (@log) {
 206     debuglog('TIMEOUT',isodate(time));
 207     fexlog($connect,@log,"TIMEOUT");
 208   }
 209   exit;
 210 };
 211
 212 REQUEST: while (*STDIN) {
 213
 214   if (defined $ENV{REQUESTCOUNT}) { $ENV{REQUESTCOUNT}++ }
 215   else                            { $ENV{REQUESTCOUNT} = 0 }
 216
 217   $connect = sprintf "%s:%s %s %s %s [%s_%s]",
 218                      $keep_alive ? 'CONTINUE' : 'CONNECT',
 219                      $port,
 220                      isodate(time),
 221                      $rh||'-',
 222                      $ra,
 223                      $$,$ENV{REQUESTCOUNT};
 224   $hid = sprintf("%s %s\n",$rh||'-',$ra);
 225
 226   @header = @log = ();
 227   $header = '';
 228
 229   # read complete HTTP header
 230   while (defined ($_ = &getaline)) {
 231     last if /^\s*$/;
 232     $hl += length;
 233     $header .= $_;
 234     s/[\r\n]+$//;
 235     # URL-encode non-printable chars
 236     s/([\x00-\x08\x0E-\x1F\x7F-\x9F])/sprintf "%%%02X",ord($1)/ge;
 237     s/%21/!/g;
 238     if (@header and s/^\s+/ /) {
 239       $header[-1] .= $_;
 240     } else {
 241       push @header,$_;
 242       $header{$1} = $2 if /(.+)\s*:\s*(.+)/;
 243       push @log,$_;
 244     }
 245     if ($hl > $MB) {
 246       fexlog($connect,@log,"OVERRUN");
 247       http_error(413);
 248     }
 249
 250     if (/^(GET \/|X-Forwarded-For|User-Agent)/i) {
 251       $hid .= $_."\n";
 252     }
 253
 254     # reverse-proxy?
 255     if ($reverse_proxy_ip and $reverse_proxy_ip eq $ra and
 256        /^X-Forwarded-For: ([\d.]+)/
 257     ) {
 258       $ENV{REMOTE_ADDR} = $ra = $1;
 259       $ENV{REMOTE_HOST} = $rh = gethostbyaddr(inet_aton($ra),AF_INET) || '';
 260       $ENV{HTTP_HOST} = $hostname;
 261       if ($ENV{PROTO} eq 'https') { $port = 443 }
 262       else                        { $port = 80 }
 263     }
 264   }
 265
 266   exit unless @header;
 267   exit if $header =~ /^\s*$/;
 268
 269   $ENV{HTTP_HEADER} = $header;
 270   debuglog($header);
 271   # http_die("<pre>$header</pre>");
 272
 273   $ENV{'HTTP_HEADER_LENGTH'} = $hl;
 274   $ENV{REQUEST_URI} = $uri = '';
 275   $cgi = '';
 276
 277   # is it a HTTP-request at all?
 278   $request = shift @header;
 279   if ($request !~ /^(GET|HEAD|POST|OPTIONS).*HTTP\/\d\.\d$/i) {
 280     fexlog($connect,$request,"DISCONNECT: no HTTP request");
 281     badlog("no HTTP request: $request");
 282     exit;
 283   }
 284
 285   if ($force_https and $port != 443
 286       and $request =~ /^(GET|HEAD|POST)\s+(.+)\s+(HTTP\/[\d\.]+$)/i) {
 287     $request = $2;
 288     nvt_print(
 289       "HTTP/1.1 301 Moved Permanently",
 290       "Location: https://$hostname$request",
 291       "Content-Length: 0",
 292       ""
 293     );
 294     fexlog($connect,@log);
 295     exit;
 296   }
 297
 298   $request =~ s{^(GET|HEAD|POST) https?://$hostname(:\d+)?}{$1 }i;
 299
 300   if ($request =~ m"^(GET|HEAD) /fop/\w+/") {
 301     # no header inquisition on regular fop request
 302     $header_hook = '';
 303   } else {
 304     &$header_hook($connect,$request,$ra) if $header_hook;
 305   }
 306
 307   unless ($keep_alive) {
 308     if ($request =~ m:(HTTP/1.(\d)): and $2) {
 309       $ENV{KEEP_ALIVE} = $keep_alive = $ra
 310     } else {
 311       $ENV{KEEP_ALIVE} = $keep_alive = '';
 312     }
 313   }
 314
 315   if ($request =~ /^OPTIONS FEX HTTP\/[\d\.]+$/i) {
 316     fexlog($connect,@log);
 317     nvt_print(
 318       "HTTP/1.1 201 OK",
 319       "X-Features: $ENV{FEATURES}",
 320       "X-Timeout: $timeout",
 321       ''
 322     );
 323     next REQUEST if $keep_alive;
 324     exit;
 325   }
 326
 327   if ($request =~ m:^GET /?SID HTTP/[\d\.]+$:i) {
 328     if ($ENV{FEATURES} !~ /\bSID\b/) {
 329       fexlog($connect,@log);
 330       nvt_print(
 331         "HTTP/1.1 501 Not Available",
 332         "Server: fexsrv",
 333         "X-Features: ".$ENV{FEATURES},
 334         "X-Timeout: ".$timeout,
 335         'Content-Length: 0',
 336         ''
 337       );
 338     } else {
 339       $ENV{SID} = randstring(8);
 340       fexlog($connect,@log);
 341       nvt_print(
 342         "HTTP/1.1 201 ".$ENV{SID},
 343         "Server: fexsrv",
 344         "X-Features: ".$ENV{FEATURES},
 345         "X-SID: ".$ENV{SID},
 346         "X-Timeout: ".$timeout,
 347         'Content-Length: 0',
 348         ''
 349       );
 350     }
 351     next REQUEST if $keep_alive;
 352     exit;
 353   }
 354
 355   if ($request =~ /^(GET|HEAD|POST)\s+(.+)\s+(HTTP\/[\d\.]+$)/i) {
 356     $ENV{REQUEST}        = $_;
 357     $ENV{REQUEST_METHOD} = uc($1);
 358     $ENV{REQUEST_URI}    = $uri = $cgi = $2;
 359     $ENV{HTTP_VERSION}   = $protocol = $3;
 360     $ENV{QUERY_STRING}   = $1               if $cgi =~ s/\?(.*)//;
 361     $ENV{PATH_INFO}      = $1               if $cgi =~ m:/.+?(/.+?)(\?|$):;
 362     $ENV{KEEP_ALIVE}     = $keep_alive = '' if $protocol =~ /1\.0/;
 363     $ENV{REQUEST_URL}    = "$ENV{PROTO}://$ENV{HTTP_HOST}$ENV{REQUEST_URI}";
 364     if ($uri =~ /<|%3c/i)  { badchar("&lt;") }
 365     if ($uri =~ />|%3e/i)  { badchar(">") }
 366     if ($uri =~ /\||%7c/i) { badchar("|") }
 367     if ($uri =~ /\\|%5c/i) { badchar("\\") }
 368   }
 369
 370   while ($_ = shift @header) {
 371
 372     # header inquisition!
 373     &$header_hook($connect,$_,$ra) if $header_hook;
 374
 375     # mega stupid "Download Manager" FlashGet
 376     if ($uri =~ m{^/fop/} and m{^Referer: https?://.*\Q$uri$}) {
 377       fexlog($connect,@log,"NULL: FlashGet");
 378       debuglog("NULL: FlashGet");
 379       exec qw'cat /dev/zero' or sleep 30;
 380       exit;
 381     }
 382
 383     if ($header =~ /\nRange:/ and /^User-Agent: (FDM)/) {
 384       disconnect($1,"499 Download Manager $1 Not Supported",30);
 385     }
 386
 387     if (/^User-Agent: (Java\/[\d\.]+)/) {
 388       disconnect($1,"499 User-Agent $1 Not Supported",30);
 389     }
 390
 391     if (/^Range:.*,/) {
 392       disconnect("Range a,b","416 Requested Range Not Satisfiable",30);
 393     }
 394     if (/^Range:.*(\d+)-(\d+)/) {
 395       if ($1 > $2) {
 396         disconnect("Range a>b","416 Requested Range Not Satisfiable",0);
 397       }
 398       if (($header{'User-Agent'}||'') !~ /$adlm/ ) {
 399         disconnect("Range a-b","416 Requested Range Not Satisfiable",30);
 400       }
 401     }
 402
 403     if (/^Range:.*\d+-$/ and $hid) {
 404       my $lock = untaint($lockdir.'/'.md5_hex($hid));
 405       if (open $lock,'+>>',$lock) {
 406         if (flock($lock,LOCK_EX|LOCK_NB)) {
 407           seek $lock,0,0;
 408           truncate $lock,0;
 409           print {$lock} $hid;
 410         } else {
 411           disconnect(
 412             "multiple Range request",
 413             "400 Multiple Requests Not Allowed",
 414             10,
 415           );
 416         }
 417       }
 418     }
 419
 420     # client signed int bug
 421     if (/^Range:.*-\d+-/) {
 422       disconnect("Range -a-","416 Requested Range Not Satisfiable",0);
 423     }
 424
 425 #    if (/^Range:/ and $protocol =~ /1\.0/) {
 426 #      &$header_hook($connect,$_,$ra) while ($header_hook and $_ = shift @header);
 427 #      fexlog($connect,@log,"DISCONNECT: Range + HTTP/1.0");
 428 #      debuglog("DISCONNECT: Range + HTTP/1.0");
 429 #      http_error(416);
 430 #      exit;
 431 #    }
 432
 433     if (/^Connection:\s*close/i) {
 434       $ENV{KEEP_ALIVE} = $keep_alive = '';
 435     }
 436
 437     # HTTP header ==> environment variables
 438     if (/^([\w\-]+):\s*(.+)/s) {
 439       $http_var = $1;
 440       $http_val = $2;
 441       $http_var =~ s/-/_/g;
 442       $http_var = uc($http_var);
 443       $http_val =~ s/^\s+//;
 444       $http_val =~ s/\s+$//;
 445       if ($http_var =~ /^X_(FEX_\w+|CONTENT_LENGTH)$/) {
 446         $http_var = $1;
 447       } else {
 448         $http_val =~ s/\s+/ /g;
 449         if ($http_var =~ /^HTTP_(HOST|VERSION)$/) {
 450           $http_var = 'X-'.$http_var;
 451         } elsif ($http_var !~ /^CONTENT_/) {
 452           $http_var = 'HTTP_'.$http_var;
 453         }
 454       }
 455       $ENV{$http_var} = $http_val;
 456     }
 457   }
 458
 459   # multiline header inquisition
 460   &$header_hook($connect,$header,$ra) if $header_hook;
 461
 462   exit unless $cgi;
 463
 464   # extra download request? (request http://fexserver//xkey)
 465   if ($cgi =~ m{^//([^/]+)$}) {
 466     my $xkey = $1;
 467     my $dkey;
 468     if ($xkey =~ /^afex_\d/) {
 469       $dkey = readlink "$xkeydir/$xkey" and $dkey =~ s/^\.\.\///;
 470     } else {
 471       $dkey = readlink "$xkeydir/$xkey/dkey" and $dkey .= "/$xkey";
 472     }
 473     if ($dkey) {
 474       # xkey downloads are only one time possible - besides afex
 475       if ($xkey !~ /^afex_\d/) {
 476         unlink "$xkeydir/$xkey/xkey";
 477         unlink "$xkeydir/$xkey";
 478       }
 479       nvt_print(
 480         "HTTP/1.1 301 Moved Permanently",
 481         "Location: $ENV{PROTO}://$ENV{HTTP_HOST}/fop/$dkey",
 482         "Content-Length: 0",
 483         ""
 484       );
 485       fexlog($connect,@log);
 486       exit;
 487     }
 488     fexlog($connect,@log);
 489     http_error(404);
 490     exit;
 491   }
 492
 493   # get locale
 494   if (($ENV{QUERY_STRING} =~ /.*locale=([\w-]+)/ or
 495        $ENV{HTTP_COOKIE}  =~ /.*locale=([\w-]+)/)
 496       and -d "$FEXHOME/locale/$1") {
 497     $ENV{LOCALE} = $locale = $1;
 498   } else {
 499     $ENV{LOCALE} = $locale = $default_locale;
 500   }
 501
 502   # check for name based virtual host
 503   $vhost = vhost($ENV{'HTTP_HOST'});
 504
 505   if ($debug) {
 506     debuglog("ENV:\n");
 507     foreach $var (sort keys %ENV) {
 508       if (defined($ENV{$var})) {
 509         debuglog(sprintf "  %s = >%s<\n",$var,$ENV{$var});
 510       }
 511     }
 512     debuglog("\n");
 513   }
 514
 515   # locale definitions in fex.ph?
 516   if (@locales) {
 517     if (@locales == 1) {
 518       $locale = $locales[0];
 519     } elsif (not grep /^$locale$/,@locales) {
 520       $locale = $default_locale;
 521     }
 522   }
 523
 524   # prepare document file name
 525   if ($ENV{REQUEST_METHOD} =~ /^GET|HEAD$/) {
 526     if (%redirect) {
 527       foreach my $r (keys %redirect) {
 528         if ($uri =~ /^\Q$r/) {
 529           redirect($uri,$r);
 530           exit;
 531         }
 532       }
 533     }
 534     $doc = untaint($uri);
 535     $doc =~ s/%([\dA-F]{2})/unpack("a",pack("H2",$1))/ge;
 536     $doc =~ m:/\.\./: and http_error(403);
 537     $doc =~ s:^/+::;
 538     $doc =~ s/\?.*//;
 539     if ($locale and $locale ne 'english' and -e "$docdir/locale/$locale/$doc") {
 540       $doc = "$docdir/locale/$locale/$doc";
 541     } else {
 542       $doc = "$docdir/$doc";
 543     }
 544   }
 545
 546   # CGI or document request?
 547   if ($cgi =~ s:^/+::) {
 548     $cgi =~ s:/.*::;
 549     unless ($cgi) {
 550       my $login = "$FEXHOME/cgi-bin/login";
 551       if (-x $login) {
 552         $cgi = untaint(readlink($login) || $login);
 553         $cgi =~ s:.*/::;
 554       }
 555     }
 556
 557     $ENV{SCRIPT_NAME} = $cgi;
 558
 559     # locale CGIs? (vhost comes already with own FEXLIB)
 560     if ($locale and $locale ne 'english'
 561         and -f "$FEXHOME/locale/$locale/cgi-bin/$cgi") {
 562       $ENV{SCRIPT_FILENAME} = $cgi = "$FEXHOME/locale/$locale/cgi-bin/$cgi";
 563       $ENV{FEXLIB} = $FEXLIB = "$FEXHOME/locale/$locale/lib" unless $vhost;
 564     } else {
 565       $ENV{SCRIPT_FILENAME} = $cgi = "$FEXHOME/cgi-bin/$cgi";
 566       $ENV{FEXLIB} = $FEXLIB = "$FEXHOME/lib" unless $vhost;
 567     }
 568
 569     $status = '';
 570     if (-x $cgi and -f $cgi) {
 571       if (@forbidden_hosts and ipin($ra,@forbidden_hosts)) {
 572         fexlog($connect,@log,"FORBIDDEN");
 573         http_error(403);
 574       }
 575       unlink "$spooldir/.error/$ra";
 576       # push @log,"DEBUG: locale=$locale locales=(@locales)";
 577       fexlog($connect,@log,"EXEC $cgi");
 578       eval { local $^W = 0; exec $cgi };
 579       $status = "$! or bad interpreter";
 580       fexlog($connect,@log,"FAILED to exec $cgi : $status");
 581       http_error(555);
 582     } else {
 583       if (-f "$doc/.htindex") {
 584         require "$FEXLIB/dop";
 585         fexlog($connect,@log);
 586
 587         showindex($doc);
 588         STDOUT->flush;
 589         next REQUEST if $keep_alive;
 590         exit;
 591       }
 592       if (-f "$doc/index.html") {
 593         # force redirect if trailing / is missing
 594         # this is mandatory for processing further HTTP request!
 595         if ($doc !~ m{/$}) {
 596           nvt_print(
 597             "HTTP/1.1 301 Moved Permanently",
 598             "Location: $ENV{REQUEST_URL}/",
 599             "Content-Length: 0",
 600             ""
 601           );
 602           fexlog($connect,@log);
 603           next REQUEST if $keep_alive;
 604           exit;
 605         }
 606         $doc .= '/index.html';
 607         $doc =~ s:/+:/:g;
 608       }
 609       $doc =~ s/#.*//; # ignore HTML anchors (stupid msnbot)
 610
 611       # special request for F*EX UNIX clients
 612       if ($ENV{SCRIPT_NAME} eq 'xx.tar') {
 613         bintar(qw'fexget fexsend xx zz ezz');
 614       }
 615       if ($ENV{SCRIPT_NAME} eq 'sex.tar') {
 616         bintar(qw'sexsend sexget sexxx');
 617       }
 618       if ($ENV{SCRIPT_NAME} eq 'afex.tar') {
 619         bintar(qw'afex asex fexget fexsend sexsend sexget');
 620       }
 621       if ($ENV{SCRIPT_NAME} eq 'afs.tar') {
 622         bintar(qw'afex asex fexget fexsend xx sexsend sexget sexxx zz ezz');
 623       }
 624       # URL ends with ".html!" or ".html?!"
 625       if ($doc =~ s/(\.html)!$/$1/ or
 626           $doc =~ /\.html$/ and $ENV{'QUERY_STRING'} eq '!')
 627       { $htmlsource = $doc } else { $htmlsource = '' }
 628
 629       if (-f $doc
 630           or $doc =~ /(.+)\.(tar|tgz|zip)$/ and lstat("$1.stream")
 631           or $doc =~ /(.+)\.tgz$/           and -f "$1.tar"
 632           or $doc =~ /(.+)\.gz$/            and -f $1)
 633       {
 634         unlink "$spooldir/.error/$ra";
 635         delete $ENV{SCRIPT_FILENAME};
 636         $ENV{DOCUMENT_FILENAME} = $doc;
 637         require "$FEXLIB/dop";
 638         fexlog($connect,@log);
 639         dop($doc);
 640         STDOUT->flush;
 641         next REQUEST if $keep_alive;
 642         exit;
 643       } elsif ($uri eq '/bunny') {
 644         fexlog($connect,@log);
 645         nvt_print(
 646           'HTTP/1.1 200 OK',
 647           'Server: fexsrv',
 648           "Content-Type: text/plain",
 649           '',
 650           '=:3',
 651         );
 652         exit;
 653       } elsif ($uri eq '/camel') {
 654         fexlog($connect,@log);
 655         nvt_print(
 656           'HTTP/1.1 200 OK',
 657           'Server: fexsrv',
 658           "Content-Type: text/plain",
 659           '',
 660         );
 661         local $/;
 662         print unpack('u',<DATA>);
 663         exit;
 664       } elsif (-e $cgi) {
 665         $status = 'not executable';
 666       }
 667
 668     }
 669
 670   }
 671
 672   # neither document nor CGI ==> error
 673
 674   if ($status) {
 675     fexlog($connect,@log,"FAILED to exec $cgi : $status");
 676     http_error(666);
 677   } else {
 678     fexlog($connect,@log,"UNKNOWN URL");
 679     badlog($request);
 680     http_error(404);
 681   }
 682   exit;
 683 }
 684
 685
 686 # read one text line unbuffered from STDIN
 687 sub getaline {
 688   my $line = '';
 689   my $n = 0;
 690   my $c;
 691
 692   alarm($timeout);
 693
 694   # must use sysread to avoid perl line buffering
 695   # (later exec would destroy line buffer)
 696   while (sysread STDIN,$c,1) {
 697     $line .= $c;
 698     $n++;
 699     last if $c eq "\n";
 700     if ($n > $bs) {
 701       fexlog($connect,@log,$line,"OVERRUN");
 702       http_error(413);
 703     }
 704   }
 705
 706   alarm(0);
 707
 708   return $line;
 709 }
 710
 711
 712 sub fexlog {
 713   my @log = @_;
 714
 715   foreach my $logdir (@logdir) {
 716     if (open $log,'>>',"$logdir/$log") {
 717       flock $log,LOCK_EX;
 718       seek $log,0,SEEK_END;
 719       print {$log} "\n",join("\n",@log),"\n";
 720       close $log;
 721     } else {
 722       http_die("$0: cannot write to $logdir/$log - $!\n");
 723     }
 724   }
 725 }
 726
 727
 728 sub badchar {
 729   my $bc = shift;
 730
 731   fexlog($connect,@log,"DISCONNECT: bad characters in URL");
 732   debuglog("DISCONNECT: bad characters in URL $uri");
 733   badlog($request);
 734   http_die("\"$bc\" is not allowed in URL");
 735 }
 736
 737
 738 sub bintar {
 739   my $tmpdir = "$FEXHOME/tmp";
 740   my $fs = "$ENV{PROTO}://$ENV{HTTP_HOST}";
 741
 742   if (chdir "$FEXHOME/bin") {
 743     fexlog($connect,@log);
 744     chdir $fstb if $fstb;
 745     mkdir $tmpdir;
 746     foreach my $f (@_) {
 747       copy($f,"$tmpdir/$f","s#fexserver = ''#fexserver = '$fs'#");
 748       chmod 0755,"$tmpdir/$f";
 749     }
 750     chdir $tmpdir or http_die("internal error: $tmpdir - $!");
 751     my $tar = `tar cf - @_ 2>/dev/null`;
 752     unlink @_;
 753     nvt_print(
 754       'HTTP/1.1 200 OK',
 755       'Server: fexsrv',
 756       "Content-Length: ".length($tar),
 757       "Content-Type: application/x-tar",
 758       '',
 759     );
 760     print $tar;
 761     exit;
 762   }
 763 }
 764
 765
 766 sub http_error {
 767   my $error = shift;
 768   my $URL = $ENV{REQUEST_URL}||'';
 769   my $URI = $ENV{REQUEST_URI}||'';
 770
 771   if ($error eq 400) {
 772     http_error_header("400 Bad Request");
 773     nvt_print("Your request $URL is not acceptable.");
 774   } elsif ($error eq 403) {
 775     http_error_header("403 Forbidden");
 776     nvt_print("You have no permission to request $URL");
 777   } elsif ($error eq 404) {
 778     http_error_header("404 Not Found");
 779     nvt_print("The requested URI $URI was not found on this server.");
 780   } elsif ($error eq 413) {
 781     http_error_header("413 Payload Too Large");
 782     nvt_print("Your HTTP header is too large.");
 783   } elsif ($error eq 416) {
 784     http_error_header("416 Requested Range Not Satisfiable");
 785   } elsif ($error eq 503) {
 786     http_error_header("503 Service Unavailable");
 787     # nvt_print("No Perl ipv6 support on this server.");
 788   } else {
 789     http_error_header("555 Unknown Error");
 790     nvt_print("The requested URL $URL produced an internal error.");
 791   }
 792   nvt_print(
 793     "<hr>",
 794     "<address>fexsrv at <a href=\"/index.html\">$hostname:$port</a></address>",
 795     "</body></html>",
 796   );
 797   exit;
 798 }
 799
 800
 801 sub disconnect {
 802   my $info = shift;
 803   my $error = shift;
 804   my $wait = shift||0;
 805
 806   # &$header_hook($connect,$_,$ra) while ($header_hook and $_ = shift @header);
 807   fexlog($connect,@log,"DISCONNECT: $info");
 808   debuglog("DISCONNECT: $info");
 809   errorlog("$ENV{REQUEST_URI} ==> $error");
 810   badlog("$ENV{REQUEST_URI} ==> $error ($info)");
 811
 812   sleep $wait;
 813   nvt_print("HTTP/1.0 $error");
 814   exit;
 815 }
 816
 817
 818 sub http_error_header {
 819   my $error = shift;
 820   my $uri = $ENV{REQUEST_URI};
 821
 822   errorlog("$uri ==> $error") if $uri;
 823   nvt_print(
 824     "HTTP/1.1 $error",
 825     "Connection: close",
 826     "Content-Type: text/html; charset=iso-8859-1",
 827     "",
 828     '<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">',
 829     "<html>",
 830     "<head><title>$error</title></head>",
 831     "<body>",
 832     "<h1>$error</h1>",
 833   );
 834 }
 835
 836
 837 sub redirect {
 838   my $uri = shift;
 839   my $r = shift;
 840   my $rr = $redirect{$r};
 841   my $newurl;
 842
 843   $uri =~ s/\Q$r//;
 844
 845   if ($rr =~ s/^!//) {
 846     $newurl = $rr.$uri;
 847     nvt_print(
 848       "HTTP/1.1 301 Moved Permanently",
 849       "Location: $newurl",
 850       "Content-Length: 0",
 851       ""
 852     );
 853   } else {
 854     if ($rr =~ /^http/) {
 855       $newurl = $rr.$uri;
 856     } else {
 857       $newurl = "$ENV{PROTO}://$ENV{HTTP_HOST}$rr$uri";
 858     }
 859
 860     http_header("200 OK");
 861     print html_header("$hostname page has moved");
 862     pq(qq(
 863       '<h3>Please use new URL: <a href="$newurl">$newurl</a></h3>'
 864       '</body></html>'
 865     ));
 866   }
 867   if ($rr =~ /^http/) {
 868     exit;
 869   } else {
 870     &reexec;
 871   }
 872 }
 873
 874
 875 sub badlog {
 876   my $request = shift;
 877   my @n;
 878   my $ed = "$spooldir/.error";
 879   local $_;
 880
 881   if (@ignore_error) {
 882     foreach (@ignore_error) {
 883       return if $request =~ /$_/;
 884     }
 885   }
 886
 887   if ($ra and $max_error and $max_error_handler) {
 888     mkdir($ed) unless -d $ed;
 889
 890     if (open $ra,"+>>$ed/$ra") {
 891       flock($ra,LOCK_EX);
 892       seek $ra,0,SEEK_SET;
 893       @n = <$ra>;
 894       printf {$ra} "%s %s\n",isodate(time),$request;
 895       close $ra;
 896       &$max_error_handler($ra,@n) if scalar(@n) > $max_error;
 897     }
 898   }
 899 }
 900
 901
 902 __END__
 903 M("`@("`@("`@("`@("`@("`@("`@("`@("`@("`@("`@("PM)R(G+5P*("`@
 904 M("`@("`@("`@("`@("`@("`@("`@("]@8&`M+B`@(&!<("`@("Q=+B`@("`@
 905 M("`@("`@("`@("`@("`@("`L+BY?"B`@("`@("`@("`@("`@("`@("`@("`@
 906 M+&`@("`@(&`B+B`@72X@("`@(&`N("`@("`@("`@("`@("`@7U]?+BY>(&!?
 907 M)V`B(B(*("`@("`@("`@("`@("`@("`@("`@("`I("`@("`@("`G+"TG+2T@
 908 M+B`@("!@+B`@("`@(%]?7RPN+2<@("XN("T@("`G("TP("Y?"B`@("`@("`@
 909 M("`@+"X@("`@("`@("`@?%]?+"Y?("!?("`N+5\@("!<("`\("Y@(B<G)V`L
 910 M7R`@("`@("`@+2!?("TN("`@("`@("<M+BX*("`@("`@("`@('P@(&8M+2TM
 911 M+2TM+2<O("`@("!@)RTM+BXL("`@("`M("`@("`@("`@("T@("`@("`@("`@
 912 M("`@("`G("XL7U\N7%\N)PH@("`@("`@("`@8"TM)R<G)R<G8"TM7"`@("`@
 913 M("`@("`@("!@)RTM+B`@("`@("`@("`@("`@("`@("`@7RPN)RTM)R<*("`@
 914 M("`@("`@("`@("`@("`@("`@("\@("`@("`@("`@("`@("`@("!@8#T@+2`@
 915 M+2`@("!?+2`@7RXM)PH@("`@("`@("`@("`@("`@("`@("!\("`@("`@("`@
 916 M("`@("`@("`@("`@("!?)V`@("`G)U\M+2<*("`@("`@("`@("`@("`@("`@
 917 M("`@?"`@("`@("`@("`@("`@("`@("`O("`@?"T]+BXM+2<*("`@("`@("`@
 918 M("`@("`@(%\@("`@("<N("`@("`@("`N7R`@(%\N+2=@)R`@(&!?7PH@("`@
 919 M("`@("`@("`@("PG("`N("PG("TL3%]?+WP@(%P@8"<G+&\N("`@+5\@("`@
 920 M)V`M+2X*("`@("`@("`@("`@("`@+BPG(BT@("`O("`@("`@("`@?"`@8'8@
 921 M+R`N("PG8"TM+BXG7R`G+@H@("`@("`@("`@("`@("`@("TN+E\L)R`@("`@
 922 M('P@("!\("`@)RTM+E]@("!?+R`@('P@("!\"B`@("`@("`@("`@("`@("`@
 923 M("`@("`@("`@("=@8"<@6R`@("`@("`@("=@)R`@("`L+RXN+PH@("`@("`@
 924 M("`@("`@("`@("`@("`@("`@('P@("`M+B<@("`@("`@("`@("`@("Y;("`@
 925 M+PH@("`@("`@("`@("`@("`@("`@(%]?7U]?7RX@("`L.E]?7U]?7U]?7U]?
 926 M7U]?7RQ@("PG"B`@("TM+2TM+2TM+2TM+2TM+2TM+2TM+2TM+2T@+2(M+2TM
 927 M+2TM+2TM+2TM+2TM+2T]+0H@+2TM+2TM+2TM+2TM+2TM+2TM+2TM+2TM+2TM
 928 6+2TM+2TM+2TM+2TM+2TM+2TM+2TM"@``