File:  [LON-CAPA] / loncom / lonnet / perl / lonnet.pm
Revision 1.30: download - view: text, annotated - select for diffs
Wed Sep 6 14:25:17 2000 UTC (23 years, 11 months ago) by www
Branches: MAIN
CVS tags: HEAD
Access control course level

    1: # The LearningOnline Network
    2: # TCP networking package
    3: #
    4: # Functions for use by content handlers:
    5: #
    6: # plaintext(short)   : plain text explanation of short term
    7: # fileembstyle(ext)  : embed style in page for file extension
    8: # filedescription(ext) : descriptor text for file extension
    9: # allowed(short,url) : returns codes for allowed actions 
   10: #                      F: full access
   11: #                      U,I,K: authentication modes (cxx only)
   12: #                      '': forbidden
   13: #                      1: user needs to choose course
   14: #                      2: browse allowed
   15: # definerole(rolename,sys,dom,cou) : define a custom role rolename
   16: #                      set priviledges in format of lonTabs/roles.tab for
   17: #                      system, domain and course level, 
   18: # assignrole(udom,uname,url,role,end,start) : give a role to a user for the
   19: #                      level given by url. Optional start and end dates
   20: #                      (leave empty string or zero for "no date") 
   21: # assigncustomrole (udom,uname,url,rdom,rnam,rolename,end,start) : give a
   22: #                      custom role to a user for the level given by url.
   23: #                      Specify name and domain of role author, and role name
   24: # revokerole (udom,uname,url,role) : Revoke a role for url
   25: # revokecustomrole (udom,uname,url,rdom,rnam,rolename) : Revoke a custom role
   26: # appenv(hash)       : adds hash to session environment
   27: # store(hash)        : stores hash permanently for this url
   28: # restore            : returns hash for this url
   29: # eget(namesp,array) : returns hash with keys from array filled in from namesp
   30: # get(namesp,array)  : returns hash with keys from array filled in from namesp
   31: # del(namesp,array)  : deletes keys out of arry from namesp
   32: # put(namesp,hash)   : stores hash in namesp
   33: # dump(namesp)       : dumps the complete namespace into a hash
   34: # ssi(url,hash)      : does a complete request cycle on url to localhost, posts
   35: #                      hash
   36: # repcopy(filename)  : replicate file
   37: # dirlist(url)       : gets a directory listing
   38: # condval(index)     : value of condition index based on state
   39: # varval(name)       : value of a variable
   40: # refreshstate()     : refresh the state information string 
   41: #
   42: # 6/1/99,6/2,6/10,6/11,6/12,6/14,6/26,6/28,6/29,6/30,
   43: # 7/1,7/2,7/9,7/10,7/12,7/14,7/15,7/19,
   44: # 11/8,11/16,11/18,11/22,11/23,12/22,
   45: # 01/06,01/13,02/24,02/28,02/29,
   46: # 03/01,03/02,03/06,03/07,03/13,
   47: # 04/05,05/29,05/31,06/01,
   48: # 06/05,06/26 Gerd Kortemeyer
   49: # 06/26 Ben Tyszka
   50: # 06/30,07/15,07/17,07/18,07/20,07/21,07/22,07/25 Gerd Kortemeyer
   51: # 08/14 Ben Tyszka
   52: # 08/22,08/28,08/31,09/01,09/02,09/04,09/05 Gerd Kortemeyer
   53: 
   54: package Apache::lonnet;
   55: 
   56: use strict;
   57: use Apache::File;
   58: use LWP::UserAgent();
   59: use HTTP::Headers;
   60: use vars 
   61: qw(%perlvar %hostname %homecache %spareid %hostdom %libserv %pr %prp %fe %fd $readit);
   62: use IO::Socket;
   63: use Apache::Constants qw(:common :http);
   64: 
   65: # --------------------------------------------------------------------- Logging
   66: 
   67: sub logthis {
   68:     my $message=shift;
   69:     my $execdir=$perlvar{'lonDaemons'};
   70:     my $now=time;
   71:     my $local=localtime($now);
   72:     my $fh=Apache::File->new(">>$execdir/logs/lonnet.log");
   73:     print $fh "$local ($$): $message\n";
   74:     return 1;
   75: }
   76: 
   77: sub logperm {
   78:     my $message=shift;
   79:     my $execdir=$perlvar{'lonDaemons'};
   80:     my $now=time;
   81:     my $local=localtime($now);
   82:     my $fh=Apache::File->new(">>$execdir/logs/lonnet.perm.log");
   83:     print $fh "$now:$message:$local\n";
   84:     return 1;
   85: }
   86: 
   87: # -------------------------------------------------- Non-critical communication
   88: sub subreply {
   89:     my ($cmd,$server)=@_;
   90:     my $peerfile="$perlvar{'lonSockDir'}/$server";
   91:     my $client=IO::Socket::UNIX->new(Peer    =>"$peerfile",
   92:                                      Type    => SOCK_STREAM,
   93:                                      Timeout => 10)
   94:        or return "con_lost";
   95:     print $client "$cmd\n";
   96:     my $answer=<$client>;
   97:     if (!$answer) { $answer="con_lost"; }
   98:     chomp($answer);
   99:     return $answer;
  100: }
  101: 
  102: sub reply {
  103:     my ($cmd,$server)=@_;
  104:     my $answer=subreply($cmd,$server);
  105:     if ($answer eq 'con_lost') { $answer=subreply($cmd,$server); }
  106:     if (($answer=~/^error:/) || ($answer=~/^refused/) || 
  107:         ($answer=~/^rejected/)) {
  108:        &logthis("<font color=blue>WARNING:".
  109:                 " $cmd to $server returned $answer</font>");
  110:     }
  111:     return $answer;
  112: }
  113: 
  114: # ----------------------------------------------------------- Send USR1 to lonc
  115: 
  116: sub reconlonc {
  117:     my $peerfile=shift;
  118:     &logthis("Trying to reconnect for $peerfile");
  119:     my $loncfile="$perlvar{'lonDaemons'}/logs/lonc.pid";
  120:     if (my $fh=Apache::File->new("$loncfile")) {
  121: 	my $loncpid=<$fh>;
  122:         chomp($loncpid);
  123:         if (kill 0 => $loncpid) {
  124: 	    &logthis("lonc at pid $loncpid responding, sending USR1");
  125:             kill USR1 => $loncpid;
  126:             sleep 1;
  127:             if (-e "$peerfile") { return; }
  128:             &logthis("$peerfile still not there, give it another try");
  129:             sleep 5;
  130:             if (-e "$peerfile") { return; }
  131:             &logthis(
  132:   "<font color=blue>WARNING: $peerfile still not there, giving up</font>");
  133:         } else {
  134: 	    &logthis(
  135:                "<font color=blue>WARNING:".
  136:                " lonc at pid $loncpid not responding, giving up</font>");
  137:         }
  138:     } else {
  139:      &logthis('<font color=blue>WARNING: lonc not running, giving up</font>');
  140:     }
  141: }
  142: 
  143: # ------------------------------------------------------ Critical communication
  144: 
  145: sub critical {
  146:     my ($cmd,$server)=@_;
  147:     my $answer=reply($cmd,$server);
  148:     if ($answer eq 'con_lost') {
  149:         my $pingreply=reply('ping',$server);
  150: 	&reconlonc("$perlvar{'lonSockDir'}/$server");
  151:         my $pongreply=reply('pong',$server);
  152:         &logthis("Ping/Pong for $server: $pingreply/$pongreply");
  153:         $answer=reply($cmd,$server);
  154:         if ($answer eq 'con_lost') {
  155:             my $now=time;
  156:             my $middlename=$cmd;
  157:             $middlename=substr($middlename,0,16);
  158:             $middlename=~s/\W//g;
  159:             my $dfilename=
  160:              "$perlvar{'lonSockDir'}/delayed/$now.$middlename.$server";
  161:             {
  162:              my $dfh;
  163:              if ($dfh=Apache::File->new(">$dfilename")) {
  164:                 print $dfh "$cmd\n";
  165: 	     }
  166:             }
  167:             sleep 2;
  168:             my $wcmd='';
  169:             {
  170: 	     my $dfh;
  171:              if ($dfh=Apache::File->new("$dfilename")) {
  172:                 $wcmd=<$dfh>;
  173: 	     }
  174:             }
  175:             chomp($wcmd);
  176:             if ($wcmd eq $cmd) {
  177: 		&logthis("<font color=blue>WARNING: ".
  178:                          "Connection buffer $dfilename: $cmd</font>");
  179:                 &logperm("D:$server:$cmd");
  180: 	        return 'con_delayed';
  181:             } else {
  182:                 &logthis("<font color=red>CRITICAL:"
  183:                         ." Critical connection failed: $server $cmd</font>");
  184:                 &logperm("F:$server:$cmd");
  185:                 return 'con_failed';
  186:             }
  187:         }
  188:     }
  189:     return $answer;
  190: }
  191: 
  192: # ---------------------------------------------------------- Append Environment
  193: 
  194: sub appenv {
  195:     my %newenv=@_;
  196:     my @oldenv;
  197:     {
  198:      my $fh;
  199:      unless ($fh=Apache::File->new("$ENV{'user.environment'}")) {
  200: 	return 'error';
  201:      }
  202:      @oldenv=<$fh>;
  203:     }
  204:     for (my $i=0; $i<=$#oldenv; $i++) {
  205:         chomp($oldenv[$i]);
  206:         if ($oldenv[$i] ne '') {
  207:            my ($name,$value)=split(/=/,$oldenv[$i]);
  208:            unless (defined($newenv{$name})) {
  209: 	      $newenv{$name}=$value;
  210: 	   }
  211:         }
  212:     }
  213:     {
  214:      my $fh;
  215:      unless ($fh=Apache::File->new(">$ENV{'user.environment'}")) {
  216: 	return 'error';
  217:      }
  218:      my $newname;
  219:      foreach $newname (keys %newenv) {
  220: 	 print $fh "$newname=$newenv{$newname}\n";
  221:      }
  222:     }
  223:     return 'ok';
  224: }
  225: 
  226: # ------------------------------ Find server with least workload from spare.tab
  227: 
  228: sub spareserver {
  229:     my $tryserver;
  230:     my $spareserver='';
  231:     my $lowestserver=100;
  232:     foreach $tryserver (keys %spareid) {
  233:        my $answer=reply('load',$tryserver);
  234:        if (($answer =~ /\d/) && ($answer<$lowestserver)) {
  235: 	   $spareserver="http://$hostname{$tryserver}";
  236:            $lowestserver=$answer;
  237:        }
  238:     }    
  239:     return $spareserver;
  240: }
  241: 
  242: # --------- Try to authenticate user from domain's lib servers (first this one)
  243: 
  244: sub authenticate {
  245:     my ($uname,$upass,$udom)=@_;
  246:     $upass=escape($upass);
  247:     if (($perlvar{'lonRole'} eq 'library') && 
  248:         ($udom eq $perlvar{'lonDefDomain'})) {
  249:     my $answer=reply("encrypt:auth:$udom:$uname:$upass",$perlvar{'lonHostID'});
  250:         if ($answer =~ /authorized/) {
  251:               if ($answer eq 'authorized') {
  252:                  &logthis("User $uname at $udom authorized by local server"); 
  253:                  return $perlvar{'lonHostID'}; 
  254:               }
  255:               if ($answer eq 'non_authorized') {
  256:                  &logthis("User $uname at $udom rejected by local server"); 
  257:                  return 'no_host'; 
  258:               }
  259: 	}
  260:     }
  261: 
  262:     my $tryserver;
  263:     foreach $tryserver (keys %libserv) {
  264: 	if ($hostdom{$tryserver} eq $udom) {
  265:            my $answer=reply("encrypt:auth:$udom:$uname:$upass",$tryserver);
  266:            if ($answer =~ /authorized/) {
  267:               if ($answer eq 'authorized') {
  268:                  &logthis("User $uname at $udom authorized by $tryserver"); 
  269:                  return $tryserver; 
  270:               }
  271:               if ($answer eq 'non_authorized') {
  272:                  &logthis("User $uname at $udom rejected by $tryserver");
  273:                  return 'no_host';
  274:               } 
  275: 	   }
  276:        }
  277:     }
  278:     &logthis("User $uname at $udom could not be authenticated");    
  279:     return 'no_host';
  280: }
  281: 
  282: # ---------------------- Find the homebase for a user from domain's lib servers
  283: 
  284: sub homeserver {
  285:     my ($uname,$udom)=@_;
  286: 
  287:     my $index="$uname:$udom";
  288:     if ($homecache{$index}) { return "$homecache{$index}"; }
  289: 
  290:     my $tryserver;
  291:     foreach $tryserver (keys %libserv) {
  292: 	if ($hostdom{$tryserver} eq $udom) {
  293:            my $answer=reply("home:$udom:$uname",$tryserver);
  294:            if ($answer eq 'found') { 
  295: 	      $homecache{$index}=$tryserver;
  296:               return $tryserver; 
  297: 	   }
  298:        }
  299:     }    
  300:     return 'no_host';
  301: }
  302: 
  303: # ----------------------------- Subscribe to a resource, return URL if possible
  304: 
  305: sub subscribe {
  306:     my $fname=shift;
  307:     my $author=$fname;
  308:     $author=~s/\/home\/httpd\/html\/res\/([^\/]*)\/([^\/]*).*/$1\/$2/;
  309:     my ($udom,$uname)=split(/\//,$author);
  310:     my $home=homeserver($uname,$udom);
  311:     if (($home eq 'no_host') || ($home eq $perlvar{'lonHostID'})) { 
  312:         return 'not_found'; 
  313:     }
  314:     my $answer=reply("sub:$fname",$home);
  315:     return $answer;
  316: }
  317:     
  318: # -------------------------------------------------------------- Replicate file
  319: 
  320: sub repcopy {
  321:     my $filename=shift;
  322:     $filename=~s/\/+/\//g;
  323:     my $transname="$filename.in.transfer";
  324:     if ((-e $filename) || (-e $transname)) { return OK; }
  325:     my $remoteurl=subscribe($filename);
  326:     if ($remoteurl eq 'con_lost') {
  327: 	   &logthis("Subscribe returned con_lost: $filename");
  328:            return HTTP_SERVICE_UNAVAILABLE;
  329:     } elsif ($remoteurl eq 'not_found') {
  330: 	   &logthis("Subscribe returned not_found: $filename");
  331: 	   return HTTP_NOT_FOUND;
  332:     } elsif ($remoteurl eq 'rejected') {
  333: 	   &logthis("Subscribe returned rejected: $filename");
  334:            return FORBIDDEN;
  335:     } elsif ($remoteurl eq 'directory') {
  336:            return OK;
  337:     } else {
  338:            my @parts=split(/\//,$filename);
  339:            my $path="/$parts[1]/$parts[2]/$parts[3]/$parts[4]";
  340:            if ($path ne "$perlvar{'lonDocRoot'}/res") {
  341:                &logthis("Malconfiguration for replication: $filename");
  342: 	       return HTTP_BAD_REQUEST;
  343:            }
  344:            my $count;
  345:            for ($count=5;$count<$#parts;$count++) {
  346:                $path.="/$parts[$count]";
  347:                if ((-e $path)!=1) {
  348: 		   mkdir($path,0777);
  349:                }
  350:            }
  351:            my $ua=new LWP::UserAgent;
  352:            my $request=new HTTP::Request('GET',"$remoteurl");
  353:            my $response=$ua->request($request,$transname);
  354:            if ($response->is_error()) {
  355: 	       unlink($transname);
  356:                my $message=$response->status_line;
  357:                &logthis("<font color=blue>WARNING:"
  358:                        ." LWP get: $message: $filename</font>");
  359:                return HTTP_SERVICE_UNAVAILABLE;
  360:            } else {
  361: 	       if ($remoteurl!~/\.meta$/) {
  362:                   my $mrequest=new HTTP::Request('GET',$remoteurl.'.meta');
  363:                   my $mresponse=$ua->request($mrequest,$filename.'.meta');
  364:                   if ($mresponse->is_error()) {
  365: 		      unlink($filename.'.meta');
  366:                       &logthis(
  367:                      "<font color=yellow>INFO: No metadata: $filename</font>");
  368:                   }
  369: 	       }
  370:                rename($transname,$filename);
  371:                return OK;
  372:            }
  373:     }
  374: }
  375: 
  376: # --------------------------------------------------------- Server Side Include
  377: 
  378: sub ssi {
  379: 
  380:     my ($fn,%form)=@_;
  381: 
  382:     my $ua=new LWP::UserAgent;
  383:     
  384:     my $request;
  385:     
  386:     if (%form) {
  387:       $request=new HTTP::Request('POST',"http://".$ENV{'HTTP_HOST'}.$fn);
  388:       $request->content(join '&', map { "$_=$form{$_}" } keys %form);
  389:     } else {
  390:       $request=new HTTP::Request('GET',"http://".$ENV{'HTTP_HOST'}.$fn);
  391:     }
  392: 
  393:     $request->header(Cookie => $ENV{'HTTP_COOKIE'});
  394:     my $response=$ua->request($request);
  395: 
  396:     return $response->content;
  397: }
  398: 
  399: # ------------------------------------------------------------------------- Log
  400: 
  401: sub log {
  402:     my ($dom,$nam,$hom,$what)=@_;
  403:     return reply("log:$dom:$nam:$what",$hom);
  404: }
  405: 
  406: # ----------------------------------------------------------------------- Store
  407: 
  408: sub store {
  409:     my %storehash=shift;
  410:     my $namevalue='';
  411:     map {
  412:         $namevalue.=escape($_).'='.escape($storehash{$_}).'&';
  413:     } keys %storehash;
  414:     $namevalue=~s/\&$//;
  415:     return reply("store:$ENV{'user.domain'}:$ENV{'user.name'}:"
  416:                ."$ENV{'user.class'}:$ENV{'request.filename'}:$namevalue",
  417: 		 "$ENV{'user.home'}");
  418: }
  419: 
  420: # --------------------------------------------------------------------- Restore
  421: 
  422: sub restore {
  423:     my $answer=reply("restore:$ENV{'user.domain'}:$ENV{'user.name'}:"
  424:                ."$ENV{'user.class'}:$ENV{'request.filename'}",
  425:                 "$ENV{'user.home'}");
  426:     my %returnhash=();
  427:     map {
  428: 	my ($name,$value)=split(/\=/,$_);
  429:         $returnhash{&unescape($name)}=&unescape($value);
  430:     } split(/\&/,$answer);
  431:     return %returnhash;
  432: }
  433: 
  434: # -------------------------------------------------------- Get user priviledges
  435: 
  436: sub rolesinit {
  437:     my ($domain,$username,$authhost)=@_;
  438:     my $rolesdump=reply("dump:$domain:$username:roles",$authhost);
  439:     if (($rolesdump eq 'con_lost') || ($rolesdump eq '')) { return ''; }
  440:     my %allroles=();
  441:     my %thesepriv=();
  442:     my $now=time;
  443:     my $userroles="user.login.time=$now\n";
  444:     my $thesestr;
  445: 
  446:     if ($rolesdump ne '') {
  447:         map {
  448: 	  if ($_!~/^rolesdef\&/) {
  449:             my ($area,$role)=split(/=/,$_);
  450:             $area=~s/\_\w\w$//;
  451:             my ($trole,$tend,$tstart)=split(/_/,$role);
  452:             $userroles.='user.role.'.$trole.'.'.$area.'='.
  453:                         $tstart.'.'.$tend."\n";
  454:             if ($tend!=0) {
  455: 	        if ($tend<$now) {
  456: 	            $trole='';
  457:                 } 
  458:             }
  459:             if ($tstart!=0) {
  460:                 if ($tstart>$now) {
  461:                    $trole='';        
  462:                 }
  463:             }
  464:             if (($area ne '') && ($trole ne '')) {
  465:                my ($tdummy,$tdomain,$trest)=split(/\//,$area);
  466:                if ($trole =~ /^cr\//) {
  467: 		   my ($rdummy,$rdomain,$rauthor,$rrole)=split(/\//,$trole);
  468:                    my $homsvr=homeserver($rauthor,$rdomain);
  469:                    if ($hostname{$homsvr} ne '') {
  470:                       my $roledef=
  471: 			  reply("get:$rdomain:$rauthor:roles:rolesdef_$rrole",
  472:                                 $homsvr);
  473:                       if (($roledef ne 'con_lost') && ($roledef ne '')) {
  474:                          my ($syspriv,$dompriv,$coursepriv)=
  475: 			     split(/\_/,unescape($roledef));
  476:  	                 $allroles{'/'}.=':'.$syspriv;
  477:                          if ($tdomain ne '') {
  478:                              $allroles{'/'.$tdomain.'/'}.=':'.$dompriv;
  479:                              if ($trest ne '') {
  480: 		                $allroles{$area}.=':'.$coursepriv;
  481:                              }
  482: 	                 }
  483:                       }
  484:                    }
  485:                } else {
  486: 	           $allroles{'/'}.=':'.$pr{$trole.':s'};
  487:                    if ($tdomain ne '') {
  488:                       $allroles{'/'.$tdomain.'/'}.=':'.$pr{$trole.':d'};
  489:                       if ($trest ne '') {
  490: 		          $allroles{$area}.=':'.$pr{$trole.':c'};
  491:                       }
  492: 	           }
  493: 	       }
  494:             }
  495:           } 
  496:         } split(/&/,$rolesdump);
  497:         map {
  498:             %thesepriv=();
  499:             map {
  500:                 if ($_ ne '') {
  501: 		    my ($priviledge,$restrictions)=split(/&/,$_);
  502:                     if ($restrictions eq '') {
  503: 			$thesepriv{$priviledge}='F';
  504:                     } else {
  505:                         if ($thesepriv{$priviledge} ne 'F') {
  506: 			    $thesepriv{$priviledge}.=$restrictions;
  507:                         }
  508:                     }
  509:                 }
  510:             } split(/:/,$allroles{$_});
  511:             $thesestr='';
  512:             map { $thesestr.=':'.$_.'&'.$thesepriv{$_}; } keys %thesepriv;
  513:             $userroles.='user.priv.'.$_.'='.$thesestr."\n";
  514:         } keys %allroles;            
  515:     }
  516:     return $userroles;  
  517: }
  518: 
  519: # --------------------------------------------------------------- get interface
  520: 
  521: sub get {
  522:    my ($namespace,@storearr)=@_;
  523:    my $items='';
  524:    map {
  525:        $items.=escape($_).'&';
  526:    } @storearr;
  527:    $items=~s/\&$//;
  528:  my $rep=reply("get:$ENV{'user.domain'}:$ENV{'user.name'}:$namespace:$items",
  529:                  $ENV{'user.home'});
  530:    my @pairs=split(/\&/,$rep);
  531:    my %returnhash=();
  532:    map {
  533:       my ($key,$value)=split(/=/,$_);
  534:       $returnhash{unescape($key)}=unescape($value);
  535:    } @pairs;
  536:    return %returnhash;
  537: }
  538: 
  539: # --------------------------------------------------------------- del interface
  540: 
  541: sub del {
  542:    my ($namespace,@storearr)=@_;
  543:    my $items='';
  544:    map {
  545:        $items.=escape($_).'&';
  546:    } @storearr;
  547:    $items=~s/\&$//;
  548:    return reply("del:$ENV{'user.domain'}:$ENV{'user.name'}:$namespace:$items",
  549:                  $ENV{'user.home'});
  550: }
  551: 
  552: # -------------------------------------------------------------- dump interface
  553: 
  554: sub dump {
  555:    my $namespace=shift;
  556:    my $rep=reply("dump:$ENV{'user.domain'}:$ENV{'user.name'}:$namespace",
  557:                 $ENV{'user.home'});
  558:    my @pairs=split(/\&/,$rep);
  559:    my %returnhash=();
  560:    map {
  561:       my ($key,$value)=split(/=/,$_);
  562:       $returnhash{unescape($key)}=unescape($value);
  563:    } @pairs;
  564:    return %returnhash;
  565: }
  566: 
  567: # --------------------------------------------------------------- put interface
  568: 
  569: sub put {
  570:    my ($namespace,%storehash)=@_;
  571:    my $items='';
  572:    map {
  573:        $items.=escape($_).'='.escape($storehash{$_}).'&';
  574:    } keys %storehash;
  575:    $items=~s/\&$//;
  576:    return reply("put:$ENV{'user.domain'}:$ENV{'user.name'}:$namespace:$items",
  577:                  $ENV{'user.home'});
  578: }
  579: 
  580: # -------------------------------------------------------------- eget interface
  581: 
  582: sub eget {
  583:    my ($namespace,@storearr)=@_;
  584:    my $items='';
  585:    map {
  586:        $items.=escape($_).'&';
  587:    } @storearr;
  588:    $items=~s/\&$//;
  589:  my $rep=reply("eget:$ENV{'user.domain'}:$ENV{'user.name'}:$namespace:$items",
  590:                  $ENV{'user.home'});
  591:    my @pairs=split(/\&/,$rep);
  592:    my %returnhash=();
  593:    map {
  594:       my ($key,$value)=split(/=/,$_);
  595:       $returnhash{unescape($key)}=unescape($value);
  596:    } @pairs;
  597:    return %returnhash;
  598: }
  599: 
  600: # ------------------------------------------------- Check for a user priviledge
  601: 
  602: sub allowed {
  603:     my ($priv,$uri)=@_;
  604:     $uri=~s/^\/res//;
  605:     $uri=~s/^\///;
  606: 
  607: # Free bre access to adm resources
  608: 
  609:     if (($uri=~/^adm\//) && ($priv eq 'bre')) {
  610: 	return 'F';
  611:     }
  612: 
  613: # Gather priviledges over system and domain
  614: 
  615:     my $thisallowed='';
  616:     if ($ENV{'user.priv./'}=~/$priv\&([^\:]*)/) {
  617:        $thisallowed.=$1;
  618:     }
  619:     if ($ENV{'user.priv./'.(split(/\//,$uri))[0].'/'}=~/$priv\&([^\:]*)/) {
  620:        $thisallowed.=$1;
  621:     }
  622: 
  623: # Full access at system or domain level? Exit.
  624: 
  625:     if ($thisallowed=~/F/) {
  626: 	return 'F';
  627:     }
  628: 
  629: # The user does not have full access at system or domain level
  630: # Course level access control
  631: 
  632: # uri itself refering to a course?
  633:     
  634:     if ($uri=~/\.course$/) {
  635:        if ($ENV{'user.priv./'.$uri}=~/$priv\&([^\:]*)/) {
  636:           $thisallowed.=$1;
  637:        }
  638: # Full access on course level? Exit.
  639:        if ($thisallowed=~/F/) {
  640: 	  return 'F';
  641:        }
  642: 
  643: # uri is refering to an individual resource; user needs to be in a course
  644: 
  645:    } else {
  646: 
  647:        unless(defined($ENV{'request.course.uri'})) {
  648: 	   return '1';
  649:        }
  650: 
  651: # Get access priviledges for course
  652: 
  653:        if ($ENV{'user.priv./'.$ENV{'request.course.uri'}}=~/$priv\&([^\:]*)/) {
  654:           $thisallowed.=$1;
  655:        }
  656: 
  657: # See if resource or referer is part of this course
  658:           
  659:        my @uriparts=split(/\//,$uri);
  660:        my $urifile=$uriparts[$#uriparts];
  661:        $urifile=~/\.(\w+)$/;
  662:        my $uritype=$1;
  663:        $#uriparts--;
  664:        my $uripath=join('/',@uriparts);
  665:        my $uricond=-1;
  666:        if ($ENV{'acc.res.'.$ENV{'request.course'}.'.'.$uripath}=~
  667: 	   /\&$urifile\:(\d+)\&/) {
  668: 	   $uricond=$1;
  669:        } elsif (($fe{$uritype} eq 'emb') || ($fe{$uritype} eq 'img')) {
  670: 	  my $refuri=$ENV{'HTTP_REFERER'};
  671:           $refuri=~s/^\/res//;
  672:           $refuri=~s/^\///;
  673:           @uriparts=split(/\//,$refuri);
  674:           $urifile=$uriparts[$#uriparts];
  675:           $#uriparts--;
  676:           $uripath=join('/',@uriparts);
  677:           if ($ENV{'acc.res.'.$ENV{'request.course'}.'.'.$uripath}=~
  678: 	     /\&$urifile\:(\d+)\&/) {
  679: 	     $uricond=$1;
  680: 	  }
  681:        }
  682: 
  683:        if ($uricond>=0) {
  684: 
  685: # The resource is part of the course
  686: # If user had full access on course level, go ahead
  687: 
  688:            if ($thisallowed=~/F/) {
  689: 	       return 'F';
  690:            }
  691: 
  692: # Restricted by state?
  693: 
  694:            if ($thisallowed=~/X/) {
  695: 	      if (&condval($uricond)>1) {
  696: 	         return '2';
  697:               } else {
  698:                  return '';
  699:               }
  700: 	   }
  701:        }
  702:     }
  703:     return $thisallowed;
  704: }
  705: 
  706: # ---------------------------------------------------------- Refresh State Info
  707: 
  708: sub refreshstate {
  709: }
  710: 
  711: # ----------------------------------------------------------------- Define Role
  712: 
  713: sub definerole {
  714:   if (allowed('mcr','/')) {
  715:     my ($rolename,$sysrole,$domrole,$courole)=@_;
  716:     map {
  717: 	my ($crole,$cqual)=split(/\&/,$_);
  718:         if ($pr{'cr:s'}!~/$crole/) { return "refused:s:$crole"; }
  719:         if ($pr{'cr:s'}=~/$crole\&/) {
  720: 	    if ($pr{'cr:s'}!~/$crole\&\w*$cqual/) { 
  721:                return "refused:s:$crole&$cqual"; 
  722:             }
  723:         }
  724:     } split('/',$sysrole);
  725:     map {
  726: 	my ($crole,$cqual)=split(/\&/,$_);
  727:         if ($pr{'cr:d'}!~/$crole/) { return "refused:d:$crole"; }
  728:         if ($pr{'cr:d'}=~/$crole\&/) {
  729: 	    if ($pr{'cr:d'}!~/$crole\&\w*$cqual/) { 
  730:                return "refused:d:$crole&$cqual"; 
  731:             }
  732:         }
  733:     } split('/',$domrole);
  734:     map {
  735: 	my ($crole,$cqual)=split(/\&/,$_);
  736:         if ($pr{'cr:c'}!~/$crole/) { return "refused:c:$crole"; }
  737:         if ($pr{'cr:c'}=~/$crole\&/) {
  738: 	    if ($pr{'cr:c'}!~/$crole\&\w*$cqual/) { 
  739:                return "refused:c:$crole&$cqual"; 
  740:             }
  741:         }
  742:     } split('/',$courole);
  743:     my $command="encrypt:rolesput:$ENV{'user.domain'}:$ENV{'user.name'}:".
  744:                 "$ENV{'user.domain'}:$ENV{'user.name'}:".
  745: 	        "rolesdef_$rolename=".
  746:                 escape($sysrole.'_'.$domrole.'_'.$courole);
  747:     return reply($command,$ENV{'user.home'});
  748:   } else {
  749:     return 'refused';
  750:   }
  751: }
  752: 
  753: # ------------------------------------------------------------------ Plain Text
  754: 
  755: sub plaintext {
  756:     my $short=shift;
  757:     return $prp{$short};
  758: }
  759: 
  760: # ------------------------------------------------------------------ Plain Text
  761: 
  762: sub fileembstyle {
  763:     my $ending=shift;
  764:     return $fe{$ending};
  765: }
  766: 
  767: # ------------------------------------------------------------ Description Text
  768: 
  769: sub filedecription {
  770:     my $ending=shift;
  771:     return $fd{$ending};
  772: }
  773: 
  774: # ----------------------------------------------------------------- Assign Role
  775: 
  776: sub assignrole {
  777:     my ($udom,$uname,$url,$role,$end,$start)=@_;
  778:     my $mrole;
  779:     $url=~s/^\///;
  780:     $url=~s/^res\///;
  781:     if ($role =~ /^cr\//) {
  782:         unless ($url=~/\.course$/) { return 'invalid'; }
  783: 	unless (allowed('ccr',$url)) { return 'refused'; }
  784:         $mrole='cr';
  785:     } else {
  786:         unless (($url=~/\.course$/) || ($url=~/\/$/)) { return 'invalid'; }
  787:         unless (allowed('c'+$role)) { return 'refused'; }
  788:         $mrole=$role;
  789:     }
  790:     my $command="encrypt:rolesput:$ENV{'user.domain'}:$ENV{'user.name'}:".
  791:                 "$udom:$uname:$url".'_'."$mrole=$role";
  792:     if ($end) { $command.='_$end'; }
  793:     if ($start) {
  794: 	if ($end) { 
  795:            $command.='_$start'; 
  796:         } else {
  797:            $command.='_0_$start';
  798:         }
  799:     }
  800:     return &reply($command,&homeserver($uname,$udom));
  801: }
  802: 
  803: # ---------------------------------------------------------- Assign Custom Role
  804: 
  805: sub assigncustomrole {
  806:     my ($udom,$uname,$url,$rdom,$rnam,$rolename,$end,$start)=@_;
  807:     return &assignrole($udom,$uname,$url,'cr/'.$rdom.'/'.$rnam.'/'.$rolename,
  808:                        $end,$start);
  809: }
  810: 
  811: # ----------------------------------------------------------------- Revoke Role
  812: 
  813: sub revokerole {
  814:     my ($udom,$uname,$url,$role)=@_;
  815:     my $now=time;
  816:     return &assignrole($udom,$uname,$url,$role,$now);
  817: }
  818: 
  819: # ---------------------------------------------------------- Revoke Custom Role
  820: 
  821: sub revokecustomrole {
  822:     my ($udom,$uname,$url,$rdom,$rnam,$rolename)=@_;
  823:     my $now=time;
  824:     return &assigncustomrole($udom,$uname,$url,$rdom,$rnam,$rolename,$now);
  825: }
  826: 
  827: # ------------------------------------------------------------ Directory lister
  828: 
  829: sub dirlist {
  830:     my $uri=shift;
  831:     $uri=~s/^\///;
  832:     $uri=~s/\/$//;
  833:     my ($res,$udom,$uname,@rest)=split(/\//,$uri);
  834:     if ($udom) {
  835:      if ($uname) {
  836:        my $listing=reply('ls:'.$perlvar{'lonDocRoot'}.'/'.$uri,
  837:                       homeserver($uname,$udom));
  838:        return split(/:/,$listing);
  839:      } else {
  840:        my $tryserver;
  841:        my %allusers=();
  842:        foreach $tryserver (keys %libserv) {
  843: 	  if ($hostdom{$tryserver} eq $udom) {
  844:              my $listing=reply('ls:'.$perlvar{'lonDocRoot'}.'/res/'.$udom,
  845: 			       $tryserver);
  846:              if (($listing ne 'no_such_dir') && ($listing ne 'empty')
  847:               && ($listing ne 'con_lost')) {
  848:                 map {
  849:                   my ($entry,@stat)=split(/&/,$_);
  850:                   $allusers{$entry}=1;
  851:                 } split(/:/,$listing);
  852:              }
  853: 	  }
  854:        }
  855:        my $alluserstr='';
  856:        map {
  857:            $alluserstr.=$_.'&user:';
  858:        } sort keys %allusers;
  859:        $alluserstr=~s/:$//;
  860:        return split(/:/,$alluserstr);
  861:      } 
  862:    } else {
  863:        my $tryserver;
  864:        my %alldom=();
  865:        foreach $tryserver (keys %libserv) {
  866: 	   $alldom{$hostdom{$tryserver}}=1;
  867:        }
  868:        my $alldomstr='';
  869:        map {
  870:           $alldomstr.=$perlvar{'lonDocRoot'}.'/res/'.$_.'&domain:';
  871:        } sort keys %alldom;
  872:        $alldomstr=~s/:$//;
  873:        return split(/:/,$alldomstr);       
  874:    }
  875: }
  876: 
  877: # -------------------------------------------------------- Value of a Condition
  878: 
  879: sub condval {
  880:     my $condidx=shift;
  881:     my $result=0;
  882:     if ($ENV{'request.course'}) {
  883:        if (defined($ENV{'acc.cond.'.$ENV{'request.course'}.'.'.$condidx})) {
  884:           my $operand='|';
  885: 	  my @stack;
  886:           map {
  887:               if ($_ eq '(') {
  888:                  push @stack,($operand,$result)
  889:               } elsif ($_ eq ')') {
  890:                   my $before=pop @stack;
  891: 		  if (pop @stack eq '&') {
  892: 		      $result=$result>$before?$before:$result;
  893:                   } else {
  894:                       $result=$result>$before?$result:$before;
  895:                   }
  896:               } elsif (($_ eq '&') || ($_ eq '|')) {
  897:                   $operand=$_;
  898:               } else {
  899:                   my $new=
  900:                        substr($ENV{'user.state.'.$ENV{'request.course'}},$_,1);
  901:                   if ($operand eq '&') {
  902:                      $result=$result>$new?$new:$result;
  903:                   } else {
  904:                      $result=$result>$new?$result:$new;
  905:                   }                  
  906:               }
  907:           } ($ENV{'acc.cond.'.$ENV{'request.course'}.'.'.$condidx}=~
  908:              /(\d+|\(|\)|\&|\|)/g);
  909:        }
  910:     }
  911:     return $result;
  912: }
  913: 
  914: # --------------------------------------------------------- Value of a Variable
  915: 
  916: sub varval {
  917:     my ($realm,$space,@components)=split(/\./,shift);
  918:     my $value='';
  919:     if ($realm eq 'user') {
  920: 	if ($space=~/^resource/) {
  921: 	    $space=~s/^resource\[//;
  922:             $space=~s/\]$//;
  923: 
  924:         } else {
  925:         }
  926:     } elsif ($realm eq 'course') {
  927:     } elsif ($realm eq 'session') {
  928:     } elsif ($realm eq 'system') {
  929:     }
  930:     return $value;
  931: }
  932: 
  933: # -------------------------------------------------------- Escape Special Chars
  934: 
  935: sub escape {
  936:     my $str=shift;
  937:     $str =~ s/(\W)/"%".unpack('H2',$1)/eg;
  938:     return $str;
  939: }
  940: 
  941: # ----------------------------------------------------- Un-Escape Special Chars
  942: 
  943: sub unescape {
  944:     my $str=shift;
  945:     $str =~ s/%([a-fA-F0-9][a-fA-F0-9])/pack("C",hex($1))/eg;
  946:     return $str;
  947: }
  948: 
  949: # ================================================================ Main Program
  950: 
  951: sub BEGIN {
  952: if ($readit ne 'done') {
  953: # ------------------------------------------------------------ Read access.conf
  954: {
  955:     my $config=Apache::File->new("/etc/httpd/conf/access.conf");
  956: 
  957:     while (my $configline=<$config>) {
  958:         if ($configline =~ /PerlSetVar/) {
  959: 	   my ($dummy,$varname,$varvalue)=split(/\s+/,$configline);
  960:            chomp($varvalue);
  961:            $perlvar{$varname}=$varvalue;
  962:         }
  963:     }
  964: }
  965: 
  966: # ------------------------------------------------------------- Read hosts file
  967: {
  968:     my $config=Apache::File->new("$perlvar{'lonTabDir'}/hosts.tab");
  969: 
  970:     while (my $configline=<$config>) {
  971:        my ($id,$domain,$role,$name,$ip)=split(/:/,$configline);
  972:        $hostname{$id}=$name;
  973:        $hostdom{$id}=$domain;
  974:        if ($role eq 'library') { $libserv{$id}=$name; }
  975:     }
  976: }
  977: 
  978: # ------------------------------------------------------ Read spare server file
  979: {
  980:     my $config=Apache::File->new("$perlvar{'lonTabDir'}/spare.tab");
  981: 
  982:     while (my $configline=<$config>) {
  983:        chomp($configline);
  984:        if (($configline) && ($configline ne $perlvar{'lonHostID'})) {
  985:           $spareid{$configline}=1;
  986:        }
  987:     }
  988: }
  989: # ------------------------------------------------------------ Read permissions
  990: {
  991:     my $config=Apache::File->new("$perlvar{'lonTabDir'}/roles.tab");
  992: 
  993:     while (my $configline=<$config>) {
  994:        chomp($configline);
  995:        my ($role,$perm)=split(/ /,$configline);
  996:        if ($perm ne '') { $pr{$role}=$perm; }
  997:     }
  998: }
  999: 
 1000: # -------------------------------------------- Read plain texts for permissions
 1001: {
 1002:     my $config=Apache::File->new("$perlvar{'lonTabDir'}/rolesplain.tab");
 1003: 
 1004:     while (my $configline=<$config>) {
 1005:        chomp($configline);
 1006:        my ($short,$plain)=split(/:/,$configline);
 1007:        if ($plain ne '') { $prp{$short}=$plain; }
 1008:     }
 1009: }
 1010: 
 1011: # ------------------------------------------------------------- Read file types
 1012: {
 1013:     my $config=Apache::File->new("$perlvar{'lonTabDir'}/filetypes.tab");
 1014: 
 1015:     while (my $configline=<$config>) {
 1016:        chomp($configline);
 1017:        my ($ending,$emb,@descr)=split(/\s+/,$configline);
 1018:        if ($descr[0] ne '') { 
 1019:          $fe{$ending}=$emb;
 1020:          $fd{$ending}=join(' ',@descr);
 1021:        }
 1022:     }
 1023: }
 1024: 
 1025: 
 1026: $readit='done';
 1027: &logthis('<font color=yellow>INFO: Read configuration</font>');
 1028: }
 1029: }
 1030: 1;

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>