scripts/process.in

   1 #!/usr/bin/perl
   2 # $Id: process.in,v 1.109 2006/02/09 22:02:04 don Exp $
   3 #
   4 # Usage: process nn
   5 # Temps:  incoming/Pnn
   6
   7 use warnings;
   8 use strict;
   9
  10 use POSIX qw(strftime);
  11
  12 use MIME::Parser;
  13 use Debbugs::MIME qw(decode_rfc1522 create_mime_message getmailbody);
  14 use Debbugs::Mail qw(send_mail_message encode_headers);
  15 use Debbugs::Packages qw(getpkgsrc);
  16 use Debbugs::User qw(read_usertags write_usertags);
  17 use Debbugs::Common qw(:lock get_hashname);
  18 use Debbugs::Status qw(writebug isstrongseverity lockreadbugmerge lockreadbug);
  19
  20 use Debbugs::CGI qw(html_escape bug_url);
  21
  22 use Debbugs::Log qw(:misc);
  23
  24 use Debbugs::Text qw(:templates);
  25
  26 use Debbugs::Status qw(:versions);
  27 use Debbugs::Config qw(:globals :config);
  28
  29 chdir( "$gSpoolDir" ) || die "chdir spool: $!\n";
  30
  31 #open(DEBUG,"> /tmp/debbugs.debug");
  32 umask(002);
  33 open DEBUG, ">/dev/null";
  34
  35 my $intdate = time or quit("failed to get time: $!");
  36
  37 $_=shift;
  38 m/^([BMQFDUL])(\d*)\.\d+$/ or quit("bad argument: $_");
  39 my $codeletter= $1;
  40 my $tryref= length($2) ? $2 : -1;
  41 my $nn= $_;
  42
  43 if (!rename("incoming/G$nn","incoming/P$nn"))
  44 {
  45     $_=$!.'';  m/no such file or directory/i && exit 0;
  46     &quit("renaming to lock: $!");
  47 }
  48
  49 my $baddress= 'submit' if $codeletter eq 'B';
  50 $baddress= 'maintonly' if $codeletter eq 'M';
  51 $baddress= 'quiet' if $codeletter eq 'Q';
  52 $baddress= 'forwarded' if $codeletter eq 'F';
  53 $baddress= 'done' if $codeletter eq 'D';
  54 $baddress= 'submitter' if $codeletter eq 'U';
  55 bug_list_forward($nn) if $codeletter eq 'L';
  56 $baddress || &quit("bad codeletter $codeletter");
  57 my $baddressroot= $baddress;
  58 $baddress= "$tryref-$baddress" if $tryref>=0;
  59
  60 open(M,"incoming/P$nn");
  61 my @log=<M>;
  62 close(M);
  63
  64 my @msg = @log;
  65 chomp @msg;
  66
  67 print DEBUG "###\n",join("##\n",@msg),"\n###\n";
  68
  69 my $tdate = strftime "%a, %d %h %Y %T +0000", gmtime;
  70 my $fwd= <<END;
  71 Received: via spool by $baddress\@$gEmailDomain id=$nn
  72           (code $codeletter ref $tryref); $tdate
  73 END
  74
  75 # header and decoded body respectively
  76 my (@headerlines, @bodylines);
  77
  78 # whether maintainer addresses have been checked
  79 our $maintainerschecked = 0;
  80 #maintainer address for this message
  81 our @maintaddrs;
  82 # other src addresses
  83 our @addsrcaddrs;
  84 our @resentccs;
  85 our @bccs;
  86
  87 my $resentccexplain='';
  88
  89 # whether there's a new reference with this email
  90 our $newref = 0;
  91
  92 our $brokenness = '';
  93
  94 my $parser = new MIME::Parser;
  95 mkdir "$gSpoolDir/mime.tmp", 0777;
  96 $parser->output_under("$gSpoolDir/mime.tmp");
  97 my $entity = eval { $parser->parse_data(join('',@log)) };
  98
  99 my $i;
 100 if ($entity and $entity->head->tags) {
 101     @headerlines = @{$entity->head->header};
 102     chomp @headerlines;
 103
 104     my $entity_body = getmailbody($entity);
 105     @bodylines = $entity_body ? $entity_body->as_lines() : ();
 106     chomp @bodylines;
 107
 108     # set $i to beginning of encoded body data, so we can dump it out
 109     # verbatim later
 110     $i = 0;
 111     ++$i while $msg[$i] =~ /./;
 112 } else {
 113     # Legacy pre-MIME code, kept around in case MIME::Parser fails.
 114     for ($i = 0; $i <= $#msg; $i++) {
 115         $_ = $msg[$i];
 116         last unless length($_);
 117         while ($msg[$i+1] =~ m/^\s/) {
 118             $i++;
 119             $_ .= "\n".$msg[$i];
 120         }
 121         push @headerlines, $_;
 122     }
 123
 124     @bodylines = @msg[$i..$#msg];
 125 }
 126
 127 my %header;
 128
 129 for my $hdr (@headerlines) {
 130     $hdr = decode_rfc1522($hdr);
 131     $_ = $hdr;
 132     s/\n\s/ /g;
 133     &finish if m/^x-loop: (\S+)$/i && $1 eq "$gMaintainerEmail";
 134     my $ins = !m/^subject:/i && !m/^reply-to:/i && !m/^return-path:/i
 135            && !m/^From / && !m/^X-Debbugs-/i;
 136     $fwd .= $hdr."\n" if $ins;
 137     # print DEBUG ">$_<\n";
 138     if (s/^(\S+):\s*//) {
 139         my $v = lc $1;
 140         print DEBUG ">$v=$_<\n";
 141         $header{$v} = $_;
 142     } else {
 143         print DEBUG "!>$_<\n";
 144     }
 145 }
 146 $header{'message-id'} = '' if not defined $header{'message-id'};
 147
 148 # remove blank lines
 149 shift @bodylines while @bodylines and $bodylines[0] !~ /\S/;
 150
 151 # Strip off RFC2440-style PGP clearsigning.
 152 if (@bodylines and $bodylines[0] =~ /^-----BEGIN PGP SIGNED/) {
 153     shift @bodylines while @bodylines and length $bodylines[0];
 154     shift @bodylines while @bodylines and $bodylines[0] !~ /\S/;
 155     for my $findsig (0 .. $#bodylines) {
 156         if ($bodylines[$findsig] =~ /^-----BEGIN PGP SIGNATURE/) {
 157             $#bodylines = $findsig - 1;
 158             last;
 159         }
 160     }
 161     map { s/^- // } @bodylines;
 162 }
 163
 164 #psuedoheaders
 165 my %pheader;
 166 # extract pseudo-headers
 167 for my $phline (@bodylines)
 168 {
 169     last if $phline !~ m/^([\w-]+):\s*(\S.*)/;
 170     my ($fn, $fv) = ($1, $2);
 171     $fv =~ s/\s*$//;
 172     print DEBUG ">$fn|$fv|\n";
 173     $fn = lc $fn;
 174     # Don't lc owner or forwarded
 175     $fv = lc $fv unless $fn =~ /^(?:owner|forwarded|usertags|version|source-version)$/;
 176     $pheader{$fn} = $fv;
 177     print DEBUG ">$fn~$fv<\n";
 178 }
 179
 180 # Allow pseudo headers to set x-debbugs- stuff [#179340]
 181 for my $key (grep /X-Debbugs-.*/i, keys %pheader) {
 182      $header{$key} = $pheader{$key} if not exists $header{$key};
 183 }
 184
 185 $fwd .= join("\n",@msg[$i..$#msg]);
 186
 187 print DEBUG "***\n$fwd\n***\n";
 188
 189 if (defined $header{'resent-from'} && !defined $header{'from'}) {
 190     $header{'from'} = $header{'resent-from'};
 191 }
 192 defined($header{'from'}) || &quit("no From header");
 193
 194 my $replyto = $header{'reply-to'};
 195 $replyto = '' unless defined $replyto;
 196 $replyto =~ s/^ +//;
 197 $replyto =~ s/ +$//;
 198 unless (length $replyto) {
 199     $replyto = $header{'from'};
 200 }
 201
 202 my $subject = '(no subject)';
 203 if (!defined($header{'subject'}))
 204 {
 205         $brokenness.= fill_template('mail/process_broken_subject');
 206
 207 } else {
 208     $subject= $header{'subject'};
 209 }
 210
 211 my $ref=-1;
 212 $subject =~ s/^Re:\s*//i; $_= $subject."\n";
 213 if ($tryref < 0 && m/^Bug ?\#(\d+)\D/i) {
 214     $tryref= $1+0;
 215 }
 216 my $data;
 217 if ($tryref >= 0)
 218 {
 219      my $bfound;
 220     ($bfound, $data)= &lockreadbugmerge($tryref);
 221     if ($bfound) {
 222         $ref= $tryref;
 223     } else {
 224         &htmllog("Reply","sent", $replyto,"Unknown problem report number <code>$tryref</code>.");
 225         &sendmessage(create_mime_message(
 226           [From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 227            To            => $replyto,
 228            Subject       => "Unknown problem report $gBug#$tryref ($subject)",
 229            'Message-ID'  => "<handler.x.$nn.unknown\@$gEmailDomain>",
 230            'In-Reply-To' => $header{'message-id'},
 231            References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 232            Precedence    => 'bulk',
 233            "X-$gProject-PR-Message" => 'error',
 234           ],message_body_template('process_unknown_bug_number',
 235                                   {subject => $subject,
 236                                    date    => $header{date},
 237                                    baddress => $baddress,
 238                                    tryref   => $tryref,
 239                                    messageid => $header{'message-id'},
 240                                   },
 241                                  )),'');
 242         &appendlog;
 243         &finish;
 244     }
 245 } else {
 246     &filelock('lock/-1');
 247 }
 248
 249 # Attempt to determine which source package this is
 250 my $source_pr_header = '';
 251 my $source_package = '';
 252 if (defined $pheader{source}) {
 253      $source_package = $pheader{source};
 254 }
 255 elsif (defined $data->{package} or defined $pheader{package}) {
 256      my $pkg_src = getpkgsrc();
 257      $source_package = $pkg_src->{defined $data->{package}?$data->{package}:$pheader{package}};
 258 }
 259 $source_pr_header = "X-$gProject-PR-Source: $source_package\n"
 260      if defined $source_package and length $source_package;
 261
 262 # Done and Forwarded Bugs
 263 if ($codeletter eq 'D' || $codeletter eq 'F')
 264 {
 265     if ($replyto =~ m/$gBounceFroms/o ||
 266         $header{'from'} =~ m/$gBounceFroms/o)
 267     {
 268          print STDERR "bounce detected !  Mwaap! Mwaap!";
 269          exit 1;
 270     }
 271     my $markedby= $header{'from'} eq $replyto ? $replyto :
 272                "$header{'from'} (reply to $replyto)";
 273     my @generalcc;
 274     my $receivedat;
 275     my $markaswhat;
 276     my $set_forwarded;
 277     my $generalcc;
 278     my $set_done;
 279     if ($codeletter eq 'F') { # Forwarded
 280         (&appendlog,&finish) if defined $data->{forwarded} and length($data->{forwarded});
 281         $receivedat= "forwarded\@$gEmailDomain";
 282         $markaswhat= 'forwarded';
 283         $set_forwarded= $header{'to'};
 284         # Dissallow forwarded being set to this bug tracking system
 285         if (defined $set_forwarded and $set_forwarded =~ /\Q$gEmailDomain\E/) {
 286              undef $set_forwarded;
 287         }
 288         if ( length( $gListDomain ) > 0 && length( $gForwardList ) > 0 ) {
 289             push @generalcc, "$gForwardList\@$gListDomain";
 290             $generalcc= "$gForwardList\@$gListDomain";
 291         } else {
 292             $generalcc='';
 293         }
 294     } else { # Done
 295         if (defined $data->{done} and length($data->{done}) and
 296                 not defined $pheader{'source-version'} and
 297                 not defined $pheader{'version'}) {
 298             &appendlog;
 299             &finish;
 300         }
 301         $receivedat= "done\@$gEmailDomain";
 302         $markaswhat= 'done';
 303         $set_done= $header{'from'};
 304         if ( length( $gListDomain ) > 0 && length( $gDoneList ) > 0 ) {
 305             $generalcc= "$gDoneList\@$gListDomain";
 306             push @generalcc, "$gDoneList\@$gListDomain";
 307         } else {
 308             $generalcc='';
 309         }
 310     }
 311     if (defined $gStrongList and isstrongseverity($data->{severity})) {
 312         $generalcc = join ', ', $generalcc, "$gStrongList\@$gListDomain";
 313         push @generalcc,"$gStrongList\@$gListDomain";
 314     }
 315     if ($ref<0) {
 316         &htmllog("Warning","sent",$replyto,"Message ignored.");
 317         &sendmessage(create_mime_message(
 318           [From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 319            To            => $replyto,
 320            Subject       => "Message with no $gBug number ignored by $receivedat ($subject)",
 321            'Message-ID'  => "<handler.x.$nn.warnignore\@$gEmailDomain>",
 322            'In-Reply-To' => $header{'message-id'},
 323            References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 324            Precedence    => 'bulk',
 325            "X-$gProject-PR-Message" => 'error',
 326           ],message_body_template('mail/process_no_bug_number',
 327                                   {subject => $subject,
 328                                    date    => $header{date},
 329                                    markaswhat => $markaswhat,
 330                                    receivedat => $receivedat,
 331                                    messageid => $header{'message-id'},
 332                                   },
 333                                  )),'');
 334         &appendlog;
 335         &finish;
 336     }
 337
 338     &checkmaintainers;
 339
 340     my @noticecc = grep($_ ne $replyto,@maintaddrs);
 341     my $noticeccval.= join(', ', grep($_ ne $replyto,@maintaddrs));
 342     $noticeccval =~ s/\s+\n\s+/ /g;
 343     $noticeccval =~ s/^\s+/ /; $noticeccval =~ s/\s+$//;
 344
 345     my @process= ($ref,split(/ /,$data->{mergedwith}));
 346     my $orgref= $ref;
 347
 348     for $ref (@process) {
 349         if ($ref != $orgref) {
 350             &unfilelock;
 351             $data = &lockreadbug($ref)
 352                 || die "huh ? $ref from $orgref out of ".join(' ',@process);
 353         }
 354         $data->{done}= $set_done if defined($set_done);
 355         $data->{forwarded}= $set_forwarded if defined($set_forwarded);
 356         if ($codeletter eq 'D') {
 357             $data->{keywords} = join ' ', grep $_ ne 'pending',
 358                                      split ' ', $data->{keywords};
 359             if (defined $pheader{'source-version'}) {
 360                  if ($pheader{'source-version'} !~ m/^$config{package_version_re}$/) {
 361                       $brokenness .= fill_template('mail/invalid_version',
 362                                                    {version => $pheader{'source-version'}},
 363                                                   );
 364                  }
 365                  else {
 366                       addfixedversions($data, $pheader{source}, $pheader{'source-version'}, '');
 367                  }
 368             } elsif (defined $pheader{version}) {
 369                  if ($pheader{version} !~ m/^$config{package_version_re}$/) {
 370                       $brokenness .= fill_template('mail/invalid_version',
 371                                                    {version => $pheader{version}},
 372                                                   );
 373                  }
 374                  else {
 375                       addfixedversions($data, $pheader{package}, $pheader{version}, '');
 376                  }
 377             }
 378         }
 379
 380         # Add bug mailing list to $generalbcc as appropriate
 381         # This array is used to specify bcc in the cases where we're using create_mime_message.
 382         my @generalbcc = (@generalcc,@addsrcaddrs,"bugs=$ref\@$gListDomain");
 383         my $generalbcc = join(', ', $generalcc, @addsrcaddrs,"bugs=$ref\@$gListDomain");
 384         $generalbcc =~ s/\s+\n\s+/ /g;
 385         $generalbcc =~ s/^\s+/ /; $generalbcc =~ s/\s+$//;
 386         if (length $generalbcc) {$generalbcc = "Bcc: $generalbcc\n"};
 387
 388         writebug($ref, $data);
 389
 390         my $hash = get_hashname($ref);
 391         open(O,"db-h/$hash/$ref.report") || &quit("read original report: $!");
 392         my $orig_report= join('',<O>); close(O);
 393         if ($codeletter eq 'F') {
 394             &htmllog("Reply","sent",$replyto,"You have marked $gBug as forwarded.");
 395             &sendmessage(create_mime_message(
 396              ["X-Loop"      => "$gMaintainerEmail",
 397               From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 398               To            => "$replyto",
 399               Subject       => "$gBug#$ref: marked as forwarded ($data->{subject})",
 400               "Message-ID"  => "<header.$ref.$nn.ackfwdd\@$gEmailDomain>",
 401               "In-Reply-To" => $header{'message-id'},
 402               References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 403               Precedence    => 'bulk',
 404               "X-$gProject-PR-Message"  => "forwarded $ref",
 405               "X-$gProject-PR-Package"  => $data->{package},
 406               "X-$gProject-PR-Keywords" => $data->{keywords},
 407               # Only have a X-$gProject-PR-Source when we know the source package
 408               (defined($source_package) and length($source_package))?("X-$gProject-PR-Source" => $source_package):(),
 409              ],message_body_template('mail/process_mark_as_forwarded',
 410                                      {date => $header{date},
 411                                       messageid => $header{'message-id'},
 412                                       data      => $data,
 413                                      },
 414                                     ),
 415              [join("\n",@msg)]),'',[$replyto,@generalbcc,@noticecc],1);
 416         } else {
 417             &htmllog("Reply","sent",$replyto,"You have taken responsibility.");
 418             &sendmessage(create_mime_message(
 419              ["X-Loop"      => "$gMaintainerEmail",
 420               From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 421               To            => $replyto,
 422               Subject       => "$gBug#$ref: marked as done ($data->{subject})",
 423               "Message-ID"  => "<handler.$ref.$nn.ackdone\@$gEmailDomain>",
 424               "In-Reply-To" => $header{'message-id'},
 425               References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 426               Precedence    => 'bulk',
 427               "X-$gProject-PR-Message"  => "closed $ref",
 428               "X-$gProject-PR-Package"  => $data->{package},
 429               "X-$gProject-PR-Keywords" => $data->{keywords},
 430               # Only have a X-$gProject-PR-Source when we know the source package
 431               (defined($source_package) and length($source_package))?("X-$gProject-PR-Source" => $source_package):(),
 432              ],message_body_template('mail/process_mark_as_done',
 433                                      {date => $header{date},
 434                                       messageid => $header{'message-id'},
 435                                       subject   => $header{subject},
 436                                       data      => $data,
 437                                      },
 438                                     ),
 439              [$orig_report,join("\n",@msg)]),'',[$replyto,@generalbcc,@noticecc],1);
 440             &htmllog("Notification","sent",$data->{originator},
 441                 "$gBug acknowledged by developer.");
 442             &sendmessage(create_mime_message(
 443              ["X-Loop"      => "$gMaintainerEmail",
 444               From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 445               To            => "$data->{originator}",
 446               Subject       => "$gBug#$ref closed by $markedby ($header{'subject'})",
 447               "Message-ID"  => "<handler.$ref.$nn.notifdone\@$gEmailDomain>",
 448               "In-Reply-To" => "$data->{msgid}",
 449               References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 450               "X-$gProject-PR-Message"  => "they-closed $ref",
 451               "X-$gProject-PR-Package"  => "$data->{package}",
 452               "X-$gProject-PR-Keywords" => "$data->{keywords}",
 453               # Only have a X-$gProject-PR-Source when we know the source package
 454               (defined($source_package) and length($source_package))?("X-$gProject-PR-Source" => $source_package):(),
 455               "Reply-To"                => "$ref\@$gEmailDomain",
 456               "Content-Type"            => 'text/plain; charset="utf-8"',
 457              ],message_body_template('mail/process_your_bug_done',
 458                                      {data      => $data,
 459                                       markedby  => $markedby,
 460                                       messageid => $header{'message-id'},
 461                                       subject   => $header{subject},
 462                                      },
 463                                     ),
 464              [join("\n",@msg),$orig_report]),'',undef,1);
 465         }
 466         &appendlog;
 467     }
 468     &finish;
 469 }
 470
 471 if ($ref<0) {
 472     if ($codeletter eq 'U') {
 473         &htmllog("Warning","sent",$replyto,"Message not forwarded.");
 474         &sendmessage(create_mime_message(
 475           [From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 476            To            => $replyto,
 477            Subject       => "Message with no $gBug number cannot be sent to submitter! ($subject)",
 478            'Message-ID'  => "<handler.x.$nn.nonumnosub\@$gEmailDomain>",
 479            'In-Reply-To' => $header{'message-id'},
 480            References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 481            Precedence    => 'bulk',
 482            "X-$gProject-PR-Message" => 'error',
 483           ],message_body_template('mail/process_no_bug_number',
 484                                   {subject => $subject,
 485                                    date    => $header{date},
 486                                    markaswhat => 'submitter',
 487                                    receivedat => "$baddress\@$gEmailDomain",
 488                                    messageid => $header{'message-id'},
 489                                   },
 490                                  )),'');
 491         &appendlog;
 492         &finish;
 493     }
 494
 495     $data->{found_versions} = [];
 496     $data->{fixed_versions} = [];
 497
 498     if (defined $pheader{source}) {
 499         $data->{package} = $pheader{source};
 500     } elsif (defined $pheader{package}) {
 501         $data->{package} = $pheader{package};
 502     } elsif (defined $config{default_package}) {
 503         $data->{package} = $config{default_package},
 504     }
 505     else {
 506         &htmllog("Warning","sent",$replyto,"Message not forwarded.");
 507         my $body = message_body_template('mail/process_no_package',
 508                                         );
 509         &sendmessage(create_mime_message(
 510                        ["X-Loop"      => "$gMaintainerEmail",
 511                         From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 512                         To            => $replyto,
 513                         Subject       => "Message with no Package: tag cannot be processed! ($subject)",
 514                         "Message-ID"  => "<handler.x.$nn.nonumnosub\@$gEmailDomain>",
 515                         "In-Reply-To" => $header{'message-id'},
 516                         References    => join(' ',grep {defined $_} $header{'message-id'},$data->{msgid}),
 517                         Precedence    => 'bulk',
 518                         "X-$gProject-PR-Message" => 'error'
 519                        ],
 520            message_body_template('mail/process_no_package',
 521                                  {date => $header{date},
 522                                   subject => $subject,
 523                                   messageid => $header{'message-id'},
 524                                   baddress => $baddress,
 525                                  },
 526                                 ),[join("\n", @msg)]), '',undef,1);
 527         &appendlog;
 528         &finish;
 529     }
 530
 531     if (defined $config{default_package}) {
 532          &checkmaintainers;
 533          # if there are no maintainers for this package, assign it to the default package
 534          if (not @maintaddrs) {
 535               $data->{package} = $config{default_package};
 536               $brokenness.= fill_template('mail/process_default_package_selected',
 537                                           {old_package => $pheader{source} || $pheader{package} || 'No package',
 538                                            new_package => $data->{package},
 539                                           }
 540                                          );
 541               # force the maintainers to be rechecked
 542               $maintainerschecked = 0;
 543               &checkmaintainers;
 544          }
 545     }
 546
 547     $data->{keywords}= '';
 548     if (defined($pheader{'keywords'})) {
 549         $data->{keywords}= $pheader{'keywords'};
 550     } elsif (defined($pheader{'tags'})) {
 551         $data->{keywords}= $pheader{'tags'};
 552     }
 553     if (length($data->{keywords})) {
 554         my @kws;
 555         my %gkws = map { ($_, 1) } @gTags;
 556         foreach my $kw (sort split(/[,\s]+/, lc($data->{keywords}))) {
 557             push @kws, $kw if (defined $gkws{$kw});
 558         }
 559         $data->{keywords} = join(" ", @kws);
 560     }
 561     $data->{severity}= '';
 562     if (defined($pheader{'severity'}) || defined($pheader{'priority'})) {
 563         $data->{severity}= $pheader{'severity'};
 564         $data->{severity}= $pheader{'priority'} unless ($data->{severity});
 565         $data->{severity} =~ s/^\s*(.+)\s*$/$1/;
 566
 567         if (!grep($_ eq $data->{severity}, @gSeverityList, "$gDefaultSeverity")) {
 568             $brokenness.= fill_template('mail/invalid_severity',
 569                                         {severity=>$data->{severity}}
 570                                        );
 571             $data->{severity}= '';
 572         }
 573     }
 574     if (defined($pheader{owner})) {
 575         $data->{owner}= $pheader{owner};
 576     }
 577     if (defined($pheader{forwarded})) {
 578         $data->{'forwarded-to'} = $pheader{forwarded};
 579     }
 580     &filelock("nextnumber.lock");
 581     open(N,"nextnumber") || &quit("nextnumber: read: $!");
 582     my $nextnumber=<N>; $nextnumber =~ s/\n$// || &quit("nextnumber bad format");
 583     $ref= $nextnumber+0;  $nextnumber += 1;  $newref=1;
 584     &overwrite('nextnumber', "$nextnumber\n");
 585     &unfilelock;
 586     my $hash = get_hashname($ref);
 587     &overwrite("db-h/$hash/$ref.log",'');
 588     $data->{originator} = $replyto;
 589     $data->{date} = $intdate;
 590     $data->{subject} = $subject;
 591     $data->{msgid} = $header{'message-id'};
 592     writebug($ref, $data);
 593     # Deal with usertags
 594     if (exists $pheader{usertags}) {
 595          my $user = $replyto;
 596          $user = $pheader{user} if exists $pheader{user};
 597          $user =~ s/,.*//;
 598          $user =~ s/^.*<(.*)>.*$/$1/;
 599          $user =~ s/[(].*[)]//;
 600          $user =~ s/^\s*(\S+)\s+.*$/$1/;
 601          if ($user ne '' and Debbugs::User::is_valid_user($user)) {
 602               $pheader{usertags} =~ s/(?:^\s+|\s+$)//g;
 603               my %user_tags;
 604               read_usertags(\%user_tags,$user);
 605               for my $tag (split /[,\s]+/, $pheader{usertags}) {
 606                    if ($tag =~ /^[a-zA-Z0-9.+\@-]+/) {
 607                         my %bugs_with_tag;
 608                         @bugs_with_tag{@{$user_tags{$tag}||[]}} = (1) x @{$user_tags{$tag}||[]};
 609                         $bugs_with_tag{$ref} = 1;
 610                         $user_tags{$tag} = [keys %bugs_with_tag];
 611                    }
 612               }
 613               write_usertags(\%user_tags,$user);
 614          }
 615          else {
 616               $brokenness .= fill_template('mail/invalid_user',
 617                                            {user => $user}
 618                                           );
 619          }
 620     }
 621     &overwrite("db-h/$hash/$ref.report",
 622                join("\n",@msg)."\n");
 623 }
 624
 625 &checkmaintainers;
 626
 627 print DEBUG "maintainers >".join(' ',@maintaddrs)."<\n";
 628
 629 my $orgsender= defined($header{'sender'}) ? "Original-Sender: $header{'sender'}\n" : '';
 630 my $newsubject= $subject;  $newsubject =~ s/^$gBug#$ref:*\s*//;
 631
 632 my $xcchdr= $header{ 'x-debbugs-cc' } || '';
 633 if ($xcchdr =~ m/\S/) {
 634     push(@resentccs,$xcchdr);
 635     $resentccexplain.= fill_template('mail/xdebbugscc',
 636                                      {xcchdr => $xcchdr},
 637                                     );
 638 }
 639
 640 if (@maintaddrs && ($codeletter eq 'B' || $codeletter eq 'M')) {
 641     push(@resentccs,@maintaddrs);
 642     $resentccexplain.= fill_template('mail/maintainercc',
 643                                      {maintaddrs => \@maintaddrs,
 644                                      },
 645                                     );
 646 }
 647
 648 @bccs = @addsrcaddrs;
 649 if (defined $gStrongList and isstrongseverity($data->{severity})) {
 650     push @bccs, "$gStrongList\@$gListDomain";
 651 }
 652
 653 # Send mail to the per bug list subscription too
 654 push @bccs, "bugs=$ref\@$gListDomain";
 655
 656 if (defined $pheader{source}) {
 657     # Prefix source versions with the name of the source package. They
 658     # appear that way in version trees so that we can deal with binary
 659     # packages moving from one source package to another.
 660     if (defined $pheader{'source-version'}) {
 661          if ($pheader{'source-version'} !~ m/^$config{package_version_re}$/) {
 662               $brokenness .= fill_template('mail/invalid_version',
 663                                            {version => $pheader{'source-version'}},
 664                                           );
 665          }
 666          else {
 667               addfoundversions($data, $pheader{source}, $pheader{'source-version'}, '');
 668          }
 669     } elsif (defined $pheader{version}) {
 670          if ($pheader{version} !~ m/^$config{package_version_re}$/) {
 671               $brokenness .= fill_template('mail/invalid_version',
 672                                            {version => $pheader{version}},
 673                                           );
 674          }
 675          else {
 676               addfoundversions($data, $pheader{source}, $pheader{version}, '');
 677          }
 678     }
 679     writebug($ref, $data);
 680 } elsif (defined $pheader{package}) {
 681     # TODO: could handle Source-Version: by looking up the source package?
 682      if (defined $pheader{version}) {
 683           if ($pheader{version} !~ m/^$config{package_version_re}$/) {
 684                $brokenness .= fill_template('mail/invalid_version',
 685                                             {version => $pheader{version}},
 686                                            );
 687           }
 688           else {
 689                addfoundversions($data, $pheader{package}, $pheader{version}, 'binary');
 690           }
 691      }
 692      writebug($ref, $data);
 693 }
 694
 695 my $veryquiet= $codeletter eq 'Q';
 696 if ($codeletter eq 'M' && !@maintaddrs) {
 697     $veryquiet= 1;
 698     $brokenness.= fill_template('mail/invalid_maintainer',
 699                                 {},
 700                                );
 701 }
 702
 703 my $resentccval.= join(', ',@resentccs);
 704 $resentccval =~ s/\s+\n\s+/ /g; $resentccval =~ s/^\s+/ /; $resentccval =~ s/\s+$//;
 705 my $resentcc = '';
 706 if (length($resentccval)) {
 707     $resentcc= "Resent-CC: $resentccval\n";
 708 }
 709
 710 if ($codeletter eq 'U') {
 711     &htmllog("Message", "sent on", $data->{originator}, "$gBug#$ref.");
 712     &sendmessage(<<END,[$data->{originator},@resentccs],[@bccs]);
 713 Subject: $gBug#$ref: $newsubject
 714 Reply-To: $replyto, $ref-quiet\@$gEmailDomain
 715 ${orgsender}Resent-To: $data->{originator}
 716 ${resentcc}Resent-Date: $tdate
 717 Resent-Message-ID: <handler.$ref.$nn\@$gEmailDomain>
 718 Resent-Sender: $gMaintainerEmail
 719 X-$gProject-PR-Message: report $ref
 720 X-$gProject-PR-Package: $data->{package}
 721 X-$gProject-PR-Keywords: $data->{keywords}
 722 ${source_pr_header}$fwd
 723 END
 724 } elsif ($codeletter eq 'B') { # Sent to submit
 725     &htmllog($newref ? "Report" : "Information", "forwarded",
 726              join(', ',"$gSubmitList\@$gListDomain",@resentccs),
 727              "<code>$gBug#$ref</code>".
 728              (length($data->{package})? "; Package <code>".html_escape($data->{package})."</code>" : '').
 729              ".");
 730     &sendmessage(<<END,["$gSubmitList\@$gListDomain",@resentccs],[@bccs]);
 731 Subject: $gBug#$ref: $newsubject
 732 Reply-To: $replyto, $ref\@$gEmailDomain
 733 Resent-From: $header{'from'}
 734 ${orgsender}Resent-To: $gSubmitList\@$gListDomain
 735 ${resentcc}Resent-Date: $tdate
 736 Resent-Message-ID: <handler.$ref.$nn\@$gEmailDomain>
 737 Resent-Sender: $gMaintainerEmail
 738 X-$gProject-PR-Message: report $ref
 739 X-$gProject-PR-Package: $data->{package}
 740 X-$gProject-PR-Keywords: $data->{keywords}
 741 ${source_pr_header}$fwd
 742 END
 743 } elsif (@resentccs or @bccs) { # Quiet or Maintainer
 744     # D and F done far earlier; B just done - so this must be M or Q
 745     # We preserve whichever it was in the Reply-To (possibly adding
 746     # the $gBug#).
 747     if (@resentccs) {
 748         &htmllog($newref ? "Report" : "Information", "forwarded",
 749                  $resentccval,
 750                  "<code>$gBug#$ref</code>".
 751                  (length($data->{package}) ? "; Package <code>".html_escape($data->{package})."</code>" : '').
 752                  ".");
 753     } else {
 754         &htmllog($newref ? "Report" : "Information", "stored",
 755                  "",
 756                  "<code>$gBug#$ref</code>".
 757                  (length($data->{package}) ? "; Package <code>".html_escape($data->{package})."</code>" : '').
 758                  ".");
 759     }
 760     &sendmessage(<<END,[@resentccs],[@bccs]);
 761 Subject: $gBug#$ref: $newsubject
 762 Reply-To: $replyto, $ref-$baddressroot\@$gEmailDomain
 763 Resent-From: $header{'from'}
 764 ${orgsender}Resent-To: $resentccval
 765 Resent-Date: $tdate
 766 Resent-Message-ID: <handler.$ref.$nn\@$gEmailDomain>
 767 Resent-Sender: $gMaintainerEmail
 768 X-$gProject-PR-Message: report $ref
 769 X-$gProject-PR-Package: $data->{package}
 770 X-$gProject-PR-Keywords: $data->{keywords}
 771 ${source_pr_header}$fwd
 772 END
 773 }
 774
 775 my $htmlbreak= length($brokenness) ? "<p>\n".html_escape($brokenness)."\n<p>\n" : '';
 776 $htmlbreak =~ s/\n\n/\n<P>\n\n/g;
 777 if (length($resentccval)) {
 778     $htmlbreak = "  Copy sent to <code>".html_escape($resentccval)."</code>.".
 779         $htmlbreak;
 780 }
 781
 782 # Should we send an ack out?
 783 if (not exists $header{'x-debbugs-no-ack'} and
 784     ($newref or
 785      ($codeletter ne 'U' and
 786       (not defined $header{precedence} or
 787        $header{'precedence'} !~ /\b(?:bulk|junk|list)\b/
 788       )
 789      )
 790     )
 791    ){
 792
 793      # figure out forward explanation
 794      my $forwardexplain = '';
 795      my $thanks = '';
 796      my $extra_vars;
 797      # will contain info and -info in moreinfo messages
 798      my $info = '';
 799      my $infod = '';
 800      # temporary headers
 801      my %t_h;
 802      if ($newref) {
 803           &htmllog("Acknowledgement","sent",$replyto,
 804                    ($veryquiet ?
 805                     "New $gBug report received and filed, but not forwarded." :
 806                     "New $gBug report received and forwarded."). $htmlbreak);
 807           $thanks = fill_template('mail/process_ack_thanks_new');
 808      }
 809      else {
 810           &htmllog("Acknowledgement","sent",$replyto,
 811                    ($veryquiet ? "Extra info received and filed, but not forwarded." :
 812                     $codeletter eq 'M' ? "Extra info received and forwarded to maintainer." :
 813                     "Extra info received and forwarded to list."). $htmlbreak);
 814           $thanks = fill_template('mail/process_ack_thanks_additional');
 815           $info = 'info';
 816           $infod = '-info';
 817      }
 818      if ($veryquiet) {
 819           $forwardexplain = fill_template('mail/forward_veryquiet',
 820                                          );
 821           # these are the headers that quiet messages override
 822           $t_h{messageid}  = "<handler.$ref.$nn.ack${info}quiet\@$gEmailDomain>";
 823           $t_h{pr_message} = "ack${infod}-quiet $ref";
 824           $t_h{reply_to}   = "$ref-quiet\@$gEmailDomain";
 825           $extra_vars->{refreplyto} = "$ref-quiet\@$gEmailDomain";
 826           $t_h{subject}    = length($info)?
 827                "$gBug#$ref: Info received and FILED only ($subject)":
 828                "$gBug#$ref: Acknowledgement of QUIET report ($subject)";
 829      }
 830      elsif ($codeletter eq 'M') {
 831           $forwardexplain = fill_template('mail/forward_maintonly',
 832                                          );
 833           # these are the headers that maintonly messages override
 834           $t_h{messageid}  = "<handler.$ref.$nn.ack{$info}maintonly\@$gEmailDomain>";
 835           $t_h{pr_message} = "ack${infod}-maintonly $ref";
 836           $t_h{reply_to}   = "$ref-maintonly\@$gEmailDomain";
 837           $extra_vars->{refreplyto} = "$ref-maintonly\@$gEmailDomain";
 838           $t_h{subject}    = length($info)?
 839                "$gBug#$ref: Info received for maintainer only ($subject)":
 840                "$gBug#$ref: Acknowledgement of maintainer-only report ($subject)";
 841      }
 842      else {
 843           $forwardexplain = fill_template('mail/forward_normal',
 844                                          );
 845           $t_h{messageid}  = "<handler.$ref.$nn.ack${info}\@$gEmailDomain>";
 846           $t_h{pr_message} = "ack${infod} $ref";
 847           $t_h{reply_to}   = "$ref\@$gEmailDomain";
 848           $extra_vars->{refreplyto} = "$ref\@$gEmailDomain";
 849           $t_h{subject}    = (defined $info and length($info))?
 850                "$gBug#$ref: Info received ($subject)" :
 851                "$gBug#$ref: Acknowledgement ($subject)";
 852      }
 853      my $body = message_body_template('mail/process_ack',
 854                                       {forwardexplain  => $forwardexplain,
 855                                        resentccexplain => $resentccexplain,
 856                                        thanks          => $thanks,
 857                                        %{$extra_vars}
 858                                       }
 859                                      );
 860      &sendmessage(create_mime_message(
 861                        ["X-Loop"      => "$gMaintainerEmail",
 862                         From          => "$gMaintainerEmail ($gProject $gBug Tracking System)",
 863                         To            => $replyto,
 864                         Subject       => $t_h{subject},
 865                         "Message-ID"  => $t_h{messageid},
 866                         "In-Reply-To" => $header{'message-id'},
 867                         References    => $header{'message-id'},
 868                         Precedence    => 'bulk',
 869                         "X-$gProject-PR-Message"  => $t_h{pr_message} || "ack $ref",
 870                         "X-$gProject-PR-Package"  => $data->{package},
 871                         "X-$gProject-PR-Keywords" => $data->{keywords},
 872                         # Only have a X-$gProject-PR-Source when we know the source package
 873                         (defined($source_package) and length($source_package))?("X-$gProject-PR-Source" => $source_package):(),
 874                         "Reply-To"                => $t_h{reply_to} || "$ref\@$gEmailDomain",
 875                        ],$body,[]), '',undef,1);
 876 }
 877
 878 &appendlog;
 879 &finish;
 880
 881 sub overwrite {
 882     my ($f,$v) = @_;
 883     open(NEW,">$f.new") || &quit("$f.new: create: $!");
 884     print(NEW "$v") || &quit("$f.new: write: $!");
 885     close(NEW) || &quit("$f.new: close: $!");
 886     rename("$f.new","$f") || &quit("rename $f.new to $f: $!");
 887 }
 888
 889 sub appendlog {
 890     my $hash = get_hashname($ref);
 891     if (!open(AP,">>db-h/$hash/$ref.log")) {
 892         print DEBUG "failed open log<\n";
 893         print DEBUG "failed open log err $!<\n";
 894         &quit("opening db-h/$hash/$ref.log (li): $!");
 895     }
 896     print(AP "\7\n",escape_log(@log),"\n\3\n") || &quit("writing db-h/$hash/$ref.log (li): $!");
 897     close(AP) || &quit("closing db-h/$hash/$ref.log (li): $!");
 898 }
 899
 900 sub finish {
 901     my ($exit) = @_;
 902     $exit ||= 0;
 903     utime(time,time,"db");
 904     # cleanups are run in an end block now.
 905     #my ($u);
 906     #while ($u= $cleanups[$#cleanups]) { &$u; }
 907     unlink("incoming/P$nn") || &quit("unlinking incoming/P$nn: $!");
 908     exit $exit;
 909 }
 910
 911 &quit("wot no exit");
 912
 913 sub htmllog {
 914     my ($whatobj,$whatverb,$where,$desc) = @_;
 915     my $hash = get_hashname($ref);
 916     open(AP,">>db-h/$hash/$ref.log") || &quit("opening db-h/$hash/$ref.log (lh): $!");
 917     print(AP
 918           "\6\n".
 919           "<strong>$whatobj $whatverb</strong>".
 920           ($where eq '' ? "" : " to <code>".html_escape($where)."</code>").
 921           ":<br>\n". $desc.
 922           "\n\3\n") || &quit("writing db-h/$hash/$ref.log (lh): $!");
 923     close(AP) || &quit("closing db-h/$hash/$ref.log (lh): $!");
 924 }
 925
 926 sub stripbccs {
 927     my $msg = shift;
 928     my $ret = '';
 929     my $bcc = 0;
 930     while ($msg =~ s/(.*\n)//) {
 931         local $_ = $1;
 932         if (/^$/) {
 933             $ret .= $_;
 934             last;
 935         }
 936         if ($bcc) {
 937             # strip continuation lines too
 938             next if /^\s/;
 939             $bcc = 0;
 940         }
 941         if (/^Bcc:/i) {
 942             $bcc = 1;
 943         } else {
 944             $ret .= $_;
 945         }
 946     }
 947     return $ret . $msg;
 948 }
 949
 950 =head2 send_message
 951
 952      send_message($the_message,\@recipients,\@bcc,$do_not_encode)
 953
 954 The first argument is the scalar message, the second argument is the
 955 arrayref of recipients, the third is the arrayref of Bcc:'ed
 956 recipients.
 957
 958 The final argument turns off header encoding and the addition of the
 959 X-Loop header if true, defaults to false.
 960
 961 =cut
 962
 963
 964 sub sendmessage {
 965     my ($msg,$recips,$bcc,$no_encode) = @_;
 966     if (not defined $recips or (!ref($recips) && $recips eq '')
 967         or @$recips == 0) {
 968         $recips = ['-t'];
 969     }
 970     # This is suboptimal. The right solution is to send headers
 971     # separately from the rest of the message and encode them rather
 972     # than doing this.
 973     $msg = "X-Loop: $gMaintainerEmail\n" . $msg unless $no_encode;
 974     # The original message received is written out in appendlog, so
 975     # before writing out the other messages we've sent out, we need to
 976     # RFC1522 encode the header.
 977     $msg = encode_headers($msg) unless $no_encode;
 978
 979     my $hash = get_hashname($ref);
 980     #save email to the log
 981     open(AP,">>db-h/$hash/$ref.log") || &quit("opening db-h/$hash/$ref.log (lo): $!");
 982     print(AP "\2\n",join("\4",@$recips),"\n\5\n",
 983           escape_log(stripbccs($msg)),"\n\3\n") ||
 984         &quit("writing db-h/$hash/$ref.log (lo): $!");
 985     close(AP) || &quit("closing db-h/$hash/$ref.log (lo): $!");
 986
 987     if (ref($bcc)) {
 988         shift @$recips if $recips->[0] eq '-t';
 989         push @$recips, @$bcc;
 990     }
 991
 992     send_mail_message(message        => $msg,
 993                       # Because we encode the headers above, we do not want to encode them here
 994                       encode_headers => 0,
 995                       recipients     => $recips);
 996 }
 997
 998 =head2 message_body_template
 999
1000      message_body_template('mail/ack',{ref=>'foo'});
1001
1002 Creates a message body using a template
1003
1004 =cut
1005
1006 sub message_body_template{
1007      my ($template,$extra_var) = @_;
1008      $extra_var ||={};
1009      my $body = fill_template($template,$extra_var);
1010      return fill_template('mail/message_body',
1011                           {%{$extra_var},
1012                            body => $body,
1013                           },
1014                          );
1015 }
1016
1017 =head2 fill_template
1018
1019      fill_template('mail/foo',{foo=>'bar'});
1020
1021 Calls fill_in_template with a default set of variables and any extras
1022 added in.
1023
1024 =cut
1025
1026 sub fill_template{
1027      my ($template,$extra_var) = @_;
1028      $extra_var ||={};
1029      my $variables = {config => \%config,
1030                       defined($ref)?(ref    => $ref):(),
1031                       defined($data)?(data  => $data):(),
1032                       %{$extra_var},
1033                      };
1034      my $hole_var = {'&bugurl' =>
1035                      sub{"$_[0]: ".
1036                               'http://'.$config{cgi_domain}.'/'.
1037                                    Debbugs::CGI::bug_url($_[0]);
1038                     }
1039                     };
1040      return fill_in_template(template => $template,
1041                              variables => $variables,
1042                              hole_var  => $hole_var,
1043                             );
1044 }
1045
1046
1047 sub checkmaintainers {
1048     return if $maintainerschecked++;
1049     return if !length($data->{package});
1050     my %maintainerof;
1051     open(MAINT,"$gMaintainerFile") || die &quit("maintainers open: $!");
1052     while (<MAINT>) {
1053         m/^\n$/ && next;
1054         m/^\s*$/ && next;
1055         m/^(\S+)\s+(\S.*\S)\s*\n$/ || &quit("maintainers bogus \`$_'");
1056         $a= $1; $b= $2; $a =~ y/A-Z/a-z/;
1057         # use the package which is normalized to lower case; we do this because we lc the pseudo headers.
1058         $maintainerof{$a}= $2;
1059     }
1060     close(MAINT);
1061     open(MAINT,"$gMaintainerFileOverride") || die &quit("maintainers.override open: $!");
1062     while (<MAINT>) {
1063         m/^\n$/ && next;
1064         m/^\s*$/ && next;
1065         m/^(\S+)\s+(\S.*\S)\s*\n$/ || &quit("maintainers.override bogus \`$_'");
1066         $a= $1; $b= $2; $a =~ y/A-Z/a-z/;
1067         # use the package which is normalized to lower case; we do this because we lc the pseudo headers.
1068         $maintainerof{$a}= $2;
1069     }
1070     close(MAINT);
1071     my %pkgsrc;
1072     open(SOURCES,"$gPackageSource") || &quit("pkgsrc open: $!");
1073     while (<SOURCES>) {
1074         next unless m/^(\S+)\s+\S+\s+(\S.*\S)\s*$/;
1075         ($a,$b)=($1,$2);
1076         $a =~ y/A-Z/a-z/;
1077         $pkgsrc{$a} = $b;
1078     }
1079     close(SOURCES);
1080     my $anymaintfound=0; my $anymaintnotfound=0;
1081     for my $p (split(m/[ \t?,():]+/,$data->{package})) {
1082         $p =~ y/A-Z/a-z/;
1083         $p =~ /([a-z0-9.+-]+)/;
1084         $p = $1;
1085         next unless defined $p;
1086         if (defined $gSubscriptionDomain) {
1087             if (defined($pkgsrc{$p})) {
1088                 push @addsrcaddrs, "$pkgsrc{$p}\@$gSubscriptionDomain";
1089             } else {
1090                 push @addsrcaddrs, "$p\@$gSubscriptionDomain";
1091             }
1092         }
1093         if (defined($maintainerof{$p})) {
1094             print DEBUG "maintainer add >$p|$maintainerof{$p}<\n";
1095             my $addmaint= $maintainerof{$p};
1096             push(@maintaddrs,$addmaint) unless
1097                 $addmaint eq $replyto || grep($_ eq $addmaint, @maintaddrs);
1098             $anymaintfound++;
1099         } else {
1100             print DEBUG "maintainer none >$p<\n";
1101             push(@maintaddrs,$gUnknownMaintainerEmail) unless $anymaintnotfound;
1102             $anymaintnotfound++;
1103             last;
1104         }
1105     }
1106
1107     if (defined $data->{owner} and length $data->{owner}) {
1108         print DEBUG "owner add >$data->{package}|$data->{owner}<\n";
1109         my $addmaint = $data->{owner};
1110         push(@maintaddrs, $addmaint) unless
1111             $addmaint eq $replyto or grep($_ eq $addmaint, @maintaddrs);
1112     }
1113 }
1114
1115 =head2 bug_list_forward
1116
1117      bug_list_forward($spool_filename) if $codeletter eq 'L';
1118
1119
1120 Given the spool file, will forward a bug to the per bug mailing list
1121 subscription system.
1122
1123 =cut
1124
1125 sub bug_list_forward{
1126      my ($bug_fn) = @_;
1127      # Read the bug information and package information for passing to
1128      # the mailing list
1129      my ($bug_number) = $bug_fn =~ /^L(\d+)\./;
1130      my ($bfound, $data)= lockreadbugmerge($bug_number);
1131      my $bug_fh = new IO::File "incoming/P$bug_fn" or die "Unable to open incoming/P$bug_fn $!";
1132
1133      local $/ = undef;
1134      my $bug_message = <$bug_fh>;
1135      my ($bug_address) = $bug_message =~ /^Received: \(at ([^\)]+)\) by/;
1136      my ($envelope_from) = $bug_message =~ s/\nFrom\s+([^\s]+)[^\n]+\n/\n/;
1137      if (not defined $envelope_from) {
1138           # Try to use the From: header or something to set it
1139           ($envelope_from) = $bug_message =~ /\nFrom:\s+(.+?)\n/;
1140           # Kludgy, and should really be using a full scale header
1141           # parser to do this.
1142           $envelope_from =~ s/^.+?<([^>]+)>.+$/$1/;
1143      }
1144      my ($header,$body) = split /\n\n/, $bug_message, 2;
1145      # Add X-$gProject-PR-Message: list bug_number, package name, and bug title headers
1146      $header .= qq(\nX-$gProject-PR-Message: list $bug_number\n).
1147           qq(X-$gProject-PR-Package: $data->{package}\n).
1148                qq(X-$gProject-PR-Title: $data->{subject})
1149                if defined $data;
1150      print STDERR "Tried to loop me with $envelope_from\n"
1151           and exit 1 if $envelope_from =~ /\Q$gListDomain\E|\Q$gEmailDomain\E/;
1152      print DEBUG $envelope_from,qq(\n);
1153      # If we don't have a bug address, something has gone horribly wrong.
1154      print STDERR "Doesn't match: $bug_address\n" and exit 1 unless defined $bug_address;
1155      $bug_address =~ s/\@.+//;
1156      print DEBUG "Sending message to bugs=$bug_address\@$gListDomain\n";
1157      print DEBUG $header.qq(\n\n).$body;
1158      send_mail_message(message        => $header.qq(\n\n).$body,
1159                        recipients     => ["bugs=$bug_address\@$gListDomain"],
1160                        envelope_from  => $envelope_from,
1161                        encode_headers => 0,
1162                       );
1163      unlink("incoming/P$bug_fn") || &quit("unlinking incoming/P$bug_fn: $!");
1164      exit 0;
1165 }