File Coverage

blib/lib/Finance/Bank/Postbank_de.pm

Criterion	Covered	Total	%
statement	79	96	82.2
branch	12	18	66.6
condition	6	9	66.6
subroutine	22	31	70.9
pod	8	18	44.4
total	127	172	73.8

package Finance::Bank::Postbank_de;

use 5.006; # we use lexical filehandles now
use strict;
use warnings;
use Carp;
use Moo 2;

use Time::Local;
use POSIX 'strftime';

use Finance::Bank::Postbank_de::Account;
use Finance::Bank::Postbank_de::APIv1;
use Encode qw(decode);
use Mozilla::CA;

#use IO::Socket::SSL qw(SSL_VERIFY_PEER SSL_VERIFY_NONE);

our $VERSION = '0.57';

has 'login' => (
    is => 'ro',
);

has 'password' => (
    is => 'ro',
);

has 'urls' => (
    is => 'ro',
    default => sub { {} },
);

has 'logger' => (
    is => 'ro',
    default => sub { {} },
);

has 'past_days' => (
    is => 'ro',
    default => sub { {} },
);

has 'api' => (
    is => 'rw',
    default => sub {
        my $api = Finance::Bank::Postbank_de::APIv1->new();
        $api->configure_ua();
        $api
    },
);

has 'session' => (
    is => 'rw',
);

has '_account_numbers' => (
    is => 'rw',
);

our %functions;
BEGIN {
  %functions = (
    quit		=> [ text_regex => qr'\bBanking\s+beenden\b' ],
    accountstatement	=> [ text_regex => qr'\bUms.*?tze\b' ],
  );
};

around BUILDARGS => sub {
    my ($orig,$class,%args) = @_;

    croak "Login/Account number must be specified"
      unless $args{login};
    croak "Password/PIN must be specified"
      unless $args{password};
    if( exists $args{ status }) {
        $args{ logger } = delete $args{ status };
    };

    $orig->($class, %args);
};

sub log { $_[0]->logger->(@_); };
sub log_httpresult { $_[0]->log("HTTP Code",$_[0]->agent->status,$_[0]->agent->res->headers->as_string . $_[0]->agent->content) };

sub new_session {
  my ($self) = @_;

  $self->close_session()
    if ($self->session);
  my $pb;
  my $ok = eval {
    $pb = $self->api->login( $self->login, $self->password );
    1
  };
  if( ! $ok ) {
    #warn sprintf "Got HTTP error %d, message %s", $self->api->ua->status, $self->api->ua->message;
    #croak $@;
  } else {
    $self->session( $pb );
  }
};

sub is_security_advice {
  my ($self) = @_;
  #$self->agent->content() =~ /\bZum\s+Finanzstatus\b/;
};

sub is_nutzungshinweis {
  my ($self) = @_;
  #$self->agent->content() =~ /\bAus Sicherheitsgr.*?nden haben wir einige\b/;
};


sub skip_security_advice {
  my ($self) = @_;
  #$self->log('Skipping security advice page');
  #$self->agent->follow_link(text_regex => qr/\bZum\s+Finanzstatus\b/);
  # $self->agent->content() =~ /Sicherheitshinweis/;
};

sub skip_nutzungshinweis {
  my ($self) = @_;
  #$self->log('Skipping nutzungshinweis page');
  #$self->agent->follow_link(text_regex => qr/\bZur\s+Konten.bersicht\b/);
  # $self->agent->content() =~ /Sicherheitshinweis/;
};

sub error_page {
  # Check if an error page is shown
  my ($self) = @_;
  $self->api->ua->status != 200
  #return unless $self->agent;
  #
  #$self->agent->content =~ m!!sm
  #    or
  #$self->agent->content =~ m!!sm
  #    or $self->maintenance;
};

sub error_message {
  my ($self) = @_;
  #return unless $self->agent;
  #die "No error condition detected in:\n" . $self->agent->content
  #  unless $self->error_page;
  #if(
  #$self->agent->content =~ m!\s*\s*(.*?)\s*\s*!sm
  #  or
  #$self->agent->content =~ m!\s*(.*?)\s*!sm
  #  ) { return $1 }
  #  #or croak "No error message found in:\n" . $self->agent->content;
  return ''
};

sub maintenance {
  my ($self) = @_;
  #return unless $self->agent;
  ##$self->error_page and
  #$self->agent->content =~ m!Sehr geehrter Online-Banking\s+Nutzer,\s+wegen einer hohen Auslastung kommt es derzeit im Online-Banking zu\s*längeren Wartezeiten.!sm
  #or $self->agent->content =~ m! Wartung\b!
  #or $self->agent->content =~ m!\s*\s*Diese Funktion steht auf Grund einer technischen St.*?rung derzeit leider nicht zur Verf.*?gung.*?\s*!sm # Testumgebung...
  ()
};

