Annotation of loncom/lonnet/perl/lonnet.pm, revision 1.30

1.1       albertel    1: # The LearningOnline Network
                      2: # TCP networking package
1.12      www         3: #
                      4: # Functions for use by content handlers:
                      5: #
                      6: # plaintext(short)   : plain text explanation of short term
1.25      www         7: # fileembstyle(ext)  : embed style in page for file extension
                      8: # filedescription(ext) : descriptor text for file extension
1.29      www         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
1.21      www        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
1.24      www        26: # appenv(hash)       : adds hash to session environment
1.12      www        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
1.27      www        31: # del(namesp,array)  : deletes keys out of arry from namesp
1.12      www        32: # put(namesp,hash)   : stores hash in namesp
1.15      www        33: # dump(namesp)       : dumps the complete namespace into a hash
1.23      www        34: # ssi(url,hash)      : does a complete request cycle on url to localhost, posts
                     35: #                      hash
1.17      www        36: # repcopy(filename)  : replicate file
                     37: # dirlist(url)       : gets a directory listing
1.28      www        38: # condval(index)     : value of condition index based on state
1.29      www        39: # varval(name)       : value of a variable
                     40: # refreshstate()     : refresh the state information string 
1.12      www        41: #
1.1       albertel   42: # 6/1/99,6/2,6/10,6/11,6/12,6/14,6/26,6/28,6/29,6/30,
1.5       www        43: # 7/1,7/2,7/9,7/10,7/12,7/14,7/15,7/19,
1.8       www        44: # 11/8,11/16,11/18,11/22,11/23,12/22,
1.12      www        45: # 01/06,01/13,02/24,02/28,02/29,
                     46: # 03/01,03/02,03/06,03/07,03/13,
1.15      www        47: # 04/05,05/29,05/31,06/01,
                     48: # 06/05,06/26 Gerd Kortemeyer
                     49: # 06/26 Ben Tyszka
1.22      www        50: # 06/30,07/15,07/17,07/18,07/20,07/21,07/22,07/25 Gerd Kortemeyer
1.23      www        51: # 08/14 Ben Tyszka
1.29      www        52: # 08/22,08/28,08/31,09/01,09/02,09/04,09/05 Gerd Kortemeyer
1.1       albertel   53: 
                     54: package Apache::lonnet;
                     55: 
                     56: use strict;
                     57: use Apache::File;
1.8       www        58: use LWP::UserAgent();
1.15      www        59: use HTTP::Headers;
1.11      www        60: use vars 
1.25      www        61: qw(%perlvar %hostname %homecache %spareid %hostdom %libserv %pr %prp %fe %fd $readit);
1.1       albertel   62: use IO::Socket;
1.8       www        63: use Apache::Constants qw(:common :http);
1.1       albertel   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>;
1.9       www        97:     if (!$answer) { $answer="con_lost"; }
1.1       albertel   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); }
1.12      www       106:     if (($answer=~/^error:/) || ($answer=~/^refused/) || 
                    107:         ($answer=~/^rejected/)) {
                    108:        &logthis("<font color=blue>WARNING:".
                    109:                 " $cmd to $server returned $answer</font>");
                    110:     }
1.1       albertel  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; }
1.12      www       131:             &logthis(
                    132:   "<font color=blue>WARNING: $peerfile still not there, giving up</font>");
1.1       albertel  133:         } else {
1.12      www       134: 	    &logthis(
                    135:                "<font color=blue>WARNING:".
                    136:                " lonc at pid $loncpid not responding, giving up</font>");
1.1       albertel  137:         }
                    138:     } else {
1.12      www       139:      &logthis('<font color=blue>WARNING: lonc not running, giving up</font>');
1.1       albertel  140:     }
                    141: }
                    142: 
                    143: # ------------------------------------------------------ Critical communication
