Added in importing Supplier CSV

lib/Pear/LocalLoop/Import/LCCCsv.pm

@@ -2,12 +2,6 @@ package Pear::LocalLoop::Import::LCCCsv;
 use Moo;
 use Pear::LocalLoop::Error;
 
-with qw/
-  Pear::LocalLoop::Import::Role::ExternalName
-  Pear::LocalLoop::Import::Role::Schema
-  Pear::LocalLoop::Import::Role::CSV
-/;
-
 has external_name => (
   is      => 'ro',
   default => 'LCC CSV',
@@ -20,4 +14,10 @@ has csv_required_columns => (
   },
 );
 
-1;
+with qw/
+  Pear::LocalLoop::Import::Role::ExternalName
+  Pear::LocalLoop::Import::Role::Schema
+  Pear::LocalLoop::Import::Role::CSV
+/;
+
+1;

lib/Pear/LocalLoop/Import/LCCCsv/Suppliers.pm

@@ -1,18 +1,44 @@
 package Pear::LocalLoop::Import::LCCCsv::Suppliers;
 use Moo;
+use Devel::Dwarn;
 
 extends qw/Pear::LocalLoop::Import::LCCCsv/;
 
-sub import {
-  my $self = shift;
+has '+csv_required_columns' => (
+  builder => sub { return [ qw/
+  supplier_id
+  name
+  / ]},
+);
 
-  $import = Pear::LocalLoop::Import::LCCCsv->new;
+sub import_csv {
+  my ($self) = @_;
+
+  my $rows = $self->csv_data;
+  foreach my $row ( @{$rows} ) {
+    $self->_row_to_result($row);
+  }
+  return 1;
 }
 
 sub _row_to_result {
   my ( $self, $row ) = @_;
 
+    my $addr2 = $row->{post_town};
 
+    my $address = ( defined $addr2 ? ( $row->{"address line 2"} . ' ' . $addr2) : $row->{"address line 2"} );
+
+    $self->external_result->find_or_create_related('organisations', {
+      external_id => $row->{supplier_id},
+      organisation => {
+        name => $row->{name},
+        street_name => $row->{"address line 1"},
+        town => $address,
+        postcode => $row->{post_code},
+        country => $row->{country_code},
+        entity => { type => 'organisation' },
+      }
+    });
 }
 
 1;

lib/Pear/LocalLoop/Import/Role/CSV.pm

@@ -8,13 +8,27 @@ requires 'csv_required_columns';
 
 has csv_file => (
   is       => 'ro',
-  required => 1,
+  predicate => 1,
+);
+
+has csv_string => (
+  is => 'ro',
+  predicate => 1,
 );
 
 has _csv_filehandle => (
   is      => 'lazy',
   builder => sub {
-    open my $fh, '<', $self->csv_file;
+    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;
   }
 );
@@ -40,7 +54,25 @@ has csv_data => (
   is      => 'lazy',
   builder => sub {
     my $self = shift;
+    $self->check_headers;
+    return $self->_text_csv->getline_hr_all( $self->_csv_filehandle );
   }
 );
 
-1;
+sub check_headers {
+  my $self = shift;
+  my $req_headers = $self->csv_required_columns;
+  use Devel::Dwarn;
+  Dwarn $req_headers;
+  # TODO catch the boom
+  my @headers = $self->_text_csv->header( $self->_csv_filehandle );
+  Dwarn \@headers;
+  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;

lib/Pear/LocalLoop/Import/Role/ExternalName.pm

@@ -12,8 +12,8 @@ has external_result => (
   is      => 'lazy',
   builder => sub {
     my $self = shift;
-    return $self->resultset('ExternalReference')->find_or_create({ name => $self->external_name });
+    return $self->schema->resultset('ExternalReference')->find_or_create({ name => $self->external_name });
   }
 );
 
-1;
+1;