summaryrefslogtreecommitdiff
path: root/lib/Travel/Status
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Travel/Status')
-rw-r--r--lib/Travel/Status/DE/EFA.pm83
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;