diff options
| -rw-r--r-- | lib/Travel/Status/DE/EFA.pm | 83 |
1 files changed, 80 insertions, 3 deletions
diff --git a/lib/Travel/Status/DE/EFA.pm b/lib/Travel/Status/DE/EFA.pm index 56a870d..64ba297 100644 --- a/lib/Travel/Status/DE/EFA.pm +++ b/lib/Travel/Status/DE/EFA.pm @@ -16,6 +16,73 @@ use Travel::Status::DE::EFA::Stop; use LWP::UserAgent; use XML::LibXML; +sub new_p { + my ( $class, %opt ) = @_; + my $promise = $opt{promise}->new; + + my $self; + + eval { $self = $class->new( %opt, async => 1 ); }; + if ($@) { + return $promise->reject($@); + } + + $self->{promise} = $opt{promise}; + + $self->{ua}->post_p( $opt{efa_url} => form => $self->{post} )->then( + sub { + my ($tx) = @_; + if ( my $err = $tx->error ) { + $promise->reject( +"POST $opt{efa_url} returned HTTP $err->{code} $err->{message}" + ); + return; + } + my $content = $tx->res->body; + + if ( $opt{efa_encoding} ) { + $self->{xml} = encode( $opt{efa_encoding}, $content ); + } + else { + $self->{xml} = $content; + } + + if ( not $self->{xml} ) { + + # LibXML doesn't like empty documents + $promise->reject('Server returned nothing (empty result)'); + return; + } + + $self->{tree} = XML::LibXML->load_xml( + string => $self->{xml}, + ); + + if ( $self->{developer_mode} ) { + say $self->{tree}->toString(1); + } + + $self->check_for_ambiguous(); + + if ( $self->{errstr} ) { + $promise->reject( $self->{errstr} ); + return; + } + + $promise->resolve($self); + return; + } + )->catch( + sub { + my ($err) = @_; + $promise->reject($err); + return; + } + )->wait; + + return $promise; +} + sub new { my ( $class, %opt ) = @_; @@ -24,7 +91,6 @@ sub new { delete $opt{timeout}; } - my $ua = LWP::UserAgent->new(%opt); my @now = localtime( time() ); my @time = @now[ 2, 1 ]; @@ -121,9 +187,20 @@ sub new { bless( $self, $class ); - $ua->env_proxy; + if ( $opt{user_agent} ) { + $self->{ua} = $opt{user_agent}; + } + else { + my %lwp_options = %{ $opt{lwp_options} // { timeout => 10 } }; + $self->{ua} = LWP::UserAgent->new(%lwp_options); + $self->{ua}->env_proxy; + } + + if ( $opt{async} ) { + return $self; + } - my $response = $ua->post( $opt{efa_url}, $self->{post} ); + my $response = $self->{ua}->post( $opt{efa_url}, $self->{post} ); if ( $response->is_error ) { $self->{errstr} = $response->status_line; |