File Coverage

blib/lib/App/RecordStream/Aggregator/UniqConcatenate.pm

Criterion	Covered	Total	%
statement	35	38	92.1
branch			n/a
condition			n/a
subroutine	11	14	78.5
pod	0	8	0.0
total	46	60	76.6

package App::RecordStream::Aggregator::UniqConcatenate;

our $VERSION = "4.0.24";

use strict;
use warnings;

use App::RecordStream::Aggregator;
use App::RecordStream::DomainLanguage::Registry;
use App::RecordStream::DomainLanguage::Valuation::KeySpec;

use base qw(App::RecordStream::Aggregator::Aggregation);

sub new
{
  my $class = shift;
  my $delim = shift;
  my $field = shift;

  return new_from_valuation($class, $delim, App::RecordStream::DomainLanguage::Valuation::KeySpec->new($field));
}

sub new_from_valuation
{
  my $class = shift;
  my $delim = shift;
  my $valuation = shift;

  my $this =
  {
    'valuation' => $valuation,
    'delim' => $delim,
  };

  bless $this, $class;

  return $this;
}

sub squish
{
  my ($this, $cookie) = @_;

  return join($this->{'delim'}, sort(keys(%$cookie)));
}

sub long_usage
{
  return <
Usage: uconcat,,
   Concatenate unique values from specified field.
EOF
}

sub short_usage
{
  return "concatenate unique values from provided field";
}

sub argct
{
  return 2;
}

sub initial
{
  return {};
}

sub combine
{
  my ($this, $cookie, $record) = @_;

  my $value = $this->{'valuation'}->evaluate_record($record);

  $cookie->{$value} = 1;

  return $cookie;
}

App::RecordStream::Aggregator->register_implementation('uconcatenate', __PACKAGE__);
App::RecordStream::Aggregator->register_implementation('uconcat', __PACKAGE__);

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

1;