File Coverage

blib/lib/SPOPS/Import/Object.pm

Criterion	Covered	Total	%
statement	6	6	100.0
branch			n/a
condition			n/a
subroutine	2	2	100.0
pod			n/a
total	8	8	100.0

package SPOPS::Import::Object;

# $Id: Object.pm,v 3.7 2004/06/02 00:48:22 lachoy Exp $

use strict;
use base qw( SPOPS::Import );
use SPOPS::Exception qw( spops_error );

$SPOPS::Import::Object::VERSION  = sprintf("%d.%02d", q$Revision: 3.7 $ =~ /(\d+)\.(\d+)/);

my @FIELDS = qw( include_id fields ); # skip_fields
SPOPS::Import::Object->mk_accessors( @FIELDS );


########################################;
# Core API

sub get_fields { return ( $_[0]->SUPER::get_fields(), @FIELDS ) }

sub run {
    my ( $self ) = @_;
    my $fields       = $self->fields;
    my $object_class = $self->object_class;
    unless ( $fields )       { spops_error "Cannot run without fields defined" }
    unless ( $object_class ) { spops_error "Cannot run without object class defined" }
    my $all_data = $self->data;
    unless ( ref( $all_data ) eq 'ARRAY' and scalar @{ $all_data } > 0 ) {
        spops_error "Cannot run without data defined";
    }

    my $num_fields = scalar @{ $fields };
    my @status = ();
    foreach my $data ( @{ $all_data } ) {
        my $obj = $object_class->new;
        for ( my $i = 0; $i < $num_fields; $i++ ) {
            $obj->{ $fields->[ $i ] } = $data->[ $i ];
        }
        eval {
            $obj->save({ is_add => 1,
                         DEBUG  => $self->DEBUG })
        };
        if ( $@ ) {
            push @status, [ undef, $data, $@ ];
        }
        else {
            push @status, [ 1, $obj, undef ];
        }
    }
    return \@status;
}


########################################
# Property manipulation

sub fields_as_hashref {
    my ( $self ) = @_;
    my $field_list = $self->fields;
    unless ( ref $field_list eq 'ARRAY' and scalar @{ $field_list } ) {
        spops_error 'Please set the fields in the importer object using: ',
                    '\$importer->fields( \\\@fields" )';
    }
    my $count = 0;
    return { map { $_ => $count++ } @{ $field_list } };
}

########################################
# I/O and property assignment

sub data_from_file {
    my ( $self, $filename ) = @_;
    $self->assign_raw_data( $self->raw_data_from_file( $filename ) );
}


sub data_from_fh {
    my ( $self, $fh ) = @_;
    $self->assign_raw_data( $self->raw_data_from_fh( $fh ) );
}


# Note that we support 'spops_class' and 'field_order' below for
# backward compatibility

sub assign_raw_data {
    my ( $self, $raw_data_orig ) = @_;
    my @raw_data = @{ $raw_data_orig };
    my %meta = %{ shift @raw_data };
    $self->object_class( $meta{object_class} || $meta{spops_class} );
    $self->fields( $meta{fields} || $meta{field_order} );
    delete $meta{ $_ } for( qw( object_class spops_class fields field_order ) );
    $self->extra_metadata( \%meta );
    $self->data( \@raw_data );
    return $self;
}

1;

__END__