X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=Debbugs%2FCommon.pm;h=ae7d8b4724c32f693ab4ef76403e6b9ec9da2fa5;hb=0c2305d4c89d165140bc955a50f3248c9c9ba7ad;hp=2bc3e0dfe3280143f0243b6ae8df189376ead1a7;hpb=1f81df46999fc3699ce73aeba95af5095a5a413a;p=debbugs.git

diff --git a/Debbugs/Common.pm b/Debbugs/Common.pm
index 2bc3e0d..ae7d8b4 100644
--- a/Debbugs/Common.pm
+++ b/Debbugs/Common.pm
@@ -40,11 +40,13 @@ BEGIN{
      @EXPORT = ();
      %EXPORT_TAGS = (util   => [qw(getbugcomponent getbuglocation getlocationpath get_hashname),
 				qw(appendfile overwritefile buglog getparsedaddrs getmaintainers),
+                                qw(getsourcemaintainers getsourcemaintainers_reverse),
 				qw(bug_status),
 				qw(getmaintainers_reverse),
 				qw(getpseudodesc),
 				qw(package_maintainer),
 				qw(sort_versions),
+				qw(open_compressed_file),
 			       ],
 		     misc   => [qw(make_list globify_scalar english_join checkpid),
 				qw(cleanup_eval_fail),
@@ -239,7 +241,40 @@ sub overwritefile {
 	    die "Unable to rename ${file}.new to $file: $!";
 }
 
+=head2 open_compressed_file
 
+     my $fh = open_compressed_file('foo.gz') or
+          die "Unable to open compressed file: $!";
+
+
+Opens a file; if the file ends in .gz, .xz, or .bz2, the appropriate
+decompression program is forked and output from it is read.
+
+This routine by default opens the file with UTF-8 encoding; if you want some
+other encoding, specify it with the second option.
+
+=cut
+sub open_compressed_file {
+    my ($file,$encoding) = @_;
+    $encoding //= ':encoding(UTF-8)';
+    my $fh;
+    my $mode = "<$encoding";
+    my @opts;
+    if ($file =~ /\.gz$/) {
+	$mode = "-|$encoding";
+	push @opts,'gzip','-dc';
+    }
+    if ($file =~ /\.xz$/) {
+	$mode = "-|$encoding";
+	push @opts,'xz','-dc';
+    }
+    if ($file =~ /\.bz2$/) {
+	$mode = "-|$encoding";
+	push @opts,'bzip2','-dc';
+    }
+    open($fh,$mode,@opts,$file);
+    return $fh;
+}
 
 
 
@@ -299,6 +334,36 @@ sub getmaintainers_reverse{
      return $_maintainer_rev;
 }
 
+=head2 getsourcemaintainers
+
+     my $maintainer = getsourcemaintainers()->{debbugs}
+
+Returns a hashref of src_package => maintainer pairs.
+
+=cut
+
+our $_source_maintainer = undef;
+our $_source_maintainer_rev = undef;
+sub getsourcemaintainers {
+    return $_source_maintainer if defined $_source_maintainer;
+    package_maintainer(rehash => 1);
+    return $_source_maintainer;
+}
+
+=head2 getsourcemaintainers_reverse
+
+     my @src_packages = @{getsourcemaintainers_reverse->{'don@debian.org'}||[]};
+
+Returns a hashref of maintainer => [qw(list of source packages)] pairs.
+
+=cut
+
+sub getsourcemaintainers_reverse{
+     return $_source_maintainer_rev if defined $_source_maintainer_rev;
+     package_maintainer(rehash => 1);
+     return $_source_maintainer_rev;
+}
+
 =head2 package_maintainer
 
      my @s = package_maintainer(source => [qw(foo bar baz)],
@@ -324,8 +389,6 @@ files; defaults to 0
 
 =cut
 
-our $_source_maintainer = undef;
-our $_source_maintainer_rev = undef;
 sub package_maintainer {
     my %param = validate_with(params => \@_,
 			      spec   => {source => {type => SCALAR|ARRAYREF,
@@ -364,7 +427,7 @@ sub package_maintainer {
 	for my $fn (@config{('source_maintainer_file',
 			     'source_maintainer_file_override',
 			     'pseudo_maint_file')}) {
-	    next unless defined $fn;
+	    next unless defined $fn and length $fn;
 	    if (not -e $fn) {
 		warn "Missing source maintainer file '$fn'";
 		next;
@@ -380,7 +443,7 @@ sub package_maintainer {
 	for my $fn (@config{('maintainer_file',
 			     'maintainer_file_override',
 			     'pseudo_maint_file')}) {
-	    next unless defined $fn;
+	    next unless defined $fn and length $fn;
 	    if (not -e $fn) {
 		warn "Missing maintainer file '$fn'";
 		next;
@@ -431,7 +494,7 @@ sub __add_to_hash {
     }
     $type //= 'address';
     my $fh = IO::File->new($fn,'r') or
-	die "Unable to open $fn for reading: $!";
+	croak "Unable to open $fn for reading: $!";
     binmode($fh,':encoding(UTF-8)');
     while (<$fh>) {
 	chomp;
@@ -471,7 +534,8 @@ sub getpseudodesc {
     return $_pseudodesc if defined $_pseudodesc;
     $_pseudodesc = {};
     __add_to_hash($config{pseudo_desc_file},$_pseudodesc) if
-	defined $config{pseudo_desc_file};
+	defined $config{pseudo_desc_file} and
+	length $config{pseudo_desc_file};
     return $_pseudodesc;
 }