File Coverage

blib/lib/App/RecordStream/Operation/fromsplit.pm

Criterion	Covered	Total	%
statement	56	60	93.3
branch	8	8	100.0
condition	5	5	100.0
subroutine	12	13	92.3
pod	0	8	0.0
total	81	94	86.1

package App::RecordStream::Operation::fromsplit;

our $VERSION = "4.0.24";

use strict;

use base qw(App::RecordStream::Operation);

sub init {
  my $this = shift;
  my $args = shift;

  my $headers = 0;
  my $strict  = 0;
  my %options = (
    "delim|d=s"       => sub { $this->_set_delimiter($_[1]); },
    "key|k|field|f=s" => sub { $this->add_field(split(/,/, $_[1])); },
    "header"          => \$headers,
    "strict"          => \$strict,
  );

  $this->parse_options($args, \%options);

  $this->{'HEADER'} = $headers;
  $this->{'STRICT'} = $strict;
}

sub _set_delimiter {
  my ($this, $value) = @_;
  $this->{'DELIMITER'} = $value;
}

sub get_delimiter {
  my ($this) = @_;
  if(!defined($this->{'DELIMITER'})) {
    return ',';
  }
  return $this->{'DELIMITER'};
}

sub add_field {
  my $this = shift;
  $this->{'FIELDS'} ||= [];
  push @{$this->{'FIELDS'}}, @_;
}

sub get_field {
  my ($this, $index) = @_;

  if($this->{'FIELDS'} && $index < @{$this->{'FIELDS'}}) {
    return $this->{'FIELDS'}->[$index];
  }
  else {
    return $index;
  }
}

sub accept_line {
  my $this = shift;
  my $line = shift;

  if ($this->{'HEADER'}) {
    $this->add_field($_) for @{$this->get_values_for_line($line)};
    delete $this->{'HEADER'};
  }
  else {
    my $record = App::RecordStream::Record->new();
    my $index = 0;

    foreach my $value (@{$this->get_values_for_line($line)}) {
      ${$record->guess_key_from_spec($this->get_field($index))} = $value;
      ++$index;
    }

    $this->push_record($record);
  }

  return 1;
}

sub get_values_for_line {
  my $this = shift;
  my $line = shift;

  my @values;
  my $delim = $this->get_delimiter();
  if ( $this->{'STRICT'} ) {
    @values = split(/\Q$delim\E/, $line, -1);
  }
  else {
    @values = split(/$delim/, $line, -1);
  }

  return \@values;
}

sub add_help_types {
  my $this = shift;
  $this->use_help_type('keyspecs');
}

sub usage {
  my $this = shift;

  my $options = [
    [ 'delim|-d ', "Delimiter to use for splitting input lines (default ',')."],
    [ 'key|-k ', 'Comma separated list of key names.  May be specified multiple times, may be key specs'],
    [ 'header', 'Take key names from the first line of input.'],
    [ 'strict', 'Delimiter is not treated as a regex'],
  ];

  my $args_string = $this->options_string($options);

  return <
Usage: recs-fromsplit  []
   __FORMAT_TEXT__
   Each line of input (or lines of ) is split on provided delimiter to
   produce an output record.  Keys are named numerically (0, 1, etc.) or as
   given by --key.
   __FORMAT_TEXT__

Arguments:
$args_string

Examples:
   Parse space separated keys x and y.
      recs-fromsplit --key x,y --delim ' '
   Parse comma separated keys a, b, and c.
      recs-fromsplit --key a,b,c
USAGE
}

1;