1.12      www       144: 
1.1       albertel  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;
1.5       www       157:             $middlename=substr($middlename,0,16);
1.1       albertel  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")) {
1.7       www       164:                 print $dfh "$cmd\n";
1.1       albertel  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);
1.7       www       176:             if ($wcmd eq $cmd) {
1.12      www       177: 		&logthis("<font color=blue>WARNING: ".
                    178:                          "Connection buffer $dfilename: $cmd</font>");
1.1       albertel  179:                 &logperm("D:$server:$cmd");
                    180: 	        return 'con_delayed';
                    181:             } else {
1.12      www       182:                 &logthis("<font color=red>CRITICAL:"
                    183:                         ." Critical connection failed: $server $cmd</font>");
1.1       albertel  184:                 &logperm("F:$server:$cmd");
                    185:                 return 'con_failed';
                    186:             }
                    187:         }
                    188:     }
                    189:     return $answer;
                    190: }
                    191: 
1.5       www       192: # ---------------------------------------------------------- Append Environment
                    193: 
                    194: sub appenv {
1.6       www       195:     my %newenv=@_;
                    196:     my @oldenv;
                    197:     {
                    198:      my $fh;
                    199:      unless ($fh=Apache::File->new("$ENV{'user.environment'}")) {
1.5       www       200: 	return 'error';
1.6       www       201:      }
                    202:      @oldenv=<$fh>;
                    203:     }
                    204:     for (my $i=0; $i<=$#oldenv; $i++) {
                    205:         chomp($oldenv[$i]);
1.9       www       206:         if ($oldenv[$i] ne '') {
                    207:            my ($name,$value)=split(/=/,$oldenv[$i]);
1.24      www       208:            unless (defined($newenv{$name})) {
                    209: 	      $newenv{$name}=$value;
                    210: 	   }
1.9       www       211:         }
1.6       www       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:      }
1.5       www       222:     }
                    223:     return 'ok';
                    224: }
1.1       albertel  225: 
                    226: # ------------------------------ Find server with least workload from spare.tab
1.11      www       227: 
1.1       albertel  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)
1.11      www       243: 
1.1       albertel  244: sub authenticate {
                    245:     my ($uname,$upass,$udom)=@_;
1.12      www       246:     $upass=escape($upass);
1.1       albertel  247:     if (($perlvar{'lonRole'} eq 'library') && 
                    248:         ($udom eq $perlvar{'lonDefDomain'})) {
1.3       www       249:     my $answer=reply("encrypt:auth:$udom:$uname:$upass",$perlvar{'lonHostID'});
1.2       www       250:         if ($answer =~ /authorized/) {
1.9       www       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:               }
1.2       www       259: 	}
1.1       albertel  260:     }
                    261: 
                    262:     my $tryserver;
                    263:     foreach $tryserver (keys %libserv) {
                    264: 	if ($hostdom{$tryserver} eq $udom) {
1.10      www       265:            my $answer=reply("encrypt:auth:$udom:$uname:$upass",$tryserver);
1.1       albertel  266:            if ($answer =~ /authorized/) {
1.9       www       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:               } 
1.1       albertel  275: 	   }
                    276:        }
1.9       www       277:     }
                    278:     &logthis("User $uname at $udom could not be authenticated");    
1.1       albertel  279:     return 'no_host';
                    280: }
                    281: 
                    282: # ---------------------- Find the homebase for a user from domain's lib servers
1.11      www       283: 
1.1       albertel  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
1.11      www       304: 
1.1       albertel  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:     
1.8       www       318: # -------------------------------------------------------------- Replicate file
                    319: 
                    320: sub repcopy {
                    321:     my $filename=shift;
1.23      www       322:     $filename=~s/\/+/\//g;
1.8       www       323:     my $transname="$filename.in.transfer";
1.17      www       324:     if ((-e $filename) || (-e $transname)) { return OK; }
1.8       www       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;
1.20      www       332:     } elsif ($remoteurl eq 'rejected') {
                    333: 	   &logthis("Subscribe returned rejected: $filename");
1.8       www       334:            return FORBIDDEN;
1.20      www       335:     } elsif ($remoteurl eq 'directory') {
                    336:            return OK;
1.8       www       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;
1.12      www       357:                &logthis("<font color=blue>WARNING:"
                    358:                        ." LWP get: $message: $filename</font>");
1.8       www       359:                return HTTP_SERVICE_UNAVAILABLE;
                    360:            } else {
1.16      www       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: 	       }
1.8       www       370:                rename($transname,$filename);
                    371:                return OK;
                    372:            }
                    373:     }
                    374: }
                    375: 
