package Pear::LocalLoop::Import::Role::CSV;
use strict;
use warnings;
use Moo::Role;
use Text::CSV;
use Try::Tiny;
use Pear::LocalLoop::Error;

requires 'csv_required_columns';

has csv_file => (
  is       => 'ro',
  predicate => 1,
);

has csv_string => (
  is => 'ro',
  predicate => 1,
);

has csv_error => (
  is => 'ro',
  predicate => 1,
);

has _csv_filehandle => (
  is      => 'lazy',
  builder => sub {
    my $self = shift;
    my $fh;
    if ( $self->has_csv_file ) {
      open $fh, '<', $self->csv_file;
    } elsif ( $self->has_csv_string ) {
      my $string = $self->csv_string;
      open $fh, '<', \$string;
    } else {
      die "Must provide csv_file or csv_string"
    }
    return $fh;
  }
);

has text_csv_options => (
  is      => 'lazy',
  builder => sub {
    return {
      binary           => 1,
      allow_whitespace => 1,
    };
  }
);

has _text_csv => (
  is      => 'lazy',
  builder => sub {
    return Text::CSV->new(shift->text_csv_options);
  }
);

has csv_data => (
  is      => 'lazy',
  builder => sub {
    my $self = shift;
    my $header_check = $self->check_headers;
    return 0 unless $header_check;
    return $self->_text_csv->getline_hr_all( $self->_csv_filehandle );
  }
);

sub get_csv_line {
  my $self = shift;
  return $self->_text_csv->getline_hr( $self->_csv_filehandle );
}

sub check_headers {
  my $self = shift;
  my $req_headers = $self->csv_required_columns;
  my @headers;
  @headers = $self->_text_csv->header( $self->_csv_filehandle );
  my %header_map = ( map { $_ => 1 } @headers );
  for my $req_header ( @$req_headers ) {
    next if $header_map{$req_header};
    die "Require header [" . $req_header . "]";
  }
  return 1;
}

1;