File:  [LON-CAPA] / loncom / lonnet / perl / lonnet.pm
Revision 1.23: download - view: text, annotated - select for diffs
Mon Aug 14 21:40:46 2000 UTC (23 years, 11 months ago) by www
Branches: MAIN
CVS tags: HEAD
repcopy remove multiple slashes
ssi now also posts parameters

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

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