#!/usr/bin/env perl # # '$RCSfile$' # Copyright: 2000 Regents of the University of California # # '$Author$' # '$Date$' # '$Revision$' # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA # # # This is a CGI application for inserting metadata documents into # the Metacat database. It utilizes the Metacat.pm module for most work. # In this script, we process the form fields passed in from a POST, insert a # metadata document and an ACL document. use lib '../WEB-INF/lib'; use Metacat; use Config::Properties; use Cwd 'abs_path'; use XML::LibXML; use XML::LibXSLT; use Template; use Net::SMTP; use CGI qw/:standard :html3/; use CGI::Session; use Digest::SHA1; use File::stat; use File::Basename; use File::Temp; use File::Copy; use Fcntl qw(:flock); use Crypt::JWT qw(decode_jwt); use Crypt::X509; use strict; #debug("running register-dataset.cgi"); # Global configuration paramters my $cgiDir = $ENV{'SCRIPT_FILENAME'}; my $workingDirectory = "."; if ( $cgiDir ne "" ) { my $workingDirectory = dirname($cgiDir); } my $metacatProps = "${workingDirectory}/../WEB-INF/metacat.properties"; my $properties = new Config::Properties(); unless ( open( METACAT_PROPERTIES, $metacatProps ) ) { print "Content-type: text/html\n\n"; print "Unable to locate Metacat properties. Working directory is set as '$workingDirectory', is this correct?"; exit(); } $properties->load(*METACAT_PROPERTIES); # local directory configuration my $skinsDir = "${workingDirectory}/../style/skins"; my $templatesDir = abs_path("${workingDirectory}/../style/common/templates"); my $tempDir = $properties->getProperty('application.tempDir'); my $dataDir = $properties->getProperty('application.datafilepath'); my $metacatDir = "/var/metacat"; my $cnUrl = $properties->getProperty('D1Client.CN_URL'); my $cn = "server"; my $pem_file_path = "/tmp/server.pem"; my $der_file_path = "/tmp/server.der"; # Signing certificate file name is based on the CN environment if ( $cnUrl && $tempDir ) { my @parts = split(/\//, $cnUrl); $cn = $parts[2]; $pem_file_path = $tempDir . "/" . $cn . ".pem"; $der_file_path = $tempDir . "/" . $cn . ".der"; } # url configuration my $server = $properties->splitToTree( qr/\./, 'server' ); my $protocol = 'http://'; if ( $properties->getProperty('server.httpPort') eq '443' ) { $protocol = 'https://'; } my $contextUrl = $protocol . $properties->getProperty('server.name'); if ( $properties->getProperty('server.httpPort') ne '80' ) { $contextUrl = $contextUrl . ':' . $properties->getProperty('server.httpPort'); } $contextUrl = $contextUrl . '/' . $properties->getProperty('application.context'); my $metacatUrl = $contextUrl . "/metacat"; my $cgiPrefix = "/" . $properties->getProperty('application.context') . "/cgi-bin"; my $styleSkinsPath = $contextUrl . "/style/skins"; my $styleCommonPath = $contextUrl . "/style/common"; my $userManagementUrl = $properties->getProperty('auth.userManagementUrl'); my $now = time; # The party param index of the first creator role encountered my $firstCreatorIndex = -1; # Was a contact submitted in the form? my $hasContact = 0; # Was a metadataProvider submitted in the form? my $hasMetadataProvider = 0; # Import all of the HTML form fields as variables import_names('FORM'); # Must have a config to use Metacat my $skinName = ""; if ( hasContent($FORM::cfg) ) { $skinName = $FORM::cfg; } elsif ( hasContent( $ARGV[0] ) ) { $skinName = $ARGV[0]; } else { debug("No configuration set."); print "Content-type: text/html\n\n"; 'Registry Error: The registry requires a skin name to continue.'; exit(); } # Metacat isn't initialized, the registry will fail in strange ways. if ( !hasContent($metacatUrl) ) { debug("No Metacat."); print "Content-type: text/html\n\n"; 'Registry Error: Metacat is not initialized! Make sure' . ' MetacatUrl is set correctly in ' . $skinName . '.properties'; exit(); } # Set up the hash for returning data to the HTML templates my $templateVars = { 'status' => 'success' }; my $error = 0; my @errorMessages; my $skinProperties = new Config::Properties(); if ( !hasContent($skinName) ) { $error = "Application misconfigured. Please contact the administrator."; push( @errorMessages, $error ); } else { my $skinProps = "$skinsDir/$skinName/$skinName.properties"; unless ( open( SKIN_PROPERTIES, $skinProps ) ) { print "Content-type: text/html\n\n"; print "Unable to locate skin properties at $skinProps. Is this path correct?"; exit(); } $skinProperties->load(*SKIN_PROPERTIES); } # replacements for appconfig values using properties my $moderators = $properties->getProperty('auth.moderators'); my $config = $skinProperties->splitToTree( qr/\./, 'registry.config' ); my $templates = $skinProperties->splitToTree( qr/\./, 'registry.templates' ); my $modules = $skinProperties->splitToTree( qr/\./, 'registry.modules' ); my $required = $skinProperties->splitToTree( qr/\./, 'registry.required' ); my $spatial = $skinProperties->splitToTree( qr/\./, 'registry.spatial' ); my $show = $skinProperties->splitToTree( qr/\./, 'registry.show' ); # set stderr printing if configured my $debug_enabled = $config->{'debug'}; if ($FORM::debug) { $debug_enabled = $FORM::debug; } # skin owner credentials my $adminUsername = $config->{'username'}; my $adminPassword = $config->{'password'}; # contains sender, recipient, admin, mailhost my $skinEmail = $skinProperties->splitToTree( qr/\./, 'email' ); my $email = $properties->splitToTree( qr/\./, 'email' ); # override email properties with skin-based ones my @emailData = keys(%$email); foreach my $d (@emailData) { if ( %$skinEmail->{$d} ) { $email->{$d} = %$skinEmail->{$d}; } } # convert the lat and lon configs into usable data structures my @sitelist; my %siteLatDMS; my %siteLongDMS; while ( my ( $key, $value ) = each(%$spatial) ) { my ( $name, $lon, $lat ) = split( /\|/, $value ); my ( $latd, $latm, $lats, $latdir ) = split( /\|/, $lat ); my ( $lond, $lonm, $lons, $londir ) = split( /\|/, $lon ); push( @sitelist, $name ); $siteLatDMS{$name} = [ $latd, $latm, $lats, $latdir ]; $siteLongDMS{$name} = [ $lond, $lonm, $lons, $londir ]; } # set some configuration options for the template object my $ttConfig = { INCLUDE_PATH => $templatesDir, INTERPOLATE => 0, POST_CHOMP => 1, DEBUG => 1, }; # create an instance of the template processor my $template = Template->new($ttConfig) || die $Template::ERROR, "\n"; #print "Content-type: text/html\n\n"; #print "Is debug enabled? `$debug_enabled`"; #use Data::Dumper; #print Dumper($config); #exit; # Set up the template information that is common to all forms $$templateVars{'contextUrl'} = $contextUrl; $$templateVars{'styleSkinsPath'} = $styleSkinsPath; $$templateVars{'styleCommonPath'} = $styleCommonPath; $$templateVars{'cgiPrefix'} = $cgiPrefix; $$templateVars{'metacatUrl'} = $metacatUrl; $$templateVars{'cfg'} = $skinName; $$templateVars{'email'} = $email; $$templateVars{'templates'} = $templates; $$templateVars{'required'} = $required; $$templateVars{'config'} = $config; $$templateVars{'userManagementUrl'} = $userManagementUrl; debug("Initialized -- stage set: $FORM::stage"); # handle pids, set the mapped docid in the FORM params # see: https://projects.ecoinformatics.org/ecoinfo/issues/5932 debug("PID: $FORM::pid"); if ($FORM::pid ne "" ) { my $pid = $FORM::pid; my $metacat = Metacat->new($metacatUrl); my $docid = $metacat->getDocid($pid); $FORM::docid = $docid; } # Process the form based on stage parameter. if ( $FORM::stage =~ "loginform" ) { print "Content-type: text/html\n\n"; # Send back the login form..... my $session = CGI::Session->load() or die CGI::Session->errstr(); if ( $FORM::submission eq 'true' ) { $$templateVars{'message'} = 'You must login to view your submissions.'; } if ( !$session->is_empty ) { # session found ... delete the session.... $session->delete(); } $template->process( $templates->{'login'}, $templateVars ); exit(); } elsif ( $FORM::stage =~ "logout" ) { handleLogoutRequest(); exit(); } elsif ( $FORM::stage =~ "login" ) { handleLoginRequest(); exit(); } elsif ( $FORM::stage =~ "mod_accept" ) { handleModAccept(); exit(); } elsif ( $FORM::stage =~ "mod_decline" ) { handleModDecline(); exit(); } elsif ( $FORM::stage =~ "mod_revise" ) { handleModRevise(); exit(); } elsif ( $FORM::stage =~ "read" ) { handleRead(); exit(); } elsif ( $FORM::stage =~ "review_frame" ) { handleReviewFrame(); exit(); } print "Content-type: text/html\n\n"; if ( $FORM::stage =~ "guide" ) { # Send back the information on how to fill the form $$templateVars{'section'} = "Guide on How to Complete Registry Entries"; $template->process( $templates->{'guide'}, $templateVars ); exit(); } elsif ( $FORM::stage =~ "insert" ) { # The user has entered the data. Do data validation and send back data # to confirm the data that has been entered. toConfirmData(); exit(); } elsif ($FORM::dataWrong =~ "No, go back to editing" && $FORM::stage =~ "confirmed" ) { # The user wants to correct the data that he has entered. # Hence show the data again in entryData form. confirmDataToReEntryData(); exit(); } elsif ( $FORM::stage =~ "modify" ) { #debug("in modify stage"); # Modification of a file has been requested. # check if the user is logged in... if ( !validateSession() ) { # no session found ... redirect to login page template $$templateVars{'message'} = 'Please login to modify your dataset.'; $template->process( $templates->{'login'}, $templateVars ); } else { # Show the form will all the values filled in. my @sortedSites; foreach my $site ( sort @sitelist ) { push( @sortedSites, $site ); } $$templateVars{'siteList'} = \@sortedSites; $$templateVars{'section'} = "Modification Form"; my ( $foundScope, $id, $rev ) = split( /\./, $FORM::docid ); if ( !$rev ) { my $metacat = Metacat->new($metacatUrl); my $lastRev = $metacat->getLastRevision($FORM::docid); $$templateVars{'docid'} = $FORM::docid . "." . $lastRev; } else { $$templateVars{'docid'} = $FORM::docid; } modifyData(); } exit(); } elsif ( $FORM::stage =~ "delete_confirm" ) { # Result from deleteData form. if ( $FORM::deleteData =~ "Delete document" ) { # delete Data deleteData(1); exit(); } else { $$templateVars{'status'} = "Cancel"; $$templateVars{'function'} = "cancel"; $template->process( $templates->{'response'}, $templateVars ); exit(); } } elsif ( $FORM::stage =~ "delete" ) { # Deletion of a file has been requested. # Ask for username and password using deleteDataForm $$templateVars{'docid'} = $FORM::docid; $template->process( $templates->{'deleteData'}, $templateVars ); exit(); } elsif ( $FORM::stage !~ "confirmed" ) { # None of the stages have been reached and data is not being confirmed. # check if the user is logged in... if ( ! validateSession() ) { # no session found ... redirect to login page template $$templateVars{'showInstructions'} = 'true'; $$templateVars{'message'} = 'Please login to register your dataset.'; $template->process( $templates->{'login'}, $templateVars ); } else { # Hence, send back entry form for entry of data. debug("Sending form"); my @sortedSites; foreach my $site ( sort @sitelist ) { push( @sortedSites, $site ); } if ( $skinName eq 'nceas' ) { my $projects = getProjectList($properties); $$templateVars{'projects'} = $projects; $$templateVars{'wg'} = \@FORM::wg; } $$templateVars{'modules'} = $modules; $$templateVars{'required'} = $required; $$templateVars{'templates'} = $templates; $$templateVars{'show'} = $show; $$templateVars{'site'} = $config->{'site'}; $$templateVars{'siteList'} = \@sortedSites; $$templateVars{'section'} = "Entry Form"; $$templateVars{'docid'} = ""; debug("Sending form: ready to process template"); $template->process( $templates->{'entry'}, $templateVars ); debug("Sending form: template processed"); } exit(); } # Confirm stage has been reached. Enter the data into metacat. # Initialize some global vars my $latDeg1 = ""; my $latMin1 = ""; my $latSec1 = ""; my $hemisphLat1 = ""; my $longDeg1 = ""; my $longMin1 = ""; my $longSec1 = ""; my $hemisphLong1 = ""; my $latDeg2 = ""; my $latMin2 = ""; my $latSec2 = ""; my $hemisphLat2 = ""; my $longDeg2 = ""; my $longMin2 = ""; my $longSec2 = ""; my $hemisphLong2 = ""; my $modUsername = ""; my $modPassword = ""; # validate the input form parameters my $invalidParams; if ( !$error ) { $invalidParams = validateParameters(1); if ( scalar(@$invalidParams) ) { $$templateVars{'status'} = 'failure'; $$templateVars{'invalidParams'} = $invalidParams; $error = 1; } } my $docid; my $scope = $FORM::scope; if(($scope eq "") || (!$scope)){ $scope = $config->{'scope'}; } # Create a metacat object my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); if ( !$error ) { # Login to metacat if there is no authentication token my $response = hasValidAuthToken(); if ( ! $response ) { my ( $username, $password ) = getCredentials(); $response = $metacat->login( $username, $password ); my $errorMessage = ""; } # Parameters have been validated and Create the XML document my $xmldoc = createXMLDocument(); my $xmldocWithDocID = $xmldoc; my $errorMessage = ""; if ( !$response ) { debug("No response from Metacat"); push( @errorMessages, $metacat->getMessage() ); push( @errorMessages, "Failed during login.\n" ); $$templateVars{'status'} = 'login_failure'; $$templateVars{'errorMessages'} = \@errorMessages; $$templateVars{'docid'} = $docid; $$templateVars{'cfg'} = $skinName; $$templateVars{'function'} = "submitted"; $$templateVars{'section'} = "Submission Status"; $template->process( $templates->{'response'}, $templateVars ); exit(); } else { if ( $config->{'adminIsDocOwner'} eq 'true' ) { debug("adminIsDocOwner is set."); $response = $metacat->login( $adminUsername, $adminPassword ); if ( !$response ) { push( @errorMessages, $metacat->getMessage() ); push( @errorMessages, "Failed during login for admin.\n" ); $$templateVars{'status'} = 'login_failure'; $$templateVars{'errorMessages'} = \@errorMessages; $$templateVars{'docid'} = $docid; $$templateVars{'cfg'} = $skinName; $$templateVars{'function'} = "submitted"; $$templateVars{'section'} = "Submission Status"; $template->process( $templates->{'response'}, $templateVars ); exit(); } } debug("Checking for a FORM docid."); if ( $FORM::docid eq "" ) { debug("No FORM docid is present. Generating one from Metacat."); # document is being inserted my $docStatus = "INCOMPLETE"; while ($docStatus eq "INCOMPLETE") { #Create the docid $docid = newDocid($scope, $metacat); $xmldocWithDocID =~ s/docid/$docid/; debugDoc($xmldocWithDocID); $docStatus = insertMetadata( $xmldocWithDocID, $docid ); } if ( $docStatus ne "SUCCESS" ) { debug("NO SUCCESS"); debug("Message is: $docStatus"); push( @errorMessages, $docStatus ); } else{ deleteRemovedData(); } } else { debug("The form has an existing docid: " . $FORM::docid); # document is being modified $docid = incrementRevision($FORM::docid); $xmldoc =~ s/docid/$docid/; debugDoc($xmldoc); debug('Updating docid: ' . $docid); my $response = $metacat->update( $docid, $xmldoc ); if ( !$response ) { push( @errorMessages, $metacat->getMessage() ); push( @errorMessages, "Failed while updating.\n" ); } debug("Updated document with docid: $docid"); if ( scalar(@errorMessages) ) { debug("Errors defined in modify."); $$templateVars{'docid'} = $FORM::docid; copyFormToTemplateVars(); $$templateVars{'status'} = 'failure'; $$templateVars{'errorMessages'} = \@errorMessages; $error = 1; } else { deleteRemovedData(); $$templateVars{'docid'} = $docid; $$templateVars{'cfg'} = $skinName; } # Create our HTML response and send it back $$templateVars{'function'} = "modified"; $$templateVars{'section'} = "Modification Status"; $template->process( $templates->{'response'}, $templateVars ); # send a notification email to the moderator if ( hasContent($FORM::cfg) && $FORM::cfg eq 'esa' ) { my $title = ""; my $contactEmailAddress = ""; my $contactName = ""; my $parser = XML::LibXML->new(); my $parsedDoc = $parser->parse_string($xmldoc); $FORM::function = 'modified'; my $findNodes = $parsedDoc->findnodes('//dataset/title'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $title = findValue( $node, '../title' ); } } $findNodes = $parsedDoc->findnodes('//dataset/contact'); if ( $findNodes->size() > 0 ) { # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { my $surName = findValue( $node, 'individualName/surName' ); my $givenName = findValue( $node, 'individualName/givenName' ); my $organizationName = findValue( $node, 'organizationName' ); if ( $surName ne '' ) { $contactName = $givenName . ' ' . $surName; } else { $contactName = $organizationName; } } } $FORM::docid = $docid; modSendNotification( $title, $contactEmailAddress, $contactName, "Document $docid modification review pending" ); } exit(); } } if ( hasContent($FORM::cfg) && $FORM::cfg eq 'esa' ) { my $title = ""; my $contactEmailAddress = ""; my $contactName = ""; my $parser = XML::LibXML->new(); my $parsedDoc = $parser->parse_string($xmldoc); my $findNodes = $parsedDoc->findnodes('//dataset/title'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $title = findValue( $node, '../title' ); } } $findNodes = $parsedDoc->findnodes('//dataset/contact'); if ( $findNodes->size() > 0 ) { # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $contactEmailAddress = findValue( $node, 'electronicMailAddress' ); my $surName = findValue( $node, 'individualName/surName' ); my $givenName = findValue( $node, 'individualName/givenName' ); my $organizationName = findValue( $node, 'organizationName' ); if ( $surName ne '' ) { $contactName = $givenName . ' ' . $surName; } else { $contactName = $organizationName; } } } $FORM::docid = $docid; modSendNotification( $title, $contactEmailAddress, $contactName, "Document $docid review pending" ); } } if ( scalar(@errorMessages) ) { debug("ErrorMessages defined."); $$templateVars{'docid'} = $FORM::docid; copyFormToTemplateVars(); $$templateVars{'status'} = 'failure'; $$templateVars{'errorMessages'} = \@errorMessages; $error = 1; } else { $$templateVars{'docid'} = $docid; $$templateVars{'cfg'} = $skinName; # delete the remaining file objects from disk for ( my $fileNum = 0 ; $fileNum <= $FORM::upCount ; $fileNum++ ) { my $fn = 'uploadname_' . $fileNum; if ( hasContent( param($fn) ) ) { deleteFile( param($fn) ); } } } # Create our HTML response and send it back $$templateVars{'function'} = "submitted"; $$templateVars{'section'} = "Submission Status"; $template->process( $templates->{'response'}, $templateVars ); exit(); ################################################################################ # # Subroutine for inserting a document to metacat # ################################################################################ sub insertMetadata { my $xmldoc = shift; my $docid = shift; debug("Trying to insert the following document"); my $docStatus = "SUCCESS"; debug("Starting insert of $docid"); my $response = $metacat->insert( $docid, $xmldoc ); if ( !$response ) { debug("Response gotten for docid: " . $docid); my $errormsg = $metacat->getMessage(); debug( "Error is: " . $errormsg ); if ( $errormsg =~ /is already in use/ ) { $docStatus = "INCOMPLETE"; } elsif ( $errormsg =~ // ) { $docStatus = "SUCCESS"; } else { $docStatus = $errormsg; } } debug("Ending insert of docid: " . $docid); return $docStatus; } ################################################################################ # # Subroutine for generating a new accession number # Note: this is not threadsafe, assumes only one running process at a time # Also: need to check metacat for max id # used in this scope already ################################################################################ sub newAccessionNumber { my $scope = shift; my $metacat = shift; my $errormsg = 0; my $docid = $metacat->getLastId($scope); if ( !$docid ) { $docid = "$scope.1.1"; debug( "Error in newAccessionNumber: " . $metacat->getMessage() ); } else { my ( $foundScope, $id, $rev ) = split( /\./, $docid ); $id++; $docid = "$scope.$id.1"; } debug("Metcat handed us a new docid: $docid"); return $docid; } ################################################################################ # # Subroutine for generating a new docid # Checks a local file for the max id # in use for this scope. After several tries, # checks metacat using newAccessionNumber ################################################################################ sub newDocid { my $scope = shift; my $metacat = shift; my $scopeFound = 0; #Lock a local file while we are creating a new docid my $lockFilePath = "docids.lock"; open(LOCK, ">$lockFilePath"); flock(LOCK, LOCK_EX); my $lastdocid = newAccessionNumber($scope, $metacat); #Extract the docid number from the docid my @line = split(/\./, $lastdocid); my $num = $line[1]; my $docidsFilePath = $tempDir."/docids.txt"; my $docidsFilePathNew = $tempDir."/docids.txt.new"; #Open/create a local file while we are creating a new docid open my $docidsFile, '+<', $docidsFilePath; open my $docidsNewFile, '>', $docidsFilePathNew; #Read each docid scope,num in the file while( <$docidsFile> ) { my @line = split /,/; my $currentScope = $line[0]; if($currentScope eq $scope){ my $docidNum = $line[1] + 1; if($num > $docidNum){ $docid = "$scope.$num.1"; print $docidsNewFile "$scope,$num \n"; } else{ $docid = "$scope.$docidNum.1"; print $docidsNewFile "$scope,$docidNum \n"; } $scopeFound = 1; } else{ print $docidsNewFile $_; } } #If this scope is not in the local docid store then add it if(!$scopeFound){ #Add to the local file print $docidsNewFile "$scope,$num \n"; } #Close the file and replace the old docids file with this new one close $docidsNewFile; close $docidsFile; move($docidsFilePathNew, $docidsFilePath); close LOCK; return $docid; } sub incrementRevision { my $initDocid = shift; my $docid = ''; if ( !$initDocid ) { debug("No docid entered."); } else { my ( $scope, $id, $rev ) = split( /\./, $initDocid ); $rev++; $docid = "$scope.$id.$rev"; } return $docid; } ################################################################################ # # Validate the parameters to make sure that required params are provided # ################################################################################ sub validateParameters { my $chkUser = shift; my @invalidParams; push( @invalidParams, "Name of the Project is not selected in the form." ) if ( scalar(@FORM::wg) == 0 && $required->{'wgList'} eq 'true' ); push( @invalidParams, "Please provide a dataset title." ) unless hasContent($FORM::title); if ( $show->{'siteList'} eq 'true' ) { push( @invalidParams, ucfirst( $config->{'site'} ) . " name is missing." ) unless ( ( hasContent($FORM::site) && !( $FORM::site =~ /^Select/ ) ) || $skinName eq "nceas" ); } if ( $required->{'funding'} eq 'true' ) { push( @invalidParams, "Please provide an award number." ) unless hasContent($FORM::funding); } push( @invalidParams, "Please provide a person's first name, last name, and role, or an organization name and it's role.") unless ((hasContent($FORM::partyFirstName) && hasContent($FORM::partyLastName) && hasContent($FORM::partyRole)) || (hasContent($FORM::partyOrgName) && hasContent($FORM::partyRole))); my @partyRoles = param('partyRole'); my $hasCreator = 0; foreach my $partyRole (@partyRoles) { if ( $partyRole eq 'creator' ) { $hasCreator = 1; last; } } push( @invalidParams, "Please provide a party entry with a 'Creator' role." ) unless $hasCreator == 1; push( @invalidParams, "Please provide a dataset abstract." ) unless hasContent($FORM::abstract); if ( $modules->{'temporal'} eq 'true' ) { push( @invalidParams, "Please provide a start date year." ) unless ( hasContent($FORM::beginningYear) || $required->{'temporal'} ne 'true' ); push( @invalidParams, "Year of stop date has been specified but year of start date is missing." ) if ( ( !hasContent($FORM::beginningYear) ) && hasContent($FORM::endingYear) ); } push( @invalidParams, "Please provide a geographic description." ) unless ( hasContent($FORM::geogdesc) || $required->{'spatial'} ne 'true' ); if ( $FORM::beginningMonth eq "MM" ) { $FORM::beginningMonth = ""; } if ( $FORM::beginningDay eq "DD" ) { $FORM::beginningDay = ""; } if ( $FORM::endingMonth eq "MM" ) { $FORM::endingMonth = ""; } if ( $FORM::endingDay eq "DD" ) { $FORM::endingDay = ""; } if ( hasContent($FORM::beginningYear) && !( $FORM::beginningYear =~ /[0-9]{4}/ ) ) { push( @invalidParams, "Please provide a four digit start date." ); } if ( hasContent($FORM::endingYear) && !( $FORM::endingYear =~ /[0-9]{4}/ ) ) { push( @invalidParams, "Please provide a four digit stop date." ); } # If the "use site" coord. box is checked and if the site is in # the longitude hash ... && ($siteLatDMS{$FORM::site}) if ( $modules->{'spatial'} eq 'true' ) { if ( ($FORM::useSiteCoord) && ( $siteLatDMS{$FORM::site} ) ) { $latDeg1 = $siteLatDMS{$FORM::site}[0]; $latMin1 = $siteLatDMS{$FORM::site}[1]; $latSec1 = $siteLatDMS{$FORM::site}[2]; $hemisphLat1 = $siteLatDMS{$FORM::site}[3]; $longDeg1 = $siteLongDMS{$FORM::site}[0]; $longMin1 = $siteLongDMS{$FORM::site}[1]; $longSec1 = $siteLongDMS{$FORM::site}[2]; $hemisphLong1 = $siteLongDMS{$FORM::site}[3]; } else { $latDeg1 = $FORM::latDeg1; $latMin1 = $FORM::latMin1; $latSec1 = $FORM::latSec1; $hemisphLat1 = $FORM::hemisphLat1; $longDeg1 = $FORM::longDeg1; $longMin1 = $FORM::longMin1; $longSec1 = $FORM::longSec1; $hemisphLong1 = $FORM::hemisphLong1; } if ( $latDeg1 > 90 || $latDeg1 < 0 ) { push( @invalidParams, "Invalid first latitude degrees specified." ); } if ( $latMin1 > 59 || $latMin1 < 0 ) { push( @invalidParams, "Invalid first latitude minutes specified." ); } if ( $latSec1 > 59 || $latSec1 < 0 ) { push( @invalidParams, "Invalid first latitude seconds specified." ); } if ( $longDeg1 > 180 || $longDeg1 < 0 ) { push( @invalidParams, "Invalid first longitude degrees specified." ); } if ( $longMin1 > 59 || $longMin1 < 0 ) { push( @invalidParams, "Invalid first longitude minutes specified." ); } if ( $longSec1 > 59 || $longSec1 < 0 ) { push( @invalidParams, "Invalid first longitude seconds specified." ); } if ( hasContent($FORM::latDeg2) && ( $FORM::latDeg2 > 90 || $FORM::latDeg2 < 0 ) ) { push( @invalidParams, "Invalid second latitude degrees specified." ); } if ( hasContent($FORM::latMin2) && ( $FORM::latMin2 > 59 || $FORM::latMin2 < 0 ) ) { push( @invalidParams, "Invalid second latitude minutes specified." ); } if ( hasContent($FORM::latSec2) && ( $FORM::latSec2 > 59 || $FORM::latSec2 < 0 ) ) { push( @invalidParams, "Invalid second latitude seconds specified." ); } if ( hasContent($FORM::latDeg2) && ( $FORM::longDeg2 > 180 || $FORM::longDeg2 < 0 ) ) { push( @invalidParams, "Invalid second longitude degrees specified." ); } if ( hasContent($FORM::latMin2) && ( $FORM::longMin2 > 59 || $FORM::longMin2 < 0 ) ) { push( @invalidParams, "Invalid second longitude minutes specified." ); } if ( hasContent($FORM::latSec2) && ( $FORM::longSec2 > 59 || $FORM::longSec2 < 0 ) ) { push( @invalidParams, "Invalid second longitude seconds specified." ); } } # Check if latDeg1 and longDeg1 has values if useSiteCoord is used. # This check is required because some of the sites dont have lat # and long mentioned in the config file. if ( $modules->{'spatial'} eq 'true' && $required->{'spatial'} eq 'true' ) { if ($FORM::useSiteCoord) { push( @invalidParams, "The Data Registry doesn't have latitude and longitude information for the site that you chose. Please go back and enter the spatial information." ) unless ( hasContent($latDeg1) && hasContent($longDeg1) ); } else { push( @invalidParams, "Latitude degrees are missing." ) unless ( hasContent($latDeg1) || $required->{'spatial'} ne 'true' ); push( @invalidParams, "Longitude degrees are missing." ) unless ( hasContent($longDeg1) || $required->{'spatial'} ne 'true' ); } push( @invalidParams, "You must provide a geographic description if you provide latitude and longitude information." ) if ( ( hasContent($latDeg1) || ( hasContent($longDeg1) ) ) && ( !hasContent($FORM::geogdesc) ) ); } if ( $modules->{'method'} eq 'true' ) { push( @invalidParams, "You must provide a method description if you provide a method title." ) if ( hasContent($FORM::methodTitle) && ( !( scalar(@FORM::methodPara) > 0 ) || ( !hasContent( $FORM::methodPara[0] ) ) ) ); push( @invalidParams, "You must provide a method description if you provide an extent of study description." ) if ( hasContent($FORM::studyExtentDescription) && ( !( scalar(@FORM::methodPara) > 0 ) || ( !hasContent( $FORM::methodPara[0] ) ) ) ); push( @invalidParams, "You must provide both an extent of study description and a sampling description, or neither." ) if ( ( hasContent($FORM::studyExtentDescription) && !hasContent($FORM::samplingDescription) ) || ( !hasContent($FORM::studyExtentDescription) && hasContent($FORM::samplingDescription) ) ); } if ( $modules->{'upload'} eq 'true' ) { for ( my $upNum = 0 ; $upNum <= $FORM::upCount ; $upNum++ ) { my $upn = "upload_$upNum"; if ( hasContent( param($upn) ) && !grep { $_ eq ("uploadname_$upNum") } @FORM::deletefile ) { push( @invalidParams, "Must select a permission for file " . param("uploadname_$upNum") ) if ( !hasContent( param("uploadperm_$upNum") ) ); } } } push( @invalidParams, "Please provide the data medium." ) unless ( hasContent($FORM::dataMedium)); push( @invalidParams, "Please provide usage rights." ) unless ( hasContent($FORM::useConstraints) ); if ( $FORM::useConstraints eq 'other' ) { push( @invalidParams, "Must enter custom usage rights when 'other' is selected." ) unless ( hasContent($FORM::useConstraintsOther) ); } return \@invalidParams; } ################################################################################ # # utility function to determine if a paramter is defined and not an empty string # ################################################################################ sub hasContent { my $param = shift; my $paramHasContent; if ( !defined($param) || $param eq '' ) { $paramHasContent = 0; } else { $paramHasContent = 1; } return $paramHasContent; } ################################################################################ # # Subroutine for replacing characters not recognizable by XML and otherwise. # ################################################################################ sub normalize { my $val = shift; $val =~ s/&/&/g; $val =~ s//>/g; $val =~ s/\"/"/g; $val =~ s/%/%/g; my $returnVal = ""; foreach ( split( //, $val ) ) { my $var = unpack "C*", $_; if ( $var < 128 && $var > 31 ) { $returnVal = $returnVal . $_; } elsif ( $var < 32 ) { if ( $var == 10 ) { $returnVal = $returnVal . $_; } if ( $var == 13 ) { $returnVal = $returnVal . $_; } if ( $var == 9 ) { $returnVal = $returnVal . $_; } } else { $returnVal = $returnVal . $_; } } return $returnVal; } ################################################################################ # # Subroutine for replacing characters not recognizable by XML and otherwise # except for ", > amd <. # ################################################################################ sub delNormalize { my $val = shift; $val =~ s/&/&/g; $val =~ s/%/%/g; my $returnVal = ""; foreach ( split( //, $val ) ) { my $var = unpack "C*", $_; if ( $var < 128 && $var > 31 ) { $returnVal = $returnVal . $_; } elsif ( $var < 32 ) { if ( $var == 10 ) { $returnVal = $returnVal . $_; } if ( $var == 13 ) { $returnVal = $returnVal . $_; } if ( $var == 9 ) { $returnVal = $returnVal . $_; } } else { $returnVal = $returnVal . "&#" . $var . ";"; } } $returnVal =~ s/&/%26/g; return $returnVal; } ################################################################################ # # Subroutine for replacing characters that might create problem in HTML. # Specifically written for " being used in any text field. This creates a # problem in confirmData template, when you specify input name value pair # with value having a " in it. # ################################################################################ sub normalizeCD { my $val = shift; $val =~ s/\"/"/g; return $val; } ################################################################################ # # Upload new file objects into Metacat, if they're present and valid. # ################################################################################ sub allFileData { if ( $debug_enabled ) { debug("allFileData() called. "); } my %uploadedFiles = (); my $fileInfo; my $docid; for ( my $fileNum = 0 ; $fileNum <= $FORM::upCount ; $fileNum++ ) { my $fn = 'upload_' . $fileNum; if ( hasContent( param($fn) ) ) { # ignore data which is scheduled for deletion if ( grep { $_ eq ("uploadname_$fileNum") } @FORM::deletefile ) { debug("Not generating metadata for file scheduled for deletion: $fn"); } else { debug("Retrieving metadata for file: $fn"); ( $docid, $fileInfo ) = fileMetadata($fileNum); $uploadedFiles{$docid} = $fileInfo; } } } return %uploadedFiles; } # Returns minimal metadata about an uploaded file: hash, name, content-type, permissions sub fileMetadata { if ( $debug_enabled ) { debug("fileMetadata() called."); } my $fileNum = shift; my $fileHash = param("upload_$fileNum"); my $fileName = param("uploadname_$fileNum"); my $contentType = param("uploadtype_$fileNum"); my $filePerm = param("uploadperm_$fileNum"); my $docid; my $outFile; my $cleanName = $fileName; # process an _existing_ data file, which is already within Metacat. if ( $fileHash =~ /ondisk/ ) { ( $docid, $fileHash ) = datafileInfo($fileHash); $outFile = $dataDir . "/" . $docid; } else { # normalize input filenames; Windows filenames include full paths $cleanName =~ s/.*[\/\\](.*)/$1/; $outFile = $tempDir . "/" . $cleanName; } debug("Reading file from disk: $outFile"); my $fileSize = stat($outFile)->size; if ( $fileSize == 0 ) { push( @errorMessages, "file $fileName is zero bytes!" ); debug("File $fileName is zero bytes!"); } # Now the file is on disk, send the object to Metacat if ( ! validateSession() ) { push( @errorMessages, "Must be logged in to upload files." ); debug("Not logged in, cannot upload files."); return 0; } # remove the uniqueness of the filename # 'tempXXXXX' if it exists if ( $cleanName =~ /^temp[A-Za-z0-9_]{5}/ && length($cleanName) > 9 ) { $cleanName = substr($cleanName, 9); } if ( !$docid ) { my $uploadStatus = shift; while(!$uploadStatus){ $docid = newDocid($scope, $metacat); $uploadStatus = uploadData( $outFile, $docid, $cleanName ); if ( !$uploadStatus ) { debug("Uploading the data failed."); push( @errorMessages, "Data file $cleanName failed to upload"); } } } my $entityid = $fileHash . "001"; my $distribid = $fileHash . "002"; my $uploadUrl = 'ecogrid://knb/' . $docid; # TODO: should match the object promotion path, so that an # Excel upload results in 'dataTable' in this field my $entityType = 'Other'; my %dataInfo = ( 'docid' => $docid, 'entityid' => $entityid, 'distribid' => $distribid, 'fileName' => $cleanName, 'fileSize' => $fileSize, 'fileHash' => $fileHash, 'filePerm' => $filePerm, 'contentType' => $contentType, 'url' => $uploadUrl, 'entityType' => $entityType, ); return ( $docid, \%dataInfo ); } # Returns the docid and SHA1 hash from the colon-delimited string sub datafileInfo { my $finfo = shift; $finfo =~ s/ondisk://g; return my ( $docid, $fileHash ) = split( ":", $finfo ); } sub processFile { my $fileName = shift; # test that we actually got a file if ( !$fileName || cgi_error() ) { debug( "Error receiving file " . cgi_error() ); } debug( "Process file: " . $fileName ); # write file to disk, get SHA1 hash and size my ( $outFile, $fileHash ) = writeFile($fileName); debug( "processed file to temp directory: $outFile" ); my $fileSize = stat($outFile)->size; if ( $fileSize == 0 ) { push( @errorMessages, "file $fileName is zero bytes!" ); debug("File $fileName is zero bytes!"); } # file is in Metacat, generate the pertinent EML elements my $contentType = uploadInfo($fileName)->{'Content-Type'}; # occasionally CGI.pm doesn't get the file info. In this case, # use a default MIME type of text/plain. Seems fixed in the newer CGI.pm: # http://bugs.debian.org/cgi-bin/bugreport.cgi?bug=313141 if ( !$contentType ) { $contentType = 'text/plain'; } elsif ( $contentType =~ "application/vnd.ms-excel" && $fileName =~ /\.csv$/) { debug("Reassigning content type (" . $contentType . ")to CSV for file: " . $fileName); $contentType = 'text/csv'; } my %dataInfo = ( 'fileName' => $outFile, 'fileHash' => $fileHash, 'contentType' => $contentType, ); return \%dataInfo; } sub writeFile { my $fileName = shift; my $fileData; my $length = 0; my $buffer; my $cleanName = $fileName; # normalize input filenames; Windows filenames include full paths $cleanName =~ s/.*[\/\\](.*)/$1/; while ( my $bytesRead = read( $fileName, $buffer, 4096 ) ) { $fileData .= $buffer; $length += $bytesRead; } # create SHA1 sum to store file hash my $ctx = Digest::SHA1->new; $ctx->add($fileData); my $digest = $ctx->hexdigest; # use tempfile for writing my $tmp = File::Temp->new( TEMPLATE => 'tempXXXXX', DIR => $tempDir, SUFFIX => $cleanName, UNLINK => 0); my $outputName = $tmp->filename(); #open( OUT, ">$outputName" ) or die "Could not open: $!"; print $tmp $fileData; close($tmp); debug("Writing output, result is: $outputName"); return ( $outputName, $digest ); } sub deleteRemovedData { # if we have any associated datafiles which are scheduled for deletion, remove them now for ( my $delNum = 0 ; $delNum <= $FORM::delCount ; $delNum++ ) { # need to look up the actual upload number, which is contained in the name my $upNum = param("deletefile_$delNum"); $upNum =~ s/uploadname_//; my $upn = param("upload_$upNum"); if ( hasContent($upn) ) { debug("Deleting upload_$upNum, $upn"); if ( grep { $_ eq ("uploadname_$upNum") } @FORM::deletefile ) { if ( param("upload_$upNum") =~ /ondisk/ ) { debug( "got a file which is ondisk, proceeding with deletion"); deleteFileData( param("upload_$upNum") ); } else { debug( "got an old reference, not yet in EML, remove from tempdir" ); deleteFile( param("uploadname_$upNum") ); } } else { debug("Name didn't match in deletefile list"); } } } } sub deleteFile { my $input = shift; #my $fileName = $tempDir . "/" . $input; my $fileName = $input; if ( -e $fileName ) { unlink $fileName or debug("Failed to delete file $fileName."); } else { debug("Unable to find file $fileName"); } if ( !-e $fileName ) { debug("Successfully deleted $fileName"); } } sub deleteFileData { my $input = shift; my ( $docid, $fileHash ) = datafileInfo($input); my ($username, $password); my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); my $response = hasValidAuthToken(); if ( ! $response ) { ( $username, $password ) = getCredentials(); $response = $metacat->login( $username, $password ); } if ( !$response ) { my $msg = $metacat->getMessage(); push( @errorMessages, "Failed to login with credentials for `$username`. Error was $msg" ); debug( "Failed to login with given credentials for username $username, Error is: $msg" ); } else { $response = $metacat->delete($docid); if ( !$response ) { my $msg = $metacat->getMessage(); push( @errorMessages, "Failed to delete existing file. Error was: $msg" ); debug("Delete -- Error is: $msg"); } else { debug("Delete -- Success! Removed docid $docid"); } } } sub uploadData { my $data = shift; my $docid = shift; my $filename = shift; debug("Upload -- Starting upload of $docid"); my $response = $metacat->upload( $docid, $data, $filename ); if ( !$response ) { my $uploadMsg = $metacat->getMessage(); push( @errorMessages, "Failed to upload file. Error was: $uploadMsg\n" ); debug("Upload -- Error is: $uploadMsg"); } else { debug("Upload -- Success! New docid $docid"); } return $response; } ################################################################################ # # Create the XML document from the HTML form input # returns the XML document as a string # ################################################################################ sub createXMLDocument { if ( $debug_enabled ) { debug("createXMLDocument() called."); } #FIXME placeholder for $FORM element, should be determined by config if ( $skinName eq "ebm" ) { return createProjectDocument(); } else { return createDatasetDocument(); } } sub createProjectDocument { my $doc = EMLStart(); $doc .= accessElement(); $doc .= datasetStart(); $doc .= titleElement(); $doc .= createParties('creator'); if ( $hasMetadataProvider > 0 ) { $doc .= createParties('metadataProvider'); } else { copyFirstCreator('metadataProvider'); $doc .= createParties('metadataProvider'); } $doc .= pubElement(); $doc .= setDisplayType('project'); $doc .= keywordElement(); if ( $hasContact > 0 ) { $doc .= createParties('contact'); } else { copyFirstCreator('contact'); $doc .= createParties('contact'); } # putting everything else under project $doc .= ""; $doc .= titleElement(); $doc .= createParties('personnel'); $doc .= abstractElement(); $doc .= "\n"; $doc .= coverageElement(); $doc .= "\n"; $doc .= ""; $doc .= datasetEnd(); $doc .= EMLEnd(); return $doc; } sub createDatasetDocument { if ( $debug_enabled ) { debug("createDatasetDocument() called."); } my $doc = EMLStart(); $doc .= accessElement(); $doc .= datasetStart(); $doc .= titleElement(); $doc .= createParties('creator'); if ( $hasMetadataProvider > 0 ) { $doc .= createParties('metadataProvider'); } else { copyFirstCreator('metadataProvider'); $doc .= createParties('metadataProvider'); } $doc .= createParties('associatedParty'); $doc .= pubElement(); $doc .= abstractElement(); $doc .= keywordElement(); $doc .= distributionElement(); $doc .= coverageElement(); if ( $hasContact > 0 ) { $doc .= createParties('contact'); } else { copyFirstCreator('contact'); $doc .= createParties('contact'); } $doc .= createParties('publisher'); $doc .= methodsElement(); $doc .= fundingElement(); my %fileData = allFileData(); $doc .= entityElement( \%fileData ); $doc .= datasetEnd(); $doc .= EMLEnd(); } # EML document creation functions # Build a party element based on the party type passed in and the submitted party form fields. # Party types are limited to: # creator, contact, metadataProvider, publisher, personnel, and associatedParty sub createParties { my $partyType = shift; my $partiesStr = ""; my $partyStr = ""; my @associatedPartyRoles = [ 'principalInvestigator', 'coPrincipalInvestigator', 'collaboratingPrincipalInvestigator', 'custodianSteward', 'user']; # Process the party* parameters, first getting the indexed number foreach my $paramName ( param() ) { $partyStr = ""; my $partyNumber = $paramName; $partyNumber =~ s/partyRole//; # indexed number 1, 2, 3, etc # Check that the party number is valid if ( $partyNumber =~ /^([0-9]+)$/) { # The role we're processing my $partyRole = normalize(param("partyRole" . $partyNumber)); # Find the first creator index in the parties if present if ( $partyRole eq "creator" && $firstCreatorIndex == -1 ) { $firstCreatorIndex = $partyNumber; } # Find the first metadataProvider in the parties if present if ( $partyRole eq "metadataProvider" ) { $hasMetadataProvider = 1; } # Find the first contact in the parties if present if ( $partyRole eq "contact" ) { $hasContact = 1; } # Process roles corresponding to specific EML elements if ( $partyRole eq $partyType ) { debug("Role: " . $partyRole . " matches Type: " . $partyType ); $partyStr = createParty( $partyType, $partyRole, $partyNumber); # handle associated parties } elsif ( $partyType eq "associatedParty" && $partyRole ~~ @associatedPartyRoles ) { $partyStr = createParty( $partyType, $partyRole, $partyNumber); debug("Asscociated Party Type: " . $partyType . " and Role: " . $partyRole . " is in @associatedPartyRoles"); # handle personnel } elsif ( $partyType eq "personnel" && $partyRole ~~ @associatedPartyRoles ) { $partyStr = createParty( $partyType, $partyRole, $partyNumber); debug("Personnel Type: " . $partyType . " and Role: " . $partyRole . " is in @associatedPartyRoles"); } } $partiesStr .= $partyStr; } return $partiesStr; } # Build an EML party based on the given element type (creator, associatedParty, contact, publisher, personnel) sub createParty() { my $partyType = shift; my $partyRole = shift; my $partyNumber = shift; my $partyStr = ""; my $partyRole = ""; my $partyId = ""; my $partyFirstName = ""; my $partyLastName = ""; my $partyOrgName = ""; my $partyPositionName = ""; my $partyEmail = ""; my $partyURL = ""; my $partyPhone = ""; my $partyFAX = ""; my $partyDelivery = ""; my $partyCity = ""; my $partyState = ""; my $partyStateOther = ""; my $partyZIP = ""; my $partyCountry = ""; my $individualName = ""; my $organizationName = ""; my $positionName = ""; my $address = ""; my $phone = ""; my $fax = ""; my $email = ""; my $onlineUrl = ""; my $role = ""; if ( hasContent(param("partyRole" . $partyNumber))) { $partyRole = normalize(param("partyRole" . $partyNumber)); $role .= ""; $role .= $partyRole; $role .= "\n"; } if ( hasContent(param("partyId" . $partyNumber))) { $partyId = normalize(param("partyId" . $partyNumber)); } else { $partyId = int(rand(10000000000000000)); } if ( hasContent(param("partyLastName" . $partyNumber))) { $individualName .= "\n"; if ( hasContent(param("partyFirstName" . $partyNumber))) { $partyFirstName = normalize(param("partyFirstName" . $partyNumber)); $individualName .= ""; $individualName .= $partyFirstName; $individualName .= "\n"; } $partyLastName = normalize(param("partyLastName" . $partyNumber)); $individualName .= ""; $individualName .= $partyLastName; $individualName .= "\n"; $individualName .= "\n"; } if ( hasContent(param("partyOrgName" . $partyNumber))) { $organizationName .= ""; $partyOrgName = normalize(param("partyOrgName" . $partyNumber)); $organizationName .= $partyOrgName; $organizationName .= "\n"; } if ( hasContent(param("partyPositionName" . $partyNumber))) { $positionName .= ""; $partyPositionName = normalize(param("partyPositionName" . $partyNumber)); $positionName .= $partyPositionName; $positionName .= "\n"; } $address .= "
"; if ( hasContent(param("partyDelivery" . $partyNumber))) { $partyDelivery = normalize(param("partyDelivery" . $partyNumber)); $address .= ""; $address .= $partyDelivery; $address .= "\n"; } if ( hasContent(param("partyCity" . $partyNumber))) { $partyCity = normalize(param("partyCity" . $partyNumber)); $address .= ""; $address .= $partyCity; $address .= "\n"; } if ( hasContent(param("partyState" . $partyNumber))) { $partyState = normalize(param("partyState" . $partyNumber)); $address .= ""; $address .= $partyState; $address .= "\n"; } elsif ( hasContent(param("partyStateOther" . $partyNumber))) { $partyStateOther = normalize(param("partyStateOther" . $partyNumber)); $address .= ""; $address .= $partyStateOther; $address .= "\n"; } if ( hasContent(param("partyZIP" . $partyNumber))) { $partyZIP = normalize(param("partyZIP" . $partyNumber)); $address .= ""; $address .= $partyZIP; $address .= "\n"; } if ( hasContent(param("partyCountry" . $partyNumber))) { $partyCountry = normalize(param("partyCountry" . $partyNumber)); $address .= ""; $address .= $partyCountry; $address .= "\n"; } $address .= "
\n"; if ( hasContent(param("partyPhone" . $partyNumber))) { $partyPhone = normalize(param("partyPhone" . $partyNumber)); $phone .= ""; $phone .= $partyPhone; $phone .= "\n"; } if ( hasContent(param("partyFAX" . $partyNumber))) { $partyFAX = normalize(param("partyFAX" . $partyNumber)); $fax .= ""; $fax .= $partyFAX; $fax .= "\n"; } if ( hasContent(param("partyEmail" . $partyNumber))) { $partyEmail = normalize(param("partyEmail" . $partyNumber)); $email .= ""; $email .= $partyEmail; $email .= "\n"; } if ( hasContent(param("partyURL" . $partyNumber))) { $partyURL = normalize(param("partyURL" . $partyNumber)); $onlineUrl .= ""; $onlineUrl .= $partyURL; $onlineUrl .= "\n"; } # add the party begin tag (like ) $partyStr .= "<" . $partyType . " id=\"" . $partyId ."\">\n"; # add in the person if ( $individualName ne "" ) { $partyStr .= $individualName; } # add in the organization if ( $organizationName ne "" ) { $partyStr .= $organizationName; } # add in the position if ( $positionName ne "" ) { $partyStr .= $positionName; } # add in the address if ( $address ne "" || $address ne "
\n") { $partyStr .= $address; } # add in the phone if ( $phone ne "") { $partyStr .= $phone; } # add in the fax if ( $fax ne "") { $partyStr .= $fax; } # add in the email if ( $email ne "") { $partyStr .= $email; } # add in the online URL if ( $onlineUrl ne "") { $partyStr .= $onlineUrl; } if ( $partyType eq "associatedParty" || $partyType eq "personnel" ) { $partyStr .= $role; } # add the party end tag (like
) $partyStr .= "\n"; } sub entityElement() { my $entityObjects = shift; my %entityObjects = %$entityObjects; my $entityList = ""; my $access = fileAccessElement( \%entityObjects ); while ( my ( $docid, $data ) = each(%entityObjects) ) { my $entityStub = qq| $data->{'fileName'} $data->{'fileName'} $data->{'fileSize'} $data->{'fileHash'} $data->{'contentType'} $data->{'url'} $access $data->{'entityType'} |; $entityList .= $entityStub; } return $entityList; } sub fileAccessElement() { my $entityObjects = shift; my %entityObjects = %$entityObjects; my $userAccess = allowElement( getUsername(), 'all' ); my $skinAccess = allowElement( $adminUsername, 'all' ); my $accessList = ""; # form name => EML permission; roles akin to Apache model my %accessRoles = ( 'public' => 'allow', 'private' => 'deny', ); while ( my ( $docid, $data ) = each(%entityObjects) ) { my $defaultAccess = $accessRoles{ $data->{'filePerm'} }; $accessList = qq| $skinAccess $userAccess <$defaultAccess> public read |; } return $accessList; } sub keywordElement() { my %kwSet, my $kwList = (), ""; # process the standard keywords foreach my $kwName ( param() ) { my $kwNum = $kwName; $kwNum =~ s/keyword//; # get the index of the parameter 0, ..., 10 if ( $kwNum =~ /^([0-9]+)$/ ) { # don't generate xml for empty keyword fields # don't generate taxonomic keyword fields, those go in taxonomic coverage if ( hasContent( param($kwName) ) ) { my $kwType = param( "kwType" . $kwNum ); my $kwTh = param( "kwTh" . $kwNum ); my $kw = param( "keyword" . $kwNum ); push( @{ $kwSet{$kwTh} }, [ $kw, $kwType ] ); } } } # output keyword lists while ( ( my $thesaurus, my $a_ref ) = each %kwSet ) { my $kwElem .= "\n"; foreach my $x (@$a_ref) { my ( $kw, $kwType ) = @$x; $kwElem .= "\n"; $kwElem .= "\n"; $kwList .= $kwElem; } return $kwList; } sub EMLStart() { my $gmt = gmtime($now); my $doc = "\n"; $doc .= qq| |; $doc .= "\n"; $doc .= "\n"; return $doc; } sub EMLEnd() { return "\n"; } sub datasetStart() { my $dataset = "\n"; ## handle multiple alternate identifiers my $identifierArray = \@FORM::identifier; debug( "datasetStart identifier array size = " . $#$identifierArray ); for ( my $i = 0 ; $i <= $#$identifierArray ; $i++ ) { if ( hasContent( $identifierArray->[$i] ) ) { debug( "Processing identifier: id = " . $identifierArray->[$i] ); #$dataset .= ""; $dataset .= ""; $dataset .= normalize($identifierArray->[$i]) . "\n"; } } return $dataset; } sub datasetEnd() { return "\n"; } sub setDisplayType { my $kwDisp = shift; if ( !$kwDisp ) { $kwDisp = 'dataset'; } my $kw = "\n"; $kw .= " $kwDisp\n"; $kw .= " EMLDisplayType\n"; $kw .= "\n"; return $kw; } sub pubElement() { #add the publication Date to the eml document. my ( $Day, $Month, $Year ) = (localtime)[ 3, 4, 5 ]; return "" . sprintf( "%03d-%02d-%02d", $Year + 1900, $Month + 1, $Day ) . "\n"; } sub titleElement() { if ( hasContent($FORM::title) ) { return "" . normalize($FORM::title) . "\n"; } } sub abstractElement() { return "\n" . normalize($FORM::abstract) . "\n\n"; } sub partyElement() { my $creators; if ( $skinName eq 'nceas' ) { for ( my $i = 0 ; $i < scalar(@FORM::wg) ; $i++ ) { $creators .= creatorNode( $FORM::wg[$i] ); } } else { $creators .= creatorNode($FORM::site); } # only use configured organization for certain skins if ( $skinName ne 'knb' && $skinName ne 'metacatui' ) { $creators .= creatorNode(); } return $creators; } sub creatorNode { my $org = shift; my $content = ""; if ( !hasContent($org) ) { $content = $config->{'organization'}; } else { $content = $org; } return "\n" . normalize($content) . "\n\n"; } sub creatorNameElement { my $role = shift; my $creator; if ( !hasContent($role) ) { $role = "creator"; } $creator .= "\n"; $creator .= "" . normalize($FORM::partyFirstName0) . "\n"; $creator .= "" . normalize($FORM::partyLastName0) . "\n"; $creator .= "\n"; return "<$role>\n$creator\n"; } sub methodsElement() { my $methods = ""; if ( ( hasContent($FORM::methodTitle) ) || scalar(@FORM::methodsPara) > 0 || ( $FORM::methodPara[0] ne "" ) ) { $methods = "
\n"; if ( hasContent($FORM::methodTitle) ) { $methods .= "" . normalize($FORM::methodTitle) . "\n"; } for ( my $i = 0 ; $i < scalar(@FORM::methodPara) ; $i++ ) { $methods .= "" . normalize( $FORM::methodPara[$i] ) . "\n"; } $methods .= "
\n"; if ( hasContent($FORM::studyExtentDescription) ) { $methods .= "\n"; $methods .= "" . normalize($FORM::studyExtentDescription) . "\n"; $methods .= "\n"; $methods .= "\n"; $methods .= "" . normalize($FORM::samplingDescription) . "\n"; $methods .= "\n"; $methods .= "\n"; } $methods .= "
\n"; } return $methods; } sub fundingElement() { if ( $debug_enabled ) { debug("fundingElement() called."); } my $project = ""; if ( hasContent($FORM::funding) ) { # Add a project title based on the dataset title $project .= "\n"; $project .= "" . normalize($FORM::title) . "\n"; # Add a project personnel based on the dataset owner $project .= "\n" . "\n" . "" . normalize($FORM::partyFirstName0) . "\n" . "" . normalize($FORM::partyLastName0) . "\n" . "\n"; # Add a default role $project .= "originator\n" . "\n"; # Add the funding info (grant number) $project .= "\n"; # split funding by comma delimiter my $funding = normalize($FORM::funding); foreach my $para (split(',', $funding)) { $project .= "" . $para . "\n"; } $project .= "\n"; $project .= "\n"; } return $project; } sub partyElement() { my $cont = ""; if ( hasContent($FORM::partyLastName) ) { $cont .= "\n"; if ( hasContent($FORM::partyFirstName) ) { $cont .= "" . normalize($FORM::partyFirstName) . "\n"; } $cont .= "" . normalize($FORM::partyLastName) . "\n"; $cont .= "\n"; } if ( hasContent($FORM::partyOrgName) ) { $cont .= "" . normalize($FORM::partyOrgName) . "\n"; } if ( hasContent($FORM::partyDelivery) || hasContent($FORM::partyCity) || hasContent($FORM::partyState) || hasContent($FORM::partyStateOther) || hasContent($FORM::partyZIP) || hasContent($FORM::partyCountry) ) { $cont .= "
\n"; if ( hasContent($FORM::partyDelivery) ) { $cont .= "" . normalize($FORM::partyDelivery); $cont .= "\n"; } if ( hasContent($FORM::partyCity) ) { $cont .= "" . normalize($FORM::partyCity) . "\n"; } if ( hasContent($FORM::partyState) && ( $FORM::partyState !~ /select state/i ) ) { $cont .= "" . normalize($FORM::partyState); $cont .= "\n"; } elsif ( hasContent($FORM::partyStateOther) ) { $cont .= "" . normalize($FORM::partyStateOther); $cont .= "\n"; } if ( hasContent($FORM::partyZIP) ) { $cont .= "" . normalize($FORM::partyZIP) . "\n"; } if ( hasContent($FORM::partyCountry) ) { $cont .= "" . normalize($FORM::partyCountry) . "\n"; } $cont .= "
\n"; } if ( hasContent($FORM::partyPhone) ) { $cont .= "" . normalize($FORM::partyPhone) . "\n"; } if ( hasContent($FORM::partyFAXContact) ) { $cont .= "" . normalize($FORM::partyFAXContact) . "\n"; } if ( hasContent($FORM::partyEmail) ) { $cont .= "" . normalize($FORM::partyEmail); $cont .= "\n"; } if ( hasContent($FORM::partyURL) ) { $cont .= "" . normalize($FORM::partyURL); $cont .= "\n"; } return "\n$cont\n"; } sub contactElement() { my $role = shift; my $cont = ""; if ( !hasContent($role) ) { $role = 'contact'; } $cont .= "\n"; $cont .= "" . normalize($FORM::partyFirstNameContact) . "\n"; $cont .= "" . normalize($FORM::partyLastNameContact) . "\n"; $cont .= "\n"; if ( hasContent($FORM::partyOrgNameContact) ) { $cont .= "" . normalize($FORM::partyOrgNameContact) . "\n"; } if ( hasContent($FORM::origDeliveryContact) || hasContent($FORM::origCityContact) || hasContent($FORM::origStateContact) || hasContent($FORM::origStateOtherContact) || hasContent($FORM::origZIPContact) || hasContent($FORM::origCountryContact) ) { $cont .= "
\n"; if ( hasContent($FORM::origDeliveryContact) ) { $cont .= "" . normalize($FORM::origDeliveryContact); $cont .= "\n"; } if ( hasContent($FORM::origCityContact) ) { $cont .= "" . normalize($FORM::origCityContact) . "\n"; } if ( hasContent($FORM::origStateContact) && ( $FORM::origStateContact !~ /select state/i ) ) { $cont .= "" . normalize($FORM::origStateContact); $cont .= "\n"; } elsif ( hasContent($FORM::origStateOtherContact) ) { $cont .= "" . normalize($FORM::origStateOtherContact); $cont .= "\n"; } if ( hasContent($FORM::origZIPContact) ) { $cont .= "" . normalize($FORM::origZIPContact) . "\n"; } if ( hasContent($FORM::origCountryContact) ) { $cont .= "" . normalize($FORM::origCountryContact) . "\n"; } $cont .= "
\n"; } if ( hasContent($FORM::origPhoneContact) ) { $cont .= "" . normalize($FORM::origPhoneContact) . "\n"; } if ( hasContent($FORM::origFAXContact) ) { $cont .= "" . normalize($FORM::origFAXContact) . "\n"; } if ( hasContent($FORM::origEmailContact) ) { $cont .= "" . normalize($FORM::origEmailContact); $cont .= "\n"; } return "<$role>\n$cont\n"; } sub coverageElement() { my $cov = ""; # temporal coverage if ( hasContent($FORM::endingYear) ) { $cov .= "\n"; $cov .= "\n"; if ( hasContent($FORM::beginningMonth) ) { my $month = ( "JAN", "FEB", "MAR", "APR", "MAY", "JUN", "JUL", "AUG", "SEP", "OCT", "NOV", "DEC" )[ $FORM::beginningMonth - 1 ]; if ( hasContent($FORM::beginningDay) ) { $cov .= "\n"; $cov .= ""; $cov .= normalize($FORM::beginningYear) . "-" . normalize($FORM::beginningMonth) . "-" . normalize($FORM::beginningDay); $cov .= "\n"; $cov .= "\n"; } else { $cov .= "\n"; $cov .= ""; $cov .= normalize($FORM::beginningYear) . "-" . normalize($FORM::beginningMonth) . "-01"; $cov .= "\n"; $cov .= "\n"; } } else { $cov .= "\n"; $cov .= ""; $cov .= normalize($FORM::beginningYear); $cov .= "\n"; $cov .= "\n"; } if ( hasContent($FORM::endingMonth) ) { my $month = ( "JAN", "FEB", "MAR", "APR", "MAY", "JUN", "JUL", "AUG", "SEP", "OCT", "NOV", "DEC" )[ $FORM::endingMonth - 1 ]; if ( hasContent($FORM::endingDay) ) { $cov .= "\n"; $cov .= ""; $cov .= normalize($FORM::endingYear) . "-" . normalize($FORM::endingMonth) . "-" . normalize($FORM::endingDay); $cov .= "\n"; $cov .= "\n"; } else { $cov .= "\n"; $cov .= ""; $cov .= normalize($FORM::endingYear) . "-" . normalize($FORM::endingMonth) . "-01"; $cov .= "\n"; $cov .= "\n"; } } else { $cov .= "\n"; $cov .= ""; $cov .= normalize($FORM::endingYear); $cov .= "\n"; $cov .= "\n"; } $cov .= "\n"; $cov .= "\n"; } else { if ( hasContent($FORM::beginningYear) ) { $cov .= "\n"; $cov .= "\n"; if ( hasContent($FORM::beginningMonth) ) { my $month = ( "JAN", "FEB", "MAR", "APR", "MAY", "JUN", "JUL", "AUG", "SEP", "OCT", "NOV", "DEC" )[ $FORM::beginningMonth - 1 ]; if ( hasContent($FORM::beginningDay) ) { $cov .= ""; $cov .= normalize($FORM::beginningYear) . "-" . normalize($FORM::beginningMonth) . "-" . normalize($FORM::beginningDay); $cov .= "\n"; } else { $cov .= ""; $cov .= normalize($FORM::beginningYear) . "-" . normalize($FORM::beginningMonth) . "-01"; $cov .= "\n"; } } else { $cov .= ""; $cov .= normalize($FORM::beginningYear); $cov .= "\n"; } $cov .= "\n"; $cov .= "\n"; } } # geographic coverage if ( hasContent($FORM::geogdesc) || ( hasContent($FORM::latDeg1) && $FORM::latDeg1 < 91 && $FORM::latDeg1 > -1 && hasContent($FORM::longDeg1) && $FORM::longDeg1 < 181 && $FORM::longDeg1 > -1 ) ) { $cov .= "\n"; if ( hasContent($FORM::geogdesc) ) { $cov .= "" . normalize($FORM::geogdesc) . "\n"; } if ( $latDeg1 < 91 && $latDeg1 > -1 && $longDeg1 < 181 && $longDeg1 > -1 ) { $cov .= "\n"; # if the second latitude is missing, then set the second lat/long pair # equal to the first this makes a point appear like a rectangle if ( $FORM::useSiteCoord || ( $FORM::latDeg2 eq "" && $FORM::latMin2 eq "" && $FORM::latSec2 eq "" ) ) { $latDeg2 = $latDeg1; $latMin2 = $latMin1; $latSec2 = $latSec1; $hemisphLat2 = $hemisphLat1; $longDeg2 = $longDeg1; $longMin2 = $longMin1; $longSec2 = $longSec1; $hemisphLong2 = $hemisphLong1; } else { $latDeg2 = $FORM::latDeg2; $latMin2 = $FORM::latMin2; $latSec2 = $FORM::latSec2; $hemisphLat2 = $FORM::hemisphLat2; $longDeg2 = $FORM::longDeg2; $longMin2 = $FORM::longMin2; $longSec2 = $FORM::longSec2; $hemisphLong2 = $FORM::hemisphLong2; } my $hemisph; $hemisph = ( $hemisphLong1 eq "W" ) ? -1 : 1; $cov .= ""; my $var = $hemisph * ( $longDeg1 + ( 60 * $longMin1 + $longSec1 ) / 3600 ); $cov .= sprintf( "%.4f", $var ); $cov .= "\n"; $hemisph = ( $hemisphLong2 eq "W" ) ? -1 : 1; $cov .= ""; $var = $hemisph * ( $longDeg2 + ( 60 * $longMin2 + $longSec2 ) / 3600 ); $cov .= sprintf( "%.4f", $var ); $cov .= "\n"; $hemisph = ( $hemisphLat1 eq "S" ) ? -1 : 1; $cov .= ""; $var = $hemisph * ( $latDeg1 + ( 60 * $latMin1 + $latSec1 ) / 3600 ); $cov .= sprintf( "%.4f", $var ); $cov .= "\n"; $hemisph = ( $hemisphLat2 eq "S" ) ? -1 : 1; $cov .= ""; $var = $hemisph * ( $latDeg2 + ( 60 * $latMin2 + $latSec2 ) / 3600 ); $cov .= sprintf( "%.4f", $var ); $cov .= "\n"; $cov .= "\n"; } $cov .= "\n"; } # taxonomic coverage my $foundFirstTaxon = 0; foreach my $trn ( param() ) { if ( $trn =~ /taxonRankName/ ) { my $taxIndex = $trn; $taxIndex =~ s/taxonRankName//; # get the index of the parameter 0, ..., 10 my $trv = "taxonRankValue" . $taxIndex; if ( $taxIndex =~ /[0-9]+/ ) { if ( hasContent( param($trn) ) && hasContent( param($trv) ) ) { if ( !$foundFirstTaxon ) { $cov .= "\n"; $foundFirstTaxon = 1; if ( hasContent($FORM::taxaAuth) ) { $cov .= "" . normalize($FORM::taxaAuth) . "\n"; } } $cov .= "\n"; $cov .= " " . normalize( param($trn) ) . "\n"; $cov .= " " . normalize( param($trv) ) . "\n"; $cov .= "\n"; } } } } if ($foundFirstTaxon) { $cov .= "\n"; } return "\n$cov\n"; } sub distributionElement() { my $dist = ""; if ( hasContent($FORM::addComments) ) { $dist .= "\n"; $dist .= "" . normalize($FORM::addComments) . "\n"; $dist .= "\n"; } if ( hasContent($FORM::useConstraints) || hasContent($FORM::useConstraintsOther) ) { $dist .= "\n"; if ( $show->{cclicenses} eq 'true' ) { # Creative Commons license statements if ( $FORM::useConstraints =~ /CC-0/ ) { $dist .= "\n"; $dist .= "This work is dedicated to the public domain under the Creative Commons Universal 1.0 Public Domain Dedication.\n"; $dist .= "To view a copy of this dedication, visit https://creativecommons.org/publicdomain/zero/1.0/.\n"; $dist .= "\n"; } else { $dist .= "\n"; $dist .= "This work is licensed under the Creative Commons Attribution 4.0 International License.\n"; $dist .= "To view a copy of this license, visit http://creativecommons.org/licenses/by/4.0/.\n"; $dist .= "\n"; } } else { # Custom license statements if ( hasContent($FORM::useConstraints) ) { $dist .= "" . normalize($FORM::useConstraints) . "\n"; } if ( hasContent($FORM::useConstraintsOther) ) { $dist .= "" . normalize($FORM::useConstraintsOther) . "\n"; } } $dist .= "\n"; } if ( hasContent($FORM::url) ) { $dist .= "\n"; $dist .= "\n"; $dist .= "" . normalize($FORM::url) . "\n"; $dist .= "\n"; $dist .= "\n"; } $dist .= "\n"; $dist .= "\n"; $dist .= "" . normalize($FORM::dataMedium) . " " . normalize($FORM::dataMediumOther); $dist .= "\n"; $dist .= "\n"; $dist .= "\n"; return $dist; } sub accessElement { if ( $debug_enabled ) { debug('accessElement() called.'); } my $public = shift; if ( !$public ) { $public = $config->{'publicReadable'}; } my $access = ""; $access .= "\n"; $access .= allowElement( $adminUsername, 'all' ); if ( $moderators eq '' ) { $access .= allowElement( getUsername(), 'all' ); } else { foreach ( split( ":", $moderators ) ) { $access .= allowElement( $_, 'all' ); } $access .= allowElement( getUsername(), 'read', 'write' ); } if ( $public eq "true" ) { $access .= allowElement( 'public', 'read' ); } $access .= "\n"; return $access; } sub allowElement { my $principal = shift; my @permissions = @_; my $allowElem = "\n" . " $principal"; foreach my $perm (@permissions) { $allowElem .= "$perm\n"; } $allowElem .= "\n"; return $allowElem; } sub getUsername() { if ( $debug_enabled ) { debug('getUsername() called.'); } my $username = ''; my $authBase = $properties->getProperty("auth.base"); # Support authentication token usernames my $token_info = getTokenInfo(); if ( $token_info->{'isValid'} ) { $username = $token_info->{'sub'}; debug("Username: $username"); return $token_info->{'sub'}; } # Support CGI session usernames if ( $FORM::username ne '' ) { $username = "uid=$FORM::username,o=$FORM::organization,$authBase"; } else { my $session = CGI::Session->load(); if ( !$session->is_empty ) { $username = $session->param("username"); } } return $username; } sub readDocumentFromMetacat() { #debug("read the document from metacat"); my $docid = $FORM::docid; # create metacat instance my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); my $httpMessage; my $doc; my $xmldoc; my $findType; my $parser = XML::LibXML->new(); my @fileArray; my $pushDoc; my $alreadyInArray; my $node; my $response; my $element; my $tempfile; if ( ! hasValidAuthToken() ) { my ( $username, $password ) = getCredentials(); $metacat->login( $username, $password ); } $httpMessage = $metacat->read($docid); $doc = $httpMessage->content(); $xmldoc = $parser->parse_string($doc); if ( $xmldoc eq "" ) { $error = "Error in parsing the eml document"; push( @errorMessages, $error ); } elsif ( $doc =~ /findnodes('//dataset/identifier'); if ( $findType->size() > 0 ) { # This is a eml beta6 document # Read the documents mentioned in triples also push( @errorMessages, "EML2 beta6 support deprecated." ); } } return $xmldoc; } ################################################################################ # # read the eml document and send back a form with values filled in. # ################################################################################ sub modifyData { #debug("in modifyData"); my $xmldoc = readDocumentFromMetacat(); if ( !scalar(@errorMessages) ) { getFormValuesFromEml2($xmldoc); } if ( scalar(@errorMessages) ) { # if any errors, print them in the response template $$templateVars{'status'} = 'failure_no_resubmit'; $$templateVars{'errorMessages'} = \@errorMessages; $error = 1; $$templateVars{'function'} = "modification"; $$templateVars{'section'} = "Modification Status"; $template->process( $templates->{'response'}, $templateVars ); } else { $$templateVars{'form'} = 're_entry'; $template->process( $templates->{'entry'}, $templateVars ); } } ################################################################################ # # Convert EML 2.0.x documents into 2.1.0 using an XSLT transform # ################################################################################ sub transformEmlTo210 { my $xmldoc = shift; my $xslt = XML::LibXSLT->new(); my $results; my $stylesheet; my $resultsheet; my $transform = "$styleCommonPath/conversions/eml201to210.xsl"; $stylesheet = $xslt->parse_stylesheet_file($transform); $results = $stylesheet->transform($xmldoc); # if debugging is enabled, dump the transformed document to disk debugDoc( $stylesheet->output_string($results) ); return $results; } ################################################################################ # # transform the EML document if necessary, otherwise leave unadultered # ################################################################################ sub transformEml { my $doc = shift; # get the document namespace my $root = $doc->getDocumentElement(); my $emlns = $root->lookupNamespaceURI("eml"); if ( $emlns =~ 'eml-2.0' ) { debug("Translation: Upgrading a 2.0.x doc to 2.1.0"); $doc = transformEmlTo210($doc); } elsif ( $emlns =~ 'eml-2.1' ) { debug("Translation: Found a 2.1.x doc."); } else { $error = "Unrecognized document type!"; debug("Translation: $error"); push( @errorMessages, $error . "\n" ); } return $doc; } ################################################################################ # # Parse getaccesscontrol XML response # from Metacat and return the allow elements # ################################################################################ sub getAllowAccess { my $docid = shift; debug("looking up access control block for docid: $docid"); # read the access control block my $parser = XML::LibXML->new(); my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); my $response = $metacat->getaccess($docid); my $doc = $response->content(); debug("Retrieved access control block: $doc"); my $xmldoc = $parser->parse_string($doc); if ( $xmldoc eq "" || $doc =~ /findnodes('/access/allow'); return $results; } ################################################################################ # # Parse an EML 2.x file and extract the metadata into perl variables for # processing and returning to the template processor # ################################################################################ sub getFormValuesFromEml2 { #debug("getting form values from eml 2"); my $doc = shift; my $results; my $error; my $node; my $tempResult; my $tempNode; my $partyCount = 0; my $foundDSO; # set variable values $$templateVars{'modules'} = $modules; $$templateVars{'required'} = $required; $$templateVars{'show'} = $show; $$templateVars{'site'} = $config->{'site'}; # perform any required transformation $doc = transformEml($doc); # Find . $results = $doc->findnodes('//dataset/alternateIdentifier'); if ( $results->size() > 0 ) { # handle multiple alternate identifiers $results = $doc->findnodes('//dataset/alternateIdentifier'); my $identifierIndex = 0; foreach $node ( $results->get_nodelist ) { $identifierIndex++; $$templateVars{ "identifierValue" . $identifierIndex } = findValue( $node, '../alternateIdentifier[' . $identifierIndex . ']' ); } $$templateVars{'identifierCount'} = $identifierIndex; } # Find . $results = $doc->findnodes('//dataset/title'); if ( $results->size() > 1 ) { errMoreThanOne("title"); } elsif ( $results->size() < 1 ) { $error = "Following tag not found: title. Please use Morpho to edit this document"; push( @errorMessages, $error . "\n" ); } else { foreach $node ( $results->get_nodelist ) { $$templateVars{'title'} = findValue( $node, '../title' ); } } # Find <creator>s populatePartyFields(\$doc, "//dataset/creator", \$partyCount); # Find <metadataProvider>s populatePartyFields(\$doc, "//dataset/metadataProvider", \$partyCount); # Find <associatedParty>s populatePartyFields(\$doc, "//dataset/associatedParty", \$partyCount); # Find <publisher>s populatePartyFields(\$doc, "//dataset/publisher", \$partyCount); # Find <contact>s populatePartyFields(\$doc, "//dataset/contact", \$partyCount); $$templateVars{'partyCount'} = $partyCount; dontOccur( $doc, "./pubDate", "pubDate" ); dontOccur( $doc, "./language", "language" ); dontOccur( $doc, "./series", "series" ); $results = $doc->findnodes('//dataset/abstract'); if ( $results->size() > 1 ) { errMoreThanOne("abstract"); } else { foreach my $node ( $results->get_nodelist ) { dontOccur( $node, "./section", "section" ); $$templateVars{'abstract'} = findValueNoChild( $node, "para" ); } } $results = $doc->findnodes('//dataset/keywordSet'); my $count = 1; foreach $node ( $results->get_nodelist ) { my $thesaurus = findValue( $node, "keywordThesaurus" ); $tempResult = $node->findnodes('./keyword'); foreach $tempNode ( $tempResult->get_nodelist ) { $$templateVars{"keyword$count"} = $tempNode->textContent(); if ( $tempNode->hasAttributes() ) { my @attlist = $tempNode->attributes(); my $tmp = $attlist[0]->value; $tmp =~ s/\b(\w)/\U$1/g; # convert the first letter to upper case $$templateVars{"kwType$count"} = $tmp; } $$templateVars{"kwTh$count"} = $thesaurus; #debug("Keyword Found: $count `" . $tempNode->textContent() . "`, $thesaurus"); $count++; } } $$templateVars{'keyCount'} = $count; if ( $count > 1 ) { $$templateVars{'hasKeyword'} = "true"; } $results = $doc->findnodes('//dataset/additionalInfo'); if ( $results->size() > 1 ) { errMoreThanOne("additionalInfo"); } else { foreach $node ( $results->get_nodelist ) { dontOccur( $node, "./section", "section" ); $$templateVars{'addComments'} = findValueNoChild( $node, "para" ); } } $$templateVars{'useConstraints'} = ""; $results = $doc->findnodes('//dataset/intellectualRights'); if ( $results->size() > 1 ) { errMoreThanOne("intellectualRights"); } else { foreach $node ( $results->get_nodelist ) { dontOccur( $node, "./section", "section in intellectualRights" ); $tempResult = $node->findnodes("para"); if ( $tempResult->size() > 2 ) { errMoreThanN("para"); } else { foreach $tempNode ( $tempResult->get_nodelist ) { my $childNodes = $tempNode->childNodes; if ( $childNodes->size() > 1 ) { $error = "The tag para in intellectualRights has children which cannot be shown using the form. Please use Morpho to edit this document"; push( @errorMessages, $error ); } else { #print $tempNode->nodeName().":".$tempNode->textContent(); #print "\n"; if ( $$templateVars{'useConstraints'} eq "" ) { if ($tempNode->textContent() =~ 'Creative Commons Universal 1.0 Public Domain Dedication') { $$templateVars{'useConstraints'} = "Public Domain (CC-0)"; } elsif ($tempNode->textContent() =~ 'Creative Commons Attribution 4.0 International License') { $$templateVars{'useConstraints'} = "Attribution (CC-BY)"; } else { $$templateVars{'useConstraints'} = $tempNode->textContent(); } } else { $$templateVars{'useConstraintsOther'} = $tempNode->textContent(); } } } } } } $results = $doc->findnodes('//dataset/distribution/online'); if ( $results->size() > 1 ) { errMoreThanOne("distribution/online"); } else { foreach my $tempNode ( $results->get_nodelist ) { $$templateVars{'url'} = findValue( $tempNode, "url" ); dontOccur( $tempNode, "./connection", "/distribution/online/connection" ); dontOccur( $tempNode, "./connectionDefinition", "/distribution/online/connectionDefinition" ); } } $results = $doc->findnodes('//dataset/distribution/offline'); if ( $results->size() > 1 ) { errMoreThanOne("distribution/online"); } else { foreach my $tempNode ( $results->get_nodelist ) { my $temp = findValue( $tempNode, "mediumName" ); if ( substr( $temp, 0, 5 ) eq "other" ) { $$templateVars{'dataMedium'} = substr( $temp, 0, 5 ); $$templateVars{'dataMediumOther'} = substr( $temp, 6 ); } else { $$templateVars{'dataMedium'} = $temp; } dontOccur( $tempNode, "./mediumDensity", "/distribution/offline/mediumDensity" ); dontOccur( $tempNode, "./mediumDensityUnits", "/distribution/offline/mediumDensityUnits" ); dontOccur( $tempNode, "./mediumVolume", "/distribution/offline/mediumVolume" ); dontOccur( $tempNode, "./mediumFormat", "/distribution/offline/mediumFormat" ); dontOccur( $tempNode, "./mediumNote", "/distribution/offline/mediumNote" ); } } dontOccur( $doc, "./inline", "//dataset/distribution/inline" ); $results = $doc->findnodes('//dataset/coverage'); if ( $results->size() > 1 ) { errMoreThanOne("coverage"); } else { foreach $node ( $results->get_nodelist ) { dontOccur( $node, "./temporalCoverage/rangeOfDates/beginDate/alternativeTimeScale|./temporalCoverage/rangeOfDates/endDate/alternativeTimeScale|./taxonomicCoverage/taxonomicSystem|./taxonomicCoverage/taxonomicClassification/commonName|./taxonomicCoverage/taxonomicClassification/taxonomicClassification|./geographicCoverage/datasetGPolygon|./geographicCoverage/boundingCoordinates/boundingAltitudes", "/temporalCoverage/rangeOfDates/beginDate/alternativeTimeScale, /temporalCoverage/rangeOfDates/endDate/alternativeTimeScale, /taxonomicCoverage/taxonomicSystem, /taxonomicCoverage/taxonomicClassification/commonName, /taxonomicCoverage/taxonomicClassification/taxonomicClassification, /geographicCoverage/datasetGPolygon, /geographicCoverage/boundingCoordinates/boundingAltitudes" ); $tempResult = $node->findnodes('./temporalCoverage'); if ( $tempResult->size() > 1 ) { errMoreThanOne("temporalCoverage"); } else { foreach $tempNode ( $tempResult->get_nodelist ) { my $x; my $y; my $z; my $tempdate = findValue( $tempNode, "rangeOfDates/beginDate/calendarDate" ); ( $x, $y, $z ) = split( "-", $tempdate ); $$templateVars{'beginningYear'} = $x; $$templateVars{'beginningMonth'} = $y; $$templateVars{'beginningDay'} = $z; $tempdate = findValue( $tempNode, "rangeOfDates/endDate/calendarDate" ); ( $x, $y, $z ) = split( "-", $tempdate ); $$templateVars{'endingYear'} = $x; $$templateVars{'endingMonth'} = $y; $$templateVars{'endingDay'} = $z; $tempdate = ""; $tempdate = findValue( $tempNode, "singleDateTime/calendarDate" ); if ( $tempdate ne "" ) { ( $x, $y, $z ) = split( "-", $tempdate ); $$templateVars{'beginningYear'} = $x; $$templateVars{'beginningMonth'} = $y; $$templateVars{'beginningDay'} = $z; } $$templateVars{'hasTemporal'} = "true"; } } $tempResult = $node->findnodes('./geographicCoverage'); if ( $tempResult->size() > 1 ) { errMoreThanOne("geographicCoverage"); } else { foreach $tempNode ( $tempResult->get_nodelist ) { my $geogdesc = findValue( $tempNode, "geographicDescription" ); debug("Geogdesc from xml is: $geogdesc"); $$templateVars{'geogdesc'} = $geogdesc; my $coord = findValue( $tempNode, "boundingCoordinates/westBoundingCoordinate" ); if ( $coord > 0 ) { #print "+"; $$templateVars{'hemisphLong1'} = "E"; } else { #print "-"; eval( $coord = $coord * -1 ); $$templateVars{'hemisphLong1'} = "W"; } eval( $$templateVars{'longDeg1'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'longMin1'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'longSec1'} = int($coord) ); $coord = findValue( $tempNode, "boundingCoordinates/southBoundingCoordinate" ); if ( $coord > 0 ) { #print "+"; $$templateVars{'hemisphLat2'} = "N"; } else { #print "-"; eval( $coord = $coord * -1 ); $$templateVars{'hemisphLat2'} = "S"; } eval( $$templateVars{'latDeg2'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'latMin2'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'latSec2'} = int($coord) ); $coord = findValue( $tempNode, "boundingCoordinates/northBoundingCoordinate" ); if ( $coord > 0 ) { #print "+"; $$templateVars{'hemisphLat1'} = "N"; } else { #print "-"; eval( $coord = $coord * -1 ); $$templateVars{'hemisphLat1'} = "S"; } eval( $$templateVars{'latDeg1'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'latMin1'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'latSec1'} = int($coord) ); $coord = findValue( $tempNode, "boundingCoordinates/eastBoundingCoordinate" ); if ( $coord > 0 ) { #print "+"; $$templateVars{'hemisphLong2'} = "E"; } else { #print "-"; eval( $coord = $coord * -1 ); $$templateVars{'hemisphLong2'} = "W"; } eval( $$templateVars{'longDeg2'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'longMin2'} = int($coord) ); eval( $coord = ( $coord - int($coord) ) * 60 ); eval( $$templateVars{'longSec2'} = int($coord) ); $$templateVars{'hasSpatial'} = "true"; } } $tempResult = $node->findnodes('./taxonomicCoverage/taxonomicClassification'); my $taxonIndex = 0; foreach $tempNode ( $tempResult->get_nodelist ) { $taxonIndex++; my $taxonRankName = findValue( $tempNode, "taxonRankName" ); my $taxonRankValue = findValue( $tempNode, "taxonRankValue" ); $$templateVars{ "taxonRankName" . $taxonIndex } = $taxonRankName; $$templateVars{ "taxonRankValue" . $taxonIndex } = $taxonRankValue; $$templateVars{'hasTaxonomic'} = "true"; } $$templateVars{'taxaCount'} = $taxonIndex; my $taxaAuth = findValue( $node, "./taxonomicCoverage/generalTaxonomicCoverage" ); $$templateVars{'taxaAuth'} = $taxaAuth; } } dontOccur( $doc, "./purpose", "purpose" ); dontOccur( $doc, "./maintenance", "maintnance" ); $results = $doc->findnodes('//dataset/methods/methodStep/description/section'); debug( "Number methods: " . $results->size() ); if ( $results->size() > 1 ) { errMoreThanN("methods/methodStep/description/section"); } else { my @methodPara; foreach $node ( $results->get_nodelist ) { my @children = $node->childNodes; for ( my $i = 0 ; $i < scalar(@children) ; $i++ ) { debug("Method child loop ($i)"); my $child = $children[$i]; if ( $child->nodeName eq 'title' ) { my $title = $child->textContent(); debug("Method title ($title)"); $$templateVars{'methodTitle'} = $title; } elsif ( $child->nodeName eq 'para' ) { my $para = $child->textContent(); debug("Method para ($para)"); $methodPara[ scalar(@methodPara) ] = $para; } } $$templateVars{'hasMethod'} = "true"; } if ( scalar(@methodPara) > 0 ) { $$templateVars{'methodPara'} = \@methodPara; } } $results = $doc->findnodes( '//dataset/methods/sampling/studyExtent/description/para'); if ( $results->size() > 1 ) { errMoreThanN("methods/sampling/studyExtent/description/para"); } else { foreach $node ( $results->get_nodelist ) { my $studyExtentDescription = $node->textContent(); $$templateVars{'studyExtentDescription'} = $studyExtentDescription; $$templateVars{'hasMethod'} = "true"; } } $results = $doc->findnodes('//dataset/methods/sampling/samplingDescription/para'); if ( $results->size() > 1 ) { errMoreThanN("methods/sampling/samplingDescription/para"); } else { foreach $node ( $results->get_nodelist ) { my $samplingDescription = $node->textContent(); $$templateVars{'samplingDescription'} = $samplingDescription; $$templateVars{'hasMethod'} = "true"; } } dontOccur( $doc, "//methodStep/citation", "methodStep/citation" ); dontOccur( $doc, "//methodStep/protocol", "methodStep/protocol" ); dontOccur( $doc, "//methodStep/instrumentation", "methodStep/instrumentation" ); dontOccur( $doc, "//methodStep/software", "methodStep/software" ); dontOccur( $doc, "//methodStep/subStep", "methodStep/subStep" ); dontOccur( $doc, "//methodStep/dataSource", "methodStep/dataSource" ); dontOccur( $doc, "//methods/qualityControl", "methods/qualityControl" ); dontOccur( $doc, "//methods/sampling/spatialSamplingUnits", "methods/sampling/spatialSamplingUnits" ); dontOccur( $doc, "//methods/sampling/citation", "methods/sampling/citation" ); dontOccur( $doc, "./pubPlace", "pubPlace" ); dontOccur( $doc, "./project", "project" ); # Code for checking ACL: with EML 2.1, we should only look within the top-level elements #debug("checking user access"); # deny rules have been discontinued in metacat, but we'll keep this in here dontOccur( $doc, "/eml:eml/access/deny", "access/deny" ); # check access from Metacat API instead of eml-embedded rules my $docid = $FORM::docid; $results = getAllowAccess($docid); # $results = $doc->findnodes('/eml:eml/access/allow'); my $accessError = 0; my $accessGranted = 0; my $docOwner; my $errorMessage; my @admins; foreach ( split( ":", $moderators ) ) { push( @admins, $_ ); #debug("getting moderator: $_"); } push( @admins, $adminUsername ); debug("getting user groups for current user"); my @userGroups = getUserGroups(); foreach $node ( $results->get_nodelist ) { my @children = $node->childNodes; my $permission = ""; my $principal = ""; for ( my $i = 0 ; $i < scalar(@children) ; $i++ ) { my $child = $children[$i]; if ( $child->nodeName eq 'principal' ) { $principal = $child->textContent(); } elsif ( $child->nodeName eq 'permission' ) { $permission = $child->textContent(); } } if (($principal eq 'public') && ($permission ne 'read')) { # If the principal is 'public' and the permission is not 'read' then this document # could not have been created in the registry. $errorMessage = "The ACL for this document has been changed outside the registry. Please use Morpho to edit this document (Access Error: public principal cannot have $permission permission).\n"; $accessError = 1; debug($errorMessage); } #if (($principal eq $adminUsername) && ($permission ne 'all' || $permission ne 'chmod' || $permission ne 'write')) { # # If the principal is the admin and permission is not 'all' then this document # # could not have been created in the registry. # $errorMessage = "The ACL for this document has been changed outside the registry. Please use Morpho to edit this document (Access Error: admin principal cannot have $permission permission).\n"; # $accessError = 1; # debug($errorMessage); #} # no access error in doc, if principal is not equal to public and permission is # 'all' (requirements in registry) then try and determine if user has access if (!$accessError && ($principal ne 'public') && ($permission eq 'all' || $permission eq 'write' || $permission eq 'chmod')) { my ($username, $password) = getCredentials(); # 1) check if user matches principal debug("does user $username match principal $principal?"); if ($principal eq $username) { $accessGranted = 1; debug("Access granted: user $username matches principal"); } # 2) if access not granted, check if user group matches principal if (!$accessGranted) { debug("is one of the user groups @userGroups the principal $principal?"); for my $userGroup (@userGroups) { my $lowercaseUserGroup = lc $userGroup; my $lowercasePrincipal = lc $principal; if ($lowercaseUserGroup eq $lowercasePrincipal) { $accessGranted = 1; debug("Access granted: user group $userGroup matches principal"); last; } } } } # if there was an access error, we know this is not a valid registry doc. No need to # continue looking at access sections in doc. Same it true if we were granted access # already. if ( $accessError || $accessGranted ) { last; } } if (!$accessError) { my ($username, $password) = getCredentials(); # 3) if access not granted, check if the user is a moderator or admin if (!$accessGranted) { debug("is user $username in admins @admins?"); if (grep { $_ eq $username } @admins) { $accessGranted = 1; #debug("Access granted: user $username is an admin or moderator"); } } # 4) if access not granted, check if user group in moderator/admin list if (!$accessGranted) { debug("is one of the user groups @userGroups in admins @admins?"); foreach my $userGroup (split(":", @userGroups)) { if (grep {$_ eq $userGroup} @admins) { $accessGranted = 1; #debug("Access granted: user group $userGroup is an admin or moderator"); last; } } } # 5) if access not granted, and there was no other error, the user is not authorized. # Set accessError to true and set the error string if (!$accessError && !$accessGranted) { $errorMessage = "User $username is not authorized to access document\n"; $accessError = 1; } } # push the error message, if any if ( $accessError ) { debug($errorMessage); push( @errorMessages, $errorMessage ); } # handle otherEntity objects, by populating the relevant file form elements $results = $doc->findnodes('//otherEntity/physical'); my $upCount = 0; foreach $node ( $results->get_nodelist() ) { my $distUrl = findValue( $node, 'distribution/online/url' ); debug("Found distUrl of value $distUrl."); if ( $distUrl !~ /^ecogrid/ ) { my $error = "The file URL referenced is not a local resource and has been changed outside the registry. Please use Morpho to edit this document."; push( @errorMessages, $error . "\n" ); } else { # have a file with a ecogrid distUrl, use this to set up the file parameters $distUrl =~ s/ecogrid:\/\/knb\///g; # TODO: check getaccess() method for access control rules? my $accessNodes = $node->findnodes('distribution/access/allow'); my $accessRule = 'private'; foreach my $accessNode ( $accessNodes->get_nodelist() ) { my @children = $accessNode->childNodes(); my $permission = ""; my $principal = ""; for ( my $i = 0 ; $i < scalar(@children) ; $i++ ) { my $child = $children[$i]; if ( $child->nodeName() eq 'principal' ) { $principal = $child->textContent(); } elsif ( $child->nodeName() eq 'permission' ) { $permission = $child->textContent(); } } if ( $principal eq 'public' && $permission eq 'read' ) { $accessRule = 'public'; } } # overload the name with the ondisk status, the docid and the SHA1 sum $$templateVars{"upload_$upCount"} = "ondisk:$distUrl:" . findValue( $node, 'authentication' ); $$templateVars{"uploadname_$upCount"} = findValue( $node, 'objectName' ); $$templateVars{"uploadtype_$upCount"} = findValue( $node, 'dataFormat/externallyDefinedFormat/formatName' ); $$templateVars{"uploadperm_$upCount"} = $accessRule; debug( "Setting upload data: " . $$templateVars{"upload_$upCount"} . ", " . $$templateVars{"uploadname_$upCount"} . ", " . $$templateVars{"uploadtype_$upCount"} . ", " . $$templateVars{"uploadperm_$upCount"} ); $upCount++; } } if ( $upCount > 0 ) { $$templateVars{"upCount"} = $upCount; } dontOccur( $doc, "./dataTable", "dataTable" ); dontOccur( $doc, "./spatialRaster", "spatialRaster" ); dontOccur( $doc, "./spatialVector", "spatialVector" ); dontOccur( $doc, "./storedProcedure", "storedProcedure" ); dontOccur( $doc, "./view", "view" ); dontOccur( $doc, "./references", "references" ); dontOccur( $doc, "//citation", "citation" ); dontOccur( $doc, "//software", "software" ); dontOccur( $doc, "//protocol", "protocol" ); $results = $doc->findnodes('//additionalMetadata/metadata/moderatorComment'); if ( $results->size() == 0 ) { dontOccur( $doc, "//additionalMetadata", "additionalMetadata" ); } # find the last funding element my $fundingNodes = $doc->findnodes('//dataset/project/funding'); foreach my $fundingNode ($fundingNodes->get_nodelist()) { foreach my $fundingParagraph ($fundingNode->findnodes('./para')) { if( $fundingParagraph->textContent() ) { my $fundingPara = $fundingParagraph->textContent(); if ($debug_enabled ) { debug("Found a funding paragraph: $fundingPara"); } if ($$templateVars{'funding'} ne '') { $$templateVars{'funding'} .= ', '; } $$templateVars{'funding'} .= $fundingPara; } else { if ( $debug_enabled ) { debug("No funding paragraph found."); } } } } } ################################################################################ # # Delete the eml file that has been requested for deletion. # ################################################################################ sub deleteData { my $deleteAll = shift; # create metacat instance my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); my $docid = $FORM::docid; # Login to metacat my $errorMessage = ""; my $response = hasValidAuthToken(); if ( ! $response ) { my ( $username, $password ) = getCredentials(); $response = $metacat->login( $username, $password ); } if ( !$response ) { # Could not login push( @errorMessages, $metacat->getMessage() ); push( @errorMessages, "Failed during login.\n" ); } else { #Able to login - try to delete the file my $parser; my @fileArray; my $httpMessage; my $xmldoc; my $doc; my $pushDoc; my $alreadyInArray; my $findType; my $node; my $element; push( @fileArray, $docid ); $parser = XML::LibXML->new(); $httpMessage = $metacat->read($docid); $doc = $httpMessage->content(); $doc = delNormalize($doc); $xmldoc = $parser->parse_string($doc); if ( $xmldoc eq "" ) { $error = "Error in parsing the eml document"; push( @errorMessages, $error ); } else { $findType = $xmldoc->findnodes('//dataset/identifier'); if ( $findType->size() > 0 ) { # This is a eml beta6 document # Delete the documents mentioned in triples also $findType = $xmldoc->findnodes('//dataset/triple'); if ( $findType->size() > 0 ) { foreach $node ( $findType->get_nodelist ) { $pushDoc = findValue( $node, 'subject' ); # If the file is already in the @fileArray then do not add it $alreadyInArray = 0; foreach $element (@fileArray) { if ( $element eq $pushDoc ) { $alreadyInArray = 1; } } if ( !$alreadyInArray ) { # If not already in array then delete the file. push( @fileArray, $pushDoc ); $response = $metacat->delete($pushDoc); if ( !$response ) { # Could not delete push( @errorMessages, $metacat->getMessage() ); push( @errorMessages, "Failed during deleting $pushDoc. Please check if you are authorized to delete this document.\n" ); } } } } } } # Delete the main document. if ($deleteAll) { $response = $metacat->delete($docid); if ( !$response ) { # Could not delete push( @errorMessages, $metacat->getMessage() ); push( @errorMessages, "Failed during deleting $docid. Please check if you are authorized to delete this document.\n" ); } } } if ( scalar(@errorMessages) ) { # If any errors, print them in the response template $$templateVars{'status'} = 'failure'; $$templateVars{'errorMessages'} = \@errorMessages; $error = 1; } # Process the response template if ($deleteAll) { $$templateVars{'function'} = "deleted"; $$templateVars{'section'} = "Deletion Status"; $template->process( $templates->{'response'}, $templateVars ); } } ################################################################################ # # function to handle login request # ################################################################################ sub handleLoginRequest() { # Check if a session already exists my $session = CGI::Session->load() or die CGI::Session->errstr(); if ( ! validateSession() ) { # tokens won't be involved in login() # no session found ... check if the login is correct my $username = $FORM::username; my $password = $FORM::password; my $metacat = Metacat->new($metacatUrl); my $returnVal = $metacat->login( $username, $password ); debug("Login was $returnVal for login " . "attempt to $metacatUrl, with $username"); if ( $returnVal > 0 ) { # valid username and passwd # create a new session and store username and passswd $session = new CGI::Session(); $session->param( 'username', $username ); $session->param( 'password', $password ); if ( $returnVal == 2 || $returnVal == 4 ) { # is a moderator. store this information in the session $session->param( 'moderator', 'true' ); } # send redirect to metacat and action = login my $html = "<html><head>"; $html .= "</head><body onload=\"document.loginForm.submit()\">"; $html .= "<form name=\"loginForm\" method=\"post\" action=\"" . $metacatUrl . "\">"; $html .= "<input type=\"hidden\" name=\"action\" value=\"login\" />"; $html .= "<input type=\"hidden\" name=\"username\" value=\"" . $FORM::username . "\" />"; $html .= "<input type=\"hidden\" name=\"password\" value=\"" . $FORM::password . "\" />"; $html .= "<input type=\"hidden\" name=\"qformat\" value=\"" . $skinName . "\" />"; $html .= "</form></body></html>"; print $session->header(); print $html; } else { # send back the error template with error message as wrong username password # push(@errorMessages, $metacat->getMessage()); print "Content-type: text/html\n\n"; push( @errorMessages, "Failed during login.\n" ); $$templateVars{'status'} = 'login_failure'; $$templateVars{'errorMessages'} = \@errorMessages; $$templateVars{'cfg'} = $skinName; $$templateVars{'section'} = "Login Status"; $template->process( $templates->{'response'}, $templateVars ); } exit(); } else { # session found ... redirect to index page my $url = "/"; redirect($url); exit(); } } ################################################################################ # # function to handle logout request # ################################################################################ sub handleLogoutRequest() { print "Content-type: text/html\n\n"; # Check if the session exists debug("Stage is logout"); my $uname; my $session = CGI::Session->load(); if ( $session->is_empty || $session->is_expired ) { # no session found ... send back to index.html page ... debug("Session empty or not found"); # just show the logout form without other info #my $url = "/"; #redirect($url); } else { # get the user name and delete the session debug("Session found"); $uname = $session->param("username"); $session->delete(); } # send redirect form to metacat and action = logout my $html = "<html><head>"; $html .= "</head><body onload=\"document.loginForm.submit()\">"; $html .= "<form name=\"loginForm\" method=\"post\" action=\"" . $metacatUrl . "\">"; $html .= "<input type=\"hidden\" name=\"action\" value=\"logout\" />"; $html .= "<input type=\"hidden\" name=\"username\" value=\"" . $uname . "\" />"; $html .= "<input type=\"hidden\" name=\"qformat\" value=\"" . $skinName . "\" />"; $html .= "</form></body></html>"; print($html); } ################################################################################ # # get current user credentials from session # ################################################################################ sub getCredentials { my $userDN = $FORM::username; my $userOrg = $FORM::organization; my $userPass = $FORM::password; my $authBase = $properties->getProperty("auth.base"); my $dname = "uid=$userDN,o=$userOrg,$authBase"; my $token_info; if ( hasValidAuthToken() ) { $token_info = getTokenInfo(); $dname = $token_info->{'sub'}; } else { my $session = CGI::Session->load(); if ( !( $session->is_empty || $session->is_expired ) ) { $dname = $session->param("username"); $userPass = $session->param("password"); } } return ( $dname, $userPass ); } ################################################################################ # # get user groups from metacat for the currently logged in user # ################################################################################ sub getUserGroups { my $sessionId = shift; #debug("getting user info for session id: $sessionId"); my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); if ( ! hasValidAuthToken() ) { my ( $username, $password ) = getCredentials(); $metacat->login( $username, $password ); } my $userInfo = $metacat->getUserInfo(); debug("user info xml: $userInfo"); my $parser = XML::LibXML->new(); my $parsedDoc = $parser->parse_string($userInfo); my $results = $parsedDoc->findnodes('//userInformation/group'); #my $groupString = $parsedDoc->findvalue('//userInformation/group'); my @groupArray; my $node = ''; foreach $node ( $results->get_nodelist ) { my $group = $node->textContent(); $group =~ s/^\s+//; $group =~ s/\s+$//; debug("pushing: $group"); push(@groupArray, $group); } return @groupArray; } ################################################################################ # # function to check if the moderator is logged in - if yes, then username and # password are set # ################################################################################ sub isModerator { my $stage = shift; my $returnValue = 1; # Check if the session exists my $session = CGI::Session->load(); if ( $session->is_empty || $session->is_expired ) { # no session found ... send back to index.html page ... processResultTemplate( $stage, 'failure', "Moderator is not logged in.\n" ); $returnValue = -1; } # check if logged in user is moderator my $moderator = $session->param("moderator"); if ( $moderator ne 'true' ) { # no session found ... send back to index.html page ... debug("Logged in user is not moderator"); processResultTemplate( $stage, 'failure', "Logged in user is not moderator.\n" ); $returnValue = -1; } if ( $returnValue eq 1 ) { ( $modUsername, $modPassword ) = getCredentials(); } return $returnValue; } sub handleRead { my $docid = $FORM::docid; my $sessionId = $FORM::sessionid; my $errorMessage; #debug("\n\n\n\n$docid"); print "Content-type: text/html\n\n"; # Check if the session exists my $session = CGI::Session->load(); if ( $session->is_empty || $session->is_expired ) { # no session found ... send back the regular read page ... my $url = "$skinsDir/$skinName/index.html"; redirect($url); } else { my $htmldoc = qq|<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Frameset//EN" "http://www.w3.org/TR/html4/frameset.dtd"> <html><head><title>Dataset Description: $docid |; print $htmldoc; } } sub handleReviewFrame { print "Content-type: text/html\n\n"; my $session = CGI::Session->load(); if ( $session->is_empty || $session->is_expired ) { return; } my $moderator = $session->param("moderator"); $$templateVars{'reviewdocid'} = getReviewHistoryHTML(); $$templateVars{'docid'} = $FORM::docid; if ( $moderator eq 'true' ) { $$templateVars{'isModerator'} = "true"; } $template->process( $templates->{'getReviews'}, $templateVars ); } sub getReviewHistoryHTML { my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); if ( ! hasValidAuthToken() ) { my ( $username, $password ) = getCredentials(); $metacat->login( $username, $password ); } my $parser = XML::LibXML->new(); my $docid = $FORM::docid; my ( $x, $y, $z ) = split( /\./, $docid ); if ( $x eq "" ) { return "Error: Unable to find review for invalid docid."; } my $docidWithoutRev = $x . "." . $y; my $reviewDocumentId = ''; #debug("find review history for docid $docidWithoutRev"); my $reviewQuery = "Moderator-Search$docidWithoutRev/reviewHistory/review/packageId"; my $response = $metacat->squery($reviewQuery); my $doc = $response->content(); my $xmldoc = $parser->parse_string($doc); my $reviewHTML = ''; if ( $xmldoc eq "" || $doc =~ /findnodes('//resultset/document'); if ( $findNodes->size() > 0 ) { #debug("//resultset/document section found"); # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $reviewDocumentId = findValue( $node, 'docid' ); } } } return $reviewDocumentId; } ################################################################################ # # function to handle accept request for moderator # ################################################################################ sub handleModAccept() { my $errorMessage = ''; my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); print "Content-type: text/html\n\n"; debug("Stage is mod_accept"); my $isMod = isModerator("accept"); if ( $isMod < 0 ) { return; } # read the document from my $parser = XML::LibXML->new(); my $title = ''; my $contactEmailAddress = ''; my $contactName = ''; my $userDN = ''; # Log into metacat my $response = hasValidAuthToken(); if ( ! $response ) { $response = $metacat->login( $modUsername, $modPassword ); } my $docid = $FORM::docid; if ( !$response ) { # Could not login $errorMessage = $errorMessage . " Failed during moderator login."; } else { # read the document and get the contact name and address $response = $metacat->read($docid); my $docFromMetacat = $response->content(); my $xmldoc = $parser->parse_string($docFromMetacat); my $dataElem = ''; my $results; if ( $xmldoc eq "" || $docFromMetacat =~ /findnodes('//dataset'); foreach my $r ( $results->get_nodelist ) { $dataElem .= $r->toString(); } $emldoc .= EMLStart(); $emldoc .= accessElement("true"); $emldoc .= $dataElem; $emldoc .= EMLEnd(); #debug("Document created by handleModAccept is " . $emldoc); # update the document my $docid = incrementRevision($docid); $emldoc =~ s/packageId="docid"/packageId=\"$docid\"/; debugDoc($emldoc); $response = $metacat->update( $docid, $emldoc ); if ( !$response ) { debug("Error while updating in handleModAccept."); #push(@errorMessages, $metacat->getMessage()); $errorMessage = $errorMessage . " Failed while updating the document with new access rules."; } # get the contact email address from the $xmldoc = $parser->parse_string($emldoc); if ( $xmldoc eq "" || $xmldoc =~ /findnodes('//dataset/contact'); if ( $findNodes->size() > 0 ) { # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $contactEmailAddress = findValue( $node, 'electronicMailAddress' ); my $surName = findValue( $node, 'individualName/surName' ); my $givenName = findValue( $node, 'individualName/givenName' ); my $organizationName = findValue( $node, 'organizaitionName' ); if ( $surName ne '' ) { $contactName = $givenName . ' ' . $surName; } else { $contactName = $organizationName; } } } else { $contactEmailAddress = ''; } $findNodes = $xmldoc->findnodes('//dataset/title'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $title = findValue( $node, '../title' ); } } else { $title = ''; } $findNodes = $xmldoc->findnodes('//access/allow'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { my $perm = findValue( $node, 'permission' ); if ( $perm ne 'all' ) { $userDN = findValue( $node, 'principal' ); } } } else { $userDN = ''; } } } } # give the system a chance to finish databasing and indexing sleep(5); # send notification to the user and the moderator if ( $errorMessage eq '' ) { modSendNotification( $title, $contactEmailAddress, $contactName, "Document $docid Accepted" ); if ( $FORM::review ne '' ) { $errorMessage = modStoreReview( 'accept', $metacat, $userDN ); if ( $errorMessage ne '' ) { processResultTemplate( 'accept', 'failure', $errorMessage ); return; } } # send notifications processResultTemplate( 'accept', 'success', $errorMessage ); } else { processResultTemplate( 'accept', 'failure', $errorMessage ); } } ################################################################################ # # function to handle decline request for moderator # ################################################################################ sub handleModDecline() { my $errorMessage = ''; my $userDN = ''; my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); my $docid = $FORM::docid; print "Content-type: text/html\n\n"; debug("Stage is mod_decline"); if ( isModerator('decline') < 0 ) { return; } # variables for contact information my $contactEmailAddress; my $contactName; my $title; # Log into metacat my $response = hasValidAuthToken(); if ( ! $response ) { $response = $metacat->login( $modUsername, $modPassword ); } if ( !$response ) { # Could not login #push(@errorMessages, $metacat->getMessage()); $errorMessage = $errorMessage . " Failed during moderator login."; } else { # read the document and get the contact name and address my $parser = XML::LibXML->new(); $response = $metacat->read($docid); my $doc = $response->content(); my $xmldoc = $parser->parse_string($doc); if ( $xmldoc eq "" || $doc =~ /findnodes('//dataset/contact'); if ( $findNodes->size() > 0 ) { # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $contactEmailAddress = findValue( $node, 'electronicMailAddress' ); my $surName = findValue( $node, 'individualName/surName' ); my $givenName = findValue( $node, 'individualName/givenName' ); my $organizationName = findValue( $node, 'organizaitionName' ); if ( $surName ne '' ) { $contactName = $givenName . ' ' . $surName; } else { $contactName = $organizationName; } } } else { $contactEmailAddress = ''; } $findNodes = $xmldoc->findnodes('//dataset/title'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $title = findValue( $node, '../title' ); } } else { $title = ''; } $findNodes = $xmldoc->findnodes('//access/allow'); if ( $findNodes->size() > 0 ) { # found allow my $node = ''; foreach $node ( $findNodes->get_nodelist ) { my $perm = findValue( $node, 'permission' ); if ( $perm ne 'all' ) { $userDN = findValue( $node, 'principal' ); } } } else { $userDN = ''; } } $response = $metacat->delete($docid); if ( !$response ) { debug("Error while deleting document in handleModDecline."); #push(@errorMessages, $metacat->getMessage()); $errorMessage = $errorMessage . " Failed during deleting $docid. Please check if you are authorized to delete this document or if the document is not already deleted."; } else { debug( "Document deleted by handleModDecline is " . $docid ); } } if ( $errorMessage eq '' ) { modSendNotification( $title, $contactEmailAddress, $contactName, "Document $docid Rejected" ); if ( $FORM::review ne '' ) { $errorMessage = modStoreReview( 'decline', $metacat, $userDN ); if ( $errorMessage ne '' ) { processResultTemplate( 'decline', 'failure', $errorMessage ); return; } } # send notifications processResultTemplate( 'decline', 'success', $errorMessage ); } else { processResultTemplate( 'decline', 'failure', $errorMessage ); } } ################################################################################ # # function to handle revise request for moderator # ################################################################################ sub handleModRevise() { my $errorMessage = ''; my $metacat = Metacat->new($metacatUrl); setAuthToken($metacat); my $docid = $FORM::docid; print "Content-type: text/html\n\n"; debug("Stage is mod_revise"); if ( isModerator('revise') < 0 ) { return; } # variables for contact information my $contactEmailAddress; my $contactName; my $title; my $userDN = ''; # Log into metacat my $response = hasValidAuthToken(); if ( ! $response ) { $response = $metacat->login( $modUsername, $modPassword ); } if ( !$response ) { # Could not login #push(@errorMessages, $metacat->getMessage()); $errorMessage = $errorMessage . " Failed during moderator login."; } else { # read the document and get the contact name and address my $parser = XML::LibXML->new(); $response = $metacat->read($docid); my $doc = $response->content(); my $xmldoc = $parser->parse_string($doc); $xmldoc = transformEml($xmldoc); if ( $xmldoc eq "" || $doc =~ /findnodes('//dataset/contact'); if ( $findNodes->size() > 0 ) { # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $contactEmailAddress = findValue( $node, 'electronicMailAddress' ); my $surName = findValue( $node, 'individualName/surName' ); my $givenName = findValue( $node, 'individualName/givenName' ); my $organizationName = findValue( $node, 'organizaitionName' ); if ( $surName ne '' ) { $contactName = $givenName . ' ' . $surName; } else { $contactName = $organizationName; } } } else { $contactEmailAddress = ''; } $findNodes = $xmldoc->findnodes('//dataset/title'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $title = findValue( $node, '../title' ); } } else { $title = ''; } $findNodes = $xmldoc->findnodes('//access/allow'); if ( $findNodes->size() > 0 ) { # found title my $node = ''; foreach $node ( $findNodes->get_nodelist ) { my $perm = findValue( $node, 'permission' ); if ( $perm ne 'all' ) { $userDN = findValue( $node, 'principal' ); } } } else { $userDN = ''; } } my $emldoc = ''; my $dataElem = ''; my $accessElem = ''; # pull out existing dataset entry my $results = $xmldoc->findnodes('/eml:eml/dataset'); foreach my $r ( $results->get_nodelist ) { $dataElem .= $r->toString(); } # also grab the access element $results = $xmldoc->findnodes('/eml:eml/access'); foreach my $r ( $results->get_nodelist ) { $accessElem .= $r->toString(); } my $addlMetadata = qq| Revision Requested |; $emldoc .= EMLStart(); $emldoc .= $accessElem; $emldoc .= $dataElem; $emldoc .= $addlMetadata; $emldoc .= EMLEnd(); # update the document my $docid = incrementRevision($docid); $emldoc =~ s/packageId="docid"/packageId="$docid"/; debugDoc($emldoc); $response = $metacat->update( $docid, $emldoc ); if ( !$response ) { debug( "Error while updating in handleModAccept." . $metacat->getMessage() ); $errorMessage = $errorMessage . " Failed while updating the document with additional metadata."; } } if ( $errorMessage eq '' ) { modSendNotification( $title, $contactEmailAddress, $contactName, "Revise document: $docid" ); if ( $FORM::review ne '' ) { $errorMessage = modStoreReview( 'revise', $metacat, $userDN ); if ( $errorMessage ne '' ) { processResultTemplate( 'revise', 'failure', $errorMessage ); return; } } # send notifications processResultTemplate( 'revise', 'success', $errorMessage ); } else { processResultTemplate( 'revise', 'failure', $errorMessage ); } } sub modStoreReview { my $action = shift; my $metacat = shift; my $userDN = shift; my $gmt = gmtime($now); my $docid = $FORM::docid; my $parser = XML::LibXML->new(); # create the xml part that has to be inserted my $review = qq| $docid $action $gmt $FORM::review |; # find out if a docid already exists... my ( $x, $y, $z ) = split( /\./, $docid ); my $docidWithoutRev = $x . "." . $y; debug("docid without rev: $docidWithoutRev"); my $reviewDocumentId = ''; my $response = $metacat->squery( "Moderator-Search$docidWithoutRev/reviewHistory/review/packageId" ); my $doc = $response->content(); my $xmldoc = $parser->parse_string($doc); if ( $xmldoc eq "" || $doc =~ /findnodes('//resultset/document'); if ( $findNodes->size() > 0 ) { # found contact email address my $node = ''; foreach $node ( $findNodes->get_nodelist ) { $reviewDocumentId = findValue( $node, 'docid' ); } # update the old document $response = $metacat->read($reviewDocumentId); $doc = $response->content(); $xmldoc = $parser->parse_string($doc); if ( $xmldoc eq "" || $doc =~ /', $doc ); $reviewdoc .= $review . "\n\n"; $reviewDocumentId = incrementRevision($reviewDocumentId); debug( "Generating review history document for $reviewDocumentId"); debugDoc($reviewdoc); $response = $metacat->update( $reviewDocumentId, $reviewdoc ); if ( $response != '1' ) { return " Unable to update the review on Metacat for the docid:" . $docid; } else { $response = $metacat->setaccess( $reviewDocumentId, $userDN, "read", "allow", "allowFirst" ); if ( $response != '1' ) { return " Unable to set access for the review document in Metacat for the docid:" . $docid; } foreach ( split( ":", $moderators ) ) { $response = $metacat->setaccess( $reviewDocumentId, $_, "all", "allow", "allowFirst" ); if ( $response != '1' ) { return " Unable to set access for the review document in Metacat for the docid:" . $docid; } } } } } else { #insert a new document debug("no review history document found, generating a new one."); my $id = newAccessionNumber( 'esa_reviews', $metacat ); my $reviewDoc = ''; my $failMessage = " Unable to insert the review on Metacat for the docid:" . $docid; $reviewDoc .= ""; $reviewDoc .= ""; $reviewDoc .= $review; $reviewDoc .= ""; $response = $metacat->insert( $id, $reviewDoc ); if ( $response != '1' ) { return $failMessage; } else { # set access $response = $metacat->setaccess( $id, $userDN, "read", "allow", "allowFirst" ); if ( $response != '1' ) { return $failMessage; } foreach ( split( ":", $moderators ) ) { $response = $metacat->setaccess( $id, $_, "all", "allow", "allowFirst" ); if ( $response != '1' ) { return $failMessage; } } # DENY all public access to these documents $response = $metacat->setaccess( $id, 'public', "all", "deny", "allowFirst" ); if ( $response != '1' ) { return $failMessage; } } } } return ''; # find out if a document already exist. if not then insert a new one. otherwise update the old one # the owner of the document is the moderator } ################################################################################ # # send an email message to the moderator and the contact # ################################################################################ sub modSendNotification { my $title = shift; my $contactEmailAddress = shift; my $contactName = shift; my $subject = shift; #debug($subject); # send notification to the user and the moderator my $templateVars = { 'stage' => $FORM::stage }; my ( $x, $y, $z ) = split( /\./, $FORM::docid ); my $docidWithoutRev = $x . "." . $y; $$templateVars{'docid'} = $docidWithoutRev; $$templateVars{'fullDocid'} = $FORM::docid; if (hasContent($FORM::function)) { $$templateVars{'function'} = $FORM::function; } else { $$templateVars{'function'} = 'unknown'; } $$templateVars{'comment'} = $FORM::review; $$templateVars{'contactName'} = $contactName; $$templateVars{'dpTitle'} = $title; $$templateVars{'registryUrl'} = $contextUrl . "/cgi-bin/register-dataset.cgi"; $$templateVars{'metacatUrl'} = $metacatUrl; $$templateVars{'contextUrl'} = $contextUrl; $$templateVars{'recipient_status'} = 'moderator'; debug( "modSendNotification - sending moderator notification to: $email->{'recipient'} with subject: $subject" ); sendNotification( $email->{'sender'}, $email->{'recipient'}, $subject, $templates->{'modEmailNotification'}, $templateVars ); if ( $contactEmailAddress ne '' ) { # send notification to contact email address specified in cfg $$templateVars{'recipient_status'} = 'user'; debug( "modSendNotification - sending user notification to: $contactEmailAddress with subject: $subject" ); sendNotification( $email->{'sender'}, $contactEmailAddress, $subject, $templates->{'modEmailNotification'}, $templateVars ); } } ################################################################################ # # send an email message notifying the moderator of a new submission # ################################################################################ sub sendNotification { my $sender = shift; my $recipient = shift; my $subject = shift; my $templateForm = shift; my $templateVars = shift; # When testing, set recipient to your email address # $recipient = 'walbridge@nceas.ucsb.edu'; my $smtp = Net::SMTP->new( $email->{'mailhost'} ); $smtp->mail($sender); $smtp->to($recipient); $smtp->data; $smtp->datasend("From: $sender\n"); $smtp->datasend("To: <$recipient>\n"); $smtp->datasend("Subject: $subject\n"); $smtp->datasend("\n"); my $message; $template->process( $templateForm, $templateVars, \$message ); $smtp->datasend($message); $smtp->dataend(); $smtp->quit; } ################################################################################ # # sends back the result to the use # ################################################################################ sub processResultTemplate() { my $stage = shift; my $result = shift; my $message = shift; if ( $result eq 'success' ) { if ( $stage eq 'accept' ) { $message = "Dataset (docid:" . $FORM::docid . ") accepted "; } elsif ( $stage eq 'decline' ) { $message = "Dataset (docid:" . $FORM::docid . ") declined "; } else { $message = "Revision requested for dataset (docid:" . $FORM::docid . ") "; } } else { if ( $stage eq 'accept' ) { $message = "Failure in accepting docid: " . $FORM::docid . " (" . $message . ")"; } elsif ( $stage eq 'decline' ) { $message = "Failure in declining docid: " . $FORM::docid . " (" . $message . ")"; } else { $message = "Failure in requesting revision of docid: " . $FORM::docid . " (" . $message . ")"; } } $$templateVars{'message'} = $message; $template->process( $templates->{'modResult'}, $templateVars ); } ################################################################################ # # Do data validation and send the data to confirm data template. # ################################################################################ sub toConfirmData { # Check if any invalid parameters my $invalidParams; if ( !$error ) { $invalidParams = validateParameters(0); if ( scalar(@$invalidParams) ) { $$templateVars{'status'} = 'failure'; $$templateVars{'invalidParams'} = $invalidParams; $error = 1; } } $$templateVars{'providerGivenName'} = normalizeCD($FORM::providerGivenName); $$templateVars{'providerSurName'} = normalizeCD($FORM::providerSurName); if ( $FORM::site eq "Select your station here." ) { $$templateVars{'site'} = ""; } else { $$templateVars{'site'} = $FORM::site; } if ( $skinName eq "nceas" ) { $$templateVars{'wg'} = \@FORM::wg; } $$templateVars{'funding'} = normalizeCD($FORM::funding); # handle multiple identifiers #$$templateVars{'identifier'} = normalizeCD($FORM::identifier); my $identifierArray = \@FORM::identifier; debug( "Processing identifier array size = " . $#$identifierArray ); my $identifierCount = 1; for ( my $i = 0 ; $i <= $#$identifierArray ; $i++ ) { if ( hasContent( $identifierArray->[$i] ) ) { debug( "Processing confirm identifier: id = " . $identifierArray->[$i] ); $$templateVars{ "identifierValue" . $identifierCount } = normalizeCD( $identifierArray->[$i] ); $identifierCount++; } } $$templateVars{'identifierCount'} = $identifierCount - 1; $$templateVars{'title'} = normalizeCD($FORM::title); # Handle multiple parties my $partyIds = \@FORM::partyId; my $partyFirstNames = \@FORM::partyFirstName; my $partyLastNames = \@FORM::partyLastName; my $partyRoles = \@FORM::partyRole; # role is required no matter what my $partyOrgNames = \@FORM::partyOrgName; my $partyPositionNames = \@FORM::partyPositionName; my $partyEmails = \@FORM::partyEmail; my $partyURLs = \@FORM::partyURL; my $partyPhones = \@FORM::partyPhone; my $partyFaxes = \@FORM::partyFAX; my $partyDeliveries = \@FORM::partyDelivery; my $partyCities = \@FORM::partyCity; my $partyStates = \@FORM::partyState; my $partyStatesOther = \@FORM::partyStateOther; my $partyZIPs = \@FORM::partyZIP; my $partyCountries = \@FORM::partyCountry; my $partyCount = $FORM::partyCount; for ( my $partyIndex = 0; $partyIndex <= $partyCount; $partyIndex++ ) { $$templateVars{'partyId' . $partyIndex} = normalizeCD($partyIds->[$partyIndex]); $$templateVars{'partyFirstName' . $partyIndex} = normalizeCD($partyFirstNames->[$partyIndex]); $$templateVars{'partyLastName' . $partyIndex} = normalizeCD($partyLastNames->[$partyIndex]); $$templateVars{'partyRole' . $partyIndex} = normalizeCD($partyRoles->[$partyIndex]); $$templateVars{'partyOrgName' . $partyIndex} = normalizeCD($partyOrgNames->[$partyIndex]); $$templateVars{'partyPositionName' . $partyIndex} = normalizeCD($partyPositionNames->[$partyIndex]); $$templateVars{'partyEmail' . $partyIndex} = normalizeCD($partyEmails->[$partyIndex]); $$templateVars{'partyURL' . $partyIndex} = normalizeCD($partyURLs->[$partyIndex]); $$templateVars{'partyPhone' . $partyIndex} = normalizeCD($partyPhones->[$partyIndex]); $$templateVars{'partyFAX' . $partyIndex} = normalizeCD($partyFaxes->[$partyIndex]); $$templateVars{'partyDelivery' . $partyIndex} = normalizeCD($partyDeliveries->[$partyIndex]); $$templateVars{'partyCity' . $partyIndex} = normalizeCD($partyCities->[$partyIndex]); if ( $partyStates->[$partyIndex] =~ /select state/i ) { $$templateVars{'partyState' . $partyIndex} = ""; } else { $$templateVars{'partyState' . $partyIndex} = $partyStates->[$partyIndex]; } $$templateVars{'partyStateOther' . $partyIndex} = normalizeCD($partyStatesOther->[$partyIndex]); $$templateVars{'partyZIP' . $partyIndex} = normalizeCD($partyZIPs->[$partyIndex]); $$templateVars{'partyCountry' . $partyIndex} = normalizeCD($partyCountries->[$partyIndex]); #$partyCount++; } #$$templateVars{'partyCount'} = $partyCount - 1; $$templateVars{'partyCount'} = $FORM::partyCount; $$templateVars{'abstract'} = normalizeCD($FORM::abstract); my $keywordArray = \@FORM::keyword; my $keywordTypeArray = \@FORM::keywordType; my $keywordThArray = \@FORM::keywordTh; my $keyCount = 1; for ( my $i = 0 ; $i <= $#$keywordArray ; $i++ ) { if ( hasContent( $keywordArray->[$i] ) ) { debug( "Processing keyword: keyword = " . $keywordArray->[$i] . " keywordType = " . $keywordTypeArray->[$i] . " keywordTh = " . $keywordThArray->[$i] ); $$templateVars{ "keyword" . $keyCount } = normalizeCD( $keywordArray->[$i] ); $$templateVars{ "kwType" . $keyCount } = normalizeCD( $keywordTypeArray->[$i] ); $$templateVars{ "kwTh" . $keyCount } = normalizeCD( $keywordThArray->[$i] ); $keyCount++; } } $$templateVars{'keyCount'} = $keyCount; $$templateVars{'addComments'} = normalizeCD($FORM::addComments); $$templateVars{'useConstraints'} = $FORM::useConstraints; if ( $FORM::useConstraints eq "other" ) { $$templateVars{'useConstraintsOther'} = $FORM::useConstraintsOther; } $$templateVars{'url'} = $FORM::url; $$templateVars{'dataMedium'} = $FORM::dataMedium; if ( $FORM::dataMedium eq "other" ) { $$templateVars{'dataMediumOther'} = normalizeCD($FORM::dataMediumOther); } $$templateVars{'beginningYear'} = $FORM::beginningYear; $$templateVars{'beginningMonth'} = $FORM::beginningMonth; $$templateVars{'beginningDay'} = $FORM::beginningDay; $$templateVars{'endingYear'} = $FORM::endingYear; $$templateVars{'endingMonth'} = $FORM::endingMonth; $$templateVars{'endingDay'} = $FORM::endingDay; $$templateVars{'geogdesc'} = normalizeCD($FORM::geogdesc); $$templateVars{'useSiteCoord'} = $FORM::useSiteCoord; $$templateVars{'latDeg1'} = $FORM::latDeg1; $$templateVars{'latMin1'} = $FORM::latMin1; $$templateVars{'latSec1'} = $FORM::latSec1; $$templateVars{'hemisphLat1'} = $FORM::hemisphLat1; $$templateVars{'longDeg1'} = $FORM::longDeg1; $$templateVars{'longMin1'} = $FORM::longMin1; $$templateVars{'longSec1'} = $FORM::longSec1; $$templateVars{'hemisphLong1'} = $FORM::hemisphLong1; $$templateVars{'latDeg2'} = $FORM::latDeg2; $$templateVars{'latMin2'} = $FORM::latMin2; $$templateVars{'latSec2'} = $FORM::latSec2; $$templateVars{'hemisphLat2'} = $FORM::hemisphLat2; $$templateVars{'longDeg2'} = $FORM::longDeg2; $$templateVars{'longMin2'} = $FORM::longMin2; $$templateVars{'longSec2'} = $FORM::longSec2; $$templateVars{'hemisphLong2'} = $FORM::hemisphLong2; my $taxonRankArray = \@FORM::taxonRank; my $taxonNameArray = \@FORM::taxonName; my $taxonCount = 1; for ( my $i = 0 ; $i <= $#$taxonNameArray ; $i++ ) { if ( hasContent( $taxonRankArray->[$i] ) && hasContent( $taxonNameArray->[$i] ) ) { debug( "Processing keyword: trv = " . $taxonRankArray->[$i] . " trn = " . $taxonNameArray->[$i] ); $$templateVars{ "taxonRankName" . $taxonCount } = normalizeCD( $taxonRankArray->[$i] ); $$templateVars{ "taxonRankValue" . $taxonCount } = normalizeCD( $taxonNameArray->[$i] ); $taxonCount++; } } $$templateVars{'taxaCount'} = $taxonCount - 1; $$templateVars{'taxaAuth'} = normalizeCD($FORM::taxaAuth); my $deleteCount = 0; for ( my $i = 0 ; $i <= scalar(@FORM::deletefile) ; $i++ ) { my $delfile = pop(@FORM::deletefile); $$templateVars{"deletefile_$deleteCount"} = $delfile; debug(" creating deletefile_$deleteCount = $delfile"); $deleteCount++; } $$templateVars{"delCount"} = $deleteCount; for ( my $upNum = 0 ; $upNum <= $FORM::upCount ; $upNum++ ) { my $upn = "upload_$upNum"; if ( hasContent( param($upn) ) ) { debug("Processing existing file: $upn"); $$templateVars{"upload_$upNum"} = param("upload_$upNum"); $$templateVars{"uploadname_$upNum"} = param("uploadname_$upNum"); $$templateVars{"uploadtype_$upNum"} = param("uploadtype_$upNum"); $$templateVars{"uploadperm_$upNum"} = param("uploadperm_$upNum"); } } my $uploadCount = 0; for ( my $fileNum = 0 ; $fileNum <= $FORM::fileCount ; $fileNum++ ) { my $fn = 'file_' . $fileNum; if ( hasContent( param($fn) ) ) { my $fileName = eval "\$FORM::file_$fileNum"; debug("Processing file: $fn"); # Upload the file object itself to a temporary file, copy file metadata to form my $fileInfo = processFile($fileName); $$templateVars{"upload_$fileNum"} = $fileInfo->{'fileHash'}; $$templateVars{"uploadname_$fileNum"} = $fileInfo->{'fileName'}; $$templateVars{"uploadtype_$fileNum"} = $fileInfo->{'contentType'}; $$templateVars{"uploadperm_$fileNum"} = param("uploadperm_$fileNum"); $uploadCount++; } } # total uploads are: new uploads - deleted files + original uploads $$templateVars{'upCount'} = $uploadCount + $FORM::upCount; $$templateVars{'methodTitle'} = normalizeCD($FORM::methodTitle); my @tempMethodPara; for ( my $i = 0 ; $i < scalar(@FORM::methodPara) ; $i++ ) { $tempMethodPara[$i] = normalizeCD( $FORM::methodPara[$i] ); } $$templateVars{'methodPara'} = \@tempMethodPara; $$templateVars{'studyExtentDescription'} = normalizeCD($FORM::studyExtentDescription); $$templateVars{'samplingDescription'} = normalizeCD($FORM::samplingDescription); # $$templateVars{'origStateContact'} = $FORM::origState; $$templateVars{'modules'} = $modules; $$templateVars{'required'} = $required; $$templateVars{'show'} = $show; $$templateVars{'site'} = $FORM::site; $$templateVars{'docid'} = $FORM::docid; # Check if the session exists if ( validateSession() ) { $$templateVars{'userLoggedIn'} = 'true'; } # Errors from validation function. print the errors out using the response template if ( scalar(@errorMessages) ) { debug("Error messages found when confirming data."); $$templateVars{'status'} = 'failure'; $$templateVars{'errorMessages'} = \@errorMessages; $error = 1; } if ( !$error ) { # If no errors, then print out data in confirm Data template $$templateVars{'section'} = "Confirm Data"; #Just return the data file upload details, if specified if(param("justGetUploadDetails")){ $template->process( $templates->{'dataUploadDetails'}, $templateVars ); } else{ $template->process( $templates->{'confirmData'}, $templateVars ); } } else { # Create our HTML response and send it back $$templateVars{'function'} = "submitted"; $$templateVars{'section'} = "Submission Status"; $template->process( $templates->{'response'}, $templateVars ); } } ################################################################################ # # From confirm Data template - user wants to make some changes. # ################################################################################ sub confirmDataToReEntryData { my @sortedSites; foreach my $site ( sort @sitelist ) { push( @sortedSites, $site ); } $$templateVars{'siteList'} = \@sortedSites; $$templateVars{'section'} = "Re-Entry Form"; copyFormToTemplateVars(); $$templateVars{'docid'} = $FORM::docid; $$templateVars{'form'} = 're_entry'; $template->process( $templates->{'entry'}, $templateVars ); } ################################################################################ # # Copy form data to templateVars..... # ################################################################################ sub copyFormToTemplateVars { $$templateVars{'providerGivenName'} = $FORM::providerGivenName; $$templateVars{'providerSurName'} = $FORM::providerSurName; $$templateVars{'site'} = $FORM::site; if ( $skinName eq "nceas" ) { my $projects = getProjectList($properties); $$templateVars{'projects'} = $projects; $$templateVars{'wg'} = \@FORM::wg; } $$templateVars{'funding'} = $FORM::funding; # handle multiple identifier values #$$templateVars{'identifier'} = $FORM::identifier; $$templateVars{'identifierCount'} = $FORM::identifierCount; debug( "Identifier template count: " . $FORM::identifierCount ); foreach my $id ( param() ) { if ( $id =~ /identifier/ ) { debug( "Processing identifier param: $id = " . param($id) ); my $identifierIndex = $id; $identifierIndex =~ s/identifierValue//; # get the index of the parameter 0, ..., 10 my $idParamName = "identifierValue" . $identifierIndex; debug( "identifierIndex:" . $identifierIndex ); debug( "idParamName: " . $idParamName ); debug( "id: " . $id ); if ( $identifierIndex =~ /[0-9]+/ ) { if ( hasContent( param($idParamName) ) ) { debug( "Processing template identifier: $id = " . param($idParamName) ); $$templateVars{$idParamName} = param($idParamName); } } } } $$templateVars{'title'} = $FORM::title; if ( $FORM::useSiteCoord ne "" ) { $$templateVars{'useOrigAddress'} = "CHECKED"; } else { $$templateVars{'useOrigAddress'} = $FORM::useOrigAddress; } $$templateVars{'partyCount'} = $FORM::partyCount; foreach my $paramName ( param() ) { if ( $paramName =~ /partyRole/ ) { my $partyIndex = $paramName; $partyIndex =~ s/partyRole//; # get the index of the parameter 0, 1, 2, ... my $partyId = "partyId" . $partyIndex; my $partyFirstName = "partyFirstName" . $partyIndex; my $partyLastName = "partyLastName" . $partyIndex; my $partyRole = "partyRole" . $partyIndex; my $partyOrgName = "partyOrgName" . $partyIndex; my $partyPositionName = "partyPositionName" . $partyIndex; my $partyDelivery = "partyDelivery" . $partyIndex; my $partyCity = "partyCity" . $partyIndex; my $partyState = "partyState" . $partyIndex; my $partyStateOther = "partyStateOther" . $partyIndex; my $partyZIP = "partyZIP" . $partyIndex; my $partyCountry = "partyCountry" . $partyIndex; my $partyPhone = "partyPhone" . $partyIndex; my $partyFAX = "partyFAX" . $partyIndex; my $partyEmail = "partyEmail" . $partyIndex; my $partyURL = "partyURL" . $partyIndex; if ( $partyIndex >= 0 ) { if ( hasContent(param($partyRole)) ) { $$templateVars{$partyId} = normalizeCD(param($partyId)); $$templateVars{$partyFirstName} = normalizeCD(param($partyFirstName)); $$templateVars{$partyLastName} = normalizeCD(param($partyLastName)); $$templateVars{$partyRole} = normalizeCD(param($partyRole)); $$templateVars{$partyOrgName} = normalizeCD(param($partyOrgName)); $$templateVars{$partyPositionName} = normalizeCD(param($partyPositionName)); $$templateVars{$partyDelivery} = normalizeCD(param($partyDelivery)); $$templateVars{$partyCity} = normalizeCD(param($partyCity)); $$templateVars{$partyState} = normalizeCD(param($partyState)); $$templateVars{$partyStateOther} = normalizeCD(param($partyStateOther)); $$templateVars{$partyZIP} = normalizeCD(param($partyZIP)); $$templateVars{$partyCountry} = normalizeCD(param($partyCountry)); $$templateVars{$partyPhone} = normalizeCD(param($partyPhone)); $$templateVars{$partyFAX} = normalizeCD(param($partyFAX)); $$templateVars{$partyEmail} = normalizeCD(param($partyEmail)); $$templateVars{$partyURL} = normalizeCD(param($partyURL)); } } } } $$templateVars{'abstract'} = $FORM::abstract; $$templateVars{'keyCount'} = $FORM::keyCount; foreach my $kyd ( param() ) { if ( $kyd =~ /keyword/ ) { my $keyIndex = $kyd; $keyIndex =~ s/keyword//; # get the index of the parameter 0, ..., 10 my $keyType = "kwType" . $keyIndex; my $keyTh = "kwTh" . $keyIndex; if ( $keyIndex =~ /[0-9]+/ ) { if ( hasContent( param($kyd) ) && hasContent( param($keyType) ) && hasContent( param($keyTh) ) ) { debug( "Processing keyword: $kyd = " . param($kyd) . " $keyType = " . param($keyType) . " $keyTh = " . param($keyTh) ); $$templateVars{$kyd} = param($kyd); my $tmp = param($keyType); #convert the first letter to upper case $tmp =~ s/\b(\w)/\U$1/g; $$templateVars{$keyType} = $tmp; $$templateVars{$keyTh} = param($keyTh); } } } } $$templateVars{'addComments'} = $FORM::addComments; $$templateVars{'useConstraints'} = $FORM::useConstraints; $$templateVars{'useConstraintsOther'} = $FORM::useConstraintsOther; $$templateVars{'url'} = $FORM::url; $$templateVars{'dataMedium'} = $FORM::dataMedium; $$templateVars{'dataMediumOther'} = $FORM::dataMediumOther; $$templateVars{'beginningYear'} = $FORM::beginningYear; $$templateVars{'beginningMonth'} = $FORM::beginningMonth; $$templateVars{'beginningDay'} = $FORM::beginningDay; $$templateVars{'endingYear'} = $FORM::endingYear; $$templateVars{'endingMonth'} = $FORM::endingMonth; $$templateVars{'endingDay'} = $FORM::endingDay; $$templateVars{'geogdesc'} = $FORM::geogdesc; if ( $FORM::useSiteCoord ne "" ) { $$templateVars{'useSiteCoord'} = "CHECKED"; } else { $$templateVars{'useSiteCoord'} = ""; } $$templateVars{'latDeg1'} = $FORM::latDeg1; $$templateVars{'latMin1'} = $FORM::latMin1; $$templateVars{'latSec1'} = $FORM::latSec1; $$templateVars{'hemisphLat1'} = $FORM::hemisphLat1; $$templateVars{'longDeg1'} = $FORM::longDeg1; $$templateVars{'longMin1'} = $FORM::longMin1; $$templateVars{'longSec1'} = $FORM::longSec1; $$templateVars{'hemisphLong1'} = $FORM::hemisphLong1; $$templateVars{'latDeg2'} = $FORM::latDeg2; $$templateVars{'latMin2'} = $FORM::latMin2; $$templateVars{'latSec2'} = $FORM::latSec2; $$templateVars{'hemisphLat2'} = $FORM::hemisphLat2; $$templateVars{'longDeg2'} = $FORM::longDeg2; $$templateVars{'longMin2'} = $FORM::longMin2; $$templateVars{'longSec2'} = $FORM::longSec2; $$templateVars{'hemisphLong2'} = $FORM::hemisphLong2; $$templateVars{'taxaCount'} = $FORM::taxaCount; foreach my $trn ( param() ) { if ( $trn =~ /taxonRankName/ ) { my $taxIndex = $trn; $taxIndex =~ s/taxonRankName//; # get the index of the parameter 0, ..., 10 my $trv = "taxonRankValue" . $taxIndex; if ( $taxIndex =~ /[0-9]+/ ) { if ( hasContent( param($trn) ) && hasContent( param($trv) ) ) { debug( "Processing taxon: $trn = " . param($trn) . " $trv = " . param($trv) ); $$templateVars{$trn} = param($trn); $$templateVars{$trv} = param($trv); } } } } $$templateVars{'taxaAuth'} = $FORM::taxaAuth; $$templateVars{'methodTitle'} = $FORM::methodTitle; $$templateVars{'methodPara'} = \@FORM::methodPara; $$templateVars{'studyExtentDescription'} = $FORM::studyExtentDescription; $$templateVars{'samplingDescription'} = $FORM::samplingDescription; $$templateVars{'modules'} = $modules; $$templateVars{'required'} = $required; $$templateVars{'show'} = $show; $$templateVars{'site'} = $FORM::site; $$templateVars{'fileCount'} = $FORM::fileCount; my $uploadCount = 0; foreach my $upload ( param() ) { if ( $upload =~ /upload_/ ) { my $fileIndex = $upload; $fileIndex =~ s/upload_//; if ( $fileIndex =~ /[0-9]+/ ) { if ( hasContent( param($upload) ) ) { debug( "Returning filename: " . param($upload) ); $$templateVars{"upload_$fileIndex"} = param($upload); $$templateVars{"uploadname_$fileIndex"} = param("uploadname_$fileIndex"); $$templateVars{"uploadtype_$fileIndex"} = param("uploadtype_$fileIndex"); $$templateVars{"uploadperm_$fileIndex"} = param("uploadperm_$fileIndex"); $uploadCount++; } } } } $$templateVars{'upCount'} = $uploadCount; } ################################################################################ # # check if there is multiple occurence of the given tag and find its value. # ################################################################################ sub findValue { my $node = shift; my $value = shift; my $result; my $tempNode; $result = $node->findnodes("./$value"); if ( $result->size() > 1 ) { errMoreThanOne("$value"); } else { foreach $tempNode ( $result->get_nodelist ) { #print $tempNode->nodeName().":".$tempNode->textContent(); #print "\n"; return $tempNode->textContent(); } } } ################################################################################ # # check if given tags has any children. if not return the value # ################################################################################ sub findValueNoChild { my $node = shift; my $value = shift; my $tempNode; my $childNodes; my $result; my $error; $result = $node->findnodes("./$value"); if ( $result->size() > 1 ) { errMoreThanOne("$value"); } else { foreach $tempNode ( $result->get_nodelist ) { $childNodes = $tempNode->childNodes; if ( $childNodes->size() > 1 ) { $error = "The tag $value has children which cannot be shown using the form. Please use Morpho to edit this document"; push( @errorMessages, $error ); } else { return $tempNode->textContent(); } } } } ################################################################################ # # check if given tags are children of given node. # ################################################################################ sub dontOccur { my $node = shift; my $value = shift; my $errVal = shift; my $result = $node->findnodes("$value"); if ( $result->size() > 0 ) { debug("Error trying to find $value, $errVal."); $error = "One of the following tags found: $errVal. Please use Morpho to edit this document"; push( @errorMessages, $error . "\n" ); } } ################################################################################ # # print out error for more than one occurence of a given tag # ################################################################################ sub errMoreThanOne { my $value = shift; my $error = "More than one occurence of the tag $value found. Please use Morpho to edit this document"; push( @errorMessages, $error . "\n" ); } ################################################################################ # # print out error for more than given number of occurences of a given tag # ################################################################################ sub errMoreThanN { my $value = shift; my $error = "More occurences of the tag $value found than that can be shown in the form. Please use Morpho to edit this document"; push( @errorMessages, $error ); } ################################################################################ # # print redirect html code # ################################################################################ sub redirect() { my $url = shift; print ""; print ""; print ""; } ################################################################################ # # print debugging messages to stderr # ################################################################################ sub debug { my $msg = shift; if ($debug_enabled) { my $date = localtime(); print STDERR "Registry $date: $msg\n"; } else { # This empty print statement is to prevent a bizzare error of the NCEAS # skin failing when: debug = 0, and a file upload is attached. Maybe # related to function return values? print ""; } } ################################################################################ # # dump the EML document to disk # ################################################################################ sub debugDoc { my $doc = shift; if ($debug_enabled) { # Write out the XML file for debugging purposes my $testFile = $tempDir . "/registry-eml-upload.xml"; if ( open( TFILE, ">$testFile" ) ) { print TFILE $doc; close(TFILE); } else { debug("WARNING: Cant open xml file: $testFile"); } } } ################################################################################ # # get the list of projects # ################################################################################ sub getProjectList { my $properties = shift; my $projects; # Check for availability AdminDB.pm, for accessing NCEAS projects eval { require NCEAS::AdminDB }; if ($@) { $projects = getTestProjectList(); } else { my $admindb = NCEAS::AdminDB->new(); # populate db parameters for NCEAS AdminDB my $db = $skinProperties->splitToTree( qr/\./, 'registry.db' ); # check all neccessary parameters exist if ( !$db->{'connection'} || !$db->{'user'} || !$db->{'password'} ) { debug( "NCEAS AdminDB misconfigured. Check database configuration parameters, in the registry.db section of nceas.properties." ); $projects = getTestProjectList(); } else { $admindb->connect( $db->{'connection'}, $db->{'user'}, $db->{'password'} ); if ( $admindb->{'connected'} ) { $projects = $admindb->getProjects(); } else { $projects = getTestProjectList(); } } } return $projects; } ################################################################################ # # get a test list of projects for use only in testing where the NCEAS # admin db is not available. # ################################################################################ sub getTestProjectList { # This block is for testing only! Remove for production use my @row1; $row1[0] = 6000; $row1[1] = 'Andelman'; $row1[2] = 'Sandy'; $row1[3] = 'The very long and windy path to an apparent ecological conclusion: statistics lie'; my @row2; $row2[0] = 7000; $row2[1] = 'Bascompte'; $row2[2] = 'Jordi'; $row2[3] = 'Postdoctoral Fellow'; my @row3; $row3[0] = 7001; $row3[1] = 'Hackett'; $row3[2] = 'Edward'; $row3[3] = 'Sociology rules the world'; my @row4; $row4[0] = 7002; $row4[1] = 'Jones'; $row4[2] = 'Matthew'; $row4[3] = 'Informatics rules the world'; my @row5; $row5[0] = 7003; $row5[1] = 'Schildhauer'; $row5[2] = 'Mark'; $row5[3] = 'Excel rocks my world, assuming a, b, and c'; my @row6; $row6[0] = 7004; $row6[1] = 'Rogers'; $row6[2] = 'Bill'; $row6[3] = 'Graduate Intern'; my @row7; $row7[0] = 7005; $row7[1] = 'Zedfried'; $row7[2] = 'Karl'; $row7[3] = 'A multivariate analysis of thing that go bump in the night'; my @projects; $projects[0] = \@row1; $projects[1] = \@row2; $projects[2] = \@row3; $projects[3] = \@row4; $projects[4] = \@row5; $projects[5] = \@row6; $projects[6] = \@row7; return \@projects; } ################################################################################ # # Set the incoming HTTP Authorization header as an instance variable in the # given Metacat object # ################################################################################ sub setAuthToken() { my $metacat = shift; if ( $debug_enabled ) { debug('setAuthToken() called.'); } eval { $metacat->isa('Metacat'); }; if ( ! $@ ) { # Set the auth_token_header if available if ( $ENV{'HTTP_AUTHORIZATION'}) { $metacat->set_options( auth_token_header => $ENV{'HTTP_AUTHORIZATION'}); } else { if ( $debug_enabled ) { debug("There is no HTTP_AUTHORIZATION variable. " . "Did not set Metacat->{'auth_token_header'}"); } } } else { debug('Not an instance of Metacat.' . 'Pass a Metacat object only to setAuthToken().'); } } ################################################################################ # # Downloads the server certificate used to sign tokens, and converts it from PEM # format to DER format. Writes both to the Metacat temp directory if configured. # ################################################################################ sub getSigningCertificate() { if ( $debug_enabled ) { debug('getSigningCertificate called.'); } open(my $pem_cert_file, ">", $pem_file_path) or die "\nCould not open PEM certificate file: $!\n"; # Attempts to use IO::Socket::SSL->peer_certificate() # and Net::SSLeay->get_peer_certificate() # return an unparseable cert (it seems). # Settle for the openssl command instead. # my $client = IO::Socket::SSL->new('cn-stage.test.dataone.org:443') # or die "error=$!, ssl_error=$SSL_ERROR"; #$signing_cert = $client->peer_certificate(); #print $signing_cert; #$client->close(); my @lines = `openssl s_client -connect $cn:443 -showcerts 2>/dev/null`; my $count = 0; my ($start_line_number, $end_line_number); # Find the start line of the first cert for my $line (@lines) { $count = $count + 1; if ( $line =~ /BEGIN/) { $start_line_number = $count; last; } } # Find the end line of the first cert $count = 0; for my $line (@lines) { $count = $count + 1; if ( $line =~ /END/) { $end_line_number = $count; last; } } # print the cert to a PEM file $count = 0; for my $line (@lines) { $count = $count + 1; if ( $count >= $start_line_number && $count <= $end_line_number) { print $pem_cert_file $line; } } close($pem_cert_file); # Convert the PEM to DER my @convert_der_args = ("openssl", "x509", "-in", $pem_file_path, "-inform", "PEM", "-out", $der_file_path, "-outform", "DER"); system(@convert_der_args); # For debugging, display the cert details if ( $debug_enabled ) { my @cert_info = `openssl x509 -noout -issuer -subject -dates -in $pem_file_path`; debug("Signing certificate info: "); for my $info_line (@cert_info) { debug($info_line); } } } ################################################################################ # # Returns details about the parsed token # ################################################################################ sub getTokenInfo() { # Initialize the token info hash if ( $debug_enabled ) { debug('getTokenInfo() called.'); } my $token_info = { userId => '', issuedAt => '', iat => '', sub => '', consumerKey => '', exp => '', ttl => '', fullName => '', isValid => 0 }; my $token = "NO TOKEN YET"; if ( $ENV{'HTTP_AUTHORIZATION'} ) { my @token_parts = split(/ /, $ENV{'HTTP_AUTHORIZATION'}); $token = @token_parts[1]; } my $der_cert_file; my $signing_cert; # If we don't already have the CN signing cert, get it if ( ! -e $der_file_path ) { getSigningCertificate(); } # Read the DER-encoded certificate open($der_cert_file, "<", $der_file_path) or die "\nCould not open DER certificate file: $!\n"; binmode($der_cert_file); read($der_cert_file, $signing_cert, 4096) or die "Problem reading the DER-encoded server cert: $!\n" if $!; close($der_cert_file); my $cert = Crypt::X509->new(cert=>$signing_cert); # Decode the token using Crypt::JWT eval{ $token_info = decode_jwt(token=>$token, key=>$cert) }; if ( ! $@ ) { $$token_info{isValid} = 1; } else { debug("There was a problem parsing the token: $token"); debug($@); } return $token_info; } ################################################################################ # # Validate the session, and return true if the session is not expired. Support # both CGI::Session and JWT authentication token sessions, where auth tokens # take precendence. # ################################################################################ sub validateSession() { if ( $debug_enabled ) { debug('validateSession() called.'); } my $token_info = getTokenInfo(); my $session = CGI::Session->load(); my $valid = 0; if ( $token_info->{"isValid"} ) { $valid = 1; if ( $debug_enabled ) { debug('The auth token session is valid.'); } } elsif ( ! $session->is_empty && ! $session->is_expired ) { $valid = 1; if ( $debug_enabled ) { debug('The CGI session is valid.'); } } if ( $debug_enabled ) { if ( ! $valid ) { debug('The session is not valid.'); } } if ( $debug_enabled ) { while( my ($k, $v) = each %$token_info ) { debug("$k: $v"); } } return $valid; } ################################################################################ # # Determine if the current authentication token is valid # ################################################################################ sub hasValidAuthToken() { if ( $debug_enabled ) { debug('hasValidAuthToken() called.'); } my $token_info = getTokenInfo(); if ( $debug_enabled ) { debug("Auth token is valid: $token_info->{'isValid'}"); } return $token_info->{'isValid'}; } ################################################################################ # Given an EML document, a node to search and the current count of # parties in the template variables, add more party* fields in the template # variables found in the search node passed in ################################################################################ sub populatePartyFields() { my $doc = shift; my $searchNode = shift; my $partyCount = shift; # this is a reference, update it as $$partyCount my $results = $$doc->findnodes($searchNode); debug( "Looking for: " . $searchNode . ", found " . $results->size() ); foreach my $partyChild ( $results->get_nodelist ) { dontOccur($partyChild, "userId", "userId"); dontOccur( $partyChild, "./individualName/salutation", "salutation" ); my $ids = $partyChild->findnodes('./@id'); my $givenNames = $partyChild->findnodes('./individualName/givenName'); my $surNames = $partyChild->findnodes('./individualName/surName'); my $orgNames = $partyChild->findnodes('./organizationName'); my $positionNames = $partyChild->findnodes('./positionName'); my $addresses = $partyChild->findnodes('./address'); my $deliveryPoints = $partyChild->findnodes('./address/deliveryPoint'); my $cities = $partyChild->findnodes('./address/city'); my $states = $partyChild->findnodes('./address/administrativeArea'); my $postalCodes = $partyChild->findnodes('./address/postalCode'); my $countries = $partyChild->findnodes('./address/country'); my $phones = $partyChild->findnodes('./phone'); my $emails = $partyChild->findnodes('./electronicMailAddress'); my $onlineUrls = $partyChild->findnodes('./onlineUrl'); my $roles = $partyChild->findnodes('./role'); # Add the id to the form fields my $id = ""; if ( $ids->size() > 0 ) { $id = findValue($partyChild, './@id'); } else { # No /eml/dataset/{party}/@id attributes are present. Assign a random id. $id = int(rand(10000000000000000)); } $$templateVars{'partyId' . $$partyCount} = $id; # Add the first name to the form fields if ( $givenNames->size() > 0 ) { # handle multiple givenName my $givenNameStr = ''; for ( my $i = ($givenNames->size - 1); $i >= 0; $i-- ) { my $givenNameNode = $givenNames->get_node($i); # $givenNameStr .= $givenNameNode->textContent(); $givenNameStr = $givenNameStr . $givenNameNode->textContent(); # Add a space delimiter for all but the last given name if ( $i > 0 ) { $givenNameStr .= " "; } } $$templateVars{'partyFirstName' . $$partyCount} = normalizeCD($givenNameStr); # $$templateVars{'partyFirstName' . $$partyCount} = findValue($partyChild, './individualName/givenName'); } # Add the last name to the form fields if ( $surNames->size() > 0 ) { $$templateVars{'partyLastName' . $$partyCount} = findValue($partyChild, './individualName/surName'); } # Add the organization name to the form fields if ( $orgNames->size() > 0 ) { $$templateVars{'partyOrgName' . $$partyCount} = findValue($partyChild, './organizationName'); } # Add the organization name to the form fields if ( $positionNames->size() > 0 ) { $$templateVars{'partyPositionName' . $$partyCount} = findValue($partyChild, './positionName'); } # Add the address fields to the form fields if ( $addresses->size() > 1 ) { errMoreThanOne("address"); } else { # Add the deliveryPoint fields to the form fields if ( $deliveryPoints->size() > 0 ) { my $deliveryPointStr = ""; for ( my $i = 0; $i < $deliveryPoints->size; $i++ ) { my $deliveryPoint = $deliveryPoints->get_node($i); $deliveryPointStr .= $deliveryPoint->textContent(); # Add an address delimiter for all but the last deliveryPoint if ( $i < $deliveryPoints->size() - 1 ) { $deliveryPointStr .= ", "; } } $$templateVars{'partyDelivery' . $$partyCount} = normalizeCD($deliveryPointStr); } } # Add the city to the form fields if ( $cities->size() > 0 ) { $$templateVars{'partyCity' . $$partyCount} = findValue($partyChild, './address/city'); } # Add the state to the form fields if ( $states->size() > 0 ) { $$templateVars{'partyState' . $$partyCount} = findValue($partyChild, './address/administrativeArea'); } # Add the postal code to the form fields if ( $postalCodes->size() > 0 ) { $$templateVars{'partyZIP' . $$partyCount} = findValue($partyChild, './address/postalCode'); } # Add the country to the form fields if ( $countries->size() > 0 ) { $$templateVars{'partyCountry' . $$partyCount} = findValue($partyChild, './address/country'); } # Add the phones to the form fields if ( $phones->size() > 2 ) { errMoreThanN("phone"); } elsif ( $phones->size() > 0) { # use Data::Dumper; # debug(Dumper($templateVars)); foreach my $phone ($phones->get_nodelist()) { if ( $phone->hasAttribute("phonetype") ) { my $phoneType = $phone->getAttribute("phonetype"); # Is this a fax number? if ( lc $phoneType eq lc "Fax" || lc $phoneType eq lc "facsimile") { $$templateVars{'partyFAX' . $$partyCount} = normalizeCD($phone->textContent()); } else { $$templateVars{'partyPhone' . $$partyCount} = normalizeCD($phone->textContent()); } } else { # Default to a voice phone $$templateVars{'partyPhone' . $$partyCount} = normalizeCD($phone->textContent()); } } } # Add the email to the form fields if ( $emails->size() > 0 ) { $$templateVars{'partyEmail' . $$partyCount} = findValue($partyChild, './electronicMailAddress'); } # Add the online URL to the form fields if ( $onlineUrls->size() > 0 ) { $$templateVars{'partyURL' . $$partyCount} = findValue($partyChild, './onlineUrl'); } # Add the role to the form fields if ( $searchNode =~ /creator/ ) { $$templateVars{'partyRole' . $$partyCount} = "creator"; } elsif ( $searchNode =~ /metadataProvider/ ) { $$templateVars{'partyRole' . $$partyCount} = "metadataProvider"; } elsif ( $searchNode =~ /contact/ ) { $$templateVars{'partyRole' . $$partyCount} = "contact"; } elsif ( $searchNode =~ /publisher/ ) { $$templateVars{'partyRole' . $$partyCount} = "publisher"; } elsif ( $searchNode =~ /associatedParty/ ) { if ( $roles->size() > 0 ) { $$templateVars{'partyRole' . $$partyCount} = findValue($partyChild, './role'); } } $$partyCount++; } } ################################################################################ # Copy the first creator party to the given role argument passed in. # Use the partyCount to determine what index to use (i.e. append to the party* array) ################################################################################ sub copyFirstCreator('metadataProvider') { my $targetRole = shift; my $partyCount = param('partyCount'); $partyCount++; # Copy the first creator, and replace the id and role my $partyId = int(rand(10000000000000000)); my $partyFirstName = param("partyFirstName" . $firstCreatorIndex); my $partyLastName = param("partyLastName" . $firstCreatorIndex); my $partyRole = $targetRole; my $partyOrgName = param("partyOrgName" . $firstCreatorIndex); my $partyPositionName = param("partyPositionName" . $firstCreatorIndex); my $partyEmail = param("partyEmail" . $firstCreatorIndex); my $partyURL = param("partyURL" . $firstCreatorIndex); my $partyPhone = param("partyPhone" . $firstCreatorIndex); my $partyFAX = param("partyFAX" . $firstCreatorIndex); my $partyDelivery = param("partyDelivery" . $firstCreatorIndex); my $partyCity = param("partyCity" . $firstCreatorIndex); my $partyState = param("partyState" . $firstCreatorIndex); my $partyStateOther = param("partyStateOther" . $firstCreatorIndex); my $partyZIP = param("partyZIP" . $firstCreatorIndex); my $partyCountry = param("partyCountry" . $firstCreatorIndex); # Add the new party into the params param("partyFirstName" . $partyCount, $partyFirstName ); param("partyLastName" . $partyCount, $partyLastName ); param("partyRole" . $partyCount, $partyRole ); param("partyOrgName" . $partyCount, $partyOrgName ); param("partyPositionName" . $partyCount, $partyPositionName ); param("partyEmail" . $partyCount, $partyEmail ); param("partyURL" . $partyCount, $partyURL ); param("partyPhone" . $partyCount, $partyPhone ); param("partyFAX" . $partyCount, $partyFAX ); param("partyDelivery" . $partyCount, $partyDelivery ); param("partyCity" . $partyCount, $partyCity ); param("partyState" . $partyCount, $partyState ); param("partyStateOther" . $partyCount, $partyStateOther); param("partyZIP" . $partyCount, $partyZIP ); param("partyCountry" . $partyCount, $partyCountry ); # Add the new party into the template variabes $$templateVars{"partyFirstName" . $partyCount} = $partyFirstName ; $$templateVars{"partyLastName" . $partyCount} = $partyLastName ; $$templateVars{"partyRole" . $partyCount} = $partyRole ; $$templateVars{"partyOrgName" . $partyCount} = $partyOrgName ; $$templateVars{"partyPositionName" . $partyCount} = $partyPositionName; $$templateVars{"partyEmail" . $partyCount} = $partyEmail ; $$templateVars{"partyURL" . $partyCount} = $partyURL ; $$templateVars{"partyPhone" . $partyCount} = $partyPhone ; $$templateVars{"partyFAX" . $partyCount} = $partyFAX ; $$templateVars{"partyDelivery" . $partyCount} = $partyDelivery ; $$templateVars{"partyCity" . $partyCount} = $partyCity ; $$templateVars{"partyState" . $partyCount} = $partyState ; $$templateVars{"partyStateOther" . $partyCount} = $partyStateOther; $$templateVars{"partyZIP" . $partyCount} = $partyZIP ; $$templateVars{"partyCountry" . $partyCount} = $partyCountry ; # Update the party count param("partyCount", $partyCount); $$templateVars{"partyCount" . $partyCount} = $partyCount; }