File Coverage

blib/lib/Cikl/AddressBuilder.pm

Criterion	Covered	Total	%
statement	22	46	47.8
branch	2	12	16.6
condition			n/a
subroutine	6	9	66.6
pod	0	3	0.0
total	30	70	42.8

package Cikl::AddressBuilder;
use strict;
use warnings;
use Carp;
use Module::Pluggable search_path => "Cikl::Models::Address", require => 1,
  sub_name => "_plugins", on_require_error => \&croak;

use namespace::autoclean;
require Exporter;
our @ISA = qw/Exporter/;
our @EXPORT_OK = qw/address_from_protoevent create_address create_addresses/;

my $type_map = _build_type_map();

sub _build_type_map {
  my $ret = {};
  foreach my $module (_plugins()) {
    unless ($module->does("Cikl::Models::AddressRole")) {
      die("$module must implement Cikl::Models::AddressRole");
    }
    my $type = $module->type();
    if (my $existing = $ret->{$type}) {
      die("Cannot associate '$module' with the type '$type'. Already registered with $existing.");
    }
    $ret->{$type} = $module;
  }
  return $ret;
}

sub create_address {
  my $type = shift;
  my $value = shift;
  my $type_class = $type_map->{$type};
  unless($type_class) {
    die("Unknown type: $type");
  }
  return $type_class->new_normalized(value => $value);
}

sub create_addresses {
  my $protoevent = shift; # hashref
  my @ret;
  foreach my $type (keys(%{$type_map})) {
    if (my $value = delete($protoevent->{$type})) {
      push(@ret, create_address($type, $value));
    }
  }
  return \@ret;
}

sub address_from_protoevent {
  my $protoevent = shift; # hashref
  my $address;
  foreach my $type (keys(%{$type_map})) {
    if (my $value = delete($protoevent->{$type})) {
      if (defined($address)) {
        die("An event can only have one address! Has: " . $address->type() . " and $type");
      }
      $address = create_address($type, $value);
    }
  }
  return $address;
}

1;