File Coverage

blib/lib/SSIS/Package.pm

Criterion	Covered	Total	%
statement	7	9	77.7
branch			n/a
condition			n/a
subroutine	3	3	100.0
pod			n/a
total	10	12	83.3

package SSIS::Package;

use 5.010;
use Mouse;

use XML::Simple ; #qw(:strict);
#use XML::LibXML;
use XML::CompactTree::XS;
use XML::LibXML::Reader;

use Data::Dumper;

use Carp;

=head1 NAME

SSIS::Package - Report on SSIS packages by Ded MedVed

=head1 VERSION

Version 0.04

=cut

our $VERSION = '0.04';

has 'file' => (
    is          => 'rw'
,   isa         => 'Str'
);
has 'parsedssiscode' => (
    is          => 'rw'
);


has 'connectorsXML' => (
    is          => 'rw'
);

has 'tasksXML' => (
    is          => 'rw'
);

has 'connectors' => (
    is          => 'rw'
);

has 'tasks' => (
    is          => 'rw'
);


sub BUILD {
    my ($self) = @_;
} ;

sub parse {

    local $_ ;

    my $self                = shift ;
    my $class               = ref($self) || $self ;
    my $filename            = shift or croak "no filename";

    $self->file($filename);
    $self->parsedssiscode(XMLin($filename,ForceArray => [ 'DTS:Executable', 'connections'  ]));

    my $stuff               = $self->parsedssiscode() ;

#warn Dumper $stuff ;

    my @connectorsXML ;
    foreach my $k (keys %{$stuff}) {
        if ( $k eq 'DTS:ConnectionManager' ) {
            foreach my $item (@{$stuff->{$k}} ) {
                push @connectorsXML, $item ;
            }
        }
    }
    $self->connectorsXML(\@connectorsXML);


    my @connectors ;
    foreach my $conn (@connectorsXML) {
        my @type = grep { $_->{'DTS:Name'} eq 'CreationName' }  @{$conn->{'DTS:Property'}};
        my $type = $type[0]->{'content'};
        my $obj = SSIS::Package::ConnectionManagerFactory->make( { type => $type , properties =>  $conn->{'DTS:Property'} , objectData => $conn->{'DTS:ObjectData'} });
        push @connectors, $obj;
    }
    $self->connectors(\@connectors);

    my @tasksXML;
    foreach my $k (keys %{$stuff}) {
#warn Dumper $k, $stuff->{$k};
#exit;
        if ( $k eq 'DTS:Executable' ) {
            foreach my $item (@{$stuff->{$k}} ) {
                push @tasksXML, $item ;
            }
        }
    }
    $self->tasksXML(\@tasksXML);

    my @tasks ;
    foreach my $task (@tasksXML) {
        my @connectors ;
        $self->parse_getConnectors($task, \@connectors) ;

        my @type = grep { $_->{'DTS:Name'} eq 'CreationName' }  @{$task->{'DTS:Property'}};
        my $type = $type[0]->{'content'};
        my $obj = SSIS::Package::DTSTaskFactory->make( { type => $task->{'DTS:ExecutableType'}, properties =>  $task->{'DTS:Property'}, connectors => \@connectors } );
        push @tasks, $obj;
    }
    $self->tasks(\@tasks);

}

sub parse_getConnectors {

    local $_ ;

    my $self                = shift ;
    my $class               = ref($self) || $self ;
    my $dataTree            = shift ;
    my $return              = shift ;

    if  (ref($dataTree)   eq 'HASH' ) {
        foreach my $k (keys %$dataTree) {
            if ( $k eq 'connections') {
                push @$return, $dataTree->{$k} ;
            }
            else {
                $self->parse_getConnectors($dataTree->{$k}, $return );
            }
        }
    }
    elsif  (ref($dataTree)   eq 'ARRAY' ) {
        foreach my $r (@$dataTree) {
            $self->parse_getConnectors($r,$return);
        }
    }
    return ;


}



__PACKAGE__->meta->make_immutable();


1;
__DATA__