File Coverage

blib/lib/App/RecordStream/Deaggregator/Unhash.pm

Criterion	Covered	Total	%
statement	37	47	78.7
branch	2	2	100.0
condition			n/a
subroutine	9	12	75.0
pod	0	6	0.0
total	48	67	71.6

package App::RecordStream::Deaggregator::Unhash;

use strict;
use warnings;

use App::RecordStream::Deaggregator::Field;
use App::RecordStream::Deaggregator;
use App::RecordStream::DomainLanguage::Registry;

use base 'App::RecordStream::Deaggregator::Field';

sub new
{
  my $class = shift;
  my $old_field = shift;
  my $new_key_field = shift;
  my $new_value_field = shift;

  my $this = $class->SUPER::new($old_field);

  $this->{'new_key_field'} = $new_key_field;
  $this->{'new_value_field'} = $new_value_field;

  return $this;
}

sub new_from_valuation
{
  my $class = shift;
  my $valuation = shift;
  my $new_key_field = shift;
  my $new_value_field = shift;

  my $this = $class->SUPER::new_from_valuation($valuation);

  $this->{'new_key_field'} = $new_key_field;
  $this->{'new_value_field'} = $new_value_field;

  return $this;
}

sub deaggregate_field
{
  my $this = shift;
  my $hashref = shift;

  my @ret;

  for my $key (sort(keys(%$hashref)))
  {
    my $record = {};
    $record->{$this->{'new_key_field'}} = $key;
    if(defined($this->{'new_value_field'}))
    {
      $record->{$this->{'new_value_field'}} = $hashref->{$key};
    }
    push @ret, $record;
  }

  return \@ret;
}

sub long_usage
{
  return <
Usage: unhash,,[,]
   Split the hash into key/value \"pair\" records
EOF
}

sub short_usage
{
  return "split the provided hash";
}

sub argct
{
  return [2, 3];
}

App::RecordStream::Deaggregator->register_implementation('unhash', __PACKAGE__);

App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'unhash', 'VALUATION', 'SCALAR');
App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'unhash', 'VALUATION', 'SCALAR', 'SCALAR');

1;