1.15      www       376: # --------------------------------------------------------- Server Side Include
                    377: 
                    378: sub ssi {
                    379: 
1.23      www       380:     my ($fn,%form)=@_;
1.15      www       381: 
                    382:     my $ua=new LWP::UserAgent;
1.23      www       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: 
1.15      www       393:     $request->header(Cookie => $ENV{'HTTP_COOKIE'});
                    394:     my $response=$ua->request($request);
                    395: 
                    396:     return $response->content;
                    397: }
                    398: 
1.14      www       399: # ------------------------------------------------------------------------- Log
                    400: 
                    401: sub log {
                    402:     my ($dom,$nam,$hom,$what)=@_;
                    403:     return reply("log:$dom:$nam:$what",$hom);
                    404: }
                    405: 
1.9       www       406: # ----------------------------------------------------------------------- Store
                    407: 
                    408: sub store {
                    409:     my %storehash=shift;
1.12      www       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'}");
1.9       www       418: }
                    419: 
                    420: # --------------------------------------------------------------------- Restore
                    421: 
                    422: sub restore {
1.12      www       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);
1.13      www       431:     return %returnhash;
1.9       www       432: }
1.1       albertel  433: 
1.11      www       434: # -------------------------------------------------------- Get user priviledges
                    435: 
                    436: sub rolesinit {
                    437:     my ($domain,$username,$authhost)=@_;
                    438:     my $rolesdump=reply("dump:$domain:$username:roles",$authhost);
1.12      www       439:     if (($rolesdump eq 'con_lost') || ($rolesdump eq '')) { return ''; }
1.11      www       440:     my %allroles=();
                    441:     my %thesepriv=();
                    442:     my $now=time;
1.21      www       443:     my $userroles="user.login.time=$now\n";
1.11      www       444:     my $thesestr;
                    445: 
                    446:     if ($rolesdump ne '') {
                    447:         map {
1.21      www       448: 	  if ($_!~/^rolesdef\&/) {
1.11      www       449:             my ($area,$role)=split(/=/,$_);
1.21      www       450:             $area=~s/\_\w\w$//;
1.11      www       451:             my ($trole,$tend,$tstart)=split(/_/,$role);
1.21      www       452:             $userroles.='user.role.'.$trole.'.'.$area.'='.
                    453:                         $tstart.'.'.$tend."\n";
1.11      www       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 '')) {
1.12      www       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=
1.21      www       471: 			  reply("get:$rdomain:$rauthor:roles:rolesdef_$rrole",
1.12      www       472:                                 $homsvr);
                    473:                       if (($roledef ne 'con_lost') && ($roledef ne '')) {
                    474:                          my ($syspriv,$dompriv,$coursepriv)=
1.21      www       475: 			     split(/\_/,unescape($roledef));
1.12      www       476:  	                 $allroles{'/'}.=':'.$syspriv;
                    477:                          if ($tdomain ne '') {
                    478:                              $allroles{'/'.$tdomain.'/'}.=':'.$dompriv;
                    479:                              if ($trest ne '') {
                    480: 		                $allroles{$area}.=':'.$coursepriv;
                    481:                              }
                    482: 	                 }
                    483:                       }
1.11      www       484:                    }
1.12      www       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: 	           }
1.11      www       493: 	       }
1.12      www       494:             }
                    495:           } 
1.11      www       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: 
1.12      www       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'});
1.15      www       530:    my @pairs=split(/\&/,$rep);
                    531:    my %returnhash=();
                    532:    map {
                    533:       my ($key,$value)=split(/=/,$_);
1.29      www       534:       $returnhash{unescape($key)}=unescape($value);
1.15      www       535:    } @pairs;
                    536:    return %returnhash;
