File Coverage

blib/lib/App/sourcepan.pm

Criterion	Covered	Total	%
statement	18	81	22.2
branch	0	66	0.0
condition	0	3	0.0
subroutine	6	10	60.0
pod	0	3	0.0
total	24	163	14.7

#  You may distribute under the terms of either the GNU General Public License
#  or the Artistic License (the same terms as Perl itself)
#
#  (C) Paul Evans, 2013-2019 -- [e-mail]

package App::sourcepan;

use strict;
use warnings;

our $VERSION = '0.03';

use CPAN;
use File::Basename qw( basename );
use File::Copy qw( copy );
use IPC::Run qw();

=head1 NAME

C - modulino implementation of F

=head1 SYNOPSIS

This module contains the code to implement the F command.

See L for usage information.

=cut

# TODO: damnit does CPAN::Shell not have a method for this??
sub _split_version
{
   shift =~ m/^(.*?)(?:-(\d+[[:digit:].]*))?$/;
}

sub run
{
   shift;
   my ( $opts, @items ) = @_;

   my $type = $opts->{type};

   my %dists;
   if( $type eq "module" ) {
      foreach my $module ( CPAN::Shell->expand( Module => @items ) ) {
         my $dist = $module->distribution;
         $dists{$dist->pretty_id} = $dist;
      }
   }
   else {
      # Dists have full names; search by regexp to match on dist base name
      foreach ( @items ) {
         my ( $basename, $ver ) = _split_version( $_ );

         # CPAN::Shell doesn't like a qr//, only a literal string
         my $match = defined $ver ? "/\\/$basename-$ver\\./"
                                  : "/\\/$basename-\\d+/";

         my $latestver;
         foreach my $dist ( CPAN::Shell->expand( Distribution => $match ) ) {
            $dists{$dist->pretty_id} = $dist;
            my ( undef, $thisver ) = _split_version $dist->base_id;
            if( !defined $latestver or $latestver < $thisver ) {
               $latestver = $thisver;
            }
         }

         if( !defined $ver ) {
            foreach ( keys %dists ) {
               my ( $thisname, $thisver ) = _split_version $dists{$_}->base_id;
               next if $thisname ne $basename;
               next if $thisver == $latestver;
               delete $dists{$_};
            }
         }
      }
   }

   foreach my $id ( sort keys %dists ) {
      my $dist = $dists{$id};

      # Peeking inside
      $dist->get_file_onto_local_disk;

      my $basename = basename $id;
      copy( $dist->{localfile}, $basename ) or die "Cannot copy - $!";

      print "$id => $basename\n";

      next unless $opts->{extract};

      my $dirname;

      if( $id =~ m/\.tar\.(?:gz|bz2)$/ ) {
         my $tarflags = ( $id =~ m/bz2$/ ) ? "xjf" : "xzf";
         system( "tar", $tarflags, $basename ) == 0 or
            die "Unable to extract - tar failed with exit code $?\n";

         ( $dirname = $basename ) =~ s/\.tar.(?:gz|bz2)$//;
         -d $dirname or
            die "Expected to extract a directory called $dirname\n";
      }
      elsif( $id =~ m/\.zip$/ ) {
         IPC::Run::run [ "unzip", $basename ], ">/dev/null" or
            die "Unable to extract - unzip failed with exit code $?\n";

         ( $dirname = $basename ) =~ s/\.zip$//;
         -d $dirname or
            die "Expected to extract a directory called $dirname\n";
      }
      else {
         die "Unsure how to unpack $id\n";
      }

      if( $opts->{unversioned} ) {
         ( my $newname = $dirname ) =~ s/-[0-9._]+$// or
            die "Unable to determine the unversioned name for $dirname\n";

         rename $dirname, $newname or
            die "Unable to rename $dirname to $newname - $!";

         $dirname = $newname;
      }

      print "Unpacked $basename to $dirname\n";

      if( my $vc = $opts->{vc_init} ) {
         my $code = __PACKAGE__->can( "vc_init_$vc" ) or
            die "Unsure how to initialise version control system $vc\n";

         $code->( $dirname,
            id => $id
         ) or exit $?;
      }
   }
}

sub vc_init_bzr
{
   my ( $dirname, %opts ) = @_;

   defined( my $kid = fork() ) or die "Cannot fork - $!";
   return waitpid $kid, 0 if $kid;

   # In a subprocess
   chdir $dirname or die "Cannot chdir $dirname - $!";

   IPC::Run::run( [ "bzr", "init" ] ) or die "Unable to 'bzr init' ($?)\n";
   IPC::Run::run( [ "bzr", "add", "." ] ) or die "Unable to 'bzr add ($?)\n";
   IPC::Run::run( [ "bzr", "commit", "-m", "Imported $opts{id}" ] ) or die "Unable to 'bzr commit' ($?)\n";
}

sub vc_init_git
{
   my ( $dirname, %opts ) = @_;

   defined( my $kid = fork() ) or die "Cannot fork - $!";
   return waitpid $kid, 0 if $kid;

   # In a subprocess
   chdir $dirname or die "Cannot chdir $dirname - $!";

   IPC::Run::run( [ "git", "init" ] ) or die "Unable to 'git init' ($?)\n";
   IPC::Run::run( [ "git", "add", "." ] ) or die "Unable to 'git add ($?)\n";
   IPC::Run::run( [ "git", "commit", "-m", "Imported $opts{id}" ] ) or die "Unable to 'git commit' ($?)\n";
}

=head1 AUTHOR

Paul Evans

=cut

0x55AA;