--- loncom/lonsql	2006/05/11 17:53:22	1.77
+++ loncom/lonsql	2007/01/02 12:51:31	1.78
@@ -3,7 +3,7 @@
 # The LearningOnline Network
 # lonsql - LON TCP-MySQL-Server Daemon for handling database requests.
 #
-# $Id: lonsql,v 1.77 2006/05/11 17:53:22 albertel Exp $
+# $Id: lonsql,v 1.78 2007/01/02 12:51:31 raeburn Exp $
 #
 # Copyright Michigan State University Board of Trustees
 #
@@ -117,6 +117,8 @@ use Tie::RefHash;
 use DBI;
 use File::Find;
 use localenroll;
+use GDBM_File;
+use Storable qw(thaw);
 
 ########################################################
 ########################################################
@@ -471,6 +473,10 @@ sub make_new_child {
                 } else {
                     $result = 'success';
                 }
+            } elsif (($query eq 'portfolio_metadata') || 
+                    ($query eq 'portfolio_access')) {
+                $result = &portfolio_table_update($query,$arg1,$arg2,
+                                                  $arg3);
             } else {
                 # Do an sql query
                 $result = &do_sql_query($query,$arg1,$arg2,$searchdomain);
@@ -632,6 +638,166 @@ sub do_sql_query {
 } # End of &do_sql_query
 
 } # End of scoping curly braces for &process_file and &do_sql_query
+
+sub portfolio_table_update { 
+    my ($query,$arg1,$arg2,$arg3) = @_;
+    my %tablenames = (
+                       'portfolio'   => 'portfolio_metadata',
+                       'access'      => 'portfolio_access',
+                       'addedfields' => 'portfolio_addedfields',
+                     );
+    my $result = 'ok';
+    my $tablechk = &check_table($query);
+    if ($tablechk == 0) {
+        my $request =
+   &LONCAPA::lonmetadata::create_metadata_storage($query,$query);
+        $dbh->do($request);
+        if ($dbh->err) {
+            &logthis("create $query".
+                     " ERROR: ".$dbh->errstr);
+                     $result = 'error';
+        }
+    }
+    if ($result eq 'ok') {
+        my ($uname,$udom) = split(/:/,&unescape($arg1));
+        my $file_name = &unescape($arg2);
+        my $group = &unescape($arg3);
+        my $is_course = 0;
+        if ($group ne '') {
+            $is_course = 1;
+        }
+        my $urlstart = '/uploaded/'.$udom.'/'.$uname;
+        my $pathstart = &propath($udom,$uname).'/userfiles';
+        my ($fullpath,$url);
+        if ($is_course) {
+            $fullpath = $pathstart.'/groups/'.$group.'/portfolio'.
+                        $file_name;
+            $url = $urlstart.'/groups/'.$group.'/portfolio'.$file_name;
+        } else {
+            $fullpath = $pathstart.'/portfolio'.$file_name;
+            $url = $urlstart.'/portfolio'.$file_name;
+        }
+        my %access = &get_access_hash($uname,$udom,$group.$file_name);
+        if ($query eq 'portfolio_metadata') {
+            if (-e $fullpath.'.meta') {
+                my %loghash = &LONCAPA::lonmetadata::process_portfolio_metadata($dbh,undef,\%tablenames,$url,$fullpath,$is_course,$udom,$uname,$group,'update');
+                if (keys(%loghash) > 0) {
+                    &portfolio_logging(%loghash);
+                }
+            }
+        } elsif ($query eq 'portfolio_access') {
+            my %loghash =
+     &LONCAPA::lonmetadata::process_portfolio_access_data($dbh,undef,
+         \%tablenames,$url,$fullpath,\%access,'update');
+            if (keys(%loghash) > 0) {
+                &portfolio_logging(%loghash);
+            } else {
+                my $available = 0;
+                foreach my $key (keys(%access)) {
+                    my ($num,$scope,$end,$start) =
+                        ($key =~ /^([^:]+):([a-z]+)_(\d*)_?(\d*)$/);
+                    if ($scope eq 'public' || $scope eq 'guest') {
+                        $available = 1;
+                        last;
+                    }
+                }
+                if ($available) {
+                    # Retrieve current values
+                    my $condition = 'url='.$dbh->quote("$url");
+                    my ($error,$row) =
+    &LONCAPA::lonmetadata::lookup_metadata($dbh,$condition,undef,
+                                           'portfolio_metadata');
+                    if (!$error) {
+                        if (!(ref($row->[0]) eq 'ARRAY')) {  
+                            my %loghash =
+     &LONCAPA::lonmetadata::process_portfolio_metadata($dbh,undef,
+         \%tablenames,$url,$fullpath,$is_course,$udom,$uname,$group);
+                            if (keys(%loghash) > 0) {
+                                &portfolio_logging(%loghash);
+                            }
+                        } 
+                    }
+                }
+            }
+        }
+    }
+    return $result;
+}
+
+sub get_access_hash {
+    my ($uname,$udom,$file) = @_;
+    my $hashref = &tie_user_hash($udom,$uname,'file_permissions',
+                                 &GDBM_READER());
+    my %curr_perms;
+    my %access; 
+    if ($hashref) {
+        while (my ($key,$value) = each(%$hashref)) {
+            $key = &unescape($key);
+            next if ($key =~ /^error: 2 /);
+            $curr_perms{$key}=&thaw_unescape($value);
+        }
+        if (!&untie_user_hash($hashref)) {
+            &logthis("error: ".($!+0)." untie (GDBM) Failed");
+        }
+    } else {
+        &logthis("error: ".($!+0)." tie (GDBM) Failed");
+    }
+    if (keys(%curr_perms) > 0) {
+        if (ref($curr_perms{$file."\0".'accesscontrol'}) eq 'HASH') {
+            foreach my $acl (keys(%{$curr_perms{$file."\0".'accesscontrol'}})) {
+                $access{$acl} = $curr_perms{$file."\0".$acl};
+            }
+        }
+    }
+    return %access;
+}
+
+sub thaw_unescape {
+    my ($value)=@_;
+    if ($value =~ /^__FROZEN__/) {
+        substr($value,0,10,undef);
+        $value=&unescape($value);
+        return &thaw($value);
+    }
+    return &unescape($value);
+}
+
+###########################################
+sub check_table {
+    my ($table_id) = @_;
+    my $sth=$dbh->prepare('SHOW TABLES');
+    $sth->execute();
+    my $aref = $sth->fetchall_arrayref;
+    $sth->finish();
+    if ($sth->err()) {
+        &logthis("fetchall_arrayref after SHOW TABLES".
+            " ERROR: ".$sth->errstr);
+        return undef;
+    }
+    my $result = 0;
+    foreach my $table (@{$aref}) {
+        if ($table->[0] eq $table_id) { 
+            $result = 1;
+            last;
+        }
+    }
+    return $result;
+}
+
+###########################################
+
+sub portfolio_logging {
+    my (%portlog) = @_;
+    foreach my $key (keys(%portlog)) {
+        if (ref($portlog{$key}) eq 'HASH') {
+            foreach my $item (keys(%{$portlog{$key}})) {
+                &logthis($portlog{$key}{$item});
+            }
+        }
+    }
+}
+
+
 ########################################################
 ########################################################