File Coverage

blib/lib/ObjectDB/InflateColumn.pm

Criterion	Covered	Total	%
statement	22	42	52.3
branch	2	14	14.2
condition	0	8	0.0
subroutine	7	12	58.3
pod			n/a
total	31	76	40.7

package ObjectDB::InflateColumn;
use strict;
use warnings;

our $VERSION = '0.01';

BEGIN {
    use Carp;
    use Module::Util qw();
    unless (Module::Util::module_is_loaded('ObjectDB')) {
        croak __PACKAGE__." can't be loaded before ObjectDB"
    }
    # ok, lets go
}

use Sub::Install;

my $imported = 0;
sub import {
	my $class = shift;
	return if $imported;

	# extend ObjectDB::Schema
	Sub::Install::install_sub({
	    code => sub {
	        my $self = shift;
	        my $field = shift;
	        unless ($field) {
	            return $self->{_inflate_columns_info} ||= {};
	        };
	        my $param = ref $_[0] eq 'HASH' ? $_[0] : {@_};
	        $param->{inflate} ||= sub {$_[0]};
	        $param->{deflate} ||= sub {$_[0]};

	        $self->{_inflate_columns_info}->{$field} = $param;

	        return 1;
	    },
	    into => 'ObjectDB::Schema',
	    as   => 'inflate_column'
	});
	# method 'inflate_column' has been added

	Sub::Install::install_sub({
	    code => sub {$_[0]->{_inflate_columns_info} ||= {}},
	    into => 'ObjectDB::Schema',
	    as   => '_inflate_columns_info'
	});
	# method '_inflate_columns_info' has been added (access to field {_inflate_columns_info})

	# extend ObjectDB
	Sub::Install::install_sub({
	    code => sub {
	        my $self = shift;
	        my $inflate_info = $self->schema->_inflate_columns_info;
	        if (exists $inflate_info->{$_[0]}) {
	            if (@_==1) {
	                return $inflate_info->{$_[0]}->{deflate}->($self->column($_[0]));
	            } elsif (@_==2) {
	                return $self->column($_[0], $inflate_info->{$_[0]}->{inflate}->($_[1]));
	            };
	        };
	        return $self->column(@_);
	    },
	    into => 'ObjectDB',
	    as   => 'inflate_column'
	});
	# method 'inflate_column' has been added
	$imported++;
};

1;
__END__