sub access_denied {
  my ($self) = @_;
  $self->api->ua->status == 401
  #if ($self->error_page) {
  #  my $message = $self->error_message;
  #
  #  return (
  #       $message =~ m!^Die Kontonummer ist nicht für das Internet Online-Banking freigeschaltet. Bitte verwenden Sie zur Freischaltung den Link "Online-Banking freischalten"\.\s*$!sm
  #    or $message =~ m!^Sie haben zu viele Zeichen in das Feld eingegeben.\s*$!sm
  #    or $message =~ m!^Die eingegebene Postbank Girokontonummer ist zu lang. Bitte überprüfen Sie Ihre Eingabe.$!sm
  #    or $message =~ m!^Die Anmeldung ist fehlgeschlagen. Bitte vergewissern Sie sich der Richtigkeit Ihrer Eingaben und f.*?hren Sie den Anmeldevorgang erneut durch.\s*$!sm
  #  )
  #} else {
  #  return;
  #};
};

sub session_timed_out {
  my ($self) = @_;
  #$self->agent->content =~ /Die Sitzungsdaten sind ungültig, bitte führen Sie einen erneuten Login durch.\s+\(27000\)/;
  ()
};

sub select_function {
    my ($self,$function) = @_;
    if (! $self->session) {
        $self->new_session;
    };
    croak "Unknown account function '$function'"
        unless exists $functions{$function};
    my $method = $functions{ $function };

    my $res = $self->session->navigate($method);
    $res
};

sub close_session {
    my ($self) = @_;
    $self->session(undef);
    $self->api(undef);
    1
};

sub finanzstatus {
    my( $self ) = @_;
    $self->new_session unless $self->session;
    my $finanzstatus = $self->session->navigate(
        class => 'Finance::Bank::Postbank_de::APIv1::Finanzstatus',
        path => ['banking_v1' => 'financialstatus']
    );
}

sub _build_account_numbers {
  my ($self,%args) = @_;

  my $finanzstatus = $self->finanzstatus;
  (my $bp) = $finanzstatus->get_businesspartners; # always take the first...
  my %numbers;
  # this currently includes the credit card numbers ...
  for my $acc ( $bp->get_accounts() ) {
      $numbers{ $acc->iban } = $acc if (!$acc->is_depot and !$acc->is_mortgage);
  };

  return $self->_account_numbers( \%numbers );
}

sub account_numbers {
  my ($self,%args) = @_;

  my $n = $self->_account_numbers || $self->_build_account_numbers;

  sort keys %{ $n };
};

sub get_account_statement {
  my ($self,%args) = @_;

  #my $past_days = $args{past_days} || $self->{past_days};
  #if($past_days) {
  #  my ($day, $month, $year) = split/\./, $agent->current_form->value('umsatzanzeigeGiro:salesForm:umsatzFilterOptionenAufklappbarSuchfeldPanel:accordion:vonBisDatum:datumForm:bisGruppe:bisDatum');
  #  my $end_epoch = timegm(0, 0, 0, $day, $month-1, $year);
  #  my $from_date = strftime '%d.%m.%Y', localtime($end_epoch-($past_days-1)*60*60*24);
  #  $agent->current_form->value('umsatzanzeigeGiro:salesForm:umsatzFilterOptionenAufklappbarSuchfeldPanel:accordion:vonBisDatum:datumForm:vonGruppe:vonDatum' => $from_date);
  #};

  my $accounts = $self->_account_numbers || $self->_build_account_numbers;

  if( ! $args{ account_number }) {
    # Hopefully we only got one account (?!)
    ($args{ account_number }) = keys %$accounts;
  };

  my $account = $accounts->{ $args{ account_number }};

  #if (exists $args{account_number}) {
  #  $self->log("Getting account statement for $args{account_number}");
  #  # Load the account numbers if not already loaded
  #  $self->account_numbers;
  #  if(! exists $self->{account_numbers}->{$args{account_number}}) {
  #      croak "Unknown account number '$args{account_number}'";
  #  };
  #  my $index = $self->{account_numbers}->{$args{account_number}};
  #  $agent->current_form->param( 'selectForm:kontoauswahl' => $index );
  #} else {
  #  my @accounts = $agent->current_form->value('selectForm:kontoauswahl');
  #  $self->log("Getting account statement via default (@accounts)");
  #};
  my $content = $account->transactions_csv();
  if( $args{ file }) {
      open my $fh, '>', $args{ file }
          or croak "Couldn't create '$args{ file }': $!";
      binmode $fh, ':encoding(UTF-8)';
      print $fh $content;
  };
  #if ($agent->status == 200) {
    my $result = $content;
    # Result is in UTF-8
    return Finance::Bank::Postbank_de::Account->parse_statement(content => $result);
};

sub unread_messages {
    my( $self )= @_;
    $self->finanzstatus->available_messages
}

1;
__END__