File Coverage

blib/lib/App/Environ/Mojo/Pg.pm

Criterion	Covered	Total	%
statement	12	14	85.7
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	17	19	89.4

package App::Environ::Mojo::Pg;

our $VERSION = '0.1';

use strict;
use warnings;
use v5.10;
use utf8;

use App::Environ;
use App::Environ::Config;
use Params::Validate qw(validate_pos);
use URI;
use Mojo::Pg;

my %PG;

App::Environ::Config->register(qw(pg.yml));

sub pg {
  my $class = shift;

  my ($connector) = validate_pos( @_, 1 );

  unless ( defined $PG{$connector} ) {
    my $pg_string = $class->pg_string($connector);
    $PG{$connector} = Mojo::Pg->new($pg_string);

    my $conf = App::Environ::Config->instance->{pg}{connectors}{$connector};

    if ( $conf->{max_connections} ) {
      $PG{$connector}->max_connections( $conf->{max_connections} );
    }

    if ( $conf->{migrations} && defined $conf->{migrations}{file} ) {
      if ( defined $conf->{migrations}{name} ) {
        $PG{$connector}->migrations->name( $conf->{migrations}{name} );
      }

      $PG{$connector}->migrations->from_file( $conf->{migrations}{file} );
    }
  }

  return $PG{$connector};
}

sub pg_string {
  my $class = shift;

  my ($connector) = validate_pos( @_, 1 );

  my $conf = App::Environ::Config->instance->{pg}{connectors}{$connector};

  my $url = URI->new();

  ## Non standart schema workaround
  ## For URI objects that do not belong to one of these, you can only use the common and generic methods.
  $url->scheme('https');

  $url->userinfo("$conf->{user}:$conf->{password}");
  $url->host( $conf->{host} );
  $url->port( $conf->{port} );
  $url->path( $conf->{dbname} );
  $url->query_form( %{ $conf->{options} } );

  $url->scheme('postgresql');

  return $url->as_string;
}

1;

__END__