Annotation of loncom/interface/lonmsg.pm, revision 1.239.2.5.2.1

1.1       www         1: # The LearningOnline Network with CAPA
1.26      albertel    2: # Routines for messaging
                      3: #
1.239.2.5.2.1! (raeburn    4:: # $Id: lonmsg.pm,v 1.239.2.5 2024/02/08 03:09:10 raeburn Exp $
1.26      albertel    5: #
                      6: # Copyright Michigan State University Board of Trustees
                      7: #
                      8: # This file is part of the LearningOnline Network with CAPA (LON-CAPA).
                      9: #
                     10: # LON-CAPA is free software; you can redistribute it and/or modify
                     11: # it under the terms of the GNU General Public License as published by
                     12: # the Free Software Foundation; either version 2 of the License, or
                     13: # (at your option) any later version.
                     14: #
                     15: # LON-CAPA is distributed in the hope that it will be useful,
                     16: # but WITHOUT ANY WARRANTY; without even the implied warranty of
                     17: # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
                     18: # GNU General Public License for more details.
                     19: #
                     20: # You should have received a copy of the GNU General Public License
                     21: # along with LON-CAPA; if not, write to the Free Software
                     22: # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
                     23: #
                     24: # /home/httpd/html/adm/gpl.txt
                     25: #
                     26: # http://www.lon-capa.org/
1.1       www        27: #
1.75      www        28: 
1.1       www        29: package Apache::lonmsg;
                     30: 
1.199     raeburn    31: =pod
                     32: 
                     33: =head1 NAME
                     34: 
                     35: Apache::lonmsg: supports internal messaging
                     36: 
                     37: =head1 SYNOPSIS
                     38: 
                     39: lonmsg provides routines for sending messages.
                     40: 
                     41: Right now, this document will cover just how to send a message, since
                     42: it is likely you will not need to programmatically read messages,
                     43: since lonmsg already implements that functionality.
                     44: 
                     45: The routines used to package messages and unpackage messages are not
                     46: only used by lonmsg when creating/extracting messages for LON-CAPA's
                     47: internal messaging system, but also by lonnotify.pm which is available
                     48: for use by Domain Coordinators to broadcast standard e-mail to specified
                     49: users in their domain.  The XML packaging used in the two cases is very
                     50: similar.  The differences are the use of <recuser>$uname</recuser> and
                     51: <recdomain>$udom</recdomain> in stored internal messages, compared
                     52: with <recipient username="$uname:$udom">$email</recipient> in stored
                     53: Domain Coordinator e-mail for the storage of information about
                     54: recipients of the message/e-mail.
                     55: 
1.215     jms        56: =head1 SUBROUTINES
1.199     raeburn    57: 
1.215     jms        58: =over
                     59: 
                     60: =pod
                     61: 
                     62: =item packagemsg()
                     63: 
                     64: Package
                     65: 
                     66: =item get_course_context()
                     67: 
                     68: =item unpackagemsg()
                     69: 
                     70: Unpack message into a hash
                     71: 
                     72: =item buildmsgid()
                     73: 
                     74: Get info out of msgid
                     75: 
                     76: =item unpackmsgid()
                     77: 
                     78: =item sendemail()
                     79: 
                     80: =item sendnotification()
                     81: 
                     82: Send notification emails
                     83: 
                     84: =item newmail()
                     85: 
                     86: Check for email
                     87: 
                     88: =item author_res_msg()
                     89: 
                     90: Automated message to the author of a resource
                     91: 
                     92: =item * B<author_res_msg($filename, $message)>: Sends message $message to the owner
                     93:     of the resource with the URI $filename.
                     94: 
                     95: =item retrieve_author_res_msg()
                     96: 
                     97: Retrieve author resource messages
                     98: 
                     99: =item del_url_author_res_msg()
                    100: 
                    101: Delete all author messages related to one URL
                    102: 
                    103: =item clear_author_res_msg()
                    104: 
                    105: Clear out all author messages in URL path
                    106: 
                    107: =item all_url_author_res_msg()
                    108: 
                    109: Return hash with URLs for which there is a resource message
                    110: 
                    111: =item store_instructor_comment()
                    112: 
                    113: Add a comment to the User Notes screen
                    114: 
                    115: =item user_crit_msg_raw()
                    116: 
                    117: Critical message to a user
                    118: 
                    119: =item user_crit_msg()
                    120: 
                    121: New routine that respects "forward" and calls old routine
                    122: 
1.239.2.4  raeburn   123: =item * B<user_crit_msg($user, $domain, $subject, $message, $sendback, $toperm, $sentmessage, $nosentstore, $recipid, $attachmenturl, $permresults, $senthide)>: 
1.215     jms       124:     Sends a critical message $message to the $user at $domain.  If $sendback
                    125:     is true,  a receipt will be sent to the current user when $user receives 
                    126:     the message.
                    127: 
                    128:     Additionally it will check if the user has a Forwarding address
                    129:     set, and send the message to that address instead
                    130: 
                    131:     returns 
                    132:       - in array context a list of results for each message that was sent
                    133:       - in scalar context a space seperated list of results for each 
                    134:            message sent
                    135: 
                    136: 
                    137: =item user_crit_received()
                    138: 
                    139: Critical message received
                    140: 
                    141: =item user_normal_msg_raw()
                    142: 
                    143: Normal communication
                    144: 
                    145: =item user_normal_msg()
                    146: 
                    147: New routine that respects "forward" and calls old routine
                    148: 
                    149: =item * B<user_normal_msg($user, $domain, $subject, $message, $citation,
                    150:        $baseurl, $attachmenturl, $toperm, $sentmessage, $symb, $restitle,
1.239.2.4  raeburn   151:        $error,$nosentstore,$recipid,$permresults,$senthide)>:
1.215     jms       152:  Sends a message to the  $user at $domain, with subject $subject and message $message.
                    153: 
                    154:     Additionally it will check if the user has a Forwarding address
                    155:     set, and send the message to that address instead
                    156: 
                    157:     returns
                    158:       - in array context a list of results for each message that was sent
                    159:       - in scalar context a space seperated list of results for each
                    160:            message sent
                    161: 
                    162: =item store_sent_mail()
                    163: 
                    164: =item store_recipients()
                    165: 
                    166: =item foldersuffix()
                    167: 
                    168: =item get_user_folders()
                    169: 
                    170: User-defined folders 
                    171: 
                    172: =item secapply()
                    173: 
                    174: =item B<decide_receiver($feedurl,$author,$question,$course,$policy,$defaultflag)>:
                    175: 
                    176: Arguments
                    177:   $feedurl - /res/ url of resource (only need if $author is true)
                    178:   $author,$question,$course,$policy - all true/false parameters
                    179:     if true will attempt to find the addresses of user that should receive
                    180:     this type of feedback (author - feedback to author of resource $feedurl,
                    181:     $question 'Resource Content Questions', $course 'Course Content Question',
                    182:     $policy 'Course Policy')
                    183:     (Additionally it also checks $env for whether the corresponding form.<name>
                    184:     element exists, for ease of use in a html response context)
                    185:    
                    186:   $defaultflag - (internal should be left blank) if true gather addresses 
                    187:                  that aren't for a section even if I have a section
                    188:                  (used for reccursion internally, first we look for
                    189:                  addresses for our specific section then we recurse
                    190:                  and look for non section addresses)
                    191: 
                    192: Returns
                    193:   $typestyle - string of html text, describing what addresses were found
                    194:   %to - a hash, which keys are addresses of users to send messages to
                    195:         the keys will look like   name:domain
                    196: 
                    197: =back
1.199     raeburn   198: 
                    199: =cut
                    200: 
1.1       www       201: use strict;
1.140     albertel  202: use Apache::lonnet;
1.47      albertel  203: use HTML::TokeParser();
1.180     albertel  204: use Apache::lonlocal;
1.53      www       205: use Mail::Send;
1.226     raeburn   206: use HTML::Entities;
                    207: use Encode;
1.187     albertel  208: use LONCAPA qw(:DEFAULT :match);
1.180     albertel  209: 
                    210: {
                    211:     my $uniq;
                    212:     sub get_uniq {
                    213: 	$uniq++;
                    214: 	return $uniq;
                    215:     }
                    216: }
1.65      www       217: 
1.215     jms       218: 
1.1       www       219: 
1.3       www       220: sub packagemsg {
1.239.2.4  raeburn   221:     my ($subject,$message,$citation,$baseurl,$attachmenturl,$recuser,$recdomain,
                    222: 	$msgid,$type,$crsmsgid,$symb,$error,$recipid,$senthide,$origmsgid)=@_;
1.96      albertel  223:     $message =&HTML::Entities::encode($message,'<>&"');
                    224:     $citation=&HTML::Entities::encode($citation,'<>&"');
                    225:     $subject =&HTML::Entities::encode($subject,'<>&"');
1.49      albertel  226:     #remove machine specification
1.218     raeburn   227:     $baseurl =~ s|^https?://[^/]+/|/|;
1.96      albertel  228:     $baseurl =&HTML::Entities::encode($baseurl,'<>&"');
1.51      www       229:     #remove machine specification
1.218     raeburn   230:     $attachmenturl =~ s|^https?://[^/]+/|/|;
1.96      albertel  231:     $attachmenturl =&HTML::Entities::encode($attachmenturl,'<>&"');
1.239.2.4  raeburn   232:     if ($senthide) {
                    233:         foreach my $item ($subject,$message) {
                    234:             if ($item ne '') {
                    235:                 $item = 'Not shown due to IP block';
                    236:             }
                    237:         }
                    238:         if ($attachmenturl ne '') {
                    239:             $attachmenturl = '';
                    240:         }
                    241:         if ($citation ne '') {
                    242:             $citation = '';
                    243:         }
                    244:         if ($msgid ne '') {
                    245:             $msgid = '';
                    246:         }
                    247:     }
1.201     raeburn   248:     my $course_context = &get_course_context();
1.2       www       249:     my $now=time;
1.239.2.2  raeburn   250:     my $ip = &Apache::lonnet::get_requestor_ip();
1.180     albertel  251:     my $msgcount = &get_uniq();
1.156     raeburn   252:     unless(defined($msgid)) {
1.159     raeburn   253:         $msgid = &buildmsgid($now,$subject,$env{'user.name'},$env{'user.domain'},
1.191     raeburn   254:                            $msgcount,$course_context,$symb,$error,$$);
1.156     raeburn   255:     }
1.174     raeburn   256:     my $result = '<sendername>'.$env{'user.name'}.'</sendername>'.
1.140     albertel  257:            '<senderdomain>'.$env{'user.domain'}.'</senderdomain>'.
1.1       www       258:            '<subject>'.$subject.'</subject>'.
1.174     raeburn   259:            '<time>'.&Apache::lonlocal::locallocaltime($now).'</time>';
                    260:     if (defined($crsmsgid)) {
                    261:         $result.= '<courseid>'.$course_context.'</courseid>'.
                    262:                   '<coursesec>'.$env{'request.course.sec'}.'</coursesec>'.
                    263:                   '<msgid>'.$msgid.'</msgid>'.
                    264:                   '<coursemsgid>'.$crsmsgid.'</coursemsgid>'.
                    265:                   '<message>'.$message.'</message>';
                    266:         return ($msgid,$result);
                    267:     }
                    268:     $result .= '<servername>'.$ENV{'SERVER_NAME'}.'</servername>'.
1.1       www       269:            '<host>'.$ENV{'HTTP_HOST'}.'</host>'.
1.239.2.2  raeburn   270: 	   '<client>'.$ip.'</client>'.
1.140     albertel  271: 	   '<browsertype>'.$env{'browser.type'}.'</browsertype>'.
                    272: 	   '<browseros>'.$env{'browser.os'}.'</browseros>'.
                    273: 	   '<browserversion>'.$env{'browser.version'}.'</browserversion>'.
                    274:            '<browsermathml>'.$env{'browser.mathml'}.'</browsermathml>'.
1.1       www       275: 	   '<browserraw>'.$ENV{'HTTP_USER_AGENT'}.'</browserraw>'.
1.158     raeburn   276: 	   '<courseid>'.$course_context.'</courseid>'.
1.140     albertel  277: 	   '<coursesec>'.$env{'request.course.sec'}.'</coursesec>'.
                    278: 	   '<role>'.$env{'request.role'}.'</role>'.
                    279: 	   '<resource>'.$env{'request.filename'}.'</resource>'.
1.156     raeburn   280:            '<msgid>'.$msgid.'</msgid>';
1.214     raeburn   281:     if (defined($env{'form.group'})) {
                    282:         $result .= '<group>'.$env{'form.group'}.'</group>';
                    283:     }
1.156     raeburn   284:     if (ref($recuser) eq 'ARRAY') {
                    285:         for (my $i=0; $i<@{$recuser}; $i++) {
1.162     raeburn   286:             if ($type eq 'dcmail') {
                    287:                 my ($username,$email) = split(/:/,$$recuser[$i]);
1.184     www       288:                 $username = &unescape($username);
                    289:                 $email = &unescape($email);
1.162     raeburn   290:                 $username = &HTML::Entities::encode($username,'<>&"');
                    291:                 $email = &HTML::Entities::encode($email,'<>&"');
                    292:                 $result .= '<recipient username="'.$username.'">'.
                    293:                                             $email.'</recipient>';
                    294:             } else {
                    295:                 $result .= '<recuser>'.$$recuser[$i].'</recuser>'.
                    296:                            '<recdomain>'.$$recdomain[$i].'</recdomain>';
                    297:             }
1.156     raeburn   298:         }
                    299:     } else {
                    300:         $result .= '<recuser>'.$recuser.'</recuser>'.
                    301:                    '<recdomain>'.$recdomain.'</recdomain>';
                    302:     }
                    303:     $result .= '<message>'.$message.'</message>';
1.49      albertel  304:     if (defined($citation)) {
                    305: 	$result.='<citation>'.$citation.'</citation>';
                    306:     }
                    307:     if (defined($baseurl)) {
                    308: 	$result.= '<baseurl>'.$baseurl.'</baseurl>';
                    309:     }
1.51      www       310:     if (defined($attachmenturl)) {
1.52      www       311: 	$result.= '<attachmenturl>'.$attachmenturl.'</attachmenturl>';
1.51      www       312:     }
1.191     raeburn   313:     if (defined($symb)) {
                    314:         $result.= '<symb>'.$symb.'</symb>';
1.201     raeburn   315:         if ($course_context ne '') {
1.191     raeburn   316:             if ($course_context eq $env{'request.course.id'}) {
                    317:                 my $resource_title = &Apache::lonnet::gettitle($symb);
                    318:                 if (defined($resource_title)) {
                    319:                     $result .= '<resource_title>'.$resource_title.'</resource_title>';
                    320:                 }
                    321:             }
                    322:         }
                    323:     }
1.202     raeburn   324:     if (defined($recipid)) {
                    325:         $result.= '<recipid>'.$recipid.'</recipid>';
                    326:     }
1.204     raeburn   327:     if ($env{'form.can_reply'} eq 'N') {
                    328:         $result .= '<noreplies>1</noreplies>';
                    329:     }
                    330:     if ($env{'form.reply_to_addr'}) {
                    331:         my ($replytoname,$replytodom) = split(/:/,$env{'form.reply_to_addr'});
                    332:         if (!($replytoname eq $env{'user.name'} && $replytodom eq $env{'user.domain'})) {
                    333:             if (&Apache::lonnet::homeserver($replytoname,$replytodom) ne 'no_host') {
                    334:                 $result .= '<replytoaddr>'.$env{'form.reply_to_addr'}.'</replytoaddr>';
                    335:             }
                    336:         }
                    337:     }
1.239.2.4  raeburn   338:     if ($senthide) {
                    339:         $result .= '<senthide>$origmsgid</senthide>';
                    340:     }
1.191     raeburn   341:     return ($msgid,$result);
1.1       www       342: }
                    343: 
1.201     raeburn   344: sub get_course_context {
                    345:     my $course_context;
1.212     raeburn   346:     my $msgkey;
1.201     raeburn   347:     if (defined($env{'form.replyid'})) {
1.212     raeburn   348:         $msgkey = $env{'form.replyid'};
                    349:     } elsif (defined($env{'form.forwid'})) {
                    350:         $msgkey = $env{'form.forwid'}
                    351:     } elsif (defined($env{'form.multiforwid'})) {
                    352:         $msgkey = $env{'form.multiforwid'};
                    353:     }
                    354:     if ($msgkey ne '') {
1.201     raeburn   355:         my ($sendtime,$shortsubj,$fromname,$fromdomain,$count,$origcid)=
1.212     raeburn   356:                    split(/\:/,&unescape($msgkey));
1.201     raeburn   357:         $course_context = $origcid;
                    358:     }
                    359:     foreach my $key (keys(%env)) {
                    360:         if ($key=~/^form\.(rep)?rec\_(.*)$/) {
                    361:             my ($sendtime,$shortsubj,$fromname,$fromdomain,$count,$origcid) =
                    362:                                     split(/\:/,&unescape($2));
                    363:             $course_context = $origcid;
                    364:             last;
                    365:         }
                    366:     }
                    367:     if ($course_context eq '') {
                    368:         $course_context = $env{'request.course.id'};
                    369:     }
                    370:     return $course_context;
                    371: }
                    372: 
1.2       www       373: 
1.3       www       374: sub unpackagemsg {
1.212     raeburn   375:     my ($message,$notoken,$noattachmentlink)=@_;
1.2       www       376:     my %content=();
                    377:     my $parser=HTML::TokeParser->new(\$message);
                    378:     my $token;
                    379:     while ($token=$parser->get_token) {
                    380:        if ($token->[0] eq 'S') {
                    381: 	   my $entry=$token->[1];
                    382:            my $value=$parser->get_text('/'.$entry);
1.156     raeburn   383:            if (($entry eq 'recuser') || ($entry eq 'recdomain')) {
                    384:                push(@{$content{$entry}},$value);
1.162     raeburn   385:            } elsif ($entry eq 'recipient') {
                    386:                my $username = $token->[2]{'username'};
                    387:                $username = &HTML::Entities::decode($username,'<>&"');
                    388:                $content{$entry}{$username} = $value;
1.156     raeburn   389:            } else {
                    390:                $content{$entry}=$value;
                    391:            }
1.2       www       392:        }
                    393:     }
1.168     albertel  394:     if (!exists($content{'recuser'})) { $content{'recuser'} = []; }
1.212     raeburn   395:     if (($content{'attachmenturl'}) && (!$noattachmentlink)) {
1.100     albertel  396:        my ($fname)=($content{'attachmenturl'}=~m|/([^/]+)$|);
1.52      www       397:        if ($notoken) {
1.100     albertel  398: 	   $content{'message'}.='<p>'.&mt('Attachment').': <tt>'.$fname.'</tt>';
1.52      www       399:        } else {
1.99      albertel  400: 	   &Apache::lonnet::allowuploaded('/adm/msg',
                    401: 					  $content{'attachmenturl'});
                    402: 	   $content{'message'}.='<p>'.&mt('Attachment').
                    403: 	       ': <a href="'.$content{'attachmenturl'}.'"><tt>'.
1.100     albertel  404: 	       $fname.'</tt></a>';
1.52      www       405:        }
                    406:     }
1.2       www       407:     return %content;
                    408: }
                    409: 
1.6       www       410: 
1.159     raeburn   411: sub buildmsgid {
1.191     raeburn   412:     my ($now,$subject,$uname,$udom,$msgcount,$course_context,$symb,$error,$pid) = @_;
1.184     www       413:     $subject=&escape($subject);
1.192     raeburn   414:     $symb = &escape($symb);
1.184     www       415:     return(&escape($now.':'.$subject.':'.$uname.':'.
1.191     raeburn   416:            $udom.':'.$msgcount.':'.$course_context.':'.$pid.':'.$symb.':'.$error));
1.159     raeburn   417: }
                    418: 
1.6       www       419: sub unpackmsgid {
1.239.2.1  raeburn   420:     my ($msgid,$folder,$skipstatus,$status_cache,$onlycid)=@_;
1.184     www       421:     $msgid=&unescape($msgid);
1.167     raeburn   422:     my ($sendtime,$shortsubj,$fromname,$fromdomain,$count,$fromcid,
1.191     raeburn   423:         $processid,$symb,$error) = split(/\:/,&unescape($msgid));
1.239.2.1  raeburn   424:     if (!defined($processid)) { $fromcid = ''; }
                    425:     if (($onlycid) && ($onlycid ne $fromcid)) {
                    426:         return ($sendtime,'',$fromname,$fromdomain,'',$fromcid,'',$error);
                    427:     }
1.184     www       428:     $shortsubj = &unescape($shortsubj);
1.182     albertel  429:     $shortsubj = &HTML::Entities::decode($shortsubj);
1.192     raeburn   430:     $symb = &unescape($symb);
1.167     raeburn   431:     if (!defined($processid)) { $fromcid = ''; }
1.164     raeburn   432:     my %status=();
                    433:     unless ($skipstatus) {
1.169     albertel  434: 	if (ref($status_cache)) {
                    435: 	    $status{$msgid} = $status_cache->{$msgid};
                    436: 	} else {
                    437: 	    my $suffix=&foldersuffix($folder);
                    438: 	    %status=&Apache::lonnet::get('email_status'.$suffix,[$msgid]);
                    439: 	}
                    440: 	if ($status{$msgid}=~/^error\:/) { $status{$msgid}=''; }
1.164     raeburn   441:         unless ($status{$msgid}) { $status{$msgid}='new'; }
                    442:     }
1.191     raeburn   443:     return ($sendtime,$shortsubj,$fromname,$fromdomain,$status{$msgid},$fromcid,$symb,$error);
1.141     raeburn   444: }
1.6       www       445: 
1.53      www       446: 
                    447: sub sendemail {
1.213     raeburn   448:     my ($to,$subject,$body,$to_uname,$to_udom,$user_lh)=@_;
1.186     www       449:     my $senderaddress='';
1.220     raeburn   450:     my $replytoaddress='';
1.238     raeburn   451:     my $msgsent;
1.220     raeburn   452:     if ($env{'form.can_reply'} eq 'N') {
                    453:         my $lonhost = $Apache::lonnet::perlvar{'lonHostID'};
                    454:         my $hostname = &Apache::lonnet::hostname($lonhost);
                    455:         $replytoaddress = 'do-not-reply@'.$hostname;
                    456:     } else {
                    457:         my %senderemails;
1.239.2.5  raeburn   458:         my ($have_sender,$setreplyto);
1.220     raeburn   459:         if ($env{'form.reply_to_addr'}) {
                    460:             my ($replytoname,$replytodom) = split(/:/,$env{'form.reply_to_addr'});
1.239.2.5  raeburn   461:             if (($replytoname eq $env{'user.name'} && $replytodom eq $env{'user.domain'})) {
                    462:                 $setreplyto = 1;
                    463:             } else {
1.220     raeburn   464:                 if (&Apache::lonnet::homeserver($replytoname,$replytodom) ne 'no_host') {
                    465:                     %senderemails = 
                    466:                         &Apache::loncommon::getemails($replytoname,$replytodom);
                    467:                     $have_sender = 1;
1.239.2.5  raeburn   468:                     $setreplyto = 1;
1.220     raeburn   469:                 }
                    470:             }
                    471:         }
                    472:         if (!$have_sender) {
                    473:             %senderemails=&Apache::loncommon::getemails();
                    474:         }
                    475:         foreach my $type ('permanentemail','critnotification','notification') {
                    476:             if ($senderemails{$type}) {
                    477:                 ($senderaddress) = split(/,/,$senderemails{$type});
1.239.2.5  raeburn   478:                 if ($senderaddress) {
                    479:                     if ($setreplyto) {
                    480:                         $replytoaddress = $senderaddress;
                    481:                     }
                    482:                     last;
                    483:                 }
1.220     raeburn   484:             }
                    485:         }
1.186     www       486:     }
1.53      www       487:     $body=
1.217     schafran  488:     "*** ".&mt_user($user_lh,'This is an automatic e-mail generated by the LON-CAPA system.')."\n".
                    489:     "*** ".($senderaddress?&mt_user($user_lh,'You can reply to this e-mail'):&mt_user($user_lh,'Please do not reply to this address.')."\n*** ".
1.220     raeburn   490:     &mt_user($user_lh,'A reply will not be received by the recipient!'))."\n\n".$body;
1.225     jms       491:     
1.53      www       492:     my $msg = new Mail::Send;
                    493:     $msg->to($to);
                    494:     $msg->subject('[LON-CAPA] '.$subject);
1.220     raeburn   495:     if ($replytoaddress) {
                    496:         $msg->add('Reply-to',$replytoaddress);
                    497:     }
                    498:     if ($senderaddress) {
                    499:         $msg->add('From',$senderaddress);
                    500:     }
1.230     bisitz    501:     $msg->add('Content-type','text/plain; charset=UTF-8');
1.97      matthew   502:     if (my $fh = $msg->open()) {
1.172     albertel  503: 	print $fh $body;
                    504: 	$fh->close;
1.238     raeburn   505:         $msgsent = 1;
1.68      www       506:     }
1.238     raeburn   507:     return $msgsent;
1.53      www       508: }
                    509: 
                    510: # ==================================================== Send notification emails
                    511: 
                    512: sub sendnotification {
1.194     raeburn   513:     my ($to,$touname,$toudom,$subj,$crit,$text,$msgid)=@_;
1.140     albertel  514:     my $sender=$env{'environment.firstname'}.' '.$env{'environment.lastname'};
1.131     www       515:     unless ($sender=~/\w/) { 
1.208     raeburn   516: 	$sender=$env{'user.name'}.':'.$env{'user.domain'};
1.131     www       517:     }
1.53      www       518:     my $critical=($crit?' critical':'');
1.238     raeburn   519:     my $numsent = 0;
1.208     raeburn   520: 
1.131     www       521:     $text=~s/\&lt\;/\</gs;
                    522:     $text=~s/\&gt\;/\>/gs;
1.239.2.5.2.1! (raeburn  523::     my $touhome = &Apache::lonnet::homeserver($touname,$toudom);
        !           524::     my $url = &Apache::lonnet::url_prefix('',$toudom,$touhome,'email').
1.226     raeburn   525:               '/adm/email?username='.$touname.'&domain='.$toudom.
                    526:               '&display='.&escape($msgid);
1.194     raeburn   527:     my ($sendtime,$shortsubj,$fromname,$fromdomain,$status,$fromcid,
                    528:         $symb,$error) = &Apache::lonmsg::unpackmsgid($msgid);
1.208     raeburn   529:     my ($coursetext,$body,$bodybegin,$bodysubj,$bodyend);
1.222     raeburn   530:     my $user_lh = &Apache::loncommon::user_lang($touname,$toudom,$fromcid);
1.194     raeburn   531:     if ($fromcid ne '') {
1.213     raeburn   532:         $coursetext = "\n".&mt_user($user_lh,'Course').': ';
1.194     raeburn   533:         if ($env{'course.'.$fromcid.'.description'} ne '') {
                    534:             $coursetext .= $env{'course.'.$fromcid.'.description'};
                    535:         } else {
                    536:             my %coursehash = &Apache::lonnet::coursedescription($fromcid,);
                    537:             if ($coursehash{'description'} ne '') {
                    538:                 $coursetext .= $coursehash{'description'};
                    539:             }
                    540:         }
                    541:         $coursetext .= "\n\n";
                    542:     }
1.206     raeburn   543:     my @recipients = split(/,/,$to);
1.208     raeburn   544:     $bodybegin = $coursetext. 
1.213     raeburn   545:                &mt_user($user_lh,
                    546:                          'You received a'.$critical.' message from [_1] in LON-CAPA.',$sender).' ';
                    547:     $bodysubj = &mt_user($user_lh,'The subject is 
1.53      www       548: 
1.195     raeburn   549:  [_1]
1.53      www       550: 
1.195     raeburn   551: ',$subj)."\n".
1.213     raeburn   552: '=== '.&mt_user($user_lh,'Excerpt')." ============================================================
1.206     raeburn   553: ";
                    554:     $bodyend = "
1.131     www       555: ========================================================================
                    556: 
1.213     raeburn   557: ".&mt_user($user_lh,'Use 
1.53      www       558: 
1.195     raeburn   559:  [_1]
1.53      www       560: 
1.195     raeburn   561: to access the full message.',$url);
1.206     raeburn   562:     my %userenv = &Apache::lonnet::get('environment',['notifywithhtml'],$toudom,$touname);
1.235     bisitz    563:     my $subject = &mt_user($user_lh,"'New'$critical message from [_1]",$sender);
1.232     raeburn   564:     unless ($subj eq '') {
                    565:         $subject = $subj;
                    566:     }
1.208     raeburn   567:  
1.239.2.3  raeburn   568:     my ($blocked,$blocktext,$clientip);
                    569:     $clientip = &Apache::lonnet::get_requestor_ip();
1.208     raeburn   570:     if (!$crit) {
                    571:         my %setters;
1.239.2.3  raeburn   572:         my ($startblock,$endblock,$triggerblock,$by_ip,$blockdom) = 
                    573:             &Apache::loncommon::blockcheck(\%setters,'com',$clientip,$touname,$toudom);
1.208     raeburn   574:         if ($startblock && $endblock) {
                    575:             $blocked = 1;
1.209     albertel  576:             my $showstart = &Apache::lonlocal::locallocaltime($startblock);
                    577:             my $showend = &Apache::lonlocal::locallocaltime($endblock);
1.213     raeburn   578:             $blocktext = &mt_user($user_lh,'LON-CAPA messages sent to you between [_1] and [_2] will be inaccessible until the end of this time period, because you are a student in a course with an active communications block.',$showstart,$showend);
1.239.2.3  raeburn   579:         } elsif ($by_ip) {
                    580:             $blocked = 1;
                    581:             $blocktext = &mt_user($user_lh,'LON-CAPA messages sent to you will be inaccessible from your IP address [_1], because communication is being blocked for certain IP address(es).',$clientip);
1.208     raeburn   582:         }
                    583:     }
1.206     raeburn   584:     if ($userenv{'notifywithhtml'} ne '') {
                    585:         my @htmlexcerpt = split(/,/,$userenv{'notifywithhtml'});
1.226     raeburn   586:         my $htmlfree = &make_htmlfree($text);
1.206     raeburn   587:         foreach my $addr (@recipients) {
1.208     raeburn   588:             if ($blocked) {
                    589:                 $body = $bodybegin."\n".$blocktext."\n".$bodyend;
                    590:             } else {
1.226     raeburn   591:                 my $sendtext;
1.208     raeburn   592:                 if (!grep/^\Q$addr\E/,@htmlexcerpt) {
1.227     raeburn   593:                     $sendtext = $htmlfree;
1.226     raeburn   594:                 } else {
                    595:                     $sendtext = $text;
1.208     raeburn   596:                 }
                    597:                 $body = $bodybegin.$bodysubj.$sendtext.$bodyend;
1.206     raeburn   598:             }
1.238     raeburn   599:             if (&sendemail($addr,$subject,$body,$touname,$toudom,$user_lh)) {
                    600:                 $numsent ++;
                    601:             }
1.206     raeburn   602:         }
                    603:     } else {
1.208     raeburn   604:         if ($blocked) {
                    605:             $body = $bodybegin."\n".$blocktext."\n".$bodyend;
                    606:         } else {
1.226     raeburn   607:             my $htmlfree = &make_htmlfree($text);
                    608:             $body = $bodybegin.$bodysubj.$htmlfree.$bodyend;
1.208     raeburn   609:         }
1.238     raeburn   610:         if (&sendemail($to,$subject,$body,$touname,$toudom,$user_lh)) {
                    611:             $numsent ++;
                    612:         }
1.206     raeburn   613:     }
1.238     raeburn   614:     return $numsent;
1.53      www       615: }
1.215     jms       616: 
1.226     raeburn   617: sub make_htmlfree {
                    618:     my ($text) = @_;
                    619:     $text =~ s/\<\/*[^\>]+\>//gs;
                    620:     $text = &HTML::Entities::decode($text);
                    621:     $text = &Encode::encode('utf8',$text);
                    622:     return $text;
                    623: }
                    624: 
1.223     kaisler   625: sub mynewmail{
                    626: 	&newmail();
1.231     raeburn   627: 	return $env{'user.mailcheck.lastnewmessagetime'} > $env{'user.mailcheck.lastvisit'};
1.223     kaisler   628: }
                    629: 
1.40      www       630: 
                    631: sub newmail {
1.140     albertel  632:     if ((time-$env{'user.mailcheck.time'})>300) {
1.40      www       633:         my %what=&Apache::lonnet::get('email_status',['recnewemail']);
1.211     raeburn   634:         &Apache::lonnet::appenv({'user.mailcheck.time'=>time});
1.231     raeburn   635: 		&Apache::lonnet::appenv({'user.mailcheck.lastnewmessagetime'=> $what{'recnewemail'}});
1.40      www       636:         if ($what{'recnewemail'}>0) { return 1; }
                    637:     }
                    638:     return 0;
                    639: }
                    640: 
1.1       www       641: 
1.58      bowersj2  642: 
1.1       www       643: sub author_res_msg {
                    644:     my ($filename,$message)=@_;
1.2       www       645:     unless ($message) { return 'empty'; }
1.1       www       646:     $filename=&Apache::lonnet::declutter($filename);
1.72      www       647:     my ($domain,$author,@dummy)=split(/\//,$filename);
1.1       www       648:     my $homeserver=&Apache::lonnet::homeserver($author,$domain);
                    649:     if ($homeserver ne 'no_host') {
                    650:        my $id=unpack("%32C*",$message);
1.181     albertel  651:        $message .= " <p>This error occurred on machine ".
                    652: 	   $Apache::lonnet::perlvar{'lonHostID'}."</p>";
1.2       www       653:        my $msgid;
1.72      www       654:        ($msgid,$message)=&packagemsg($filename,$message);
1.3       www       655:        return &Apache::lonnet::reply('put:'.$domain.':'.$author.
1.72      www       656:          ':nohist_res_msgs:'.
1.184     www       657:           &escape($filename.'_'.$id).'='.
                    658:           &escape($message),$homeserver);
1.1       www       659:     }
1.2       www       660:     return 'no_host';
1.73      www       661: }
                    662: 
1.215     jms       663: 
1.73      www       664: 
                    665: sub retrieve_author_res_msg {
1.75      www       666:     my $url=shift;
1.73      www       667:     $url=&Apache::lonnet::declutter($url);
1.187     albertel  668:     my ($domain,$author)=($url=~/^($match_domain)\/($match_username)\//);
1.76      www       669:     my %errormsgs=&Apache::lonnet::dump('nohist_res_msgs',$domain,$author);
1.73      www       670:     my $msgs='';
1.239     raeburn   671:     foreach my $msg (keys(%errormsgs)) {
                    672: 	if ($msg =~ /^\Q$url\E\_\d+$/) {
                    673: 	    my %content=&unpackagemsg($errormsgs{$msg});
1.74      www       674: 	    $msgs.='<p><img src="/adm/lonMisc/bomb.gif" /><b>'.
                    675: 		$content{'time'}.'</b>: '.$content{'message'}.
                    676: 		'<br /></p>';
1.73      www       677: 	}
                    678:     } 
                    679:     return $msgs;     
                    680: }
                    681: 
                    682: 
1.215     jms       683: 
                    684: 
1.73      www       685: 
                    686: sub del_url_author_res_msg {
1.75      www       687:     my $url=shift;
1.73      www       688:     $url=&Apache::lonnet::declutter($url);
1.187     albertel  689:     my ($domain,$author)=($url=~/^($match_domain)\/($match_username)\//);
1.77      www       690:     my @delmsgs=();
1.239     raeburn   691:     foreach my $msg (&Apache::lonnet::getkeys('nohist_res_msgs',$domain,$author)) {
                    692: 	if ($msg =~ /^\Q$url\E\_\d+$/) {
                    693: 	    push (@delmsgs,$msg);
1.77      www       694: 	}
                    695:     }
                    696:     return &Apache::lonnet::del('nohist_res_msgs',\@delmsgs,$domain,$author);
1.73      www       697: }
1.215     jms       698: 
1.73      www       699: 
1.152     www       700: sub clear_author_res_msg {
                    701:     my $url=shift;
                    702:     $url=&Apache::lonnet::declutter($url);
1.187     albertel  703:     my ($domain,$author)=($url=~/^($match_domain)\/($match_username)\//);
1.152     www       704:     my @delmsgs=();
1.239     raeburn   705:     foreach my $msg (&Apache::lonnet::getkeys('nohist_res_msgs',$domain,$author)) {
                    706: 	if ($msg =~ /^\Q$url\E/) {
                    707: 	    push (@delmsgs,$msg);
1.152     www       708: 	}
                    709:     }
                    710:     return &Apache::lonnet::del('nohist_res_msgs',\@delmsgs,$domain,$author);
                    711: }
1.215     jms       712: 
                    713: 
1.73      www       714: 
                    715: sub all_url_author_res_msg {
                    716:     my ($author,$domain)=@_;
1.75      www       717:     my %returnhash=();
1.239     raeburn   718:     foreach my $msg (&Apache::lonnet::getkeys('nohist_res_msgs',$domain,$author)) {
                    719: 	$msg =~ /^(.+)\_\d+/;
1.75      www       720: 	$returnhash{$1}=1;
                    721:     }
                    722:     return %returnhash;
1.1       www       723: }
                    724: 
1.185     albertel  725: 
                    726: sub store_instructor_comment {
                    727:     my ($msg,$uname,$udom) = @_;
                    728:     my $cid  = $env{'request.course.id'};
                    729:     my $cnum = $env{'course.'.$cid.'.num'};
                    730:     my $cdom = $env{'course.'.$cid.'.domain'};
                    731:     my $subject= &mt('Record').' ['.$uname.':'.$udom.']';
                    732:     my $result = &user_normal_msg_raw($cnum,$cdom,$subject,$msg);
1.201     raeburn   733:     if ($result eq 'ok' || $result eq 'con_delayed') {
                    734:         
                    735:     }
1.185     albertel  736:     return $result;
                    737: }
                    738: 
1.1       www       739: 
1.38      www       740: sub user_crit_msg_raw {
1.201     raeburn   741:     my ($user,$domain,$subject,$message,$sendback,$toperm,$sentmessage,
1.239.2.4  raeburn   742:         $nosentstore,$recipid,$attachmenturl,$permresults,$senthide)=@_;
1.2       www       743: # Check if allowed missing
1.190     raeburn   744:     my ($status,$packed_message);
1.2       www       745:     my $msgid='undefined';
                    746:     unless (($message)&&($user)&&($domain)) { $status='empty'; };
1.131     www       747:     my $text=$message;
1.2       www       748:     my $homeserver=&Apache::lonnet::homeserver($user,$domain);
                    749:     if ($homeserver ne 'no_host') {
1.202     raeburn   750:        ($msgid,$packed_message)=&packagemsg($subject,$message,undef,undef,
1.212     raeburn   751:                                   $attachmenturl,undef,undef,undef,undef,undef,
                    752:                                   undef,undef,$recipid);
1.190     raeburn   753:        if ($sendback) { $packed_message.='<sendback>true</sendback>'; }
1.210     albertel  754:        $status=&Apache::lonnet::cput('critical', {$msgid => $packed_message},
                    755: 				     $domain,$user);
1.159     raeburn   756:         if (defined($sentmessage)) {
1.190     raeburn   757:             $$sentmessage = $packed_message;
1.159     raeburn   758:         }
1.201     raeburn   759:         if (!$nosentstore) {
1.239.2.4  raeburn   760:             my ($sentmsgid,$packed_message_no_citation) =
1.212     raeburn   761:             &packagemsg($subject,$message,undef,undef,$attachmenturl,$user,
1.239.2.4  raeburn   762:                         $domain,$msgid,undef,undef,undef,undef,undef,$senthide,$msgid);
1.193     raeburn   763:             if ($status eq 'ok' || $status eq 'con_delayed') {
1.239.2.4  raeburn   764:                 if ($senthide && $sentmsgid) {
                    765:                     &store_sent_mail($sentmsgid,$packed_message_no_citation);
                    766:                 } else {
                    767:                     &store_sent_mail($msgid,$packed_message_no_citation);
                    768:                 }
1.193     raeburn   769:             }
                    770:         }
1.2       www       771:     } else {
                    772:        $status='no_host';
                    773:     }
1.190     raeburn   774: 
1.53      www       775: # Notifications
1.186     www       776:     my %userenv = &Apache::loncommon::getemails($user,$domain);
1.238     raeburn   777:     my $critnotify = $userenv{'critnotification'};
                    778:     my $permemail = $userenv{'permanentemail'};
                    779:     my $numcrit = 0;
                    780:     my $numperm = 0;
                    781:     my $permlogmsgstatus;
                    782:     if ($critnotify) {
                    783:         $numcrit = &sendnotification($critnotify,$user,$domain,$subject,1,$text,$msgid);
                    784:     }
                    785:     if ($toperm && $permemail) {
                    786:         if ($critnotify && $numcrit) {
                    787:             if (grep(/^\Q$permemail\E/,split(/,/,$critnotify))) {
                    788:                 $numperm = 1;
                    789:             }
                    790:         }
                    791:         unless ($numperm) {
                    792:             $numperm = &sendnotification($permemail,$user,$domain,$subject,1,$text,$msgid);
                    793:         }
                    794:     }
                    795:     if ($toperm) {
                    796:         $permlogmsgstatus = '. Perm. email log status '.
                    797:                             &Apache::lonnet::log($env{'user.domain'},$env{'user.name'},$env{'user.home'},
                    798:                                                  "Perm. e-mail count $numperm for $user at $domain");
                    799:         if (ref($permresults) eq 'HASH') {
                    800:             $permresults->{"$user:$domain"} = $numperm;
                    801:         }
1.132     www       802:     }
1.53      www       803: # Log this
1.2       www       804:     &Apache::lonnet::logthis(
1.238     raeburn   805:       'Sending critical '.$msgid.
1.2       www       806:       ', log status: '.
1.140     albertel  807:       &Apache::lonnet::log($env{'user.domain'},$env{'user.name'},
                    808:                          $env{'user.home'},
1.238     raeburn   809:       'Sending critical '.$msgid.' to '.$user.' at '.$domain.' with status '
                    810:       .$status).$permlogmsgstatus);
1.2       www       811:     return $status;
                    812: }
                    813: 
1.38      www       814: 
1.58      bowersj2  815: 
1.38      www       816: sub user_crit_msg {
1.201     raeburn   817:     my ($user,$domain,$subject,$message,$sendback,$toperm,$sentmessage,
1.239.2.4  raeburn   818:         $nosentstore,$recipid,$attachmenturl,$permresults,$senthide)=@_;
1.183     albertel  819:     my @status;
1.38      www       820:     my %userenv = &Apache::lonnet::get('environment',['msgforward'],
                    821:                                        $domain,$user);
                    822:     my $msgforward=$userenv{'msgforward'};
                    823:     if ($msgforward) {
1.183     albertel  824:        foreach my $addr (split(/\,/,$msgforward)) {
                    825: 	 my ($forwuser,$forwdomain)=split(/\:/,$addr);
                    826:          push(@status,
                    827: 	      &user_crit_msg_raw($forwuser,$forwdomain,$subject,$message,
1.202     raeburn   828: 				 $sendback,$toperm,$sentmessage,$nosentstore,
1.239.2.4  raeburn   829:                                  $recipid,$attachmenturl,$permresults,$senthide));
1.38      www       830:        }
                    831:     } else { 
1.183     albertel  832: 	push(@status,
                    833: 	     &user_crit_msg_raw($user,$domain,$subject,$message,$sendback,
1.212     raeburn   834: 				$toperm,$sentmessage,$nosentstore,$recipid,
1.239.2.4  raeburn   835:                                 $attachmenturl,$permresults,$senthide));
1.38      www       836:     }
1.183     albertel  837:     if (wantarray) {
                    838: 	return @status;
                    839:     }
                    840:     return join(' ',@status);
1.38      www       841: }
                    842: 
1.2       www       843: 
                    844: sub user_crit_received {
1.12      www       845:     my $msgid=shift;
                    846:     my %message=&Apache::lonnet::get('critical',[$msgid]);
1.52      www       847:     my %contents=&unpackagemsg($message{$msgid},1);
1.204     raeburn   848:     my $destname = $contents{'sendername'};
                    849:     my $destdom = $contents{'senderdomain'};
                    850:     if ($contents{'replytoaddr'}) {
                    851:         my ($repname,$repdom) = split(/:/,$contents{'replytoaddr'});
                    852:         if (&Apache::lonnet::homeserver($repname,$repdom) ne 'no_host') {
                    853:             $destname = $repname;
                    854:             $destdom = $repdom;    
                    855:         }
                    856:     }
1.24      www       857:     my $status='rec: '.($contents{'sendback'}?
1.204     raeburn   858:      &user_normal_msg($destname,$destdom,&mt('Receipt').': '.$env{'user.name'}.
                    859:                       ' '.&mt('at').' '.$env{'user.domain'}.', '.
                    860:                       $contents{'subject'},&mt('User').' '.$env{'user.name'}.
                    861:                       ' '.&mt('at').' '.$env{'user.domain'}.
                    862:                       ' acknowledged receipt of message'."\n".'   "'.
                    863:                       $contents{'subject'}.'"'."\n".&mt('dated').' '.
                    864:                       $contents{'time'}.".\n"
                    865:                       ):'no msg req');
1.5       www       866:     $status.=' trans: '.
1.12      www       867:      &Apache::lonnet::put(
                    868:      'nohist_email',{$contents{'msgid'} => $message{$msgid}});
1.5       www       869:     $status.=' del: '.
1.9       albertel  870:      &Apache::lonnet::del('critical',[$contents{'msgid'}]);
1.140     albertel  871:     &Apache::lonnet::log($env{'user.domain'},$env{'user.name'},
                    872:                          $env{'user.home'},'Received critical message '.
1.5       www       873:                          $contents{'msgid'}.
                    874:                          ', '.$status);
1.12      www       875:     return $status;
1.2       www       876: }
                    877: 
1.215     jms       878: 
                    879: 
1.2       www       880: 
1.38      www       881: sub user_normal_msg_raw {
1.132     www       882:     my ($user,$domain,$subject,$message,$citation,$baseurl,$attachmenturl,
1.191     raeburn   883:         $toperm,$currid,$newid,$sentmessage,$crsmsgid,$symb,$restitle,
1.239.2.4  raeburn   884:         $error,$nosentstore,$recipid,$permresults,$senthide)=@_;
1.2       www       885: # Check if allowed missing
1.173     albertel  886:     my ($status,$packed_message);
1.2       www       887:     my $msgid='undefined';
1.131     www       888:     my $text=$message;
1.2       www       889:     unless (($message)&&($user)&&($domain)) { $status='empty'; };
                    890:     my $homeserver=&Apache::lonnet::homeserver($user,$domain);
                    891:     if ($homeserver ne 'no_host') {
1.173     albertel  892:        ($msgid,$packed_message)=
                    893: 	                 &packagemsg($subject,$message,$citation,$baseurl,
1.174     raeburn   894:                                      $attachmenturl,$user,$domain,$currid,
1.202     raeburn   895:                                      undef,$crsmsgid,$symb,$error,$recipid);
1.174     raeburn   896: 
1.108     www       897: # Store in user folder
1.210     albertel  898:        $status=
                    899: 	   &Apache::lonnet::cput('nohist_email',{$msgid => $packed_message},
                    900: 				 $domain,$user);
1.108     www       901: # Save new message received time
1.40      www       902:        &Apache::lonnet::put
                    903:                          ('email_status',{'recnewemail'=>time},$domain,$user);
1.201     raeburn   904: # Into sent-mail folder if sent mail storage required
                    905:        if (!$nosentstore) {
1.239.2.4  raeburn   906:            my ($sentmsgid,$packed_message_no_citation) =
1.190     raeburn   907:                &packagemsg($subject,$message,undef,$baseurl,$attachmenturl,
1.239.2.4  raeburn   908:                            $user,$domain,$currid,undef,$crsmsgid,$symb,$error,
                    909:                            undef,$senthide,$msgid);
1.193     raeburn   910:            if ($status eq 'ok' || $status eq 'con_delayed') {
1.239.2.4  raeburn   911:                if ($senthide && $sentmsgid) {
                    912:                    &store_sent_mail($sentmsgid,$packed_message_no_citation);
                    913:                } else { 
                    914:                    &store_sent_mail($msgid,$packed_message_no_citation);
                    915:                }
1.193     raeburn   916:            }
1.156     raeburn   917:        }
1.201     raeburn   918:        if (ref($newid) eq 'SCALAR') {
1.196     www       919: 	   $$newid = $msgid;
                    920:        }
1.201     raeburn   921:        if (ref($sentmessage) eq 'SCALAR') {
1.196     www       922: 	   $$sentmessage = $packed_message;
                    923:        }
                    924: # Notifications
1.206     raeburn   925:        my %userenv = &Apache::loncommon::getemails($user,$domain);
1.238     raeburn   926:        my $notify = $userenv{'notification'};
                    927:        my $permemail = $userenv{'permanentemail'};
                    928:        my $numnotify = 0;
                    929:        my $numperm = 0;
                    930:        my $permlogmsgstatus;
                    931:        if ($notify) {
                    932:            $numnotify = &sendnotification($notify,$user,$domain,$subject,0,$text,$msgid);
                    933:        }
                    934:        if ($toperm && $permemail) {
                    935:            if ($notify && $numnotify) {
                    936:                if (grep(/^\Q$permemail\E/,split(/,/,$notify))) {
                    937:                    $numperm = 1;
                    938:                }
                    939:            }
                    940:            unless ($numperm) {
                    941:                $numperm = &sendnotification($permemail,$user,$domain,$subject,0,
                    942:                                             $text,$msgid);
                    943:            }
1.196     www       944:        }
1.238     raeburn   945:        if ($toperm) {
                    946:            $permlogmsgstatus = '. Perm. email log status '.
                    947:                          &Apache::lonnet::log($env{'user.domain'},$env{'user.name'},$env{'user.home'},
                    948:                                               "Perm. e-mail count $numperm for $user at $domain");
                    949:            if (ref($permresults) eq 'HASH') {
                    950:                $permresults->{"$user:$domain"} = $numperm;
1.214     raeburn   951:            }
1.196     www       952:        }
                    953:        &Apache::lonnet::log($env{'user.domain'},$env{'user.name'},
                    954: 			    $env{'user.home'},
1.238     raeburn   955: 			    'Sending '.$msgid.' to '.$user.' at '.$domain.' with status '.$status.
                    956:                             $permlogmsgstatus);
1.196     www       957:    } else {
1.2       www       958:        $status='no_host';
1.196     www       959:    }
1.2       www       960:     return $status;
                    961: }
1.38      www       962: 
                    963: sub user_normal_msg {
1.132     www       964:     my ($user,$domain,$subject,$message,$citation,$baseurl,$attachmenturl,
1.238     raeburn   965: 	$toperm,$sentmessage,$symb,$restitle,$error,$nosentstore,$recipid,
1.239.2.4  raeburn   966:         $permresults,$senthide)=@_;
1.199     raeburn   967:     my @status;
1.38      www       968:     my %userenv = &Apache::lonnet::get('environment',['msgforward'],
                    969:                                        $domain,$user);
                    970:     my $msgforward=$userenv{'msgforward'};
                    971:     if ($msgforward) {
1.239     raeburn   972:         foreach my $fwd (split(/\,/,$msgforward)) {
                    973: 	    my ($forwuser,$forwdomain)=split(/\:/,$fwd);
1.199     raeburn   974: 	    push(@status,
1.171     banghart  975: 	        &user_normal_msg_raw($forwuser,$forwdomain,$subject,$message,
1.172     albertel  976: 				     $citation,$baseurl,$attachmenturl,$toperm,
1.201     raeburn   977: 				     undef,undef,$sentmessage,undef,$symb,
1.239.2.4  raeburn   978:                                      $restitle,$error,$nosentstore,$recipid,
                    979:                                      $permresults,$senthide));
1.171     banghart  980:         }
1.191     raeburn   981:     } else {
1.199     raeburn   982: 	push(@status,&user_normal_msg_raw($user,$domain,$subject,$message,
1.172     albertel  983: 				     $citation,$baseurl,$attachmenturl,$toperm,
1.201     raeburn   984: 				     undef,undef,$sentmessage,undef,$symb,
1.239.2.4  raeburn   985:                                      $restitle,$error,$nosentstore,$recipid,
                    986:                                      $permresults,$senthide));
1.199     raeburn   987:     }
                    988:     if (wantarray) {
                    989:         return @status;
1.38      www       990:     }
1.199     raeburn   991:     return join(' ',@status);
1.38      www       992: }
                    993: 
1.201     raeburn   994: sub process_sent_mail {
1.236     raeburn   995:     my ($msgsubj,$subj_prefix,$numsent,$stamp,$msgname,$msgdom,$msgcount,
                    996:         $context,$pid,$savemsg,$recusers,$recudoms,$baseurl,$attachmenturl,
                    997:         $symb,$error,$senderuname,$senderdom,$recipid) = @_;
1.201     raeburn   998:     my $sentsubj;
                    999:     if ($numsent > 1) {
                   1000:         $sentsubj = $subj_prefix.' ('.$numsent.' sent) '.$msgsubj;
1.205     raeburn  1001:     } else {
                   1002:         if ($subj_prefix) {
                   1003:             $sentsubj = $subj_prefix.' ';
                   1004:         }
                   1005:         $sentsubj .= $msgsubj;
1.201     raeburn  1006:     }
                   1007:     $sentsubj = &HTML::Entities::encode($sentsubj,'<>&"');
                   1008:     my $sentmsgid = 
                   1009:         &buildmsgid($stamp,$sentsubj,$msgname,$msgdom,$msgcount,$context,$pid);
                   1010:     (undef,my $sentmessage) =
                   1011:         &packagemsg($msgsubj,$savemsg,undef,$baseurl,$attachmenturl,$recusers,
1.214     raeburn  1012:                     $recudoms,$sentmsgid,undef,undef,$symb,$error,$recipid);
1.201     raeburn  1013:     my $status = &store_sent_mail($sentmsgid,$sentmessage,$senderuname,
1.210     albertel 1014:                                   $senderdom);
1.201     raeburn  1015:     return $status;
                   1016: }
                   1017: 
1.156     raeburn  1018: sub store_sent_mail {
1.210     albertel 1019:     my ($msgid,$message,$senderuname,$senderdom) = @_;
1.201     raeburn  1020:     if ($senderuname eq '') {
                   1021:         $senderuname = $env{'user.name'};
                   1022:     }
                   1023:     if ($senderdom eq '') {
                   1024:         $senderdom = $env{'user.domain'};
                   1025:     }
1.210     albertel 1026:     my $status =' '.&Apache::lonnet::cput('nohist_email_sent',
                   1027: 					  {$msgid => $message},
                   1028: 					  $senderdom,$senderuname);
1.156     raeburn  1029:     return $status;
                   1030: }
1.2       www      1031: 
1.202     raeburn  1032: sub store_recipients {
                   1033:     my ($subject,$sendername,$senderdom,$reciphash) = @_;
                   1034:     my $context = &get_course_context();
1.203     albertel 1035:     my $now = time();
1.202     raeburn  1036:     my $msgcount = &get_uniq();
                   1037:     my $recipid =
                   1038:         &buildmsgid($now,$subject,$sendername,$senderdom,$msgcount,$context,$$);
                   1039:     my %recipinfo = (
                   1040:                          $recipid => $reciphash,
                   1041:                     );
                   1042:     my $status = &Apache::lonnet::put('nohist_emailrecip',\%recipinfo,
                   1043:                                       $senderdom,$sendername); 
                   1044:     if ($status eq 'ok') {
                   1045:         return ($recipid,$status);
                   1046:     } else {
                   1047:         return (undef,$status);
                   1048:     }
                   1049: }
                   1050: 
1.106     www      1051: 
                   1052: sub foldersuffix {
                   1053:     my $folder=shift;
                   1054:     unless ($folder) { return ''; }
1.189     raeburn  1055:     my $suffix;
                   1056:     my %folderhash = &get_user_folders($folder);
                   1057:     if (ref($folderhash{$folder}) eq 'HASH') {
                   1058:         $suffix = '_'.&escape($folderhash{$folder}{'id'});
                   1059:     } else {
                   1060:         $suffix = '_'.&escape($folder);
                   1061:     }
                   1062:     return $suffix;
                   1063: }
                   1064: 
                   1065: 
                   1066: sub get_user_folders {
                   1067:     my ($folder) = @_;
                   1068:     my %userfolders = 
                   1069:           &Apache::lonnet::dump('email_folders',undef,undef,$folder);
                   1070:     my $lock = "\0".'lock_counter'; # locks db while counter incremented
                   1071:     my $counter = "\0".'idcount';   # used in suffix for email db files
                   1072:     if (defined($userfolders{$lock})) {
                   1073:         delete($userfolders{$lock});
                   1074:     }
                   1075:     if (defined($userfolders{$counter})) {
                   1076:         delete($userfolders{$counter});
                   1077:     }
                   1078:     return %userfolders;
1.106     www      1079: }
                   1080: 
1.197     albertel 1081: sub secapply {
                   1082:     my $rec=shift;
                   1083:     my $defaultflag=shift;
                   1084:     $rec=~s/\s+//g;
1.229     raeburn  1085:     unless ($rec =~ /\:/) {
                   1086:         $rec=~s/\@/\:/g;
                   1087:     }
1.197     albertel 1088:     my ($adr,$sections_or_groups)=($rec=~/^([^\(]+)\(([^\)]+)\)/);
                   1089:     if ($sections_or_groups) {
                   1090: 	foreach my $item (split(/\;/,$sections_or_groups)) {
                   1091:             if (($item eq $env{'request.course.sec'}) ||
                   1092:                 ($defaultflag && ($item eq '*'))) {
                   1093:                 return $adr; 
                   1094:             } elsif ($env{'request.course.groups'}) {
                   1095:                 my @usersgroups = split(/:/,$env{'request.course.groups'});
                   1096:                 if (grep(/^\Q$item\E$/,@usersgroups)) {
                   1097:                     return $adr;
                   1098:                 }
                   1099:             } 
                   1100:         }
                   1101:     } else {
                   1102:        return $rec;
                   1103:     }
                   1104:     return '';
                   1105: }
                   1106: 
                   1107: sub decide_receiver {
                   1108:     my ($feedurl,$author,$question,$course,$policy,$defaultflag) = @_;
                   1109:     &Apache::lonenc::check_decrypt(\$feedurl);
                   1110:     my $typestyle='';
                   1111:     my %to=();
                   1112:     if ($env{'form.discuss'} eq 'author' ||$author) {
                   1113: 	$typestyle.='Submitting as Author Feedback<br />';
                   1114: 	$feedurl=~ m{^/res/($LONCAPA::domain_re)/($LONCAPA::username_re)/};
                   1115: 	$to{$2.':'.$1}=1;
                   1116:     }
                   1117:     my $cid = $env{'request.course.id'};
                   1118:     if ($env{'form.discuss'} eq 'question' ||$question) {
                   1119: 	$typestyle.=&mt('Submitting as Question').'<br />';
                   1120: 	foreach my $item (split(/\,/,$env{'course.'.$cid.'.question.email'})) {
                   1121: 	    my $rec=&secapply($item,$defaultflag);
                   1122: 	    if ($rec) { $to{$rec}=1; }
                   1123: 	} 
                   1124:     }
                   1125:     if ($env{'form.discuss'} eq 'course' ||$course) {
                   1126: 	$typestyle.=&mt('Submitting as Comment').'<br />';
                   1127: 	foreach my $item (split(/\,/,$env{'course.'.$cid.'.comment.email'})) {
                   1128: 	    my $rec=&secapply($item,$defaultflag);
                   1129: 	    if ($rec) { $to{$rec}=1; }
                   1130: 	} 
                   1131:     }
                   1132:     if ($env{'form.discuss'} eq 'policy' ||$policy) {
                   1133: 	$typestyle.=&mt('Submitting as Policy Feedback').'<br />';
                   1134: 	foreach my $item (split(/\,/,$env{'course.'.$cid.'.policy.email'})) {
                   1135: 	    my $rec=&secapply($item,$defaultflag);
                   1136: 	    if ($rec) { $to{$rec}=1; }
                   1137: 	} 
                   1138:     }
                   1139:     if ((scalar(%to) eq '0') && (!$defaultflag)) {
                   1140: 	($typestyle,%to)=
                   1141: 	    &decide_receiver($feedurl,$author,$question,$course,$policy,1);
                   1142:     }
                   1143:     return ($typestyle,%to);
                   1144: }
                   1145: 
1.180     albertel 1146: 1;
1.1       www      1147: __END__
                   1148: 

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