1.27      www       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'});
1.15      www       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'});
1.12      www       558:    my @pairs=split(/\&/,$rep);
                    559:    my %returnhash=();
                    560:    map {
                    561:       my ($key,$value)=split(/=/,$_);
1.29      www       562:       $returnhash{unescape($key)}=unescape($value);
1.12      www       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(/=/,$_);
1.29      www       595:       $returnhash{unescape($key)}=unescape($value);
1.12      www       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/^\///;
1.29      www       606: 
                    607: # Free bre access to adm resources
                    608: 
                    609:     if (($uri=~/^adm\//) && ($priv eq 'bre')) {
1.14      www       610: 	return 'F';
                    611:     }
1.29      www       612: 
                    613: # Gather priviledges over system and domain
                    614: 
1.12      www       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:     }
1.29      www       622: 
                    623: # Full access at system or domain level? Exit.
                    624: 
                    625:     if ($thisallowed=~/F/) {
                    626: 	return 'F';
                    627:     }
                    628: 
1.30    ! www       629: # The user does not have full access at system or domain level
1.29      www       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:        }
1.30    ! www       638: # Full access on course level? Exit.
1.29      www       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')) {
1.30    ! www       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) {
1.29      www       684: 
1.30    ! www       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: 	   }
1.29      www       701:        }
1.12      www       702:     }
                    703:     return $thisallowed;
                    704: }
                    705: 
1.29      www       706: # ---------------------------------------------------------- Refresh State Info
                    707: 
                    708: sub refreshstate {
                    709: }
                    710: 
1.12      www       711: # ----------------------------------------------------------------- Define Role
                    712: 
                    713: sub definerole {
                    714:   if (allowed('mcr','/')) {
                    715:     my ($rolename,$sysrole,$domrole,$courole)=@_;
1.21      www       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);
1.12      www       743:     my $command="encrypt:rolesput:$ENV{'user.domain'}:$ENV{'user.name'}:".
                    744:                 "$ENV{'user.domain'}:$ENV{'user.name'}:".
1.21      www       745: 	        "rolesdef_$rolename=".
                    746:                 escape($sysrole.'_'.$domrole.'_'.$courole);
1.12      www       747:     return reply($command,$ENV{'user.home'});
                    748:   } else {
                    749:     return 'refused';
                    750:   }
                    751: }
                    752: 
                    753: # ------------------------------------------------------------------ Plain Text
                    754: 
                    755: sub plaintext {
1.22      www       756:     my $short=shift;
                    757:     return $prp{$short};
1.12      www       758: }
                    759: 
1.25      www       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: 
1.12      www       774: # ----------------------------------------------------------------- Assign Role
                    775: 
                    776: sub assignrole {
1.21      www       777:     my ($udom,$uname,$url,$role,$end,$start)=@_;
                    778:     my $mrole;
1.29      www       779:     $url=~s/^\///;
                    780:     $url=~s/^res\///;
1.21      www       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);
1.17      www       825: }
                    826: 
                    827: # ------------------------------------------------------------ Directory lister
                    828: 
                    829: sub dirlist {
                    830:     my $uri=shift;
1.18      www       831:     $uri=~s/^\///;
                    832:     $uri=~s/\/$//;
1.19      www       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:    }
1.26      www       875: }
                    876: 
                    877: # -------------------------------------------------------- Value of a Condition
                    878: 
                    879: sub condval {
                    880:     my $condidx=shift;
                    881:     my $result=0;
                    882:     if ($ENV{'request.course'}) {
1.28      www       883:        if (defined($ENV{'acc.cond.'.$ENV{'request.course'}.'.'.$condidx})) {
1.26      www       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;
1.28      www       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') {
1.29      www       920: 	if ($space=~/^resource/) {
                    921: 	    $space=~s/^resource\[//;
                    922:             $space=~s/\]$//;
                    923: 
                    924:         } else {
                    925:         }
1.28      www       926:     } elsif ($realm eq 'course') {
                    927:     } elsif ($realm eq 'session') {
                    928:     } elsif ($realm eq 'system') {
                    929:     }
                    930:     return $value;
1.12      www       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: }
1.11      www       948: 
1.1       albertel  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);
1.8       www       960:            chomp($varvalue);
1.1       albertel  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: }
1.11      www       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; }
1.25      www      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:        }
1.11      www      1022:     }
                   1023: }
                   1024: 
1.22      www      1025: 
1.1       albertel 1026: $readit='done';
1.12      www      1027: &logthis('<font color=yellow>INFO: Read configuration</font>');
1.1       albertel 1028: }
                   1029: }
                   1030: 1;

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